fix: channel consumer (#19)

eventiq/__about__.py

@@ -1 +1 @@
-__version__ = "1.1.6"
+__version__ = "1.1.7"

eventiq/consumer.py

@@ -148,17 +148,14 @@ def publish(self) -> Publisher:
 
 
 class ChannelConsumer(Consumer[CloudEventType]):
-    def __inii__(
+    def __init__(
         self,
         channel: MemoryObjectSendStream[tuple[CloudEventType, Callable[[], None]]],
         **extra: Any,
     ) -> None:
-        name_parts = [socket.gethostname(), str(uuid4())]
-        base_name = extra.get("name")
-        if base_name:
-            name_parts.insert(0, base_name)
-        name = ":".join(name_parts)
-        extra["name"] = name
+        if "name" not in extra:
+            extra.setdefault("dynamic", True)
+            extra["name"] = f"{socket.gethostname()}:{uuid4()}"
         super().__init__(**extra)
         self.channel = channel
         self._timeout = to_float(self.timeout) or 10.0

eventiq/service.py

@@ -287,7 +287,13 @@ async def watch_for_signals(self, scope: CancelScope) -> None:
 
     async def _dispatch(self, event: str, **kwargs: Any) -> None:
         message = kwargs.get("message")
-        for middleware in self.middlewares:
+        middlewares = (
+            reversed(self.middlewares)
+            if event.startswith("after_")
+            else self.middlewares
+        )
+
+        for middleware in middlewares:
             if message and (
                 middleware.requires is not None
                 and not isinstance(message, middleware.requires)
@@ -479,8 +485,7 @@ async def subscription(
         consumer_send, user_receive = create_memory_object_stream[
             tuple[CloudEvent, Callable[[], None]]
         ](1)
-        options["dynamic"] = True
-        consumer = ChannelConsumer(
+        consumer: Consumer[CloudEvent] = ChannelConsumer(
             channel=consumer_send,
             event_type=event_type,
             topic=topic,

pyproject.toml

@@ -67,7 +67,7 @@ dependencies = [
     "pytest-repeat",
     "pyyaml",
     "ruff",
-    "mypy",
+    "mypy==1.11.1",
     "bandit",
     "nats-py",
     "aiokafka",