mirror of https://github.com/morpheus65535/bazarr
32 lines
1.1 KiB
Python
32 lines
1.1 KiB
Python
from ..protocol.json_hub_protocol import JsonHubProtocol
|
|
from ..helpers import Helpers
|
|
|
|
class BaseTransport(object):
|
|
def __init__(self, protocol=JsonHubProtocol(), on_message=None):
|
|
self.protocol = protocol
|
|
self._on_message= on_message
|
|
self.logger = Helpers.get_logger()
|
|
self._on_open = lambda: self.logger.info("on_connect not defined")
|
|
self._on_close = lambda: self.logger.info("on_disconnect not defined")
|
|
self._on_reconnect = lambda: self.logger.info("on_reconnect not defined")
|
|
|
|
def on_open_callback(self, callback):
|
|
self._on_open = callback
|
|
|
|
def on_close_callback(self, callback):
|
|
self._on_close = callback
|
|
|
|
def on_reconnect_callback(self, callback):
|
|
self._on_reconnect = callback
|
|
|
|
def start(self): # pragma: no cover
|
|
raise NotImplementedError()
|
|
|
|
def stop(self): # pragma: no cover
|
|
raise NotImplementedError()
|
|
|
|
def is_running(self): # pragma: no cover
|
|
raise NotImplementedError()
|
|
|
|
def send(self, message, on_invocation = None): # pragma: no cover
|
|
raise NotImplementedError() |