]> Pileus Git - ~andy/fetchmail/blobdiff - fetchmail.c
Added plugin/plugout option.
[~andy/fetchmail] / fetchmail.c
index b738cf9d3e4ec10214c131115865a9f6b1b2c74b..ef40f0b9db2fad63813ad56650e5f5936474ddee 100644 (file)
@@ -50,19 +50,19 @@ static void dump_params (struct runctl *runp, struct query *, flag implicit);
 static int query_host(struct query *);
 
 /* controls the detail level of status/progress messages written to stderr */
-int outlevel;          /* see the O_.* constants above */
+int outlevel;              /* see the O_.* constants above */
 
 /* miscellaneous global controls */
-struct runctl run;     /* global controls for this run */
-flag nodetach;         /* if TRUE, don't detach daemon process */
-flag quitmode;         /* if --quit was set */
-flag check_only;       /* if --probe was set */
-flag versioninfo;      /* emit only version info */
-char *user;            /* the name of the invoking user */
-char *home;            /* invoking user's home directory */
-char *program_name;    /* the name to prefix error messages with */
-flag configdump;       /* dump control blocks for configurator */
-char *fetchmailhost;   /* either `localhost' or the host FQDN */
+struct runctl run;         /* global controls for this run */
+flag nodetach;             /* if TRUE, don't detach daemon process */
+flag quitmode;             /* if --quit was set */
+flag check_only;           /* if --probe was set */
+flag versioninfo;          /* emit only version info */
+char *user;                /* the name of the invoking user */
+char *home;                /* invoking user's home directory */
+char *program_name;        /* the name to prefix error messages with */
+flag configdump;           /* dump control blocks for configurator */
+const char *fetchmailhost;  /* either `localhost' or the host's FQDN */
 
 #if NET_SECURITY
 void *request = NULL;
@@ -75,7 +75,7 @@ static int successes;         /* count number of successful polls */
 static int lastsig;            /* last signal received */
 static struct runctl cmd_run;  /* global options set from command line */
 
-static void termhook();                /* forward declaration of exit hook */
+static void termhook(int);             /* forward declaration of exit hook */
 
 #if 0
 #define SLEEP_WITH_ALARM
@@ -107,7 +107,7 @@ int sig;
 }
 #endif /* SLEEP_WITH_ALARM */
 
-RETSIGTYPE donothing(sig) int sig; {signal(sig, donothing); lastsig = sig;}
+RETSIGTYPE donothing(int sig) {signal(sig, donothing); lastsig = sig;}
 
 #ifdef HAVE_ON_EXIT
 static void unlockit(int n, void *p)
@@ -367,6 +367,9 @@ int main (int argc, char **argv)
 
     /* pick up interactively any passwords we need but don't have */ 
     for (ctl = querylist; ctl; ctl = ctl->next)
+    {
+       ctl->authfailcount = 0;
+
        if (ctl->active && !(implicitmode && ctl->server.skip)&&!ctl->password)
        {
            if (ctl->server.preauthenticate == A_KERBEROS_V4 ||
@@ -406,6 +409,7 @@ int main (int argc, char **argv)
 #undef PASSWORD_PROMPT
            }
        }
+    }
 
     /*
      * Maybe time to go to demon mode...
@@ -481,6 +485,13 @@ int main (int argc, char **argv)
        batchcount = 0;
        for (ctl = querylist; ctl; ctl = ctl->next)
        {
+           if (ctl->authfailcount)
+           {
+               error(0, -1, 
+                     "poll of %s skipped until authentication is unwedged",
+                     ctl->server.pollname);
+               continue;
+           }
            if (ctl->active && !(implicitmode && ctl->server.skip))
            {
                /* check skip interval first so that it counts all polls */
@@ -489,8 +500,8 @@ int main (int argc, char **argv)
                    if (ctl->server.poll_count++ % ctl->server.interval) 
                    {
                        if (outlevel >= O_VERBOSE)
-                           fprintf(stderr,
-                                   "fetchmail: interval not reached, not querying %s\n",
+                           error(0, -1,
+                                   "interval not reached, not querying %s",
                                    ctl->server.pollname);
                        continue;
                    }
@@ -521,11 +532,6 @@ int main (int argc, char **argv)
                    }
 #endif  /* POP3_ENABLE */
                }
