from Abe.DataStore import DataStore as Datastore_class
from Abe import DataStore, readconf, BCDataStream, deserialize, util, base58
-import psycopg2, binascii
+import binascii
import thread, traceback, sys, urllib, operator
from json import dumps, loads
if self.block_number != old_block_number:
old_block_number = self.block_number
- self.push_response({ 'method':'blockchain.numblocks.subscribe', 'result':self.block_number })
+ self.push_response({ 'method':'blockchain.numblocks.subscribe', 'params':[self.block_number] })
while True:
try:
break
if addr in self.watched_addresses:
status = self.store.get_status( addr )
- self.push_response({ 'method':'blockchain.address.subscribe', 'params':[addr], 'result':status })
+ print "push_response", addr
+ self.push_response({ 'method':'blockchain.address.subscribe', 'params':[addr, status] })
time.sleep(10)