Function TestTaskSessionBridgeErrorPaths

internal/daemon/task_runtime_test.go:850–979

(t *testing.T)

}

func TestTaskSessionBridgeErrorPaths(t *testing.T) {
	t.Parallel()

	t.Run("Should reject a nil start spec", func(t *testing.T) {
		t.Parallel()

		bridge, err := newTaskSessionBridge(&fakeSessionManager{}, t.TempDir(), discardLogger())
		if err != nil {
			t.Fatalf("newTaskSessionBridge() error = %v", err)
		}

		if _, err := bridge.StartTaskSession(context.Background(), nil); err == nil {
			t.Fatal("StartTaskSession(nil spec) error = nil, want validation error")
		}
	})

	t.Run("Should propagate session creation failures", func(t *testing.T) {
		t.Parallel()

		wantErr := errors.New("create failed")
		bridge, err := newTaskSessionBridge(
			&taskBridgeCreateErrorSessionManager{err: wantErr},
			t.TempDir(),
			discardLogger(),
		)
		if err != nil {
			t.Fatalf("newTaskSessionBridge() error = %v", err)
		}

		_, err = bridge.StartTaskSession(context.Background(), &taskpkg.StartTaskSession{
			Task: taskpkg.Task{
				ID:          "task-workspace",
				Scope:       taskpkg.ScopeWorkspace,
				WorkspaceID: "ws-123",
			},
			Run: taskpkg.Run{
				ID:      "run-1",
				Attempt: 1,
			},
		})
		if !errors.Is(err, wantErr) {
			t.Fatalf("StartTaskSession(create error) error = %v, want %v", err, wantErr)
		}
	})

	t.Run("Should reject create calls that return a nil session", func(t *testing.T) {
		t.Parallel()

		bridge, err := newTaskSessionBridge(&taskBridgeStopOnlySessionManager{}, t.TempDir(), discardLogger())
		if err != nil {
			t.Fatalf("newTaskSessionBridge() error = %v", err)
		}

		_, err = bridge.StartTaskSession(context.Background(), &taskpkg.StartTaskSession{
			Task: taskpkg.Task{
				ID:          "task-workspace",
				Scope:       taskpkg.ScopeWorkspace,
				WorkspaceID: "ws-123",