Hopiu/django-ddp
1
0
Fork 0
mirror of https://github.com/jazzband/django-ddp.git synced 2026-05-12 09:33:15 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Bugfix thread locals setup when opening WebSocket.

Browse source
This commit is contained in:
Tyson Clugg 2015-10-13 11:18:24 +11:00
parent 0bbf5ac10c
commit 91a1b4a3db
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
dddp/websocket.py
View file

@ -115,6 +115,12 @@ class DDPWebSocketApplication(geventwebsocket.WebSocketApplication):
def on_open(self):
"""Handle new websocket connection."""
this.request = WSGIRequest(self.ws.environ)
this.ws = self
this.send = self.send
this.reply = self.reply
this.error = self.error
self.logger = self.ws.logger
self.remote_ids = collections.defaultdict(set)
@ -325,12 +331,6 @@ class DDPWebSocketApplication(geventwebsocket.WebSocketApplication):
elif version not in support:
self.error('Client version/support mismatch.')
else:
this.request = WSGIRequest(self.ws.environ)
this.ws = self
this.send = self.send
this.reply = self.reply
this.error = self.error
from dddp.models import Connection
cur = connection.cursor()
cur.execute('SELECT pg_backend_pid()')