diff options
| author | Eion Robb <eion@robbmob.com> | 2007-11-01 22:11:55 +0300 |
|---|---|---|
| committer | Eion Robb <eion@robbmob.com> | 2007-11-01 22:11:55 +0300 |
| commit | 474952053bb2c6f060e0e66e2ca0a6f9bad4a260 (patch) | |
| tree | 13829e64a825af030e694c8e4515cbee6a7cd8d6 /skype_messaging.c | |
Diffstat (limited to 'skype_messaging.c')
| -rw-r--r-- | skype_messaging.c | 141 |
1 files changed, 141 insertions, 0 deletions
diff --git a/skype_messaging.c b/skype_messaging.c new file mode 100644 index 0000000..7c2863b --- /dev/null +++ b/skype_messaging.c @@ -0,0 +1,141 @@ +#include <glib.h>
+
+#include "skype_events.c"
+
+static gboolean skype_handle_received_message(char *message);
+
+static void skype_message_received(char *message);
+static gboolean skype_connect();
+static void skype_disconnect();
+static void send_message(char* message);
+
+void skype_send_message_nowait(char *message, ...);
+char *skype_send_message(char *message, ...);
+
+// Sort through the mess of different OS's to get the right proto
+
+#ifdef _WIN32
+# include "skype_messaging_win32.c"
+#else /*if !win32 */
+# ifdef __APPLE__
+# include "skype_messaging_carbon.c"
+# else /*if !apple */
+# if 1
+# include "skype_messaging_x11.c"
+# else
+# include "skype_messaging_dbus.c"
+# endif /* !x11 */
+# endif /* !apple */
+#endif /* win32 */
+
+
+typedef struct {
+ gpointer sender;
+ gpointer body;
+ int time;
+ gpointer chatname;
+} SkypeMessage;
+
+static GHashTable *message_queue = NULL;
+static GStaticMutex mutex = G_STATIC_MUTEX_INIT;
+
+static void
+skype_message_received(char *orig_message)
+{
+ int request_number;
+ int string_pos;
+ char *message;
+
+ if (strlen(orig_message) == 0)
+ return;
+
+ message = g_strdup(orig_message);
+
+ purple_debug_info("skype", "Received: %s\n", message);
+
+ if(message[0] == '#')
+ {
+ //It's a reply from a call we've made - update the hash table
+ sscanf(message, "#%d %n", &request_number, &string_pos);
+ g_static_mutex_lock(&mutex);
+ g_hash_table_insert(message_queue, (gpointer)request_number, g_strdup(&message[string_pos]));
+ g_static_mutex_unlock(&mutex);
+ } else {
+ purple_timeout_add(0, (GSourceFunc)skype_handle_received_message, (gpointer)message);
+ }
+}
+
+void
+skype_send_message_nowait(char *message_format, ...)
+{
+ va_list args;
+ char* message;
+
+ va_start(args, message_format);
+ message = g_strdup_vprintf(message_format, args);
+ va_end(args);
+
+ purple_debug_info("skype", "Sending: '%s'\n", message);
+ g_thread_create((GThreadFunc)send_message, message, FALSE, NULL);
+
+}
+
+char *skype_send_message(char *message_format, ...)
+{
+ static int next_message_num = 0;
+ int cur_message_num;
+ char *message;
+ char *return_msg;
+ va_list args;
+ unsigned int timeout = 0;
+
+ va_start(args, message_format);
+ message = g_strdup_vprintf(message_format, args);
+ va_end(args);
+
+ if (!message_queue)
+ message_queue = g_hash_table_new_full(g_direct_hash, g_direct_equal, NULL, NULL);
+
+
+ g_static_mutex_lock(&mutex);
+ cur_message_num = next_message_num++;
+
+ g_hash_table_insert(message_queue, (gpointer)cur_message_num, NULL);
+ g_static_mutex_unlock(&mutex);
+
+ //Send message asynchronously
+ skype_send_message_nowait("#%d %s", cur_message_num, message);
+
+ g_static_mutex_lock(&mutex);
+ //Wait for a response
+ while(g_hash_table_lookup(message_queue, (gpointer)cur_message_num) == NULL)
+ {
+ g_static_mutex_unlock(&mutex);
+ g_thread_yield();
+#ifdef __APPLE__
+ RunCurrentEventLoop(0);
+#endif
+#ifndef _WIN32
+ usleep(1000);
+#else
+ Sleep(1);
+#endif
+ g_static_mutex_lock(&mutex);
+
+ if(timeout++ == 10000)
+ {
+ g_hash_table_remove(message_queue, (gpointer)cur_message_num);
+ return "";
+ }
+ }
+ return_msg = (char *)g_hash_table_lookup(message_queue, (gpointer)cur_message_num);
+ g_hash_table_remove(message_queue, (gpointer)cur_message_num);
+ g_static_mutex_unlock(&mutex);
+
+ if (strncmp(return_msg, "ERROR", 5) == 0)
+ {
+ g_free(return_msg);
+ return "";
+ }
+ return return_msg;
+}
|