Function TestWorker_NoPR_BoundaryExactWindow_Skips

coderd/x/gitsync/worker_test.go:310–347

(t *testing.T)

}

func TestWorker_NoPR_BoundaryExactWindow_Skips(t *testing.T) {
	t.Parallel()
	ctx := testutil.Context(t, testutil.WaitShort)

	chatID := uuid.New()
	ownerID := uuid.New()

	// When updated_at is exactly NoPRRetryWindow ago, the strict
	// "<" comparison means the row should be skipped (no backoff).
	// This pins the boundary so an accidental change to "<=" is
	// caught.
	tickDone := make(chan struct{})

	ctrl := gomock.NewController(t)
	store := dbmock.NewMockStore(ctrl)

	mClock := quartz.NewMock(t)

	row := makeAcquiredRowWithBranch(chatID, ownerID, "feature")
	row.UpdatedAt = mClock.Now().Add(-gitsync.NoPRRetryWindow) // exactly at boundary

	store.EXPECT().AcquireStaleChatDiffStatuses(gomock.Any(), gomock.Any()).
		Return([]database.AcquireStaleChatDiffStatusesRow{row}, nil)
	// BackoffChatDiffStatus should NOT be called.

	logger := slogtest.Make(t, &slogtest.Options{IgnoreErrors: true})

	refresher := newTestRefresher(t, mClock, withResolveBranchPR(
		func(context.Context, string, gitprovider.BranchRef) (*gitprovider.PRRef, error) {
			close(tickDone)
			return nil, nil
		},
	))

	worker := gitsync.NewWorker(store, refresher, nil, mClock, logger)

	tickOnce(ctx, t, mClock, worker, tickDone)
}

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