Merge pull request #293 from bugout-dev/bugout-provider-fix

Add ETHTXPOOL_HUMBUG_CLIENT_ID as env variable for escape desynchroni…

backend/moonstream/providers/bugout.py

@@ -16,6 +16,7 @@ from sqlalchemy.orm import Session
 from .. import data
 from ..stream_queries import StreamQuery
 
+from ..settings import ETHTXPOOL_HUMBUG_CLIENT_ID
 
 logger = logging.getLogger(__name__)
 logger.setLevel(logging.WARN)
@@ -376,7 +377,7 @@ ethereum_txpool_provider = EthereumTXPoolProvider(
     description=ethereum_txpool_description,
     default_time_interval_seconds=5,
     estimated_events_per_time_interval=50,
-    tags=["client:ethereum-txpool-crawler-0"],
+    tags=[f"client:{ETHTXPOOL_HUMBUG_CLIENT_ID}"],
 )
 
 nft_summary_description = """Event provider for NFT market summaries.

backend/moonstream/settings.py

@@ -46,6 +46,10 @@ for path in MOONSTREAM_OPENAPI_LIST:
 
 DEFAULT_STREAM_TIMEINTERVAL = 5 * 60
 
+ETHTXPOOL_HUMBUG_CLIENT_ID = os.environ.get(
+    "ETHTXPOOL_HUMBUG_CLIENT_ID", "client:ethereum-txpool-crawler-0"
+)
+
 # S3 Bucket
 ETHERSCAN_SMARTCONTRACTS_BUCKET = os.environ.get("AWS_S3_SMARTCONTRACT_BUCKET")
 if ETHERSCAN_SMARTCONTRACTS_BUCKET is None:

backend/sample.env

@@ -9,3 +9,4 @@ export AWS_S3_SMARTCONTRACT_BUCKET="<AWS S3 bucket to store smart contracts>"
 export BUGOUT_BROOD_URL="https://auth.bugout.dev"
 export BUGOUT_SPIRE_URL="https://spire.bugout.dev"
 export HUMBUG_REPORTER_BACKEND_TOKEN="<Bugout Humbug token for crash reports>"
+export ETHTXPOOL_HUMBUG_CLIENT_ID="<Bugout Humbug client id for txpool transactions in journal>"