service

type AgentBuilderWorkflow struct{}

type AgentRunInput struct {
	Message           responses.InputMessageUnion `json:"message"`
	Namespace         string                      `json:"namespace"`
	PreviousMessageID string                      `json:"previous_message_id,omitempty"`
	Context           map[string]any              `json:"context,omitempty"`
	SessionID         string                      `json:"session_id"`

	// These are passed via URL path/query in converse, but included in body for Restate
	ProjectID  string `json:"project_id"`
	AgentName  string `json:"agent_name"`
	VirtualKey string `json:"virtual_key,omitempty"` // Optional - falls back to project default
}

type AgentRunOutput struct {
	FinalMessage []responses.InputMessageUnion `json:"final_message"`
}

type AgentStatus struct {
	Status        string `json:"status"`
	CurrentStep   string `json:"current_step"`
	LoopCount     int    `json:"loop_count"`
	CurrentTool   string `json:"current_tool,omitempty"`
	StreamChannel string `json:"stream_channel"`
	Error         string `json:"error,omitempty"`
}

type StreamEvent struct {
	RunID     string                   `json:"run_id"`
	Type      string                   `json:"type"`
	Message   *responses.ResponseChunk `json:"message,omitempty"`
	Status    string                   `json:"status,omitempty"`
	Error     string                   `json:"error,omitempty"`
	Timestamp int64                    `json:"timestamp"`
}