core.py 文件源码

def connect(self, host = None, port = None):
        """
        Connect to the websocket server

        :return: Nothing
        """
        if not host is None:
            self.host = host
        if not port is None:
            self.port = port

        try:
            self.ws = websocket.WebSocket()
            LOG.info("Connecting...")
            self.ws.connect("ws://{}:{}".format(self.host, self.port))
            LOG.info("Connected!")
            self._auth(self.password)
            self._run_threads()
        except socket.error as e:
            raise exceptions.ConnectionFailure(str(e))