[Update] Add debug

coco/models.py

@@ -171,6 +171,9 @@ class BaseServer:
     def recv(self, size):
         data = self.chan.recv(size)
         self.session.put_replay(data)
+        print(">>>>>>>>>>>>>>>>>>>>")
+        print(repr(data))
+        print("<<<<<<<<<<<<<<<<<<<<")
         if self._input_initial:
             if self._in_input_state:
                 self.input_data.append(data)
@@ -224,127 +227,6 @@ class Server(BaseServer):
         if self.sock:
             self.sock.transport.close()
 
-    # def __del__(self):
-    #     print("GC: Server object has been gc")
-
-
-'''
-class Server:
-    """
-    SSH Server
-    Server object like client, a wrapper object, a connection to the asset,
-    Because we don't want to using python dynamic feature, such asset
-    have the chan and system_user attr.
-    """
-
-    # Todo: Server name is not very suitable
-    def __init__(self, chan, sock, asset, system_user):
-        self.chan = chan
-        self.sock = sock
-        self.asset = asset
-        self.system_user = system_user
-        self.send_bytes = 0
-        self.recv_bytes = 0
-        self.stop_evt = threading.Event()
-
-        self.input_data = SizedList(maxsize=1024)
-        self.output_data = SizedList(maxsize=1024)
-        self._in_input_state = True
-        self._input_initial = False
-        self._in_vim_state = False
-
-        self._input = ""
-        self._output = ""
-        self._session_ref = None
-
-    def fileno(self):
-        return self.chan.fileno()
-
-    def set_session(self, session):
-        self._session_ref = weakref.ref(session)
-
-    @property
-    def session(self):
-        if self._session_ref:
-            return self._session_ref()
-        else:
-            return None
-
-    def parse(self, b):
-        if isinstance(b, str):
-            b = b.encode("utf-8")
-        if not self._input_initial:
-            self._input_initial = True
-
-        if self._have_enter_char(b):
-            self._in_input_state = False
-            self._input = self._parse_input()
-        else:
-            if not self._in_input_state:
-                self._output = self._parse_output()
-                logger.debug("\n{}\nInput: {}\nOutput: {}\n{}".format(
-                    "#" * 30 + " Command " + "#" * 30,
-                    self._input, self._output,
-                    "#" * 30 + " End " + "#" * 30,
-                ))
-                if self._input:
-                    self.session.put_command(self._input, self._output)
-                self.input_data.clean()
-                self.output_data.clean()
-            self._in_input_state = True
-
-    def send(self, b):
-        self.parse(b)
-        return self.chan.send(b)
-
-    def recv(self, size):
-        data = self.chan.recv(size)
-        self.session.put_replay(data)
-        if self._input_initial:
-            if self._in_input_state:
-                self.input_data.append(data)
-            else:
-                self.output_data.append(data)
-        return data
-
-    def close(self):
-        logger.info("Closed server {}".format(self))
-        self.parse(b'')
-        self.stop_evt.set()
-        self.chan.close()
-        self.chan.transport.close()
-        if self.sock:
-            self.sock.transport.close()
-
-    @staticmethod
-    def _have_enter_char(s):
-        for c in char.ENTER_CHAR:
-            if c in s:
-                return True
-        return False
-
-    def _parse_output(self):
-        if not self.output_data:
-            return ''
-        parser = utils.TtyIOParser()
-        return parser.parse_output(self.output_data)
-
-    def _parse_input(self):
-        if not self.input_data or self.input_data[0] == char.RZ_PROTOCOL_CHAR:
-            return
-        parser = utils.TtyIOParser()
-        return parser.parse_input(self.input_data)
-
-    def __getattr__(self, item):
-        return getattr(self.chan, item)
-
-    def __str__(self):
-        return "<To: {}>".format(str(self.asset))
-
-    # def __del__(self):
-    #     print("GC: Server object has been gc")
-'''
-
 
 class WSProxy:
     """