answerscripts.c

   1 //#define __WIN32__
   2 #ifndef __WIN32__
   3         #define ANSWERSCRIPT_EXT ""
   4 #else
   5         #define ANSWERSCRIPT_EXT ".exe"
   6 #endif
   7 #define ANSWERSCRIPT "answerscripts" ANSWERSCRIPT_EXT
   8 #define ANSWERSCRIPTS_TIMEOUT_INTERVAL 250
   9 #define ANSWERSCRIPTS_LINE_LENGTH 4096
  10 #define ENV_PREFIX "ANSW_"
  11 #define PROTOCOL_PREFIX "prpl-"
  12
  13 #include <stdio.h>
  14 #include <stdlib.h>
  15 #include <errno.h>
  16 #include <string.h>
  17
  18 #ifndef __WIN32__
  19         #include <fcntl.h>
  20 #endif
  21
  22 /* Purple plugin */
  23 #define PURPLE_PLUGINS
  24 #include <libpurple/debug.h>
  25 #include <libpurple/version.h>
  26 #include <libpurple/conversation.h>
  27 #include <libpurple/plugin.h>
  28 #include <libpurple/signals.h>
  29 #include <libpurple/util.h>
  30
  31 char *message = NULL;
  32 char *hook_script = NULL;
  33 char response[ANSWERSCRIPTS_LINE_LENGTH+1];
  34 int i;
  35
  36 typedef struct {
  37   FILE *pipe;
  38   PurpleConversation *conv;
  39 } answerscripts_job;
  40
  41 int answerscripts_process_message_cb(answerscripts_job *job) {
  42         FILE *pipe = job->pipe;
  43         PurpleConversation *conv = job->conv;
  44
  45         if (pipe && !feof(pipe)) {
  46                 if(!fgets(response, ANSWERSCRIPTS_LINE_LENGTH, pipe)
  47                         && (errno == EWOULDBLOCK || errno == EAGAIN)
  48                 ) return 1;
  49
  50                 for(i=0;response[i];i++) if(response[i]=='\n') response[i]=0;
  51                 purple_conv_im_send(purple_conversation_get_im_data(conv), response);
  52
  53                 if(!feof(pipe)) return 1;
  54         }
  55         pclose(pipe);
  56         free(job);
  57         return 0;
  58 }
  59
  60 static void received_im_msg_cb(PurpleAccount *account, char *who, char *buffer, PurpleConversation *conv, PurpleMessageFlags flags, void *data) {
  61         if (conv == NULL) conv = purple_conversation_new(PURPLE_CONV_TYPE_IM, account, who); //* A workaround to avoid skipping of the first message as a result on NULL-conv: */
  62
  63         //Get message
  64         message = purple_markup_strip_html(buffer);
  65         //printf("\nHarvie received: %s: %s\n", who, message); //debug
  66         //purple_conv_im_send(purple_conversation_get_im_data(conv), ":-*"); //debug
  67
  68         //Get protocol ID
  69         const char *protocol_id = purple_account_get_protocol_id(account);
  70         if(!strncmp(protocol_id,PROTOCOL_PREFIX,strlen(PROTOCOL_PREFIX))) protocol_id += strlen(PROTOCOL_PREFIX); //trim out protocol prefix (eg.: "prpl-irc" => "irc")
  71
  72         //Get status
  73         PurpleStatus *status = purple_account_get_active_status(account);
  74         PurpleStatusType *type = purple_status_get_type(status);
  75
  76         //Get status id
  77         const char *status_id = NULL;
  78         status_id = purple_primitive_get_id_from_type(purple_status_type_get_primitive(type));
  79
  80         //Get status message
  81         const char *status_msg = NULL;
  82         if (purple_status_type_get_attr(type, "message") != NULL) {
  83                 status_msg = purple_status_get_attr_string(status, "message");
  84         } else {
  85                 status_msg = (char *) purple_savedstatus_get_message(purple_savedstatus_get_current());
  86         }
  87
  88         //Export variables to environment
  89         setenv(ENV_PREFIX "MSG", message, 1);
  90         setenv(ENV_PREFIX "FROM", who, 1);
  91         setenv(ENV_PREFIX "PROTOCOL", protocol_id, 1);
  92         setenv(ENV_PREFIX "STATUS", status_id, 1);
  93         setenv(ENV_PREFIX "STATUS_MSG", status_msg, 1);
  94
  95         //Launch job on background
  96         answerscripts_job *job = (answerscripts_job*) malloc(sizeof(answerscripts_job));
  97         job->pipe = popen(hook_script, "r");
  98         job->conv = conv;
  99
 100         #ifndef __WIN32__
 101                 int fflags = fcntl(fileno(job->pipe), F_GETFL, 0);
 102                 fcntl(fileno(job->pipe), F_SETFL, fflags | O_NONBLOCK);
 103         #endif
 104
 105         purple_timeout_add(ANSWERSCRIPTS_TIMEOUT_INTERVAL, (GSourceFunc) answerscripts_process_message_cb, (gpointer) job);
 106 }
 107
 108 static gboolean plugin_load(PurplePlugin * plugin) {
 109         asprintf(&hook_script,"%s/%s",purple_user_dir(),ANSWERSCRIPT);
 110         void *conv_handle = purple_conversations_get_handle();
 111         purple_signal_connect(conv_handle, "received-im-msg", plugin, PURPLE_CALLBACK(received_im_msg_cb), NULL);
 112         return TRUE;
 113 }
 114
 115 static gboolean plugin_unload(PurplePlugin * plugin) {
 116         free(hook_script);
 117         return TRUE;
 118 }
 119
 120 static PurplePluginInfo info = {
 121         PURPLE_PLUGIN_MAGIC,
 122         PURPLE_MAJOR_VERSION,
 123         PURPLE_MINOR_VERSION,
 124         PURPLE_PLUGIN_STANDARD,
 125         NULL,
 126         0,
 127         NULL,
 128         PURPLE_PRIORITY_DEFAULT,
 129
 130         "core-answerscripts",
 131         "AnswerScripts",
 132         "0.3.1",
 133         "Framework for hooking scripts to process received messages for libpurple clients",
 134         "\nThis plugin will execute script \"~/.purple/" ANSWERSCRIPT "\" "
 135                 "(or any other executable called \"" ANSWERSCRIPT "\" and found in purple_user_dir()) "
 136                 "each time when instant message is received.\n"
 137                 "\n- Any text printed to STDOUT by this script will be sent back as answer to received message."
 138                 "\n- Following environment values will be set, so script can use them for responding:\n"
 139                 "\t- ANSW_MSG\n"
 140                 "\t- ANSW_FROM\n"
 141                 "\t- ANSW_PROTOCOL\n"
 142                 "\t- ANSW_STATUS\n"
 143                 "\t- ANSW_STATUS_MSG\n"
 144                 "\nPlease see sample scripts, documentation, website and source code for more informations...\n"
 145                 "\n(-; Peace ;-)\n",
 146         "Tomas Mudrunka <harvie@email.cz>",
 147         "http://github.com/harvie/libpurple-core-answerscripts",
 148
 149         plugin_load,
 150         plugin_unload,
 151         NULL,
 152         NULL,
 153         NULL,
 154         NULL,
 155         NULL,
 156         NULL,
 157         NULL,
 158         NULL,
 159         NULL
 160 };
 161
 162 static void init_plugin(PurplePlugin * plugin) {
 163
 164 }
 165
 166 PURPLE_INIT_PLUGIN(autoanswer, init_plugin, info)