From 16595432c3fa47db7831363f8025e9af135048d9 Mon Sep 17 00:00:00 2001 From: faris Aljohari <83524184+farisaljohari@users.noreply.github.com> Date: Sat, 10 Aug 2024 21:01:10 +0300 Subject: [PATCH] Switch device status storage to Firebase from MongoDB --- libs/common/src/helper/helper.module.ts | 4 ++-- libs/common/src/helper/services/tuya.web.socket.service.ts | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/libs/common/src/helper/helper.module.ts b/libs/common/src/helper/helper.module.ts index 75ec360..dfcc43b 100644 --- a/libs/common/src/helper/helper.module.ts +++ b/libs/common/src/helper/helper.module.ts @@ -9,7 +9,7 @@ import { OneSignalService } from './services/onesignal.service'; import { DeviceMessagesService } from './services/device.messages.service'; import { DeviceNotificationRepositoryModule } from '../modules/device-notification/device.notification.module'; import { DeviceNotificationRepository } from '../modules/device-notification/repositories'; -import { DeviceStatusMongoModule } from '../mongoose/devices-status/devices-status.module'; +import { DeviceStatusFirebaseModule } from '../firebase/devices-status/devices-status.module'; @Global() @Module({ @@ -27,7 +27,7 @@ import { DeviceStatusMongoModule } from '../mongoose/devices-status/devices-stat imports: [ SpaceRepositoryModule, DeviceNotificationRepositoryModule, - DeviceStatusMongoModule, + DeviceStatusFirebaseModule, ], }) export class HelperModule {} diff --git a/libs/common/src/helper/services/tuya.web.socket.service.ts b/libs/common/src/helper/services/tuya.web.socket.service.ts index 779cc35..5b8d89a 100644 --- a/libs/common/src/helper/services/tuya.web.socket.service.ts +++ b/libs/common/src/helper/services/tuya.web.socket.service.ts @@ -1,7 +1,7 @@ import { Injectable } from '@nestjs/common'; import TuyaWebsocket from '../../config/tuya-web-socket-config'; import { ConfigService } from '@nestjs/config'; -import { DeviceStatusMongoService } from '@app/common/mongoose/devices-status/services/devices-status.service'; +import { DeviceStatusFirebaseService } from '@app/common/firebase/devices-status/services/devices-status.service'; @Injectable() export class TuyaWebSocketService { @@ -9,7 +9,7 @@ export class TuyaWebSocketService { constructor( private readonly configService: ConfigService, - private readonly deviceStatusMongoService: DeviceStatusMongoService, + private readonly deviceStatusFirebaseService: DeviceStatusFirebaseService, ) { // Initialize the TuyaWebsocket client this.client = new TuyaWebsocket({ @@ -37,7 +37,7 @@ export class TuyaWebSocketService { this.client.message(async (ws: WebSocket, message: any) => { try { - await this.deviceStatusMongoService.addDeviceStatusToMongo({ + await this.deviceStatusFirebaseService.addDeviceStatusToFirebase({ deviceTuyaUuid: message.payload.data.bizData.devId, status: message.payload.data.bizData.properties, });