Subversion Repositories planix.SVN

#include "common.h"

#include "dat.h"

String*

getaddr(Node *p)

{

	for(; p; p = p->next){

		if(p->s && p->addr)

			return p->s;

	}

	return nil;

}

/* send message adding our own reply-to and precedence */

void

getaddrs(void)

{

	Field *f;

	for(f = firstfield; f; f = f->next){

		if(f->node->c == FROM && from == nil)

			from = getaddr(f->node);

		if(f->node->c == SENDER && sender == nil)

			sender = getaddr(f->node);

	}

}

/* write address file, should be append only */

void

writeaddr(char *file, char *addr, int rem, char *listname)

{

	int fd;

	Dir nd;

	fd = open(file, OWRITE);

	if(fd < 0){

		fd = create(file, OWRITE, DMAPPEND|0666);

		if(fd < 0)

			sysfatal("creating address list %s: %r", file);

		nulldir(&nd);

		nd.mode = DMAPPEND|0666;

		dirwstat(file, &nd);

	} else

		seek(fd, 0, 2);

	if(rem)

		fprint(fd, "!%s\n", addr);

	else

		fprint(fd, "%s\n", addr);

	close(fd);

	if(*addr != '#')

		sendnotification(addr, listname, rem);

}

void

remaddr(char *addr)

{

	Addr **l;

	Addr *a;

	for(l = &al; *l; l = &(*l)->next){

		a = *l;

		if(strcmp(addr, a->addr) == 0){

			(*l) = a->next;

			free(a);

			na--;

			break;

		}

	}

}

int

addaddr(char *addr)

{

	Addr **l;

	Addr *a;

	for(l = &al; *l; l = &(*l)->next){

		if(strcmp(addr, (*l)->addr) == 0)

			return 0;

	}

	na++;

	*l = a = malloc(sizeof(*a)+strlen(addr)+1);

	if(a == nil)

		sysfatal("allocating: %r");

	a->addr = (char*)&a[1];

	strcpy(a->addr, addr);

	a->next = nil;

	*l = a;

	return 1;

}

/* read address file */

void

readaddrs(char *file)

{

	Biobuf *b;

	char *p;

	b = Bopen(file, OREAD);

	if(b == nil)

		return;

	while((p = Brdline(b, '\n')) != nil){

		p[Blinelen(b)-1] = 0;

		if(*p == '#')

			continue;

		if(*p == '!')

			remaddr(p+1);

		else

			addaddr(p);

	}

	Bterm(b);

}

/* start a mailer sending to all the receivers for list `name' */

int

startmailer(char *name)

{

	int pfd[2];

	char **av;

	int ac;

	Addr *a;

	/*

	 * we used to send mail to the list from /dev/null,

	 * which is equivalent to an smtp return address of <>,

	 * but such a return address should only be used when

	 * sending a bounce to a single address.  our smtpd lets

	 * such mail through, but refuses mail from <> to multiple

	 * addresses, since that's not allowed and is likely spam.

	 * thus mailing list mail to another upas system with

	 * multiple addressees was being rejected.

	 */

	putenv("upasname", smprint("%s-owner", name));

	if(pipe(pfd) < 0)

		sysfatal("creating pipe: %r");

	switch(fork()){

	case -1:

		sysfatal("starting mailer: %r");

	case 0:

		close(pfd[1]);

		break;

	default:

		close(pfd[0]);

		return pfd[1];

	}

	dup(pfd[0], 0);

	close(pfd[0]);

	av = malloc(sizeof(char*)*(na+2));

	if(av == nil)

		sysfatal("starting mailer: %r");

	ac = 0;

	av[ac++] = name;

	for(a = al; a != nil; a = a->next)

		av[ac++] = a->addr;

	av[ac] = 0;

	exec("/bin/upas/send", av);

	sysfatal("execing mailer: %r");

	/* not reached */

	return -1;

}

void

sendnotification(char *addr, char *listname, int rem)

{

	int pfd[2];

	Waitmsg *w;

	putenv("upasname", smprint("%s-owner", listname));

	if(pipe(pfd) < 0)

		sysfatal("creating pipe: %r");

	switch(fork()){

	case -1:

		sysfatal("starting mailer: %r");

	case 0:

		close(pfd[1]);

		dup(pfd[0], 0);

		close(pfd[0]);

		execl("/bin/upas/send", "mlnotify", addr, nil);

		sysfatal("execing mailer: %r");

		break;

	default:

		close(pfd[0]);

		fprint(pfd[1], "From: %s-owner\n\n", listname);

		if(rem)

			fprint(pfd[1], "You have been removed from the %s mailing list\n", listname);

		else{

			fprint(pfd[1], "You have been added to the %s mailing list\n", listname);

			fprint(pfd[1], "To be removed, send an email to %s-owner containing\n",

				listname);

			fprint(pfd[1], "the word 'remove' in the subject or body.\n");

		}

		close(pfd[1]);

		/* wait for mailer to end */

		while(w = wait()){

			if(w->msg != nil && w->msg[0])

				sysfatal("%s", w->msg);

			free(w);

		}

		break;

	}

}