Merge remote-tracking branch 'origin/0.0.10-dev' into lash/args-only

CHANGELOG

@@ -1,12 +1,3 @@
-- 0.0.23:
-	* Make get block args and responses compatible with picky golang marhaling in geth
-- 0.0.22:
-	* Enable unpack of pre EIP-155 transactions
-	* Allow missing status property of receipts in non-strict modes
-- 0.0.21:
-	* Remove warnings from cytoolz/rlp in funga-eth
-- 0.0.15:
-	* Correct inverted addess checksum check for gas cli
-- 0.0.5-unreleased:
+- 0.0.5-pending
 	* Receive all ethereum components from chainlib package
 	* Make settings configurable

chainlib/eth/address.py

@@ -4,7 +4,7 @@ from hexathon import (
         strip_0x,
         uniform,
     )
-from funga.eth.encoding import (
+from crypto_dev_signer.encoding import (
         is_address,
         is_checksum_address,
         to_checksum_address,
@@ -42,7 +42,3 @@ class AddressChecksum:
         :returns: Checksum address
         """
         return to_checksum_address(v)
-
-
-def is_same_address(a, b):
-    return uniform(strip_0x(a)) == uniform(strip_0x(b))

chainlib/eth/block.py

@@ -4,7 +4,7 @@ from chainlib.block import Block as BaseBlock
 from hexathon import (
         add_0x,
         strip_0x,
-        compact,
+        even,
         )
 
 # local imports
@@ -34,9 +34,7 @@ def block_by_hash(hsh, include_tx=True, id_generator=None):
 def block_by_number(n, include_tx=True, id_generator=None):
     """Implements chainlib.interface.ChainInterface method
     """
-    hx = strip_0x(hex(n))
-    nhx = add_0x(compact(hx), compact_value=True)
-    print('>>>>> hx {}'.format(hx))
+    nhx = add_0x(even(hex(n)[2:]))
     j = JSONRPCRequest(id_generator)
     o = j.template()
     o['method'] = 'eth_getBlockByNumber'
@@ -62,20 +60,6 @@ def transaction_count(block_hash, id_generator=None):
     return j.finalize(o)
 
 
-def syncing(id_generator=None):
-    """Request the syncing state of the node
-
-    :param id_generator: JSONRPC id generator
-    :type id_generator: JSONRPCIdGenerator
-    :rtype: dict
-    :returns: rpc query object
-    """
-    j = JSONRPCRequest(id_generator)
-    o = j.template()
-    o['method'] = 'eth_syncing'
-    return j.finalize(o)
-
-
 class Block(BaseBlock):
     """Encapsulates an Ethereum block
 

chainlib/eth/cli.py

@@ -1,8 +1,22 @@
+# standard imports
+import os
+import logging
+
 # external imports
-from chainlib.cli import Rpc as BaseRpc
-from chainlib.eth.connection import EthHTTPConnection
+from chainlib.cli import (
+        ArgumentParser,
+        argflag_std_read,
+        argflag_std_write,
+        argflag_std_base,
+        Config as BaseConfig,
+        Wallet as BaseWallet,
+        Rpc as BaseRpc, Flag,
+    )
+from crypto_dev_signer.eth.signer import ReferenceSigner as EIP155Signer
 
 # local imports
+from chainlib.eth.address import AddressChecksum
+from chainlib.eth.connection import EthHTTPConnection
 from chainlib.eth.gas import (
         OverrideGasOracle,
         RPCGasOracle,
@@ -12,6 +26,20 @@ from chainlib.eth.nonce import (
         RPCNonceOracle,
         )
 
+logg = logging.getLogger(__name__)
+
+script_dir = os.path.dirname(os.path.realpath(__file__))
+
+
+class Wallet(BaseWallet):
+    """Convenience constructor to set Ethereum defaults for chainlib cli Wallet object
+
+    :param checksummer: Address checksummer object
+    :type checksummer: Implementation of chainlib.eth.address.AddressChecksum
+    """
+    def __init__(self, checksummer=AddressChecksum):
+        super(Wallet, self).__init__(EIP155Signer, checksummer=checksummer)
+
 
 # TODO: how is the keystore implemented in rpc here?
 class Rpc(BaseRpc):
@@ -69,3 +97,27 @@ class Rpc(BaseRpc):
 
     def get_gas_oracle(self):
         return self.get_fee_oracle()
+
+
+class Config(BaseConfig):
+    """Convenience constructor to set Ethereum defaults for the chainlib cli config object
+    """
+    default_base_config_dir = os.path.join(script_dir, 'data', 'config')
+    default_fee_limit = 21000
+
+    @classmethod
+    def from_args(cls, args, arg_flags=0x0f, env=os.environ, extra_args={}, base_config_dir=None, default_config_dir=None, user_config_dir=None, default_fee_limit=None, logger=None, load_callback=None):
+        super(Config, cls).override_defaults(base_dir=cls.default_base_config_dir)
+        if default_fee_limit == None:
+            default_fee_limit = cls.default_fee_limit
+        config = BaseConfig.from_args(args, arg_flags=arg_flags, env=env, extra_args=extra_args, base_config_dir=base_config_dir, default_config_dir=default_config_dir, user_config_dir=user_config_dir, default_fee_limit=default_fee_limit, logger=logger, load_callback=load_callback)
+
+        if not config.get('RPC_DIALECT'):
+            config.add('default', 'RPC_DIALECT', exists_ok=True)
+        elif config.get('RPC_DIALECT') not in [
+                'openethereum',
+                'default',
+                ]:
+            raise ValueError('unknown rpc dialect {}'.format(config.get('RPC_DIALECT'))) 
+
+        return config

chainlib/eth/cli/__init__.py

@@ -1,4 +0,0 @@
-from .arg import *
-from .config import Config
-from .rpc import Rpc
-from .wallet import Wallet

chainlib/eth/cli/arg.py

@@ -1,9 +0,0 @@
-# external imports
-from chainlib.cli import (
-        ArgumentParser,
-        argflag_std_read,
-        argflag_std_write,
-        argflag_std_base,
-        reset as argflag_reset,
-        Flag,        
-    )

chainlib/eth/cli/config.py

@@ -1,33 +0,0 @@
-# standard imports
-import os
-
-# external imports
-from chainlib.cli import Config as BaseConfig
-
-script_dir = os.path.dirname(os.path.realpath(__file__))
-data_dir = os.path.join(script_dir, '..')
-
-
-class Config(BaseConfig):
-    """Convenience constructor to set Ethereum defaults for the chainlib cli config object
-    """
-    default_base_config_dir = os.path.join(data_dir, 'data', 'config')
-    default_fee_limit = 21000
-
-    @classmethod
-    def from_args(cls, args, arg_flags=0x0f, env=os.environ, extra_args={}, base_config_dir=None, default_config_dir=None, user_config_dir=None, default_fee_limit=None, logger=None, load_callback=None):
-        super(Config, cls).override_defaults(base_dir=cls.default_base_config_dir)
-        if default_fee_limit == None:
-            default_fee_limit = cls.default_fee_limit
-        config = BaseConfig.from_args(args, arg_flags=arg_flags, env=env, extra_args=extra_args, base_config_dir=base_config_dir, default_config_dir=default_config_dir, user_config_dir=user_config_dir, default_fee_limit=default_fee_limit, logger=logger, load_callback=load_callback)
-
-        if not config.get('RPC_DIALECT'):
-            config.add('default', 'RPC_DIALECT', exists_ok=True)
-        elif config.get('RPC_DIALECT') not in [
-                'openethereum',
-                'default',
-                ]:
-            raise ValueError('unknown rpc dialect {}'.format(config.get('RPC_DIALECT'))) 
-
-        return config
-

chainlib/eth/cli/encode.py

@@ -1,103 +0,0 @@
-# standard imports
-import re
-import logging
-
-# external imports
-from chainlib.eth.contract import (
-        ABIContractType,
-        ABIContractEncoder,
-        )
-
-logg = logging.getLogger(__name__)
-
-
-class CLIEncoder(ABIContractEncoder):
-
-    __re_uint = r'^([uU])[int]*([0-9]+)?$'
-    __re_bytes = r'^([bB])[ytes]*([0-9]+)?$'
-    __re_string = r'^([sS])[tring]*$'
-    __re_address = r'^([aA])[ddress]*?$'
-    __translations = [
-            'to_uint',
-            'to_bytes',
-            'to_string',
-            'to_address',
-            ]
-
-    def __init__(self, signature=None):
-        super(CLIEncoder, self).__init__()
-        self.signature = signature
-        if signature != None:
-            self.method(signature)
-
-    def to_uint(self, typ):
-        s = None
-        a = None
-        m = re.match(self.__re_uint, typ)
-        if m == None:
-            return None
-
-        n = m.group(2)
-        if m.group(2) == None:
-            n = 256
-        s = 'UINT256'.format(m.group(2))
-        a = getattr(ABIContractType, s)
-        return (s, a)
-
-
-    def to_bytes(self, typ):
-        s = None
-        a = None
-        m = re.match(self.__re_bytes, typ)
-        if m == None:
-            return None
-        
-        n = m.group(2)
-        if n == None:
-            n = 32
-        s = 'BYTES{}'.format(n)
-        a = getattr(ABIContractType, s)
-        return (s, a)
-
-
-    def to_address(self, typ):
-        s = None
-        a = None
-        m = re.match(self.__re_address, typ)
-        if m == None:
-            return None
-        
-        s = 'ADDRESS'
-        a = getattr(ABIContractType, s)
-        return (s, a)
-
-
-    def to_string(self, typ):
-        m = re.match(self.__re_string, typ)
-        if m == None:
-            return None
-        s = 'STRING'
-        a = getattr(ABIContractType, s)
-        return (s, a)
-
-
-    def translate_type(self, typ):
-        r = None
-        for tr in self.__translations:
-            r = getattr(self, tr)(typ)
-            if r != None:
-                break
-        if r == None:
-            raise ValueError('no translation for type {}'.format(typ))
-        logg.debug('type {} translated to {}'.format(typ, r[0]))
-        return r[1]
-
-
-    def add_from(self, arg):
-        logg.debug('arg {}'.format(arg))
-        (typ, val) = arg.split(':', maxsplit=1)
-        real_typ = self.translate_type(typ)
-        if self.signature != None:
-            self.typ(real_typ)
-        fn = getattr(self, real_typ.value)
-        fn(val)

chainlib/eth/cli/wallet.py

@@ -1,20 +0,0 @@
-# external imports
-from funga.eth.signer import EIP155Signer
-from funga.eth.keystore.dict import DictKeystore
-from chainlib.cli import Wallet as BaseWallet
-
-# local imports
-from chainlib.eth.address import AddressChecksum
-
-
-class Wallet(BaseWallet):
-    """Convenience constructor to set Ethereum defaults for chainlib cli Wallet object
-
-    :param checksummer: Address checksummer object
-    :type checksummer: Implementation of chainlib.eth.address.AddressChecksum
-    """
-    def __init__(self, checksummer=AddressChecksum):
-        super(Wallet, self).__init__(EIP155Signer, checksummer=checksummer, keystore=DictKeystore())
-
-
-

chainlib/eth/connection.py

@@ -36,7 +36,6 @@ from chainlib.jsonrpc import (
 from chainlib.eth.tx import (
         unpack,
         )
-from potaahto.symbols import snake_and_camel
 
 logg = logging.getLogger(__name__)
 
@@ -89,16 +88,11 @@ class EthHTTPConnection(JSONRPCHTTPConnection):
 
             e = jsonrpc_result(r, error_parser)
             if e != None:
-                e = snake_and_camel(e)
-                # In openethereum we encounter receipts that have NONE block hashes and numbers. WTF...
-                logg.debug('({}) poll receipt received {}'.format(str(self), r))
-                if e['block_hash'] == None:
-                    logg.warning('poll receipt attempt {} returned receipt but with a null block hash value!'.format(i))
-                else:
-                    logg.debug('e {}'.format(strip_0x(e['status'])))
-                    if strip_0x(e['status']) == '00':
-                        raise RevertEthException(tx_hash_hex)
-                    return e
+                logg.debug('({}) poll receipt completed {}'.format(str(self), r))
+                logg.debug('e {}'.format(strip_0x(e['status'])))
+                if strip_0x(e['status']) == '00':
+                    raise RevertEthException(tx_hash_hex)
+                return e
 
             if timeout > 0.0:
                 delta = (datetime.datetime.utcnow() - t) + datetime.timedelta(seconds=delay)

chainlib/eth/data/config/config.ini

@@ -1,13 +1,13 @@
 [rpc]
+http_provider = http://localhost:8545
 provider = http://localhost:8545
 auth =
 credentials =
 dialect = default
 scheme = http
-verify = 1
 
 [chain]
-spec = evm:berlin:1:ethereum
+spec = evm:ethereum:1
 
 [wallet]
 key_file = 

chainlib/eth/gas.py

@@ -6,7 +6,7 @@ from hexathon import (
         add_0x,
         strip_0x,
         )
-from funga.eth.transaction import EIP155Transaction
+from crypto_dev_signer.eth.transaction import EIP155Transaction
 
 # local imports
 from chainlib.fee import FeeOracle
@@ -55,7 +55,7 @@ def balance(address, id_generator=None, height=BlockSpec.LATEST):
     j = JSONRPCRequest(id_generator)
     o = j.template()
     o['method'] = 'eth_getBalance'
-    o['params'].append(add_0x(address))
+    o['params'].append(address)
     height = to_blockheight_param(height)
     o['params'].append(height)
     return j.finalize(o)

chainlib/eth/nonce.py

@@ -44,7 +44,7 @@ class NonceOracle(BaseNonceOracle):
     """
     def __init__(self, address, id_generator=None):
         self.id_generator = id_generator
-        super(NonceOracle, self).__init__(add_0x(address))
+        super(NonceOracle, self).__init__(address)
 
 
     def get_nonce(self):

chainlib/eth/pytest/fixtures_ethtester.py

@@ -5,8 +5,8 @@ import logging
 # external imports
 import eth_tester
 import pytest
-from funga.eth.signer import EIP155Signer
-from funga.eth.keystore.dict import DictKeystore
+from crypto_dev_signer.eth.signer import ReferenceSigner as EIP155Signer
+from crypto_dev_signer.keystore.dict import DictKeystore
 
 # local imports
 from chainlib.eth.unittest.base import *

chainlib/eth/pytest/fixtures_signer.py

@@ -3,6 +3,7 @@
 
 # external imports
 import pytest
+#from crypto_dev_signer.eth.signer import ReferenceSigner as EIP155Signer
 
 
 @pytest.fixture(scope='function')

chainlib/eth/runnable/balance.py

@@ -24,7 +24,7 @@ from chainlib.eth.gas import (
         balance,
         )
 from chainlib.chain import ChainSpec
-from funga.eth.signer import EIP155Signer
+from crypto_dev_signer.eth.signer import ReferenceSigner as EIP155Signer
 
 logging.basicConfig(level=logging.WARNING)
 logg = logging.getLogger()

chainlib/eth/runnable/count.py

@@ -15,8 +15,8 @@ from chainlib.eth.connection import EthHTTPConnection
 from chainlib.eth.tx import count
 from chainlib.chain import ChainSpec
 from chainlib.jsonrpc import IntSequenceGenerator
-from funga.eth.keystore.dict import DictKeystore
-from funga.eth.signer import EIP155Signer
+from crypto_dev_signer.keystore.dict import DictKeystore
+from crypto_dev_signer.eth.signer import ReferenceSigner as EIP155Signer
 from hexathon import add_0x
 
 logging.basicConfig(level=logging.WARNING)
@@ -43,7 +43,7 @@ conn = rpc.connect_by_config(config)
 
 def main():
     # TODO: should tolerate if address not prefixed with 0x 
-    o = count(add_0x(holder_address), id_generator=rpc.id_generator)
+    o = count(holder_address, id_generator=rpc.id_generator)
     r = conn.do(o)
     count_result = None
     try:

chainlib/eth/runnable/encode.py

@@ -1,168 +0,0 @@
-# SPDX-License-Identifier: GPL-3.0-or-later
-
-# standard imports
-import io
-import sys
-import os
-import json
-import argparse
-import logging
-import urllib
-import sha3
-
-# external imports
-import chainlib.eth.cli
-from chainlib.eth.cli.encode import CLIEncoder
-from funga.eth.signer import EIP155Signer
-from funga.eth.keystore.dict import DictKeystore
-from hexathon import (
-        add_0x,
-        strip_0x,
-        )
-
-# local imports
-from chainlib.eth.constant import ZERO_ADDRESS
-from chainlib.eth.address import to_checksum
-from chainlib.eth.connection import EthHTTPConnection
-from chainlib.jsonrpc import (
-        JSONRPCRequest,
-        IntSequenceGenerator,
-        )
-from chainlib.eth.nonce import (
-        RPCNonceOracle,
-        OverrideNonceOracle,
-        )
-from chainlib.eth.gas import (
-        RPCGasOracle,
-        OverrideGasOracle,
-        )
-from chainlib.eth.tx import (
-        TxFactory,
-        TxFormat,
-        raw,
-        )
-from chainlib.error import SignerMissingException
-from chainlib.chain import ChainSpec
-from chainlib.eth.runnable.util import decode_for_puny_humans
-from chainlib.eth.jsonrpc import to_blockheight_param
-from chainlib.eth.address import to_checksum_address
-
-logging.basicConfig(level=logging.WARNING)
-logg = logging.getLogger()
-
-script_dir = os.path.dirname(os.path.realpath(__file__)) 
-config_dir = os.path.join(script_dir, '..', 'data', 'config')
-
-arg_flags = chainlib.eth.cli.argflag_std_write | chainlib.eth.cli.Flag.EXEC | chainlib.eth.cli.Flag.FEE
-argparser = chainlib.eth.cli.ArgumentParser(arg_flags)
-argparser.add_argument('--notx', action='store_true', help='Network send is not a transaction')
-argparser.add_argument('--signature', type=str, help='Method signature to encode')
-argparser.add_argument('contract_args', type=str, nargs='*', help='arguments to encode')
-args = argparser.parse_args()
-extra_args = {
-    'signature': None,
-    'contract_args': None,
-    'notx': None,
-        }
-config = chainlib.eth.cli.Config.from_args(args, arg_flags, extra_args=extra_args, default_config_dir=config_dir)
-
-block_all = args.ww
-block_last = args.w or block_all
-
-wallet = chainlib.eth.cli.Wallet(EIP155Signer)
-wallet.from_config(config)
-
-rpc = chainlib.eth.cli.Rpc(wallet=wallet)
-conn = rpc.connect_by_config(config)
-
-send = config.true('_RPC_SEND')
-
-chain_spec = None
-try:
-    chain_spec = ChainSpec.from_chain_str(config.get('CHAIN_SPEC'))
-except AttributeError:
-    pass
-
-
-def main():
-
-    signer_address = ZERO_ADDRESS
-    signer = None
-    try:
-        signer = rpc.get_signer()
-        signer_address = rpc.get_signer_address()
-    except SignerMissingException:
-        pass
-
-    code = '0x'
-    cli_encoder = CLIEncoder(signature=config.get('_SIGNATURE'))
-
-    for arg in config.get('_CONTRACT_ARGS'):
-        cli_encoder.add_from(arg)
-    
-    code += cli_encoder.get()
-
-    if not config.get('_SIGNATURE'):
-        print(strip_0x(code))
-        return
-
-    exec_address = config.get('_EXEC_ADDRESS')
-    if exec_address:
-        exec_address = add_0x(to_checksum_address(exec_address))
-
-    if signer == None or config.true('_NOTX'):
-        if config.true('_RAW'):
-            print(strip_0x(code))
-            return
-
-        if not exec_address:
-            argparser.error('exec address (-e) must be defined')
-
-        c = TxFactory(chain_spec)
-        j = JSONRPCRequest(id_generator=rpc.id_generator)
-        o = j.template()
-        o['method'] = 'eth_call'
-        gas_limit = add_0x(int.to_bytes(config.get('_FEE_LIMIT'), 8, byteorder='big').hex(), compact_value=True)
-        gas_price = add_0x(int.to_bytes(config.get('_FEE_PRICE'), 8, byteorder='big').hex(), compact_value=True)
-        o['params'].append({
-                'to': exec_address,
-                'from': signer_address,
-                'value': '0x0',
-                'gas': gas_limit, # TODO: better get of network gas limit
-                'gasPrice': gas_price,
-                'data': add_0x(code),
-                })
-        height = to_blockheight_param(config.get('_HEIGHT'))
-        o['params'].append(height)
-        o = j.finalize(o)
-        r = conn.do(o)
-        try:
-            print(strip_0x(r))
-            return
-        except ValueError:
-            sys.stderr.write('query returned an empty value ({})\n'.format(r))
-            sys.exit(1)
-
-    if not exec_address:
-        argparser.error('exec address (-e) must be defined')
-
-    if chain_spec == None:
-        raise ValueError('chain spec must be specified')
-
-    c = TxFactory(chain_spec, signer=signer, gas_oracle=rpc.get_gas_oracle(), nonce_oracle=rpc.get_nonce_oracle())
-    tx = c.template(signer_address, config.get('_EXEC_ADDRESS'), use_nonce=True)
-    tx = c.set_code(tx, code)
-    tx_format = TxFormat.JSONRPC
-    if config.get('_RAW'):
-        tx_format = TxFormat.RLP_SIGNED
-    (tx_hash_hex, o) = c.finalize(tx, tx_format=tx_format)
-    if send:
-        r = conn.do(o)
-        print(r)
-    else:
-        if config.get('_RAW'):
-            o = strip_0x(o)
-        print(o)
-
-if __name__ == '__main__':
-    main()

chainlib/eth/runnable/gas.py

@@ -26,10 +26,6 @@ from chainlib.eth.gas import Gas
 from chainlib.eth.gas import balance as gas_balance
 from chainlib.chain import ChainSpec
 from chainlib.eth.runnable.util import decode_for_puny_humans
-from chainlib.eth.address import (
-        is_same_address,
-        is_checksum_address,
-        )
 import chainlib.eth.cli
 
 logging.basicConfig(level=logging.WARNING)
@@ -66,12 +62,8 @@ send = config.true('_RPC_SEND')
 def balance(address, id_generator):
     o = gas_balance(address, id_generator=id_generator)
     r = conn.do(o)
-    try:
-        balance = int(r)
-    except ValueError:
-        balance = strip_0x(r)
-        balance = int(balance, 16)
-    return balance
+    hx = strip_0x(r)
+    return int(hx, 16)
 
 
 def main():
@@ -81,32 +73,32 @@ def main():
     g = Gas(chain_spec, signer=signer, gas_oracle=rpc.get_gas_oracle(), nonce_oracle=rpc.get_nonce_oracle())
 
     recipient = to_checksum_address(config.get('_RECIPIENT'))
-    if not config.true('_UNSAFE') and not is_checksum_address(recipient):
+    if not config.true('_UNSAFE') and recipient != add_0x(config.get('_RECIPIENT')):
         raise ValueError('invalid checksum address')
 
     logg.info('gas transfer from {} to {} value {}'.format(signer_address, recipient, value))
     if logg.isEnabledFor(logging.DEBUG):
         try:
-            sender_balance = balance(add_0x(signer_address), rpc.id_generator)
-            recipient_balance = balance(add_0x(recipient), rpc.id_generator)
+            sender_balance = balance(signer_address, rpc.id_generator)
+            recipient_balance = balance(recipient, rpc.id_generator)
             logg.debug('sender {} balance before: {}'.format(signer_address, sender_balance))
             logg.debug('recipient {} balance before: {}'.format(recipient, recipient_balance))
         except urllib.error.URLError:
             pass
      
-    (tx_hash_hex, o) = g.create(signer_address, add_0x(recipient), value, data=config.get('_DATA'), id_generator=rpc.id_generator)
+    (tx_hash_hex, o) = g.create(signer_address, recipient, value, data=config.get('_DATA'), id_generator=rpc.id_generator)
 
     if send:
         conn.do(o)
         if block_last:
             r = conn.wait(tx_hash_hex)
             if logg.isEnabledFor(logging.DEBUG):
-                sender_balance = balance(add_0x(signer_address), rpc.id_generator)
-                recipient_balance = balance(add_0x(recipient), rpc.id_generator)
+                sender_balance = balance(signer_address, rpc.id_generator)
+                recipient_balance = balance(recipient, rpc.id_generator)
                 logg.debug('sender {} balance after: {}'.format(signer_address, sender_balance))
                 logg.debug('recipient {} balance after: {}'.format(recipient, recipient_balance))
             if r['status'] == 0:
-                logg.critical('VM revert for {}. Wish I could tell you more'.format(tx_hash_hex))
+                logg.critical('VM revert. Wish I could tell you more')
                 sys.exit(1)
         print(tx_hash_hex)
     else:

chainlib/eth/runnable/get.py

@@ -63,7 +63,6 @@ item = add_0x(args.item)
 
 
 def get_transaction(conn, tx_hash, id_generator):
-    tx_hash = add_0x(tx_hash)
     j = JSONRPCRequest(id_generator=id_generator)
     o = j.template()
     o['method'] = 'eth_getTransactionByHash'
@@ -98,13 +97,13 @@ def get_transaction(conn, tx_hash, id_generator):
         r = conn.do(o)
         block = Block(r)
         tx.apply_block(block)
+    logg.debug('foo {}'.format(tx_src))
     tx.generate_wire(chain_spec)
     return tx
     
 
 
 def get_address(conn, address, id_generator, height):
-    address = add_0x(address)
     j = JSONRPCRequest(id_generator=id_generator)
     o = j.template()
     o['method'] = 'eth_getCode'

chainlib/eth/runnable/info.py

@@ -16,7 +16,7 @@ from hexathon import (
         even,
         )
 import sha3
-from funga.eth.signer import EIP155Signer
+from crypto_dev_signer.eth.signer import ReferenceSigner as EIP155Signer
 
 # local imports
 from chainlib.eth.address import AddressChecksum
@@ -24,7 +24,6 @@ from chainlib.eth.chain import network_id
 from chainlib.eth.block import (
         block_latest,
         block_by_number,
-        syncing,
         Block,
         )
 from chainlib.eth.tx import count
@@ -44,35 +43,21 @@ logg = logging.getLogger()
 script_dir = os.path.dirname(os.path.realpath(__file__)) 
 config_dir = os.path.join(script_dir, '..', 'data', 'config')
 
-results_translation = {
-    'network_id': 'Network Id',
-    'block': 'Block',
-    'syncing': 'Syncing',
-    'gas_limit': 'Gas Limit',
-    'gas_price': 'Gas Price',
-    'block_time': 'Block time',
-        }
-
-
 arg_flags = chainlib.eth.cli.argflag_std_read
 argparser = chainlib.eth.cli.ArgumentParser(arg_flags)
+argparser.add_positional('address', type=str, help='Address to retrieve info for', required=False)
 argparser.add_argument('--long', action='store_true', help='Calculate averages through sampling of blocks and txs')
-argparser.add_argument('--local', action='store_true', help='Include local info')
-argparser.add_positional('entry', required=False, help='Output single item')
 args = argparser.parse_args()
 
-extra_args = {
-        'local': None,
-        'long': None,
-        'entry': None,
-        }
-config = chainlib.eth.cli.Config.from_args(args, arg_flags, extra_args=extra_args, default_config_dir=config_dir)
+config = chainlib.eth.cli.Config.from_args(args, arg_flags, extra_args={'long': None}, default_config_dir=config_dir)
 
-if config.get('_ENTRY') != None:
-    if config.get('_ENTRY') not in results_translation.keys():
-        raise ValueError('Unknown entry {}'.format(config.get('_ENTRY')))
+holder_address = args.address
+wallet = chainlib.eth.cli.Wallet()
+wallet.from_config(config)
+if wallet.get_signer_address() == None and holder_address != None:
+    wallet.from_address(holder_address)
 
-rpc = chainlib.eth.cli.Rpc()
+rpc = chainlib.eth.cli.Rpc(wallet=wallet)
 conn = rpc.connect_by_config(config)
 
 token_symbol = 'eth'
@@ -83,37 +68,20 @@ human = not config.true('_RAW')
 
 longmode = config.true('_LONG')
 
-def set_result(results, k, v, w=sys.stdout):
-    kt = results_translation[k]
-    if str(config.get('_ENTRY')) == k:
-        w.write('{}'.format(v))
-        return True
-    logg.info('{}: {}\n'.format(kt, v))
-    results[k] = v
-    return False
-
-
 def main():
-    results = {}
-
     o = network_id(id_generator=rpc.id_generator)
     r = conn.do(o)
     #if human:
     #    n = format(n, ',')
-    if set_result(results, 'network_id', r):
-        return
+    sys.stdout.write('Network id: {}\n'.format(r))
 
     o = block_latest(id_generator=rpc.id_generator)
     r = conn.do(o)
-    try:
-        n = int(r, 16)
-    except ValueError:
-        n = int(r)
+    n = int(r, 16)
     first_block_number = n
     if human:
         n = format(n, ',')
-    if set_result(results, 'block', n):
-        return
+    sys.stdout.write('Block: {}\n'.format(n))
 
     o = block_by_number(first_block_number, False, id_generator=rpc.id_generator)
     r = conn.do(o)
@@ -139,31 +107,22 @@ def main():
         if human:
             n = format(n, ',')
 
-        if set_result(results, 'gas_limit', n):
-            return
-        if set_result(results, 'block_time', aggr_time / BLOCK_SAMPLES):
-            return
+        sys.stdout.write('Gaslimit: {}\n'.format(n))
+        sys.stdout.write('Blocktime: {}\n'.format(aggr_time / BLOCK_SAMPLES))
 
     o = price(id_generator=rpc.id_generator)
     r = conn.do(o)
     n = int(r, 16)
     if human:
         n = format(n, ',')
-    if set_result(results, 'gas_price', n):
-        return
+    sys.stdout.write('Gasprice: {}\n'.format(n))
 
-    if config.get('_LOCAL'):
-        o = syncing()
+    if holder_address != None:
+        o = count(holder_address)
         r = conn.do(o)
-        if set_result(results, 'syncing', r):
-            return
-
-    if config.get('_ENTRY') != None:
-        raise RuntimeError('entry {} ({}) not processed, please review the flag settings'.format(config.get('_ENTRY'), results_translation[config.get('_ENTRY')]))
-
-    for k in results.keys():
-        kt = results_translation[k]
-        sys.stdout.write('{}: {}\n'.format(kt, results[k]))
+        n = int(r, 16)
+        sys.stdout.write('Address: {}\n'.format(holder_address))
+        sys.stdout.write('Nonce: {}\n'.format(n))
 
 
 if __name__ == '__main__':

chainlib/eth/runnable/raw.py

@@ -11,8 +11,8 @@ import urllib
 
 # external imports
 import chainlib.eth.cli
-from funga.eth.signer import EIP155Signer
-from funga.eth.keystore.dict import DictKeystore
+from crypto_dev_signer.eth.signer import ReferenceSigner as EIP155Signer
+from crypto_dev_signer.keystore.dict import DictKeystore
 from hexathon import (
         add_0x,
         strip_0x,
@@ -50,7 +50,6 @@ config_dir = os.path.join(script_dir, '..', 'data', 'config')
 
 arg_flags = chainlib.eth.cli.argflag_std_write | chainlib.eth.cli.Flag.EXEC
 argparser = chainlib.eth.cli.ArgumentParser(arg_flags)
-argparser.add_argument('--deploy', action='store_true', help='Deploy data as contract')
 argparser.add_positional('data', type=str, help='Transaction data')
 args = argparser.parse_args()
 config = chainlib.eth.cli.Config.from_args(args, arg_flags, default_config_dir=config_dir)
@@ -66,6 +65,9 @@ conn = rpc.connect_by_config(config)
 
 send = config.true('_RPC_SEND')
 
+if config.get('_EXEC_ADDRESS') != None:
+    send = False
+
 chain_spec = None
 try:
     chain_spec = ChainSpec.from_chain_str(config.get('CHAIN_SPEC'))
@@ -81,37 +83,34 @@ def main():
     except SignerMissingException:
         pass
 
-    if config.get('_EXEC_ADDRESS') != None or args.deploy:
-        exec_address = None
-        if config.get('_EXEC_ADDRESS') != None:
-            exec_address = add_0x(to_checksum(config.get('_EXEC_ADDRESS')))
-        #if not args.u and exec_address != add_0x(exec_address):
-            if not args.u and exec_address != exec_address:
-                raise ValueError('invalid checksum address')
+    if config.get('_EXEC_ADDRESS') != None:
+        exec_address = add_0x(to_checksum(config.get('_EXEC_ADDRESS')))
+        if not args.u and exec_address != add_0x(exec_address):
+            raise ValueError('invalid checksum address')
 
-        if signer_address == None:
-            j = JSONRPCRequest(id_generator=rpc.id_generator)
-            o = j.template()
-            o['method'] = 'eth_call'
-            o['params'].append({
-                'to': exec_address,
-                'from': signer_address,
-                'value': '0x00',
-                'gas': add_0x(int.to_bytes(8000000, 8, byteorder='big').hex()), # TODO: better get of network gas limit
-                'gasPrice': '0x01',
-                'data': add_0x(args.data),
-                })
-            height = to_blockheight_param(config.get('_HEIGHT'))
-            o['params'].append(height)
-            o = j.finalize(o)
-            r = conn.do(o)
-            try:
-                print(strip_0x(r))
-            except ValueError:
-                sys.stderr.write('query returned an empty value ({})\n'.format(r))
-                sys.exit(1)
+        j = JSONRPCRequest(id_generator=rpc.id_generator)
+        o = j.template()
+        o['method'] = 'eth_call'
+        o['params'].append({
+            'to': exec_address,
+            'from': signer_address,
+            'value': '0x00',
+            'gas': add_0x(int.to_bytes(8000000, 8, byteorder='big').hex()), # TODO: better get of network gas limit
+            'gasPrice': '0x01',
+            'data': add_0x(args.data),
+            })
+        height = to_blockheight_param(config.get('_HEIGHT'))
+        o['params'].append(height)
+        o = j.finalize(o)
+        r = conn.do(o)
+        try:
+            print(strip_0x(r))
+        except ValueError:
+            sys.stderr.write('query returned an empty value\n')
+            sys.exit(1)
+        return
 
-        else:
+        if signer_address != None:
             if chain_spec == None:
                 raise ValueError('chain spec must be specified')
             g = TxFactory(chain_spec, signer=rpc.get_signer(), gas_oracle=rpc.get_gas_oracle(), nonce_oracle=rpc.get_nonce_oracle())
@@ -125,19 +124,13 @@ def main():
                 r = conn.do(o)
                 print(r)
             else:
-                if config.get('_RAW'):
-                    o = strip_0x(o)
                 print(o)
+                print(tx_hash_hex)
 
     else:
         o = raw(args.data, id_generator=rpc.id_generator)
         if send:
             r = conn.do(o)
-            if block_last:
-                r = conn.wait(tx_hash_hex)
-                if r['status'] == 0:
-                    logg.critical('VM revert for {}. Wish I could tell you more'.format(tx_hash_hex))
-                    sys.exit(1)
             print(r)
         else:
             print(o)

chainlib/eth/runnable/wait.py

@@ -1,114 +0,0 @@
-# SPDX-License-Identifier: GPL-3.0-or-later
-
-# standard imports
-import io
-import sys
-import os
-import json
-import argparse
-import logging
-import urllib
-
-# external imports
-import chainlib.eth.cli
-from funga.eth.signer import EIP155Signer
-from funga.eth.keystore.dict import DictKeystore
-from hexathon import (
-        add_0x,
-        strip_0x,
-        uniform as hex_uniform,
-        )
-
-# local imports
-from chainlib.eth.address import to_checksum
-from chainlib.eth.connection import EthHTTPConnection
-from chainlib.jsonrpc import (
-        JSONRPCRequest,
-        IntSequenceGenerator,
-        )
-from chainlib.eth.nonce import (
-        RPCNonceOracle,
-        OverrideNonceOracle,
-        )
-from chainlib.eth.gas import (
-        RPCGasOracle,
-        OverrideGasOracle,
-        )
-from chainlib.eth.tx import (
-        TxFactory,
-        raw,
-        )
-from chainlib.eth.error import RevertEthException
-from chainlib.chain import ChainSpec
-from chainlib.eth.runnable.util import decode_for_puny_humans
-from chainlib.eth.jsonrpc import to_blockheight_param
-
-logging.basicConfig(level=logging.WARNING)
-logg = logging.getLogger()
-
-script_dir = os.path.dirname(os.path.realpath(__file__)) 
-config_dir = os.path.join(script_dir, '..', 'data', 'config')
-
-arg_flags = chainlib.eth.cli.argflag_std_read
-argparser = chainlib.eth.cli.ArgumentParser(arg_flags)
-argparser.add_argument('--ignore', type=str, action='append', default=[], help='Ignore error from the given transaction')
-argparser.add_argument('--ignore-all', action='store_true', dest='ignore_all', help='Ignore errors from all transactions')
-argparser.add_positional('hashes', append=True, type=str, help='Transaction hashes to wait for')
-args = argparser.parse_args()
-extra_args = {
-    'ignore': None,
-    'ignore_all': None,
-    'hashes': None,
-        }
-config = chainlib.eth.cli.Config.from_args(args, arg_flags, extra_args=extra_args, default_config_dir=config_dir)
-
-rpc = chainlib.eth.cli.Rpc()
-conn = rpc.connect_by_config(config)
-
-chain_spec = None
-try:
-    chain_spec = ChainSpec.from_chain_str(config.get('CHAIN_SPEC'))
-except AttributeError:
-    pass
-
-
-def main():
-
-    hashes_ready = []
-    hashes_ignore = []
-
-    for hsh in config.get('_IGNORE'):
-        hashes_ignore.append(add_0x(hex_uniform(strip_0x(hsh))))
-
-    if len(config.get('_HASHES')) == 1:
-        try:
-            hsh = add_0x(hex_uniform(strip_0x(config.get('_HASHES')[0])))
-            hashes_ready = [hsh]
-        except ValueError:
-            logg.debug('hash argument not a hash, will try it as a file name')
-            f = open(config.get('_HASHES')[0])
-            for hsh in f:
-                logg.debug('hshs {}'.format(hsh))
-                hashes_ready.append(add_0x(hex_uniform(strip_0x(hsh.rstrip()))))
-            f.close()
-    else:
-        for hsh in config.get('_HASHES'):
-            logg.debug('hsh {}'.format(hsh))
-            hashes_ready.append(add_0x(hex_uniform(strip_0x(hsh))))
-            
-    for hsh in hashes_ready:
-        logg.debug('processing transaction hash {}'.format(hsh))
-        try:
-            r = conn.wait(hsh)
-        except RevertEthException:
-            if config.get('_IGNORE_ALL') or hsh in hashes_ignore:
-                logg.info('ignoring revert in transaction hash {}'.format(hsh))
-                continue
-            sys.stderr.write('revert in transaction hash {}\n'.format(hsh))
-            sys.exit(1)
-           
-
-if __name__ == '__main__':
-    main()
-
-

chainlib/eth/tx.py

@@ -13,11 +13,9 @@ from hexathon import (
         )
 from rlp import decode as rlp_decode
 from rlp import encode as rlp_encode
-from funga.eth.transaction import EIP155Transaction
-from funga.eth.encoding import (
-        public_key_to_address,
-        chain_id_to_v,
-        )
+from crypto_dev_signer.eth.transaction import EIP155Transaction
+from crypto_dev_signer.encoding import public_key_to_address
+from crypto_dev_signer.eth.encoding import chain_id_to_v
 from potaahto.symbols import snake_and_camel
 from chainlib.hash import keccak256_hex_to_hex
 from chainlib.status import Status
@@ -162,14 +160,14 @@ def __unpack_raw(tx_raw_bytes, chain_id=1):
     vb = chain_id
     if chain_id != 0:
         v = int.from_bytes(d[6], 'big')
-        if v > 29:
-            vb = v - (chain_id * 2) - 35
+        vb = v - (chain_id * 2) - 35
     r = bytearray(32)
     r[32-len(d[7]):] = d[7]
     s = bytearray(32)
     s[32-len(d[8]):] = d[8]
     logg.debug('vb {}'.format(vb))
     sig = b''.join([r, s, bytes([vb])])
+    #so = KeyAPI.Signature(signature_bytes=sig)
 
     h = sha3.keccak_256()
     h.update(rlp_encode(d))
@@ -301,7 +299,7 @@ class TxFactory:
     :param chain_spec: Chain spec to use for signer.
     :type chain_spec: chainlib.chain.ChainSpec
     :param signer: Signer middleware.
-    :type param: Object implementing interface ofchainlib.eth.connection.sign_transaction_to_wire
+    :type param: Object implementing interface of chainlib.eth.connection.sign_transaction_to_wire
     :param gas_oracle: Backend to generate gas parameters
     :type gas_oracle: Object implementing chainlib.eth.gas.GasOracle interface
     :param nonce_oracle: Backend to generate gas parameters
@@ -422,7 +420,7 @@ class TxFactory:
         elif tx_format == TxFormat.RLP_SIGNED:
             return self.build_raw(tx)
         elif tx_format == TxFormat.RAW_ARGS:
-            return strip_0x(tx['data'])
+            return tx['data']
         raise NotImplementedError('tx formatting {} not implemented'.format(tx_format))
 
 
@@ -519,7 +517,7 @@ class Tx(BaseTx):
     #:todo: divide up constructor method
     """
 
-    def __init__(self, src, block=None, rcpt=None, strict=False):
+    def __init__(self, src, block=None, rcpt=None):
         self.__rcpt_block_hash = None
 
         src = self.src_normalize(src)
@@ -575,7 +573,7 @@ class Tx(BaseTx):
         self.logs = None
 
         if rcpt != None:
-            self.apply_receipt(rcpt, strict=strict)
+            self.apply_receipt(rcpt)
 
         self.v = src.get('v')
         self.r = src.get('r')
@@ -618,7 +616,7 @@ class Tx(BaseTx):
         return self.src()
 
 
-    def apply_receipt(self, rcpt, strict=False):
+    def apply_receipt(self, rcpt):
         """Apply receipt data to transaction object.
 
         Effect is the same as passing a receipt at construction.
@@ -642,12 +640,6 @@ class Tx(BaseTx):
             status_number = int(rcpt['status'], 16)
         except TypeError:
             status_number = int(rcpt['status'])
-        except KeyError as e:
-            if strict:
-                raise(e)
-            logg.warning('setting "sucess" status on missing status property for {}'.format(self.hash))
-            status_number = 1
-
         if rcpt['block_number'] == None:
             self.status = Status.PENDING
         else:
@@ -702,12 +694,12 @@ class Tx(BaseTx):
 
 
     @staticmethod
-    def from_src(src, block=None, rcpt=None, strict=False):
+    def from_src(src, block=None, rcpt=None):
         """Creates a new Tx object.
 
         Alias of constructor.
         """
-        return Tx(src, block=block, rcpt=rcpt, strict=strict)
+        return Tx(src, block=block, rcpt=rcpt)
 
 
     def __str__(self):

chainlib/eth/unittest/base.py

@@ -25,8 +25,8 @@ from hexathon import (
         )
 from chainlib.eth.tx import receipt
 
-from funga.eth.signer import EIP155Signer
-from funga.eth.encoding import private_key_to_address
+from crypto_dev_signer.eth.signer import ReferenceSigner as EIP155Signer
+from crypto_dev_signer.encoding import private_key_to_address
 
 
 logg = logging.getLogger().getChild(__name__)

chainlib/eth/unittest/ethtester.py

@@ -5,8 +5,8 @@ import logging
 
 # external imports
 import eth_tester
-from funga.eth.signer import EIP155Signer
-from funga.eth.keystore.dict import DictKeystore
+from crypto_dev_signer.eth.signer import ReferenceSigner as EIP155Signer
+from crypto_dev_signer.keystore.dict import DictKeystore
 from hexathon import (
         strip_0x,
         add_0x,
@@ -26,8 +26,7 @@ from chainlib.connection import (
 from chainlib.eth.address import to_checksum_address
 from chainlib.chain import ChainSpec
 
-#logg = logging.getLogger(__name__)
-logg = logging.getLogger()
+logg = logging.getLogger(__name__)
 
 test_address = bytes.fromhex('Eb3907eCad74a0013c259D5874AE7f22DcBcC95C')
 
@@ -64,7 +63,6 @@ class EthTesterCase(unittest.TestCase):
         self.helper = eth_tester_instance
         self.backend = self.helper.backend
         self.rpc = TestRPCConnection(None, eth_tester_instance, self.signer)
-
         for a in self.keystore.list():
             self.accounts.append(add_0x(to_checksum_address(a)))
 
@@ -75,6 +73,7 @@ class EthTesterCase(unittest.TestCase):
         RPCConnection.register_constructor(ConnType.CUSTOM, rpc_with_tester, tag='signer')
         RPCConnection.register_location('custom', self.chain_spec, tag='default', exist_ok=True)
         RPCConnection.register_location('custom', self.chain_spec, tag='signer', exist_ok=True)
+
         
 
     def tearDown(self):

requirements.txt

@@ -1,7 +1,7 @@
-funga-eth~=0.5.3
+funga-eth>=0.5.0a1,<0.6.0
 pysha3==1.0.2
-hexathon~=0.1.2
+hexathon~=0.0.1a8
 websocket-client==0.57.0
-potaahto~=0.1.0
-chainlib~=0.0.17
-confini~=0.5.3
+potaahto~=0.0.1a1
+chainlib==0.0.10a1
+confini>=0.4.1a1,<0.5.0

setup.cfg

@@ -1,6 +1,6 @@
 [metadata]
 name = chainlib-eth
-version = 0.0.23
+version = 0.0.10a2
 description = Ethereum implementation of the chainlib interface
 author = Louis Holbrook
 author_email = dev@holbrook.no
@@ -14,7 +14,6 @@ classifiers =
 	Programming Language :: Python :: 3
 	Operating System :: OS Independent
 	Development Status :: 3 - Alpha
-	Topic :: Software Development :: Libraries
 	Environment :: Console
 	Intended Audience :: Developers
 	License :: OSI Approved :: GNU General Public License v3 or later (GPLv3+)
@@ -33,18 +32,15 @@ packages =
 	chainlib.eth.runnable
 	chainlib.eth.pytest
 	chainlib.eth.unittest
-	chainlib.eth.cli
 
 [options.entry_points]
 console_scripts =
-	eth-count = chainlib.eth.runnable.count:main
 	eth-balance = chainlib.eth.runnable.balance:main
 	eth-checksum = chainlib.eth.runnable.checksum:main
 	eth-gas = chainlib.eth.runnable.gas:main
 	eth-raw = chainlib.eth.runnable.raw:main
 	eth-get = chainlib.eth.runnable.get:main
 	eth-decode = chainlib.eth.runnable.decode:main
-	eth-encode = chainlib.eth.runnable.encode:main
 	eth-info = chainlib.eth.runnable.info:main
 	eth-nonce = chainlib.eth.runnable.count:main
-	eth-wait = chainlib.eth.runnable.wait:main
+	eth = chainlib.eth.runnable.info:main

test_requirements.txt

@@ -2,4 +2,3 @@ eth_tester==0.5.0b3
 py-evm==0.3.0a20
 rlp==2.0.1
 pytest==6.0.1
-coverage==5.5

tests/test_address.py

@@ -12,7 +12,7 @@ from tests.base import TestBase
 class TestChain(TestBase):
 
     def test_chain_spec(self):
-        checksum_address = 'Eb3907eCad74a0013c259D5874AE7f22DcBcC95C'
+        checksum_address = '0xEb3907eCad74a0013c259D5874AE7f22DcBcC95C'
         plain_address = checksum_address.lower()
 
         self.assertEqual(checksum_address, to_checksum(checksum_address))

tests/test_sign.py

@@ -7,19 +7,16 @@ import logging
 import json
 
 # external imports
-from funga.eth.transaction import EIP155Transaction
-from funga.eth.signer.defaultsigner import EIP155Signer
-from funga.eth.keystore.dict import DictKeystore
+from crypto_dev_signer.eth.transaction import EIP155Transaction
+from crypto_dev_signer.eth.signer.defaultsigner import ReferenceSigner
+from crypto_dev_signer.keystore.dict import DictKeystore
 
 # local imports
 import chainlib
 from chainlib.eth.connection import EthUnixSignerConnection
 from chainlib.eth.sign import sign_transaction
 from chainlib.eth.tx import TxFactory
-from chainlib.eth.address import (
-        to_checksum_address,
-        is_same_address,
-        )
+from chainlib.eth.address import to_checksum_address
 from chainlib.jsonrpc import (
         jsonrpc_response,
         jsonrpc_error,
@@ -55,13 +52,11 @@ class Mocket(socket.socket):
         logg.debug('mocket received {}'.format(v))
         Mocket.req_id = o['id']
         params = o['params'][0]
-        from_address = to_checksum_address(params.get('from'))
-        if not is_same_address(alice, from_address):
-            logg.error('from {} does not match alice {}'.format(from_address, alice)) #params))
+        if to_checksum_address(params.get('from')) != alice:
+            logg.error('from does not match alice {}'.format(params))
             Mocket.error = True
-        to_address = to_checksum_address(params.get('to'))
-        if not is_same_address(bob, to_address):
-            logg.error('to {} does not match bob {}'.format(to_address, bob)) #params))
+        if to_checksum_address(params.get('to')) != bob:
+            logg.error('to does not match bob {}'.format(params))
             Mocket.error = True
         if not Mocket.error:
             Mocket.tx = EIP155Transaction(params, params['nonce'], params['chainId'])
@@ -97,7 +92,7 @@ class TestSign(TestBase):
         logg.debug('alice {}'.format(alice))
         logg.debug('bob {}'.format(bob))
 
-        self.signer = EIP155Signer(keystore)
+        self.signer = ReferenceSigner(keystore)
 
         Mocket.signer = self.signer
     

tests/test_tx.py

@@ -23,10 +23,7 @@ from chainlib.eth.contract import (
         ABIContractEncoder,
         ABIContractType,
         )
-from chainlib.eth.address import (
-        to_checksum_address,
-        is_same_address,
-        )
+from chainlib.eth.address import to_checksum_address
 from hexathon import (
         strip_0x,
         add_0x,
@@ -46,8 +43,8 @@ class TxTestCase(EthTesterCase):
         c = Gas(signer=self.signer, nonce_oracle=nonce_oracle, gas_oracle=gas_oracle, chain_spec=self.chain_spec)
         (tx_hash_hex, o) = c.create(self.accounts[0], self.accounts[1], 1024, tx_format=TxFormat.RLP_SIGNED)
         tx = unpack(bytes.fromhex(strip_0x(o)), self.chain_spec)
-        self.assertTrue(is_same_address(tx['from'], self.accounts[0]))
-        self.assertTrue(is_same_address(tx['to'], self.accounts[1]))
+        self.assertEqual(tx['from'], self.accounts[0])
+        self.assertEqual(tx['to'], self.accounts[1])
 
 
     def test_tx_pack(self):