}
-int Chan_playerLeave(client_t *client)
+int Chan_userLeave(client_t *client)
{
channel_t *leaving = NULL;
int leaving_id = -1;
return leaving_id;
}
-int Chan_playerJoin(channel_t *ch, client_t *client)
+int Chan_userJoin(channel_t *ch, client_t *client)
{
int leaving_id;
- Log_debug("Add player %s to channel %s", client->playerName, ch->name);
+ Log_debug("Add user %s to channel %s", client->username, ch->name);
/* Only allowed in one channel at a time */
- leaving_id = Chan_playerLeave(client);
+ leaving_id = Chan_userLeave(client);
list_add_tail(&client->chan_node, &ch->clients);
client->channel = (void *)ch;
return leaving_id;
}
-int Chan_playerJoin_id(int channelid, client_t *client)
+int Chan_userJoin_id(int channelid, client_t *client)
{
channel_t *ch_itr = NULL;
do {
return -1;
}
else
- return Chan_playerJoin(ch_itr, client);
+ return Chan_userJoin(ch_itr, client);
}
-bool_t Chan_playerJoin_id_test(int channelid)
+bool_t Chan_userJoin_id_test(int channelid)
{
channel_t *ch_itr = NULL;
do {
void Chan_removeChannel(channel_t *c);
void Chan_addClient(channel_t *c, client_t *client);
void Chan_removeClient(channel_t *c, client_t *client);
-int Chan_playerJoin(channel_t *ch, client_t *client);
-int Chan_playerJoin_id(int channelid, client_t *client);
-int Chan_playerLeave(client_t *client);
-bool_t Chan_playerJoin_id_test(int channelid);
+int Chan_userJoin(channel_t *ch, client_t *client);
+int Chan_userJoin_id(int channelid, client_t *client);
+int Chan_userLeave(client_t *client);
+bool_t Chan_userJoin_id_test(int channelid);
channel_t *Chan_iterate(channel_t **channelpptr);
channel_t *Chan_iterate_siblings(channel_t *parent, channel_t **channelpptr);
channel_t *Chan_createChannel(const char *name, const char *desc);
list_iterate(itr, &clients) {
client_t *c;
c = list_get_entry(itr, client_t, node);
- Log_debug("Client %s BW available %d", c->playerName, c->availableBandwidth);
+ Log_debug("Client %s BW available %d", c->username, c->availableBandwidth);
c->availableBandwidth += maxBandwidth;
if (c->availableBandwidth > bwTop)
c->availableBandwidth = bwTop;
if (client->authenticated) {
int leave_id;
- leave_id = Chan_playerLeave(client);
+ leave_id = Chan_userLeave(client);
if (leave_id > 0) { /* Remove temp channel */
sendmsg = Msg_create(ChannelRemove);
sendmsg->payload.channelRemove->channel_id = leave_id;
free(client->release);
if (client->os)
free(client->os);
- if (client->playerName)
- free(client->playerName);
+ if (client->username)
+ free(client->username);
if (client->context)
free(client->context);
free(client);
if (itr != client) {
if (count++ > 0)
Msg_inc_ref(msg); /* One extra reference for each new copy */
- Log_debug("Msg %d to %s refcount %d", msg->messageType, itr->playerName, msg->refcount);
+ Log_debug("Msg %d to %s refcount %d", msg->messageType, itr->username, msg->refcount);
Client_send_message(itr, msg);
}
}
uint32_t rxcount, msgsize, drainleft, txcount, txsize;
int sessionId;
uint64_t key;
- char *playerName;
+ char *username;
bool_t authenticated, deaf, mute;
char *os, *release;
uint32_t version;
va_end(argp);
offset += snprintf(&buf[offset], STRSIZE - offset, " - [%d] %s@%s:%d",
client->sessionId,
- client->playerName == NULL ? "" : client->playerName,
+ client->username == NULL ? "" : client->username,
inet_ntoa(client->remote_tcp.sin_addr),
ntohs(client->remote_tcp.sin_port));
strcat(buf, "\n");
}
switch (msg->messageType) {
case Authenticate:
- /*
- * 1. Check stuff, Serverreject if not ok
- * 2. Setup UDP encryption -> MessageCryptSetup
- * 3. (Enter channel)
- * 4. MessageChannelAdd + MessageChannelDescUpdate for all channels
- * 5. (MessageChannelLink)
- * 6. MessageServerJoin
- * 7. MessagePlayerMove
- * 8. MessageServerJoin for all connected users
- * 9. PlayerDeaf/PlayerMute/PlayerSelfMuteDeaf for all users it applies to
- * 10. MessageServerSync
- */
Log_debug("Authenticate message received");
Log_debug("Username: %s", msg->payload.authenticate->username);
while (Client_iterate(&client_itr) != NULL) {
if (!IS_AUTH(client_itr))
continue;
- if (client_itr->playerName && strncmp(client_itr->playerName, msg->payload.authenticate->username, MAX_TEXT) == 0) {
+ if (client_itr->username && strncmp(client_itr->username, msg->payload.authenticate->username, MAX_TEXT) == 0) {
char buf[64];
sprintf(buf, "Username already in use");
Log_debug("Username already in use");
}
/* Name & password */
- client->playerName = strdup(msg->payload.authenticate->username);
+ client->username = strdup(msg->payload.authenticate->username);
/* Setup UDP encryption */
CryptState_init(&client->cryptState);
Client_send_message(client, sendmsg);
/* Channel stuff */
- Chan_playerJoin(defaultChan, client); /* Join default channel */
+ Chan_userJoin(defaultChan, client); /* Join default channel */
/* Codec version */
if (msg->payload.authenticate->n_celt_versions > MAX_CODECS)
sendmsg->payload.userState->session = client->sessionId;
sendmsg->payload.userState->has_user_id = true;
sendmsg->payload.userState->user_id = client->sessionId;
- sendmsg->payload.userState->name = strdup(client->playerName);
+ 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 = Msg_create(UserState);
sendmsg->payload.userState->has_session = true;
sendmsg->payload.userState->session = client_itr->sessionId;
- sendmsg->payload.userState->name = strdup(client_itr->playerName);
+ 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.serverSync->allow_html = true; /* Support this? */
Client_send_message(client, sendmsg);
- Log_info_client(client, "User %s authenticated", client->playerName);
+ Log_info_client(client, "User %s authenticated", client->username);
break;
case Ping:
}
if (msg->payload.userState->has_channel_id) {
int leave_id;
- if (!Chan_playerJoin_id_test(msg->payload.userState->channel_id))
+ if (!Chan_userJoin_id_test(msg->payload.userState->channel_id))
break;
- leave_id = Chan_playerJoin_id(msg->payload.userState->channel_id, client);
+ leave_id = Chan_userJoin_id(msg->payload.userState->channel_id, client);
if (leave_id > 0) {
Log_debug("Removing channel ID %d", leave_id);
sendmsg = Msg_create(ChannelRemove);
sendmsg->payload.userState->channel_id = newchan->id;
Client_send_message_except(NULL, sendmsg);
- leave_id = Chan_playerJoin(newchan, client);
+ leave_id = Chan_userJoin(newchan, client);
if (leave_id > 0) {
Log_debug("Removing channel ID %d", leave_id);
sendmsg = Msg_create(ChannelRemove);