Maybe ... it works? Sort of! Needs more testing, and for me to finish

OAuth support.

diff --git a/h/prototypes.h b/h/prototypes.h
index cb47ca6a8f7e42d116fad78e98e6758fb20d33ae..c9dd291e986eedfd26a145e574e121e043365857 100644 (file)
--- a/h/prototypes.h
+++ b/h/prototypes.h
@@ -474,8 +474,8 @@ int WhatNow(int, char **);
  */
 int writeBase64aux(FILE *in, FILE *out, int crlf);
 
  */
 int writeBase64aux(FILE *in, FILE *out, int crlf);
 

-int writeBase64 (unsigned char *, size_t, unsigned char *);
-int writeBase64raw (unsigned char *, size_t, unsigned char *);
+int writeBase64 (const unsigned char *, size_t, unsigned char *);
+int writeBase64raw (const unsigned char *, size_t, unsigned char *);

 
 /*
  * first argument:  the string to be decoded
 
 /*
  * first argument:  the string to be decoded

diff --git a/sbr/base64.c b/sbr/base64.c
index eb3c8ea2de79f6c0b34733359c535c9cb343476e..f1fec4edf46b24df6fc4e6dc4aa43a3d6a1f179f 100644 (file)
--- a/sbr/base64.c
+++ b/sbr/base64.c
@@ -113,7 +113,7 @@ writeBase64aux (FILE *in, FILE *out, int crlf)
      4 * [length/3]  +  length/57  +  2
    But double the length will certainly be sufficient. */
 int
      4 * [length/3]  +  length/57  +  2
    But double the length will certainly be sufficient. */
 int

