From cf19f08dcadcf51d419ab19492a453d2dca072c6 Mon Sep 17 00:00:00 2001 From: faris Aljohari <83524184+farisaljohari@users.noreply.github.com> Date: Mon, 23 Jun 2025 07:33:01 -0600 Subject: [PATCH] turn on all the updates data points --- .../services/devices-status.service.ts | 76 +++++++++---------- 1 file changed, 38 insertions(+), 38 deletions(-) diff --git a/libs/common/src/firebase/devices-status/services/devices-status.service.ts b/libs/common/src/firebase/devices-status/services/devices-status.service.ts index 477df26..4b0b0f7 100644 --- a/libs/common/src/firebase/devices-status/services/devices-status.service.ts +++ b/libs/common/src/firebase/devices-status/services/devices-status.service.ts @@ -226,49 +226,49 @@ export class DeviceStatusFirebaseService { }); await this.deviceStatusLogRepository.save(newLogs); - // if (addDeviceStatusDto.productType === ProductType.PC) { - // const energyCodes = new Set([ - // PowerClampEnergyEnum.ENERGY_CONSUMED, - // PowerClampEnergyEnum.ENERGY_CONSUMED_A, - // PowerClampEnergyEnum.ENERGY_CONSUMED_B, - // PowerClampEnergyEnum.ENERGY_CONSUMED_C, - // ]); + if (addDeviceStatusDto.productType === ProductType.PC) { + const energyCodes = new Set([ + PowerClampEnergyEnum.ENERGY_CONSUMED, + PowerClampEnergyEnum.ENERGY_CONSUMED_A, + PowerClampEnergyEnum.ENERGY_CONSUMED_B, + PowerClampEnergyEnum.ENERGY_CONSUMED_C, + ]); - // const energyStatus = addDeviceStatusDto?.log?.properties?.find((status) => - // energyCodes.has(status.code), - // ); + const energyStatus = addDeviceStatusDto?.log?.properties?.find((status) => + energyCodes.has(status.code), + ); - // if (energyStatus) { - // await this.powerClampService.updateEnergyConsumedHistoricalData( - // addDeviceStatusDto.deviceUuid, - // ); - // } - // } + if (energyStatus) { + await this.powerClampService.updateEnergyConsumedHistoricalData( + addDeviceStatusDto.deviceUuid, + ); + } + } - // if ( - // addDeviceStatusDto.productType === ProductType.CPS || - // addDeviceStatusDto.productType === ProductType.WPS - // ) { - // const occupancyCodes = new Set([PresenceSensorEnum.PRESENCE_STATE]); + if ( + addDeviceStatusDto.productType === ProductType.CPS || + addDeviceStatusDto.productType === ProductType.WPS + ) { + const occupancyCodes = new Set([PresenceSensorEnum.PRESENCE_STATE]); - // const occupancyStatus = addDeviceStatusDto?.log?.properties?.find( - // (status) => occupancyCodes.has(status.code), - // ); + const occupancyStatus = addDeviceStatusDto?.log?.properties?.find( + (status) => occupancyCodes.has(status.code), + ); - // if (occupancyStatus) { - // await this.occupancyService.updateOccupancySensorHistoricalData( - // addDeviceStatusDto.deviceUuid, - // ); - // await this.occupancyService.updateOccupancySensorHistoricalDurationData( - // addDeviceStatusDto.deviceUuid, - // ); - // } - // } - // if (addDeviceStatusDto.productType === ProductType.AQI) { - // await this.aqiDataService.updateAQISensorHistoricalData( - // addDeviceStatusDto.deviceUuid, - // ); - // } + if (occupancyStatus) { + await this.occupancyService.updateOccupancySensorHistoricalData( + addDeviceStatusDto.deviceUuid, + ); + await this.occupancyService.updateOccupancySensorHistoricalDurationData( + addDeviceStatusDto.deviceUuid, + ); + } + } + if (addDeviceStatusDto.productType === ProductType.AQI) { + await this.aqiDataService.updateAQISensorHistoricalData( + addDeviceStatusDto.deviceUuid, + ); + } // Return the updated data const snapshot: DataSnapshot = await get(dataRef); return snapshot.val();