X-Git-Url: http://git.harvie.cz/?p=mirrors%2Flibpurple-core-answerscripts.git;a=blobdiff_plain;f=answerscripts.c;h=44fa0c12ed20972d76c6ef6d6cfc369bd5051f3a;hp=e3f070a2ea65d98c2807324f5bc2f596f86390d5;hb=fe6fec76e1c7705e9e80f923f39c76a4768da031;hpb=d852a69454e41e5c4d354b509da04c7dfd5e80ad;ds=inline diff --git a/answerscripts.c b/answerscripts.c index e3f070a..44fa0c1 100755 --- a/answerscripts.c +++ b/answerscripts.c @@ -1,75 +1,107 @@ -#define PURPLE_PLUGINS +//#define __WIN32__ +#ifndef __WIN32__ + #define ANSWERSCRIPT_EXT "" +#else + #define ANSWERSCRIPT_EXT ".exe" +#endif +#define ANSWERSCRIPT "answerscripts" ANSWERSCRIPT_EXT +#define ANSWERSCRIPTS_TIMEOUT_INTERVAL 250 +#define ANSWERSCRIPTS_LINE_LENGTH 4096 +#define ENV_PREFIX "ANSW_" + +#include +#include +#include + +#ifndef __WIN32__ + #include +#endif -/* Purple headers */ +/* Purple plugin */ +#define PURPLE_PLUGINS #include #include #include -#include -#include #include -#include -#include #include #include -#include -#include -#include +char *message = NULL; +char *hook_script = NULL; +char response[ANSWERSCRIPTS_LINE_LENGTH+1]; +int i; -#define RESPONSE_LINE_LENGTH 4096 -#define HOOK_SCRIPT "answerscripts.exe" +typedef struct { + FILE *pipe; + PurpleConversation *conv; +} answerscripts_job; -#ifdef PTHREAD - #include -#endif +int answerscripts_process_message_cb(answerscripts_job *job) { + FILE *pipe = job->pipe; + PurpleConversation *conv = job->conv; -char *buff = NULL; -char *hook_script = NULL; -char response[RESPONSE_LINE_LENGTH+1]; -int i; + if (pipe && !feof(pipe)) { + if(!fgets(response, ANSWERSCRIPTS_LINE_LENGTH, pipe) + && (errno == EWOULDBLOCK || errno == EAGAIN) + ) return 1; -void *answerscripts_process_message(void *conv) { - FILE* pipe = popen(hook_script, "r"); //TODO: process scripts and send response asynchronously - while (pipe && fgets(response, RESPONSE_LINE_LENGTH, pipe)) { for(i=0;response[i];i++) if(response[i]=='\n') response[i]=0; - purple_conv_im_send(purple_conversation_get_im_data((PurpleConversation *)conv), response); + purple_conv_im_send(purple_conversation_get_im_data(conv), response); + + if(!feof(pipe)) return 1; } pclose(pipe); + free(job); + return 0; } -static void -received_im_msg_cb(PurpleAccount * account, char *who, char *buffer, -PurpleConversation * conv, PurpleMessageFlags flags, -void *data) { - /* A workaround to avoid skipping of the first message as a result on NULL-conv: */ - if (conv == NULL) conv = purple_conversation_new(PURPLE_CONV_TYPE_IM, account, who); +static void received_im_msg_cb(PurpleAccount *account, char *who, char *buffer, PurpleConversation *conv, PurpleMessageFlags flags, void *data) { + 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: */ - buff = purple_markup_strip_html(buffer); - //printf("\nHarvie received: %s: %s\n", who, buff); //debug + //Get message + message = purple_markup_strip_html(buffer); + //printf("\nHarvie received: %s: %s\n", who, message); //debug //purple_conv_im_send(purple_conversation_get_im_data(conv), ":-*"); //debug - setenv("PURPLE_FROM", who, 1); - setenv("PURPLE_MSG", buff, 1); + //Get status + PurpleStatus *status = purple_account_get_active_status(account); + PurpleStatusType *type = purple_status_get_type(status); + + //Get status id + const char *status_id = NULL; + status_id = purple_primitive_get_id_from_type(purple_status_type_get_primitive(type)); + + //Get status message + const char *status_msg = NULL; + if (purple_status_type_get_attr(type, "message") != NULL) { + status_msg = purple_status_get_attr_string(status, "message"); + } else { + status_msg = (char *) purple_savedstatus_get_message(purple_savedstatus_get_current()); + } - #ifndef PTHREAD - answerscripts_process_message((void *)conv); - #else - pthread_t t; - puts("new thread..."); - pthread_create(&t, NULL, answerscripts_process_message, (void *)conv); - puts("new thread created!"); + //Export variables to environment + setenv(ENV_PREFIX "FROM", who, 1); + setenv(ENV_PREFIX "MSG", message, 1); + setenv(ENV_PREFIX "STATUS", status_id, 1); + setenv(ENV_PREFIX "STATUS_MSG", status_msg, 1); + + //Launch job on background + answerscripts_job *job = (answerscripts_job*) malloc(sizeof(answerscripts_job)); + job->pipe = popen(hook_script, "r"); + job->conv = conv; + + #ifndef __WIN32__ + int fflags = fcntl(fileno(job->pipe), F_GETFL, 0); + fcntl(fileno(job->pipe), F_SETFL, fflags | O_NONBLOCK); #endif -} + purple_timeout_add(ANSWERSCRIPTS_TIMEOUT_INTERVAL, (GSourceFunc) answerscripts_process_message_cb, (gpointer) job); +} static gboolean plugin_load(PurplePlugin * plugin) { - asprintf(&hook_script,"%s/%s",purple_user_dir(),HOOK_SCRIPT); - + asprintf(&hook_script,"%s/%s",purple_user_dir(),ANSWERSCRIPT); void *conv_handle = purple_conversations_get_handle(); - - purple_signal_connect(conv_handle, "received-im-msg", - plugin, PURPLE_CALLBACK(received_im_msg_cb), - NULL); + purple_signal_connect(conv_handle, "received-im-msg", plugin, PURPLE_CALLBACK(received_im_msg_cb), NULL); return TRUE; } @@ -90,16 +122,17 @@ static PurplePluginInfo info = { "core-answerscripts", "AnswerScripts", - "0.1", - "Framework for hooking scripts to received messages for various libpurple clients", - "This plugin will call ~/.purple/" HOOK_SCRIPT " (or wherever purple_user_dir() points) " - "script (or any executable) for each single message called." - "Envinronment values PURPLE_MSG and PURPLE_FROM will be set to carry " - "informations about message text and sender so script can respond to that message. " - "Any text printed to STDOUT by the script will be sent back as answer to message. " - "Please see example scripts for more informations...", + "0.3.0", + "Framework for hooking scripts to process received messages for libpurple clients", + "This plugin will execute script ~/.purple/" ANSWERSCRIPT " " + "or any other executable called " ANSWERSCRIPT " and found in purple_user_dir() " + "for each single instant message received.\n" + "\n- Envinronment values PURPLE_MSG and PURPLE_FROM will be set to carry " + "informations about message text and sender so script can respond to that message." + "\n- Any text printed to STDOUT by the script will be sent back as answer to message." + "\n\nPlease see example scripts, documentation or source code for more informations...", "Harvie ", - "http://github.com/harvie", + "http://github.com/harvie/libpurple-core-answerscripts", plugin_load, plugin_unload,