async

type AsyncTool interface {
	core.BaseTool

	// RunStream executes the tool and returns a stream of progress updates and final result.
	// This is the preferred method for long-running operations.
	RunStream(ctx context.Context, args map[string]any, toolCtx *core.ToolContext) (*ToolStream, error)

	// CanCancel indicates if the tool supports cancellation during execution.
	CanCancel() bool

	// Cancel cancels a running tool execution by ID.
	Cancel(ctx context.Context, toolID string) error

	// GetStatus returns the current status of a running tool execution.
	GetStatus(ctx context.Context, toolID string) (*ToolProgress, error)
}

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

type FileProcessorTool struct {
	*StreamingTool
}

type StreamingTool struct {
	*BaseToolImpl
	// contains filtered or unexported fields
}

type ToolProgress struct {
	ID         string         `json:"id"`
	Progress   float64        `json:"progress"` // 0.0 to 1.0
	Message    string         `json:"message"`  // Human-readable status
	Metadata   map[string]any `json:"metadata,omitempty"`
	Timestamp  time.Time      `json:"timestamp"`
	Cancelable bool           `json:"cancelable"`
}

type ToolResult struct {
	Result any    `json:"result,omitempty"`
	Error  error  `json:"error,omitempty"`
	Done   bool   `json:"done"`
	ID     string `json:"id"`
}

type ToolStream struct {
	Progress <-chan *ToolProgress `json:"-"`
	Result   <-chan *ToolResult   `json:"-"`
	Cancel   context.CancelFunc   `json:"-"`
}

type WebScraperTool struct {
	*StreamingTool
	// contains filtered or unexported fields
}