Implement eth_getTransactionByHash, eth_getTransactionReceipt JSON RPC function

trinity/chains/base.py

@@ -7,6 +7,7 @@
 from eth.rlp.blocks import BaseBlock
 from eth.rlp.headers import BlockHeader
 from eth.rlp.receipts import Receipt
+from eth.rlp.transactions import BaseTransaction
 
 
 # This class is a work in progress; its main purpose is to define the API of an asyncio-compatible
@@ -48,6 +49,16 @@ async def coro_get_canonical_block_by_number(self,
                                                  block_number: BlockNumber) -> BaseBlock:
         pass
 
+    @abstractmethod
+    async def coro_get_canonical_transaction(self,
+                                             transaction_hash: Hash32) -> BaseTransaction:
+        pass
+
+    @abstractmethod
+    async def coro_get_transaction_receipt(self,
+                                           transaction_hash: Hash32) -> Receipt:
+        pass
+
 
 class BaseAsyncChain(BaseAsyncChainAPI, BaseChain):
     pass

trinity/chains/coro.py

@@ -9,6 +9,8 @@ class AsyncChainMixin(BaseAsyncChain):
     coro_get_block_by_hash = async_method('get_block_by_hash')
     coro_get_block_by_header = async_method('get_block_by_header')
     coro_get_canonical_block_by_number = async_method('get_canonical_block_by_number')
+    coro_get_canonical_transaction = async_method('get_canonical_transaction')
+    coro_get_transaction_receipt = async_method('get_transaction_receipt')
     coro_import_block = async_method('import_block')
     coro_validate_chain = async_method('validate_chain')
     coro_validate_receipt = async_method('validate_receipt')

trinity/chains/light.py

@@ -174,7 +174,7 @@ async def coro_get_canonical_block_by_number(self, block_number: BlockNumber) ->
         Raises HeaderNotFound if it is not found.
         """
         header = self._headerdb.get_canonical_block_header_by_number(block_number)
-        return await self.get_block_by_header(header)
+        return await self.coro_get_block_by_header(header)
 
     def get_canonical_block_hash(self, block_number: BlockNumber) -> Hash32:
         return self._headerdb.get_canonical_block_hash(block_number)
@@ -203,6 +203,15 @@ def create_unsigned_transaction(cls,
     def get_canonical_transaction(self, transaction_hash: Hash32) -> BaseTransaction:
         raise NotImplementedError("Chain classes must implement " + inspect.stack()[0][3])
 
+    async def coro_get_canonical_transaction(self, transaction_hash: Hash32) -> BaseTransaction:
+        raise NotImplementedError("Chain classes must implement " + inspect.stack()[0][3])
+
+    def get_transaction_receipt(self, transaction_hash: Hash32) -> Receipt:
+        raise NotImplementedError("Chain classes must implement " + inspect.stack()[0][3])
+
+    async def coro_get_transaction_receipt(self, transaction_hash: Hash32) -> Receipt:
+        raise NotImplementedError("Chain classes must implement " + inspect.stack()[0][3])
+
     #
     # Execution API
     #

trinity/rpc/format.py

@@ -29,6 +29,12 @@
 from eth.rlp.headers import (
     BlockHeader
 )
+from eth.rlp.logs import (
+    Log
+)
+from eth.rlp.receipts import (
+    Receipt
+)
 from eth.rlp.transactions import (
     BaseTransaction
 )
@@ -51,6 +57,15 @@ def transaction_to_dict(transaction: BaseTransaction) -> Dict[str, str]:
     )
 
 
+def receipt_to_dict(receipt: Receipt) -> Dict[str, Union[str, List[Log]]]:
+    return dict(
+        state_root=encode_hex(receipt.state_root),
+        gas_used=hex(receipt.gas_used),
+        bloom=hex(receipt.bloom),
+        logs=receipt.logs,
+    )
+
+
 hexstr_to_int = functools.partial(int, base=16)
 
 

trinity/rpc/modules/eth.py

@@ -36,6 +36,9 @@
 from eth.rlp.headers import (
     BlockHeader
 )
+from eth.rlp.logs import (
+    Log
+)
 from eth.vm.spoof import (
     SpoofTransaction,
 )
@@ -52,6 +55,7 @@
     header_to_dict,
     format_params,
     normalize_transaction_dict,
+    receipt_to_dict,
     to_int_if_hex,
     transaction_to_dict,
 )
@@ -247,6 +251,18 @@ async def getTransactionCount(self, address: Address, at_block: Union[str, int])
         nonce = account_db.get_nonce(address)
         return hex(nonce)
 
+    @format_params(decode_hex)
+    async def getTransactionByHash(self, transaction_hash: Hash32) -> Dict[str, str]:
+        transaction = self.chain.coro_get_canonical_transaction(transaction_hash)
+        return transaction_to_dict(transaction)
+
+    @format_params(decode_hex)
+    async def getTransactionReceipt(
+            self,
+            transaction_hash: Hash32) -> Dict[str, Union[str, List[Log]]]:
+        receipt = self.chain.coro_get_transaction_receipt(transaction_hash)
+        return receipt_to_dict(receipt)
+
     @format_params(decode_hex)
     async def getUncleCountByBlockHash(self, block_hash: Hash32) -> str:
         block = await self.chain.coro_get_block_by_hash(block_hash)