-               else if (querystatus == PS_AUTHFAIL) {
-                   /* have it logged with priority LOG_ALERT */
-                   error(querystatus, -1, "Authentication failed for %s@%s",
-                               ctl->remotename, visbuf(ctl->server.pollname));
-               }
                else if (!check_only && 
                         ((querystatus!=PS_NOMAIL) || (outlevel==O_DEBUG)))
                    error(0, 0, "Query status=%d", querystatus);
@@ -570,14 +576,27 @@ int main (int argc, char **argv)
         */
        if (run.poll_interval)
        {
-           if (outlevel >= O_VERBOSE)
-           {
-               time_t  now;
+           /* 
+            * Because passwords can expire, it may happen that *all*
+            * hosts are now out of the loop due to authfail
+            * conditions.  If this happens daemon-mode fetchmail
+            * should softly and silently vanish away, rather than
+            * spinning uselessly.
+            */
+           int auth_ok = 0;
 
-               time(&now);
-               fprintf(stderr, "fetchmail: sleeping at %s", ctime(&now));
+           for (ctl = querylist; ctl; ctl = ctl->next)
+               if (!ctl->authfailcount)
+                   auth_ok++;
+           if (!auth_ok)
+           {
+               error(0, -1, "All authentications have failed.  Exiting.");
+               exit(PS_AUTHFAIL);
            }
 
+           if (outlevel >= O_VERBOSE)
+               error(0, -1, "fetchmail: sleeping at %s", rfc822timestamp());
+
            /*
             * With this simple hack, we make it possible for a foreground 
             * fetchmail to wake up one in daemon mode.  What we want is the
@@ -683,18 +702,13 @@ int main (int argc, char **argv)
                signal(SIGHUP, SIG_IGN);
 
            if (outlevel >= O_VERBOSE)
-           {
-               time_t  now;
-
-               time(&now);
-               fprintf(stderr, "fetchmail: awakened at %s", ctime(&now));
-           }
+               error(0, -1, "awakened at %s", rfc822timestamp());
        }
     } while
        (run.poll_interval);
 
     if (outlevel >= O_VERBOSE)
-       fprintf(stderr,"fetchmail: normal termination, status %d\n",
+       error(0, -1, "normal termination, status %d",
                successes ? PS_SUCCESS : querystatus);
 
     termhook(0);
@@ -745,10 +759,13 @@ static void optmerge(struct query *h2, struct query *h1, int force)
     FLAG_MERGE(server.interface_pair);
 #endif /* linux */
 
+    FLAG_MERGE(server.plugin);
+    FLAG_MERGE(server.plugout);
     FLAG_MERGE(wildcard);
     FLAG_MERGE(remotename);
     FLAG_MERGE(password);
     FLAG_MERGE(mda);
+    FLAG_MERGE(bsmtp);
     FLAG_MERGE(smtpaddress);
     FLAG_MERGE(preconnect);
     FLAG_MERGE(postconnect);
@@ -814,6 +831,9 @@ static int load_params(int argc, char **argv, int optind)
                if (!strcmp(ctl->server.pollname, argv[optind])
                        || str_in_list(&ctl->server.akalist, argv[optind], TRUE))
                {
+                   /* Is this correct? */
+                   if(predeclared)
+                       fprintf(stderr,"Warning: multiple mentions of host %s in config file\n",argv[optind]);
                    ctl->active = TRUE;
                    predeclared = TRUE;
                }
@@ -862,6 +882,27 @@ static int load_params(int argc, char **argv, int optind)
            /* force command-line options */
            optmerge(ctl, &cmd_opts, TRUE);
 
+           /* this code enables flags to be turned off */
+#define DEFAULT(flag, dflt)    if (flag == FLAG_TRUE)\
+                                       flag = TRUE;\
+                               else if (flag == FLAG_FALSE)\
+                                       flag = FALSE;\
+                               else\
+                                       flag = (dflt)
+           DEFAULT(ctl->keep, FALSE);
+           DEFAULT(ctl->fetchall, FALSE);
+           DEFAULT(ctl->flush, FALSE);
+           DEFAULT(ctl->rewrite, TRUE);
+           DEFAULT(ctl->stripcr, (ctl->mda != (char *)NULL)); 
+           DEFAULT(ctl->forcecr, FALSE);
+           DEFAULT(ctl->pass8bits, FALSE);
+           DEFAULT(ctl->dropstatus, FALSE);
+           DEFAULT(ctl->mimedecode, FALSE);
+           DEFAULT(ctl->server.dns, TRUE);
+           DEFAULT(ctl->server.uidl, FALSE);
+           DEFAULT(ctl->server.checkalias, FALSE);
+#undef DEFAULT
+
            /*
             * DNS support is required for some protocols.
             *
@@ -873,9 +914,9 @@ static int load_params(int argc, char **argv, int optind)
             * If we're using Kerberos for authentication, we need 
             * the FQDN in order to generate capability keys.
             */
-           if ((ctl->server.protocol == P_ETRN
+           if (ctl->server.protocol == P_ETRN
                         || ctl->server.preauthenticate == A_KERBEROS_V4
-                        || ctl->server.preauthenticate == A_KERBEROS_V5))
+                        || ctl->server.preauthenticate == A_KERBEROS_V5)
                if (strcmp(fetchmailhost, "localhost") == 0)
                        fetchmailhost = host_fqdn();
 
@@ -893,27 +934,6 @@ static int load_params(int argc, char **argv, int optind)
            if (!ctl->localnames)       /* for local delivery via SMTP */
                save_str_pair(&ctl->localnames, user, NULL);
 
-           /* this code enables flags to be turned off */
-#define DEFAULT(flag, dflt)    if (flag == FLAG_TRUE)\
-                                       flag = TRUE;\
-                               else if (flag == FLAG_FALSE)\
-                                       flag = FALSE;\
-                               else\
-                                       flag = (dflt)
-           DEFAULT(ctl->keep, FALSE);
-           DEFAULT(ctl->fetchall, FALSE);
-           DEFAULT(ctl->flush, FALSE);
-           DEFAULT(ctl->rewrite, TRUE);
-           DEFAULT(ctl->stripcr, (ctl->mda != (char *)NULL)); 
-           DEFAULT(ctl->forcecr, FALSE);
-           DEFAULT(ctl->pass8bits, FALSE);
-           DEFAULT(ctl->dropstatus, FALSE);
-           DEFAULT(ctl->mimedecode, FALSE);
-           DEFAULT(ctl->server.dns, TRUE);
-           DEFAULT(ctl->server.uidl, FALSE);
-           DEFAULT(ctl->server.checkalias, FALSE);
-#undef DEFAULT
-
 #if !defined(HAVE_GETHOSTBYNAME) || !defined(HAVE_RES_SEARCH)
            /* can't handle multidrop mailboxes unless we can do DNS lookups */
            if (ctl->localnames && ctl->localnames->next && ctl->server.dns)
@@ -1116,7 +1136,7 @@ static int query_host(struct query *ctl)
        time_t now;
 
        time(&now);
-       fprintf(stderr, "fetchmail: %s querying %s (protocol %s) at %s",
+       error(0, -1, "fetchmail: %s querying %s (protocol %s) at %s",
            RELEASE_ID,
            ctl->server.pollname, showproto(ctl->server.protocol), ctime(&now));
     }
@@ -1135,7 +1155,7 @@ static int query_host(struct query *ctl)
 #ifdef POP2_ENABLE
        return(doPOP2(ctl));
 #else
-       fprintf(stderr, "POP2 support is not configured.\n");
+       error(0, -1, "POP2 support is not configured.\n");
        return(PS_PROTOCOL);
 #endif /* POP2_ENABLE */
        break;
@@ -1145,7 +1165,7 @@ static int query_host(struct query *ctl)
 #ifdef POP3_ENABLE
        return(doPOP3(ctl));
 #else
-       fprintf(stderr, "POP3 support is not configured.\n");
+       error(0, -1, "POP3 support is not configured.\n");
        return(PS_PROTOCOL);
 #endif /* POP3_ENABLE */
        break;
@@ -1157,19 +1177,19 @@ static int query_host(struct query *ctl)
 #ifdef IMAP_ENABLE
        return(doIMAP(ctl));
 #else
-       fprintf(stderr, "IMAP support is not configured.\n");
+       error(0, -1, "IMAP support is not configured.\n");
        return(PS_PROTOCOL);
 #endif /* IMAP_ENABLE */
        break;
     case P_ETRN:
 #ifndef ETRN_ENABLE
-       fprintf(stderr, "ETRN support is not configured.\n");
+       error(0, -1, "ETRN support is not configured.\n");
        return(PS_PROTOCOL);
 #else
 #ifdef HAVE_GETHOSTBYNAME
        return(doETRN(ctl));
 #else
-       fprintf(stderr, "Cannot support ETRN without gethostbyname(2).\n");
+       error(0, -1, "Cannot support ETRN without gethostbyname(2).\n");
        return(PS_PROTOCOL);
 #endif /* HAVE_GETHOSTBYNAME */
 #endif /* ETRN_ENABLE */
@@ -1244,7 +1264,8 @@ void dump_params (struct runctl *runp, struct query *querylist, flag implicit)
 #endif /* INET6 */
            && (ctl->server.preauthenticate == A_KERBEROS_V4 ||
                ctl->server.preauthenticate == A_KERBEROS_V5))
-           printf("  Protocol is KPOP");
+           printf("  Protocol is KPOP with Kerberos %s authentication",
+                  ctl->server.preauthenticate == A_KERBEROS_V5 ? "V" : "IV");
        else
            printf("  Protocol is %s", showproto(ctl->server.protocol));
 #if INET6
@@ -1340,7 +1361,9 @@ void dump_params (struct runctl *runp, struct query *querylist, flag implicit)
                    else if (outlevel >= O_VERBOSE)
                        printf("  No expunges (--expunge 0).\n");
        }
