eclipse-sailing-analytics/sailing-analytics
1
0 Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-11-04 10:09:42 +00:00
Code Activity

bug6059 aftermath: fixed Igtimi persistence tests after using MultiTimeRanges

Browse Source
This commit is contained in:
Axel Uhl committed 2025-01-09 15:01:05 +01:00
1 parent 36442e93f3
commit a3d8d58a8e
1 file changed
+7 -6
Download Patch File Download Diff File Expand all files Collapse all files
java/com.sap.sailing.domain.igtimiadapter.persistence.test/src/com/sap/sailing/domain/igtimiadapter/persistence/IgtimiPersistenceTest.java
+7 -6
View File
@@ -24,6 +24,7 @@ import com.mongodb.client.ClientSession;
import com.sap.sailing.domain.igtimiadapter.DataAccessWindow; import com.sap.sailing.domain.igtimiadapter.DataAccessWindow;
import com.sap.sailing.domain.igtimiadapter.Device; import com.sap.sailing.domain.igtimiadapter.Device;
import com.sap.sse.common.Duration; import com.sap.sse.common.Duration;
import com.sap.sse.common.MultiTimeRange;
import com.sap.sse.common.TimePoint; import com.sap.sse.common.TimePoint;
import com.sap.sse.common.TimeRange; import com.sap.sse.common.TimeRange;
import com.sap.sse.common.Util; import com.sap.sse.common.Util;
@@ -104,7 +105,7 @@ public class IgtimiPersistenceTest {
logger.info("Storing message: "+msg); logger.info("Storing message: "+msg);
mongoObjectFactory.storeMessage(SERIAL_NUMBER, msg, clientSession); mongoObjectFactory.storeMessage(SERIAL_NUMBER, msg, clientSession);
final Set<DataCase> dataCases = new HashSet<>(Arrays.asList(DataCase.values())); final Set<DataCase> dataCases = new HashSet<>(Arrays.asList(DataCase.values()));
final Iterable<Msg> result = domainObjectFactory.getMessages(SERIAL_NUMBER, TimeRange.create(AWS_TIME_POINT.minus(Duration.ONE_MINUTE), AWS_TIME_POINT.plus(Duration.ONE_MINUTE)), dataCases, clientSession); final Iterable<Msg> result = domainObjectFactory.getMessages(SERIAL_NUMBER, MultiTimeRange.of(TimeRange.create(AWS_TIME_POINT.minus(Duration.ONE_MINUTE), AWS_TIME_POINT.plus(Duration.ONE_MINUTE))), dataCases, clientSession);
final Iterator<Msg> iterator = result.iterator(); final Iterator<Msg> iterator = result.iterator();
assertTrue(iterator.hasNext()); assertTrue(iterator.hasNext());
final Msg readMsg = iterator.next(); final Msg readMsg = iterator.next();
@@ -118,14 +119,14 @@ public class IgtimiPersistenceTest {
final ApparentWindSpeed aws = dataPoint.getAws(); final ApparentWindSpeed aws = dataPoint.getAws();
assertEquals(AWS, aws.getValue(), 0.000000001); assertEquals(AWS, aws.getValue(), 0.000000001);
// search with a time range *before* the actual message // search with a time range *before* the actual message
assertTrue(Util.isEmpty(domainObjectFactory.getMessages(SERIAL_NUMBER, TimeRange.create(AWS_TIME_POINT.minus(Duration.ONE_MINUTE.times(2)), AWS_TIME_POINT.minus(Duration.ONE_MINUTE)), dataCases, clientSession))); assertTrue(Util.isEmpty(domainObjectFactory.getMessages(SERIAL_NUMBER, MultiTimeRange.of(TimeRange.create(AWS_TIME_POINT.minus(Duration.ONE_MINUTE.times(2)), AWS_TIME_POINT.minus(Duration.ONE_MINUTE))), dataCases, clientSession)));
// search with a time range *after* the actual message // search with a time range *after* the actual message
assertTrue(Util.isEmpty(domainObjectFactory.getMessages(SERIAL_NUMBER, TimeRange.create(AWS_TIME_POINT.plus(Duration.ONE_MINUTE), AWS_TIME_POINT.plus(Duration.ONE_MINUTE.times(2))), dataCases, clientSession))); assertTrue(Util.isEmpty(domainObjectFactory.getMessages(SERIAL_NUMBER, MultiTimeRange.of(TimeRange.create(AWS_TIME_POINT.plus(Duration.ONE_MINUTE), AWS_TIME_POINT.plus(Duration.ONE_MINUTE.times(2)))), dataCases, clientSession)));
// search with the wrong device serial number // search with the wrong device serial number
assertTrue(Util.isEmpty(domainObjectFactory.getMessages(SERIAL_NUMBER+"-wrong", TimeRange.create(AWS_TIME_POINT.minus(Duration.ONE_MINUTE), AWS_TIME_POINT.plus(Duration.ONE_MINUTE)), dataCases, clientSession))); assertTrue(Util.isEmpty(domainObjectFactory.getMessages(SERIAL_NUMBER+"-wrong", MultiTimeRange.of(TimeRange.create(AWS_TIME_POINT.minus(Duration.ONE_MINUTE), AWS_TIME_POINT.plus(Duration.ONE_MINUTE))), dataCases, clientSession)));
// search with a time range open at the end // search with a time range open at the end
assertFalse(Util.isEmpty(domainObjectFactory.getMessages(SERIAL_NUMBER, TimeRange.create(AWS_TIME_POINT.minus(Duration.ONE_MINUTE), null), dataCases, clientSession))); assertFalse(Util.isEmpty(domainObjectFactory.getMessages(SERIAL_NUMBER, MultiTimeRange.of(TimeRange.create(AWS_TIME_POINT.minus(Duration.ONE_MINUTE), null)), dataCases, clientSession)));
// search with a time range open at the start // search with a time range open at the start
assertFalse(Util.isEmpty(domainObjectFactory.getMessages(SERIAL_NUMBER, TimeRange.create(null, AWS_TIME_POINT.plus(Duration.ONE_MINUTE)), dataCases, clientSession))); assertFalse(Util.isEmpty(domainObjectFactory.getMessages(SERIAL_NUMBER, MultiTimeRange.of(TimeRange.create(null, AWS_TIME_POINT.plus(Duration.ONE_MINUTE))), dataCases, clientSession)));
} }
} }