#include "EventLogger.h"
#include "bots.h"
#include "cmd_neonserv.h"
+#include "cmd_neonspam.h"
#define BOTID 2
static int loadNeonSpamSettings(struct ChanNode *chan);
static void createSpamNode(struct ChanUser *chanuser);
+static void freeJoinNode(struct NeonSpamJoinNode *joinnode);
+static struct NeonSpamJoinNode *getNeonSpamJoinNode(struct ChanUser *chanuser);
+
+#define SPAMSERV_CHECK_IGNORE 0
+#define SPAMSERV_CHECK_WARN 1
+#define SPAMSERV_CHECK_PUNISH 2
+
+#define SPAMSERV_MSG_SPAM "Spamming"
+#define SPAMSERV_MSG_FLOOD "Flooding the channel/network"
+#define SPAMSERV_MSG_ADV "Advertising"
+#define SPAMSERV_MSG_JOINFLOOD "Join flooding the channel"
+#define SPAMSERV_MSG_WARNING "%s is against the channel rules"
//EVENTS
-//#include "event_neonspam_join.c"
+#include "event_neonspam_join.c"
#include "event_neonspam_chanmsg.c"
static void neonspam_bot_ready(struct ClientSocket *client) {
}
static int loadNeonSpamSettings(struct ChanNode *chan) {
+ if(chan->spam_settings) return 0;
struct NeonSpamSettings *settings = malloc(sizeof(*settings));
if(!settings) {
perror("malloc() failed");
return 0;
}
- settings->flags = SPAMSETTINGS_SCANVOICE | SPAMSETTINGS_FLOODSCAN | SPAMSETTINGS_SPAMSCAN;
- settings->spam_amount = 3;
- settings->flood_amount = 4;
- settings->flood_time = 5;
+ MYSQL_RES *res;
+ MYSQL_ROW row, defaults = NULL;
+ loadChannelSettings(chan);
+ printf_mysql_query("SELECT `channel_scanstate`, `channel_maxrepeat`, `channel_maxflood`, `channel_floodtime`, `channel_maxjoin`, `channel_jointime`, `channel_scanexcept` FROM `channels` WHERE `channel_id` = '%d'", chan->channel_id);
+ res = mysql_use();
+ row = mysql_fetch_row(res);
+ if(!row[0] || !row[1] || !row[2] || !row[3] || !row[4] || !row[5]) {
+ printf_mysql_query("SELECT `channel_scanstate`, `channel_maxrepeat`, `channel_maxflood`, `channel_floodtime`, `channel_maxjoin`, `channel_jointime`, `channel_scanexcept` FROM `channels` WHERE `channel_name` = 'defaults'");
+ res = mysql_use();
+ defaults = mysql_fetch_row(res);
+ }
+ settings->flags = atoi(row[0] ? row[0] : defaults[0]);
+ settings->spam_amount = atoi(row[1] ? row[1] : defaults[1]);
+ settings->flood_amount = atoi(row[2] ? row[2] : defaults[2]);
+ settings->flood_time = atoi(row[3] ? row[3] : defaults[3]);
+ settings->join_amount = atoi(row[4] ? row[4] : defaults[4]);
+ settings->join_time = atoi(row[5] ? row[5] : defaults[5]);
+ settings->exceptlevel = atoi(row[6] ? row[6] : defaults[6]);
+ settings->join_nodes = NULL;
chan->spam_settings = settings;
return 1;
}
+void freeNeonSpamSettings(struct NeonSpamSettings *settings) {
+ struct NeonSpamJoinNode *joinnode, *nextjoinnode;
+ for(joinnode = settings->join_nodes; joinnode; joinnode = nextjoinnode) {
+ nextjoinnode = joinnode->next;
+ freeJoinNode(joinnode);
+ }
+ free(settings);
+}
+
+static void freeJoinNode(struct NeonSpamJoinNode *joinnode) {
+ free(joinnode->ident);
+ free(joinnode->host);
+ free(joinnode);
+}
+
+static struct NeonSpamJoinNode *getNeonSpamJoinNode(struct ChanUser *chanuser) {
+ struct NeonSpamJoinNode *joinnode, *prevjoinnode = NULL, *nextjoinnode, *result = NULL;
+ for(joinnode = chanuser->chan->spam_settings->join_nodes; joinnode; joinnode = nextjoinnode) {
+ nextjoinnode = joinnode->next;
+ if(!stricmp(joinnode->ident, chanuser->user->ident) && !stricmp(joinnode->host, chanuser->user->host)) {
+ prevjoinnode = joinnode;
+ result = joinnode;
+ } else if(time(0) - joinnode->last_penalty_update > MAX_JOIN_TIME) {
+ freeJoinNode(joinnode);
+ if(prevjoinnode)
+ prevjoinnode->next = nextjoinnode;
+ else
+ chanuser->chan->spam_settings->join_nodes = nextjoinnode;
+ } else
+ prevjoinnode = joinnode;
+ }
+ if(result)
+ return result;
+ joinnode = malloc(sizeof(*joinnode));
+ if(!joinnode) {
+ perror("malloc() failed");
+ return NULL;
+ }
+ joinnode->ident = strdup(chanuser->user->ident);
+ joinnode->host = strdup(chanuser->user->host);
+ joinnode->last_penalty_update = time(0);
+ joinnode->joinpenalty = 0;
+ joinnode->next = chanuser->chan->spam_settings->join_nodes;
+ chanuser->chan->spam_settings->join_nodes = joinnode;
+ return joinnode;
+}
+
static void createSpamNode(struct ChanUser *chanuser) {
struct NeonSpamNode *spamnode = malloc(sizeof(*spamnode));
if(!spamnode) {
// NAME FUNCTION PARAMS PRIVS FLAGS
USER_COMMAND("netinfo", neonserv_cmd_netinfo, 0, NULL, 0);
USER_COMMAND("version", neonserv_cmd_version, 0, NULL, 0);
+ USER_COMMAND("set", neonspam_cmd_set, 0, "#channel_setters", CMDFLAG_REQUIRE_CHAN | CMDFLAG_REGISTERED_CHAN | CMDFLAG_REQUIRE_AUTH | CMDFLAG_CHECK_AUTH | CMDFLAG_LOG);
#undef USER_COMMAND
#define OPER_COMMAND(NAME,FUNCTION,PARAMCOUNT,GACCESS,FLAGS) register_command(BOTID, NAME, FUNCTION, PARAMCOUNT, NULL, GACCESS, FLAGS)
OPER_COMMAND("unregister", neonserv_cmd_unregister,1, 200, CMDFLAG_REQUIRE_AUTH | CMDFLAG_CHECK_AUTH | CMDFLAG_CHAN_PARAM | CMDFLAG_OPLOG);
OPER_COMMAND("bind", neonserv_cmd_bind, 2, 900, CMDFLAG_REQUIRE_AUTH | CMDFLAG_CHECK_AUTH | CMDFLAG_OPLOG);
OPER_COMMAND("unbind", neonserv_cmd_unbind, 1, 900, CMDFLAG_REQUIRE_AUTH | CMDFLAG_CHECK_AUTH | CMDFLAG_OPLOG);
+ OPER_COMMAND("csuspend", neonserv_cmd_csuspend, 1, 100, CMDFLAG_REQUIRE_AUTH | CMDFLAG_CHECK_AUTH | CMDFLAG_CHAN_PARAM | CMDFLAG_OPLOG);
+ OPER_COMMAND("cunsuspend", neonserv_cmd_cunsuspend,1, 100, CMDFLAG_REQUIRE_AUTH | CMDFLAG_CHECK_AUTH | CMDFLAG_CHAN_PARAM | CMDFLAG_OPLOG);
+ OPER_COMMAND("say", neonserv_cmd_say, 2, 600, CMDFLAG_REQUIRE_AUTH | CMDFLAG_CHECK_AUTH | CMDFLAG_CHAN_PARAM | CMDFLAG_OPLOG);
+ OPER_COMMAND("emote", neonserv_cmd_emote, 2, 600, CMDFLAG_REQUIRE_AUTH | CMDFLAG_CHECK_AUTH | CMDFLAG_CHAN_PARAM | CMDFLAG_OPLOG);
+ OPER_COMMAND("notice", neonserv_cmd_notice, 2, 600, CMDFLAG_REQUIRE_AUTH | CMDFLAG_CHECK_AUTH | CMDFLAG_CHAN_PARAM | CMDFLAG_OPLOG);
+ OPER_COMMAND("raw", neonserv_cmd_raw, 1, 800, CMDFLAG_REQUIRE_AUTH | CMDFLAG_CHECK_AUTH | CMDFLAG_OPLOG);
+ OPER_COMMAND("god", neonserv_cmd_god, 0, 1, CMDFLAG_REQUIRE_AUTH | CMDFLAG_CHECK_AUTH | CMDFLAG_OPLOG);
#undef OPER_COMMAND
start_bots();
//register events
bind_bot_ready(neonspam_bot_ready);
- //bind_join(neonspam_event_join);
+ bind_join(neonspam_event_join);
bind_chanmsg(neonspam_event_chanmsg);
bind_privctcp(general_event_privctcp);