fixed mypy issue

backend/moonstream/providers/bugout.py

@@ -321,6 +321,34 @@ class EthereumTXPoolProvider(BugoutEventProvider):
         return subscriptions_filters
 
 
+class NftProvider(BugoutEventProvider):
+    def __init__(
+        self,
+        event_type: str,
+        description: str,
+        default_time_interval_seconds: int,
+        estimated_events_per_time_interval: float,
+        tags: Optional[List[str]] = None,
+        batch_size: int = 100,
+        timeout: float = 30.0,
+    ):
+
+        super().__init__(
+            event_type=event_type,
+            description=description,
+            default_time_interval_seconds=default_time_interval_seconds,
+            estimated_events_per_time_interval=estimated_events_per_time_interval,
+            tags=tags,
+            batch_size=batch_size,
+            timeout=timeout,
+        )
+
+    def parse_filters(
+        self, query: StreamQuery, user_subscriptions: Dict[str, List[BugoutResource]]
+    ) -> Optional[List[str]]:
+        return []
+
+
 whalewatch_description = """Event provider for Ethereum whale watch.
 
 Shows the top 10 addresses active on the Ethereum blockchain over the last hour in the following categories:
@@ -360,7 +388,7 @@ Currently, it summarizes the activities on the following NFT markets:
 
 This provider is currently not accessible for subscription. The data from this provider is publicly
 available at the /nft endpoint."""
-nft_summary_provider = BugoutEventProvider(
+nft_summary_provider = NftProvider(
     event_type="nft_summary",
     description=nft_summary_description,
     # 40 blocks per summary, 15 seconds per block + 2 seconds wiggle room.

backend/moonstream/routes/nft.py

@@ -7,6 +7,8 @@ from datetime import datetime
 import logging
 from typing import Optional
 
+from bugout.data import BugoutResource
+
 from fastapi import Depends, FastAPI, Query
 from moonstreamdb import db
 from fastapi.middleware.cors import CORSMiddleware
@@ -70,9 +72,7 @@ async def stream_handler(
         data_journal_id=MOONSTREAM_DATA_JOURNAL_ID,
         data_access_token=MOONSTREAM_ADMIN_ACCESS_TOKEN,
         stream_boundary=stream_boundary,
-        user_subscriptions={
+        user_subscriptions={nft_summary_provider.event_type: []},
-            nft_summary_provider.event_type: [nft_summary_provider.event_type]
-        },
         query=StreamQuery(subscription_types=[nft_summary_provider.event_type]),
     )