Release v4.4.12

Author: MervinPraison

docker/Dockerfile.chat

@@ -16,7 +16,7 @@ RUN mkdir -p /root/.praison
 # Install Python packages (using latest versions)
 RUN pip install --no-cache-dir \
     praisonai_tools \
-    "praisonai>=4.4.11" \
+    "praisonai>=4.4.12" \
     "praisonai[chat]" \
     "embedchain[github,youtube]"
 

docker/Dockerfile.dev

@@ -20,7 +20,7 @@ RUN mkdir -p /root/.praison
 # Install Python packages (using latest versions)
 RUN pip install --no-cache-dir \
     praisonai_tools \
-    "praisonai>=4.4.11" \
+    "praisonai>=4.4.12" \
     "praisonai[ui]" \
     "praisonai[chat]" \
     "praisonai[realtime]" \

docker/Dockerfile.ui

@@ -16,7 +16,7 @@ RUN mkdir -p /root/.praison
 # Install Python packages (using latest versions)
 RUN pip install --no-cache-dir \
     praisonai_tools \
-    "praisonai>=4.4.11" \
+    "praisonai>=4.4.12" \
     "praisonai[ui]" \
     "praisonai[crewai]"
 

src/praisonai-agents/praisonaiagents/gateway/protocols.py

@@ -53,6 +53,11 @@ class EventType(str, Enum):
     MESSAGE_ACK = "message_ack"
     TYPING = "typing"
 
+    # Streaming events (relayed from agent's StreamEventEmitter)
+    TOKEN_STREAM = "token_stream"
+    TOOL_CALL_STREAM = "tool_call_stream"
+    STREAM_END = "stream_end"
+    
     # System events
     HEALTH = "health"
     ERROR = "error"

src/praisonai-agents/praisonaiagents/hooks/__init__.py

@@ -71,6 +71,10 @@ def my_hook(event_data):
     "SessionEndInput",
     "OnErrorInput",
     "OnRetryInput",
+    # Message lifecycle event inputs
+    "MessageReceivedInput",
+    "MessageSendingInput",
+    "MessageSentInput",
     # Middleware types
     "InvocationContext",
     "ModelRequest",
@@ -130,6 +134,9 @@ def my_hook(event_data):
         'SessionEndInput': ('praisonaiagents.hooks.events', 'SessionEndInput'),
         'OnErrorInput': ('praisonaiagents.hooks.events', 'OnErrorInput'),
         'OnRetryInput': ('praisonaiagents.hooks.events', 'OnRetryInput'),
+        'MessageReceivedInput': ('praisonaiagents.hooks.events', 'MessageReceivedInput'),
+        'MessageSendingInput': ('praisonaiagents.hooks.events', 'MessageSendingInput'),
+        'MessageSentInput': ('praisonaiagents.hooks.events', 'MessageSentInput'),
     },
     'middleware_types': {
         'InvocationContext': ('praisonaiagents.hooks.middleware', 'InvocationContext'),

src/praisonai-agents/praisonaiagents/hooks/events.py

@@ -193,3 +193,68 @@ def to_dict(self) -> Dict[str, Any]:
             "operation": self.operation
         })
         return base
+
+
+@dataclass
+class MessageReceivedInput(HookInput):
+    """Input for MESSAGE_RECEIVED hooks (bot received an incoming message)."""
+    platform: str = ""
+    content: str = ""
+    sender_id: str = ""
+    channel_id: str = ""
+    channel_type: str = ""
+    message_id: str = ""
+    
+    def to_dict(self) -> Dict[str, Any]:
+        base = super().to_dict()
+        base.update({
+            "platform": self.platform,
+            "content": self.content[:500] if self.content else "",
+            "sender_id": self.sender_id,
+            "channel_id": self.channel_id,
+            "channel_type": self.channel_type,
+            "message_id": self.message_id,
+        })
+        return base
+
+
+@dataclass
+class MessageSendingInput(HookInput):
+    """Input for MESSAGE_SENDING hooks (bot about to send a message).
+    
+    Hooks can modify content or cancel the send by returning
+    HookResult with decision=DENY.
+    """
+    platform: str = ""
+    content: str = ""
+    channel_id: str = ""
+    reply_to: Optional[str] = None
+    
+    def to_dict(self) -> Dict[str, Any]:
+        base = super().to_dict()
+        base.update({
+            "platform": self.platform,
+            "content": self.content[:500] if self.content else "",
+            "channel_id": self.channel_id,
+            "reply_to": self.reply_to,
+        })
+        return base
+
+
+@dataclass
+class MessageSentInput(HookInput):
+    """Input for MESSAGE_SENT hooks (bot successfully sent a message)."""
+    platform: str = ""
+    content: str = ""
+    channel_id: str = ""
+    message_id: str = ""
+    
+    def to_dict(self) -> Dict[str, Any]:
+        base = super().to_dict()
+        base.update({
+            "platform": self.platform,
+            "content": self.content[:500] if self.content else "",
+            "channel_id": self.channel_id,
+            "message_id": self.message_id,
+        })
+        return base