-writeBase64 (unsigned char *in, size_t length, unsigned char *out)
+writeBase64 (const unsigned char *in, size_t length, unsigned char *out)

 {
     unsigned int n = BPERLIN;
 
 {
     unsigned int n = BPERLIN;
 


@@ -121,7 +121,7 @@ writeBase64 (unsigned char *in, size_t length, unsigned char *out)
        unsigned long bits;
        unsigned char *bp;
        unsigned int cc;
        unsigned long bits;
        unsigned char *bp;
        unsigned int cc;

-       for (cc = 0, bp = in; length > 0 && cc < 3; ++cc, ++bp, --length)
+       for (cc = 0; length > 0 && cc < 3; ++cc, --length)

           /* empty */ ;
 
        if (cc == 0) {
           /* empty */ ;
 
        if (cc == 0) {


@@ -168,13 +168,13 @@ writeBase64 (unsigned char *in, size_t length, unsigned char *out)
  */
 
 int
  */
 
 int

-writeBase64raw (unsigned char *in, size_t length, unsigned char *out)
+writeBase64raw (const unsigned char *in, size_t length, unsigned char *out)

 {
     while (1) {
        unsigned long bits;
        unsigned char *bp;
        unsigned int cc;
 {
     while (1) {
        unsigned long bits;
        unsigned char *bp;
        unsigned int cc;

-       for (cc = 0, bp = in; length > 0 && cc < 3; ++cc, ++bp, --length)
+       for (cc = 0; length > 0 && cc < 3; ++cc, --length)

           /* empty */ ;
 
        if (cc == 0) {
           /* empty */ ;
 
        if (cc == 0) {

diff --git a/sbr/netsec.c b/sbr/netsec.c
index 5bfbea60ccc7b4d0f9f303b025eb2c8a1b2c951c..abdcaee85008cac7eb5c26cb0c9f242ae461c97d 100644 (file)
--- a/sbr/netsec.c
+++ b/sbr/netsec.c
@@ -1008,7 +1008,7 @@ netsec_negotiate_sasl(netsec_context *nsc, const char *mechlist, char **errstr)
     }
 
 #ifdef OAUTH_SUPPORT
     }
 
 #ifdef OAUTH_SUPPORT

-    if (strcasecmp(nsc->sasl_mech, "XOAUTH2") == 0) {
+    if (nsc->sasl_mech && strcasecmp(nsc->sasl_mech, "XOAUTH2") == 0) {

        /*
         * This should be relatively straightforward, but requires some
         * help from the plugin.  Basically, if XOAUTH2 is a success,
        /*
         * This should be relatively straightforward, but requires some
         * help from the plugin.  Basically, if XOAUTH2 is a success,

diff --git a/uip/msgchk.c b/uip/msgchk.c
index 3c78217b5d6af767102e84c1ee4c9a639d0f7bcf..3a650bc6633dd40176180824d96e8db1d5a80e8b 100644 (file)
--- a/uip/msgchk.c
+++ b/uip/msgchk.c
@@ -350,7 +350,7 @@ remotemail (char *host, char *port, char *user, char *proxy, int notifysw,
 
     /* open the POP connection */
     if (pop_init (host, port, creds.user, creds.password, proxy, snoop, sasl,
 
     /* open the POP connection */
     if (pop_init (host, port, creds.user, creds.password, proxy, snoop, sasl,

-                 0, saslmech, auth_svc) == NOTOK
+                 saslmech, 0, auth_svc) == NOTOK

            || pop_stat (&nmsgs, &nbytes) == NOTOK     /* check for messages  */
            || pop_quit () == NOTOK) {                 /* quit POP connection */
        advise (NULL, "%s", response);
            || pop_stat (&nmsgs, &nbytes) == NOTOK     /* check for messages  */
            || pop_quit () == NOTOK) {                 /* quit POP connection */
        advise (NULL, "%s", response);

diff --git a/uip/popsbr.c b/uip/popsbr.c
index 7126b95002f59ee2b3c87287e03b7a17091de430..884fea4f1861f7bb2c51fa543c66ce7dd64c43e4 100644 (file)
--- a/uip/popsbr.c
+++ b/uip/popsbr.c
@@ -33,8 +33,10 @@ static int multiline(void);
 static int traverse (int (*)(char *), const char *, ...);
 static int vcommand(const char *, va_list);
 static int pop_getline (char *, int, netsec_context *);
 static int traverse (int (*)(char *), const char *, ...);
 static int vcommand(const char *, va_list);
 static int pop_getline (char *, int, netsec_context *);

+#if 0

 static int sasl_fgetc(FILE *);
 static int putline (char *, FILE *);
 static int sasl_fgetc(FILE *);
 static int putline (char *, FILE *);

+#endif

 static int pop_sasl_callback(enum sasl_message_type, unsigned const char *,
                             unsigned int, unsigned char **, unsigned int *,
                             char **);
 static int pop_sasl_callback(enum sasl_message_type, unsigned const char *,
                             unsigned int, unsigned char **, unsigned int *,
                             char **);


@@ -87,7 +89,7 @@ check_mech(char *server_mechs, size_t server_mechs_size)
     return OK;
 }
 
     return OK;
 }
 

-#ifdef CYRUS_SASL
+#if 0

 /*
  * This function implements the AUTH command for various SASL mechanisms
  *
 /*
  * This function implements the AUTH command for various SASL mechanisms
  *


@@ -103,7 +105,6 @@ check_mech(char *server_mechs, size_t server_mechs_size)
       } \
     }
 
       } \
     }
 

-#if 0

 int
 pop_auth_sasl(char *user, char *host, char *mech)
 {
 int
 pop_auth_sasl(char *user, char *host, char *mech)
 {


@@ -117,7 +118,7 @@ pop_auth_sasl(char *user, char *host, char *mech)
     sasl_ssf_t *ssf;
     int *moutbuf;
 
     sasl_ssf_t *ssf;
     int *moutbuf;
 

-    if ((status = check_mech(server_mechs, sizeof(server_mechs), mech)) != OK) {
+    if ((status = check_mech(server_mechs, sizeof(server_mechs))) != OK) {

        return status;
     }
 
        return status;
     }
 


@@ -564,7 +565,7 @@ pop_init (char *host, char *port, char *user, char *pass, char *proxy,
            if (*response == '+') {
                if (sasl) {
                    char server_mechs[256];
            if (*response == '+') {
                if (sasl) {
                    char server_mechs[256];

-                   if (check_mech(server_mechs, sizeof(server_mechs) != OK))
+                   if (check_mech(server_mechs, sizeof(server_mechs)) != OK)

                        return NOTOK;
                    if (netsec_negotiate_sasl(nsc, server_mechs,
                                              &errstr) != OK) {
                        return NOTOK;
                    if (netsec_negotiate_sasl(nsc, server_mechs,
                                              &errstr) != OK) {


@@ -606,8 +607,8 @@ pop_init (char *host, char *port, char *user, char *pass, char *proxy,
 
 static int
 pop_sasl_callback(enum sasl_message_type mtype, unsigned const char *indata,
 
 static int
 pop_sasl_callback(enum sasl_message_type mtype, unsigned const char *indata,

-                 unsigned int indatasize, unsigned char **outdata,
-                 unsigned int *outdatasize, char **errstr)
+                 unsigned int indatalen, unsigned char **outdata,
+                 unsigned int *outdatalen, char **errstr)

 {
     int rc;
     char *mech, *line;
 {
     int rc;
     char *mech, *line;


@@ -627,10 +628,10 @@ pop_sasl_callback(enum sasl_message_type mtype, unsigned const char *indata,
 
        mech = netsec_get_sasl_mechanism(nsc);
 
 
        mech = netsec_get_sasl_mechanism(nsc);
 

-       if (indatasize) {
+       if (indatalen) {

            char *b64data;
            char *b64data;

-           b64data = mh_xmalloc(BASE64SIZE(indatasize));
-           writeBase64raw(indata, indatasize, line);
+           b64data = mh_xmalloc(BASE64SIZE(indatalen));
+           writeBase64raw(indata, indatalen, (unsigned char *) b64data);

            b64len = strlen(b64data);
 
            /* Formula here is AUTH + SP + mech + SP + out + CR + LF */
            b64len = strlen(b64data);
 
            /* Formula here is AUTH + SP + mech + SP + out + CR + LF */


@@ -675,6 +676,8 @@ pop_sasl_callback(enum sasl_message_type mtype, unsigned const char *indata,
                return NOTOK;
        }
 
                return NOTOK;
        }
 

+       *outdatalen = 0;
+

        break;
 
        /*
        break;
 
        /*


@@ -686,7 +689,7 @@ pop_sasl_callback(enum sasl_message_type mtype, unsigned const char *indata,
 
        if (line == NULL)
            return NOTOK;
 
        if (line == NULL)
            return NOTOK;

-       if (len < 2 || (len == 2 && strcmp(line, "+ ") != 0) {
+       if (len < 2 || (len == 2 && strcmp(line, "+ ") != 0)) {

            netsec_err(errstr, "Invalid format for SASL response");
            return NOTOK;
        }
            netsec_err(errstr, "Invalid format for SASL response");
            return NOTOK;
        }


@@ -695,12 +698,62 @@ pop_sasl_callback(enum sasl_message_type mtype, unsigned const char *indata,
            *outdata = NULL;
            *outdatalen = 0;
        } else {
            *outdata = NULL;
            *outdatalen = 0;
        } else {

-           rc = decodeBase64(line + 2, &outdata, &outdatasize, 0, NULL);
+           rc = decodeBase64(line + 2, (const char **) outdata, &len, 0, NULL);
+           *outdatalen = len;

            if (rc != OK)
                return NOTOK;
        }
        break;
 
            if (rc != OK)
                return NOTOK;
        }
        break;
 

+    /*
+     * Our encoding is pretty simple, so this is easy.
+     */
+
+    case NETSEC_SASL_WRITE:
+       if (indatalen == 0) {
+           *outdata = (unsigned char *) getcpy("\r\n");
+           *outdatalen = strlen((char *) *outdata);
+       } else {
+           unsigned char *b64data;
+           b64data = mh_xmalloc(BASE64SIZE(indatalen) + 3);
+           writeBase64raw(indata, indatalen, b64data);
+           len = strlen((char *) b64data);
+           b64data[len++] = '\r';
+           b64data[len++] = '\n';
+           b64data[len++] = '\0';
+           *outdata = b64data;
+           *outdatalen = len - 1;
+       }
+
+       return OK;
+       break;
+
+    /*
+     * Finish the protocol; we're looking for an +OK
+     */
+
+    case NETSEC_SASL_FINISH:
+       line = netsec_readline(nsc, &len, errstr);
+       if (line == NULL)
+           return NOTOK;
+
+       if (strncmp(line, "+OK", 3) != 0) {
+           netsec_err(errstr, "Authentication failed: %s", line);
+           return NOTOK;
+       }
+       break;
+
+    /*
+     * Cancel the SASL exchange in the middle of the commands; for
+     * POP, that's a single "*".
+     */
+
+    case NETSEC_SASL_CANCEL:
+       *outdata = (unsigned char *) getcpy("*\r\n");
+       *outdatalen = strlen((char *) *outdata);
+       break;
+    }
+

     return OK;
 }
 
     return OK;
 }
 


@@ -880,8 +933,31 @@ command(const char *fmt, ...)
 static int
 vcommand (const char *fmt, va_list ap)
 {
 static int
 vcommand (const char *fmt, va_list ap)
 {

-    char *cp, buffer[65536];
+    /* char *cp; */
+    char *errstr;
+
+    if (netsec_vprintf(nsc, &errstr, fmt, ap) != OK) {
+       strncpy(response, errstr, sizeof(response));
+       response[sizeof(response) - 1] = '\0';
+       free(errstr);
+       return NOTOK;
+    }

 
 

+    if (netsec_printf(nsc, &errstr, "\r\n") != OK) {
+       strncpy(response, errstr, sizeof(response));
+       response[sizeof(response) - 1] = '\0';
+       free(errstr);
+       return NOTOK;
+    }
+
+    if (netsec_flush(nsc, &errstr) != OK) {
+       strncpy(response, errstr, sizeof(response));
+       response[sizeof(response) - 1] = '\0';
+       free(errstr);
+       return NOTOK;
+    }
+
+#if 0

     vsnprintf (buffer, sizeof(buffer), fmt, ap);
 
     if (poprint) {
     vsnprintf (buffer, sizeof(buffer), fmt, ap);
 
     if (poprint) {


@@ -897,13 +973,14 @@ vcommand (const char *fmt, va_list ap)
            fprintf (stderr, "---> %s\n", buffer);
     }
 
            fprintf (stderr, "---> %s\n", buffer);
     }
 

-    if (putline (buffer, output) == NOTOK)
+    if (netsec_printf(nsc, "%s\r\n"buffer, output) == NOTOK)

        return NOTOK;
 
 #ifdef CYRUS_SASL
     if (poprint && sasl_ssf)
        fprintf(stderr, "(decrypted) ");
 #endif /* CYRUS_SASL */
        return NOTOK;
 
 #ifdef CYRUS_SASL
     if (poprint && sasl_ssf)
        fprintf(stderr, "(decrypted) ");
 #endif /* CYRUS_SASL */

+#endif

 
     switch (pop_getline (response, sizeof response, nsc)) {
        case OK: 
 
     switch (pop_getline (response, sizeof response, nsc)) {
        case OK: 


@@ -957,10 +1034,10 @@ multiline (void)
 static int
 pop_getline (char *s, int n, netsec_context *ns)
 {
 static int
 pop_getline (char *s, int n, netsec_context *ns)
 {

-    int c = -2;
+    /* int c = -2; */

     char *p;
     size_t len, destlen;
     char *p;
     size_t len, destlen;

-    int rc;
+    /* int rc; */

     char *errstr;
 
     p = netsec_readline(ns, &len, &errstr);
     char *errstr;
 
     p = netsec_readline(ns, &len, &errstr);


@@ -983,7 +1060,7 @@ pop_getline (char *s, int n, netsec_context *ns)
      * someday.
      */
 
      * someday.
      */
 

-    destlen = len > n - 1 ? len : n - 1;
+    destlen = len < ((size_t) (n - 1)) ? len : n - 1;

 
     memcpy(s, p, destlen);
     s[destlen] = '\0';
 
     memcpy(s, p, destlen);
     s[destlen] = '\0';


@@ -992,6 +1069,7 @@ pop_getline (char *s, int n, netsec_context *ns)
 }
 
 
 }
 
 

+#if 0

 static int
 putline (char *s, FILE *iop)
 {
 static int
 putline (char *s, FILE *iop)
 {


@@ -1051,7 +1129,9 @@ putline (char *s, FILE *iop)
 
     return OK;
 }
 
     return OK;
 }

+#endif 

 
 

+#if 0

 #ifdef CYRUS_SASL
 /*
  * Okay, our little fgetc replacement.  Hopefully this is a little more
 #ifdef CYRUS_SASL
 /*
  * Okay, our little fgetc replacement.  Hopefully this is a little more


@@ -1084,6 +1164,7 @@ sasl_fgetc(FILE *f)
 
 #ifdef TLS_SUPPORT
        if (tls_active) {
 
 #ifdef TLS_SUPPORT
        if (tls_active) {

+#endif

 
        cc = read(fileno(f), tmpbuf, sizeof(tmpbuf));
 
 
        cc = read(fileno(f), tmpbuf, sizeof(tmpbuf));
 


@@ -1131,3 +1212,4 @@ sasl_fgetc(FILE *f)
     return (int) buffer[0];
 }
 #endif /* CYRUS_SASL */
     return (int) buffer[0];
 }
 #endif /* CYRUS_SASL */

+#endif