package com.philips.ampm.ods.deviceobservations.domain.dataaccess; import static org.junit.jupiter.api.Assertions.assertEquals; import com.philips.ampm.ods.deviceobservations.domain.dataaccess.dao.obs.DeviceMetric; import com.philips.ampm.ods.deviceobservations.domain.dataaccess.dao.obs.DeviceMetricId; import com.philips.ampm.ods.deviceobservations.domain.dataaccess.dao.obs.SleepObservationCalculationEntity; import com.philips.ampm.ods.deviceobservations.domain.dataaccess.dao.obs.SleepObservationMeasurementEntity; import com.philips.ampm.ods.deviceobservations.domain.dataaccess.repo.DeviceMetricSQLSerializer; import java.time.OffsetDateTime; import java.util.Arrays; import java.util.Collections; import java.util.List; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Test; class DeviceMetricSQLSerializerTest { private static String EXPECTED_EMPTY_RESPONSE = "{}"; @Test void serializerDeviceMetricsToSQLText_emptyList() { Assertions.assertEquals(EXPECTED_EMPTY_RESPONSE, DeviceMetricSQLSerializer.serializerDeviceMetricsToSQLText(Collections.emptyList())); } @Test void serializerDeviceMetricsToSQLText_NullList() { assertEquals(EXPECTED_EMPTY_RESPONSE, DeviceMetricSQLSerializer.serializerDeviceMetricsToSQLText(null)); } @Test void singleDeviceMetric() { String expected = "{\"(5," + "ABC," + "2021-03-23T01:03:05Z," + "2021-03-24T23:40:30Z," + "5.600000," + "849102," + "1," + "B2x.3," + "null," + "2," + "obs_id," + "MEASUREMENT)\"}"; DeviceMetric metric = getSleepMeasurement(); assertEquals(expected, DeviceMetricSQLSerializer.serializerDeviceMetricsToSQLText( Collections.singletonList(metric))); } @Test void multipleDeviceMetrics() { String expected = "{\"(5," + "ABC," + "2021-03-23T01:03:05Z," + "2021-03-24T23:40:30Z," + "5.600000," + "849102," + "1," + "B2x.3," + "null," + "2," + "obs_id," + "MEASUREMENT)\"," + "\"(345," + "XYZ," + "2021-04-01T11:58:01Z," + "2021-05-09T23:59:59Z," + "1837.234679," + "773348489," + "56733," + "BC82\\\",\\\"837," + "c\\\"`\\\"alc\\\"''\\\"Mode," + "3485758," + "obs_id," + "CALCULATION)\"}"; DeviceMetric measurement = getSleepMeasurement(); DeviceMetric calculation = getSleepCalculation(); List<DeviceMetric> metrics = Arrays.asList(measurement, calculation); assertEquals(expected, DeviceMetricSQLSerializer.serializerDeviceMetricsToSQLText(metrics)); } private SleepObservationMeasurementEntity getSleepMeasurement() { SleepObservationMeasurementEntity metric = new SleepObservationMeasurementEntity(); metric.setId(new DeviceMetricId("obs_id", OffsetDateTime.parse("2021-03-23T01:03:05Z"))); metric.setDeviceId(5L); metric.setMetricName("ABC"); metric.setDeviceSoftwareVersion("B2x.3"); metric.setDownloadId(2L); metric.setMode(null); metric.setValue(5.6D); metric.setDurationInSeconds(849102); metric.setNumberOfSamples(1); metric.setEndTime(OffsetDateTime.parse("2021-03-24T23:40:30Z")); return metric; } private SleepObservationCalculationEntity getSleepCalculation() { SleepObservationCalculationEntity metric = new SleepObservationCalculationEntity(); metric.setId(new DeviceMetricId("obs_id", OffsetDateTime.parse("2021-04-01T11:58:01Z"))); metric.setDeviceId(345L); metric.setMetricName("XYZ"); metric.setDeviceSoftwareVersion("BC82,837"); metric.setDownloadId(3485758L); metric.setMode("c`alc'Mode"); metric.setValue(1837.2346789D); metric.setEndTime(OffsetDateTime.parse("2021-05-09T23:59:59Z")); metric.setNumberOfSamples(56733L); metric.setDurationInSeconds(773348489); return metric; } }

package com.philips.ampm.ods.deviceobservations.domain.dataaccess;

import static org.junit.jupiter.api.Assertions.assertEquals;

import com.philips.ampm.ods.deviceobservations.domain.dataaccess.dao.obs.DeviceMetric;
import com.philips.ampm.ods.deviceobservations.domain.dataaccess.dao.obs.DeviceMetricId;
import com.philips.ampm.ods.deviceobservations.domain.dataaccess.dao.obs.SleepObservationCalculationEntity;
import com.philips.ampm.ods.deviceobservations.domain.dataaccess.dao.obs.SleepObservationMeasurementEntity;
import com.philips.ampm.ods.deviceobservations.domain.dataaccess.repo.DeviceMetricSQLSerializer;
import java.time.OffsetDateTime;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;