voctocore/controlserver.py



import socket, threading, queue
from gi.repository import GObject

class 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)
        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()
        print("Connected")
        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):
            print("Connection closed.")
            return False
        
        livevideo = self.videomix.pipeline.get_by_name('livevideo')
        pad = livevideo.get_static_pad('sink_1')
        pad.set_property('alpha', 00)
        print(line)
        return True