BSD 4_4 release

[unix-history] / usr / src / contrib / mh-6.8 / uip / popsbr.c

/* popsbr.c - POP client subroutines */
#ifndef lint
static char ident[] = "@(#)$Id: popsbr.c,v 2.4 1992/11/24 18:32:32 jromine Exp $";
#endif  lint

#if defined(NNTP) && !defined(PSHSBR)
#undef  NNTP
#endif

/* LINTLIBRARY */

#include "../h/strings.h"
#ifdef NNTP                     /* building pshsbr.o from popsbr.c */
#include "../h/nntp.h"
#endif /* NNTP */
#include <stdio.h>
#include <signal.h>

#ifndef POPSERVICE
#define POPSERVICE      "pop"
#endif

#define NOTOK   (-1)
#define OK      0
#define DONE    1

#define TRM     "."
#define TRMLEN  (sizeof TRM - 1)

extern int  errno;
#ifndef BSD44
extern int  sys_nerr;
extern char *sys_errlist[];
#endif

static int  poprint = 0;
static int  pophack = 0;

char    response[BUFSIZ];

static FILE *input;
static FILE *output;

#ifdef __STDC__
static int  traverse (int (*)(), const char*, char *, char *, char *, char *);
#define targ_t  char *
#else
static int      traverse();
#define targ_t  int
#endif

#if !defined(NNTP) && defined(MPOP)
#define command pop_command
#define multiline pop_multiline
int     command(), multiline();
#else
static  int     command(), multiline();
#endif

static int      getline();
static putline();

#ifdef NNTP
#ifdef  BPOP    /* stupid */
static  int     xtnd_last = -1,
               xtnd_first = 0;
static char     xtnd_name[512]; /* INCREDIBLE HACK!! */
#endif
#endif /* NNTP */

/* \f */

#ifndef NNTP
#ifdef  APOP
#include "md5.c"

static char *pop_auth (user, pass)
char   *user,
      *pass;
{
   register char *cp,
                 *lp;
   register unsigned char *dp;
   unsigned char *ep,
                  digest[16];
   MD5_CTX mdContext;
   static char buffer[BUFSIZ];

   if ((cp = index (response, '<')) == NULL
           || (lp = index (cp, '>')) == NULL) {
       (void) sprintf (buffer, "APOP not available: %s", response);
       (void) strcpy (response, buffer);
       return NULL;
   }

   *++lp = NULL;
   (void) sprintf (buffer, "%s%s", cp, pass);

   MD5Init (&mdContext);
   MD5Update (&mdContext, (unsigned char *) buffer,
              (unsigned int) strlen (buffer));
   MD5Final (digest, &mdContext);

   (void) sprintf (cp = buffer, "%s ", user);
   cp += strlen (cp);
   for (ep = (dp = digest) + sizeof digest / sizeof digest[0];
            dp < ep;
            cp += 2)
       (void) sprintf (cp, "%02x", *dp++ & 0xff);
   *cp = NULL;

   return buffer;
}
#endif  /* APOP */
#endif  /* !NNTP */

/* \f */

#if defined(RPOP) || defined(APOP)
int     pop_init (host, user, pass, snoop, rpop)
int     rpop;
#else
int     pop_init (host, user, pass, snoop)
#endif
char   *host,
      *user,
      *pass;
