X-Git-Url: https://git.novaco.in/?a=blobdiff_plain;f=mining%2Fsubscription.py;h=41c77d079cd3c8b85c8d0871fdb77b3ffb18337e;hb=HEAD;hp=3e39a603319c6fbc784b1cbc5bba71e364148e73;hpb=f473c12488449c6080097bf625082acae30f7827;p=stratum-mining.git

diff --git a/mining/subscription.py b/mining/subscription.py
index 3e39a60..41c77d0 100644
--- a/mining/subscription.py
+++ b/mining/subscription.py
@@ -1,6 +1,7 @@
 from stratum.pubsub import Pubsub, Subscription
 from mining.interfaces import Interfaces
 
+from stratum import settings
 import stratum.logger
 log = stratum.logger.get_logger('subscription')
 
@@ -11,7 +12,7 @@ class MiningSubscription(Subscription):
     event = 'mining.notify'
     
     @classmethod
-    def on_block(cls, is_new_block):
+    def on_template(cls, is_new_block):
         '''This is called when TemplateRegistry registers
            new block which we have to broadcast clients.'''
         
@@ -37,8 +38,7 @@ class MiningSubscription(Subscription):
             return result
         
         # Force set higher difficulty
-        # TODO
-        #self.connection_ref().rpc('mining.set_difficulty', [2,], is_notification=True)
+        self.connection_ref().rpc('mining.set_difficulty', [settings.POOL_TARGET,], is_notification=True)
         #self.connection_ref().rpc('client.get_version', [])
         
         # Force client to remove previous jobs if any (eg. from previous connection)
@@ -51,4 +51,5 @@ class MiningSubscription(Subscription):
         '''This will send new job to the client *after* he receive subscription details.
         on_finish callback solve the issue that job is broadcasted *during*
         the subscription request and client receive messages in wrong order.'''
-        self.connection_ref().on_finish.addCallback(self._finish_after_subscribe)
\ No newline at end of file
+        self.connection_ref().on_finish.addCallback(self._finish_after_subscribe)
+