Changeset 8076ec0

Timestamp:

2007-12-05T01:30:50Z (17 years ago)

Author:

ulim <a.sporto+bee@…>

Branches:

master

Children:

dc0ba9c

Parents:

dce3903 (diff), 793cc25 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

merges from upstream/release

ulim 2007-12-04 Follow rename of jabber_chat_by_jid from upstrem

ulim 2007-12-04 Merged in current devel
Wilmer van der Gaast 2007-12-02 Imported setuid() patch from Simo Leone <simo@archlinux...> with some
Wilmer van der Gaast 2007-12-02 Forgot to return something in jabber_chat_join_failed().
Wilmer van der Gaast 2007-12-02 Merging a change I should've pulled before committing three other changes.
Wilmer van der Gaast 2007-12-02 Added charset checks on incoming msgs (from the IRC side) to prevent possible
Wilmer van der Gaast 2007-12-02 Handling of presence-error packets (only useful for groupchats now), moved
Wilmer van der Gaast 2007-12-02 Defining DEBUG via CFLAGS so that it'll always be there, even when a file
ulim 2007-12-04 Jabber file transfer now also with sending! You can't use a proxy yet when
Wilmer van der Gaast 2007-12-02 Removed retarded printf() (ARGH) and moved the event handling handling of
Wilmer van der Gaast 2007-11-29 printf() in daemons considered harmful.
Wilmer van der Gaast 2007-11-28 Fixed the epoll+ForkDaemon combination. The libevent event handling

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;
@@ -77 +78 @@
         }
         
-        while( argc > 0 && ( opt = getopt( argc, argv, "i:p:P:nvIDFc:d:hR:" ) ) >= 0 )
+        while( argc > 0 && ( opt = getopt( argc, argv, "i:p:P:nvIDFc:d:hR:u:" ) ) >= 0 )
         /*     ^^^^ Just to make sure we skip this step from the REHASH handler. */
         {
@@ -133 +134 @@
                                 "  -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"
@@ -152 +154 @@
                         ipc_master_set_statefile( optarg );
                 }
+                else if( opt == 'u' )
+                {
+                        g_free( conf->user );
+                        conf->user = g_strdup( optarg );
+                }
         }
         
@@ -193 +200 @@
                         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 );
                         }
@@ -210 +219 @@
                         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 );
                         }
@@ -282 +294 @@
                                 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
-        echo '#define DEBUG' >> config.h
+        CFLAGS="$CFLAGS -DDEBUG"
 else
         [ -z "$CFLAGS" ] && CFLAGS="-O2 -fno-strict-aliasing"

irc.c

@@ -324 +324 @@
                         }
                         
-                        if( ( cs = set_getstr( &irc->set, "charset" ) ) && ( g_strcasecmp( cs, "utf-8" ) != 0 ) )
+                        if( ( cs = set_getstr( &irc->set, "charset" ) ) )
                         {
                                 conv[IRC_MAX_LINE] = 0;
-                                if( do_iconv( cs, "UTF-8", lines[i], conv, 0, IRC_MAX_LINE - 2 ) != -1 )
-                                        lines[i] = conv;
+                                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;
                         }
                         

lib/events.h

@@ -45 +45 @@
 #include <gmodule.h>
 
-/* The conditions you can pass to gaim_input_add()/that will be passed to
+/* The conditions you can pass to b_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>
-
-static guint id_next;
+#include "proxy.h"
+
+static void b_main_restart();
+static guint id_next = 1;
 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
 {
@@ -59 +62 @@
 void b_main_init()
 {
-        event_init();
-        
-        id_next = 1;
+        if( leh != NULL )
+        {
+                /* Clean up the hash tables? */
+                
+                b_main_restart();
+                old_leh = leh;
+        }
+        
+        leh = event_init();
+        
         id_hash = g_hash_table_new( g_int_hash, g_int_equal );
         read_hash = g_hash_table_new( g_int_hash, g_int_equal );
@@ -69 +79 @@
 void b_main_run()
 {
-        event_dispatch();
+        /* 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()
+{
+        struct timeval tv;
+        
+        memset( &tv, 0, sizeof( struct timeval ) );
+        event_base_loopexit( leh, &tv );
+        
+        event_debug( "b_main_restart()\n" );
 }
 
 void b_main_quit()
 {
-        struct timeval tv;
-        
-        /* libevent sometimes generates events before really quitting,
+        /* Tell b_main_run() that it shouldn't restart the loop. Also,
+           libevent sometimes generates events before really quitting,
            we want to stop them. */
         quitting = 1;
         
-        memset( &tv, 0, sizeof( struct timeval ) );
-        event_loopexit( &tv );
+        b_main_restart();
 }
 

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 )
 {
@@ -35 +37 @@
         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 );
@@ -63 +64 @@
         
         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;
 }
 
@@ -148 +188 @@
         char *s;
         
-        if( ( chat = jabber_chat_by_name( ic, bud->bare_jid ) ) == NULL )
+        if( ( chat = jabber_chat_by_jid( ic, bud->bare_jid ) ) == NULL )
         {
                 /* How could this happen?? We could do kill( self, 11 )
@@ -250 +290 @@
                 return;
         }
-        else if( ( chat = jabber_chat_by_name( ic, bud->bare_jid ) ) == NULL )
+        else if( ( chat = jabber_chat_by_jid( 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;
@@ -47 +46 @@
         if( strcmp( type, "result" ) == 0 || strcmp( type, "error" ) == 0 )
         {
-                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 );
+                return jabber_cache_handle_packet( ic, 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 );
 }
 
@@ -272 +270 @@
                 return jabber_write( ic, message, strlen( message ) );
         
-        if( ( s = strchr( who, '=' ) ) && jabber_chat_by_name( ic, s + 1 ) )
+        if( ( s = strchr( who, '=' ) ) && jabber_chat_by_jid( ic, s + 1 ) )
                 bud = jabber_buddy_by_ext_jid( ic, who, 0 );
         else
@@ -399 +397 @@
         if( strchr( room, '@' ) == NULL )
                 imcb_error( ic, "Invalid room name: %s", room );
-        else if( jabber_chat_by_name( ic, room ) )
+        else if( jabber_chat_by_jid( 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 );
@@ -249 +250 @@
 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;
 }
 
@@ -595 +625 @@
 }
 
-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 )
 {
@@ -663 +676 @@
 struct jabber_error *jabber_error_parse( struct xt_node *node, char *xmlns )
 {
-        struct jabber_error *err = g_new0( struct jabber_error, 1 );
+        struct jabber_error *err;
         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_name( ic, from ) )
+                if( jabber_chat_by_jid( 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" ) ) )
                 {
@@ -173 +175 @@
                                     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_name( ic, s + 1 ) )
+        if( ( s = strchr( who, '=' ) ) && jabber_chat_by_jid( 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 */
@@ -45 +46 @@
         struct sigaction sig, old;
         
-        memset( &global, 0, sizeof( global_t ) );
-        
         log_init();
         CONF_FILE = g_strdup( CONF_FILE_DEF );
@@ -87 +86 @@
                 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 */