tool

type Adjuster interface {
	AfterTool(context.Context, AfterToolRequest) (AfterToolResult, error)
}

type AfterToolRequest struct {
	NodeID   string            `json:"node_id"`
	Call     Call              `json:"call"`
	Result   Result            `json:"result"`
	Metadata map[string]string `json:"metadata,omitempty"`
}

type AfterToolResult struct {
	Result *Result `json:"result,omitempty"`
}

type Call struct {
	ID        string          `json:"id"`
	Name      string          `json:"name"`
	Arguments json.RawMessage `json:"arguments,omitempty"`
}

type Definition[TIn, TOut any] struct {
	// contains filtered or unexported fields
}

type Executable interface {
	Spec() Spec
	ExecuteJSON(context.Context, json.RawMessage) (Result, error)
	PermissionJSON(context.Context, json.RawMessage) (hitl.Request, bool, error)
}

type ExecuteFunc[TIn, TOut any] func(context.Context, TIn) (TOut, error)

type NodeSpec[S any] struct {
	Registry         *Registry
	ToolIDs          []string
	Calls            func(context.Context, S) ([]Call, error)
	Output           func(context.Context, S, []Result) (graph.Command[S], error)
	Error            func(context.Context, S, Call, error) (graph.Command[S], error)
	ContinueOnError  bool
	MaxConcurrency   int
	ProgressInterval time.Duration
	Metadata         map[string]string
}

type PermissionPolicy[TIn any] func(context.Context, TIn) (hitl.Request, bool, error)

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

type Result struct {
	CallID  string          `json:"call_id"`
	Name    string          `json:"name"`
	Content string          `json:"content,omitempty"`
	Raw     json.RawMessage `json:"raw,omitempty"`
	Error   string          `json:"error,omitempty"`
}

type Spec struct {
	Name        string          `json:"name"`
	Description string          `json:"description,omitempty"`
	InputSchema json.RawMessage `json:"input_schema,omitempty"`
}