Initial revision

1 files changed, 565 insertions, 0 deletions

diff --git a/clients/zmailnotify/zmailnotify.c b/clients/zmailnotify/zmailnotify.c
new file mode 100644
index 0000000..445ab2d
--- /dev/null
+++ b/clients/zmailnotify/zmailnotify.c
@@ -0,0 +1,565 @@
+/* This file is part of the Project Athena Zephyr Notification System.
+ * It contains code for the "zwmnotify" command.
+ *
+ *	Created by:	Robert French
+ *
+ *	$Source$
+ *	$Author$
+ *
+ *	Copyright (c) 1987 by the Massachusetts Institute of Technology.
+ *	For copying and distribution information, see the file
+ *	"mit-copyright.h". 
+ */
+
+#include <zephyr/mit-copyright.h>
+
+#include <zephyr/zephyr.h>
+
+#ifndef lint
+static char rcsid_zwmnotify_c[] = "$Header$";
+#endif lint
+
+#include <zephyr/zephyr.h>
+#include <sys/uio.h>
+#include <sys/syslog.h>
+#include <sys/wait.h>
+#include <sys/socket.h>
+#include <sys/file.h>
+#include <ttyent.h>
+#include <pwd.h>
+#include <stdio.h>
+#include <sgtty.h>
+#include <signal.h>
+#include <errno.h>
+#include <netdb.h>
+#include <hesiod.h>
+
+#ifdef KPOP
+#include <krb.h>
+#endif KPOP
+
+#define NOTOK (-1)
+#define OK 0
+#define DONE 1
+
+char *progname;
+FILE *sfi;
+FILE *sfo;
+char Errmsg[80];
+#ifdef KPOP
+char *PrincipalHostname(), *index();
+#endif KPOP
+
+#define MAXMAIL 8
+
+struct _mail {
+	char *from;
+	char *to;
+	char *subj;
+} maillist[MAXMAIL];
+
+char *mailptr;
+
+/* This entire program is a kludge - beware! */
+
+main()
+{
+	FILE *lock;
+	int nmsgs;
+	char *user,response[512],lockfile[100];
+	char *host,*dir;
+	int i,nbytes,retval,uselock;
+	struct passwd *pwd;
+	struct _mail mymail;
+#ifdef HESIOD
+	struct hes_postoffice *p;
+#endif HESIOD
+
+	if ((retval = ZInitialize()) != ZERR_NONE) {
+		com_err("zwmnotify",retval,"while initializing");
+		exit(1);
+	}
+
+	dir = (char *)getenv("HOME");
+	user = (char *)getenv("USER");
+	if (!user || !dir) {
+		pwd = (struct passwd *)getpwuid(getuid());
+		if (!pwd) {
+			fprintf(stderr,"Can't figure out who you are!\n");
+			exit(1);
+		}
+		if (!user)
+			user = pwd->pw_name;
+		if (!dir)
+			dir = pwd->pw_dir;
+	}
+
+	sprintf(lockfile,"%s/.maillock",dir);
+	
+	host = (char *)getenv("MAILHOST");
+#ifdef HESIOD
+	if (host == NULL) {
+		p = hes_getmailhost(user);
+		if (p != NULL && strcmp(p->po_type, "POP") == 0)
+			host = p->po_host;
+		else {
+			fprintf(stderr,"no POP server listed in Hesiod");
+			exit(1);
+		} 
+	}
+#endif HESIOD
+	if (host == NULL) {
+		fprintf(stderr,"no MAILHOST defined");
+		exit(1);
+	}
+
+	lock = fopen(lockfile,"r");
+	if (lock)
+		flock(fileno(lock),LOCK_EX);
+	
+	if (pop_init(host) == NOTOK) {
+		fprintf(stderr,Errmsg);
+		exit(1);
+	}
+
+	if ((getline(response, sizeof response, sfi) != OK) ||
+	    (*response != '+')) {
+		fprintf(stderr,"%s",response);
+		exit(1);
+	}
+
+#ifdef KPOP
+	if (pop_command("USER %s", user) == NOTOK || 
+	    pop_command("PASS %s", user) == NOTOK) {
+#else !KPOP
+	if (pop_command("USER %s", user) == NOTOK || 
+	    pop_command("RPOP %s", user) == NOTOK) {
+#endif KPOP
+		fprintf(stderr,Errmsg);
+		pop_command("QUIT");
+		pop_close();
+		exit (1);
+	} 
+
+	if (pop_stat(&nmsgs, &nbytes) == NOTOK) {
+		fprintf(stderr,Errmsg);
+		pop_command("QUIT");
+		pop_close();
+		exit (1);
+	}
+
+	if (!nmsgs) {
+		if (lock) {
+			flock(fileno(lock),LOCK_UN);
+			fclose(lock);
+		} 
+		unlink(lockfile);
+		pop_command("QUIT");
+		pop_close();
+		exit (0);
+	}
+
+	uselock = 0;
+        if (lock) {
+		uselock = 1;
+		mymail.to = (char *)malloc(BUFSIZ);
+		mymail.from = (char *)malloc(BUFSIZ);
+		mymail.subj = (char *)malloc(BUFSIZ);
+		fgets(mymail.from,BUFSIZ,lock);
+		fgets(mymail.to,BUFSIZ,lock);
+		fgets(mymail.subj,BUFSIZ,lock);
+		mymail.from[strlen(mymail.from)-1] = 0;
+		mymail.to[strlen(mymail.to)-1] = 0;
+		mymail.subj[strlen(mymail.subj)-1] = 0;
+	}
+	else {
+		lock = fopen(lockfile,"w");
+		if (lock)
+			flock(fileno(lock),LOCK_EX);
+		uselock = 0;
+	}
+	
+	for (i=nmsgs;i>0;i--) {
+		if (nmsgs-i == MAXMAIL)
+			break;
+		if (get_mail(i,&maillist[nmsgs-i]))
+			exit (1);
+		if (uselock && (!strcmp(maillist[nmsgs-i].to,mymail.to) &&
+				!strcmp(maillist[nmsgs-i].from,mymail.from) &&
+				!strcmp(maillist[nmsgs-i].subj,mymail.subj)))
+			break;
+	}
+	i++;
+	for (;i<=nmsgs;i++)
+		mail_notify(&maillist[nmsgs-i]);
+	i--;
+	if (lock) {
+		flock(fileno(lock),LOCK_UN);
+		fclose(lock);
+	} 
+	lock = fopen(lockfile,"w");
+	if (!lock)
+		exit (1);
+	fprintf(lock,"%s\n%s\n%s\n",
+		maillist[nmsgs-i].from,
+		maillist[nmsgs-i].to,
+		maillist[nmsgs-i].subj);
+	fclose(lock);
+
+	pop_command("QUIT");
+	pop_close();
+}
+
+get_message(i)
+	int i;
+{
+	int mbx_write();
+
+	if (pop_retr(i, mbx_write, 0) != OK) {
+		fprintf(stderr,Errmsg);
+		pop_command("QUIT");
+		pop_close();
+		exit(1);
+	}
+}
+
+/* Pop stuff */
+
+pop_close()
+{
+	if (sfi)
+		fclose(sfi);
+	if (sfo)
+		fclose(sfo);
+}
+
+get_mail(i,mail)
+	int i;
+	struct _mail *mail;
+{
+	char from[512],to[512],subj[512];
+	char *c,*ptr,*ptr2;
+	
+	*from = 0;
+	*to = 0;
+	*subj = 0;
+
+	if (mailptr)
+		free(mailptr);
+
+	mailptr = 0;
+	
+	get_message(i);
+
+	ptr = mailptr;
+	while (ptr) {
+		ptr2 = (char *)index(ptr,'\n');
+		if (ptr2)
+			*ptr2++ = 0;
+		if (*ptr == '\0')
+			break;
+		if (!strncmp(ptr, "From: ", 6))
+			strcpy(from, ptr+6);
+		else if (!strncmp(ptr, "To: ", 4))
+			strcpy(to, ptr+4);
+		else if (!strncmp(ptr, "Subject: ", 9))
+			strcpy(subj, ptr+9);
+		ptr = ptr2;
+	}
+
+	/* add elipsis at end of "To:" field if it continues onto */
+	/* more than one line */
+	i = strlen(to) - 2;
+	c = to+i;
+	if (*c++ == ',') {
+		*c++ = ' ';
+		*c++ = '.';
+		*c++ = '.';
+		*c++ = '.';
+		*c++ = '\n';
+		*c = 0;
+	}
+
+	mail->from = (char *)malloc(strlen(from)+1);
+	strcpy(mail->from,from);
+	mail->to = (char *)malloc(strlen(to)+1);
+	strcpy(mail->to,to);
+	mail->subj = (char *)malloc(strlen(subj)+1);
+	strcpy(mail->subj,subj);
+
+	return (0);
+}
+
+mail_notify(mail)
+	struct _mail *mail;
+{
+	int retval;
+	char *fields[3];
+	ZNotice_t notice;
+
+	notice.z_kind = UNACKED;
+	notice.z_port = 0;
+	notice.z_class = "MAIL";
+	notice.z_class_inst = "POPRET";
+	notice.z_opcode = "NEW_MAIL";
+	notice.z_sender = 0;
+	notice.z_recipient = ZGetSender();
+	notice.z_default_format = "You have new mail:\n\nFrom: $1\nTo: $1\nSubject: $3";
+
+	fields[0] = mail->from;
+	fields[1] = mail->to;
+	fields[2] = mail->subj;
+      
+	if ((retval = ZSendList(&notice,fields,3,ZNOAUTH)) != ZERR_NONE)
+		com_err("zwmnotify",retval,"while sending notice");
+}
+
+/*
+ * These are the necessary KPOP routines snarfed from
+ * the GNU movemail program.
+ */
+
+pop_init(host)
+char *host;
+{
+    register struct hostent *hp;
+    register struct servent *sp;
+    int lport = IPPORT_RESERVED - 1;
+    struct sockaddr_in sin;
+    register int s;
+#ifdef KPOP
+    KTEXT ticket = (KTEXT)NULL;
+    int rem;
+#endif KPOP
+    char *get_errmsg();
+
+    hp = gethostbyname(host);
+    if (hp == NULL) {
+	sprintf(Errmsg, "MAILHOST unknown: %s", host);
+	return(NOTOK);
+    }
+
+#ifdef KPOP
+    sp = getservbyname("knetd", "tcp");
+    if (sp == 0) {
+	strcpy(Errmsg, "tcp/knetd: unknown service");
+	return(NOTOK);
+    }
+#else !KPOP
+    sp = getservbyname("pop", "tcp");
+    if (sp == 0) {
+	strcpy(Errmsg, "tcp/pop: unknown service");
+	return(NOTOK);
+    }
+#endif KPOP
+
+    sin.sin_family = hp->h_addrtype;
+    bcopy(hp->h_addr, (char *)&sin.sin_addr, hp->h_length);
+    sin.sin_port = sp->s_port;
+#ifdef KPOP
+    s = socket(AF_INET, SOCK_STREAM, 0);
+#else !KPOP
+    s = rresvport(&lport);
+#endif KPOP
+    if (s < 0) {
+	sprintf(Errmsg, "error creating socket: %s", get_errmsg());
+	return(NOTOK);
+    }
+
+    if (connect(s, (char *)&sin, sizeof sin) < 0) {
+	sprintf(Errmsg, "error during connect: %s", get_errmsg());
+	close(s);
+	return(NOTOK);
+    }
+#ifdef KPOP
+    ticket = (KTEXT)malloc( sizeof(KTEXT_ST) );
+    rem=KSUCCESS;
+    rem = SendKerberosData(s, ticket, "pop", hp->h_name);
+    if (rem != KSUCCESS) {
+	sprintf(Errmsg, "kerberos error: %s",krb_err_txt[rem]);
+	close(s);
+	return(NOTOK);
+    }
+#endif KPOP
+
+    sfi = fdopen(s, "r");
+    sfo = fdopen(s, "w");
+    if (sfi == NULL || sfo == NULL) {
+	sprintf(Errmsg, "error in fdopen: %s", get_errmsg());
+	close(s);
+	return(NOTOK);
+    }
+
+    return(OK);
+}
+
+pop_command(fmt, a, b, c, d)
+char *fmt;
+{
+    char buf[4096];
+    char errmsg[64];
+
+    sprintf(buf, fmt, a, b, c, d);
+
+    if (putline(buf, Errmsg, sfo) == NOTOK) return(NOTOK);
+
+    if (getline(buf, sizeof buf, sfi) != OK) {
+	strcpy(Errmsg, buf);
+	return(NOTOK);
+    }
+
+    if (*buf != '+') {
+	strcpy(Errmsg, buf);
+	return(NOTOK);
+    } else {
+	return(OK);
+    }
+}
+
+    
+pop_stat(nmsgs, nbytes)
+int *nmsgs, *nbytes;
+{
+    char buf[4096];
+
+    if (putline("STAT", Errmsg, sfo) == NOTOK) return(NOTOK);
+
+    if (getline(buf, sizeof buf, sfi) != OK) {
+	strcpy(Errmsg, buf);
+	return(NOTOK);
+    }
+
+    if (*buf != '+') {
+	strcpy(Errmsg, buf);
+	return(NOTOK);
+    } else {
+	sscanf(buf, "+OK %d %d", nmsgs, nbytes);
+	return(OK);
+    }
+}
+
+pop_retr(msgno, action, arg)
+int (*action)();
+{
+    char buf[4096];
+
+    sprintf(buf, "RETR %d", msgno);
+    if (putline(buf, Errmsg, sfo) == NOTOK) return(NOTOK);
+
+    if (getline(buf, sizeof buf, sfi) != OK) {
+	strcpy(Errmsg, buf);
+	return(NOTOK);
+    }
+
+    while (1) {
+	switch (multiline(buf, sizeof buf, sfi)) {
+	case OK:
+	    (*action)(buf, arg);
+	    break;
+	case DONE:
+	    return (OK);
+	case NOTOK:
+	    strcpy(Errmsg, buf);
+	    return (NOTOK);
+	}
+    }
+}
+
+getline(buf, n, f)
+char *buf;
+register int n;
+FILE *f;
+{
+    register char *p;
+    int c;
+
+    p = buf;
+    while (--n > 0 && (c = fgetc(f)) != EOF)
+      if ((*p++ = c) == '\n') break;
+
+    if (ferror(f)) {
+	strcpy(buf, "error on connection");
+	return (NOTOK);
+    }
+
+    if (c == EOF && p == buf) {
+	strcpy(buf, "connection closed by foreign host");
+	return (DONE);
+    }
+
+    *p = NULL;
+    if (*--p == '\n') *p = NULL;
+    if (*--p == '\r') *p = NULL;
+    return(OK);
+}
+
+multiline(buf, n, f)
+char *buf;
+register int n;
+FILE *f;
+{
+    if (getline(buf, n, f) != OK) return (NOTOK);
+    if (*buf == '.') {
+	if (*(buf+1) == NULL) {
+	    return (DONE);
+	} else {
+	    strcpy(buf, buf+1);
+	}
+    }
+    return(OK);
+}
+
+char *
+get_errmsg()
+{
+    extern int errno, sys_nerr;
+    extern char *sys_errlist[];
+    char *s;
+
+    if (errno < sys_nerr)
+      s = sys_errlist[errno];
+    else
+      s = "unknown error";
+    return(s);
+}
+
+putline(buf, err, f)
+char *buf;
+char *err;
+FILE *f;
+{
+    fprintf(f, "%s\r\n", buf);
+    fflush(f);
+    if (ferror(f)) {
+	strcpy(err, "lost connection");
+	return(NOTOK);
+    }
+    return(OK);
+}
+
+mbx_write(line, foo)
+char *line;
+int foo;
+{
+	if (mailptr) {
+		mailptr = (char *)realloc(mailptr,strlen(mailptr)+strlen(line)+2);
+		strcat(mailptr,line);
+	} 
+	else {
+		mailptr = (char *)malloc(strlen(line)+2);
+		strcpy(mailptr,line);
+	}
+	strcat(mailptr,"\n");
+}
+
+mbx_delimit_begin(mbf)
+FILE *mbf;
+{
+    fputs("\f\n0,unseen,,\n", mbf);
+}
+
+mbx_delimit_end(mbf)
+FILE *mbf;
+{
+    putc('\037', mbf);
+}