diff --git a/backend/moonstreamapi/actions.py b/backend/moonstreamapi/actions.py index 0c61df2c..597af7d5 100644 --- a/backend/moonstreamapi/actions.py +++ b/backend/moonstreamapi/actions.py @@ -38,6 +38,12 @@ from web3 import Web3 logger = logging.getLogger(__name__) +blockchain_by_subscription_id = { + "ethereum_blockchain": "ethereum", + "polygon_blockchain": "polygon", +} + + class StatusAPIException(Exception): """ Raised during checking Moonstream API statuses. @@ -409,7 +415,7 @@ def upload_abi_to_s3( bucket = MOONSTREAM_S3_SMARTCONTRACTS_ABI_BUCKET result_bytes = abi.encode("utf-8") - result_key = f"{MOONSTREAM_S3_SMARTCONTRACTS_ABI_PREFIX}/abi/{resource.resource_data['address']}/{resource.id}/abi.json" + result_key = f"{MOONSTREAM_S3_SMARTCONTRACTS_ABI_PREFIX}/{blockchain_by_subscription_id[resource.resource_data['subscription_type_id']]}/abi/{resource.resource_data['address']}/{resource.id}/abi.json" s3_client.put_object( Body=result_bytes, diff --git a/crawlers/mooncrawl/mooncrawl/stats_worker/dashboard.py b/crawlers/mooncrawl/mooncrawl/stats_worker/dashboard.py index 4da0114d..d5f5d83f 100644 --- a/crawlers/mooncrawl/mooncrawl/stats_worker/dashboard.py +++ b/crawlers/mooncrawl/mooncrawl/stats_worker/dashboard.py @@ -8,7 +8,7 @@ import logging import time from datetime import datetime, timedelta from enum import Enum -from typing import Any, Callable, Dict, List +from typing import Any, Dict, List import boto3 # type: ignore from bugout.data import BugoutResources @@ -465,8 +465,6 @@ def stats_generate_handler(args: argparse.Namespace): ) already_processed.append(f"{address}/{hash}") - time.sleep(10) - def main() -> None: parser = argparse.ArgumentParser(description="Command Line Interface")