mirror of
https://github.com/kennethreitz/flask-sockets.git
synced 2026-06-05 23:10:16 +00:00
Jules Olleon
69 lines
1.7 KiB
Python
69 lines
1.7 KiB
Python
# -*- coding: utf-8 -*-
|
|
from werkzeug.routing import Map, Rule
|
|
from werkzeug.exceptions import NotFound
|
|
|
|
def log_request(self):
|
|
log = self.server.log
|
|
if log:
|
|
if hasattr(log, 'info'):
|
|
log.info(self.format_request() + '\n')
|
|
else:
|
|
log.write(self.format_request() + '\n')
|
|
|
|
|
|
# Monkeys are made for freedom.
|
|
try:
|
|
import gevent
|
|
from geventwebsocket.gunicorn.workers import GeventWebSocketWorker as Worker
|
|
except ImportError:
|
|
pass
|
|
|
|
if 'gevent' in locals():
|
|
# Freedom-Patch logger for Gunicorn.
|
|
if hasattr(gevent, 'pywsgi'):
|
|
gevent.pywsgi.WSGIHandler.log_request = log_request
|
|
|
|
|
|
|
|
class SocketMiddleware(object):
|
|
|
|
def __init__(self, wsgi_app, socket):
|
|
self.ws = socket
|
|
self.app = wsgi_app
|
|
|
|
def __call__(self, environ, start_response):
|
|
adapter = self.ws.url_map.bind_to_environ(environ)
|
|
try:
|
|
handler, values = adapter.match()
|
|
environment = environ['wsgi.websocket']
|
|
handler(environment, **values)
|
|
return []
|
|
except NotFound:
|
|
return self.app(environ, start_response)
|
|
|
|
|
|
class Sockets(object):
|
|
|
|
def __init__(self, app=None):
|
|
self.url_map = Map()
|
|
if app:
|
|
self.init_app(app)
|
|
|
|
def init_app(self, app):
|
|
app.wsgi_app = SocketMiddleware(app.wsgi_app, self)
|
|
|
|
def route(self, rule, **options):
|
|
|
|
def decorator(f):
|
|
endpoint = options.pop('endpoint', None)
|
|
self.add_url_rule(rule, endpoint, f, **options)
|
|
return f
|
|
return decorator
|
|
|
|
def add_url_rule(self, rule, _, f, **options):
|
|
self.url_map.add(Rule(rule, endpoint=f))
|
|
|
|
# CLI sugar.
|
|
if 'Worker' in locals():
|
|
worker = Worker
|