Remove ValueOnlySerializer

Author: strawgate

key-value/key-value-aio/src/key_value/aio/stores/simple/store.py

@@ -5,7 +5,7 @@
 
 from key_value.shared.utils.compound import compound_key, get_collections_from_compound_keys, get_keys_from_compound_keys
 from key_value.shared.utils.managed_entry import ManagedEntry, load_from_json
-from key_value.shared.utils.serialization import ValueOnlySerializationAdapter
+from key_value.shared.utils.serialization import BasicSerializationAdapter
 from key_value.shared.utils.time_to_live import seconds_to
 from typing_extensions import override
 
@@ -62,7 +62,7 @@ def __init__(self, max_entries: int | None = None, default_collection: str | Non
 
         self._data = defaultdict[str, SimpleStoreEntry]()
 
-        self._serialization_adapter = ValueOnlySerializationAdapter()
+        self._serialization_adapter = BasicSerializationAdapter(date_format=None)
 
         super().__init__(default_collection=default_collection)
 

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

@@ -146,21 +146,3 @@ def prepare_load(self, data: dict[str, Any]) -> dict[str, Any]:
 
     def prepare_dump(self, data: dict[str, Any]) -> dict[str, Any]:
         return data
-
-
-class ValueOnlySerializationAdapter(SerializationAdapter):
-    """Serialization adapter that only serializes the value."""
-
-    def __init__(self, *, value_format: Literal["string", "dict"] | None = "dict") -> None:
-        super().__init__(date_format=None, value_format=value_format)
-
-    def prepare_load(self, data: dict[str, Any]) -> dict[str, Any]:
-        return {
-            "value": data,
-        }
-
-    def prepare_dump(self, data: dict[str, Any]) -> dict[str, Any]:
-        if "value" not in data:
-            msg = "Value field not found"
-            raise DeserializationError(message=msg)
-        return verify_dict(obj=data["value"])

key-value/key-value-shared/tests/utils/test_serialization.py

@@ -4,7 +4,7 @@
 from inline_snapshot import snapshot
 
 from key_value.shared.utils.managed_entry import ManagedEntry
-from key_value.shared.utils.serialization import BasicSerializationAdapter, ValueOnlySerializationAdapter
+from key_value.shared.utils.serialization import BasicSerializationAdapter
 
 FIXED_DATETIME_ONE = datetime(2025, 1, 1, 0, 0, 0, tzinfo=timezone.utc)
 FIXED_DATETIME_ONE_ISOFORMAT = FIXED_DATETIME_ONE.isoformat()
@@ -78,45 +78,3 @@ def test_entry_two(self, adapter: BasicSerializationAdapter):
 
         assert adapter.load_dict(data=adapter.dump_dict(entry=TEST_ENTRY_TWO)) == snapshot(TEST_ENTRY_TWO)
         assert adapter.load_json(json_str=adapter.dump_json(entry=TEST_ENTRY_TWO)) == snapshot(TEST_ENTRY_TWO)
-
-
-class TestValueOnlySerializationAdapter:
-    @pytest.fixture
-    def adapter(self) -> ValueOnlySerializationAdapter:
-        return ValueOnlySerializationAdapter()
-
-    def test_entry_one(self, adapter: ValueOnlySerializationAdapter):
-        assert adapter.dump_dict(entry=TEST_ENTRY_ONE) == snapshot(
-            {"key_one": "value_one", "key_two": "value_two", "key_three": {"nested_key": "nested_value"}}
-        )
-
-        assert adapter.dump_json(entry=TEST_ENTRY_ONE) == snapshot(
-            '{"key_one": "value_one", "key_three": {"nested_key": "nested_value"}, "key_two": "value_two"}'
-        )
-
-        assert adapter.load_json(json_str=adapter.dump_json(entry=TEST_ENTRY_ONE)) == snapshot(
-            ManagedEntry(value={"key_one": "value_one", "key_three": {"nested_key": "nested_value"}, "key_two": "value_two"})
-        )
-        assert adapter.load_dict(data=adapter.dump_dict(entry=TEST_ENTRY_ONE)) == snapshot(
-            ManagedEntry(value={"key_one": "value_one", "key_two": "value_two", "key_three": {"nested_key": "nested_value"}})
-        )
-
-    def test_entry_two(self, adapter: ValueOnlySerializationAdapter):
-        assert adapter.dump_dict(entry=TEST_ENTRY_TWO) == snapshot(
-            {"key_one": ["value_one", "value_two", "value_three"], "key_two": 123, "key_three": {"nested_key": "nested_value"}}
-        )
-
-        assert adapter.dump_json(entry=TEST_ENTRY_TWO) == snapshot(
-            '{"key_one": ["value_one", "value_two", "value_three"], "key_three": {"nested_key": "nested_value"}, "key_two": 123}'
-        )
-
-        assert adapter.load_json(json_str=adapter.dump_json(entry=TEST_ENTRY_TWO)) == snapshot(
-            ManagedEntry(
-                value={"key_one": ["value_one", "value_two", "value_three"], "key_three": {"nested_key": "nested_value"}, "key_two": 123}
-            )
-        )
-        assert adapter.load_dict(data=adapter.dump_dict(entry=TEST_ENTRY_TWO)) == snapshot(
-            ManagedEntry(
-                value={"key_one": ["value_one", "value_two", "value_three"], "key_two": 123, "key_three": {"nested_key": "nested_value"}}
-            )
-        )

key-value/key-value-sync/src/key_value/sync/code_gen/stores/simple/store.py

@@ -8,7 +8,7 @@
 
 from key_value.shared.utils.compound import compound_key, get_collections_from_compound_keys, get_keys_from_compound_keys
 from key_value.shared.utils.managed_entry import ManagedEntry, load_from_json
-from key_value.shared.utils.serialization import ValueOnlySerializationAdapter
+from key_value.shared.utils.serialization import BasicSerializationAdapter
 from key_value.shared.utils.time_to_live import seconds_to
 from typing_extensions import override
 
@@ -58,7 +58,7 @@ def __init__(self, max_entries: int | None = None, default_collection: str | Non
 
         self._data = defaultdict[str, SimpleStoreEntry]()
 
-        self._serialization_adapter = ValueOnlySerializationAdapter()
+        self._serialization_adapter = BasicSerializationAdapter(date_format=None)
 
         super().__init__(default_collection=default_collection)