source: protocols/msn/msn_util.c @ d2411a1

Last change on this file since d2411a1 was d2411a1, checked in by dequis <dx@…>, at 2015-05-31T02:40:04Z

msn: all commands have a payload size now, simplify parsing

  • Property mode set to 100644
File size: 10.1 KB
Line 
1/********************************************************************\
2  * BitlBee -- An IRC to other IM-networks gateway                     *
3  *                                                                    *
4  * Copyright 2002-2012 Wilmer van der Gaast and others                *
5  \********************************************************************/
6
7/* MSN module - Miscellaneous utilities                                 */
8
9/*
10  This program is free software; you can redistribute it and/or modify
11  it under the terms of the GNU General Public License as published by
12  the Free Software Foundation; either version 2 of the License, or
13  (at your option) any later version.
14
15  This program is distributed in the hope that it will be useful,
16  but WITHOUT ANY WARRANTY; without even the implied warranty of
17  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
18  GNU General Public License for more details.
19
20  You should have received a copy of the GNU General Public License with
21  the Debian GNU/Linux distribution in /usr/share/common-licenses/GPL;
22  if not, write to the Free Software Foundation, Inc., 51 Franklin St.,
23  Fifth Floor, Boston, MA  02110-1301  USA
24*/
25
26#include "nogaim.h"
27#include "msn.h"
28#include "md5.h"
29#include "soap.h"
30#include <ctype.h>
31
32static char *adlrml_entry(const char *handle_, msn_buddy_flags_t list)
33{
34        char *domain, handle[strlen(handle_) + 1];
35
36        strcpy(handle, handle_);
37        if ((domain = strchr(handle, '@'))) {
38                *(domain++) = '\0';
39        } else {
40                return NULL;
41        }
42
43        return g_markup_printf_escaped("<ml><d n=\"%s\"><c n=\"%s\" l=\"%d\" t=\"1\"/></d></ml>",
44                                       domain, handle, list);
45}
46
47int msn_buddy_list_add(struct im_connection *ic, msn_buddy_flags_t list, const char *who, const char *realname,
48                       const char *group)
49{
50        struct msn_data *md = ic->proto_data;
51        char groupid[8];
52        bee_user_t *bu;
53        struct msn_buddy_data *bd;
54        char *adl;
55
56        *groupid = '\0';
57
58        if (!((bu = bee_user_by_handle(ic->bee, ic, who)) ||
59              (bu = bee_user_new(ic->bee, ic, who, 0))) ||
60            !(bd = bu->data) || bd->flags & list) {
61                return 1;
62        }
63
64        bd->flags |= list;
65
66        if (list == MSN_BUDDY_FL) {
67                msn_soap_ab_contact_add(ic, bu);
68        } else {
69                msn_soap_memlist_edit(ic, who, TRUE, list);
70        }
71
72        if ((adl = adlrml_entry(who, list))) {
73                int st = msn_ns_write(ic, "ADL %d %zd\r\n%s",
74                                      ++md->trId, strlen(adl), adl);
75                g_free(adl);
76
77                return st;
78        }
79
80        return 1;
81}
82
83int msn_buddy_list_remove(struct im_connection *ic, msn_buddy_flags_t list, const char *who, const char *group)
84{
85        struct msn_data *md = ic->proto_data;
86        char groupid[8];
87        bee_user_t *bu;
88        struct msn_buddy_data *bd;
89        char *adl;
90
91        *groupid = '\0';
92
93        if (!(bu = bee_user_by_handle(ic->bee, ic, who)) ||
94            !(bd = bu->data) || !(bd->flags & list)) {
95                return 1;
96        }
97
98        bd->flags &= ~list;
99
100        if (list == MSN_BUDDY_FL) {
101                msn_soap_ab_contact_del(ic, bu);
102        } else {
103                msn_soap_memlist_edit(ic, who, FALSE, list);
104        }
105
106        if ((adl = adlrml_entry(who, list))) {
107                int st = msn_ns_write(ic, "RML %d %zd\r\n%s",
108                                      ++md->trId, strlen(adl), adl);
109                g_free(adl);
110
111                return st;
112        }
113
114        return 1;
115}
116
117struct msn_buddy_ask_data {
118        struct im_connection *ic;
119        char *handle;
120        char *realname;
121};
122
123static void msn_buddy_ask_free(void *data)
124{
125        struct msn_buddy_ask_data *bla = data;
126
127        g_free(bla->handle);
128        g_free(bla->realname);
129        g_free(bla);
130}
131
132static void msn_buddy_ask_yes(void *data)
133{
134        struct msn_buddy_ask_data *bla = data;
135
136        msn_buddy_list_add(bla->ic, MSN_BUDDY_AL, bla->handle, bla->realname, NULL);
137
138        imcb_ask_add(bla->ic, bla->handle, NULL);
139
140        msn_buddy_ask_free(bla);
141}
142
143static void msn_buddy_ask_no(void *data)
144{
145        struct msn_buddy_ask_data *bla = data;
146
147        msn_buddy_list_add(bla->ic, MSN_BUDDY_BL, bla->handle, bla->realname, NULL);
148
149        msn_buddy_ask_free(bla);
150}
151
152void msn_buddy_ask(bee_user_t *bu)
153{
154        struct msn_buddy_ask_data *bla;
155        struct msn_buddy_data *bd = bu->data;
156        char buf[1024];
157
158        if (!(bd->flags & MSN_BUDDY_PL)) {
159                return;
160        }
161
162        bla = g_new0(struct msn_buddy_ask_data, 1);
163        bla->ic = bu->ic;
164        bla->handle = g_strdup(bu->handle);
165        bla->realname = g_strdup(bu->fullname);
166
167        g_snprintf(buf, sizeof(buf),
168                   "The user %s (%s) wants to add you to his/her buddy list.",
169                   bu->handle, bu->fullname);
170
171        imcb_ask_with_free(bu->ic, buf, bla, msn_buddy_ask_yes, msn_buddy_ask_no, msn_buddy_ask_free);
172}
173
174void msn_queue_feed(struct msn_data *h, char *bytes, int st)
175{
176        h->rxq = g_renew(char, h->rxq, h->rxlen + st);
177        memcpy(h->rxq + h->rxlen, bytes, st);
178        h->rxlen += st;
179
180        if (getenv("BITLBEE_DEBUG")) {
181                fprintf(stderr, "\n\x1b[92m<<< ");
182                write(2, bytes , st);
183                fprintf(stderr, "\x1b[97m");
184        }
185}
186
187
188static int msn_handle_command(struct msn_data *h) {
189        char *msg, **cmd;
190        int count, st;
191
192        msg = g_strndup(h->rxq, h->msglen);
193
194        cmd = g_strsplit_set(h->cmd_text, " ", -1);
195        count = g_strv_length(cmd);
196
197        st = msn_ns_command(h, cmd, count, msg, h->msglen);
198
199        g_strfreev(cmd);
200        g_free(msg);
201
202        g_free(h->cmd_text);
203        h->cmd_text = NULL;
204
205        return st;
206}
207
208/* This one handles input from a MSN Messenger server. Both the NS and SB servers usually give
209   commands, but sometimes they give additional data (payload). This function tries to handle
210   this all in a nice way and send all data to the right places. */
211
212/* Return values: -1: Read error, abort connection.
213                   0: Command reported error; Abort *immediately*. (The connection does not exist anymore)
214                   1: OK */
215
216int msn_handler(struct msn_data *h)
217{
218        int st = 1;
219
220        while (st) {
221                int i;
222
223                if (h->msglen == 0) {
224                        for (i = 0; i < h->rxlen; i++) {
225                                if (h->rxq[i] == '\r' || h->rxq[i] == '\n') {
226                                        char *cmd_text, *last_param;
227                                        guint64 parsed_len;
228
229                                        cmd_text = g_strndup(h->rxq, i);
230
231                                        /* find the position of the last parameter from the end */
232                                        last_param = cmd_text + i;
233                                        while (last_param != cmd_text && last_param[-1] != ' ') {
234                                                last_param--;
235                                        }
236
237                                        /* that parameter is the payload size */
238                                        if (!parse_int64(last_param, 10, &parsed_len)) {
239                                                return -1;
240                                        }
241
242                                        h->msglen = (int) parsed_len;
243                                        h->cmd_text = cmd_text;
244
245                                        /* if there's no payload, handle it right away */
246                                        if (parsed_len == 0 && !msn_handle_command(h)) {
247                                                return 0;
248                                        }
249
250                                        /* Skip the \r\n */
251                                        i += 2;
252
253                                        break;
254                                }
255                        }
256
257                        /* If we reached the end of the buffer, there's still an incomplete command there.
258                           Return and wait for more data. */
259                        if (i && i == h->rxlen && h->rxq[i - 1] != '\r' && h->rxq[i - 1] != '\n') {
260                                break;
261                        }
262                } else {
263
264                        /* Do we have the complete message already? */
265                        if (h->msglen > h->rxlen) {
266                                break;
267                        } else if (!msn_handle_command(h)) {
268                                return 0;
269                        }
270
271                        i = h->msglen;
272                        h->msglen = 0;
273                }
274
275                /* More data after this block? */
276                if (i < h->rxlen) {
277                        char *tmp;
278
279                        tmp = g_memdup(h->rxq + i, h->rxlen - i);
280                        g_free(h->rxq);
281                        h->rxq = tmp;
282                        h->rxlen -= i;
283                        i = 0;
284                } else {
285                        /* If not, reset the rx queue and get lost. */
286                        g_free(h->rxq);
287                        h->rxq = g_new0(char, 1);
288                        h->rxlen = 0;
289                        return(1);
290                }
291        }
292
293        return(1);
294}
295
296/* Copied and heavily modified from http://tmsnc.sourceforge.net/chl.c */
297char *msn_p11_challenge(char *challenge)
298{
299        char *output, buf[256];
300        md5_state_t md5c;
301        unsigned char md5Hash[16], *newHash;
302        unsigned int *md5Parts, *chlStringParts, newHashParts[5];
303        long long nHigh = 0, nLow = 0;
304        int i, n;
305
306        /* Create the MD5 hash */
307        md5_init(&md5c);
308        md5_append(&md5c, (unsigned char *) challenge, strlen(challenge));
309        md5_append(&md5c, (unsigned char *) MSNP11_PROD_KEY, strlen(MSNP11_PROD_KEY));
310        md5_finish(&md5c, md5Hash);
311
312        /* Split it into four integers */
313        md5Parts = (unsigned int *) md5Hash;
314        for (i = 0; i < 4; i++) {
315                md5Parts[i] = GUINT32_TO_LE(md5Parts[i]);
316
317                /* & each integer with 0x7FFFFFFF */
318                /* and save one unmodified array for later */
319                newHashParts[i] = md5Parts[i];
320                md5Parts[i] &= 0x7FFFFFFF;
321        }
322
323        /* make a new string and pad with '0' */
324        n = g_snprintf(buf, sizeof(buf) - 5, "%s%s00000000", challenge, MSNP11_PROD_ID);
325        /* truncate at an 8-byte boundary */
326        buf[n &= ~7] = '\0';
327
328        /* split into integers */
329        chlStringParts = (unsigned int *) buf;
330
331        /* this is magic */
332        for (i = 0; i < (n / 4) - 1; i += 2) {
333                long long temp;
334
335                chlStringParts[i]   = GUINT32_TO_LE(chlStringParts[i]);
336                chlStringParts[i + 1] = GUINT32_TO_LE(chlStringParts[i + 1]);
337
338                temp  =
339                        (md5Parts[0] *
340                         (((0x0E79A9C1 *
341                            (long long) chlStringParts[i]) % 0x7FFFFFFF) + nHigh) + md5Parts[1]) % 0x7FFFFFFF;
342                nHigh =
343                        (md5Parts[2] *
344                         (((long long) chlStringParts[i + 1] + temp) % 0x7FFFFFFF) + md5Parts[3]) % 0x7FFFFFFF;
345                nLow  = nLow + nHigh + temp;
346        }
347        nHigh = (nHigh + md5Parts[1]) % 0x7FFFFFFF;
348        nLow = (nLow + md5Parts[3]) % 0x7FFFFFFF;
349
350        newHashParts[0] ^= nHigh;
351        newHashParts[1] ^= nLow;
352        newHashParts[2] ^= nHigh;
353        newHashParts[3] ^= nLow;
354
355        /* swap more bytes if big endian */
356        for (i = 0; i < 4; i++) {
357                newHashParts[i] = GUINT32_TO_LE(newHashParts[i]);
358        }
359
360        /* make a string of the parts */
361        newHash = (unsigned char *) newHashParts;
362
363        /* convert to hexadecimal */
364        output = g_new(char, 33);
365        for (i = 0; i < 16; i++) {
366                sprintf(output + i * 2, "%02x", newHash[i]);
367        }
368
369        return output;
370}
371
372gint msn_domaintree_cmp(gconstpointer a_, gconstpointer b_)
373{
374        const char *a = a_, *b = b_;
375        gint ret;
376
377        if (!(a = strchr(a, '@')) || !(b = strchr(b, '@')) ||
378            (ret = strcmp(a, b)) == 0) {
379                ret = strcmp(a_, b_);
380        }
381
382        return ret;
383}
384
385struct msn_group *msn_group_by_name(struct im_connection *ic, const char *name)
386{
387        struct msn_data *md = ic->proto_data;
388        GSList *l;
389
390        for (l = md->groups; l; l = l->next) {
391                struct msn_group *mg = l->data;
392
393                if (g_strcasecmp(mg->name, name) == 0) {
394                        return mg;
395                }
396        }
397
398        return NULL;
399}
400
401struct msn_group *msn_group_by_id(struct im_connection *ic, const char *id)
402{
403        struct msn_data *md = ic->proto_data;
404        GSList *l;
405
406        for (l = md->groups; l; l = l->next) {
407                struct msn_group *mg = l->data;
408
409                if (g_strcasecmp(mg->id, id) == 0) {
410                        return mg;
411                }
412        }
413
414        return NULL;
415}
416
417int msn_ns_set_display_name(struct im_connection *ic, const char *value)
418{
419        // TODO, implement this through msn_set_away's method
420        return 1;
421}
422
423const char *msn_normalize_handle(const char *handle)
424{
425        if (strncmp(handle, "1:", 2) == 0) {
426                return handle + 2;
427        } else {
428                return handle;
429        }
430}
Note: See TracBrowser for help on using the repository browser.