event_neonserv_join.c

   1
   2 struct neonserv_event_join_cache {
   3     struct ClientSocket *client;
   4     struct ChanUser *chanuser;
   5 };
   6
   7 static USERAUTH_CALLBACK(neonserv_event_join_nick_lookup);
   8 static void neonserv_event_join_async1(struct ClientSocket *client, struct ChanUser *chanuser);
   9
  10 static void neonserv_event_join(struct ChanUser *chanuser) {
  11     struct UserNode *user = chanuser->user;
  12     struct ClientSocket *client = getBotForChannel(chanuser->chan);
  13     if(!client) return; //we can't "see" this event
  14     if(user->flags & USERFLAG_ISBOT) {
  15         putsock(client, "MODE %s +o %s", chanuser->chan->name, chanuser->user->nick);
  16         return;
  17     }
  18     loadChannelSettings(chanuser->chan);
  19     if(!(chanuser->chan->flags & CHANFLAG_CHAN_REGISTERED)) return;
  20     char *ban;
  21     char usermask[NICKLEN+USERLEN+HOSTLEN+3];
  22     sprintf(usermask, "%s!%s@%s", user->nick, user->ident, user->host);
  23     if((ban = getBanAffectingMask(chanuser->chan, usermask)) != NULL && !(user->flags & (USERFLAG_ISBOT | USERFLAG_ISIRCOP))) {
  24         MYSQL_RES *res;
  25         MYSQL_ROW row;
  26         printf_mysql_query("SELECT `ban_reason`, `user_user` FROM `bans` LEFT JOIN `users` ON `ban_owner` = `user_id` WHERE `ban_channel` = '%d' AND `ban_mask` = '%s'", chanuser->chan->channel_id, escape_string(ban));
  27         res = mysql_use();
  28         if ((row = mysql_fetch_row(res)) != NULL) {
  29             putsock(client, "MODE %s +b %s", chanuser->chan->name, ban);
  30             putsock(client, "KICK %s %s :(%s) %s", chanuser->chan->name, chanuser->user->nick, row[1], row[0]);
  31             return;
  32         }
  33     }
  34     if(!(user->flags & USERFLAG_ISAUTHED)) {
  35         struct neonserv_event_join_cache *cache = malloc(sizeof(*cache));
  36         if (!cache) {
  37             perror("malloc() failed");
  38             return;
  39         }
  40         cache->client = client;
  41         cache->chanuser = chanuser;
  42         get_userauth(user, neonserv_event_join_nick_lookup, cache);
  43     } else
  44         neonserv_event_join_async1(client, chanuser);
  45 }
  46
  47 static USERAUTH_CALLBACK(neonserv_event_join_nick_lookup) {
  48     struct neonserv_event_join_cache *cache = data;
  49     if(user) {
  50         neonserv_event_join_async1(cache->client, cache->chanuser);
  51     }
  52     free(cache);
  53 }
  54
  55 static void neonserv_event_join_async1(struct ClientSocket *client, struct ChanUser *chanuser) {
  56     struct ClientSocket *textclient = ((client->flags & SOCKET_FLAG_PREFERRED) ? client : get_prefered_bot(client->botid));
  57     struct ChanNode *chan = chanuser->chan;
  58     struct UserNode *user = chanuser->user;
  59     MYSQL_RES *res;
  60     MYSQL_ROW row, chanuserrow;
  61     printf_mysql_query("SELECT `channel_maxusers`, `channel_greeting`, `channel_usergreeting` FROM `channels` WHERE `channel_id` = '%d'", chan->channel_id);
  62     res = mysql_use();
  63     if ((row = mysql_fetch_row(res)) == NULL) return;
  64     if(chan->usercount > atoi(row[0])) {
  65         //update maxusers
  66         printf_mysql_query("UPDATE `channels` SET `channel_maxusers` = '%d' WHERE `channel_id` = '%d'", chan->usercount, chan->channel_id);
  67     }
  68     printf_mysql_query("SELECT `chanuser_access`, `chanuser_flags`, `chanuser_info` FROM `channels` WHERE `channel_id` = '%d'", chan->channel_id);
  69     res = mysql_use();
  70     chanuserrow = mysql_fetch_row(res);
  71     int userflags = (chanuserrow ? atoi(chanuserrow[1]) : 0);
  72     int uaccess = ((chanuserrow && !(userflags & DB_CHANUSER_SUSPENDED)) ? atoi(chanuserrow[0]) : 0);
  73     //GREETING
  74     char greeting[MAXLEN];
  75     int greetingPos = 0;
  76     char *a, *b = (chanuserrow ? row[2] : row[1]);
  77     do {
  78         if(!b) break;
  79         a = strstr(b, "$");
  80         if(a) *a = '\0';
  81         greetingPos += sprintf(greeting + greetingPos, "%s", b);
  82         if(!a) break;
  83         switch(a[1]) {
  84             case '\0':
  85                 a = NULL;
  86                 break;
  87             case 'A':
  88                 greetingPos += sprintf(greeting + greetingPos, "%d", uaccess);
  89                 break;
  90             case 'B':
  91                 greetingPos += sprintf(greeting + greetingPos, "%s", client->user->nick);
  92                 break;
  93             case 'N':
  94                 greetingPos += sprintf(greeting + greetingPos, "%s", user->nick);
  95                 break;
  96             case 'H':
  97                 greetingPos += sprintf(greeting + greetingPos, "%s@%s", user->ident, user->host);
  98                 break;
  99             case 'U':
 100                 greetingPos += sprintf(greeting + greetingPos, "%s", ((user->flags & USERFLAG_ISAUTHED) ? user->auth : "*"));
 101                 break;
 102             default:
 103                 greeting[greetingPos++] = '$';
 104                 greeting[greetingPos++] = a[1];
 105                 break;
 106         }
 107         if(a)
 108             b = a+2;
 109     } while(a);
 110     if(greetingPos)
 111         reply(textclient, user, "[%s] %s", chan->name, greeting);
 112     //USER RIGHTS
 113     //INFOLINE / SEEN
 114     //DYNLIMIT
 115     //AUTOINVITE
 116 }