Prepare implementation of $geoNear stage #138

bwaldvogel · May 23, 2020 · 0082800 · 0082800
1 parent f2e508e
commit 0082800
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 0 deletions.
diff --git a/core/src/main/java/de/bwaldvogel/mongo/backend/aggregation/Aggregation.java b/core/src/main/java/de/bwaldvogel/mongo/backend/aggregation/Aggregation.java
@@ -39,6 +39,7 @@
 import de.bwaldvogel.mongo.bson.Document;
 import de.bwaldvogel.mongo.exception.FailedToParseException;
 import de.bwaldvogel.mongo.exception.MongoServerError;
+import de.bwaldvogel.mongo.exception.MongoServerNotYetImplementedException;
 import de.bwaldvogel.mongo.exception.TypeMismatchException;
 
 public class Aggregation {
@@ -157,6 +158,8 @@ private static Aggregation fromPipeline(List<Document> pipeline, MongoDatabase d
                     Document redactExpression = (Document) stage.get(stageOperation);
                     aggregation.addStage(new RedactStage(redactExpression));
                     break;
+                case "$geoNear":
+                    throw new MongoServerNotYetImplementedException(138, stageOperation);
                 default:
                     throw new MongoServerError(40324, "Unrecognized pipeline stage name: '" + stageOperation + "'");
             }

diff --git a/test-common/src/main/java/de/bwaldvogel/mongo/backend/AbstractAggregationTest.java b/test-common/src/main/java/de/bwaldvogel/mongo/backend/AbstractAggregationTest.java
@@ -1955,6 +1955,16 @@ void testAggregateWithRedact() {
             .containsOnly(json("_id: 1"));
     }
 
+    // https://github.com/bwaldvogel/mongo-java-server/issues/138
+    @Test
+    public void testAggregateWithGeoNear() throws Exception {
+        List<Document> pipeline = jsonList("$geoNear: {}");
+
+        assertThatExceptionOfType(MongoCommandException.class)
+            .isThrownBy(() -> collection.aggregate(pipeline).first())
+            .withMessageContaining("Command failed with error -1: '$geoNear is not yet implemented. See https://github.com/bwaldvogel/mongo-java-server/issues/138'");
+    }
+
     private static Function<Document, Document> withSortedStringList(String key) {
         return document -> {
             @SuppressWarnings("unchecked")

diff --git a/test-common/src/test/java/de/bwaldvogel/mongo/RealMongoAggregationTest.java b/test-common/src/test/java/de/bwaldvogel/mongo/RealMongoAggregationTest.java
@@ -2,6 +2,7 @@
 
 import java.net.InetSocketAddress;
 
+import org.junit.Assume;
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
 import org.testcontainers.containers.GenericContainer;
@@ -33,4 +34,9 @@ protected MongoBackend createBackend() throws Exception {
         throw new UnsupportedOperationException();
     }
 
+    @Override
+    public void testAggregateWithGeoNear() throws Exception {
+        Assume.assumeTrue(false);
+        super.testAggregateWithGeoNear();
+    }
 }