WIP - add support

tests/integration/results.go

@@ -16,6 +16,7 @@ import (
 	"testing"
 	"time"
 
+	"github.com/ipfs/go-cid"
 	"github.com/sourcenetwork/immutable"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
@@ -227,3 +228,42 @@ func assertCollectionDescriptions(
 		}
 	}
 }
+
+//////////////////////////////////////
+
+type Foo interface { // probs not needed
+	Validate(s *state, actualValue any)
+}
+
+type UniqueCid struct {
+	ID any
+}
+
+func NewUniqueCid(id any) UniqueCid {
+	return UniqueCid{
+		ID: id,
+	}
+}
+
+func (ucid *UniqueCid) Validate(s *state, actualValue any, msgAndArgs ...any) {
+	isNew := true
+	for id, value := range s.cids {
+		if id == ucid.ID {
+			require.Equal(s.t, value, actualValue)
+			isNew = false
+		} else {
+			require.NotEqual(s.t, value, actualValue, "UniqueCid must be unique!", msgAndArgs)
+		}
+	}
+
+	if isNew {
+		require.IsType(s.t, "", actualValue)
+
+		cid, err := cid.Decode(actualValue.(string))
+		if err != nil {
+			require.NoError(s.t, err)
+		}
+
+		s.cids[ucid.ID] = cid.String()
+	}
+}

tests/integration/state.go

@@ -175,6 +175,8 @@ type state struct {
 	// nodes.
 	docIDs [][]client.DocID
 
+	cids map[any]string
+
 	// Indexes, by index, by collection index, by node index.
 	indexes [][][]client.IndexDescription
 
@@ -218,6 +220,7 @@ func newState(
 		collectionNames:          collectionNames,
 		collectionIndexesByRoot:  map[uint32]int{},
 		docIDs:                   [][]client.DocID{},
+		cids:                     map[any]string{},
 		indexes:                  [][][]client.IndexDescription{},
 		isBench:                  false,
 	}

tests/integration/utils.go

@@ -2067,6 +2067,8 @@ func assertRequestResultDocs(
 
 		for field, actualValue := range actualDoc {
 			stack.pushMap(field)
+			pathInfo := fmt.Sprintf("node: %v, path: %s", nodeID, stack)
+
 			switch expectedValue := expectedDoc[field].(type) {
 			case AnyOf:
 				assertResultsAnyOf(s.t, s.clientType, expectedValue, actualValue)
@@ -2077,7 +2079,7 @@ func assertRequestResultDocs(
 					s.clientType,
 					expectedDocID,
 					actualValue,
-					fmt.Sprintf("node: %v, path: %s", nodeID, stack),
+					pathInfo,
 				)
 			case []map[string]any:
 				actualValueMap := ConvertToArrayOfMaps(s.t, actualValue)
@@ -2090,13 +2092,16 @@ func assertRequestResultDocs(
 					stack,
 				)
 
+			case UniqueCid:
+				expectedValue.Validate(s, actualValue, pathInfo)
+
 			default:
 				assertResultsEqual(
 					s.t,
 					s.clientType,
 					expectedValue,
 					actualValue,
-					fmt.Sprintf("node: %v, path: %s", nodeID, stack),
+					pathInfo,
 				)
 			}
 			stack.pop()