int     snoop;
{
#ifdef  APOP
   int     apop;
#else
#ifndef RPOP    /* !APOP && !RPOP */
   int     rpop = 0;
#endif
#endif
   int     fd1,
           fd2;
   char    buffer[BUFSIZ];

#ifdef  APOP
   if ((apop = rpop) < 0)
       rpop = 0;
#endif  /* APOP */

#ifndef NNTP
#ifndef KPOP
   if ((fd1 = client (host, "tcp", POPSERVICE, rpop, response)) == NOTOK)
#else   /* KPOP */
   (void) sprintf (buffer, "%s/%s", POPSERVICE, "kpop");
   if ((fd1 = client (host, "tcp", buffer, rpop, response)) == NOTOK)
#endif
#else   /* NNTP */
   if ((fd1 = client (host, "tcp", "nntp", rpop, response)) == NOTOK)
#endif
       return NOTOK;

   if ((fd2 = dup (fd1)) == NOTOK) {
       (void) sprintf (response, "unable to dup connection descriptor: %s",
               errno > 0 && errno < sys_nerr ? sys_errlist[errno]
               : "unknown error");
       (void) close (fd1);
       return NOTOK;
   }
#ifndef NNTP
   if (pop_set (fd1, fd2, snoop) == NOTOK)
#else   /* NNTP */
   if (pop_set (fd1, fd2, snoop, (char *)0) == NOTOK)
#endif  /* NNTP */
       return NOTOK;

   (void) signal (SIGPIPE, SIG_IGN);

   switch (getline (response, sizeof response, input)) {
       case OK: 
           if (poprint)
               fprintf (stderr, "<--- %s\n", response);
#ifndef NNTP
           if (*response == '+') {
#ifndef KPOP
#ifdef  APOP
               if (apop < 0) {
                   char   *cp = pop_auth (user, pass);

                   if (cp && command ("APOP %s", cp) != NOTOK)
                       return OK;
               }
               else
#endif  /* apop */
               if (command ("USER %s", user) != NOTOK
                   && command ("%s %s", rpop ? "RPOP" : (pophack++, "PASS"),
                                       pass) != NOTOK)
               return OK;
#else   /* KPOP */
               if (command ("USER %s", user) != NOTOK
                   && command ("PASS %s", pass) != NOTOK)
               return OK;
#endif
           }
#else   /* NNTP */
           if (*response < CHAR_ERR)
               return OK;
#endif
           (void) strcpy (buffer, response);
           (void) command ("QUIT");
           (void) strcpy (response, buffer);
                               /* and fall */

       case NOTOK: 
       case DONE: 
           if (poprint)            
               fprintf (stderr, "%s\n", response);
           (void) fclose (input);
           (void) fclose (output);
           return NOTOK;
   }
/* NOTREACHED */
}
/* \f */

#ifndef NNTP
int     pop_set (in, out, snoop)
#else   /* NNTP */
int     pop_set (in, out, snoop, myname)
char   *myname;
#endif  /* NNTP */
int     in,
       out,
       snoop;
{
#ifdef NNTP
   if (myname && *myname)
       strcpy (xtnd_name, myname);     /* interface from bbc to msh */

#endif  /* NNTP */
   if ((input = fdopen (in, "r")) == NULL
           || (output = fdopen (out, "w")) == NULL) {
       (void) strcpy (response, "fdopen failed on connection descriptor");
       if (input)
           (void) fclose (input);
       else
           (void) close (in);
       (void) close (out);
       return NOTOK;
   }

   poprint = snoop;

   return OK;
}


int     pop_fd (in, out)
char   *in,
      *out;
{
   (void) sprintf (in, "%d", fileno (input));
   (void) sprintf (out, "%d", fileno (output));
   return OK;
}

/* \f */

int     pop_stat (nmsgs, nbytes)
int    *nmsgs,
      *nbytes;
{
#ifdef NNTP
   char **ap;
   extern char **brkstring();
#endif  /* NNTP */

#ifndef NNTP
   if (command ("STAT") == NOTOK)
       return NOTOK;

   *nmsgs = *nbytes = 0;
   (void) sscanf (response, "+OK %d %d", nmsgs, nbytes);

#else   /* NNTP */
   if (xtnd_last < 0) {        /* in msh, xtnd_name is set from myname */
       if (command("GROUP %s", xtnd_name) == NOTOK)
           return NOTOK;

       ap = brkstring (response, " ", "\n"); /* "211 nart first last ggg" */
       xtnd_first = atoi (ap[2]);
       xtnd_last  = atoi (ap[3]);
   }

   /* nmsgs is not the real nart, but an incredible simuation */
   if (xtnd_last > 0)
       *nmsgs = xtnd_last - xtnd_first + 1;    /* because of holes... */
   else
       *nmsgs = 0;
   *nbytes = xtnd_first;       /* for subtracting offset in msh() */
#endif  /* NNTP */

   return OK;
}

#ifdef NNTP
int     pop_exists (action)
int     (*action) ();
{
   if (traverse (action, "XMSGS %d-%d",
           (targ_t)xtnd_first, (targ_t)xtnd_last, 0, 0) == OK)
       return OK;
   return traverse (action, "XHDR NONAME %d-%d",
           (targ_t)xtnd_first, (targ_t)xtnd_last, 0, 0);
}
#endif  /* NNTP */

