#include "authlib.h"
#include "../core/hooks.h"
#include "../core/schedule.h"
+#include "../lib/version.h"
+
+MODULE_VERSION(QVERSION);
int chanservnext;
int chanserv_init_status;
sstring **chantypes;
-
-const flag rcflags[] = {
- { 'a', QCFLAG_AUTOOP },
- { 'b', QCFLAG_BITCH },
- { 'c', QCFLAG_AUTOLIMIT },
- { 'e', QCFLAG_ENFORCE },
- { 'f', QCFLAG_FORCETOPIC },
- { 'g', QCFLAG_AUTOVOICE },
- { 'i', QCFLAG_INFO },
- { 'j', QCFLAG_JOINED },
- { 'k', QCFLAG_KNOWNONLY },
- { 'p', QCFLAG_PROTECT },
- { 't', QCFLAG_TOPICSAVE },
- { 'v', QCFLAG_VOICEALL },
- { 'w', QCFLAG_WELCOME },
- { 'z', QCFLAG_SUSPENDED },
- { '\0', 0 } };
-
-const flag rcuflags[] = {
- { 'a', QCUFLAG_AUTOOP },
- { 'b', QCUFLAG_BANNED },
- { 'd', QCUFLAG_DENY },
- { 'g', QCUFLAG_AUTOVOICE },
- { 'i', QCUFLAG_HIDEINFO },
- { 'j', QCUFLAG_AUTOINVITE },
- { 'k', QCUFLAG_KNOWN },
- { 'm', QCUFLAG_MASTER },
- { 'n', QCUFLAG_OWNER },
- { 'o', QCUFLAG_OP },
- { 'p', QCUFLAG_PROTECT },
- { 'q', QCUFLAG_QUIET },
- { 't', QCUFLAG_TOPIC },
- { 'v', QCUFLAG_VOICE },
- { 'w', QCUFLAG_HIDEWELCOME },
- { '\0', 0 } };
-
-const flag ruflags[] = {
- { 'a', QUFLAG_ADMIN },
- { 'd', QUFLAG_DEV },
- { 'D', QUFLAG_CLEANUPEXEMPT },
- { 'g', QUFLAG_GLINE },
- { 'G', QUFLAG_DELAYEDGLINE },
- { 'h', QUFLAG_HELPER },
- { 'i', QUFLAG_INFO },
- { 'l', QUFLAG_NEEDAUTH },
- { 'L', QUFLAG_NOAUTHLIMIT },
- { 'n', QUFLAG_NOTICE },
- { 'o', QUFLAG_OPER },
- { 'p', QUFLAG_PROTECT },
- { 'r', QUFLAG_RESTRICTED },
- { 'z', QUFLAG_SUSPENDED },
- { '\0', 0 } };
-
-const flag mdflags[] = {
- { 'l', MDFLAG_LIMIT },
- { 'b', MDFLAG_BANNED },
- { 'u', MDFLAG_ACTLIMIT },
- { '\0', 0 } };
+sstring *cs_quitreason;
void chanservfreestuff();
void chanservfinishinit(int hooknum, void *arg);
+static void cs_hourlyfunc(void *arg);
+
+DBModuleIdentifier q9dbid;
void chanservdumpstuff(void *arg) {
dumplastjoindata("lastjoin.dump");
chanservcryptoinit();
csa_initregex();
+ q9dbid = dbgetid();
+
if (chanservext!=-1 && chanservnext!=-1 && chanservaext!=-1) {
/* Set up the chantypes */
chantypes=(sstring **)malloc(CHANTYPES*sizeof(sstring *));
chantypes[4]=getsstring("special",20);
chantypes[5]=getsstring("gamesite",20);
chantypes[6]=getsstring("game",20);
+ chantypes[7]=getsstring("upgrade",20);
+ chantypes[8]=getsstring("partner",20);
/* And the log system */
cs_initlog();
/* Set up the command handler, and built in commands */
chanservcommandinit();
- chanservaddcommand("showcommands", 0, 1, cs_doshowcommands, "Lists available commands.","Usage: showcommands\n\nPrints a list of all commands currently available to you.\n");
+ chanservaddcommand("showcommands", 0, 1, cs_doshowcommands, "Lists available commands.","Usage: SHOWCOMMANDS [<mask>]\nPrints a list of commands currently available to you, where:\nmask - Mask of commands to list (* or ? are wildcards). If no mask is specified,\n all available commands are displayed.");
chanservaddcommand("quit", QCMD_DEV, 1, cs_doquit, "Makes the bot QUIT and \"reconnect\".","");
+ chanservaddcommand("setquitreason", QCMD_DEV, 1, cs_dosetquitreason, "Sets the reason to be sent when quitting due to an unload.","");
chanservaddcommand("rename", QCMD_DEV, 1, cs_dorename, "Changes the bot's name.","");
chanservaddcommand("rehash", QCMD_DEV, 0, cs_dorehash, "Reloads all text from database.","");
- chanservaddcommand("help", 0, 1, cs_dohelp, "Displays help on a specific command.","");
- chanservaddcommand("version", 0, 1, cs_doversion, "Show Version.","");
+ /* Make "HELP" take 2 arguments so things like "HELP chanflags #channel" work. Any junk after the command will go into arg 2 and be ignored. */
+ chanservaddcommand("help", 0, 2, cs_dohelp, "Displays help on a specific command.","Usage: HELP <command>\nShows help for a command, where:\ncommand - the command to show help for.\nFor a list of available commands, see SHOWCOMMANDS.\n");
+ chanservaddcommand("version", 0, 1, cs_doversion, "Show Version.","Usage: VERSION\nShows the version number of the running bot.");
chanservaddctcpcommand("ping",cs_doctcpping);
chanservaddctcpcommand("version",cs_doctcpversion);
/* Schedule the dumps */
schedulerecurring(time(NULL)+DUMPINTERVAL,0,DUMPINTERVAL,chanservdumpstuff,NULL);
+ schedulerecurring(time(NULL)+5,0,5,csdb_flushchannelcounters,NULL);
chanserv_init_status = CS_INIT_NOUSER;
void chanserv_finalinit() {
int i;
- nick *np;
+ nick *np, *nnp;
/* Scan for users */
for (i=0;i<NICKHASHSIZE;i++)
- for (np=nicktable[i];np;np=np->next)
+ for (np=nicktable[i];np;np=nnp) {
+ nnp=np->next;
cs_checknick(np);
+ }
/* Register core hooks */
registerhook(HOOK_NICK_NEWNICK, cs_handlenick);
chanserv_init_status = CS_INIT_READY;
triggerhook(HOOK_CHANSERV_RUNNING, NULL);
+
+ /* run every 60 minutes, first one 5 minutes after start */
+ schedulerecurring(time(NULL)+60*5,0,3600,cs_hourlyfunc,NULL);
+
Error("chanserv",ERR_INFO,"Ready to roll.");
}
void _fini() {
+ csdb_flushchannelcounters(NULL);
+
+ dbfreeid(q9dbid);
+
+ deleteallschedules(cs_hourlyfunc);
deleteallschedules(cs_timerfunc);
deleteallschedules(chanservreguser);
deleteallschedules(chanservdumpstuff);
deleteallschedules(chanservdgline);
+ deleteallschedules(csdb_flushchannelcounters);
if (chanservext>-1 && chanservnext>-1 && chanservaext>-1) {
int i;
}
if (chanservnick)
- deregisterlocaluser(chanservnick, "Leaving");
+ deregisterlocaluser(chanservnick, cs_quitreason?cs_quitreason->content:"Leaving");
+
+ freesstring(cs_quitreason);
deregisterhook(HOOK_NICK_NEWNICK, cs_handlenick);
deregisterhook(HOOK_NICK_ACCOUNT, cs_handlenick);
chanservremovecommand("showcommands", cs_doshowcommands);
chanservremovecommand("quit", cs_doquit);
+ chanservremovecommand("setquitreason", cs_dosetquitreason);
chanservremovecommand("rename", cs_dorename);
chanservremovecommand("rehash", cs_dorehash);
chanservremovecommand("help", cs_dohelp);
chanservcommandclose();
csa_freeregex();
+ chanservcryptofree();
cs_closelog();
}
+
+static void cs_hourlyfunc(void *arg) {
+ int i, total = 0, touched = 0, toorecent = 0;
+ chanindex *cip, *ncip;
+ regchan *rcp;
+ time_t t = time(NULL);
+
+ for (i=0;i<CHANNELHASHSIZE;i++) {
+ for (cip=chantable[i];cip;cip=ncip) {
+ ncip=cip->next;
+ if (!(rcp=cip->exts[chanservext]))
+ continue;
+
+ total++;
+
+ if(cip->channel && cs_ischannelactive(cip->channel, rcp)) {
+ rcp->lastactive = t;
+ if (rcp->lastcountersync < (t - COUNTERSYNCINTERVAL)) {
+ csdb_updatechannelcounters(rcp);
+ rcp->lastcountersync=t;
+ touched++;
+ } else {
+ toorecent++;
+ }
+ }
+
+ }
+ }
+ cs_log(NULL,"hourly update active completed, %d seen, %d touched, %d too recent to update.",total,touched,toorecent);
+}