Function newTaskSessionBridge

internal/daemon/task_runtime.go:100–123

(
	sessions taskBridgeSessionManager,
	globalWorkspacePath string,
	logger *slog.Logger,
	options ...taskSessionBridgeOption,
)

var _ taskpkg.SessionExecutor = (*taskSessionBridge)(nil)

func newTaskSessionBridge(
	sessions taskBridgeSessionManager,
	globalWorkspacePath string,
	logger *slog.Logger,
	options ...taskSessionBridgeOption,
) (*taskSessionBridge, error) {
	if sessions == nil {
		return nil, errors.New("daemon: task session bridge requires a session manager")
	}
	if logger == nil {
		logger = slog.Default()
	}
	bridge := &taskSessionBridge{
		sessions:            sessions,
		globalWorkspacePath: strings.TrimSpace(globalWorkspacePath),
		logger:              logger,
	}
	for _, option := range options {
		if option != nil {
			option(bridge)
		}
	}
	return bridge, nil
}

func (b *taskSessionBridge) StartTaskSession(
	ctx context.Context,