connect

#! /usr/bin/python3

import threading
import readline
import socket
import sys


class BufferManger(object):
    CLR_LINE = '\r\033[K'
    READLINE_OPTS = [
        'tab: complete'
        'set editing-mode emacs'
    ]

    def __init__(self):
        for opt in self.READLINE_OPTS:
            readline.parse_and_bind(opt)

    def _write(self, text):
        sys.stdout.write(text)

    def _flush(self):
        sys.stdout.flush()

    def on_recv(self, text):
        self._write(self.CLR_LINE)
        self._write(text)
        self._write(readline.get_line_buffer())
        self._flush()


class Client(object):
    RECV_SIZE = 2048

    def __init__(self, host, port):
        self.__bman = BufferManger()
        self.__host = host
        self.__port = port

    def start(self):
        self.__s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.__s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        self.__s.connect((self.__host, self.__port))

        # Start listener
        self.__t = threading.Thread(target=self._listen)
        self.__t.daemon = True
        self.__t.start()

        self._prompt()

    def _send(self, text):
        self.__s.send((text + '\n').encode())

    def _listen(self):
        while True:
            self.__bman.on_recv(self.__s.recv(self.RECV_SIZE).decode())

    def _prompt(self):
        while True:
            self._send(input())

    def close(self):
        self.__s.close()


if __name__ == "__main__":
    c = Client('127.0.0.1', 4242)
    try:
        c.start()
    except:
        print("Client stopping...")
    finally:
        c.close()