Changes in / [8076ec0:dce3903]

Files:

• bitlbee.c (modified) (1 diff)
• bitlbee.conf (modified) (1 diff)
• conf.c (modified) (7 diffs)
• conf.h (modified) (1 diff)
• configure (modified) (1 diff)
• irc.c (modified) (1 diff)
• lib/events.h (modified) (2 diffs)
• lib/events_libevent.c (modified) (4 diffs)
• protocols/jabber/conference.c (modified) (5 diffs)
• protocols/jabber/iq.c (modified) (2 diffs)
• protocols/jabber/jabber.c (modified) (3 diffs)
• protocols/jabber/jabber.h (modified) (3 diffs)
• protocols/jabber/jabber_util.c (modified) (3 diffs)
• protocols/jabber/presence.c (modified) (3 diffs)
• protocols/jabber/si.c (modified) (1 diff)
• protocols/oscar/msgcookie.c (modified) (1 diff)
• unix.c (modified) (3 diffs)

bitlbee.c

@@ -293 +293 @@
                         srand( time( NULL ) ^ getpid() );
                         
-                        b_main_init();
-                        
                         /* Close the listening socket, we're a client. */
                         close( global.listen_socket );

bitlbee.conf

@@ -19 +19 @@
 ##
 # RunMode = Inetd
-
-## User:
-## 
-## If BitlBee is started by root as a daemon, it can drop root privileges,
-## and change to the specified user.
-##
-# User = bitlbee
 
 ## DaemonPort/DaemonInterface:

conf.c

@@ -63 +63 @@
         conf->ping_interval = 180;
         conf->ping_timeout = 300;
-        conf->user = NULL;
         conf->max_filetransfer_size = G_MAXUINT;
         proxytype = 0;
@@ -78 +77 @@
         }
         
-        while( argc > 0 && ( opt = getopt( argc, argv, "i:p:P:nvIDFc:d:hR:u:" ) ) >= 0 )
+        while( argc > 0 && ( opt = getopt( argc, argv, "i:p:P:nvIDFc:d:hR:" ) ) >= 0 )
         /*     ^^^^ Just to make sure we skip this step from the REHASH handler. */
         {
@@ -134 +133 @@
                                 "  -D  Daemon mode. (Still EXPERIMENTAL!)\n"
                                 "  -F  Forking daemon. (one process per client)\n"
-                                "  -u  Run daemon as specified user.\n"
                                 "  -P  Specify PID-file (not for inetd mode)\n"
                                 "  -i  Specify the interface (by IP address) to listen on.\n"
@@ -154 +152 @@
                         ipc_master_set_statefile( optarg );
                 }
-                else if( opt == 'u' )
-                {
-                        g_free( conf->user );
-                        conf->user = g_strdup( optarg );
-                }
         }
         
@@ -200 +193 @@
                         else if( g_strcasecmp( ini->key, "daemoninterface" ) == 0 )
                         {
-                                g_free( conf->iface );
                                 conf->iface = g_strdup( ini->value );
                         }
                         else if( g_strcasecmp( ini->key, "daemonport" ) == 0 )
                         {
-                                g_free( conf->port );
                                 conf->port = g_strdup( ini->value );
                         }
@@ -219 +210 @@
                         else if( g_strcasecmp( ini->key, "authpassword" ) == 0 )
                         {
-                                g_free( conf->auth_pass );
                                 conf->auth_pass = g_strdup( ini->value );
                         }
                         else if( g_strcasecmp( ini->key, "operpassword" ) == 0 )
                         {
-                                g_free( conf->oper_pass );
                                 conf->oper_pass = g_strdup( ini->value );
                         }
                         else if( g_strcasecmp( ini->key, "hostname" ) == 0 )
                         {
-                                g_free( conf->hostname );
                                 conf->hostname = g_strdup( ini->value );
                         }
@@ -294 +282 @@
                                 g_free( url );
                         }
-                        else if( g_strcasecmp( ini->key, "user" ) == 0 )
-                        {
-                                g_free( conf->user );
-                                conf->user = g_strdup( ini->value );
-                        }
                         else
                         {

conf.h

@@ -49 +49 @@
         int ping_interval;
         int ping_timeout;
-        char *user;
         size_t max_filetransfer_size;
 } conf_t;

