Start listening when mining service is ready

[stratum-mining.git] / mining / subscription.py

diff --git a/mining/subscription.py b/mining/subscription.py
index cbbeea5..3e39a60 100644 (file)
--- a/mining/subscription.py
+++ b/mining/subscription.py
@@ -18,7 +18,7 @@ class MiningSubscription(Subscription):
         start = Interfaces.timestamper.time()
         
         clean_jobs = is_new_block
-        (job_id, prevhash, coinb1, coinb2, merkle_branch, version, nbits, ntime, clean_jobs) = \
+        (job_id, prevhash, coinb1, coinb2, merkle_branch, version, nbits, ntime, _) = \
                         Interfaces.template_registry.get_last_broadcast_args()
         
         # Push new job to subscribed clients
@@ -30,7 +30,7 @@ class MiningSubscription(Subscription):
     def _finish_after_subscribe(self, result):
         '''Send new job to newly subscribed client'''
         try:        
-            (job_id, prevhash, coinb1, coinb2, merkle_branch, version, nbits, ntime, clean_jobs) = \
+            (job_id, prevhash, coinb1, coinb2, merkle_branch, version, nbits, ntime, _) = \
                         Interfaces.template_registry.get_last_broadcast_args()
         except Exception:
             log.error("Template not ready yet")
@@ -39,10 +39,11 @@ class MiningSubscription(Subscription):
         # Force set higher difficulty
         # TODO
         #self.connection_ref().rpc('mining.set_difficulty', [2,], is_notification=True)
+        #self.connection_ref().rpc('client.get_version', [])
         
         # Force client to remove previous jobs if any (eg. from previous connection)
         clean_jobs = True
-        self.emit_single(job_id, prevhash, coinb1, coinb2, merkle_branch, version, nbits, ntime, clean_jobs)
+        self.emit_single(job_id, prevhash, coinb1, coinb2, merkle_branch, version, nbits, ntime, True)
         
         return result