removed some debugs
[citadel.git] / citadel / internet_addressing.c
index 6c46199732e09ffdf555c06064dddc4b1fe9a535..e67a9dc12c7a482f5e07a5a74d7c3f79a9da2e24 100644 (file)
@@ -1,17 +1,15 @@
-/*
- * This file contains functions which handle the mapping of Internet addresses
- * to users on the Citadel system.
- *
- * Copyright (c) 1987-2021 by the citadel.org team
- *
- * This program is open source software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License version 3.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
- * GNU General Public License for more details.
- */
+// This file contains functions which handle the mapping of Internet addresses
+// to users on the Citadel system.
+//
+// Copyright (c) 1987-2022 by the citadel.org team
+//
+// This program is open source software; you can redistribute it and/or modify
+// it under the terms of the GNU General Public License version 3.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU General Public License for more details.
 
 #include "sysdep.h"
 #include <stdlib.h>
@@ -44,7 +42,7 @@
 #ifdef HAVE_ICONV
 #include <iconv.h>
 
-/* This is the non-define version in case it is needed for debugging */
+// This is the non-define version in case it is needed for debugging
 #if 0
 inline void FindNextEnd (char *bptr, char *end)
 {
@@ -71,10 +69,8 @@ inline void FindNextEnd (char *bptr, char *end)
        } \
 }
 
