Implement new chainlib arg setup, rename deploy to publish

This commit is contained in:
lash 2023-02-11 05:41:41 +00:00
parent aab2107efc
commit 243f0e325c
Signed by: lash
GPG Key ID: 21D2E7BB88C2A746
6 changed files with 216 additions and 176 deletions

View File

@ -1,5 +1,4 @@
"""Adds a new Address declaration
.. moduleauthor:: Louis Holbrook <dev@holbrook.no>
.. pgp:: 0826EDA1702D1E87C6E2875121D2E7BB88C2A746
@ -21,6 +20,19 @@ from hexathon import (
add_0x,
strip_0x,
)
from chainlib.eth.cli.arg import (
Arg,
ArgFlag,
process_args,
)
from chainlib.eth.cli.config import (
Config,
process_config,
)
from chainlib.eth.cli.log import process_log
from chainlib.eth.settings import process_settings
from chainlib.settings import ChainSettings
# local imports
from eth_address_declarator.declarator import AddressDeclarator
@ -28,58 +40,57 @@ from eth_address_declarator.declarator import AddressDeclarator
logging.basicConfig(level=logging.WARNING)
logg = logging.getLogger()
script_dir = os.path.dirname(__file__)
data_dir = os.path.join(script_dir, '..', 'data')
arg_flags = chainlib.eth.cli.argflag_std_write | chainlib.eth.cli.Flag.EXEC
argparser = chainlib.eth.cli.ArgumentParser(arg_flags)
argparser.add_argument('-a', '--address', type=str, help='Address to add declaration for')
argparser.add_positional('declaration', type=str, help='SHA256 sum of endorsement data to add')
def process_config_local(config, arg, args, flags):
hsh = strip_0x(config.get('_POSARG'))
if len(hsh) != 64:
raise ValueError('declaration hash must be 32 bytes')
config.add(hsh, '_DECLARATION')
return config
arg_flags = ArgFlag()
arg = Arg(arg_flags)
flags = arg_flags.STD_WRITE | arg_flags.WALLET | arg_flags.EXEC
argparser = chainlib.eth.cli.ArgumentParser()
argparser = process_args(argparser, arg, flags)
argparser.add_argument('declaration', type=str, help='SHA256 sum of endorsement data to add')
args = argparser.parse_args()
extra_args = {
'address': None,
'declaration': None,
}
config = chainlib.eth.cli.Config.from_args(args, arg_flags, extra_args=extra_args, default_fee_limit=AddressDeclarator.gas())
logg = process_log(args, logg)
wallet = chainlib.eth.cli.Wallet()
wallet.from_config(config)
config = Config()
config = process_config(config, arg, args, flags, positional_name='declaration')
config = process_config_local(config, arg, args, flags)
logg.debug('config loaded:\n{}'.format(config))
rpc = chainlib.eth.cli.Rpc(wallet=wallet)
conn = rpc.connect_by_config(config)
chain_spec = ChainSpec.from_chain_str(config.get('CHAIN_SPEC'))
settings = ChainSettings()
settings = process_settings(settings, config)
logg.debug('settings loaded:\n{}'.format(settings))
def main():
signer = rpc.get_signer()
signer_address = rpc.get_sender_address()
conn = settings.get('CONN')
c = AddressDeclarator(
settings.get('CHAIN_SPEC'),
signer=settings.get('SIGNER'),
gas_oracle=settings.get('FEE_ORACLE'),
nonce_oracle=settings.get('NONCE_ORACLE'),
)
subject_address = to_checksum_address(settings.get('RECIPIENT'))
contract_address = to_checksum_address(settings.get('EXEC'))
gas_oracle = rpc.get_gas_oracle()
nonce_oracle = rpc.get_nonce_oracle()
(tx_hash_hex, o) = c.add_declaration(
settings.get('EXEC'),
settings.get('SENDER_ADDRESS'),
settings.get('RECIPIENT'),
add_0x(config.get('_DECLARATION')),
)
c = AddressDeclarator(chain_spec, signer=signer, gas_oracle=gas_oracle, nonce_oracle=nonce_oracle)
subject_address = to_checksum_address(config.get('_ADDRESS'))
if not config.true('_UNSAFE') and subject_address != add_0x(config.get('_ADDRESS')):
raise ValueError('invalid checksum address for subject_address')
contract_address = to_checksum_address(config.get('_EXEC_ADDRESS'))
if not config.true('_UNSAFE') and contract_address != add_0x(config.get('_EXEC_ADDRESS')):
raise ValueError('invalid checksum address for contract')
declaration = config.get('_DECLARATION')
declaration_bytes = bytes.fromhex(strip_0x(declaration))
if len(declaration_bytes) != 32:
raise ValueError('declaration hash must be 32 bytes')
declaration = add_0x(declaration)
(tx_hash_hex, o) = c.add_declaration(contract_address, signer_address, subject_address, declaration)
if config.get('_RPC_SEND'):
if settings.get('RPC_SEND'):
conn.do(o)
if config.get('_WAIT'):
if config.true('_WAIT'):
r = conn.wait(tx_hash_hex)
if r['status'] == 0:
sys.stderr.write('EVM revert while deploying contract. Wish I had more to tell you')

View File

@ -1,84 +0,0 @@
"""Deploys address declaration contract
.. moduleauthor:: Louis Holbrook <dev@holbrook.no>
.. pgp:: 0826EDA1702D1E87C6E2875121D2E7BB88C2A746
"""
# standard imports
import sys
import os
import json
import argparse
import logging
from hexathon import (
add_0x,
strip_0x,
)
# external imports
import chainlib.eth.cli
from chainlib.chain import ChainSpec
from chainlib.eth.connection import EthHTTPConnection
from chainlib.eth.tx import receipt
# local imports
from eth_address_declarator.declarator import AddressDeclarator
logging.basicConfig(level=logging.WARNING)
logg = logging.getLogger()
arg_flags = chainlib.eth.cli.argflag_std_write
argparser = chainlib.eth.cli.ArgumentParser(arg_flags)
argparser.add_argument('owner_description_hash', type=str, help='SHA256 of description metadata of contract deployer')
args = argparser.parse_args()
extra_args = {
'owner_description_hash': None,
}
config = chainlib.eth.cli.Config.from_args(args, arg_flags, extra_args=extra_args, default_fee_limit=AddressDeclarator.gas())
wallet = chainlib.eth.cli.Wallet()
wallet.from_config(config)
rpc = chainlib.eth.cli.Rpc(wallet=wallet)
conn = rpc.connect_by_config(config)
chain_spec = ChainSpec.from_chain_str(config.get('CHAIN_SPEC'))
def main():
signer = rpc.get_signer()
signer_address = rpc.get_sender_address()
gas_oracle = rpc.get_gas_oracle()
nonce_oracle = rpc.get_nonce_oracle()
c = AddressDeclarator(chain_spec, signer=signer, gas_oracle=gas_oracle, nonce_oracle=nonce_oracle)
owner_description_hash = config.get('_OWNER_DESCRIPTION_HASH')
owner_description_hash_bytes = bytes.fromhex(strip_0x(owner_description_hash))
if len(owner_description_hash_bytes) != 32:
raise ValueError('chain config hash must be 32 bytes')
owner_description_hash = add_0x(owner_description_hash)
(tx_hash_hex, o) = c.constructor(signer_address, owner_description_hash)
if config.get('_RPC_SEND'):
conn.do(o)
if config.get('_WAIT'):
r = conn.wait(tx_hash_hex)
if r['status'] == 0:
sys.stderr.write('EVM revert while deploying contract. Wish I had more to tell you')
sys.exit(1)
# TODO: pass through translator for keys (evm tester uses underscore instead of camelcase)
address = r['contractAddress']
print(address)
else:
print(tx_hash_hex)
else:
print(o)
if __name__ == '__main__':
main()

View File

@ -0,0 +1,110 @@
"""Deploys address declaration contract
.. moduleauthor:: Louis Holbrook <dev@holbrook.no>
.. pgp:: 0826EDA1702D1E87C6E2875121D2E7BB88C2A746
"""
# standard imports
import sys
import os
import json
import argparse
import logging
from hexathon import (
add_0x,
strip_0x,
)
# external imports
import chainlib.eth.cli
from chainlib.chain import ChainSpec
from chainlib.eth.connection import EthHTTPConnection
from chainlib.eth.tx import receipt
from chainlib.eth.cli.arg import (
Arg,
ArgFlag,
process_args,
)
from chainlib.eth.cli.config import (
Config,
process_config,
)
from chainlib.eth.cli.log import process_log
from chainlib.eth.settings import process_settings
from chainlib.settings import ChainSettings
from chainlib.eth.constant import ZERO_CONTENT
# local imports
from eth_address_declarator.declarator import AddressDeclarator
logging.basicConfig(level=logging.WARNING)
logg = logging.getLogger()
def process_config_local(config, arg, args, flags):
hsh = args.owner_description_hash
if hsh == None:
hsh = ZERO_CONTENT
hsh = add_0x(hsh)
config.add(hsh, '_OWNER_DESCRIPTION_HASH')
return config
arg_flags = ArgFlag()
arg = Arg(arg_flags)
flags = arg_flags.STD_WRITE
argparser = chainlib.eth.cli.ArgumentParser()
argparser = process_args(argparser, arg, flags)
argparser.add_argument('--owner-description-hash', type=str, help='SHA256 of description metadata of contract deployer')
args = argparser.parse_args()
logg = process_log(args, logg)
config = Config()
config = process_config(config, arg, args, flags)
config = process_config_local(config, arg, args, flags)
logg.debug('config loaded:\n{}'.format(config))
settings = ChainSettings()
settings = process_settings(settings, config)
logg.debug('settings loaded:\n{}'.format(settings))
def main():
conn = settings.get('CONN')
c = AddressDeclarator(
settings.get('CHAIN_SPEC'),
signer=settings.get('SIGNER'),
gas_oracle=settings.get('FEE_ORACLE'),
nonce_oracle=settings.get('NONCE_ORACLE'),
)
owner_description_hash = config.get('_OWNER_DESCRIPTION_HASH')
owner_description_hash_bytes = bytes.fromhex(strip_0x(owner_description_hash))
if len(owner_description_hash_bytes) != 32:
raise ValueError('chain config hash must be 32 bytes')
(tx_hash_hex, o) = c.constructor(
settings.get('SENDER_ADDRESS'),
owner_description_hash,
)
if settings.get('RPC_SEND'):
conn.do(o)
if config.true('_WAIT'):
r = conn.wait(tx_hash_hex)
if r['status'] == 0:
sys.stderr.write('EVM revert while deploying contract. Wish I had more to tell you')
sys.exit(1)
# TODO: pass through translator for keys (evm tester uses underscore instead of camelcase)
address = r['contractAddress']
print(address)
else:
print(tx_hash_hex)
else:
print(o)
if __name__ == '__main__':
main()

View File

@ -22,6 +22,19 @@ from hexathon import (
add_0x,
strip_0x,
)
from chainlib.eth.cli.arg import (
Arg,
ArgFlag,
process_args,
)
from chainlib.eth.cli.config import (
Config,
process_config,
)
from chainlib.eth.cli.log import process_log
from chainlib.eth.settings import process_settings
from chainlib.settings import ChainSettings
# local imports
from eth_address_declarator import Declarator
@ -30,27 +43,38 @@ from eth_address_declarator.declarator import AddressDeclarator
logging.basicConfig(level=logging.WARNING)
logg = logging.getLogger()
#argparser.add_argument('--resolve', action='store_true', help='Attempt to resolve the hashes to actual content')
#argparser.add_argument('--resolve-http', dest='resolve_http', type=str, help='Base url to look up content hashes')
arg_flags = chainlib.eth.cli.argflag_std_read | chainlib.eth.cli.Flag.EXEC | chainlib.eth.cli.Flag.WALLET
argparser = chainlib.eth.cli.ArgumentParser(arg_flags, arg_long={'-a': '--declarator-address'})
argparser.add_positional('address', type=str, help='Ethereum declaration address to look up')
def process_config_local(config, arg, args, flags):
a = strip_0x(config.get('_POSARG'))
ac = to_checksum_address(a)
if config.true('_UNSAFE'):
a = ac
else:
if a != ac:
raise ValueError('declarator is not a valid checksum address')
config.add(a, '_DECLARATOR')
return config
arg_flags = ArgFlag()
arg = Arg(arg_flags)
flags = arg_flags.STD_WRITE | arg_flags.WALLET | arg_flags.EXEC
argparser = chainlib.eth.cli.ArgumentParser()
argparser = process_args(argparser, arg, flags)
argparser.add_argument('declarator', type=str, help='Ethereum declaration address to look up')
args = argparser.parse_args()
extra_args = {
'address': None,
}
config = chainlib.eth.cli.Config.from_args(args, arg_flags, extra_args=extra_args, default_fee_limit=AddressDeclarator.gas())
logg = process_log(args, logg)
wallet = chainlib.eth.cli.Wallet()
wallet.from_config(config)
config = Config()
config = process_config(config, arg, args, flags, positional_name='declarator')
config = process_config_local(config, arg, args, flags)
logg.debug('config loaded:\n{}'.format(config))
rpc = chainlib.eth.cli.Rpc()
conn = rpc.connect_by_config(config)
chain_spec = ChainSpec.from_chain_str(config.get('CHAIN_SPEC'))
declarator_address = config.get('_WALLET_ADDRESS')
settings = ChainSettings()
settings = process_settings(settings, config)
logg.debug('settings loaded:\n{}'.format(settings))
def out_element(e, w=sys.stdout):
@ -68,41 +92,20 @@ def ls(ifc, conn, contract_address, declarator_address, subject_address, w=sys.s
def main():
c = Declarator(chain_spec)
c = Declarator(
settings.get('CHAIN_SPEC')
)
contract_address = to_checksum_address(config.get('_EXEC_ADDRESS'))
if not config.true('_UNSAFE') and contract_address != add_0x(config.get('_EXEC_ADDRESS')):
raise ValueError('invalid checksum address for contract')
declarator_address = to_checksum_address(config.get('_DECLARATOR_ADDRESS'))
if not config.true('_UNSAFE') and declarator_address != add_0x(config.get('_DECLARATOR_ADDRESS')):
raise ValueError('invalid checksum address for declarator')
subject_address = to_checksum_address(config.get('_ADDRESS'))
if not config.true('_UNSAFE') and subject_address != add_0x(config.get('_ADDRESS')):
raise ValueError('invalid checksum address for subject')
ls(c, conn, contract_address, declarator_address, subject_address)
ls(
c,
settings.get('CONN'),
settings.get('EXEC'),
config.get('_DECLARATOR'),
settings.get('RECIPIENT'),
)
declarations = []
# for d in declarations:
# if not args.resolve:
# print(d.hex())
# continue
# if args.resolve_http:
# try:
# r = try_sha256(d)
# print(r)
# continue
# except urllib.error.HTTPError:
# pass
# try:
# print(try_utf8(d))
# except UnicodeDecodeError:
# pass
if __name__ == '__main__':
main()

View File

@ -36,6 +36,6 @@ packages =
[options.entry_points]
console_scripts =
eth-address-declarator-deploy = eth_address_declarator.runnable.deploy:main
eth-address-declarator-publish = eth_address_declarator.runnable.publish:main
eth-address-declarator-add = eth_address_declarator.runnable.add:main
eth-address-declarator-view = eth_address_declarator.runnable.view:main

File diff suppressed because one or more lines are too long