Fix bitcoin payments by adding blockcypher token

feature/cython
voltar13 2019-01-30 21:02:44 +01:00 committed by Piotr Dobrowolski
parent 9adff5141e
commit 4459130370
1 changed files with 9 additions and 4 deletions

View File

@ -15,12 +15,15 @@ class PaymentProcessor(threading.Thread):
last_pong = 0
app = None
def __init__(self, device, input_address=None, chain_id=None, app=None):
def __init__(
self, device, input_address=None, chain_id=None, app=None,
token=None):
super(PaymentProcessor, self).__init__()
self.device = device
self.input_address = input_address
self.chain_id = chain_id
self.logger = logging.getLogger(type(self).__name__)
self.token = token
if app:
self.init_app(app)
@ -31,6 +34,7 @@ class PaymentProcessor(threading.Thread):
if not self.input_address:
self.input_address = self.app.config['INPUT_ADDRESS']
self.chain_id = self.app.config['BLOCKCYPHER_CHAIN']
self.token = self.app.config['BLOCKCYPHER_TOKEN']
def run(self):
self.logger.info('Starting...')
@ -38,12 +42,13 @@ class PaymentProcessor(threading.Thread):
while True:
try:
ws = websocket.WebSocketApp(
"wss://socket.blockcypher.com/v1/%s" % self.chain_id,
"wss://socket.blockcypher.com/v1/%s?token=%s" \
% (self.chain_id, self.token),
on_message=self.on_message,
on_error=self.on_error,
on_close=self.on_close)
on_close=self.on_close,
on_open=self.on_open)
ws.on_open = self.on_open
ws.run_forever(ping_timeout=20, ping_interval=30)
except:
self.logger.exception('run_forever failed')