-/*
- * Handle subjects with RFC2047 encoding such as:
- * =?koi8-r?B?78bP0s3Mxc7JxSDXz9rE1dvO2c3JINvB0sHNySDP?=
- */
+// Handle subjects with RFC2047 encoding such as:
+// =?koi8-r?B?78bP0s3Mxc7JxSDXz9rE1dvO2c3JINvB0sHNySDP?=
 void utf8ify_rfc822_string(char *buf) {
        char *start, *end, *next, *nextend, *ptr;
        char newbuf[1024];
@@ -92,12 +88,11 @@ void utf8ify_rfc822_string(char *buf) {
        int i, len, delta;
        int illegal_non_rfc2047_encoding = 0;
 
-       /* Sometimes, badly formed messages contain strings which were simply
-        * written out directly in some foreign character set instead of
-        * using RFC2047 encoding.  This is illegal but we will attempt to
-        * handle it anyway by converting from a user-specified default
-        * charset to UTF-8 if we see any nonprintable characters.
-        */
+       // Sometimes, badly formed messages contain strings which were simply
+       // written out directly in some foreign character set instead of
+       // using RFC2047 encoding.  This is illegal but we will attempt to
+       // handle it anyway by converting from a user-specified default
+       // charset to UTF-8 if we see any nonprintable characters.
        len = strlen(buf);
        for (i=0; i<len; ++i) {
                if ((buf[i] < 32) || (buf[i] > 126)) {
@@ -127,7 +122,7 @@ void utf8ify_rfc822_string(char *buf) {
                }
        }
 
-       /* pre evaluate the first pair */
+       // pre evaluate the first pair
        nextend = end = NULL;
        len = strlen(buf);
        start = strstr(buf, "=?");
@@ -141,7 +136,7 @@ void utf8ify_rfc822_string(char *buf) {
                if (nextend == NULL)
                        next = NULL;
 
-               /* did we find two partitions */
+               // did we find two partitions
                if ((next != NULL) && ((next - end) > 2)) {
                        ptr = end + 2;
                        while ((ptr < next) && 
@@ -150,24 +145,21 @@ void utf8ify_rfc822_string(char *buf) {
                                (*ptr == '\n') || 
                                (*ptr == '\t')))
                                ptr ++;
-                       /* did we find a gab just filled with blanks? */
-                       if (ptr == next)
-                       {
-                               memmove (end + 2,
-                                        next,
-                                        len - (next - start));
+                       // did we find a gab just filled with blanks?
+                       if (ptr == next) {
+                               memmove(end + 2, next, len - (next - start));
 
-                               /* now terminate the gab at the end */
+                               // now terminate the gab at the end
                                delta = (next - end) - 2;
                                len -= delta;
                                buf[len] = '\0';
 
-                               /* move next to its new location. */
+                               // move next to its new location.
                                next -= delta;
                                nextend -= delta;
                        }
                }
-               /* our next-pair is our new first pair now. */
+               // our next-pair is our new first pair now.
                start = next;
                end = nextend;
        }
@@ -240,12 +232,10 @@ void utf8ify_rfc822_string(char *buf) {
 
                free(isav);
 
-               /*
-                * Since spammers will go to all sorts of absurd lengths to get their
-                * messages through, there are LOTS of corrupt headers out there.
-                * So, prevent a really badly formed RFC2047 header from throwing
-                * this function into an infinite loop.
-                */
+               // Since spammers will go to all sorts of absurd lengths to get their
+               // messages through, there are LOTS of corrupt headers out there.
+               // So, prevent a really badly formed RFC2047 header from throwing
+               // this function into an infinite loop.
                ++passes;
                if (passes > 20) return;
 
@@ -262,9 +252,7 @@ inline void utf8ify_rfc822_string(char *a){};
 
 char *inetcfg = NULL;
 
-/*
- * Return nonzero if the supplied name is an alias for this host.
- */
+// Return nonzero if the supplied name is an alias for this host.
 int CtdlHostAlias(char *fqdn) {
        int config_lines;
        int i;
@@ -287,9 +275,8 @@ int CtdlHostAlias(char *fqdn) {
 
                found = 0;
 
-               /* Process these in a specific order, in case there are multiple matches.
-                * We want localhost to override masq, for example.
-                */
+               // Process these in a specific order, in case there are multiple matches.
+               // We want localhost to override masq, for example.
 
                if ( (!strcasecmp(type, "masqdomain")) && (!strcasecmp(fqdn, host))) {
                        found = hostalias_masq;
@@ -310,9 +297,7 @@ int CtdlHostAlias(char *fqdn) {
 }
 
 
-/*
- * Determine whether a given Internet address belongs to the current user
- */
+// Determine whether a given Internet address belongs to the current user
 int CtdlIsMe(char *addr, int addr_buf_len) {
        struct recptypes *recp;
        int i;
@@ -338,11 +323,9 @@ int CtdlIsMe(char *addr, int addr_buf_len) {
 }
 
 
-/* If the last item in a list of recipients was truncated to a partial address,
- * remove it completely in order to avoid choking library functions.
- */
-void sanitize_truncated_recipient(char *str)
-{
+// If the last item in a list of recipients was truncated to a partial address,
+// remove it completely in order to avoid choking library functions.
+void sanitize_truncated_recipient(char *str) {
        if (!str) return;
        if (num_tokens(str, ',') < 2) return;
 
@@ -362,10 +345,8 @@ void sanitize_truncated_recipient(char *str)
 }
 
 
-/*
- * This function is self explanatory.
- * (What can I say, I'm in a weird mood today...)
- */
+// This function is self explanatory.
+// (What can I say, I'm in a weird mood today...)
 void remove_any_whitespace_to_the_left_or_right_of_at_symbol(char *name) {
        char *ptr;
        if (!name) return;
@@ -387,7 +368,8 @@ enum {
        EA_ERROR,               // Can't send message due to bad address
        EA_MULTIPLE,            // Alias expanded into multiple recipients -- run me again!
        EA_LOCAL,               // Local message, do no network processing
-       EA_INTERNET             // Convert msg and send as Internet mail
+       EA_INTERNET,            // Convert msg and send as Internet mail
+       EA_SKIP                 // This recipient has been invalidated -- skip it!
 };
 
 
@@ -426,7 +408,7 @@ int expand_aliases(char *name, char *aliases) {
        remove_any_whitespace_to_the_left_or_right_of_at_symbol(name);
        stripallbut(name, '<', '>');
 
-       /* Hit the email address directory */
+       // Hit the email address directory
        if (CtdlDirectoryLookup(aaa, name, sizeof aaa) == 0) {
                strcpy(name, aaa);
        }
@@ -435,7 +417,7 @@ int expand_aliases(char *name, char *aliases) {
                syslog(LOG_INFO, "internet_addressing: directory alias <%s> to <%s>", original_name, name);
        }
 
-       /* Change "user @ xxx" to "user" if xxx is an alias for this host */
+       // Change "user @ xxx" to "user" if xxx is an alias for this host
        for (a=0; name[a] != '\0'; ++a) {
                if (name[a] == '@') {
                        if (CtdlHostAlias(&name[a+1]) == hostalias_localhost) {
@@ -446,57 +428,66 @@ int expand_aliases(char *name, char *aliases) {
                }
        }
 
-       /* Is this a local or remote recipient? */
+       // Is this a local or remote recipient?
        at = haschar(name, '@');
        if (at == 0) {
-               return(EA_LOCAL);                       /* no @'s = local address */
+               return(EA_LOCAL);                       // no @'s = local address
        }
        else if (at == 1) {
-               return(EA_INTERNET);                    /* one @ = internet address */
+               return(EA_INTERNET);                    // one @ = internet address
        }
        else {
-               return(EA_ERROR);                       /* more than one @ = badly formed address */
+               return(EA_ERROR);                       // more than one @ = badly formed address
        }
 }
 
 
 // Return a supplied list of email addresses as an array, removing superfluous information and syntax.
-Array *split_recps(char *addresses) {
+// If an existing Array is supplied as "append_to" it will do so; otherwise a new Array is allocated.
+Array *split_recps(char *addresses, Array *append_to) {
+
+       if (IsEmptyStr(addresses)) {            // nothing supplied, nothing returned
+               return(NULL);
+       }
 
-       // Copy the supplied address list into our own memory space, because we are going to mangle it.
-       char *a = malloc(strlen(addresses));
+       // Copy the supplied address list into our own memory space, because we are going to modify it.
+       char *a = strdup(addresses);
        if (a == NULL) {
                syslog(LOG_ERR, "internet_addressing: malloc() failed: %m");
                return(NULL);
        }
 
        // Strip out anything in double quotes
-       a[0] = 0;
-       int toggle = 0;
-       int pos = 0;
-       char *t;
-       for (t=addresses; t[0]; ++t) {
-               if (t[0] == '\"') {
-                       toggle = 1 - toggle;
-               }
-               else if (!toggle) {
-                       a[pos++] = t[0];
-                       a[pos] = 0;
+       char *l = NULL;
+       char *r = NULL;
+       do {
+               l = strchr(a, '\"');
+               r = strrchr(a, '\"');
+               if (r > l) {
+                       strcpy(l, r+1);
                }
-       }
+       } while (r > l);
 
        // Transform all qualifying delimiters to commas
+       char *t;
        for (t=a; t[0]; ++t) {
                if ((t[0]==';') || (t[0]=='|')) {
                        t[0]=',';
                }
        }
 
-       // Tokenize the recipients into an array
-       Array *recipients_array = array_new(256);               // no single recipient should be bigger than 256 bytes
+       // Tokenize the recipients into an array.  No single recipient should be larger than 256 bytes.
+       Array *recipients_array = NULL;
+       if (append_to) {
+               recipients_array = append_to;                   // Append to an existing array of recipients
+       }
+       else {
+               recipients_array = array_new(256);              // This is a new array of recipients
+       }
 
        int num_addresses = num_tokens(a, ',');
-       for (int i=0; i<num_addresses; ++i) {
+       int i;
+       for (i=0; i<num_addresses; ++i) {
                char this_address[256];
                extract_token(this_address, a, i, ',', sizeof this_address);
                striplt(this_address);                          // strip leading and trailing whitespace
@@ -513,7 +504,6 @@ Array *split_recps(char *addresses) {
 
 
 // Validate recipients, count delivery types and errors, and handle aliasing
-// FIXME check for dupes!!!!!
 //
 // Returns 0 if all addresses are ok, ret->num_error = -1 if no addresses 
 // were specified, or the number of addresses found invalid.
@@ -561,45 +551,35 @@ struct recptypes *validate_recipients(char *supplied_recipients, const char *Rem
        ret->display_recp[0] = 0;
        ret->recptypes_magic = RECPTYPES_MAGIC;
 
-       // char *aliases = CtdlGetSysConfig(GLOBAL_ALIASES);                            // First hit the Global Alias Table
-       // char *aliases = strdup("root|admin,ajc@citadel.org,artcancro@gmail.com\n abuse|admin\n ajc|ajc@citadel.org\n");//crashes
-       // char *aliases = strdup("root|admin,eeeeee@example.com\nabuse|admin\neek|blat\nwoiwozerosf|wow\n"); //works
-       // char *aliases = strdup("root|admin,ajc@citadel.org");        // works
-       // char *aliases = strdup("root|admin,eeeeee@example.com");     // works
-       // char *aliases = strdup("root|admin,eeeeeee@example.com");    // crashes
-       char *aliases = strdup("root|admin,ignatius.t.foobar@uncensored.citadel.org");  // crashes on the first try
-
-       Array *recp_array = split_recps(supplied_recipients);
-       int original_array_len = array_len(recp_array);
-       for (int r=0; r<array_len(recp_array); ++r) {
+       Array *recp_array = split_recps(supplied_recipients, NULL);
+
+       char *aliases = CtdlGetSysConfig(GLOBAL_ALIASES);                               // First hit the Global Alias Table
+
+       int r;
+       for (r=0; (recp_array && r<array_len(recp_array)); ++r) {
                org_recp = (char *)array_get_element_at(recp_array, r);
                strncpy(this_recp, org_recp, sizeof this_recp);
-               mailtype = expand_aliases(this_recp, aliases);
-
-               // If an alias expanded to multiple recipients, strip off those recipients and append them
-               // to the end of the array.  This loop will hit those again when it gets there.
-               // Note that we don't do this after we get past the *original* array length, to avoid aliasing loops.
-               if (mailtype == EA_MULTIPLE) {
-                       if (r < original_array_len) {
-                               char *comma;
-                               while ((comma = strrchr(this_recp, ','))) {
-                                       comma[0] = 0;
-                                       array_append(recp_array, &comma[1]);
-                                       strcpy(org_recp, this_recp);
-                               }
-                       }
-                       else {
-                               mailtype = EA_ERROR;
+
+               int i;
+               for (i=0; i<3; ++i) {                                           // pass three times through the aliaser
+                       mailtype = expand_aliases(this_recp, aliases);
+       
+                       // If an alias expanded to multiple recipients, strip off those recipients and append them
+                       // to the end of the array.  This loop will hit those again when it gets there.
+                       if (mailtype == EA_MULTIPLE) {
+                               recp_array = split_recps(this_recp, recp_array);
                        }
                }
 
-               syslog(LOG_DEBUG, "\x1b[7m%s\x1b[0m", this_recp);
-
-               mailtype = expand_aliases(this_recp, aliases);  // do it ONCE again to handle alias expansions
-               if (mailtype == EA_MULTIPLE) {
-                       mailtype = EA_ERROR;                    // and fail if it wants to expand a second time
+               // This loop searches for duplicate recipients in the final list and marks them to be skipped.
+               int j;
+               for (j=0; j<r; ++j) {
+                       if (!strcasecmp(this_recp, (char *)array_get_element_at(recp_array, j) )) {
+                               mailtype = EA_SKIP;
+                       }
                }
 
+               syslog(LOG_DEBUG, "Recipient #%d of type %d is <%s>", r, mailtype, this_recp);
                invalid = 0;
                errmsg[0] = 0;
                switch(mailtype) {
@@ -643,12 +623,12 @@ struct recptypes *validate_recipients(char *supplied_recipients, const char *Rem
                                                if (!IsEmptyStr(ret->recp_room)) {
                                                        strcat(ret->recp_room, "|");
                                                }
-                                               strcat(ret->recp_room, &this_recp[5]);
+                                               strcat(ret->recp_room, CC->room.QRname);
        
                                                if (!IsEmptyStr(ret->recp_orgroom)) {
                                                        strcat(ret->recp_orgroom, "|");
                                                }
-                                               strcat(ret->recp_orgroom, org_recp);
+                                               strcat(ret->recp_orgroom, this_recp);
        
                                        }
                                }
@@ -694,6 +674,10 @@ struct recptypes *validate_recipients(char *supplied_recipients, const char *Rem
                                strcat(ret->recp_internet, this_recp);
                        }
                        break;
+               case EA_MULTIPLE:
+               case EA_SKIP:
+                       // no action required, anything in this slot has already been processed elsewhere
+                       break;
                case EA_ERROR:
                        ++ret->num_error;
                        invalid = 1;
@@ -740,15 +724,15 @@ struct recptypes *validate_recipients(char *supplied_recipients, const char *Rem
        );
 
        free(recipients);
-       array_free(recp_array);
+       if (recp_array) {
+               array_free(recp_array);
+       }
 
        return(ret);
 }
 
 
-/*
- * Destructor for recptypes
- */
+// Destructor for recptypes
 void free_recipients(struct recptypes *valid) {
 
        if (valid == NULL) {
@@ -840,7 +824,7 @@ char *qp_encode_email_addrs(char *source) {
        for (i = 0; i < nColons; i++) {
                source[AddrPtr[i]++] = '\0';
        }
-       /* TODO: if libidn, this might get larger*/
+       // TODO: if libidn, this might get larger
        user = malloc(SourceLen + 1);
        node = malloc(SourceLen + 1);
        name = malloc(SourceLen + 1);
@@ -851,7 +835,7 @@ char *qp_encode_email_addrs(char *source) {
                nmax = EncodedMaxLen - (nPtr - Encoded);
                if (AddrUtf8[i]) {
                        process_rfc822_addr(&source[AddrPtr[i]], user, node, name);
-                       /* TODO: libIDN here ! */
+                       // TODO: libIDN here !
                        if (IsEmptyStr(name)) {
                                n = snprintf(nPtr, nmax, (i==0)?"%s@%s" : ",%s@%s", user, node);
                        }
@@ -873,7 +857,7 @@ char *qp_encode_email_addrs(char *source) {
                        nnPtr = ptr + (nPtr - Encoded), nPtr = nnPtr;
                        free(Encoded), Encoded = ptr;
                        EncodedMaxLen *= 2;
-                       i--; /* do it once more with properly lengthened buffer */
+                       i--; // do it once more with properly lengthened buffer
                }
        }
        for (i = 0; i < nColons; i++)
@@ -888,9 +872,7 @@ char *qp_encode_email_addrs(char *source) {
 }
 
 
-/*
- * Unfold a multi-line field into a single line, removing multi-whitespaces
- */
+// Unfold a multi-line field into a single line, removing multi-whitespaces
 void unfold_rfc822_field(char **field, char **FieldEnd) 
 {
        int quote = 0;
@@ -900,14 +882,14 @@ void unfold_rfc822_field(char **field, char **FieldEnd)
 
        while (isspace(*pField))
                pField++;
-       /* remove leading/trailing whitespace */
+       // remove leading/trailing whitespace
        ;
 
        while (isspace(*pFieldEnd))
                pFieldEnd --;
 
        *FieldEnd = pFieldEnd;
-       /* convert non-space whitespace to spaces, and remove double blanks */
+       // convert non-space whitespace to spaces, and remove double blanks
        for (sField = *field = pField; 
             sField < pFieldEnd; 
             pField++, sField++)
@@ -944,10 +926,10 @@ void unfold_rfc822_field(char **field, char **FieldEnd)
 }
 
 
-/*
- * Split an RFC822-style address into userid, host, and full name
- *
- */
+// Split an RFC822-style address into userid, host, and full name
+//
+// Note: This still handles obsolete address syntaxes such as user%node@node and ...node!user
+//       We should probably remove that.
 void process_rfc822_addr(const char *rfc822, char *user, char *node, char *name) {
        int a;
 
@@ -957,15 +939,15 @@ void process_rfc822_addr(const char *rfc822, char *user, char *node, char *name)
 
        if (rfc822 == NULL) return;
 
-       /* extract full name - first, it's From minus <userid> */
+       // extract full name - first, it's From minus <userid>
        strcpy(name, rfc822);
        stripout(name, '<', '>');
 
-       /* strip anything to the left of a bang */
+       // strip anything to the left of a bang
        while ((!IsEmptyStr(name)) && (haschar(name, '!') > 0))
                strcpy(name, &name[1]);
 
-       /* and anything to the right of a @ or % */
+       // and anything to the right of a @ or %
        for (a = 0; name[a] != '\0'; ++a) {
                if (name[a] == '@') {
                        name[a] = 0;
@@ -977,13 +959,13 @@ void process_rfc822_addr(const char *rfc822, char *user, char *node, char *name)
                }
        }
 
-       /* but if there are parentheses, that changes the rules... */
+       // but if there are parentheses, that changes the rules...
        if ((haschar(rfc822, '(') == 1) && (haschar(rfc822, ')') == 1)) {
                strcpy(name, rfc822);
                stripallbut(name, '(', ')');
        }
 
-       /* but if there are a set of quotes, that supersedes everything */
+       // but if there are a set of quotes, that supersedes everything
        if (haschar(rfc822, 34) == 2) {
                strcpy(name, rfc822);
                while ((!IsEmptyStr(name)) && (name[0] != 34)) {
@@ -996,22 +978,22 @@ void process_rfc822_addr(const char *rfc822, char *user, char *node, char *name)
                                break;
                        }
        }
-       /* extract user id */
+       // extract user id
        strcpy(user, rfc822);
 
-       /* first get rid of anything in parens */
+       // first get rid of anything in parens
        stripout(user, '(', ')');
 
-       /* if there's a set of angle brackets, strip it down to that */
+       // if there's a set of angle brackets, strip it down to that
        if ((haschar(user, '<') == 1) && (haschar(user, '>') == 1)) {
                stripallbut(user, '<', '>');
        }
 
-       /* strip anything to the left of a bang */
+       // strip anything to the left of a bang
        while ((!IsEmptyStr(user)) && (haschar(user, '!') > 0))
                strcpy(user, &user[1]);
 
-       /* and anything to the right of a @ or % */
+       // and anything to the right of a @ or %
        for (a = 0; user[a] != '\0'; ++a) {
                if (user[a] == '@') {
                        user[a] = 0;
@@ -1024,18 +1006,18 @@ void process_rfc822_addr(const char *rfc822, char *user, char *node, char *name)
        }
 
 
-       /* extract node name */
+       // extract node name
        strcpy(node, rfc822);
 
-       /* first get rid of anything in parens */
+       // first get rid of anything in parens
        stripout(node, '(', ')');
 
-       /* if there's a set of angle brackets, strip it down to that */
+       // if there's a set of angle brackets, strip it down to that
        if ((haschar(node, '<') == 1) && (haschar(node, '>') == 1)) {
                stripallbut(node, '<', '>');
        }
 
-       /* If no node specified, tack ours on instead */
+       // If no node specified, tack ours on instead
        if (
                (haschar(node, '@')==0)
                && (haschar(node, '%')==0)
@@ -1045,19 +1027,19 @@ void process_rfc822_addr(const char *rfc822, char *user, char *node, char *name)
        }
        else {
 
-               /* strip anything to the left of a @ */
+               // strip anything to the left of a @
                while ((!IsEmptyStr(node)) && (haschar(node, '@') > 0))
                        strcpy(node, &node[1]);
        
-               /* strip anything to the left of a % */
+               // strip anything to the left of a %
                while ((!IsEmptyStr(node)) && (haschar(node, '%') > 0))
                        strcpy(node, &node[1]);
        
-               /* reduce multiple system bang paths to node!user */
+               // reduce multiple system bang paths to node!user
                while ((!IsEmptyStr(node)) && (haschar(node, '!') > 1))
                        strcpy(node, &node[1]);
        
-               /* now get rid of the user portion of a node!user string */
+               // now get rid of the user portion of a node!user string
                for (a = 0; node[a] != '\0'; ++a)
                        if (node[a] == '!') {
                                node[a] = 0;
@@ -1065,30 +1047,27 @@ void process_rfc822_addr(const char *rfc822, char *user, char *node, char *name)
                        }
        }
 
-       /* strip leading and trailing spaces in all strings */
+       // strip leading and trailing spaces in all strings
        striplt(user);
        striplt(node);
        striplt(name);
 
-       /* If we processed a string that had the address in angle brackets
-        * but no name outside the brackets, we now have an empty name.  In
-        * this case, use the user portion of the address as the name.
-        */
+       // If we processed a string that had the address in angle brackets
+       // but no name outside the brackets, we now have an empty name.  In
+       // this case, use the user portion of the address as the name.
        if ((IsEmptyStr(name)) && (!IsEmptyStr(user))) {
                strcpy(name, user);
        }
 }
 
 
-/*
- * convert_field() is a helper function for convert_internet_message().
- * Given start/end positions for an rfc822 field, it converts it to a Citadel
- * field if it wants to, and unfolds it if necessary.
- *
- * Returns 1 if the field was converted and inserted into the Citadel message
- * structure, implying that the source field should be removed from the
- * message text.
- */
+// convert_field() is a helper function for convert_internet_message().
+// Given start/end positions for an rfc822 field, it converts it to a Citadel
+// field if it wants to, and unfolds it if necessary.
+//
+// Returns 1 if the field was converted and inserted into the Citadel message
+// structure, implying that the source field should be removed from the
+// message text.
 int convert_field(struct CtdlMessage *msg, const char *beg, const char *end) {
        char *key, *value, *valueend;
        long len;
@@ -1116,18 +1095,15 @@ int convert_field(struct CtdlMessage *msg, const char *beg, const char *end) {
        valueend = key + len;
        * ( key + (colonpos - beg) ) = '\0';
        value = &key[(colonpos - beg) + 1];
-/*     printf("Header: [%s]\nValue: [%s]\n", key, value); */
+       // printf("Header: [%s]\nValue: [%s]\n", key, value);
        unfold_rfc822_field(&value, &valueend);
        valuelen = valueend - value + 1;
-/*     printf("UnfoldedValue: [%s]\n", value); */
+       // printf("UnfoldedValue: [%s]\n", value);
 
-       /*
-        * Here's the big rfc822-to-citadel loop.
-        */
+       // Here's the big rfc822-to-citadel loop.
 
-       /* Date/time is converted into a unix timestamp.  If the conversion
-        * fails, we replace it with the time the message arrived locally.
-        */
+       // Date/time is converted into a unix timestamp.  If the conversion
+       // fails, we replace it with the time the message arrived locally.
        if (!strcasecmp(key, "Date")) {
                parsed_date = parsedate(value);
                if (parsed_date < 0L) parsed_date = time(NULL);
@@ -1184,7 +1160,7 @@ int convert_field(struct CtdlMessage *msg, const char *beg, const char *end) {
 
                        pValue = value;
                        pValueLen = valuelen;
-                       /* Strip angle brackets */
+                       // Strip angle brackets
                        while (haschar(pValue, '<') > 0) {
                                pValue ++;
                                pValueLen --;
@@ -1225,22 +1201,20 @@ int convert_field(struct CtdlMessage *msg, const char *beg, const char *end) {
        }
 
        else if (!strcasecmp(key, "In-reply-to")) {
-               if (CM_IsEmpty(msg, eWeferences)) /* References: supersedes In-reply-to: */
+               if (CM_IsEmpty(msg, eWeferences)) // References: supersedes In-reply-to:
                        CM_SetField(msg, eWeferences, value, valuelen);
                processed = 1;
        }
 
 
 
-       /* Clean up and move on. */
-       free(key);      /* Don't free 'value', it's actually the same buffer */
+       // Clean up and move on.
+       free(key);      // Don't free 'value', it's actually the same buffer
        return processed;
 }
 
 
-/*
- * Convert RFC822 references format (References) to Citadel references format (Weferences)
- */
+// Convert RFC822 references format (References) to Citadel references format (Weferences)
 void convert_references_to_wefewences(char *str) {
        int bracket_nesting = 0;
        char *ptr = str;
@@ -1273,13 +1247,11 @@ void convert_references_to_wefewences(char *str) {
 }
 
 
-/*
- * Convert an RFC822 message (headers + body) to a CtdlMessage structure.
- * NOTE: the supplied buffer becomes part of the CtdlMessage structure, and
- * will be deallocated when CM_Free() is called.  Therefore, the
- * supplied buffer should be DEREFERENCED.  It should not be freed or used
- * again.
- */
+// Convert an RFC822 message (headers + body) to a CtdlMessage structure.
+// NOTE: the supplied buffer becomes part of the CtdlMessage structure, and
+// will be deallocated when CM_Free() is called.  Therefore, the
+// supplied buffer should be DEREFERENCED.  It should not be freed or used
+// again.
 struct CtdlMessage *convert_internet_message(char *rfc822) {
        StrBuf *RFCBuf = NewStrBufPlain(rfc822, -1);
        free (rfc822);
@@ -1299,9 +1271,9 @@ struct CtdlMessage *convert_internet_message_buf(StrBuf **rfc822)
        if (msg == NULL) return msg;
 
        memset(msg, 0, sizeof(struct CtdlMessage));
-       msg->cm_magic = CTDLMESSAGE_MAGIC;      /* self check */
-       msg->cm_anon_type = 0;                  /* never anonymous */
-       msg->cm_format_type = FMT_RFC822;       /* internet message */
+       msg->cm_magic = CTDLMESSAGE_MAGIC;      // self check
+       msg->cm_anon_type = 0;                  // never anonymous
+       msg->cm_format_type = FMT_RFC822;       // internet message
 
        pos = ChrPtr(*rfc822);
        totalend = pos + StrLength(*rfc822);
@@ -1646,22 +1618,19 @@ void CtdlRebuildDirectoryIndex(void) {
 }
 
 
-/*
- * Configure Internet email addresses for a user account, updating the Directory Index in the process
- */
-void CtdlSetEmailAddressesForUser(char *requested_user, char *new_emailaddrs)
-{
+// Configure Internet email addresses for a user account, updating the Directory Index in the process
+void CtdlSetEmailAddressesForUser(char *requested_user, char *new_emailaddrs) {
        struct ctdluser usbuf;
        int i;
        char buf[SIZ];
 
-       if (CtdlGetUserLock(&usbuf, requested_user) != 0) {     // We are relying on the fact that the DirectoryIndex functions don't lock.
-               return;                                         // Silently fail here if we can't acquire a lock on the user record.
+       if (CtdlGetUserLock(&usbuf, requested_user) != 0) {     // We can lock because the DirectoryIndex functions don't lock.
+               return;                                         // Silently fail here if the specified user does not exist.
        }
 
        syslog(LOG_DEBUG, "internet_addressing: setting email addresses for <%s> to <%s>", usbuf.fullname, new_emailaddrs);
 
-       /* Delete all of the existing directory index records for the user (easier this way) */
+       // Delete all of the existing directory index records for the user (easier this way)
        for (i=0; i<num_tokens(usbuf.emailaddrs, '|'); ++i) {
                extract_token(buf, usbuf.emailaddrs, i, '|', sizeof buf);
                CtdlDirectoryDelUser(buf, requested_user);
@@ -1669,7 +1638,7 @@ void CtdlSetEmailAddressesForUser(char *requested_user, char *new_emailaddrs)
 
        strcpy(usbuf.emailaddrs, new_emailaddrs);               // make it official.
 
-       /* Index all of the new email addresses (they've already been sanitized) */
+       // Index all of the new email addresses (they've already been sanitized)
        for (i=0; i<num_tokens(usbuf.emailaddrs, '|'); ++i) {
                extract_token(buf, usbuf.emailaddrs, i, '|', sizeof buf);
                CtdlDirectoryAddUser(buf, requested_user);
@@ -1682,8 +1651,7 @@ void CtdlSetEmailAddressesForUser(char *requested_user, char *new_emailaddrs)
 /*
  * Auto-generate an Internet email address for a user account
  */
-void AutoGenerateEmailAddressForUser(struct ctdluser *user)
-{
+void AutoGenerateEmailAddressForUser(struct ctdluser *user) {
        char synthetic_email_addr[1024];
        int i, j;
        int u = 0;
@@ -1715,3 +1683,39 @@ void AutoGenerateEmailAddressForUser(struct ctdluser *user)
        strncpy(CC->user.emailaddrs, synthetic_email_addr, sizeof(user->emailaddrs));
        syslog(LOG_DEBUG, "user_ops: auto-generated email address <%s> for <%s>", synthetic_email_addr, user->fullname);
 }
+
+
+// Determine whether the supplied email address is subscribed to the supplied room's mailing list service.
+int is_email_subscribed_to_list(char *email, char *room_name) {
+       struct ctdlroom room;
+       long roomnum;
+       char *roomnetconfig;
+       int found_it = 0;
+
+       if (CtdlGetRoom(&room, room_name)) {
+               return(0);                                      // room not found, so definitely not subscribed
+       }
+
+       // If this room has the QR2_SMTP_PUBLIC flag set, anyone may email a post to this room, even non-subscribers.
+       if (room.QRflags2 & QR2_SMTP_PUBLIC) {
+               return(1);
+       }
+
+       roomnum = room.QRnumber;
+       roomnetconfig = LoadRoomNetConfigFile(roomnum);
+       if (roomnetconfig == NULL) {
+               return(0);
+       }
+
+       // We're going to do a very sloppy match here and simply search for the specified email address
+       // anywhere in the room's netconfig.  If you don't like this, fix it yourself.
+       if (bmstrcasestr(roomnetconfig, email)) {
+               found_it = 1;
+       }
+       else {
+               found_it = 0;
+       }
+
+       free(roomnetconfig);
+       return(found_it);
+}