Revert "feat: harness lifecycle commands (init/add/list/delete/deploy/invoke) + credentials"

Author: innsd

agentkit/apps/agent_server_app/agent_server_app.py

@@ -148,9 +148,7 @@ def __init__(
         @asynccontextmanager
         async def lifespan(app: FastAPI):
             # trigger A2A server app startup
-            logger.info(
-                "Triggering A2A server app startup within API server..."
-            )
+            logger.info("Triggering A2A server app startup within API server...")
             for handler in _a2a_server_app.router.on_startup:
                 await handler()
             yield
@@ -245,78 +243,6 @@ async def event_generator():
                 routes.insert(0, routes.pop(i))
                 break
 
-        @self.app.post("/run_sse")
-        async def run_agent_sse(req: RunAgentRequest) -> StreamingResponse:
-            print("my run sse !!!")
-            # SSE endpoint
-            session = await self.server.session_service.get_session(
-                app_name=req.app_name,
-                user_id=req.user_id,
-                session_id=req.session_id,
-            )
-            if not session:
-                raise HTTPException(status_code=404, detail="Session not found")
-
-            # Convert the events to properly formatted SSE
-            async def event_generator():
-                try:
-                    stream_mode = (
-                        StreamingMode.SSE
-                        if req.streaming
-                        else StreamingMode.NONE
-                    )
-                    runner = await self.server.get_runner_async(req.app_name)
-                    async with Aclosing(
-                        runner.run_async(
-                            user_id=req.user_id,
-                            session_id=req.session_id,
-                            new_message=req.new_message,
-                            state_delta=req.state_delta,
-                            run_config=RunConfig(streaming_mode=stream_mode),
-                            invocation_id=req.invocation_id,
-                        )
-                    ) as agen:
-                        async for event in agen:
-                            # ADK Web renders artifacts from `actions.artifactDelta`
-                            # during part processing *and* during action processing
-                            # 1) the original event with `artifactDelta` cleared (content)
-                            # 2) a content-less "action-only" event carrying `artifactDelta`
-                            events_to_stream = [event]
-                            if (
-                                event.actions.artifact_delta
-                                and event.content
-                                and event.content.parts
-                            ):
-                                content_event = event.model_copy(deep=True)
-                                content_event.actions.artifact_delta = {}
-                                artifact_event = event.model_copy(deep=True)
-                                artifact_event.content = None
-                                events_to_stream = [
-                                    content_event,
-                                    artifact_event,
-                                ]
-
-                            for event_to_stream in events_to_stream:
-                                sse_event = event_to_stream.model_dump_json(
-                                    exclude_none=True,
-                                    by_alias=True,
-                                )
-                                logger.debug(
-                                    "Generated event in agent run streaming: %s",
-                                    sse_event,
-                                )
-                                yield f"data: {sse_event}\n\n"
-                except Exception as e:
-                    logger.exception("Error in event_generator: %s", e)
-                    yield f"data: {json.dumps({'error': str(e)})}\n\n"
-
-                # Returns a streaming response with the proper media type for SSE
-
-            return StreamingResponse(
-                event_generator(),
-                media_type="text/event-stream",
-            )
-
         # Attach ASGI middleware for unified telemetry across all routes
         self.app.add_middleware(AgentkitTelemetryHTTPMiddleware)
 
@@ -392,9 +318,7 @@ async def event_generator():
                             user_id=user_id,
                             session_id=session_id,
                             new_message=content,
-                            run_config=RunConfig(
-                                streaming_mode=StreamingMode.SSE
-                            ),
+                            run_config=RunConfig(streaming_mode=StreamingMode.SSE),
                         )
                     ) as agen:
                         async for event in agen:

agentkit/sdk/identity/client.py

@@ -23,7 +23,7 @@
 
 # Import command modules
 from agentkit.toolkit.cli.cli_init import init_command, show_logo
-from agentkit.toolkit.cli.cli_invoke import invoke_app
+from agentkit.toolkit.cli.cli_invoke import invoke_command
 from agentkit.toolkit.cli.cli_config import config_command
 from agentkit.toolkit.cli.cli_version import version_command, get_package_version
 from agentkit.toolkit.cli.cli_build import build_command
@@ -36,9 +36,6 @@
 from agentkit.toolkit.cli.cli_tools import tools_app
 from agentkit.toolkit.cli.cli_runtime import runtime_app
 from agentkit.toolkit.cli.cli_skills import skills_app
-from agentkit.toolkit.cli.cli_add import add_app
-from agentkit.toolkit.cli.cli_list import list_app
-from agentkit.toolkit.cli.cli_delete import delete_app
 
 # Note: Avoid importing heavy packages at the top to keep CLI startup fast
 
@@ -94,6 +91,7 @@ def main(
 
 # Register commands
 app.command(name="init")(init_command)
+app.command(name="invoke")(invoke_command)
 app.command(name="config")(config_command)
 app.command(name="version")(version_command)
 app.command(name="build")(build_command)
@@ -108,10 +106,6 @@ def main(
 app.add_typer(tools_app, name="tools")
 app.add_typer(runtime_app, name="runtime")
 app.add_typer(skills_app, name="skills")
-app.add_typer(invoke_app, name="invoke")
-app.add_typer(add_app, name="add")
-app.add_typer(list_app, name="list")
-app.add_typer(delete_app, name="delete")
 
 
 if __name__ == "__main__":