Function TestDuplicateDocID

db/channel_cache_single_test.go:27–80

(t *testing.T)

)

func TestDuplicateDocID(t *testing.T) {

	base.SetUpTestLogging(t, base.LevelInfo, base.KeyCache)

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

	collection := GetSingleDatabaseCollection(t, db.DatabaseContext)

	stats, err := base.NewSyncGatewayStats()
	require.NoError(t, err)

	dbstats, err := stats.NewDBStats("", false, false, false, nil, nil)
	require.NoError(t, err)

	cache := newSingleChannelCache(collection, channels.NewID("Test1", collection.GetCollectionID()), 0, dbstats.Cache())
	assert.NotNil(t, cache)

	// Add some entries to cache
	cache.addToCache(ctx, testLogEntry(1, "doc1", "1-a"), false)
	cache.addToCache(ctx, testLogEntry(2, "doc3", "3-a"), false)
	cache.addToCache(ctx, testLogEntry(3, "doc5", "5-a"), false)

	entries, err := cache.GetChanges(ctx, getChangesOptionsWithZeroSeq(t))
	require.Len(t, entries, 3)
	assert.True(t, verifyChannelSequences(entries, []uint64{1, 2, 3}))
	assert.True(t, verifyChannelDocIDs(entries, []string{"doc1", "doc3", "doc5"}))
	assert.True(t, err == nil)

	// Add a new revision matching mid-list
	cache.addToCache(ctx, testLogEntry(4, "doc3", "3-b"), false)
	entries, err = cache.GetChanges(ctx, getChangesOptionsWithZeroSeq(t))
	require.Len(t, entries, 3)
	assert.True(t, verifyChannelSequences(entries, []uint64{1, 3, 4}))
	assert.True(t, verifyChannelDocIDs(entries, []string{"doc1", "doc5", "doc3"}))
	assert.True(t, err == nil)

	// Add a new revision matching first
	cache.addToCache(ctx, testLogEntry(5, "doc1", "1-b"), false)
	entries, err = cache.GetChanges(ctx, getChangesOptionsWithZeroSeq(t))
	require.Len(t, entries, 3)
	assert.True(t, verifyChannelSequences(entries, []uint64{3, 4, 5}))
	assert.True(t, verifyChannelDocIDs(entries, []string{"doc5", "doc3", "doc1"}))
	assert.True(t, err == nil)

	// Add a new revision matching last
	cache.addToCache(ctx, testLogEntry(6, "doc1", "1-c"), false)
	entries, err = cache.GetChanges(ctx, getChangesOptionsWithZeroSeq(t))
	require.Len(t, entries, 3)
	assert.True(t, verifyChannelSequences(entries, []uint64{3, 4, 6}))
	assert.True(t, verifyChannelDocIDs(entries, []string{"doc5", "doc3", "doc1"}))
	assert.True(t, err == nil)

}

func TestLateArrivingSequence(t *testing.T) {