src/bot_NeonHelp.c

   1 /* bot_NeonHelp.c - NeonServ v5.3
   2  * Copyright (C) 2011-2012  Philipp Kreil (pk910)
   3  *
   4  * This program is free software: you can redistribute it and/or modify
   5  * it under the terms of the GNU General Public License as published by
   6  * the Free Software Foundation, either version 3 of the License, or
   7  * (at your option) any later version.
   8  *
   9  * This program is distributed in the hope that it will be useful,
  10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12  * GNU General Public License for more details.
  13  *
  14  * You should have received a copy of the GNU General Public License
  15  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  16  */
  17
  18 #include "bot_NeonHelp.h"
  19 #include "modcmd.h"
  20 #include "cmd_neonhelp.h"
  21 #include "lang.h"
  22 #include "mysqlConn.h"
  23 #include "ClientSocket.h"
  24 #include "UserNode.h"
  25 #include "ChanNode.h"
  26 #include "ChanUser.h"
  27 #include "IRCEvents.h"
  28 #include "IRCParser.h"
  29 #include "bots.h"
  30 #include "DBHelper.h"
  31 #include "WHOHandler.h"
  32
  33 #define BOTID 4
  34 #define BOTALIAS "NeonHelp"
  35
  36 static const struct default_language_entry msgtab[] = {
  37     {"NH_NOT_ON_CHAN_1", "You cannot open this request as you are not in %s."}, /* {ARGS: "#test"} */
  38     {"NH_NOT_ON_CHAN_2", "You cannot open this request as you are not in %s or %s."}, /* {ARGS: "test", "#test-support"} */
  39     {"NH_REQUEST_RECORDED", "Your message has been recorded and assigned request ID#%d A helper should contact you shortly."}, /* {ARGS: 5} */
  40     {"NH_REQUEST_OTHERS_0", "There are no other unhandled requests."},
  41     {"NH_REQUEST_OTHERS_1", "There is 1 other unhandled request."},
  42     {"NH_REQUEST_OTHERS_2", "There are %d other unhandled requests."}, /* {ARGS: 1337} */
  43     {"NH_REQUEST_FOOTER_1", "Everything you tell me until you are helped (or you leave %1$s) will be recorded. If you part %1$s, your request will be lost."}, /* {ARGS: "#test"} */
  44     {"NH_REQUEST_FOOTER_2", "Everything you tell me until you are helped (or you leave %1$s or %2$s) will be recorded. If you part %1$s or %2$s, your request will be lost."}, /* {ARGS: "#test", "#test-support"} */
  45     {"NH_NEW_REQUEST", "New request #%d by %s: %s"}, /* {ARGS: 5, "pk910", "Help, I've fallen and I can't get up!"} */
  46     {"NH_NEXT_NONE", "No more requests."},
  47     {"NH_NEXT_NOT_FOUND", "No request found."},
  48     {"NH_NEXT_HEADER", "$bNext request: #%d %s$b"}, /* {ARGS: 5, "pk910"} */
  49     {"NH_NEXT_HELPER", "Your helper for request ID#%d is %s (Current nick: %s)."}, /* {ARGS: 5, "pk910", "Skynet"} */
  50     {"NH_NEXT_JOIN", "Please /join %s now."}, /* {ARGS: "#test-support"} */
  51     {"NH_DELETED", "Your request ID#%d has been deleted."}, /* {ARGS: 5} */
  52     {"NH_DELETED_STAFF", "Request deleted: #%d (%s)"}, /* {ARGS: 5, "pk910"} */
  53     {NULL, NULL}
  54 };
  55
  56 static void neonhelp_bot_ready(struct ClientSocket *client) {
  57     MYSQL_RES *res;
  58     MYSQL_ROW row;
  59
  60     printf_mysql_query("SELECT `automodes` FROM `bots` WHERE `id` = '%d'", client->clientid);
  61     res = mysql_use();
  62     if ((row = mysql_fetch_row(res)) != NULL) {
  63         putsock(client, "MODE %s +%s", client->user->nick, row[0]);
  64     }
  65
  66     printf_mysql_query("SELECT `channel_name`, `channel_key` FROM `bot_channels` LEFT JOIN `channels` ON `chanid` = `channel_id` WHERE `botid` = '%d' AND `suspended` = '0'", client->clientid);
  67     res = mysql_use();
  68
  69     while ((row = mysql_fetch_row(res)) != NULL) {
  70         putsock(client, "JOIN %s %s", row[0], row[1]);
  71     }
  72 }
  73
  74 static void neonhelp_trigger_callback(int clientid, struct ChanNode *chan, char *trigger) {
  75     MYSQL_RES *res;
  76     MYSQL_ROW row;
  77     loadChannelSettings(chan);
  78     if(!(chan->flags & CHANFLAG_CHAN_REGISTERED)) {
  79         strcpy(trigger, "!");
  80         return;
  81     }
  82     printf_mysql_query("SELECT `trigger`, `defaulttrigger` FROM `bot_channels` LEFT JOIN `bots` ON `botid` = `bots`.`id` WHERE `chanid` = '%d' AND `botclass` = '%d'", chan->channel_id, BOTID);
  83     res = mysql_use();
  84     row = mysql_fetch_row(res);
  85     if(row[0] && *row[0])
  86         strcpy(trigger, row[0]);
  87     else
  88         strcpy(trigger, ((row[1] && *row[1]) ? row[1] : "!"));
  89 }
  90
  91 static void start_bots() {
  92     struct ClientSocket *client;
  93     MYSQL_RES *res, *res2;
  94     MYSQL_ROW row;
  95
  96     printf_mysql_query("SELECT `nick`, `ident`, `realname`, `server`, `port`, `pass`, `textbot`, `id`, `queue`, `ssl`, `bind` FROM `bots` WHERE `botclass` = '%d' AND `active` = '1'", BOTID);
  97     res = mysql_use();
  98
  99     while ((row = mysql_fetch_row(res)) != NULL) {
 100         client = create_socket(row[3], atoi(row[4]), row[10], row[5], row[0], row[1], row[2]);
 101         client->flags |= (strcmp(row[6], "0") ? SOCKET_FLAG_PREFERRED : 0);
 102         client->flags |= (strcmp(row[8], "0") ? SOCKET_FLAG_USE_QUEUE : 0);
 103         client->flags |= (strcmp(row[9], "0") ? SOCKET_FLAG_SSL : 0);
 104         client->flags |= SOCKET_FLAG_SILENT;
 105         client->botid = BOTID;
 106         client->clientid = atoi(row[7]);
 107         connect_socket(client);
 108     }
 109
 110     printf_mysql_query("SELECT `command`, `function`, `parameters`, `global_access`, `chan_access`, `flags` FROM `bot_binds` WHERE `botclass` = '%d'", BOTID);
 111     res2 = mysql_use();
 112     while ((row = mysql_fetch_row(res2)) != NULL) {
 113         if(bind_cmd_to_command(BOTID, row[0], row[1])) {
 114             if(row[2] && strcmp(row[2], "")) {
 115                 bind_set_parameters(BOTID, row[0], row[2]);
 116             }
 117             if(row[3]) {
 118                 bind_set_global_access(BOTID, row[0], atoi(row[3]));
 119             }
 120             if(row[4]) {
 121                 bind_set_channel_access(BOTID, row[0], row[4]);
 122             }
 123             if(strcmp(row[5], "0"))
 124                 bind_set_bind_flags(BOTID, row[0], atoi(row[5]));
 125         }
 126     }
 127     bind_unbound_required_functions(BOTID);
 128 }
 129
 130 static void neonhelp_event_privmsg_async(struct ClientSocket *client, struct UserNode *user, struct UserNode *target, char *message);
 131 static USERAUTH_CALLBACK(neonhelp_event_privmsg_nick_lookup);
 132 struct neonhelp_event_privmsg_cache {
 133     struct ClientSocket *client;
 134     struct UserNode *user, *target;
 135     char *message;
 136 };
 137
 138 static void neonhelp_event_privmsg(struct UserNode *user, struct UserNode *target, char *message) {
 139     struct ClientSocket *client;
 140     for(client = getBots(SOCKET_FLAG_READY, NULL); client; client = getBots(SOCKET_FLAG_READY, client)) {
 141         if(client->user == target) {
 142             if(client->botid != BOTID) return;
 143             break;
 144         }
 145     }
 146     if(!client) return; //we got the message but we have no client that could receive it???
 147     if(user->flags & USERFLAG_ISAUTHED) {
 148         neonhelp_event_privmsg_async(client, user, target, message);
 149     } else {
 150         struct neonhelp_event_privmsg_cache *cache = malloc(sizeof(*cache));
 151         if(!cache) return;
 152         cache->client = client;
 153         cache->user = user;
 154         cache->target = target;
 155         cache->message = strdup(message);
 156         get_userauth(user, neonhelp_event_privmsg_nick_lookup, cache);
 157     }
 158 }
 159
 160 static USERAUTH_CALLBACK(neonhelp_event_privmsg_nick_lookup) {
 161     struct neonhelp_event_privmsg_cache *cache = data;
 162     neonhelp_event_privmsg_async(cache->client, cache->user, cache->target, cache->message);
 163     free(cache->message);
 164     free(cache);
 165 }
 166
 167 static void neonhelp_event_privmsg_async(struct ClientSocket *client, struct UserNode *user, struct UserNode *target, char *message) {
 168     MYSQL_RES *res;
 169     MYSQL_ROW row, row2;
 170     printf_mysql_query("SELECT `helpserv_support`, `helpserv_public`, `helpserv_intern` FROM `helpserv_settings` WHERE `helpserv_botid` = '%d'", client->clientid);
 171     res = mysql_use();
 172     if (!(row = mysql_fetch_row(res))) return;
 173     //check if the user is a supporter (access in the support channel)
 174     if((user->flags & USERFLAG_ISAUTHED)) {
 175         int caccess = 0;
 176         int userid;
 177         if(user->flags & USERFLAG_HAS_USERID)
 178             userid = user->user_id;
 179         else {
 180             printf_mysql_query("SELECT `user_id` FROM `users` WHERE `user_user` = '%s'", escape_string(user->auth));
 181             res = mysql_use();
 182             if ((row2 = mysql_fetch_row(res)) != NULL) {
 183                 userid = atoi(row2[0]);
 184                 user->user_id = userid;
 185                 user->flags |= USERFLAG_HAS_USERID;
 186             } else
 187                 userid = 0;
 188         }
 189         printf_mysql_query("SELECT `chanuser_access`, `chanuser_flags` FROM `chanusers` LEFT JOIN `channels` ON `chanuser_cid` = `channel_id` WHERE `chanuser_uid` = '%d' AND `channel_name` = '%s'", userid, escape_string(row[0]));
 190         res = mysql_use();
 191         if ((row2 = mysql_fetch_row(res)) != NULL) {
 192             int cflags = atoi(row2[1]);
 193             if(!(cflags & DB_CHANUSER_SUSPENDED))
 194                 caccess = atoi(row2[0]);
 195         }
 196         if(caccess) return; //ignore messages from supporters
 197     }
 198     //check if the user is in one of the bot's channels
 199     struct ChanUser *chanuser;
 200     struct ChanNode *chan;
 201     for(chanuser = getUserChannels(target, NULL); chanuser; chanuser = getUserChannels(target, chanuser)) {
 202         chan = chanuser->chan;
 203         if((!stricmp(chan->name, row[0]) || (row[1] && !stricmp(chan->name, row[1]))) && isUserOnChan(user, chan))
 204             break;
 205     }
 206     if(!chanuser) {
 207         if(row[1])
 208             reply(client, user, "NH_NOT_ON_CHAN_2", row[0], row[1]);
 209         else
 210             reply(client, user, "NH_NOT_ON_CHAN_1", row[0]);
 211         return;
 212     }
 213     //check if there is already a support request
 214     int others = 0;
 215     if(client->flags & SOCKET_HAVE_HELPNODE) {
 216         struct NeonHelpNode *helpnode;
 217         for(helpnode = client->botclass_helpnode; helpnode; helpnode = helpnode->next) {
 218             if(helpnode->user == user) {
 219                 //simply append the message to the database
 220                 printf_mysql_query("SELECT `text` FROM `helpserv_requests` WHERE `id` = %d", helpnode->suppid);
 221                 res = mysql_use();
 222                 if ((row2 = mysql_fetch_row(res)) != NULL) {
 223                     char *old_msg = escape_string(row2[0]);
 224                     char *new_msg = escape_string(message);
 225                     printf_long_mysql_query(1024 + strlen(old_msg) + strlen(new_msg), "UPDATE `helpserv_requests` SET `text` = '%s\n%s' WHERE `id` = %d", old_msg, new_msg, helpnode->suppid);
 226                 }
 227                 return;
 228             }
 229             others++;
 230         }
 231     }
 232     //add new request
 233     struct NeonHelpNode *helpnode = malloc(sizeof(*helpnode));
 234     if(!helpnode) return;
 235     helpnode->user = user;
 236     helpnode->status = 0;
 237     printf_mysql_query("INSERT INTO `helpserv_requests` (`host`, `hand`, `nick`, `status`, `supporter`, `time`, `text`) VALUES ('%s@%s', '%s', '%s', '0', '-1', UNIX_TIMESTAMP(), '%s')", escape_string(user->ident), escape_string(user->host), ((user->flags & USERFLAG_ISAUTHED) ? escape_string(user->auth) : "*"), escape_string(user->nick), escape_string(message));
 238     helpnode->suppid = (int) mysql_insert_id(mysql_conn);
 239     helpnode->next = ((client->flags & SOCKET_HAVE_HELPNODE) ? client->botclass_helpnode : NULL);
 240     client->botclass_helpnode = helpnode;
 241     client->flags |= SOCKET_HAVE_HELPNODE;
 242     //build the user reply...
 243     char user_reply[MAXLEN];
 244     int user_reply_pos = 0;
 245     char reply_buff[MAXLEN];
 246     //1st part: NH_REQUEST_RECORDED
 247     strcpy(user_reply + user_reply_pos, build_language_string(user, reply_buff, "NH_REQUEST_RECORDED", helpnode->suppid));
 248     user_reply_pos += strlen(reply_buff);
 249     //2nd part: NH_REQUEST_OTHERS_0 / NH_REQUEST_OTHERS_1 / NH_REQUEST_OTHERS_2
 250     user_reply[user_reply_pos++] = ' ';
 251     if(others <= 1)
 252         strcpy(user_reply + user_reply_pos, build_language_string(user, reply_buff, (others ? "NH_REQUEST_OTHERS_1" : "NH_REQUEST_OTHERS_0")));
 253     else
 254         strcpy(user_reply + user_reply_pos, build_language_string(user, reply_buff, "NH_REQUEST_OTHERS_2", others));
 255     user_reply_pos += strlen(reply_buff);
 256     //3th part: NH_REQUEST_FOOTER_1 / NH_REQUEST_FOOTER_2
 257     user_reply[user_reply_pos++] = ' ';
 258     if(row[1])
 259         strcpy(user_reply + user_reply_pos, build_language_string(user, reply_buff, "NH_REQUEST_FOOTER_2", row[0], row[1]));
 260     else
 261         strcpy(user_reply + user_reply_pos, build_language_string(user, reply_buff, "NH_REQUEST_FOOTER_1", row[0]));
 262     user_reply_pos += strlen(reply_buff);
 263     reply(client, user, "%s", user_reply);
 264     //sent a message to the internal channel / onotice to supp channel
 265     build_language_string(user, reply_buff, "NH_NEW_REQUEST", helpnode->suppid, user->nick, message);
 266     if(row[2]) {
 267         putsock(client, "PRIVMSG %s :%s", row[2], reply_buff);
 268     } else {
 269         putsock(client, "NOTICE @%s :%s", row[0], reply_buff);
 270     }
 271 }
 272
 273 static void destroy_support_request(struct ClientSocket *client, struct NeonHelpNode *helpnode, int do_reply) {
 274     printf_mysql_query("UPDATE `helpserv_requests` SET `status` = '2' WHERE `id` = %d", helpnode->suppid);
 275     if(do_reply) {
 276         reply(client, helpnode->user, "NH_DELETED", helpnode->suppid);
 277     }
 278     free(helpnode);
 279 }
 280
 281 static void neonhelp_event_kick(struct UserNode *user, struct ChanUser *target, char *reason) {
 282     struct ClientSocket *client;
 283     MYSQL_RES *res;
 284     MYSQL_ROW row;
 285     struct ChanNode *support, *public;
 286     int userHasRequest;
 287     for(client = getBots(SOCKET_FLAG_READY, NULL); client; client = getBots(SOCKET_FLAG_READY, client)) {
 288         if(client->botid == BOTID && isUserOnChan(client->user, target->chan)) {
 289             userHasRequest = 0;
 290             struct NeonHelpNode *helpnode, *prev_helpnode = NULL;
 291             if(client->flags & SOCKET_HAVE_HELPNODE) {
 292                 for(helpnode = client->botclass_helpnode; helpnode; helpnode = helpnode->next) {
 293                     if(helpnode->user == target->user) {
 294                         userHasRequest = 1;
 295                         break;
 296                     } else
 297                         prev_helpnode = helpnode;
 298                 }
 299             }
 300             if(!userHasRequest) continue;
 301             printf_mysql_query("SELECT `helpserv_support`, `helpserv_public`, `helpserv_intern` FROM `helpserv_settings` WHERE `helpserv_botid` = '%d'", client->clientid);
 302             res = mysql_use();
 303             if (!(row = mysql_fetch_row(res))) continue;
 304             support = getChanByName(row[0]);
 305             public = (row[1] ? getChanByName(row[1]) : NULL);
 306             if(target->chan == support || !((support && isUserOnChan(target->user, support)) || (public && isUserOnChan(target->user, public)))) {
 307                 //free the user's support request
 308                 if(prev_helpnode)
 309                     prev_helpnode->next = helpnode->next;
 310                 else
 311                     client->botclass_helpnode = helpnode->next;
 312                 destroy_support_request(client, helpnode, 1);
 313             }
 314         }
 315     }
 316 }
 317
 318 static void neonhelp_event_part(struct ChanUser *target, char *reason) {
 319     struct ClientSocket *client;
 320     MYSQL_RES *res;
 321     MYSQL_ROW row;
 322     struct ChanNode *support, *public;
 323     int userHasRequest;
 324     for(client = getBots(SOCKET_FLAG_READY, NULL); client; client = getBots(SOCKET_FLAG_READY, client)) {
 325         if(client->botid == BOTID && isUserOnChan(client->user, target->chan)) {
 326             userHasRequest = 0;
 327             struct NeonHelpNode *helpnode, *prev_helpnode = NULL;
 328             if(client->flags & SOCKET_HAVE_HELPNODE) {
 329                 for(helpnode = client->botclass_helpnode; helpnode; helpnode = helpnode->next) {
 330                     if(helpnode->user == target->user) {
 331                         userHasRequest = 1;
 332                         break;
 333                     } else
 334                         prev_helpnode = helpnode;
 335                 }
 336             }
 337             if(!userHasRequest) continue;
 338             printf_mysql_query("SELECT `helpserv_support`, `helpserv_public`, `helpserv_intern` FROM `helpserv_settings` WHERE `helpserv_botid` = '%d'", client->clientid);
 339             res = mysql_use();
 340             if (!(row = mysql_fetch_row(res))) continue;
 341             support = getChanByName(row[0]);
 342             public = (row[1] ? getChanByName(row[1]) : NULL);
 343             if(target->chan == support || !((support && isUserOnChan(target->user, support)) || (public && isUserOnChan(target->user, public)))) {
 344                 //free the user's support request
 345                 if(prev_helpnode)
 346                     prev_helpnode->next = helpnode->next;
 347                 else
 348                     client->botclass_helpnode = helpnode->next;
 349                 destroy_support_request(client, helpnode, 1);
 350             }
 351         }
 352     }
 353 }
 354
 355 static void neonhelp_event_quit(struct UserNode *target, char *reason) {
 356     struct ClientSocket *client;
 357     int userHasRequest;
 358     for(client = getBots(SOCKET_FLAG_READY, NULL); client; client = getBots(SOCKET_FLAG_READY, client)) {
 359         if(client->botid == BOTID) {
 360             userHasRequest = 0;
 361             struct NeonHelpNode *helpnode, *prev_helpnode = NULL;
 362             if(client->flags & SOCKET_HAVE_HELPNODE) {
 363                 for(helpnode = client->botclass_helpnode; helpnode; helpnode = helpnode->next) {
 364                     if(helpnode->user == target) {
 365                         userHasRequest = 1;
 366                         break;
 367                     } else
 368                         prev_helpnode = helpnode;
 369                 }
 370             }
 371             if(!userHasRequest) continue;
 372             //free the user's support request
 373             if(prev_helpnode)
 374                 prev_helpnode->next = helpnode->next;
 375             else
 376                 client->botclass_helpnode = helpnode->next;
 377             destroy_support_request(client, helpnode, 0);
 378         }
 379     }
 380 }
 381
 382 void init_NeonHelp() {
 383
 384     set_bot_alias(BOTID, BOTALIAS);
 385     start_bots();
 386
 387     //register events
 388     bind_bot_ready(neonhelp_bot_ready);
 389     bind_privmsg(neonhelp_event_privmsg);
 390     bind_part(neonhelp_event_part);
 391     bind_kick(neonhelp_event_kick);
 392     bind_quit(neonhelp_event_quit);
 393
 394     set_trigger_callback(BOTID, neonhelp_trigger_callback);
 395
 396     register_default_language_table(msgtab);
 397 }
 398
 399 void loop_NeonHelp() {
 400
 401 }
 402
 403 void free_NeonHelp() {
 404
 405 }
 406
 407 #undef BOTID
 408 #undef BOTALIAS