einoacp

type ACPConn interface {
	ReadTextFile(ctx context.Context, req acpproto.ReadTextFileRequest) (acpproto.ReadTextFileResponse, error)
	WriteTextFile(ctx context.Context, req acpproto.WriteTextFileRequest) (acpproto.WriteTextFileResponse, error)
	CreateTerminal(ctx context.Context, req acpproto.CreateTerminalRequest) (acpproto.CreateTerminalResponse, error)
	WaitForTerminalExit(ctx context.Context, req acpproto.WaitForTerminalExitRequest) (acpproto.WaitForTerminalExitResponse, error)
	TerminalOutput(ctx context.Context, req acpproto.TerminalOutputRequest) (acpproto.TerminalOutputResponse, error)
	ReleaseTerminal(ctx context.Context, req acpproto.ReleaseTerminalRequest) (acpproto.ReleaseTerminalResponse, error)
}

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

type Config struct {
	// SessionID is the ACP session the middleware will operate on. Required.
	SessionID acpproto.SessionID
	// Conn is the agent-side ACP connection used to issue client requests. Required.
	// Any implementation of ACPConn is accepted; *conn.AgentConnection (from
	// github.com/eino-contrib/acp/conn) satisfies this interface and is the
	// typical production choice.
	Conn ACPConn
	// Capabilities is the client capability set advertised during initialization.
	// Required: tools are enabled based on what the client supports.
	Capabilities *acpproto.ClientCapabilities

	// UseTerminalForFileTools enables terminal-backed implementations of the
	// ls, glob, and grep tools. It only takes effect when the client
	// also advertises the terminal capability; otherwise those tools stay
	// disabled because the ACP protocol does not expose corresponding
	// filesystem methods.
	//
	// Note: edit always requires fs capability (ReadTextFile + WriteTextFile).
	//
	// Implementation: ls runs `ls -1A`, glob enumerates with `find` and matches
	// in-process via doublestar, grep prefers ripgrep (`rg --json`) and
	// transparently falls back to POSIX `grep -RnE` when `rg` is not
	// installed on the client side.
	UseTerminalForFileTools bool

	// Logger is an optional structured logger for non-fatal diagnostics (e.g.
	// ReleaseTerminal failures). If nil, slog.Default() is used.
	Logger *slog.Logger
}

type EventConverterOption struct {
	// InterruptConverter is an optional custom converter for interrupt events.
	// If nil, the default conversion is used: the interrupt data is converted to
	// an AgentMessageChunk with the interrupt metadata in _meta.
	InterruptConverter InterruptConverter

	// PreserveToolCallStream controls how an upstream tool-call stream is mapped
	// into ACP SessionUpdates. ACP's ToolCall update has no native streaming
	// concept for arguments, so by default (false) the converter concatenates
	// every chunk into a single, complete ToolCall before yielding it. When set
	// to true, each upstream chunk is forwarded as its own ToolCall SessionUpdate
	// and the partial argument fragment is placed in RawInput as a JSON-encoded
	// string (so it stays valid JSON on the wire).
	//
	// Whether the upstream is a stream at all is determined by the eino event
	// (MessageVariant.IsStreaming), not by this flag — this flag only chooses
	// between "preserve the stream" and "concat into one update" when it is.
	//
	// When true, the converter guarantees that ToolCallIDs do not interleave:
	// once the emitted ToolCallID changes, the previous call is finalized and
	// no further chunks for it will appear. Clients reassemble fragments by
	// ToolCallID and treat an ID change as the end of the previous call.
	PreserveToolCallStream bool
}

type InterruptConverter func(info *adk.InterruptInfo) iter.Seq2[acpproto.SessionUpdate, error]