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

Update contract status in time_actions table after external committee trigger

Browse Source
This commit is contained in:
Vivek Teega 2022-11-23 20:08:17 +00:00
parent 9dd69065c8
commit 8b112bf0b3
1 changed files with 5 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
tracktokens_smartcontracts.py
View File

@ -2503,20 +2503,16 @@ def processTransaction(transaction_data, parsed_data, blockinfo):
# check the status of the contract # check the status of the contract
connection = create_database_connection('system_dbs', {'db_name':'system'}) connection = create_database_connection('system_dbs', {'db_name':'system'})
contractStatus = connection.execute( contractStatus = connection.execute(f"select status from activecontracts where contractName=='{parsed_data['contractName']}' and contractAddress='{outputlist[0]}'").fetchall()[0][0]
f"select status from activecontracts where contractName=='{parsed_data['contractName']}' and contractAddress='{outputlist[0]}'").fetchall()[
0][0]
connection.close() connection.close()
contractList = [] contractList = []
if contractStatus == 'closed': if contractStatus == 'closed':
logger.info( logger.info(f"Transaction {transaction_data['txid']} closed as Smart contract {parsed_data['contractName']} at the {outputlist[0]} is closed")
f"Transaction {transaction_data['txid']} closed as Smart contract {parsed_data['contractName']} at the {outputlist[0]} is closed")
# Store transfer as part of RejectedContractTransactionHistory # Store transfer as part of RejectedContractTransactionHistory
session = create_database_session_orm('system_dbs', {'db_name': "system"}, SystemBase) session = create_database_session_orm('system_dbs', {'db_name': "system"}, SystemBase)
blockchainReference = neturl + 'tx/' + transaction_data['txid'] blockchainReference = neturl + 'tx/' + transaction_data['txid']
session.add( session.add(RejectedContractTransactionHistory(transactionType='trigger',
RejectedContractTransactionHistory(transactionType='trigger',
contractName=parsed_data['contractName'], contractName=parsed_data['contractName'],
contractAddress=outputlist[0], contractAddress=outputlist[0],
sourceFloAddress=inputadd, sourceFloAddress=inputadd,
@ -2722,13 +2718,8 @@ def processTransaction(transaction_data, parsed_data, blockinfo):
session.close() session.close()
connection = create_database_connection('system_dbs', {'db_name':'system'}) connection = create_database_connection('system_dbs', {'db_name':'system'})
connection.execute( connection.execute('update activecontracts set status="closed", closeDate="{}" where contractName="{}" and contractAddress="{}"'.format(transaction_data['blocktime'], parsed_data['contractName'], outputlist[0]))
'update activecontracts set status="closed" where contractName="{}" and contractAddress="{}"'.format( connection.execute('update time_actions set status="closed" where contractName="{}" and contractAddress="{}"'.format(parsed_data['contractName'], outputlist[0]))
parsed_data['contractName'], outputlist[0]))
connection.execute(
'update activecontracts set closeDate="{}" where contractName="{}" and contractAddress="{}"'.format(
transaction_data['blocktime'],
parsed_data['contractName'], outputlist[0]))
connection.close() connection.close()
updateLatestTransaction(transaction_data, parsed_data, f"{parsed_data['contractName']}-{outputlist[0]}") updateLatestTransaction(transaction_data, parsed_data, f"{parsed_data['contractName']}-{outputlist[0]}")