src/services/pis.services.js

@@ -10,22 +10,20 @@ async function findPisByOrigDest(start,end) {
     const lastCrs = clean.cleanApiEndpointTxt(end.toLowerCase())
     const query = {
         stops: {
-            $elemMatch: {
-                $eq: firstCrs,
-                $position: 0
-            }
+            $all: [
+              { $elemMatch: { $eq: firstCrs } },
+              { $elemMatch: { $eq: lastCrs } }
+            ]
           },
-        stops: {
-            $elemMatch: {
-                $eq: lastCrs,
-                $position: {
-                    $exists: false
-                }
-            }
+          $expr: {
+            $eq: [
+              { $arrayElemAt: [ "$stops", 0 ] },
+              firstCrs
+            ]
           }
         }
     const oldQuery = {$and:[{$expr:{$eq:[{$first:"$stops"},firstCrs]}},{$expr:{$eq:[{$last:"$stops"},lastCrs]}}]}
-    const search = db.query("pis", query)
+    const search = db.query("pis", oldQuery)
     return search
 }