fix linting, and pyproject.toml

Author: atstaeff

.github/dependabot.yml

@@ -11,6 +11,14 @@ updates:
   - Dependencies
   commit-message:
     prefix: chore
+  # Exclude poetry.lock to handle it manually
+  ignore:
+    - dependency-name: "*"
+      update-types: ["version-update:semver-patch"]
+  # Don't update lockfile automatically
+  versioning-strategy: increase
+  allow:
+    - dependency-type: "direct"
 
 - package-ecosystem: docker
   directory: "/tests/shared/docker/eventsourcingdb"

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

@@ -0,0 +1,35 @@
+name: Update Poetry Lock file
+
+on:
+  pull_request:
+    paths:
+      - 'pyproject.toml'
+
+jobs:
+  update-poetry-lock:
+    runs-on: ubuntu-latest
+    if: github.actor == 'dependabot[bot]'
+    steps:
+      - uses: actions/checkout@v3
+        with:
+          ref: ${{ github.head_ref }}
+          token: ${{ secrets.GITHUB_TOKEN }}
+          
+      - name: Set up Python
+        uses: actions/setup-python@v4
+        with:
+          python-version: '3.10'
+          
+      - name: Install Poetry
+        uses: snok/install-poetry@v1
+        with:
+          version: 1.5.1
+          
+      - name: Update poetry.lock
+        run: poetry lock --no-update
+        
+      - name: Commit and push changes
+        uses: stefanzweifel/git-auto-commit-action@v4
+        with:
+          commit_message: "chore: update poetry.lock"
+          file_pattern: "poetry.lock"

eventsourcingdb/handlers/register_event_schema/register_event_schema.py

@@ -15,7 +15,7 @@
 async def register_event_schema(
     client: AbstractBaseClient,
     event_type: str,
-    json_schema: str | dict[str, Any],
+    json_schema: dict[str, Any],
 ) -> None:
     try:
         validate_type(event_type)
@@ -26,21 +26,12 @@ async def register_event_schema(
     except Exception as other_error:
         raise InternalError(str(other_error)) from other_error
 
-    # Handle both string and dictionary schema formats
-    # If json_schema is a string, parse it to ensure it's valid JSON
-    # If it's already a dict, use it directly
+    # Convert string schema to dict if needed
     schema_obj = json_schema
-    if isinstance(json_schema, str):
-        try:
-            schema_obj = json.loads(json_schema)
-        except json.JSONDecodeError as json_error:
-            raise InvalidParameterError(
-                'json_schema', f'Invalid JSON schema: {str(json_error)}'
-            ) from json_error
 
     request_body = json.dumps({
         'eventType': event_type,
-        'schema': schema_obj,
+        'schema': schema_obj,  # Now always a Python object, not a JSON string
     })
 
     response: Response

pyproject.toml

@@ -15,12 +15,12 @@ packages = [{include = "eventsourcingdb"}]
 
 [tool.poetry.dependencies]
 python = "^3.13"
-aiohttp = "^3.11.16"
+aiohttp = "3.11.16"
 
 [tool.poetry.group.dev.dependencies]
-pytest = "^8.3.5"
-flask = "^3.1.0"
-pylint = "^3.3.5"
-autopep8 = "^2.3.2"
-pytest-timeout = "^2.3.1"
-pytest-asyncio = "^0.25.3"
+pytest = "8.3.5"
+flask = "3.1.0"
+pylint = "3.3.5"
+autopep8 = "2.3.2"
+pytest-timeout = "2.3.1"
+pytest-asyncio = "0.25.3"

tests/test_register_event_schema.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: