mirror
/
moonstream
kopia lustrzana https://github.com/bugout-dev/moonstream
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność

Fix transactions insert.

pull/1085/head
Andrey 2024-06-14 19:50:18 +03:00
rodzic a4224285be
commit db25d3cacf
4 zmienionych plików z 7 dodań i 9 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

10
crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py
Wyświetl plik

@ -120,8 +120,6 @@ def _function_call_to_label(
origin_address=function_call.caller_address, origin_address=function_call.caller_address,
) )
print(label)
return label return label
@ -355,10 +353,10 @@ def add_function_calls_to_session(
"transaction_hash": label_function_call.transaction_hash, "transaction_hash": label_function_call.transaction_hash,
"log_index": None, "log_index": None,
"block_number": label_function_call.block_number, "block_number": label_function_call.block_number,
"block_hash": None, "block_hash": label_function_call.block_hash,
"block_timestamp": label_function_call.block_timestamp, "block_timestamp": label_function_call.block_timestamp,
"caller_address": label_function_call.label_data["caller"], "caller_address": label_function_call.caller_address,
"origin_address": None, "origin_address": label_function_call.caller_address,
"address": label_function_call.address, "address": label_function_call.address,
"label_name": label_function_call.label_name, "label_name": label_function_call.label_name,
"label_type": "tx_call", "label_type": "tx_call",
@ -370,7 +368,7 @@ def add_function_calls_to_session(
# Insert records using a single batched query with an ON CONFLICT clause # Insert records using a single batched query with an ON CONFLICT clause
statement = insert(table).values(records) statement = insert(table).values(records)
do_nothing_statement = statement.on_conflict_do_nothing( do_nothing_statement = statement.on_conflict_do_nothing(
index_elements=["transaction_hash", "log_index"], index_elements=["transaction_hash"],
index_where=(table.c.label == "seer") & (table.c.label_type == "tx_call"), index_where=(table.c.label == "seer") & (table.c.label_type == "tx_call"),
) )

1
crawlers/mooncrawl/mooncrawl/moonworm_crawler/function_call_crawler.py
Wyświetl plik

@ -43,7 +43,6 @@ def _crawl_functions(
"function_call", blockchain_type "function_call", blockchain_type
), ),
) )
print(f"Processing job {function_call_crawler.whitelisted_methods}")
function_call_crawler.crawl( function_call_crawler.crawl(
from_block, from_block,
to_block, to_block,

3
crawlers/mooncrawl/mooncrawl/moonworm_crawler/historical_crawler.py
Wyświetl plik

@ -156,11 +156,12 @@ def historical_crawler(
db_session, db_session,
all_function_calls[i : i + max_insert_batch], all_function_calls[i : i + max_insert_batch],
blockchain_type, blockchain_type,
version,
) )
else: else:
add_function_calls_to_session( add_function_calls_to_session(
db_session, all_function_calls, blockchain_type db_session, all_function_calls, blockchain_type, version
) )
if addresses_deployment_blocks: if addresses_deployment_blocks:

2
crawlers/mooncrawl/setup.py
Wyświetl plik

@ -38,7 +38,7 @@ setup(
"chardet", "chardet",
"fastapi", "fastapi",
"moonstreamdb>=0.4.4", "moonstreamdb>=0.4.4",
"moonstreamdb-v3>=0.0.9", "moonstreamdb-v3>=0.1.0",
"moonstream-types>=0.0.3", "moonstream-types>=0.0.3",
"moonstream>=0.1.1", "moonstream>=0.1.1",
"moonworm[moonstream]>=0.7.3", "moonworm[moonstream]>=0.7.3",