ammar/backend
1
0
Fork 0
mirror of https://github.com/SyncrowIOT/backend.git synced 2025-07-14 09:57:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

Compare commits

base: ammar:fix/increase-db-connections-timeout
Branches Tags
ammar:main ammar:master ammar:feat/implement-booking ammar:dev ammar:cdk-aq1 ammar:fix/integrate-cur2-with-schedule ammar:fix-update-aqi-data-on-staging ammar:SP-1736-fe-on-user-management-page-when-i-invited-a-user-as-a-space-member-his-role-appeared-as-admin-in-the-email ammar:fix/add-device-to-firebase-when-comissioning ammar:refactor/add-device-name-to-create-password-api ammar:fix/schedule-device-types ammar:task/curatin-module ammar:add-check-log-to-trace-the-map-issue ammar:temp-fix-to-check ammar:feat/delete-user-account ammar:refactor/increase-rate-limit ammar:fix-time-out-connections-db ammar:DATA-adjust-remaining-procedures ammar:test/prevent-server-block-on-rate-limit ammar:DATA-adjust-procedures ammar:fix/SP-1632-be-get-space-by-id ammar:add-queue-event-handler ammar:revert-426-SP-1778-be-fix-time-out-connections-in-the-db ammar:SP-1778-be-fix-time-out-connections-in-the-db ammar:fix/increase-db-connections-timeout ammar:SP-1780-be-configure-the-curtain-module-device ammar:fix/get-communities-with-spaces ammar:SP-1779-be-add-a-filter-on-get-devices-by-proejct-to-pass-array-of-space-ids ammar:fix/community-structure ammar:task/sort-communities-by-creation-date ammar:fix-staging-insirt-logs-data ammar:DATA-occupancy-count ammar:revamp/space-management ammar:hotfix/power-clamp-hitorical-api ammar:DATA-occupancy-hot-fix ammar:daily-aqi-score ammar:DATA-bug-fix-occupancy-duration-daily ammar:DATA-daily-occupancy-procedure
..
compare: ammar:revert-426-SP-1778-be-fix-time-out-connections-in-the-db
Branches Tags
ammar:master ammar:feat/implement-booking ammar:dev ammar:cdk-aq1 ammar:main ammar:fix/integrate-cur2-with-schedule ammar:fix-update-aqi-data-on-staging ammar:SP-1736-fe-on-user-management-page-when-i-invited-a-user-as-a-space-member-his-role-appeared-as-admin-in-the-email ammar:fix/add-device-to-firebase-when-comissioning ammar:refactor/add-device-name-to-create-password-api ammar:fix/schedule-device-types ammar:task/curatin-module ammar:add-check-log-to-trace-the-map-issue ammar:temp-fix-to-check ammar:feat/delete-user-account ammar:refactor/increase-rate-limit ammar:fix-time-out-connections-db ammar:DATA-adjust-remaining-procedures ammar:test/prevent-server-block-on-rate-limit ammar:DATA-adjust-procedures ammar:fix/SP-1632-be-get-space-by-id ammar:add-queue-event-handler ammar:revert-426-SP-1778-be-fix-time-out-connections-in-the-db ammar:SP-1778-be-fix-time-out-connections-in-the-db ammar:fix/increase-db-connections-timeout ammar:SP-1780-be-configure-the-curtain-module-device ammar:fix/get-communities-with-spaces ammar:SP-1779-be-add-a-filter-on-get-devices-by-proejct-to-pass-array-of-space-ids ammar:fix/community-structure ammar:task/sort-communities-by-creation-date ammar:fix-staging-insirt-logs-data ammar:DATA-occupancy-count ammar:revamp/space-management ammar:hotfix/power-clamp-hitorical-api ammar:DATA-occupancy-hot-fix ammar:daily-aqi-score ammar:DATA-bug-fix-occupancy-duration-daily ammar:DATA-daily-occupancy-procedure

5 Commits
fix/increa ... revert-426

Author SHA1 Message Date
faris Aljohari
c8d691b380 tern off data procedure 2025-06-23 07:02:23 -06:00
faljawhary
75d03366c2 Revert "SP-1778-be-fix-time-out-connections-in-the-db" 2025-06-23 06:58:57 -06:00
faljawhary
52cb69cc84 Merge pull request #426 from SyncrowIOT/SP-1778-be-fix-time-out-connections-in-the-db 
SP-1778-be-fix-time-out-connections-in-the-db
 2025-06-23 06:38:58 -06:00
faris Aljohari
a6053b3971 refactor: implement query runners for database operations in multiple services 2025-06-23 06:34:53 -06:00
ZaydSkaff
60d2c8330b fix: increase DB max pool size (#425) 2025-06-23 15:23:53 +03:00
1 changed files with 22 additions and 22 deletions
Expand all files Collapse all files

44
libs/common/src/firebase/devices-status/services/devices-status.service.ts
View File

@ -245,30 +245,30 @@ export class DeviceStatusFirebaseService {
}
}
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();