Feat/acp protocol

code_puppy/agents/base_agent.py

@@ -157,6 +157,11 @@ def __init__(self):
         # This is populated after the first successful run when MCP tools are retrieved
         self._mcp_tool_definitions_cache: List[Dict[str, Any]] = []
 
+    @property
+    def code_generation_agent(self):
+        """Public accessor for the underlying pydantic-ai Agent."""
+        return self._code_generation_agent
+
     def get_identity(self) -> str:
         """Get a unique identity for this agent instance.
 

code_puppy/cli_runner.py

@@ -89,8 +89,69 @@ async def main():
     parser.add_argument(
         "command", nargs="*", help="Run a single command (deprecated, use -p instead)"
     )
+    parser.add_argument(
+        "--acp",
+        action="store_true",
+        help="Start ACP Gateway (Agent Communication Protocol) server",
+    )
+    parser.add_argument(
+        "--acp-transport",
+        choices=["http", "stdio"],
+        default="http",
+        help="ACP transport: http (port 9001) or stdio (stdin/stdout). Default: http",
+    )
     args = parser.parse_args()
 
+    # ACP stdio mode: early exit — skip banner, version check, renderers.
+    # stdio needs clean stdout (only JSON-RPC), all logs go to stderr.
+    if args.acp and args.acp_transport == 'stdio':
+        import logging
+        os.environ["ACP_ENABLED"] = "true"
+        os.environ["ACP_TRANSPORT"] = "stdio"
+        logging.basicConfig(
+            stream=sys.stderr,
+            level=logging.INFO,
+            format="%(asctime)s [%(name)s] %(levelname)s: %(message)s",
+        )
+
+        # Initialize DBOS — pydantic-ai's .run() goes through DBOS
+        # durable execution and will raise DBOSException if not launched.
+        if get_use_dbos():
+            dbos_app_version = os.environ.get(
+                "DBOS_APP_VERSION",
+                f"{__version__}-{int(time.time() * 1000)}",
+            )
+            dbos_config: DBOSConfig = {
+                "name": "dbos-code-puppy",
+                "system_database_url": DBOS_DATABASE_URL,
+                "run_admin_server": False,
+                "conductor_key": os.environ.get("DBOS_CONDUCTOR_KEY"),
+                "log_level": os.environ.get("DBOS_LOG_LEVEL", "ERROR"),
+                "application_version": dbos_app_version,
+            }
+            try:
+                DBOS(config=dbos_config)
+                DBOS.launch()
+            except Exception as e:
+                logging.getLogger(__name__).error("DBOS init failed: %s", e)
+                return
+
+        # Plugins already loaded at module level — no need to reload here.
+        # Do NOT call callbacks.on_startup() because that would start a
+        # SECOND stdio server in a background thread.
+        try:
+            from code_puppy.plugins.acp_gateway.agent import run_code_puppy_agent
+            await run_code_puppy_agent()
+        except KeyboardInterrupt:
+            pass
+        finally:
+            if get_use_dbos():
+                try:
+                    DBOS.destroy()
+                except Exception:
+                    pass
+        return
+
     from code_puppy.messaging import (
         RichConsoleRenderer,
         SynchronousInteractiveRenderer,
@@ -320,6 +381,11 @@ def _uvx_protective_sigint_handler(_sig, _frame):
         initial_command = None
         prompt_only_mode = False
 
+        if args.acp:
+            os.environ["ACP_ENABLED"] = "true"
+            os.environ["ACP_TRANSPORT"] = args.acp_transport
+            # http mode: falls through to interactive mode with ACP enabled in background
+
         if args.prompt:
             initial_command = args.prompt
             prompt_only_mode = True

code_puppy/plugins/acp_gateway/__init__.py

@@ -0,0 +1,22 @@
+"""ACP Gateway Plugin.
+
+Exposes Code Puppy as an ACP (Agent Client Protocol) agent using the
+official ``agent-client-protocol`` Python SDK.
+
+The SDK handles all transport concerns (stdio JSON-RPC, session
+lifecycle, content blocks).  This plugin provides the bridge between
+ACP and Code Puppy's pydantic-ai agent system.
+
+The plugin gracefully degrades — if ``agent-client-protocol`` is not
+installed, Code Puppy starts normally with a warning log.
+"""
+
+__version__ = "0.2.0"
+__description__ = "ACP Gateway plugin for Code Puppy"
+
+from code_puppy.plugins.acp_gateway.agent import CodePuppyAgent, run_code_puppy_agent
+
+__all__ = [
+    "CodePuppyAgent",
+    "run_code_puppy_agent",
+]

code_puppy/plugins/acp_gateway/__main__.py

@@ -0,0 +1,21 @@
+"""Allow running the ACP agent as: python -m code_puppy.plugins.acp_gateway
+
+All transport concerns (stdio JSON-RPC) are handled by the ACP SDK.
+We just start the CodePuppyAgent and let ``run_agent()`` do the rest.
+"""
+
+import asyncio
+import logging
+import sys
+
+from code_puppy.plugins.acp_gateway.agent import run_code_puppy_agent
+
+# Redirect logging to stderr so stdout stays clean for JSON-RPC
+logging.basicConfig(
+    stream=sys.stderr,
+    level=logging.INFO,
+    format="%(asctime)s [%(name)s] %(levelname)s: %(message)s",
+)
+
+if __name__ == "__main__":
+    asyncio.run(run_code_puppy_agent())