diff options
| author | Sven Moritz Hallberg <pesco@khjk.org> | 2010-06-03 13:00:45 +0200 | 
|---|---|---|
| committer | Sven Moritz Hallberg <pesco@khjk.org> | 2010-06-03 13:00:45 +0200 | 
| commit | 814aa52228c7cad1d036c1a6dc5ea03cce61c048 (patch) | |
| tree | 7db06b9191f00b086f25789a0a040d15cef580cf /protocols | |
| parent | 5f8ab6a9adf09ea7c07f728227bdb6d3953588f1 (diff) | |
| parent | f4bcc223fea70de8555bbc4d2caf48e0476c0e13 (diff) | |
merge in bitlbee 1.2.6
Diffstat (limited to 'protocols')
| -rw-r--r-- | protocols/jabber/jabber.c | 14 | ||||
| -rw-r--r-- | protocols/jabber/jabber.h | 11 | ||||
| -rw-r--r-- | protocols/jabber/jabber_util.c | 104 | ||||
| -rw-r--r-- | protocols/jabber/message.c | 6 | ||||
| -rw-r--r-- | protocols/jabber/presence.c | 3 | ||||
| -rw-r--r-- | protocols/msn/msn.c | 32 | ||||
| -rw-r--r-- | protocols/msn/msn.h | 9 | ||||
| -rw-r--r-- | protocols/msn/msn_util.c | 16 | ||||
| -rw-r--r-- | protocols/msn/ns.c | 77 | ||||
| -rw-r--r-- | protocols/msn/sb.c | 56 | ||||
| -rw-r--r-- | protocols/nogaim.c | 149 | ||||
| -rw-r--r-- | protocols/nogaim.h | 2 | ||||
| -rw-r--r-- | protocols/oscar/oscar.c | 17 | ||||
| -rw-r--r-- | protocols/twitter/Makefile | 43 | ||||
| -rw-r--r-- | protocols/twitter/twitter.c | 248 | ||||
| -rw-r--r-- | protocols/twitter/twitter.h | 52 | ||||
| -rw-r--r-- | protocols/twitter/twitter_http.c | 161 | ||||
| -rw-r--r-- | protocols/twitter/twitter_http.h | 34 | ||||
| -rw-r--r-- | protocols/twitter/twitter_lib.c | 677 | ||||
| -rw-r--r-- | protocols/twitter/twitter_lib.h | 86 | 
20 files changed, 1666 insertions, 131 deletions
| diff --git a/protocols/jabber/jabber.c b/protocols/jabber/jabber.c index 011f81c2..2841c0db 100644 --- a/protocols/jabber/jabber.c +++ b/protocols/jabber/jabber.c @@ -57,6 +57,8 @@ static void jabber_init( account_t *acc )  	set_t *s;  	char str[16]; +	s = set_add( &acc->set, "activity_timeout", "600", set_eval_int, acc ); +	  	g_snprintf( str, sizeof( str ), "%d", jabber_port_list[0] );  	s = set_add( &acc->set, "port", str, set_eval_int, acc );  	s->flags |= ACC_SET_OFFLINE_ONLY; @@ -306,7 +308,7 @@ static int jabber_buddy_msg( struct im_connection *ic, char *who, char *message,  	if( ( s = strchr( who, '=' ) ) && jabber_chat_by_jid( ic, s + 1 ) )  		bud = jabber_buddy_by_ext_jid( ic, who, 0 );  	else -		bud = jabber_buddy_by_jid( ic, who, 0 ); +		bud = jabber_buddy_by_jid( ic, who, GET_BUDDY_BARE_OK );  	node = xt_new_node( "body", message, NULL );  	node = jabber_make_packet( "message", "chat", bud ? bud->full_jid : who, node ); @@ -351,17 +353,9 @@ static GList *jabber_away_states( struct im_connection *ic )  static void jabber_get_info( struct im_connection *ic, char *who )  { -	struct jabber_data *jd = ic->proto_data;  	struct jabber_buddy *bud; -	if( strchr( who, '/' ) ) -		bud = jabber_buddy_by_jid( ic, who, 0 ); -	else -	{ -		char *s = jabber_normalize( who ); -		bud = g_hash_table_lookup( jd->buddies, s ); -		g_free( s ); -	} +	bud = jabber_buddy_by_jid( ic, who, GET_BUDDY_FIRST );  	while( bud )  	{ diff --git a/protocols/jabber/jabber.h b/protocols/jabber/jabber.h index 8e3bf036..40cf3957 100644 --- a/protocols/jabber/jabber.h +++ b/protocols/jabber/jabber.h @@ -107,6 +107,13 @@ struct jabber_cache_entry  	jabber_cache_event func;  }; +/* Somewhat messy data structure: We have a hash table with the bare JID as +   the key and the head of a struct jabber_buddy list as the value. The head +   is always a bare JID. If the JID has other resources (often the case, +   except for some transports that don't support multiple resources), those +   follow. In that case, the bare JID at the beginning doesn't actually +   refer to a real session and should only be used for operations that +   support incomplete JIDs. */  struct jabber_buddy  {  	char *bare_jid; @@ -120,7 +127,7 @@ struct jabber_buddy  	struct jabber_away_state *away_state;  	char *away_message; -	time_t last_act; +	time_t last_msg;  	jabber_buddy_flags_t flags;  	struct jabber_buddy *next; @@ -208,6 +215,8 @@ typedef enum  	GET_BUDDY_CREAT = 1,	/* Try to create it, if necessary. */  	GET_BUDDY_EXACT = 2,	/* Get an exact match (only makes sense with bare JIDs). */  	GET_BUDDY_FIRST = 4,	/* No selection, simply get the first resource for this JID. */ +	GET_BUDDY_BARE = 8,	/* Get the bare version of the JID (possibly inexistent). */ +	GET_BUDDY_BARE_OK = 16,	/* Allow returning a bare JID if that seems better. */  } get_buddy_flags_t;  struct jabber_error diff --git a/protocols/jabber/jabber_util.c b/protocols/jabber/jabber_util.c index 185d3878..b8b625f7 100644 --- a/protocols/jabber/jabber_util.c +++ b/protocols/jabber/jabber_util.c @@ -3,7 +3,7 @@  *  BitlBee - An IRC to IM gateway                                           *  *  Jabber module - Misc. stuff                                              *  *                                                                           * -*  Copyright 2006 Wilmer van der Gaast <wilmer@gaast.net>                   * +*  Copyright 2006-2010 Wilmer van der Gaast <wilmer@gaast.net>                *                                                                           *  *  This program is free software; you can redistribute it and/or modify     *  *  it under the terms of the GNU General Public License as published by     * @@ -344,6 +344,11 @@ struct jabber_buddy *jabber_buddy_add( struct im_connection *ic, char *full_jid_  	if( ( bud = g_hash_table_lookup( jd->buddies, full_jid ) ) )  	{ +		/* The first entry is always a bare JID. If there are more, we +		   should ignore the first one here. */ +		if( bud->next ) +			bud = bud->next; +		  		/* If this is a transport buddy or whatever, it can't have more  		   than one instance, so this is always wrong: */  		if( s == NULL || bud->resource == NULL ) @@ -378,10 +383,15 @@ struct jabber_buddy *jabber_buddy_add( struct im_connection *ic, char *full_jid_  	}  	else  	{ -		/* Keep in mind that full_jid currently isn't really -		   a full JID... */ -		new->bare_jid = g_strdup( full_jid ); +		new->full_jid = new->bare_jid = g_strdup( full_jid );  		g_hash_table_insert( jd->buddies, new->bare_jid, new ); +		 +		if( s ) +		{ +			new->next = g_new0( struct jabber_buddy, 1 ); +			new->next->bare_jid = new->bare_jid; +			new = new->next; +		}  	}  	if( s ) @@ -407,7 +417,7 @@ struct jabber_buddy *jabber_buddy_add( struct im_connection *ic, char *full_jid_  struct jabber_buddy *jabber_buddy_by_jid( struct im_connection *ic, char *jid_, get_buddy_flags_t flags )  {  	struct jabber_data *jd = ic->proto_data; -	struct jabber_buddy *bud; +	struct jabber_buddy *bud, *head;  	char *s, *jid;  	jid = jabber_normalize( jid_ ); @@ -419,6 +429,11 @@ struct jabber_buddy *jabber_buddy_by_jid( struct im_connection *ic, char *jid_,  		*s = 0;  		if( ( bud = g_hash_table_lookup( jd->buddies, jid ) ) )  		{ +			bare_exists = 1; +			 +			if( bud->next ) +				bud = bud->next; +			  			/* Just return the first one for this bare JID. */  			if( flags & GET_BUDDY_FIRST )  			{ @@ -440,16 +455,9 @@ struct jabber_buddy *jabber_buddy_by_jid( struct im_connection *ic, char *jid_,  				if( strcmp( bud->resource, s + 1 ) == 0 )  					break;  		} -		else -		{ -			/* This variable tells the if down here that the bare -			   JID already exists and we should feel free to add -			   more resources, if the caller asked for that. */ -			bare_exists = 1; -		}  		if( bud == NULL && ( flags & GET_BUDDY_CREAT ) && -		    ( !bare_exists || imcb_find_buddy( ic, jid ) ) ) +		    ( bare_exists || imcb_find_buddy( ic, jid ) ) )  		{  			*s = '/';  			bud = jabber_buddy_add( ic, jid ); @@ -463,7 +471,8 @@ struct jabber_buddy *jabber_buddy_by_jid( struct im_connection *ic, char *jid_,  		struct jabber_buddy *best_prio, *best_time;  		char *set; -		bud = g_hash_table_lookup( jd->buddies, jid ); +		head = g_hash_table_lookup( jd->buddies, jid ); +		bud = ( head && head->next ) ? head->next : head;  		g_free( jid ); @@ -480,22 +489,31 @@ struct jabber_buddy *jabber_buddy_by_jid( struct im_connection *ic, char *jid_,  		else if( flags & GET_BUDDY_FIRST )  			/* Looks like the caller doesn't care about details. */  			return bud; +		else if( flags & GET_BUDDY_BARE ) +			return head;  		best_prio = best_time = bud;  		for( ; bud; bud = bud->next )  		{  			if( bud->priority > best_prio->priority )  				best_prio = bud; -			if( bud->last_act > best_time->last_act ) +			if( bud->last_msg > best_time->last_msg )  				best_time = bud;  		}  		if( ( set = set_getstr( &ic->acc->set, "resource_select" ) ) == NULL )  			return NULL; -		else if( strcmp( set, "activity" ) == 0 ) -			return best_time; -		else /* if( strcmp( set, "priority" ) == 0 ) */ +		else if( strcmp( set, "priority" ) == 0 )  			return best_prio; +		else if( flags & GET_BUDDY_BARE_OK ) /* && strcmp( set, "activity" ) == 0 */ +		{ +			if( best_time->last_msg + set_getint( &ic->acc->set, "activity_timeout" ) >= time( NULL ) ) +				return best_time; +			else +				return head; +		} +		else +			return best_time;  	}  } @@ -537,7 +555,7 @@ struct jabber_buddy *jabber_buddy_by_ext_jid( struct im_connection *ic, char *ji  int jabber_buddy_remove( struct im_connection *ic, char *full_jid_ )  {  	struct jabber_data *jd = ic->proto_data; -	struct jabber_buddy *bud, *prev, *bi; +	struct jabber_buddy *bud, *prev = NULL, *bi;  	char *s, *full_jid;  	full_jid = jabber_normalize( full_jid_ ); @@ -547,6 +565,9 @@ int jabber_buddy_remove( struct im_connection *ic, char *full_jid_ )  	if( ( bud = g_hash_table_lookup( jd->buddies, full_jid ) ) )  	{ +		if( bud->next ) +			bud = (prev=bud)->next; +		  		/* If there's only one item in the list (and if the resource  		   matches), removing it is simple. (And the hash reference  		   should be removed too!) */ @@ -554,16 +575,7 @@ int jabber_buddy_remove( struct im_connection *ic, char *full_jid_ )  		    ( ( s == NULL && bud->resource == NULL ) ||  		      ( bud->resource && s && strcmp( bud->resource, s + 1 ) == 0 ) ) )  		{ -			g_hash_table_remove( jd->buddies, bud->bare_jid ); -			g_free( bud->bare_jid ); -			g_free( bud->ext_jid ); -			g_free( bud->full_jid ); -			g_free( bud->away_message ); -			g_free( bud ); -			 -			g_free( full_jid ); -			 -			return 1; +			return jabber_buddy_remove_bare( ic, full_jid );  		}  		else if( s == NULL || bud->resource == NULL )  		{ @@ -574,7 +586,7 @@ int jabber_buddy_remove( struct im_connection *ic, char *full_jid_ )  		}  		else  		{ -			for( bi = bud, prev = NULL; bi; bi = (prev=bi)->next ) +			for( bi = bud; bi; bi = (prev=bi)->next )  				if( strcmp( bi->resource, s + 1 ) == 0 )  					break; @@ -585,8 +597,7 @@ int jabber_buddy_remove( struct im_connection *ic, char *full_jid_ )  				if( prev )  					prev->next = bi->next;  				else -					/* The hash table should point at the second -					   item, because we're removing the first. */ +					/* Don't think this should ever happen anymore. */  					g_hash_table_replace( jd->buddies, bi->bare_jid, bi->next );  				g_free( bi->ext_jid ); @@ -655,10 +666,9 @@ int jabber_buddy_remove_bare( struct im_connection *ic, char *bare_jid )  time_t jabber_get_timestamp( struct xt_node *xt )  { -	struct tm tp, utc;  	struct xt_node *c; -	time_t res, tres;  	char *s = NULL; +	struct tm tp;  	for( c = xt->children; ( c = xt_find_node( c, "x" ) ); c = c->next )  	{ @@ -676,30 +686,8 @@ time_t jabber_get_timestamp( struct xt_node *xt )  	tp.tm_year -= 1900;  	tp.tm_mon --; -	tp.tm_isdst = -1; /* GRRRRRRRRRRR */ -	 -	res = mktime( &tp ); -	/* Problem is, mktime() just gave us the GMT timestamp for the -	   given local time... While the given time WAS NOT local. So -	   we should fix this now. -	 -	   Now I could choose between messing with environment variables -	   (kludgy) or using timegm() (not portable)... Or doing the -	   following, which I actually prefer... */ -	gmtime_r( &res, &utc ); -	utc.tm_isdst = -1; /* Once more: GRRRRRRRRRRRRRRRRRR!!! */ -	if( utc.tm_hour == tp.tm_hour && utc.tm_min == tp.tm_min ) -		/* Sweet! We're in UTC right now... */ -		return res; -	 -	tres = mktime( &utc ); -	res += res - tres; -	 -	/* Yes, this is a hack. And it will go wrong around DST changes. -	   BUT this is more likely to be threadsafe than messing with -	   environment variables, and possibly more portable... */ -	 -	return res; +	 +	return mktime_utc( &tp );  }  struct jabber_error *jabber_error_parse( struct xt_node *node, char *xmlns ) diff --git a/protocols/jabber/message.c b/protocols/jabber/message.c index 6cb67d42..e8161029 100644 --- a/protocols/jabber/message.c +++ b/protocols/jabber/message.c @@ -70,7 +70,7 @@ xt_status jabber_pkt_message( struct xt_node *node, gpointer data )  		{  			if( bud )  			{ -				bud->last_act = time( NULL ); +				bud->last_msg = time( NULL );  				from = bud->ext_jid ? : bud->bare_jid;  			}  			else @@ -79,8 +79,8 @@ xt_status jabber_pkt_message( struct xt_node *node, gpointer data )  		if( type && strcmp( type, "headline" ) == 0 )  		{ -			c = xt_find_node( node->children, "subject" ); -			g_string_append_printf( fullmsg, "Headline: %s\n", c && c->text_len > 0 ? c->text : "" ); +			if( ( c = xt_find_node( node->children, "subject" ) ) && c->text_len > 0 ) +				g_string_append_printf( fullmsg, "Headline: %s\n", c->text );  			/* <x xmlns="jabber:x:oob"><url>http://....</url></x> can contain a URL, it seems. */  			for( c = node->children; c; c = c->next ) diff --git a/protocols/jabber/presence.c b/protocols/jabber/presence.c index 28aaea1b..006eeead 100644 --- a/protocols/jabber/presence.c +++ b/protocols/jabber/presence.c @@ -67,9 +67,6 @@ xt_status jabber_pkt_presence( struct xt_node *node, gpointer data )  		else  		{  			bud->away_state = NULL; -			/* Let's only set last_act if there's *no* away state, -			   since it could be some auto-away thingy. */ -			bud->last_act = time( NULL );  		}  		if( ( c = xt_find_node( node->children, "priority" ) ) && c->text_len > 0 ) diff --git a/protocols/msn/msn.c b/protocols/msn/msn.c index 327fb028..8bf61aa1 100644 --- a/protocols/msn/msn.c +++ b/protocols/msn/msn.c @@ -30,16 +30,14 @@ int msn_chat_id;  GSList *msn_connections;  GSList *msn_switchboards; -static char *msn_set_display_name( set_t *set, char *value ); +static char *set_eval_display_name( set_t *set, char *value );  static void msn_init( account_t *acc )  { -	set_t *s; -	 -	s = set_add( &acc->set, "display_name", NULL, msn_set_display_name, acc ); -	s->flags |= ACC_SET_NOSAVE | ACC_SET_ONLINE_ONLY; - -	s = set_add( &acc->set, "mail_notifications", "false", set_eval_bool, acc ); +	set_add( &acc->set, "display_name", NULL, set_eval_display_name, acc ); +	set_add( &acc->set, "local_display_name", "false", set_eval_bool, acc ); +	set_add( &acc->set, "mail_notifications", "false", set_eval_bool, acc ); +	set_add( &acc->set, "switchboard_keepalives", "false", set_eval_bool, acc );  }  static void msn_login( account_t *acc ) @@ -166,7 +164,7 @@ static void msn_set_away( struct im_connection *ic, char *state, char *message )  static void msn_set_my_name( struct im_connection *ic, char *info )  { -	msn_set_display_name( set_find( &ic->acc->set, "display_name" ), info ); +	msn_set_display_name( ic, info );  }  static void msn_get_info(struct im_connection *ic, char *who)  @@ -282,18 +280,14 @@ static int msn_send_typing( struct im_connection *ic, char *who, int typing )  		return( 1 );  } -static char *msn_set_display_name( set_t *set, char *value ) +static char *set_eval_display_name( set_t *set, char *value )  {  	account_t *acc = set->data;  	struct im_connection *ic = acc->ic; -	struct msn_data *md; -	char buf[1024], *fn; -	/* Double-check. */ +	/* Allow any name if we're offline. */  	if( ic == NULL ) -		return NULL; -	 -	md = ic->proto_data; +		return value;  	if( strlen( value ) > 129 )  	{ @@ -301,16 +295,10 @@ static char *msn_set_display_name( set_t *set, char *value )  		return NULL;  	} -	fn = msn_http_encode( value ); -	 -	g_snprintf( buf, sizeof( buf ), "REA %d %s %s\r\n", ++md->trId, ic->acc->user, fn ); -	msn_write( ic, buf, strlen( buf ) ); -	g_free( fn ); -	  	/* Returning NULL would be better, because the server still has to  	   confirm the name change. However, it looks a bit confusing to the  	   user. */ -	return value; +	return msn_set_display_name( ic, value ) ? value : NULL;  }  void msn_initmodule() diff --git a/protocols/msn/msn.h b/protocols/msn/msn.h index 84914bc3..83a080a3 100644 --- a/protocols/msn/msn.h +++ b/protocols/msn/msn.h @@ -30,6 +30,7 @@   */  #define TYPING_NOTIFICATION_MESSAGE "\r\r\rBEWARE, ME R TYPINK MESSAGE!!!!\r\r\r"  #define GROUPCHAT_SWITCHBOARD_MESSAGE "\r\r\rME WANT TALK TO MANY PEOPLE\r\r\r" +#define SB_KEEPALIVE_MESSAGE "\r\r\rDONT HANG UP ON ME!\r\r\r"  #ifdef DEBUG_MSN  #define debug( text... ) imcb_log( ic, text ); @@ -53,6 +54,10 @@                             "TypingUser: %s\r\n" \                             "\r\n\r\n" +#define SB_KEEPALIVE_HEADERS "MIME-Version: 1.0\r\n" \ +                             "Content-Type: text/x-ping\r\n" \ +                             "\r\n\r\n" +  #define PROFILE_URL "http://members.msn.com/"  struct msn_data @@ -82,6 +87,7 @@ struct msn_switchboard  	int fd;  	gint inp;  	struct msn_handler_data *handler; +	gint keepalive;  	int trId;  	int ready; @@ -160,6 +166,7 @@ char **msn_linesplit( char *line );  int msn_handler( struct msn_handler_data *h );  char *msn_http_encode( const char *input );  void msn_msgq_purge( struct im_connection *ic, GSList **list ); +gboolean msn_set_display_name( struct im_connection *ic, const char *rawname );  /* tables.c */  const struct msn_away_state *msn_away_state_by_number( int number ); @@ -178,5 +185,7 @@ struct groupchat *msn_sb_to_chat( struct msn_switchboard *sb );  void msn_sb_destroy( struct msn_switchboard *sb );  gboolean msn_sb_connected( gpointer data, gint source, b_input_condition cond );  int msn_sb_write_msg( struct im_connection *ic, struct msn_message *m ); +void msn_sb_start_keepalives( struct msn_switchboard *sb, gboolean initial ); +void msn_sb_stop_keepalives( struct msn_switchboard *sb );  #endif //_MSN_H diff --git a/protocols/msn/msn_util.c b/protocols/msn/msn_util.c index 668a8b8a..9c9d2720 100644 --- a/protocols/msn/msn_util.c +++ b/protocols/msn/msn_util.c @@ -37,10 +37,10 @@ int msn_write( struct im_connection *ic, char *s, int len )  	{  		imcb_error( ic, "Short write() to main server" );  		imc_logout( ic, TRUE ); -		return( 0 ); +		return 0;  	} -	return( 1 ); +	return 1;  }  int msn_logged_in( struct im_connection *ic ) @@ -376,3 +376,15 @@ void msn_msgq_purge( struct im_connection *ic, GSList **list )  	imcb_log( ic, "%s", ret->str );  	g_string_free( ret, TRUE );  } + +gboolean msn_set_display_name( struct im_connection *ic, const char *rawname ) +{ +	char *fn = msn_http_encode( rawname ); +	struct msn_data *md = ic->proto_data; +	char buf[1024]; +	 +	g_snprintf( buf, sizeof( buf ), "REA %d %s %s\r\n", ++md->trId, ic->acc->user, fn ); +	g_free( fn ); +	 +	return msn_write( ic, buf, strlen( buf ) ) != 0; +} diff --git a/protocols/msn/ns.c b/protocols/msn/ns.c index 046fe0af..ca3c38e2 100644 --- a/protocols/msn/ns.c +++ b/protocols/msn/ns.c @@ -34,6 +34,7 @@ static int msn_ns_command( gpointer data, char **cmd, int num_parts );  static int msn_ns_message( gpointer data, char *msg, int msglen, char **cmd, int num_parts );  static void msn_auth_got_passport_token( struct msn_auth_data *mad ); +static gboolean msn_ns_got_display_name( struct im_connection *ic, char *name );  gboolean msn_ns_connected( gpointer data, gint source, b_input_condition cond )  { @@ -230,25 +231,10 @@ static int msn_ns_command( gpointer data, char **cmd, int num_parts )  		}  		else if( num_parts >= 7 && strcmp( cmd[2], "OK" ) == 0 )  		{ -			set_t *s; -			  			if( num_parts == 7 ) -			{ -				http_decode( cmd[4] ); -				 -				strncpy( ic->displayname, cmd[4], sizeof( ic->displayname ) ); -				ic->displayname[sizeof(ic->displayname)-1] = 0; -				 -				if( ( s = set_find( &ic->acc->set, "display_name" ) ) ) -				{ -					g_free( s->value ); -					s->value = g_strdup( cmd[4] ); -				} -			} +				msn_ns_got_display_name( ic, cmd[4] );  			else -			{  				imcb_log( ic, "Warning: Friendly name in server response was corrupted" ); -			}  			imcb_log( ic, "Authenticated, getting buddy list" ); @@ -421,8 +407,12 @@ static int msn_ns_command( gpointer data, char **cmd, int num_parts )  	}  	else if( strcmp( cmd[0], "FLN" ) == 0 )  	{ -		if( cmd[1] ) -			imcb_buddy_status( ic, cmd[1], 0, NULL, NULL ); +		if( cmd[1] == NULL ) +			return 1; +		 +		imcb_buddy_status( ic, cmd[1], 0, NULL, NULL ); +		 +		msn_sb_start_keepalives( msn_sb_by_handle( ic, cmd[1] ), TRUE );  	}  	else if( strcmp( cmd[0], "NLN" ) == 0 )  	{ @@ -448,6 +438,8 @@ static int msn_ns_command( gpointer data, char **cmd, int num_parts )  		imcb_buddy_status( ic, cmd[2], OPT_LOGGED_IN |   		                   ( st != msn_away_state_list ? OPT_AWAY : 0 ),  		                   st->name, NULL ); +		 +		msn_sb_stop_keepalives( msn_sb_by_handle( ic, cmd[2] ) );  	}  	else if( strcmp( cmd[0], "RNG" ) == 0 )  	{ @@ -552,6 +544,9 @@ static int msn_ns_command( gpointer data, char **cmd, int num_parts )  		imc_logout( ic, allow_reconnect );  		return( 0 );  	} +#if 0 +	/* Discard this one completely for now since I don't care about the ack +	   and since MSN servers can apparently screw up the formatting. */  	else if( strcmp( cmd[0], "REA" ) == 0 )  	{  		if( num_parts != 5 ) @@ -582,6 +577,7 @@ static int msn_ns_command( gpointer data, char **cmd, int num_parts )  			imcb_rename_buddy( ic, cmd[3], cmd[4] );  		}  	} +#endif  	else if( strcmp( cmd[0], "IPG" ) == 0 )  	{  		imcb_error( ic, "Received IPG command, we don't handle them yet." ); @@ -731,3 +727,48 @@ static void msn_auth_got_passport_token( struct msn_auth_data *mad )  		imc_logout( ic, TRUE );  	}  } + +static gboolean msn_ns_got_display_name( struct im_connection *ic, char *name ) +{ +	set_t *s; +	 +	if( ( s = set_find( &ic->acc->set, "display_name" ) ) == NULL ) +		return FALSE; /* Shouldn't happen.. */ +	 +	http_decode( name ); +	 +	if( s->value && strcmp( s->value, name ) == 0 ) +	{ +		return TRUE; +		/* The names match, nothing to worry about. */ +	} +	else if( s->value != NULL && +	         ( strcmp( name, ic->acc->user ) == 0 || +	           set_getbool( &ic->acc->set, "local_display_name" ) ) ) +	{ +		/* The server thinks our display name is our e-mail address +		   which is probably wrong, or the user *wants* us to do this: +		   Always use the locally set display_name. */ +		return msn_set_display_name( ic, s->value ); +	} +	else +	{ +		if( s->value && *s->value ) +			imcb_log( ic, "BitlBee thinks your display name is `%s' but " +			              "the MSN server says it's `%s'. Using the MSN " +			              "server's name. Set local_display_name to true " +			              "to use the local name.", s->value, name ); +		 +		if( g_utf8_validate( name, -1, NULL ) ) +		{ +			g_free( s->value ); +			s->value = g_strdup( name ); +		} +		else +		{ +			imcb_log( ic, "Warning: Friendly name in server response was corrupted" ); +		} +		 +		return TRUE; +	} +} diff --git a/protocols/msn/sb.c b/protocols/msn/sb.c index e9526234..e2ee8570 100644 --- a/protocols/msn/sb.c +++ b/protocols/msn/sb.c @@ -167,7 +167,18 @@ int msn_sb_sendmessage( struct msn_switchboard *sb, char *text )  		int i, j;  		/* Build the message. Convert LF to CR-LF for normal messages. */ -		if( strcmp( text, TYPING_NOTIFICATION_MESSAGE ) != 0 ) +		if( strcmp( text, TYPING_NOTIFICATION_MESSAGE ) == 0 ) +		{ +			i = strlen( MSN_TYPING_HEADERS ) + strlen( sb->ic->acc->user ); +			buf = g_new0( char, i ); +			i = g_snprintf( buf, i, MSN_TYPING_HEADERS, sb->ic->acc->user ); +		} +		else if( strcmp( text, SB_KEEPALIVE_MESSAGE ) == 0 ) +		{ +			buf = g_strdup( SB_KEEPALIVE_HEADERS ); +			i = strlen( buf ); +		} +		else  		{  			buf = g_new0( char, sizeof( MSN_MESSAGE_HEADERS ) + strlen( text ) * 2 + 1 );  			i = strlen( MSN_MESSAGE_HEADERS ); @@ -181,12 +192,6 @@ int msn_sb_sendmessage( struct msn_switchboard *sb, char *text )  				buf[i++] = text[j];  			}  		} -		else -		{ -			i = strlen( MSN_TYPING_HEADERS ) + strlen( sb->ic->acc->user ); -			buf = g_new0( char, i ); -			i = g_snprintf( buf, i, MSN_TYPING_HEADERS, sb->ic->acc->user ); -		}  		/* Build the final packet (MSG command + the message). */  		packet = g_strdup_printf( "MSG %d N %d\r\n%s", ++sb->trId, i, buf ); @@ -249,6 +254,7 @@ void msn_sb_destroy( struct msn_switchboard *sb )  	debug( "Destroying switchboard: %s", sb->who ? sb->who : sb->key ? sb->key : "" );  	msn_msgq_purge( ic, &sb->msgq ); +	msn_sb_stop_keepalives( sb );  	if( sb->key ) g_free( sb->key );  	if( sb->who ) g_free( sb->who ); @@ -470,6 +476,8 @@ static int msn_sb_command( gpointer data, char **cmd, int num_parts )  		}  		sb->ready = 1; +		 +		msn_sb_start_keepalives( sb, FALSE );  	}  	else if( strcmp( cmd[0], "CAL" ) == 0 )  	{ @@ -519,6 +527,8 @@ static int msn_sb_command( gpointer data, char **cmd, int num_parts )  				sb->msgq = g_slist_remove( sb->msgq, m );  			} +			msn_sb_start_keepalives( sb, FALSE ); +			  			return( st );  		}  		else if( sb->who ) @@ -580,6 +590,8 @@ static int msn_sb_command( gpointer data, char **cmd, int num_parts )  		if( sb->who )  		{ +			msn_sb_stop_keepalives( sb ); +			  			/* This is a single-person chat, and the other person is leaving. */  			g_free( sb->who );  			sb->who = NULL; @@ -763,3 +775,33 @@ static int msn_sb_message( gpointer data, char *msg, int msglen, char **cmd, int  	return( 1 );  } + +static gboolean msn_sb_keepalive( gpointer data, gint source, b_input_condition cond ) +{ +	struct msn_switchboard *sb = data; +	return sb->ready && msn_sb_sendmessage( sb, SB_KEEPALIVE_MESSAGE ); +} + +void msn_sb_start_keepalives( struct msn_switchboard *sb, gboolean initial ) +{ +	struct buddy *b; +	 +	if( sb && sb->who && sb->keepalive == 0 && +	    ( b = imcb_find_buddy( sb->ic, sb->who ) ) && !b->present && +	    set_getbool( &sb->ic->acc->set, "switchboard_keepalives" ) ) +	{ +		if( initial ) +			msn_sb_keepalive( sb, 0, 0 ); +		 +		sb->keepalive = b_timeout_add( 20000, msn_sb_keepalive, sb ); +	} +} + +void msn_sb_stop_keepalives( struct msn_switchboard *sb ) +{ +	if( sb && sb->keepalive > 0 ) +	{ +		b_event_remove( sb->keepalive ); +		sb->keepalive = 0; +	} +} diff --git a/protocols/nogaim.c b/protocols/nogaim.c index 2b186f1c..f0c87c20 100644 --- a/protocols/nogaim.c +++ b/protocols/nogaim.c @@ -38,6 +38,7 @@  #include "chat.h"  static int remove_chat_buddy_silent( struct groupchat *b, const char *handle ); +static char *format_timestamp( irc_t *irc, time_t msg_ts );  GSList *connections; @@ -131,6 +132,7 @@ void nogaim_init()  	extern void oscar_initmodule();  	extern void byahoo_initmodule();  	extern void jabber_initmodule(); +	extern void twitter_initmodule();  #ifdef WITH_MSN  	msn_initmodule(); @@ -148,6 +150,10 @@ void nogaim_init()  	jabber_initmodule();  #endif +#ifdef WITH_TWITTER +	twitter_initmodule(); +#endif +  #ifdef WITH_PLUGINS  	load_plugins();  #endif @@ -726,7 +732,7 @@ void imcb_buddy_status( struct im_connection *ic, const char *handle, int flags,  void imcb_buddy_msg( struct im_connection *ic, const char *handle, char *msg, uint32_t flags, time_t sent_at )  {  	irc_t *irc = ic->irc; -	char *wrapped; +	char *wrapped, *ts = NULL;  	user_t *u;  	/* pass the message through OTR */ @@ -775,11 +781,20 @@ void imcb_buddy_msg( struct im_connection *ic, const char *handle, char *msg, ui  	if( ( g_strcasecmp( set_getstr( &ic->irc->set, "strip_html" ), "always" ) == 0 ) ||  	    ( ( ic->flags & OPT_DOES_HTML ) && set_getbool( &ic->irc->set, "strip_html" ) ) )  		strip_html( msg ); - +	 +	if( set_getbool( &ic->irc->set, "display_timestamps" ) && +	    ( ts = format_timestamp( irc, sent_at ) ) ) +	{ +		char *new = g_strconcat( ts, msg, NULL ); +		g_free( ts ); +		ts = msg = new; +	} +	  	wrapped = word_wrap( msg, 425 );  	irc_msgfrom( irc, u->nick, wrapped );  	g_free( wrapped );  	g_free( msg ); +	g_free( ts );  }  void imcb_buddy_typing( struct im_connection *ic, char *handle, uint32_t flags ) @@ -823,6 +838,35 @@ struct groupchat *imcb_chat_new( struct im_connection *ic, const char *handle )  	return c;  } +void imcb_chat_name_hint( struct groupchat *c, const char *name ) +{ +	if( !c->joined ) +	{ +		struct im_connection *ic = c->ic; +		char stripped[MAX_NICK_LENGTH+1], *full_name; +		 +		strncpy( stripped, name, MAX_NICK_LENGTH ); +		stripped[MAX_NICK_LENGTH] = '\0'; +		nick_strip( stripped ); +		if( set_getbool( &ic->irc->set, "lcnicks" ) ) +			nick_lc( stripped ); +		 +		full_name = g_strdup_printf( "&%s", stripped ); +		 +		if( stripped[0] && +		    nick_cmp( stripped, ic->irc->channel + 1 ) != 0 && +		    irc_chat_by_channel( ic->irc, full_name ) == NULL ) +		{ +			g_free( c->channel ); +			c->channel = full_name; +		} +		else +		{ +			g_free( full_name ); +		} +	} +} +  void imcb_chat_free( struct groupchat *c )  {  	struct im_connection *ic = c->ic; @@ -883,7 +927,11 @@ void imcb_chat_msg( struct groupchat *c, const char *who, char *msg, uint32_t fl  	wrapped = word_wrap( msg, 425 );  	if( c && u )  	{ -		irc_privmsg( ic->irc, u, "PRIVMSG", c->channel, "", wrapped ); +		char *ts = NULL; +		if( set_getbool( &ic->irc->set, "display_timestamps" ) ) +			ts = format_timestamp( ic->irc, sent_at ); +		irc_privmsg( ic->irc, u, "PRIVMSG", c->channel, ts ? : "", wrapped ); +		g_free( ts );  	}  	else  	{ @@ -1020,6 +1068,97 @@ static int remove_chat_buddy_silent( struct groupchat *b, const char *handle )  } +/* Misc. BitlBee stuff which shouldn't really be here */ + +char *set_eval_timezone( set_t *set, char *value ) +{ +	char *s; +	 +	if( strcmp( value, "local" ) == 0 || +	    strcmp( value, "gmt" ) == 0 || strcmp( value, "utc" ) == 0 ) +		return value; +	 +	/* Otherwise: +/- at the beginning optional, then one or more numbers, +	   possibly followed by a colon and more numbers. Don't bother bound- +	   checking them since users are free to shoot themselves in the foot. */ +	s = value; +	if( *s == '+' || *s == '-' ) +		s ++; +	 +	/* \d+ */ +	if( !isdigit( *s ) ) +		return SET_INVALID; +	while( *s && isdigit( *s ) ) s ++; +	 +	/* EOS? */ +	if( *s == '\0' ) +		return value; +	 +	/* Otherwise, colon */ +	if( *s != ':' ) +		return SET_INVALID; +	s ++; +	 +	/* \d+ */ +	if( !isdigit( *s ) ) +		return SET_INVALID; +	while( *s && isdigit( *s ) ) s ++; +	 +	/* EOS */ +	return *s == '\0' ? value : SET_INVALID; +} + +static char *format_timestamp( irc_t *irc, time_t msg_ts ) +{ +	time_t now_ts = time( NULL ); +	struct tm now, msg; +	char *set; +	 +	/* If the timestamp is <= 0 or less than a minute ago, discard it as +	   it doesn't seem to add to much useful info and/or might be noise. */ +	if( msg_ts <= 0 || msg_ts > now_ts - 60 ) +		return NULL; +	 +	set = set_getstr( &irc->set, "timezone" ); +	if( strcmp( set, "local" ) == 0 ) +	{ +		localtime_r( &now_ts, &now ); +		localtime_r( &msg_ts, &msg ); +	} +	else +	{ +		int hr, min = 0, sign = 60; +		 +		if( set[0] == '-' ) +		{ +			sign *= -1; +			set ++; +		} +		else if( set[0] == '+' ) +		{ +			set ++; +		} +		 +		if( sscanf( set, "%d:%d", &hr, &min ) >= 1 ) +		{ +			msg_ts += sign * ( hr * 60 + min ); +			now_ts += sign * ( hr * 60 + min ); +		} +		 +		gmtime_r( &now_ts, &now ); +		gmtime_r( &msg_ts, &msg ); +	} +	 +	if( msg.tm_year == now.tm_year && msg.tm_yday == now.tm_yday ) +		return g_strdup_printf( "\x02[\x02\x02\x02%02d:%02d:%02d\x02]\x02 ", +		                        msg.tm_hour, msg.tm_min, msg.tm_sec ); +	else +		return g_strdup_printf( "\x02[\x02\x02\x02%04d-%02d-%02d " +		                        "%02d:%02d:%02d\x02]\x02 ", +		                        msg.tm_year + 1900, msg.tm_mon, msg.tm_mday, +		                        msg.tm_hour, msg.tm_min, msg.tm_sec ); +} +  /* The plan is to not allow straight calls to prpl functions anymore, but do     them all from some wrappers. We'll start to define some down here: */ @@ -1063,6 +1202,10 @@ int imc_away_send_update( struct im_connection *ic )  {  	char *away, *msg = NULL; +	if( ic->acc->prpl->away_states == NULL || +	    ic->acc->prpl->set_away == NULL ) +		return 0; +	  	away = set_getstr( &ic->acc->set, "away" ) ?  	     : set_getstr( &ic->irc->set, "away" );  	if( away && *away ) diff --git a/protocols/nogaim.h b/protocols/nogaim.h index ace46053..d3f5847f 100644 --- a/protocols/nogaim.h +++ b/protocols/nogaim.h @@ -305,6 +305,7 @@ G_MODULE_EXPORT void imcb_chat_invited( struct im_connection *ic, char *handle,   *   the user her/himself. At that point the group chat will be visible to the   *   user, too. */  G_MODULE_EXPORT struct groupchat *imcb_chat_new( struct im_connection *ic, const char *handle ); +G_MODULE_EXPORT void imcb_chat_name_hint( struct groupchat *c, const char *name );  G_MODULE_EXPORT void imcb_chat_add_buddy( struct groupchat *b, const char *handle );  /* To remove a handle from a group chat. Reason can be NULL. */  G_MODULE_EXPORT void imcb_chat_remove_buddy( struct groupchat *b, const char *handle, const char *reason ); @@ -327,6 +328,7 @@ void imc_add_block( struct im_connection *ic, char *handle );  void imc_rem_block( struct im_connection *ic, char *handle );  /* Misc. stuff */ +char *set_eval_timezone( set_t *set, char *value );  gboolean auto_reconnect( gpointer data, gint fd, b_input_condition cond );  void cancel_auto_reconnect( struct account *a ); diff --git a/protocols/oscar/oscar.c b/protocols/oscar/oscar.c index cea1e0c4..dbab5c4f 100644 --- a/protocols/oscar/oscar.c +++ b/protocols/oscar/oscar.c @@ -372,11 +372,15 @@ static void oscar_init(account_t *acc)  {  	set_t *s; -	s = set_add( &acc->set, "server", AIM_DEFAULT_LOGIN_SERVER, set_eval_account, acc ); +	if (isdigit(acc->user[0])) { +		set_add(&acc->set, "ignore_auth_requests", "false", set_eval_bool, acc); +	} +	 +	s = set_add(&acc->set, "server", AIM_DEFAULT_LOGIN_SERVER, set_eval_account, acc);  	s->flags |= ACC_SET_NOSAVE | ACC_SET_OFFLINE_ONLY; -	if (isdigit(acc->user[0])) { -		s = set_add( &acc->set, "web_aware", "false", set_eval_bool, acc ); +	if(isdigit(acc->user[0])) { +		s = set_add(&acc->set, "web_aware", "false", set_eval_bool, acc);  		s->flags |= ACC_SET_OFFLINE_ONLY;  	} @@ -1211,10 +1215,15 @@ static void gaim_icq_authdeny(void *data_) {   * For when other people ask you for authorization   */  static void gaim_icq_authask(struct im_connection *ic, guint32 uin, char *msg) { -	struct icq_auth *data = g_new(struct icq_auth, 1); +	struct icq_auth *data;  	char *reason = NULL;  	char *dialog_msg; + +	if (set_getbool(&ic->acc->set, "ignore_auth_requests")) +		return; +	data = g_new(struct icq_auth, 1); +  	if (strlen(msg) > 6)  		reason = msg + 6; diff --git a/protocols/twitter/Makefile b/protocols/twitter/Makefile new file mode 100644 index 00000000..ca1e4695 --- /dev/null +++ b/protocols/twitter/Makefile @@ -0,0 +1,43 @@ +########################### +## Makefile for BitlBee  ## +##                       ## +## Copyright 2002 Lintux ## +########################### + +### DEFINITIONS + +-include ../../Makefile.settings + +# [SH] Program variables +objects = twitter.o twitter_http.o twitter_lib.o + +CFLAGS += -Wall +LFLAGS += -r + +# [SH] Phony targets +all: twitter_mod.o +check: all +lcov: check +gcov:  +	gcov *.c +	 +.PHONY: all clean distclean + +clean: +	rm -f *.o core + +distclean: clean + +### MAIN PROGRAM + +$(objects): ../../Makefile.settings Makefile + +$(objects): %.o: %.c +	@echo '*' Compiling $< +	@$(CC) -c $(CFLAGS) $< -o $@ + +twitter_mod.o: $(objects) +	@echo '*' Linking twitter_mod.o +	@$(LD) $(LFLAGS) $(objects) -o twitter_mod.o +	 + diff --git a/protocols/twitter/twitter.c b/protocols/twitter/twitter.c new file mode 100644 index 00000000..29be8a96 --- /dev/null +++ b/protocols/twitter/twitter.c @@ -0,0 +1,248 @@ +/***************************************************************************\ +*                                                                           * +*  BitlBee - An IRC to IM gateway                                           * +*  Simple module to facilitate twitter functionality.                       * +*                                                                           * +*  Copyright 2009 Geert Mulders <g.c.w.m.mulders@gmail.com>                 * +*                                                                           * +*  This library is free software; you can redistribute it and/or            * +*  modify it under the terms of the GNU Lesser General Public               * +*  License as published by the Free Software Foundation, version            * +*  2.1.                                                                     * +*                                                                           * +*  This library is distributed in the hope that it will be useful,          * +*  but WITHOUT ANY WARRANTY; without even the implied warranty of           * +*  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU        * +*  Lesser General Public License for more details.                          * +*                                                                           * +*  You should have received a copy of the GNU Lesser General Public License * +*  along with this library; if not, write to the Free Software Foundation,  * +*  Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA           * +*                                                                           * +****************************************************************************/ + +#include "nogaim.h" +#include "twitter.h" +#include "twitter_http.h" +#include "twitter_lib.h" + + +/** + * Main loop function + */ +gboolean twitter_main_loop(gpointer data, gint fd, b_input_condition cond) +{ +	struct im_connection *ic = data; +	 +	// Check if we are still logged in... +	if (!g_slist_find( twitter_connections, ic )) +		return 0; + +	// If the user uses multiple private message windows we need to get the  +	// users buddies. +	if (g_strcasecmp(set_getstr(&ic->acc->set, "mode"), "many") == 0) +		twitter_get_statuses_friends(ic, -1); + +	// Do stuff.. +	twitter_get_home_timeline(ic, -1); + +	// If we are still logged in run this function again after timeout. +	return (ic->flags & OPT_LOGGED_IN) == OPT_LOGGED_IN; +} + +static char *set_eval_mode( set_t *set, char *value ) +{ +	if( g_strcasecmp( value, "one" ) == 0 || +	    g_strcasecmp( value, "many" ) == 0 || +	    g_strcasecmp( value, "char" ) == 0 ) +		return value; +	else +		return NULL; +} + +static void twitter_init( account_t *acc ) +{ +	set_t *s; +	 +	s = set_add( &acc->set, "mode", "one", set_eval_mode, acc ); +	s->flags |= ACC_SET_OFFLINE_ONLY; +} + +/** + * Login method. Since the twitter API works with seperate HTTP request we  + * only save the user and pass to the twitter_data object. + */ +static void twitter_login( account_t *acc ) +{ +	struct im_connection *ic = imcb_new( acc ); +	struct twitter_data *td = g_new0( struct twitter_data, 1 ); +	char name[strlen(acc->user)+9]; + +	twitter_connections = g_slist_append( twitter_connections, ic ); + +	td->user = acc->user; +	td->pass = acc->pass; +	td->home_timeline_id = 0; + +	ic->proto_data = td; + +	imcb_log( ic, "Connecting to Twitter" ); + +	// Run this once. After this queue the main loop function. +	twitter_main_loop(ic, -1, 0); + +	// Queue the main_loop +	// Save the return value, so we can remove the timeout on logout. +	td->main_loop_id = b_timeout_add(60000, twitter_main_loop, ic); +	 +	sprintf( name, "twitter_%s", acc->user ); +	imcb_add_buddy( ic, name, NULL ); +	imcb_buddy_status( ic, name, OPT_LOGGED_IN, NULL, NULL ); +} + +/** + * Logout method. Just free the twitter_data. + */ +static void twitter_logout( struct im_connection *ic ) +{ +	struct twitter_data *td = ic->proto_data; +	 +	// Set the status to logged out. +	ic->flags = 0; + +	// Remove the main_loop function from the function queue. +	b_event_remove(td->main_loop_id); + +	if(td->home_timeline_gc) +		imcb_chat_free(td->home_timeline_gc); + +	if( td ) +	{ +		g_free( td ); +	} + +	twitter_connections = g_slist_remove( twitter_connections, ic ); +} + +/** + * + */ +static int twitter_buddy_msg( struct im_connection *ic, char *who, char *message, int away ) +{ +	if (g_strncasecmp(who, "twitter_", 8) == 0 && +	    g_strcasecmp(who + 8, ic->acc->user) == 0) +		twitter_post_status(ic, message); +	else +		twitter_direct_messages_new(ic, who, message); +	 +	return( 0 ); +} + +/** + * + */ +static void twitter_set_my_name( struct im_connection *ic, char *info ) +{ +} + +static void twitter_get_info(struct im_connection *ic, char *who)  +{ +} + +static void twitter_add_buddy( struct im_connection *ic, char *who, char *group ) +{ +} + +static void twitter_remove_buddy( struct im_connection *ic, char *who, char *group ) +{ +} + +static void twitter_chat_msg( struct groupchat *c, char *message, int flags ) +{ +	if( c && message ) +		twitter_post_status(c->ic, message); +} + +static void twitter_chat_invite( struct groupchat *c, char *who, char *message ) +{ +} + +static void twitter_chat_leave( struct groupchat *c ) +{ +	struct twitter_data *td = c->ic->proto_data; +	 +	if( c != td->home_timeline_gc ) +		return; /* WTF? */ +	 +	/* If the user leaves the channel: Fine. Rejoin him/her once new +	   tweets come in. */ +	imcb_chat_free(td->home_timeline_gc); +	td->home_timeline_gc = NULL; +} + +static struct groupchat *twitter_chat_with( struct im_connection *ic, char *who ) +{ +	return NULL; +} + +static void twitter_keepalive( struct im_connection *ic ) +{ +} + +static void twitter_add_permit( struct im_connection *ic, char *who ) +{ +} + +static void twitter_rem_permit( struct im_connection *ic, char *who ) +{ +} + +static void twitter_add_deny( struct im_connection *ic, char *who ) +{ +} + +static void twitter_rem_deny( struct im_connection *ic, char *who ) +{ +} + +static int twitter_send_typing( struct im_connection *ic, char *who, int typing ) +{ +	return( 1 ); +} + +//static char *twitter_set_display_name( set_t *set, char *value ) +//{ +//	return value; +//} + +void twitter_initmodule() +{ +	struct prpl *ret = g_new0(struct prpl, 1); +	 +	ret->name = "twitter"; +	ret->login = twitter_login; +	ret->init = twitter_init; +	ret->logout = twitter_logout; +	ret->buddy_msg = twitter_buddy_msg; +	ret->get_info = twitter_get_info; +	ret->set_my_name = twitter_set_my_name; +	ret->add_buddy = twitter_add_buddy; +	ret->remove_buddy = twitter_remove_buddy; +	ret->chat_msg = twitter_chat_msg; +	ret->chat_invite = twitter_chat_invite; +	ret->chat_leave = twitter_chat_leave; +	ret->chat_with = twitter_chat_with; +	ret->keepalive = twitter_keepalive; +	ret->add_permit = twitter_add_permit; +	ret->rem_permit = twitter_rem_permit; +	ret->add_deny = twitter_add_deny; +	ret->rem_deny = twitter_rem_deny; +	ret->send_typing = twitter_send_typing; +	ret->handle_cmp = g_strcasecmp; + +	register_protocol(ret); + +	// Initialise the twitter_connections GSList. +	twitter_connections = NULL; +} + diff --git a/protocols/twitter/twitter.h b/protocols/twitter/twitter.h new file mode 100644 index 00000000..88caa104 --- /dev/null +++ b/protocols/twitter/twitter.h @@ -0,0 +1,52 @@ +/***************************************************************************\ +*                                                                           * +*  BitlBee - An IRC to IM gateway                                           * +*  Simple module to facilitate twitter functionality.                       * +*                                                                           * +*  Copyright 2009 Geert Mulders <g.c.w.m.mulders@gmail.com>                 * +*                                                                           * +*  This library is free software; you can redistribute it and/or            * +*  modify it under the terms of the GNU Lesser General Public               * +*  License as published by the Free Software Foundation, version            * +*  2.1.                                                                     * +*                                                                           * +*  This library is distributed in the hope that it will be useful,          * +*  but WITHOUT ANY WARRANTY; without even the implied warranty of           * +*  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU        * +*  Lesser General Public License for more details.                          * +*                                                                           * +*  You should have received a copy of the GNU Lesser General Public License * +*  along with this library; if not, write to the Free Software Foundation,  * +*  Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA           * +*                                                                           * +****************************************************************************/ + +#include "nogaim.h" + +#ifndef _TWITTER_H +#define _TWITTER_H + +#ifdef DEBUG_TWITTER +#define debug( text... ) imcb_log( ic, text ); +#else +#define debug( text... ) +#endif + +struct twitter_data +{ +	char* user; +	char* pass; +	guint64 home_timeline_id; +	gint main_loop_id; +	struct groupchat *home_timeline_gc; +	gint http_fails; +}; + +/** + * This has the same function as the msn_connections GSList. We use this to  + * make sure the connection is still alive in callbacks before we do anything + * else. + */ +GSList *twitter_connections; + +#endif //_TWITTER_H diff --git a/protocols/twitter/twitter_http.c b/protocols/twitter/twitter_http.c new file mode 100644 index 00000000..3632140f --- /dev/null +++ b/protocols/twitter/twitter_http.c @@ -0,0 +1,161 @@ +/***************************************************************************\ +*                                                                           * +*  BitlBee - An IRC to IM gateway                                           * +*  Simple module to facilitate twitter functionality.                       * +*                                                                           * +*  Copyright 2009 Geert Mulders <g.c.w.m.mulders@gmail.com>                 * +*                                                                           * +*  This library is free software; you can redistribute it and/or            * +*  modify it under the terms of the GNU Lesser General Public               * +*  License as published by the Free Software Foundation, version            * +*  2.1.                                                                     * +*                                                                           * +*  This library is distributed in the hope that it will be useful,          * +*  but WITHOUT ANY WARRANTY; without even the implied warranty of           * +*  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU        * +*  Lesser General Public License for more details.                          * +*                                                                           * +*  You should have received a copy of the GNU Lesser General Public License * +*  along with this library; if not, write to the Free Software Foundation,  * +*  Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA           * +*                                                                           * +****************************************************************************/ + +/***************************************************************************\ +*                                                                           * +*  Some funtions within this file have been copied from other files within  * +*  BitlBee.                                                                 * +*                                                                           * +****************************************************************************/  + +#include "twitter_http.h" +#include "twitter.h" +#include "bitlbee.h" +#include "url.h" +#include "misc.h" +#include "base64.h" +#include <ctype.h> +#include <errno.h> + + +char *twitter_url_append(char *url, char *key, char* value); + +/** + * Do a request. + * This is actually pretty generic function... Perhaps it should move to the lib/http_client.c + */ +void *twitter_http(char *url_string, http_input_function func, gpointer data, int is_post, char* user, char* pass, char** arguments, int arguments_len) +{ +	url_t *url = g_new0( url_t, 1 ); +	char *tmp; +	char *request; +	void *ret; +	char *userpass = NULL; +	char *userpass_base64; +	char *url_arguments; + +	// Fill the url structure. +	if( !url_set( url, url_string ) ) +	{ +		g_free( url ); +		return NULL; +	} + +	if( url->proto != PROTO_HTTP && url->proto != PROTO_HTTPS ) +	{ +		g_free( url ); +		return NULL; +	} + +	// Concatenate user and pass +	if (user && pass) { +		userpass = g_strdup_printf("%s:%s", user, pass); +		userpass_base64 = base64_encode((unsigned char*)userpass, strlen(userpass)); +	} else { +		userpass_base64 = NULL; +	} + +	url_arguments = g_malloc(1); +	url_arguments[0] = '\0'; + +	// Construct the url arguments. +	if (arguments_len != 0) +	{ +		int i; +		for (i=0; i<arguments_len; i+=2)  +		{ +			tmp = twitter_url_append(url_arguments, arguments[i], arguments[i+1]); +			g_free(url_arguments); +			url_arguments = tmp; +		} +	} + +	// Do GET stuff... +	if (!is_post) +	{ +		// Find the char-pointer of the end of the string. +		tmp = url->file + strlen(url->file); +		tmp[0] = '?'; +		// append the url_arguments to the end of the url->file. +		// TODO GM: Check the length? +		g_stpcpy (tmp+1, url_arguments); +	} + + +	// Make the request. +	request = g_strdup_printf(  "%s %s HTTP/1.0\r\n" +	                            "Host: %s\r\n" +	                            "User-Agent: BitlBee " BITLBEE_VERSION " " ARCH "/" CPU "\r\n", +	                            is_post ? "POST" : "GET", url->file, url->host ); + +	// If a pass and user are given we append them to the request. +	if (userpass_base64) +	{ +		tmp = g_strdup_printf("%sAuthorization: Basic %s\r\n", request, userpass_base64); +		g_free(request); +		request = tmp; +	} + +	// Do POST stuff.. +	if (is_post) +	{ +		// Append the Content-Type and url-encoded arguments. +		tmp = g_strdup_printf("%sContent-Type: application/x-www-form-urlencoded\r\nContent-Length: %zd\r\n\r\n%s",  +								request, strlen(url_arguments), url_arguments); +		g_free(request); +		request = tmp; +	} else { +		// Append an extra \r\n to end the request... +		tmp = g_strdup_printf("%s\r\n", request); +		g_free(request); +		request = tmp; +	} + +	ret = http_dorequest( url->host, url->port,	url->proto == PROTO_HTTPS, request, func, data ); + +	g_free( url ); +	g_free( userpass ); +	g_free( userpass_base64 ); +	g_free( url_arguments ); +	g_free( request ); +	return ret; +} + +char *twitter_url_append(char *url, char *key, char* value) +{ +	char *key_encoded = g_strndup(key, 3 * strlen(key)); +	http_encode(key_encoded); +	char *value_encoded = g_strndup(value, 3 * strlen(value)); +	http_encode(value_encoded); + +	char *retval; +	if (strlen(url) != 0) +		retval = g_strdup_printf("%s&%s=%s", url, key_encoded, value_encoded); +	else +		retval = g_strdup_printf("%s=%s", key_encoded, value_encoded); + +	g_free(key_encoded); +	g_free(value_encoded); + +	return retval; +} diff --git a/protocols/twitter/twitter_http.h b/protocols/twitter/twitter_http.h new file mode 100644 index 00000000..ec4a0b7c --- /dev/null +++ b/protocols/twitter/twitter_http.h @@ -0,0 +1,34 @@ +/***************************************************************************\ +*                                                                           * +*  BitlBee - An IRC to IM gateway                                           * +*  Simple module to facilitate twitter functionality.                       * +*                                                                           * +*  Copyright 2009 Geert Mulders <g.c.w.m.mulders@gmail.com>                 * +*                                                                           * +*  This library is free software; you can redistribute it and/or            * +*  modify it under the terms of the GNU Lesser General Public               * +*  License as published by the Free Software Foundation, version            * +*  2.1.                                                                     * +*                                                                           * +*  This library is distributed in the hope that it will be useful,          * +*  but WITHOUT ANY WARRANTY; without even the implied warranty of           * +*  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU        * +*  Lesser General Public License for more details.                          * +*                                                                           * +*  You should have received a copy of the GNU Lesser General Public License * +*  along with this library; if not, write to the Free Software Foundation,  * +*  Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA           * +*                                                                           * +****************************************************************************/ + +#ifndef _TWITTER_HTTP_H +#define _TWITTER_HTTP_H + +#include "nogaim.h" +#include "http_client.h" + +void *twitter_http(char *url_string, http_input_function func, gpointer data, int is_post,  +					char* user, char* pass, char** arguments, int arguments_len); + +#endif //_TWITTER_HTTP_H + diff --git a/protocols/twitter/twitter_lib.c b/protocols/twitter/twitter_lib.c new file mode 100644 index 00000000..d58afd73 --- /dev/null +++ b/protocols/twitter/twitter_lib.c @@ -0,0 +1,677 @@ +/***************************************************************************\ +*                                                                           * +*  BitlBee - An IRC to IM gateway                                           * +*  Simple module to facilitate twitter functionality.                       * +*                                                                           * +*  Copyright 2009 Geert Mulders <g.c.w.m.mulders@gmail.com>                 * +*                                                                           * +*  This library is free software; you can redistribute it and/or            * +*  modify it under the terms of the GNU Lesser General Public               * +*  License as published by the Free Software Foundation, version            * +*  2.1.                                                                     * +*                                                                           * +*  This library is distributed in the hope that it will be useful,          * +*  but WITHOUT ANY WARRANTY; without even the implied warranty of           * +*  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU        * +*  Lesser General Public License for more details.                          * +*                                                                           * +*  You should have received a copy of the GNU Lesser General Public License * +*  along with this library; if not, write to the Free Software Foundation,  * +*  Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA           * +*                                                                           * +****************************************************************************/ + +/* For strptime(): */ +#define _XOPEN_SOURCE + +#include "twitter_http.h" +#include "twitter.h" +#include "bitlbee.h" +#include "url.h" +#include "misc.h" +#include "base64.h" +#include "xmltree.h" +#include "twitter_lib.h" +#include <ctype.h> +#include <errno.h> + +#define TXL_STATUS 1 +#define TXL_USER 2 +#define TXL_ID 3 + +struct twitter_xml_list { +	int type; +	int next_cursor; +	GSList *list; +	gpointer data; +}; + +struct twitter_xml_user { +	char *name; +	char *screen_name; +}; + +struct twitter_xml_status { +	time_t created_at; +	char *text; +	struct twitter_xml_user *user; +	guint64 id; +}; + +/** + * Frees a twitter_xml_user struct. + */ +static void txu_free(struct twitter_xml_user *txu) +{ +	g_free(txu->name); +	g_free(txu->screen_name); +	g_free(txu); +} + + +/** + * Frees a twitter_xml_status struct. + */ +static void txs_free(struct twitter_xml_status *txs) +{ +	g_free(txs->text); +	txu_free(txs->user); +	g_free(txs); +} + +/** + * Free a twitter_xml_list struct. + * type is the type of list the struct holds. + */ +static void txl_free(struct twitter_xml_list *txl) +{ +	GSList *l; +	for ( l = txl->list; l ; l = g_slist_next(l) ) +		if (txl->type == TXL_STATUS) +			txs_free((struct twitter_xml_status *)l->data); +		else if (txl->type == TXL_ID) +			g_free(l->data); +	g_slist_free(txl->list); +} + +/** + * Add a buddy if it is not allready added, set the status to logged in. + */ +static void twitter_add_buddy(struct im_connection *ic, char *name, const char *fullname) +{ +	struct twitter_data *td = ic->proto_data; + +	// Check if the buddy is allready in the buddy list. +	if (!imcb_find_buddy( ic, name )) +	{ +		char *mode = set_getstr(&ic->acc->set, "mode"); +		 +		// The buddy is not in the list, add the buddy and set the status to logged in. +		imcb_add_buddy( ic, name, NULL ); +		imcb_rename_buddy( ic, name, fullname ); +		if (g_strcasecmp(mode, "chat") == 0) +			imcb_chat_add_buddy( td->home_timeline_gc, name ); +		else if (g_strcasecmp(mode, "many") == 0) +			imcb_buddy_status( ic, name, OPT_LOGGED_IN, NULL, NULL ); +	} +} + +static void twitter_http_get_friends_ids(struct http_request *req); + +/** + * Get the friends ids. + */ +void twitter_get_friends_ids(struct im_connection *ic, int next_cursor) +{ +	struct twitter_data *td = ic->proto_data; + +	// Primitive, but hey! It works...	 +	char* args[2]; +	args[0] = "cursor"; +	args[1] = g_strdup_printf ("%d", next_cursor); +	twitter_http(TWITTER_FRIENDS_IDS_URL, twitter_http_get_friends_ids, ic, 0, td->user, td->pass, args, 2); + +	g_free(args[1]); +} + +/** + * Function to help fill a list. + */ +static xt_status twitter_xt_next_cursor( struct xt_node *node, struct twitter_xml_list *txl ) +{ +	// Do something with the cursor. +	txl->next_cursor = node->text != NULL ? atoi(node->text) : -1; + +	return XT_HANDLED; +} + +/** + * Fill a list of ids. + */ +static xt_status twitter_xt_get_friends_id_list( struct xt_node *node, struct twitter_xml_list *txl ) +{ +	struct xt_node *child; +	 +	// Set the list type. +	txl->type = TXL_ID; + +	// The root <statuses> node should hold the list of statuses <status> +	// Walk over the nodes children. +	for( child = node->children ; child ; child = child->next ) +	{ +		if ( g_strcasecmp( "id", child->name ) == 0) +		{ +			// Add the item to the list. +			txl->list = g_slist_append (txl->list, g_memdup( child->text, child->text_len + 1 )); +		} +		else if ( g_strcasecmp( "next_cursor", child->name ) == 0) +		{ +			twitter_xt_next_cursor(child, txl); +		} +	} + +	return XT_HANDLED; +} + +/** + * Callback for getting the friends ids. + */ +static void twitter_http_get_friends_ids(struct http_request *req) +{ +	struct im_connection *ic; +	struct xt_parser *parser; +	struct twitter_xml_list *txl; +	struct twitter_data *td; + +	ic = req->data; + +	// Check if the connection is still active. +	if( !g_slist_find( twitter_connections, ic ) ) +		return; +	 +	td = ic->proto_data; + +	// Check if the HTTP request went well. +	if (req->status_code != 200) { +		// It didn't go well, output the error and return. +		if (++td->http_fails >= 5) +			imcb_error(ic, "Could not retrieve friends. HTTP STATUS: %d", req->status_code); +		 +		return; +	} else { +		td->http_fails = 0; +	} + +	txl = g_new0(struct twitter_xml_list, 1); + +	// Parse the data. +	parser = xt_new( NULL, txl ); +	xt_feed( parser, req->reply_body, req->body_size ); +	twitter_xt_get_friends_id_list(parser->root, txl); +	xt_free( parser ); + +	if (txl->next_cursor) +		twitter_get_friends_ids(ic, txl->next_cursor); + +	txl_free(txl); +	g_free(txl); +} + +/** + * Function to fill a twitter_xml_user struct. + * It sets: + *  - the name and + *  - the screen_name. + */ +static xt_status twitter_xt_get_user( struct xt_node *node, struct twitter_xml_user *txu ) +{ +	struct xt_node *child; + +	// Walk over the nodes children. +	for( child = node->children ; child ; child = child->next ) +	{ +		if ( g_strcasecmp( "name", child->name ) == 0) +		{ +			txu->name = g_memdup( child->text, child->text_len + 1 ); +		} +		else if (g_strcasecmp( "screen_name", child->name ) == 0) +		{ +			txu->screen_name = g_memdup( child->text, child->text_len + 1 ); +		} +	} +	return XT_HANDLED; +} + +/** + * Function to fill a twitter_xml_list struct. + * It sets: + *  - all <user>s from the <users> element. + */ +static xt_status twitter_xt_get_users( struct xt_node *node, struct twitter_xml_list *txl ) +{ +	struct twitter_xml_user *txu; +	struct xt_node *child; + +	// Set the type of the list. +	txl->type = TXL_USER; + +	// The root <users> node should hold the list of users <user> +	// Walk over the nodes children. +	for( child = node->children ; child ; child = child->next ) +	{ +		if ( g_strcasecmp( "user", child->name ) == 0) +		{ +			txu = g_new0(struct twitter_xml_user, 1); +			twitter_xt_get_user(child, txu); +			// Put the item in the front of the list. +			txl->list = g_slist_prepend (txl->list, txu); +		} +	} + +	return XT_HANDLED; +} + +/** + * Function to fill a twitter_xml_list struct. + * It calls twitter_xt_get_users to get the <user>s from a <users> element. + * It sets: + *  - the next_cursor. + */ +static xt_status twitter_xt_get_user_list( struct xt_node *node, struct twitter_xml_list *txl ) +{ +	struct xt_node *child; + +	// Set the type of the list. +	txl->type = TXL_USER; + +	// The root <user_list> node should hold a users <users> element +	// Walk over the nodes children. +	for( child = node->children ; child ; child = child->next ) +	{ +		if ( g_strcasecmp( "users", child->name ) == 0) +		{ +			twitter_xt_get_users(child, txl); +		} +		else if ( g_strcasecmp( "next_cursor", child->name ) == 0) +		{ +			twitter_xt_next_cursor(child, txl); +		} +	} + +	return XT_HANDLED; +} + + +/** + * Function to fill a twitter_xml_status struct. + * It sets: + *  - the status text and + *  - the created_at timestamp and + *  - the status id and + *  - the user in a twitter_xml_user struct. + */ +static xt_status twitter_xt_get_status( struct xt_node *node, struct twitter_xml_status *txs ) +{ +	struct xt_node *child; + +	// Walk over the nodes children. +	for( child = node->children ; child ; child = child->next ) +	{ +		if ( g_strcasecmp( "text", child->name ) == 0) +		{ +			txs->text = g_memdup( child->text, child->text_len + 1 ); +		} +		else if (g_strcasecmp( "created_at", child->name ) == 0) +		{ +			struct tm parsed; +			 +			/* Very sensitive to changes to the formatting of +			   this field. :-( Also assumes the timezone used +			   is UTC since C time handling functions suck. */ +			if( strptime( child->text, "%a %b %d %H:%M:%S %z %Y", &parsed ) != NULL ) +				txs->created_at = mktime_utc( &parsed ); +		} +		else if (g_strcasecmp( "user", child->name ) == 0) +		{ +			txs->user = g_new0(struct twitter_xml_user, 1); +			twitter_xt_get_user( child, txs->user ); +		} +		else if (g_strcasecmp( "id", child->name ) == 0) +		{ +			txs->id = g_ascii_strtoull (child->text, NULL, 10); +		} +	} +	return XT_HANDLED; +} + +/** + * Function to fill a twitter_xml_list struct. + * It sets: + *  - all <status>es within the <status> element and + *  - the next_cursor. + */ +static xt_status twitter_xt_get_status_list( struct xt_node *node, struct twitter_xml_list *txl ) +{ +	struct twitter_xml_status *txs; +	struct xt_node *child; + +	// Set the type of the list. +	txl->type = TXL_STATUS; + +	// The root <statuses> node should hold the list of statuses <status> +	// Walk over the nodes children. +	for( child = node->children ; child ; child = child->next ) +	{ +		if ( g_strcasecmp( "status", child->name ) == 0) +		{ +			txs = g_new0(struct twitter_xml_status, 1); +			twitter_xt_get_status(child, txs); +			// Put the item in the front of the list. +			txl->list = g_slist_prepend (txl->list, txs); +		} +		else if ( g_strcasecmp( "next_cursor", child->name ) == 0) +		{ +			twitter_xt_next_cursor(child, txl); +		} +	} + +	return XT_HANDLED; +} + +static void twitter_http_get_home_timeline(struct http_request *req); + +/** + * Get the timeline. + */ +void twitter_get_home_timeline(struct im_connection *ic, int next_cursor) +{ +	struct twitter_data *td = ic->proto_data; + +	char* args[4]; +	args[0] = "cursor"; +	args[1] = g_strdup_printf ("%d", next_cursor); +	if (td->home_timeline_id) { +		args[2] = "since_id"; +		args[3] = g_strdup_printf ("%llu", (long long unsigned int) td->home_timeline_id); +	} + +	twitter_http(TWITTER_HOME_TIMELINE_URL, twitter_http_get_home_timeline, ic, 0, td->user, td->pass, args, td->home_timeline_id ? 4 : 2); + +	g_free(args[1]); +	if (td->home_timeline_id) { +		g_free(args[3]); +	} +} + +/** + * Function that is called to see the statuses in a groupchat window. + */ +static void twitter_groupchat(struct im_connection *ic, GSList *list) +{ +	struct twitter_data *td = ic->proto_data; +	GSList *l = NULL; +	struct twitter_xml_status *status; +	struct groupchat *gc; + +	// Create a new groupchat if it does not exsist. +	if (!td->home_timeline_gc) +	{    +		char *name_hint = g_strdup_printf( "Twitter_%s", ic->acc->user ); +		td->home_timeline_gc = gc = imcb_chat_new( ic, "home/timeline" ); +		imcb_chat_name_hint( gc, name_hint ); +		g_free( name_hint ); +		// Add the current user to the chat... +		imcb_chat_add_buddy( gc, ic->acc->user ); +	} +	else +	{    +		gc = td->home_timeline_gc; +	} + +	for ( l = list; l ; l = g_slist_next(l) ) +	{ +		status = l->data; +		twitter_add_buddy(ic, status->user->screen_name, status->user->name); +		 +		// Say it! +		if (g_strcasecmp(td->user, status->user->screen_name) == 0) +			imcb_chat_log (gc, "Your Tweet: %s", status->text); +		else +			imcb_chat_msg (gc, status->user->screen_name, status->text, 0, status->created_at ); +		 +		// Update the home_timeline_id to hold the highest id, so that by the next request +		// we won't pick up the updates allready in the list. +		td->home_timeline_id = td->home_timeline_id < status->id ? status->id : td->home_timeline_id; +	} +} + +/** + * Function that is called to see statuses as private messages. + */ +static void twitter_private_message_chat(struct im_connection *ic, GSList *list) +{ +	struct twitter_data *td = ic->proto_data; +	GSList *l = NULL; +	struct twitter_xml_status *status; +	char from[MAX_STRING]; +	gboolean mode_one; +	 +	mode_one = g_strcasecmp( set_getstr( &ic->acc->set, "mode" ), "one" ) == 0; + +	if( mode_one ) +	{ +		g_snprintf( from, sizeof( from ) - 1, "twitter_%s", ic->acc->user ); +		from[MAX_STRING-1] = '\0'; +	} +	 +	for ( l = list; l ; l = g_slist_next(l) ) +	{ +		char *text = NULL; +		 +		status = l->data; +		 +		if( mode_one ) +			text = g_strdup_printf( "\002<\002%s\002>\002 %s", +			                        status->user->screen_name, status->text ); +		else +			twitter_add_buddy(ic, status->user->screen_name, status->user->name); +		 +		imcb_buddy_msg( ic, +		                mode_one ? from : status->user->screen_name, +		                mode_one ? text : status->text, +		                0, status->created_at ); +		 +		// Update the home_timeline_id to hold the highest id, so that by the next request +		// we won't pick up the updates allready in the list. +		td->home_timeline_id = td->home_timeline_id < status->id ? status->id : td->home_timeline_id; +		 +		g_free( text ); +	} +} + +/** + * Callback for getting the home timeline. + */ +static void twitter_http_get_home_timeline(struct http_request *req) +{ +	struct im_connection *ic = req->data; +	struct twitter_data *td; +	struct xt_parser *parser; +	struct twitter_xml_list *txl; + +	// Check if the connection is still active. +	if( !g_slist_find( twitter_connections, ic ) ) +		return; +	 +	td = ic->proto_data; + +	// Check if the HTTP request went well. +	if (req->status_code == 200) +	{ +		td->http_fails = 0; +		if (!ic->flags & OPT_LOGGED_IN) +			imcb_connected(ic); +	} +	else if (req->status_code == 401) +	{ +		imcb_error( ic, "Authentication failure" ); +		imc_logout( ic, FALSE ); +		return; +	} +	else +	{ +		// It didn't go well, output the error and return. +		if (++td->http_fails >= 5) +			imcb_error(ic, "Could not retrieve " TWITTER_HOME_TIMELINE_URL ". HTTP STATUS: %d", req->status_code); +		 +		return; +	} + +	txl = g_new0(struct twitter_xml_list, 1); +	txl->list = NULL; + +	// Parse the data. +	parser = xt_new( NULL, txl ); +	xt_feed( parser, req->reply_body, req->body_size ); +	// The root <statuses> node should hold the list of statuses <status> +	twitter_xt_get_status_list(parser->root, txl); +	xt_free( parser ); + +	// See if the user wants to see the messages in a groupchat window or as private messages. +	if (g_strcasecmp(set_getstr(&ic->acc->set, "mode"), "chat") == 0) +		twitter_groupchat(ic, txl->list); +	else +		twitter_private_message_chat(ic, txl->list); + +	// Free the structure.	 +	txl_free(txl); +	g_free(txl); +} + +/** + * Callback for getting (twitter)friends... + * + * Be afraid, be very afraid! This function will potentially add hundreds of "friends". "Who has  + * hundreds of friends?" you wonder? You probably not, since you are reading the source of  + * BitlBee... Get a life and meet new people! + */ +static void twitter_http_get_statuses_friends(struct http_request *req) +{ +	struct im_connection *ic = req->data; +	struct twitter_data *td; +	struct xt_parser *parser; +	struct twitter_xml_list *txl; +	GSList *l = NULL; +	struct twitter_xml_user *user; + +	// Check if the connection is still active. +	if( !g_slist_find( twitter_connections, ic ) ) +		return; +	 +	td = ic->proto_data; +	 +	// Check if the HTTP request went well. +	if (req->status_code != 200) { +		// It didn't go well, output the error and return. +		if (++td->http_fails >= 5) +			imcb_error(ic, "Could not retrieve " TWITTER_SHOW_FRIENDS_URL " HTTP STATUS: %d", req->status_code); +		 +		return; +	} else { +		td->http_fails = 0; +	} + +	txl = g_new0(struct twitter_xml_list, 1); +	txl->list = NULL; + +	// Parse the data. +	parser = xt_new( NULL, txl ); +	xt_feed( parser, req->reply_body, req->body_size ); + +	// Get the user list from the parsed xml feed. +	twitter_xt_get_user_list(parser->root, txl); +	xt_free( parser ); + +	// Add the users as buddies. +	for ( l = txl->list; l ; l = g_slist_next(l) ) +	{ +		user = l->data; +		twitter_add_buddy(ic, user->screen_name, user->name); +	} + +	// if the next_cursor is set to something bigger then 0 there are more friends to gather. +	if (txl->next_cursor > 0) +		twitter_get_statuses_friends(ic, txl->next_cursor); + +	// Free the structure. +	txl_free(txl); +	g_free(txl); +} + +/** + * Get the friends. + */ +void twitter_get_statuses_friends(struct im_connection *ic, int next_cursor) +{ +	struct twitter_data *td = ic->proto_data; + +	char* args[2]; +	args[0] = "cursor"; +	args[1] = g_strdup_printf ("%d", next_cursor); + +	twitter_http(TWITTER_SHOW_FRIENDS_URL, twitter_http_get_statuses_friends, ic, 0, td->user, td->pass, args, 2); + +	g_free(args[1]); +} + +/** + * Callback after sending a new update to twitter. + */ +static void twitter_http_post_status(struct http_request *req) +{ +	struct im_connection *ic = req->data; + +	// Check if the connection is still active. +	if( !g_slist_find( twitter_connections, ic ) ) +		return; + +	// Check if the HTTP request went well. +	if (req->status_code != 200) { +		// It didn't go well, output the error and return. +		imcb_error(ic, "Could not post message... HTTP STATUS: %d", req->status_code); +		return; +	} +} + +/** + * Function to POST a new status to twitter. + */  +void twitter_post_status(struct im_connection *ic, char* msg) +{ +	struct twitter_data *td = ic->proto_data; + +	char* args[2]; +	args[0] = "status"; +	args[1] = msg; +	twitter_http(TWITTER_STATUS_UPDATE_URL, twitter_http_post_status, ic, 1, td->user, td->pass, args, 2); +//	g_free(args[1]); +} + + +/** + * Function to POST a new message to twitter. + */ +void twitter_direct_messages_new(struct im_connection *ic, char *who, char *msg) +{ +	struct twitter_data *td = ic->proto_data; + +	char* args[4]; +	args[0] = "screen_name"; +	args[1] = who; +	args[2] = "text"; +	args[3] = msg; +	// Use the same callback as for twitter_post_status, since it does basically the same. +	twitter_http(TWITTER_DIRECT_MESSAGES_NEW_URL, twitter_http_post_status, ic, 1, td->user, td->pass, args, 4); +//	g_free(args[1]); +//	g_free(args[3]); +} diff --git a/protocols/twitter/twitter_lib.h b/protocols/twitter/twitter_lib.h new file mode 100644 index 00000000..e47bfd95 --- /dev/null +++ b/protocols/twitter/twitter_lib.h @@ -0,0 +1,86 @@ +/***************************************************************************\ +*                                                                           * +*  BitlBee - An IRC to IM gateway                                           * +*  Simple module to facilitate twitter functionality.                       * +*                                                                           * +*  Copyright 2009 Geert Mulders <g.c.w.m.mulders@gmail.com>                 * +*                                                                           * +*  This library is free software; you can redistribute it and/or            * +*  modify it under the terms of the GNU Lesser General Public               * +*  License as published by the Free Software Foundation, version            * +*  2.1.                                                                     * +*                                                                           * +*  This library is distributed in the hope that it will be useful,          * +*  but WITHOUT ANY WARRANTY; without even the implied warranty of           * +*  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU        * +*  Lesser General Public License for more details.                          * +*                                                                           * +*  You should have received a copy of the GNU Lesser General Public License * +*  along with this library; if not, write to the Free Software Foundation,  * +*  Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA           * +*                                                                           * +****************************************************************************/ + + +#ifndef _TWITTER_LIB_H +#define _TWITTER_LIB_H + +#include "nogaim.h" +#include "twitter_http.h" + +#define TWITTER_API_URL "http://twitter.com" + +/* Status URLs */ +#define TWITTER_STATUS_UPDATE_URL TWITTER_API_URL "/statuses/update.xml" +#define TWITTER_STATUS_SHOW_URL TWITTER_API_URL "/statuses/show/" +#define TWITTER_STATUS_DESTROY_URL TWITTER_API_URL "/statuses/destroy/" + +/* Timeline URLs */ +#define TWITTER_PUBLIC_TIMELINE_URL TWITTER_API_URL "/statuses/public_timeline.xml" +#define TWITTER_FEATURED_USERS_URL TWITTER_API_URL "/statuses/featured.xml" +#define TWITTER_FRIENDS_TIMELINE_URL TWITTER_API_URL "/statuses/friends_timeline.xml" +#define TWITTER_HOME_TIMELINE_URL TWITTER_API_URL "/statuses/home_timeline.xml" +#define TWITTER_MENTIONS_URL TWITTER_API_URL "/statuses/mentions.xml" +#define TWITTER_USER_TIMELINE_URL TWITTER_API_URL "/statuses/user_timeline.xml" + +/* Users URLs */ +#define TWITTER_SHOW_USERS_URL TWITTER_API_URL "/users/show.xml" +#define TWITTER_SHOW_FRIENDS_URL TWITTER_API_URL "/statuses/friends.xml" +#define TWITTER_SHOW_FOLLOWERS_URL TWITTER_API_URL "/statuses/followers.xml" + +/* Direct messages URLs */ +#define TWITTER_DIRECT_MESSAGES_URL TWITTER_API_URL "/direct_messages.xml" +#define TWITTER_DIRECT_MESSAGES_NEW_URL TWITTER_API_URL "/direct_messages/new.xml" +#define TWITTER_DIRECT_MESSAGES_SENT_URL TWITTER_API_URL "/direct_messages/sent.xml" +#define TWITTER_DIRECT_MESSAGES_DESTROY_URL TWITTER_API_URL "/direct_messages/destroy/" + +/* Friendships URLs */ +#define TWITTER_FRIENDSHIPS_CREATE_URL TWITTER_API_URL "/friendships/create.xml" +#define TWITTER_FRIENDSHIPS_DESTROY_URL TWITTER_API_URL "/friendships/destroy.xml" +#define TWITTER_FRIENDSHIPS_SHOW_URL TWITTER_API_URL "/friendships/show.xml" + +/* Social graphs URLs */ +#define TWITTER_FRIENDS_IDS_URL TWITTER_API_URL "/friends/ids.xml" +#define TWITTER_FOLLOWERS_IDS_URL TWITTER_API_URL "/followers/ids.xml" + +/* Account URLs */ +#define TWITTER_ACCOUNT_RATE_LIMIT_URL TWITTER_API_URL "/account/rate_limit_status.xml" + +/* Favorites URLs */ +#define TWITTER_FAVORITES_GET_URL TWITTER_API_URL "/favorites.xml" +#define TWITTER_FAVORITE_CREATE_URL TWITTER_API_URL "/favorites/create/" +#define TWITTER_FAVORITE_DESTROY_URL TWITTER_API_URL "/favorites/destroy/" + +/* Block URLs */ +#define TWITTER_BLOCKS_CREATE_URL TWITTER_API_URL "/blocks/create/" +#define TWITTER_BLOCKS_DESTROY_URL TWITTER_API_URL "/blocks/destroy/" + +void twitter_get_friends_ids(struct im_connection *ic, int next_cursor); +void twitter_get_home_timeline(struct im_connection *ic, int next_cursor); +void twitter_get_statuses_friends(struct im_connection *ic, int next_cursor); + +void twitter_post_status(struct im_connection *ic, char *msg); +void twitter_direct_messages_new(struct im_connection *ic, char *who, char *message); + +#endif //_TWITTER_LIB_H + | 
