]>
Commit | Line | Data |
---|---|---|
b263aa79 | 1 | /* |
2 | * chanservdb.c: | |
3 | * Handles the SQL stuff for the channel service. | |
4 | */ | |
5 | ||
6 | #include "../chanserv.h" | |
b263aa79 | 7 | #include "../../core/config.h" |
8 | #include "../../lib/sstring.h" | |
9 | #include "../../parser/parser.h" | |
10 | #include "../../core/events.h" | |
103521a1 | 11 | #include "../../core/nsmalloc.h" |
beb29b55 | 12 | #include "../../lib/strlfunc.h" |
ee8cd7d0 | 13 | #include "../../dbapi/dbapi.h" |
5857b2db | 14 | #include "../../lib/version.h" |
b263aa79 | 15 | |
16 | #include <string.h> | |
b263aa79 | 17 | #include <stdio.h> |
18 | #include <sys/poll.h> | |
19 | #include <stdarg.h> | |
20 | ||
5857b2db P |
21 | MODULE_VERSION(QVERSION); |
22 | ||
b263aa79 | 23 | int chanservdb_ready; |
24 | ||
b263aa79 | 25 | regchan **allchans; |
97390b65 | 26 | maillock *maillocks; |
b263aa79 | 27 | |
28 | int chanservext; | |
29 | int chanservaext; | |
30 | ||
31 | unsigned int lastchannelID; | |
32 | unsigned int lastuserID; | |
33 | unsigned int lastbanID; | |
e3805f60 | 34 | unsigned int lastdomainID; |
97390b65 | 35 | unsigned int lastmaillockID; |
b263aa79 | 36 | |
37 | /* Local prototypes */ | |
38 | void csdb_handlestats(int hooknum, void *arg); | |
ee8cd7d0 CP |
39 | void loadmessages_part1(DBConn *, void *); |
40 | void loadmessages_part2(DBConn *, void *); | |
41 | void loadcommandsummary_real(DBConn *, void *); | |
b263aa79 | 42 | |
43 | /* User loading functions */ | |
ee8cd7d0 CP |
44 | void loadsomeusers(DBConn *, void *); |
45 | void loadusersdone(DBConn *, void *); | |
b263aa79 | 46 | |
47 | /* Channel loading functions */ | |
ee8cd7d0 CP |
48 | void loadsomechannels(DBConn *, void *); |
49 | void loadchannelsdone(DBConn *, void *); | |
b263aa79 | 50 | |
51 | /* Chanuser loading functions */ | |
ee8cd7d0 CP |
52 | void loadchanusersinit(DBConn *, void *); |
53 | void loadsomechanusers(DBConn *, void *); | |
54 | void loadchanusersdone(DBConn *, void *); | |
b263aa79 | 55 | |
56 | /* Chanban loading functions */ | |
ee8cd7d0 CP |
57 | void loadsomechanbans(DBConn *, void *); |
58 | void loadchanbansdone(DBConn *, void *); | |
b263aa79 | 59 | |
e3805f60 | 60 | /* Mail Domain loading functions */ |
ee8cd7d0 CP |
61 | void loadsomemaildomains(DBConn *, void *); |
62 | void loadmaildomainsdone(DBConn *, void *); | |
e3805f60 | 63 | |
97390b65 | 64 | /* Mail lock loading functions */ |
ee8cd7d0 CP |
65 | void loadsomemaillocks(DBConn *, void *); |
66 | void loadmaillocksdone(DBConn *, void *); | |
97390b65 | 67 | |
b263aa79 | 68 | /* Free sstrings in the structures */ |
69 | void csdb_freestuff(); | |
70 | ||
71 | static void setuptables() { | |
72 | /* Set up the tables */ | |
73 | /* User table */ | |
aa944539 | 74 | dbattach("chanserv"); |
ee8cd7d0 | 75 | dbcreatequery("CREATE TABLE chanserv.users (" |
b263aa79 | 76 | "ID INT NOT NULL," |
77 | "username VARCHAR(16) NOT NULL," | |
78 | "created INT NOT NULL," | |
79 | "lastauth INT NOT NULL," | |
80 | "lastemailchng INT NOT NULL," | |
81 | "flags INT NOT NULL," | |
82 | "language INT NOT NULL," | |
83 | "suspendby INT NOT NULL," | |
84 | "suspendexp INT NOT NULL," | |
88d191e3 | 85 | "suspendtime INT NOT NULL," |
b438f642 | 86 | "lockuntil INT NOT NULL," |
b263aa79 | 87 | "password VARCHAR(11) NOT NULL," |
b263aa79 | 88 | "email VARCHAR(100)," |
9708f78f | 89 | "lastemail VARCHAR(100)," |
b263aa79 | 90 | "lastuserhost VARCHAR(75)," |
91 | "suspendreason VARCHAR(250)," | |
92 | "comment VARCHAR(250)," | |
93 | "info VARCHAR(100)," | |
86d2bc73 | 94 | "lastpasschng INT NOT NULL," |
b263aa79 | 95 | "PRIMARY KEY (ID))"); |
96 | ||
ee8cd7d0 | 97 | dbcreatequery("CREATE INDEX user_username_index ON chanserv.users (username)"); |
b263aa79 | 98 | |
99 | /* Channel table */ | |
ee8cd7d0 | 100 | dbcreatequery("CREATE TABLE chanserv.channels (" |
b263aa79 | 101 | "ID INT NOT NULL," |
102 | "name VARCHAR(250) NOT NULL," | |
103 | "flags INT NOT NULL," | |
104 | "forcemodes INT NOT NULL," | |
105 | "denymodes INT NOT NULL," | |
106 | "chanlimit INT NOT NULL," | |
107 | "autolimit INT NOT NULL," | |
108 | "banstyle INT NOT NULL," | |
109 | "created INT NOT NULL," | |
110 | "lastactive INT NOT NULL," | |
111 | "statsreset INT NOT NULL," | |
112 | "banduration INT NOT NULL," | |
113 | "founder INT NOT NULL," | |
114 | "addedby INT NOT NULL," | |
115 | "suspendby INT NOT NULL," | |
88d191e3 | 116 | "suspendtime INT NOT NULL," |
b263aa79 | 117 | "chantype SMALLINT NOT NULL," |
118 | "totaljoins INT NOT NULL," | |
119 | "tripjoins INT NOT NULL," | |
120 | "maxusers INT NOT NULL," | |
121 | "tripusers INT NOT NULL," | |
122 | "welcome VARCHAR(500)," | |
123 | "topic VARCHAR(250)," | |
124 | "chankey VARCHAR(23)," | |
125 | "suspendreason VARCHAR(250)," | |
126 | "comment VARCHAR(250)," | |
127 | "lasttimestamp INT," | |
128 | "PRIMARY KEY (ID))"); | |
129 | ||
130 | /* Chanuser table */ | |
ee8cd7d0 | 131 | dbcreatequery("CREATE TABLE chanserv.chanusers (" |
b263aa79 | 132 | "userID INT NOT NULL," |
133 | "channelID INT NOT NULL," | |
134 | "flags INT NOT NULL," | |
135 | "changetime INT NOT NULL," | |
136 | "usetime INT NOT NULL," | |
137 | "info VARCHAR(100) NOT NULL," | |
138 | "PRIMARY KEY (userID, channelID))"); | |
139 | ||
ee8cd7d0 CP |
140 | dbcreatequery("CREATE INDEX chanusers_userID_index on chanserv.chanusers (userID)"); |
141 | dbcreatequery("CREATE INDEX chanusers_channelID_index on chanserv.chanusers (channelID)"); | |
b263aa79 | 142 | |
ee8cd7d0 | 143 | dbcreatequery("CREATE TABLE chanserv.bans (" |
b263aa79 | 144 | "banID INT NOT NULL," /* Unique number for the ban to make |
145 | DELETEs process in finite time.. */ | |
146 | "channelID INT NOT NULL," | |
147 | "userID INT NOT NULL," /* Who set the ban.. */ | |
148 | "hostmask VARCHAR(100) NOT NULL," /* needs to be at least USERLEN+NICKLEN+HOSTLEN+2 */ | |
149 | "expiry INT NOT NULL," | |
150 | "reason VARCHAR(200)," | |
151 | "PRIMARY KEY(banID))"); | |
152 | ||
ee8cd7d0 | 153 | dbcreatequery("CREATE INDEX bans_channelID_index on chanserv.bans (channelID)"); |
b263aa79 | 154 | |
ee8cd7d0 | 155 | dbcreatequery("CREATE TABLE chanserv.languages (" |
b263aa79 | 156 | "languageID INT NOT NULL," |
157 | "code VARCHAR(2) NOT NULL," | |
158 | "name VARCHAR(30) NOT NULL)"); | |
159 | ||
ee8cd7d0 | 160 | dbcreatequery("CREATE TABLE chanserv.messages (" |
b263aa79 | 161 | "languageID INT NOT NULL," |
162 | "messageID INT NOT NULL," | |
163 | "message VARCHAR(250) NOT NULL," | |
164 | "PRIMARY KEY (languageID, messageID))"); | |
165 | ||
ee8cd7d0 | 166 | dbcreatequery("CREATE TABLE chanserv.help (" |
b263aa79 | 167 | "commandID INT NOT NULL," |
168 | "command VARCHAR(30) NOT NULL," | |
169 | "languageID INT NOT NULL," | |
170 | "summary VARCHAR(200) NOT NULL," | |
171 | "fullinfo TEXT NOT NULL," | |
172 | "PRIMARY KEY (commandID, languageID))"); | |
173 | ||
ee8cd7d0 | 174 | dbcreatequery("CREATE TABLE chanserv.email (" |
b263aa79 | 175 | "userID INT NOT NULL," |
176 | "emailtype INT NOT NULL," | |
177 | "prevEmail VARCHAR(100)," | |
7713925b CP |
178 | "mailID SERIAL," |
179 | "PRIMARY KEY (mailID))"); | |
e3805f60 | 180 | |
ee8cd7d0 | 181 | dbcreatequery("CREATE TABLE chanserv.maildomain (" |
e3805f60 P |
182 | "ID INT NOT NULL," |
183 | "name VARCHAR NOT NULL," | |
184 | "domainlimit INT NOT NULL," | |
185 | "actlimit INT NOT NULL," | |
186 | "flags INT NOT NULL," | |
187 | "PRIMARY KEY (ID))"); | |
188 | ||
ee8cd7d0 | 189 | dbcreatequery("CREATE TABLE chanserv.authhistory (" |
183b8e2f P |
190 | "userID INT NOT NULL," |
191 | "nick VARCHAR(15) NOT NULL," | |
192 | "username VARCHAR(10) NOT NULL," | |
193 | "host VARCHAR(63) NOT NULL," | |
194 | "authtime INT NOT NULL," | |
49031c0c | 195 | "disconnecttime INT NOT NULL," |
196 | "numeric INT NOT NULL," | |
197 | "quitreason VARCHAR(100) ," | |
183b8e2f P |
198 | "PRIMARY KEY (userID, authtime))"); |
199 | ||
ee8cd7d0 CP |
200 | dbcreatequery("CREATE INDEX authhistory_userID_index on chanserv.authhistory(userID)"); |
201 | dbcreatequery("CREATE TABLE chanserv.chanlevhistory (" | |
183b8e2f P |
202 | "userID INT NOT NULL," |
203 | "channelID INT NOT NULL," | |
204 | "targetID INT NOT NULL," | |
205 | "changetime INT NOT NULL," | |
206 | "authtime INT NOT NULL," | |
207 | "oldflags INT NOT NULL," | |
208 | "newflags INT NOT NULL)"); | |
209 | ||
ee8cd7d0 CP |
210 | dbcreatequery("CREATE INDEX chanlevhistory_userID_index on chanserv.chanlevhistory(userID)"); |
211 | dbcreatequery("CREATE INDEX chanlevhistory_channelID_index on chanserv.chanlevhistory(channelID)"); | |
212 | dbcreatequery("CREATE INDEX chanlevhistory_targetID_index on chanserv.chanlevhistory(targetID)"); | |
183b8e2f | 213 | |
ee8cd7d0 | 214 | dbcreatequery("CREATE TABLE chanserv.accounthistory (" |
183b8e2f P |
215 | "userID INT NOT NULL," |
216 | "changetime INT NOT NULL," | |
217 | "authtime INT NOT NULL," | |
218 | "oldpassword VARCHAR(11)," | |
219 | "newpassword VARCHAR(11)," | |
220 | "oldemail VARCHAR(100)," | |
221 | "newemail VARCHAR(100)," | |
222 | "PRIMARY KEY (userID, changetime))"); | |
223 | ||
ee8cd7d0 | 224 | dbcreatequery("CREATE INDEX accounthistory_userID_index on chanserv.accounthistory(userID)"); |
97390b65 | 225 | |
ee8cd7d0 | 226 | dbcreatequery("CREATE TABLE chanserv.maillocks (" |
97390b65 CP |
227 | "ID INT NOT NULL," |
228 | "pattern VARCHAR NOT NULL," | |
229 | "reason VARCHAR NOT NULL," | |
230 | "createdby INT NOT NULL," | |
231 | "created INT NOT NULL," | |
232 | "PRIMARY KEY (ID))"); | |
b263aa79 | 233 | } |
234 | ||
235 | void _init() { | |
236 | chanservext=registerchanext("chanserv"); | |
04b12064 | 237 | chanservaext=registerauthnameext("chanserv",1); |
b263aa79 | 238 | |
62f29043 | 239 | /* Set up the hashes */ |
b263aa79 | 240 | chanservhashinit(); |
241 | ||
242 | /* And the messages */ | |
243 | initmessages(); | |
244 | ||
ee8cd7d0 | 245 | if (dbconnected() && (chanservext!=-1) && (chanservaext!=-1)) { |
b263aa79 | 246 | registerhook(HOOK_CORE_STATSREQUEST, csdb_handlestats); |
247 | ||
248 | setuptables(); | |
249 | ||
e3805f60 | 250 | lastuserID=lastchannelID=lastdomainID=0; |
b263aa79 | 251 | |
ee8cd7d0 CP |
252 | dbloadtable("chanserv.users",NULL,loadsomeusers,loadusersdone); |
253 | dbloadtable("chanserv.channels",NULL,loadsomechannels,loadchannelsdone); | |
254 | dbloadtable("chanserv.chanusers",loadchanusersinit,loadsomechanusers,loadchanusersdone); | |
255 | dbloadtable("chanserv.bans",NULL,loadsomechanbans,loadchanbansdone); | |
256 | dbloadtable("chanserv.maildomain",NULL, loadsomemaildomains,loadmaildomainsdone); | |
257 | dbloadtable("chanserv.maillocks",NULL, loadsomemaillocks,loadmaillocksdone); | |
e3805f60 | 258 | |
b263aa79 | 259 | loadmessages(); |
260 | } | |
261 | } | |
262 | ||
263 | void _fini() { | |
6cb084fc | 264 | deregisterhook(HOOK_CORE_STATSREQUEST, csdb_handlestats); |
265 | ||
b4d3e4be CP |
266 | csdb_freestuff(); |
267 | ||
b263aa79 | 268 | if (chanservext!=-1) |
269 | releasechanext(chanservext); | |
270 | ||
271 | if (chanservaext!=-1) | |
272 | releaseauthnameext(chanservaext); | |
273 | ||
103521a1 | 274 | nsfreeall(POOL_CHANSERVDB); |
aa944539 | 275 | dbdetach("chanserv"); |
b263aa79 | 276 | } |
277 | ||
278 | void csdb_handlestats(int hooknum, void *arg) { | |
279 | /* long level=(long)arg; */ | |
280 | ||
281 | /* Keeping options open here */ | |
282 | } | |
283 | ||
284 | void chanservdbclose() { | |
285 | ||
286 | deregisterhook(HOOK_CORE_STATSREQUEST, csdb_handlestats); | |
287 | ||
288 | } | |
289 | ||
b263aa79 | 290 | /* |
291 | * loadsomeusers(): | |
292 | * Loads some users in from the SQL DB | |
293 | */ | |
294 | ||
ee8cd7d0 CP |
295 | void loadsomeusers(DBConn *dbconn, void *arg) { |
296 | DBResult *pgres; | |
b263aa79 | 297 | reguser *rup; |
e3805f60 | 298 | char *local; |
beb29b55 | 299 | char mailbuf[1024]; |
b263aa79 | 300 | |
ee8cd7d0 | 301 | pgres=dbgetresult(dbconn); |
b263aa79 | 302 | |
ee8cd7d0 | 303 | if (!dbquerysuccessful(pgres)) { |
b263aa79 | 304 | Error("chanserv",ERR_ERROR,"Error loading user DB"); |
305 | return; | |
306 | } | |
307 | ||
86d2bc73 | 308 | if (dbnumfields(pgres)!=19) { |
b263aa79 | 309 | Error("chanserv",ERR_ERROR,"User DB format error"); |
310 | return; | |
311 | } | |
312 | ||
ee8cd7d0 | 313 | while(dbfetchrow(pgres)) { |
b263aa79 | 314 | rup=getreguser(); |
315 | rup->status=0; | |
ee8cd7d0 CP |
316 | rup->ID=strtoul(dbgetvalue(pgres,0),NULL,10); |
317 | strncpy(rup->username,dbgetvalue(pgres,1),NICKLEN); rup->username[NICKLEN]='\0'; | |
318 | rup->created=strtoul(dbgetvalue(pgres,2),NULL,10); | |
319 | rup->lastauth=strtoul(dbgetvalue(pgres,3),NULL,10); | |
320 | rup->lastemailchange=strtoul(dbgetvalue(pgres,4),NULL,10); | |
321 | rup->flags=strtoul(dbgetvalue(pgres,5),NULL,10); | |
322 | rup->languageid=strtoul(dbgetvalue(pgres,6),NULL,10); | |
323 | rup->suspendby=strtoul(dbgetvalue(pgres,7),NULL,10); | |
324 | rup->suspendexp=strtoul(dbgetvalue(pgres,8),NULL,10); | |
325 | rup->suspendtime=strtoul(dbgetvalue(pgres,9),NULL,10); | |
326 | rup->lockuntil=strtoul(dbgetvalue(pgres,10),NULL,10); | |
327 | strncpy(rup->password,dbgetvalue(pgres,11),PASSLEN); rup->password[PASSLEN]='\0'; | |
328 | rup->email=getsstring(dbgetvalue(pgres,12),100); | |
e3805f60 P |
329 | if (rup->email) { |
330 | rup->domain=findorcreatemaildomain(rup->email->content); | |
331 | addregusertomaildomain(rup, rup->domain); | |
beb29b55 CP |
332 | |
333 | strlcpy(mailbuf, rup->email->content, sizeof(mailbuf)); | |
334 | if((local=strchr(mailbuf, '@'))) { | |
e3805f60 | 335 | *(local++)='\0'; |
beb29b55 | 336 | rup->localpart=getsstring(mailbuf,EMAILLEN); |
e3805f60 P |
337 | } else { |
338 | rup->localpart=NULL; | |
339 | } | |
340 | } else { | |
341 | rup->domain=NULL; | |
342 | rup->localpart=NULL; | |
343 | } | |
ee8cd7d0 CP |
344 | rup->lastemail=getsstring(dbgetvalue(pgres,13),100); |
345 | rup->lastuserhost=getsstring(dbgetvalue(pgres,14),75); | |
346 | rup->suspendreason=getsstring(dbgetvalue(pgres,15),250); | |
347 | rup->comment=getsstring(dbgetvalue(pgres,16),250); | |
348 | rup->info=getsstring(dbgetvalue(pgres,17),100); | |
86d2bc73 | 349 | rup->lastpasschange=strtoul(dbgetvalue(pgres,18),NULL,10); |
b263aa79 | 350 | rup->knownon=NULL; |
b263aa79 | 351 | rup->checkshd=NULL; |
352 | rup->stealcount=0; | |
353 | rup->fakeuser=NULL; | |
354 | addregusertohash(rup); | |
355 | ||
356 | if (rup->ID > lastuserID) { | |
357 | lastuserID=rup->ID; | |
358 | } | |
359 | } | |
360 | ||
ee8cd7d0 | 361 | dbclear(pgres); |
b263aa79 | 362 | } |
363 | ||
ee8cd7d0 | 364 | void loadusersdone(DBConn *conn, void *arg) { |
b263aa79 | 365 | Error("chanserv",ERR_INFO,"Load users done (highest ID was %d)",lastuserID); |
366 | } | |
367 | ||
368 | /* | |
369 | * Channel loading functions | |
370 | */ | |
371 | ||
ee8cd7d0 CP |
372 | void loadsomechannels(DBConn *dbconn, void *arg) { |
373 | DBResult *pgres; | |
b263aa79 | 374 | regchan *rcp; |
ee8cd7d0 | 375 | int j; |
b263aa79 | 376 | chanindex *cip; |
377 | time_t now=time(NULL); | |
378 | ||
ee8cd7d0 | 379 | pgres=dbgetresult(dbconn); |
b263aa79 | 380 | |
ee8cd7d0 | 381 | if (!dbquerysuccessful(pgres)) { |
b263aa79 | 382 | Error("chanserv",ERR_ERROR,"Error loading channel DB"); |
383 | return; | |
384 | } | |
385 | ||
ee8cd7d0 | 386 | if (dbnumfields(pgres)!=27) { |
b263aa79 | 387 | Error("chanserv",ERR_ERROR,"Channel DB format error"); |
388 | return; | |
389 | } | |
390 | ||
ee8cd7d0 CP |
391 | while(dbfetchrow(pgres)) { |
392 | cip=findorcreatechanindex(dbgetvalue(pgres,1)); | |
b263aa79 | 393 | if (cip->exts[chanservext]) { |
394 | Error("chanserv",ERR_WARNING,"%s in database twice - this WILL cause problems later.",cip->name->content); | |
395 | continue; | |
396 | } | |
397 | rcp=getregchan(); | |
398 | cip->exts[chanservext]=rcp; | |
399 | ||
ee8cd7d0 | 400 | rcp->ID=strtoul(dbgetvalue(pgres,0),NULL,10); |
b263aa79 | 401 | rcp->index=cip; |
ee8cd7d0 | 402 | rcp->flags=strtoul(dbgetvalue(pgres,2),NULL,10); |
b263aa79 | 403 | rcp->status=0; /* Non-DB field */ |
404 | rcp->lastbancheck=0; | |
405 | rcp->lastcountersync=now; | |
406 | rcp->lastpart=0; | |
407 | rcp->bans=NULL; | |
ee8cd7d0 CP |
408 | rcp->forcemodes=strtoul(dbgetvalue(pgres,3),NULL,10); |
409 | rcp->denymodes=strtoul(dbgetvalue(pgres,4),NULL,10); | |
410 | rcp->limit=strtoul(dbgetvalue(pgres,5),NULL,10); | |
411 | rcp->autolimit=strtoul(dbgetvalue(pgres,6),NULL,10); | |
412 | rcp->banstyle=strtoul(dbgetvalue(pgres,7),NULL,10); | |
413 | rcp->created=strtoul(dbgetvalue(pgres,8),NULL,10); | |
414 | rcp->lastactive=strtoul(dbgetvalue(pgres,9),NULL,10); | |
415 | rcp->statsreset=strtoul(dbgetvalue(pgres,10),NULL,10); | |
416 | rcp->banduration=strtoul(dbgetvalue(pgres,11),NULL,10); | |
417 | rcp->founder=strtol(dbgetvalue(pgres,12),NULL,10); | |
418 | rcp->addedby=strtol(dbgetvalue(pgres,13),NULL,10); | |
419 | rcp->suspendby=strtol(dbgetvalue(pgres,14),NULL,10); | |
420 | rcp->suspendtime=strtol(dbgetvalue(pgres,15),NULL,10); | |
421 | rcp->chantype=strtoul(dbgetvalue(pgres,16),NULL,10); | |
422 | rcp->totaljoins=strtoul(dbgetvalue(pgres,17),NULL,10); | |
423 | rcp->tripjoins=strtoul(dbgetvalue(pgres,18),NULL,10); | |
424 | rcp->maxusers=strtoul(dbgetvalue(pgres,19),NULL,10); | |
425 | rcp->tripusers=strtoul(dbgetvalue(pgres,20),NULL,10); | |
426 | rcp->welcome=getsstring(dbgetvalue(pgres,21),500); | |
427 | rcp->topic=getsstring(dbgetvalue(pgres,22),TOPICLEN); | |
428 | rcp->key=getsstring(dbgetvalue(pgres,23),KEYLEN); | |
429 | rcp->suspendreason=getsstring(dbgetvalue(pgres,24),250); | |
430 | rcp->comment=getsstring(dbgetvalue(pgres,25),250); | |
b263aa79 | 431 | rcp->checksched=NULL; |
ee8cd7d0 | 432 | rcp->ltimestamp=strtoul(dbgetvalue(pgres,26),NULL,10); |
b263aa79 | 433 | memset(rcp->regusers,0,REGCHANUSERHASHSIZE*sizeof(reguser *)); |
434 | ||
435 | if (rcp->ID > lastchannelID) | |
436 | lastchannelID=rcp->ID; | |
437 | ||
438 | if (CIsAutoLimit(rcp)) | |
439 | rcp->limit=0; | |
1482fb78 | 440 | |
441 | for (j=0;j<CHANOPHISTORY;j++) { | |
442 | rcp->chanopnicks[j][0]='\0'; | |
443 | rcp->chanopaccts[j]=0; | |
444 | } | |
445 | rcp->chanoppos=0; | |
b263aa79 | 446 | } |
447 | ||
ee8cd7d0 | 448 | dbclear(pgres); |
b263aa79 | 449 | } |
450 | ||
ee8cd7d0 | 451 | void loadchannelsdone(DBConn *dbconn, void *arg) { |
b263aa79 | 452 | Error("chanserv",ERR_INFO,"Channel load done (highest ID was %d)",lastchannelID); |
453 | } | |
454 | ||
ee8cd7d0 | 455 | void loadchanusersinit(DBConn *dbconn, void *arg) { |
b263aa79 | 456 | int i; |
457 | chanindex *cip; | |
458 | regchan *rcp; | |
459 | ||
460 | allchans=(regchan **)malloc((lastchannelID+1)*sizeof(regchan *)); | |
461 | memset(allchans,0,(lastchannelID+1)*sizeof(regchan *)); | |
462 | for (i=0;i<CHANNELHASHSIZE;i++) { | |
463 | for (cip=chantable[i];cip;cip=cip->next) { | |
464 | if (cip->exts[chanservext]) { | |
465 | rcp=(regchan *)cip->exts[chanservext]; | |
466 | allchans[rcp->ID]=rcp; | |
467 | } | |
468 | } | |
469 | } | |
470 | } | |
471 | ||
ee8cd7d0 CP |
472 | void loadsomechanusers(DBConn *dbconn, void *arg) { |
473 | DBResult *pgres; | |
b263aa79 | 474 | regchanuser *rcup; |
b263aa79 | 475 | regchan *rcp; |
476 | reguser *rup; | |
477 | authname *anp; | |
478 | int uid,cid; | |
479 | int total=0; | |
480 | ||
481 | /* Set up the allchans array */ | |
ee8cd7d0 | 482 | pgres=dbgetresult(dbconn); |
b263aa79 | 483 | |
ee8cd7d0 | 484 | if (!dbquerysuccessful(pgres)) { |
b263aa79 | 485 | Error("chanserv",ERR_ERROR,"Error loading chanusers."); |
486 | return; | |
487 | } | |
488 | ||
ee8cd7d0 | 489 | if (dbnumfields(pgres)!=6) { |
b263aa79 | 490 | Error("chanserv",ERR_ERROR,"Chanusers format error"); |
491 | return; | |
492 | } | |
493 | ||
ee8cd7d0 CP |
494 | while(dbfetchrow(pgres)) { |
495 | uid=strtol(dbgetvalue(pgres,0),NULL,10); | |
496 | cid=strtol(dbgetvalue(pgres,1),NULL,10); | |
b263aa79 | 497 | |
498 | if (!(anp=findauthname(uid)) || !(rup=anp->exts[chanservaext])) { | |
499 | Error("chanserv",ERR_WARNING,"Skipping channeluser for unknown user %d",uid); | |
500 | continue; | |
501 | } | |
502 | ||
503 | if (cid>lastchannelID || !(rcp=allchans[cid])) { | |
504 | Error("chanserv",ERR_WARNING,"Skipping channeluser for unknown chan %d",cid); | |
505 | continue; | |
506 | } | |
507 | ||
508 | if (rup==NULL || rcp==NULL) { | |
509 | Error("chanserv",ERR_ERROR,"Can't add user %s on channel %s", | |
ee8cd7d0 | 510 | dbgetvalue(pgres,0),dbgetvalue(pgres,1)); |
b263aa79 | 511 | } else { |
512 | rcup=getregchanuser(); | |
513 | rcup->user=rup; | |
514 | rcup->chan=rcp; | |
ee8cd7d0 CP |
515 | rcup->flags=strtol(dbgetvalue(pgres,2),NULL,10); |
516 | rcup->changetime=strtol(dbgetvalue(pgres,3),NULL,10); | |
517 | rcup->usetime=strtol(dbgetvalue(pgres,4),NULL,10); | |
518 | rcup->info=getsstring(dbgetvalue(pgres,5),100); | |
b263aa79 | 519 | addregusertochannel(rcup); |
520 | total++; | |
521 | } | |
522 | } | |
523 | ||
ee8cd7d0 | 524 | dbclear(pgres); |
b263aa79 | 525 | } |
526 | ||
ee8cd7d0 | 527 | void loadchanusersdone(DBConn *dbconn, void *arg) { |
b263aa79 | 528 | Error("chanserv",ERR_INFO,"Channel user load done."); |
529 | } | |
530 | ||
ee8cd7d0 CP |
531 | void loadsomechanbans(DBConn *dbconn, void *arg) { |
532 | DBResult *pgres; | |
b263aa79 | 533 | regban *rbp; |
b263aa79 | 534 | regchan *rcp; |
535 | int uid,cid,bid; | |
ea4a0a50 | 536 | time_t expiry; |
b263aa79 | 537 | int total=0; |
538 | ||
ee8cd7d0 | 539 | pgres=dbgetresult(dbconn); |
b263aa79 | 540 | |
ee8cd7d0 | 541 | if (!dbquerysuccessful(pgres)) { |
b263aa79 | 542 | Error("chanserv",ERR_ERROR,"Error loading bans."); |
543 | return; | |
544 | } | |
545 | ||
ee8cd7d0 | 546 | if (dbnumfields(pgres)!=6) { |
b263aa79 | 547 | Error("chanserv",ERR_ERROR,"Ban format error"); |
548 | return; | |
549 | } | |
550 | ||
ee8cd7d0 CP |
551 | while(dbfetchrow(pgres)) { |
552 | bid=strtoul(dbgetvalue(pgres,0),NULL,10); | |
553 | cid=strtoul(dbgetvalue(pgres,1),NULL,10); | |
554 | uid=strtoul(dbgetvalue(pgres,2),NULL,10); | |
555 | expiry=strtoul(dbgetvalue(pgres,4),NULL,10); | |
b263aa79 | 556 | |
557 | if (cid>lastchannelID || !(rcp=allchans[cid])) { | |
558 | Error("chanserv",ERR_WARNING,"Skipping ban for unknown chan %d",cid); | |
559 | continue; | |
560 | } | |
561 | ||
562 | rbp=getregban(); | |
563 | rbp->setby=uid; | |
564 | rbp->ID=bid; | |
565 | rbp->expiry=expiry; | |
ee8cd7d0 CP |
566 | rbp->reason=getsstring(dbgetvalue(pgres,5),200); |
567 | rbp->cbp=makeban(dbgetvalue(pgres,3)); | |
b263aa79 | 568 | rbp->next=rcp->bans; |
569 | rcp->bans=rbp; | |
570 | ||
571 | total++; | |
572 | ||
573 | if (bid>lastbanID) | |
574 | lastbanID=bid; | |
575 | } | |
576 | ||
ee8cd7d0 | 577 | dbclear(pgres); |
b263aa79 | 578 | } |
579 | ||
ee8cd7d0 | 580 | void loadchanbansdone(DBConn *dbconn, void *arg) { |
b263aa79 | 581 | free(allchans); |
582 | ||
583 | Error("chanserv",ERR_INFO,"Channel ban load done, highest ID was %d",lastbanID); | |
b263aa79 | 584 | } |
585 | ||
586 | void loadmessages() { | |
ee8cd7d0 | 587 | dbasyncquery(loadmessages_part1, NULL, "SELECT * from chanserv.languages"); |
b263aa79 | 588 | } |
589 | ||
ee8cd7d0 | 590 | void loadmessages_part1(DBConn *dbconn, void *arg) { |
b263aa79 | 591 | int i,j; |
ee8cd7d0 | 592 | DBResult *pgres; |
b263aa79 | 593 | |
594 | /* Firstly, clear up any stale messages */ | |
595 | for (i=0;i<MAXLANG;i++) { | |
596 | if (cslanguages[i]) { | |
597 | freesstring(cslanguages[i]->name); | |
598 | free(cslanguages[i]); | |
599 | } | |
600 | for (j=0;j<MAXMESSAGES;j++) { | |
601 | if (csmessages[i][j]) { | |
602 | freesstring(csmessages[i][j]); | |
603 | csmessages[i][j]=NULL; | |
604 | } | |
605 | } | |
606 | } | |
607 | ||
ee8cd7d0 | 608 | pgres=dbgetresult(dbconn); |
b263aa79 | 609 | |
ee8cd7d0 | 610 | if (!dbquerysuccessful(pgres)) { |
b263aa79 | 611 | Error("chanserv",ERR_ERROR,"Error loading language list."); |
612 | return; | |
613 | } | |
614 | ||
ee8cd7d0 | 615 | if (dbnumfields(pgres)!=3) { |
b263aa79 | 616 | Error("chanserv",ERR_ERROR,"Language list format error."); |
617 | return; | |
618 | } | |
619 | ||
ee8cd7d0 CP |
620 | while(dbfetchrow(pgres)) { |
621 | j=strtol(dbgetvalue(pgres,0),NULL,10); | |
b263aa79 | 622 | if (j<MAXLANG && j>=0) { |
623 | cslanguages[j]=(cslang *)malloc(sizeof(cslang)); | |
624 | ||
ee8cd7d0 CP |
625 | strncpy(cslanguages[j]->code,dbgetvalue(pgres,1),2); cslanguages[j]->code[2]='\0'; |
626 | cslanguages[j]->name=getsstring(dbgetvalue(pgres,2),30); | |
b263aa79 | 627 | } |
628 | } | |
629 | ||
ee8cd7d0 | 630 | dbclear(pgres); |
b263aa79 | 631 | |
632 | if (i>MAXLANG) | |
633 | Error("chanserv",ERR_ERROR,"Found too many languages (%d > %d)",i,MAXLANG); | |
634 | ||
ee8cd7d0 | 635 | dbasyncquery(loadmessages_part2, NULL, "SELECT * from chanserv.messages"); |
b263aa79 | 636 | } |
637 | ||
ee8cd7d0 CP |
638 | void loadmessages_part2(DBConn *dbconn, void *arg) { |
639 | DBResult *pgres; | |
640 | int j,k; | |
b263aa79 | 641 | |
ee8cd7d0 | 642 | pgres=dbgetresult(dbconn); |
b263aa79 | 643 | |
ee8cd7d0 | 644 | if (!dbquerysuccessful(pgres)) { |
b263aa79 | 645 | Error("chanserv",ERR_ERROR,"Error loading message list."); |
646 | return; | |
647 | } | |
648 | ||
ee8cd7d0 | 649 | if (dbnumfields(pgres)!=3) { |
b263aa79 | 650 | Error("chanserv",ERR_ERROR,"Message list format error."); |
651 | return; | |
652 | } | |
653 | ||
ee8cd7d0 CP |
654 | while(dbfetchrow(pgres)) { |
655 | k=strtol(dbgetvalue(pgres,0),NULL,10); | |
656 | j=strtol(dbgetvalue(pgres,1),NULL,10); | |
b263aa79 | 657 | |
658 | if (k<0 || k >= MAXLANG) { | |
659 | Error("chanserv",ERR_WARNING,"Language ID out of range on message: %d",k); | |
660 | continue; | |
661 | } | |
662 | ||
663 | if (j<0 || j >= MAXMESSAGES) { | |
664 | Error("chanserv",ERR_WARNING,"Message ID out of range on message: %d",j); | |
665 | continue; | |
666 | } | |
667 | ||
ee8cd7d0 | 668 | csmessages[k][j]=getsstring(dbgetvalue(pgres,2),250); |
b263aa79 | 669 | } |
670 | ||
ee8cd7d0 | 671 | dbclear(pgres); |
b263aa79 | 672 | } |
673 | ||
674 | void loadcommandsummary(Command *cmd) { | |
ee8cd7d0 | 675 | dbasyncquery(loadcommandsummary_real, (void *)cmd, |
522e2b8c | 676 | "SELECT languageID,summary from chanserv.help where lower(command) = lower('%s')",cmd->command->content); |
b263aa79 | 677 | } |
678 | ||
ee8cd7d0 CP |
679 | void loadcommandsummary_real(DBConn *dbconn, void *arg) { |
680 | int i,j; | |
681 | DBResult *pgres; | |
b263aa79 | 682 | cmdsummary *cs; |
683 | Command *cmd=arg; | |
684 | ||
685 | /* Clear up old text first */ | |
686 | cs=cmd->ext; | |
687 | for (i=0;i<MAXLANG;i++) { | |
688 | if (cs->bylang[i]) | |
689 | freesstring(cs->bylang[i]); | |
690 | } | |
691 | ||
ee8cd7d0 | 692 | pgres=dbgetresult(dbconn); |
b263aa79 | 693 | |
ee8cd7d0 | 694 | if (!dbquerysuccessful(pgres)) { |
b263aa79 | 695 | Error("chanserv",ERR_ERROR,"Error loading command summary."); |
696 | return; | |
697 | } | |
698 | ||
ee8cd7d0 | 699 | if (dbnumfields(pgres)!=2) { |
b263aa79 | 700 | Error("chanserv",ERR_ERROR,"Command summary format error."); |
ee8cd7d0 | 701 | dbclear(pgres); |
b263aa79 | 702 | return; |
703 | } | |
704 | ||
ee8cd7d0 CP |
705 | while(dbfetchrow(pgres)) { |
706 | j=strtol(dbgetvalue(pgres,0),NULL,10); | |
b263aa79 | 707 | if (j<MAXLANG && j>=0) { |
ee8cd7d0 | 708 | cs->bylang[j]=getsstring(dbgetvalue(pgres,1),200); |
b263aa79 | 709 | } |
710 | } | |
711 | ||
ee8cd7d0 | 712 | dbclear(pgres); |
b263aa79 | 713 | } |
714 | ||
715 | void csdb_freestuff() { | |
716 | int i; | |
717 | chanindex *cip, *ncip; | |
718 | regchan *rcp; | |
719 | reguser *rup; | |
720 | regchanuser *rcup; | |
721 | regban *rbp; | |
e3805f60 | 722 | maildomain *mdp; |
97390b65 | 723 | maillock *mlp, *nmlp; |
b263aa79 | 724 | |
725 | for (i=0;i<REGUSERHASHSIZE;i++) { | |
726 | for (rup=regusernicktable[i];rup;rup=rup->nextbyname) { | |
727 | freesstring(rup->email); | |
b4d3e4be | 728 | freesstring(rup->localpart); |
9708f78f | 729 | freesstring(rup->lastemail); |
b263aa79 | 730 | freesstring(rup->lastuserhost); |
731 | freesstring(rup->suspendreason); | |
732 | freesstring(rup->comment); | |
733 | freesstring(rup->info); | |
734 | ||
735 | for (rcup=rup->knownon;rcup;rcup=rcup->nextbyuser) | |
736 | freesstring(rcup->info); | |
737 | } | |
738 | } | |
739 | ||
740 | for (i=0;i<CHANNELHASHSIZE;i++) { | |
741 | for (cip=chantable[i];cip;cip=ncip) { | |
742 | ncip=cip->next; | |
743 | if ((rcp=cip->exts[chanservext])) { | |
744 | freesstring(rcp->welcome); | |
745 | freesstring(rcp->topic); | |
746 | freesstring(rcp->key); | |
747 | freesstring(rcp->suspendreason); | |
748 | freesstring(rcp->comment); | |
749 | for (rbp=rcp->bans;rbp;rbp=rbp->next) { | |
750 | freesstring(rbp->reason); | |
751 | freechanban(rbp->cbp); | |
752 | } | |
753 | cip->exts[chanservext]=NULL; | |
754 | releasechanindex(cip); | |
755 | } | |
756 | } | |
757 | } | |
e3805f60 P |
758 | |
759 | for (i=0; i<MAILDOMAINHASHSIZE; i++) { | |
760 | for (mdp=maildomainnametable[i]; mdp; mdp=mdp->nextbyname) | |
761 | freesstring(mdp->name); | |
762 | } | |
97390b65 CP |
763 | |
764 | for(mlp=maillocks;mlp;mlp=nmlp) { | |
765 | nmlp=mlp->next; | |
766 | freemaillock(mlp); | |
767 | } | |
768 | maillocks=NULL; | |
e3805f60 P |
769 | } |
770 | ||
ee8cd7d0 CP |
771 | void loadsomemaildomains(DBConn *dbconn,void *arg) { |
772 | DBResult *pgres; | |
e3805f60 | 773 | maildomain *mdp; |
e3805f60 | 774 | char *domain; |
ee8cd7d0 | 775 | pgres=dbgetresult(dbconn); |
e3805f60 | 776 | |
ee8cd7d0 | 777 | if (!dbquerysuccessful(pgres)) { |
e3805f60 P |
778 | Error("chanserv",ERR_ERROR,"Error loading maildomain DB"); |
779 | return; | |
ee8cd7d0 | 780 | } |
e3805f60 | 781 | |
ee8cd7d0 | 782 | if (dbnumfields(pgres)!=5) { |
e3805f60 | 783 | Error("chanserv",ERR_ERROR,"Mail Domain DB format error"); |
ee8cd7d0 | 784 | dbclear(pgres); |
e3805f60 P |
785 | return; |
786 | } | |
e3805f60 P |
787 | lastdomainID=0; |
788 | ||
ee8cd7d0 CP |
789 | while(dbfetchrow(pgres)) { |
790 | domain=dbgetvalue(pgres,1); | |
e3805f60 P |
791 | mdp=findorcreatemaildomain(domain); //@@@ LEN |
792 | ||
ee8cd7d0 CP |
793 | mdp->ID=strtoul(dbgetvalue(pgres,0),NULL,10); |
794 | mdp->limit=strtoul(dbgetvalue(pgres,2),NULL,10); | |
795 | mdp->actlimit=strtoul(dbgetvalue(pgres,3),NULL,10); | |
796 | mdp->flags=strtoul(dbgetvalue(pgres,4),NULL,10); | |
e3805f60 P |
797 | |
798 | if (mdp->ID > lastdomainID) { | |
799 | lastdomainID=mdp->ID; | |
800 | } | |
801 | } | |
802 | ||
ee8cd7d0 | 803 | dbclear(pgres); |
e3805f60 P |
804 | } |
805 | ||
ee8cd7d0 | 806 | void loadmaildomainsdone(DBConn *dbconn, void *arg) { |
e3805f60 | 807 | Error("chanserv",ERR_INFO,"Load Mail Domains done (highest ID was %d)",lastdomainID); |
b263aa79 | 808 | } |
e3805f60 | 809 | |
ee8cd7d0 CP |
810 | void loadsomemaillocks(DBConn *dbconn,void *arg) { |
811 | DBResult *pgres; | |
97390b65 | 812 | maillock *mlp; |
ee8cd7d0 | 813 | pgres=dbgetresult(dbconn); |
97390b65 | 814 | |
ee8cd7d0 | 815 | if (!dbquerysuccessful(pgres)) { |
97390b65 CP |
816 | Error("chanserv",ERR_ERROR,"Error loading maillock DB"); |
817 | return; | |
ee8cd7d0 | 818 | } |
97390b65 | 819 | |
ee8cd7d0 | 820 | if (dbnumfields(pgres)!=5) { |
97390b65 | 821 | Error("chanserv",ERR_ERROR,"Maillock DB format error"); |
ee8cd7d0 | 822 | dbclear(pgres); |
97390b65 CP |
823 | return; |
824 | } | |
97390b65 CP |
825 | lastmaillockID=0; |
826 | ||
ee8cd7d0 | 827 | while(dbfetchrow(pgres)) { |
97390b65 | 828 | mlp=getmaillock(); |
ee8cd7d0 CP |
829 | mlp->id=strtoul(dbgetvalue(pgres,0),NULL,10); |
830 | mlp->pattern=getsstring(dbgetvalue(pgres,1), 300); | |
831 | mlp->reason=getsstring(dbgetvalue(pgres,2), 300); | |
832 | mlp->createdby=strtoul(dbgetvalue(pgres,3),NULL,10); | |
833 | mlp->created=strtoul(dbgetvalue(pgres,4),NULL,10); | |
97390b65 CP |
834 | mlp->next=maillocks; |
835 | maillocks=mlp; | |
836 | ||
837 | if (mlp->id > lastmaillockID) | |
838 | lastmaillockID=mlp->id; | |
839 | } | |
840 | ||
ee8cd7d0 | 841 | dbclear(pgres); |
97390b65 CP |
842 | } |
843 | ||
ee8cd7d0 | 844 | void loadmaillocksdone(DBConn *dbconn, void *arg) { |
97390b65 | 845 | Error("chanserv",ERR_INFO,"Load Mail Locks done (highest ID was %d)",lastmaillockID); |
136d271d P |
846 | |
847 | chanservdb_ready=1; | |
848 | triggerhook(HOOK_CHANSERV_DBLOADED, NULL); | |
97390b65 CP |
849 | } |
850 |