X-Git-Url: http://git.code-monkey.de/?a=blobdiff_plain;f=src%2Fmessagehandler.c;h=2dea8588d6cca8defbf5d0c40e15eaaef0d5a7fc;hb=772cee17b53bb6795a5e98f1ae2acb7e7d6c25c1;hp=0b7c2328db534da0c83ee69fe1b025ad2303a4d4;hpb=1f6407aa1a69c734dfeb202a967609c99403f947;p=umurmur.git diff --git a/src/messagehandler.c b/src/messagehandler.c index 0b7c232..2dea858 100644 --- a/src/messagehandler.c +++ b/src/messagehandler.c @@ -1,5 +1,5 @@ -/* Copyright (C) 2009-2011, Martin Johansson - Copyright (C) 2005-2011, Thorvald Natvig +/* Copyright (C) 2009-2012, Martin Johansson + Copyright (C) 2005-2012, Thorvald Natvig All rights reserved. @@ -40,6 +40,7 @@ #include "channel.h" #include "conf.h" #include "voicetarget.h" +#include "ban.h" #define MAX_TEXT 512 #define MAX_USERNAME 128 @@ -127,9 +128,12 @@ void Mh_handle_message(client_t *client, message_t *msg) break; } - SSLi_getSHA1Hash(client->ssl, client->hash); - if (Ban_isBanned(client)) + if (SSLi_getSHA1Hash(client->ssl, client->hash) && Ban_isBanned(client)) { + char hexhash[41]; + SSLi_hash2hex(client->hash, hexhash); + Log_info("Client with hash '%s' is banned. Disconnecting", hexhash); goto disconnect; + } client->authenticated = true; @@ -184,7 +188,7 @@ void Mh_handle_message(client_t *client, message_t *msg) if (strlen(getStrConf(ADMIN_PASSPHRASE)) > 0 && Client_token_match(client, getStrConf(ADMIN_PASSPHRASE))) { client->isAdmin = true; - Log_info("User is admin"); + Log_info_client(client, "User provided admin password"); } /* Setup UDP encryption */ @@ -294,15 +298,22 @@ void Mh_handle_message(client_t *client, message_t *msg) sendmsg->payload.userState->has_channel_id = true; sendmsg->payload.userState->channel_id = ((channel_t *)client_itr->channel)->id; - /* Only self_mute/deaf supported */ - if (client_itr->deaf) { + if (client_itr->self_deaf) { sendmsg->payload.userState->has_self_deaf = true; sendmsg->payload.userState->self_deaf = true; } - if (client_itr->mute) { + if (client_itr->self_mute) { sendmsg->payload.userState->has_self_mute = true; sendmsg->payload.userState->self_mute = true; } + if (client_itr->deaf) { + sendmsg->payload.userState->has_deaf = true; + sendmsg->payload.userState->deaf = true; + } + if (client_itr->mute) { + sendmsg->payload.userState->has_mute = true; + sendmsg->payload.userState->mute = true; + } if (client_itr->recording) { sendmsg->payload.userState->has_recording = true; sendmsg->payload.userState->recording = true; @@ -406,7 +417,7 @@ void Mh_handle_message(client_t *client, message_t *msg) } if (msg->payload.userState->has_user_id || msg->payload.userState->has_suppress || - msg->payload.userState->has_texture) { + msg->payload.userState->has_priority_speaker || msg->payload.userState->has_texture) { sendPermissionDenied(client, "Not supported by uMurmur"); break; } @@ -421,24 +432,32 @@ void Mh_handle_message(client_t *client, message_t *msg) if (msg->payload.userState->has_deaf) { target->deaf = msg->payload.userState->deaf; + if (target->deaf) { + msg->payload.userState->has_mute = true; + msg->payload.userState->mute = true; + } } if (msg->payload.userState->has_mute) { target->mute = msg->payload.userState->mute; if (!target->mute) { msg->payload.userState->has_deaf = true; msg->payload.userState->deaf = false; - client->deaf = false; + target->deaf = false; } } if (msg->payload.userState->has_self_deaf) { - client->deaf = msg->payload.userState->self_deaf; + client->self_deaf = msg->payload.userState->self_deaf; + if (client->self_deaf) { + msg->payload.userState->has_self_mute = true; + msg->payload.userState->self_mute = true; + } } if (msg->payload.userState->has_self_mute) { - client->mute = msg->payload.userState->self_mute; - if (!client->mute) { + client->self_mute = msg->payload.userState->self_mute; + if (!client->self_mute) { msg->payload.userState->has_self_deaf = true; msg->payload.userState->self_deaf = false; - client->deaf = false; + client->self_deaf = false; } } if (msg->payload.userState->has_recording && @@ -467,16 +486,25 @@ void Mh_handle_message(client_t *client, message_t *msg) } if (msg->payload.userState->has_channel_id) { int leave_id; - channelJoinResult_t chjoin_rc = Chan_userJoin_id_test(msg->payload.userState->channel_id, client); + channelJoinResult_t chjoin_rc = Chan_userJoin_id_test(msg->payload.userState->channel_id, target); if (chjoin_rc != CHJOIN_OK) { if (chjoin_rc == CHJOIN_WRONGPW) { - sendPermissionDenied(client, "Wrong channel password"); + if (target == client && !client->isAdmin) { + sendPermissionDenied(client, "Wrong channel password"); + break; + } + /* Tricky one: if user hasn't the password, but is moved to the channel by admin then let + * the user in. Also let admin user in regardless of channel password. + * Take no action on other errors. + */ + else if (!client->isAdmin) + break; } - break; + else break; } - leave_id = Chan_userJoin_id(msg->payload.userState->channel_id, client); + leave_id = Chan_userJoin_id(msg->payload.userState->channel_id, target); if (leave_id > 0) { Log_debug("Removing channel ID %d", leave_id); sendmsg = Msg_create(ChannelRemove); @@ -505,6 +533,8 @@ void Mh_handle_message(client_t *client, message_t *msg) break; case TextMessage: + if (!getBoolConf(ALLOW_TEXTMESSAGE)) + break; msg->payload.textMessage->has_actor = true; msg->payload.textMessage->actor = client->sessionId; @@ -527,7 +557,7 @@ void Mh_handle_message(client_t *client, message_t *msg) list_iterate(itr, &ch_itr->clients) { client_t *c; c = list_get_entry(itr, client_t, chan_node); - if (c != client && !c->deaf) { + if (c != client && !c->deaf && !c->self_deaf) { Msg_inc_ref(msg); Client_send_message(c, msg); Log_debug("Text message to session ID %d", c->sessionId); @@ -545,7 +575,7 @@ void Mh_handle_message(client_t *client, message_t *msg) if (!IS_AUTH(itr)) continue; if (itr->sessionId == msg->payload.textMessage->session[i]) { - if (!itr->deaf) { + 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); @@ -610,11 +640,17 @@ void Mh_handle_message(client_t *client, message_t *msg) case PermissionQuery: Msg_inc_ref(msg); /* Re-use message */ msg->payload.permissionQuery->has_permissions = true; + if (client->isAdmin) msg->payload.permissionQuery->permissions = PERM_ADMIN; else msg->payload.permissionQuery->permissions = PERM_DEFAULT; + if (!getBoolConf(ALLOW_TEXTMESSAGE)) + msg->payload.permissionQuery->permissions &= ~PERM_TEXTMESSAGE; + if (!getBoolConf(ENABLE_BAN)) + msg->payload.permissionQuery->permissions &= ~PERM_BAN; + Client_send_message(client, msg); break; case UDPTunnel: @@ -787,6 +823,7 @@ void Mh_handle_message(client_t *client, message_t *msg) memset(sendmsg->payload.userStats->address.data, 0, 16); /* ipv4 representation as ipv6 address. Supposedly correct. */ memcpy(&sendmsg->payload.userStats->address.data[12], &target->remote_tcp.sin_addr, 4); + memset(&sendmsg->payload.userStats->address.data[10], 0xff, 2); /* IPv4 */ sendmsg->payload.userStats->address.len = 16; } /* BW */ @@ -822,9 +859,13 @@ void Mh_handle_message(client_t *client, message_t *msg) msg->payload.userRemove->actor = client->sessionId; if (msg->payload.userRemove->has_ban && msg->payload.userRemove->ban) { - Ban_UserBan(target, msg->payload.userRemove->reason); + if (!getBoolConf(ENABLE_BAN)) + sendPermissionDenied(client, "Permission denied"); + else + Ban_UserBan(target, msg->payload.userRemove->reason); } else { - Log_info("User kicked"); + Log_info_client(target, "User kicked. Reason: '%s'", + strlen(msg->payload.userRemove->reason) == 0 ? "N/A" : msg->payload.userRemove->reason); } /* Re-use message */ Msg_inc_ref(msg); @@ -832,13 +873,32 @@ void Mh_handle_message(client_t *client, message_t *msg) Client_send_message_except(NULL, msg); Client_close(target); break; + case BanList: + /* Only admin can issue this */ + if (!client->isAdmin) { + sendPermissionDenied(client, "Permission denied"); + break; + } + if (!getBoolConf(ENABLE_BAN)) { + sendPermissionDenied(client, "Permission denied"); + break; + } + if (msg->payload.banList->has_query && msg->payload.banList->query) { + /* Create banlist message and add banentrys */ + sendmsg = Ban_getBanList(); + Client_send_message(client, sendmsg); + } else { + /* Clear banlist and set the new one */ + Ban_clearBanList(); + Ban_putBanList(msg, msg->payload.banList->n_bans); + } + break; /* Permission denied for all these messages. Not implemented. */ case ChannelRemove: case ContextAction: case ContextActionAdd: case ACL: - case BanList: case UserList: case QueryUsers: sendPermissionDenied(client, "Not supported by uMurmur");