// This file written completely by Tim Johnson (Tim@TimMUD) static void process_channel(int fd, mixed *info){ string mudname; debug("extra stuff is ["+info[0][8..]+"]"); switch(info[0][8..]){ // what is after the "channel-" case "m": // message case "e": // emote case "t": // targetted emote debug("they want to do a message..."); // (drop-through from m/e is intentional) // Probably should check if the target is 0@0 like it should be, // and give a warning if it's not... I don't carethough, I'll just // ignore the target and save some CPU. // Check if string parts are strings... if(info[0][8..]=="t"){ if(sizeof(info)!=12 || !stringp(info[9]) || !stringp(info[10]) || !stringp(info[11]) || !stringp(info[12])){ send_error(info[2],info[3],"bad-pkt","Bad packet format.",info); return; } } else{ // m, e if(sizeof(info)!=9){ send_error(info[2],info[3],"bad-pkt","Bad packet format.",info); return; } } if(info[4]!=0 || info[5]!=0 || !stringp(info[6]) || !stringp(info[7]) || !stringp(info[8])){ send_error(info[2],info[3],"bad-pkt","Bad packet format.",info); return; } if(!channels[info[6]]){ // error, channel is not registered! send_error(info[2],info[3],"unk-channel", "Unknown channel: "+info[6],info); return; } if(member_array(info[2],listening[info[6]])==-1){ // if mud is not listening, then make them listen // and let them know they weren't listening. send_error(info[2],info[3],"warning", // No applicable message codes... change // "warning" to something else if you want. "Your mud wasn't listening to "+info[6]+ ", so I'll start you listening right now.",info); // Could do all the listen stuff, or could just // pretend they requested it... I'm gonna pretend... process_channel(fd,({ "channel-listen", 5, info[2], 0, router_name, 0, info[6], 1 })); return; } if(channels[info[6]][0]==2){ // filtered channel if(channels[info[6]][1]!=info[2]){ // not from chan owner // if from anybody else other than the owner, // check if the owner is online, then either give // an error, or forward to the owner... if(!connected_muds[channels[info[6]][1]]){ send_error(info[2],info[3],"unk-dst", channels[info[6]][1]+" is not online to filter "+info[6], info); return; } if(info[4]!=0 || info[5]!=0 || !stringp(info[6]) || !stringp(info[7]) || !stringp(info[8])){ send_error(info[2],info[3],"bad-pkt","Bad packet format",info); return; } write_data(connected_muds[channels[info[6]][1]],({ "chan-filter-req", 5, router_name, 0, channels[info[6]][1], // mud name of chan owner 0, info[6], info })); return; } // IS from chan owner, just broadcast it... // drop through and broadcast like the other types do... } debug("CHAN: I think it's a good message at this point..."); // at this point, they're wanting to do a message on a // selective banned/allowed channel, or else are the owner // of a filtered channel and they have not been // blocked, so I will just do it... foreach(mudname in keys(connected_muds)){ if(member_array(mudname, listening[info[6]])!=-1) write_data(connected_muds[mudname],info); } //broadcast_data(muds_not_on_this_fd(fd), info); // send to all the other fd's that have a mud listening // write_data(fd,info); // also send the message to the connection that this mud is on // from too... why do this? 'cause I'm allowing multiple muds to // log on from the same connection :) // I think the normal I3 server does this too, but I don't know // since I can't test at the moment. return; case "add": // check if already exists... // check if a valid channel name (illegal characters?) // check if other stuff is valid, like channel_type is 0,1,2 // at this point, is being successfully added... channel_update_counter++; channels[info[6]]=({ info[7], info[2], ({}) }); channel_updates[info[6]] = channel_update_counter; debug(info[3]+"@"+info[2]+" created the channel: "+info[6]); // broadcast an update saying that this channel is added or changed now // chanlist-reply packet to everybody (who has a channel service?) broadcast_chanlist(info[6]); // broadcast_data(muds_not_on_this_fd(fd), ({ // "chanlist-reply",5,router_name,0, // 0, // should be mudname, I think 0 would work just as well? // 0, channel_update_counter, // ([ info[6]:({ info[2], info[7] }) ]) // })); // write_data(fd,({ // "chanlist-reply",5,router_name,0, // 0, // should be mudname, I think 0 would work just as well? // 0, channel_update_counter, // ([ info[6]:({ info[2], info[7] }) ]) // })); return; case "remove": if(!channels[info[6]]){ // error, channel is not registered! send_error(info[2],info[3],"unk-channel", "Unknown channel: "+info[6],info); return; } if(channels[info[6]][1]!=info[2]){ // error, not owner! send_error(info[2],info[3],"not-allowed","Channel "+ info[6]+" owned by: "+channels[info[6]][1],info); return; } // at this point, is being removed by the owner... channel_update_counter++; map_delete(channels,info[6]); channel_updates[info[6]] = channel_update_counter; debug(info[3]+"@"+info[2]+" deleted the channel: "+info[6]); // broadcast an update saying that this channel is gone now return; case "admin": // add/delete muds from the 2 lists... if(!listening[info[6]]) listening[info[6]] = ({}); if(info[7]){ // add to list... channels[info[6]][2] += info[7]; // if add to ban list, unlisten... if(channels[info[6]][0]==0) // type 0 means selective ban listening[info[6]] -= info[7]; } if(info[8]){ // remove from list... channels[info[6]][2] += info[8]; if(channels[info[6]][0]!=0) // type 0 means selective ban... // selective allow and filtered are the same though... // so if not selective ban, then act like selective allow... // if removed from allow list, unlisten... listening[info[6]] -= info[8]; } return; case "listen": // mudname=info[2], channame=info[6], on_or_off=info[7] if(!channels[info[6]]){ // error, channel is not registered! send_error(info[2],info[3],"unk-channel", "Unknown channel: "+info[6],info); return; } if(!listening) listening=([ ]); if(!listening[info[6]]) listening[info[6]]=({ }); // first MUD to listen if(info[7]){ // on_or_off is on if(member_array(info[2],listening[info[6]])!=-1) return; // already listening, ignore them } else{ // on_or_off is on if(member_array(info[2],listening[info[6]])==-1) return; // already NOT listening, ignore them } debug("listening change on chan:"+info[6]+", mud="+info[2]+", on_or_off="+info[7]); // only CHANGES should get to this point switch(channels[info[6]][0]){ case 0: // selectively banned if(member_array(info[2],channels[info[6]][2])!=-1){ // in list, you're banned... send_error(info[2],0,"not-allowed", "Banned from "+info[6],info); return; } // not in ban list at this point if(info[7]) listening[info[6]] += ({ info[2] }); else listening[info[6]] -= ({ info[2] }); return; case 1: // selectively allowed if(member_array(info[2],channels[info[6]][2])==-1 && info[2] != channels[info[6]][1]){ // NOT in list, you're banned! send_error(info[2],0,"not-allowed", "Not in allow list for "+info[6],info); return; } // in allow list at this point if(info[7]) listening[info[6]] += ({ info[2] }); else listening[info[6]] -= ({ info[2] }); return; case 2: // filtered... act like selectively allowed if(member_array(info[2],channels[info[6]][2])==-1 && info[2] != channels[info[6]][1]){ // NOT in list, you're banned! send_error(info[2],0,"not-allowed", "Not in allow list for "+info[6], info); return; } // in allow list at this point if(info[7]) listening[info[6]] += ({ info[2] }); else listening[info[6]] -= ({ info[2] }); return; } // switch default: // trying to do "channel-blah" send_error(info[2],info[3],"unk-type","I don't know what "+info[0]+ " means.",info); debug("Don't know what the ["+info[0]+"] packet means.", DEB_INVALID); return; } debug("can't get here?"); }