--- /dev/null
+/* This file is part of the Project Athena Zephyr Notification System.
+ * It contains code for the "zmailnotify" command.
+ *
+ * Created by: Robert French
+ *
+ * $OrigSource: /mit/zephyr/src/clients/zmailnotify/RCS/zmailnotify.c,v $
+ * $OrigAuthor: jtkohl $
+ *
+ * Copyright (c) 1987,1988 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[] = "$OrigHeader: zmailnotify.c,v 1.8 88/11/14 11:50:30 jtkohl Exp $";
+#endif /* lint */
+
+#include <stdlib.h>
+#include <sys/uio.h>
+#include <sys/wait.h>
+#include <sys/socket.h>
+#include <sys/file.h>
+#ifdef HAS_UNISTD_H
+#include <unistd.h>
+#endif
+#include <pwd.h>
+#include <stdio.h>
+#include <sgtty.h>
+#include <signal.h>
+#include <errno.h>
+#include <netdb.h>
+#ifdef HESIOD
+#include <hesiod.h>
+#endif
+#ifdef NIS
+#include <rpcsvc/ypclnt.h>
+#endif
+#include <string.h>
+
+#ifdef KERBEROS
+#ifndef KPOP_SNAME
+#define KPOP_SNAME "pop"
+#endif
+#ifndef KPOP_SERVICE
+#define KPOP_SERVICE "kpop"
+#endif
+#ifdef KRB5
+/* these need to be here to declare the functions which are used by
+ non-kerberos specific code */
+#include <krb5/krb5.h>
+#include <krb5/ext-proto.h>
+#else
+#include <krb.h>
+#endif
+#endif
+
+#define NOTOK (-1)
+#define OK 0
+#define DONE 1
+
+FILE *sfi;
+FILE *sfo;
+char Errmsg[80];
+#ifdef KERBEROS
+char *PrincipalHostname(), *index();
+#endif /* KERBEROS */
+
+extern uid_t getuid();
+char *getenv();
+void get_message(), pop_close(), mail_notify();
+#define MAXMAIL 4
+
+struct _mail {
+ char *from;
+ char *to;
+ char *subj;
+} maillist[MAXMAIL];
+
+char *mailptr = NULL;
+
+/* 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 */
+#ifdef NIS
+ char *domainname;
+ int yperr, len;
+#endif /* NIS */
+ char *host_list;
+
+ if ((retval = ZInitialize()) != ZERR_NONE) {
+ com_err("zmailnotify",retval,"while initializing");
+ exit(1);
+ }
+
+ dir = getenv("HOME");
+ user = getenv("USER");
+ if (!user || !dir) {
+ pwd = (struct passwd *)getpwuid((int) 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;
+ }
+
+ (void) sprintf(lockfile,"%s/.maillock",dir);
+
+ host = 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 */
+#ifdef NIS
+ /* Get pop-hosts for user from NIS map */
+ if (yp_get_default_domain(&domainname) == 0) {
+ if (yp_bind(domainname) == 0) {
+ yperr = yp_match(domainname, "pop-hosts", user, strlen(user), &host_list, &len);
+ if (yperr == YPERR_KEY) {
+ yperr = yp_match(domainname, "pop-hosts", "*", 1, &host_list, &len);
+ }
+ if (yperr) {
+ fprintf(stderr, "Cannot find pop host for %s : %s\n", user, yperr_string(yperr));
+ }
+ else {
+ host_list[len] = '\0';
+ host = host_list;
+ }
+ }
+ }
+#endif /* NIS */
+ if (host == NULL) {
+ fprintf(stderr,"no MAILHOST defined");
+ exit(1);
+ }
+
+ lock = fopen(lockfile,"r");
+ if (lock)
+#if SYS5_FILE_LOCKS
+ (void) lockf(fileno(lock),F_LOCK, 0);
+#else
+ (void) flock(fileno(lock),LOCK_EX);
+#endif
+
+ host_list = host;
+ while (host = strtok(host_list, " \t,:")) {
+ host_list = NULL;
+ if (pop_init(host) == OK) {
+ break;
+ }
+ }
+ if (!host) {
+ fprintf(stderr,Errmsg);
+ exit(1);
+ }
+
+ if ((getline(response, sizeof response, sfi) != OK) ||
+ (*response != '+')) {
+ fprintf(stderr,"%s",response);
+ exit(1);
+ }
+
+#ifdef KERBEROS
+ if (pop_command("USER %s", user) == NOTOK ||
+ pop_command("PASS %s", user) == NOTOK) {
+#else /* !KERBEROS */
+ if (pop_command("USER %s", user) == NOTOK ||
+ pop_command("RPOP %s", user) == NOTOK) {
+#endif /* KERBEROS */
+ fprintf(stderr,Errmsg);
+ (void) pop_command("QUIT");
+ pop_close();
+ exit (1);
+ }
+
+ if (pop_stat(&nmsgs, &nbytes) == NOTOK) {
+ fprintf(stderr,Errmsg);
+ (void) pop_command("QUIT");
+ pop_close();
+ exit (1);
+ }
+
+#ifndef KERBEROS
+ setuid(getuid());
+#endif
+
+ if (!nmsgs) {
+ if (lock) {
+#if !SYS5_FILE_LOCKS
+ (void) flock(fileno(lock),LOCK_UN);
+#endif
+ (void) fclose(lock);
+ }
+ (void) unlink(lockfile);
+ (void) pop_command("QUIT");
+ pop_close();
+ exit (0);
+ }
+
+ uselock = 0;
+ if (lock) {
+ uselock = 1;
+ mymail.to = malloc(BUFSIZ);
+ mymail.from = malloc(BUFSIZ);
+ mymail.subj = malloc(BUFSIZ);
+ if (fgets(mymail.from,BUFSIZ,lock) != NULL)
+ mymail.from[strlen(mymail.from)-1] = 0;
+ else
+ mymail.from[0]=0;
+ if (fgets(mymail.to,BUFSIZ,lock) != NULL)
+ mymail.to[strlen(mymail.to)-1] = 0;
+ else
+ mymail.to[0] = 0;
+ if (fgets(mymail.subj,BUFSIZ,lock) != NULL)
+ mymail.subj[strlen(mymail.subj)-1] = 0;
+ else
+ mymail.subj[0] = 0;
+ }
+ else {
+ lock = fopen(lockfile,"w");
+ if (lock)
+#if SYS5_FILE_LOCKS
+ (void) lockf(fileno(lock),F_LOCK,0);
+#else
+ (void) flock(fileno(lock),LOCK_EX);
+#endif
+ else
+ perror("create lock file");
+ 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) {
+#if !SYS5_FILE_LOCKS
+ (void) flock(fileno(lock),LOCK_UN);
+#endif
+ (void) fclose(lock);
+ }
+ lock = fopen(lockfile,"w");
+ if (!lock) {
+ perror("open lockfile");
+ exit (1);
+ }
+ fprintf(lock,"%s\n%s\n%s\n",
+ maillist[nmsgs-i].from,
+ maillist[nmsgs-i].to,
+ maillist[nmsgs-i].subj);
+ (void) fclose(lock);
+
+ (void) pop_command("QUIT");
+ pop_close();
+ exit(0);
+}
+
+void get_message(i)
+ int i;
+{
+ int mbx_write();
+ if (pop_retr(i, mbx_write, 0) != OK) {
+ fprintf(stderr,Errmsg);
+ (void) pop_command("QUIT");
+ pop_close();
+ exit(1);
+ }
+}
+
+/* Pop stuff */
+
+void pop_close()
+{
+ if (sfi)
+ (void) fclose(sfi);
+ if (sfo)
+ (void) 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 = index(ptr,'\n');
+ if (ptr2)
+ *ptr2++ = 0;
+ if (*ptr == '\0')
+ break;
+ if (!strncmp(ptr, "From: ", 6))
+ (void) strcpy(from, ptr+6);
+ else if (!strncmp(ptr, "To: ", 4))
+ (void) strcpy(to, ptr+4);
+ else if (!strncmp(ptr, "Subject: ", 9))
+ (void) 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 = malloc((unsigned)(strlen(from)+1));
+ (void) strcpy(mail->from,from);
+ mail->to = malloc((unsigned)(strlen(to)+1));
+ (void) strcpy(mail->to,to);
+ mail->subj = malloc((unsigned)(strlen(subj)+1));
+ (void) strcpy(mail->subj,subj);
+
+ return (0);
+}
+
+void
+mail_notify(mail)
+ struct _mail *mail;
+{
+ int retval;
+ char *fields[3];
+ ZNotice_t notice;
+
+ (void) bzero((char *)¬ice, sizeof(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: $2\nSubject: $3";
+
+ fields[0] = mail->from;
+ fields[1] = mail->to;
+ fields[2] = mail->subj;
+
+ if ((retval = ZSendList(¬ice,fields,3,ZNOAUTH)) != ZERR_NONE)
+ com_err("zmailnotify",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;
+ int s;
+ char *get_errmsg();
+#ifdef KERBEROS
+#ifdef KRB4
+ KTEXT ticket;
+ MSG_DAT msg_data;
+ CREDENTIALS cred;
+ Key_schedule schedule;
+ int rem;
+#endif /* KRB4 */
+#ifdef KRB5
+ krb5_error_code retval;
+ krb5_ccache ccdef;
+ krb5_principal client, server;
+ krb5_error *err_ret = NULL;
+ register char *cp;
+#endif /* KRB5 */
+#endif /* KERBEROS */
+ hp = gethostbyname(host);
+ if (hp == NULL) {
+ sprintf(Errmsg, "MAILHOST unknown: %s", host);
+ return(NOTOK);
+ }
+
+#ifdef KERBEROS
+ sp = getservbyname(KPOP_SERVICE, "tcp");
+#else
+ sp = getservbyname("pop", "tcp");
+#endif
+ if (sp == 0) {
+#ifdef KERBEROS
+ strcpy(Errmsg, "tcp/kpop: unknown service");
+#else
+ strcpy(Errmsg, "tcp/pop: unknown service");
+#endif
+ return(NOTOK);
+ }
+
+ sin.sin_family = hp->h_addrtype;
+ memcpy((char *)&sin.sin_addr, hp->h_addr, hp->h_length);
+ sin.sin_port = sp->s_port;
+#ifdef KERBEROS
+ s = socket(AF_INET, SOCK_STREAM, 0);
+#else
+ s = rresvport(&lport);
+#endif
+
+ if (s < 0) {
+ sprintf(Errmsg, "error creating socket: %s", get_errmsg());
+ return(NOTOK);
+ }
+
+ if (connect(s, (struct sockaddr *)&sin, sizeof sin) < 0) {
+ sprintf(Errmsg, "error during connect: %s", get_errmsg());
+ close(s);
+ return(NOTOK);
+ }
+
+#ifdef KERBEROS
+#ifdef KRB4
+ ticket = (KTEXT) malloc(sizeof(KTEXT_ST));
+ rem = krb_sendauth(0L, s, ticket, KPOP_SNAME, hp->h_name,
+ (char *) krb_realmofhost(hp->h_name),
+ (unsigned long)0, &msg_data, &cred, schedule,
+ (struct sockaddr_in *)0,
+ (struct sockaddr_in *)0,
+ "KPOPV0.1");
+ if (rem != KSUCCESS) {
+ sprintf(Errmsg, "kerberos error: %s", krb_err_txt[rem]);
+ close(s);
+ return(NOTOK);
+ }
+#endif /* KRB4 */
+#ifdef KRB5
+ krb5_init_ets();
+
+ if (retval = krb5_cc_default(&ccdef)) {
+ krb5error:
+ sprintf(Errmsg, "krb5 error: %s", error_message(retval));
+ close(s);
+ return(NOTOK);
+ }
+ if (retval = krb5_cc_get_principal(ccdef, &client)) {
+ goto krb5error;
+ }
+
+#if 0
+ /* lower-case to get name for "instance" part of service name */
+ for (cp = hp->h_name; *cp; cp++)
+ if (isupper(*cp))
+ *cp = tolower(*cp);
+#endif
+
+ if (retval = krb5_sname_to_principal(hp->h_name, KPOP_SNAME,
+ KRB5_NT_SRV_HST, &server)) {
+ goto krb5error;
+ }
+
+ retval = krb5_sendauth((krb5_pointer) &s, "KPOPV1.0", client, server,
+ AP_OPTS_MUTUAL_REQUIRED,
+ 0, /* no checksum */
+ 0, /* no creds, use ccache instead */
+ ccdef,
+ 0, /* don't need seq # */
+ 0, /* don't need a subsession key */
+ &err_ret,
+ 0); /* don't need reply */
+ krb5_free_principal(server);
+ if (retval) {
+ if (err_ret && err_ret->text.length) {
+ sprintf(Errmsg, "krb5 error: %s [server says '%*s'] ",
+ error_message(retval),
+ err_ret->text.length,
+ err_ret->text.data);
+ krb5_free_error(err_ret);
+ } else
+ sprintf(Errmsg, "krb5 error: %s", error_message(retval));
+ close(s);
+ return(NOTOK);
+ }
+#endif /* KRB5 */
+#endif /* KERBEROS */
+
+ 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);
+}
+
+/*VARARGS1*/
+pop_command(fmt, a, b, c, d)
+char *fmt;
+{
+ char buf[4096];
+
+ (void) sprintf(buf, fmt, a, b, c, d);
+
+ if (putline(buf, Errmsg, sfo) == NOTOK) return(NOTOK);
+
+ if (getline(buf, sizeof buf, sfi) != OK) {
+ (void) strcpy(Errmsg, buf);
+ return(NOTOK);
+ }
+
+ if (*buf != '+') {
+ (void) 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) {
+ (void) strcpy(Errmsg, buf);
+ return(NOTOK);
+ }
+
+ if (*buf != '+') {
+ (void) strcpy(Errmsg, buf);
+ return(NOTOK);
+ } else {
+ if (sscanf(buf, "+OK %d %d", nmsgs, nbytes) != 2)
+ return(NOTOK);
+ return(OK);
+ }
+}
+
+pop_retr(msgno, action, arg)
+int (*action)();
+{
+ char buf[4096];
+
+ (void) sprintf(buf, "RETR %d", msgno);
+ if (putline(buf, Errmsg, sfo) == NOTOK) return(NOTOK);
+
+ if (getline(buf, sizeof buf, sfi) != OK) {
+ (void) 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:
+ (void) strcpy(Errmsg, buf);
+ return (NOTOK);
+ }
+ }
+}
+
+getline(buf, n, f)
+char *buf;
+register int n;
+FILE *f;
+{
+ register char *p;
+ int c;
+
+ p = fgets(buf, n, f);
+
+ if (ferror(f)) {
+ (void) strcpy(buf, "error on connection");
+ return (NOTOK);
+ }
+
+ if (p == NULL) {
+ (void) strcpy(buf, "connection closed by foreign host\n");
+ return (DONE);
+ }
+
+ p = buf + strlen(buf);
+ 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 {
+ (void) 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);
+ (void) fflush(f);
+ if (ferror(f)) {
+ (void) strcpy(err, "lost connection");
+ return(NOTOK);
+ }
+ return(OK);
+}
+
+/*ARGSUSED*/
+mbx_write(line, dummy)
+char *line;
+int dummy; /* for consistency with pop_retr */
+{
+ if (mailptr) {
+ mailptr = realloc(mailptr,(unsigned)(strlen(mailptr)+strlen(line)+2));
+ (void) strcat(mailptr,line);
+ }
+ else {
+ mailptr = malloc((unsigned)(strlen(line)+2));
+ (void) strcpy(mailptr,line);
+ }
+ (void) strcat(mailptr,"\n");
+ return(0);
+}
projects / krb5.git / commitdiff