- import socket, threading, queue, logging
- from gi.repository import GObject
- def controlServerEntrypoint(f):
- # mark the method as something that requires view's class
- f.is_control_server_entrypoint = True
- return f
- class ControlServer():
- log = logging.getLogger('ControlServer')
- def __init__(self, videomix):
- '''Initialize server and start listening.'''
- self.videomix = videomix
- sock = socket.socket()
- sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
- sock.bind(('0.0.0.0', 23000))
- sock.listen(1)
- # register socket for callback inside the GTK-Mainloop
- GObject.io_add_watch(sock, GObject.IO_IN, self.listener)
- def listener(self, sock, *args):
- '''Asynchronous connection listener. Starts a handler for each connection.'''
- conn, addr = sock.accept()
- self.log.info("Connection from %s", addr)
- # register data-received handler inside the GTK-Mainloop
- GObject.io_add_watch(conn, GObject.IO_IN, self.handler)
- return True
- def handler(self, conn, *args):
- '''Asynchronous connection handler. Processes each line from the socket.'''
- line = conn.recv(4096)
- if not len(line):
- self.log.debug("Connection closed.")
- return False
- r = self.processLine(line.decode('utf-8'))
- if isinstance(r, str):
- conn.send((r+'\n').encode('utf-8'))
- return False
- conn.send('OK\n'.encode('utf-8'))
- return True
- def processLine(self, line):
- command, argstring = (line.strip()+' ').split(' ', 1)
- args = argstring.strip().split()
- self.log.info(command % args)
- if not hasattr(self.videomix, command):
- return 'unknown command {}'.format(command)
- f = getattr(self.videomix, command)
- if not hasattr(f, 'is_control_server_entrypoint'):
- return 'method {} not callable from controlserver'.format(command)
- try:
- return f(*args)
- except Exception as e:
- return str(e)
|