configure

@@ -135 +135 @@
         [ -z "$CFLAGS" ] && CFLAGS=-g
         echo 'DEBUG=1' >> Makefile.settings
-        CFLAGS="$CFLAGS -DDEBUG"
+        echo '#define DEBUG' >> config.h
 else
         [ -z "$CFLAGS" ] && CFLAGS="-O2 -fno-strict-aliasing"

irc.c

@@ -324 +324 @@
                         }
                         
-                        if( ( cs = set_getstr( &irc->set, "charset" ) ) )
+                        if( ( cs = set_getstr( &irc->set, "charset" ) ) && ( g_strcasecmp( cs, "utf-8" ) != 0 ) )
                         {
                                 conv[IRC_MAX_LINE] = 0;
-                                if( do_iconv( cs, "UTF-8", lines[i], conv, 0, IRC_MAX_LINE - 2 ) == -1 )
-                                {
-                                        if( irc->status & USTATUS_LOGGED_IN )
-                                                irc_usermsg( irc, "ERROR: Charset mismatch detected. The charset "
-                                                                  "setting is currently set to %s, so please make "
-                                                                  "sure your IRC client will send and accept text in "
-                                                                  "that charset, or tell BitlBee which charset to "
-                                                                  "expect by changing the charset setting. See "
-                                                                  "`help set charset' for more information. Your "
-                                                                  "message was ignored.", cs );
-                                        *conv = 0;
-                                }
-                                lines[i] = conv;
+                                if( do_iconv( cs, "UTF-8", lines[i], conv, 0, IRC_MAX_LINE - 2 ) != -1 )
+                                        lines[i] = conv;
                         }
                         

lib/events.h

@@ -45 +45 @@
 #include <gmodule.h>
 
