http

type Handler struct {
	// contains filtered or unexported fields
}

type HandlerConfig struct {
	Queue        asyncpkg.Queue
	RunState     runstate.Repository
	Policy       security.Policy
	Audit        audit.Sink
	IDGenerator  func() string
	Now          func() time.Time
	MaxBodyBytes int64
	// InsecureAllowNoAuth explicitly restores the legacy open behavior when
	// Policy is nil. Production callers should configure a policy instead.
	InsecureAllowNoAuth bool
}

type JobResponse struct {
	Job asyncpkg.Job `json:"job"`
}

type JobsResponse struct {
	Jobs []asyncpkg.Job `json:"jobs"`
}

type SubmitEventRequest struct {
	Type        string            `json:"type"`
	RunID       string            `json:"run_id,omitempty"`
	Payload     json.RawMessage   `json:"payload,omitempty"`
	JobID       string            `json:"job_id,omitempty"`
	MaxAttempts int               `json:"max_attempts,omitempty"`
	Metadata    map[string]string `json:"metadata,omitempty"`
}

type SubmitResumeContinueRequest struct {
	Token       string            `json:"token"`
	Decision    string            `json:"decision"`
	Amendment   json.RawMessage   `json:"amendment,omitempty"`
	JobID       string            `json:"job_id,omitempty"`
	RunID       string            `json:"run_id,omitempty"`
	MaxAttempts int               `json:"max_attempts,omitempty"`
	Metadata    map[string]string `json:"metadata,omitempty"`
}

type SubmitRunRequest struct {
	RunID       string            `json:"run_id,omitempty"`
	ScenarioID  string            `json:"scenario_id,omitempty"`
	Scenario    json.RawMessage   `json:"scenario,omitempty"`
	Agent       string            `json:"agent,omitempty"`
	Prompt      string            `json:"prompt,omitempty"`
	Context     json.RawMessage   `json:"context,omitempty"`
	MaxAttempts int               `json:"max_attempts,omitempty"`
	Metadata    map[string]string `json:"metadata,omitempty"`
}