#ifndef BPOP
int     pop_list (msgno, nmsgs, msgs, bytes)
#else   BPOP
int     pop_list (msgno, nmsgs, msgs, bytes, ids)
int    *ids;
#endif  BPOP
int     msgno,
      *nmsgs,
      *msgs,
      *bytes;
{
   int     i;
#ifndef BPOP
   int    *ids = NULL;
#endif

   if (msgno) {
#ifndef NNTP
       if (command ("LIST %d", msgno) == NOTOK)
           return NOTOK;
       *msgs = *bytes = 0;
       if (ids) {
           *ids = 0;
           (void) sscanf (response, "+OK %d %d %d", msgs, bytes, ids);
       }
       else
           (void) sscanf (response, "+OK %d %d", msgs, bytes);
#else   /* NNTP */
       *msgs = *bytes = 0;
       if (command ("STAT %d", msgno) == NOTOK) 
           return NOTOK;
       if (ids) {
           *ids = msgno;
       }
#endif  /* NNTP */
       return OK;
   }

#ifndef NNTP
   if (command ("LIST") == NOTOK)
       return NOTOK;

   for (i = 0; i < *nmsgs; i++)
       switch (multiline ()) {
           case NOTOK: 
               return NOTOK;
           case DONE: 
               *nmsgs = ++i;
               return OK;
           case OK: 
               *msgs = *bytes = 0;
               if (ids) {
                   *ids = 0;
                   (void) sscanf (response, "%d %d %d",
                           msgs++, bytes++, ids++);
               }
               else
                   (void) sscanf (response, "%d %d", msgs++, bytes++);
               break;
       }
   for (;;)
       switch (multiline ()) {
           case NOTOK: 
               return NOTOK;
           case DONE: 
               return OK;
           case OK: 
               break;
       }
#else   /* NNTP */
   return NOTOK;
#endif  /* NNTP */
}

/* \f */

int     pop_retr (msgno, action)
int     msgno,
       (*action) ();
{
#ifndef NNTP
   return traverse (action, "RETR %d", (targ_t)msgno, 0, 0, 0);
#else   /* NNTP */
   return traverse (action, "ARTICLE %d", (targ_t)msgno, 0, 0, 0);
#endif  /* NNTP */
}


/* VARARGS2 */

static int  traverse (action, fmt, a, b, c, d)
int     (*action) ();
#ifdef __STDC__
const char   *fmt;
#else
char *fmt;
#endif
char   *a,
      *b,
      *c,
      *d;
{
   char    buffer[sizeof response];

   if (command (fmt, a, b, c, d) == NOTOK)
       return NOTOK;
   (void) strcpy (buffer, response);

   for (;;)
       switch (multiline ()) {
           case NOTOK: 
               return NOTOK;

           case DONE: 
               (void) strcpy (response, buffer);
               return OK;

           case OK: 
               (*action) (response);
               break;
       }
}

/* \f */

int     pop_dele (msgno)
int     msgno;
{
   return command ("DELE %d", msgno);
}


int     pop_noop () {
   return command ("NOOP");
}


#ifndef NNTP
#ifdef  MPOP
int     pop_last () {
   return command ("LAST");
}
#endif  /* MPOP */
#endif  /* !NNTP */

int     pop_rset () {
   return command ("RSET");
}

/* \f */

int     pop_top (msgno, lines, action)
int     msgno,
       lines,
       (*action) ();
{
#ifndef NNTP
   return traverse (action, "TOP %d %d", (targ_t)msgno, (targ_t)lines, 0, 0);
#else   /* NNTP */
   return traverse (action, "HEAD %d", (targ_t)msgno, 0, 0, 0);
#endif  /* NNTP */
}


