merge Release/2024 q3 into master

.gitmodules

@@ -5,4 +5,4 @@
 
 [submodule "api/asn1_codec"]
 	path = api/asn1_codec
-	url = https://github.com/iyourshaw/asn1_codec.git
+	url = https://github.com/usdot-jpo-ode/asn1_codec.git

README.md

@@ -132,6 +132,7 @@ Once these components have been installed. Download and install additional depen
 ```
 cd api/jpo-conflictvisualizer-api
 mvn clean install
+mvn spring-boot:run
 ```
 
 ### 2. Running Conflict Visualizer GUI Locally

api/jpo-conflictvisualizer-api/pom.xml

@@ -11,7 +11,7 @@
 	</parent>
 	<groupId>usdot.jpo.ode</groupId>
 	<artifactId>jpo-conflictvisualizer-api</artifactId>
-	<version>1.3.1-SNAPSHOT</version>
+	<version>1.4.0-SNAPSHOT</version>
 	<packaging>jar</packaging>
 	<name>jpo-conflictvisualizer-api</name>
 	<description>Conflict Visualizer</description>
@@ -98,7 +98,7 @@
 		<dependency>
 			<groupId>usdot.jpo.ode</groupId>
 			<artifactId>jpo-ode-core</artifactId>
-			<version>2.1.0-SNAPSHOT</version>
+			<version>3.0.0-SNAPSHOT</version>
 			<!-- required exclusion to preserve keycloak versions -->
 			<exclusions>
 				<exclusion>
@@ -110,23 +110,23 @@
 		<dependency>
 			<groupId>usdot.jpo.ode</groupId>
 			<artifactId>jpo-ode-plugins</artifactId>
-			<version>2.1.0-SNAPSHOT</version>
+			<version>3.0.0-SNAPSHOT</version>
 		</dependency>
 		<dependency>
 			<groupId>usdot.jpo.ode</groupId>
 			<artifactId>jpo-ode-svcs</artifactId>
-			<version>2.1.0-SNAPSHOT</version>
+			<version>3.0.0-SNAPSHOT</version>
 		</dependency>
 		<dependency>
 			<groupId>usdot.jpo.ode</groupId>
 			<artifactId>jpo-geojsonconverter</artifactId>
-			<version>1.3.1-SNAPSHOT</version>
+			<version>1.4.2-SNAPSHOT</version>
 			<classifier>jpo-geojsonconverter</classifier>
 		</dependency>
 		<dependency>
 			<groupId>usdot.jpo.ode</groupId>
 			<artifactId>jpo-conflictmonitor</artifactId>
-			<version>1.3.1-SNAPSHOT</version>
+			<version>1.4.1-SNAPSHOT</version>
 			<classifier>jpo-conflictmonitor</classifier>
 		</dependency>
 		<dependency>

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/assessments/ConnectionOfTravelAssessment/ConnectionOfTravelAssessmentRepository.java

@@ -11,7 +11,11 @@ public interface ConnectionOfTravelAssessmentRepository extends DataLoader<Conne
     Query getQuery(Integer intersectionID, Long startTime, Long endTime, boolean latest);
 
     long getQueryResultCount(Query query);
+
+    long getQueryFullCount(Query query);
 
     List<ConnectionOfTravelAssessment> find(Query query);  
+
+
 }
 

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/assessments/ConnectionOfTravelAssessment/ConnectionOfTravelAssessmentRepositoryImpl.java

@@ -51,11 +51,20 @@ public Query getQuery(Integer intersectionID, Long startTime, Long endTime, bool
         return query;
     }
 
+
     public long getQueryResultCount(Query query) {
-        query.limit(-1);
         return mongoTemplate.count(query, ConnectionOfTravelAssessment.class, collectionName);
     }
 
+    // Removes the result limit on a count query. 
+    public long getQueryFullCount(Query query){
+        int limit = query.getLimit();
+        query.limit(-1);
+        long count = mongoTemplate.count(query, ConnectionOfTravelAssessment.class, collectionName);
+        query.limit(limit);
+        return count;
+    }
+
     public List<ConnectionOfTravelAssessment> find(Query query) {
         return mongoTemplate.find(query, ConnectionOfTravelAssessment.class, collectionName);
     }

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/assessments/LaneDirectionOfTravelAssessment/LaneDirectionOfTravelAssessmentRepository.java

