execute mysql_check only if a query fails.
[NeonServV5.git] / cmd_neonserv_clvl.c
1
2 /*
3 * argv[0] - nick / *auth
4 * argv[1] - access
5 */
6 static USERAUTH_CALLBACK(neonserv_cmd_clvl_nick_lookup);
7 static void neonserv_cmd_clvl_async1(struct ClientSocket *client, struct ClientSocket *textclient, struct UserNode *user, struct ChanNode *chan, char *nick, char *auth, int caccess);
8
9 struct neonserv_cmd_clvl_cache {
10     struct ClientSocket *client, *textclient;
11     struct UserNode *user;
12     struct ChanNode *chan;
13     char *nick;
14     int access;
15 };
16
17 static CMD_BIND(neonserv_cmd_clvl) {
18     int caccess;
19     caccess = atoi(argv[1]);
20     if(caccess <= 0 || caccess > 500) {
21         reply(getTextBot(), user, "NS_INVALID_ACCESS", caccess);
22         return;
23     }
24     if(caccess >= getChannelAccess(user, chan, 1)) {
25         reply(getTextBot(), user, "NS_ACCESS_OUTRANKED");
26         return;
27     }
28     if(argv[0][0] == '*') {
29         //we've got an auth
30         argv[0]++;
31         neonserv_cmd_clvl_async1(client, getTextBot(), user, chan, argv[0], argv[0], caccess);
32     } else {
33         struct UserNode *cuser = getUserByNick(argv[0]);
34         if(!cuser) {
35             cuser = createTempUser(argv[0]);
36             cuser->flags |= USERFLAG_ISTMPUSER;
37         }
38         if(cuser->flags & USERFLAG_ISAUTHED) {
39             neonserv_cmd_clvl_async1(client, getTextBot(), user, chan, argv[0], cuser->auth, caccess);
40         } else {
41             struct neonserv_cmd_clvl_cache *cache = malloc(sizeof(*cache));
42             if (!cache) {
43                 perror("malloc() failed");
44                 return;
45             }
46             cache->client = client;
47             cache->textclient = getTextBot();
48             cache->user = user;
49             cache->chan = chan;
50             cache->nick = strdup(argv[0]);
51             cache->access = caccess;
52             get_userauth(cuser, neonserv_cmd_clvl_nick_lookup, cache);
53         }
54     }
55 }
56
57 static USERAUTH_CALLBACK(neonserv_cmd_clvl_nick_lookup) {
58     struct neonserv_cmd_clvl_cache *cache = data;
59     if(!user) {
60         //USER_DOES_NOT_EXIST
61         reply(cache->textclient, cache->user, "NS_USER_UNKNOWN", cache->nick);
62     }
63     else if(!(user->flags & USERFLAG_ISAUTHED)) {
64         //USER_NOT_AUTHED
65         reply(cache->textclient, cache->user, "NS_USER_NEED_AUTH", cache->nick);
66     }
67     else
68         neonserv_cmd_clvl_async1(cache->client, cache->textclient, cache->user, cache->chan, user->nick, user->auth, cache->access);
69     free(cache->nick);
70     free(cache);
71 }
72
73 static void neonserv_cmd_clvl_async1(struct ClientSocket *client, struct ClientSocket *textclient, struct UserNode *user, struct ChanNode *chan, char *nick, char *auth, int caccess) {
74     //we've got a valid auth now...
75     MYSQL_RES *res;
76     MYSQL_ROW row;
77     int userid;
78     printf_mysql_query("SELECT `user_id` FROM `users` WHERE `user_user` = '%s'", escape_string(auth));
79     res = mysql_use();
80     if ((row = mysql_fetch_row(res)) != NULL) {
81         userid = atoi(row[0]);
82         //check if the user is already added
83         printf_mysql_query("SELECT `chanuser_access`, `chanuser_id` FROM `chanusers` WHERE `chanuser_cid` = '%d' AND `chanuser_uid` = '%d'", chan->channel_id, userid);
84         res = mysql_use();
85         if ((row = mysql_fetch_row(res)) != NULL) {
86             //clvl
87             if(atoi(row[0]) >= getChannelAccess(user, chan, 1)) {
88                 reply(textclient, user, "NS_USER_OUTRANKED", nick);
89                 return;
90             }
91             printf_mysql_query("UPDATE `chanusers` SET `chanuser_access` = '%d' WHERE `chanuser_id` = '%s'", caccess, row[1]);
92             reply(textclient, user, "NS_CLVL_DONE", nick, caccess, chan->name);
93             return;
94         }
95     }
96     reply(textclient, user, "NS_NOT_ON_USERLIST", nick, chan->name);
97 }