Function TestChannelQueryRevocation

db/database_test.go:3036–3112

TestChannelQueryRevocation ensures that the correct rev (revTreeID and cv) is returned by the channel query.

(t *testing.T)

// TestChannelQueryRevocation ensures that the correct rev (revTreeID and cv) is returned by the channel query.
func TestChannelQueryRevocation(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 with three channels (ABC, DEF, GHI)
	docID := "removalTestDoc"
	body := Body{"key1": "value1", "key2": 1234, "channels": []string{"ABC", "DEF", "GHI"}}
	rev1ID, _, err := collection.Put(ctx, docID, body)
	require.NoError(t, err, "Couldn't create document")

	// Update the doc with a simple PUT to remove channel ABC
	updatedChannelBody := Body{"_rev": rev1ID, "key1": "value1", "key2": 1234, "channels": []string{"DEF", "GHI"}}
	_, rev2, err := collection.Put(ctx, docID, updatedChannelBody)
	require.NoError(t, err, "Couldn't update document via Put")

	// Update the doc with PutExistingCurrentVersion to remove channel DEF
	/* TODO: requires fix to HLV conflict detection
	updatedChannelBody = Body{"_rev": rev2ID, "key1": "value1", "key2": 2345, "channels": "GHI"}
	existingDoc, err := collection.GetDocument(ctx, docID, DocUnmarshalAll)
	require.NoError(t, err)
	cblVersion := Version{SourceID: "CBLSource", Value: existingDoc.HLV.Version + 10}
	hlvErr := existingDoc.HLV.AddVersion(cblVersion)
	require.NoError(t, hlvErr)
	existingDoc.UpdateBody(updatedChannelBody)
	rev3, _, _, err := collection.PutExistingCurrentVersion(ctx, existingDoc, *existingDoc.HLV, nil)
	require.NoError(t, err, "Couldn't update document via PutExistingCurrentVersion")

	*/

	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:    "removal by SGW write",
			channelName: "ABC",
			expectedRev: rev2.RevAndVersion,
		},
		/*
			{
				testName:    "removal by CBL write",
				channelName: "DEF",
				expectedRev: rev3.RevAndVersion,
			},
		*/
	}

	for _, testCase := range testCases {