Add python interfaces, package

python/cic_contracts/accounts_index.py

@@ -0,0 +1,121 @@
+# standard imports
+import logging
+
+# external imports
+from chainlib.eth.tx import (
+        TxFormat,
+        )
+from chainlib.eth.contract import (
+        ABIContractEncoder,
+        ABIContractDecoder,
+        ABIContractType,
+        abi_decode_single,
+        )
+from chainlib.eth.constant import ZERO_ADDRESS
+from chainlib.jsonrpc import JSONRPCRequest
+from chainlib.eth.error import RequestMismatchException
+from hexathon import (
+        add_0x,
+        strip_0x,
+        )
+
+# local imports
+from .base import CICTxHelper
+from .writer import CICWriter
+
+logg = logging.getLogger(__name__)
+
+
+class CICAccountsIndex(CICWriter):
+
+    def add(self, contract_address, sender_address, address, tx_format=TxFormat.JSONRPC):
+        return self.single_address_method('add', contract_address, sender_address, address, tx_format)
+
+
+    def have(self, contract_address, address, sender_address=ZERO_ADDRESS, id_generator=None):
+        j = JSONRPCRequest(id_generator)
+        o = j.template()
+        o['method'] = 'eth_call'
+        enc = ABIContractEncoder()
+        enc.method('have')
+        enc.typ(ABIContractType.ADDRESS)
+        enc.address(address)
+        data = add_0x(enc.get())
+        tx = self.template(sender_address, contract_address)
+        tx = self.set_code(tx, data)
+        o['params'].append(self.normalize(tx))
+        return o
+
+
+    def entry_count(self, contract_address, sender_address=ZERO_ADDRESS, id_generator=None):
+        j = JSONRPCRequest(id_generator)
+        o = j.template()
+        o['method'] = 'eth_call'
+        enc = ABIContractEncoder()
+        enc.method('entryCount')
+        data = add_0x(enc.get())
+        tx = self.template(sender_address, contract_address)
+        tx = self.set_code(tx, data)
+        o['params'].append(self.normalize(tx))
+        return o
+
+
+    def count(self, contract_address, sender_address=ZERO_ADDRESS, id_generator=None):
+        return self.entry_count(contract_address, sender_address=sender_address, id_generator=id_generator)
+
+
+    def entry(self, contract_address, idx, sender_address=ZERO_ADDRESS, id_generator=None):
+        j = JSONRPCRequest(id_generator)
+        o = j.template()
+        o['method'] = 'eth_call'
+        enc = ABIContractEncoder()
+        enc.method('entry')
+        enc.typ(ABIContractType.UINT256)
+        enc.uint256(idx)
+        data = add_0x(enc.get())
+        tx = self.template(sender_address, contract_address)
+        tx = self.set_code(tx, data)
+        o['params'].append(self.normalize(tx))
+        return o
+
+
+    @classmethod
+    def parse_account(self, v):
+        return abi_decode_single(ABIContractType.ADDRESS, v)
+
+
+    @classmethod
+    def parse_entry(self, v):
+        return abi_decode_single(ABIContractType.ADDRESS, v)
+
+
+    @classmethod
+    def parse_entry_count(self, v):
+        return abi_decode_single(ABIContractType.UINT256, v)
+
+
+    @classmethod
+    def parse_have(self, v):
+        return abi_decode_single(ABIContractType.BOOLEAN, v)
+
+
+    @classmethod
+    def parse_add_request(self, v):
+        v = strip_0x(v)
+        cursor = 0
+        enc = ABIContractEncoder()
+        enc.method('add')
+        enc.typ(ABIContractType.ADDRESS)
+        r = enc.get()
+        l = len(r)
+        m = v[:l]
+        if m != r:
+            logg.debug('method mismatch, expected {}, got {}'.format(r, m))
+            raise RequestMismatchException(v)
+        cursor += l
+
+        dec = ABIContractDecoder()
+        dec.typ(ABIContractType.ADDRESS)
+        dec.val(v[cursor:cursor+64])
+        r = dec.decode()
+        return r 

