Function TestChannelCacheBufferingWithUserDoc

db/change_cache_test.go:467–502

Test notification when buffered entries are processed after a user doc arrives.

(t *testing.T)

// Test notification when buffered entries are processed after a user doc arrives.
func TestChannelCacheBufferingWithUserDoc(t *testing.T) {

	base.SetUpTestLogging(t, base.LevelDebug, base.KeyCache, base.KeyChanges, base.KeyDCP)

	db, ctx := setupTestDB(t)
	defer db.Close(ctx)

	collection := GetSingleDatabaseCollection(t, db.DatabaseContext)
	collectionID := collection.GetCollectionID()

	// Simulate seq 1 (user doc) being delayed - write 2 first
	WriteDirect(t, collection, []string{"ABC"}, 2)

	// Start wait for doc in ABC
	chans := channels.SetOfNoValidate(
		channels.NewID("ABC", collectionID))
	waiter := db.mutationListener.NewWaiterWithChannels(chans, nil, false)

	successChan := make(chan bool)
	go func() {
		waiter.Wait(ctx)
		close(successChan)
	}()

	// Simulate a user doc update
	writeUserDirect(t, db, "bernard", 1)

	// Wait 3 seconds for notification, else fail the test.
	select {
	case <-successChan:
		log.Println("notification successful")
	case <-time.After(time.Second * 3):
		t.Fatal("No notification after 3 seconds")
	}

}

// Test backfill of late arriving sequences to the channel caches
func TestChannelCacheBackfill(t *testing.T) {