Dev

agent_core/__init__.py

@@ -31,6 +31,7 @@
 )
 from agent_core.core.embedding_interface import EmbeddingInterface
 from agent_core.core.vlm_interface import VLMInterface
+from agent_core.core.image_gen_interface import ImageGenInterface
 from agent_core.core.database_interface import DatabaseInterface
 from agent_core.core.trigger import Trigger
 from agent_core.core.task import Task, TodoItem, TodoStatus
@@ -272,6 +273,7 @@
     # Interfaces
     "EmbeddingInterface",
     "VLMInterface",
+    "ImageGenInterface",
     "DatabaseInterface",
     "GeminiClient",
     "GeminiAPIError",

agent_core/core/credentials/embedded_credentials.py

@@ -55,6 +55,16 @@
         "api_id": ["MzQyNDc4MTc="],
         "api_hash": ["N2Q5ZjkzN2ZkNzAzYTI0NTkyMDQzNGM2YjU5MDE4OGE="],
     },
+    "hubspot": {
+        "client_id": [
+            "YmM5ZGM4MzctMGJjMC00Y2Y3L",
+            "WFmY2EtYWVjYTY4YWNiMjhm",
+        ],
+        "client_secret": [
+            "MzI5MzM4ZDktNzVkYi00YTg4L",
+            "Tg2ZmQtMDZhNzI2N2FjNmRk",
+        ],
+    },
 }
 
 

agent_core/core/image_gen_interface.py

@@ -0,0 +1,12 @@
+# -*- coding: utf-8 -*-
+"""
+Image generation interface.
+
+Re-exports ImageGenInterface from the impl module for backward compatibility.
+Use the runtime-specific wrapper (app/image_gen_interface.py) when running
+inside CraftBot — it injects the appropriate state and usage hooks.
+"""
+
+from agent_core.core.impl.image_gen import ImageGenInterface
+
+__all__ = ["ImageGenInterface"]

agent_core/core/impl/action/router.py

@@ -1238,10 +1238,45 @@ def _validate_parallel_actions(
         # Cap at 10 actions
         actions = actions[:10]
 
+        dropped_actions = []
+
+        # A message that waits for a user reply keeps the task parked until the
+        # user responds — so ending the task in the same batch is contradictory.
+        # task_end tears down the session, which means the user's reply can never
+        # be routed back to the waiting task (it gets orphaned into a new session).
+        # Resolve the conflict in favour of waiting: drop task_end, keep the task
+        # alive. The agent should end the task only AFTER the user replies.
+        def _wants_reply(action_dict: Dict[str, Any]) -> bool:
+            v = (action_dict.get("parameters") or {}).get("wait_for_user_reply")
+            if isinstance(v, str):
+                return v.strip().lower() == "true"
+            return bool(v)
+
+        waits_for_reply = any(_wants_reply(a) for a in actions)
+        if waits_for_reply and any(a.get("action_name") == "task_end" for a in actions):
+            kept = []
+            for action_dict in actions:
+                if action_dict.get("action_name") == "task_end":
+                    dropped_action = action_dict.copy()
+                    dropped_action["_error"] = (
+                        "Action dropped: cannot end the task in the same step as a "
+                        "message with wait_for_user_reply=true. The task must stay "
+                        "active to receive the user's reply — call task_end only "
+                        "after the user has responded."
+                    )
+                    dropped_actions.append(dropped_action)
+                    logger.warning(
+                        "[PARALLEL] Dropping task_end paired with "
+                        "wait_for_user_reply=true — keeping task parked so the "
+                        "user's reply can be routed back to it."
+                    )
+                else:
+                    kept.append(action_dict)
+            actions = kept
+
         # Check for non-parallelizable actions by looking up each action's parallelizable attribute
         # If found, we need to keep the non-parallelizable action (not just the first action)
         non_parallel_action = None
-        dropped_actions = []
         for action_dict in actions:
             action_name = action_dict.get("action_name", "")
             if action_name:

agent_core/core/impl/context/engine.py

@@ -184,14 +184,18 @@ def create_system_policy(self) -> str:
     def create_system_environmental_context(self) -> str:
         """Create a system message block with environmental context."""
         import platform
+        from datetime import datetime
 
         try:
             from app.config import AGENT_WORKSPACE_ROOT
         except ImportError:
             AGENT_WORKSPACE_ROOT = "."
 
         local_timezone = get_localzone()
+        now = datetime.now(local_timezone)
+        current_datetime = now.strftime("%Y-%m-%d %H:%M:%S") + f" ({local_timezone})"
         return ENVIRONMENTAL_CONTEXT_PROMPT.format(
+            current_datetime=current_datetime,
             user_location=local_timezone,
             working_directory=AGENT_WORKSPACE_ROOT,
             operating_system=platform.system(),

agent_core/core/impl/image_gen/__init__.py

@@ -0,0 +1,6 @@
+# -*- coding: utf-8 -*-
+"""Image generation interface package."""
+
+from agent_core.core.impl.image_gen.interface import ImageGenInterface
+
+__all__ = ["ImageGenInterface"]