Revert "CBG-4905: update defualt resolver for blip tester" (#7928)

Author: gregns1

rest/utilities_testing_blip_client.go

@@ -344,37 +344,25 @@ func (cd *clientDoc) _hasConflict(t testing.TB, incomingHLV *db.HybridLogicalVec
 	return false
 }
 
-func (btcc *BlipTesterCollectionClient) _resolveConflict(incomingHLV *db.HybridLogicalVector, incomingBody []byte, incomingIsDelete bool, localDoc *clientDocRev) (body []byte, hlv db.HybridLogicalVector, isTombstone bool) {
+func (btcc *BlipTesterCollectionClient) _resolveConflict(incomingHLV *db.HybridLogicalVector, incomingBody []byte, localDoc *clientDocRev) (body []byte, hlv db.HybridLogicalVector) {
 	switch btcc.parent.ConflictResolver {
 	case ConflictResolverLastWriteWins:
 		return btcc._resolveConflictLWW(incomingHLV, incomingBody, localDoc)
 	}
 	btcc.TB().Fatalf("Unknown conflict resolver %q - cannot resolve detected conflict", btcc.parent.ConflictResolver)
-	return nil, db.HybridLogicalVector{}, isTombstone
+	return nil, db.HybridLogicalVector{}
 }
 
-func (btcc *BlipTesterCollectionClient) _resolveConflictLWW(incomingHLV *db.HybridLogicalVector, incomingBody []byte, latestLocalRev *clientDocRev) (body []byte, hlv db.HybridLogicalVector, isTombstone bool) {
+func (btcc *BlipTesterCollectionClient) _resolveConflictLWW(incomingHLV *db.HybridLogicalVector, incomingBody []byte, latestLocalRev *clientDocRev) (body []byte, hlv db.HybridLogicalVector) {
 	latestLocalHLV := latestLocalRev.HLV
 	updatedHLV := latestLocalRev.HLV.Copy()
-	localDeleted := latestLocalRev.isDelete
-	incomingIsDelete := incomingBody == nil || bytes.Equal(incomingBody, []byte(`{}`))
-	if localDeleted && !incomingIsDelete {
-		// resolve in favour of local document
-		incomingHLV.UpdateWithIncomingHLV(updatedHLV)
-		return latestLocalRev.body, *updatedHLV, true
-	}
-	if incomingIsDelete && !localDeleted {
-		// resolve in favour of remote document
-		updatedHLV.UpdateWithIncomingHLV(incomingHLV)
-		return incomingBody, *updatedHLV, true
-	}
 	// resolve conflict in favor of remote document
 	if incomingHLV.Version > latestLocalHLV.Version {
 		updatedHLV.UpdateWithIncomingHLV(incomingHLV)
-		return incomingBody, *updatedHLV, incomingIsDelete
+		return incomingBody, *updatedHLV
 	}
 	incomingHLV.UpdateWithIncomingHLV(updatedHLV)
-	return latestLocalRev.body, *updatedHLV, latestLocalRev.isDelete
+	return latestLocalRev.body, *updatedHLV
 }
 
 type BlipTesterCollectionClient struct {
@@ -2199,15 +2187,14 @@ func (btcc *BlipTesterCollectionClient) addRev(ctx context.Context, docID string
 	btcc.seqLock.Lock()
 	defer btcc.seqLock.Unlock()
 	newClientSeq := btcc._nextSequence()
-	isDelete := opts.isDelete
 
 	newBody := opts.body
 	newVersion := opts.incomingVersion
 	doc, hasLocalDoc := btcc._getClientDoc(docID)
 	updatedHLV := doc._getLatestHLVCopy(btcc.TB())
 	require.NotNil(btcc.TB(), updatedHLV, "updatedHLV should not be nil for docID %q", docID)
 	if doc._hasConflict(btcc.TB(), opts.incomingHLV) {
-		newBody, updatedHLV, isDelete = btcc._resolveConflict(opts.incomingHLV, opts.body, opts.isDelete, doc._latestRev(btcc.TB()))
+		newBody, updatedHLV = btcc._resolveConflict(opts.incomingHLV, opts.body, doc._latestRev(btcc.TB()))
 		base.DebugfCtx(ctx, base.KeySGTest, "Resolved conflict for docID %q, incomingHLV:%#v, existingHLV:%#v, updatedHLV:%#v", docID, opts.incomingHLV, doc._latestRev(btcc.TB()).HLV, updatedHLV)
 	} else {
 		base.DebugfCtx(ctx, base.KeySGTest, "No conflict")
@@ -2220,7 +2207,7 @@ func (btcc *BlipTesterCollectionClient) addRev(ctx context.Context, docID string
 	// ConflictResolver is currently on BlipTesterClient, but might be per replication in the future.
 	docRev := clientDocRev{
 		clientSeq:   newClientSeq,
-		isDelete:    isDelete,
+		isDelete:    opts.isDelete,
 		pullMessage: opts.msg,
 		body:        newBody,
 		HLV:         updatedHLV,

topologytest/multi_actor_no_conflict_test.go

@@ -10,7 +10,6 @@ package topologytest
 
 import (
 	"fmt"
-	"strings"
 	"testing"
 
 	"github.com/couchbase/sync_gateway/base"
@@ -107,21 +106,9 @@ func TestMultiActorResurrect(t *testing.T) {
 
 							resBody := fmt.Appendf(nil, `{"activePeer": "%s", "createPeer": "%s", "deletePeer": "%s", "resurrectPeer": "%s", "topology": "%s", "action": "resurrect"}`, resurrectPeerName, createPeerName, deletePeer, resurrectPeer, topology.specDescription)
 							resurrectVersion := resurrectPeer.WriteDocument(collectionName, docID, resBody)
-							// in the case of a Couchbase Server resurrection, the hlv is lost since all system xattrs are
-							// lost on a resurrection so the resurrecting version may conflict with a version on cbl
-							// peer then cbl will resolve in favor if its own tombstone.
+							// in the case of a Couchbase Server resurrection, the hlv is lost since all system xattrs are lost on a resurrection
 							if resurrectPeer.Type() == PeerTypeCouchbaseServer {
-								if strings.Contains(topologySpec.description, "CBL") {
-									if conflictNotExpectedOnCBL(deletePeer, resurrectPeer) {
-										// if no cbl conflict is expected we can wait on CV and body
-										waitForCVAndBody(t, collectionName, docID, resurrectVersion, topology)
-									} else {
-										// if cbl conflict is expected we need to wait for tombstone convergence
-										waitForConvergingTombstones(t, collectionName, docID, topology)
-									}
-								} else {
-									waitForCVAndBody(t, collectionName, docID, resurrectVersion, topology)
-								}
+								waitForCVAndBody(t, collectionName, docID, resurrectVersion, topology)
 							} else {
 								waitForVersionAndBody(t, collectionName, docID, resurrectVersion, topology)
 							}

topologytest/peer_test.go

@@ -127,30 +127,6 @@ func (p Peers) SortedPeers() iter.Seq2[string, Peer] {
 	}
 }
 
-// peerIsServerSide returns true if the peer is a Couchbase Server or Sync Gateway peer.
-func peerIsServerSide(p Peer) bool {
-	return p.Type() == PeerTypeCouchbaseServer || p.Type() == PeerTypeSyncGateway
-}
-
-// conflictNotExpectedOnCBL will return true if no conflict is expected for delete and resurrect operations for
-// topologies with cbl peer in them and false for expected conflict
-func conflictNotExpectedOnCBL(deletePeer Peer, resurrectPeer Peer) bool {
-	if deletePeer.Type() == PeerTypeCouchbaseLite {
-		// cbl delete will mean cbs resurrect has a conflict
-		return false
-	}
-	if peerIsServerSide(deletePeer) && peerIsServerSide(resurrectPeer) {
-		if deletePeer.SourceID() != resurrectPeer.SourceID() {
-			// conflict expected due to different backing bucket (sourceID)
-			return false
-		}
-		// if both actors are server side and same backing bucket, no conflict expected
-		return true
-	}
-	// conflict expected
-	return false
-}
-
 // NonImportSortedPeers returns a sorted iterator peers that will not cause import operations. For example:
 //   - cbs1 <-> sg1 <-> cbl1 would return sg1 and cbl1, but not cbs1
 //   - cbs1 <-> cbs2 would return cbs1 and cbs2