#ifdef  BPOP
int     pop_xtnd (action, fmt, a, b, c, d)
int     (*action) ();
char   *fmt,
      *a,
      *b,
      *c,
      *d;
{
   char buffer[BUFSIZ];
#ifdef NNTP
   extern char **brkstring();
   char  **ap;
#endif  /* NNTP */

#ifndef NNTP
   (void) sprintf (buffer, "XTND %s", fmt);
   return traverse (action, buffer, a, b, c, d);
#else   /* NNTP */
   sprintf (buffer, fmt, a, b, c, d);
   ap = brkstring (buffer, " ", "\n"); /* a hack, i know... */

   if (uleq(ap[0], "x-bboards")) {     /* XTND "X-BBOARDS group */
       /* most of these parameters are meaningless under NNTP. 
        * bbc.c was modified to set AKA and LEADERS as appropriate,
        * the rest are left blank.
        */
       return OK;
   }
   if (uleq (ap[0], "archive") && ap[1]) {
       sprintf (xtnd_name, "%s", ap[1]);               /* save the name */
       xtnd_last = 0;
       xtnd_first = 1;         /* setup to fail in pop_stat */
       return OK;
   }
   if (uleq (ap[0], "bboards")) {

       if (ap[1]) {                    /* XTND "BBOARDS group" */
           sprintf (xtnd_name, "%s", ap[1]);           /* save the name */
           if (command("GROUP %s", xtnd_name) == NOTOK)
               return NOTOK;

           strcpy (buffer, response);  /* action must ignore extra args */
           ap = brkstring (response, " ", "\n");/* "211 nart first last g" */
           xtnd_first = atoi (ap[2]);
           xtnd_last  = atoi (ap[3]);

           (*action) (buffer);         
           return OK;

       } else {                /* XTND "BBOARDS" */
           return traverse (action, "LIST", a, b, c, d);
       }
   }
   return NOTOK;       /* unknown XTND command */
#endif  /* NNTP */
}
#endif  BPOP

/* \f */

int     pop_quit () {
   int     i;

   i = command ("QUIT");
   (void) pop_done ();

   return i;
}


int     pop_done () {
   (void) fclose (input);
   (void) fclose (output);

   return OK;
}

/* \f */

/* VARARGS1 */

#if defined(MPOP) && !defined(NNTP)
int     command (fmt, a, b, c, d)
#else
static int  command (fmt, a, b, c, d)
#endif
char   *fmt,
      *a,
      *b,
      *c,
      *d;
{
   char   *cp,
           buffer[BUFSIZ];

   (void) sprintf (buffer, fmt, a, b, c, d);
   if (poprint)
       if (pophack) {
           if (cp = index (buffer, ' '))
               *cp = 0;
           fprintf (stderr, "---> %s ********\n", buffer);
           if (cp)
               *cp = ' ';
           pophack = 0;
       }
       else
           fprintf (stderr, "---> %s\n", buffer);

   if (putline (buffer, output) == NOTOK)
       return NOTOK;

   switch (getline (response, sizeof response, input)) {
       case OK: 
           if (poprint)
               fprintf (stderr, "<--- %s\n", response);
#ifndef NNTP
           return (*response == '+' ? OK : NOTOK);
#else   /* NNTP */
           return (*response < CHAR_ERR ? OK : NOTOK);
#endif  /* NNTP */

       case NOTOK: 
       case DONE: 
           if (poprint)            
               fprintf (stderr, "%s\n", response);
           return NOTOK;
   }
/* NOTREACHED */
}

#if     defined(MPOP) && !defined(NNTP)
int  multiline () {
#else
static int  multiline () {
#endif
   char    buffer[BUFSIZ + TRMLEN];

   if (getline (buffer, sizeof buffer, input) != OK)
       return NOTOK;
#ifdef  DEBUG
   if (poprint)
       fprintf (stderr, "<--- %s\n", response);
#endif  DEBUG
   if (strncmp (buffer, TRM, TRMLEN) == 0) {
       if (buffer[TRMLEN] == 0)
           return DONE;
       else
           (void) strcpy (response, buffer + TRMLEN);
   }
   else
       (void) strcpy (response, buffer);

   return OK;
}

/* \f */

static int  getline (s, n, iop)
char   *s;
int     n;
FILE * iop;
{
   int     c;
   char   *p;

   p = s;
   while (--n > 0 && (c = fgetc (iop)) != EOF)
       if ((*p++ = c) == '\n')
           break;
   if (ferror (iop) && c != EOF) {
       (void) strcpy (response, "error on connection");
       return NOTOK;
   }
   if (c == EOF && p == s) {
       (void) strcpy (response, "connection closed by foreign host");
       return DONE;
   }
   *p = 0;
   if (*--p == '\n')
       *p = 0;
   if (*--p == '\r')
       *p = 0;

   return OK;
}


static  putline (s, iop)
char   *s;
FILE * iop;
{
   (void) fprintf (iop, "%s\r\n", s);
   (void) fflush (iop);
   if (ferror (iop)) {
       (void) strcpy (response, "lost connection");
       return NOTOK;
   }

   return OK;
}