python/cic_contracts/base.py

@@ -0,0 +1,23 @@
+# external imports
+from chainlib.eth.tx import (
+        TxFactory,
+        TxFormat,
+        )
+from chainlib.eth.contract import (
+    ABIContractEncoder,
+    ABIContractType,
+    )
+
+
+class CICTxHelper(TxFactory):
+
+    def single_address_method(self, method, contract_address, sender_address, address, tx_format=TxFormat.JSONRPC):
+        enc = ABIContractEncoder()
+        enc.method(method)
+        enc.typ(ABIContractType.ADDRESS)
+        enc.address(address)
+        data = enc.get()
+        tx = self.template(sender_address, contract_address, use_nonce=True)
+        tx = self.set_code(tx, data)
+        tx = self.finalize(tx, tx_format)        
+        return tx

python/cic_contracts/erc20.py

@@ -0,0 +1,294 @@
+# standard imports
+import logging
+
+# external imports
+import sha3
+from hexathon import (
+        add_0x,
+        strip_0x,
+        )
+
+# external imports
+from chainlib.hash import (
+        keccak256_hex_to_hex,
+        keccak256_string_to_hex,
+        )
+from chainlib.eth.constant import ZERO_ADDRESS
+from chainlib.eth.tx import (
+        TxFactory,
+        TxFormat,
+        )
+from chainlib.jsonrpc import JSONRPCRequest
+from chainlib.eth.contract import (
+        ABIContractEncoder,
+        ABIContractDecoder,
+        ABIContractType,
+        abi_decode_single,
+        )
+from chainlib.eth.error import RequestMismatchException
+
+logg = logging.getLogger(__name__)
+
+
+class ERC20(TxFactory):
+    
+
+    def balance_of(self, contract_address, address, sender_address=ZERO_ADDRESS, id_generator=None):
+        j = JSONRPCRequest(id_generator)
+        o = j.template()
+        o['method'] = 'eth_call'
+        enc = ABIContractEncoder()
+        enc.method('balanceOf')
+        enc.typ(ABIContractType.ADDRESS)
+        enc.address(address)
+        data = add_0x(enc.get())
+        tx = self.template(sender_address, contract_address)
+        tx = self.set_code(tx, data)
+        o['params'].append(self.normalize(tx))
+        o['params'].append('latest')
+        o = j.finalize(o)
+        return o
+
+
+    def balance(self, contract_address, address, sender_address=ZERO_ADDRESS, id_generator=None):
+        return self.balance_of(contract_address, address, sender_address=sender_address, id_generator=id_generator)
+
+
+    def symbol(self, contract_address, sender_address=ZERO_ADDRESS, id_generator=None):
+        j = JSONRPCRequest(id_generator)
+        o = j.template()
+        o['method'] = 'eth_call'
+        enc = ABIContractEncoder()
+        enc.method('symbol')
+        data = add_0x(enc.get())
+        tx = self.template(sender_address, contract_address)
+        tx = self.set_code(tx, data)
+        o['params'].append(self.normalize(tx))
+        o['params'].append('latest')
+        o = j.finalize(o)
+        return o
+
+
+    def name(self, contract_address, sender_address=ZERO_ADDRESS, id_generator=None):
+        j = JSONRPCRequest(id_generator)
+        o = j.template()
+        o['method'] = 'eth_call'
+        enc = ABIContractEncoder()
+        enc.method('name')
+        data = add_0x(enc.get())
+        tx = self.template(sender_address, contract_address)
+        tx = self.set_code(tx, data)
+        o['params'].append(self.normalize(tx))
+        o['params'].append('latest')
+        o = j.finalize(o)
+        return o
+
+    
+    def decimals(self, contract_address, sender_address=ZERO_ADDRESS, id_generator=None):
+        j = JSONRPCRequest(id_generator)
+        o = j.template()
+        o['method'] = 'eth_call'
+        enc = ABIContractEncoder()
+        enc.method('decimals')
+        data = add_0x(enc.get())
+        tx = self.template(sender_address, contract_address)
+        tx = self.set_code(tx, data)
+        o['params'].append(self.normalize(tx))
+        o['params'].append('latest')
+        o = j.finalize(o)
+        return o
+
+
+    def total_supply(self, contract_address, sender_address=ZERO_ADDRESS, id_generator=None):
+        j = JSONRPCRequest(id_generator)
+        o = j.template()
+        o['method'] = 'eth_call'
+        enc = ABIContractEncoder()
+        enc.method('totalSupply')
+        data = add_0x(enc.get())
+        tx = self.template(sender_address, contract_address)
+        tx = self.set_code(tx, data)
+        o['params'].append(self.normalize(tx))
+        o['params'].append('latest')
+        o = j.finalize(o)
+        return o
+
+
+    def allowance(self, contract_address, holder_address, spender_address, sender_address=ZERO_ADDRESS, id_generator=None):
+        j = JSONRPCRequest(id_generator)
+        o = j.template()
+        o['method'] = 'eth_call'
+        enc = ABIContractEncoder()
+        enc.method('allowance')
+        enc.typ(ABIContractType.ADDRESS)
+        enc.typ(ABIContractType.ADDRESS)
+        enc.address(holder_address)
+        enc.address(spender_address)
+        data = add_0x(enc.get())
+        tx = self.template(sender_address, contract_address)
+        tx = self.set_code(tx, data)
+        o['params'].append(self.normalize(tx))
+        o['params'].append('latest')
+        o = j.finalize(o)
+        return o
+
+
+    def transfer(self, contract_address, sender_address, recipient_address, value, tx_format=TxFormat.JSONRPC, id_generator=None):
+        enc = ABIContractEncoder()
+        enc.method('transfer')
+        enc.typ(ABIContractType.ADDRESS)
+        enc.typ(ABIContractType.UINT256)
+        enc.address(recipient_address)
+        enc.uint256(value)
+        data = add_0x(enc.get())
+        tx = self.template(sender_address, contract_address, use_nonce=True)
+        tx = self.set_code(tx, data)
+        tx = self.finalize(tx, tx_format, id_generator=id_generator)
+        return tx
+
+
+    def transfer_from(self, contract_address, sender_address, holder_address, recipient_address, value, tx_format=TxFormat.JSONRPC, id_generator=None):
+        enc = ABIContractEncoder()
+        enc.method('transferFrom')
+        enc.typ(ABIContractType.ADDRESS)
+        enc.typ(ABIContractType.ADDRESS)
+        enc.typ(ABIContractType.UINT256)
+        enc.address(holder_address)
+        enc.address(recipient_address)
+        enc.uint256(value)
+        data = add_0x(enc.get())
+        tx = self.template(sender_address, contract_address, use_nonce=True)
+        tx = self.set_code(tx, data)
+        tx = self.finalize(tx, tx_format)
+        return tx
+
+
+    def approve(self, contract_address, sender_address, spender_address, value, tx_format=TxFormat.JSONRPC, id_generator=None):
+        enc = ABIContractEncoder()
+        enc.method('approve')
+        enc.typ(ABIContractType.ADDRESS)
+        enc.typ(ABIContractType.UINT256)
+        enc.address(spender_address)
+        enc.uint256(value)
+        data = add_0x(enc.get())
+        tx = self.template(sender_address, contract_address, use_nonce=True)
+        tx = self.set_code(tx, data)
+        tx = self.finalize(tx, tx_format)
+        return tx
+
+
+    @classmethod
+    def parse_symbol(self, v):
+        return abi_decode_single(ABIContractType.STRING, v)
+
+
+    @classmethod
+    def parse_name(self, v):
+        return abi_decode_single(ABIContractType.STRING, v)
+
+
+    @classmethod
+    def parse_decimals(self, v):
+        return abi_decode_single(ABIContractType.UINT256, v)
+
+
+    @classmethod
+    def parse_balance(self, v):
+        return abi_decode_single(ABIContractType.UINT256, v)
+
+
+    @classmethod
+    def parse_balance_of(self, v):
+        return self.parse_balance(v)
+
+
+    @classmethod
+    def parse_total_supply(self, v):
+        return abi_decode_single(ABIContractType.UINT256, v)
+
+
+    @classmethod
+    def parse_allowance(self, v):
+        return abi_decode_single(ABIContractType.UINT256, v)
+
+
+    @classmethod
+    def parse_transfer_request(self, v):
+        v = strip_0x(v)
+        cursor = 0
+        enc = ABIContractEncoder()
+        enc.method('transfer')
+        enc.typ(ABIContractType.ADDRESS)
+        enc.typ(ABIContractType.UINT256)
+        r = enc.get()
+        l = len(r)
+        m = v[:l]
+        if m != r:
+            logg.debug('method mismatch, expected {}, got {}'.format(r, m))
+            raise RequestMismatchException(v)
+        cursor += l
+
+        dec = ABIContractDecoder()
+        dec.typ(ABIContractType.ADDRESS)
+        dec.typ(ABIContractType.UINT256)
+        dec.val(v[cursor:cursor+64])
+        cursor += 64
+        dec.val(v[cursor:cursor+64])
+        r = dec.decode()
+        return r 
+
+
+    @classmethod
+    def parse_transfer_from_request(self, v):
+        v = strip_0x(v)
+        cursor = 0
+        enc = ABIContractEncoder()
+        enc.method('transferFrom')
+        enc.typ(ABIContractType.ADDRESS)
+        enc.typ(ABIContractType.ADDRESS)
+        enc.typ(ABIContractType.UINT256)
+        r = enc.get()
+        l = len(r)
+        m = v[:l]
+        if m != r:
+            logg.debug('method mismatch, expected {}, got {}'.format(r, m))
+            raise RequestMismatchException(v)
+        cursor += l
+
+        dec = ABIContractDecoder()
+        dec.typ(ABIContractType.ADDRESS)
+        dec.typ(ABIContractType.ADDRESS)
+        dec.typ(ABIContractType.UINT256)
+        dec.val(v[cursor:cursor+64])
+        cursor += 64
+        dec.val(v[cursor:cursor+64])
+        cursor += 64
+        dec.val(v[cursor:cursor+64])
+        r = dec.decode()
+        return r 
+
+
+    @classmethod
+    def parse_approve_request(self, v):
+        v = strip_0x(v)
+        cursor = 0
+        enc = ABIContractEncoder()
+        enc.method('approve')
+        enc.typ(ABIContractType.ADDRESS)
+        enc.typ(ABIContractType.UINT256)
+        r = enc.get()
+        l = len(r)
+        m = v[:l]
+        if m != r:
+            logg.debug('method mismatch, expected {}, got {}'.format(r, m))
+            raise RequestMismatchException(v)
+        cursor += l
+
+        dec = ABIContractDecoder()
+        dec.typ(ABIContractType.ADDRESS)
+        dec.typ(ABIContractType.UINT256)
+        dec.val(v[cursor:cursor+64])
+        cursor += 64
+        dec.val(v[cursor:cursor+64])
+        r = dec.decode()
+        return r 

