chore: define type alias for EventFactory and use it everywhere

Signed-off-by: Tudor Plugaru <[email protected]>

Author: PlugaruT

src/cloudevents/core/base.py

@@ -13,7 +13,21 @@
 #    under the License.
 
 from datetime import datetime
-from typing import Any, Protocol
+from typing import Any, Callable, Protocol
+
+EventFactory = Callable[
+    [dict[str, Any], dict[str, Any] | str | bytes | None], "BaseCloudEvent"
+]
+"""
+Type alias for a callable that creates a BaseCloudEvent from attributes and data.
+
+Args:
+    attributes: The CloudEvent attributes (required fields like id, source, type, etc.)
+    data: The CloudEvent data payload (optional)
+
+Returns:
+    A BaseCloudEvent instance
+"""
 
 
 class BaseCloudEvent(Protocol):

src/cloudevents/core/bindings/amqp.py

@@ -14,11 +14,11 @@
 
 from dataclasses import dataclass
 from datetime import datetime, timezone
-from typing import Any, Callable, Final
+from typing import Any, Final
 
 from dateutil.parser import isoparse
 
-from cloudevents.core.base import BaseCloudEvent
+from cloudevents.core.base import BaseCloudEvent, EventFactory
 from cloudevents.core.formats.base import Format
 
 # AMQP CloudEvents spec allows both cloudEvents_ and cloudEvents: prefixes
@@ -149,9 +149,7 @@ def to_binary(event: BaseCloudEvent, event_format: Format) -> AMQPMessage:
 def from_binary(
     message: AMQPMessage,
     event_format: Format,
-    event_factory: Callable[
-        [dict[str, Any], dict[str, Any] | str | bytes | None], BaseCloudEvent
-    ],
+    event_factory: EventFactory,
 ) -> BaseCloudEvent:
     """
     Parse an AMQP binary content mode message to a CloudEvent.
@@ -250,9 +248,7 @@ def to_structured(event: BaseCloudEvent, event_format: Format) -> AMQPMessage:
 def from_structured(
     message: AMQPMessage,
     event_format: Format,
-    event_factory: Callable[
-        [dict[str, Any], dict[str, Any] | str | bytes | None], BaseCloudEvent
-    ],
+    event_factory: EventFactory,
 ) -> BaseCloudEvent:
     """
     Parse an AMQP structured content mode message to a CloudEvent.
