refactor: migrate from Sentry to Logfire for error tracking and logging

Author: HitaloM

docs/source/privacy.md

@@ -31,13 +31,14 @@ All collected data is made available by the Telegram API in a public way, note t
 - **Type**: The type of the group (`supergroup` or `group`).
 - **Registration Date**: The date when the _PyKorone_ bot saw the group for the first time.
 
-### Crashlytics
+### Observability
 
-_PyKorone_ uses [Sentry](https://sentry.io/) to collect crash reports and improve the stability of the software. Crashlytics collects the same data as _PyKorone_, plus extra details of the crash itself. By using _PyKorone_ you agree to the [Sentry's privacy policy](https://sentry.io/privacy) as well.
+_PyKorone_ uses [Pydantic Logfire](https://logfire.pydantic.dev/) to collect crash reports and improve the stability of the software. Logfire collects the same data as _PyKorone_, plus extra details of the crash itself to help diagnose issues. By using _PyKorone_ you agree to the [Logfire privacy policy](https://pydantic.dev/legal/privacy-policy) as well.
 
 #### Crash Data
 
 The data displayed below is collected by crashlytics and is not stored permanently. It is used exclusively for debugging purposes.
 
 - Crash [traceback](https://en.wikipedia.org/wiki/Stack_trace).
 - [Telegram update](https://core.telegram.org/api/updates) that caused the crash.
+- Logfire trace identifier used to correlate the incident.

pyproject.toml

@@ -23,12 +23,12 @@ dependencies = [
     "yt-dlp>=2025.2.19",
     "magic-filter>=1.0.12",
     "tomlkit>=0.13.2",
-    "sentry-sdk>=2.22.0",
     "pydantic>=2.10.6",
     "orjson>=3.10.15",
     "aiocron>=2.1",
     "m3u8>=6.0.0",
     "aiofiles>=24.1.0",
+    "logfire[httpx]>=4.11.0",
 ]
 readme = "README.md"
 license = { file = "LICENSE" }

src/korone/__init__.py

@@ -1,4 +1,4 @@
 # SPDX-License-Identifier: BSD-3-Clause
 # Copyright (c) 2025 Hitalo M. <https://github.com/HitaloM>
 
-__version__ = "2025.10.03"
+__version__ = "2025.10.05"

src/korone/__main__.py

@@ -7,7 +7,7 @@
 from contextlib import suppress
 from pathlib import Path
 
-import sentry_sdk
+import logfire
 import uvloop
 from cashews.exceptions import CacheBackendInteractionError
 from hydrogram import idle
@@ -16,7 +16,6 @@
 from .client import AppParameters, Korone
 from .config import ConfigManager
 from .database.sqlite.connection import SQLite3Connection
-from .modules.errors.utils import IGNORED_EXCEPTIONS
 from .utils.caching import cache
 from .utils.logging import logger
 
@@ -38,13 +37,20 @@ async def pre_process() -> ConfigManager:
 
     config = ConfigManager()
 
-    if sentry_dsn := config.get("korone", "SENTRY_DSN"):
-        await logger.ainfo("Initializing Sentry integration")
-        sentry_sdk.init(
-            dsn=sentry_dsn,
-            release=__version__,
-            ignore_errors=IGNORED_EXCEPTIONS,
-        )
+    await logger.ainfo("Configuring Logfire integration")
+    logfire_token = (config.get("korone", "LOGFIRE_TOKEN") or "").strip() or None
+    logfire_environment = (
+        config.get("korone", "LOGFIRE_ENVIRONMENT", "production") or "production"
+    ).strip()
+
+    logfire.configure(
+        service_name="korone-bot",
+        service_version=__version__,
+        token=logfire_token,
+        send_to_logfire="if-token-present",
+        environment=logfire_environment,
+    )
+    logfire.instrument_httpx()
 
     async with SQLite3Connection() as conn:
         await conn.execute(constants.SQLITE3_TABLES, script=True)

src/korone/constants.py

@@ -24,7 +24,8 @@
         "SUDOERS": ["918317361"],
         "LOGS_CHAT": "-100123456789",
         "BACKUPS_CHAT": "-100123456789",
-        "SENTRY_DSN": "",
+        "LOGFIRE_TOKEN": "",
+        "LOGFIRE_ENVIRONMENT": "production",
         "DEEPL_KEY": "",
         "LASTFM_KEY": "",
         "CORS_BYPASS": "",

src/korone/database/sqlite/connection.py

@@ -11,7 +11,7 @@
 
 from korone import constants
 from korone.database.connection import Connection
-from korone.utils.logging import logger
+from korone.utils.logging import get_logger
 
 from .table import SQLite3Table
 
@@ -20,6 +20,8 @@
 
     from korone.database.table import Table
 
+logger = get_logger(__name__)
+
 
 class SQLite3Connection(Connection):
     """SQLite3 implementation of the database connection protocol.

src/korone/filters/sudo.py

@@ -9,7 +9,9 @@
 from hydrogram.types import CallbackQuery, Message
 
 from korone.config import ConfigManager
-from korone.utils.logging import logger
+from korone.utils.logging import get_logger
+
+logger = get_logger(__name__)
 
 
 def load_sudoers() -> set[int]:

src/korone/modules/core.py

@@ -12,7 +12,7 @@
 
 from korone.database.query import Query
 from korone.database.sqlite import SQLite3Connection
-from korone.utils.logging import logger
+from korone.utils.logging import get_logger
 
 if TYPE_CHECKING:
     from types import ModuleType
@@ -22,6 +22,8 @@
 
     from korone.database.table import Documents
 
+logger = get_logger(__name__)
+
 MODULES: dict[str, dict[str, list[str]]] = {}
 COMMANDS: dict[str, dict[str, Any]] = {}
 

src/korone/modules/errors/handlers/catcher.py

@@ -4,6 +4,7 @@
 import sys
 from traceback import format_exception
 
+import logfire
 from hydrogram import Client
 from hydrogram.errors import ChatWriteForbidden
 from hydrogram.types import (
@@ -14,13 +15,15 @@
     Message,
     Update,
 )
-from sentry_sdk import capture_exception
+from opentelemetry.trace import format_trace_id
 
 from korone import constants
 from korone.decorators import router
 from korone.modules.errors.utils import IGNORED_EXCEPTIONS
 from korone.utils.i18n import gettext as _
-from korone.utils.logging import logger
+from korone.utils.logging import get_logger
+
+logger = get_logger(__name__)
 
 
 @router.error()
@@ -38,15 +41,28 @@ async def handle_error(client: Client, update: Update, exception: Exception) ->
         await logger.aerror("[ErrorHandler] Missing exception info", exception=exception)
         return
 
-    sentry_event_id = capture_exception(exception)
     formatted_exception = format_exception(etype, value, tb)
-    await log_exception_details(formatted_exception, sentry_event_id)
+    trace_reference: str | None = None
+
+    with logfire.span(
+        "Unhandled update exception",
+        update_type=type(update).__name__,
+        chat_id=chat.id if chat else None,
+    ) as span:
+        span.record_exception(exception)
+        if chat:
+            span.set_attribute("telegram.chat_type", chat.type)
+        span_context = span.get_span_context()
+        if span_context:
+            trace_reference = format_trace_id(span_context.trace_id)
+
+    await log_exception_details(formatted_exception, trace_reference)
 
     if not chat:
         await logger.aerror("[ErrorHandler] No chat for update", update=update)
         return
 
-    await send_error_message(client, chat, sentry_event_id)
+    await send_error_message(client, chat, trace_reference)
 
 
 def get_chat_from_update(update: Update) -> Chat | None:
@@ -71,16 +87,16 @@ async def handle_ignored_exceptions(
 
 
 async def log_exception_details(
-    formatted_exception: list[str], sentry_event_id: str | None
+    formatted_exception: list[str], trace_reference: str | None
 ) -> None:
     await logger.aerror("".join(formatted_exception))
-    await logger.aerror("[ErrorHandler] Additional error data", sentry_event_id=sentry_event_id)
+    await logger.aerror("[ErrorHandler] Additional error data", trace_reference=trace_reference)
 
 
-async def send_error_message(client: Client, chat: Chat, sentry_event_id: str | None) -> None:
+async def send_error_message(client: Client, chat: Chat, trace_reference: str | None) -> None:
     text = _("An unexpected error occurred while processing this update! :/")
-    if sentry_event_id:
-        text += _("\nReference ID: {id}").format(id=sentry_event_id)
+    if trace_reference:
+        text += _("\nTrace ID: {id}").format(id=trace_reference)
 
     keyboard = InlineKeyboardMarkup([
         [

src/korone/modules/gsm_arena/handlers/get.py

@@ -12,7 +12,9 @@
 from korone.modules.gsm_arena.callback_data import GetDeviceCallback
 from korone.modules.gsm_arena.utils.scraper import check_phone_details, format_phone
 from korone.utils.i18n import gettext as _
-from korone.utils.logging import logger
+from korone.utils.logging import get_logger
+
+logger = get_logger(__name__)
 
 
 @router.callback_query(GetDeviceCallback.filter())