V1.3.1

.gitignore

@@ -49,7 +49,7 @@ app/config/settings.json
 **/CONVERSATION_HISTORY.md
 **/EVENT_UNPROCESSED.md
 **/EVENT.md
-**/TASK_HISTORY.md
+agent_file_system/TASK_HISTORY.md
 **/USER.md
 **/onboarding_config.json
 **/config.json

agent_core/core/impl/action/manager.py

@@ -387,13 +387,23 @@ async def execute_action(
 
         logger.debug(f"Persisting final state for action {action.name}...")
 
-        # Update action count in state
-        state = get_state_or_none()
-        if state:
-            state.set_agent_property(
+        # Update action count on the per-task StateSession (per-task counter).
+        # Falls back to the global state provider when no session is registered
+        # (e.g. transient/conversation-mode actions before any task is created).
+        from agent_core.core.state.session import StateSession
+        session = StateSession.get_or_none(session_id) if session_id else None
+        if session is not None:
+            session.agent_properties.set_property(
                 "action_count",
-                state.get_agent_property("action_count", 0) + 1
+                session.agent_properties.get_property("action_count", 0) + 1,
             )
+        else:
+            state = get_state_or_none()
+            if state:
+                state.set_agent_property(
+                    "action_count",
+                    state.get_agent_property("action_count", 0) + 1
+                )
 
         # Call on_action_end hook if provided
         if self._on_action_end:

agent_core/core/impl/action/router.py

@@ -98,15 +98,12 @@ async def select_action(
         # Base conversation mode actions
         base_actions = ["send_message", "task_start", "ignore"]
 
-        # Dynamically add messaging actions for connected platforms
+        # Dynamically add messaging actions for connected platforms.
+        # Curation (which actions match which integration) lives in the host —
+        # the package only reports which platforms are currently connected.
         try:
-            from app.external_comms.integration_discovery import (
-                get_connected_messaging_platforms,
-                get_messaging_actions_for_platforms,
-            )
-            connected_platforms = get_connected_messaging_platforms()
-            messaging_actions = get_messaging_actions_for_platforms(connected_platforms)
-            conversation_mode_actions = base_actions + messaging_actions
+            from app.data.action.integrations._routing import get_messaging_actions_for_connected
+            conversation_mode_actions = base_actions + get_messaging_actions_for_connected()
         except Exception as e:
             logger.debug(f"[ACTION] Could not discover messaging actions: {e}")
             conversation_mode_actions = base_actions
@@ -124,12 +121,31 @@ async def select_action(
                     "output_schema": act.output_schema
                 })
 
+        # Pull just-in-time guidance for any integrations the user named.
+        # No-ops to "" when nothing matches; never raises. See the helper
+        # in the host app — kept out of agent_core so the package stays
+        # integration-agnostic.
+        try:
+            from app.data.action.integrations._integration_essentials import (
+                get_essentials_for_message,
+            )
+            # TODO: Is keyword based deterministic search good enough?
+            integration_essentials = get_essentials_for_message(query)
+            logger.info(
+                f"[ACTION] integration essentials: "
+                f"{len(integration_essentials)} chars injected"
+            )
+        except Exception as e:
+            logger.debug(f"[ACTION] integration essentials lookup failed: {e}")
+            integration_essentials = ""
+
         # Build the instruction prompt for the LLM
         full_prompt = SELECT_ACTION_PROMPT.format(
             event_stream=self.context_engine.get_event_stream(),
             memory_context=self.context_engine.get_memory_context(query),
             query=query,
             action_candidates=self._format_candidates(action_candidates),
+            integration_essentials=integration_essentials,
         )
 
         max_format_retries = 3
@@ -219,13 +235,39 @@ async def select_action_in_task(
         task_state = self.context_engine.get_task_state(session_id=session_id)
         memory_context = self.context_engine.get_memory_context(query, session_id=session_id)
         event_stream_content = self.context_engine.get_event_stream(session_id=session_id)
+
+        # Pull integration essentials the same way conversation-mode does
+        # (see select_action). Without this, the task-mode LLM loses sight
+        # of integration-specific shortcuts (e.g. WhatsApp's `to: "user"`
+        # self-send) once the agent enters task mode and starts asking the
+        # user for info the integration could look up itself.
+        # Match against both the current step's query and the task state so
+        # the platform name from the original user request still triggers a
+        # match even after the per-step query is generic ("Perform the next
+        # best action...").
+        try:
+            from app.data.action.integrations._integration_essentials import (
+                get_essentials_for_message,
+            )
+            integration_essentials = get_essentials_for_message(
+                f"{query}\n{task_state}"
+            )
+            logger.info(
+                f"[ACTION] task-mode integration essentials: "
+                f"{len(integration_essentials)} chars injected"
+            )
+        except Exception as e:
+            logger.debug(f"[ACTION] task-mode essentials lookup failed: {e}")
+            integration_essentials = ""
+
         static_prompt = SELECT_ACTION_IN_TASK_PROMPT.format(
             agent_state=self.context_engine.get_agent_state(session_id=session_id),
             task_state=task_state,
             memory_context=memory_context,
             event_stream="",  # Empty for static prompt
             query=query,
             action_candidates=self._format_candidates(action_candidates),
+            integration_essentials=integration_essentials,
         )
         full_prompt = SELECT_ACTION_IN_TASK_PROMPT.format(
             agent_state=self.context_engine.get_agent_state(session_id=session_id),
@@ -234,6 +276,7 @@ async def select_action_in_task(
             event_stream=event_stream_content,
             query=query,
             action_candidates=self._format_candidates(action_candidates),
+            integration_essentials=integration_essentials,
         )
 
         max_format_retries = 3
@@ -325,13 +368,35 @@ async def select_action_in_simple_task(
         task_state = self.context_engine.get_task_state(session_id=session_id)
         memory_context = self.context_engine.get_memory_context(query, session_id=session_id)
         event_stream_content = self.context_engine.get_event_stream(session_id=session_id)
+
+        # Inject integration essentials so the simple-task LLM still sees
+        # integration-specific shortcuts (e.g. WhatsApp's `to: "user"`)
+        # even after the agent has left conversation mode. Match against
+        # the per-step query AND the task state so the original platform
+        # keyword still triggers a hit.
+        try:
+            from app.data.action.integrations._integration_essentials import (
+                get_essentials_for_message,
+            )
+            integration_essentials = get_essentials_for_message(
+                f"{query}\n{task_state}"
+            )
+            logger.info(
+                f"[ACTION] simple-task integration essentials: "
+                f"{len(integration_essentials)} chars injected"
+            )
+        except Exception as e:
+            logger.debug(f"[ACTION] simple-task essentials lookup failed: {e}")
+            integration_essentials = ""
+
         static_prompt = SELECT_ACTION_IN_SIMPLE_TASK_PROMPT.format(
             agent_state=self.context_engine.get_agent_state(session_id=session_id),
             task_state=task_state,
             memory_context=memory_context,
             event_stream="",  # Empty for static prompt
             query=query,
             action_candidates=self._format_candidates(action_candidates),
+            integration_essentials=integration_essentials,
         )
         full_prompt = SELECT_ACTION_IN_SIMPLE_TASK_PROMPT.format(
             agent_state=self.context_engine.get_agent_state(session_id=session_id),
@@ -340,6 +405,7 @@ async def select_action_in_simple_task(
             event_stream=event_stream_content,
             query=query,
             action_candidates=self._format_candidates(action_candidates),
+            integration_essentials=integration_essentials,
         )
 
         max_format_retries = 3

agent_core/core/impl/context/engine.py

@@ -203,11 +203,14 @@ def create_system_environmental_context(self) -> str:
     def create_system_file_system_context(self) -> str:
         """Create a system message block with agent file system context."""
         try:
-            from app.config import AGENT_FILE_SYSTEM_PATH
+            from app.config import AGENT_FILE_SYSTEM_PATH, PROJECT_ROOT
+            skills_path = PROJECT_ROOT / "skills"
         except ImportError:
             AGENT_FILE_SYSTEM_PATH = "."
+            skills_path = "./skills"
         return AGENT_FILE_SYSTEM_CONTEXT_PROMPT.format(
             agent_file_system_path=AGENT_FILE_SYSTEM_PATH,
+            skills_path=skills_path,
         )
 
     def create_system_user_profile(self) -> str: