fix: resolve type checking issues with Mapping refactor

- Fix BaseStore return types by converting Mapping to dict in get/ttl methods
- Update LoggingWrapper internal methods to accept Mapping types
- Fix test mock store to use Mapping instead of dict for protocol compatibility
- Fix ManagedEntry.to_json() to convert Mapping to dict
- Regenerate sync library with all fixes

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: William Easton <strawgate@users.noreply.github.com>

Author: github-actions[bot]

key-value/key-value-aio/src/key_value/aio/stores/base.py

@@ -134,15 +134,15 @@ async def get(
         if managed_entry.is_expired:
             return None
 
-        return managed_entry.value
+        return dict(managed_entry.value)
 
     @override
     async def get_many(self, keys: list[str], *, collection: str | None = None) -> list[dict[str, Any] | None]:
         collection = collection or self.default_collection
         await self.setup_collection(collection=collection)
 
         entries = await self._get_managed_entries(keys=keys, collection=collection)
-        return [entry.value if entry and not entry.is_expired else None for entry in entries]
+        return [dict(entry.value) if entry and not entry.is_expired else None for entry in entries]
 
     @override
     async def ttl(self, key: str, *, collection: str | None = None) -> tuple[dict[str, Any] | None, float | None]:
@@ -154,7 +154,7 @@ async def ttl(self, key: str, *, collection: str | None = None) -> tuple[dict[st
         if not managed_entry or managed_entry.is_expired:
             return (None, None)
 
-        return (managed_entry.value, managed_entry.ttl)
+        return (dict(managed_entry.value), managed_entry.ttl)
 
     @override
     async def ttl_many(
@@ -172,7 +172,7 @@ async def ttl_many(
         await self.setup_collection(collection=collection)
 
         entries = await self._get_managed_entries(keys=keys, collection=collection)
-        return [(entry.value, entry.ttl) if entry and not entry.is_expired else (None, None) for entry in entries]
+        return [(dict(entry.value), entry.ttl) if entry and not entry.is_expired else (None, None) for entry in entries]
 
     @abstractmethod
     async def _put_managed_entry(self, *, collection: str, key: str, managed_entry: ManagedEntry) -> None:

key-value/key-value-aio/src/key_value/aio/wrappers/logging/wrapper.py

@@ -59,7 +59,7 @@ def _format_message(
         action: str,
         keys: list[str] | str,
         collection: str | None,
-        values: dict[str, Any] | Sequence[dict[str, Any]] | None = None,
+        values: Mapping[str, Any] | Sequence[Mapping[str, Any]] | None = None,
         extra: dict[str, Any] | None = None,
     ) -> str:
         if self.structured_logs:
@@ -92,7 +92,7 @@ def _log(
         action: str,
         keys: list[str] | str,
         collection: str | None,
-        values: dict[str, Any] | Sequence[dict[str, Any]] | None = None,
+        values: Mapping[str, Any] | Sequence[Mapping[str, Any]] | None = None,
         extra: dict[str, Any] | None = None,
     ) -> None:
         self.logger.log(

key-value/key-value-aio/tests/stores/wrappers/test_fallback.py

@@ -1,3 +1,4 @@
+from collections.abc import Mapping
 from typing import Any, SupportsFloat
 
 import pytest
@@ -15,7 +16,7 @@ async def get(self, key: str, *, collection: str | None = None) -> dict[str, Any
         msg = "Primary store unavailable"
         raise ConnectionError(msg)
 
-    async def put(self, key: str, value: dict[str, Any], *, collection: str | None = None, ttl: SupportsFloat | None = None):  # noqa: ARG002
+    async def put(self, key: str, value: Mapping[str, Any], *, collection: str | None = None, ttl: SupportsFloat | None = None):  # noqa: ARG002
         msg = "Primary store unavailable"
         raise ConnectionError(msg)
 

key-value/key-value-shared/src/key_value/shared/utils/managed_entry.py

@@ -54,7 +54,7 @@ def to_json(self, include_metadata: bool = True, include_expiration: bool = True
             if include_expiration and self.expires_at:
                 data["expires_at"] = self.expires_at.isoformat()
         else:
-            data = self.value
+            data = dict(self.value)
 
         return dump_to_json(obj=data)
 

key-value/key-value-sync/src/key_value/sync/code_gen/stores/base.py

@@ -132,15 +132,15 @@ def get(self, key: str, *, collection: str | None = None) -> dict[str, Any] | No
         if managed_entry.is_expired:
             return None
 
-        return managed_entry.value
+        return dict(managed_entry.value)
 
     @override
     def get_many(self, keys: list[str], *, collection: str | None = None) -> list[dict[str, Any] | None]:
         collection = collection or self.default_collection
         self.setup_collection(collection=collection)
 
         entries = self._get_managed_entries(keys=keys, collection=collection)
-        return [entry.value if entry and (not entry.is_expired) else None for entry in entries]
+        return [dict(entry.value) if entry and (not entry.is_expired) else None for entry in entries]
 
     @override
     def ttl(self, key: str, *, collection: str | None = None) -> tuple[dict[str, Any] | None, float | None]:
@@ -152,7 +152,7 @@ def ttl(self, key: str, *, collection: str | None = None) -> tuple[dict[str, Any
         if not managed_entry or managed_entry.is_expired:
             return (None, None)
 
-        return (managed_entry.value, managed_entry.ttl)
+        return (dict(managed_entry.value), managed_entry.ttl)
 
     @override
     def ttl_many(self, keys: list[str], *, collection: str | None = None) -> list[tuple[dict[str, Any] | None, float | None]]:
@@ -165,7 +165,7 @@ def ttl_many(self, keys: list[str], *, collection: str | None = None) -> list[tu
         self.setup_collection(collection=collection)
 
         entries = self._get_managed_entries(keys=keys, collection=collection)
-        return [(entry.value, entry.ttl) if entry and (not entry.is_expired) else (None, None) for entry in entries]
+        return [(dict(entry.value), entry.ttl) if entry and (not entry.is_expired) else (None, None) for entry in entries]
 
     @abstractmethod
     def _put_managed_entry(self, *, collection: str, key: str, managed_entry: ManagedEntry) -> None:

key-value/key-value-sync/src/key_value/sync/code_gen/wrappers/logging/wrapper.py

@@ -62,7 +62,7 @@ def _format_message(
         action: str,
         keys: list[str] | str,
         collection: str | None,
-        values: dict[str, Any] | Sequence[dict[str, Any]] | None = None,
+        values: Mapping[str, Any] | Sequence[Mapping[str, Any]] | None = None,
         extra: dict[str, Any] | None = None,
     ) -> str:
         if self.structured_logs:
@@ -90,7 +90,7 @@ def _log(
         action: str,
         keys: list[str] | str,
         collection: str | None,
-        values: dict[str, Any] | Sequence[dict[str, Any]] | None = None,
+        values: Mapping[str, Any] | Sequence[Mapping[str, Any]] | None = None,
         extra: dict[str, Any] | None = None,
     ) -> None:
         self.logger.log(

key-value/key-value-sync/tests/code_gen/stores/wrappers/test_fallback.py

@@ -1,6 +1,7 @@
 # WARNING: this file is auto-generated by 'build_sync_library.py'
 # from the original file 'test_fallback.py'
 # DO NOT CHANGE! Change the original file instead.
+from collections.abc import Mapping
 from typing import Any, SupportsFloat
 
 import pytest
@@ -18,7 +19,7 @@ def get(self, key: str, *, collection: str | None = None) -> dict[str, Any] | No
         msg = "Primary store unavailable"
         raise ConnectionError(msg)
 
-    def put(self, key: str, value: dict[str, Any], *, collection: str | None = None, ttl: SupportsFloat | None = None):  # noqa: ARG002
+    def put(self, key: str, value: Mapping[str, Any], *, collection: str | None = None, ttl: SupportsFloat | None = None):  # noqa: ARG002
         msg = "Primary store unavailable"
         raise ConnectionError(msg)