-/* The conditions you can pass to b_input_add()/that will be passed to
+/* The conditions you can pass to gaim_input_add()/that will be passed to
    the given callback function. */
 typedef enum {
@@ -58 +58 @@
 #define GAIM_ERR_COND   (G_IO_HUP | G_IO_ERR | G_IO_NVAL)
 
-/* #define event_debug( x... ) printf( x ) */
+// #define event_debug( x... ) printf( x )
 #define event_debug( x... )
 

lib/events_libevent.c

@@ -32 +32 @@
 #include <unistd.h>
 #include <sys/types.h>
+#include "proxy.h"
+
 #include <sys/time.h>
 #include <event.h>
-#include "proxy.h"
-
-static void b_main_restart();
-static guint id_next = 1;
+
+static guint id_next;
 static GHashTable *id_hash;
 static int quitting = 0;
@@ -48 +48 @@
 static GHashTable *write_hash;
 
-struct event_base *leh;
-struct event_base *old_leh;
-
 struct b_event_data
 {
@@ -62 +59 @@
 void b_main_init()
 {
-        if( leh != NULL )
-        {
-                /* Clean up the hash tables? */
-                
-                b_main_restart();
-                old_leh = leh;
-        }
-        
-        leh = event_init();
-        
+        event_init();
+        
+        id_next = 1;
         id_hash = g_hash_table_new( g_int_hash, g_int_equal );
         read_hash = g_hash_table_new( g_int_hash, g_int_equal );
@@ -79 +69 @@
 void b_main_run()
 {
-        /* This while loop is necessary to exit the event loop and start a
-           different one (necessary for ForkDaemon mode). */
-        while( event_base_dispatch( leh ) == 0 && !quitting )
-        {
-                if( old_leh != NULL )
-                {
-                        /* For some reason this just isn't allowed...
-                           Possibly a bug in older versions, will see later.
-                        event_base_free( old_leh ); */
-                        old_leh = NULL;
-                }
-                
-                event_debug( "New event loop.\n" );
-        }
-}
-
-static void b_main_restart()
+        event_dispatch();
+}
+
+void b_main_quit()
 {
         struct timeval tv;
         
-        memset( &tv, 0, sizeof( struct timeval ) );
-        event_base_loopexit( leh, &tv );
-        
-        event_debug( "b_main_restart()\n" );
-}
-
-void b_main_quit()
-{
-        /* Tell b_main_run() that it shouldn't restart the loop. Also,
-           libevent sometimes generates events before really quitting,
+        /* libevent sometimes generates events before really quitting,
            we want to stop them. */
         quitting = 1;
         
-        b_main_restart();
+        memset( &tv, 0, sizeof( struct timeval ) );
+        event_loopexit( &tv );
 }
 

protocols/jabber/conference.c

@@ -24 +24 @@
 #include "jabber.h"
 
-static xt_status jabber_chat_join_failed( struct im_connection *ic, struct xt_node *node, struct xt_node *orig );
-
 struct groupchat *jabber_chat_join( struct im_connection *ic, char *room, char *nick, char *password )
 {
@@ -37 +35 @@
         xt_add_attr( node, "xmlns", XMLNS_MUC );
         node = jabber_make_packet( "presence", NULL, roomjid, node );
-        jabber_cache_add( ic, node, jabber_chat_join_failed );
         
         if( !jabber_write_packet( ic, node ) )
         {
                 g_free( roomjid );
+                xt_free_node( node );
                 return NULL;
         }
+        xt_free_node( node );
         
         jc = g_new0( struct jabber_chat, 1 );
@@ -64 +63 @@
         
         return c;
-}
-
-static xt_status jabber_chat_join_failed( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
-{
-        struct jabber_error *err;
-        struct jabber_buddy *bud;
-        char *room;
-        
-        room = xt_find_attr( orig, "to" );
-        if( ( bud = jabber_buddy_by_jid( ic, room, 0 ) ) )
-                jabber_chat_free( jabber_chat_by_jid( ic, bud->bare_jid ) );
-        
-        err = jabber_error_parse( xt_find_node( node->children, "error" ), XMLNS_STANZA_ERROR );
-        if( err )
-        {
-                imcb_error( ic, "Error joining groupchat %s: %s%s%s",
-                            bud->bare_jid, err->code, err->text ? ": " : "",
-                            err->text ? err->text : "" );
-                jabber_error_free( err );
-        }
-        
-        return XT_HANDLED;
-}
-
-struct groupchat *jabber_chat_by_jid( struct im_connection *ic, const char *name )
-{
-        char *normalized = jabber_normalize( name );
-        struct groupchat *ret;
-        struct jabber_chat *jc;
-        
-        for( ret = ic->groupchats; ret; ret = ret->next )
-        {
-                jc = ret->data;
-                if( strcmp( normalized, jc->name ) == 0 )
-                        break;
-        }
-        g_free( normalized );
-        
-        return ret;
 }
 
@@ -188 +148 @@
         char *s;
         
-        if( ( chat = jabber_chat_by_jid( ic, bud->bare_jid ) ) == NULL )
+        if( ( chat = jabber_chat_by_name( ic, bud->bare_jid ) ) == NULL )
         {
                 /* How could this happen?? We could do kill( self, 11 )
@@ -290 +250 @@
                 return;
         }
-        else if( ( chat = jabber_chat_by_jid( ic, bud->bare_jid ) ) == NULL )
+        else if( ( chat = jabber_chat_by_name( ic, bud->bare_jid ) ) == NULL )
         {
                 /* How could this happen?? We could do kill( self, 11 )

protocols/jabber/iq.c

@@ -31 +31 @@
 {
         struct im_connection *ic = data;
+        struct jabber_data *jd = ic->proto_data;
         struct xt_node *c, *reply = NULL;
         char *type, *s;
@@ -46 +47 @@
         if( strcmp( type, "result" ) == 0 || strcmp( type, "error" ) == 0 )
         {
-                return jabber_cache_handle_packet( ic, node );
+                struct jabber_cache_entry *entry;
+                
+                if( ( s = xt_find_attr( node, "id" ) ) == NULL ||
+                    strncmp( s, jd->cached_id_prefix, strlen( jd->cached_id_prefix ) ) != 0 )
+                {
+                        /* Silently ignore it, without an ID (or a non-cache
+                           ID) we don't know how to handle the packet and we
+                           probably don't have to. */
+                        return XT_HANDLED;
+                }
+                
+                entry = g_hash_table_lookup( jd->node_cache, s );
+                
+                if( entry == NULL )
+                        imcb_log( ic, "WARNING: Received IQ-%s packet with unknown/expired ID %s!", type, s );
+                else if( entry->func )
+                        return entry->func( ic, node, entry->node );
         }
         else if( strcmp( type, "get" ) == 0 )

protocols/jabber/jabber.c

@@ -226 +226 @@
         jd->cached_id_prefix = g_strdup_printf( "%s%s", JABBER_CACHED_ID, s );
         g_free( s );
+        
+        printf( "%s\n", jd->cached_id_prefix );
 }
 
@@ -270 +272 @@
                 return jabber_write( ic, message, strlen( message ) );
         
-        if( ( s = strchr( who, '=' ) ) && jabber_chat_by_jid( ic, s + 1 ) )
+        if( ( s = strchr( who, '=' ) ) && jabber_chat_by_name( ic, s + 1 ) )
                 bud = jabber_buddy_by_ext_jid( ic, who, 0 );
         else
@@ -397 +399 @@
         if( strchr( room, '@' ) == NULL )
                 imcb_error( ic, "Invalid room name: %s", room );
-        else if( jabber_chat_by_jid( ic, room ) )
+        else if( jabber_chat_by_name( ic, room ) )
                 imcb_error( ic, "Already present in chat `%s'", room );
         else

protocols/jabber/jabber.h

@@ -227 +227 @@
 void jabber_cache_entry_free( gpointer entry );
 void jabber_cache_clean( struct im_connection *ic );
-xt_status jabber_cache_handle_packet( struct im_connection *ic, struct xt_node *node );
 const struct jabber_away_state *jabber_away_state_by_code( char *code );
 const struct jabber_away_state *jabber_away_state_by_name( char *name );
@@ -250 +249 @@
 int jabber_buddy_remove( struct im_connection *ic, char *full_jid );
 int jabber_buddy_remove_bare( struct im_connection *ic, char *bare_jid );
+struct groupchat *jabber_chat_by_name( struct im_connection *ic, const char *name );
 time_t jabber_get_timestamp( struct xt_node *xt );
 struct jabber_error *jabber_error_parse( struct xt_node *node, char *xmlns );
@@ -272 +272 @@
 /* conference.c */
 struct groupchat *jabber_chat_join( struct im_connection *ic, char *room, char *nick, char *password );
-struct groupchat *jabber_chat_by_jid( struct im_connection *ic, const char *name );
 void jabber_chat_free( struct groupchat *c );
 int jabber_chat_msg( struct groupchat *ic, char *message, int flags );

protocols/jabber/jabber_util.c

@@ -183 +183 @@
                 return FALSE;
         }
