#include "config.h"
#ifdef ODMR_ENABLE
#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
#ifdef HAVE_STRING_H
#include <string.h>
#endif
#ifdef HAVE_NET_SOCKET_H
#include <net/socket.h>
#endif
#include <sys/types.h>
#include <sys/time.h>
#ifdef HAVE_NET_SELECT_H
#include <net/select.h>
#endif
#ifdef HAVE_SYS_SELECT_H
#include <sys/select.h>
#endif
#include <netdb.h>
#include <errno.h>
#include <unistd.h>
#include "i18n.h"
#include "fetchmail.h"
#include "smtp.h"
#include "socket.h"
static int odmr_ok (int sock, char *argbuf)
{
int ok;
ok = SMTP_ok(sock);
if (ok == SM_UNRECOVERABLE)
return(PS_PROTOCOL);
else
return(ok);
}
static int odmr_getrange(int sock, struct query *ctl, const char *id,
int *countp, int *newp, int *bytes)
{
int ok, opts, smtp_sock;
int doing_smtp_data = 0;
char buf [MSGBUFSIZE+1];
struct idlist *qnp;
if ((ok = SMTP_ehlo(sock, fetchmailhost,
ctl->server.esmtp_name, ctl->server.esmtp_password,
&opts)))
{
report(stderr, GT_("%s's SMTP listener does not support ESMTP\n"),
ctl->server.pollname);
return(ok);
}
else if (!(opts & ESMTP_ATRN))
{
report(stderr, GT_("%s's SMTP listener does not support ATRN\n"),
ctl->server.pollname);
return(PS_PROTOCOL);
}
*bytes = *countp = *newp = -1;
ok = do_cram_md5(sock, "AUTH", ctl, "334 ");
if (ok)
return(ok);
buf[0] = '\0';
for (qnp = ctl->domainlist; qnp; qnp = qnp->next)
if (strlen(buf) + strlen(qnp->id) + 1 >= sizeof(buf))
break;
else
{
strcat(buf, qnp->id);
strcat(buf, ",");
}
buf[strlen(buf) - 1] = '\0';
gen_send(sock, "ATRN %s", buf);
if ((ok = gen_recv(sock, buf, sizeof(buf))))
return(ok);
switch(atoi(buf))
{
case 250:
if (outlevel > O_SILENT)
report(stdout, GT_("Turnaround now...\n"));
break;
case 450:
if (outlevel > O_SILENT)
report(stdout, GT_("ATRN request refused.\n"));
return(PS_PROTOCOL);
case 451:
report(stderr, GT_("Unable to process ATRN request now\n"));
return(PS_EXCLUDE);
case 453:
if (outlevel > O_SILENT)
report(stderr, GT_("You have no mail.\n"));
return(PS_NOMAIL);
case 502:
report(stderr, GT_("Command not implemented\n"));
return(PS_PROTOCOL);
case 530:
report(stderr, GT_("Authentication required.\n"));
return(PS_AUTHFAIL);
default:
report(stderr, GT_("Unknown ODMR error %d\n"), atoi(buf));
return(PS_PROTOCOL);
}
if ((smtp_sock = smtp_open(ctl)) == -1)
return(PS_SOCKET);
else
{
int maxfd = (sock > smtp_sock) ? sock : smtp_sock;
for (;;)
{
fd_set readfds;
struct timeval timeout;
char buf[MSGBUFSIZE];
FD_ZERO(&readfds);
FD_SET(sock, &readfds);
FD_SET(smtp_sock, &readfds);
timeout.tv_sec = ctl->server.timeout;
timeout.tv_usec = 0;
if (select(maxfd+1, &readfds, NULL, NULL, &timeout) == -1)
return(PS_PROTOCOL);
if (FD_ISSET(sock, &readfds))
{
int n = SockRead(sock, buf, sizeof(buf));
if (n <= 0)
break;
SockWrite(smtp_sock, buf, n);
if (outlevel >= O_MONITOR && !doing_smtp_data)
report(stdout, "ODMR< %s", buf);
}
if (FD_ISSET(smtp_sock, &readfds))
{
int n = SockRead(smtp_sock, buf, sizeof(buf));
if (n <= 0)
break;
SockWrite(sock, buf, n);
if (outlevel >= O_MONITOR)
report(stdout, "ODMR> %s", buf);
if (!doing_smtp_data && !strncmp(buf, "354", 3))
{
doing_smtp_data = 1;
report(stdout, "receiving message data\n");
}
else if (doing_smtp_data)
doing_smtp_data = 0;
}
}
SockClose(smtp_sock);
}
return(0);
}
static int odmr_logout(int sock, struct query *ctl)
{
if (ctl->smtp_socket == -1)
return(gen_transact(sock, "QUIT"));
else
return(PS_SUCCESS);
}
const static struct method odmr =
{
"ODMR",
#if INET6_ENABLE
"odmr",
"odmrs",
#else
366,
2366,
#endif
FALSE,
FALSE,
odmr_ok,
NULL,
odmr_getrange,
NULL,
NULL,
NULL,
NULL,
NULL,
NULL,
NULL,
NULL,
odmr_logout,
FALSE,
};
int doODMR (struct query *ctl)
{
int status;
if (ctl->keep) {
fprintf(stderr, GT_("Option --keep is not supported with ODMR\n"));
return(PS_SYNTAX);
}
if (ctl->flush) {
fprintf(stderr, GT_("Option --flush is not supported with ODMR\n"));
return(PS_SYNTAX);
}
if (ctl->mailboxes->id) {
fprintf(stderr, GT_("Option --remote is not supported with ODMR\n"));
return(PS_SYNTAX);
}
if (check_only) {
fprintf(stderr, GT_("Option --check is not supported with ODMR\n"));
return(PS_SYNTAX);
}
peek_capable = FALSE;
status = do_protocol(ctl, &odmr);
if (status == PS_NOMAIL)
status = PS_SUCCESS;
return(status);
}
#endif