traipse_dev: orpg/networking/mplay

comparison orpg/networking/mplay_server.py @ 124:8827271fbe1b alpha

Traipse Alpha 'OpenRPG' {091001-01} Traipse is a distribution of OpenRPG that is designed to be easy to setup and go. Traipse also makes it easy for developers to work on code without fear of sacrifice. 'Ornery-Orc' continues the trend of 'Grumpy' and adds fixes to the code. 'Ornery-Orc's main goal is to offer more advanced features and enhance the productivity of the user. Update Summary (Cleaning up for Beta) Added Bookmarks Fix to Remote Admin Commands Minor fix to text based Server Fix to Pretty Print, from Core Fix to Splitter Nodes not being created Fix to massive amounts of images loading, from Core Added 'boot' command to remote admin Added confirmation window for sent nodes Minor changes to allow for portability to an OpenSUSE linux OS Miniatures Layer pop up box allows users to turn off Mini labels, from FlexiRPG Zoom Mouse plugin added Images added to Plugin UI Switching to Element Tree Map efficiency, from FlexiRPG Added Status Bar to Update Manager default_manifest.xml renamed to default_upmana.xml Cleaner clode for saved repositories New TrueDebug Class in orpg_log (See documentation for usage) Mercurial's hgweb folder is ported to upmana Happy Halloween!

author	sirebral
date	Sun, 01 Nov 2009 11:36:14 -0600
parents	36919b8a3ef9
children	fba298d65cf8

comparison

equal deleted inserted replaced

-:174658f839c0
+:8827271fbe1b
 "converts strings to intergers for list sort comparisons for group and player ids so they end up in numeric order"
 return cmp(int(a),int(b))
 class game_group(object):
-debug()
 def __init__(self, id, name, pwd, desc="", boot_pwd="",
 minVersion="", mapFile=None, messageFile=None, persist=0):
 self.id = id
 self.name = name
 self.desc = desc
 tree = f.read()
 f.close()
 self.game_map.init_from_xml(fromstring(tree))
 def save_map(self):
-debug()
+#debug(log=False)
 if self.mapFile is not None and self.persistant == 1 and self.mapFile.find("default_map.xml") == -1:
 f = open(self.mapFile, "w")
 f.write(self.game_map.get_all_xml())
 f.close()
 def add_player(self,id):
-debug()
 self.players.append(id)
 def remove_player(self,id):
-debug()
 if self.voice.has_key(id): del self.voice[id]
 self.players.remove(id)
 def get_num_players(self):
-debug()
 num =  len(self.players)
 return num
 def get_player_ids(self):
-debug()
 tmp = self.players
 return tmp
 def check_pwd(self,pwd):
-debug()
 return (pwd==self.pwd)
 def check_boot_pwd(self,pwd):
 return (pwd==self.boot_pwd)
 def check_version(self,ver):
-debug()
 if (self.minVersion == ""): return 1
 minVersion=self.minVersion.split('.')
 version=ver.split('.')
 for i in xrange(min(len(minVersion),len(version))):
 w=max(len(minVersion[i]),len(version[i]))
 return 0
 return 1
 #depreciated - see send_group_list()
 def toxml(self, act="new"):
-debug(self.name)
 #  Please don't add the boot_pwd to the xml, as this will give it away to players watching their console
 el = Element('group')
 el.set('id', self.id)
 el.set('name', self.name)
 el.set('pwd', str(self.pwd!=""))
 el.set('players', str(self.get_num_players()))
 el.set('action', act)
 return tostring(el)
 class client_stub(client_base):
-debug()
 def __init__(self,inbox,sock,props,log):
 client_base.__init__(self)
 self.ip = props['ip']
 self.role = props['role']
 self.id = props['id']
 diff = curtime - self.timeout_time
 if diff > 1800: return 1
 else: return 0
 def send(self, msg, player, group):
-debug()
 if self.get_status() == MPLAY_CONNECTED:
 #el = Element('msg')
 #el.set('to', player)
 #el.set('from', '0')
 #el.set('group_id', group)
 #el.text(msg)
 self.outbox.put("<msg to='" + player + "' from='0' group_id='" + group + "' />" + msg)
 def change_group(self, group_id, groups):
