WIP

internal/planner/select.go

@@ -255,19 +255,24 @@ func (n *selectNode) initSource() ([]aggregateNode, error) {
 		origScan.filter = n.filter
 		n.filter = nil
 
-		// If we have both a DocID and a CID, then we need to run
-		// a TimeTravel (History-Traversing Versioned) query, which means
-		// we need to propagate the values to the underlying VersionedFetcher
+		// If we have a CID, then we need to run a TimeTravel (History-Traversing Versioned)
+		// query, which means we need to propagate the values to the underlying VersionedFetcher
 		if n.selectReq.Cid.HasValue() {
 			c, err := cid.Decode(n.selectReq.Cid.Value())
 			if err != nil {
 				return nil, err
 			}
+
+			var docID string
+			if len(n.selectReq.DocIDs.Value()) > 0 {
+				docID = n.selectReq.DocIDs.Value()[0]
+			}
+
 			origScan.Spans(
 				[]core.Span{
 					core.NewSpan(
 						keys.HeadstoreDocKey{
-							DocID: n.selectReq.DocIDs.Value()[0],
+							DocID: docID,
 							Cid:   c,
 						},
 						keys.HeadstoreDocKey{},

tests/integration/query/simple/with_cid_test.go

@@ -13,10 +13,6 @@ package simple
 import (
 	"testing"
 
-	"github.com/sourcenetwork/immutable"
-	"github.com/stretchr/testify/require"
-
-	"github.com/sourcenetwork/defradb/tests/change_detector"
 	testUtils "github.com/sourcenetwork/defradb/tests/integration"
 )
 
@@ -44,20 +40,8 @@ func TestQuerySimpleWithInvalidCid(t *testing.T) {
 	executeTestCase(t, test)
 }
 
-// This test documents a bug:
-// https://github.com/sourcenetwork/defradb/issues/3214
 func TestQuerySimpleWithCid(t *testing.T) {
-	if change_detector.Enabled {
-		t.Skipf("Change detector does not support requiring panics")
-	}
-
 	test := testUtils.TestCase{
-		SupportedClientTypes: immutable.Some(
-			[]testUtils.ClientType{
-				// The CLI/Http clients don't panic in this context
-				testUtils.GoClientType,
-			},
-		),
 		Actions: []any{
 			testUtils.SchemaUpdate{
 				Schema: `
@@ -90,7 +74,5 @@ func TestQuerySimpleWithCid(t *testing.T) {
 		},
 	}
 
-	require.Panics(t, func() {
-		testUtils.ExecuteTestCase(t, test)
-	})
+	testUtils.ExecuteTestCase(t, test)
 }