Sentry integration

pyproject.toml

@@ -32,6 +32,7 @@ aiosignalrcore = "^0.9.2"
 fcache = "^0.4.7"
 click = "^8.0.1"
 pyee = "^8.1.0"
+sentry-sdk = "^1.1.0"
 
 [tool.poetry.dev-dependencies]
 black = "^20.8b1"

src/dipdup/cli.py

@@ -8,7 +8,9 @@
 from typing import List, NoReturn
 
 import click
+import sentry_sdk
 from fcache.cache import FileCache  # type: ignore
+from sentry_sdk.integrations.aiohttp import AioHttpIntegration
 
 from dipdup import __spec_version__, __version__
 from dipdup.config import DipDupConfig, LoggingConfig
@@ -80,6 +82,12 @@ async def cli(ctx, config: List[str], logging_config: str):
     if _config.spec_version != __spec_version__ and ctx.invoked_subcommand != 'migrate':
         migration_required(_config.spec_version, __spec_version__)
 
+    if _config.sentry:
+        sentry_sdk.init(
+            dsn=_config.sentry.dsn,
+            integrations=[AioHttpIntegration()],
+        )
+
     ctx.obj = CLIContext(
         config_paths=config,
         config=_config,

src/dipdup/config.py

@@ -608,6 +608,11 @@ def valid_url(cls, v):
         return v
 
 
+@dataclass
+class SentryConfig:
+    dsn: str
+
+
 @dataclass
 class DipDupConfig:
     """Main dapp config
@@ -620,6 +625,7 @@ class DipDupConfig:
     :param templates: Mapping of template aliases and index templates
     :param database: Database config
     :param hasura: Hasura config
+    :param sentry: Sentry integration config
     """
 
     spec_version: str
@@ -630,6 +636,7 @@ class DipDupConfig:
     templates: Optional[Dict[str, IndexConfigTemplateT]] = None
     database: Union[SqliteDatabaseConfig, PostgresDatabaseConfig] = SqliteDatabaseConfig(kind='sqlite')
     hasura: Optional[HasuraConfig] = None
+    sentry: Optional[SentryConfig] = None
 
     def __post_init_post_parse__(self):
         self._callback_patterns: Dict[str, List[Sequence[HandlerPatternConfigT]]] = defaultdict(list)