Fix 0x in check gas
This commit is contained in:
parent
7342927e91
commit
bff9d5bfd7
@ -3,7 +3,10 @@ import logging
|
|||||||
|
|
||||||
# external imports
|
# external imports
|
||||||
import celery
|
import celery
|
||||||
from hexathon import strip_0x
|
from hexathon import (
|
||||||
|
strip_0x,
|
||||||
|
add_0x,
|
||||||
|
)
|
||||||
#from chainlib.eth.constant import ZERO_ADDRESS
|
#from chainlib.eth.constant import ZERO_ADDRESS
|
||||||
from chainlib.chain import ChainSpec
|
from chainlib.chain import ChainSpec
|
||||||
from chainlib.eth.address import is_checksum_address
|
from chainlib.eth.address import is_checksum_address
|
||||||
@ -181,6 +184,8 @@ def check_gas(self, tx_hashes_hex, chain_spec_dict, txs_hex=[], address=None, ga
|
|||||||
raise ValueError('invalid address {}'.format(address))
|
raise ValueError('invalid address {}'.format(address))
|
||||||
address = tx_normalize.wallet_address(address)
|
address = tx_normalize.wallet_address(address)
|
||||||
|
|
||||||
|
address = add_0x(address)
|
||||||
|
|
||||||
tx_hashes = []
|
tx_hashes = []
|
||||||
txs = []
|
txs = []
|
||||||
for tx_hash in tx_hashes_hex:
|
for tx_hash in tx_hashes_hex:
|
||||||
|
@ -13,7 +13,6 @@ from chainlib.eth.nonce import RPCNonceOracle
|
|||||||
from chainlib.eth.gas import RPCGasOracle
|
from chainlib.eth.gas import RPCGasOracle
|
||||||
from cic_eth_registry import CICRegistry
|
from cic_eth_registry import CICRegistry
|
||||||
from cic_eth_registry.error import UnknownContractError
|
from cic_eth_registry.error import UnknownContractError
|
||||||
import liveness.linux
|
|
||||||
|
|
||||||
# local imports
|
# local imports
|
||||||
from cic_eth.error import SeppukuError
|
from cic_eth.error import SeppukuError
|
||||||
@ -48,6 +47,7 @@ class BaseTask(celery.Task):
|
|||||||
|
|
||||||
def on_failure(self, exc, task_id, args, kwargs, einfo):
|
def on_failure(self, exc, task_id, args, kwargs, einfo):
|
||||||
if isinstance(exc, SeppukuError):
|
if isinstance(exc, SeppukuError):
|
||||||
|
import liveness.linux
|
||||||
liveness.linux.reset(rundir=self.run_dir)
|
liveness.linux.reset(rundir=self.run_dir)
|
||||||
logg.critical(einfo)
|
logg.critical(einfo)
|
||||||
msg = 'received critical exception {}, calling shutdown'.format(str(exc))
|
msg = 'received critical exception {}, calling shutdown'.format(str(exc))
|
||||||
|
@ -10,7 +10,7 @@ version = (
|
|||||||
0,
|
0,
|
||||||
12,
|
12,
|
||||||
4,
|
4,
|
||||||
'alpha.7',
|
'alpha.8',
|
||||||
)
|
)
|
||||||
|
|
||||||
version_object = semver.VersionInfo(
|
version_object = semver.VersionInfo(
|
||||||
|
@ -1,8 +1,6 @@
|
|||||||
@node cic-eth configuration
|
@node cic-eth configuration
|
||||||
@section Configuration
|
@section Configuration
|
||||||
|
|
||||||
(refer to @code{cic-base} for a general overview of the config pipeline)
|
|
||||||
|
|
||||||
Configuration parameters are grouped by configuration filename.
|
Configuration parameters are grouped by configuration filename.
|
||||||
|
|
||||||
|
|
||||||
@ -40,7 +38,26 @@ Boolean value. If set, the amount of available context for a task in the result
|
|||||||
|
|
||||||
@subsection database
|
@subsection database
|
||||||
|
|
||||||
See ref cic-base when ready
|
@table @var
|
||||||
|
@item host
|
||||||
|
Database host
|
||||||
|
@item port
|
||||||
|
Database port
|
||||||
|
@item name
|
||||||
|
Database name
|
||||||
|
@item user
|
||||||
|
Database user
|
||||||
|
@item password
|
||||||
|
Database password
|
||||||
|
@item engine
|
||||||
|
The engine part of the dsn connection string (@code{postgresql} in @code{postgresql+psycopg2})
|
||||||
|
@item driver
|
||||||
|
The driver part of the dsn connection string (@code{psycopg2} in @code{postgresql+psycopg2})
|
||||||
|
@item pool_size
|
||||||
|
Connection pool size for database drivers that provide connection pooling
|
||||||
|
@item debug
|
||||||
|
Output actual sql queries to logs. Potentially very verbose
|
||||||
|
@end table
|
||||||
|
|
||||||
|
|
||||||
@subsection eth
|
@subsection eth
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
sarafu-faucet~=0.0.7a1
|
sarafu-faucet~=0.0.7a1
|
||||||
cic-eth[tools]~=0.12.4a7
|
cic-eth[tools]~=0.12.4a8
|
||||||
cic-types~=0.1.0a14
|
cic-types~=0.1.0a14
|
||||||
crypto-dev-signer>=0.4.15a1,<=0.4.15
|
crypto-dev-signer>=0.4.15a1,<=0.4.15
|
||||||
faker==4.17.1
|
faker==4.17.1
|
||||||
|
@ -64,6 +64,10 @@ phone_tests = [
|
|||||||
'ussd_pins'
|
'ussd_pins'
|
||||||
]
|
]
|
||||||
|
|
||||||
|
admin_tests = [
|
||||||
|
'local_key',
|
||||||
|
]
|
||||||
|
|
||||||
all_tests = eth_tests + custodial_tests + metadata_tests + phone_tests
|
all_tests = eth_tests + custodial_tests + metadata_tests + phone_tests
|
||||||
|
|
||||||
argparser = argparse.ArgumentParser(description='daemon that monitors transactions in new blocks')
|
argparser = argparse.ArgumentParser(description='daemon that monitors transactions in new blocks')
|
||||||
@ -74,6 +78,7 @@ argparser.add_argument('-i', '--chain-spec', type=str, dest='i', help='chain spe
|
|||||||
argparser.add_argument('--meta-provider', type=str, dest='meta_provider', default='http://localhost:63380', help='cic-meta url')
|
argparser.add_argument('--meta-provider', type=str, dest='meta_provider', default='http://localhost:63380', help='cic-meta url')
|
||||||
argparser.add_argument('--ussd-provider', type=str, dest='ussd_provider', default='http://localhost:63315', help='cic-ussd url')
|
argparser.add_argument('--ussd-provider', type=str, dest='ussd_provider', default='http://localhost:63315', help='cic-ussd url')
|
||||||
argparser.add_argument('--skip-custodial', dest='skip_custodial', action='store_true', help='skip all custodial verifications')
|
argparser.add_argument('--skip-custodial', dest='skip_custodial', action='store_true', help='skip all custodial verifications')
|
||||||
|
argparser.add_argument('--skip-ussd', dest='skip_ussd', action='store_true', help='skip all ussd verifications')
|
||||||
argparser.add_argument('--skip-metadata', dest='skip_metadata', action='store_true', help='skip all metadata verifications')
|
argparser.add_argument('--skip-metadata', dest='skip_metadata', action='store_true', help='skip all metadata verifications')
|
||||||
argparser.add_argument('--exclude', action='append', type=str, default=[], help='skip specified verification')
|
argparser.add_argument('--exclude', action='append', type=str, default=[], help='skip specified verification')
|
||||||
argparser.add_argument('--include', action='append', type=str, help='include specified verification')
|
argparser.add_argument('--include', action='append', type=str, help='include specified verification')
|
||||||
@ -134,6 +139,11 @@ if args.skip_custodial:
|
|||||||
for t in custodial_tests:
|
for t in custodial_tests:
|
||||||
if t not in exclude:
|
if t not in exclude:
|
||||||
exclude.append(t)
|
exclude.append(t)
|
||||||
|
if args.skip_ussd:
|
||||||
|
logg.info('will skip all ussd verifications ({})'.format(','.join(phone_tests)))
|
||||||
|
for t in phone_tests:
|
||||||
|
if t not in exclude:
|
||||||
|
exclude.append(t)
|
||||||
if args.skip_metadata:
|
if args.skip_metadata:
|
||||||
logg.info('will skip all metadata verifications ({})'.format(','.join(metadata_tests)))
|
logg.info('will skip all metadata verifications ({})'.format(','.join(metadata_tests)))
|
||||||
for t in metadata_tests:
|
for t in metadata_tests:
|
||||||
|
Loading…
Reference in New Issue
Block a user