add dsn support, service in options, sdk metadata

Author: Polliog

CHANGELOG.md

@@ -5,6 +5,18 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.9.3] - 2026-06-11
+
+### Added
+
+- DSN support: `ClientOptions(dsn="https://lp_key@host[/path]")` (plus `parse_dsn` / `DsnParseError` exported from the package root). Explicit `api_url` + `api_key` keep working; a malformed DSN raises at init time
+- `ClientOptions.service`: configure the service once and call log methods with just the message — `client.info("user logged in")`, `client.error("boom", exc)`. The legacy `(service, message)` form keeps working
+- Every entry now carries `metadata.sdk = {"name": "logtide-python", "version": ...}` (caller-provided `sdk` key wins)
+
+### Fixed
+
+- `logtide_sdk.__version__` was stale (0.9.1); version now has a single runtime source (`logtide_sdk._version`)
+
 ## [0.9.2] - 2026-06-11
 
 ### Added

logtide_sdk/__init__.py

@@ -1,6 +1,7 @@
 """LogTide SDK - Official Python SDK for LogTide."""
 
 from logtide_sdk.client import LogTideClient, serialize_exception
+from logtide_sdk.dsn import DsnParseError, DsnParts, parse_dsn
 from logtide_sdk.tracecontext import (
     TraceContext,
     format_traceparent,
@@ -31,7 +32,7 @@
 except ImportError:
     pass
 
-__version__ = "0.9.1"
+from logtide_sdk._version import VERSION as __version__
 
 __all__ = [
     "AggregatedStatsOptions",
@@ -48,11 +49,14 @@
     "LogTideHandler",
     "LogsResponse",
     "PayloadLimitsOptions",
+    "DsnParseError",
+    "DsnParts",
     "QueryOptions",
     "TraceContext",
     "format_traceparent",
     "generate_span_id",
     "generate_trace_id",
+    "parse_dsn",
     "parse_traceparent",
     "resolve_trace_id",
     "serialize_exception",

logtide_sdk/_version.py

@@ -0,0 +1,8 @@
+"""Single source of truth for the SDK version at runtime.
+
+Kept in its own module (instead of ``__init__``) so internal modules can
+import it without circular imports. Bump together with ``pyproject.toml``.
+"""
+
+VERSION = "0.9.3"
+SDK_NAME = "logtide-python"

logtide_sdk/async_client.py

@@ -21,6 +21,7 @@
 from logtide_sdk.enums import CircuitState, LogLevel
 from logtide_sdk.exceptions import CircuitBreakerOpenError
 from logtide_sdk.json_encoder import logtide_json_dumps
+from logtide_sdk._version import SDK_NAME, VERSION
 from logtide_sdk.tracecontext import generate_trace_id
 from logtide_sdk.models import (
     AggregatedStatsOptions,
@@ -164,6 +165,10 @@ async def log(self, entry: LogEntry) -> None:
         if self.options.global_metadata:
             entry.metadata = {**self.options.global_metadata, **entry.metadata}
 
+        # Stamp SDK identity (spec 003 §3); caller-provided value wins
+        if "sdk" not in entry.metadata:
+            entry.metadata["sdk"] = {"name": SDK_NAME, "version": VERSION}
+
         self._apply_payload_limits(entry)
 
         should_flush = False
@@ -183,85 +188,114 @@ async def log(self, entry: LogEntry) -> None:
         if should_flush:
             await self.flush()
 
+    def _resolve_call(
+        self,
+        service_or_message: str,
+        message_or_payload: Any,
+        payload: Any,
+    ) -> tuple[str, str, Any]:
+        """Support both call forms (spec 004 §3); see LogTideClient._resolve_call."""
+        if isinstance(message_or_payload, str):
+            return service_or_message, message_or_payload, payload
+        if self.options.service is None:
+            raise ValueError(
+                "No service configured: set ClientOptions.service to call "
+                "log methods with just a message, or pass (service, message)"
+            )
+        resolved_payload = message_or_payload if message_or_payload is not None else payload
+        return self.options.service, service_or_message, resolved_payload
+
     async def debug(
         self,
-        service: str,
-        message: str,
+        service_or_message: str,
+        message: str | dict[str, Any] | None = None,
         metadata: dict[str, Any] | None = None,
         *,
         trace_id: str | None = None,
         span_id: str | None = None,
     ) -> None:
         """Log a DEBUG-level message."""
+        service, resolved_message, resolved_metadata = self._resolve_call(
+            service_or_message, message, metadata
+        )
         await self.log(
             LogEntry(
                 service=service,
                 level=LogLevel.DEBUG,
-                message=message,
-                metadata=metadata or {},
+                message=resolved_message,
+                metadata=resolved_metadata or {},
                 trace_id=trace_id,
                 span_id=span_id,
             )
         )
 
     async def info(
         self,
-        service: str,
-        message: str,
+        service_or_message: str,
+        message: str | dict[str, Any] | None = None,
         metadata: dict[str, Any] | None = None,
         *,
         trace_id: str | None = None,
         span_id: str | None = None,
     ) -> None:
         """Log an INFO-level message."""
+        service, resolved_message, resolved_metadata = self._resolve_call(
+            service_or_message, message, metadata
+        )
         await self.log(
             LogEntry(
                 service=service,
                 level=LogLevel.INFO,
-                message=message,
-                metadata=metadata or {},
+                message=resolved_message,
+                metadata=resolved_metadata or {},
                 trace_id=trace_id,
                 span_id=span_id,
             )
         )
 
     async def warn(
         self,
-        service: str,
-        message: str,
+        service_or_message: str,
+        message: str | dict[str, Any] | None = None,
         metadata: dict[str, Any] | None = None,
         *,
         trace_id: str | None = None,
         span_id: str | None = None,
     ) -> None:
         """Log a WARN-level message."""
+        service, resolved_message, resolved_metadata = self._resolve_call(
+            service_or_message, message, metadata
+        )
         await self.log(
             LogEntry(
                 service=service,
                 level=LogLevel.WARN,
-                message=message,
-                metadata=metadata or {},
+                message=resolved_message,
+                metadata=resolved_metadata or {},
                 trace_id=trace_id,
                 span_id=span_id,
             )
         )
 
     async def error(
         self,
-        service: str,
-        message: str,
+        service_or_message: str,
+        message: str | dict[str, Any] | Exception | None = None,
         metadata_or_error: dict[str, Any] | Exception | None = None,
         *,
         trace_id: str | None = None,
         span_id: str | None = None,
     ) -> None:
         """Log an ERROR-level message. Accepts an Exception for automatic serialization."""
-        metadata = self._process_metadata_or_error(metadata_or_error)
+        service, resolved_message, payload = self._resolve_call(
+            service_or_message, message, metadata_or_error
+        )
+        metadata = self._process_metadata_or_error(payload)
         await self.log(
             LogEntry(
                 service=service,
                 level=LogLevel.ERROR,
-                message=message,
+                message=resolved_message,
                 metadata=metadata,
                 trace_id=trace_id,
                 span_id=span_id,
@@ -270,20 +304,23 @@ async def error(
 
     async def critical(
         self,
-        service: str,
-        message: str,
+        service_or_message: str,
+        message: str | dict[str, Any] | Exception | None = None,
         metadata_or_error: dict[str, Any] | Exception | None = None,
         *,
         trace_id: str | None = None,
         span_id: str | None = None,
     ) -> None:
         """Log a CRITICAL-level message. Accepts an Exception for automatic serialization."""
-        metadata = self._process_metadata_or_error(metadata_or_error)
+        service, resolved_message, payload = self._resolve_call(
+            service_or_message, message, metadata_or_error
+        )
+        metadata = self._process_metadata_or_error(payload)
         await self.log(
             LogEntry(
                 service=service,
                 level=LogLevel.CRITICAL,
-                message=message,
+                message=resolved_message,
                 metadata=metadata,
                 trace_id=trace_id,
                 span_id=span_id,