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

Optimizing blockinfo passed to the function

Browse Source
This commit is contained in:
Vivek Teega 2019-09-10 07:30:28 +05:30
parent 2f947e2992
commit f761552464
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
tracktokens-smartcontracts.py
View File

@ -103,10 +103,10 @@ def processApiBlock(blockhash):
checkLocaltriggerContracts(blockinfo) checkLocaltriggerContracts(blockinfo)
def updateLatestTransaction(transactionData, parsed_data, blockinfo): def updateLatestTransaction(transactionData, parsed_data, blockNumber):
# connect to latest transaction db # connect to latest transaction db
conn = sqlite3.connect('latestCache.db') conn = sqlite3.connect('latestCache.db')
conn.execute("INSERT INTO latestTransactions(transactionHash, blockNumber, jsonData, transactionType, parsedFloData) VALUES (?,?,?,?,?)", (transactionData['hash'], blockinfo['height'], json.dumps(transactionData), parsed_data['type'], json.dumps(parsed_data))) conn.execute("INSERT INTO latestTransactions(transactionHash, blockNumber, jsonData, transactionType, parsedFloData) VALUES (?,?,?,?,?)", (transactionData['hash'], blockNumber, json.dumps(transactionData), parsed_data['type'], json.dumps(parsed_data)))
conn.commit() conn.commit()
conn.close() conn.close()
@ -510,7 +510,7 @@ def startWorking(transaction_data, parsed_data, blockinfo):
pushData_SSEapi('Error | Something went wrong while doing the internal db transactions for {}'.format(transaction_data['txid'])) pushData_SSEapi('Error | Something went wrong while doing the internal db transactions for {}'.format(transaction_data['txid']))
return 0 return 0
else: else:
updateLatestTransaction(transaction_data, parsed_data, blockinfo) updateLatestTransaction(transaction_data, parsed_data, blockinfo['height'])
# If this is the first interaction of the outputlist's address with the given token name, add it to token mapping # If this is the first interaction of the outputlist's address with the given token name, add it to token mapping
engine = create_engine('sqlite:///system.db', echo=True) engine = create_engine('sqlite:///system.db', echo=True)
@ -657,7 +657,7 @@ def startWorking(transaction_data, parsed_data, blockinfo):
contractName = parsed_data['contractName'], contractAddress = outputlist[0], transactionHash=transaction_data['txid'])) contractName = parsed_data['contractName'], contractAddress = outputlist[0], transactionHash=transaction_data['txid']))
session.commit() session.commit()
updateLatestTransaction(transaction_data, parsed_data, blockinfo) updateLatestTransaction(transaction_data, parsed_data, blockinfo['height'])
return return
else: else:
@ -684,7 +684,7 @@ def startWorking(transaction_data, parsed_data, blockinfo):
contractName=parsed_data['contractName'], contractAddress = outputlist[0], transactionHash=transaction_data['txid'])) contractName=parsed_data['contractName'], contractAddress = outputlist[0], transactionHash=transaction_data['txid']))
session.commit() session.commit()
session.close() session.close()
updateLatestTransaction(transaction_data, parsed_data, blockinfo) updateLatestTransaction(transaction_data, parsed_data, blockinfo['height'])
return return
else: else:
@ -713,7 +713,7 @@ def startWorking(transaction_data, parsed_data, blockinfo):
contractAddress=outputlist[0], transactionHash=transaction_data['txid'])) contractAddress=outputlist[0], transactionHash=transaction_data['txid']))
session.commit() session.commit()
updateLatestTransaction(transaction_data, parsed_data, blockinfo) updateLatestTransaction(transaction_data, parsed_data, blockinfo['height'])
pushData_SSEapi('Participation | Succesfully participated in the contract {}-{} at transaction {}'.format( pushData_SSEapi('Participation | Succesfully participated in the contract {}-{} at transaction {}'.format(
parsed_data['contractName'], outputlist[0], parsed_data['contractName'], outputlist[0],
@ -752,7 +752,7 @@ def startWorking(transaction_data, parsed_data, blockinfo):
connection.close() connection.close()
updateLatestTransaction(transaction_data, parsed_data, blockinfo) updateLatestTransaction(transaction_data, parsed_data, blockinfo['height'])
pushData_SSEapi('Token | Succesfully incorporated token {} at transaction {}'.format( pushData_SSEapi('Token | Succesfully incorporated token {} at transaction {}'.format(
parsed_data['tokenIdentification'], transaction_data['txid'])) parsed_data['tokenIdentification'], transaction_data['txid']))
@ -844,7 +844,7 @@ def startWorking(transaction_data, parsed_data, blockinfo):
session.commit() session.commit()
session.close() session.close()
updateLatestTransaction(transaction_data, parsed_data, blockinfo) updateLatestTransaction(transaction_data, parsed_data, blockinfo['height'])
pushData_SSEapi('Contract | Contract incorporated at transaction {} with name {}-{}'.format( pushData_SSEapi('Contract | Contract incorporated at transaction {} with name {}-{}'.format(
transaction_data['txid'], parsed_data['contractName'], parsed_data['contractAddress'])) transaction_data['txid'], parsed_data['contractName'], parsed_data['contractAddress']))
@ -928,7 +928,7 @@ def startWorking(transaction_data, parsed_data, blockinfo):
parsed_data['contractName'], outputlist[0])) parsed_data['contractName'], outputlist[0]))
connection.close() connection.close()
updateLatestTransaction(transaction_data, parsed_data, blockinfo) updateLatestTransaction(transaction_data, parsed_data, blockinfo['height'])
pushData_SSEapi('Trigger | Contract triggered of the name {}-{} is active currentlyt at transaction {}'.format(parsed_data['contractName'], outputlist[0], transaction_data['txid'])) pushData_SSEapi('Trigger | Contract triggered of the name {}-{} is active currentlyt at transaction {}'.format(parsed_data['contractName'], outputlist[0], transaction_data['txid']))
return return
@ -1032,7 +1032,7 @@ def startWorking(transaction_data, parsed_data, blockinfo):
parsed_data['contractName'], outputlist[0])) parsed_data['contractName'], outputlist[0]))
connection.close() connection.close()
updateLatestTransaction(transaction_data, parsed_data, blockinfo) updateLatestTransaction(transaction_data, parsed_data, blockinfo['height'])
pushData_SSEapi('Trigger | Contract triggered of the name {}-{} is active currentlyt at transaction {}'.format( pushData_SSEapi('Trigger | Contract triggered of the name {}-{} is active currentlyt at transaction {}'.format(
parsed_data['contractName'], outputlist[0], transaction_data['txid'])) parsed_data['contractName'], outputlist[0], transaction_data['txid']))