From: genjix <fake@lol.u>
Date: Wed, 21 Mar 2012 10:31:33 +0000 (+0000)
Subject: Untested: response_queue (formerly output_queue) now expects a JSON object which... 
X-Git-Url: https://git.novaco.in/?p=electrum-server.git;a=commitdiff_plain;h=651a0fcb8248634bd4e28ecc72e7d592eea87d2f

Untested: response_queue (formerly output_queue) now expects a JSON object which it saves. This is to be consistent with the request queue (formerly input queue).
---

diff --git a/stratum.py b/stratum.py
index d0fd61e..74e5866 100644
--- a/stratum.py
+++ b/stratum.py
@@ -88,12 +88,13 @@ class TcpClientResponder(threading.Thread):
     def run(self):
         while not self.shared.stopped() or self.session.stopped():
             response = self.session.pop_response()
+            raw_response = json.dumps(response)
             # Possible race condition here by having session
             # close connection?
             # I assume Python connections are thread safe interfaces
             connection = self.session.connection()
             try:
-                connection.send(response + "\n")
+                connection.send(raw_response + "\n")
             except:
                 self.session.stop()