-debug()
 old_group_id = str(self.group_id)
 groups[group_id].add_player(self.id)
 groups[old_group_id].remove_player(self.id)
 self.group_id = group_id
 self.outbox.put(self.toxml('group'))
 ######################################################################
 ######################################################################
 """
 class mplay_server:
-debug()
+#debug(log=False)
 def __init__(self, log_console=None, name=None):
 logger._set_log_level = 16
 logger._set_log_to_console(True)
 self.log_to_console = 1
 self.log_console = log_console
 self.allowRemoteKill = False
 self.allowRemoteAdmin = True
 self.sendLobbySound = False
 self.lobbySound = 'http://www.digitalxero.net/music/mus_tavern1.bmu' ##used?
-@debugging
 def initServer(self, **kwargs):
+#debug(log=False)
 for atter, value in kwargs.iteritems(): setattr(self, atter, value)
 validate.config_file( self.lobbyMapFile, "default_Lobby_map.xml" )
 validate.config_file( self.lobbyMessageFile, "default_LobbyMessage.html" )
 self.server_start_time = time.time()
 except Exception, e:
 self.log_msg("Exception in saveBanList() " + str(e))
 # This method reads in the server's configuration file and reconfigs the server
 # as needed, over-riding any default values as requested.
 def initServerConfig(self):
+#debug(log=False)
 self.log_msg("Processing Server Configuration File... " + self.userPath)
 # make sure the server_ini.xml exists!
 validate.config_file( "server_ini.xml", "default_server_ini.xml" )
 # try to use it.
 try:
 badchars = "\"\\`><"
 for c in badchars: name = name.replace(c,"")
 return name
 def registerRooms(self, args=None):
+#debug()
 rooms = ''
 id = '0'
 time.sleep(500)
+#debug(self.groups)
 for rnum in self.groups.keys():
 rooms += urllib.urlencode( {"room_data[rooms][" + str(rnum) + "][name]":self.groups[rnum].name,
 "room_data[rooms][" + str(rnum) + "][pwd]":str(self.groups[rnum].pwd != "")})+'&'
 for pid in self.groups[rnum].players:
 rooms += urllib.urlencode( {"room_data[rooms][" + str(rnum) + "][players]["+str(pid)+"]":self.players[pid].name,})+'&'
+#debug(rooms)
 for meta in self.metas.keys():
 while id == '0':
 id, cookie = self.metas[meta].getIdAndCookie()
 data = urllib.urlencode( {"room_data[server_id]":id,
 "act":'registerrooms'})
-get_server_dom(data+'&'+rooms, self.metas[meta].path)
+#debug((data, rooms))
+get_server_dom(data+'&'+rooms, self.metas[meta].path, string=True)
 def register(self,name_given=None):
 if name_given == None: name = self.name
 else: self.name = name = name_given
 name = self.clean_published_servername(name)
 print "'lobbysound' - Lets you specify which sound file to send to players joining the lobby"
 print "'help' or '?' or 'h' - for this help message"
 print
 def broadcast(self,msg):
-self.send_to_all("0","<msg to='all' from='0' group_id='1'><font color='#FF0000'>" + msg + "</font>")
+self.send_to_all("0","<msg to='all' from='0' group_id='1'><font color='#FF0000'>" + msg + "</font></msg>")
 def console_log(self):
 if self.log_to_console == 1:
 print "console logging now off"
 self.log_to_console = 0
 elif self.players[id].group_id.find(patern)>-1: self.print_player_info(self.players[id])
 elif self.players[id].role.find(patern)>-1: self.print_player_info(self.players[id])
 elif self.players[id].version.find(patern)>-1: self.print_player_info(self.players[id])
 elif self.players[id].protocol_version.find(patern)>-1: self.print_player_info(self.players[id])
 elif self.players[id].client_string.find(patern)>-1: self.print_player_info(self.players[id])
+def obtain_by_id(self, id, objects):
+### Alpha ### Basic way to obtain information for the Server GUI, currently reports the Client String only
+return self.players[id].client_string
 def print_player_info(self,player):
 print player.id, player.name, player.ip, player.group_id, player.role, player.version, player.protocol_version, player.client_string
 """
 if v1>v2: return 0
 if len(minv)>len(cver): return 0
 return 1
 def SendLobbyMessage(self, socket, player_id):
-debug()
+#debug(log=False)
 """
 #  Display the lobby message
 #  prepend this server's version string to the the lobby message
 """
 try:
 #  At this point, we're done and cleaning up.
 self.log_msg("server socket listening thread exiting...")
 self.listen_event.set()
 def acceptedNewConnectionThread( self, newsock, addr ):
-debug()
+#debug(log=False)
 """Once a new connection comes in and is accepted, this thread starts up to handle it."""
 # Initialize xml_dom
 xml_dom = None
 data = None
 print "from " + str(addr) + " created the following exception: "
 traceback.print_exc()
 return #returning causes connection thread instance to terminate
 #  Again attempt to clean out DOM stuff
-try:
+"""
-if xml_dom: xml_dom.unlink()
+try: if xml_dom: xml_dom.unlink()
 except:
 print "The following exception caught unlinking xml_dom:"
 traceback.print_exc()
-return #returning causes connection thread instance to terminate
+return #returning causes connection thread instance to terminate"""
 """
 #========================================================
 #
 #   Message_handler
 # to multiple expiring parsing/handling threads to improve server performance
 # and player load capacity -- Snowdog 3/04
 """
 def message_handler(self, arg):
-debug()
+#debug(log=False)
 xml_dom = None
 self.log_msg( "message handler thread running..." )
 while self.alive:
 data = None
 try: data=self.incoming.get(0)
 #if xml_dom: xml_dom.unlink()
 self.log_msg("message handler thread exiting...")
 self.incoming_event.set()
 def parse_incoming_dom(self,data):
