RanchiMall/flo-token-tracking
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Websocket reconnection - new logic

Browse Source
This commit is contained in:
Vivek Teega 2020-10-09 10:00:41 +05:30
parent b1c694d137
commit 2ea0996e26
1 changed files with 41 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

78
tracktokens-smartcontracts.py
View File

@ -12,7 +12,6 @@ import socketio
from sqlalchemy import create_engine, func from sqlalchemy import create_engine, func
from sqlalchemy.orm import sessionmaker from sqlalchemy.orm import sessionmaker
import time import time
import parsing import parsing
from config import * from config import *
from models import SystemData, ActiveTable, ConsumedTable, TransferLogs, TransactionHistory, RejectedTransactionHistory, \ from models import SystemData, ActiveTable, ConsumedTable, TransferLogs, TransactionHistory, RejectedTransactionHistory, \
@ -2316,7 +2315,6 @@ if args.reset == 1:
# scan from the latest block saved locally to latest network block # scan from the latest block saved locally to latest network block
scanBlockchain() scanBlockchain()
def switchNeturl(neturl): def switchNeturl(neturl):
testserverlist = ['http://0.0.0.0:9000/', 'https://testnet-flosight.duckdns.org/', 'https://testnet.flocha.in/'] testserverlist = ['http://0.0.0.0:9000/', 'https://testnet-flosight.duckdns.org/', 'https://testnet.flocha.in/']
mainserverlist = ['http://0.0.0.0:9001/', 'https://flosight.duckdns.org/', 'https://explorer.mediciland.com/', 'https://livenet.flocha.in/'] mainserverlist = ['http://0.0.0.0:9001/', 'https://flosight.duckdns.org/', 'https://explorer.mediciland.com/', 'https://livenet.flocha.in/']
@ -2335,43 +2333,49 @@ def switchNeturl(neturl):
def reconnectSSE(neturl): def reconnectSSE(neturl):
# Switch a to different flosight
# neturl = switchNeturl(neturl)
# Connect to Flosight websocket to get data on new incoming blocks # Connect to Flosight websocket to get data on new incoming blocks
sio = socketio.Client(reconnection=False) connection_status = False
try: while (not connection_status):
sio.connect( neturl + "socket.io/socket.io.js") logger.debug('The script will rescan from the latest block in local db to latest server on FLO network')
except: scanBlockchain()
logger.debug(f"Could not connect to the websocket endpoint {neturl}. Switching & retrying to next") logger.debug("Rescan completed")
return try:
logger.debug(f"Attempting websocket connection to {neturl}")
@sio.on('connect') sio.connect(neturl + "socket.io/socket.io.js")
def on_connect(): connection_status = True
logger.debug(f"Token Tracker has connected to websocket endpoint {neturl}") return neturl
sio.emit('subscribe', 'inv') except:
logger.debug(f"Could not connect to the websocket endpoint {neturl}")
@sio.on('disconnect') neturl = switchNeturl(neturl)
def disconnect():
logger.debug(f"Token Tracker disconnected from websocket endpoint {neturl}")
return
@sio.on('connect_error')
def connect_error():
logger.debug(f"CONNECTION_ERROR to the websocket endpoint {neturl}. Switching & retrying to next")
return
@sio.on('block')
def on_block(data):
logger.debug('New block received')
logger.debug(str(data))
processApiBlock(data)
# At this point the script has updated to the latest block # At this point the script has updated to the latest block
# Now we connect to flosight's websocket API to get information about the latest blocks # Now we connect to flosight's websocket API to get information about the latest blocks
neturl = 'https://flosight.duckdns.org/' neturl = 'https://flosight.duckdns.org/' # Neturl is the URL for Flosight API whose websocket endpoint is being connected to
while(True): sio = socketio.Client(reconnection=False)
logger.debug('The script will rescan from the latest block in local db to latest server on FLO network')
scanBlockchain() # Connect to the websocket endpoint and return the new neturl
logger.debug("Rescan completed") neturl = reconnectSSE(neturl)
logger.debug('Attempting reconnect to websocket ...')
reconnectSSE(neturl) @sio.on('connect')
neturl = switchNeturl(neturl) def on_connect():
logger.debug(f"Token Tracker has connected to websocket endpoint {neturl}")
sio.emit('subscribe', 'inv')
@sio.on('disconnect')
def disconnect():
logger.debug(f"Token Tracker disconnected from websocket endpoint {neturl}")
neturl = reconnectSSE(neturl)
@sio.on('connect_error')
def connect_error():
logger.debug(f"CONNECTION_ERROR to the websocket endpoint {neturl}. Switching & retrying to next")
neturl = reconnectSSE(neturl)
@sio.on('block')
def on_block(data):
logger.debug('New block received')
logger.debug(str(data))
processApiBlock(data)