]> code.citadel.org Git - citadel.git/blobdiff - citadel/internet_addressing.c
* Renamed CtdlLocalHost() to CtdlHostAlias() and worked it a little deeper into
[citadel.git] / citadel / internet_addressing.c
index 043909343b9f130c7b994b987597b7ddff9ea538..ed19a0cc02f8294c33b1d1491e2ca5a1ca746ae6 100644 (file)
 #include "tools.h"
 #include "internet_addressing.h"
 #include "user_ops.h"
+#include "room_ops.h"
+#include "parsedate.h"
+
+
+struct trynamebuf {
+       char buffer1[256];
+       char buffer2[256];
+};
+
+char *inetcfg = NULL;
+
+
+
+/*
+ * Return nonzero if the supplied name is an alias for this host.
+ */
+int CtdlHostAlias(char *fqdn) {
+       int config_lines;
+       int i;
+       char buf[256];
+       char host[256], type[256];
+
+       if (!strcasecmp(fqdn, config.c_fqdn)) return(hostalias_localhost);
+       if (inetcfg == NULL) return(hostalias_nomatch);
+
+       config_lines = num_tokens(inetcfg, '\n');
+       for (i=0; i<config_lines; ++i) {
+               extract_token(buf, inetcfg, i, '\n');
+               extract_token(host, buf, 0, '|');
+               extract_token(type, buf, 1, '|');
+
+               if ( (!strcasecmp(type, "localhost"))
+                  && (!strcasecmp(fqdn, host)))
+                       return(hostalias_localhost);
+
+               if ( (!strcasecmp(type, "gatewaydomain"))
+                  && (!strcasecmp(&fqdn[strlen(fqdn)-strlen(host)], host)))
+                       return(hostalias_gatewaydomain);
+
+       }
+
+       return(hostalias_nomatch);
+}
+
+
+
+
+
 
 
 /*
  * Return 0 if a given string fuzzy-matches a Citadel user account
  *
- * FIX ... this needs to be updated to match any and all address syntaxes.
+ * FIX ... this needs to be updated to handle aliases.
  */
 int fuzzy_match(struct usersupp *us, char *matchstring) {
        int a;
 
+       if ( (!strncasecmp(matchstring, "cit", 3)) 
+          && (atol(&matchstring[3]) == us->usernum)) {
+               return 0;
+       }
+
+
        for (a=0; a<strlen(us->fullname); ++a) {
                if (!strncasecmp(&us->fullname[a],
                   matchstring, strlen(matchstring))) {
@@ -215,22 +269,23 @@ void process_rfc822_addr(char *rfc822, char *user, char *node, char *name)
  * Back end for convert_internet_address()
  * (Compares an internet name [buffer1] and stores in [buffer2] if found)
  */
-void try_name(struct usersupp *us) {
+void try_name(struct usersupp *us, void *data) {
+       struct trynamebuf *tnb;
+       tnb = (struct trynamebuf *)data;
        
-       if (!strncasecmp(CC->buffer1, "cit", 3))
-               if (atol(&CC->buffer1[3]) == us->usernum)
-                       strcpy(CC->buffer2, us->fullname);
+       if (!strncasecmp(tnb->buffer1, "cit", 3))
+               if (atol(&tnb->buffer1[3]) == us->usernum)
+                       strcpy(tnb->buffer2, us->fullname);
 
-       if (!collapsed_strcmp(CC->buffer1, us->fullname)) 
-                       strcpy(CC->buffer2, us->fullname);
+       if (!collapsed_strcmp(tnb->buffer1, us->fullname)) 
+                       strcpy(tnb->buffer2, us->fullname);
 
        if (us->uid != BBSUID)
-               if (!strcasecmp(CC->buffer1, getpwuid(us->uid)->pw_name))
-                       strcpy(CC->buffer2, us->fullname);
+               if (!strcasecmp(tnb->buffer1, getpwuid(us->uid)->pw_name))
+                       strcpy(tnb->buffer2, us->fullname);
 }
 
 
-
 /*
  * Convert an Internet email address to a Citadel user/host combination
  */
@@ -239,39 +294,57 @@ int convert_internet_address(char *destuser, char *desthost, char *source)
        char user[256];
        char node[256];
        char name[256];
+       struct quickroom qrbuf;
+       int i;
+       int hostalias;
+       struct trynamebuf tnb;
+       char buf[256];
 
        /* Split it up */
        process_rfc822_addr(source, user, node, name);
 
        /* Map the FQDN to a Citadel node name
-        * FIX ... we have to check for all known aliases for the local
-        *         system, and also handle gateway domains, etc. etc.
         */
-       if (!strcasecmp(node, config.c_fqdn)) {
-               strcpy(node, config.c_nodename);
+       hostalias =  CtdlHostAlias(node);
+       switch(hostalias) {
+               case hostalias_localhost:
+                       strcpy(node, config.c_nodename);
+                       break;
+
+               case hostalias_gatewaydomain:
+                       extract_token(buf, node, 0, '.');
+                       safestrncpy(node, buf, sizeof buf);
        }
 
-       /* Return an error condition if the node is not known.
-        * FIX ... make this work for non-local systems
-        */
-       if (strcasecmp(node, config.c_nodename)) {
-               return(rfc822_address_invalid);
-       }
-       
        /* Now try to resolve the name
         * FIX ... do the multiple-addresses thing
         */
        if (!strcasecmp(node, config.c_nodename)) {
+               /* Try all local rooms */
+               if (!strncasecmp(user, "room_", 5)) {
+                       strcpy(name, &user[5]);
+                       for (i=0; i<strlen(name); ++i) 
+                               if (name[i]=='_') name[i]=' ';
+                       if (getroom(&qrbuf, name) == 0) {
+                               strcpy(destuser, qrbuf.QRname);
+                               strcpy(desthost, config.c_nodename);
+                               return rfc822_room_delivery;
+                       }
+               }
+
+               /* Try all local users */
                strcpy(destuser, user);
                strcpy(desthost, config.c_nodename);
-               strcpy(CC->buffer1, user);
-               strcpy(CC->buffer2, "");
-               ForEachUser(try_name);
-               if (strlen(CC->buffer2) == 0) return(rfc822_no_such_user);
-               strcpy(destuser, CC->buffer2);
+               strcpy(tnb.buffer1, user);
+               strcpy(tnb.buffer2, "");
+               ForEachUser(try_name, &tnb);
+               if (strlen(tnb.buffer2) == 0) return(rfc822_no_such_user);
+               strcpy(destuser, tnb.buffer2);
                return(rfc822_address_locally_validated);
        }
 
+       strcpy(destuser, user);
+       strcpy(desthost, node);
        return(rfc822_address_invalid); /* unknown error */
 }
 
@@ -281,29 +354,75 @@ int convert_internet_address(char *destuser, char *desthost, char *source)
 /*
  * 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
+ * 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.
  */
-void convert_field(struct CtdlMessage *msg, int beg, int end) {
+int convert_field(struct CtdlMessage *msg, int beg, int end) {
        char *rfc822;
-       char *fieldbuf;
-       char field[256];
+       char *key, *value;
        int i;
+       int colonpos = (-1);
+       int processed = 0;
+       char buf[256];
+       char *user, *node, *name;
 
        rfc822 = msg->cm_fields['M'];   /* M field contains rfc822 text */
-       strcpy(field, "");
-       for (i = beg; i <= end; ++i) {
-               if ((rfc822[i] == ':') && ((i-beg)<sizeof(field))) {
-                       if (strlen(field)==0) {
-                          safestrncpy(field, &rfc822[beg], i-beg+1);
-                       }
-               }
+       for (i = end; i >= beg; --i) {
+               if (rfc822[i] == ':') colonpos = i;
+       }
+
+       if (colonpos < 0) return(0);    /* no colon? not a valid header line */
+
+       key = mallok((end - beg) + 2);
+       safestrncpy(key, &rfc822[beg], (end-beg)+1);
+       key[colonpos - beg] = 0;
+       value = &key[(colonpos - beg) + 1];
+       unfold_rfc822_field(value);
+
+       lprintf(9, "Key=<%s> Value=<%s>\n", key, value);
+
+       /* Here's the big rfc822-to-citadel loop. */
+
+       if (!strcasecmp(key, "Date")) {
+               sprintf(buf, "%ld", parsedate(value) );
+               if (msg->cm_fields['T'] == NULL)
+                       msg->cm_fields['T'] = strdoop(buf);
+               processed = 1;
+       }
+
+       else if (!strcasecmp(key, "From")) {
+               user = mallok(1024);
+               node = mallok(1024);
+               name = mallok(1024);
+               process_rfc822_addr(value, user, node, name);
+               lprintf(9, "Converted to <%s@%s> (%s)\n", user, node, name);
+               if (msg->cm_fields['A'] == NULL)
+                       msg->cm_fields['A'] = user;
+               else
+                       phree(user);
+               if (msg->cm_fields['N'] == NULL)
+                       msg->cm_fields['N'] = node;
+               else
+                       phree(node);
+               if (msg->cm_fields['H'] == NULL)
+                       msg->cm_fields['H'] = name;
+               else
+                       phree(name);
+               processed = 1;
        }
 
-       fieldbuf = mallok(end - beg + 2);
-       safestrncpy(fieldbuf, &rfc822[beg], end-beg+1);
-       unfold_rfc822_field(fieldbuf);
-       lprintf(9, "Field: key=<%s> value=<%s>\n", field, fieldbuf);
-       phree(fieldbuf);
+       else if (!strcasecmp(key, "Subject")) {
+               if (msg->cm_fields['U'] == NULL)
+                       msg->cm_fields['U'] = strdoop(value);
+               processed = 1;
+       }
+
+       /* Clean up and move on. */
+       phree(key);     /* Don't free 'value', it's actually the same buffer */
+       return(processed);
 }
 
 
@@ -314,9 +433,9 @@ struct CtdlMessage *convert_internet_message(char *rfc822) {
 
        struct CtdlMessage *msg;
        int pos, beg, end;
-       int msglen;
        int done;
        char buf[256];
+       int converted;
 
        msg = mallok(sizeof(struct CtdlMessage));
        if (msg == NULL) return msg;
@@ -324,11 +443,10 @@ struct CtdlMessage *convert_internet_message(char *rfc822) {
        memset(msg, 0, sizeof(struct CtdlMessage));
        msg->cm_magic = CTDLMESSAGE_MAGIC;      /* self check */
        msg->cm_anon_type = 0;                  /* never anonymous */
-       msg->cm_format_type = 4;                /* always MIME */
+       msg->cm_format_type = FMT_RFC822;       /* internet message */
        msg->cm_fields['M'] = rfc822;
 
-       /* FIX   there's plenty to do here. */
-       msglen = strlen(rfc822);
+       lprintf(9, "Unconverted RFC822 message length = %d\n", strlen(rfc822));
        pos = 0;
        done = 0;
 
@@ -354,13 +472,19 @@ struct CtdlMessage *convert_internet_message(char *rfc822) {
                }
 
                /* At this point we have a field.  Are we interested in it? */
-               convert_field(msg, beg, end);
+               converted = convert_field(msg, beg, end);
+
+               /******
+               if (converted) {
+                       strcpy(&rfc822[beg], &rfc822[pos]);
+                       pos = beg;
+               }
+               ********/
 
                /* If we've hit the end of the message, bail out */
                if (pos > strlen(rfc822)) done = 1;
        }
 
-
        /* Follow-up sanity checks... */
 
        /* If there's no timestamp on this message, set it to now. */
@@ -369,5 +493,8 @@ struct CtdlMessage *convert_internet_message(char *rfc822) {
                msg->cm_fields['T'] = strdoop(buf);
        }
 
+       lprintf(9, "RFC822 length remaining after conversion = %d\n",
+               strlen(rfc822));
        return msg;
 }
+