-debug(data)
 end = data.find(">") #locate end of first element of message
 head = data[:end+1]
 #self.log_msg(head)
 xml_dom = None
 try:
 print "Error in parse of inbound message. Ignoring message."
 print "  Offending data(" + str(len(data)) + "bytes)=" + data
 print "Exception=" + str(e)
 def message_action(self, xml_dom, data):
-debug()
+tag_name = xml_dom.tag
-tag_name = xml_dom.tag; print 'message_action tag_name', tag_name
 if self.svrcmds.has_key(tag_name): self.svrcmds[tag_name]['function'](xml_dom, data)
 else: raise Exception, "Not a valid header!"
 #Message Action thread expires and closes here.
 return
 def do_alter(self, xml_dom, data):
-debug()
 target = xml_dom.get("key")
 value = xml_dom.get("val")
 player = xml_dom.get("plr")
 group_id = xml_dom.get("gid")
 boot_pwd = xml_dom.get("bpw")
 else:
 msg ="<msg to='" + player + "' from='0' group_id='0'>Invalid Administrator Password."
 self.players[player].outbox.put(msg)
 def do_role(self, xml_dom, data):
-debug()
 role = ""
 boot_pwd = ""
 act = xml_dom.get("action")
 player = xml_dom.get("player")
 group_id = xml_dom.get("group_id")
 if group_id != "0":
 self.handle_role(act, player, role, boot_pwd, group_id)
 self.log_msg(("role", (player, role)))
 def do_ping(self, xml_dom, data):
-debug()
 player = xml_dom.get("player")
 group_id = xml_dom.get("group_id")
 sent_time = ""
 msg = ""
 try: sent_time = xml_dom.get("time")
 msg += "<font color='#FF0000'>PONG!?!</font>"
 self.players[player].outbox.put(msg)
 #xml_dom.unlink()
 def do_system(self, xml_dom, data):
-debug()
 pass
 def moderate_group(self,xml_dom,data):
 try:
 action = xml_dom.get("action")
 thread.start_new_thread(self.registerRooms,(0,))
 def return_room_roles(self, from_id, group_id):
 for m in self.players.keys():
 if self.players[m].group_id == group_id:
-print 'return_room_roles', self.players[m].id, self.players[m].role, self.players[m]
 try: msg = "<role action='update' id='" + self.players[m].id  + "' role='" + self.players[m].role + "' />"
 except: exit()
 self.players[from_id].outbox.put(msg)
 """
 return lmessage
 except: return "An error occured during rename of room!"
 thread.start_new_thread(self.registerRooms,(0,))
 def create_group(self, xml_dom, data):
-debug((tostring(xml_dom), data))
 #try:
 from_id = xml_dom.get("from")
 pwd = xml_dom.get("pwd")
 name = xml_dom.get("name")
 boot_pwd = xml_dom.get("boot_pwd")
 self.register()
 except Exception, e: self.log_msg(str(e))
 self.log_msg("Explicit garbage collection shows %s undeletable items." % str(gc.collect()))
 def incoming_player_handler(self, xml_dom, data):
-debug()
 id = xml_dom.get("id")
 act = xml_dom.get("action")
 #group_id = xml_dom.get("group_id")
 group_id = self.players[id].group_id
 ip = self.players[id].ip
 except Exception, e: traceback.print_exc()
 elif act=="del":
 self.del_player(id,group_id)
 self.check_group(id, group_id)
 elif act=="update":
-debug(xml_dom)
-print xml_dom.get('name')
 self.players[id].take_dom(xml_dom)
 self.log_msg(("update", {"id": id,
 "name": xml_dom.get("name"),
 "status": xml_dom.get("status"),
 "role": xml_dom.get("role"),
 def msgTooLong(self, length):
 if length > self.maxSendSize and not self.maxSendSize == 0: return True
 return False
 def incoming_msg_handler(self,xml_dom,data):
-debug()
 xml_dom, data = ServerPlugins.preParseIncoming(xml_dom, data)
 ###########################################################
 to_id = xml_dom.get("to")
 from_id = xml_dom.get("from")
 group_id = xml_dom.get("group_id")
 else: self.players[to_id].outbox.put(data)
 self.check_group_members(group_id)
 return
 def sound_msg_handler(self, xml_dom, data):
-debug()
 from_id = xml_dom.get("from")
 group_id = xml_dom.get("group_id")
 if group_id != 0: self.send_to_group(from_id, group_id, data)
 def plugin_msg_handler(self,xml_dom,data):
 def send(self,msg,player,group):
 self.players[player].send(msg,player,group)
 def send_to_all(self,from_id,data):
 try:
-print data
 self.p_lock.acquire()
 keys = self.players.keys()
 self.p_lock.release()
 for k in keys:
 if k != from_id: self.players[k].outbox.put(data)

Mercurial > traipse_dev

comparison orpg/networking/mplay_server.py @ 124:8827271fbe1b alpha