feat: Bump thenativeweb/eventsourcingdb from 0.103.1 to 0.113.2 in /tests/shared/docker/eventsourcingdb (#66)

* chore: Bump thenativeweb/eventsourcingdb

Bumps thenativeweb/eventsourcingdb from 0.103.1 to 0.113.2.

---
updated-dependencies:
- dependency-name: thenativeweb/eventsourcingdb
  dependency-version: 0.113.2
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <[email protected]>

* update ping route

* fix event type newest eventsourcingdb version

* fix: register event schema

* fix: linting

* modify poetry lock

* fix linting, and pyproject.toml

* fix: poetry lock

* Delete .github/workflows/dependabot-poetry-lock.yml

* Delete .github/workflows/update-poetry-lock.yml

* modify makefile. for doing poetry lock auto

* fix makefile for adding poetry lock as command.

* fix: event schema cannot be string anymore

* fix return type EventType

* fix read event type

* fix: dependabot

* fix: event_type

* fix: ping.py

---------

Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Stefan Poss <[email protected]>
Co-authored-by: Golo Roden <[email protected]>

Author: 3 people

.github/dependabot.yml

@@ -27,7 +27,7 @@ updates:
 - package-ecosystem: "github-actions"
   directory: "/"
   schedule:
-    interval: "weekly"
+    interval: weekly
   open-pull-requests-limit: 10
   assignees:
   - thenativeweb/internal_dev

Makefile

@@ -6,11 +6,14 @@ analyze:
 format:
 	@poetry run autopep8 --in-place --aggressive --max-line-length=100 --recursive eventsourcingdb tests
 
+lock:
+	@poetry lock 
+
 test:
 	@poetry run pytest --maxfail=1
 
 clean:
 
 build: qa clean
 
-.PHONY: analyze build clean format qa test
+.PHONY: analyze build clean format lock qa test

eventsourcingdb/handlers/ping.py

@@ -10,7 +10,7 @@
 # CloudEvent field names
 SPECVERSION_FIELD = "specversion"
 TYPE_FIELD = "type"
-PING_RECEIVED_TYPE = "io.eventsourcingdb.ping-received"
+PING_RECEIVED_TYPE = "io.eventsourcingdb.api.ping-received"
 
 
 async def ping(client: AbstractBaseClient) -> None:
@@ -34,8 +34,9 @@ async def ping(client: AbstractBaseClient) -> None:
         isinstance(response_json, dict)
         and SPECVERSION_FIELD in response_json
         and TYPE_FIELD in response_json
+        and response_json.get(TYPE_FIELD) == PING_RECEIVED_TYPE
     ):
-        if response_json.get(TYPE_FIELD) == PING_RECEIVED_TYPE:
-            return
+        return
+
 
     raise ServerError(f"Received unexpected response: {response_body}")

eventsourcingdb/handlers/read_event_types/event_type.py

@@ -1,5 +1,5 @@
 from dataclasses import dataclass
-from typing import TypeVar
+from typing import TypeVar, Any
 
 from ...errors.validation_error import ValidationError
 
@@ -10,10 +10,10 @@
 class EventType:
     event_type: str
     is_phantom: bool
-    schema: str | None = None
+    schema: dict[str, Any] | None = None
 
     @staticmethod
-    def parse(unknown_object: dict) -> Self:
+    def parse(unknown_object: dict) -> "EventType":
         event_type = unknown_object.get('eventType')
         if not isinstance(event_type, str):
             raise ValidationError(
@@ -27,9 +27,9 @@ def parse(unknown_object: dict) -> Self:
             )
 
         schema = unknown_object.get('schema')
-        if schema is not None and not isinstance(schema, str):
+        if schema is not None and not isinstance(schema, (dict)):
             raise ValidationError(
-                f"Failed to parse schema '{schema}' to str."
+                f"Failed to parse schema '{schema}'. Schema must be dict."
             )
 
         return EventType(
@@ -39,4 +39,9 @@ def parse(unknown_object: dict) -> Self:
         )
 
     def __hash__(self):
+        # Convert dictionary schema to a hashable form (tuple of items)
+        if isinstance(self.schema, dict):
+            # Sort items to ensure consistent hashing
+            schema_items = tuple(sorted((k, str(v)) for k, v in self.schema.items()))
+            return hash((self.event_type, self.is_phantom, schema_items))
         return hash((self.event_type, self.is_phantom, self.schema))

