-/* WHOHandler.c - NeonServ v5.1
+/* WHOHandler.c - NeonServ v5.2
* Copyright (C) 2011 Philipp Kreil (pk910)
*
* This program is free software: you can redistribute it and/or modify
#define WHOQUEUETYPE_CHECKTYPE 0x07
#define WHOQUEUETYPE_FOUND 0x08
+#define MAXCALLBACKS 3
+
struct WHOQueueEntry {
char type;
struct ClientSocket *client;
struct ChanNode *chan;
struct UserNode *user;
struct WHOQueueEntry *next;
- void *callback;
- void *data;
+ void *callback[MAXCALLBACKS];
+ void *data[MAXCALLBACKS];
};
static struct WHOQueueEntry *first_entry = NULL, *last_entry = NULL;
struct WHOQueueEntry* entry = addWHOQueueEntry(bot);
entry->type = WHOQUEUETYPE_ISONQUEUE | WHOQUEUETYPE_USERLIST;
entry->chan = chan;
- entry->callback = callback;
- entry->data = data;
+ entry->callback[0] = callback;
+ int i;
+ for(i = 1; i < MAXCALLBACKS; i++)
+ entry->callback[i] = NULL;
+ entry->data[0] = data;
+ for(i = 1; i < MAXCALLBACKS; i++)
+ entry->data[i] = NULL;
putsock(bot, "WHO %s,%d %%tuhnaf,%d", chan->name, entry->type, entry->type);
} else
callback(bot, chan, data);
struct WHOQueueEntry* entry = addWHOQueueEntry(bot);
entry->type = WHOQUEUETYPE_ISONQUEUE | WHOQUEUETYPE_USERLIST;
entry->chan = chan;
- entry->callback = callback;
- entry->data = data;
+ entry->callback[0] = callback;
+ int i;
+ for(i = 1; i < MAXCALLBACKS; i++)
+ entry->callback[i] = NULL;
+ entry->data[0] = data;
+ for(i = 1; i < MAXCALLBACKS; i++)
+ entry->data[i] = NULL;
putsock(bot, "WHO %s,%d d%%tuhnaf,%d", chan->name, entry->type, entry->type);
} else
callback(bot, chan, data);
}
void get_userauth(struct UserNode *user, userauth_callback_t callback, void *data) {
+ //check if we have already an active WHO for this user
+ struct WHOQueueEntry *entry;
+ for(entry = first_entry; entry; entry = entry->next) {
+ if((entry->type & WHOQUEUETYPE_USERAUTH) && entry->user == user) {
+ int i = 0;
+ for(i = 1; i < MAXCALLBACKS; i++) {
+ if(!entry->callback[i]) {
+ entry->callback[i] = callback;
+ entry->data[i] = data;
+ return;
+ }
+ }
+ }
+ }
struct ClientSocket *bot;
for(bot = getBots(SOCKET_FLAG_READY, NULL); bot; bot = getBots(SOCKET_FLAG_READY, bot)) {
if(bot->flags & SOCKET_FLAG_PREFERRED)
callback(bot, user->nick, user, data);
return;
}
- struct WHOQueueEntry* entry = addWHOQueueEntry(bot);
+ entry = addWHOQueueEntry(bot);
entry->type = WHOQUEUETYPE_ISONQUEUE | WHOQUEUETYPE_USERAUTH;
entry->user = user;
- entry->callback = callback;
- entry->data = data;
+ entry->callback[0] = callback;
+ int i;
+ for(i = 1; i < MAXCALLBACKS; i++)
+ entry->callback[i] = NULL;
+ entry->data[0] = data;
+ for(i = 1; i < MAXCALLBACKS; i++)
+ entry->data[i] = NULL;
//WHO ".$user->getNick().",".$id." %tuhna,".$id
putsock(bot, "WHO %s,%d %%tuhna,%d", user->nick, entry->type, entry->type);
}
strcpy(entry->user->auth, argv[5]);
entry->user->flags |= USERFLAG_ISAUTHED;
}
- userauth_callback_t *callback = entry->callback;
- callback(client, entry->user->nick, entry->user, entry->data);
+ for(i = 0; i < MAXCALLBACKS; i++) {
+ userauth_callback_t *callback = entry->callback[i];
+ if(!callback) break;
+ callback(client, entry->user->nick, entry->user, entry->data[i]);
+ }
}
}
void recv_whohandler_315(struct ClientSocket *client, char **argv, unsigned int argc) {
if(argc < 2) return;
- char *typestr = strstr(argv[1], ",") + 1;
+ char *typestr = strstr(argv[1], ",");
if(!typestr) return;
+ typestr++;
int type = atoi(typestr);
if(!(type & WHOQUEUETYPE_ISONQUEUE)) return;
struct WHOQueueEntry* entry = getNextWHOQueueEntry(client, 1);
if(type & WHOQUEUETYPE_USERLIST) {
//:OGN2.OnlineGamesNet.net 315 skynet #pk910,1 :End of /WHO list.
entry->chan->flags |= CHANFLAG_RECEIVED_USERLIST;
- userlist_callback_t *callback = entry->callback;
- callback(client, entry->chan, entry->data);
+ userlist_callback_t *callback;
+ int i;
+ for(i = 0; i < MAXCALLBACKS; i++) {
+ callback = entry->callback[i];
+ if(!callback) break;
+ callback(client, entry->chan, entry->data[i]);
+ }
if(entry->chan->flags & CHANFLAG_HAVE_INVISIBLES) {
//remove all invisible users again
struct ChanUser *chanuser, *next;
}
} else if(type & WHOQUEUETYPE_USERAUTH) {
if(!(entry->type & WHOQUEUETYPE_FOUND)) {
- userauth_callback_t *callback = entry->callback;
- callback(client, entry->user->nick, NULL, entry->data);
+ userauth_callback_t *callback;
+ int i;
+ for(i = 0; i < MAXCALLBACKS; i++) {
+ callback = entry->callback[i];
+ if(!callback) break;
+ callback(client, entry->user->nick, NULL, entry->data[i]);
+ }
}
}
free(entry);