Merge pull request #643 from neonlabsorg/639-neon-api

Add implementation of neon_getSolanaTransactionByNeonTransaction. #639

Author: afalaleev

proxy/indexer/indexer_db.py

@@ -134,3 +134,6 @@ def get_contract_code(self, address) -> str:
 
     def fill_account_info_by_indexer(self, neon_account: str, pda_account: str, code_account: str, slot: int):
         self._account_db.set_acc_indexer(neon_account, pda_account, code_account, slot)
+
+    def get_sol_sign_list_by_neon_sign(self, neon_sign: str) -> [str]:
+        return self._txs_db.get_sol_sign_list_by_neon_sign(neon_sign)

proxy/indexer/transactions_db.py

@@ -22,6 +22,22 @@ def set_txs(self, neon_sign: str, used_ixs: [SolanaIxSignInfo]):
                 VALUES(%s, %s, %s, %s) ON CONFLICT DO NOTHING''',
                 rows)
 
+    def get_sol_sign_list_by_neon_sign(self, neon_sign: str) -> [str]:
+        request = f'''
+            SELECT sol_sign
+              FROM {self._table_name} AS a
+             WHERE neon_sign = %s
+        '''
+
+        with self._conn.cursor() as cursor:
+            cursor.execute(request, [neon_sign])
+            values = cursor.fetchall()
+
+        if not values:
+            return []
+
+        return [v[0] for v in values]
+
 
 class NeonTxsDB(BaseDB):
     def __init__(self):
@@ -112,3 +128,6 @@ def get_tx_list_by_sol_sign(self, sol_sign_list: [str]) -> [NeonTxFullInfo]:
             return []
 
         return [self._tx_from_value(v) for v in values if v is not None]
+
+    def get_sol_sign_list_by_neon_sign(self, neon_sign: str) -> [str]:
+        return self._sol_neon_txs_db.get_sol_sign_list_by_neon_sign(neon_sign)

proxy/memdb/memdb.py

@@ -59,3 +59,6 @@ def get_logs(self, from_block, to_block, addresses, topics, block_hash):
 
     def get_contract_code(self, address: str) -> str:
         return self._db.get_contract_code(address)
+
+    def get_sol_sign_list_by_neon_sign(self, neon_sign: str) -> [str]:
+        return self._db.get_sol_sign_list_by_neon_sign(neon_sign)

proxy/plugin/solana_rest_api.py

@@ -386,6 +386,12 @@ def eth_sendRawTransaction(self, rawTrx):
             # self.error(f"eth_sendRawTransaction type(err): {type(err}}, Exception: {err}")
             raise
 
+    def neon_getSolanaTransactionByNeonTransaction(self, neonTxId: str) -> [str]:
+        if not isinstance(neonTxId, str):
+            return []
+        return self._db.get_sol_sign_list_by_neon_sign(neonTxId)
+
+
 
 class JsonEncoder(json.JSONEncoder):
     def default(self, obj):