src/praisonai-agents/praisonaiagents/hooks/runner.py

@@ -70,7 +70,7 @@ def __init__(
             default_timeout: Default timeout for hooks
             cwd: Working directory for command hooks
         """
-        self._registry = registry or HookRegistry()
+        self._registry = registry if registry is not None else HookRegistry()
         self._default_timeout = default_timeout
         self._cwd = cwd or os.getcwd()
 

src/praisonai-agents/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "praisonaiagents"
-version = "1.4.7"
+version = "1.4.8"
 description = "Praison AI agents for completing complex tasks with Self Reflection Agents"
 readme = "README.md"
 requires-python = ">=3.10"

src/praisonai-agents/tests/integration/test_whatsapp_web_real.py

@@ -12,7 +12,6 @@
 """
 
 import asyncio
-import json
 import os
 import signal
 import subprocess
@@ -154,13 +153,17 @@ def test_web_mode_experimental_warning(self):
                 proc.kill()
                 stdout, stderr = proc.communicate()
             combined = stdout + stderr
-            # The warning is printed by the CLI before start
+            # The warning is printed by the CLI before start.
+            # Once the event loop fix landed, neonize actually connects
+            # to WhatsApp servers, so we may also see websocket messages.
             assert (
                 "experimental" in combined.lower()
                 or "EXPERIMENTAL" in combined
                 or "web mode" in combined.lower()
                 or "Starting WhatsApp" in combined
-            ), f"Expected experimental warning in output, got: {combined[:500]}"
+                or "websocket" in combined.lower()
+                or "whatsapp" in combined.lower()
+            ), f"Expected WhatsApp output, got: {combined[:500]}"
         except Exception:
             proc.kill()
             proc.wait()
@@ -430,6 +433,48 @@ async def patched_connect(self_client):
         finally:
             NewAClient.connect = original_connect
 
+    @pytest.mark.asyncio
+    async def test_adapter_connect_bridges_event_loop(self):
+        """connect() patches neonize's event_global_loop with the running loop.
+
+        Root cause fix: neonize creates event_global_loop = asyncio.new_event_loop()
+        at import time but never starts it. Go-thread callbacks (QR, messages)
+        are posted to that dead loop. Our adapter must replace it with the
+        currently running loop so callbacks actually execute.
+        """
+        sys.path.insert(0, PRAISONAI_SRC)
+        from praisonai.bots._whatsapp_web_adapter import WhatsAppWebAdapter
+        from neonize.aioze.client import NewAClient
+        import neonize.aioze.events as nz_events
+        import neonize.aioze.client as nz_client
+
+        tmpdir = tempfile.mkdtemp()
+        adapter = WhatsAppWebAdapter(creds_dir=tmpdir)
+
+        running_loop = asyncio.get_running_loop()
+
+        # Before connect: neonize's loop is NOT our running loop
+        original_nz_loop = nz_events.event_global_loop
+
+        original_connect = NewAClient.connect
+        async def patched_connect(self_client):
+            raise ConnectionError("test: skip real connection")
+
+        NewAClient.connect = patched_connect
+        try:
+            with pytest.raises(ConnectionError):
+                await adapter.connect()
+
+            # After connect: neonize's event loops must be bridged to ours
+            assert nz_events.event_global_loop is running_loop
+            assert nz_client.event_global_loop is running_loop
+            assert adapter._client.loop is running_loop
+        finally:
+            NewAClient.connect = original_connect
+            # Restore original loop to avoid test pollution
+            nz_events.event_global_loop = original_nz_loop
+            nz_client.event_global_loop = original_nz_loop
+
     def test_adapter_logout_cleans_db(self):
         """logout() removes the DB file."""
         sys.path.insert(0, PRAISONAI_SRC)