Updating SPaT index source

CDOT-CV · May 20, 2024 · 09bf1da · 09bf1da
1 parent 71cd2c1
commit 09bf1da
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 8 deletions.
diff --git a/jpo-conflictmonitor b/jpo-conflictmonitor
diff --git a/...-api/src/main/java/us/dot/its/jpo/ode/api/accessors/spat/ProcessedSpatRepositoryImpl.java b/...-api/src/main/java/us/dot/its/jpo/ode/api/accessors/spat/ProcessedSpatRepositoryImpl.java
@@ -14,11 +14,9 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 
 import us.dot.its.jpo.geojsonconverter.DateJsonMapper;
-import us.dot.its.jpo.geojsonconverter.pojos.geojson.map.ProcessedMap;
 import us.dot.its.jpo.geojsonconverter.pojos.spat.ProcessedSpat;
 import us.dot.its.jpo.ode.api.ConflictMonitorApiProperties;
 import us.dot.its.jpo.ode.api.models.IDCount;
-import org.springframework.data.domain.Sort;
 import java.util.HashMap;
 import java.util.Map;
 
@@ -29,9 +27,6 @@
 import org.springframework.data.mongodb.core.aggregation.ConvertOperators;
 import org.springframework.data.mongodb.core.aggregation.DateOperators;
 
-import java.time.format.DateTimeFormatter;
-import java.time.ZonedDateTime;
-
 @Component
 public class ProcessedSpatRepositoryImpl implements ProcessedSpatRepository {
 
@@ -62,7 +57,7 @@ public Query getQuery(Integer intersectionID, Long startTime, Long endTime) {
             endTimeString = Instant.ofEpochMilli(endTime).toString();
         }
 	    query.limit(props.getMaximumResponseSize());
-        query.addCriteria(Criteria.where("odeReceivedAt").gte(startTimeString).lte(endTimeString));
+        query.addCriteria(Criteria.where("utcTimeStamp").gte(startTimeString).lte(endTimeString));
         query.fields().exclude("recordGeneratedAt");
         return query;
     }

diff --git a/.../test/java/us/dot/its/jpo/ode/api/accessorTests/spat/ProcessedSpatRepositoryImplTest.java b/.../test/java/us/dot/its/jpo/ode/api/accessorTests/spat/ProcessedSpatRepositoryImplTest.java
@@ -60,7 +60,7 @@ public void testGetQuery() {
 
 
         // Assert Start and End Time
-        Document queryTimeDocument = (Document)query.getQueryObject().get("odeReceivedAt");
+        Document queryTimeDocument = (Document)query.getQueryObject().get("utcTimeStamp");
         assertThat(queryTimeDocument.getString("$gte")).isEqualTo(Instant.ofEpochMilli(startTime).toString());
         assertThat(queryTimeDocument.getString("$lte")).isEqualTo(Instant.ofEpochMilli(endTime).toString());