source: protocols/twitter/twitter.c @ b6bd99c

Last change on this file since b6bd99c was c203533, checked in by dequis <dx@…>, at 2014-09-27T14:54:35Z

twitter: Add support for The United States of America

Land of the Free, Home of the Brave

  • Property mode set to 100644
File size: 21.5 KB
Line 
1/***************************************************************************\
2*                                                                           *
3*  BitlBee - An IRC to IM gateway                                           *
4*  Simple module to facilitate twitter functionality.                       *
5*                                                                           *
6*  Copyright 2009-2010 Geert Mulders <g.c.w.m.mulders@gmail.com>            *
7*  Copyright 2010-2013 Wilmer van der Gaast <wilmer@gaast.net>              *
8*                                                                           *
9*  This library is free software; you can redistribute it and/or            *
10*  modify it under the terms of the GNU Lesser General Public               *
11*  License as published by the Free Software Foundation, version            *
12*  2.1.                                                                     *
13*                                                                           *
14*  This library is distributed in the hope that it will be useful,          *
15*  but WITHOUT ANY WARRANTY; without even the implied warranty of           *
16*  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU        *
17*  Lesser General Public License for more details.                          *
18*                                                                           *
19*  You should have received a copy of the GNU Lesser General Public License *
20*  along with this library; if not, write to the Free Software Foundation,  *
21*  Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA           *
22*                                                                           *
23****************************************************************************/
24
25#include "nogaim.h"
26#include "oauth.h"
27#include "twitter.h"
28#include "twitter_http.h"
29#include "twitter_lib.h"
30#include "url.h"
31
32GSList *twitter_connections = NULL;
33/**
34 * Main loop function
35 */
36gboolean twitter_main_loop(gpointer data, gint fd, b_input_condition cond)
37{
38        struct im_connection *ic = data;
39
40        // Check if we are still logged in...
41        if (!g_slist_find(twitter_connections, ic))
42                return FALSE;
43
44        // Do stuff..
45        return twitter_get_timeline(ic, -1) &&
46               ((ic->flags & OPT_LOGGED_IN) == OPT_LOGGED_IN);
47}
48
49static void twitter_main_loop_start(struct im_connection *ic)
50{
51        struct twitter_data *td = ic->proto_data;
52
53        /* Create the room now that we "logged in". */
54        if (td->flags & TWITTER_MODE_CHAT)
55                twitter_groupchat_init(ic);
56
57        imcb_log(ic, "Getting initial statuses");
58
59        // Run this once. After this queue the main loop function (or open the
60        // stream if available).
61        twitter_main_loop(ic, -1, 0);
62       
63        if (set_getbool(&ic->acc->set, "stream")) {
64                /* That fetch was just to get backlog, the stream will give
65                   us the rest. \o/ */
66                twitter_open_stream(ic);
67               
68                /* Stream sends keepalives (empty lines) or actual data at
69                   least twice a minute. Disconnect if this stops. */
70                ic->flags |= OPT_PONGS;
71        } else {
72                /* Not using the streaming API, so keep polling the old-
73                   fashioned way. :-( */
74                td->main_loop_id =
75                    b_timeout_add(set_getint(&ic->acc->set, "fetch_interval") * 1000,
76                                  twitter_main_loop, ic);
77        }
78}
79
80struct groupchat *twitter_groupchat_init(struct im_connection *ic)
81{
82        char *name_hint;
83        struct groupchat *gc;
84        struct twitter_data *td = ic->proto_data;
85        GSList *l;
86
87        if (td->timeline_gc)
88                return td->timeline_gc;
89
90        td->timeline_gc = gc = imcb_chat_new(ic, "twitter/timeline");
91
92        name_hint = g_strdup_printf("%s_%s", td->prefix, ic->acc->user);
93        imcb_chat_name_hint(gc, name_hint);
94        g_free(name_hint);
95
96        for (l = ic->bee->users; l; l = l->next) {
97                bee_user_t *bu = l->data;
98                if (bu->ic == ic)
99                        imcb_chat_add_buddy(gc, bu->handle);
100        }
101        imcb_chat_add_buddy(gc, ic->acc->user);
102       
103        return gc;
104}
105
106static void twitter_oauth_start(struct im_connection *ic);
107
108void twitter_login_finish(struct im_connection *ic)
109{
110        struct twitter_data *td = ic->proto_data;
111
112        td->flags &= ~TWITTER_DOING_TIMELINE;
113
114        if (set_getbool(&ic->acc->set, "oauth") && !td->oauth_info)
115                twitter_oauth_start(ic);
116        else if (!(td->flags & TWITTER_MODE_ONE) &&
117                 !(td->flags & TWITTER_HAVE_FRIENDS)) {
118                imcb_log(ic, "Getting contact list");
119                twitter_get_friends_ids(ic, -1);
120        } else
121                twitter_main_loop_start(ic);
122}
123
124static const struct oauth_service twitter_oauth = {
125        "https://api.twitter.com/oauth/request_token",
126        "https://api.twitter.com/oauth/access_token",
127        "https://api.twitter.com/oauth/authorize",
128        .consumer_key = "xsDNKJuNZYkZyMcu914uEA",
129        .consumer_secret = "FCxqcr0pXKzsF9ajmP57S3VQ8V6Drk4o2QYtqMcOszo",
130};
131
132static const struct oauth_service identica_oauth = {
133        "https://identi.ca/api/oauth/request_token",
134        "https://identi.ca/api/oauth/access_token",
135        "https://identi.ca/api/oauth/authorize",
136        .consumer_key = "e147ff789fcbd8a5a07963afbb43f9da",
137        .consumer_secret = "c596267f277457ec0ce1ab7bb788d828",
138};
139
140static gboolean twitter_oauth_callback(struct oauth_info *info);
141
142static const struct oauth_service *get_oauth_service(struct im_connection *ic)
143{
144        struct twitter_data *td = ic->proto_data;
145
146        if (strstr(td->url_host, "identi.ca"))
147                return &identica_oauth;
148        else
149                return &twitter_oauth;
150
151        /* Could add more services, or allow configuring your own base URL +
152           API keys. */
153}
154
155static void twitter_oauth_start(struct im_connection *ic)
156{
157        struct twitter_data *td = ic->proto_data;
158        const char *url = set_getstr(&ic->acc->set, "base_url");
159
160        imcb_log(ic, "Requesting OAuth request token");
161       
162        if (!strstr(url, "twitter.com") && !strstr(url, "identi.ca"))
163                imcb_log(ic, "Warning: OAuth only works with identi.ca and "
164                             "Twitter.");
165
166        td->oauth_info = oauth_request_token(get_oauth_service(ic), twitter_oauth_callback, ic);
167
168        /* We need help from the user to complete OAuth login, so don't time
169           out on this login. */
170        ic->flags |= OPT_SLOW_LOGIN;
171}
172
173static gboolean twitter_oauth_callback(struct oauth_info *info)
174{
175        struct im_connection *ic = info->data;
176        struct twitter_data *td;
177
178        if (!g_slist_find(twitter_connections, ic))
179                return FALSE;
180
181        td = ic->proto_data;
182        if (info->stage == OAUTH_REQUEST_TOKEN) {
183                char *name, *msg;
184
185                if (info->request_token == NULL) {
186                        imcb_error(ic, "OAuth error: %s", twitter_parse_error(info->http));
187                        imc_logout(ic, TRUE);
188                        return FALSE;
189                }
190
191                name = g_strdup_printf("%s_%s", td->prefix, ic->acc->user);
192                msg = g_strdup_printf("To finish OAuth authentication, please visit "
193                                      "%s and respond with the resulting PIN code.",
194                                      info->auth_url);
195                imcb_buddy_msg(ic, name, msg, 0, 0);
196                g_free(name);
197                g_free(msg);
198        } else if (info->stage == OAUTH_ACCESS_TOKEN) {
199                const char *sn;
200               
201                if (info->token == NULL || info->token_secret == NULL) {
202                        imcb_error(ic, "OAuth error: %s", twitter_parse_error(info->http));
203                        imc_logout(ic, TRUE);
204                        return FALSE;
205                }
206               
207                if ((sn = oauth_params_get(&info->params, "screen_name"))) {
208                        if (ic->acc->prpl->handle_cmp(sn, ic->acc->user) != 0)
209                                imcb_log(ic, "Warning: You logged in via OAuth as %s "
210                                         "instead of %s.", sn, ic->acc->user);
211                        g_free(td->user);
212                        td->user = g_strdup(sn);
213                }
214
215                /* IM mods didn't do this so far and it's ugly but I should
216                   be able to get away with it... */
217                g_free(ic->acc->pass);
218                ic->acc->pass = oauth_to_string(info);
219
220                twitter_login_finish(ic);
221        }
222
223        return TRUE;
224}
225
226int twitter_url_len_diff(gchar *msg, unsigned int target_len)
227{
228        int url_len_diff = 0;
229
230        static GRegex *regex = NULL;
231        GMatchInfo *match_info;
232
233        if (regex == NULL)
234                regex = g_regex_new("(^|\\s)(http(s)?://[^\\s$]+)", 0, 0, NULL);
235       
236        g_regex_match(regex, msg, 0, &match_info);
237        while (g_match_info_matches(match_info)) {
238                gchar *url = g_match_info_fetch(match_info, 2);
239                url_len_diff += target_len - g_utf8_strlen(url, -1);
240                /* Add another character for https://t.co/... URLs */
241                if (g_match_info_fetch(match_info, 3) != NULL)
242                        url_len_diff += 1;
243                g_free(url);
244                g_match_info_next(match_info, NULL);
245        }
246        g_match_info_free(match_info);
247
248        return url_len_diff;
249}
250
251static gboolean twitter_length_check(struct im_connection *ic, gchar * msg)
252{
253        int max = set_getint(&ic->acc->set, "message_length"), len;
254        int target_len = set_getint(&ic->acc->set, "target_url_length");
255        int url_len_diff = 0;
256
257        if (target_len > 0)
258                url_len_diff = twitter_url_len_diff(msg, target_len);
259
260        if (max == 0 || (len = g_utf8_strlen(msg, -1) + url_len_diff) <= max)
261                return TRUE;
262
263        twitter_log(ic, "Maximum message length exceeded: %d > %d", len, max);
264
265        return FALSE;
266}
267
268static char *set_eval_commands(set_t * set, char *value)
269{
270        if (g_strcasecmp(value, "strict") == 0 )
271                return value;
272        else
273                return set_eval_bool(set, value);
274}
275
276static char *set_eval_mode(set_t * set, char *value)
277{
278        if (g_strcasecmp(value, "one") == 0 ||
279            g_strcasecmp(value, "many") == 0 || g_strcasecmp(value, "chat") == 0)
280                return value;
281        else
282                return NULL;
283}
284
285static void twitter_init(account_t * acc)
286{
287        set_t *s;
288        char *def_url;
289        char *def_tul;
290        char *def_mentions;
291
292        if (strcmp(acc->prpl->name, "twitter") == 0) {
293                def_url = TWITTER_API_URL;
294                def_tul = "22";
295                def_mentions = "true";
296        } else {                /* if( strcmp( acc->prpl->name, "identica" ) == 0 ) */
297                def_url = IDENTICA_API_URL;
298                def_tul = "0";
299                def_mentions = "false";
300        }
301
302        s = set_add(&acc->set, "auto_reply_timeout", "10800", set_eval_int, acc);
303
304        s = set_add(&acc->set, "base_url", def_url, NULL, acc);
305        s->flags |= ACC_SET_OFFLINE_ONLY;
306
307        s = set_add(&acc->set, "commands", "true", set_eval_commands, acc);
308
309        s = set_add(&acc->set, "fetch_interval", "60", set_eval_int, acc);
310        s->flags |= ACC_SET_OFFLINE_ONLY;
311
312        s = set_add(&acc->set, "fetch_mentions", def_mentions, set_eval_bool, acc);
313
314        s = set_add(&acc->set, "message_length", "140", set_eval_int, acc);
315
316        s = set_add(&acc->set, "target_url_length", def_tul, set_eval_int, acc);
317
318        s = set_add(&acc->set, "mode", "chat", set_eval_mode, acc);
319        s->flags |= ACC_SET_OFFLINE_ONLY;
320
321        s = set_add(&acc->set, "oauth", "true", set_eval_oauth, acc);
322
323        s = set_add(&acc->set, "show_ids", "true", set_eval_bool, acc);
324
325        s = set_add(&acc->set, "show_old_mentions", "0", set_eval_int, acc);
326
327        s = set_add(&acc->set, "strip_newlines", "false", set_eval_bool, acc);
328       
329        if (strcmp(acc->prpl->name, "twitter") == 0) {
330                s = set_add(&acc->set, "stream", "true", set_eval_bool, acc);
331                s->flags |= ACC_SET_OFFLINE_ONLY;
332        }
333}
334
335/**
336 * Login method. Since the twitter API works with separate HTTP request we
337 * only save the user and pass to the twitter_data object.
338 */
339static void twitter_login(account_t * acc)
340{
341        struct im_connection *ic = imcb_new(acc);
342        struct twitter_data *td;
343        char name[strlen(acc->user) + 9];
344        url_t url;
345        char *s;
346       
347        if (!url_set(&url, set_getstr(&ic->acc->set, "base_url")) ||
348            (url.proto != PROTO_HTTP && url.proto != PROTO_HTTPS)) {
349                imcb_error(ic, "Incorrect API base URL: %s", set_getstr(&ic->acc->set, "base_url"));
350                imc_logout(ic, FALSE);
351                return;
352        }
353
354        if (!strstr(url.host, "twitter.com") &&
355            set_getbool(&ic->acc->set, "stream")) {
356                imcb_error(ic, "Warning: The streaming API is only supported by Twitter, "
357                               "and you seem to be connecting to a different service.");
358        }
359
360        imcb_log(ic, "Connecting");
361
362        twitter_connections = g_slist_append(twitter_connections, ic);
363        td = g_new0(struct twitter_data, 1);
364        ic->proto_data = td;
365        td->user = g_strdup(acc->user);
366
367        td->url_ssl = url.proto == PROTO_HTTPS;
368        td->url_port = url.port;
369        td->url_host = g_strdup(url.host);
370        if (strcmp(url.file, "/") != 0)
371                td->url_path = g_strdup(url.file);
372        else {
373                td->url_path = g_strdup("");
374                if (g_str_has_suffix(url.host, "twitter.com"))
375                        /* May fire for people who turned on HTTPS. */
376                        imcb_error(ic, "Warning: Twitter requires a version number in API calls "
377                                       "now. Try resetting the base_url account setting.");
378        }
379       
380        /* Hacky string mangling: Turn identi.ca into identi.ca and api.twitter.com
381           into twitter, and try to be sensible if we get anything else. */
382        td->prefix = g_strdup(url.host);
383        if (g_str_has_suffix(td->prefix, ".com"))
384                td->prefix[strlen(url.host) - 4] = '\0';
385        if ((s = strrchr(td->prefix, '.')) && strlen(s) > 4) {
386                /* If we have at least 3 chars after the last dot, cut off the rest.
387                   (mostly a www/api prefix or sth) */
388                s = g_strdup(s + 1);
389                g_free(td->prefix);
390                td->prefix = s;
391        }
392       
393        if (strstr(acc->pass, "oauth_token="))
394                td->oauth_info = oauth_from_string(acc->pass, get_oauth_service(ic));
395
396        sprintf(name, "%s_%s", td->prefix, acc->user);
397        imcb_add_buddy(ic, name, NULL);
398        imcb_buddy_status(ic, name, OPT_LOGGED_IN, NULL, NULL);
399
400        td->log = g_new0(struct twitter_log_data, TWITTER_LOG_LENGTH);
401        td->log_id = -1;
402       
403        s = set_getstr(&ic->acc->set, "mode");
404        if (g_strcasecmp(s, "one") == 0)
405                td->flags |= TWITTER_MODE_ONE;
406        else if (g_strcasecmp(s, "many") == 0)
407                td->flags |= TWITTER_MODE_MANY;
408        else
409                td->flags |= TWITTER_MODE_CHAT;
410
411        twitter_login_finish(ic);
412}
413
414/**
415 * Logout method. Just free the twitter_data.
416 */
417static void twitter_logout(struct im_connection *ic)
418{
419        struct twitter_data *td = ic->proto_data;
420
421        // Set the status to logged out.
422        ic->flags &= ~OPT_LOGGED_IN;
423
424        // Remove the main_loop function from the function queue.
425        b_event_remove(td->main_loop_id);
426
427        if (td->timeline_gc)
428                imcb_chat_free(td->timeline_gc);
429
430        if (td) {
431                http_close(td->stream);
432                oauth_info_free(td->oauth_info);
433                g_free(td->user);
434                g_free(td->prefix);
435                g_free(td->url_host);
436                g_free(td->url_path);
437                g_free(td->log);
438                g_free(td);
439        }
440
441        twitter_connections = g_slist_remove(twitter_connections, ic);
442}
443
444static void twitter_handle_command(struct im_connection *ic, char *message);
445
446/**
447 *
448 */
449static int twitter_buddy_msg(struct im_connection *ic, char *who, char *message, int away)
450{
451        struct twitter_data *td = ic->proto_data;
452        int plen = strlen(td->prefix);
453
454        if (g_strncasecmp(who, td->prefix, plen) == 0 && who[plen] == '_' &&
455            g_strcasecmp(who + plen + 1, ic->acc->user) == 0) {
456                if (set_getbool(&ic->acc->set, "oauth") &&
457                    td->oauth_info && td->oauth_info->token == NULL) {
458                        char pin[strlen(message) + 1], *s;
459
460                        strcpy(pin, message);
461                        for (s = pin + sizeof(pin) - 2; s > pin && isspace(*s); s--)
462                                *s = '\0';
463                        for (s = pin; *s && isspace(*s); s++) {
464                        }
465
466                        if (!oauth_access_token(s, td->oauth_info)) {
467                                imcb_error(ic, "OAuth error: %s",
468                                           "Failed to send access token request");
469                                imc_logout(ic, TRUE);
470                                return FALSE;
471                        }
472                } else
473                        twitter_handle_command(ic, message);
474        } else {
475                twitter_direct_messages_new(ic, who, message);
476        }
477        return (0);
478}
479
480static void twitter_get_info(struct im_connection *ic, char *who)
481{
482}
483
484static void twitter_add_buddy(struct im_connection *ic, char *who, char *group)
485{
486        twitter_friendships_create_destroy(ic, who, 1);
487}
488
489static void twitter_remove_buddy(struct im_connection *ic, char *who, char *group)
490{
491        twitter_friendships_create_destroy(ic, who, 0);
492}
493
494static void twitter_chat_msg(struct groupchat *c, char *message, int flags)
495{
496        if (c && message)
497                twitter_handle_command(c->ic, message);
498}
499
500static void twitter_chat_invite(struct groupchat *c, char *who, char *message)
501{
502}
503
504static void twitter_chat_leave(struct groupchat *c)
505{
506        struct twitter_data *td = c->ic->proto_data;
507
508        if (c != td->timeline_gc)
509                return;         /* WTF? */
510
511        /* If the user leaves the channel: Fine. Rejoin him/her once new
512           tweets come in. */
513        imcb_chat_free(td->timeline_gc);
514        td->timeline_gc = NULL;
515}
516
517static void twitter_keepalive(struct im_connection *ic)
518{
519}
520
521static void twitter_add_permit(struct im_connection *ic, char *who)
522{
523}
524
525static void twitter_rem_permit(struct im_connection *ic, char *who)
526{
527}
528
529static void twitter_add_deny(struct im_connection *ic, char *who)
530{
531}
532
533static void twitter_rem_deny(struct im_connection *ic, char *who)
534{
535}
536
537//static char *twitter_set_display_name( set_t *set, char *value )
538//{
539//      return value;
540//}
541
542static void twitter_buddy_data_add(struct bee_user *bu)
543{
544        bu->data = g_new0(struct twitter_user_data, 1);
545}
546
547static void twitter_buddy_data_free(struct bee_user *bu)
548{
549        g_free(bu->data);
550}
551
552/** Convert the given bitlbee tweet ID, bitlbee username, or twitter tweet ID
553 *  into a twitter tweet ID.
554 *
555 *  Returns 0 if the user provides garbage.
556 */
557static guint64 twitter_message_id_from_command_arg(struct im_connection *ic, char *arg, bee_user_t **bu_) {
558        struct twitter_data *td = ic->proto_data;
559        struct twitter_user_data *tud;
560        bee_user_t *bu = NULL;
561        guint64 id = 0;
562       
563        if (bu_)
564                *bu_ = NULL;
565        if (!arg || !arg[0])
566                return 0;
567       
568        if (arg[0] != '#' && (bu = bee_user_by_handle(ic->bee, ic, arg))) {
569                if ((tud = bu->data))
570                        id = tud->last_id;
571        } else {
572                if (arg[0] == '#')
573                        arg++;
574                if (sscanf(arg, "%" G_GINT64_MODIFIER "x", &id) == 1 &&
575                    id < TWITTER_LOG_LENGTH) {
576                        bu = td->log[id].bu;
577                        id = td->log[id].id;
578                        /* Beware of dangling pointers! */
579                        if (!g_slist_find(ic->bee->users, bu))
580                                bu = NULL;
581                } else if (sscanf(arg, "%" G_GINT64_MODIFIER "d", &id) == 1) {
582                        /* Allow normal tweet IDs as well; not a very useful
583                           feature but it's always been there. Just ignore
584                           very low IDs to avoid accidents. */
585                        if (id < 1000000)
586                                id = 0;
587                }
588        }
589        if (bu_)
590                *bu_ = bu;
591        return id;
592}
593
594static void twitter_handle_command(struct im_connection *ic, char *message)
595{
596        struct twitter_data *td = ic->proto_data;
597        char *cmds, **cmd, *new = NULL;
598        guint64 in_reply_to = 0, id;
599        gboolean allow_post =
600                g_strcasecmp(set_getstr(&ic->acc->set, "commands"), "strict") != 0;
601        bee_user_t *bu = NULL;
602
603        cmds = g_strdup(message);
604        cmd = split_command_parts(cmds, 2);
605
606        if (cmd[0] == NULL) {
607                goto eof;
608        } else if (!set_getbool(&ic->acc->set, "commands") && allow_post) {
609                /* Not supporting commands if "commands" is set to true/strict. */
610        } else if (g_strcasecmp(cmd[0], "undo") == 0) {
611                if (cmd[1] == NULL)
612                        twitter_status_destroy(ic, td->last_status_id);
613                else if ((id = twitter_message_id_from_command_arg(ic, cmd[1], NULL)))
614                        twitter_status_destroy(ic, id);
615                else
616                        twitter_log(ic, "Could not undo last action");
617
618                goto eof;
619        } else if ((g_strcasecmp(cmd[0], "favourite") == 0 ||
620                    g_strcasecmp(cmd[0], "favorite") == 0 ||
621                    g_strcasecmp(cmd[0], "fav") == 0) && cmd[1]) {
622                if ((id = twitter_message_id_from_command_arg(ic, cmd[1], NULL))) {
623                        twitter_favourite_tweet(ic, id);
624                } else {
625                        twitter_log(ic, "Please provide a message ID or username.");
626                }
627                goto eof;
628        } else if (g_strcasecmp(cmd[0], "follow") == 0 && cmd[1]) {
629                twitter_add_buddy(ic, cmd[1], NULL);
630                goto eof;
631        } else if (g_strcasecmp(cmd[0], "unfollow") == 0 && cmd[1]) {
632                twitter_remove_buddy(ic, cmd[1], NULL);
633                goto eof;
634        } else if ((g_strcasecmp(cmd[0], "report") == 0 ||
635                    g_strcasecmp(cmd[0], "spam") == 0) && cmd[1]) {
636                char *screen_name;
637               
638                /* Report nominally works on users but look up the user who
639                   posted the given ID if the user wants to do it that way */
640                twitter_message_id_from_command_arg(ic, cmd[1], &bu);
641                if (bu)
642                        screen_name = bu->handle;
643                else
644                        screen_name = cmd[1];
645               
646                twitter_report_spam(ic, screen_name);
647                goto eof;
648        } else if (g_strcasecmp(cmd[0], "rt") == 0 && cmd[1]) {
649                id = twitter_message_id_from_command_arg(ic, cmd[1], NULL);
650
651                td->last_status_id = 0;
652                if (id)
653                        twitter_status_retweet(ic, id);
654                else
655                        twitter_log(ic, "User `%s' does not exist or didn't "
656                                    "post any statuses recently", cmd[1]);
657
658                goto eof;
659        } else if (g_strcasecmp(cmd[0], "reply") == 0 && cmd[1] && cmd[2]) {
660                id = twitter_message_id_from_command_arg(ic, cmd[1], &bu);
661                if (!id || !bu) {
662                        twitter_log(ic, "User `%s' does not exist or didn't "
663                                    "post any statuses recently", cmd[1]);
664                        goto eof;
665                }
666                message = new = g_strdup_printf("@%s %s", bu->handle, cmd[2]);
667                in_reply_to = id;
668                allow_post = TRUE;
669        } else if (g_strcasecmp(cmd[0], "post") == 0) {
670                message += 5;
671                allow_post = TRUE;
672        }
673
674        if (allow_post) {
675                char *s;
676
677                if (!twitter_length_check(ic, message))
678                        goto eof;
679
680                s = cmd[0] + strlen(cmd[0]) - 1;
681                if (!new && s > cmd[0] && (*s == ':' || *s == ',')) {
682                        *s = '\0';
683
684                        if ((bu = bee_user_by_handle(ic->bee, ic, cmd[0]))) {
685                                struct twitter_user_data *tud = bu->data;
686
687                                new = g_strdup_printf("@%s %s", bu->handle,
688                                                      message + (s - cmd[0]) + 2);
689                                message = new;
690
691                                if (time(NULL) < tud->last_time +
692                                    set_getint(&ic->acc->set, "auto_reply_timeout"))
693                                        in_reply_to = tud->last_id;
694                        }
695                }
696
697                /* If the user runs undo between this request and its response
698                   this would delete the second-last Tweet. Prevent that. */
699                td->last_status_id = 0;
700                twitter_post_status(ic, message, in_reply_to);
701        } else {
702                twitter_log(ic, "Unknown command: %s", cmd[0]);
703        }
704eof:
705        g_free(new);
706        g_free(cmds);
707}
708
709void twitter_log(struct im_connection *ic, char *format, ... )
710{
711        struct twitter_data *td = ic->proto_data;
712        va_list params;
713        char *text;
714       
715        va_start(params, format);
716        text = g_strdup_vprintf(format, params);
717        va_end(params);
718       
719        if (td->timeline_gc)
720                imcb_chat_log(td->timeline_gc, "%s", text);
721        else
722                imcb_log(ic, "%s", text);
723       
724        g_free(text);
725}
726
727
728void twitter_initmodule()
729{
730        struct prpl *ret = g_new0(struct prpl, 1);
731
732        ret->options = OPT_NOOTR;
733        ret->name = "twitter";
734        ret->login = twitter_login;
735        ret->init = twitter_init;
736        ret->logout = twitter_logout;
737        ret->buddy_msg = twitter_buddy_msg;
738        ret->get_info = twitter_get_info;
739        ret->add_buddy = twitter_add_buddy;
740        ret->remove_buddy = twitter_remove_buddy;
741        ret->chat_msg = twitter_chat_msg;
742        ret->chat_invite = twitter_chat_invite;
743        ret->chat_leave = twitter_chat_leave;
744        ret->keepalive = twitter_keepalive;
745        ret->add_permit = twitter_add_permit;
746        ret->rem_permit = twitter_rem_permit;
747        ret->add_deny = twitter_add_deny;
748        ret->rem_deny = twitter_rem_deny;
749        ret->buddy_data_add = twitter_buddy_data_add;
750        ret->buddy_data_free = twitter_buddy_data_free;
751        ret->handle_cmp = g_strcasecmp;
752
753        register_protocol(ret);
754
755        /* And an identi.ca variant: */
756        ret = g_memdup(ret, sizeof(struct prpl));
757        ret->name = "identica";
758        register_protocol(ret);
759}
Note: See TracBrowser for help on using the repository browser.