-
-
Notifications
You must be signed in to change notification settings - Fork 150
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Internal code restructure (no functional changes)
- Loading branch information
1 parent
3f36a15
commit 83361a1
Showing
22 changed files
with
739 additions
and
736 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,23 +1,13 @@ | ||
| import sys | ||
|
|
||
| from .client import Client | ||
| from .middleware import WSGIApp, Middleware | ||
| from .server import Server | ||
| if sys.version_info >= (3, 5): # pragma: no cover | ||
| from .asyncio_server import AsyncServer | ||
| from .asyncio_client import AsyncClient | ||
| from .async_drivers.asgi import ASGIApp | ||
| try: | ||
| from .async_drivers.tornado import get_tornado_handler | ||
| except ImportError: | ||
| get_tornado_handler = None | ||
| else: # pragma: no cover | ||
| AsyncServer = None | ||
| AsyncClient = None | ||
| from .async_server import AsyncServer | ||
| from .async_client import AsyncClient | ||
| from .async_drivers.asgi import ASGIApp | ||
| try: | ||
| from .async_drivers.tornado import get_tornado_handler | ||
| except ImportError: # pragma: no cover | ||
| get_tornado_handler = None | ||
| ASGIApp = None | ||
|
|
||
| __all__ = ['Server', 'WSGIApp', 'Middleware', 'Client'] | ||
| if AsyncServer is not None: # pragma: no cover | ||
| __all__ += ['AsyncServer', 'ASGIApp', 'get_tornado_handler', | ||
| 'AsyncClient'] | ||
| __all__ = ['Server', 'WSGIApp', 'Middleware', 'Client', | ||
| 'AsyncServer', 'ASGIApp', 'get_tornado_handler', 'AsyncClient'] |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,121 @@ | ||
| import logging | ||
| import time | ||
| import urllib | ||
| from . import packet | ||
|
|
||
| default_logger = logging.getLogger('engineio.client') | ||
| connected_clients = [] | ||
|
|
||
|
|
||
| class BaseClient: | ||
| event_names = ['connect', 'disconnect', 'message'] | ||
|
|
||
| def __init__(self, logger=False, json=None, request_timeout=5, | ||
| http_session=None, ssl_verify=True, handle_sigint=True, | ||
| websocket_extra_options=None): | ||
| self.handlers = {} | ||
| self.base_url = None | ||
| self.transports = None | ||
| self.current_transport = None | ||
| self.sid = None | ||
| self.upgrades = None | ||
| self.ping_interval = None | ||
| self.ping_timeout = None | ||
| self.http = http_session | ||
| self.external_http = http_session is not None | ||
| self.handle_sigint = handle_sigint | ||
| self.ws = None | ||
| self.read_loop_task = None | ||
| self.write_loop_task = None | ||
| self.queue = None | ||
| self.state = 'disconnected' | ||
| self.ssl_verify = ssl_verify | ||
| self.websocket_extra_options = websocket_extra_options or {} | ||
|
|
||
| if json is not None: | ||
| packet.Packet.json = json | ||
| if not isinstance(logger, bool): | ||
| self.logger = logger | ||
| else: | ||
| self.logger = default_logger | ||
| if self.logger.level == logging.NOTSET: | ||
| if logger: | ||
| self.logger.setLevel(logging.INFO) | ||
| else: | ||
| self.logger.setLevel(logging.ERROR) | ||
| self.logger.addHandler(logging.StreamHandler()) | ||
|
|
||
| self.request_timeout = request_timeout | ||
|
|
||
| def is_asyncio_based(self): | ||
| return False | ||
|
|
||
| def on(self, event, handler=None): | ||
| """Register an event handler. | ||
| :param event: The event name. Can be ``'connect'``, ``'message'`` or | ||
| ``'disconnect'``. | ||
| :param handler: The function that should be invoked to handle the | ||
| event. When this parameter is not given, the method | ||
| acts as a decorator for the handler function. | ||
| Example usage:: | ||
| # as a decorator: | ||
| @eio.on('connect') | ||
| def connect_handler(): | ||
| print('Connection request') | ||
| # as a method: | ||
| def message_handler(msg): | ||
| print('Received message: ', msg) | ||
| eio.send('response') | ||
| eio.on('message', message_handler) | ||
| """ | ||
| if event not in self.event_names: | ||
| raise ValueError('Invalid event') | ||
|
|
||
| def set_handler(handler): | ||
| self.handlers[event] = handler | ||
| return handler | ||
|
|
||
| if handler is None: | ||
| return set_handler | ||
| set_handler(handler) | ||
|
|
||
| def transport(self): | ||
| """Return the name of the transport currently in use. | ||
| The possible values returned by this function are ``'polling'`` and | ||
| ``'websocket'``. | ||
| """ | ||
| return self.current_transport | ||
|
|
||
| def _reset(self): | ||
| self.state = 'disconnected' | ||
| self.sid = None | ||
|
|
||
| def _get_engineio_url(self, url, engineio_path, transport): | ||
| """Generate the Engine.IO connection URL.""" | ||
| engineio_path = engineio_path.strip('/') | ||
| parsed_url = urllib.parse.urlparse(url) | ||
|
|
||
| if transport == 'polling': | ||
| scheme = 'http' | ||
| elif transport == 'websocket': | ||
| scheme = 'ws' | ||
| else: # pragma: no cover | ||
| raise ValueError('invalid transport') | ||
| if parsed_url.scheme in ['https', 'wss']: | ||
| scheme += 's' | ||
|
|
||
| return ('{scheme}://{netloc}/{path}/?{query}' | ||
| '{sep}transport={transport}&EIO=4').format( | ||
| scheme=scheme, netloc=parsed_url.netloc, | ||
| path=engineio_path, query=parsed_url.query, | ||
| sep='&' if parsed_url.query else '', | ||
| transport=transport) | ||
|
|
||
| def _get_url_timestamp(self): | ||
| """Generate the Engine.IO query string timestamp.""" | ||
| return '&t=' + str(time.time()) |
Oops, something went wrong.