fix legacy tests

pharo-nosql · Jan 16, 2024 · 0a4a12c · 0a4a12c
1 parent 52172ac
commit 0a4a12c
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 3 deletions.
diff --git a/mc/Mongo-DriverLegacy/MongoCursorLegacy.class.st b/mc/Mongo-DriverLegacy/MongoCursorLegacy.class.st
@@ -28,11 +28,10 @@ MongoCursorLegacy >> execute [
 					collection: query collection ]
 			ifNil: [
 				self cursorQuery: query ].
-
-		reply := OpMsgReply fromStream: root stream.
+			
+		reply := (ReplyOperation stream: root stream) read.
 		reply responseTo = requestId
 			ifFalse: [ ^ MongoWireProtocolError signal: 'Unexpected responseTo in response' ].
-
 		reply do: [:each |
 			numberReturned < limit ifTrue: [
 				query doBlock value: each.

diff --git a/mc/Mongo-DriverLegacy/MongoLegacyDriver.class.st b/mc/Mongo-DriverLegacy/MongoLegacyDriver.class.st
@@ -47,6 +47,14 @@ MongoLegacyDriver >> insert: aDocument collection: aMongoCollection [
 		write
 ]
 
+{ #category : #factory }
+MongoLegacyDriver >> newCommandQuery: aQuery [
+
+	^ self commandQueryClass
+		root: self root
+		query: aQuery
+]
+
 { #category : #factory }
 MongoLegacyDriver >> newQuery [