projects / unix-history / blob
? search:
summary | tags | clone url | shortlog | log | commit | commitdiff | tree
blame | history | raw | HEAD
BSD 4_2 release
[unix-history] / usr / src / new / new / mh / cmds / refile.c
#ifndef lint
static char sccsid[] = "@(#)refile.c 1.1 5/26/83";
#endif
#include "mh.h"
#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <errno.h>
#include <strings.h>
#define NFOLD 20 /* Allow 20 folder specs */
/* file [-src folder] [msgs] +folder [+folder ...]
*
* moves messages from src folder (or current) to other one(s).
*
* all = 1-999 for a message sequence
* -preserve says preserve msg numbers
* -link says don't delete old msg
*/
char *anoyes[]; /* Std no/yes gans array */
int vecp, foldp, prsrvf;
char **vec, maildir[128], *folder, *file;
struct msgs *mp;
struct st_fold {
char *f_name;
struct msgs *f_mp;
} folders[NFOLD];
char *files[NFOLD + 1]; /* Vec of files to process--starts at 1! */
int filec = 1;
char *bellfile = "/usr/bin/file";
extern int errno;
char *rindex();
struct swit switches[] = {
"all", -3, /* 0 */
"link", 0, /* 1 */
"nolink", 0, /* 2 */
"preserve", 0, /* 3 */
"nopreserve", 0, /* 4 */
"src +folder", 0, /* 5 */
"file", 0, /* 6 */
"help", 4, /* 7 */
0, 0
};
main(argc, argv)
char *argv[];
{
register int i, msgnum;
register char *cp;
char *msgs[128];
int msgp, linkf;
int ismhfile = 0;
char **ap;
char *arguments[50], **argp;
char *pwd(), *pwds;
/*
* Rand has committed the sin of picking a name that already is
* used (file). We fix this here since we can tell the difference
* between the two (mh file has -'s and +'s always, bell file never
* has them.)
*/
for (i=1; i<argc; i++)
if (argv[i][0] == '-' || argv[i][0]=='+')
ismhfile++;
if (!ismhfile) {
execv(bellfile, argv);
fprintf(stderr, "Cannot find %s\n", bellfile);
exit(1);
}
#ifdef NEWS
m_news();
#endif
folder = 0; msgp = 0; linkf = 0;
cp = r1bindex(argv[0], '/');
if((cp = m_find(cp)) != NULL) {
ap = brkstring(cp = getcpy(cp), " ", "\n");
ap = copyip(ap, arguments);
} else
ap = arguments;
copyip(argv+1, ap);
argp = arguments;
while(cp = *argp++) {
if(*cp == '-') {
switch(smatch(++cp, switches)) {
case -2:ambigsw(cp, switches); /* ambiguous */
goto leave;
/* unknown */
case -1:fprintf(stderr, "file: -%s unknown\n", cp);
goto leave;
/* -all */
case 0: fprintf(stderr, "\"-all\" changed to \"all\"\n");
goto leave;
case 1: linkf = 1; continue; /* -link */
case 2: linkf = 0; continue; /* -nolink */
case 3: prsrvf = 1; continue; /* -preserve */
case 4: prsrvf = 0; continue; /* -nopreserve */
case 5: if(folder) { /* -src */
fprintf(stderr, "Only one src folder.\n");
goto leave;
}
if(!(folder = *argp++) || *folder == '-') {
missing: fprintf(stderr, "file: Missing argument for %s switch\n", argp[-2]);
goto leave;
}
if(*folder == '+')
folder++;
continue;
/* -help */
case 6:
if(filec >= NFOLD) {
fprintf(stderr, "Too many src files.\n");
goto leave;
}
if(!(files[filec++] = *argp) || **argp++ == '-')
goto missing;
continue;
case 7: help("file [msgs] [switches] +folder ...",
switches);
goto leave;
}
}
if(*cp == '+') {
if(foldp < NFOLD)
folders[foldp++].f_name = cp + 1;
else {
fprintf(stderr, "Only %d folders allowed.\n", NFOLD);
goto leave;
}
} else
msgs[msgp++] = cp;
}
if(!foldp) {
fprintf(stderr, "No folder specified.\n");
fprintf(stderr, "Usage: file [-src folder] [msg ...] [switches] +folder [+folder]\n");
goto leave;
}
if(filec > 1) {
if(msgp) {
fprintf(stderr, "File: Can't mix files and messages.\n");
goto leave;
}
for(i = 1; i < filec; i++)
if(*files[i] != '/') {
if(!pwds)
pwds = pwd();
files[i] = concat(pwds, "/", files[i], 0);
}
if(opnfolds())
goto leave;
for(i = 1; i < filec; i++) {
if(process(files[i]))
goto leave;
}
if(!linkf) {
if((cp = m_find("delete-prog")) != NULL) {
files[0] = cp;
execvp(cp, files);
fprintf(stderr, "Can't exec deletion-prog--");
perror(cp);
} else for(i = 1; i < filec; i++) {
if(unlink(files[i]) == -1) {
fprintf(stderr, "Can't unlink ");
perror(files[i]);
}
}
}
goto leave;
}
if(!msgp)
msgs[msgp++] = "cur";
if(!folder)
folder = m_getfolder();
copy(m_maildir(folder), maildir);
if(chdir(maildir) < 0) {
fprintf(stderr, "Can't chdir to: ");
perror(maildir);
goto leave;
}
if(!(mp = m_gmsg(folder))) {
fprintf(stderr, "Can't read folder %s!?\n",folder);
goto leave;
}
if(mp->hghmsg == 0) {
fprintf(stderr, "No messages in \"%s\".\n", folder);
goto leave;
}
for(msgnum = 0; msgnum < msgp; msgnum++)
if(!m_convert((cp = msgs[msgnum])))
goto leave;
if(mp->numsel == 0) {
fprintf(stderr, "file: ham 'n cheese\n"); /* never get here */
goto leave;
}
m_replace(pfolder, folder);
if(mp->hghsel != mp->curmsg && ((mp->numsel != mp->nummsg) || linkf))
m_setcur(mp->hghsel);
if(opnfolds())
goto leave;
for(msgnum = mp->lowsel; msgnum <= mp->hghsel; msgnum++)
if(mp->msgstats[msgnum] & SELECTED)
if(process(cp = getcpy(m_name(msgnum))))
goto leave;
else
cndfree(cp);
if(!linkf) {
if((cp = m_find("delete-prog")) != NULL) {
if(mp->numsel > MAXARGS-2) {
fprintf(stderr, "file: more than %d messages for deletion-prog\n",MAXARGS-2);
printf("[messages not unlinked]\n");
goto leave;
}
vecp = 1;
vec = (char **) calloc(MAXARGS + 2, sizeof *vec);
for(msgnum= mp->lowsel; msgnum<= mp->hghsel; msgnum++)
if(mp->msgstats[msgnum]&SELECTED)
vec[vecp++] = getcpy(m_name(msgnum));
vec[vecp] = 0;
m_update();
fflush(stdout);
vec[0] = cp;
execv(vec[0], vec);
fprintf(stderr, "Can't exec deletion-prog--");
perror(cp);
} else {
for(msgnum = mp->lowsel; msgnum <= mp->hghsel; msgnum++)
if(mp->msgstats[msgnum] & SELECTED)
if(unlink(cp = m_name(msgnum))== -1) {
fprintf(stderr, "Can't unlink %s:",folder);
perror(cp);
}
}
}
leave:
m_update();
done(0);
}
opnfolds()
{
register int i;
register char *cp;
char nmaildir[128];
for(i = 0; i < foldp; i++) {
copy(m_maildir(folders[i].f_name), nmaildir);
if(access(nmaildir, 5) < 0) {
cp = concat("Create folder \"", nmaildir, "\"? ", 0);
if(!gans(cp, anoyes))
goto bad;
free(cp);
if(!makedir(nmaildir)) {
fprintf(stderr, "Can't create folder.\n");
goto bad;
}
}
if(chdir(nmaildir) < 0) {
fprintf(stderr, "Can't chdir to: ");
perror(nmaildir);
goto bad;
}
if(!(folders[i].f_mp = m_gmsg())) {
fprintf(stderr, "Can't read folder %s\n", folders[i].f_name);
goto bad;
}
}
chdir(maildir); /* return to src folder */
return(0);
bad:
return(1);
}
process(msg)
char *msg;
{
char newmsg[256], buf[BUFSIZ];
register int i;
register char *nmsg;
register struct st_fold *fp;
struct stat stbuf, stbf1;
int n, o, linkerr;
for(fp = folders; fp < &folders[foldp]; fp++) {
if(prsrvf)
nmsg = msg;
else
nmsg = m_name(fp->f_mp->hghmsg++ + 1);
copy(nmsg, copy("/", copy(m_maildir(fp->f_name), newmsg)));
if(link(msg, newmsg) < 0) {
linkerr = errno;
if(linkerr == EEXIST ||
(linkerr == EXDEV && stat(newmsg, &stbuf) != -1)) {
if(linkerr != EEXIST || stat(msg, &stbf1) < 0 ||
stat(newmsg, &stbuf) < 0 ||
stbf1.st_ino != stbuf.st_ino) {
fprintf(stderr, "Message %s:%s already exists.\n",
fp->f_name, msg);
return(1);
}
continue;
}
if(linkerr == EXDEV) {
if((o = open(msg, 0)) == -1) {
fprintf(stderr, "Can't open %s:%s.\n",
folder, msg);
return(1);
}
fstat(o, &stbuf);
if((n = creat(newmsg, stbuf.st_mode&0777)) == -1) {
fprintf(stderr, "Can't create %s:%s.\n",
fp->f_name, nmsg);
close(o);
return(1);
}
do
if((i=read(o, buf, sizeof buf)) < 0 ||
write(n, buf, i) == -1) {
fprintf(stderr, "Copy error on %s:%s to %s:%s!\n",
folder, msg, fp->f_name, nmsg);
close(o); close(n);
return(1);
}
while(i == sizeof buf);
close(n); close(o);
} else {
fprintf(stderr, "Error on link %s:%s to %s:",
folder, msg, fp->f_name);
perror(nmsg);
return(1);
}
}
cont: ;
}
return(0);
}
char *
pwd()
{
register FILE *pp;
static char curpath[128];
register int i;
FILE *popen();
if((pp = popen("pwd", "r")) == NULL ||
fgets(curpath, sizeof curpath, pp) == NULL ||
pclose(pp) != 0) {
fprintf(stderr, "Can't find current directory!\n");
done(1);
}
*rindex(curpath, '\n') = 0; /* Zap the lf */
return curpath;
}
Continuous source code history from original PDP-7 UNIX to FreeBSD 2, the first fully unencumbered FreeBSD release.