Function TestPutExistingCurrentVersionWithConflict

db/crud_test.go:1854–1899

TestPutExistingCurrentVersionWithConflict: - Put a document in a db - Assert on the update to HLV after that PUT - Construct a HLV to represent the doc created locally being updated on a client - Call PutExistingCurrentVersion simulating doc update arriving over replicator - Assert conflict between

(t *testing.T)

//   - Assert conflict between the local HLV for the doc and the incoming mutation is correctly identified
//   - Assert that the doc's HLV in the bucket hasn't been updated
func TestPutExistingCurrentVersionWithConflict(t *testing.T) {
	db, ctx := setupTestDB(t)
	defer db.Close(ctx)

	bucketUUID := db.EncodedSourceID
	collection, ctx := GetSingleDatabaseCollectionWithUser(ctx, t, db)

	// create a new doc
	key := "doc1"
	body := Body{"key1": "value1"}

	_, _, err := collection.Put(ctx, key, body)
	require.NoError(t, err)

	// assert on the HLV values after the above creation of the doc
	doc, err := collection.GetDocument(ctx, "doc1", DocUnmarshalSync)
	require.NoError(t, err)
	assert.Equal(t, bucketUUID, doc.HLV.SourceID)
	assert.Equal(t, base.HexCasToUint64(doc.SyncData.Cas), doc.HLV.Version)
	assert.Equal(t, base.HexCasToUint64(doc.SyncData.Cas), doc.HLV.CurrentVersionCAS)

	// create a new doc update to simulate a doc update arriving over replicator from, client
	body = Body{"key1": "value2"}
	newDoc := CreateTestDocument(key, "", body, false, 0)
	incomingHLV := &HybridLogicalVector{
		SourceID: "test",
		Version:  1234,
	}

	opts := PutDocOptions{
		NewDoc:    newDoc,
		NewDocHLV: incomingHLV,
	}
	// assert that a conflict is correctly identified and the doc and cv are nil
	doc, cv, _, err := collection.PutExistingCurrentVersion(ctx, opts)
	assertHTTPError(t, err, 409)
	require.Nil(t, doc)
	require.Nil(t, cv)

	// assert persisted doc hlv hasn't been updated
	doc, err = collection.GetDocument(ctx, "doc1", DocUnmarshalSync)
	assert.NoError(t, err)
	assert.Equal(t, bucketUUID, doc.HLV.SourceID)
	assert.Equal(t, base.HexCasToUint64(doc.SyncData.Cas), doc.HLV.Version)
	assert.Equal(t, base.HexCasToUint64(doc.SyncData.Cas), doc.HLV.CurrentVersionCAS)
}

// TestPutExistingCurrentVersionWithNoExistingDoc:
//   - Purpose of this test is to test PutExistingRevWithBody code pathway where an