Function TestChannelQuery

db/database_test.go:2956–3033

(t *testing.T)

}

func TestChannelQuery(t *testing.T) {

	db, ctx := setupTestDB(t)
	defer db.Close(ctx)
	collection, ctx := GetSingleDatabaseCollectionWithUser(ctx, t, db)
	_, err := collection.UpdateSyncFun(ctx, `function(doc, oldDoc) {
		channel(doc.channels);
	}`)
	require.NoError(t, err)

	// Create doc
	body := Body{"key1": "value1", "key2": 1234, "channels": "ABC"}
	rev1ID, _, err := collection.Put(ctx, "doc1", body)
	require.NoError(t, err, "Couldn't create doc1")

	// Create a doc to test removal handling.  Needs three revisions so that the removal rev (2) isn't
	// the current revision
	removedDocID := "removed_doc"
	removedDocRev1, rev1, err := collection.Put(ctx, removedDocID, body)
	require.NoError(t, err, "Couldn't create removed_doc")

	updatedChannelBody := Body{"_rev": removedDocRev1, "key1": "value1", "key2": 1234, "channels": "DEF"}
	removalRev, rev2, err := collection.Put(ctx, removedDocID, updatedChannelBody)
	require.NoError(t, err, "Couldn't update removed_doc")

	updatedChannelBody = Body{"_rev": removalRev, "key1": "value1", "key2": 2345, "channels": "DEF"}
	_, rev3, err := collection.Put(ctx, removedDocID, updatedChannelBody)
	require.NoError(t, err, "Couldn't update removed_doc")

	log.Printf("versions: [%v %v %v]", rev1.HLV.Version, rev2.HLV.Version, rev3.HLV.Version)

	// TODO: check the case where the channel is removed with a putExistingRev mutation

	var entries LogEntries

	// Test query retrieval via star channel and named channel (queries use different indexes)
	testCases := []struct {
		testName    string
		channelName string
		expectedRev channels.RevAndVersion
	}{
		{
			testName:    "star channel",
			channelName: "*",
			expectedRev: rev3.RevAndVersion,
		},
		{
			testName:    "named channel",
			channelName: "ABC",
			expectedRev: rev2.RevAndVersion,
		},
	}

	for _, testCase := range testCases {
		t.Run(testCase.testName, func(t *testing.T) {
			entries, err = collection.getChangesInChannelFromQuery(ctx, testCase.channelName, 0, 100, 0, false)
			require.NoError(t, err)