@@ -11,6 +11,8 @@ public interface LaneDirectionOfTravelAssessmentRepository extends DataLoader<La
         Query getQuery(Integer intersectionID, Long startTime, Long endTime, boolean latest);
 
         long getQueryResultCount(Query query);
+
+        long getQueryFullCount(Query query);
 
         List<LaneDirectionOfTravelAssessment> find(Query query);
 

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/assessments/LaneDirectionOfTravelAssessment/LaneDirectionOfTravelAssessmentRepositoryImpl.java

@@ -10,6 +10,7 @@
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Component;
+
 import us.dot.its.jpo.conflictmonitor.monitor.models.assessments.LaneDirectionOfTravelAssessment;
 import us.dot.its.jpo.ode.api.ConflictMonitorApiProperties;
 
@@ -51,14 +52,24 @@ public Query getQuery(Integer intersectionID, Long startTime, Long endTime, bool
         }else{
             query.limit(props.getMaximumResponseSize());
         }
+
         return query;
     }
 
+
+
     public long getQueryResultCount(Query query) {
-        query.limit(-1);
         return mongoTemplate.count(query, LaneDirectionOfTravelAssessment.class, collectionName);
     }
 
+    public long getQueryFullCount(Query query){
+        int limit = query.getLimit();
+        query.limit(-1);
+        long count = mongoTemplate.count(query, LaneDirectionOfTravelAssessment.class, collectionName);
+        query.limit(limit);
+        return count;
+    }
+
     public List<LaneDirectionOfTravelAssessment> find(Query query) {
         return mongoTemplate.find(query, LaneDirectionOfTravelAssessment.class, collectionName);
     }

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/assessments/SignalStateAssessment/StopLineStopAssessmentRepository.java

@@ -11,6 +11,8 @@ public interface StopLineStopAssessmentRepository extends DataLoader<StopLineSto
     Query getQuery(Integer intersectionID, Long startTime, Long endTime, boolean latest);
 
     long getQueryResultCount(Query query);
+
+    long getQueryFullCount(Query query);
 
     List<StopLineStopAssessment> find(Query query);  
 }

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/assessments/SignalStateAssessment/StopLineStopAssessmentRepositoryImpl.java

@@ -10,6 +10,7 @@
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Component;
+
 import us.dot.its.jpo.conflictmonitor.monitor.models.assessments.StopLineStopAssessment;
 import us.dot.its.jpo.ode.api.ConflictMonitorApiProperties;
 
@@ -52,10 +53,17 @@ public Query getQuery(Integer intersectionID, Long startTime, Long endTime, bool
     }
 
     public long getQueryResultCount(Query query) {
-        query.limit(-1);
         return mongoTemplate.count(query, StopLineStopAssessment.class, collectionName);
     }
 
+    public long getQueryFullCount(Query query){
+        int limit = query.getLimit();
+        query.limit(-1);
+        long count = mongoTemplate.count(query, StopLineStopAssessment.class, collectionName);
+        query.limit(limit);
+        return count;
+    }
+
     public List<StopLineStopAssessment> find(Query query) {
         return mongoTemplate.find(query, StopLineStopAssessment.class, collectionName);
     }

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/assessments/SignalStateEventAssessment/SignalStateEventAssessmentRepository.java

@@ -13,5 +13,7 @@ public interface SignalStateEventAssessmentRepository extends DataLoader<StopLin
 
     long getQueryResultCount(Query query);
 
+    long getQueryFullCount(Query query);
+
     List<StopLinePassageAssessment> find(Query query);
 }

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/assessments/SignalStateEventAssessment/SignalStateEventAssessmentRepositoryImpl.java

@@ -53,10 +53,17 @@ public Query getQuery(Integer intersectionID, Long startTime, Long endTime, bool
     }
 
     public long getQueryResultCount(Query query) {
-        query.limit(-1);
         return mongoTemplate.count(query, StopLinePassageAssessment.class, collectionName);
     }
 
+    public long getQueryFullCount(Query query){
+        int limit = query.getLimit();
+        query.limit(-1);
+        long count = mongoTemplate.count(query, StopLinePassageAssessment.class, collectionName);
+        query.limit(limit);
+        return count;
+    }
+
     public List<StopLinePassageAssessment> find(Query query) {
         return mongoTemplate.find(query, StopLinePassageAssessment.class, collectionName);
     }

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/events/BsmEvent/BsmEventRepository.java

