Add changes.

moonstreamapi/moonstreamapi/settings.py

@@ -164,23 +164,22 @@ NB_ACCESS_ID_HEADER = os.environ.get("NB_ACCESS_ID_HEADER", "x-node-balancer-acc
 NB_DATA_SOURCE_HEADER = os.environ.get(
     "NB_DATA_SOURCE_HEADER", "x-node-balancer-data-source"
 )
-
-NB_CONTROLLER_ACCESS_ID: Optional[UUID] = None
-NB_CONTROLLER_ACCESS_ID_RAW = os.environ.get("NB_CONTROLLER_ACCESS_ID", "")
-try:
-    NB_CONTROLLER_ACCESS_ID = UUID(NB_CONTROLLER_ACCESS_ID_RAW)
-except:
-    pass
+NB_DATA_SOURCE_HEADER_VALUE = os.environ.get(
+    "NB_DATA_SOURCE_HEADER_VALUE", "blockchain"
+)
 
 
 support_interfaces = [
     {"name": "_INTERFACE_ID_ERC165", "selector": "0x01ffc9a7"},
     {"name": "_INTERFACE_ID_ERC20", "selector": "0x36372b07"},
     {"name": "_INTERFACE_ID_ERC721", "selector": "0x80ac58cd"},
-    {"name": "_INTERFACE_ID_ERC721_METADATA", "selector": "0x5b5e139f"}, # miss
-    {"name": "_INTERFACE_ID_ERC721_ENUMERABLE", "selector": "0x780e9d63"}, # miss
+    {"name": "_INTERFACE_ID_ERC721_METADATA", "selector": "0x5b5e139f"},  # miss
+    {"name": "_INTERFACE_ID_ERC721_ENUMERABLE", "selector": "0x780e9d63"},  # miss
     {"name": "_INTERFACE_ID_ERC721_RECEIVED", "selector": "0x150b7a02"},
-    {"name": "_INTERFACE_ID_ERC721_METADATA_RECEIVED", "selector": "0x0e89341c"}, # miss
+    {
+        "name": "_INTERFACE_ID_ERC721_METADATA_RECEIVED",
+        "selector": "0x0e89341c",
+    },  # miss
     {"name": "_INTERFACE_ID_ERC721_ENUMERABLE_RECEIVED", "selector": "0x4e2312e0"},
     {"name": "_INTERFACE_ID_ERC1155", "selector": "0xd9b67a26"},
 ]

moonstreamapi/moonstreamapi/web3_provider.py

@@ -18,6 +18,7 @@ from .settings import (
     MOONSTREAM_ETHEREUM_WEB3_PROVIDER_URI,
     NB_ACCESS_ID_HEADER,
     NB_DATA_SOURCE_HEADER,
+    NB_DATA_SOURCE_HEADER_VALUE,
     MOONSTREAM_POLYGON_WEB3_PROVIDER_URI,
     MOONSTREAM_MUMBAI_WEB3_PROVIDER_URI,
     MOONSTREAM_XDAI_WEB3_PROVIDER_URI,
@@ -47,13 +48,12 @@ def connect(
     access_id: Optional[UUID] = None,
     async_: bool = False,
 ) -> Web3:
-
     request_kwargs: Any = None
     if access_id is not None:
         request_kwargs = {
             "headers": {
                 NB_ACCESS_ID_HEADER: str(access_id),
-                NB_DATA_SOURCE_HEADER: "blockchain",
+                NB_DATA_SOURCE_HEADER: NB_DATA_SOURCE_HEADER_VALUE,
                 "Content-Type": "application/json",
             }
         }
@@ -78,8 +78,6 @@ def connect(
     else:
         web3_client = Web3(Web3.IPCProvider(web3_uri))
 
-    # Inject --dev middleware if it is not Ethereum mainnet
-    # Docs: https://web3py.readthedocs.io/en/stable/middleware.html#geth-style-proof-of-authority
     if blockchain_type != AvailableBlockchainType.ETHEREUM:
         web3_client.middleware_onion.inject(geth_poa_middleware, layer=0)