agentrunep

type AgentRunSvc interface {
	ListRuns(ctx context.Context, req *ListRunsRequest) (*apiresource.List[apiresource.AgentRun], *apierror.APIError)
	GetRun(ctx context.Context, req *RetrieveRunRequest) (*apiresource.AgentRun, *apierror.APIError)
	TriggerAgentRun(ctx context.Context, req *TriggerRunRequest) (*apiresource.AgentRun, *apierror.APIError)
	CancelAgentRun(ctx context.Context, req *CancelRunRequest) (*apiresource.AgentRun, *apierror.APIError)
	ContinueAgentRun(ctx context.Context, req *ContinueRunRequest) (*apiresource.AgentRun, *apierror.APIError)
	RetryAgentRun(ctx context.Context, req *RetryRunRequest) (*apiresource.AgentRun, *apierror.APIError)
}

type AgentRunSvcConfig struct {
	// AgentClient (required) is the agent-service gRPC client.
	AgentClient pb.AgentServiceClient
}

type CancelRunEndpoint struct{}

type CancelRunRequest struct {
	// Agent run ID.
	AgentRunID string `path:"id" validate:"required"`
}

type ContinueRunEndpoint struct{}

type ContinueRunRequest struct {
	// Agent run ID.
	AgentRunID string `path:"id" validate:"required"`
	// Message to send to the agent as the next turn of the run.
	//
	// It accompanies any approval or denial in the same request, so use it to tell the agent how to proceed with what you just allowed or blocked.
	Message string `json:"message" validate:"required"`
	// Slugs of tools whose pending calls should be approved.
	//
	// Approves every call currently pending review for each named tool. Approval is one-time — the next call to the same tool pauses for review again. Tools you do not name are left pending, and the run resumes without them.
	ApprovedToolSlugs []string `json:"approved_tool_slugs,omitzero"`
	// Slugs of tools whose pending calls should be denied.
	//
	// The run keeps going: each denied call is answered with a "denied by user" result so the agent proceeds without it, instead of cancelling the run. A single resume may both approve and reject different tools.
	RejectedToolSlugs []string `json:"rejected_tool_slugs,omitzero"`
	// Tool-call IDs (the `tool_use_id` of individual blocked calls) to approve.
	//
	// Use this instead of `approved_tool_slugs` to approve ONE specific call when several pending calls share the same tool slug — approving by slug would approve all of them. Approvals are one-time.
	ApprovedToolCallIDs []string `json:"approved_tool_call_ids,omitzero"`
	// Tool-call IDs (the `tool_use_id` of individual blocked calls) to deny.
	//
	// Per-call counterpart of `rejected_tool_slugs`, letting you deny one specific call among several that share a slug. Each denied call is answered with a "denied by user" result and the run continues.
	RejectedToolCallIDs []string `json:"rejected_tool_call_ids,omitzero"`
}

type ListRunsEndpoint struct{}

type ListRunsRequest struct {
	apiresource.PaginationRequest
	// Restricts results to runs in this status.
	Status *constants.AgentRunStatus `query:"status"`
	// Restricts results to runs of a single agent.
	AgentDefinitionID *string `query:"agent_definition_id"`
}

type RetrieveRunEndpoint struct{}

type RetrieveRunRequest struct {
	// Agent run ID.
	AgentRunID string `path:"id" validate:"required"`
}

type RetryRunEndpoint struct{}

type RetryRunRequest struct {
	// Agent run ID.
	AgentRunID string `path:"id" validate:"required"`
}

type TriggerRunEndpoint struct{}

type TriggerRunRequest struct {
	// ID of the agent definition to run.
	//
	// The agent must be active for the account; triggering an inactive agent returns a validation error.
	AgentDefinitionID string `json:"agent_definition_id" validate:"required"`
	// Instruction text passed to the agent at the start of the run.
	//
	// Recorded on the run as `{"message": <input>}` in its `input` field.
	Input field.Optional[string] `json:"input,omitzero"`
}