Fix ipfs datasource config (#225)

Author: droserasprout

CHANGELOG.md

@@ -2,6 +2,12 @@
 
 Please use [this](https://docs.gitlab.com/ee/development/changelog.html) document as guidelines to keep a changelog.
 
+## 4.2.2 - 2022-02-01
+
+### Fixed
+
+* config: Fixed `ipfs` datasource config.
+
 ## 4.2.1 - 2022-01-31
 
 ### Fixed

src/dipdup/config.py

@@ -194,7 +194,7 @@ def valid_address(cls, v):
         return v
 
 
-# NOTE: Don't forget `http` in all datasource configs
+# NOTE: Don't forget `http` and `__hash__` in all datasource configs
 @dataclass
 class TzktDatasourceConfig(NameMixin):
     """TzKT datasource config
@@ -287,12 +287,16 @@ class IpfsDatasourceConfig(NameMixin):
     url: str = DEFAULT_IPFS_URL
     http: Optional[HTTPConfig] = None
 
+    def __hash__(self):
+        return hash(self.kind + self.url)
+
 
 DatasourceConfigT = Union[
     TzktDatasourceConfig,
     BcdDatasourceConfig,
     CoinbaseDatasourceConfig,
     MetadataDatasourceConfig,
+    IpfsDatasourceConfig,
 ]
 
 

src/dipdup/datasources/ipfs/datasource.py

@@ -1,4 +1,6 @@
+import logging
 from typing import Any
+from typing import Optional
 
 from dipdup.config import HTTPConfig
 from dipdup.datasources.datasource import Datasource
@@ -9,6 +11,10 @@ class IpfsDatasource(Datasource):
         retry_count=1,
     )
 
+    def __init__(self, url, http_config: Optional[HTTPConfig] = None) -> None:
+        super().__init__(url, self._default_http_config.merge(http_config))
+        self._logger = logging.getLogger('dipdup.ipfs')
+
     async def run(self) -> None:
         pass