github.com-google-adk-go

Move llm agent code to new packages. (#68) * Move llm agent code to new packages. 1. Now it uses new session, llm, agent, llmagent packages. 2. LLMAgent request processors are now moved to the internal package. 3. Test case logic is kept the same everywhere. 4. Diffs with the doc (these are temporary to simplify the migration): * Tool interface has ProcessRequest method and llm.Request has Tools field. This is to keep current request_processors logic for llmagent. * agent.Config accepts Self field to allow setting correct entity as a parent.

Rename sessionservice -> session.Service (#133) * Rename sessionservice -> session.Service Removed StoredSession and Session.ID for ADK conformity

Agent Engine support (#749) * Agent Engine support * Test fix * Fixes * Fixes * Error handling fix * Fixes * Fixes in encode * Fixed encode * sseTimeout fix * reflection fix * sseWriteTime fix * fix * encode fixes * linter fixes * various fixes * encode tests * linter fixes * fix * linter fixes * Fixes in encode

Rename package llm->model (#130) Also 2 types rename: llm.Request -> model.LLMRequest llm.Response -> model.LLMResponse

fix: remoteagent partial response handling leads to data duplication (#545) * set explicit partial event marking and maintain a temporary artifact for streaming events * fix metadata merging * fix duplicating long running function call * fix citations not included * explicit mark as turnComplete on event conversion * fix response duplication for partial and non-partial events * aggregation logic tests * gemini mock streaming test * added failing test cases * lint * fix partial not reset on errors * fix test

feat: add plugin package (#480) * Add plugin system * Add plugin system * Removed test with redundant check, tool.Context can never be cast to agent.InvocationContext. * lint fixes * Fix tests plugin name * Added symmetrical after callback execution for plugins * Moved pluginManager to internal context value * Fix runOnToolErrorCallbacks for tool not found * Change plugins fields to private * Small test fix

feat: add human in the loop confirmation (#490) * Add ToolConfirmation (WIP) * Modify processor type to generator * Add tool confirmation sample * Fix loss of tool confirmation when handling event with multiple function calls * Add basic tool confirmation test * Add request confirmation tests * Fix merge test failures * lint fixes * Remove duplicated code block * merge fix * fix merge confict in base_flow_test * Add tool confirmation docs * merge fix set_test * lint fix * Add package doc for toolconfirmation example * Add tools_processor to cache tools * Update RequireConfirmationProvider doc * Move session.REQUEST_CONFIRMATION_FUNCTION_CALL_NAME to toolconfirmation.RequestConfirmationFunctionCallName. Add toolconfirmation.OriginalCallFrom helper function. * Add OriginalCallFrom godocs * Remove comments on OriginalCallFrom * Change RequestConfirmationFunctionCallName to toolconfirmation.FunctionCallName * Fix godoc

feat: Add conformance test recording plugin (#890) * Add conformance test recording plugin. * lint fix * lint fix * lint fix

Add DatabaseSessionService (#177) * Add DatabaseSessionService * Fix api changes * Merge gomod * Fix go mod tidy diff * Add missing err validations on test db start * Change service-test to run in sqlite instead o spanner * Fix applyEvent timestamp * Removed spanner dependency * Clear comments * Change gorm types visibility * Add error context, and dynamicJSON json nils * Add test to append event to session with existing events * Update session prefix references.

Unified launcher (#185) * Moved webui files * Rewritten universal launcher * Changed config struct * Updated example quickstart * Cleaning unsued code, minor fixes * Updated examples * Updated README for examples * Rewritten universal launcher * Removed web base * Initial A2A support * a2a fix * Improved error message * General launcher def * Universal & console implementation * New version of web + api launcher * Quickstart example with web api * Temporarly disabled * Added A2A launcher * Removed unneeded code * Added WebUI launcher * Fixes for API and Web launchers * Updated Examples/quickstart * Console code cleaning * Code cleaning & comments * Full & prod * Updated examples/quickstart * Updated examples * Lint fix * Moved api a2a and webui under web package * Removed comments * A2A fixes * Added A2A Reflection * Updated README.md for Examples * Comment fix in prod launcher * A2A update fix * Unified API_KEY: GOOGLE_API_KEY instead of GEMINI_API_KEY * Fixed typos * Minor fixes * Introduced root agent for agent loader * Added non-failing NewSingleAgentLoader and possibly failing NewMultipleAgentLoader * Comments for AgentLoader * Refactor of launchers * Updated examples * Added memory service to adk config * Comments * Comments

Add replay plugin (#618) * Add replay plugin * lint fixes * lint fix * Add allowedBaseDir to replay_plugin * lint fix * Move replay plugin to internal/configurable/comformance * Add Python-isms to JSON-isms normalizer to replay plugin * Simplify records unmarshaling

Remove agent.Context (#136) It's replaced with InvocationContext, ReadonlyContext and CallbackContext to have ADK conformity.

feat(live): Add core bidirectional streaming support (#833) * feat(live): Add core bidirectional streaming support Brings over the core files for live agent execution, including RunLive implementation, base flow updates, and session management. * Change live run config type * lint fixes * lint fix * Add logging to runtime controller * Replace fmt prints with log

fix: long-running operation handling as a2a input-required task (#499) * Include long-running tool function call and response are into A2A TaskStatus message. This is tracked by `inputRequiredProcessor`. This makes it possible for non-blocking clients to discover which input is required to continue a task. * Before starting execution in `adka2a.Executor` validate that user message carries all the required `FunctionCallResponse`s by comparing them against those recorded in task status. * Added test for checking that A2A request payload is assembled correctly by remoteagent. * Refactored `contents_processor` to use functions from `utils`. * Updated `runner.go` to handle the case when user message carries a function response for a long-running call initiated by a non-root agent. This agent needs to be invoked bypassing root. Added integration tests for two cases: * a2aclient -> a2aserver -> adka2a.Executor -> llmagent with a long running tool * a2aclient -> server A -> adka2a.Executor A ->-> llmagent with remote subagent -> remotesubagent -> server B -> adka2a.Executor B -> llmagent with a long running tool

Update runner to new packages (#67) * Add agent_context implementation. It's mostly a placeholder for now. agent.NewContext(...) will be used by the runner or agent packages to create a new context for each agent Run call. * Update runner from types package. Now runner uses new packages: session, agent. There is only types.AgentRunConfig but this will be updated in subsequent PRs. Remove internal runner -- because callback logic (the only logic there) is now moved to agent, wrapping each agent Run. * Update workflow agents to use new packages. Workflow agents are now structured as: agent/workflowagents loopagent/ sequentialagent/ And they are created now with loopagent.New(...) sequentialagent.New(...) * review comments

feat: add progressive SSE to streaming aggregator and parallel function call execution (#654) * Modify streaming aggregator to support progressive sse * Add parallel execution, add replay test * Remove previous TestStreamAggregator * Remove unused httpr * lint fixes * Add check thoughtSignature to TestParallelFunctionCalls * Change aggregator close to use response error code and message

Add callback state modification (#192) * Add state delta modification by agent callbacks and model callbacks. * Change tool context to pass state delta * Remove endInvocation bool type * Change AfterAgentCallback to create new event. * Add nil stateDelta validation to CallbackContext state * Fix state delta test comparisons * Replace base_flow tmpEvent with stateDelta reference

feat: add adk configurable and cli initializer (#617) * Add adk configurable and cli initializer * lint fixes * lint fix * Add conversion checks * lint fix * Move configurable and cli to internal packages * Move conformance loader to internal * fix nit --------- Co-authored-by: Dmitry Pasiukevich <20398573+dpasiukevich@users.noreply.github.com>

feat: adka2a conversion extendability and metadata handling (#410) * 1.0.0 compliant change to emit Task as the first event * extension point for modifying emitted events * convert and restore grounding, usage and custom metadata * callbacks for intercepting execution start and end * update a2a-go

internal/httprr: copy golang.org/x/oscar/internal/httprr to internal/httprr (#14) This provides the utility to record and replay HTTP (while removing secrets from the log). Use it to make model's TestNewGeminiModel test deterministic. To regenerate the httprr file, run `go generate` from the directory.