Function TestActiveOnlyCacheUpdate

db/changes_test.go:404–463

(t *testing.T)

}

func TestActiveOnlyCacheUpdate(t *testing.T) {

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

	base.SetUpTestLogging(t, base.LevelInfo, base.KeyChanges, base.KeyCache)
	// Create 10 documents
	revId := ""
	var err error
	for i := 1; i <= 10; i++ {
		key := fmt.Sprintf("%s_%d", t.Name(), i)
		body := Body{"foo": "bar"}
		revId, _, err = collection.Put(ctx, key, body)
		require.NoError(t, err, "Couldn't create document")
	}

	// Tombstone 5 documents
	for i := 2; i <= 6; i++ {
		key := fmt.Sprintf("%s_%d", t.Name(), i)
		_, _, err = collection.DeleteDoc(ctx, key, DocVersion{RevTreeID: revId})
		require.NoError(t, err, "Couldn't delete document")
	}

	waitErr := collection.WaitForPendingChanges(base.TestCtx(t))
	assert.NoError(t, waitErr)

	changesOptions := ChangesOptions{
		Since:      SequenceID{Seq: 0},
		ActiveOnly: true,
		ChangesCtx: base.TestCtx(t),
	}

	initQueryCount := db.DbStats.Cache().ViewQueries.Value()

	// Get changes with active_only=true
	activeChanges := getChanges(t, collection, base.SetOf("*"), changesOptions)
	require.Len(t, activeChanges, 5)

	// Ensure the test is triggering a query, and not serving from DCP-generated cache
	postChangesQueryCount := db.DbStats.Cache().ViewQueries.Value()
	assert.Equal(t, initQueryCount+1, postChangesQueryCount)

	// Get changes with active_only=false, validate that triggers a new query
	changesOptions.ActiveOnly = false
	allChanges := getChanges(t, collection, base.SetOf("*"), changesOptions)
	require.Len(t, allChanges, 10)

	postChangesQueryCount = db.DbStats.Cache().ViewQueries.Value()
	assert.Equal(t, initQueryCount+2, postChangesQueryCount)

	// Get changes with active_only=false again, verify results are served from the cache
	changesOptions.ActiveOnly = false
	allChanges = getChanges(t, collection, base.SetOf("*"), changesOptions)
	require.Len(t, allChanges, 10)

	postChangesQueryCount = db.DbStats.Cache().ViewQueries.Value()
	assert.Equal(t, initQueryCount+2, postChangesQueryCount)