Add option 'noenter' to channel configuration and implement support.
authorfatbob313 <martin@fatbob.nu>
Sun, 24 Jan 2010 16:15:28 +0000 (16:15 +0000)
committerfatbob313 <martin@fatbob.nu>
Sun, 24 Jan 2010 16:15:28 +0000 (16:15 +0000)
Fix a couple of error cases regarding temp channel creation/deletion.

src/channel.c
src/channel.h
src/conf.c
src/conf.h
src/messagehandler.c

index 942c34847debc64c6589c31aa311ca0e08b2de98..d55653b50b9c1300b9dff9e299c0768bdc6186a0 100644 (file)
@@ -149,6 +149,7 @@ void Chan_init()
                }
                if (i == 0) {
                        rootChan = createChannel(0, chdesc.name, chdesc.description);
+                       rootChan->noenter = chdesc.noenter;
                        list_add_tail(&rootChan->flatlist_node, &channels);
                        if (strcmp(defaultChannelName, chdesc.name) == 0)
                                defaultChan = rootChan;
@@ -156,6 +157,7 @@ void Chan_init()
                else {
                        channel_t *ch, *ch_itr = NULL;
                        ch = Chan_createChannel(chdesc.name, chdesc.description);
+                       ch->noenter = chdesc.noenter;
                        
                        if (strcmp(defaultChannelName, chdesc.name) == 0) {
                                Log_info("Setting default channel %s", ch->name); 
@@ -176,6 +178,9 @@ void Chan_init()
        }
        if (defaultChan == NULL)
                defaultChan = rootChan;
+       
+       if (defaultChan->noenter)
+               Log_fatal("Error in channel configuration: default channel is marked as noenter");
 
        /* Channel links */
        for (i = 0; ; i++) {
@@ -276,6 +281,22 @@ int Chan_playerJoin_id(int channelid, client_t *client)
                return Chan_playerJoin(ch_itr, client); 
 }
 
+bool_t Chan_playerJoin_id_test(int channelid)
+{
+       channel_t *ch_itr = NULL;
+       do {
+               Chan_iterate(&ch_itr);
+       } while (ch_itr != NULL && ch_itr->id != channelid);
+       if (ch_itr == NULL) {
+               Log_warn("Channel id %d not found - ignoring.", channelid);
+               return false;
+       }
+       if (ch_itr->noenter)
+               return false;
+       else
+               return true;
+}
+
 #if 0
 void Chan_addChannel_id(int parentId, channel_t *ch)
 {
index a7f31d55f90ea75842c00e179c2b77f4a8032082..aeb21dc7dfb762c59bdee82f47a0448d1a431923 100644 (file)
@@ -40,7 +40,7 @@ typedef struct channel {
        char name[MAX_TEXT];
        char desc[MAX_TEXT];
        struct channel *parent;
-       bool_t temporary;
+       bool_t temporary, noenter;
        struct dlist node;
        struct dlist subs;
        struct dlist clients;
@@ -57,6 +57,7 @@ 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);
+bool_t Chan_playerJoin_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);
index ae91b6e18076cff50dcb67e6d2de086e734b6e7a..a9d2c08e88d030429e637d5ae82c408260da2439 100644 (file)
@@ -195,20 +195,28 @@ int Conf_getNextChannel(conf_channel_t *chdesc, int index)
        sprintf(configstr, "channels.[%d].name", index);
        setting = config_lookup(&configuration, configstr);
        if (setting == NULL)
-               return -1;
+               return -1; /* Required */
        strncpy(chdesc->name, config_setting_get_string(setting), MAX_TEXT);
        
        sprintf(configstr, "channels.[%d].parent", index);
        setting = config_lookup(&configuration, configstr);
        if (setting == NULL)
-               return -1;
+               return -1; /* Required */
        strncpy(chdesc->parent, config_setting_get_string(setting), MAX_TEXT);
        
        sprintf(configstr, "channels.[%d].description", index);
        setting = config_lookup(&configuration, configstr);
-       if (setting == NULL)
-               return -1;
-       strncpy(chdesc->description, config_setting_get_string(setting), MAX_TEXT);
+       if (setting == NULL) /* Optional */
+               strncpy(chdesc->description, "", MAX_TEXT);
+       else
+               strncpy(chdesc->description, config_setting_get_string(setting), MAX_TEXT);
+       
+       sprintf(configstr, "channels.[%d].noenter", index);
+       setting = config_lookup(&configuration, configstr);
+       if (setting == NULL) /* Optional */
+               chdesc->noenter = false;
+       else
+               chdesc->noenter = config_setting_get_bool(setting);
 
        return 0;
 }
index c0a0825c47702c0e4bd68c5f3c08cd610f6346a2..04beaa3ba55428d44b4de29bba472e73bd758981 100644 (file)
@@ -49,6 +49,7 @@ typedef struct {
        char parent[MAX_TEXT];
        char name[MAX_TEXT];
        char description[MAX_TEXT];
+       bool_t noenter;
 } conf_channel_t;
 
 typedef struct {
index ebd602f357a8407826b3e0239f4e6f9b9c65f546..c69f65ed20ae90a6411034192aadd5bf4344736e 100644 (file)
@@ -326,9 +326,10 @@ void Mh_handle_message(client_t *client, message_t *msg)
                }
                if (msg->payload.userState->has_channel_id) {
                        int leave_id;
+                       if (!Chan_playerJoin_id_test(msg->payload.userState->channel_id))
+                               break;
                        leave_id = Chan_playerJoin_id(msg->payload.userState->channel_id, client);
                        if (leave_id > 0) {
-                               /* XXX - need to send update to remove channel if temporary */
                                Log_debug("Removing channel ID %d", leave_id);
                                sendmsg = Msg_create(ChannelRemove);
                                sendmsg->payload.channelRemove->channel_id = leave_id;
@@ -354,6 +355,7 @@ void Mh_handle_message(client_t *client, message_t *msg)
                if (sendmsg != NULL)
                        Client_send_message_except(NULL, sendmsg);
                break;
+               
        case TextMessage:
                msg->payload.textMessage->has_actor = true;
                msg->payload.textMessage->actor = client->sessionId;
@@ -464,7 +466,7 @@ void Mh_handle_message(client_t *client, message_t *msg)
        case ChannelState:
        {
                channel_t *ch_itr, *parent, *newchan;
-               
+               int leave_id;           
                /* Don't allow any changes to existing channels */
                if (msg->payload.channelState->has_channel_id) {
                        sendPermissionDenied(client, "Not supported by uMurmur");
@@ -501,6 +503,15 @@ void Mh_handle_message(client_t *client, message_t *msg)
                                break;
                        }
                }
+               if (ch_itr != NULL)
+                       break;
+               
+               /* Disallow temporary channels as siblings to temporary channels */
+               if (parent->temporary) {
+                       sendPermissionDenied(client, "Parent channel is temporary channel");
+                       break;
+               }
+                       
                /* XXX - Murmur looks for "\\w" and sends perm denied if not found.
                 * I don't know why so I don't do that here...
                 */
@@ -522,7 +533,14 @@ void Mh_handle_message(client_t *client, message_t *msg)
                sendmsg->payload.userState->has_channel_id = true;
                sendmsg->payload.userState->channel_id = newchan->id;
                Client_send_message_except(NULL, sendmsg);
-               Chan_playerJoin(newchan, client);
+               
+               leave_id = Chan_playerJoin(newchan, client);
+               if (leave_id > 0) {
+                       Log_debug("Removing channel ID %d", leave_id);
+                       sendmsg = Msg_create(ChannelRemove);
+                       sendmsg->payload.channelRemove->channel_id = leave_id;
+                       Client_send_message_except(NULL, sendmsg);
+               }
        }               
        break;