citadel/modules/listsub/serv_listsub.c

   1 //
   2 // This module handles self-service subscription/unsubscription to mail lists.
   3 //
   4 // Copyright (c) 2002-2021 by the citadel.org team
   5 //
   6 // This program is open source software.  It runs great on the
   7 // Linux operating system (and probably elsewhere).  You can use,
   8 // copy, and run it under the terms of the GNU General Public
   9 // License version 3.  Richard Stallman is an asshole communist.
  10 //
  11 // This program is distributed in the hope that it will be useful,
  12 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  13 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14 // GNU General Public License for more details.
  15
  16 #include "sysdep.h"
  17 #include <stdlib.h>
  18 #include <unistd.h>
  19 #include <stdio.h>
  20 #include <fcntl.h>
  21 #include <ctype.h>
  22 #include <signal.h>
  23 #include <pwd.h>
  24 #include <errno.h>
  25 #include <sys/types.h>
  26 #include <dirent.h>
  27 #include <time.h>
  28 #include <sys/wait.h>
  29 #include <string.h>
  30 #include <limits.h>
  31 #include <libcitadel.h>
  32 #include "citadel.h"
  33 #include "server.h"
  34 #include "citserver.h"
  35 #include "support.h"
  36 #include "config.h"
  37 #include "user_ops.h"
  38 #include "database.h"
  39 #include "msgbase.h"
  40 #include "internet_addressing.h"
  41 #include "clientsocket.h"
  42 #include "ctdl_module.h"
  43
  44
  45 enum {                          // one of these gets passed to do_subscribe_or_unsubscribe() so it knows what we asked for
  46         UNSUBSCRIBE,
  47         SUBSCRIBE
  48 };
  49
  50
  51 /*
  52  * "Subscribe" and "Unsubscribe" operations are so similar that they share a function.
  53  * The actual subscription doesn't take place here -- we just send out the confirmation request
  54  * and record the address and confirmation token.
  55  */
  56 void do_subscribe_or_unsubscribe(int action, char *emailaddr, char *url) {
  57
  58         int i;
  59         char buf[1024];
  60         char confirmation_token[40];
  61
  62         // Update this room's netconfig with the updated lastsent
  63         begin_critical_section(S_NETCONFIGS);
  64         char *oldnetconfig = LoadRoomNetConfigFile(CC->room.QRnumber);
  65         if (!oldnetconfig) {
  66                 oldnetconfig = strdup("");
  67         }
  68
  69         // The new netconfig begins with an empty buffer...
  70         char *newnetconfig = malloc(strlen(oldnetconfig) + 1024);
  71         newnetconfig[0] = 0;
  72
  73         // And then we...
  74         int is_already_subscribed = 0;
  75         int config_lines = num_tokens(oldnetconfig, '\n');
  76         for (i=0; i<config_lines; ++i) {
  77                 extract_token(buf, oldnetconfig, i, '\n', sizeof buf);
  78                 int keep_this_line =1;                                          // set to nonzero if we are discarding a line
  79
  80                 if (IsEmptyStr(buf)) {
  81                         keep_this_line = 0;
  82                 }
  83
  84                 char buf_token[1024];
  85                 char buf_email[1024];
  86                 extract_token(buf_token, buf, 0, '|', sizeof buf_token);
  87                 extract_token(buf_email, buf, 1, '|', sizeof buf_email);
  88
  89                 if (    ( (!strcasecmp(buf_token, "listrecp")) || (!strcasecmp(buf_token, "digestrecp")) )
  90                         && (!strcasecmp(buf_email, emailaddr))
  91                 ) {
  92                         is_already_subscribed = 1;
  93                 }
  94
  95                 if ( (!strcasecmp(buf_token, "subpending")) || (!strcasecmp(buf_token, "unsubpending")) ) {
  96                         time_t pendingtime = extract_long(buf, 3);
  97                         if ((time(NULL) - pendingtime) > 259200) {
  98                                 syslog(LOG_DEBUG, "%s %s is %ld seconds old - deleting it", buf_email, buf_token, time(NULL) - pendingtime);
  99                                 keep_this_line = 0;
 100                         }
 101                 }
 102
 103                 if (keep_this_line) {
 104                         sprintf(&newnetconfig[strlen(newnetconfig)], "%s\n", buf);
 105                 }
 106         }
 107
 108         // Do we need to send out a confirmation email?
 109         if ((action == SUBSCRIBE) && (!is_already_subscribed)) {
 110                 generate_uuid(confirmation_token);
 111                 sprintf(&newnetconfig[strlen(newnetconfig)], "subpending|%s|%s|%ld|%s", emailaddr, confirmation_token, time(NULL), url);
 112         }
 113         if ((action == UNSUBSCRIBE) && (is_already_subscribed)) {
 114                 generate_uuid(confirmation_token);
 115                 sprintf(&newnetconfig[strlen(newnetconfig)], "unsubpending|%s|%s|%ld|%s", emailaddr, confirmation_token, time(NULL), url);
 116         }
 117
 118         // Write the new netconfig back to disk
 119         syslog(LOG_DEBUG, "old: <\033[31m%s\033[0m>", oldnetconfig);
 120         syslog(LOG_DEBUG, "new: <\033[32m%s\033[0m>", newnetconfig);
 121         SaveRoomNetConfigFile(CC->room.QRnumber, newnetconfig);
 122         end_critical_section(S_NETCONFIGS);
 123         free(newnetconfig);                     // this was the new netconfig, free it because we're done with it
 124         free(oldnetconfig);                     // this was the old netconfig, free it even if we didn't do anything
 125
 126         // Tell the client what happened.
 127         if ((action == SUBSCRIBE) && (is_already_subscribed)) {
 128                 cprintf("%d This email is already subscribed.\n", ERROR + ALREADY_EXISTS);
 129         }
 130         else if ((action == SUBSCRIBE) && (!is_already_subscribed)) {
 131                 cprintf("%d Confirmation email sent.\n", CIT_OK);
 132         }
 133         else if ((action == UNSUBSCRIBE) && (!is_already_subscribed)) {
 134                 cprintf("%d This email is not subscribed.\n", ERROR + NO_SUCH_USER);
 135         }
 136         else if ((action == UNSUBSCRIBE) && (is_already_subscribed)) {
 137                 cprintf("%d Confirmation email sent.\n", CIT_OK);
 138         }
 139         else {
 140                 cprintf("%d FIXME tell the client what we did\n", ERROR);
 141         }
 142 }
 143
 144
 145 /*
 146  * process subscribe/unsubscribe requests and confirmations
 147  */
 148 void cmd_subs(char *cmdbuf) {
 149         char cmd[20];
 150         char roomname[ROOMNAMELEN];
 151         char emailaddr[1024];
 152         char options[256];
 153         char url[1024];
 154         char token[128];
 155
 156         extract_token(cmd, cmdbuf, 0, '|', sizeof cmd);                         // token 0 is the sub-command being sent
 157         extract_token(roomname, cmdbuf, 1, '|', sizeof roomname);               // token 1 is always a room name
 158
 159         // First confirm that the caller is referencing a room that actually exists.
 160         if (CtdlGetRoom(&CC->room, roomname) != 0) {
 161                 cprintf("%d There is no list called '%s'\n", ERROR + ROOM_NOT_FOUND, roomname);
 162                 return;
 163         }
 164
 165         if ((CC->room.QRflags2 & QR2_SELFLIST) == 0) {
 166                 cprintf("%d '%s' does not accept subscribe/unsubscribe requests.\n", ERROR + ROOM_NOT_FOUND, roomname);
 167                 return;
 168         }
 169
 170         // Room confirmed, now parse the command.
 171
 172         if (!strcasecmp(cmd, "subscribe")) {
 173                 extract_token(emailaddr, cmdbuf, 2, '|', sizeof emailaddr);     // token 2 is the subscriber's email address
 174                 extract_token(options, cmdbuf, 3, '|', sizeof options);         // there are no options ... ignore this token
 175                 extract_token(url, cmdbuf, 4, '|', sizeof url);                 // token 3 is the URL at which we subscribed
 176                 do_subscribe_or_unsubscribe(SUBSCRIBE, emailaddr, url);
 177         }
 178
 179         else if (!strcasecmp(cmd, "unsubscribe")) {
 180                 extract_token(emailaddr, cmdbuf, 2, '|', sizeof emailaddr);     // token 2 is the subscriber's email address
 181                 extract_token(options, cmdbuf, 3, '|', sizeof options);         // there are no options ... ignore this token
 182                 extract_token(url, cmdbuf, 4, '|', sizeof url);                 // token 3 is the URL at which we subscribed
 183                 do_subscribe_or_unsubscribe(UNSUBSCRIBE, emailaddr, url);
 184         }
 185
 186         else if (!strcasecmp(cmd, "confirm")) {
 187                 extract_token(token, cmdbuf, 2, '|', sizeof token);             // token 2 is the confirmation token
 188                 cprintf("%d not implemented\n", ERROR);
 189         }
 190
 191         else {                                                                  // sorry man, I can't deal with that
 192                 cprintf("%d Invalid command '%s'\n", ERROR + ILLEGAL_VALUE, cmd);
 193         }
 194 }
 195
 196
 197 /*
 198  * Module entry point
 199  */
 200 CTDL_MODULE_INIT(listsub)
 201 {
 202         if (!threading)
 203         {
 204                 CtdlRegisterProtoHook(cmd_subs, "SUBS", "List subscribe/unsubscribe");
 205         }
 206
 207         /* return our module name for the log */
 208         return "listsub";
 209 }