remove Abstractclient

Author: atstaeff

eventsourcingdb/client.py

@@ -1,6 +1,5 @@
 from collections.abc import AsyncGenerator
 
-from .abstract_base_client import AbstractBaseClient
 from .client_configuration import ClientConfiguration
 from .client_options import ClientOptions
 from .event.event_candidate import EventCandidate
@@ -23,7 +22,7 @@
 # for better readability. Even though it is not necessary,
 # it makes the return type clear without needing to read any
 # documentation or code.
-class Client(AbstractBaseClient):
+class Client():
     def __init__(
         self,
         base_url: str,

eventsourcingdb/handlers/observe_events/observe_events.py

@@ -6,7 +6,7 @@
 from ..is_event import is_event
 from ..is_stream_error import is_stream_error
 from ..parse_raw_message import parse_raw_message
-from ...abstract_base_client import AbstractBaseClient
+from ...client import Client
 from ...errors.custom_error import CustomError
 from ...errors.internal_error import InternalError
 from ...errors.invalid_parameter_error import InvalidParameterError
@@ -26,7 +26,7 @@
 
 
 async def observe_events(
-    client: AbstractBaseClient,
+    client: Client,
     subject: str,
     options: ObserveEventsOptions
 ) -> AsyncGenerator[StoreItem, None]:

eventsourcingdb/handlers/ping.py

@@ -1,6 +1,6 @@
 from http import HTTPStatus
 import json
-from ..abstract_base_client import AbstractBaseClient
+from ..client import Client
 from ..errors.server_error import ServerError
 
 # Define constants for response values
@@ -13,7 +13,7 @@
 PING_RECEIVED_TYPE = "io.eventsourcingdb.api.ping-received"
 
 
-async def ping(client: AbstractBaseClient) -> None:
+async def ping(client: Client) -> None:
     response = await client.http_client.get("/api/v1/ping")
     response_body = bytes.decode(await response.body.read(), encoding="utf-8")
 

eventsourcingdb/handlers/read_event_types/read_event_types.py

@@ -5,7 +5,7 @@
 from .is_event_type import is_event_type
 from ..is_stream_error import is_stream_error
 from ..parse_raw_message import parse_raw_message
-from ...abstract_base_client import AbstractBaseClient
+from ...client import Client
 from ...errors.custom_error import CustomError
 from ...errors.internal_error import InternalError
 from ...errors.server_error import ServerError
@@ -20,7 +20,7 @@
 
 
 async def read_event_types(
-    client: AbstractBaseClient,
+    client: Client,
 ) -> AsyncGenerator[EventType, None]:
     response: Response
     try:

eventsourcingdb/handlers/read_events/read_events.py

@@ -2,7 +2,7 @@
 import json
 from http import HTTPStatus
 
-from ...abstract_base_client import AbstractBaseClient
+from ...client import Client
 from ...errors.custom_error import CustomError
 from ...errors.internal_error import InternalError
 from ...errors.invalid_parameter_error import InvalidParameterError
@@ -25,7 +25,7 @@
 
 
 async def read_events(
-    client: AbstractBaseClient,
+    client: Client,
     subject: str,
     options: ReadEventsOptions
 ) -> Generator[StoreItem, None, None]:

eventsourcingdb/handlers/read_subjects/read_subjects.py

@@ -2,7 +2,7 @@
 import json
 from http import HTTPStatus
 
-from ...abstract_base_client import AbstractBaseClient
+from ...client import Client
 from ...errors.custom_error import CustomError
 from ...errors.internal_error import InternalError
 from ...errors.invalid_parameter_error import InvalidParameterError
@@ -22,7 +22,7 @@
 
 
 async def read_subjects(
-    client: AbstractBaseClient,
+    client: Client,
     base_subject: str
 ) -> AsyncGenerator[str, None, None]:
     try:

eventsourcingdb/handlers/register_event_schema/register_event_schema.py

@@ -2,7 +2,7 @@
 from http import HTTPStatus
 from typing import Any
 
-from ...abstract_base_client import AbstractBaseClient
+from ...client import Client
 from ...errors.custom_error import CustomError
 from ...errors.internal_error import InternalError
 from ...errors.invalid_parameter_error import InvalidParameterError
@@ -13,7 +13,7 @@
 
 
 async def register_event_schema(
-    client: AbstractBaseClient,
+    client: Client,
     event_type: str,
     json_schema: dict[str, Any],
 ) -> None:

eventsourcingdb/handlers/write_events/write_events.py

@@ -1,7 +1,7 @@
 from http import HTTPStatus
 import json
 
-from ...abstract_base_client import AbstractBaseClient
+from ...client import Client
 from ...errors.custom_error import CustomError
 from ...errors.internal_error import InternalError
 from ...errors.invalid_parameter_error import InvalidParameterError
@@ -14,7 +14,7 @@
 
 
 async def write_events(
-    client: AbstractBaseClient,
+    client: Client,
     event_candidates: list[EventCandidate],
     preconditions: list[Precondition]
 ) -> list[EventContext]: