Function TestWorker_NoPR_OldRow_Skips

coderd/x/gitsync/worker_test.go:271–308

(t *testing.T)

}

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

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

	// When the Refresher returns (nil, nil) but the row's
	// updated_at is outside the NoPRRetryWindow, the worker should
	// skip the row entirely (no backoff call) and let the 5-minute
	// acquisition lock serve as the natural retry interval.
	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(-5 * time.Minute) // old row

	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_BoundaryExactWindow_Skips(t *testing.T) {
	t.Parallel()