-       if (ctl->mda && (ctl->server.protocol != P_ETRN))
+       if (ctl->bsmtp)
+           printf("  Messages will be appended to %s as BSMTP\n", visbuf(ctl->bsmtp));
+       else if (ctl->mda && (ctl->server.protocol != P_ETRN))
            printf("  Messages will be delivered with \"%s\".\n", visbuf(ctl->mda));
        else
        {
@@ -1364,8 +1387,7 @@ void dump_params (struct runctl *runp, struct query *querylist, flag implicit)
                {
                    struct idlist *idp;
 
-                   printf("  Recognized listener spam block responses are:",
-                          ctl->antispam);
+                   printf("  Recognized listener spam block responses are:");
                    for (idp = ctl->antispam; idp; idp = idp->next)
                        printf(" %d", idp->val.status.num);
                    printf("\n");
@@ -1471,6 +1493,15 @@ void dump_params (struct runctl *runp, struct query *querylist, flag implicit)
            printf("  No monitor interface specified.\n");
 #endif
 
+       if (ctl->server.plugin)
+           printf("  Server connections will be mode via plugin %s (--plugin %s).\n", ctl->server.plugin, ctl->server.plugin);
+       else if (outlevel >= O_VERBOSE)
+           printf("  No plugin command specified.\n");
+       if (ctl->server.plugout)
+           printf("  Listener connections will be mode via plugout %s (--plugout %s).\n", ctl->server.plugout, ctl->server.plugout);
+       else if (outlevel >= O_VERBOSE)
+           printf("  No plugout command specified.\n");
+
        if (ctl->server.protocol > P_POP2 && (ctl->server.protocol != P_ETRN))
            if (!ctl->oldsaved)
                printf("  No UIDs saved from this host.\n");
@@ -1485,7 +1516,7 @@ void dump_params (struct runctl *runp, struct query *querylist, flag implicit)
                printf("  %d UIDs saved.\n", count);
                if (outlevel >= O_VERBOSE)
                    for (idp = ctl->oldsaved; idp; idp = idp->next)
-                       fprintf(stderr, "\t%s\n", idp->id);
+                       printf("\t%s\n", idp->id);
            }
 
        if (ctl->properties)