Changeset 8076ec0


Ignore:
Timestamp:
2007-12-05T01:30:50Z (12 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:
17 edited

Legend:

Unmodified
Added
Removed
  • bitlbee.c

    rdce3903 r8076ec0  
    293293                        srand( time( NULL ) ^ getpid() );
    294294                       
     295                        b_main_init();
     296                       
    295297                        /* Close the listening socket, we're a client. */
    296298                        close( global.listen_socket );
  • bitlbee.conf

    rdce3903 r8076ec0  
    1919##
    2020# RunMode = Inetd
     21
     22## User:
     23##
     24## If BitlBee is started by root as a daemon, it can drop root privileges,
     25## and change to the specified user.
     26##
     27# User = bitlbee
    2128
    2229## DaemonPort/DaemonInterface:
  • conf.c

    rdce3903 r8076ec0  
    6363        conf->ping_interval = 180;
    6464        conf->ping_timeout = 300;
     65        conf->user = NULL;
    6566        conf->max_filetransfer_size = G_MAXUINT;
    6667        proxytype = 0;
     
    7778        }
    7879       
    79         while( argc > 0 && ( opt = getopt( argc, argv, "i:p:P:nvIDFc:d:hR:" ) ) >= 0 )
     80        while( argc > 0 && ( opt = getopt( argc, argv, "i:p:P:nvIDFc:d:hR:u:" ) ) >= 0 )
    8081        /*     ^^^^ Just to make sure we skip this step from the REHASH handler. */
    8182        {
     
    133134                                "  -D  Daemon mode. (Still EXPERIMENTAL!)\n"
    134135                                "  -F  Forking daemon. (one process per client)\n"
     136                                "  -u  Run daemon as specified user.\n"
    135137                                "  -P  Specify PID-file (not for inetd mode)\n"
    136138                                "  -i  Specify the interface (by IP address) to listen on.\n"
     
    152154                        ipc_master_set_statefile( optarg );
    153155                }
     156                else if( opt == 'u' )
     157                {
     158                        g_free( conf->user );
     159                        conf->user = g_strdup( optarg );
     160                }
    154161        }
    155162       
     
    193200                        else if( g_strcasecmp( ini->key, "daemoninterface" ) == 0 )
    194201                        {
     202                                g_free( conf->iface );
    195203                                conf->iface = g_strdup( ini->value );
    196204                        }
    197205                        else if( g_strcasecmp( ini->key, "daemonport" ) == 0 )
    198206                        {
     207                                g_free( conf->port );
    199208                                conf->port = g_strdup( ini->value );
    200209                        }
     
    210219                        else if( g_strcasecmp( ini->key, "authpassword" ) == 0 )
    211220                        {
     221                                g_free( conf->auth_pass );
    212222                                conf->auth_pass = g_strdup( ini->value );
    213223                        }
    214224                        else if( g_strcasecmp( ini->key, "operpassword" ) == 0 )
    215225                        {
     226                                g_free( conf->oper_pass );
    216227                                conf->oper_pass = g_strdup( ini->value );
    217228                        }
    218229                        else if( g_strcasecmp( ini->key, "hostname" ) == 0 )
    219230                        {
     231                                g_free( conf->hostname );
    220232                                conf->hostname = g_strdup( ini->value );
    221233                        }
     
    282294                                g_free( url );
    283295                        }
     296                        else if( g_strcasecmp( ini->key, "user" ) == 0 )
     297                        {
     298                                g_free( conf->user );
     299                                conf->user = g_strdup( ini->value );
     300                        }
    284301                        else
    285302                        {
  • conf.h

    rdce3903 r8076ec0  
    4949        int ping_interval;
    5050        int ping_timeout;
     51        char *user;
    5152        size_t max_filetransfer_size;
    5253} conf_t;
  • configure

    rdce3903 r8076ec0  
    135135        [ -z "$CFLAGS" ] && CFLAGS=-g
    136136        echo 'DEBUG=1' >> Makefile.settings
    137         echo '#define DEBUG' >> config.h
     137        CFLAGS="$CFLAGS -DDEBUG"
    138138else
    139139        [ -z "$CFLAGS" ] && CFLAGS="-O2 -fno-strict-aliasing"
  • irc.c

    rdce3903 r8076ec0  
    324324                        }
    325325                       
    326                         if( ( cs = set_getstr( &irc->set, "charset" ) ) && ( g_strcasecmp( cs, "utf-8" ) != 0 ) )
     326                        if( ( cs = set_getstr( &irc->set, "charset" ) ) )
    327327                        {
    328328                                conv[IRC_MAX_LINE] = 0;
    329                                 if( do_iconv( cs, "UTF-8", lines[i], conv, 0, IRC_MAX_LINE - 2 ) != -1 )
    330                                         lines[i] = conv;
     329                                if( do_iconv( cs, "UTF-8", lines[i], conv, 0, IRC_MAX_LINE - 2 ) == -1 )
     330                                {
     331                                        if( irc->status & USTATUS_LOGGED_IN )
     332                                                irc_usermsg( irc, "ERROR: Charset mismatch detected. The charset "
     333                                                                  "setting is currently set to %s, so please make "
     334                                                                  "sure your IRC client will send and accept text in "
     335                                                                  "that charset, or tell BitlBee which charset to "
     336                                                                  "expect by changing the charset setting. See "
     337                                                                  "`help set charset' for more information. Your "
     338                                                                  "message was ignored.", cs );
     339                                        *conv = 0;
     340                                }
     341                                lines[i] = conv;
    331342                        }
    332343                       
  • lib/events.h

    rdce3903 r8076ec0  
    4545#include <gmodule.h>
    4646
    47 /* The conditions you can pass to gaim_input_add()/that will be passed to
     47/* The conditions you can pass to b_input_add()/that will be passed to
    4848   the given callback function. */
    4949typedef enum {
     
    5858#define GAIM_ERR_COND   (G_IO_HUP | G_IO_ERR | G_IO_NVAL)
    5959
    60 // #define event_debug( x... ) printf( x )
     60/* #define event_debug( x... ) printf( x ) */
    6161#define event_debug( x... )
    6262
  • lib/events_libevent.c

    rdce3903 r8076ec0  
    3232#include <unistd.h>
    3333#include <sys/types.h>
    34 #include "proxy.h"
    35 
    3634#include <sys/time.h>
    3735#include <event.h>
    38 
    39 static guint id_next;
     36#include "proxy.h"
     37
     38static void b_main_restart();
     39static guint id_next = 1;
    4040static GHashTable *id_hash;
    4141static int quitting = 0;
     
    4848static GHashTable *write_hash;
    4949
     50struct event_base *leh;
     51struct event_base *old_leh;
     52
    5053struct b_event_data
    5154{
     
    5962void b_main_init()
    6063{
    61         event_init();
    62        
    63         id_next = 1;
     64        if( leh != NULL )
     65        {
     66                /* Clean up the hash tables? */
     67               
     68                b_main_restart();
     69                old_leh = leh;
     70        }
     71       
     72        leh = event_init();
     73       
    6474        id_hash = g_hash_table_new( g_int_hash, g_int_equal );
    6575        read_hash = g_hash_table_new( g_int_hash, g_int_equal );
     
    6979void b_main_run()
    7080{
    71         event_dispatch();
     81        /* This while loop is necessary to exit the event loop and start a
     82           different one (necessary for ForkDaemon mode). */
     83        while( event_base_dispatch( leh ) == 0 && !quitting )
     84        {
     85                if( old_leh != NULL )
     86                {
     87                        /* For some reason this just isn't allowed...
     88                           Possibly a bug in older versions, will see later.
     89                        event_base_free( old_leh ); */
     90                        old_leh = NULL;
     91                }
     92               
     93                event_debug( "New event loop.\n" );
     94        }
     95}
     96
     97static void b_main_restart()
     98{
     99        struct timeval tv;
     100       
     101        memset( &tv, 0, sizeof( struct timeval ) );
     102        event_base_loopexit( leh, &tv );
     103       
     104        event_debug( "b_main_restart()\n" );
    72105}
    73106
    74107void b_main_quit()
    75108{
    76         struct timeval tv;
    77        
    78         /* libevent sometimes generates events before really quitting,
     109        /* Tell b_main_run() that it shouldn't restart the loop. Also,
     110           libevent sometimes generates events before really quitting,
    79111           we want to stop them. */
    80112        quitting = 1;
    81113       
    82         memset( &tv, 0, sizeof( struct timeval ) );
    83         event_loopexit( &tv );
     114        b_main_restart();
    84115}
    85116
  • protocols/jabber/conference.c

    rdce3903 r8076ec0  
    2424#include "jabber.h"
    2525
     26static xt_status jabber_chat_join_failed( struct im_connection *ic, struct xt_node *node, struct xt_node *orig );
     27
    2628struct groupchat *jabber_chat_join( struct im_connection *ic, char *room, char *nick, char *password )
    2729{
     
    3537        xt_add_attr( node, "xmlns", XMLNS_MUC );
    3638        node = jabber_make_packet( "presence", NULL, roomjid, node );
     39        jabber_cache_add( ic, node, jabber_chat_join_failed );
    3740       
    3841        if( !jabber_write_packet( ic, node ) )
    3942        {
    4043                g_free( roomjid );
    41                 xt_free_node( node );
    4244                return NULL;
    4345        }
    44         xt_free_node( node );
    4546       
    4647        jc = g_new0( struct jabber_chat, 1 );
     
    6364       
    6465        return c;
     66}
     67
     68static xt_status jabber_chat_join_failed( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
     69{
     70        struct jabber_error *err;
     71        struct jabber_buddy *bud;
     72        char *room;
     73       
     74        room = xt_find_attr( orig, "to" );
     75        if( ( bud = jabber_buddy_by_jid( ic, room, 0 ) ) )
     76                jabber_chat_free( jabber_chat_by_jid( ic, bud->bare_jid ) );
     77       
     78        err = jabber_error_parse( xt_find_node( node->children, "error" ), XMLNS_STANZA_ERROR );
     79        if( err )
     80        {
     81                imcb_error( ic, "Error joining groupchat %s: %s%s%s",
     82                            bud->bare_jid, err->code, err->text ? ": " : "",
     83                            err->text ? err->text : "" );
     84                jabber_error_free( err );
     85        }
     86       
     87        return XT_HANDLED;
     88}
     89
     90struct groupchat *jabber_chat_by_jid( struct im_connection *ic, const char *name )
     91{
     92        char *normalized = jabber_normalize( name );
     93        struct groupchat *ret;
     94        struct jabber_chat *jc;
     95       
     96        for( ret = ic->groupchats; ret; ret = ret->next )
     97        {
     98                jc = ret->data;
     99                if( strcmp( normalized, jc->name ) == 0 )
     100                        break;
     101        }
     102        g_free( normalized );
     103       
     104        return ret;
    65105}
    66106
     
    148188        char *s;
    149189       
    150         if( ( chat = jabber_chat_by_name( ic, bud->bare_jid ) ) == NULL )
     190        if( ( chat = jabber_chat_by_jid( ic, bud->bare_jid ) ) == NULL )
    151191        {
    152192                /* How could this happen?? We could do kill( self, 11 )
     
    250290                return;
    251291        }
    252         else if( ( chat = jabber_chat_by_name( ic, bud->bare_jid ) ) == NULL )
     292        else if( ( chat = jabber_chat_by_jid( ic, bud->bare_jid ) ) == NULL )
    253293        {
    254294                /* How could this happen?? We could do kill( self, 11 )
  • protocols/jabber/iq.c

    rdce3903 r8076ec0  
    3131{
    3232        struct im_connection *ic = data;
    33         struct jabber_data *jd = ic->proto_data;
    3433        struct xt_node *c, *reply = NULL;
    3534        char *type, *s;
     
    4746        if( strcmp( type, "result" ) == 0 || strcmp( type, "error" ) == 0 )
    4847        {
    49                 struct jabber_cache_entry *entry;
    50                
    51                 if( ( s = xt_find_attr( node, "id" ) ) == NULL ||
    52                     strncmp( s, jd->cached_id_prefix, strlen( jd->cached_id_prefix ) ) != 0 )
    53                 {
    54                         /* Silently ignore it, without an ID (or a non-cache
    55                            ID) we don't know how to handle the packet and we
    56                            probably don't have to. */
    57                         return XT_HANDLED;
    58                 }
    59                
    60                 entry = g_hash_table_lookup( jd->node_cache, s );
    61                
    62                 if( entry == NULL )
    63                         imcb_log( ic, "WARNING: Received IQ-%s packet with unknown/expired ID %s!", type, s );
    64                 else if( entry->func )
    65                         return entry->func( ic, node, entry->node );
     48                return jabber_cache_handle_packet( ic, node );
    6649        }
    6750        else if( strcmp( type, "get" ) == 0 )
  • protocols/jabber/jabber.c

    rdce3903 r8076ec0  
    226226        jd->cached_id_prefix = g_strdup_printf( "%s%s", JABBER_CACHED_ID, s );
    227227        g_free( s );
    228        
    229         printf( "%s\n", jd->cached_id_prefix );
    230228}
    231229
     
    272270                return jabber_write( ic, message, strlen( message ) );
    273271       
    274         if( ( s = strchr( who, '=' ) ) && jabber_chat_by_name( ic, s + 1 ) )
     272        if( ( s = strchr( who, '=' ) ) && jabber_chat_by_jid( ic, s + 1 ) )
    275273                bud = jabber_buddy_by_ext_jid( ic, who, 0 );
    276274        else
     
    399397        if( strchr( room, '@' ) == NULL )
    400398                imcb_error( ic, "Invalid room name: %s", room );
    401         else if( jabber_chat_by_name( ic, room ) )
     399        else if( jabber_chat_by_jid( ic, room ) )
    402400                imcb_error( ic, "Already present in chat `%s'", room );
    403401        else
  • protocols/jabber/jabber.h

    rdce3903 r8076ec0  
    227227void jabber_cache_entry_free( gpointer entry );
    228228void jabber_cache_clean( struct im_connection *ic );
     229xt_status jabber_cache_handle_packet( struct im_connection *ic, struct xt_node *node );
    229230const struct jabber_away_state *jabber_away_state_by_code( char *code );
    230231const struct jabber_away_state *jabber_away_state_by_name( char *name );
     
    249250int jabber_buddy_remove( struct im_connection *ic, char *full_jid );
    250251int jabber_buddy_remove_bare( struct im_connection *ic, char *bare_jid );
    251 struct groupchat *jabber_chat_by_name( struct im_connection *ic, const char *name );
    252252time_t jabber_get_timestamp( struct xt_node *xt );
    253253struct jabber_error *jabber_error_parse( struct xt_node *node, char *xmlns );
     
    272272/* conference.c */
    273273struct groupchat *jabber_chat_join( struct im_connection *ic, char *room, char *nick, char *password );
     274struct groupchat *jabber_chat_by_jid( struct im_connection *ic, const char *name );
    274275void jabber_chat_free( struct groupchat *c );
    275276int jabber_chat_msg( struct groupchat *ic, char *message, int flags );
  • protocols/jabber/jabber_util.c

    rdce3903 r8076ec0  
    183183                return FALSE;
    184184        }
     185}
     186
     187xt_status jabber_cache_handle_packet( struct im_connection *ic, struct xt_node *node )
     188{
     189        struct jabber_data *jd = ic->proto_data;
     190        struct jabber_cache_entry *entry;
     191        char *s;
     192       
     193        if( ( s = xt_find_attr( node, "id" ) ) == NULL ||
     194            strncmp( s, jd->cached_id_prefix, strlen( jd->cached_id_prefix ) ) != 0 )
     195        {
     196                /* Silently ignore it, without an ID (or a non-cache
     197                   ID) we don't know how to handle the packet and we
     198                   probably don't have to. */
     199                return XT_HANDLED;
     200        }
     201       
     202        entry = g_hash_table_lookup( jd->node_cache, s );
     203       
     204        if( entry == NULL )
     205        {
     206                imcb_log( ic, "WARNING: Received %s-%s packet with unknown/expired ID %s!",
     207                              node->name, xt_find_attr( node, "type" ) ? : "(no type)", s );
     208        }
     209        else if( entry->func )
     210        {
     211                return entry->func( ic, node, entry->node );
     212        }
     213       
     214        return XT_HANDLED;
    185215}
    186216
     
    595625}
    596626
    597 struct groupchat *jabber_chat_by_name( struct im_connection *ic, const char *name )
    598 {
    599         char *normalized = jabber_normalize( name );
    600         struct groupchat *ret;
    601         struct jabber_chat *jc;
    602        
    603         for( ret = ic->groupchats; ret; ret = ret->next )
    604         {
    605                 jc = ret->data;
    606                 if( strcmp( normalized, jc->name ) == 0 )
    607                         break;
    608         }
    609         g_free( normalized );
    610        
    611         return ret;
    612 }
    613 
    614627time_t jabber_get_timestamp( struct xt_node *xt )
    615628{
     
    663676struct jabber_error *jabber_error_parse( struct xt_node *node, char *xmlns )
    664677{
    665         struct jabber_error *err = g_new0( struct jabber_error, 1 );
     678        struct jabber_error *err;
    666679        struct xt_node *c;
    667680        char *s;
    668681       
     682        if( node == NULL )
     683                return NULL;
     684       
     685        err = g_new0( struct jabber_error, 1 );
    669686        err->type = xt_find_attr( node, "type" );
    670687       
  • protocols/jabber/presence.c

    rdce3903 r8076ec0  
    4040        {
    4141                *s = 0;
    42                 if( jabber_chat_by_name( ic, from ) )
     42                if( jabber_chat_by_jid( ic, from ) )
    4343                        is_chat = 1;
    4444                *s = '/';
     
    164164        else if( strcmp( type, "error" ) == 0 )
    165165        {
     166                return jabber_cache_handle_packet( ic, node );
     167               
     168                /*
    166169                struct jabber_error *err;
    167                
    168170                if( ( c = xt_find_node( node->children, "error" ) ) )
    169171                {
     
    173175                                    err->text ? err->text : "" );
    174176                        jabber_error_free( err );
    175                 }
    176                 /* What else to do with it? */
     177                } */
    177178        }
    178179       
  • protocols/jabber/si.c

    rdce3903 r8076ec0  
    372372        tf->sid = g_strdup_printf( "BitlBeeJabberSID%d", tf->ft->local_id );
    373373       
    374         if( ( s = strchr( who, '=' ) ) && jabber_chat_by_name( ic, s + 1 ) )
     374        if( ( s = strchr( who, '=' ) ) && jabber_chat_by_jid( ic, s + 1 ) )
    375375                bud = jabber_buddy_by_ext_jid( ic, who, 0 );
    376376        else
  • protocols/oscar/msgcookie.c

    rdce3903 r8076ec0  
    131131}
    132132
    133 #if 0 /* debugging feature */
    134 int aim_dumpcookie(aim_msgcookie_t *cookie)
    135 {
    136 
    137         if (!cookie)
    138                 return -EINVAL;
    139 
    140         printf("\tCookie at %p: %d/%s with %p, next %p\n",
    141                         cookie, cookie->type, cookie->cookie,
    142                         cookie->data, cookie->next);
    143 
    144         return 0;
    145 }
    146 #endif
    147 
    148133/**
    149134 * aim_cookie_free - free an aim_msgcookie_t struct
  • unix.c

    rdce3903 r8076ec0  
    3434#include <sys/time.h>
    3535#include <sys/wait.h>
     36#include <pwd.h>
    3637
    3738global_t global;        /* Against global namespace pollution */
     
    4546        struct sigaction sig, old;
    4647       
    47         memset( &global, 0, sizeof( global_t ) );
    48        
    4948        log_init();
    5049        CONF_FILE = g_strdup( CONF_FILE_DEF );
     
    8786                return( i );
    8887       
     88        if( ( global.conf->user && *global.conf->user ) &&
     89            ( global.conf->runmode == RUNMODE_DAEMON ||
     90              global.conf->runmode == RUNMODE_FORKDAEMON ) &&
     91            ( !getuid() || !geteuid() ) )
     92        {
     93                struct passwd *pw = NULL;
     94                pw = getpwnam( global.conf->user );
     95                if( pw )
     96                {
     97                        setgid( pw->pw_gid );
     98                        setuid( pw->pw_uid );
     99                }
     100        }
     101
    89102        global.storage = storage_init( global.conf->primary_storage, global.conf->migrate_storage );
    90         if ( global.storage == NULL) {
     103        if( global.storage == NULL )
     104        {
    91105                log_message( LOGLVL_ERROR, "Unable to load storage backend '%s'", global.conf->primary_storage );
    92106                return( 1 );
    93107        }
    94        
    95108       
    96109        /* Catch some signals to tell the user what's happening before quitting */
Note: See TracChangeset for help on using the changeset viewer.