-}
-
-xt_status jabber_cache_handle_packet( struct im_connection *ic, struct xt_node *node )
-{
-        struct jabber_data *jd = ic->proto_data;
-        struct jabber_cache_entry *entry;
-        char *s;
-        
-        if( ( s = xt_find_attr( node, "id" ) ) == NULL ||
-            strncmp( s, jd->cached_id_prefix, strlen( jd->cached_id_prefix ) ) != 0 )
-        {
-                /* Silently ignore it, without an ID (or a non-cache
-                   ID) we don't know how to handle the packet and we
-                   probably don't have to. */
-                return XT_HANDLED;
-        }
-        
-        entry = g_hash_table_lookup( jd->node_cache, s );
-        
-        if( entry == NULL )
-        {
-                imcb_log( ic, "WARNING: Received %s-%s packet with unknown/expired ID %s!",
-                              node->name, xt_find_attr( node, "type" ) ? : "(no type)", s );
-        }
-        else if( entry->func )
-        {
-                return entry->func( ic, node, entry->node );
-        }
-        
-        return XT_HANDLED;
 }
 
@@ -625 +595 @@
 }
 
+struct groupchat *jabber_chat_by_name( struct im_connection *ic, const char *name )
+{
+        char *normalized = jabber_normalize( name );
+        struct groupchat *ret;
+        struct jabber_chat *jc;
+        
+        for( ret = ic->groupchats; ret; ret = ret->next )
+        {
+                jc = ret->data;
+                if( strcmp( normalized, jc->name ) == 0 )
+                        break;
+        }
+        g_free( normalized );
+        
+        return ret;
+}
+
 time_t jabber_get_timestamp( struct xt_node *xt )
 {
@@ -676 +663 @@
 struct jabber_error *jabber_error_parse( struct xt_node *node, char *xmlns )
 {
-        struct jabber_error *err;
+        struct jabber_error *err = g_new0( struct jabber_error, 1 );
         struct xt_node *c;
         char *s;
         
-        if( node == NULL )
-                return NULL;
-        
-        err = g_new0( struct jabber_error, 1 );
         err->type = xt_find_attr( node, "type" );
         

protocols/jabber/presence.c

@@ -40 +40 @@
         {
                 *s = 0;
-                if( jabber_chat_by_jid( ic, from ) )
+                if( jabber_chat_by_name( ic, from ) )
                         is_chat = 1;
                 *s = '/';
@@ -164 +164 @@
         else if( strcmp( type, "error" ) == 0 )
         {
-                return jabber_cache_handle_packet( ic, node );
-                
-                /*
                 struct jabber_error *err;
+                
                 if( ( c = xt_find_node( node->children, "error" ) ) )
                 {
@@ -175 +173 @@
                                     err->text ? err->text : "" );
                         jabber_error_free( err );
-                } */
+                }
+                /* What else to do with it? */
         }
         

protocols/jabber/si.c

@@ -372 +372 @@
         tf->sid = g_strdup_printf( "BitlBeeJabberSID%d", tf->ft->local_id );
         
-        if( ( s = strchr( who, '=' ) ) && jabber_chat_by_jid( ic, s + 1 ) )
+        if( ( s = strchr( who, '=' ) ) && jabber_chat_by_name( ic, s + 1 ) )
                 bud = jabber_buddy_by_ext_jid( ic, who, 0 );
         else

protocols/oscar/msgcookie.c

@@ -131 +131 @@
 }
 
+#if 0 /* debugging feature */
+int aim_dumpcookie(aim_msgcookie_t *cookie) 
+{
+
+        if (!cookie)
+                return -EINVAL;
+
+        printf("\tCookie at %p: %d/%s with %p, next %p\n", 
+                        cookie, cookie->type, cookie->cookie, 
+                        cookie->data, cookie->next);
+
+        return 0;
+}
+#endif
+
 /**
  * aim_cookie_free - free an aim_msgcookie_t struct

unix.c

@@ -34 +34 @@
 #include <sys/time.h>
 #include <sys/wait.h>
-#include <pwd.h>
 
 global_t global;        /* Against global namespace pollution */
@@ -46 +45 @@
         struct sigaction sig, old;
         
+        memset( &global, 0, sizeof( global_t ) );
+        
         log_init();
         CONF_FILE = g_strdup( CONF_FILE_DEF );
@@ -86 +87 @@
                 return( i );
         
-        if( ( global.conf->user && *global.conf->user ) &&
-            ( global.conf->runmode == RUNMODE_DAEMON || 
-              global.conf->runmode == RUNMODE_FORKDAEMON ) &&
-            ( !getuid() || !geteuid() ) )
-        {
-                struct passwd *pw = NULL;
-                pw = getpwnam( global.conf->user );
-                if( pw )
-                {
-                        setgid( pw->pw_gid );
-                        setuid( pw->pw_uid );
-                }
-        }
-
         global.storage = storage_init( global.conf->primary_storage, global.conf->migrate_storage );
-        if( global.storage == NULL )
-        {
+        if ( global.storage == NULL) {
                 log_message( LOGLVL_ERROR, "Unable to load storage backend '%s'", global.conf->primary_storage );
                 return( 1 );
         }
+        
         
         /* Catch some signals to tell the user what's happening before quitting */