2022-03-15 10:13:13 +01:00
# standard imports
import os
import tempfile
import unittest
import shutil
import logging
import hashlib
# external imports
from chainlib . chain import ChainSpec
from chainqueue . cache import CacheTokenTx
from chainlib . error import RPCException
from chainlib . status import Status as TxStatus
2022-05-02 11:59:50 +02:00
from chaind . unittest . fs import TestChaindFsBase
2022-03-15 10:13:13 +01:00
from chaind . driver import QueueDriver
from chaind . filter import StateFilter
from chainlib . eth . gas import Gas
2022-03-15 10:32:20 +01:00
from jsonrpc_std . parse import jsonrpc_validate_dict
from hexathon import strip_0x
2022-03-15 10:13:13 +01:00
# local imports
from chaind . eth . cache import EthCacheTx
2022-03-15 10:32:20 +01:00
from chaind . eth . dispatch import EthDispatcher
2022-03-15 10:13:13 +01:00
logging . basicConfig ( level = logging . DEBUG )
logg = logging . getLogger ( )
2022-03-15 10:32:20 +01:00
class MockConn :
def __init__ ( self ) :
self . fails = [ ]
self . last = None
def add_fail ( self , v ) :
self . fails . append ( v )
def do ( self , v ) :
if v in self . fails :
raise RuntimeError ( v )
v = jsonrpc_validate_dict ( v )
if v [ ' method ' ] != ' eth_sendRawTransaction ' :
raise ValueError ( ' unsupported method {} ' . format ( v [ ' method ' ] ) )
self . last = v [ ' params ' ] [ 0 ]
2022-03-15 10:13:13 +01:00
class TestEthChaindFs ( TestChaindFsBase ) :
def setUp ( self ) :
self . cache_adapter = EthCacheTx
2022-03-15 10:32:20 +01:00
self . conn = MockConn ( )
self . dispatcher = EthDispatcher ( self . conn )
2022-03-15 10:13:13 +01:00
super ( TestEthChaindFs , self ) . setUp ( )
def test_deserialize ( self ) :
2022-03-15 10:32:20 +01:00
data = " f8610d2a82520894eb3907ecad74a0013c259d5874ae7f22dcbcc95c8204008078a0ddbebd76701f6531e5ea42599f890268716e2bb38e3e125874f47595c2338049a00f5648d17b20efac8cb7ff275a510ebef6815e1599e29067821372b83eb1d28c " # valid RLP example data
2022-03-15 10:13:13 +01:00
hsh = self . adapter . put ( data )
v = self . adapter . get ( hsh )
self . assertEqual ( data , v )
2022-03-15 10:32:20 +01:00
def test_dispatch ( self ) :
data = " f8610d2a82520894eb3907ecad74a0013c259d5874ae7f22dcbcc95c8204008078a0ddbebd76701f6531e5ea42599f890268716e2bb38e3e125874f47595c2338049a00f5648d17b20efac8cb7ff275a510ebef6815e1599e29067821372b83eb1d28c " # valid RLP example data
hsh = self . adapter . put ( data )
self . adapter . dispatch ( hsh )
self . assertEqual ( strip_0x ( self . conn . last ) , strip_0x ( data ) )
2022-03-15 10:13:13 +01:00
if __name__ == ' __main__ ' :
unittest . main ( )