Add gas gifter balance check
This commit is contained in:
parent
0123ce13ea
commit
8a20097934
40
apps/cic-eth/cic_eth/checks/gas.py
Normal file
40
apps/cic-eth/cic_eth/checks/gas.py
Normal file
@ -0,0 +1,40 @@
|
|||||||
|
# standard imports
|
||||||
|
import logging
|
||||||
|
|
||||||
|
# external imports
|
||||||
|
from chainlib.connection import RPCConnection
|
||||||
|
from chainlib.chain import ChainSpec
|
||||||
|
from chainlib.eth.gas import balance
|
||||||
|
|
||||||
|
# local imports
|
||||||
|
from cic_eth.db.models.role import AccountRole
|
||||||
|
from cic_eth.db.models.base import SessionBase
|
||||||
|
|
||||||
|
logg = logging.getLogger().getChild(__name__)
|
||||||
|
|
||||||
|
|
||||||
|
def health(*args, **kwargs):
|
||||||
|
|
||||||
|
session = SessionBase.create_session()
|
||||||
|
|
||||||
|
logg.info('kwargs {} {}'.format(kwargs, args))
|
||||||
|
config = kwargs['config']
|
||||||
|
chain_spec = ChainSpec.from_chain_str(config.get('CIC_CHAIN_SPEC'))
|
||||||
|
|
||||||
|
gas_provider = AccountRole.get_address('GAS_GIFTER', session=session)
|
||||||
|
session.close()
|
||||||
|
|
||||||
|
rpc = RPCConnection.connect(chain_spec, 'default')
|
||||||
|
o = balance(gas_provider)
|
||||||
|
r = rpc.do(o)
|
||||||
|
try:
|
||||||
|
r = int(r, 16)
|
||||||
|
except TypeError:
|
||||||
|
r = int(r)
|
||||||
|
gas_min = int(config.get('ETH_GAS_GIFTER_MINIMUM_BALANCE'))
|
||||||
|
if r < gas_min:
|
||||||
|
logg.error('EEK! gas gifter has balance {}, below minimum {}'.format(r, gas_min))
|
||||||
|
return False
|
||||||
|
|
||||||
|
|
||||||
|
return True
|
@ -139,6 +139,9 @@ RPCConnection.register_location(config.get('SIGNER_SOCKET_PATH'), chain_spec, 's
|
|||||||
|
|
||||||
Otx.tracing = config.true('TASKS_TRACE_QUEUE_STATUS')
|
Otx.tracing = config.true('TASKS_TRACE_QUEUE_STATUS')
|
||||||
|
|
||||||
|
import cic_eth.checks.gas
|
||||||
|
if not cic_eth.checks.gas.health(config=config):
|
||||||
|
raise RuntimeError()
|
||||||
|
|
||||||
def main():
|
def main():
|
||||||
argv = ['worker']
|
argv = ['worker']
|
||||||
|
@ -94,3 +94,8 @@ class CriticalWeb3AndSignerTask(CriticalTask):
|
|||||||
def hello(self):
|
def hello(self):
|
||||||
time.sleep(0.1)
|
time.sleep(0.1)
|
||||||
return id(SessionBase.create_session)
|
return id(SessionBase.create_session)
|
||||||
|
|
||||||
|
|
||||||
|
@celery_app.task()
|
||||||
|
def shutdown(self):
|
||||||
|
celery.app.control.shutdown()
|
||||||
|
@ -1,8 +1,3 @@
|
|||||||
[eth]
|
[eth]
|
||||||
#ws_provider = ws://localhost:8546
|
|
||||||
#ttp_provider = http://localhost:8545
|
|
||||||
provider = http://localhost:63545
|
provider = http://localhost:63545
|
||||||
gas_provider_address =
|
gas_gifter_minimum_balance = 1000000000000000
|
||||||
#chain_id =
|
|
||||||
abi_dir = /home/lash/src/ext/cic/grassrootseconomics/cic-contracts/abis
|
|
||||||
account_accounts_index_writer =
|
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
[signer]
|
[signer]
|
||||||
socket_path = /tmp/crypto-dev-signer/jsonrpc.ipc
|
socket_path = ipc:///tmp/crypto-dev-signer/jsonrpc.ipc
|
||||||
secret = deedbeef
|
secret = deedbeef
|
||||||
database_name = signer_test
|
database_name = signer_test
|
||||||
dev_keys_path =
|
dev_keys_path =
|
||||||
|
Loading…
Reference in New Issue
Block a user