X-Git-Url: http://git.code-monkey.de/?a=blobdiff_plain;f=src%2Fmessagehandler.c;h=d0c24e98d3a91cd5ed904a762e6523636cb4bbed;hb=5e3eca4e7c1a3ece4f7a6f94bc4a5f7295cd39ac;hp=a962cac477fb7484facd041d0433df6c72f153ed;hpb=ac258369305673f3d17322b845ad58f2b9f64100;p=umurmur.git diff --git a/src/messagehandler.c b/src/messagehandler.c index a962cac..d0c24e9 100644 --- a/src/messagehandler.c +++ b/src/messagehandler.c @@ -40,6 +40,8 @@ #include "conf.h" extern channel_t *defaultChan; +extern int iCodecAlpha, iCodecBeta; +extern bool_t bPreferAlpha; static void sendServerReject(client_t *client, const char *reason, MumbleProto__Reject__RejectType type) { @@ -89,7 +91,7 @@ void Mh_handle_message(client_t *client, message_t *msg) while (Client_iterate(&client_itr) != NULL) { if (!IS_AUTH(client_itr)) continue; - if (strncmp(client_itr->playerName, msg->payload.authenticate->username, MAX_TEXT) == 0) { + if (client_itr->playerName && strncmp(client_itr->playerName, msg->payload.authenticate->username, MAX_TEXT) == 0) { char buf[64]; sprintf(buf, "Username already in use"); Log_debug("Username already in use"); @@ -121,11 +123,7 @@ void Mh_handle_message(client_t *client, message_t *msg) } /* Name & password */ - strncpy(client->playerName, msg->payload.authenticate->username, MAX_TEXT); - client->playerId = client->sessionId; - - - /* XXX - Kick ghost? */ + client->playerName = strdup(msg->payload.authenticate->username); /* Setup UDP encryption */ CryptState_init(&client->cryptState); @@ -145,6 +143,33 @@ void Mh_handle_message(client_t *client, message_t *msg) /* Channel stuff */ Chan_playerJoin(defaultChan, client); /* Join default channel */ + /* Codec version */ + if (msg->payload.authenticate->n_celt_versions > MAX_CODECS) + Log_warn("Client has more than %d CELT codecs. Ignoring %d codecs", + MAX_CODECS, msg->payload.authenticate->n_celt_versions - MAX_CODECS); + + Log_debug("Client %d has %d CELT codecs", client->sessionId, msg->payload.authenticate->n_celt_versions); + if (msg->payload.authenticate->n_celt_versions > 0) { + int i; + client->codec_count = msg->payload.authenticate->n_celt_versions > MAX_CODECS ? + MAX_CODECS : msg->payload.authenticate->n_celt_versions; + for (i = 0; i < client->codec_count; i++) { + client->codecs[i] = msg->payload.authenticate->celt_versions[i]; + Log_debug("Client %d CELT codec ver 0x%x", client->sessionId, client->codecs[i]); + } + } else { + client->codecs[0] = (int32_t)0x8000000a; + client->codec_count = 1; + } + + recheckCodecVersions(); + + sendmsg = Msg_create(CodecVersion); + sendmsg->payload.codecVersion->alpha = iCodecAlpha; + sendmsg->payload.codecVersion->beta = iCodecBeta; + sendmsg->payload.codecVersion->prefer_alpha = bPreferAlpha; + Client_send_message(client, sendmsg); + /* Iterate channels and send channel info */ ch_itr = NULL; Chan_iterate(&ch_itr); @@ -173,7 +198,7 @@ void Mh_handle_message(client_t *client, message_t *msg) sendmsg->payload.userState->has_session = true; sendmsg->payload.userState->session = client->sessionId; sendmsg->payload.userState->has_user_id = true; - sendmsg->payload.userState->user_id = client->playerId; + sendmsg->payload.userState->user_id = client->sessionId; sendmsg->payload.userState->name = strdup(client->playerName); sendmsg->payload.userState->has_channel_id = true; sendmsg->payload.userState->channel_id = ((channel_t *)client->channel)->id; @@ -186,17 +211,17 @@ void Mh_handle_message(client_t *client, message_t *msg) continue; sendmsg = Msg_create(UserState); sendmsg->payload.userState->has_session = true; - sendmsg->payload.userState->session = client->sessionId; - sendmsg->payload.userState->name = strdup(client->playerName); + sendmsg->payload.userState->session = client_itr->sessionId; + sendmsg->payload.userState->name = strdup(client_itr->playerName); sendmsg->payload.userState->has_channel_id = true; - sendmsg->payload.userState->channel_id = ((channel_t *)client->channel)->id; + sendmsg->payload.userState->channel_id = ((channel_t *)client_itr->channel)->id; /* XXX - check if self_* is correct */ - if (client->deaf) { + if (client_itr->deaf) { sendmsg->payload.userState->has_self_deaf = true; sendmsg->payload.userState->self_deaf = true; } - if (client->mute) { + if (client_itr->mute) { sendmsg->payload.userState->has_self_mute = true; sendmsg->payload.userState->self_mute = true; } @@ -211,15 +236,13 @@ void Mh_handle_message(client_t *client, message_t *msg) sendmsg->payload.serverSync->has_max_bandwidth = true; sendmsg->payload.serverSync->max_bandwidth = getIntConf(MAX_BANDWIDTH); sendmsg->payload.serverSync->has_allow_html = true; - sendmsg->payload.serverSync->allow_html = false; /* Support this? */ + sendmsg->payload.serverSync->allow_html = true; /* Support this? */ Client_send_message(client, sendmsg); Log_info("User %s authenticated", client->playerName); break; case Ping: - { - uint64_t timestamp; if (msg->payload.ping->has_good) client->cryptState.uiRemoteGood = msg->payload.ping->good; if (msg->payload.ping->has_late) @@ -237,10 +260,9 @@ void Mh_handle_message(client_t *client, message_t *msg) /* Ignoring the double values since they don't seem to be used */ sendmsg = Msg_create(Ping); - timestamp = msg->payload.ping->timestamp; - sendmsg->payload.ping->timestamp = timestamp; - + sendmsg->payload.ping->timestamp = msg->payload.ping->timestamp; + sendmsg->payload.ping->has_timestamp = true; sendmsg->payload.ping->good = client->cryptState.uiGood; sendmsg->payload.ping->has_good = true; sendmsg->payload.ping->late = client->cryptState.uiLate; @@ -256,13 +278,12 @@ void Mh_handle_message(client_t *client, message_t *msg) client->cryptState.uiLost, client->cryptState.uiResync); break; - } case CryptSetup: Log_debug("Voice channel crypt resync requested"); if (!msg->payload.cryptSetup->has_client_nonce) { sendmsg = Msg_create(CryptSetup); sendmsg->payload.cryptSetup->has_server_nonce = true; - memcpy(sendmsg->payload.cryptSetup->server_nonce.data, client->cryptState.decrypt_iv, AES_BLOCK_SIZE); + sendmsg->payload.cryptSetup->server_nonce.data = client->cryptState.decrypt_iv; sendmsg->payload.cryptSetup->server_nonce.len = AES_BLOCK_SIZE; Client_send_message(client, sendmsg); } else { @@ -301,65 +322,88 @@ void Mh_handle_message(client_t *client, message_t *msg) break; case TextMessage: -#if 0 - if (msg->payload.textMessage.bTree) + msg->payload.textMessage->has_actor = true; + msg->payload.textMessage->actor = client->sessionId; + + /* XXX - Allow HTML stuff? */ + + if (msg->payload.textMessage->n_tree_id > 0) { sendPermissionDenied(client, "Tree message not supported"); - else if (msg->payload.textMessage.channel != -1) { /* To channel */ - channel_t *ch_itr = NULL; - do { - Chan_iterate(&ch_itr); - } while (ch_itr != NULL && ch_itr->id != msg->payload.textMessage.channel); - if (ch_itr == NULL) - Log_warn("Channel id %d not found - ignoring.", msg->payload.textMessage.channel); - else { - struct dlist *itr; - list_iterate(itr, &ch_itr->clients) { - client_t *c; - c = list_get_entry(itr, client_t, chan_node); - if (c != client && !c->deaf) { - Msg_inc_ref(msg); - Client_send_message(c, msg); - Log_debug("Text message to player ID %d", c->playerId); + break; + } + + if (msg->payload.textMessage->n_channel_id > 0) { /* To channel */ + int i; + channel_t *ch_itr; + for (i = 0; i < msg->payload.textMessage->n_channel_id; i++) { + ch_itr = NULL; + do { + Chan_iterate(&ch_itr); + } while (ch_itr != NULL && ch_itr->id != msg->payload.textMessage->channel_id[i]); + if (ch_itr == NULL) + Log_warn("Channel id %d not found - ignoring.", msg->payload.textMessage->channel_id[i]); + else { + struct dlist *itr; + list_iterate(itr, &ch_itr->clients) { + client_t *c; + c = list_get_entry(itr, client_t, chan_node); + if (c != client && !c->deaf) { + Msg_inc_ref(msg); + Client_send_message(c, msg); + Log_debug("Text message to session ID %d", c->sessionId); + } } } - } - } else { /* To player */ - client_t *itr = NULL; - while (Client_iterate(&itr) != NULL) { - if (!IS_AUTH(itr)) - continue; - if (itr->playerId == msg->payload.textMessage.victim) { - if (!itr->deaf) { - Msg_inc_ref(msg); - Client_send_message(itr, msg); + } /* for */ + } + if (msg->payload.textMessage->n_session > 0) { /* To user */ + 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) { + Msg_inc_ref(msg); + Client_send_message(itr, msg); + Log_debug("Text message to session ID %d", itr->sessionId); + } + break; } - break; } - } - if (itr == NULL) - Log_warn("TextMessage: Player ID %d not found", msg->payload.textMessage.victim); + if (itr == NULL) + Log_warn("TextMessage: Session ID %d not found", msg->payload.textMessage->session[i]); + } /* for */ } break; -#endif case VoiceTarget: /* XXX -TODO */ break; case Version: - sendmsg = Msg_create(Version); /* Re-use message */ Log_debug("Version message received"); - sendmsg->payload.version->has_version = true; - sendmsg->payload.version->version = (1 << 16) | (2 << 8) | 0; /* XXX fix */ - sendmsg->payload.version->release = "Phony donkey"; - sendmsg->payload.version->os = "OpenWRT"; - - Client_send_message(client, sendmsg); + if (msg->payload.version->has_version) { + client->version = msg->payload.version->version; + Log_debug("Client version 0x%x", client->version); + } + if (msg->payload.version->release) { + if (client->release) free(client->release); + client->release = strdup(msg->payload.version->release); + Log_debug("Client release %s", client->release); + } + if (msg->payload.version->os) { + if (client->os) free(client->os); + client->os = strdup(msg->payload.version->os); + Log_debug("Client OS %s", client->os); + } break; - case CodecVersion: + case PermissionQuery: Msg_inc_ref(msg); /* Re-use message */ - - /* XXX - fill in version */ + msg->payload.permissionQuery->has_permissions = true; + msg->payload.permissionQuery->permissions = PERM_DEFAULT; Client_send_message(client, msg); break; @@ -386,3 +430,4 @@ disconnect: Msg_free(msg); Client_close(client); } +