From 91a1b4a3db02c9c74ec0831c8e0d2d390b7279fc Mon Sep 17 00:00:00 2001 From: Tyson Clugg Date: Tue, 13 Oct 2015 11:18:24 +1100 Subject: [PATCH] Bugfix thread locals setup when opening WebSocket. --- dddp/websocket.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/dddp/websocket.py b/dddp/websocket.py index 89e8a69..ae8e019 100644 --- a/dddp/websocket.py +++ b/dddp/websocket.py @@ -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()')