python/cic_contracts/registry.py

@@ -0,0 +1,124 @@
+# standard imports
+import logging
+import hashlib
+
+# external imports
+from chainlib.jsonrpc import JSONRPCRequest
+from chainlib.eth.contract import (
+        ABIContractEncoder,
+        ABIContractType,
+        abi_decode_single,
+        )
+from chainlib.eth.tx import TxFactory
+from hexathon import (
+        add_0x,
+        strip_0x,
+        )
+from chainlib.eth.constant import (
+        ZERO_ADDRESS,
+        )
+
+logg = logging.getLogger(__name__)
+
+
+def to_text(b):
+        b = b[:b.find(0)]
+        # TODO: why was this part of this method previously?
+        # if len(b) % 2 > 0:
+        #     b = b'\x00' + b
+        return b.decode('utf-8')
+
+
+def from_text(txt):
+    return '0x{:0<64s}'.format(txt.encode('utf-8').hex())
+
+
+def from_identifier(b):
+    return to_text(b)
+
+
+def from_identifier_hex(hx):
+    b = bytes.fromhex(strip_0x(hx))
+    return from_identifier(b)
+
+
+def to_identifier(txt):
+    return from_text(txt)
+
+
+class CICRegistry(TxFactory):
+
+    def address_of(self, contract_address, identifier_string, sender_address=ZERO_ADDRESS, id_generator=None):
+        identifier = to_identifier(identifier_string)
+        logg.debug('using identifier for addressOf {} -> {}'.format(identifier, identifier_string))
+        return self.address_of_literatl(contract_address, identifier, sender_address=sender_address, id_generator=id_generator)
+
+
+    def address_of_literal(self, contract_address, identifier, sender_address=ZERO_ADDRESS, id_generator=None): 
+        j = JSONRPCRequest(id_generator)
+        o = j.template()
+        o['method'] = 'eth_call'
+        enc = ABIContractEncoder()
+        enc.method('addressOf')
+        enc.typ(ABIContractType.BYTES32)
+        enc.bytes32(identifier)
+        data = add_0x(enc.encode())
+        tx = self.template(sender_address, contract_address)
+        tx = self.set_code(tx, data)
+        o['params'].append(self.normalize(tx))
+        o = j.finalize(o)
+        return o
+
+
+    @classmethod
+    def parse_address_of(self, v):
+        return abi_decode_single(ABIContractType.ADDRESS, v)
+
+
+    def set(self, contract_address, sender_address, identifier_string, address):
+        enc = ABIContractEncoder()
+        enc.method('set')
+        enc.typ(ABIContractType.BYTES32)
+        enc.typ(ABIContractType.ADDRESS)
+        identifier = to_identifier(identifier_string)
+        enc.bytes32(identifier)
+        enc.address(address)
+        data = enc.encode()
+        tx = self.template(sender_address, contract_address, use_nonce=True)
+        tx = self.set_code(tx, data)
+        return self.build(tx)
+
+
+    def bind(self, contract_address, sender_address, identifier_string, reference):
+        enc = ABIContractEncoder()
+        enc.method('bind')
+        enc.typ(ABIContractType.BYTES32)
+        enc.typ(ABIContractType.BYTES32)
+        identifier = to_identifier(identifier_string)
+        enc.bytes32(identifier)
+        enc.bytes32(reference)
+        data = enc.encode()
+        tx = self.template(sender_address, contract_address, use_nonce=True)
+        tx = self.set_code(tx, data)
+        return self.build(tx)
+
+
+    def identifier(self, contract_address, idx, sender_address=ZERO_ADDRESS, id_generator=None):
+        j = JSONRPCRequest(id_generator)
+        o = j.template()
+        o['method'] = 'eth_call'
+        enc = ABIContractEncoder()
+        enc.method('identifiers')
+        enc.typ(ABIContractType.UINT256)
+        enc.uint256(idx)
+        data = add_0x(enc.encode())
+        tx = self.template(sender_address, contract_address)
+        tx = self.set_code(tx, data)
+        o['params'].append(self.normalize(tx))
+        o = j.finalize(o)
+        return o
+
+
+    @classmethod
+    def parse_identifier(self, v):
+        return from_identifier_hex(v)

python/cic_contracts/writer.py

@@ -0,0 +1,17 @@
+# external imports
+from chainlib.eth.tx import (
+        TxFactory,
+        TxFormat,
+        )
+
+# local imports
+from .base import CICTxHelper
+
+class CICWriter(CICTxHelper):
+
+    def add_writer(self, contract_address, sender_address, address, tx_format=TxFormat.JSONRPC):
+        return self.single_address_method('addWriter', contract_address, sender_address, address, tx_format)
+
+
+    def delete_writer(self, contract_address, sender_address, address, tx_format=TxFormat.JSONRPC):
+        return self.single_address_method('deleteWriter', contract_address, sender_address, address, tx_format)