Function TestAttachmentRetrievalUsingRevCache

db/attachment_test.go:279–321

(t *testing.T)

}

func TestAttachmentRetrievalUsingRevCache(t *testing.T) {
	db, ctx := setupTestDB(t)
	defer db.Close(ctx)

	collection, ctx := GetSingleDatabaseCollectionWithUser(ctx, t, db)

	// Test creating & updating a document:
	rev1input := `{"_attachments": {"hello.txt": {"data":"aGVsbG8gd29ybGQ="},
                                    "bye.txt": {"data":"Z29vZGJ5ZSBjcnVlbCB3b3JsZA=="}}}`
	_, _, err := collection.Put(ctx, "doc1", unmarshalBody(t, rev1input))
	require.NoError(t, err, "Couldn't create document")

	initCount, countErr := base.GetExpvarAsInt("syncGateway_db", "document_gets")
	require.NoError(t, countErr, "Couldn't retrieve document_gets expvar")
	gotbody, err := collection.Get1xRevBody(ctx, "doc1", "1-ca9ad22802b66f662ff171f226211d5c", false, []string{})
	require.NoError(t, err, "Couldn't get document")

	assertAttachments := func(atts AttachmentMap) {
		require.Equal(t, AttachmentMap{
			"hello.txt": DocAttachment{
				Data:   []byte("hello world"),
				Digest: "sha1-Kq5sNclPz7QV2+lfQIuc6R7oRu0=",
				Length: 11,
				Revpos: 1,
			},
			"bye.txt": DocAttachment{
				Data:   []byte("goodbye cruel world"),
				Digest: "sha1-l+N7VpXGnoxMm8xfvtWPbz2YvDc=",
				Length: 19,
				Revpos: 1,
			},
		}, atts)
		getCount, countErr := base.GetExpvarAsInt("syncGateway_db", "document_gets")
		require.NoError(t, countErr, "Couldn't retrieve document_gets expvar")
		require.Equal(t, initCount, getCount)
	}
	assertAttachments(GetAttachmentsFrom1xBody(t, gotbody))

	// Repeat, validate no additional get operations
	gotbody, err = collection.Get1xRevBody(ctx, "doc1", "1-ca9ad22802b66f662ff171f226211d5c", false, []string{})
	require.NoError(t, err, "Couldn't get document")
	assertAttachments(GetAttachmentsFrom1xBody(t, gotbody))
}

func TestAttachmentCASRetryAfterNewAttachment(t *testing.T) {