Function TestTaskRecoveryLivenessHelpers

internal/daemon/task_runtime_test.go:1385–1427

(t *testing.T)

}

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

	live, state, err := taskSessionRuntimeState(context.Background(), &fakeSessionManager{
		infos: []*session.Info{
			{ID: "sess-live", State: session.StateActive},
		},
	}, "sess-live")
	if err != nil {
		t.Fatalf("taskSessionRuntimeState(live) error = %v", err)
	}
	if !live {
		t.Fatal("taskSessionRuntimeState(live) = false, want true")
	}
	if got, want := state, string(session.StateActive); got != want {
		t.Fatalf("taskSessionRuntimeState(live) state = %q, want %q", got, want)
	}

	if got := taskSessionMatchesRecordedSubprocess(nil); got {
		t.Fatal("taskSessionMatchesRecordedSubprocess(nil) = true, want false")
	}
	if got := taskSessionMatchesRecordedSubprocess(&store.SessionLivenessMeta{}); got {
		t.Fatal("taskSessionMatchesRecordedSubprocess(blank) = true, want false")
	}
	startedAt, err := procutil.StartedAt(os.Getpid())
	if err != nil {
		t.Fatalf("procutil.StartedAt(self) error = %v", err)
	}
	if got := taskSessionMatchesRecordedSubprocess(&store.SessionLivenessMeta{
		SubprocessPID: os.Getpid(),
	}); got {
		t.Fatal("taskSessionMatchesRecordedSubprocess(missing start time) = true, want false")
	}
	if got := taskSessionMatchesRecordedSubprocess(&store.SessionLivenessMeta{
		SubprocessPID:       os.Getpid(),
		SubprocessStartedAt: &startedAt,
	}); !got {
		t.Fatal("taskSessionMatchesRecordedSubprocess(self) = false, want true")
	}
	if got, want := firstTaskRecoveryDetail("", " detail ", "fallback"), "detail"; got != want {
		t.Fatalf("firstTaskRecoveryDetail() = %q, want %q", got, want)
	}
}

type taskContextOverlayCall struct {
	taskID string