Function TestRefreshChat_UpsertError

coderd/x/gitsync/worker_test.go:1139–1174

(t *testing.T)

}

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

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

	row := database.ChatDiffStatus{
		ChatID:          chatID,
		GitBranch:       "feature",
		GitRemoteOrigin: "https://github.com/owner/repo",
	}

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

	store.EXPECT().UpsertChatDiffStatus(gomock.Any(), gomock.Any()).
		Return(database.ChatDiffStatus{}, fmt.Errorf("db write error"))

	var publishCalled atomic.Bool
	pub := func(_ context.Context, _ uuid.UUID) error {
		publishCalled.Store(true)
		return nil
	}

	mClock := quartz.NewMock(t)
	logger := slogtest.Make(t, &slogtest.Options{IgnoreErrors: true})
	refresher := newTestRefresher(t, mClock)
	worker := gitsync.NewWorker(store, refresher, pub, mClock, logger)

	result, err := worker.RefreshChat(ctx, row, ownerID)
	require.Error(t, err)
	assert.Contains(t, err.Error(), "upsert chat diff status")
	assert.Nil(t, result)
	assert.False(t, publishCalled.Load(), "publish should not be called when upsert fails")
}

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