Function TestChannelView

db/database_test.go:2919–2954

(t *testing.T)

}

func TestChannelView(t *testing.T) {

	db, ctx := setupTestDBWithViewsEnabled(t)
	defer db.Close(ctx)
	collection, err := db.GetDefaultDatabaseCollectionWithUser()
	require.NoError(t, err)
	ctx = collection.AddCollectionContext(ctx)

	// Create doc
	log.Printf("Create doc 1...")
	body := Body{"key1": "value1", "key2": 1234}
	rev1id, _, err := collection.Put(ctx, "doc1", body)
	assert.NoError(t, err, "Couldn't create document")
	assert.Equal(t, "1-cb0c9a22be0e5a1b01084ec019defa81", rev1id)

	var entries LogEntries
	// Query view (retry loop to wait for indexing)
	for i := 0; i < 10; i++ {
		var err error
		entries, err = collection.getChangesInChannelFromQuery(ctx, "*", 0, 100, 0, false)

		assert.NoError(t, err, "Couldn't create document")
		if len(entries) >= 1 {
			break
		}
		log.Printf("No entries found - retrying (%d/10)", i+1)
		time.Sleep(500 * time.Millisecond)
	}

	for i, entry := range entries {
		log.Printf("View Query returned entry (%d): %v", i, entry)
	}
	assert.Len(t, entries, 1)
	require.Equal(t, "doc1", entries[0].DocID)
	collection.RequireCurrentVersion(t, "doc1", entries[0].SourceID, entries[0].Version)
}

func TestChannelQuery(t *testing.T) {