Subversion Repositories planix.SVN

#include "common.h"
#include "dat.h"

Biobuf in;

Addr *al;
int na;
String *from;
String *sender;

void printmsg(int fd, String *msg, char *replyto, char *listname);
void appendtoarchive(char* listname, String *firstline, String *msg);
void printsubject(int fd, Field *f, char *listname);

void
usage(void)
{
        fprint(2, "usage: %s address-list-file listname\n", argv0);
        exits("usage");
}

void
main(int argc, char **argv)
{
        String *msg;
        String *firstline;
        char *listname, *alfile;
        Waitmsg *w;
        int fd;
        char *replytoname = nil;

        ARGBEGIN{
        case 'r':
                replytoname = ARGF();
                break;
        }ARGEND;

        rfork(RFENVG|RFREND);

        if(argc < 2)
                usage();
        alfile = argv[0];
        listname = argv[1];
        if(replytoname == nil)
                replytoname = listname;

        readaddrs(alfile);

        if(Binit(&in, 0, OREAD) < 0)
                sysfatal("opening input: %r");

        msg = s_new();
        firstline = s_new();

        /* discard the 'From ' line */
        if(s_read_line(&in, firstline) == nil)
                sysfatal("reading input: %r");

        /* read up to the first 128k of the message.  more is ridiculous. 
             Not if word documents are distributed.  Upped it to 2MB (pb) */
        if(s_read(&in, msg, 2*1024*1024) <= 0)
                sysfatal("reading input: %r");

        /* parse the header */
        yyinit(s_to_c(msg), s_len(msg));
        yyparse();

        /* get the sender */
        getaddrs();
        if(from == nil)
                from = sender;
        if(from == nil)
                sysfatal("message must contain From: or Sender:");
        if(strcmp(listname, s_to_c(from)) == 0)
                sysfatal("can't remail messages from myself");
        addaddr(s_to_c(from));

        /* start the mailer up and return a pipe to it */
        fd = startmailer(listname);

        /* send message adding our own reply-to and precedence */
        printmsg(fd, msg, replytoname, listname);
        close(fd);

        /* wait for mailer to end */
        while(w = wait()){
                if(w->msg != nil && w->msg[0])
                        sysfatal("%s", w->msg);
                free(w);
        }

        /* if the mailbox exists, cat the mail to the end of it */
        appendtoarchive(listname, firstline, msg);
        exits(0);
}

/* send message filtering Reply-to out of messages */
void
printmsg(int fd, String *msg, char *replyto, char *listname)
{
        Field *f, *subject;
        Node *p;
        char *cp, *ocp;

        subject = nil;
        cp = s_to_c(msg);
        for(f = firstfield; f; f = f->next){
                ocp = cp;
                for(p = f->node; p; p = p->next)
                        cp = p->end+1;
                if(f->node->c == REPLY_TO)
                        continue;
                if(f->node->c == PRECEDENCE)
                        continue;
                if(f->node->c == SUBJECT){
                        subject = f;
                        continue;
                }
                write(fd, ocp, cp-ocp);
        }
        printsubject(fd, subject, listname);
        fprint(fd, "Reply-To: %s\nPrecedence: bulk\n", replyto);
        write(fd, cp, s_len(msg) - (cp - s_to_c(msg)));
}

/* if the mailbox exists, cat the mail to the end of it */
void
appendtoarchive(char* listname, String *firstline, String *msg)
{
        String *mbox;
        int fd;

        mbox = s_new();
        mboxpath("mbox", listname, mbox, 0);
        if(access(s_to_c(mbox), 0) < 0)
                return;
        fd = open(s_to_c(mbox), OWRITE);
        if(fd < 0)
                return;
        s_append(msg, "\n");
        write(fd, s_to_c(firstline), s_len(firstline));
        write(fd, s_to_c(msg), s_len(msg));
}

/* add the listname to the subject */
void
printsubject(int fd, Field *f, char *listname)
{
        char *s, *e;
        Node *p;
        char *ln;

        if(f == nil || f->node == nil){
                fprint(fd, "Subject: [%s]\n", listname);
                return;
        }
        s = e = f->node->end + 1;
        for(p = f->node; p; p = p->next)
                e = p->end;
        *e = 0;
        ln = smprint("[%s]", listname);
        if(ln != nil && strstr(s, ln) == nil)
                fprint(fd, "Subject: %s%s\n", ln, s);
        else
                fprint(fd, "Subject:%s\n", s);
        free(ln);
}