@@ -12,6 +12,8 @@ public interface BsmEventRepository extends DataLoader<BsmEvent>{
     Query getQuery(Integer intersectionID, Long startTime, Long endTime, boolean latest);
 
     long getQueryResultCount(Query query);
+
+    long getQueryFullCount(Query query);
 
     List<BsmEvent> find(Query query);
 

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/events/BsmEvent/BsmEventRepositoryImpl.java

@@ -65,10 +65,17 @@ public Query getQuery(Integer intersectionID, Long startTime, Long endTime, bool
     }
 
     public long getQueryResultCount(Query query) {
-        query.limit(-1);
         return mongoTemplate.count(query, BsmEvent.class, collectionName);
     }
 
+    public long getQueryFullCount(Query query){
+        int limit = query.getLimit();
+        query.limit(-1);
+        long count = mongoTemplate.count(query, BsmEvent.class, collectionName);
+        query.limit(limit);
+        return count;
+    }
+
     public List<BsmEvent> find(Query query) {
 
         List<Map> documents = mongoTemplate.find(query, Map.class, collectionName);

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/events/ConnectionOfTravelEvent/ConnectionOfTravelEventRepository.java

@@ -13,6 +13,8 @@ public interface ConnectionOfTravelEventRepository extends DataLoader<Connection
     Query getQuery(Integer intersectionID, Long startTime, Long endTime, boolean latest);
 
     long getQueryResultCount(Query query);
+
+    long getQueryFullCount(Query query);
 
     List<ConnectionOfTravelEvent> find(Query query);
 

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/events/ConnectionOfTravelEvent/ConnectionOfTravelEventRepositoryImpl.java

@@ -9,6 +9,7 @@
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Component;
+
 import us.dot.its.jpo.conflictmonitor.monitor.models.events.ConnectionOfTravelEvent;
 import org.springframework.data.domain.Sort;
 
@@ -59,10 +60,17 @@ public Query getQuery(Integer intersectionID, Long startTime, Long endTime, bool
     }
 
     public long getQueryResultCount(Query query) {
-        query.limit(-1);
         return mongoTemplate.count(query, ConnectionOfTravelEvent.class, collectionName);
     }
 
+    public long getQueryFullCount(Query query){
+        int limit = query.getLimit();
+        query.limit(-1);
+        long count = mongoTemplate.count(query, ConnectionOfTravelEvent.class, collectionName);
+        query.limit(limit);
+        return count;
+    }
+
     public List<ConnectionOfTravelEvent> find(Query query) {
         return mongoTemplate.find(query, ConnectionOfTravelEvent.class, collectionName);
     }

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/events/IntersectionReferenceAlignmentEvent/IntersectionReferenceAlignmentEventRepository.java

@@ -12,6 +12,8 @@ public interface IntersectionReferenceAlignmentEventRepository extends DataLoade
     Query getQuery(Integer intersectionID, Long startTime, Long endTime, boolean latest);
 
     long getQueryResultCount(Query query);
+
+    long getQueryFullCount(Query query);
 
     List<IntersectionReferenceAlignmentEvent> find(Query query);
 

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/events/IntersectionReferenceAlignmentEvent/IntersectionReferenceAlignmentEventRepositoryImpl.java

@@ -12,6 +12,7 @@
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Component;
+
 import us.dot.its.jpo.conflictmonitor.monitor.models.events.IntersectionReferenceAlignmentEvent;
 import us.dot.its.jpo.ode.api.ConflictMonitorApiProperties;
 import us.dot.its.jpo.ode.api.models.IDCount;
@@ -58,11 +59,18 @@ public Query getQuery(Integer intersectionID, Long startTime, Long endTime, bool
     }
 
     public long getQueryResultCount(Query query) {
-        query.limit(-1);
         return mongoTemplate.count(query, IntersectionReferenceAlignmentEvent.class,
         collectionName);
     }
 
+    public long getQueryFullCount(Query query){
+        int limit = query.getLimit();
+        query.limit(-1);
+        long count = mongoTemplate.count(query, IntersectionReferenceAlignmentEvent.class, collectionName);
+        query.limit(limit);
+        return count;
+    }
+
     public List<IntersectionReferenceAlignmentEvent> find(Query query) {
         return mongoTemplate.find(query, IntersectionReferenceAlignmentEvent.class,
         collectionName);

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/events/LaneDirectionOfTravelEvent/LaneDirectionOfTravelEventRepository.java

@@ -13,6 +13,8 @@ public interface LaneDirectionOfTravelEventRepository extends DataLoader<LaneDir
 
     long getQueryResultCount(Query query);
 
+    long getQueryFullCount(Query query);
+
     List<LaneDirectionOfTravelEvent> find(Query query);
 
     List<IDCount> getLaneDirectionOfTravelEventsByDay(int intersectionID, Long startTime, Long endTime);

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/events/LaneDirectionOfTravelEvent/LaneDirectionOfTravelEventRepositoryImpl.java

@@ -63,10 +63,17 @@ public Query getQuery(Integer intersectionID, Long startTime, Long endTime, bool
     }
 
     public long getQueryResultCount(Query query) {
-        query.limit(-1);
         return mongoTemplate.count(query, LaneDirectionOfTravelEvent.class, collectionName);
     }
 
+    public long getQueryFullCount(Query query){
+        int limit = query.getLimit();
+        query.limit(-1);
+        long count = mongoTemplate.count(query, LaneDirectionOfTravelEvent.class, collectionName);
+        query.limit(limit);
+        return count;
+    }
+
     public List<LaneDirectionOfTravelEvent> find(Query query) {
         return mongoTemplate.find(query, LaneDirectionOfTravelEvent.class, collectionName);
     }

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/events/MapBroadcastRateEvents/MapBroadcastRateEventRepository.java

@@ -11,6 +11,8 @@ public interface MapBroadcastRateEventRepository extends DataLoader<MapBroadcast
     Query getQuery(Integer intersectionID, Long startTime, Long endTime, boolean latest);
 
     long getQueryResultCount(Query query);
+
+    long getQueryFullCount(Query query);
 
     List<MapBroadcastRateEvent> find(Query query);
 

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/events/MapBroadcastRateEvents/MapBroadcastRateEventRepositoryImpl.java

@@ -58,10 +58,17 @@ public Query getQuery(Integer intersectionID, Long startTime, Long endTime, bool
     }
 
     public long getQueryResultCount(Query query) {
-        query.limit(-1);
         return mongoTemplate.count(query, MapBroadcastRateEvent.class, collectionName);
     }
 
+    public long getQueryFullCount(Query query){
+        int limit = query.getLimit();
+        query.limit(-1);
+        long count = mongoTemplate.count(query, MapBroadcastRateEvent.class, collectionName);
+        query.limit(limit);
+        return count;
+    }
+
     public List<MapBroadcastRateEvent> find(Query query) {
         return mongoTemplate.find(query, MapBroadcastRateEvent.class, collectionName);
     }
@@ -91,6 +98,8 @@ public List<IDCount> getMapBroadcastRateEventsByDay(int intersectionID, Long sta
         return results;
     }
 
+
+
     @Override
     public void add(MapBroadcastRateEvent item) {
         mongoTemplate.save(item, collectionName);

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/events/MapMinimumDataEvent/MapMinimumDataEventRepository.java

@@ -10,6 +10,8 @@ public interface MapMinimumDataEventRepository extends DataLoader<MapMinimumData
     Query getQuery(Integer intersectionID, Long startTime, Long endTime, boolean latest);
 
     long getQueryResultCount(Query query);
+
+    long getQueryFullCount(Query query);
 
     List<MapMinimumDataEvent> find(Query query);
 

api/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/accessors/events/MapMinimumDataEvent/MapMinimumDataEventRepositoryImpl.java

@@ -58,10 +58,17 @@ public Query getQuery(Integer intersectionID, Long startTime, Long endTime, bool
     }
 
     public long getQueryResultCount(Query query) {
-        query.limit(-1);
         return mongoTemplate.count(query, MapMinimumDataEvent.class, collectionName);
     }
 
+    public long getQueryFullCount(Query query){
+        int limit = query.getLimit();
+        query.limit(-1);
+        long count = mongoTemplate.count(query, MapMinimumDataEvent.class, collectionName);
+        query.limit(limit);
+        return count;
+    }
+
     public List<MapMinimumDataEvent> find(Query query) {
         return mongoTemplate.find(query, MapMinimumDataEvent.class, collectionName);
     }