eventsourcingdb/handlers/register_event_schema/register_event_schema.py

@@ -1,5 +1,6 @@
 import json
 from http import HTTPStatus
+from typing import Any
 
 from ...abstract_base_client import AbstractBaseClient
 from ...errors.custom_error import CustomError
@@ -14,7 +15,7 @@
 async def register_event_schema(
     client: AbstractBaseClient,
     event_type: str,
-    json_schema: str,
+    json_schema: dict[str, Any],
 ) -> None:
     try:
         validate_type(event_type)
@@ -27,7 +28,7 @@ async def register_event_schema(
 
     request_body = json.dumps({
         'eventType': event_type,
-        'schema': json_schema,
+        'schema': json_schema, 
     })
 
     response: Response

poetry.lock

@@ -1 +1 @@
-FROM thenativeweb/eventsourcingdb:0.103.1
+FROM thenativeweb/eventsourcingdb:0.113.2

tests/shared/docker/eventsourcingdb/Dockerfile

@@ -50,8 +50,14 @@ async def test_reads_all_types_of_existing_events_and_registered_schemas(
             ),
         ])
 
-        await client.register_event_schema("org.ban.ban", '{"type":"object"}')
-        await client.register_event_schema("org.bing.chilling", '{"type":"object"}')
+        await client.register_event_schema(
+            "org.ban.ban", 
+            {"type": "object"} # type: ignore
+        )
+        await client.register_event_schema(
+            "org.bing.chilling", 
+            {"type": "object"} # type: ignore
+        )
 
         actual_event_types: set[EventType] = set()
         async for event_type in client.read_event_types():
@@ -81,12 +87,12 @@ async def test_reads_all_types_of_existing_events_and_registered_schemas(
             EventType(
                 event_type="org.ban.ban",
                 is_phantom=True,
-                schema='{"type":"object"}',
+                schema={"type": "object"},
             ),
             EventType(
                 event_type="org.bing.chilling",
                 is_phantom=True,
-                schema='{"type":"object"}',
+                schema={"type": "object"},
             ),
         }
 

tests/test_read_event_types.py

@@ -25,7 +25,10 @@ async def test_registers_new_schema_if_it_doesnt_conflict_with_existing_events(
     ):
         client = database.with_authorization.client
 
-        await client.register_event_schema("com.bar.baz", '{"type":"object"}')
+        await client.register_event_schema(
+            "com.bar.baz", 
+            {"type": "object"}
+        )
 
     @staticmethod
     @pytest.mark.asyncio
@@ -48,7 +51,7 @@ async def test_throws_error_if_schema_conflicts_with_existing_events(
         with pytest.raises(ClientError, match="additionalProperties"):
             await client.register_event_schema(
                 "com.gornisht.ekht",
-                '{"type":"object","additionalProperties":false}'
+                {"type": "object", "additionalProperties": False}
             )
 
     @staticmethod
@@ -60,13 +63,13 @@ async def test_throws_error_if_schema_already_exists(
 
         await client.register_event_schema(
             "com.gornisht.ekht",
-            '{"type":"object","additionalProperties":false}'
+            {"type": "object", "additionalProperties": False}
         )
 
         with pytest.raises(ClientError, match="schema already exists"):
             await client.register_event_schema(
                 "com.gornisht.ekht",
-                '{"type":"object","additionalProperties":false}'
+                {"type": "object", "additionalProperties": False}
             )
 
     @staticmethod
@@ -77,7 +80,7 @@ async def test_throws_error_if_schema_is_invalid(
         client = database.with_authorization.client
 
         with pytest.raises(ClientError, match="'/type' does not validate"):
-            await client.register_event_schema("com.gornisht.ekht", '{"type":"gurkenwasser"}')
+            await client.register_event_schema("com.gornisht.ekht", {"type": "gurkenwasser"})
 
 
 class TestRegisterEventSchemaWithMockServer:

tests/test_register_event_schema.py

@@ -202,7 +202,7 @@ async def test_throws_error_if_event_does_not_match_schema(
 
         await client.register_event_schema(
             "com.super.duper",
-            '{"type":"object","additionalProperties":false}'
+            {"type": "object", "additionalProperties": False}
         )
 
         with pytest.raises(ClientError, match="event candidate does not match schema"):