X-Git-Url: http://git.code-monkey.de/?a=blobdiff_plain;f=src%2Fmessagehandler.c;h=882409ae75e8d25503bec0c98c3a179d2af268e4;hb=HEAD;hp=c5233f9647a31fd158f049591b664dc2358d0ef1;hpb=0b2541420086a2e924ba5f192f36c137b958993c;p=umurmur.git diff --git a/src/messagehandler.c b/src/messagehandler.c index c5233f9..882409a 100644 --- a/src/messagehandler.c +++ b/src/messagehandler.c @@ -306,7 +306,7 @@ void Mh_handle_message(client_t *client, message_t *msg) sendmsg->payload.userState->session = client->sessionId; sendmsg->payload.userState->name = strdup(client->username); sendmsg->payload.userState->has_channel_id = true; - sendmsg->payload.userState->channel_id = ((channel_t *)client->channel)->id; + sendmsg->payload.userState->channel_id = client->channel->id; if (defaultChan->silent) { sendmsg->payload.userState->has_suppress = true; @@ -324,11 +324,11 @@ void Mh_handle_message(client_t *client, message_t *msg) sendmsg->payload.userState->session = client_itr->sessionId; sendmsg->payload.userState->name = strdup(client_itr->username); sendmsg->payload.userState->has_channel_id = true; - sendmsg->payload.userState->channel_id = ((channel_t *)client_itr->channel)->id; - sendmsg->payload.userState->has_suppress = ((channel_t *)client_itr->channel)->silent; - sendmsg->payload.userState->suppress = ((channel_t *)client_itr->channel)->silent; + sendmsg->payload.userState->channel_id = client_itr->channel->id; + sendmsg->payload.userState->has_suppress = client_itr->channel->silent; + sendmsg->payload.userState->suppress = client_itr->channel->silent; - client_itr->isSuppressed = ((channel_t *)client_itr->channel)->silent; + client_itr->isSuppressed = client_itr->channel->silent; if (client_itr->self_deaf) { sendmsg->payload.userState->has_self_deaf = true; @@ -438,10 +438,8 @@ void Mh_handle_message(client_t *client, message_t *msg) break; } if (msg->payload.userState->has_session && msg->payload.userState->session != client->sessionId) { - while (Client_iterate(&target) != NULL) { - if (target->sessionId == msg->payload.userState->session) - break; - } + target = Client_find_by_session(msg->payload.userState->session); + if (target == NULL) { Log_warn("Client with sessionID %d not found", msg->payload.userState->session); break; @@ -609,21 +607,15 @@ void Mh_handle_message(client_t *client, message_t *msg) int i; client_t *itr; for (i = 0; i < msg->payload.textMessage->n_session; i++) { - itr = NULL; - while (Client_iterate(&itr) != NULL) { - if (!IS_AUTH(itr)) - continue; - if (itr->sessionId == msg->payload.textMessage->session[i]) { - if (!itr->deaf && !itr->self_deaf) { - Msg_inc_ref(msg); - Client_send_message(itr, msg); - Log_debug("Text message to session ID %d", itr->sessionId); - } - break; - } - } + itr = Client_find_by_session(msg->payload.textMessage->session[i]); + if (itr == NULL) Log_warn("TextMessage: Session ID %d not found", msg->payload.textMessage->session[i]); + else if (IS_AUTH(itr) && !itr->deaf && !itr->self_deaf) { + Msg_inc_ref(msg); + Client_send_message(itr, msg); + Log_debug("Text message to session ID %d", itr->sessionId); + } } /* for */ } break; @@ -798,15 +790,15 @@ void Mh_handle_message(client_t *client, message_t *msg) if (!msg->payload.userStats->has_session) sendPermissionDenied(client, "Not supported by uMurmur"); - while (Client_iterate(&target) != NULL) { - if (!IS_AUTH(target)) - continue; - if (target->sessionId == msg->payload.userStats->session) - break; - } + + target = Client_find_by_session(msg->payload.userStats->session); + if (!target) /* Not found */ break; + if (!IS_AUTH(target)) /* Not authenticated. */ + break; + /* * Differences from Murmur: * o Ignoring certificates intentionally @@ -905,10 +897,9 @@ void Mh_handle_message(client_t *client, message_t *msg) sendPermissionDenied(client, "Permission denied"); break; } - while (Client_iterate(&target) != NULL) { - if (target->sessionId == msg->payload.userRemove->session) - break; - } + + target = Client_find_by_session(msg->payload.userRemove->session); + if (target == NULL) { Log_warn("Client with sessionId %d not found", msg->payload.userRemove->session); break;