1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
#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);
static void hide_skype();
static gboolean exec_skype();
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)
{
guint request_number;
guint *key;
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, "#%u %n", &request_number, &string_pos);
key = g_new(guint, 1);
*key = request_number;
g_static_mutex_lock(&mutex);
g_hash_table_insert(message_queue, key, g_strdup(&message[string_pos]));
g_static_mutex_unlock(&mutex);
g_free(message);
} else {
purple_timeout_add(1, (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 guint next_message_num = 0;
guint 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_int_hash, g_int_equal, g_free, NULL);
cur_message_num = next_message_num++;
if (next_message_num == G_MAXUINT)
next_message_num = 0;
//Send message asynchronously
skype_send_message_nowait("#%u %s", cur_message_num, message);
g_free(message);
g_static_mutex_lock(&mutex);
//Wait for a response
while(g_hash_table_lookup(message_queue, &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, &cur_message_num);
return "";
}
}
return_msg = (char *)g_hash_table_lookup(message_queue, &cur_message_num);
g_hash_table_remove(message_queue, &cur_message_num);
g_static_mutex_unlock(&mutex);
if (strncmp(return_msg, "ERROR", 5) == 0)
{
g_free(return_msg);
return g_strdup("");
}
return return_msg;
}
|
