|
3 | 3 |
|
4 | 4 | from offchain.concurrency import batched_parmap |
5 | 5 | from offchain.logger.logging import logger |
6 | | -from offchain.metadata.adapters import ( # type: ignore[attr-defined] |
7 | | - ARWeaveAdapter, |
8 | | - DataURIAdapter, |
9 | | - HTTPAdapter, |
10 | | - IPFSAdapter, |
11 | | -) |
12 | | -from offchain.metadata.adapters.base_adapter import Adapter, AdapterConfig |
| 6 | +from offchain.metadata.adapters import Adapter, AdapterConfig, DEFAULT_ADAPTER_CONFIGS |
13 | 7 | from offchain.metadata.fetchers.base_fetcher import BaseFetcher |
14 | 8 | from offchain.metadata.fetchers.metadata_fetcher import MetadataFetcher |
15 | 9 | from offchain.metadata.models.metadata import Metadata |
|
23 | 17 | from offchain.metadata.registries.parser_registry import ParserRegistry |
24 | 18 | from offchain.web3.contract_caller import ContractCaller |
25 | 19 |
|
26 | | -# TODO(luke): move the data repo's usage of this symbol to the new file, then remove this |
27 | | -DEFAULT_ADAPTER_CONFIGS: list[AdapterConfig] = [ |
28 | | - AdapterConfig( |
29 | | - adapter_cls=ARWeaveAdapter, |
30 | | - mount_prefixes=["ar://"], |
31 | | - host_prefixes=["https://arweave.net/"], |
32 | | - kwargs={"pool_connections": 100, "pool_maxsize": 1000, "max_retries": 0}, |
33 | | - ), |
34 | | - AdapterConfig(adapter_cls=DataURIAdapter, mount_prefixes=["data:"]), |
35 | | - AdapterConfig( |
36 | | - adapter_cls=IPFSAdapter, |
37 | | - mount_prefixes=[ |
38 | | - "ipfs://", |
39 | | - "https://gateway.pinata.cloud/", |
40 | | - "https://ipfs.io/", |
41 | | - ], |
42 | | - host_prefixes=["https://gateway.pinata.cloud/ipfs/"], |
43 | | - kwargs={"pool_connections": 100, "pool_maxsize": 1000, "max_retries": 0}, |
44 | | - ), |
45 | | - AdapterConfig( |
46 | | - adapter_cls=HTTPAdapter, |
47 | | - mount_prefixes=["https://", "http://"], |
48 | | - kwargs={"pool_connections": 100, "pool_maxsize": 1000, "max_retries": 0}, |
49 | | - ), |
50 | | -] |
51 | 20 |
|
52 | 21 | DEFAULT_PARSERS = ( |
53 | 22 | ParserRegistry.get_all_collection_parsers() |
@@ -80,10 +49,6 @@ def __init__( |
80 | 49 | self.contract_caller = contract_caller or ContractCaller() |
81 | 50 | self.fetcher = fetcher or MetadataFetcher(async_adapter_configs=adapter_configs) |
82 | 51 | if adapter_configs is None: |
83 | | - # TODO(luke): move the line below to the file's import section once this |
84 | | - # file's DEFAULT_ADAPTER_CONFIGS is gone |
85 | | - from offchain.metadata.adapters import DEFAULT_ADAPTER_CONFIGS |
86 | | - |
87 | 52 | adapter_configs = DEFAULT_ADAPTER_CONFIGS |
88 | 53 | for adapter_config in adapter_configs: |
89 | 54 | self.mount_adapter( |
|
0 commit comments