+#include "cmd_neonserv.h"
+
/*
* argv[0] - modes
* argv[1-*] - parameters
char *mode;
};
-static CMD_BIND(neonserv_cmd_mode) {
+CMD_BIND(neonserv_cmd_mode) {
struct neonserv_cmd_mode_cache *cache = malloc(sizeof(*cache));
if (!cache) {
perror("malloc() failed");
static void neonserv_cmd_mode_async1(struct ClientSocket *client, struct ClientSocket *textclient, struct UserNode *user, struct ChanNode *chan, struct Event *event, char *mode) {
MYSQL_ROW row, defaults = NULL;
- int i, arg, add = 1;
+ int i, arg, add = 1, skip = 0;
unsigned int modetype;
int db_canop, db_canvoice, db_canban, db_enfmodes;
struct ModeNode *modelock = createModeNode(NULL), *changemodes = createModeNode(NULL);
struct ModeBuffer *modeBuf;
+ struct UserNode *cuser;
+ struct ChanUser *chanuser;
modeBuf = initModeBuffer(client, chan);
printf_mysql_query("SELECT `channel_canop`, `channel_canvoice`, `channel_canban`, `channel_enfmodes`, `channel_modes` FROM `channels` WHERE `channel_id` = '%d'", chan->channel_id);
row = mysql_fetch_row(mysql_use());
add = 0;
break;
case 'o':
-
- break;
case 'v':
-
+ if(arg == argc) {
+ reply(textclient, user, "NS_MODE_INVALID", modeStr[i]);
+ return;
+ }
+ carg = argv[arg++];
+ if(modeStr[i] == 'o') {
+ if(uaccess < db_canop) {
+ reply(textclient, user, "NS_MODE_ENFOPS", chan->name);
+ db_canop = -1;
+ break;
+ }
+ if(db_canop == -1) break;
+ } else {
+ if(uaccess < db_canvoice) {
+ reply(textclient, user, "NS_MODE_ENFVOICE", chan->name);
+ db_canvoice = -1;
+ break;
+ }
+ if(db_canvoice == -1) break;
+ }
+ cuser = searchUserByNick(carg);
+ if(!cuser) {
+ //check for an invisible user
+ for(chanuser = getChannelUsers(chan, NULL); chanuser; chanuser = getChannelUsers(chan, chanuser)) {
+ if(!stricmp(chanuser->user->nick, carg)) {
+ cuser = chanuser->user;
+ break;
+ }
+ }
+ if(!cuser) break;
+ } else {
+ chanuser = getChanUser(cuser, chan);
+ if(!chanuser) break;
+ }
+ if(!(add ^ (chanuser->flags & (modeStr[i] == 'o' ? CHANUSERFLAG_OPPED : CHANUSERFLAG_VOICED)))) break;
+ if(!add) {
+ //check protection
+ if(modeStr[i] == 'o' && isNetworkService(cuser)) {
+ reply(textclient, user, "NS_SERVICE_IMMUNE", cuser->nick);
+ break;
+ }
+ if(isUserProtected(chan, cuser, user)) {
+ reply(textclient, user, "NS_USER_PROTECTED", cuser->nick);
+ break;
+ }
+ }
+ modeBufferSet(modeBuf, add, modeStr[i], carg);
break;
case 'b':
-
+ if(arg == argc) {
+ reply(textclient, user, "NS_MODE_INVALID", modeStr[i]);
+ return;
+ }
+ carg = argv[arg++];
+ if(uaccess < db_canban) {
+ reply(textclient, user, "NS_MODE_CANBAN", chan->name);
+ db_canban = -1;
+ break;
+ }
+ if(db_canban == -1) break;
+ char hostmask_buffer[NICKLEN+USERLEN+HOSTLEN+3];
+ char usermask[NICKLEN+USERLEN+HOSTLEN+3];
+ struct BanNode *ban;
+ int match_count = 0;
+ carg = make_banmask(carg, hostmask_buffer);
+ if(add) {
+ for(chanuser = getChannelUsers(chan, NULL); chanuser; chanuser = getChannelUsers(chan, chanuser)) {
+ cuser = chanuser->user;
+ sprintf(usermask, "%s!%s@%s", cuser->nick, cuser->ident, cuser->host);
+ if(!match(carg, usermask)) {
+ if(isNetworkService(chanuser->user)) {
+ reply(textclient, user, "NS_SERVICE_IMMUNE", chanuser->user->nick);
+ skip = 1;
+ break;
+ }
+ if(isUserProtected(chan, cuser, user)) {
+ reply(textclient, user, "NS_USER_PROTECTED", cuser->nick);
+ skip = 1;
+ break;
+ }
+ match_count++;
+ if(match_count > 4 && (match_count * 3) > chan->usercount && !isGodMode(user)) {
+ skip = 1;
+ reply(textclient, user, "NS_LAME_MASK", carg);
+ break;
+ }
+ }
+ }
+ } else {
+ skip = 1;
+ for(ban = chan->bans; ban; ban = ban->next) {
+ if(!match(carg, ban->mask)) {
+ skip = 0;
+ break;
+ }
+ }
+ }
+ if(!skip) {
+ modeBufferSet(modeBuf, add, 'b', carg);
+ }
break;
default:
modetype = getModeType(modelock, modeStr[i]);
} else
carg = NULL;
if((modetype & CHANNEL_MODE_TYPE) == CHANNEL_MODE_TYPE_D && isModeSet(chan->modes, modeStr[i]) == add)
- continue;
+ break;
if(!isModeAffected(changemodes, modeStr[i])) {
if(!add && (modetype & CHANNEL_MODE_KEY)) {
if(isModeSet(chan->modes, modeStr[i])) {
modeBufferSet(modeBuf, 0, modeStr[i], current_val);
flushModeBuffer(modeBuf);
}
- if(!add && !isModeSet(chan->modes, modeStr[i])) continue;
+ if(!add && !isModeSet(chan->modes, modeStr[i])) break;
modeBufferSet(modeBuf, add, modeStr[i], carg);
} else {
modeBufferSimpleMode(modeBuf, add, modeStr[i]);
}
getFullModeString(changemodes, tmp);
freeModeBuffer(modeBuf);
- reply(textclient, user, "NS_MODE_DONE", tmp);
+ if(strcmp(tmp, "+"))
+ reply(textclient, user, "NS_MODE_DONE", tmp);
+
logEvent(event);
freeModeNode(modelock);
freeModeNode(changemodes);