chanserv/chanservdb_updates.c

   1 /*
   2  * chanservdb_updates.c:
   3  *  Handle all the update requests for the database.
   4  */
   5
   6 #include "chanserv.h"
   7 #include "../dbapi/dbapi.h"
   8 #include "../core/config.h"
   9 #include "../lib/sstring.h"
  10 #include "../parser/parser.h"
  11 #include "../core/events.h"
  12
  13 #include <string.h>
  14 #include <stdio.h>
  15 #include <sys/poll.h>
  16 #include <stdarg.h>
  17
  18 void csdb_updateauthinfo(reguser *rup) {
  19   char eschost[2*HOSTLEN+1];
  20
  21   dbescapestring(eschost,rup->lastuserhost->content,rup->lastuserhost->length);
  22   dbquery("UPDATE chanserv.users SET lastauth=%lu,lastuserhost='%s' WHERE ID=%u",
  23                   rup->lastauth,eschost,rup->ID);
  24 }
  25
  26 void csdb_updatelastjoin(regchanuser *rcup) {
  27   dbquery("UPDATE chanserv.chanusers SET usetime=%lu WHERE userID=%u and channelID=%u",
  28           rcup->usetime, rcup->user->ID, rcup->chan->ID);
  29 }
  30
  31 void csdb_updatetopic(regchan *rcp) {
  32   char esctopic[TOPICLEN*2+5];
  33
  34   if (rcp->topic) {
  35     dbescapestring(esctopic,rcp->topic->content,rcp->topic->length);
  36   } else {
  37     esctopic[0]='\0';
  38   }
  39   dbquery("UPDATE chanserv.channels SET topic='%s' WHERE ID=%u",esctopic,rcp->ID);
  40 }
  41
  42 void csdb_updatechannel(regchan *rcp) {
  43   char escwelcome[WELCOMELEN*2+1];
  44   char esctopic[TOPICLEN*2+1];
  45   char esckey[70];
  46   char escreason[510];
  47   char esccomment[510];
  48   char escname[1000];
  49
  50   dbescapestring(escname, rcp->index->name->content, rcp->index->name->length);
  51
  52   if (rcp->welcome)
  53     dbescapestring(escwelcome, rcp->welcome->content,
  54                         rcp->welcome->length);
  55   else
  56     escwelcome[0]='\0';
  57
  58   if (rcp->topic)
  59     dbescapestring(esctopic, rcp->topic->content, rcp->topic->length);
  60   else
  61     esctopic[0]='\0';
  62
  63   if (rcp->key)
  64     dbescapestring(esckey, rcp->key->content, rcp->key->length);
  65   else
  66     esckey[0]='\0';
  67
  68   if (rcp->suspendreason)
  69     dbescapestring(escreason, rcp->suspendreason->content,
  70                         rcp->suspendreason->length);
  71   else
  72     escreason[0]='\0';
  73
  74   if (rcp->comment)
  75     dbescapestring(esccomment, rcp->comment->content,
  76                         rcp->comment->length);
  77   else
  78     esccomment[0]='\0';
  79
  80   dbquery("UPDATE chanserv.channels SET name='%s', flags=%d, forcemodes=%d,"
  81                   "denymodes=%d, chanlimit=%d, autolimit=%d, banstyle=%d,"
  82                   "lastactive=%lu,statsreset=%lu, banduration=%lu, founder=%u,"
  83                   "addedby=%u, suspendby=%u, suspendtime=%lu, chantype=%d, totaljoins=%u,"
  84                   "tripjoins=%u, maxusers=%u, tripusers=%u,"
  85                   "welcome='%s', topic='%s', chankey='%s', suspendreason='%s',"
  86                   "comment='%s', lasttimestamp=%jd WHERE ID=%u",escname,rcp->flags,rcp->forcemodes,
  87                   rcp->denymodes,rcp->limit,rcp->autolimit, rcp->banstyle,
  88                   rcp->lastactive,rcp->statsreset,rcp->banduration,
  89                   rcp->founder, rcp->addedby, rcp->suspendby, rcp->suspendtime,
  90                   rcp->chantype,rcp->totaljoins,rcp->tripjoins,
  91                   rcp->maxusers,rcp->tripusers,
  92                   escwelcome,esctopic,esckey,escreason,esccomment,(intmax_t)rcp->ltimestamp,rcp->ID);
  93 }
  94
  95 void csdb_updatechannelcounters(regchan *rcp) {
  96   dbquery("UPDATE chanserv.channels SET "
  97                   "lastactive=%lu, totaljoins=%u,"
  98                   "tripjoins=%u, maxusers=%u, tripusers=%u "
  99                   "WHERE ID=%u",
 100                   rcp->lastactive,
 101                   rcp->totaljoins,rcp->tripjoins,
 102                   rcp->maxusers,rcp->tripusers,
 103                   rcp->ID);
 104 }
 105
 106 void csdb_updatechanneltimestamp(regchan *rcp) {
 107   dbquery("UPDATE chanserv.channels SET "
 108                   "lasttimestamp=%jd WHERE ID=%u",
 109                   (intmax_t)rcp->ltimestamp, rcp->ID);
 110 }
 111
 112 void csdb_createchannel(regchan *rcp) {
 113   char escwelcome[WELCOMELEN*2+1];
 114   char esctopic[TOPICLEN*2+1];
 115   char esckey[70];
 116   char escreason[510];
 117   char esccomment[510];
 118   char escname[510];
 119
 120   dbescapestring(escname, rcp->index->name->content, rcp->index->name->length);
 121
 122   if (rcp->welcome)
 123     dbescapestring(escwelcome, rcp->welcome->content,
 124                         rcp->welcome->length);
 125   else
 126     escwelcome[0]='\0';
 127
 128   if (rcp->topic)
 129     dbescapestring(esctopic, rcp->topic->content, rcp->topic->length);
 130   else
 131     esctopic[0]='\0';
 132
 133   if (rcp->key)
 134     dbescapestring(esckey, rcp->key->content, rcp->key->length);
 135   else
 136     esckey[0]='\0';
 137
 138   if (rcp->suspendreason)
 139     dbescapestring(escreason, rcp->suspendreason->content,
 140                         rcp->suspendreason->length);
 141   else
 142     escreason[0]='\0';
 143
 144   if (rcp->comment)
 145     dbescapestring(esccomment, rcp->comment->content,
 146                         rcp->comment->length);
 147   else
 148     esccomment[0]='\0';
 149
 150   dbquery("INSERT INTO chanserv.channels (ID, name, flags, forcemodes, denymodes,"
 151                   "chanlimit, autolimit, banstyle, created, lastactive, statsreset, "
 152                   "banduration, founder, addedby, suspendby, suspendtime, chantype, totaljoins, tripjoins,"
 153                   "maxusers, tripusers, welcome, topic, chankey, suspendreason, "
 154                   "comment, lasttimestamp) VALUES (%u,'%s',%d,%d,%d,%d,%d,%d,%lu,%lu,%lu,%lu,%u,"
 155                   "%u,%u,%lu,%d,%u,%u,%u,%u,'%s','%s','%s','%s','%s',%jd)",
 156                   rcp->ID, escname, rcp->flags,rcp->forcemodes,
 157                   rcp->denymodes,rcp->limit,rcp->autolimit, rcp->banstyle, rcp->created,
 158                   rcp->lastactive,rcp->statsreset,rcp->banduration,
 159                   rcp->founder, rcp->addedby, rcp->suspendby, rcp->suspendtime,
 160                   rcp->chantype,rcp->totaljoins,rcp->tripjoins,
 161                   rcp->maxusers,rcp->tripusers,
 162                   escwelcome,esctopic,esckey,escreason,esccomment,(intmax_t)rcp->ltimestamp);
 163 }
 164
 165 void csdb_deletechannel(regchan *rcp) {
 166   dbquery("DELETE FROM chanserv.channels WHERE ID=%u",rcp->ID);
 167   dbquery("DELETE FROM chanserv.chanusers WHERE channelID=%u",rcp->ID);
 168   dbquery("DELETE FROM chanserv.bans WHERE channelID=%u",rcp->ID);
 169 }
 170
 171 void csdb_deleteuser(reguser *rup) {
 172   dbquery("DELETE FROM chanserv.users WHERE ID=%u",rup->ID);
 173   dbquery("DELETE FROM chanserv.chanusers WHERE userID=%u",rup->ID);
 174 }
 175
 176 void csdb_updateuser(reguser *rup) {
 177   char escpassword[25];
 178   char escemail[210];
 179   char esclastuserhost[160];
 180   char escreason[510];
 181   char esccomment[510];
 182   char escinfo[210];
 183   char esclastemail[210];
 184
 185   dbescapestring(escpassword, rup->password, strlen(rup->password));
 186
 187   if (rup->email)
 188     dbescapestring(escemail, rup->email->content, rup->email->length);
 189   else
 190     escemail[0]='\0';
 191
 192   if (rup->lastemail)
 193     dbescapestring(esclastemail, rup->lastemail->content, rup->lastemail->length);
 194   else
 195     esclastemail[0]='\0';
 196
 197   if (rup->lastuserhost)
 198     dbescapestring(esclastuserhost, rup->lastuserhost->content, rup->lastuserhost->length);
 199   else
 200     esclastuserhost[0]='\0';
 201
 202   if (rup->suspendreason)
 203     dbescapestring(escreason, rup->suspendreason->content, rup->suspendreason->length);
 204   else
 205     escreason[0]='\0';
 206
 207   if (rup->comment)
 208     dbescapestring(esccomment, rup->comment->content, rup->comment->length);
 209   else
 210     esccomment[0]='\0';
 211
 212   if (rup->info)
 213     dbescapestring(escinfo, rup->info->content, rup->info->length);
 214   else
 215     escinfo[0]='\0';
 216
 217   dbquery("UPDATE chanserv.users SET lastauth=%lu, lastemailchng=%lu, flags=%u,"
 218                   "language=%u, suspendby=%u, suspendexp=%lu, suspendtime=%lu, lockuntil=%lu, password='%s', email='%s',"
 219                   "lastuserhost='%s', suspendreason='%s', comment='%s', info='%s', lastemail='%s', lastpasschng=%lu "
 220                   " WHERE ID=%u",
 221                   rup->lastauth, rup->lastemailchange, rup->flags, rup->languageid, rup->suspendby, rup->suspendexp,
 222                   rup->suspendtime, rup->lockuntil, escpassword, escemail, esclastuserhost, escreason, esccomment, escinfo, esclastemail,
 223                   rup->lastpasschange,
 224                   rup->ID);
 225 }
 226
 227 void csdb_createuser(reguser *rup) {
 228   char escpassword[25];
 229   char escemail[210];
 230   char esclastuserhost[160];
 231   char escreason[510];
 232   char esccomment[510];
 233   char escusername[35];
 234   char escinfo[210];
 235   char esclastemail[210];
 236
 237   dbescapestring(escusername, rup->username, strlen(rup->username));
 238   dbescapestring(escpassword, rup->password, strlen(rup->password));
 239
 240   if (rup->email)
 241     dbescapestring(escemail, rup->email->content, rup->email->length);
 242   else
 243     escemail[0]='\0';
 244
 245   if (rup->lastemail)
 246     dbescapestring(esclastemail, rup->lastemail->content, rup->lastemail->length);
 247   else
 248     esclastemail[0]='\0';
 249
 250   if (rup->lastuserhost)
 251     dbescapestring(esclastuserhost, rup->lastuserhost->content, rup->lastuserhost->length);
 252   else
 253     esclastuserhost[0]='\0';
 254
 255   if (rup->suspendreason)
 256     dbescapestring(escreason, rup->suspendreason->content, rup->suspendreason->length);
 257   else
 258     escreason[0]='\0';
 259
 260   if (rup->comment)
 261     dbescapestring(esccomment, rup->comment->content, rup->comment->length);
 262   else
 263     esccomment[0]='\0';
 264
 265   if (rup->info)
 266     dbescapestring(escinfo, rup->info->content, rup->info->length);
 267   else
 268     escinfo[0]='\0';
 269
 270   dbquery("INSERT INTO chanserv.users (ID, username, created, lastauth, lastemailchng, "
 271                   "flags, language, suspendby, suspendexp, suspendtime, lockuntil, password, email, lastuserhost, "
 272                   "suspendreason, comment, info, lastemail, lastpasschng)"
 273                   "VALUES (%u,'%s',%lu,%lu,%lu,%u,%u,%u,%lu,%lu,%lu,'%s','%s','%s','%s','%s','%s','%s',%lu)",
 274                   rup->ID, escusername, rup->created, rup->lastauth, rup->lastemailchange, rup->flags,
 275                   rup->languageid, rup->suspendby, rup->suspendexp, rup->suspendtime, rup->lockuntil,
 276                   escpassword, escemail, esclastuserhost, escreason, esccomment, escinfo, esclastemail,
 277                   rup->lastpasschange);
 278 }
 279
 280
 281 void csdb_updatechanuser(regchanuser *rcup) {
 282   char escinfo[210];
 283
 284   if (rcup->info)
 285     dbescapestring(escinfo, rcup->info->content, rcup->info->length);
 286   else
 287     escinfo[0]='\0';
 288
 289   dbquery("UPDATE chanserv.chanusers SET flags=%u, changetime=%lu, "
 290                   "usetime=%lu, info='%s' WHERE channelID=%u and userID=%u",
 291                   rcup->flags, rcup->changetime, rcup->usetime, escinfo, rcup->chan->ID,rcup->user->ID);
 292 }
 293
 294 void csdb_createchanuser(regchanuser *rcup) {
 295   char escinfo[210];
 296
 297   if (rcup->info)
 298     dbescapestring(escinfo, rcup->info->content, rcup->info->length);
 299   else
 300     escinfo[0]='\0';
 301
 302   dbquery("INSERT INTO chanserv.chanusers VALUES(%u, %u, %u, %lu, %lu, '%s')",
 303                   rcup->user->ID, rcup->chan->ID, rcup->flags, rcup->changetime,
 304                   rcup->usetime, escinfo);
 305 }
 306
 307 void csdb_deletechanuser(regchanuser *rcup) {
 308   dbquery("DELETE FROM chanserv.chanusers WHERE channelid=%u AND userID=%u",
 309                   rcup->chan->ID, rcup->user->ID);
 310 }
 311
 312 void csdb_createban(regchan *rcp, regban *rbp) {
 313   char escreason[500];
 314   char banstr[100];
 315   char escban[200];
 316
 317   strcpy(banstr,bantostring(rbp->cbp));
 318   dbescapestring(escban,banstr,strlen(banstr));
 319
 320   if (rbp->reason)
 321     dbescapestring(escreason, rbp->reason->content, rbp->reason->length);
 322   else
 323     escreason[0]='\0';
 324
 325   dbquery("INSERT INTO chanserv.bans (banID, channelID, userID, hostmask, "
 326                   "expiry, reason) VALUES (%u,%u,%u,'%s',%lu,'%s')", rbp->ID, rcp->ID,
 327                   rbp->setby, escban, rbp->expiry, escreason);
 328 }
 329
 330 void csdb_updateban(regchan *rcp, regban *rbp) {
 331   char escreason[500];
 332   char banstr[100];
 333   char escban[200];
 334
 335   strcpy(banstr,bantostring(rbp->cbp));
 336   dbescapestring(escban,banstr,strlen(banstr));
 337
 338   if (rbp->reason)
 339     dbescapestring(escreason, rbp->reason->content, rbp->reason->length);
 340   else
 341     escreason[0]='\0';
 342
 343   dbquery("UPDATE chanserv.bans set channelID=%u, userID=%u, hostmask='%s', expiry=%lu, reason='%s' "
 344                   "WHERE banID=%u", rcp->ID, rbp->setby, escban, rbp->expiry, escreason, rbp->ID);
 345 }
 346
 347 void csdb_deleteban(regban *rbp) {
 348   dbquery("DELETE FROM chanserv.bans WHERE banID=%u", rbp->ID);
 349 }
 350
 351 void csdb_createmail(reguser *rup, int type) {
 352   char sqlquery[6000];
 353   char escemail[210];
 354
 355   if (type == QMAIL_NEWEMAIL) {
 356     if (rup->email) {
 357       dbescapestring(escemail, rup->email->content, rup->email->length);
 358       sprintf(sqlquery, "INSERT INTO chanserv.email (userID, emailType, prevEmail) "
 359               "VALUES (%u,%u,'%s')", rup->ID, type, escemail);
 360     }
 361   } else {
 362     sprintf(sqlquery, "INSERT INTO chanserv.email (userID, emailType) VALUES (%u,%u)", rup->ID, type);
 363   }
 364
 365   dbquery("%s", sqlquery);
 366 }
 367
 368 void csdb_deletemaildomain(maildomain *mdp) {
 369   dbquery("DELETE FROM chanserv.maildomain WHERE ID=%u", mdp->ID);
 370 }
 371
 372 void csdb_createmaildomain(maildomain *mdp) {
 373   char escdomain[210];
 374   dbescapestring(escdomain, mdp->name->content, mdp->name->length);
 375
 376   dbquery("INSERT INTO chanserv.maildomain (id, name, domainlimit, actlimit, flags) VALUES(%u, '%s', %u, %u, %u)", mdp->ID,escdomain,mdp->limit,mdp->actlimit,mdp->flags);
 377 }
 378
 379 void csdb_updatemaildomain(maildomain *mdp) {
 380   char escdomain[210];
 381   dbescapestring(escdomain, mdp->name->content, mdp->name->length);
 382
 383   dbquery("UPDATE chanserv.maildomain SET domainlimit=%u, actlimit=%u, flags=%u, name='%s' WHERE ID=%u", mdp->limit,mdp->actlimit,mdp->flags,escdomain,mdp->ID);
 384 }
 385
 386 void csdb_chanlevhistory_insert(regchan *rcp, nick *np, reguser *trup, flag_t oldflags, flag_t newflags) {
 387   reguser *rup=getreguserfromnick(np);
 388
 389   dbquery("INSERT INTO chanserv.chanlevhistory (userID, channelID, targetID, changetime, authtime, "
 390     "oldflags, newflags) VALUES (%u, %u, %u, %lu, %lu, %u, %u)",  rup->ID, rcp->ID, trup->ID, getnettime(), np->accountts,
 391     oldflags, newflags);
 392 }
 393
 394 void csdb_accounthistory_insert(nick *np, char *oldpass, char *newpass, char *oldemail, char *newemail) {
 395   reguser *rup=getreguserfromnick(np);
 396   char escoldpass[PASSLEN*2+5];
 397   char escnewpass[PASSLEN*2+5];
 398   char escoldemail[EMAILLEN*2+5];
 399   char escnewemail[EMAILLEN*2+5];
 400
 401   if (!rup || UHasOperPriv(rup))
 402     return;
 403
 404   if (oldpass)
 405     dbescapestring(escoldpass, oldpass, CSMIN(strlen(oldpass), PASSLEN));
 406   else
 407     escoldpass[0]='\0';
 408
 409   if (newpass)
 410     dbescapestring(escnewpass, newpass, CSMIN(strlen(newpass), PASSLEN));
 411   else
 412     escnewpass[0]='\0';
 413
 414   if (oldemail)
 415     dbescapestring(escoldemail, oldemail, CSMIN(strlen(oldemail), EMAILLEN));
 416   else
 417     escoldemail[0]='\0';
 418   if (newemail)
 419     dbescapestring(escnewemail, newemail, CSMIN(strlen(newemail), EMAILLEN));
 420   else
 421     escnewemail[0]='\0';
 422
 423   dbquery("INSERT INTO chanserv.accounthistory (userID, changetime, authtime, oldpassword, newpassword, oldemail, "
 424     "newemail) VALUES (%u, %lu, %lu, '%s', '%s', '%s', '%s')", rup->ID, getnettime(), np->accountts, escoldpass, escnewpass,
 425     escoldemail, escnewemail);
 426 }
 427
 428 void csdb_cleanuphistories(time_t expire_time) {
 429   Error("chanserv", ERR_INFO, "Cleaning histories.");
 430   dbquery("DELETE FROM chanserv.authhistory WHERE disconnecttime < %lu AND disconnecttime <> 0", expire_time);
 431   dbquery("DELETE FROM chanserv.chanlevhistory WHERE authtime < %lu", expire_time);
 432   dbquery("DELETE FROM chanserv.accounthistory WHERE authtime < %lu", expire_time);
 433 }
 434
 435 void csdb_deletemaillock(maillock *mlp) {
 436   dbquery("DELETE FROM chanserv.maillocks WHERE ID=%u", mlp->id);
 437 }
 438
 439 void csdb_createmaillock(maillock *mlp) {
 440   char escpattern[1024], escreason[1024];
 441
 442   dbescapestring(escpattern, mlp->pattern->content, mlp->pattern->length);
 443
 444   if (mlp->reason)
 445     dbescapestring(escreason, mlp->reason->content, mlp->reason->length);
 446   else
 447     escreason[0]='\0';
 448
 449   dbquery("INSERT INTO chanserv.maillocks (id, pattern, reason, createdby, created) VALUES(%u, '%s', '%s', %u, %jd)",
 450           mlp->id,escpattern,escreason,mlp->createdby,(intmax_t)mlp->created);
 451 }
 452
 453 void csdb_updatemaillock(maillock *mlp) {
 454   char escpattern[1024], escreason[1024];
 455
 456   dbescapestring(escpattern, mlp->pattern->content, mlp->pattern->length);
 457
 458   if (mlp->reason)
 459     dbescapestring(escreason, mlp->reason->content, mlp->reason->length);
 460   else
 461     escreason[0]='\0';
 462
 463   dbquery("UPDATE chanserv.maillocks SET pattern='%s', reason='%s', createdby=%u, created=%jd WHERE ID=%u", escpattern, escreason, mlp->createdby, (intmax_t)mlp->created, mlp->id);
 464 }
 465