citadel/modules/extnotify/extnotify_main.c

   1 /*
   2  * \file extnotify_main.c
   3  * @author Mathew McBride
   4  *
   5  * This module implements an external pager hook for when notifcation
   6  * of a new email is wanted.
   7  * Based on bits of serv_funambol
   8  * Contact: <matt@mcbridematt.dhs.org> / <matt@comalies>
   9  */
  10
  11 #include "sysdep.h"
  12 #include <stdlib.h>
  13 #include <unistd.h>
  14 #include <stdio.h>
  15 #include <fcntl.h>
  16 #include <signal.h>
  17 #include <pwd.h>
  18 #include <errno.h>
  19 #include <sys/types.h>
  20
  21 #if TIME_WITH_SYS_TIME
  22 # include <sys/time.h>
  23 # include <time.h>
  24 #else
  25 # if HAVE_SYS_TIME_H
  26 #  include <sys/time.h>
  27 # else
  28 #  include <time.h>
  29 # endif
  30 #endif
  31
  32 #include <sys/wait.h>
  33 #include <string.h>
  34 #include <limits.h>
  35 #include <sys/socket.h>
  36 #include <libcitadel.h>
  37 #include "citadel.h"
  38 #include "server.h"
  39 #include "citserver.h"
  40 #include "support.h"
  41 #include "config.h"
  42 #include "control.h"
  43 #include "room_ops.h"
  44 #include "user_ops.h"
  45 #include "policy.h"
  46 #include "database.h"
  47 #include "msgbase.h"
  48 #include "internet_addressing.h"
  49 #include "domain.h"
  50 #include "clientsocket.h"
  51 #include "extnotify.h"
  52
  53 #include "ctdl_module.h"
  54
  55 /*! \brief Create the notify message queue. We use the exact same room
  56  *                      as the Funambol module.
  57  *
  58  *      Run at server startup, creates FNBL_QUEUE_ROOM if it doesn't exist
  59  *      and sets as system room.
  60  */
  61 void create_extnotify_queue(void) {
  62     struct ctdlroom qrbuf;
  63
  64     create_room(FNBL_QUEUE_ROOM, 3, "", 0, 1, 0, VIEW_MAILBOX);
  65
  66     /*
  67      * Make sure it's set to be a "system room" so it doesn't show up
  68      * in the <K>nown rooms list for Aides.
  69      */
  70     if (lgetroom(&qrbuf, FNBL_QUEUE_ROOM) == 0) {
  71         qrbuf.QRflags2 |= QR2_SYSTEM;
  72         lputroom(&qrbuf);
  73     }
  74 }
  75 /*!
  76  * \brief Run through the pager room queue
  77  */
  78 void do_extnotify_queue(void) {
  79     static int doing_queue = 0;
  80
  81     /*
  82      * This is a simple concurrency check to make sure only one queue run
  83      * is done at a time.  We could do this with a mutex, but since we
  84      * don't really require extremely fine granularity here, we'll do it
  85      * with a static variable instead.
  86      */
  87     if (doing_queue) return;
  88     doing_queue = 1;
  89
  90     /*
  91      * Go ahead and run the queue
  92      */
  93     CtdlLogPrintf(CTDL_DEBUG, "serv_extnotify: processing notify queue\n");
  94
  95     if (getroom(&CC->room, FNBL_QUEUE_ROOM) != 0) {
  96         CtdlLogPrintf(CTDL_ERR, "Cannot find room <%s>\n", FNBL_QUEUE_ROOM);
  97         return;
  98     }
  99     CtdlForEachMessage(MSGS_ALL, 0L, NULL,
 100             SPOOLMIME, NULL, process_notify, NULL);
 101
 102     CtdlLogPrintf(CTDL_DEBUG, "serv_extnotify: queue run completed\n");
 103     doing_queue = 0;
 104 }
 105 /*!
 106  * \brief Process messages in the external notification queue
 107  */
 108 void process_notify(long msgnum, void *usrdata) {
 109     struct CtdlMessage *msg;
 110     msg = CtdlFetchMessage(msgnum, 1);
 111     if ( msg->cm_fields['W'] == NULL) {
 112         goto nuke;
 113     }
 114
 115     long configMsgNum = extNotify_getConfigMessage(msg->cm_fields['W']);
 116     char configMsg[SIZ];
 117
 118     extNotify_getPrefs(configMsgNum, &configMsg[0]);
 119
 120     /* Check to see if:
 121      * 1. The user has configured paging / They have and disabled it
 122      * AND 2. There is an external pager program
 123      * 3. A Funambol server has been entered
 124      *
 125      */
 126     if ((configMsgNum == -1) ||
 127         ((strncasecmp(configMsg, "none", 4) == 0) &&
 128          IsEmptyStr(config.c_pager_program) &&
 129          IsEmptyStr(config.c_funambol_host))) {
 130         CtdlLogPrintf(CTDL_DEBUG, "No external notifiers configured on system/user");
 131         goto nuke;
 132     }
 133     // Can Funambol take the message?
 134     int fnblAllowed = strncasecmp(configMsg, HKEY(FUNAMBOL_CONFIG_TEXT));
 135     int extPagerAllowedHttp = strncasecmp(configMsg, HKEY(PAGER_CONFIG_HTTP));
 136     int extPagerAllowedSystem = strncasecmp(configMsg, HKEY(PAGER_CONFIG_SYSTEM));
 137     if (fnblAllowed == 0) {
 138             char remoteurl[SIZ];
 139             snprintf(remoteurl, SIZ, "http://%s@%s:%d/%s",
 140                      config.c_funambol_auth,
 141                      config.c_funambol_host,
 142                      config.c_funambol_port,
 143                      FUNAMBOL_WS);
 144             notify_http_server(remoteurl,
 145                                file_funambol_msg,
 146                                strlen(file_funambol_msg),/*GNA*/
 147                                msg->cm_fields['W'],
 148                                    msg->cm_fields['I'],
 149                                    msgnum);
 150     } else if (extPagerAllowedHttp) {
 151 /*
 152             notify_http_server(remoteurl,
 153                                file_funambol_msg,
 154                                strlen(file_funambol_msg),/ *GNA* /
 155                                msg->cm_fields['W'],
 156                                    msg->cm_fields['I'],
 157                                    msgnum);
 158 */
 159     } else if (extPagerAllowedSystem == 0) {
 160             char *number = strtok(configMsg, "textmessage\n");
 161             int commandSiz = sizeof(config.c_pager_program) + strlen(number) + strlen(msg->cm_fields['W']) + 5;
 162             char *command = malloc(commandSiz);
 163             snprintf(command, commandSiz, "%s %s -u %s", config.c_pager_program, number, msg->cm_fields['W']);
 164             system(command);
 165             free(command);
 166     }
 167 nuke:
 168     CtdlFreeMessage(msg);
 169     memset(configMsg, 0, sizeof(configMsg));
 170     long todelete[1];
 171     todelete[0] = msgnum;
 172     CtdlDeleteMessages(FNBL_QUEUE_ROOM, todelete, 1, "");
 173 }
 174
 175 /*! \brief Checks to see what notification option the user has set
 176  *
 177  */
 178 void extNotify_getPrefs(long configMsgNum, char *configMsg) {
 179     // Do a simple string search to see if 'funambol' is selected as the
 180     // type. This string would be at the very top of the message contents.
 181     if (configMsgNum == -1) {
 182         CtdlLogPrintf(CTDL_ERR, "extNotify_isAllowedByPrefs was passed a non-existant config message id\n");
 183         return;
 184     }
 185     struct CtdlMessage *prefMsg;
 186     prefMsg = CtdlFetchMessage(configMsgNum, 1);
 187     strncpy(configMsg, prefMsg->cm_fields['M'], strlen(prefMsg->cm_fields['M']));
 188     CtdlFreeMessage(prefMsg);
 189 }
 190 /*! \brief Get configuration message for pager/funambol system from the
 191  *                      users "My Citadel Config" room
 192  */
 193 long extNotify_getConfigMessage(char *username) {
 194     struct ctdlroom qrbuf; // scratch for room
 195     struct ctdluser user; // ctdl user instance
 196     char configRoomName[ROOMNAMELEN];
 197     struct CtdlMessage *msg;
 198     struct cdbdata *cdbfr;
 199     long *msglist = NULL;
 200     int num_msgs = 0;
 201     long confMsgNum = -1;
 202     // Get the user
 203     getuser(&user, username);
 204
 205     MailboxName(configRoomName, sizeof configRoomName, &user, USERCONFIGROOM);
 206     // Fill qrbuf
 207     getroom(&qrbuf, configRoomName);
 208     /* Do something really, really stoopid here. Raid the room on ourselves,
 209      * loop through the messages manually and find it. I don't want
 210      * to use a CtdlForEachMessage callback here, as we would be
 211      * already in one */
 212     cdbfr = cdb_fetch(CDB_MSGLISTS, &qrbuf.QRnumber, sizeof(long));
 213     if (cdbfr != NULL) {
 214         msglist = (long *) cdbfr->ptr;
 215         cdbfr->ptr = NULL;      /* CtdlForEachMessage() now owns this memory */
 216         num_msgs = cdbfr->len / sizeof(long);
 217         cdb_free(cdbfr);
 218     } else {
 219         CtdlLogPrintf(CTDL_DEBUG, "extNotify_getConfigMessage: No config messages found\n");
 220         return -1;      /* No messages at all?  No further action. */
 221     }
 222     int a;
 223     for (a = 0; a < num_msgs; ++a) {
 224         msg = CtdlFetchMessage(msglist[a], 1);
 225         if (msg != NULL) {
 226             if (msg->cm_fields['U'] != NULL && strncasecmp(msg->cm_fields['U'], PAGER_CONFIG_MESSAGE,
 227                     strlen(PAGER_CONFIG_MESSAGE)) == 0) {
 228                 confMsgNum = msglist[a];
 229             }
 230             CtdlFreeMessage(msg);
 231         }
 232     }
 233     return confMsgNum;
 234
 235 }
 236 CTDL_MODULE_INIT(extnotify)
 237 {
 238         if (!threading)
 239         {
 240                 create_extnotify_queue();
 241                 CtdlRegisterSessionHook(do_extnotify_queue, EVT_TIMER);
 242         }
 243         /* return our Subversion id for the Log */
 244         return "$Id$";
 245 }