2 #include "cmd_neonserv.h"
6 * argv[1-*] - parameters
8 static USERLIST_CALLBACK(neonserv_cmd_mode_userlist_lookup);
9 static void neonserv_cmd_mode_async1(struct ClientSocket *client, struct ClientSocket *textclient, struct UserNode *user, struct ChanNode *chan, struct Event *event, char *mode);
11 struct neonserv_cmd_mode_cache {
12 struct ClientSocket *client, *textclient;
13 struct UserNode *user;
18 CMD_BIND(neonserv_cmd_mode) {
19 struct neonserv_cmd_mode_cache *cache = malloc(sizeof(*cache));
21 perror("malloc() failed");
24 cache->client = client;
25 cache->textclient = getTextBot();
28 cache->mode = strdup(merge_argv(argv, 0, argc));
29 get_userlist_with_invisible(chan, neonserv_cmd_mode_userlist_lookup, cache);
32 static USERLIST_CALLBACK(neonserv_cmd_mode_userlist_lookup) {
33 struct neonserv_cmd_mode_cache *cache = data;
34 neonserv_cmd_mode_async1(cache->client, cache->textclient, cache->user, chan, cache->event, cache->mode);
39 static void neonserv_cmd_mode_async1(struct ClientSocket *client, struct ClientSocket *textclient, struct UserNode *user, struct ChanNode *chan, struct Event *event, char *mode) {
40 MYSQL_ROW row, defaults = NULL;
41 int i, arg, add = 1, skip = 0;
42 unsigned int modetype;
43 int db_canop, db_canvoice, db_canban, db_enfmodes;
44 struct ModeNode *modelock = createModeNode(NULL), *changemodes = createModeNode(NULL);
45 struct ModeBuffer *modeBuf;
46 struct UserNode *cuser;
47 struct ChanUser *chanuser;
48 modeBuf = initModeBuffer(client, chan);
49 printf_mysql_query("SELECT `channel_canop`, `channel_canvoice`, `channel_canban`, `channel_enfmodes`, `channel_modes` FROM `channels` WHERE `channel_id` = '%d'", chan->channel_id);
50 row = mysql_fetch_row(mysql_use());
51 if(row[0] == NULL || row[1] == NULL || row[2] == NULL || row[3] == NULL) {
52 printf_mysql_query("SELECT `channel_canop`, `channel_canvoice`, `channel_canban`, `channel_enfmodes`, `channel_modes` FROM `channels` WHERE `channel_name` = 'defaults'");
53 defaults = mysql_fetch_row(mysql_use());
55 db_canop = atoi((row[0] ? row[0] : defaults[0]));
56 db_canvoice = atoi((row[1] ? row[1] : defaults[1]));
57 db_canban = atoi((row[2] ? row[2] : defaults[2]));
58 db_enfmodes = atoi((row[3] ? row[3] : defaults[3]));
60 parseModeString(modelock, row[4]);
62 parseModeString(modelock, defaults[4]);
63 int uaccess = getChannelAccess(user, chan, 0);
65 char *argv[MAXNUMPARAMS];
73 if(argc == MAXNUMPARAMS) break;
78 char *modeStr = argv[arg++];
79 for(i = 0; i < strlen(modeStr); i++) {
90 reply(textclient, user, "NS_MODE_INVALID", modeStr[i]);
94 if(modeStr[i] == 'o') {
95 if(uaccess < db_canop) {
96 reply(textclient, user, "NS_MODE_ENFOPS", chan->name);
100 if(db_canop == -1) break;
102 if(uaccess < db_canvoice) {
103 reply(textclient, user, "NS_MODE_ENFVOICE", chan->name);
107 if(db_canvoice == -1) break;
109 cuser = searchUserByNick(carg);
111 //check for an invisible user
112 for(chanuser = getChannelUsers(chan, NULL); chanuser; chanuser = getChannelUsers(chan, chanuser)) {
113 if(!stricmp(chanuser->user->nick, carg)) {
114 cuser = chanuser->user;
120 chanuser = getChanUser(cuser, chan);
123 if(!(add ^ (chanuser->flags & (modeStr[i] == 'o' ? CHANUSERFLAG_OPPED : CHANUSERFLAG_VOICED)))) break;
126 if(modeStr[i] == 'o' && isNetworkService(cuser)) {
127 reply(textclient, user, "NS_SERVICE_IMMUNE", cuser->nick);
130 if(isUserProtected(chan, cuser, user)) {
131 reply(textclient, user, "NS_USER_PROTECTED", cuser->nick);
135 modeBufferSet(modeBuf, add, modeStr[i], carg);
139 reply(textclient, user, "NS_MODE_INVALID", modeStr[i]);
143 if(uaccess < db_canban) {
144 reply(textclient, user, "NS_MODE_CANBAN", chan->name);
148 if(db_canban == -1) break;
149 char hostmask_buffer[NICKLEN+USERLEN+HOSTLEN+3];
150 char usermask[NICKLEN+USERLEN+HOSTLEN+3];
153 carg = make_banmask(carg, hostmask_buffer);
155 for(chanuser = getChannelUsers(chan, NULL); chanuser; chanuser = getChannelUsers(chan, chanuser)) {
156 cuser = chanuser->user;
157 sprintf(usermask, "%s!%s@%s", cuser->nick, cuser->ident, cuser->host);
158 if(!match(carg, usermask)) {
159 if(isNetworkService(chanuser->user)) {
160 reply(textclient, user, "NS_SERVICE_IMMUNE", chanuser->user->nick);
164 if(isUserProtected(chan, cuser, user)) {
165 reply(textclient, user, "NS_USER_PROTECTED", cuser->nick);
170 if(match_count > 4 && (match_count * 3) > chan->usercount && !isGodMode(user)) {
172 reply(textclient, user, "NS_LAME_MASK", carg);
179 for(ban = chan->bans; ban; ban = ban->next) {
180 if(!match(carg, ban->mask)) {
187 modeBufferSet(modeBuf, add, 'b', carg);
191 modetype = getModeType(modelock, modeStr[i]);
193 reply(textclient, user, "NS_MODE_INVALID", modeStr[i]);
196 if(isModeAffected(modelock, modeStr[i]) && add == !isModeSet(modelock, modeStr[i]) && uaccess < db_enfmodes) {
198 event->flags |= CMDFLAG_OPLOG;
200 getFullModeString(modelock, tmp);
201 reply(textclient, user, "NS_MODE_LOCKED", tmp, chan->name);
205 if(add && (modetype & CHANNEL_MODE_TYPE) != CHANNEL_MODE_TYPE_D) {
207 reply(textclient, user, "NS_MODE_INVALID", modeStr[i]);
211 if((modetype & CHANNEL_MODE_VALUE) == CHANNEL_MODE_VALUE_STRING && isModeSet(modelock, modeStr[i])) {
212 char *modelock_val = getModeValue(modelock, modeStr[i]);
213 if(stricmp(carg, modelock_val)) {
215 event->flags |= CMDFLAG_OPLOG;
217 getFullModeString(modelock, tmp);
218 reply(textclient, user, "NS_MODE_LOCKED", tmp, chan->name);
223 if((modetype & CHANNEL_MODE_VALUE) == CHANNEL_MODE_VALUE_STRING && isModeSet(modelock, modeStr[i])) {
224 int *modelock_val = getModeValue(modelock, modeStr[i]);
225 if(atoi(carg) != *modelock_val) {
227 event->flags |= CMDFLAG_OPLOG;
229 getFullModeString(modelock, tmp);
230 reply(textclient, user, "NS_MODE_LOCKED", tmp, chan->name);
237 if((modetype & CHANNEL_MODE_TYPE) == CHANNEL_MODE_TYPE_D && isModeSet(chan->modes, modeStr[i]) == add)
239 if(!isModeAffected(changemodes, modeStr[i])) {
240 if(!add && (modetype & CHANNEL_MODE_KEY)) {
241 if(isModeSet(chan->modes, modeStr[i])) {
242 char *current_val = getModeValue(chan->modes, modeStr[i]);
246 if(parseMode(changemodes, add, modeStr[i], carg)) {
248 if(add && (modetype & CHANNEL_MODE_KEY) && isModeSet(chan->modes, modeStr[i])) {
249 char *current_val = getModeValue(chan->modes, modeStr[i]);
250 modeBufferSet(modeBuf, 0, modeStr[i], current_val);
251 flushModeBuffer(modeBuf);
253 if(!add && !isModeSet(chan->modes, modeStr[i])) break;
254 modeBufferSet(modeBuf, add, modeStr[i], carg);
256 modeBufferSimpleMode(modeBuf, add, modeStr[i]);
259 reply(textclient, user, "NS_MODE_INVALID", modeStr[i]);
267 getFullModeString(changemodes, tmp);
268 freeModeBuffer(modeBuf);
270 reply(textclient, user, "NS_MODE_DONE", tmp);
273 freeModeNode(modelock);
274 freeModeNode(changemodes);