diff options
| -rw-r--r-- | pop3.c | 678 |
1 files changed, 5 insertions, 673 deletions
@@ -33,443 +33,14 @@ #ifdef HAVE_PROTOTYPES /* prototypes for internal functions */ -int POP3_OK (char *buf, int socket); -int POP3_auth (struct hostrec *options, int socket); -int POP3_sendQUIT (int socket); int POP3_sendSTAT (int *msgcount, int socket); -int POP3_sendRETR (int msgnum, int socket); -int POP3_sendDELE (int msgnum, int socket); int POP3_sendLAST (int *last, int socket); int POP3_sendUIDL (int num, int socket, char **cp); -int POP3_readmsg (int socket, int mboxfd, char *host, int topipe, int rewrite); int POP3_BuildDigest (char *buf, struct hostrec *options); #endif /********************************************************************* - function: doPOP3 - description: retrieve messages from the specified mail server - using Post Office Protocol 3. - - arguments: - queryctl fully-specified options (i.e. parsed, defaults invoked, - etc). - - return value: exit code from the set of PS_.* constants defined in - popclient.h - calls: - globals: reads outlevel. - *********************************************************************/ - -int doPOP3 (queryctl) -struct hostrec *queryctl; -{ - int ok, use_uidl; - int mboxfd; - char buf [POPBUFSIZE]; - int socket; - int first,number,count; - - - /* open stdout or the mailbox, locking it if it is a folder */ - if (queryctl->output == TO_FOLDER || queryctl->output == TO_STDOUT) - if ((mboxfd = openuserfolder(queryctl)) < 0) - return(PS_IOERR); - - /* open the socket and get the greeting */ - if ((socket = Socket(queryctl->servername,POP3_PORT)) < 0) { - perror("doPOP3: socket"); - ok = PS_SOCKET; - goto closeUp; - } - - ok = POP3_OK(buf,socket); - if (ok != 0) { - if (ok != PS_SOCKET) - POP3_sendQUIT(socket); - close(socket); - goto closeUp; - } - - /* print the greeting */ - if (outlevel > O_SILENT && outlevel < O_VERBOSE) - fprintf(stderr,"pop3 greeting: %s\n",buf); - else - ; - -#if defined(HAVE_APOP_SUPPORT) - /* build MD5 digest from greeting timestamp + password */ - if (queryctl->whichpop == P_APOP) - if (POP3_BuildDigest(buf,queryctl) != 0) { - ok = PS_AUTHFAIL; - goto closeUp; - } else - ; - else - ; /* not using APOP protocol this time */ -#endif - - /* try to get authorized */ - ok = POP3_auth(queryctl,socket); - if (ok == PS_ERROR) - ok = PS_AUTHFAIL; - if (ok != 0) - goto cleanUp; - - /* find out how many messages are waiting */ - ok = POP3_sendSTAT(&count,socket); - if (ok != 0) { - goto cleanUp; - } - - /* - * Ask for number of last message retrieved. - * Newer, RFC-1760-conformant POP servers may not have the LAST command. - * Therefore we don't croak if we get a nonzero return. Instead, send - * UIDL and try to find the last received ID stored for this host in - * the list we get back. - */ - first = 1; - use_uidl = 0; - if (!queryctl->fetchall) { - char buf [POPBUFSIZE]; - char id [IDLEN]; - int num; - - /* try LAST first */ - ok = POP3_sendLAST(&first, socket); - use_uidl = (ok != 0); - - /* otherwise, if we have a stored last ID for this host, - * send UIDL and search the returned list for it - */ - if (use_uidl && queryctl->lastid[0]) { - if ((ok = POP3_sendUIDL(-1, socket, 0)) == 0) { - while (SockGets(socket, buf, sizeof(buf)) >= 0) { - if (outlevel == O_VERBOSE) - fprintf(stderr,"%s\n",buf); - if (strcmp(buf, ".\n") == 0) { - break; - } - if (sscanf(buf, "%d %s\n", &num, id) == 2) - if (strcmp(id, queryctl->lastid) == 0) - first = num; - } - } - } - - if (ok == 0) - first++; - } - - /* show them how many messages we'll be downloading */ - if (outlevel > O_SILENT && outlevel < O_VERBOSE) - if (first > 1) - fprintf(stderr,"%d messages in folder, %d new messages.\n", - count, count - first + 1); - else - fprintf(stderr,"%d %smessages in folder.\n", count, ok ? "" : "new "); - else - ; - - if (count > 0) { - for (number = queryctl->flush ? 1 : first; number <= count; number++) { - - char *cp; - - /* open the mail pipe if we're using an MDA */ - if (queryctl->output == TO_MDA - && (queryctl->fetchall || number >= first)) { - ok = (mboxfd = openmailpipe(queryctl)) < 0 ? -1 : 0; - if (ok != 0) - goto cleanUp; - } - - if (queryctl->flush && number < first && !queryctl->fetchall) - ok = 0; /* no command to send here, will delete message below */ - else if (linelimit) - ok = POP3_sendTOP(number,linelimit,socket); - else - ok = POP3_sendRETR(number,socket); - if (ok != 0) - goto cleanUp; - -#ifdef DEBUGLOG - if (outlevel == O_VERBOSE) - fprintf(stderr, "reading text of %d\n", number); -#endif /* DEBUGLOG */ - - if (number >= first || queryctl->fetchall) - ok = POP3_readmsg(socket,mboxfd, - queryctl->servername, - queryctl->output == TO_MDA, - queryctl->rewrite); - else - ok = 0; - -#ifdef DEBUGLOG - if (outlevel == O_VERBOSE) - fprintf(stderr, "done reading text of %d; status %d\n", number, ok); -#endif /* DEBUGLOG */ - - if (ok != 0) - goto cleanUp; - -#ifdef DEBUGLOG - if (outlevel == O_VERBOSE) - fprintf(stderr, "about to update last-seen field with %d\n", number); -#endif /* DEBUGLOG */ - - /* update the last-seen field for this host */ - if (use_uidl && (ok = POP3_sendUIDL(number, socket, &cp)) == 0) - (void) strcpy(queryctl->lastid, cp); - -#ifdef DEBUGLOG - if (outlevel == O_VERBOSE) - fprintf(stderr, "about to check for deletion of %d\n", number); -#endif /* DEBUGLOG */ - - /* maybe we delete this message now? */ - if ((number < first && queryctl->flush) || !queryctl->keep) { - if (outlevel > O_SILENT && outlevel < O_VERBOSE) - fprintf(stderr,"flushing message %d\n", number); - else - ; - ok = POP3_sendDELE(number,socket); - if (ok != 0) - goto cleanUp; - } - else - ; /* message is kept */ - -#ifdef DEBUGLOG - if (outlevel == O_VERBOSE) - fprintf(stderr, "about to check for mail folder close after %d\n", number); -#endif /* DEBUGLOG */ - - /* close the mail pipe, we'll reopen before next message */ - if (queryctl->output == TO_MDA - && (queryctl->fetchall || number >= first)) { - -#ifdef DEBUGLOG - if (outlevel == O_VERBOSE) - fprintf(stderr, "about to close pipe\n"); -#endif /* DEBUGLOG */ - - ok = closemailpipe(mboxfd); - -#ifdef DEBUGLOG - if (outlevel == O_VERBOSE) - fprintf(stderr, "done closing pipe, status %d\n", ok); -#endif /* DEBUGLOG */ - - if (ok != 0) - goto cleanUp; - } - -#ifdef DEBUGLOG - if (outlevel == O_VERBOSE) - fprintf(stderr, "finished processing of %d\n", number); -#endif /* DEBUGLOG */ - } - - ok = POP3_sendQUIT(socket); - if (ok == 0) - ok = PS_SUCCESS; - close(socket); - goto closeUp; - } - else { - ok = POP3_sendQUIT(socket); - if (ok == 0) - ok = PS_NOMAIL; - close(socket); - goto closeUp; - } - -cleanUp: - if (ok != 0 && ok != PS_SOCKET) - POP3_sendQUIT(socket); - -closeUp: - if (queryctl->output == TO_FOLDER) - if (closeuserfolder(mboxfd) < 0 && ok == 0) - ok = PS_IOERR; - - if (ok == PS_IOERR || ok == PS_SOCKET) - perror("doPOP3: cleanUp"); - - return(ok); -} - - - -/********************************************************************* - function: POP3_OK - description: get the server's response to a command, and return - the extra arguments sent with the response. - arguments: - argbuf buffer to receive the argument string. - socket socket to which the server is connected. - - return value: zero if okay, else return code. - calls: SockGets - globals: reads outlevel. - *********************************************************************/ - -int POP3_OK (argbuf,socket) -char *argbuf; -int socket; -{ - int ok; - char buf [POPBUFSIZE]; - char *bufp; - - if (SockGets(socket, buf, sizeof(buf)) >= 0) { - if (outlevel == O_VERBOSE) - fprintf(stderr,"%s\n",buf); - - bufp = buf; - if (*bufp == '+' || *bufp == '-') - bufp++; - else - return(PS_PROTOCOL); - - while (isalpha(*bufp)) - bufp++; - *(bufp++) = '\0'; - - if (strcmp(buf,"+OK") == 0) - ok = 0; - else if (strcmp(buf,"-ERR") == 0) - ok = PS_ERROR; - else - ok = PS_PROTOCOL; - - if (argbuf != NULL) - strcpy(argbuf,bufp); - } - else - ok = PS_SOCKET; - - return(ok); -} - - - -/********************************************************************* - function: POP3_auth - description: send the USER and PASS commands to the server, and - get the server's response. - arguments: - queryctl merged options record. - socket socket to which the server is connected. - - return value: zero if success, else status code. - calls: SockPrintf, POP3_OK. - globals: read outlevel. - *********************************************************************/ - -int POP3_auth (queryctl,socket) -struct hostrec *queryctl; -int socket; -{ - char buf [POPBUFSIZE]; - - switch (queryctl->protocol) { - case P_POP3: - SockPrintf(socket,"USER %s\r\n",queryctl->remotename); - if (outlevel == O_VERBOSE) - fprintf(stderr,"> USER %s\n",queryctl->remotename); - if (POP3_OK(buf,socket) != 0) - goto badAuth; - - SockPrintf(socket,"PASS %s\r\n",queryctl->password); - if (outlevel == O_VERBOSE) - fprintf(stderr,"> PASS password\n"); - if (POP3_OK(buf,socket) != 0) - goto badAuth; - - break; - -#if defined(HAVE_APOP_SUPPORT) - case P_APOP: - SockPrintf(socket,"APOP %s %s\r\n", - queryctl->remotename, queryctl->digest); - if (outlevel == O_VERBOSE) - fprintf(stderr,"> APOP %s %s\n",queryctl->remotename, queryctl->digest); - if (POP3_OK(buf,socket) != 0) - goto badAuth; - break; -#endif /* HAVE_APOP_SUPPORT */ - -#if defined(HAVE_RPOP_SUPPORT) - case P_RPOP: - SockPrintf(socket, "RPOP %s\r\n", queryctl->remotename); - if (POP3_OK(buf,socket) != 0) - goto badAuth; - if (outlevel == O_VERBOSE) - fprintf(stderr,"> RPOP %s %s\n",queryctl->remotename); - break; -#endif /* HAVE_RPOP_SUPPORT */ - - default: - fprintf(stderr,"Undefined protocol request in POP3_auth\n"); - } - - /* we're approved */ - return(0); - - /*NOTREACHED*/ - -badAuth: - if (outlevel > O_SILENT && outlevel < O_VERBOSE) - fprintf(stderr,"%s\n",buf); - else - ; /* say nothing */ - - return(PS_ERROR); -} - - - - -/********************************************************************* - function: POP3_sendQUIT - description: send the QUIT command to the server and close - the socket. - - arguments: - socket socket to which the server is connected. - - return value: none. - calls: SockPuts, POP3_OK. - globals: reads outlevel. - *********************************************************************/ - -int POP3_sendQUIT (socket) -int socket; -{ - int ok; - char buf [POPBUFSIZE]; - - SockPuts(socket,"QUIT"); - - if (outlevel == O_VERBOSE) - fprintf(stderr,"> QUIT\n"); - else - ; - - ok = POP3_OK(buf,socket); - if (ok != 0 && outlevel > O_SILENT && outlevel < O_VERBOSE) - fprintf(stderr,"%s\n",buf); - - return(ok); -} - - - -/********************************************************************* function: POP3_sendSTAT description: send the STAT command to the POP3 server to find out how many messages are waiting. @@ -494,7 +65,7 @@ int socket; if (outlevel == O_VERBOSE) fprintf(stderr,"> STAT\n"); - ok = POP3_OK(buf,socket); + ok = pop3_ok(buf,socket); if (ok == 0) sscanf(buf,"%d %d",msgcount,&totalsize); else if (outlevel > O_SILENT && outlevel < O_VERBOSE) @@ -503,245 +74,6 @@ int socket; return(ok); } - - - -/********************************************************************* - function: POP3_sendRETR - description: send the RETR command to the POP3 server. - arguments: - msgnum message ID number - socket socket to which the POP3 server is connected. - - return value: return code from POP3_OK. - calls: POP3_OK, SockPrintf - globals: reads outlevel. - *********************************************************************/ - -int POP3_sendRETR (msgnum,socket) -int msgnum; -int socket; -{ - int ok; - char buf [POPBUFSIZE]; - - SockPrintf(socket,"RETR %d\r\n",msgnum); - if (outlevel == O_VERBOSE) - fprintf(stderr,"> RETR %d\n",msgnum); - - ok = POP3_OK(buf,socket); - if (ok != 0 && outlevel > O_SILENT && outlevel < O_VERBOSE) - fprintf(stderr,"%s\n",buf); - - return(ok); -} - - -/********************************************************************* - function: POP3_sendTOP - description: send the TOP command to the POP3 server. - arguments: - msgnum message ID number - limit maximum number of message body lines to retrieve. - socket socket to which the POP3 server is connected. - - return value: return code from POP3_OK. - calls: POP3_OK, SockPrintf - globals: reads outlevel. - *********************************************************************/ - -int POP3_sendTOP (msgnum,limit,socket) -int msgnum; -int socket; -{ - int ok; - char buf [POPBUFSIZE]; - - SockPrintf(socket,"TOP %d %d\r\n",msgnum,limit); - if (outlevel == O_VERBOSE) - fprintf(stderr,"> TOP %d %d\n",msgnum,limit); - - ok = POP3_OK(buf,socket); - if (ok != 0 && outlevel > O_SILENT && outlevel < O_VERBOSE) - fprintf(stderr,"option --limit failed; server says '%s'\n",buf); - - return(ok); -} - - - - -/********************************************************************* - function: POP3_sendDELE - description: send the DELE command to the POP3 server. - arguments: - msgnum message ID number - socket socket to which the POP3 server is connected. - - return value: return code from POP3_OK. - calls: POP3_OK, SockPrintF. - globals: reads outlevel. - *********************************************************************/ - -int POP3_sendDELE (msgnum,socket) -int msgnum; -int socket; -{ - int ok; - char buf [POPBUFSIZE]; - - SockPrintf(socket,"DELE %d\r\n",msgnum); - if (outlevel == O_VERBOSE) - fprintf(stderr,"> DELE %d\n",msgnum); - - ok = POP3_OK(buf,socket); - if (ok != 0 && outlevel > O_SILENT && outlevel < O_VERBOSE) - fprintf(stderr,"%s\n",buf); - - return(ok); -} - - - -/********************************************************************* - function: POP3_readmsg - description: Read the message content as described in RFC 1225. - arguments: - socket ... to which the server is connected. - mboxfd open file descriptor to which the retrieved message will - be written. - pophost name of the POP host - topipe true if we're writing to the system mailbox pipe. - - return value: zero if success else PS_* return code. - calls: SockGets. - globals: reads outlevel. - *********************************************************************/ - -int POP3_readmsg (socket,mboxfd,pophost,topipe,rewrite) -int socket; -int mboxfd; -char *pophost; -int topipe; -int rewrite; -{ - char buf [MSGBUFSIZE]; - char *bufp; - char savec; - char fromBuf[MSGBUFSIZE]; - int needFrom; - int inheaders; - int lines,sizeticker; - time_t now; - /* This keeps the retrieved message count for display purposes */ - static int msgnum = 0; - - /* set up for status message if outlevel allows it */ - if (outlevel > O_SILENT && outlevel < O_VERBOSE) { - fprintf(stderr,"reading message %d",++msgnum); - /* won't do the '...' if retrieved messages are being sent to stdout */ - if (mboxfd == 1) - fputs(".\n",stderr); - else - ; - } - else - ; - - /* read the message content from the server */ - inheaders = 1; - lines = 0; - sizeticker = MSGBUFSIZE; - while (1) { - if (SockGets(socket,buf,sizeof(buf)) < 0) - return(PS_SOCKET); - bufp = buf; - if (buf[0] == '\r' || buf[0] == '\n') - inheaders = 0; - if (*bufp == '.') { - bufp++; - if (*bufp == 0) - break; /* end of message */ - } - strcat(bufp,"\n"); - - /* Check for Unix 'From' header, and add a bogus one if it's not - present -- only if not using an MDA. - XXX -- should probably parse real From: header and use its - address field instead of bogus 'POPmail' string. - */ - if (!topipe && lines == 0) { - if (strlen(bufp) >= strlen("From ")) { - savec = *(bufp + 5); - *(bufp + 5) = 0; - needFrom = strcmp(bufp,"From ") != 0; - *(bufp + 5) = savec; - } - else - needFrom = 1; - if (needFrom) { - now = time(NULL); - sprintf(fromBuf,"From POPmail %s",ctime(&now)); - if (write(mboxfd,fromBuf,strlen(fromBuf)) < 0) { - perror("POP3_readmsg: write"); - return(PS_IOERR); - } - } - } - - /* - * Edit some headers so that replies will work properly. - */ - if (inheaders && rewrite) - reply_hack(bufp, pophost); - - /* write this line to the file */ - if (write(mboxfd,bufp,strlen(bufp)) < 0) { - perror("POP3_readmsg: write"); - return(PS_IOERR); - } - - sizeticker -= strlen(bufp); - if (sizeticker <= 0) { - if (outlevel > O_SILENT && outlevel < O_VERBOSE && mboxfd != 1) - fputc('.',stderr); - sizeticker = MSGBUFSIZE; - } - lines++; - } - - if (!topipe) { - /* The server may not write the extra newline required by the Unix - mail folder format, so we write one here just in case */ - if (write(mboxfd,"\n",1) < 0) { - perror("POP3_readmsg: write"); - return(PS_IOERR); - } - } - else { - /* The mail delivery agent may require a terminator. Write it if - it has been defined */ -#ifdef BINMAIL_TERM - if (write(mboxfd,BINMAIL_TERM,strlen(BINMAIL_TERM)) < 0) { - perror("POP3_readmsg: write"); - return(PS_IOERR); - } -#endif - } - - /* finish up display output */ - if (outlevel == O_VERBOSE) - fprintf(stderr,"(%d lines of message content)\n",lines); - else if (outlevel > O_SILENT && mboxfd != 1) - fputs(".\n",stderr); - else - ; - return(0); -} - - - - /****************************************************************** function: POP3_sendLAST description: send the LAST command to the server, which should @@ -751,7 +83,7 @@ int rewrite; last integer buffer to receive last message# ret. value: zero if success, else status code. - globals: SockPrintf, POP3_OK. + globals: SockPrintf, pop3_ok. calls: reads outlevel. *****************************************************************/ @@ -766,7 +98,7 @@ int socket; if (outlevel == O_VERBOSE) fprintf(stderr,"> LAST\n"); - ok = POP3_OK(buf,socket); + ok = pop3_ok(buf,socket); if (ok == 0 && sscanf(buf,"%d",last) == 0) ok = PS_ERROR; @@ -784,7 +116,7 @@ int socket; num number of message to query (may be -1) ret. value: zero if success, else status code. - globals: SockPrintf, POP3_OK. + globals: SockPrintf, pop3_ok. calls: reads outlevel. *****************************************************************/ @@ -805,7 +137,7 @@ char **cp; if (outlevel == O_VERBOSE) fprintf(stderr,"> %s", buf); - ok = POP3_OK(buf,socket); + ok = pop3_ok(buf,socket); if (ok != 0 && outlevel > O_SILENT) fprintf(stderr,"Server says '%s' to UIDL command.\n",buf); |