Method initializeCollections

rest/utilities_testing.go:1542–1577

(collections []string)

}

func (bt *BlipTester) initializeCollections(collections []string) {
	getCollectionsRequest := blip.NewRequest()
	getCollectionsRequest.SetProfile(db.MessageGetCollections)

	checkpointIDs := make([]string, len(collections))
	for i := range checkpointIDs {
		checkpointIDs[i] = "0"
	}

	requestBody := db.GetCollectionsRequestBody{
		Collections:   collections,
		CheckpointIDs: checkpointIDs,
	}
	body, err := base.JSONMarshal(requestBody)
	require.NoError(bt.restTester.TB(), err)

	getCollectionsRequest.SetBody(body)
	sent := bt.sender.Send(getCollectionsRequest)
	require.True(bt.restTester.TB(), sent)

	type CollectionsResponseEntry struct {
		LastSequence *int    `json:"last_sequence"`
		Rev          *string `json:"rev"`
	}

	response, err := getCollectionsRequest.Response().Body()
	require.NoError(bt.restTester.TB(), err)

	var collectionResponse []*CollectionsResponseEntry
	err = base.JSONUnmarshal(response, &collectionResponse)
	require.NoError(bt.restTester.TB(), err)

	for _, perCollectionResponse := range collectionResponse {
		require.NotNil(bt.restTester.TB(), perCollectionResponse)
	}
}

// newRequest returns a blip msg with a collection property enabled. This function is only ssafe to call if there is a single collection running.
func (bt *BlipTester) newRequest() *blip.Message {