cli

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

type EventSink interface {
	Write(events.Event) error
	Close() error
}

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

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

type ServerDiscovery struct {
	URL    string
	Source string
	Mode   string
}

type SessionWaitConfig struct {
	EventCh                <-chan events.Event
	PromptDone             <-chan error
	InterruptCh            <-chan struct{}
	SessionID              string
	RunID                  string
	RunLabel               string
	PermissionClaimScope   string
	AutoApprove            bool
	PermissionClaimTimeout time.Duration
	ProgressTimeout        time.Duration
	Timeout                <-chan time.Time
	// AcceptSessionID validates an authoritative provider ID before the legacy
	// AdoptSessionID callback is invoked. Rejection is a fatal session identity
	// conflict; continuing on the provisional ID would report false success for
	// a conversation owned by another attempt.
	AcceptSessionID func(string) bool
	AdoptSessionID  func(string)
}

type SessionWaitDeps struct {
	Writer        EventSink
	FileHandler   *permission.FileHandler
	ControlServer *control.ControlServer
	Stderr        io.Writer
	// ProgressTimerC overrides the progress timer channel; nil preserves the
	// normal wall-clock timer behavior.
	ProgressTimerC <-chan time.Time

	// PreparePermissionClaim lets stable runtimes serialize a reused request ID
	// with direct provider completion. Nil uses ControlServer directly.
	PreparePermissionClaim func(context.Context, string, string, control.PermissionResolverState, []any) bool
	// ProviderTurn coordinates permission answers, cancellation, and eventual
	// provider close with the caller's provider lifecycle. Nil creates a turn
	// suitable for callers that do not own provider teardown.
	ProviderTurn *ProviderTurn
	// contains filtered or unexported fields
}