add irc bridge plugin

.gitignore

@@ -0,0 +1 @@
+*.pyc

headless.py

@@ -17,6 +17,7 @@
 import plugins
 from utils import extends
 from itemdb import load_itemdb
+from logicmanager import logic_manager
 
 
 @extends('smsg_player_warp')
@@ -31,7 +32,7 @@ def map_login_success(data):
 
 if __name__ == '__main__':
  logging.basicConfig(format="[%(asctime)s] %(message)s",
- level=logging.INFO,
+ level=logging.WARNING,
  datefmt="%Y-%m-%d %H:%M:%S")
  config = ConfigParser()
  config.read('manachat.ini')
@@ -47,6 +48,8 @@ def map_login_success(data):
  charname=config.get('Player', 'charname'))
 
  try:
- asyncore.loop()
+ while True:
+ asyncore.loop(timeout=0.2, count=5)
+ logic_manager.tick()
  except KeyboardInterrupt:
  mapserv.cleanup()

irc_bridge_db.pkl

@@ -0,0 +1 @@
+(d.

net/common.py

@@ -20,13 +20,14 @@ class SocketWrapper(asyncore.dispatcher_with_send):
  """
  socket wrapper with file-like read() and write() methods
  """
- def __init__(self, host=None, port=0, buffer_size=1500, protodef={}):
+ def __init__(self, host=None, port=0, buffer_size=1500, protodef={}, onclose=None):
  asyncore.dispatcher_with_send.__init__(self)
  self.buffer_size = buffer_size
  self.read_buffer = ''
  self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
  self.protodef = protodef
- self.raw = False
+ self.raw = True
+ self.onclose = onclose
  if protodef == {}:
  netlog.warning("protodef is empty")
  if host is not None:
@@ -69,6 +70,18 @@ def write(self, data):
  else:
  self.send(data)
 
+ def handle_error(self):
+ self.handle_close()
+ return
+
+ def handle_expt(self):
+ return
+
+ def handle_close(self):
+ self.close()
+ if self.onclose is not None:
+ self.onclose()
+
 
 def send_packet(srv, opcode_, *fields):
  class C:

net/mapserv.py

@@ -36,6 +36,9 @@
 def smsg_ignore(data):
  pass
 
+@extendable
+def on_close():
+ netlog.warning("connection to map server lost")
 
 @extendable
 def smsg_being_chat(data):
@@ -1169,7 +1172,7 @@ def cmsg_storage_close():
 def connect(host, port):
  global server, beings_cache
  beings_cache = BeingsCache(cmsg_name_request)
- server = SocketWrapper(host=host, port=port, protodef=protodef)
+ server = SocketWrapper(host=host, port=port, protodef=protodef, onclose=on_close)
  timers.append(Schedule(15, 20, cmsg_map_server_ping))