@@ -283,9 +279,7 @@ def from_structured(
 def from_amqp(
     message: AMQPMessage,
     event_format: Format,
-    event_factory: Callable[
-        [dict[str, Any], dict[str, Any] | str | bytes | None], BaseCloudEvent
-    ],
+    event_factory: EventFactory,
 ) -> BaseCloudEvent:
     """
     Parse an AMQP message to a CloudEvent with automatic mode detection.

src/cloudevents/core/bindings/http.py

@@ -13,9 +13,9 @@
 #    under the License.
 
 from dataclasses import dataclass
-from typing import Any, Callable, Final
+from typing import Any, Final
 
-from cloudevents.core.base import BaseCloudEvent
+from cloudevents.core.base import BaseCloudEvent, EventFactory
 from cloudevents.core.bindings.common import (
     CONTENT_TYPE_HEADER,
     DATACONTENTTYPE_ATTR,
@@ -92,9 +92,7 @@ def to_binary(event: BaseCloudEvent, event_format: Format) -> HTTPMessage:
 def from_binary(
     message: HTTPMessage,
     event_format: Format,
-    event_factory: Callable[
-        [dict[str, Any], dict[str, Any] | str | bytes | None], BaseCloudEvent
-    ],
+    event_factory: EventFactory,
 ) -> BaseCloudEvent:
     """
     Parse an HTTP binary content mode message to a CloudEvent.
@@ -172,9 +170,7 @@ def to_structured(event: BaseCloudEvent, event_format: Format) -> HTTPMessage:
 def from_structured(
     message: HTTPMessage,
     event_format: Format,
-    event_factory: Callable[
-        [dict[str, Any], dict[str, Any] | str | bytes | None], BaseCloudEvent
-    ],
+    event_factory: EventFactory,
 ) -> BaseCloudEvent:
     """
     Parse an HTTP structured content mode message to a CloudEvent.
@@ -203,9 +199,7 @@ def from_structured(
 def from_http(
     message: HTTPMessage,
     event_format: Format,
-    event_factory: Callable[
-        [dict[str, Any], dict[str, Any] | str | bytes | None], BaseCloudEvent
-    ],
+    event_factory: EventFactory,
 ) -> BaseCloudEvent:
     """
     Parse an HTTP message to a CloudEvent with automatic mode detection.

src/cloudevents/core/bindings/kafka.py

@@ -15,7 +15,7 @@
 from dataclasses import dataclass
 from typing import Any, Callable, Final
 
-from cloudevents.core.base import BaseCloudEvent
+from cloudevents.core.base import BaseCloudEvent, EventFactory
 from cloudevents.core.bindings.common import (
     CONTENT_TYPE_HEADER,
     DATACONTENTTYPE_ATTR,
@@ -125,9 +125,7 @@ def to_binary(
 def from_binary(
     message: KafkaMessage,
     event_format: Format,
-    event_factory: Callable[
-        [dict[str, Any], dict[str, Any] | str | bytes | None], BaseCloudEvent
-    ],
+    event_factory: EventFactory,
 ) -> BaseCloudEvent:
     """
     Parse a Kafka binary content mode message to a CloudEvent.
@@ -228,9 +226,7 @@ def to_structured(
 def from_structured(
     message: KafkaMessage,
     event_format: Format,
-    event_factory: Callable[
-        [dict[str, Any], dict[str, Any] | str | bytes | None], BaseCloudEvent
-    ],
+    event_factory: EventFactory,
 ) -> BaseCloudEvent:
     """
     Parse a Kafka structured content mode message to a CloudEvent.
@@ -276,9 +272,7 @@ def from_structured(
 def from_kafka(
     message: KafkaMessage,
     event_format: Format,
-    event_factory: Callable[
-        [dict[str, Any], dict[str, Any] | str | bytes | None], BaseCloudEvent
-    ],
+    event_factory: EventFactory,
 ) -> BaseCloudEvent:
     """
     Parse a Kafka message to a CloudEvent with automatic mode detection.

src/cloudevents/core/formats/base.py

@@ -12,9 +12,9 @@
 #    License for the specific language governing permissions and limitations
 #    under the License.
 
-from typing import Any, Callable, Protocol
+from typing import Any, Protocol
 
-from cloudevents.core.base import BaseCloudEvent
+from cloudevents.core.base import BaseCloudEvent, EventFactory
 
 
 class Format(Protocol):
@@ -29,10 +29,7 @@ class Format(Protocol):
 
     def read(
         self,
-        event_factory: Callable[
-            [dict[str, Any], dict[str, Any] | str | bytes | None],
-            BaseCloudEvent,
-        ],
+        event_factory: EventFactory,
         data: str | bytes,
     ) -> BaseCloudEvent:
         """

src/cloudevents/core/formats/json.py

@@ -16,11 +16,11 @@
 import re
 from datetime import datetime
 from json import JSONEncoder, dumps, loads
-from typing import Any, Callable, Final, Pattern
+from typing import Any, Final, Pattern
 
 from dateutil.parser import isoparse
 
-from cloudevents.core.base import BaseCloudEvent
+from cloudevents.core.base import BaseCloudEvent, EventFactory
 from cloudevents.core.formats.base import Format
 
 
@@ -49,10 +49,7 @@ class JSONFormat(Format):
 
     def read(
         self,
-        event_factory: Callable[
-            [dict[str, Any], dict[str, Any] | str | bytes | None],
-            BaseCloudEvent,
-        ],
+        event_factory: EventFactory,
         data: str | bytes,
     ) -> BaseCloudEvent:
         """