(t *testing.T)
| 756 | } |
| 757 | |
| 758 | func TestWorker_TickStoreError(t *testing.T) { |
| 759 | t.Parallel() |
| 760 | ctx := testutil.Context(t, testutil.WaitShort) |
| 761 | |
| 762 | tickDone := make(chan struct{}) |
| 763 | |
| 764 | ctrl := gomock.NewController(t) |
| 765 | store := dbmock.NewMockStore(ctrl) |
| 766 | |
| 767 | store.EXPECT().AcquireStaleChatDiffStatuses(gomock.Any(), gomock.Any()). |
| 768 | DoAndReturn(func(context.Context, int32) ([]database.AcquireStaleChatDiffStatusesRow, error) { |
| 769 | close(tickDone) |
| 770 | return nil, fmt.Errorf("database unavailable") |
| 771 | }) |
| 772 | |
| 773 | mClock := quartz.NewMock(t) |
| 774 | logger := slogtest.Make(t, &slogtest.Options{IgnoreErrors: true}) |
| 775 | refresher := newTestRefresher(t, mClock) |
| 776 | worker := gitsync.NewWorker(store, refresher, nil, mClock, logger) |
| 777 | |
| 778 | tickOnce(ctx, t, mClock, worker, tickDone) |
| 779 | } |
| 780 | |
| 781 | func TestWorker_MarkStale_EmptyBranchOrOrigin(t *testing.T) { |
| 782 | t.Parallel() |
nothing calls this directly
no test coverage detected