Changes in protocols/msn/sb.c [e35d1a1:8ff0a61]

File:

• protocols/msn/sb.c (modified) (10 diffs)

protocols/msn/sb.c

@@ -128 +128 @@
                 if( strcmp( text, TYPING_NOTIFICATION_MESSAGE ) != 0 )
                 {
-                        buf = g_new0( char, sizeof( MSN_MESSAGE_HEADERS ) + strlen( text ) * 2 );
+                        buf = g_new0( char, sizeof( MSN_MESSAGE_HEADERS ) + strlen( text ) * 2 + 1 );
                         i = strlen( MSN_MESSAGE_HEADERS );
                         
@@ -207 +207 @@
         debug( "Destroying switchboard: %s", sb->who ? sb->who : sb->key ? sb->key : "" );
         
-        if( sb->msgq )
-        {
-                struct msn_message *m;
-                GSList *l;
-                
-                for( l = sb->msgq; l; l = l->next )
-                {
-                        m = l->data;
-
-                        g_free( m->who );
-                        g_free( m->text );
-                        g_free( m );
-                }
-                g_slist_free( sb->msgq );
-                
-                imcb_log( ic, "Warning: Closing down MSN switchboard connection with "
-                                   "unsent message to %s, you'll have to resend it.",
-                                   sb->who ? sb->who : "(unknown)" );
-        }
+        msn_msgq_purge( ic, &sb->msgq );
         
         if( sb->key ) g_free( sb->key );
@@ -266 +248 @@
         if( source != sb->fd )
         {
-                debug( "ERROR %d while connecting to switchboard server", 1 );
+                debug( "Error %d while connecting to switchboard server", 1 );
                 msn_sb_destroy( sb );
                 return FALSE;
@@ -287 +269 @@
                 sb->inp = b_input_add( sb->fd, GAIM_INPUT_READ, msn_sb_callback, sb );
         else
-                debug( "ERROR %d while connecting to switchboard server", 2 );
+                debug( "Error %d while connecting to switchboard server", 2 );
         
         return FALSE;
@@ -295 +277 @@
 {
         struct msn_switchboard *sb = data;
+        struct im_connection *ic = sb->ic;
+        struct msn_data *md = ic->proto_data;
         
         if( msn_handler( sb->handler ) == -1 )
         {
-                debug( "ERROR: Switchboard died" );
+                time_t now = time( NULL );
+                
+                if( now - md->first_sb_failure > 600 )
+                {
+                        /* It's not really the first one, but the start of this "series".
+                           With this, the warning below will be shown only if this happens
+                           at least three times in ten minutes. This algorithm isn't
+                           perfect, but for this purpose it will do. */
+                        md->first_sb_failure = now;
+                        md->sb_failures = 0;
+                }
+                
+                debug( "Error: Switchboard died" );
+                if( ++ md->sb_failures >= 3 )
+                        imcb_log( ic, "Warning: Many switchboard failures on MSN connection. "
+                                      "There might be problems delivering your messages." );
+                
+                if( sb->msgq != NULL )
+                {
+                        char buf[1024];
+                        
+                        if( md->msgq == NULL )
+                        {
+                                md->msgq = sb->msgq;
+                        }
+                        else
+                        {
+                                GSList *l;
+                                
+                                for( l = md->msgq; l->next; l = l->next );
+                                l->next = sb->msgq;
+                        }
+                        sb->msgq = NULL;
+                        
+                        debug( "Moved queued messages back to the main queue, creating a new switchboard to retry." );
+                        g_snprintf( buf, sizeof( buf ), "XFR %d SB\r\n", ++md->trId );
+                        if( !msn_write( ic, buf, strlen( buf ) ) )
+                                return FALSE;
+                }
+                
                 msn_sb_destroy( sb );
                 
@@ -304 +327 @@
         }
         else
+        {
                 return TRUE;
+        }
 }
 
@@ -491 +516 @@
                 }
         }
+        else if( strcmp( cmd[0], "NAK" ) == 0 )
+        {
+                if( sb->who )
+                {
+                        imcb_log( ic, "The MSN servers could not deliver one of your messages to %s.", sb->who );
+                }
+                else
+                {
+                        imcb_log( ic, "The MSN servers could not deliver one of your groupchat messages to all participants." );
+                }
+        }
         else if( strcmp( cmd[0], "BYE" ) == 0 )
         {
@@ -544 +580 @@
                         if( sb->who )
                         {
-                                struct msn_message *m;
-                                GSList *l;
-                                
                                 /* Apparently some invitation failed. We might want to use this
                                    board later, so keep it as a spare. */
@@ -553 +586 @@
                                 
                                 /* Also clear the msgq, otherwise someone else might get them. */
-                                for( l = sb->msgq; l; l = l->next )
-                                {
-                                        m = l->data;
-                                        g_free( m->who );
-                                        g_free( m->text );
-                                        g_free( m );
-                                }
-                                g_slist_free( sb->msgq );
-                                sb->msgq = NULL;
+                                msn_msgq_purge( ic, &sb->msgq );
                         }
                         
@@ -569 +594 @@
         else
         {
-                debug( "Received unknown command from switchboard server: %s", cmd[0] );
+                /* debug( "Received unknown command from switchboard server: %s", cmd[0] ); */
         }