adjusted the codes completely

.eslintrc.js

@@ -21,7 +21,6 @@ module.exports = {
     '@typescript-eslint/explicit-function-return-type': 'off',
     '@typescript-eslint/explicit-module-boundary-types': 'off',
     '@typescript-eslint/no-explicit-any': 'off',
-    "@typescript-eslint/no-unused-vars": 'warn',
   },
   settings: {
     'import/resolver': {

libs/common/src/constants/controller-route.ts

@@ -524,20 +524,6 @@ export class ControllerRoute {
         'This endpoint retrieves the occupancy heat map data based on the provided parameters.';
     };
   };
-  static AQI = class {
-    public static readonly ROUTE = 'aqi';
-
-    static ACTIONS = class {
-      public static readonly GET_AQI_RANGE_DATA_SUMMARY = 'Get AQI range data';
-      public static readonly GET_AQI_RANGE_DATA_DESCRIPTION =
-        'This endpoint retrieves the AQI (Air Quality Index) range data based on the provided parameters.';
-
-      public static readonly GET_AQI_DISTRIBUTION_DATA_SUMMARY =
-        'Get AQI distribution data';
-      public static readonly GET_AQI_DISTRIBUTION_DATA_DESCRIPTION =
-        'This endpoint retrieves the AQI (Air Quality Index) distribution data based on the provided parameters.';
-    };
-  };
   static DEVICE = class {
     public static readonly ROUTE = 'devices';
 

libs/common/src/constants/pollutants.enum.ts

@@ -1,8 +0,0 @@
-export enum PollutantType {
-  AQI = 'aqi',
-  PM25 = 'pm25',
-  PM10 = 'pm10',
-  VOC = 'voc',
-  CO2 = 'co2',
-  CH2O = 'ch2o',
-}

libs/common/src/constants/product-type.enum.ts

@@ -15,10 +15,8 @@ export enum ProductType {
   WL = 'WL',
   GD = 'GD',
   CUR = 'CUR',
-  CUR_2 = 'CUR_2',
   PC = 'PC',
   FOUR_S = '4S',
   SIX_S = '6S',
   SOS = 'SOS',
-  AQI = 'AQI',
 }

libs/common/src/database/database.module.ts

@@ -1,31 +1,51 @@
 import { Module } from '@nestjs/common';
 import { ConfigModule, ConfigService } from '@nestjs/config';
 import { TypeOrmModule } from '@nestjs/typeorm';
-import { DeviceEntity } from '../modules/device/entities';
+import { SnakeNamingStrategy } from './strategies';
-import { PermissionTypeEntity } from '../modules/permission/entities';
+import { UserEntity } from '../modules/user/entities/user.entity';
-import { ProductEntity } from '../modules/product/entities';
 import { UserSessionEntity } from '../modules/session/entities/session.entity';
 import { UserOtpEntity } from '../modules/user/entities';
-import { UserEntity } from '../modules/user/entities/user.entity';
+import { ProductEntity } from '../modules/product/entities';
-import { SnakeNamingStrategy } from './strategies';
+import { DeviceEntity } from '../modules/device/entities';
+import { PermissionTypeEntity } from '../modules/permission/entities';
 
-import { TypeOrmWinstonLogger } from '@app/common/logger/services/typeorm.logger';
+import { UserSpaceEntity } from '../modules/user/entities';
-import { createLogger } from 'winston';
+import { DeviceUserPermissionEntity } from '../modules/device/entities';
-import { winstonLoggerOptions } from '../logger/services/winston.logger';
+import { RoleTypeEntity } from '../modules/role-type/entities';
-import { AqiSpaceDailyPollutantStatsEntity } from '../modules/aqi/entities';
+import { UserNotificationEntity } from '../modules/user/entities';
-import { AutomationEntity } from '../modules/automation/entities';
+import { DeviceNotificationEntity } from '../modules/device/entities';
-import { ClientEntity } from '../modules/client/entities';
+import { RegionEntity } from '../modules/region/entities';
+import { TimeZoneEntity } from '../modules/timezone/entities';
+import { VisitorPasswordEntity } from '../modules/visitor-password/entities';
 import { CommunityEntity } from '../modules/community/entities';
 import { DeviceStatusLogEntity } from '../modules/device-status-log/entities';
+import { SceneEntity, SceneIconEntity } from '../modules/scene/entities';
+import { SceneDeviceEntity } from '../modules/scene-device/entities';
+import { ProjectEntity } from '../modules/project/entities';
 import {
-  DeviceNotificationEntity,
+  SpaceModelEntity,
-  DeviceUserPermissionEntity,
+  SubspaceModelEntity,
-} from '../modules/device/entities';
+  TagModel,
+  SpaceModelProductAllocationEntity,
+  SubspaceModelProductAllocationEntity,
+} from '../modules/space-model/entities';
 import {
   InviteUserEntity,
   InviteUserSpaceEntity,
 } from '../modules/Invite-user/entities';
-import { SpaceDailyOccupancyDurationEntity } from '../modules/occupancy/entities';
+import { InviteSpaceEntity } from '../modules/space/entities/invite-space.entity';
+import { AutomationEntity } from '../modules/automation/entities';
+import { SpaceProductAllocationEntity } from '../modules/space/entities/space-product-allocation.entity';
+import { NewTagEntity } from '../modules/tag/entities/tag.entity';
+import { SpaceEntity } from '../modules/space/entities/space.entity';
+import { SpaceLinkEntity } from '../modules/space/entities/space-link.entity';
+import { SubspaceProductAllocationEntity } from '../modules/space/entities/subspace/subspace-product-allocation.entity';
+import { SubspaceEntity } from '../modules/space/entities/subspace/subspace.entity';
+import { TagEntity } from '../modules/space/entities/tag.entity';
+import { ClientEntity } from '../modules/client/entities';
+import { TypeOrmWinstonLogger } from '@app/common/logger/services/typeorm.logger';
+import { createLogger } from 'winston';
+import { winstonLoggerOptions } from '../logger/services/winston.logger';
 import {
   PowerClampDailyEntity,
   PowerClampHourlyEntity,
@@ -35,29 +55,6 @@ import {
   PresenceSensorDailyDeviceEntity,
   PresenceSensorDailySpaceEntity,
 } from '../modules/presence-sensor/entities';
-import { ProjectEntity } from '../modules/project/entities';
-import { RegionEntity } from '../modules/region/entities';
-import { RoleTypeEntity } from '../modules/role-type/entities';
-import { SceneDeviceEntity } from '../modules/scene-device/entities';
-import { SceneEntity, SceneIconEntity } from '../modules/scene/entities';
-import {
-  SpaceModelEntity,
-  SpaceModelProductAllocationEntity,
-  SubspaceModelEntity,
-  SubspaceModelProductAllocationEntity,
-} from '../modules/space-model/entities';
-import { InviteSpaceEntity } from '../modules/space/entities/invite-space.entity';
-import { SpaceProductAllocationEntity } from '../modules/space/entities/space-product-allocation.entity';
-import { SpaceEntity } from '../modules/space/entities/space.entity';
-import { SubspaceProductAllocationEntity } from '../modules/space/entities/subspace/subspace-product-allocation.entity';
-import { SubspaceEntity } from '../modules/space/entities/subspace/subspace.entity';
-import { NewTagEntity } from '../modules/tag/entities/tag.entity';
-import { TimeZoneEntity } from '../modules/timezone/entities';
-import {
-  UserNotificationEntity,
-  UserSpaceEntity,
-} from '../modules/user/entities';
-import { VisitorPasswordEntity } from '../modules/visitor-password/entities';
 @Module({
   imports: [
     TypeOrmModule.forRootAsync({
@@ -86,7 +83,9 @@ import { VisitorPasswordEntity } from '../modules/visitor-password/entities';
             PermissionTypeEntity,
             CommunityEntity,
             SpaceEntity,
+            SpaceLinkEntity,
             SubspaceEntity,
+            TagEntity,
             UserSpaceEntity,
             DeviceUserPermissionEntity,
             RoleTypeEntity,
@@ -101,6 +100,7 @@ import { VisitorPasswordEntity } from '../modules/visitor-password/entities';
             SceneDeviceEntity,
             SpaceModelEntity,
             SubspaceModelEntity,
+            TagModel,
             InviteUserEntity,
             InviteUserSpaceEntity,
             InviteSpaceEntity,
@@ -115,8 +115,6 @@ import { VisitorPasswordEntity } from '../modules/visitor-password/entities';
             PowerClampMonthlyEntity,
             PresenceSensorDailyDeviceEntity,
             PresenceSensorDailySpaceEntity,
-            AqiSpaceDailyPollutantStatsEntity,
-            SpaceDailyOccupancyDurationEntity,
           ],
           namingStrategy: new SnakeNamingStrategy(),
           synchronize: Boolean(JSON.parse(configService.get('DB_SYNC'))),
@@ -125,8 +123,8 @@ import { VisitorPasswordEntity } from '../modules/visitor-password/entities';
           logger: typeOrmLogger,
           extra: {
             charset: 'utf8mb4',
-            max: 100, // set pool max size
+            max: 20, // set pool max size
-            idleTimeoutMillis: 3000, // close idle clients after 5 second
+            idleTimeoutMillis: 5000, // close idle clients after 5 second
             connectionTimeoutMillis: 12_000, // return an error after 11 second if connection could not be established
             maxUses: 7500, // close (and replace) a connection after it has been used 7500 times (see below for discussion)
           },

libs/common/src/dto/pagination.request.dto.ts

@@ -1,9 +1,10 @@
-import { ApiProperty } from '@nestjs/swagger';
+import { IsBoolean, IsDate, IsOptional } from 'class-validator';
-import { Transform } from 'class-transformer';
-import { IsBoolean, IsOptional } from 'class-validator';
-import { BooleanValues } from '../constants/boolean-values.enum';
 import { IsPageRequestParam } from '../validators/is-page-request-param.validator';
+import { ApiProperty } from '@nestjs/swagger';
 import { IsSizeRequestParam } from '../validators/is-size-request-param.validator';
+import { Transform } from 'class-transformer';
+import { parseToDate } from '../util/parseToDate';
+import { BooleanValues } from '../constants/boolean-values.enum';
 
 export class PaginationRequestGetListDto {
   @ApiProperty({
@@ -18,7 +19,6 @@ export class PaginationRequestGetListDto {
     return value.obj.includeSpaces === BooleanValues.TRUE;
   })
   public includeSpaces?: boolean = false;
-
   @IsOptional()
   @IsPageRequestParam({
     message: 'Page must be bigger than 0',
@@ -40,4 +40,40 @@ export class PaginationRequestGetListDto {
     description: 'Size request',
   })
   size?: number;
+
+  @IsOptional()
+  @ApiProperty({
+    name: 'name',
+    required: false,
+    description: 'Name to be filtered',
+  })
+  name?: string;
+
+  @ApiProperty({
+    name: 'from',
+    required: false,
+    type: Number,
+    description: `Start time in UNIX timestamp format to filter`,
+    example: 1674172800000,
+  })
+  @IsOptional()
+  @Transform(({ value }) => parseToDate(value))
+  @IsDate({
+    message: `From must be in UNIX timestamp format in order to parse to Date instance`,
+  })
+  from?: Date;
+
+  @ApiProperty({
+    name: 'to',
+    required: false,
+    type: Number,
+    description: `End time in UNIX timestamp format to filter`,
+    example: 1674259200000,
+  })
+  @IsOptional()
+  @Transform(({ value }) => parseToDate(value))
+  @IsDate({
+    message: `To must be in UNIX timestamp format in order to parse to Date instance`,
+  })
+  to?: Date;
 }

libs/common/src/firebase/devices-status/devices-status.module.ts

@@ -3,12 +3,26 @@ import { DeviceStatusFirebaseController } from './controllers/devices-status.con
 import { DeviceStatusFirebaseService } from './services/devices-status.service';
 import { DeviceRepository } from '@app/common/modules/device/repositories';
 import { DeviceStatusLogRepository } from '@app/common/modules/device-status-log/repositories/device-status.repository';
+import { PowerClampService } from '@app/common/helper/services/power.clamp.service';
+import {
+  PowerClampHourlyRepository,
+  PowerClampDailyRepository,
+  PowerClampMonthlyRepository,
+} from '@app/common/modules/power-clamp/repositories';
+import { SqlLoaderService } from '@app/common/helper/services/sql-loader.service';
+import { OccupancyService } from '@app/common/helper/services/occupancy.service';
 
 @Module({
   providers: [
     DeviceStatusFirebaseService,
     DeviceRepository,
     DeviceStatusLogRepository,
+    PowerClampService,
+    PowerClampHourlyRepository,
+    PowerClampDailyRepository,
+    PowerClampMonthlyRepository,
+    SqlLoaderService,
+    OccupancyService,
   ],
   controllers: [DeviceStatusFirebaseController],
   exports: [DeviceStatusFirebaseService, DeviceStatusLogRepository],

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

@@ -18,6 +18,11 @@ import {
   runTransaction,
 } from 'firebase/database';
 import { DeviceStatusLogRepository } from '@app/common/modules/device-status-log/repositories';
+import { ProductType } from '@app/common/constants/product-type.enum';
+import { PowerClampService } from '@app/common/helper/services/power.clamp.service';
+import { PowerClampEnergyEnum } from '@app/common/constants/power.clamp.enargy.enum';
+import { PresenceSensorEnum } from '@app/common/constants/presence.sensor.enum';
+import { OccupancyService } from '@app/common/helper/services/occupancy.service';
 @Injectable()
 export class DeviceStatusFirebaseService {
   private tuya: TuyaContext;
@@ -25,6 +30,8 @@ export class DeviceStatusFirebaseService {
   constructor(
     private readonly configService: ConfigService,
     private readonly deviceRepository: DeviceRepository,
+    private readonly powerClampService: PowerClampService,
+    private readonly occupancyService: OccupancyService,
     private deviceStatusLogRepository: DeviceStatusLogRepository,
   ) {
     const accessKey = this.configService.get<string>('auth-config.ACCESS_KEY');
@@ -67,94 +74,25 @@ export class DeviceStatusFirebaseService {
       );
     }
   }
-  async addBatchDeviceStatusToOurDb(
-    batch: {
-      deviceTuyaUuid: string;
-      status: any;
-      log: any;
-      device: any;
-    }[],
-  ): Promise<void> {
-    const allLogs = [];
-
-    console.log(`🔁 Preparing logs from batch of ${batch.length} items...`);
-
-    for (const item of batch) {
-      const device = item.device;
-      if (!device?.uuid) {
-        console.log(`⛔ Skipped unknown device: ${item.deviceTuyaUuid}`);
-        continue;
-      }
-
-      const logs = item.log.properties.map((property) =>
-        this.deviceStatusLogRepository.create({
-          deviceId: device.uuid,
-          deviceTuyaId: item.deviceTuyaUuid,
-          productId: item.log.productId,
-          log: item.log,
-          code: property.code,
-          value: property.value,
-          eventId: item.log.dataId,
-          eventTime: new Date(property.time).toISOString(),
-        }),
-      );
-      allLogs.push(...logs);
-    }
-
-    console.log(`📝 Total logs to insert: ${allLogs.length}`);
-
-    const insertLogsPromise = (async () => {
-      const chunkSize = 300;
-      let insertedCount = 0;
-
-      for (let i = 0; i < allLogs.length; i += chunkSize) {
-        const chunk = allLogs.slice(i, i + chunkSize);
-        try {
-          const result = await this.deviceStatusLogRepository
-            .createQueryBuilder()
-            .insert()
-            .into('device-status-log') // or use DeviceStatusLogEntity
-            .values(chunk)
-            .orIgnore() // skip duplicates
-            .execute();
-
-          insertedCount += result.identifiers.length;
-          console.log(
-            `✅ Inserted ${result.identifiers.length} / ${chunk.length} logs (chunk)`,
-          );
-        } catch (error) {
-          console.error('❌ Insert error (skipped chunk):', error.message);
-        }
-      }
-
-      console.log(
-        `✅ Total logs inserted: ${insertedCount} / ${allLogs.length}`,
-      );
-    })();
-
-    await insertLogsPromise;
-  }
-
   async addDeviceStatusToFirebase(
-    addDeviceStatusDto: AddDeviceStatusDto & { device?: any },
+    addDeviceStatusDto: AddDeviceStatusDto,
   ): Promise<AddDeviceStatusDto | null> {
     try {
-      let device = addDeviceStatusDto.device;
+      const device = await this.getDeviceByDeviceTuyaUuid(
-      if (!device) {
+        addDeviceStatusDto.deviceTuyaUuid,
-        device = await this.getDeviceByDeviceTuyaUuid(
+      );
-          addDeviceStatusDto.deviceTuyaUuid,
+
-        );
-      }
       if (device?.uuid) {
         return await this.createDeviceStatusFirebase({
           deviceUuid: device.uuid,
           ...addDeviceStatusDto,
-          productType: device.productDevice?.prodType,
+          productType: device.productDevice.prodType,
         });
       }
       // Return null if device not found or no UUID
       return null;
     } catch (error) {
+      // Handle the error silently, perhaps log it internally or ignore it
       return null;
     }
   }
@@ -168,15 +106,6 @@ export class DeviceStatusFirebaseService {
       relations: ['productDevice'],
     });
   }
-  async getAllDevices() {
-    return await this.deviceRepository.find({
-      where: {
-        isActive: true,
-      },
-      relations: ['productDevice'],
-    });
-  }
-
   async getDevicesInstructionStatus(deviceUuid: string) {
     try {
       const deviceDetails = await this.getDeviceByDeviceUuid(deviceUuid);
@@ -280,6 +209,60 @@ export class DeviceStatusFirebaseService {
       return existingData;
     });
 
+    // Save logs to your repository
+    const newLogs = addDeviceStatusDto.log.properties.map((property) => {
+      return this.deviceStatusLogRepository.create({
+        deviceId: addDeviceStatusDto.deviceUuid,
+        deviceTuyaId: addDeviceStatusDto.deviceTuyaUuid,
+        productId: addDeviceStatusDto.log.productId,
+        log: addDeviceStatusDto.log,
+        code: property.code,
+        value: property.value,
+        eventId: addDeviceStatusDto.log.dataId,
+        eventTime: new Date(property.time).toISOString(),
+      });
+    });
+    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,
+      ]);
+
+      const energyStatus = addDeviceStatusDto?.log?.properties?.find((status) =>
+        energyCodes.has(status.code),
+      );
+
+      if (energyStatus) {
+        await this.powerClampService.updateEnergyConsumedHistoricalData(
+          addDeviceStatusDto.deviceUuid,
+        );
+      }
+    }
+
+    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),
+      );
+
+      if (occupancyStatus) {
+        await this.occupancyService.updateOccupancySensorHistoricalData(
+          addDeviceStatusDto.deviceUuid,
+        );
+        await this.occupancyService.updateOccupancySensorHistoricalDurationData(
+          addDeviceStatusDto.deviceUuid,
+        );
+      }
+    }
+
     // Return the updated data
     const snapshot: DataSnapshot = await get(dataRef);
     return snapshot.val();

libs/common/src/helper/helper.module.ts

@@ -8,10 +8,7 @@ import { TuyaWebSocketService } from './services/tuya.web.socket.service';
 import { OneSignalService } from './services/onesignal.service';
 import { DeviceMessagesService } from './services/device.messages.service';
 import { DeviceRepositoryModule } from '../modules/device/device.repository.module';
-import {
+import { DeviceNotificationRepository } from '../modules/device/repositories';
-  DeviceNotificationRepository,
-  DeviceRepository,
-} from '../modules/device/repositories';
 import { DeviceStatusFirebaseModule } from '../firebase/devices-status/devices-status.module';
 import { CommunityPermissionService } from './services/community.permission.service';
 import { CommunityRepository } from '../modules/community/repositories';
@@ -30,7 +27,6 @@ import { SosHandlerService } from './services/sos.handler.service';
     DeviceNotificationRepository,
     CommunityRepository,
     SosHandlerService,
-    DeviceRepository,
   ],
   exports: [
     HelperHashService,

libs/common/src/helper/services/aqi.data.service.ts

@@ -1,66 +0,0 @@
-import { Injectable } from '@nestjs/common';
-import { DataSource } from 'typeorm';
-import { SQL_PROCEDURES_PATH } from '@app/common/constants/sql-query-path';
-import { SqlLoaderService } from './sql-loader.service';
-
-@Injectable()
-export class AqiDataService {
-  constructor(
-    private readonly sqlLoader: SqlLoaderService,
-    private readonly dataSource: DataSource,
-  ) {}
-
-  async updateAQISensorHistoricalData(): Promise<void> {
-    try {
-      const { dateStr } = this.getFormattedDates();
-
-      // Execute all procedures in parallel
-      await Promise.all([
-        this.executeProcedureWithRetry(
-          'proceduce_update_daily_space_aqi',
-          [dateStr],
-          'fact_daily_space_aqi',
-        ),
-      ]);
-    } catch (err) {
-      console.error('Failed to update AQI sensor historical data:', err);
-      throw err;
-    }
-  }
-  private getFormattedDates(): { dateStr: string } {
-    const now = new Date();
-    return {
-      dateStr: now.toLocaleDateString('en-CA'), // YYYY-MM-DD
-    };
-  }
-  private async executeProcedureWithRetry(
-    procedureFileName: string,
-    params: (string | number | null)[],
-    folderName: string,
-    retries = 3,
-  ): Promise<void> {
-    try {
-      const query = this.loadQuery(folderName, procedureFileName);
-      await this.dataSource.query(query, params);
-      console.log(`Procedure ${procedureFileName} executed successfully.`);
-    } catch (err) {
-      if (retries > 0) {
-        const delayMs = 1000 * (4 - retries); // Exponential backoff
-        console.warn(`Retrying ${procedureFileName} (${retries} retries left)`);
-        await new Promise((resolve) => setTimeout(resolve, delayMs));
-        return this.executeProcedureWithRetry(
-          procedureFileName,
-          params,
-          folderName,
-          retries - 1,
-        );
-      }
-      console.error(`Failed to execute ${procedureFileName}:`, err);
-      throw err;
-    }
-  }
-
-  private loadQuery(folderName: string, fileName: string): string {
-    return this.sqlLoader.loadQuery(folderName, fileName, SQL_PROCEDURES_PATH);
-  }
-}

libs/common/src/helper/services/occupancy.service.ts

@@ -1,69 +1,66 @@
+import { DeviceRepository } from '@app/common/modules/device/repositories';
 import { Injectable } from '@nestjs/common';
+import { SqlLoaderService } from './sql-loader.service';
 import { DataSource } from 'typeorm';
 import { SQL_PROCEDURES_PATH } from '@app/common/constants/sql-query-path';
-import { SqlLoaderService } from './sql-loader.service';
 
 @Injectable()
 export class OccupancyService {
   constructor(
     private readonly sqlLoader: SqlLoaderService,
     private readonly dataSource: DataSource,
+    private readonly deviceRepository: DeviceRepository,
   ) {}
-
+  async updateOccupancySensorHistoricalDurationData(
-  async updateOccupancyDataProcedures(): Promise<void> {
+    deviceUuid: string,
-    try {
-      const { dateStr } = this.getFormattedDates();
-
-      // Execute all procedures in parallel
-      await Promise.all([
-        this.executeProcedureWithRetry(
-          'procedure_update_fact_space_occupancy',
-          [dateStr],
-          'fact_space_occupancy_count',
-        ),
-        this.executeProcedureWithRetry(
-          'procedure_update_daily_space_occupancy_duration',
-          [dateStr],
-          'fact_daily_space_occupancy_duration',
-        ),
-      ]);
-    } catch (err) {
-      console.error('Failed to update occupancy data:', err);
-      throw err;
-    }
-  }
-  private getFormattedDates(): { dateStr: string } {
-    const now = new Date();
-    return {
-      dateStr: now.toLocaleDateString('en-CA'), // YYYY-MM-DD
-    };
-  }
-  private async executeProcedureWithRetry(
-    procedureFileName: string,
-    params: (string | number | null)[],
-    folderName: string,
-    retries = 3,
   ): Promise<void> {
     try {
-      const query = this.loadQuery(folderName, procedureFileName);
+      const now = new Date();
-      await this.dataSource.query(query, params);
+      const dateStr = now.toLocaleDateString('en-CA'); // YYYY-MM-DD
-      console.log(`Procedure ${procedureFileName} executed successfully.`);
+      const device = await this.deviceRepository.findOne({
+        where: { uuid: deviceUuid },
+        relations: ['spaceDevice'],
+      });
+
+      await this.executeProcedure(
+        'fact_daily_space_occupancy_duration',
+        'procedure_update_daily_space_occupancy_duration',
+        [dateStr, device.spaceDevice?.uuid],
+      );
     } catch (err) {
-      if (retries > 0) {
+      console.error('Failed to insert or update occupancy duration data:', err);
-        const delayMs = 1000 * (4 - retries); // Exponential backoff
-        console.warn(`Retrying ${procedureFileName} (${retries} retries left)`);
-        await new Promise((resolve) => setTimeout(resolve, delayMs));
-        return this.executeProcedureWithRetry(
-          procedureFileName,
-          params,
-          folderName,
-          retries - 1,
-        );
-      }
-      console.error(`Failed to execute ${procedureFileName}:`, err);
       throw err;
     }
   }
+  async updateOccupancySensorHistoricalData(deviceUuid: string): Promise<void> {
+    try {
+      const now = new Date();
+      const dateStr = now.toLocaleDateString('en-CA'); // YYYY-MM-DD
+      const device = await this.deviceRepository.findOne({
+        where: { uuid: deviceUuid },
+        relations: ['spaceDevice'],
+      });
+
+      await this.executeProcedure(
+        'fact_space_occupancy_count',
+        'procedure_update_fact_space_occupancy',
+        [dateStr, device.spaceDevice?.uuid],
+      );
+    } catch (err) {
+      console.error('Failed to insert or update occupancy data:', err);
+      throw err;
+    }
+  }
+
+  private async executeProcedure(
+    procedureFolderName: string,
+    procedureFileName: string,
+    params: (string | number | null)[],
+  ): Promise<void> {
+    const query = this.loadQuery(procedureFolderName, procedureFileName);
+    await this.dataSource.query(query, params);
+    console.log(`Procedure ${procedureFileName} executed successfully.`);
+  }
 
   private loadQuery(folderName: string, fileName: string): string {
     return this.sqlLoader.loadQuery(folderName, fileName, SQL_PROCEDURES_PATH);

libs/common/src/helper/services/power.clamp.service.ts

@@ -1,7 +1,7 @@
 import { Injectable } from '@nestjs/common';
+import { SqlLoaderService } from './sql-loader.service';
 import { DataSource } from 'typeorm';
 import { SQL_PROCEDURES_PATH } from '@app/common/constants/sql-query-path';
-import { SqlLoaderService } from './sql-loader.service';
 
 @Injectable()
 export class PowerClampService {
@@ -10,74 +10,50 @@ export class PowerClampService {
     private readonly dataSource: DataSource,
   ) {}
 
-  async updateEnergyConsumedHistoricalData(): Promise<void> {
+  async updateEnergyConsumedHistoricalData(deviceUuid: string): Promise<void> {
     try {
-      const { dateStr, monthYear } = this.getFormattedDates();
+      const now = new Date();
-
+      const dateStr = now.toLocaleDateString('en-CA'); // YYYY-MM-DD
-      // Execute all procedures in parallel
+      const hour = now.getHours();
-      await Promise.all([
+      const monthYear = now
-        this.executeProcedureWithRetry(
-          'fact_hourly_device_energy_consumed_procedure',
-          [dateStr],
-          'fact_device_energy_consumed',
-        ),
-        this.executeProcedureWithRetry(
-          'fact_daily_device_energy_consumed_procedure',
-          [dateStr],
-          'fact_device_energy_consumed',
-        ),
-        this.executeProcedureWithRetry(
-          'fact_monthly_device_energy_consumed_procedure',
-          [monthYear],
-          'fact_device_energy_consumed',
-        ),
-      ]);
-    } catch (err) {
-      console.error('Failed to update energy consumption data:', err);
-      throw err;
-    }
-  }
-
-  private getFormattedDates(): { dateStr: string; monthYear: string } {
-    const now = new Date();
-    return {
-      dateStr: now.toLocaleDateString('en-CA'), // YYYY-MM-DD
-      monthYear: now
         .toLocaleDateString('en-US', {
           month: '2-digit',
           year: 'numeric',
         })
-        .replace('/', '-'), // MM-YYYY
+        .replace('/', '-'); // MM-YYYY
-    };
-  }
 
-  private async executeProcedureWithRetry(
+      await this.executeProcedure(
-    procedureFileName: string,
+        'fact_hourly_device_energy_consumed_procedure',
-    params: (string | number | null)[],
+        [deviceUuid, dateStr, hour],
-    folderName: string,
+      );
-    retries = 3,
+
-  ): Promise<void> {
+      await this.executeProcedure(
-    try {
+        'fact_daily_device_energy_consumed_procedure',
-      const query = this.loadQuery(folderName, procedureFileName);
+        [deviceUuid, dateStr],
-      await this.dataSource.query(query, params);
+      );
-      console.log(`Procedure ${procedureFileName} executed successfully.`);
+
+      await this.executeProcedure(
+        'fact_monthly_device_energy_consumed_procedure',
+        [deviceUuid, monthYear],
+      );
     } catch (err) {
-      if (retries > 0) {
+      console.error('Failed to insert or update energy data:', err);
-        const delayMs = 1000 * (4 - retries); // Exponential backoff
-        console.warn(`Retrying ${procedureFileName} (${retries} retries left)`);
-        await new Promise((resolve) => setTimeout(resolve, delayMs));
-        return this.executeProcedureWithRetry(
-          procedureFileName,
-          params,
-          folderName,
-          retries - 1,
-        );
-      }
-      console.error(`Failed to execute ${procedureFileName}:`, err);
       throw err;
     }
   }
 
+  private async executeProcedure(
+    procedureFileName: string,
+    params: (string | number | null)[],
+  ): Promise<void> {
+    const query = this.loadQuery(
+      'fact_device_energy_consumed',
+      procedureFileName,
+    );
+    await this.dataSource.query(query, params);
+    console.log(`Procedure ${procedureFileName} executed successfully.`);
+  }
+
   private loadQuery(folderName: string, fileName: string): string {
     return this.sqlLoader.loadQuery(folderName, fileName, SQL_PROCEDURES_PATH);
   }

libs/common/src/helper/services/sos.handler.service.ts

@@ -16,46 +16,21 @@ export class SosHandlerService {
     );
   }
 
-  async handleSosEventFirebase(device: any, logData: any): Promise<void> {
+  async handleSosEvent(devId: string, logData: any): Promise<void> {
-    const sosTrueStatus = [{ code: 'sos', value: true }];
-    const sosFalseStatus = [{ code: 'sos', value: false }];
-
     try {
-      // ✅ Send true status
       await this.deviceStatusFirebaseService.addDeviceStatusToFirebase({
-        deviceTuyaUuid: device.deviceTuyaUuid,
+        deviceTuyaUuid: devId,
-        status: sosTrueStatus,
+        status: [{ code: 'sos', value: true }],
         log: logData,
-        device,
       });
 
-      await this.deviceStatusFirebaseService.addBatchDeviceStatusToOurDb([
-        {
-          deviceTuyaUuid: device.deviceTuyaUuid,
-          status: sosTrueStatus,
-          log: logData,
-          device,
-        },
-      ]);
-
-      // ✅ Schedule false status
       setTimeout(async () => {
         try {
           await this.deviceStatusFirebaseService.addDeviceStatusToFirebase({
-            deviceTuyaUuid: device.deviceTuyaUuid,
+            deviceTuyaUuid: devId,
-            status: sosFalseStatus,
+            status: [{ code: 'sos', value: false }],
             log: logData,
-            device,
           });
-
-          await this.deviceStatusFirebaseService.addBatchDeviceStatusToOurDb([
-            {
-              deviceTuyaUuid: device.deviceTuyaUuid,
-              status: sosFalseStatus,
-              log: logData,
-              device,
-            },
-          ]);
         } catch (err) {
           this.logger.error('Failed to send SOS false value', err);
         }

libs/common/src/helper/services/tuya.web.socket.service.ts

@@ -1,24 +1,13 @@
-import { Injectable, OnModuleInit } from '@nestjs/common';
+import { Injectable } from '@nestjs/common';
 import TuyaWebsocket from '../../config/tuya-web-socket-config';
 import { ConfigService } from '@nestjs/config';
 import { DeviceStatusFirebaseService } from '@app/common/firebase/devices-status/services/devices-status.service';
 import { SosHandlerService } from './sos.handler.service';
-import * as NodeCache from 'node-cache';
 
 @Injectable()
-export class TuyaWebSocketService implements OnModuleInit {
+export class TuyaWebSocketService {
   private client: any;
   private readonly isDevEnv: boolean;
-  private readonly deviceCache = new NodeCache({ stdTTL: 7200 }); // TTL = 2 hour
-
-  private messageQueue: {
-    devId: string;
-    status: any;
-    logData: any;
-    device: any;
-  }[] = [];
-
-  private isProcessing = false;
 
   constructor(
     private readonly configService: ConfigService,
@@ -37,36 +26,16 @@ export class TuyaWebSocketService implements OnModuleInit {
     });
 
     if (this.configService.get<string>('tuya-config.TRUN_ON_TUYA_SOCKET')) {
+      // Set up event handlers
       this.setupEventHandlers();
+
+      // Start receiving messages
       this.client.start();
     }
-
-    // Run the queue processor every 15 seconds
-    setInterval(() => this.processQueue(), 15000);
-
-    // Refresh the cache every 1 hour
-    setInterval(() => this.initializeDeviceCache(), 30 * 60 * 1000); // 30 minutes
-  }
-
-  async onModuleInit() {
-    await this.initializeDeviceCache();
-  }
-
-  private async initializeDeviceCache() {
-    try {
-      const allDevices = await this.deviceStatusFirebaseService.getAllDevices();
-      allDevices.forEach((device) => {
-        if (device.deviceTuyaUuid) {
-          this.deviceCache.set(device.deviceTuyaUuid, device);
-        }
-      });
-      console.log(`✅ Refreshed cache with ${allDevices.length} devices.`);
-    } catch (error) {
-      console.error('❌ Failed to initialize device cache:', error);
-    }
   }
 
   private setupEventHandlers() {
+    // Event handlers
     this.client.open(() => {
       console.log('open');
     });
@@ -74,38 +43,23 @@ export class TuyaWebSocketService implements OnModuleInit {
     this.client.message(async (ws: WebSocket, message: any) => {
       try {
         const { devId, status, logData } = this.extractMessageData(message);
-        if (!Array.isArray(logData?.properties)) {
-          this.client.ackMessage(message.messageId);
-          return;
-        }
-
-        const device = this.deviceCache.get(devId);
-        if (!device) {
-          // console.log(⛔ Unknown device: ${devId}, message ignored.);
-          this.client.ackMessage(message.messageId);
-          return;
-        }
 
         if (this.sosHandlerService.isSosTriggered(status)) {
-          await this.sosHandlerService.handleSosEventFirebase(devId, logData);
+          await this.sosHandlerService.handleSosEvent(devId, logData);
         } else {
           await this.deviceStatusFirebaseService.addDeviceStatusToFirebase({
             deviceTuyaUuid: devId,
-            status,
+            status: status,
             log: logData,
-            device,
           });
         }
 
-        // Push to internal queue
-        this.messageQueue.push({ devId, status, logData, device });
-
-        // Acknowledge the message
         this.client.ackMessage(message.messageId);
       } catch (error) {
-        console.error('❌ Error receiving message:', error);
+        console.error('Error processing message:', error);
       }
     });
+
     this.client.reconnect(() => {
       console.log('reconnect');
     });
@@ -126,37 +80,6 @@ export class TuyaWebSocketService implements OnModuleInit {
       console.error('WebSocket error:', error);
     });
   }
-  private async processQueue() {
-    if (this.isProcessing) {
-      console.log('⏳ Skipping: still processing previous batch');
-      return;
-    }
-
-    if (this.messageQueue.length === 0) return;
-
-    this.isProcessing = true;
-    const batch = [...this.messageQueue];
-    this.messageQueue = [];
-
-    console.log(`🔁 Processing batch of size: ${batch.length}`);
-
-    try {
-      await this.deviceStatusFirebaseService.addBatchDeviceStatusToOurDb(
-        batch.map((item) => ({
-          deviceTuyaUuid: item.devId,
-          status: item.status,
-          log: item.logData,
-          device: item.device,
-        })),
-      );
-    } catch (error) {
-      console.error('❌ Error processing batch:', error);
-      this.messageQueue.unshift(...batch); // retry
-    } finally {
-      this.isProcessing = false;
-    }
-  }
-
   private extractMessageData(message: any): {
     devId: string;
     status: any;

libs/common/src/modules/aqi/aqi.repository.module.ts

@@ -1,11 +0,0 @@
-import { Module } from '@nestjs/common';
-import { TypeOrmModule } from '@nestjs/typeorm';
-import { AqiSpaceDailyPollutantStatsEntity } from './entities/aqi.entity';
-
-@Module({
-  providers: [],
-  exports: [],
-  controllers: [],
-  imports: [TypeOrmModule.forFeature([AqiSpaceDailyPollutantStatsEntity])],
-})
-export class AqiRepositoryModule {}

libs/common/src/modules/aqi/dtos/aqi.dto.ts

@@ -1,82 +0,0 @@
-import { IsNotEmpty, IsNumber, IsString } from 'class-validator';
-
-export class AqiSpaceDailyPollutantStatsDto {
-  @IsString()
-  @IsNotEmpty()
-  public uuid: string;
-
-  @IsNotEmpty()
-  @IsString()
-  spaceUuid: string;
-
-  @IsNotEmpty()
-  @IsString()
-  eventDay: string;
-
-  @IsNotEmpty()
-  @IsNumber()
-  eventHour: number;
-
-  @IsNumber()
-  pm1Min: number;
-
-  @IsNumber()
-  pm1Avg: number;
-
-  @IsNumber()
-  pm1Max: number;
-
-  @IsNumber()
-  pm10Min: number;
-
-  @IsNumber()
-  pm10Avg: number;
-
-  @IsNumber()
-  pm10Max: number;
-
-  @IsNumber()
-  pm25Min: number;
-
-  @IsNumber()
-  pm25Avg: number;
-
-  @IsNumber()
-  pm25Max: number;
-
-  @IsNumber()
-  ch2oMin: number;
-
-  @IsNumber()
-  ch2oAvg: number;
-
-  @IsNumber()
-  ch2oMax: number;
-
-  @IsNumber()
-  vocMin: number;
-
-  @IsNumber()
-  vocAvg: number;
-
-  @IsNumber()
-  vocMax: number;
-
-  @IsNumber()
-  co2Min: number;
-
-  @IsNumber()
-  co2Avg: number;
-
-  @IsNumber()
-  co2Max: number;
-
-  @IsNumber()
-  aqiMin: number;
-
-  @IsNumber()
-  aqiAvg: number;
-
-  @IsNumber()
-  aqiMax: number;
-}

libs/common/src/modules/aqi/dtos/index.ts

@@ -1 +0,0 @@
-export * from './aqi.dto';

libs/common/src/modules/aqi/entities/aqi.entity.ts

@@ -1,184 +0,0 @@
-import { Column, Entity, ManyToOne, Unique } from 'typeorm';
-import { AbstractEntity } from '../../abstract/entities/abstract.entity';
-import { SpaceEntity } from '../../space/entities/space.entity';
-import { AqiSpaceDailyPollutantStatsDto } from '../dtos';
-
-@Entity({ name: 'space-daily-pollutant-stats' })
-@Unique(['spaceUuid', 'eventDate'])
-export class AqiSpaceDailyPollutantStatsEntity extends AbstractEntity<AqiSpaceDailyPollutantStatsDto> {
-  @Column({ nullable: false })
-  public spaceUuid: string;
-
-  @ManyToOne(() => SpaceEntity, (space) => space.aqiSensorDaily)
-  space: SpaceEntity;
-
-  @Column({ type: 'date', nullable: false })
-  public eventDate: Date;
-
-  @Column('float', { nullable: true })
-  public goodAqiPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public moderateAqiPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public unhealthySensitiveAqiPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public unhealthyAqiPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public veryUnhealthyAqiPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public hazardousAqiPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public dailyAvgAqi?: number;
-
-  @Column('float', { nullable: true })
-  public dailyMaxAqi?: number;
-
-  @Column('float', { nullable: true })
-  public dailyMinAqi?: number;
-
-  @Column('float', { nullable: true })
-  public goodPm25Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public moderatePm25Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public unhealthySensitivePm25Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public unhealthyPm25Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public veryUnhealthyPm25Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public hazardousPm25Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public dailyAvgPm25?: number;
-
-  @Column('float', { nullable: true })
-  public dailyMaxPm25?: number;
-
-  @Column('float', { nullable: true })
-  public dailyMinPm25?: number;
-
-  @Column('float', { nullable: true })
-  public goodPm10Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public moderatePm10Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public unhealthySensitivePm10Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public unhealthyPm10Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public veryUnhealthyPm10Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public hazardousPm10Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public dailyAvgPm10?: number;
-
-  @Column('float', { nullable: true })
-  public dailyMaxPm10?: number;
-
-  @Column('float', { nullable: true })
-  public dailyMinPm10?: number;
-
-  @Column('float', { nullable: true })
-  public goodVocPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public moderateVocPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public unhealthySensitiveVocPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public unhealthyVocPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public veryUnhealthyVocPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public hazardousVocPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public dailyAvgVoc?: number;
-
-  @Column('float', { nullable: true })
-  public dailyMaxVoc?: number;
-
-  @Column('float', { nullable: true })
-  public dailyMinVoc?: number;
-
-  @Column('float', { nullable: true })
-  public goodCo2Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public moderateCo2Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public unhealthySensitiveCo2Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public unhealthyCo2Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public veryUnhealthyCo2Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public hazardousCo2Percentage?: number;
-
-  @Column('float', { nullable: true })
-  public dailyAvgCo2?: number;
-
-  @Column('float', { nullable: true })
-  public dailyMaxCo2?: number;
-
-  @Column('float', { nullable: true })
-  public dailyMinCo2?: number;
-
-  @Column('float', { nullable: true })
-  public goodCh2oPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public moderateCh2oPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public unhealthySensitiveCh2oPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public unhealthyCh2oPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public veryUnhealthyCh2oPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public hazardousCh2oPercentage?: number;
-
-  @Column('float', { nullable: true })
-  public dailyAvgCh2o?: number;
-
-  @Column('float', { nullable: true })
-  public dailyMaxCh2o?: number;
-
-  @Column('float', { nullable: true })
-  public dailyMinCh2o?: number;
-
-  constructor(partial: Partial<AqiSpaceDailyPollutantStatsEntity>) {
-    super();
-    Object.assign(this, partial);
-  }
-}

libs/common/src/modules/aqi/entities/index.ts

@@ -1 +0,0 @@
-export * from './aqi.entity';

libs/common/src/modules/aqi/repositories/aqi.repository.ts

@@ -1,10 +0,0 @@
-import { DataSource, Repository } from 'typeorm';
-import { Injectable } from '@nestjs/common';
-import { AqiSpaceDailyPollutantStatsEntity } from '../entities';
-
-@Injectable()
-export class AqiSpaceDailyPollutantStatsRepository extends Repository<AqiSpaceDailyPollutantStatsEntity> {
-  constructor(private dataSource: DataSource) {
-    super(AqiSpaceDailyPollutantStatsEntity, dataSource.createEntityManager());
-  }
-}

libs/common/src/modules/aqi/repositories/index.ts

@@ -1 +0,0 @@
-export * from './aqi.repository';

libs/common/src/modules/device-status-log/entities/device-status-log.entity.ts

@@ -2,15 +2,15 @@ import { SourceType } from '@app/common/constants/source-type.enum';
 import { Entity, Column, PrimaryColumn, Unique } from 'typeorm';
 
 @Entity('device-status-log')
-@Unique('event_time_idx', ['eventTime', 'deviceId', 'code', 'value'])
+@Unique('event_time_idx', ['eventTime'])
 export class DeviceStatusLogEntity {
-  @PrimaryColumn({ type: 'int', generated: true, unsigned: true })
+  @Column({ type: 'int', generated: true, unsigned: true })
   id: number;
 
   @Column({ type: 'text' })
   eventId: string;
 
-  @Column({ type: 'timestamptz' })
+  @PrimaryColumn({ type: 'timestamptz' })
   eventTime: Date;
 
   @Column({

libs/common/src/modules/device/entities/device.entity.ts

@@ -78,8 +78,8 @@ export class DeviceEntity extends AbstractEntity<DeviceDto> {
   @OneToMany(() => SceneDeviceEntity, (sceneDevice) => sceneDevice.device, {})
   sceneDevices: SceneDeviceEntity[];
 
-  @ManyToOne(() => NewTagEntity, (tag) => tag.devices)
+  @OneToMany(() => NewTagEntity, (tag) => tag.devices)
-  @JoinColumn({ name: 'tag_uuid' })
+  // @JoinTable({ name: 'device_tags' })
   public tag: NewTagEntity;
   @OneToMany(() => PowerClampHourlyEntity, (powerClamp) => powerClamp.device)
   powerClampHourly: PowerClampHourlyEntity[];

libs/common/src/modules/occupancy/dtos/index.ts

@@ -1 +0,0 @@
-export * from './occupancy.dto';

libs/common/src/modules/occupancy/dtos/occupancy.dto.ts

@@ -1,23 +0,0 @@
-import { IsNotEmpty, IsNumber, IsString } from 'class-validator';
-
-export class SpaceDailyOccupancyDurationDto {
-  @IsString()
-  @IsNotEmpty()
-  public uuid: string;
-
-  @IsString()
-  @IsNotEmpty()
-  public spaceUuid: string;
-
-  @IsString()
-  @IsNotEmpty()
-  public eventDate: string;
-
-  @IsNumber()
-  @IsNotEmpty()
-  public occupancyPercentage: number;
-
-  @IsNumber()
-  @IsNotEmpty()
-  public occupiedSeconds: number;
-}

libs/common/src/modules/occupancy/entities/index.ts

@@ -1 +0,0 @@
-export * from './occupancy.entity';

libs/common/src/modules/occupancy/entities/occupancy.entity.ts

@@ -1,32 +0,0 @@
-import { Column, Entity, ManyToOne, Unique } from 'typeorm';
-import { AbstractEntity } from '../../abstract/entities/abstract.entity';
-import { SpaceEntity } from '../../space/entities/space.entity';
-import { SpaceDailyOccupancyDurationDto } from '../dtos';
-
-@Entity({ name: 'space-daily-occupancy-duration' })
-@Unique(['spaceUuid', 'eventDate'])
-export class SpaceDailyOccupancyDurationEntity extends AbstractEntity<SpaceDailyOccupancyDurationDto> {
-  @Column({ nullable: false })
-  public spaceUuid: string;
-
-  @Column({ nullable: false, type: 'date' })
-  public eventDate: string;
-
-  public CountTotalPresenceDetected: number;
-
-  @ManyToOne(() => SpaceEntity, (space) => space.presenceSensorDaily)
-  space: SpaceEntity;
-
-  @Column({ type: 'int' })
-  occupancyPercentage: number;
-
-  @Column({ type: 'int', nullable: true })
-  occupiedSeconds?: number;
-
-  @Column({ type: 'int', nullable: true })
-  deviceCount?: number;
-  constructor(partial: Partial<SpaceDailyOccupancyDurationEntity>) {
-    super();
-    Object.assign(this, partial);
-  }
-}

libs/common/src/modules/occupancy/occupancy.repository.module.ts

@@ -1,11 +0,0 @@
-import { Module } from '@nestjs/common';
-import { TypeOrmModule } from '@nestjs/typeorm';
-import { SpaceDailyOccupancyDurationEntity } from './entities/occupancy.entity';
-
-@Module({
-  providers: [],
-  exports: [],
-  controllers: [],
-  imports: [TypeOrmModule.forFeature([SpaceDailyOccupancyDurationEntity])],
-})
-export class SpaceDailyOccupancyDurationRepositoryModule {}

libs/common/src/modules/occupancy/repositories/index.ts

@@ -1 +0,0 @@
-export * from './occupancy.repository';

libs/common/src/modules/occupancy/repositories/occupancy.repository.ts

@@ -1,10 +0,0 @@
-import { DataSource, Repository } from 'typeorm';
-import { Injectable } from '@nestjs/common';
-import { SpaceDailyOccupancyDurationEntity } from '../entities/occupancy.entity';
-
-@Injectable()
-export class SpaceDailyOccupancyDurationEntityRepository extends Repository<SpaceDailyOccupancyDurationEntity> {
-  constructor(private dataSource: DataSource) {
-    super(SpaceDailyOccupancyDurationEntity, dataSource.createEntityManager());
-  }
-}

libs/common/src/modules/product/entities/product.entity.ts

@@ -1,7 +1,10 @@
 import { Column, Entity, OneToMany } from 'typeorm';
+import { ProductDto } from '../dtos';
 import { AbstractEntity } from '../../abstract/entities/abstract.entity';
 import { DeviceEntity } from '../../device/entities';
-import { ProductDto } from '../dtos';
+import { TagModel } from '../../space-model';
+import { TagEntity } from '../../space/entities/tag.entity';
+import { NewTagEntity } from '../../tag/entities';
 @Entity({ name: 'product' })
 export class ProductEntity extends AbstractEntity<ProductDto> {
   @Column({
@@ -25,6 +28,15 @@ export class ProductEntity extends AbstractEntity<ProductDto> {
   })
   public prodType: string;
 
+  @OneToMany(() => NewTagEntity, (tag) => tag.product, { cascade: true })
+  public newTags: NewTagEntity[];
+
+  @OneToMany(() => TagModel, (tag) => tag.product)
+  tagModels: TagModel[];
+
+  @OneToMany(() => TagEntity, (tag) => tag.product)
+  tags: TagEntity[];
+
   @OneToMany(
     () => DeviceEntity,
     (devicesProductEntity) => devicesProductEntity.productDevice,

libs/common/src/modules/space-model/dtos/tag-model.dto.ts

@@ -0,0 +1,21 @@
+import { IsNotEmpty, IsString } from 'class-validator';
+
+export class TagModelDto {
+  @IsString()
+  @IsNotEmpty()
+  public uuid: string;
+
+  @IsString()
+  @IsNotEmpty()
+  public name: string;
+
+  @IsString()
+  @IsNotEmpty()
+  public productUuid: string;
+
+  @IsString()
+  spaceModelUuid: string;
+
+  @IsString()
+  subspaceModelUuid: string;
+}

libs/common/src/modules/space-model/entities/index.ts

@@ -1,3 +1,4 @@
-export * from './space-model-product-allocation.entity';
 export * from './space-model.entity';
 export * from './subspace-model';
+export * from './tag-model.entity';
+export * from './space-model-product-allocation.entity';

libs/common/src/modules/space-model/entities/space-model-product-allocation.entity.ts

@@ -1,12 +1,18 @@
-import { Column, Entity, ManyToOne, OneToMany, Unique } from 'typeorm';
+import {
-import { AbstractEntity } from '../../abstract/entities/abstract.entity';
+  Entity,
+  Column,
+  ManyToOne,
+  ManyToMany,
+  JoinTable,
+  OneToMany,
+} from 'typeorm';
+import { SpaceModelEntity } from './space-model.entity';
+import { NewTagEntity } from '../../tag/entities/tag.entity';
 import { ProductEntity } from '../../product/entities/product.entity';
 import { SpaceProductAllocationEntity } from '../../space/entities/space-product-allocation.entity';
-import { NewTagEntity } from '../../tag/entities/tag.entity';
+import { AbstractEntity } from '../../abstract/entities/abstract.entity';
-import { SpaceModelEntity } from './space-model.entity';
 
 @Entity({ name: 'space_model_product_allocation' })
-@Unique(['spaceModel', 'product', 'tag'])
 export class SpaceModelProductAllocationEntity extends AbstractEntity<SpaceModelProductAllocationEntity> {
   @Column({
     type: 'uuid',
@@ -25,8 +31,9 @@ export class SpaceModelProductAllocationEntity extends AbstractEntity<SpaceModel
   @ManyToOne(() => ProductEntity, { nullable: false, onDelete: 'CASCADE' })
   public product: ProductEntity;
 
-  @ManyToOne(() => NewTagEntity, { nullable: true, onDelete: 'CASCADE' })
+  @ManyToMany(() => NewTagEntity, { cascade: true, onDelete: 'CASCADE' })
-  public tag: NewTagEntity;
+  @JoinTable({ name: 'space_model_product_tags' })
+  public tags: NewTagEntity[];
 
   @OneToMany(
     () => SpaceProductAllocationEntity,

libs/common/src/modules/space-model/entities/space-model.entity.ts

@@ -1,10 +1,11 @@
-import { Column, Entity, JoinColumn, ManyToOne, OneToMany } from 'typeorm';
+import { Entity, Column, OneToMany, ManyToOne, JoinColumn } from 'typeorm';
 import { AbstractEntity } from '../../abstract/entities/abstract.entity';
-import { ProjectEntity } from '../../project/entities';
-import { SpaceEntity } from '../../space/entities/space.entity';
 import { SpaceModelDto } from '../dtos';
-import { SpaceModelProductAllocationEntity } from './space-model-product-allocation.entity';
 import { SubspaceModelEntity } from './subspace-model';
+import { ProjectEntity } from '../../project/entities';
+import { TagModel } from './tag-model.entity';
+import { SpaceModelProductAllocationEntity } from './space-model-product-allocation.entity';
+import { SpaceEntity } from '../../space/entities/space.entity';
 
 @Entity({ name: 'space-model' })
 export class SpaceModelEntity extends AbstractEntity<SpaceModelDto> {
@@ -48,6 +49,9 @@ export class SpaceModelEntity extends AbstractEntity<SpaceModelDto> {
   })
   public spaces: SpaceEntity[];
 
+  @OneToMany(() => TagModel, (tag) => tag.spaceModel)
+  tags: TagModel[];
+
   @OneToMany(
     () => SpaceModelProductAllocationEntity,
     (allocation) => allocation.spaceModel,

libs/common/src/modules/space-model/entities/subspace-model/subspace-model-product-allocation.entity.ts

@@ -1,12 +1,11 @@
-import { AbstractEntity } from '@app/common/modules/abstract/entities/abstract.entity';
+import { Entity, Column, ManyToOne, ManyToMany, JoinTable } from 'typeorm';
+import { SubspaceModelEntity } from './subspace-model.entity';
 import { ProductEntity } from '@app/common/modules/product/entities/product.entity';
 import { NewTagEntity } from '@app/common/modules/tag/entities/tag.entity';
-import { Column, Entity, ManyToOne, Unique } from 'typeorm';
 import { SubspaceModelProductAllocationDto } from '../../dtos/subspace-model/subspace-model-product-allocation.dto';
-import { SubspaceModelEntity } from './subspace-model.entity';
+import { AbstractEntity } from '@app/common/modules/abstract/entities/abstract.entity';
 
 @Entity({ name: 'subspace_model_product_allocation' })
-@Unique(['subspaceModel', 'product', 'tag'])
 export class SubspaceModelProductAllocationEntity extends AbstractEntity<SubspaceModelProductAllocationDto> {
   @Column({
     type: 'uuid',
@@ -28,8 +27,12 @@ export class SubspaceModelProductAllocationEntity extends AbstractEntity<Subspac
   @ManyToOne(() => ProductEntity, { nullable: false, onDelete: 'CASCADE' })
   public product: ProductEntity;
 
-  @ManyToOne(() => NewTagEntity, { nullable: true, onDelete: 'CASCADE' })
+  @ManyToMany(() => NewTagEntity, (tag) => tag.subspaceModelAllocations, {
-  public tag: NewTagEntity;
+    cascade: true,
+    onDelete: 'CASCADE',
+  })
+  @JoinTable({ name: 'subspace_model_product_tags' })
+  public tags: NewTagEntity[];
 
   constructor(partial: Partial<SubspaceModelProductAllocationEntity>) {
     super();

libs/common/src/modules/space-model/entities/subspace-model/subspace-model.entity.ts

@@ -1,9 +1,10 @@
 import { AbstractEntity } from '@app/common/modules/abstract/entities/abstract.entity';
-import { SubspaceEntity } from '@app/common/modules/space/entities/subspace/subspace.entity';
 import { Column, Entity, ManyToOne, OneToMany } from 'typeorm';
 import { SubSpaceModelDto } from '../../dtos';
 import { SpaceModelEntity } from '../space-model.entity';
+import { TagModel } from '../tag-model.entity';
 import { SubspaceModelProductAllocationEntity } from './subspace-model-product-allocation.entity';
+import { SubspaceEntity } from '@app/common/modules/space/entities/subspace/subspace.entity';
 
 @Entity({ name: 'subspace-model' })
 export class SubspaceModelEntity extends AbstractEntity<SubSpaceModelDto> {
@@ -40,6 +41,9 @@ export class SubspaceModelEntity extends AbstractEntity<SubSpaceModelDto> {
   })
   public disabled: boolean;
 
+  @OneToMany(() => TagModel, (tag) => tag.subspaceModel)
+  tags: TagModel[];
+
   @OneToMany(
     () => SubspaceModelProductAllocationEntity,
     (allocation) => allocation.subspaceModel,

libs/common/src/modules/space-model/entities/tag-model.entity.ts

@@ -0,0 +1,38 @@
+import { Column, Entity, JoinColumn, ManyToOne, OneToMany } from 'typeorm';
+import { AbstractEntity } from '../../abstract/entities/abstract.entity';
+import { TagModelDto } from '../dtos/tag-model.dto';
+import { SpaceModelEntity } from './space-model.entity';
+import { SubspaceModelEntity } from './subspace-model';
+import { ProductEntity } from '../../product/entities';
+import { TagEntity } from '../../space/entities/tag.entity';
+
+@Entity({ name: 'tag_model' })
+export class TagModel extends AbstractEntity<TagModelDto> {
+  @Column({ type: 'varchar', length: 255 })
+  tag: string;
+
+  @ManyToOne(() => ProductEntity, (product) => product.tagModels, {
+    nullable: false,
+  })
+  @JoinColumn({ name: 'product_id' })
+  product: ProductEntity;
+
+  @ManyToOne(() => SpaceModelEntity, (space) => space.tags, { nullable: true })
+  @JoinColumn({ name: 'space_model_id' })
+  spaceModel: SpaceModelEntity;
+
+  @ManyToOne(() => SubspaceModelEntity, (subspace) => subspace.tags, {
+    nullable: true,
+  })
+  @JoinColumn({ name: 'subspace_model_id' })
+  subspaceModel: SubspaceModelEntity;
+
+  @Column({
+    nullable: false,
+    default: false,
+  })
+  public disabled: boolean;
+
+  @OneToMany(() => TagEntity, (tag) => tag.model)
+  tags: TagEntity[];
+}

libs/common/src/modules/space-model/repositories/space-model.repository.ts

@@ -1,10 +1,11 @@
-import { Injectable } from '@nestjs/common';
 import { DataSource, Repository } from 'typeorm';
+import { Injectable } from '@nestjs/common';
 import {
   SpaceModelEntity,
   SpaceModelProductAllocationEntity,
   SubspaceModelEntity,
   SubspaceModelProductAllocationEntity,
+  TagModel,
 } from '../entities';
 
 @Injectable()
@@ -20,6 +21,13 @@ export class SubspaceModelRepository extends Repository<SubspaceModelEntity> {
   }
 }
 
+@Injectable()
+export class TagModelRepository extends Repository<TagModel> {
+  constructor(private dataSource: DataSource) {
+    super(TagModel, dataSource.createEntityManager());
+  }
+}
+
 @Injectable()
 export class SpaceModelProductAllocationRepoitory extends Repository<SpaceModelProductAllocationEntity> {
   constructor(private dataSource: DataSource) {

libs/common/src/modules/space-model/space-model.repository.module.ts

@@ -1,11 +1,13 @@
-import { Module } from '@nestjs/common';
 import { TypeOrmModule } from '@nestjs/typeorm';
-import { SpaceModelEntity, SubspaceModelEntity } from './entities';
+import { SpaceModelEntity, SubspaceModelEntity, TagModel } from './entities';
+import { Module } from '@nestjs/common';
 
 @Module({
   providers: [],
   exports: [],
   controllers: [],
-  imports: [TypeOrmModule.forFeature([SpaceModelEntity, SubspaceModelEntity])],
+  imports: [
+    TypeOrmModule.forFeature([SpaceModelEntity, SubspaceModelEntity, TagModel]),
+  ],
 })
 export class SpaceModelRepositoryModule {}

libs/common/src/modules/space/entities/space-link.entity.ts

@@ -1,3 +1,32 @@
+import { Column, Entity, JoinColumn, ManyToOne } from 'typeorm';
 import { AbstractEntity } from '../../abstract/entities/abstract.entity';
+import { SpaceEntity } from './space.entity';
+import { Direction } from '@app/common/constants/direction.enum';
 
-export class SpaceLinkEntity extends AbstractEntity {}
+@Entity({ name: 'space-link' })
+export class SpaceLinkEntity extends AbstractEntity {
+  @ManyToOne(() => SpaceEntity, { nullable: false, onDelete: 'CASCADE' })
+  @JoinColumn({ name: 'start_space_id' })
+  public startSpace: SpaceEntity;
+
+  @ManyToOne(() => SpaceEntity, { nullable: false, onDelete: 'CASCADE' })
+  @JoinColumn({ name: 'end_space_id' })
+  public endSpace: SpaceEntity;
+
+  @Column({
+    nullable: false,
+    default: false,
+  })
+  public disabled: boolean;
+
+  @Column({
+    nullable: false,
+    enum: Object.values(Direction),
+  })
+  direction: string;
+
+  constructor(partial: Partial<SpaceLinkEntity>) {
+    super();
+    Object.assign(this, partial);
+  }
+}

libs/common/src/modules/space/entities/space-product-allocation.entity.ts

@@ -1,13 +1,12 @@
-import { Column, Entity, ManyToOne, Unique } from 'typeorm';
+import { Entity, Column, ManyToOne, ManyToMany, JoinTable } from 'typeorm';
-import { AbstractEntity } from '../../abstract/entities/abstract.entity';
-import { ProductEntity } from '../../product/entities/product.entity';
-import { SpaceModelProductAllocationEntity } from '../../space-model/entities/space-model-product-allocation.entity';
-import { NewTagEntity } from '../../tag/entities/tag.entity';
-import { SpaceProductAllocationDto } from '../dtos/space-product-allocation.dto';
 import { SpaceEntity } from './space.entity';
+import { SpaceModelProductAllocationEntity } from '../../space-model/entities/space-model-product-allocation.entity';
+import { ProductEntity } from '../../product/entities/product.entity';
+import { NewTagEntity } from '../../tag/entities/tag.entity';
+import { AbstractEntity } from '../../abstract/entities/abstract.entity';
+import { SpaceProductAllocationDto } from '../dtos/space-product-allocation.dto';
 
 @Entity({ name: 'space_product_allocation' })
-@Unique(['space', 'product', 'tag'], {})
 export class SpaceProductAllocationEntity extends AbstractEntity<SpaceProductAllocationDto> {
   @Column({
     type: 'uuid',
@@ -31,8 +30,9 @@ export class SpaceProductAllocationEntity extends AbstractEntity<SpaceProductAll
   @ManyToOne(() => ProductEntity, { nullable: false, onDelete: 'CASCADE' })
   public product: ProductEntity;
 
-  @ManyToOne(() => NewTagEntity, { nullable: true, onDelete: 'CASCADE' })
+  @ManyToMany(() => NewTagEntity)
-  public tag: NewTagEntity;
+  @JoinTable({ name: 'space_product_tags' })
+  public tags: NewTagEntity[];
 
   constructor(partial: Partial<SpaceProductAllocationEntity>) {
     super();

libs/common/src/modules/space/entities/space.entity.ts

@@ -1,17 +1,16 @@
 import { Column, Entity, JoinColumn, ManyToOne, OneToMany } from 'typeorm';
+import { SpaceDto } from '../dtos';
 import { AbstractEntity } from '../../abstract/entities/abstract.entity';
-import { AqiSpaceDailyPollutantStatsEntity } from '../../aqi/entities';
+import { UserSpaceEntity } from '../../user/entities';
-import { CommunityEntity } from '../../community/entities';
 import { DeviceEntity } from '../../device/entities';
-import { InviteUserSpaceEntity } from '../../Invite-user/entities';
+import { CommunityEntity } from '../../community/entities';
-import { SpaceDailyOccupancyDurationEntity } from '../../occupancy/entities';
+import { SpaceLinkEntity } from './space-link.entity';
-import { PresenceSensorDailySpaceEntity } from '../../presence-sensor/entities';
 import { SceneEntity } from '../../scene/entities';
 import { SpaceModelEntity } from '../../space-model';
-import { UserSpaceEntity } from '../../user/entities';
+import { InviteUserSpaceEntity } from '../../Invite-user/entities';
-import { SpaceDto } from '../dtos';
 import { SpaceProductAllocationEntity } from './space-product-allocation.entity';
 import { SubspaceEntity } from './subspace/subspace.entity';
+import { PresenceSensorDailySpaceEntity } from '../../presence-sensor/entities';
 
 @Entity({ name: 'space' })
 export class SpaceEntity extends AbstractEntity<SpaceDto> {
@@ -74,6 +73,16 @@ export class SpaceEntity extends AbstractEntity<SpaceDto> {
   )
   devices: DeviceEntity[];
 
+  @OneToMany(() => SpaceLinkEntity, (connection) => connection.startSpace, {
+    nullable: true,
+  })
+  public outgoingConnections: SpaceLinkEntity[];
+
+  @OneToMany(() => SpaceLinkEntity, (connection) => connection.endSpace, {
+    nullable: true,
+  })
+  public incomingConnections: SpaceLinkEntity[];
+
   @Column({
     nullable: true,
     type: 'text',
@@ -106,15 +115,6 @@ export class SpaceEntity extends AbstractEntity<SpaceDto> {
   @OneToMany(() => PresenceSensorDailySpaceEntity, (sensor) => sensor.space)
   presenceSensorDaily: PresenceSensorDailySpaceEntity[];
 
-  @OneToMany(() => AqiSpaceDailyPollutantStatsEntity, (aqi) => aqi.space)
-  aqiSensorDaily: AqiSpaceDailyPollutantStatsEntity[];
-
-  @OneToMany(
-    () => SpaceDailyOccupancyDurationEntity,
-    (occupancy) => occupancy.space,
-  )
-  occupancyDaily: SpaceDailyOccupancyDurationEntity[];
-
   constructor(partial: Partial<SpaceEntity>) {
     super();
     Object.assign(this, partial);

libs/common/src/modules/space/entities/subspace/subspace-product-allocation.entity.ts

@@ -1,13 +1,20 @@
-import { AbstractEntity } from '@app/common/modules/abstract/entities/abstract.entity';
+import {
+  Entity,
+  Column,
+  ManyToOne,
+  ManyToMany,
+  JoinTable,
+  Unique,
+} from 'typeorm';
+import { SubspaceEntity } from './subspace.entity';
 import { ProductEntity } from '@app/common/modules/product/entities';
 import { SubspaceModelProductAllocationEntity } from '@app/common/modules/space-model';
 import { NewTagEntity } from '@app/common/modules/tag/entities/tag.entity';
-import { Column, Entity, ManyToOne, Unique } from 'typeorm';
+import { AbstractEntity } from '@app/common/modules/abstract/entities/abstract.entity';
 import { SubspaceProductAllocationDto } from '../../dtos/subspace-product-allocation.dto';
-import { SubspaceEntity } from './subspace.entity';
 
 @Entity({ name: 'subspace_product_allocation' })
-@Unique(['subspace', 'product', 'tag'])
+// @Unique(['subspace', 'product'])
 export class SubspaceProductAllocationEntity extends AbstractEntity<SubspaceProductAllocationDto> {
   @Column({
     type: 'uuid',
@@ -31,8 +38,9 @@ export class SubspaceProductAllocationEntity extends AbstractEntity<SubspaceProd
   @ManyToOne(() => ProductEntity, { nullable: false, onDelete: 'CASCADE' })
   public product: ProductEntity;
 
-  @ManyToOne(() => NewTagEntity, { nullable: true, onDelete: 'CASCADE' })
+  @ManyToMany(() => NewTagEntity)
-  public tag: NewTagEntity;
+  @JoinTable({ name: 'subspace_product_tags' })
+  public tags: NewTagEntity[];
 
   constructor(partial: Partial<SubspaceProductAllocationEntity>) {
     super();

libs/common/src/modules/space/entities/subspace/subspace.entity.ts

@@ -4,6 +4,7 @@ import { SubspaceModelEntity } from '@app/common/modules/space-model';
 import { Column, Entity, JoinColumn, ManyToOne, OneToMany } from 'typeorm';
 import { SubspaceDto } from '../../dtos';
 import { SpaceEntity } from '../space.entity';
+import { TagEntity } from '../tag.entity';
 import { SubspaceProductAllocationEntity } from './subspace-product-allocation.entity';
 
 @Entity({ name: 'subspace' })
@@ -42,6 +43,9 @@ export class SubspaceEntity extends AbstractEntity<SubspaceDto> {
   })
   subSpaceModel?: SubspaceModelEntity;
 
+  @OneToMany(() => TagEntity, (tag) => tag.subspace)
+  tags: TagEntity[];
+
   @OneToMany(
     () => SubspaceProductAllocationEntity,
     (allocation) => allocation.subspace,

libs/common/src/modules/space/entities/tag.entity.ts

@@ -0,0 +1,41 @@
+import { Entity, Column, ManyToOne, JoinColumn, OneToOne } from 'typeorm';
+import { AbstractEntity } from '../../abstract/entities/abstract.entity';
+import { ProductEntity } from '../../product/entities';
+import { TagDto } from '../dtos';
+import { TagModel } from '../../space-model/entities/tag-model.entity';
+import { DeviceEntity } from '../../device/entities';
+import { SubspaceEntity } from './subspace/subspace.entity';
+
+@Entity({ name: 'tag' })
+export class TagEntity extends AbstractEntity<TagDto> {
+  @Column({ type: 'varchar', length: 255, nullable: true })
+  tag: string;
+
+  @ManyToOne(() => TagModel, (model) => model.tags, {
+    nullable: true,
+  })
+  model: TagModel;
+
+  @ManyToOne(() => ProductEntity, (product) => product.tags, {
+    nullable: false,
+  })
+  product: ProductEntity;
+
+  @ManyToOne(() => SubspaceEntity, (subspace) => subspace.tags, {
+    nullable: true,
+  })
+  @JoinColumn({ name: 'subspace_id' })
+  subspace: SubspaceEntity;
+
+  @Column({
+    nullable: false,
+    default: false,
+  })
+  public disabled: boolean;
+
+  @OneToOne(() => DeviceEntity, (device) => device.tag, {
+    nullable: true,
+  })
+  @JoinColumn({ name: 'device_id' })
+  device: DeviceEntity;
+}

libs/common/src/modules/space/repositories/space.repository.ts

@@ -1,8 +1,10 @@
-import { Injectable } from '@nestjs/common';
 import { DataSource, Repository } from 'typeorm';
+import { Injectable } from '@nestjs/common';
 import { InviteSpaceEntity } from '../entities/invite-space.entity';
-import { SpaceProductAllocationEntity } from '../entities/space-product-allocation.entity';
+import { SpaceLinkEntity } from '../entities/space-link.entity';
 import { SpaceEntity } from '../entities/space.entity';
+import { TagEntity } from '../entities/tag.entity';
+import { SpaceProductAllocationEntity } from '../entities/space-product-allocation.entity';
 
 @Injectable()
 export class SpaceRepository extends Repository<SpaceEntity> {
@@ -12,7 +14,18 @@ export class SpaceRepository extends Repository<SpaceEntity> {
 }
 
 @Injectable()
-export class SpaceLinkRepository {}
+export class SpaceLinkRepository extends Repository<SpaceLinkEntity> {
+  constructor(private dataSource: DataSource) {
+    super(SpaceLinkEntity, dataSource.createEntityManager());
+  }
+}
+
+@Injectable()
+export class TagRepository extends Repository<TagEntity> {
+  constructor(private dataSource: DataSource) {
+    super(TagEntity, dataSource.createEntityManager());
+  }
+}
 
 @Injectable()
 export class InviteSpaceRepository extends Repository<InviteSpaceEntity> {

libs/common/src/modules/space/space.repository.module.ts

@@ -6,6 +6,7 @@ import { SpaceProductAllocationEntity } from './entities/space-product-allocatio
 import { SpaceEntity } from './entities/space.entity';
 import { SubspaceProductAllocationEntity } from './entities/subspace/subspace-product-allocation.entity';
 import { SubspaceEntity } from './entities/subspace/subspace.entity';
+import { TagEntity } from './entities/tag.entity';
 
 @Module({
   providers: [],
@@ -15,6 +16,7 @@ import { SubspaceEntity } from './entities/subspace/subspace.entity';
     TypeOrmModule.forFeature([
       SpaceEntity,
       SubspaceEntity,
+      TagEntity,
       InviteSpaceEntity,
       SpaceProductAllocationEntity,
       SubspaceProductAllocationEntity,

libs/common/src/modules/tag/entities/tag.entity.ts

@@ -1,10 +1,11 @@
-import { Column, Entity, ManyToOne, OneToMany, Unique } from 'typeorm';
+import { Entity, Column, ManyToOne, Unique, ManyToMany } from 'typeorm';
-import { AbstractEntity } from '../../abstract/entities/abstract.entity';
+import { ProductEntity } from '../../product/entities';
-import { DeviceEntity } from '../../device/entities/device.entity';
 import { ProjectEntity } from '../../project/entities';
+import { AbstractEntity } from '../../abstract/entities/abstract.entity';
+import { NewTagDto } from '../dtos/tag.dto';
 import { SpaceModelProductAllocationEntity } from '../../space-model/entities/space-model-product-allocation.entity';
 import { SubspaceModelProductAllocationEntity } from '../../space-model/entities/subspace-model/subspace-model-product-allocation.entity';
-import { NewTagDto } from '../dtos/tag.dto';
+import { DeviceEntity } from '../../device/entities/device.entity';
 
 @Entity({ name: 'new_tag' })
 @Unique(['name', 'project'])
@@ -23,25 +24,31 @@ export class NewTagEntity extends AbstractEntity<NewTagDto> {
   })
   name: string;
 
+  @ManyToOne(() => ProductEntity, (product) => product.newTags, {
+    nullable: true,
+    onDelete: 'CASCADE',
+  })
+  public product: ProductEntity;
+
   @ManyToOne(() => ProjectEntity, (project) => project.tags, {
     nullable: false,
     onDelete: 'CASCADE',
   })
   public project: ProjectEntity;
 
-  @OneToMany(
+  @ManyToMany(
     () => SpaceModelProductAllocationEntity,
-    (allocation) => allocation.tag,
+    (allocation) => allocation.tags,
   )
   public spaceModelAllocations: SpaceModelProductAllocationEntity[];
 
-  @OneToMany(
+  @ManyToMany(
     () => SubspaceModelProductAllocationEntity,
-    (allocation) => allocation.tag,
+    (allocation) => allocation.tags,
   )
   public subspaceModelAllocations: SubspaceModelProductAllocationEntity[];
 
-  @OneToMany(() => DeviceEntity, (device) => device.tag)
+  @ManyToOne(() => DeviceEntity, (device) => device.tag)
   public devices: DeviceEntity[];
 
   constructor(partial: Partial<NewTagEntity>) {

libs/common/src/sql/procedures/fact_daily_space_aqi/proceduce_update_daily_space_aqi.sql

@@ -1,6 +1,7 @@
 WITH params AS (
 	SELECT 
-      TO_DATE(NULLIF($1, ''), 'YYYY-MM-DD') AS event_date
+      TO_DATE(NULLIF($1, ''), 'YYYY-MM-DD') AS event_date,
+      $2::uuid AS space_id
 ),
 
 -- Query Pipeline Starts Here
@@ -276,10 +277,7 @@ SELECT
   a.daily_avg_ch2o,a.daily_max_ch2o, a.daily_min_ch2o
 FROM daily_percentages p
 LEFT JOIN daily_averages a 
-  ON p.space_id = a.space_id 
+  ON p.space_id = a.space_id AND p.event_date = a.event_date
-  AND p.event_date = a.event_date
-JOIN params  
-    ON params.event_date = a.event_date
 ORDER BY p.space_id, p.event_date)
 
 

libs/common/src/sql/procedures/fact_daily_space_occupancy_duration/procedure_insert_all_daily_spacy_occupancy_duration.sql

@@ -13,81 +13,142 @@ WITH presence_logs AS (
     AND p.cat_name = 'hps'
 ),
 
--- Intervals when device was in 'presence' (between prev_time and event_time when value='none')
+raw_absence_intervals AS (
-presence_intervals AS (
   SELECT 
     space_id,
+    device_id,
     prev_time AS start_time,
     event_time AS end_time
   FROM presence_logs
-  WHERE value = 'none' 
+  WHERE prev_value = 'none' AND prev_time IS NOT NULL
-    AND prev_value = 'presence'
-    AND prev_time IS NOT NULL
 ),
 
--- Split intervals across days
+absence_intervals AS (
-split_intervals AS (
+  SELECT
+    r.space_id,
+    r.device_id,
+    gs.day,
+    GREATEST(r.start_time, gs.day) AS start_time,
+    LEAST(r.end_time, gs.day + INTERVAL '1 day') AS end_time
+  FROM raw_absence_intervals r
+  CROSS JOIN LATERAL (
+    SELECT generate_series(
+      date_trunc('day', r.start_time),
+      date_trunc('day', r.end_time),
+      INTERVAL '1 day'
+    ) AS day
+  ) gs
+  WHERE GREATEST(r.start_time, gs.day) < LEAST(r.end_time, gs.day + INTERVAL '1 day')
+),
+
+device_counts AS (
+  SELECT space_id, day, COUNT(DISTINCT device_id) AS device_count
+  FROM absence_intervals
+  GROUP BY 1, 2
+),
+
+timeline AS (
+  SELECT 
+    a.space_id,
+    a.day,
+    a.device_id,
+    a.start_time AS ts,
+    1 AS is_start
+  FROM absence_intervals a
+  UNION ALL
+  SELECT 
+    a.space_id,
+    a.day,
+    a.device_id,
+    a.end_time AS ts,
+    0 AS is_start
+  FROM absence_intervals a
+),
+
+ordered_events AS (
   SELECT 
     space_id,
-    generate_series(
+    day,
-      date_trunc('day', start_time),
+    ts,
-      date_trunc('day', end_time),
+    is_start,
-      interval '1 day'
+    device_id,
-    )::date AS event_date,
+    SUM(CASE WHEN is_start = 1 THEN 1 ELSE -1 END) 
-    GREATEST(start_time, date_trunc('day', start_time)) AS interval_start,
+      OVER (PARTITION BY space_id, day, device_id ORDER BY ts) AS device_active
-    LEAST(end_time, date_trunc('day', end_time) + interval '1 day') AS interval_end
+  FROM timeline
-  FROM presence_intervals
 ),
 
--- Mark and group overlapping intervals per space per day
+device_state_changes AS (
-ordered_intervals AS (
-  SELECT 
-    space_id,
-    event_date,
-    interval_start,
-    interval_end,
-    LAG(interval_end) OVER (PARTITION BY space_id, event_date ORDER BY interval_start) AS prev_end
-  FROM split_intervals
-),
-
-grouped_intervals AS (
-  SELECT *,
-    SUM(CASE 
-          WHEN prev_end IS NULL OR interval_start > prev_end THEN 1 
-          ELSE 0 
-        END) OVER (PARTITION BY space_id, event_date ORDER BY interval_start) AS grp
-  FROM ordered_intervals
-),
-
--- Merge overlapping intervals per group
-merged_intervals AS (
-  SELECT 
-    space_id,
-    event_date,
-    MIN(interval_start) AS merged_start,
-    MAX(interval_end) AS merged_end
-  FROM grouped_intervals
-  GROUP BY space_id, event_date, grp
-),
-
--- Sum durations of merged intervals
-summed_intervals AS (
   SELECT
     space_id,
-    event_date,
+    day,
-    SUM(EXTRACT(EPOCH FROM (merged_end - merged_start))) AS raw_occupied_seconds
+    ts,
-  FROM merged_intervals
+    SUM(CASE WHEN is_start = 1 THEN 1 ELSE -1 END) 
-  GROUP BY space_id, event_date
+      OVER (PARTITION BY space_id, day ORDER BY ts) AS net_active_devices
-  ),
+  FROM (
+    SELECT DISTINCT space_id, day, ts, is_start
+    FROM timeline
+  ) t
+),
 
-final_data AS (
+absence_windows AS (
+  SELECT 
+    dc.space_id,
+    dc.day,
+    ts AS start_time,
+    LEAD(ts) OVER (PARTITION BY dc.space_id, dc.day ORDER BY ts) AS end_time
+  FROM device_state_changes dsc
+  JOIN device_counts dc ON dc.space_id = dsc.space_id AND dc.day = dsc.day
+  WHERE net_active_devices = 0
+),
+
+empty_periods AS (
+  SELECT
+    space_id,
+    day,
+    EXTRACT(EPOCH FROM (end_time - start_time)) AS unoccupied_seconds
+  FROM absence_windows
+  WHERE end_time IS NOT NULL
+),
+
+unoccupied_summary AS (
+  SELECT
+    space_id,
+    day,
+    SUM(unoccupied_seconds) AS total_unoccupied_seconds
+  FROM empty_periods
+  GROUP BY space_id, day
+),
+
+-- Include device count even for days with 0 unoccupied time
+all_days_with_devices AS (
+  SELECT 
+    space_id, 
+    DATE(event_time) AS day, 
+    COUNT(DISTINCT device_id) AS device_count
+  FROM presence_logs
+  GROUP BY 1, 2
+),
+
+final_occupancy AS (
+  SELECT 
+    d.space_id,
+    d.day,
+    d.device_count,
+    COALESCE(u.total_unoccupied_seconds, 0) AS unoccupied_seconds,
+    86400 - COALESCE(u.total_unoccupied_seconds, 0) AS occupied_seconds
+  FROM all_days_with_devices d
+  LEFT JOIN unoccupied_summary u 
+    ON d.space_id = u.space_id AND d.day = u.day
+)
+, final_data as (
 SELECT 
   space_id,
-  event_date,
+  day,
-  LEAST(raw_occupied_seconds, 86400) AS occupied_seconds,
+  device_count,
-  ROUND(LEAST(raw_occupied_seconds, 86400) / 86400.0 * 100, 2) AS occupancy_percentage
+  occupied_seconds,
-FROM summed_intervals
+  ROUND(occupied_seconds / 86400.0 * 100, 2) AS occupancy_percentage
-ORDER BY space_id, event_date)
+FROM final_occupancy
+ORDER BY space_id, day)
 
 
 INSERT INTO public."space-daily-occupancy-duration" (

libs/common/src/sql/procedures/fact_daily_space_occupancy_duration/procedure_update_daily_space_occupancy_duration.sql

@@ -1,6 +1,7 @@
 WITH params AS (
 	SELECT 
-      TO_DATE(NULLIF($1, ''), 'YYYY-MM-DD') AS event_date
+      TO_DATE(NULLIF($1, ''), 'YYYY-MM-DD') AS event_date,
+      $2::uuid AS space_id
 ),
 
 presence_logs AS (
@@ -9,7 +10,8 @@ presence_logs AS (
     l.device_id,
     l.event_time,
     l.value,
-    LAG(l.event_time) OVER (PARTITION BY l.device_id ORDER BY l.event_time) AS prev_time
+    LAG(l.event_time) OVER (PARTITION BY l.device_id ORDER BY l.event_time) AS prev_time,
+    LAG(l.value) OVER (PARTITION BY l.device_id ORDER BY l.event_time) AS prev_value 
   FROM device d
   JOIN "device-status-log" l ON d.uuid = l.device_id
   JOIN product p ON p.uuid = d.product_device_uuid
@@ -17,76 +19,147 @@ presence_logs AS (
     AND p.cat_name = 'hps'
 ),
 
-presence_intervals AS (
+raw_absence_intervals AS (
   SELECT 
     space_id,
+    device_id,
     prev_time AS start_time,
     event_time AS end_time
   FROM presence_logs
-  WHERE value = 'none' AND prev_time IS NOT NULL
+  WHERE prev_value = 'none' AND prev_time IS NOT NULL
 ),
 
-split_intervals AS (
+absence_intervals AS (
+  SELECT
+    r.space_id,
+    r.device_id,
+    gs.day,
+    GREATEST(r.start_time, gs.day) AS start_time,
+    LEAST(r.end_time, gs.day + INTERVAL '1 day') AS end_time
+  FROM raw_absence_intervals r
+  CROSS JOIN LATERAL (
+    SELECT generate_series(
+      date_trunc('day', r.start_time),
+      date_trunc('day', r.end_time),
+      INTERVAL '1 day'
+    ) AS day
+  ) gs
+  WHERE GREATEST(r.start_time, gs.day) < LEAST(r.end_time, gs.day + INTERVAL '1 day')
+),
+
+device_counts AS (
+  SELECT space_id, day, COUNT(DISTINCT device_id) AS device_count
+  FROM absence_intervals
+  GROUP BY 1, 2
+),
+
+timeline AS (
+  SELECT 
+    a.space_id,
+    a.day,
+    a.device_id,
+    a.start_time AS ts,
+    1 AS is_start
+  FROM absence_intervals a
+  UNION ALL
+  SELECT 
+    a.space_id,
+    a.day,
+    a.device_id,
+    a.end_time AS ts,
+    0 AS is_start
+  FROM absence_intervals a
+),
+
+ordered_events AS (
   SELECT 
     space_id,
-    generate_series(
+    day,
-      date_trunc('day', start_time),
+    ts,
-      date_trunc('day', end_time),
+    is_start,
-      interval '1 day'
+    device_id,
-    )::date AS event_date,
+    SUM(CASE WHEN is_start = 1 THEN 1 ELSE -1 END) 
-    GREATEST(start_time, date_trunc('day', start_time)) AS interval_start,
+      OVER (PARTITION BY space_id, day, device_id ORDER BY ts) AS device_active
-    LEAST(end_time, date_trunc('day', end_time) + INTERVAL '1 day') AS interval_end
+  FROM timeline
-  FROM presence_intervals
 ),
 
-ordered_intervals AS (
+device_state_changes AS (
-  SELECT 
-    space_id,
-    event_date,
-    interval_start,
-    interval_end,
-    LAG(interval_end) OVER (PARTITION BY space_id, event_date ORDER BY interval_start) AS prev_end
-  FROM split_intervals
-),
-
-grouped_intervals AS (
-  SELECT *,
-    SUM(CASE 
-          WHEN prev_end IS NULL OR interval_start > prev_end THEN 1 
-          ELSE 0 
-        END) OVER (PARTITION BY space_id, event_date ORDER BY interval_start) AS grp
-  FROM ordered_intervals
-),
-
-merged_intervals AS (
-  SELECT 
-    space_id,
-    event_date,
-    MIN(interval_start) AS merged_start,
-    MAX(interval_end) AS merged_end
-  FROM grouped_intervals
-  GROUP BY space_id, event_date, grp
-),
-
-summed_intervals AS (
   SELECT
     space_id,
-    event_date,
+    day,
-    SUM(EXTRACT(EPOCH FROM (merged_end - merged_start))) AS raw_occupied_seconds
+    ts,
-  FROM merged_intervals
+    SUM(CASE WHEN is_start = 1 THEN 1 ELSE -1 END) 
-  GROUP BY space_id, event_date
+      OVER (PARTITION BY space_id, day ORDER BY ts) AS net_active_devices
+  FROM (
+    SELECT DISTINCT space_id, day, ts, is_start
+    FROM timeline
+  ) t
 ),
 
-final_data AS (
+absence_windows AS (
   SELECT 
-    s.space_id,
+    dc.space_id,
-    s.event_date,
+    dc.day,
-    LEAST(raw_occupied_seconds, 86400) AS occupied_seconds,
+    ts AS start_time,
-    ROUND(LEAST(raw_occupied_seconds, 86400) / 86400.0 * 100, 2) AS occupancy_percentage
+    LEAD(ts) OVER (PARTITION BY dc.space_id, dc.day ORDER BY ts) AS end_time
-  FROM summed_intervals s
+  FROM device_state_changes dsc
-  JOIN params p 
+  JOIN device_counts dc ON dc.space_id = dsc.space_id AND dc.day = dsc.day
-    ON p.event_date = s.event_date
+  WHERE net_active_devices = 0
-)
+),
+
+empty_periods AS (
+  SELECT
+    space_id,
+    day,
+    EXTRACT(EPOCH FROM (end_time - start_time)) AS unoccupied_seconds
+  FROM absence_windows
+  WHERE end_time IS NOT NULL
+),
+
+unoccupied_summary AS (
+  SELECT
+    space_id,
+    day,
+    SUM(unoccupied_seconds) AS total_unoccupied_seconds
+  FROM empty_periods
+  GROUP BY space_id, day
+),
+
+-- Include device count even for days with 0 unoccupied time
+all_days_with_devices AS (
+  SELECT 
+    space_id, 
+    DATE(event_time) AS day, 
+    COUNT(DISTINCT device_id) AS device_count
+  FROM presence_logs
+  GROUP BY 1, 2
+),
+
+final_occupancy AS (
+  SELECT 
+    d.space_id,
+    d.day,
+    d.device_count,
+    COALESCE(u.total_unoccupied_seconds, 0) AS unoccupied_seconds,
+    86400 - COALESCE(u.total_unoccupied_seconds, 0) AS occupied_seconds
+  FROM all_days_with_devices d
+  LEFT JOIN unoccupied_summary u 
+    ON d.space_id = u.space_id AND d.day = u.day
+),
+
+final_data as(
+SELECT 
+  space_id,
+  day,
+  device_count,
+  occupied_seconds,
+  ROUND(occupied_seconds / 86400.0 * 100, 2) AS occupancy_percentage
+FROM final_occupancy s
+JOIN params p 
+    ON p.space_id = s.space_id 
+   AND p.event_date = s.event_date
+ORDER BY space_id, DAY)
+
 
 INSERT INTO public."space-daily-occupancy-duration" (
 	space_uuid,	

libs/common/src/sql/procedures/fact_device_energy_consumed/fact_daily_device_energy_consumed_procedure.sql

@@ -1,6 +1,7 @@
 WITH params AS (
     SELECT 
-        $1::date AS target_date
+        $1::uuid AS device_id,
+        $2::date AS target_date
 ),
 total_energy AS (
     SELECT 
@@ -13,7 +14,8 @@ total_energy AS (
         MAX(log.value)::integer AS max_value
     FROM "device-status-log" log, params
     WHERE log.code = 'EnergyConsumed'
-    AND log.event_time::date = params.target_date
+      AND log.device_id = params.device_id
+      AND log.event_time::date = params.target_date
     GROUP BY 1,2,3,4,5
 ),
 energy_phase_A AS (
@@ -27,7 +29,8 @@ energy_phase_A AS (
         MAX(log.value)::integer AS max_value
     FROM "device-status-log" log, params
     WHERE log.code = 'EnergyConsumedA'
-    AND log.event_time::date = params.target_date
+      AND log.device_id = params.device_id
+      AND log.event_time::date = params.target_date
     GROUP BY 1,2,3,4,5
 ),
 energy_phase_B AS (
@@ -41,7 +44,8 @@ energy_phase_B AS (
         MAX(log.value)::integer AS max_value
     FROM "device-status-log" log, params
     WHERE log.code = 'EnergyConsumedB'
-    AND log.event_time::date = params.target_date
+      AND log.device_id = params.device_id
+      AND log.event_time::date = params.target_date
     GROUP BY 1,2,3,4,5
 ),
 energy_phase_C AS (
@@ -55,7 +59,8 @@ energy_phase_C AS (
         MAX(log.value)::integer AS max_value
     FROM "device-status-log" log, params
     WHERE log.code = 'EnergyConsumedC'
-    AND log.event_time::date = params.target_date
+      AND log.device_id = params.device_id
+      AND log.event_time::date = params.target_date
     GROUP BY 1,2,3,4,5
 ),
 final_data AS (

libs/common/src/sql/procedures/fact_device_energy_consumed/fact_hourly_device_energy_consumed_procedure.sql

@@ -1,6 +1,8 @@
 WITH params AS (
     SELECT 
-        $1::date AS target_date
+        $1::uuid AS device_id,
+        $2::date AS target_date,
+        $3::text AS target_hour
 ),
 total_energy AS (
     SELECT 
@@ -13,7 +15,9 @@ total_energy AS (
         MAX(log.value)::integer AS max_value
     FROM "device-status-log" log, params
     WHERE log.code = 'EnergyConsumed'
+      AND log.device_id = params.device_id
       AND log.event_time::date = params.target_date
+      AND EXTRACT(HOUR FROM log.event_time)::text = params.target_hour
     GROUP BY 1,2,3,4,5
 ),
 energy_phase_A AS (
@@ -27,7 +31,9 @@ energy_phase_A AS (
         MAX(log.value)::integer AS max_value
     FROM "device-status-log" log, params
     WHERE log.code = 'EnergyConsumedA'
+      AND log.device_id = params.device_id
       AND log.event_time::date = params.target_date
+      AND EXTRACT(HOUR FROM log.event_time)::text = params.target_hour
     GROUP BY 1,2,3,4,5
 ),
 energy_phase_B AS (
@@ -41,7 +47,9 @@ energy_phase_B AS (
         MAX(log.value)::integer AS max_value
     FROM "device-status-log" log, params
     WHERE log.code = 'EnergyConsumedB'
+      AND log.device_id = params.device_id
       AND log.event_time::date = params.target_date
+      AND EXTRACT(HOUR FROM log.event_time)::text = params.target_hour
     GROUP BY 1,2,3,4,5
 ),
 energy_phase_C AS (
@@ -55,7 +63,9 @@ energy_phase_C AS (
         MAX(log.value)::integer AS max_value
     FROM "device-status-log" log, params
     WHERE log.code = 'EnergyConsumedC'
+      AND log.device_id = params.device_id
       AND log.event_time::date = params.target_date
+      AND EXTRACT(HOUR FROM log.event_time)::text = params.target_hour
     GROUP BY 1,2,3,4,5
 ),
 final_data AS (

libs/common/src/sql/procedures/fact_device_energy_consumed/fact_monthly_device_energy_consumed_procedure.sql

@@ -1,6 +1,7 @@
 WITH params AS (
     SELECT 
-        $1::text AS target_month  -- Format should match 'MM-YYYY'
+        $1::uuid AS device_id,
+        $2::text AS target_month  -- Format should match 'MM-YYYY'
 ),
 total_energy AS (
     SELECT 
@@ -13,6 +14,7 @@ total_energy AS (
         MAX(log.value)::integer AS max_value
     FROM "device-status-log" log, params
     WHERE log.code = 'EnergyConsumed'
+      AND log.device_id = params.device_id
       AND TO_CHAR(log.event_time, 'MM-YYYY') = params.target_month
     GROUP BY 1,2,3,4,5
 ),
@@ -27,6 +29,7 @@ energy_phase_A AS (
         MAX(log.value)::integer AS max_value
     FROM "device-status-log" log, params
     WHERE log.code = 'EnergyConsumedA'
+      AND log.device_id = params.device_id
       AND TO_CHAR(log.event_time, 'MM-YYYY') = params.target_month
     GROUP BY 1,2,3,4,5
 ),
@@ -41,6 +44,7 @@ energy_phase_B AS (
         MAX(log.value)::integer AS max_value
     FROM "device-status-log" log, params
     WHERE log.code = 'EnergyConsumedB'
+      AND log.device_id = params.device_id
       AND TO_CHAR(log.event_time, 'MM-YYYY') = params.target_month
     GROUP BY 1,2,3,4,5
 ),
@@ -55,6 +59,7 @@ energy_phase_C AS (
         MAX(log.value)::integer AS max_value
     FROM "device-status-log" log, params
     WHERE log.code = 'EnergyConsumedC'
+      AND log.device_id = params.device_id
       AND TO_CHAR(log.event_time, 'MM-YYYY') = params.target_month
     GROUP BY 1,2,3,4,5
 ),

libs/common/src/sql/procedures/fact_space_occupancy_count/proceduce_select_fact_space_occupancy.sql

@@ -12,4 +12,8 @@ AND (
   P.event_year IS NULL 
   OR TO_CHAR(psdsd.event_date, 'YYYY') = TO_CHAR(P.event_year, 'YYYY')
 )
-ORDER BY space_uuid, event_date
+ORDER BY space_uuid, event_date
+
+
+
+

libs/common/src/sql/procedures/fact_space_occupancy_count/procedure_update_fact_space_occupancy.sql

@@ -1,6 +1,7 @@
 WITH params AS (
 	SELECT 
-      TO_DATE(NULLIF($1, ''), 'YYYY-MM-DD') AS event_date
+      TO_DATE(NULLIF($1, ''), 'YYYY-MM-DD') AS event_date,
+      $2::uuid AS space_id
 ),
 
 device_logs AS (
@@ -86,7 +87,8 @@ SELECT summary.space_id,
        count_total_presence_detected
 FROM summary
 JOIN params P ON true
-where (P.event_date IS NULL or summary.event_date::date = P.event_date)
+where summary.space_id = P.space_id
+and (P.event_date IS NULL or summary.event_date::date = P.event_date)
 ORDER BY space_id, event_date)
 
 

libs/common/src/sql/queries/fact_daily_space_presence_duration/fact_daily_space_presence_duration.sql

@@ -13,78 +13,156 @@ WITH presence_logs AS (
     AND p.cat_name = 'hps'
 ),
 
--- Intervals when device was in 'presence' (between prev_time and event_time when value='none')
+-- Intervals when device was in 'absence' (between prev_time and event_time when value='none')
-presence_intervals AS (
+raw_absence_intervals AS (
   SELECT 
     space_id,
+    device_id,
     prev_time AS start_time,
     event_time AS end_time
   FROM presence_logs
-  WHERE value = 'none' 
+  WHERE value <> 'none' 
-    AND prev_value = 'presence'
+    AND prev_value = 'none'
     AND prev_time IS NOT NULL
 ),
 
--- Split intervals across days
+-- Split intervals that span multiple days into day-specific chunks
-split_intervals AS (
+absence_intervals AS (
+  SELECT
+    r.space_id,
+    r.device_id,
+    GREATEST(r.start_time, gs.day::timestamp) AS start_time,
+    LEAST(r.end_time, (gs.day + INTERVAL '1 day' - INTERVAL '1 second')::timestamp) AS end_time
+  FROM raw_absence_intervals r
+  CROSS JOIN LATERAL (
+    SELECT generate_series(
+      date_trunc('day', r.start_time),
+      date_trunc('day', r.end_time),
+      INTERVAL '1 day'
+    ) AS day
+  ) gs
+  WHERE GREATEST(r.start_time, gs.day::timestamp) < LEAST(r.end_time, (gs.day + INTERVAL '1 day')::timestamp)
+),
+
+-- FIXED: Count devices based on presence_logs OR absence_intervals
+devices_per_day AS (
   SELECT 
     space_id,
-    generate_series(
+    day,
-      date_trunc('day', start_time),
+    COUNT(DISTINCT device_id) AS device_count
-      date_trunc('day', end_time),
+  FROM (
-      interval '1 day'
+    -- Devices that logged events on that day
-    )::date AS event_date,
+    SELECT space_id, DATE(event_time) AS day, device_id
-    GREATEST(start_time, date_trunc('day', start_time)) AS interval_start,
+    FROM presence_logs
-    LEAST(end_time, date_trunc('day', end_time) + interval '1 day') AS interval_end
+    
-  FROM presence_intervals
+    UNION
+    
+    -- Devices that had absence intervals on that day
+    SELECT space_id, DATE(start_time) AS day, device_id
+    FROM absence_intervals
+  ) combined
+  GROUP BY space_id, day
 ),
 
--- Mark and group overlapping intervals per space per day
-ordered_intervals AS (
-  SELECT 
-    space_id,
-    event_date,
-    interval_start,
-    interval_end,
-    LAG(interval_end) OVER (PARTITION BY space_id, event_date ORDER BY interval_start) AS prev_end
-  FROM split_intervals
-),
 
-grouped_intervals AS (
+-- For multi-device spaces, find all time periods when ALL devices were absent
-  SELECT *,
+multi_device_unoccupied AS (
-    SUM(CASE 
+  WITH device_absence_per_day AS (
-          WHEN prev_end IS NULL OR interval_start > prev_end THEN 1 
+    SELECT
-          ELSE 0 
+      a.space_id,
-        END) OVER (PARTITION BY space_id, event_date ORDER BY interval_start) AS grp
+      DATE(a.start_time) AS day,
-  FROM ordered_intervals
+      a.device_id,
-),
+      a.start_time,
-
+      a.end_time,
--- Merge overlapping intervals per group
+      d.device_count
-merged_intervals AS (
+    FROM absence_intervals a
-  SELECT 
+    JOIN devices_per_day d ON a.space_id = d.space_id AND DATE(a.start_time) = d.day
-    space_id,
+    WHERE d.device_count > 1
-    event_date,
+  ),
-    MIN(interval_start) AS merged_start,
+  -- Generate time slots for each day with multiple devices
-    MAX(interval_end) AS merged_end
+  time_ranges AS (
-  FROM grouped_intervals
+    SELECT
-  GROUP BY space_id, event_date, grp
+      space_id,
-),
+      day,
-
+      day::timestamp AS range_start,
--- Sum durations of merged intervals
+      (day + INTERVAL '1 day')::timestamp AS range_end,
-summed_intervals AS (
+      device_count
+    FROM devices_per_day
+    WHERE device_count > 1
+  ),
+  
+  -- Find all time periods when all devices were absent
+  all_devices_absent AS (
+    SELECT
+      t.space_id,
+      t.day,
+      t.range_start,
+      t.range_end,
+      t.device_count,
+      -- Find the latest start time of all devices' absence intervals
+      MAX(a.start_time) OVER (PARTITION BY t.space_id, t.day) AS max_start_time,
+      -- Find the earliest end time of all devices' absence intervals
+      MIN(a.end_time) OVER (PARTITION BY t.space_id, t.day) AS min_end_time
+    FROM time_ranges t
+    LEFT JOIN device_absence_per_day a ON 
+      t.space_id = a.space_id AND 
+      t.day = a.day
+    GROUP BY t.space_id, t.day, t.range_start, t.range_end, t.device_count, a.start_time, a.end_time
+  )
+  
+  -- Calculate total unoccupied seconds when all devices were absent
   SELECT
     space_id,
-    event_date,
+    day,
-    SUM(EXTRACT(EPOCH FROM (merged_end - merged_start))) AS raw_occupied_seconds
+    CASE
-  FROM merged_intervals
+      WHEN max_start_time IS NULL OR min_end_time IS NULL THEN 0
-  GROUP BY space_id, event_date
+      WHEN max_start_time >= min_end_time THEN 0
+      ELSE EXTRACT(EPOCH FROM (LEAST(min_end_time, range_end) - GREATEST(max_start_time, range_start)))
+    END AS unoccupied_seconds
+  FROM all_devices_absent
+  GROUP BY space_id, day, range_start, range_end, device_count, max_start_time, min_end_time
+  HAVING COUNT(*) = device_count  -- Only include periods when all devices were absent
+)
+,
+
+-- Calculate unoccupied time for spaces with single device reporting
+single_device_unoccupied AS (
+  SELECT
+    a.space_id,
+    DATE(a.start_time) AS day,
+    SUM(EXTRACT(EPOCH FROM (a.end_time - a.start_time))) AS unoccupied_seconds
+  FROM absence_intervals a
+  JOIN devices_per_day d ON a.space_id = d.space_id AND DATE(a.start_time) = d.day
+  WHERE d.device_count = 1
+  GROUP BY a.space_id, DATE(a.start_time)
+)
+,
+
+-- Combine results from both single and multi-device cases
+combined_unoccupied AS (
+  SELECT space_id, day, unoccupied_seconds FROM single_device_unoccupied
+  UNION ALL
+  SELECT space_id, day, unoccupied_seconds FROM multi_device_unoccupied
+), 
+
+-- Calculate total occupied time per space per day
+daily_occupancy AS (
+  SELECT
+    space_id,
+    day,
+    -- Total seconds in day (86400) minus unoccupied seconds
+    86400 - COALESCE(SUM(unoccupied_seconds), 0) AS occupied_seconds
+  FROM combined_unoccupied
+  GROUP BY space_id, day
 )
 
--- Final output with capped seconds and percentage
+-- Final result
 SELECT 
   space_id,
-  event_date,
+  day,
-  LEAST(raw_occupied_seconds, 86400) AS occupied_seconds,
+  occupied_seconds,
-  ROUND(LEAST(raw_occupied_seconds, 86400) / 86400.0 * 100, 2) AS occupancy_percentage
+  -- Also include percentage for convenience
-FROM summed_intervals
+  ROUND((occupied_seconds / 86400.0) * 100, 2) AS occupancy_percentage
-ORDER BY space_id, event_date;
+FROM daily_occupancy
+ORDER BY space_id, day;
+

libs/common/src/util/email.service.ts

@@ -1,7 +1,7 @@
 import { HttpException, HttpStatus, Injectable } from '@nestjs/common';
 import { ConfigService } from '@nestjs/config';
-import axios from 'axios';
 import * as nodemailer from 'nodemailer';
+import axios from 'axios';
 import {
   SEND_EMAIL_API_URL_DEV,
   SEND_EMAIL_API_URL_PROD,
@@ -83,17 +83,12 @@ export class EmailService {
       );
     }
   }
-  async sendEmailWithTemplate({
+  async sendEmailWithTemplate(
-    email,
+    email: string,
-    name,
+    name: string,
-    isEnable,
+    isEnable: boolean,
-    isDelete,
+    isDelete: boolean,
-  }: {
+  ): Promise<void> {
-    email: string;
-    name: string;
-    isEnable: boolean;
-    isDelete: boolean;
-  }): Promise<void> {
     const isProduction = process.env.NODE_ENV === 'production';
     const API_TOKEN = this.configService.get<string>(
       'email-config.MAILTRAP_API_TOKEN',

package-lock.json

@@ -18,7 +18,6 @@
         "@nestjs/jwt": "^10.2.0",
         "@nestjs/passport": "^10.0.3",
         "@nestjs/platform-express": "^10.0.0",
-        "@nestjs/schedule": "^6.0.0",
         "@nestjs/swagger": "^7.3.0",
         "@nestjs/terminus": "^11.0.0",
         "@nestjs/throttler": "^6.4.0",
@@ -39,7 +38,6 @@
         "ioredis": "^5.3.2",
         "morgan": "^1.10.0",
         "nest-winston": "^1.10.2",
-        "node-cache": "^5.1.2",
         "nodemailer": "^6.9.10",
         "onesignal-node": "^3.4.0",
         "passport-jwt": "^4.0.1",
@@ -2540,19 +2538,6 @@
         "@nestjs/core": "^10.0.0"
       }
     },
-    "node_modules/@nestjs/schedule": {
-      "version": "6.0.0",
-      "resolved": "https://registry.npmjs.org/@nestjs/schedule/-/schedule-6.0.0.tgz",
-      "integrity": "sha512-aQySMw6tw2nhitELXd3EiRacQRgzUKD9mFcUZVOJ7jPLqIBvXOyvRWLsK9SdurGA+jjziAlMef7iB5ZEFFoQpw==",
-      "license": "MIT",
-      "dependencies": {
-        "cron": "4.3.0"
-      },
-      "peerDependencies": {
-        "@nestjs/common": "^10.0.0 || ^11.0.0",
-        "@nestjs/core": "^10.0.0 || ^11.0.0"
-      }
-    },
     "node_modules/@nestjs/schematics": {
       "version": "10.2.3",
       "resolved": "https://registry.npmjs.org/@nestjs/schematics/-/schematics-10.2.3.tgz",
@@ -3230,12 +3215,6 @@
         "@types/node": "*"
       }
     },
-    "node_modules/@types/luxon": {
-      "version": "3.6.2",
-      "resolved": "https://registry.npmjs.org/@types/luxon/-/luxon-3.6.2.tgz",
-      "integrity": "sha512-R/BdP7OxEMc44l2Ex5lSXHoIXTB2JLNa3y2QISIbr58U/YcsffyQrYW//hZSdrfxrjRZj3GcUoxMPGdO8gSYuw==",
-      "license": "MIT"
-    },
     "node_modules/@types/methods": {
       "version": "1.1.4",
       "resolved": "https://registry.npmjs.org/@types/methods/-/methods-1.1.4.tgz",
@@ -5447,19 +5426,6 @@
       "devOptional": true,
       "license": "MIT"
     },
-    "node_modules/cron": {
-      "version": "4.3.0",
-      "resolved": "https://registry.npmjs.org/cron/-/cron-4.3.0.tgz",
-      "integrity": "sha512-ciiYNLfSlF9MrDqnbMdRWFiA6oizSF7kA1osPP9lRzNu0Uu+AWog1UKy7SkckiDY2irrNjeO6qLyKnXC8oxmrw==",
-      "license": "MIT",
-      "dependencies": {
-        "@types/luxon": "~3.6.0",
-        "luxon": "~3.6.0"
-      },
-      "engines": {
-        "node": ">=18.x"
-      }
-    },
     "node_modules/cross-spawn": {
       "version": "7.0.6",
       "resolved": "https://registry.npmjs.org/cross-spawn/-/cross-spawn-7.0.6.tgz",
@@ -9811,15 +9777,6 @@
         "yallist": "^3.0.2"
       }
     },
-    "node_modules/luxon": {
-      "version": "3.6.1",
-      "resolved": "https://registry.npmjs.org/luxon/-/luxon-3.6.1.tgz",
-      "integrity": "sha512-tJLxrKJhO2ukZ5z0gyjY1zPh3Rh88Ej9P7jNrZiHMUXHae1yvI2imgOZtL1TO8TW6biMMKfTtAOoEJANgtWBMQ==",
-      "license": "MIT",
-      "engines": {
-        "node": ">=12"
-      }
-    },
     "node_modules/magic-string": {
       "version": "0.30.8",
       "resolved": "https://registry.npmjs.org/magic-string/-/magic-string-0.30.8.tgz",
@@ -10185,27 +10142,6 @@
         "node": "^18 || ^20 || >= 21"
       }
     },
-    "node_modules/node-cache": {
-      "version": "5.1.2",
-      "resolved": "https://registry.npmjs.org/node-cache/-/node-cache-5.1.2.tgz",
-      "integrity": "sha512-t1QzWwnk4sjLWaQAS8CHgOJ+RAfmHpxFWmc36IWTiWHQfs0w5JDMBS1b1ZxQteo0vVVuWJvIUKHDkkeK7vIGCg==",
-      "license": "MIT",
-      "dependencies": {
-        "clone": "2.x"
-      },
-      "engines": {
-        "node": ">= 8.0.0"
-      }
-    },
-    "node_modules/node-cache/node_modules/clone": {
-      "version": "2.1.2",
-      "resolved": "https://registry.npmjs.org/clone/-/clone-2.1.2.tgz",
-      "integrity": "sha512-3Pe/CF1Nn94hyhIYpjtiLhdCoEoz0DqQ+988E9gmeEdQZlojxnOb74wctFyuwWQHzqyf9X7C7MG8juUpqBJT8w==",
-      "license": "MIT",
-      "engines": {
-        "node": ">=0.8"
-      }
-    },
     "node_modules/node-emoji": {
       "version": "1.11.0",
       "resolved": "https://registry.npmjs.org/node-emoji/-/node-emoji-1.11.0.tgz",

package.json

@@ -10,7 +10,6 @@
     "format": "prettier --write \"apps/**/*.ts\" \"libs/**/*.ts\"",
     "start": "npm run test && node dist/main",
     "start:dev": "npm run test && npx nest start --watch",
-    "dev": "npx nest start --watch",
     "start:debug": "npm run test && npx nest start --debug --watch",
     "start:prod": "npm run test && node dist/main",
     "lint": "eslint \"{src,apps,libs,test}/**/*.ts\" --fix",
@@ -30,7 +29,6 @@
     "@nestjs/jwt": "^10.2.0",
     "@nestjs/passport": "^10.0.3",
     "@nestjs/platform-express": "^10.0.0",
-    "@nestjs/schedule": "^6.0.0",
     "@nestjs/swagger": "^7.3.0",
     "@nestjs/terminus": "^11.0.0",
     "@nestjs/throttler": "^6.4.0",
@@ -51,7 +49,6 @@
     "ioredis": "^5.3.2",
     "morgan": "^1.10.0",
     "nest-winston": "^1.10.2",
-    "node-cache": "^5.1.2",
     "nodemailer": "^6.9.10",
     "onesignal-node": "^3.4.0",
     "passport-jwt": "^4.0.1",

src/app.module.ts

@@ -1,66 +1,52 @@
-import { SeederModule } from '@app/common/seed/seeder.module';
 import { Module } from '@nestjs/common';
 import { ConfigModule } from '@nestjs/config';
-import { APP_GUARD, APP_INTERCEPTOR } from '@nestjs/core';
-import { WinstonModule } from 'nest-winston';
-import { AuthenticationModule } from './auth/auth.module';
-import { AutomationModule } from './automation/automation.module';
-import { ClientModule } from './client/client.module';
-import { DeviceCommissionModule } from './commission-device/commission-device.module';
-import { CommunityModule } from './community/community.module';
 import config from './config';
-import { DeviceMessagesSubscriptionModule } from './device-messages/device-messages.module';
+import { AuthenticationModule } from './auth/auth.module';
-import { DeviceModule } from './device/device.module';
+import { UserModule } from './users/user.module';
-import { DoorLockModule } from './door-lock/door.lock.module';
 import { GroupModule } from './group/group.module';
-import { HealthModule } from './health/health.module';
+import { DeviceModule } from './device/device.module';
+import { UserDevicePermissionModule } from './user-device-permission/user-device-permission.module';
+import { CommunityModule } from './community/community.module';
+import { SeederModule } from '@app/common/seed/seeder.module';
+import { UserNotificationModule } from './user-notification/user-notification.module';
+import { DeviceMessagesSubscriptionModule } from './device-messages/device-messages.module';
+import { SceneModule } from './scene/scene.module';
+import { DoorLockModule } from './door-lock/door.lock.module';
+import { APP_GUARD, APP_INTERCEPTOR } from '@nestjs/core';
 import { LoggingInterceptor } from './interceptors/logging.interceptor';
-import { InviteUserModule } from './invite-user/invite-user.module';
+import { AutomationModule } from './automation/automation.module';
-import { PermissionModule } from './permission/permission.module';
+import { RegionModule } from './region/region.module';
-import { PowerClampModule } from './power-clamp/power-clamp.module';
+import { TimeZoneModule } from './timezone/timezone.module';
-import { PrivacyPolicyModule } from './privacy-policy/privacy-policy.module';
+import { VisitorPasswordModule } from './vistor-password/visitor-password.module';
+import { ScheduleModule } from './schedule/schedule.module';
+import { SpaceModule } from './space/space.module';
 import { ProductModule } from './product';
 import { ProjectModule } from './project';
-import { RegionModule } from './region/region.module';
-import { RoleModule } from './role/role.module';
-import { SceneModule } from './scene/scene.module';
-import { ScheduleModule } from './schedule/schedule.module';
 import { SpaceModelModule } from './space-model';
-import { SpaceModule } from './space/space.module';
+import { InviteUserModule } from './invite-user/invite-user.module';
-import { TagModule } from './tags/tags.module';
+import { PermissionModule } from './permission/permission.module';
+import { RoleModule } from './role/role.module';
 import { TermsConditionsModule } from './terms-conditions/terms-conditions.module';
-import { TimeZoneModule } from './timezone/timezone.module';
+import { PrivacyPolicyModule } from './privacy-policy/privacy-policy.module';
-import { UserDevicePermissionModule } from './user-device-permission/user-device-permission.module';
+import { TagModule } from './tags/tags.module';
-import { UserNotificationModule } from './user-notification/user-notification.module';
+import { ClientModule } from './client/client.module';
-import { UserModule } from './users/user.module';
+import { DeviceCommissionModule } from './commission-device/commission-device.module';
-import { VisitorPasswordModule } from './vistor-password/visitor-password.module';
+import { PowerClampModule } from './power-clamp/power-clamp.module';
+import { WinstonModule } from 'nest-winston';
+import { ThrottlerGuard, ThrottlerModule } from '@nestjs/throttler';
+import { HealthModule } from './health/health.module';
 
-import { ThrottlerGuard } from '@nestjs/throttler';
-import { ThrottlerModule } from '@nestjs/throttler/dist/throttler.module';
-import { isArray } from 'class-validator';
 import { winstonLoggerOptions } from '../libs/common/src/logger/services/winston.logger';
-import { AqiModule } from './aqi/aqi.module';
 import { OccupancyModule } from './occupancy/occupancy.module';
 import { WeatherModule } from './weather/weather.module';
-import { ScheduleModule as NestScheduleModule } from '@nestjs/schedule';
-import { SchedulerModule } from './scheduler/scheduler.module';
 @Module({
   imports: [
     ConfigModule.forRoot({
       load: config,
     }),
-    ThrottlerModule.forRoot({
+    /*   ThrottlerModule.forRoot({
-      throttlers: [{ ttl: 60000, limit: 100 }],
+      throttlers: [{ ttl: 100000, limit: 30 }],
-      generateKey: (context) => {
+    }), */
-        const req = context.switchToHttp().getRequest();
-        console.log('Real IP:', req.headers['x-forwarded-for']);
-        return req.headers['x-forwarded-for']
-          ? isArray(req.headers['x-forwarded-for'])
-            ? req.headers['x-forwarded-for'][0].split(':')[0]
-            : req.headers['x-forwarded-for'].split(':')[0]
-          : req.ip;
-      },
-    }),
     WinstonModule.forRoot(winstonLoggerOptions),
     ClientModule,
     AuthenticationModule,
@@ -95,19 +81,16 @@ import { SchedulerModule } from './scheduler/scheduler.module';
     HealthModule,
     OccupancyModule,
     WeatherModule,
-    AqiModule,
-    SchedulerModule,
-    NestScheduleModule.forRoot(),
   ],
   providers: [
     {
       provide: APP_INTERCEPTOR,
       useClass: LoggingInterceptor,
     },
-    {
+    /*  {
       provide: APP_GUARD,
       useClass: ThrottlerGuard,
-    },
+    }, */
   ],
 })
 export class AppModule {}

src/aqi/aqi.module.ts

@@ -1,11 +0,0 @@
-import { Module } from '@nestjs/common';
-import { ConfigModule } from '@nestjs/config';
-import { SqlLoaderService } from '@app/common/helper/services/sql-loader.service';
-import { AqiService } from './services';
-import { AqiController } from './controllers';
-@Module({
-  imports: [ConfigModule],
-  controllers: [AqiController],
-  providers: [AqiService, SqlLoaderService],
-})
-export class AqiModule {}

src/aqi/controllers/aqi.controller.ts

@@ -1,64 +0,0 @@
-import { Controller, Get, Param, Query, UseGuards } from '@nestjs/common';
-import {
-  ApiTags,
-  ApiBearerAuth,
-  ApiOperation,
-  ApiParam,
-} from '@nestjs/swagger';
-import { EnableDisableStatusEnum } from '@app/common/constants/days.enum';
-import { ControllerRoute } from '@app/common/constants/controller-route';
-import { JwtAuthGuard } from '@app/common/guards/jwt.auth.guard';
-import { AqiService } from '../services/aqi.service';
-import {
-  GetAqiDailyBySpaceDto,
-  GetAqiPollutantBySpaceDto,
-} from '../dto/get-aqi.dto';
-import { BaseResponseDto } from '@app/common/dto/base.response.dto';
-import { SpaceParamsDto } from '../dto/aqi-params.dto';
-
-@ApiTags('AQI Module')
-@Controller({
-  version: EnableDisableStatusEnum.ENABLED,
-  path: ControllerRoute.AQI.ROUTE,
-})
-export class AqiController {
-  constructor(private readonly aqiService: AqiService) {}
-
-  @ApiBearerAuth()
-  @UseGuards(JwtAuthGuard)
-  @Get('range/space/:spaceUuid')
-  @ApiOperation({
-    summary: ControllerRoute.AQI.ACTIONS.GET_AQI_RANGE_DATA_SUMMARY,
-    description: ControllerRoute.AQI.ACTIONS.GET_AQI_RANGE_DATA_DESCRIPTION,
-  })
-  @ApiParam({
-    name: 'spaceUuid',
-    description: 'UUID of the Space',
-    required: true,
-  })
-  async getAQIRangeDataBySpace(
-    @Param() params: SpaceParamsDto,
-    @Query() query: GetAqiDailyBySpaceDto,
-  ): Promise<BaseResponseDto> {
-    return await this.aqiService.getAQIRangeDataBySpace(params, query);
-  }
-  @ApiBearerAuth()
-  @UseGuards(JwtAuthGuard)
-  @Get('distribution/space/:spaceUuid')
-  @ApiOperation({
-    summary: ControllerRoute.AQI.ACTIONS.GET_AQI_DISTRIBUTION_DATA_SUMMARY,
-    description:
-      ControllerRoute.AQI.ACTIONS.GET_AQI_DISTRIBUTION_DATA_DESCRIPTION,
-  })
-  @ApiParam({
-    name: 'spaceUuid',
-    description: 'UUID of the Space',
-    required: true,
-  })
-  async getAQIDistributionDataBySpace(
-    @Param() params: SpaceParamsDto,
-    @Query() query: GetAqiPollutantBySpaceDto,
-  ): Promise<BaseResponseDto> {
-    return await this.aqiService.getAQIDistributionDataBySpace(params, query);
-  }
-}

src/aqi/controllers/index.ts

@@ -1 +0,0 @@
-export * from './aqi.controller';

src/aqi/dto/aqi-params.dto.ts

@@ -1,7 +0,0 @@
-import { IsNotEmpty, IsUUID } from 'class-validator';
-
-export class SpaceParamsDto {
-  @IsUUID('4', { message: 'Invalid UUID format' })
-  @IsNotEmpty()
-  spaceUuid: string;
-}

src/aqi/dto/get-aqi.dto.ts

@@ -1,37 +0,0 @@
-import { PollutantType } from '@app/common/constants/pollutants.enum';
-import { ApiProperty } from '@nestjs/swagger';
-import { Matches, IsNotEmpty, IsString } from 'class-validator';
-
-export class GetAqiDailyBySpaceDto {
-  @ApiProperty({
-    description: 'Month and year in format YYYY-MM',
-    example: '2025-03',
-    required: true,
-  })
-  @Matches(/^\d{4}-(0[1-9]|1[0-2])$/, {
-    message: 'monthDate must be in YYYY-MM format',
-  })
-  @IsNotEmpty()
-  monthDate: string;
-}
-export class GetAqiPollutantBySpaceDto {
-  @ApiProperty({
-    description: 'Pollutant Type',
-    enum: PollutantType,
-    example: PollutantType.AQI,
-    required: true,
-  })
-  @IsString()
-  @IsNotEmpty()
-  public pollutantType: string;
-  @ApiProperty({
-    description: 'Month and year in format YYYY-MM',
-    example: '2025-03',
-    required: true,
-  })
-  @Matches(/^\d{4}-(0[1-9]|1[0-2])$/, {
-    message: 'monthDate must be in YYYY-MM format',
-  })
-  @IsNotEmpty()
-  monthDate: string;
-}

src/aqi/services/aqi.service.ts

@@ -1,138 +0,0 @@
-import { HttpException, HttpStatus, Injectable } from '@nestjs/common';
-import {
-  GetAqiDailyBySpaceDto,
-  GetAqiPollutantBySpaceDto,
-} from '../dto/get-aqi.dto';
-import { SuccessResponseDto } from '@app/common/dto/success.response.dto';
-import { SpaceParamsDto } from '../dto/aqi-params.dto';
-import { SqlLoaderService } from '@app/common/helper/services/sql-loader.service';
-import { DataSource } from 'typeorm';
-import { SQL_PROCEDURES_PATH } from '@app/common/constants/sql-query-path';
-import { BaseResponseDto } from '@app/common/dto/base.response.dto';
-import { convertKeysToCamelCase } from '@app/common/helper/camelCaseConverter';
-import { PollutantType } from '@app/common/constants/pollutants.enum';
-
-@Injectable()
-export class AqiService {
-  constructor(
-    private readonly sqlLoader: SqlLoaderService,
-    private readonly dataSource: DataSource,
-  ) {}
-  async getAQIDistributionDataBySpace(
-    params: SpaceParamsDto,
-    query: GetAqiPollutantBySpaceDto,
-  ): Promise<BaseResponseDto> {
-    const { monthDate, pollutantType } = query;
-    const { spaceUuid } = params;
-
-    try {
-      const data = await this.executeProcedure(
-        'fact_daily_space_aqi',
-        'proceduce_select_daily_space_aqi',
-        [spaceUuid, monthDate],
-      );
-
-      const categories = [
-        'good',
-        'moderate',
-        'unhealthy_sensitive',
-        'unhealthy',
-        'very_unhealthy',
-        'hazardous',
-      ];
-
-      const transformedData = data.map((item) => {
-        const date = new Date(item.event_date).toLocaleDateString('en-CA'); // YYYY-MM-DD
-
-        const categoryData = categories.map((category) => {
-          const key = `${category}_${pollutantType.toLowerCase()}_percentage`;
-          return {
-            type: category,
-            percentage: item[key] ?? 0,
-          };
-        });
-
-        return { date, data: categoryData };
-      });
-
-      const response = this.buildResponse(
-        `AQI distribution data fetched successfully for ${spaceUuid} space and pollutant ${pollutantType}`,
-        transformedData,
-      );
-      return response;
-    } catch (error) {
-      console.error('Failed to fetch AQI distribution data', {
-        error,
-        spaceUuid,
-      });
-      throw new HttpException(
-        error.response?.message || 'Failed to fetch AQI distribution data',
-        error.status || HttpStatus.INTERNAL_SERVER_ERROR,
-      );
-    }
-  }
-
-  async getAQIRangeDataBySpace(
-    params: SpaceParamsDto,
-    query: GetAqiDailyBySpaceDto,
-  ): Promise<BaseResponseDto> {
-    const { monthDate } = query;
-    const { spaceUuid } = params;
-
-    try {
-      const data = await this.executeProcedure(
-        'fact_daily_space_aqi',
-        'proceduce_select_daily_space_aqi',
-        [spaceUuid, monthDate],
-      );
-
-      // Define pollutants dynamically
-      const pollutants = Object.values(PollutantType);
-
-      const transformedData = data.map((item) => {
-        const date = new Date(item.event_date).toLocaleDateString('en-CA'); // YYYY-MM-DD
-        const dailyData = pollutants.map((type) => ({
-          type,
-          min: item[`daily_min_${type}`],
-          max: item[`daily_max_${type}`],
-          average: item[`daily_avg_${type}`],
-        }));
-        return { date, data: dailyData };
-      });
-
-      const response = this.buildResponse(
-        `AQI data fetched successfully for ${spaceUuid} space`,
-        transformedData,
-      );
-      return convertKeysToCamelCase(response);
-    } catch (error) {
-      console.error('Failed to fetch AQI data', {
-        error,
-        spaceUuid,
-      });
-      throw new HttpException(
-        error.response?.message || 'Failed to fetch AQI data',
-        error.status || HttpStatus.INTERNAL_SERVER_ERROR,
-      );
-    }
-  }
-
-  private buildResponse(message: string, data: any[]) {
-    return new SuccessResponseDto({
-      message,
-      data,
-      statusCode: HttpStatus.OK,
-    });
-  }
-  private async executeProcedure(
-    procedureFolderName: string,
-    procedureFileName: string,
-    params: (string | number | null)[],
-  ): Promise<any[]> {
-    const query = this.loadQuery(procedureFolderName, procedureFileName);
-    return await this.dataSource.query(query, params);
-  }
-  private loadQuery(folderName: string, fileName: string): string {
-    return this.sqlLoader.loadQuery(folderName, fileName, SQL_PROCEDURES_PATH);
-  }
-}

src/aqi/services/index.ts

@@ -1 +0,0 @@
-export * from './aqi.service';

src/commission-device/commission-device.module.ts

@@ -29,9 +29,6 @@ import {
 import { PowerClampService } from '@app/common/helper/services/power.clamp.service';
 import { SqlLoaderService } from '@app/common/helper/services/sql-loader.service';
 import { OccupancyService } from '@app/common/helper/services/occupancy.service';
-import { AqiDataService } from '@app/common/helper/services/aqi.data.service';
-import { PresenceSensorDailySpaceRepository } from '@app/common/modules/presence-sensor/repositories';
-import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/repositories';
 
 @Module({
   imports: [ConfigModule, SpaceRepositoryModule],
@@ -60,9 +57,6 @@ import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/r
     PowerClampMonthlyRepository,
     SqlLoaderService,
     OccupancyService,
-    AqiDataService,
-    PresenceSensorDailySpaceRepository,
-    AqiSpaceDailyPollutantStatsRepository,
   ],
   exports: [],
 })

src/commission-device/services/commission-device.service.ts

@@ -1,19 +1,17 @@
-import * as csv from 'csv-parser';
 import * as fs from 'fs';
+import * as csv from 'csv-parser';
 
-import { ProjectParam } from '@app/common/dto/project-param.dto';
-import { SuccessResponseDto } from '@app/common/dto/success.response.dto';
 import { TuyaService } from '@app/common/integrations/tuya/services/tuya.service';
-import { CommunityRepository } from '@app/common/modules/community/repositories';
-import { DeviceRepository } from '@app/common/modules/device/repositories';
-import { ProjectRepository } from '@app/common/modules/project/repositiories';
-import { SpaceRepository } from '@app/common/modules/space';
-import { SpaceProductAllocationEntity } from '@app/common/modules/space/entities/space-product-allocation.entity';
-import { SubspaceProductAllocationEntity } from '@app/common/modules/space/entities/subspace/subspace-product-allocation.entity';
-import { SubspaceEntity } from '@app/common/modules/space/entities/subspace/subspace.entity';
-import { SubspaceRepository } from '@app/common/modules/space/repositories/subspace.repository';
 import { HttpException, HttpStatus, Injectable } from '@nestjs/common';
 import { DeviceService } from 'src/device/services';
+import { CommunityRepository } from '@app/common/modules/community/repositories';
+import { SpaceRepository } from '@app/common/modules/space';
+import { SubspaceRepository } from '@app/common/modules/space/repositories/subspace.repository';
+import { SubspaceEntity } from '@app/common/modules/space/entities/subspace/subspace.entity';
+import { DeviceRepository } from '@app/common/modules/device/repositories';
+import { SuccessResponseDto } from '@app/common/dto/success.response.dto';
+import { ProjectParam } from '@app/common/dto/project-param.dto';
+import { ProjectRepository } from '@app/common/modules/project/repositiories';
 
 @Injectable()
 export class DeviceCommissionService {
@@ -120,7 +118,7 @@ export class DeviceCommissionService {
         where: { uuid: spaceId },
         relations: [
           'productAllocations',
-          'productAllocations.tag',
+          'productAllocations.tags',
           'productAllocations.product',
         ],
       });
@@ -137,7 +135,7 @@ export class DeviceCommissionService {
           where: { uuid: subspaceId },
           relations: [
             'productAllocations',
-            'productAllocations.tag',
+            'productAllocations.tags',
             'productAllocations.product',
           ],
         });
@@ -153,23 +151,19 @@ export class DeviceCommissionService {
         subspace?.productAllocations || space.productAllocations;
 
       const match = allocations
-        .map(
+        .flatMap((pa) =>
-          ({
+          (pa.tags || []).map((tag) => ({ product: pa.product, tag })),
-            product,
-            tag,
-          }:
-            | SpaceProductAllocationEntity
-            | SubspaceProductAllocationEntity) => ({ product, tag }),
         )
-        .find(
+        .find(({ tag }) => tag.name === tagName);
-          ({ tag, product }) =>
-            tag.name === tagName && product.name === productName,
-        );
 
       if (!match) {
-        console.error(
+        console.error(`No matching tag found for Device ID: ${rawDeviceId}`);
-          `No matching tag-product combination found for Device ID: ${rawDeviceId}`,
+        failureCount.value++;
-        );
+        return;
+      }
+
+      if (match.product.name !== productName) {
+        console.error(`Product name mismatch for Device ID: ${rawDeviceId}`);
         failureCount.value++;
         return;
       }

src/community/community.module.ts

@@ -8,6 +8,7 @@ import {
   SpaceLinkRepository,
   SpaceProductAllocationRepository,
   SpaceRepository,
+  TagRepository,
 } from '@app/common/modules/space/repositories';
 import { UserSpaceRepository } from '@app/common/modules/user/repositories';
 import { UserRepositoryModule } from '@app/common/modules/user/user.repository.module';
@@ -63,9 +64,6 @@ import {
 } from '@app/common/modules/power-clamp/repositories';
 import { SqlLoaderService } from '@app/common/helper/services/sql-loader.service';
 import { OccupancyService } from '@app/common/helper/services/occupancy.service';
-import { AqiDataService } from '@app/common/helper/services/aqi.data.service';
-import { PresenceSensorDailySpaceRepository } from '@app/common/modules/presence-sensor/repositories';
-import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/repositories';
 
 @Module({
   imports: [ConfigModule, SpaceRepositoryModule, UserRepositoryModule],
@@ -80,7 +78,6 @@ import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/r
     ProjectRepository,
     SpaceService,
     InviteSpaceRepository,
-    // Todo: find out why this is needed
     SpaceLinkService,
     SubSpaceService,
     ValidationService,
@@ -89,7 +86,6 @@ import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/r
     SpaceProductAllocationService,
     SpaceLinkRepository,
     SubspaceRepository,
-    // Todo: find out why this is needed
     TagService,
     SubspaceDeviceService,
     SubspaceProductAllocationService,
@@ -101,6 +97,7 @@ import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/r
     SpaceModelProductAllocationService,
     SpaceProductAllocationRepository,
     SubspaceProductAllocationRepository,
+    TagRepository,
     SubspaceModelRepository,
     SubspaceModelProductAllocationService,
     SpaceModelProductAllocationRepoitory,
@@ -119,9 +116,6 @@ import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/r
     PowerClampMonthlyRepository,
     SqlLoaderService,
     OccupancyService,
-    AqiDataService,
-    PresenceSensorDailySpaceRepository,
-    AqiSpaceDailyPollutantStatsRepository,
   ],
   exports: [CommunityService, SpacePermissionService],
 })

src/community/controllers/community.controller.ts

@@ -1,3 +1,4 @@
+import { CommunityService } from '../services/community.service';
 import {
   Body,
   Controller,
@@ -9,18 +10,17 @@ import {
   Query,
   UseGuards,
 } from '@nestjs/common';
-import { ApiBearerAuth, ApiOperation, ApiTags } from '@nestjs/swagger';
+import { ApiTags, ApiBearerAuth, ApiOperation } from '@nestjs/swagger';
 import { AddCommunityDto } from '../dtos/add.community.dto';
 import { GetCommunityParams } from '../dtos/get.community.dto';
 import { UpdateCommunityNameDto } from '../dtos/update.community.dto';
-import { CommunityService } from '../services/community.service';
 // import { CheckUserCommunityGuard } from 'src/guards/user.community.guard';
 import { ControllerRoute } from '@app/common/constants/controller-route';
 import { BaseResponseDto } from '@app/common/dto/base.response.dto';
-import { PaginationRequestWithSearchGetListDto } from '@app/common/dto/pagination-with-search.request.dto';
-import { Permissions } from 'src/decorators/permissions.decorator';
-import { PermissionsGuard } from 'src/guards/permissions.guard';
 import { ProjectParam } from '../dtos';
+import { PermissionsGuard } from 'src/guards/permissions.guard';
+import { Permissions } from 'src/decorators/permissions.decorator';
+import { PaginationRequestWithSearchGetListDto } from '@app/common/dto/pagination-with-search.request.dto';
 
 @ApiTags('Community Module')
 @Controller({
@@ -45,21 +45,6 @@ export class CommunityController {
     return await this.communityService.createCommunity(param, addCommunityDto);
   }
 
-  @ApiBearerAuth()
-  @UseGuards(PermissionsGuard)
-  @Permissions('COMMUNITY_VIEW')
-  @ApiOperation({
-    summary: ControllerRoute.COMMUNITY.ACTIONS.LIST_COMMUNITY_SUMMARY,
-    description: ControllerRoute.COMMUNITY.ACTIONS.LIST_COMMUNITY_DESCRIPTION,
-  })
-  @Get('v2')
-  async getCommunitiesV2(
-    @Param() param: ProjectParam,
-    @Query() query: PaginationRequestWithSearchGetListDto,
-  ): Promise<any> {
-    return this.communityService.getCommunitiesV2(param, query);
-  }
-
   @ApiBearerAuth()
   @UseGuards(PermissionsGuard)
   @Permissions('COMMUNITY_VIEW')

src/community/services/community.service.ts

@@ -1,33 +1,29 @@
 import {
-  ORPHAN_COMMUNITY_NAME,
+  Injectable,
-  ORPHAN_SPACE_NAME,
+  HttpException,
-} from '@app/common/constants/orphan-constant';
+  HttpStatus,
+  NotFoundException,
+} from '@nestjs/common';
+import { AddCommunityDto, GetCommunityParams, ProjectParam } from '../dtos';
+import { UpdateCommunityNameDto } from '../dtos/update.community.dto';
 import { BaseResponseDto } from '@app/common/dto/base.response.dto';
-import { PageResponse } from '@app/common/dto/pagination.response.dto';
-import { SuccessResponseDto } from '@app/common/dto/success.response.dto';
-import { TuyaService } from '@app/common/integrations/tuya/services/tuya.service';
 import {
   ExtendedTypeORMCustomModelFindAllQuery,
   TypeORMCustomModel,
 } from '@app/common/models/typeOrmCustom.model';
-import { CommunityDto } from '@app/common/modules/community/dtos';
+import { PageResponse } from '@app/common/dto/pagination.response.dto';
-import { CommunityEntity } from '@app/common/modules/community/entities';
 import { CommunityRepository } from '@app/common/modules/community/repositories';
-import { DeviceEntity } from '@app/common/modules/device/entities';
+import { CommunityDto } from '@app/common/modules/community/dtos';
+import { SuccessResponseDto } from '@app/common/dto/success.response.dto';
+import { TuyaService } from '@app/common/integrations/tuya/services/tuya.service';
 import { ProjectRepository } from '@app/common/modules/project/repositiories';
+import { ORPHAN_COMMUNITY_NAME } from '@app/common/constants/orphan-constant';
+import { ILike, In, Not } from 'typeorm';
+import { SpaceService } from 'src/space/services';
 import { SpaceRepository } from '@app/common/modules/space';
+import { DeviceEntity } from '@app/common/modules/device/entities';
 import { SpaceEntity } from '@app/common/modules/space/entities/space.entity';
 import { addSpaceUuidToDevices } from '@app/common/util/device-utils';
-import {
-  HttpException,
-  HttpStatus,
-  Injectable,
-  NotFoundException,
-} from '@nestjs/common';
-import { SpaceService } from 'src/space/services';
-import { QueryRunner, SelectQueryBuilder } from 'typeorm';
-import { AddCommunityDto, GetCommunityParams, ProjectParam } from '../dtos';
-import { UpdateCommunityNameDto } from '../dtos/update.community.dto';
 
 @Injectable()
 export class CommunityService {
@@ -72,18 +68,12 @@ export class CommunityService {
     }
   }
 
-  async getCommunityById(
+  async getCommunityById(params: GetCommunityParams): Promise<BaseResponseDto> {
-    params: GetCommunityParams,
-    queryRunner?: QueryRunner,
-  ): Promise<BaseResponseDto> {
     const { communityUuid, projectUuid } = params;
 
     await this.validateProject(projectUuid);
 
-    const communityRepository =
+    const community = await this.communityRepository.findOneBy({
-      queryRunner?.manager.getRepository(CommunityEntity) ||
-      this.communityRepository;
-    const community = await communityRepository.findOneBy({
       uuid: communityUuid,
     });
 
@@ -103,36 +93,56 @@ export class CommunityService {
   }
 
   async getCommunities(
-    { projectUuid }: ProjectParam,
+    param: ProjectParam,
     pageable: Partial<ExtendedTypeORMCustomModelFindAllQuery>,
   ): Promise<BaseResponseDto> {
     try {
-      const project = await this.validateProject(projectUuid);
+      const project = await this.validateProject(param.projectUuid);
 
-      /**
+      pageable.modelName = 'community';
-       * TODO: removing this breaks the code (should be fixed when refactoring @see TypeORMCustomModel
+      pageable.where = {
-       */
+        project: { uuid: param.projectUuid },
-      pageable.where = {};
+        name: Not(`${ORPHAN_COMMUNITY_NAME}-${project.name}`),
-      let qb: undefined | SelectQueryBuilder<CommunityEntity> = undefined;
+      };
 
-      qb = this.communityRepository
-        .createQueryBuilder('c')
-        .leftJoin('c.spaces', 's', 's.disabled = false')
-        .where('c.project = :projectUuid', { projectUuid })
-        .andWhere(`c.name != '${ORPHAN_COMMUNITY_NAME}-${project.name}'`)
-        .distinct(true);
       if (pageable.search) {
-        qb.andWhere(
+        const matchingCommunities = await this.communityRepository.find({
-          `c.name ILIKE '%${pageable.search}%' OR s.space_name ILIKE '%${pageable.search}%'`,
+          where: {
-        );
+            project: { uuid: param.projectUuid },
-      }
+            name: ILike(`%${pageable.search}%`),
+          },
+        });
 
+        const matchingSpaces = await this.spaceRepository.find({
+          where: {
+            spaceName: ILike(`%${pageable.search}%`),
+            disabled: false,
+            community: { project: { uuid: param.projectUuid } },
+          },
+          relations: ['community'],
+        });
+
+        const spaceCommunityUuids = [
+          ...new Set(matchingSpaces.map((space) => space.community.uuid)),
+        ];
+
+        const allMatchedCommunityUuids = [
+          ...new Set([
+            ...matchingCommunities.map((c) => c.uuid),
+            ...spaceCommunityUuids,
+          ]),
+        ];
+
+        pageable.where = {
+          ...pageable.where,
+          uuid: In(allMatchedCommunityUuids),
+        };
+      }
       const customModel = TypeORMCustomModel(this.communityRepository);
 
       const { baseResponseDto, paginationResponseDto } =
-        await customModel.findAll({ ...pageable, modelName: 'community' }, qb);
+        await customModel.findAll(pageable);
 
-      // todo: refactor this to minimize the number of queries
       if (pageable.includeSpaces) {
         const communitiesWithSpaces = await Promise.all(
           baseResponseDto.data.map(async (community: CommunityDto) => {
@@ -140,7 +150,7 @@ export class CommunityService {
               await this.spaceService.getSpacesHierarchyForCommunity(
                 {
                   communityUuid: community.uuid,
-                  projectUuid: projectUuid,
+                  projectUuid: param.projectUuid,
                 },
                 {
                   onlyWithDevices: false,
@@ -170,75 +180,6 @@ export class CommunityService {
     }
   }
 
-  async getCommunitiesV2(
-    { projectUuid }: ProjectParam,
-    {
-      search,
-      includeSpaces,
-      ...pageable
-    }: Partial<ExtendedTypeORMCustomModelFindAllQuery>,
-  ) {
-    try {
-      const project = await this.validateProject(projectUuid);
-
-      let qb: undefined | SelectQueryBuilder<CommunityEntity> = undefined;
-
-      qb = this.communityRepository
-        .createQueryBuilder('c')
-        .where('c.project = :projectUuid', { projectUuid })
-        .andWhere(`c.name != '${ORPHAN_COMMUNITY_NAME}-${project.name}'`)
-        .distinct(true);
-
-      if (includeSpaces) {
-        qb.leftJoinAndSelect(
-          'c.spaces',
-          'space',
-          'space.disabled = :disabled AND space.spaceName != :orphanSpaceName',
-          { disabled: false, orphanSpaceName: ORPHAN_SPACE_NAME },
-        )
-          .leftJoinAndSelect('space.parent', 'parent')
-          .leftJoinAndSelect(
-            'space.children',
-            'children',
-            'children.disabled = :disabled',
-            { disabled: false },
-          );
-        // .leftJoinAndSelect('space.spaceModel', 'spaceModel')
-      }
-
-      if (search) {
-        qb.andWhere(
-          `c.name ILIKE :search ${includeSpaces ? 'OR space.space_name ILIKE :search' : ''}`,
-          { search },
-        );
-      }
-
-      const customModel = TypeORMCustomModel(this.communityRepository);
-
-      const { baseResponseDto, paginationResponseDto } =
-        await customModel.findAll({ ...pageable, modelName: 'community' }, qb);
-      if (includeSpaces) {
-        baseResponseDto.data = baseResponseDto.data.map((community) => ({
-          ...community,
-          spaces: this.spaceService.buildSpaceHierarchy(community.spaces || []),
-        }));
-      }
-      return new PageResponse<CommunityDto>(
-        baseResponseDto,
-        paginationResponseDto,
-      );
-    } catch (error) {
-      // Generic error handling
-      if (error instanceof HttpException) {
-        throw error;
-      }
-      throw new HttpException(
-        error.message || 'An error occurred while fetching communities.',
-        HttpStatus.INTERNAL_SERVER_ERROR,
-      );
-    }
-  }
-
   async updateCommunity(
     params: GetCommunityParams,
     updateCommunityDto: UpdateCommunityNameDto,

src/device/commands/cur2-commands.ts

@@ -1,28 +0,0 @@
-interface BaseCommand {
-  code: string;
-  value: any;
-}
-export interface ControlCur2Command extends BaseCommand {
-  code: 'control';
-  value: 'open' | 'close' | 'stop';
-}
-export interface ControlCur2PercentCommand extends BaseCommand {
-  code: 'percent_control';
-  value: 10 | 20 | 30 | 40 | 50 | 60 | 70 | 80 | 90 | 100;
-}
-export interface ControlCur2AccurateCalibrationCommand extends BaseCommand {
-  code: 'accurate_calibration';
-  value: 'start' | 'end'; // Assuming this is a numeric value for calibration
-}
-export interface ControlCur2TDirectionConCommand extends BaseCommand {
-  code: 'control_t_direction_con';
-  value: 'forward' | 'back';
-}
-export interface ControlCur2QuickCalibrationCommand extends BaseCommand {
-  code: 'tr_timecon';
-  value: number; // between 10 and 120
-}
-export interface ControlCur2MotorModeCommand extends BaseCommand {
-  code: 'elec_machinery_mode';
-  value: 'strong_power' | 'dry_contact';
-}

src/device/controllers/device-project.controller.ts

@@ -1,11 +1,11 @@
-import { ControllerRoute } from '@app/common/constants/controller-route';
-import { EnableDisableStatusEnum } from '@app/common/constants/days.enum';
-import { Controller, Get, Param, Query, UseGuards } from '@nestjs/common';
-import { ApiBearerAuth, ApiOperation, ApiTags } from '@nestjs/swagger';
-import { Permissions } from 'src/decorators/permissions.decorator';
-import { PermissionsGuard } from 'src/guards/permissions.guard';
-import { GetDevicesFilterDto, ProjectParam } from '../dtos';
 import { DeviceService } from '../services/device.service';
+import { Controller, Get, Param, Query, UseGuards } from '@nestjs/common';
+import { ApiTags, ApiBearerAuth, ApiOperation } from '@nestjs/swagger';
+import { EnableDisableStatusEnum } from '@app/common/constants/days.enum';
+import { ControllerRoute } from '@app/common/constants/controller-route';
+import { PermissionsGuard } from 'src/guards/permissions.guard';
+import { Permissions } from 'src/decorators/permissions.decorator';
+import { GetDoorLockDevices, ProjectParam } from '../dtos';
 
 @ApiTags('Device Module')
 @Controller({
@@ -25,7 +25,7 @@ export class DeviceProjectController {
   })
   async getAllDevices(
     @Param() param: ProjectParam,
-    @Query() query: GetDevicesFilterDto,
+    @Query() query: GetDoorLockDevices,
   ) {
     return await this.deviceService.getAllDevices(param, query);
   }

src/device/dtos/get.device.dto.ts

@@ -1,7 +1,6 @@
 import { DeviceTypeEnum } from '@app/common/constants/device-type.enum';
 import { ApiProperty } from '@nestjs/swagger';
 import {
-  IsArray,
   IsEnum,
   IsNotEmpty,
   IsOptional,
@@ -42,7 +41,16 @@ export class GetDeviceLogsDto {
   @IsOptional()
   public endTime: string;
 }
-
+export class GetDoorLockDevices {
+  @ApiProperty({
+    description: 'Device Type',
+    enum: DeviceTypeEnum,
+    required: false,
+  })
+  @IsEnum(DeviceTypeEnum)
+  @IsOptional()
+  public deviceType: DeviceTypeEnum;
+}
 export class GetDevicesBySpaceOrCommunityDto {
   @ApiProperty({
     description: 'Device Product Type',
@@ -64,23 +72,3 @@ export class GetDevicesBySpaceOrCommunityDto {
   @IsNotEmpty({ message: 'Either spaceUuid or communityUuid must be provided' })
   requireEither?: never; // This ensures at least one of them is provided
 }
-
-export class GetDevicesFilterDto {
-  @ApiProperty({
-    description: 'Device Type',
-    enum: DeviceTypeEnum,
-    required: false,
-  })
-  @IsEnum(DeviceTypeEnum)
-  @IsOptional()
-  public deviceType: DeviceTypeEnum;
-  @ApiProperty({
-    description: 'List of Space IDs to filter devices',
-    required: false,
-    example: ['60d21b4667d0d8992e610c85', '60d21b4967d0d8992e610c86'],
-  })
-  @IsOptional()
-  @IsArray()
-  @IsUUID('4', { each: true })
-  public spaces?: string[];
-}

src/device/services/device.service.ts

@@ -1,46 +1,39 @@
-import { AUTOMATION_CONFIG } from '@app/common/constants/automation.enum';
+import { ORPHAN_SPACE_NAME } from './../../../libs/common/src/constants/orphan-constant';
-import { BatchDeviceTypeEnum } from '@app/common/constants/batch-device.enum';
+import { ProductRepository } from './../../../libs/common/src/modules/product/repositories/product.repository';
-import { BatteryStatus } from '@app/common/constants/battery-status.enum';
-import { DeviceStatuses } from '@app/common/constants/device-status.enum';
-import { DeviceTypeEnum } from '@app/common/constants/device-type.enum';
-import { CommonErrorCodes } from '@app/common/constants/error-codes.enum';
-import { ProductType } from '@app/common/constants/product-type.enum';
-import { SceneSwitchesTypeEnum } from '@app/common/constants/scene-switch-type.enum';
-import { BaseResponseDto } from '@app/common/dto/base.response.dto';
-import { SuccessResponseDto } from '@app/common/dto/success.response.dto';
-import { DeviceStatusFirebaseService } from '@app/common/firebase/devices-status/services/devices-status.service';
-import { convertKeysToCamelCase } from '@app/common/helper/camelCaseConverter';
-import { TuyaService } from '@app/common/integrations/tuya/services/tuya.service';
-import { CommunityRepository } from '@app/common/modules/community/repositories';
-import { DeviceEntity } from '@app/common/modules/device/entities';
-import { DeviceRepository } from '@app/common/modules/device/repositories';
-import { ProjectEntity } from '@app/common/modules/project/entities';
-import { ProjectRepository } from '@app/common/modules/project/repositiories';
-import { SceneDeviceRepository } from '@app/common/modules/scene-device/repositories';
-import { SpaceEntity } from '@app/common/modules/space/entities/space.entity';
-import { SpaceRepository } from '@app/common/modules/space/repositories';
-import { addSpaceUuidToDevices } from '@app/common/util/device-utils';
 import {
-  BadRequestException,
+  Injectable,
-  forwardRef,
   HttpException,
   HttpStatus,
-  Inject,
-  Injectable,
   NotFoundException,
+  BadRequestException,
+  forwardRef,
+  Inject,
 } from '@nestjs/common';
-import { ConfigService } from '@nestjs/config';
 import { TuyaContext } from '@tuya/tuya-connector-nodejs';
-import { AddAutomationDto } from 'src/automation/dtos';
+import { ConfigService } from '@nestjs/config';
-import { SceneService } from 'src/scene/services';
-import { In, Not, QueryRunner } from 'typeorm';
-import { ProjectParam } from '../dtos';
 import {
   AddDeviceDto,
   AddSceneToFourSceneDeviceDto,
-  AssignDeviceToSpaceDto,
   UpdateDeviceDto,
+  AssignDeviceToSpaceDto,
 } from '../dtos/add.device.dto';
+import {
+  DeviceInstructionResponse,
+  GetDeviceDetailsFunctionsInterface,
+  GetDeviceDetailsFunctionsStatusInterface,
+  GetDeviceDetailsInterface,
+  GetMacAddressInterface,
+  GetPowerClampFunctionsStatusInterface,
+  controlDeviceInterface,
+  getDeviceLogsInterface,
+  updateDeviceFirmwareInterface,
+} from '../interfaces/get.device.interface';
+import {
+  GetDeviceBySpaceUuidDto,
+  GetDeviceLogsDto,
+  GetDevicesBySpaceOrCommunityDto,
+  GetDoorLockDevices,
+} from '../dtos/get.device.dto';
 import {
   BatchControlDevicesDto,
   BatchFactoryResetDevicesDto,
@@ -48,29 +41,33 @@ import {
   ControlDeviceDto,
   GetSceneFourSceneDeviceDto,
 } from '../dtos/control.device.dto';
-import { DeleteSceneFromSceneDeviceDto } from '../dtos/delete.device.dto';
+import { convertKeysToCamelCase } from '@app/common/helper/camelCaseConverter';
+import { DeviceRepository } from '@app/common/modules/device/repositories';
+import { In, Not, QueryRunner } from 'typeorm';
+import { ProductType } from '@app/common/constants/product-type.enum';
+import { SpaceRepository } from '@app/common/modules/space/repositories';
+import { DeviceStatusFirebaseService } from '@app/common/firebase/devices-status/services/devices-status.service';
+import { DeviceStatuses } from '@app/common/constants/device-status.enum';
+import { CommonErrorCodes } from '@app/common/constants/error-codes.enum';
+import { BatteryStatus } from '@app/common/constants/battery-status.enum';
+import { SceneService } from 'src/scene/services';
+import { AddAutomationDto } from 'src/automation/dtos';
+import { TuyaService } from '@app/common/integrations/tuya/services/tuya.service';
+import { SceneDeviceRepository } from '@app/common/modules/scene-device/repositories';
+import { SceneSwitchesTypeEnum } from '@app/common/constants/scene-switch-type.enum';
+import { AUTOMATION_CONFIG } from '@app/common/constants/automation.enum';
 import { DeviceSceneParamDto } from '../dtos/device.param.dto';
-import {
+import { BaseResponseDto } from '@app/common/dto/base.response.dto';
-  GetDeviceLogsDto,
+import { SuccessResponseDto } from '@app/common/dto/success.response.dto';
-  GetDevicesBySpaceOrCommunityDto,
+import { DeleteSceneFromSceneDeviceDto } from '../dtos/delete.device.dto';
-  GetDevicesFilterDto,
+import { DeviceEntity } from '@app/common/modules/device/entities';
-} from '../dtos/get.device.dto';
+import { SpaceEntity } from '@app/common/modules/space/entities/space.entity';
-import {
+import { ProjectRepository } from '@app/common/modules/project/repositiories';
-  controlDeviceInterface,
+import { ProjectParam } from '../dtos';
-  DeviceInstructionResponse,
+import { BatchDeviceTypeEnum } from '@app/common/constants/batch-device.enum';
-  GetDeviceDetailsFunctionsInterface,
+import { DeviceTypeEnum } from '@app/common/constants/device-type.enum';
-  GetDeviceDetailsFunctionsStatusInterface,
+import { CommunityRepository } from '@app/common/modules/community/repositories';
-  GetDeviceDetailsInterface,
+import { addSpaceUuidToDevices } from '@app/common/util/device-utils';
-  getDeviceLogsInterface,
-  GetMacAddressInterface,
-  GetPowerClampFunctionsStatusInterface,
-  updateDeviceFirmwareInterface,
-} from '../interfaces/get.device.interface';
-import {
-  ORPHAN_COMMUNITY_NAME,
-  ORPHAN_SPACE_NAME,
-} from './../../../libs/common/src/constants/orphan-constant';
-import { ProductRepository } from './../../../libs/common/src/modules/product/repositories/product.repository';
 
 @Injectable()
 export class DeviceService {
@@ -201,6 +198,46 @@ export class DeviceService {
     }
   }
 
+  async getDevicesBySpaceId(
+    getDeviceBySpaceUuidDto: GetDeviceBySpaceUuidDto,
+  ): Promise<GetDeviceDetailsInterface[]> {
+    try {
+      const devices = await this.deviceRepository.find({
+        where: {
+          spaceDevice: { uuid: getDeviceBySpaceUuidDto.spaceUuid },
+          isActive: true,
+        },
+        relations: [
+          'spaceDevice',
+          'productDevice',
+          'permission',
+          'permission.permissionType',
+        ],
+      });
+      const devicesData = await Promise.all(
+        devices.map(async (device) => {
+          return {
+            haveRoom: device.spaceDevice ? true : false,
+            productUuid: device.productDevice.uuid,
+            productType: device.productDevice.prodType,
+            permissionType: device.permission[0].permissionType.type,
+            ...(await this.getDeviceDetailsByDeviceIdTuya(
+              device.deviceTuyaUuid,
+            )),
+            uuid: device.uuid,
+          } as GetDeviceDetailsInterface;
+        }),
+      );
+
+      return devicesData;
+    } catch (error) {
+      // Handle the error here
+      throw new HttpException(
+        'Error fetching devices by space',
+        HttpStatus.INTERNAL_SERVER_ERROR,
+      );
+    }
+  }
   async transferDeviceInSpaces(
     assignDeviceToSpaceDto: AssignDeviceToSpaceDto,
     projectUuid: string,
@@ -955,20 +992,19 @@ export class DeviceService {
 
   async getAllDevices(
     param: ProjectParam,
-    { deviceType, spaces }: GetDevicesFilterDto,
+    query: GetDoorLockDevices,
   ): Promise<BaseResponseDto> {
     try {
       await this.validateProject(param.projectUuid);
-      if (deviceType === DeviceTypeEnum.DOOR_LOCK) {
+      if (query.deviceType === DeviceTypeEnum.DOOR_LOCK) {
-        return await this.getDoorLockDevices(param.projectUuid, spaces);
+        return await this.getDoorLockDevices(param.projectUuid);
-      } else if (!deviceType) {
+      } else if (!query.deviceType) {
         const devices = await this.deviceRepository.find({
           where: {
             isActive: true,
             spaceDevice: {
-              uuid: spaces && spaces.length ? In(spaces) : undefined,
-              spaceName: Not(ORPHAN_SPACE_NAME),
               community: { project: { uuid: param.projectUuid } },
+              spaceName: Not(ORPHAN_SPACE_NAME),
             },
           },
           relations: [
@@ -1163,6 +1199,39 @@ export class DeviceService {
     }
   }
 
+  async getFullSpaceHierarchy(
+    space: SpaceEntity,
+  ): Promise<{ uuid: string; spaceName: string }[]> {
+    try {
+      // Fetch only the relevant spaces, starting with the target space
+      const targetSpace = await this.spaceRepository.findOne({
+        where: { uuid: space.uuid },
+        relations: ['parent', 'children'],
+      });
+
+      // Fetch only the ancestors of the target space
+      const ancestors = await this.fetchAncestors(targetSpace);
+
+      // Optionally, fetch descendants if required
+      const descendants = await this.fetchDescendants(targetSpace);
+
+      const fullHierarchy = [...ancestors, targetSpace, ...descendants].map(
+        (space) => ({
+          uuid: space.uuid,
+          spaceName: space.spaceName,
+        }),
+      );
+
+      return fullHierarchy;
+    } catch (error) {
+      console.error('Error fetching space hierarchy:', error.message);
+      throw new HttpException(
+        'Error fetching space hierarchy',
+        HttpStatus.INTERNAL_SERVER_ERROR,
+      );
+    }
+  }
+
   async getPowerClampInstructionStatus(deviceDetails: any) {
     try {
       const deviceStatus = await this.getPowerClampInstructionStatusTuya(
@@ -1262,6 +1331,27 @@ export class DeviceService {
     return ancestors.reverse();
   }
 
+  private async fetchDescendants(space: SpaceEntity): Promise<SpaceEntity[]> {
+    const descendants: SpaceEntity[] = [];
+
+    // Fetch the immediate children of the current space
+    const children = await this.spaceRepository.find({
+      where: { parent: { uuid: space.uuid } },
+      relations: ['children'], // To continue fetching downwards
+    });
+
+    for (const child of children) {
+      // Add the child to the descendants list
+      descendants.push(child);
+
+      // Recursively fetch the child's descendants
+      const childDescendants = await this.fetchDescendants(child);
+      descendants.push(...childDescendants);
+    }
+
+    return descendants;
+  }
+
   async addSceneToSceneDevice(
     deviceUuid: string,
     addSceneToFourSceneDeviceDto: AddSceneToFourSceneDeviceDto,
@@ -1564,7 +1654,23 @@ export class DeviceService {
     }
   }
 
-  async getDoorLockDevices(projectUuid: string, spaces?: string[]) {
+  async moveDevicesToSpace(
+    targetSpace: SpaceEntity,
+    deviceIds: string[],
+  ): Promise<void> {
+    if (!deviceIds || deviceIds.length === 0) {
+      throw new HttpException(
+        'No device IDs provided for transfer',
+        HttpStatus.BAD_REQUEST,
+      );
+    }
+
+    await this.deviceRepository.update(
+      { uuid: In(deviceIds) },
+      { spaceDevice: targetSpace },
+    );
+  }
+  async getDoorLockDevices(projectUuid: string) {
     await this.validateProject(projectUuid);
 
     const devices = await this.deviceRepository.find({
@@ -1574,7 +1680,6 @@ export class DeviceService {
         },
         spaceDevice: {
           spaceName: Not(ORPHAN_SPACE_NAME),
-          uuid: spaces && spaces.length ? In(spaces) : undefined,
           community: {
             project: {
               uuid: projectUuid,
@@ -1755,39 +1860,4 @@ export class DeviceService {
 
     return allDevices;
   }
-
-  async addDevicesToOrphanSpace(
-    space: SpaceEntity,
-    project: ProjectEntity,
-    queryRunner: QueryRunner,
-  ) {
-    const spaceRepository = queryRunner.manager.getRepository(SpaceEntity);
-    const deviceRepository = queryRunner.manager.getRepository(DeviceEntity);
-    try {
-      const orphanSpace = await spaceRepository.findOne({
-        where: {
-          community: {
-            name: `${ORPHAN_COMMUNITY_NAME}-${project.name}`,
-          },
-          spaceName: ORPHAN_SPACE_NAME,
-        },
-      });
-
-      if (!orphanSpace) {
-        throw new HttpException(
-          `Orphan space not found in community ${project.name}`,
-          HttpStatus.NOT_FOUND,
-        );
-      }
-
-      await deviceRepository.update(
-        { uuid: In(space.devices.map((device) => device.uuid)) },
-        { spaceDevice: orphanSpace },
-      );
-    } catch (error) {
-      throw new Error(
-        `Failed to add devices to orphan spaces: ${error.message}`,
-      );
-    }
-  }
 }

src/door-lock/door.lock.module.ts

@@ -29,9 +29,6 @@ import {
 import { SqlLoaderService } from '@app/common/helper/services/sql-loader.service';
 import { OccupancyService } from '@app/common/helper/services/occupancy.service';
 import { CommunityRepository } from '@app/common/modules/community/repositories';
-import { AqiDataService } from '@app/common/helper/services/aqi.data.service';
-import { PresenceSensorDailySpaceRepository } from '@app/common/modules/presence-sensor/repositories';
-import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/repositories';
 @Module({
   imports: [ConfigModule, DeviceRepositoryModule],
   controllers: [DoorLockController],
@@ -59,9 +56,6 @@ import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/r
     SqlLoaderService,
     OccupancyService,
     CommunityRepository,
-    AqiDataService,
-    PresenceSensorDailySpaceRepository,
-    AqiSpaceDailyPollutantStatsRepository,
   ],
   exports: [DoorLockService],
 })

src/group/group.module.ts

@@ -27,9 +27,6 @@ import {
 import { SqlLoaderService } from '@app/common/helper/services/sql-loader.service';
 import { OccupancyService } from '@app/common/helper/services/occupancy.service';
 import { CommunityRepository } from '@app/common/modules/community/repositories';
-import { AqiDataService } from '@app/common/helper/services/aqi.data.service';
-import { PresenceSensorDailySpaceRepository } from '@app/common/modules/presence-sensor/repositories';
-import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/repositories';
 @Module({
   imports: [ConfigModule, DeviceRepositoryModule],
   controllers: [GroupController],
@@ -56,9 +53,6 @@ import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/r
     SqlLoaderService,
     OccupancyService,
     CommunityRepository,
-    AqiDataService,
-    PresenceSensorDailySpaceRepository,
-    AqiSpaceDailyPollutantStatsRepository,
   ],
   exports: [GroupService],
 })

src/invite-user/invite-user.module.ts

@@ -1,89 +1,89 @@
 import { Module } from '@nestjs/common';
-import { ConfigModule } from '@nestjs/config';
-import { InviteUserController } from './controllers/invite-user.controller';
 import { InviteUserService } from './services/invite-user.service';
+import { InviteUserController } from './controllers/invite-user.controller';
+import { ConfigModule } from '@nestjs/config';
 
-import { DeviceStatusFirebaseService } from '@app/common/firebase/devices-status/services/devices-status.service';
-import { AqiDataService } from '@app/common/helper/services/aqi.data.service';
-import { OccupancyService } from '@app/common/helper/services/occupancy.service';
-import { PowerClampService } from '@app/common/helper/services/power.clamp.service';
-import { SqlLoaderService } from '@app/common/helper/services/sql-loader.service';
-import { TuyaService } from '@app/common/integrations/tuya/services/tuya.service';
-import { AutomationRepository } from '@app/common/modules/automation/repositories';
-import { CommunityRepository } from '@app/common/modules/community/repositories';
-import { DeviceStatusLogRepository } from '@app/common/modules/device-status-log/repositories';
 import {
-  DeviceRepository,
+  UserRepository,
-  DeviceUserPermissionRepository,
+  UserSpaceRepository,
-} from '@app/common/modules/device/repositories';
+} from '@app/common/modules/user/repositories';
 import { InviteUserRepositoryModule } from '@app/common/modules/Invite-user/Invite-user.repository.module';
 import {
   InviteUserRepository,
   InviteUserSpaceRepository,
 } from '@app/common/modules/Invite-user/repositiories';
-import { PermissionTypeRepository } from '@app/common/modules/permission/repositories';
-import {
-  PowerClampDailyRepository,
-  PowerClampHourlyRepository,
-  PowerClampMonthlyRepository,
-} from '@app/common/modules/power-clamp/repositories';
-import { ProductRepository } from '@app/common/modules/product/repositories';
-import { ProjectRepository } from '@app/common/modules/project/repositiories';
-import { RegionRepository } from '@app/common/modules/region/repositories';
-import { RoleTypeRepository } from '@app/common/modules/role-type/repositories';
-import { SceneDeviceRepository } from '@app/common/modules/scene-device/repositories';
-import {
-  SceneIconRepository,
-  SceneRepository,
-} from '@app/common/modules/scene/repositories';
-import {
-  InviteSpaceRepository,
-  SpaceLinkRepository,
-  SpaceProductAllocationRepository,
-  SpaceRepository,
-} from '@app/common/modules/space';
-import {
-  SpaceModelProductAllocationRepoitory,
-  SpaceModelRepository,
-  SubspaceModelProductAllocationRepoitory,
-  SubspaceModelRepository,
-} from '@app/common/modules/space-model';
-import {
-  SubspaceProductAllocationRepository,
-  SubspaceRepository,
-} from '@app/common/modules/space/repositories/subspace.repository';
-import { NewTagRepository } from '@app/common/modules/tag/repositories/tag-repository';
-import { TimeZoneRepository } from '@app/common/modules/timezone/repositories';
-import {
-  UserRepository,
-  UserSpaceRepository,
-} from '@app/common/modules/user/repositories';
 import { EmailService } from '@app/common/util/email.service';
-import { CommunityModule } from 'src/community/community.module';
-import { CommunityService } from 'src/community/services';
-import { DeviceService } from 'src/device/services';
-import { ProjectUserService } from 'src/project/services/project-user.service';
-import { SceneService } from 'src/scene/services';
-import {
-  SpaceModelService,
-  SubSpaceModelService,
-} from 'src/space-model/services';
-import { SpaceModelProductAllocationService } from 'src/space-model/services/space-model-product-allocation.service';
-import { SubspaceModelProductAllocationService } from 'src/space-model/services/subspace/subspace-model-product-allocation.service';
 import {
+  SpaceLinkService,
   SpaceService,
   SpaceUserService,
   SubspaceDeviceService,
   SubSpaceService,
   ValidationService,
 } from 'src/space/services';
-import { SpaceProductAllocationService } from 'src/space/services/space-product-allocation.service';
+import { CommunityService } from 'src/community/services';
-import { SubspaceProductAllocationService } from 'src/space/services/subspace/subspace-product-allocation.service';
+import {
-import { TagService as NewTagService } from 'src/tags/services';
+  InviteSpaceRepository,
-import { UserDevicePermissionService } from 'src/user-device-permission/services';
+  SpaceLinkRepository,
+  SpaceProductAllocationRepository,
+  SpaceRepository,
+  TagRepository,
+} from '@app/common/modules/space';
+import { SpaceModelRepository } from '@app/common/modules/space-model';
+import { CommunityRepository } from '@app/common/modules/community/repositories';
+import { ProjectRepository } from '@app/common/modules/project/repositiories';
+import { TuyaService } from '@app/common/integrations/tuya/services/tuya.service';
 import { UserService, UserSpaceService } from 'src/users/services';
-import { PresenceSensorDailySpaceRepository } from '@app/common/modules/presence-sensor/repositories';
+import { UserDevicePermissionService } from 'src/user-device-permission/services';
-import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/repositories';
+import {
+  DeviceRepository,
+  DeviceUserPermissionRepository,
+} from '@app/common/modules/device/repositories';
+import { PermissionTypeRepository } from '@app/common/modules/permission/repositories';
+import { ProjectUserService } from 'src/project/services/project-user.service';
+import { RoleTypeRepository } from '@app/common/modules/role-type/repositories';
+import { RegionRepository } from '@app/common/modules/region/repositories';
+import { TimeZoneRepository } from '@app/common/modules/timezone/repositories';
+import { CommunityModule } from 'src/community/community.module';
+import { TagService as NewTagService } from 'src/tags/services';
+import { TagService } from 'src/space/services/tag';
+import {
+  SpaceModelService,
+  SubSpaceModelService,
+} from 'src/space-model/services';
+import { SpaceProductAllocationService } from 'src/space/services/space-product-allocation.service';
+import {
+  SubspaceProductAllocationRepository,
+  SubspaceRepository,
+} from '@app/common/modules/space/repositories/subspace.repository';
+import { SubspaceProductAllocationService } from 'src/space/services/subspace/subspace-product-allocation.service';
+import {
+  SpaceModelProductAllocationRepoitory,
+  SubspaceModelProductAllocationRepoitory,
+  SubspaceModelRepository,
+} from '@app/common/modules/space-model';
+import { NewTagRepository } from '@app/common/modules/tag/repositories/tag-repository';
+import { ProductRepository } from '@app/common/modules/product/repositories';
+import { SpaceModelProductAllocationService } from 'src/space-model/services/space-model-product-allocation.service';
+import { SubspaceModelProductAllocationService } from 'src/space-model/services/subspace/subspace-model-product-allocation.service';
+import { DeviceService } from 'src/device/services';
+import { SceneDeviceRepository } from '@app/common/modules/scene-device/repositories';
+import { DeviceStatusFirebaseService } from '@app/common/firebase/devices-status/services/devices-status.service';
+import { SceneService } from 'src/scene/services';
+import { DeviceStatusLogRepository } from '@app/common/modules/device-status-log/repositories';
+import {
+  SceneIconRepository,
+  SceneRepository,
+} from '@app/common/modules/scene/repositories';
+import { AutomationRepository } from '@app/common/modules/automation/repositories';
+import {
+  PowerClampHourlyRepository,
+  PowerClampDailyRepository,
+  PowerClampMonthlyRepository,
+} from '@app/common/modules/power-clamp/repositories';
+import { PowerClampService } from '@app/common/helper/services/power.clamp.service';
+import { SqlLoaderService } from '@app/common/helper/services/sql-loader.service';
+import { OccupancyService } from '@app/common/helper/services/occupancy.service';
 
 @Module({
   imports: [ConfigModule, InviteUserRepositoryModule, CommunityModule],
@@ -116,6 +116,7 @@ import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/r
     TimeZoneRepository,
     SpaceService,
     InviteSpaceRepository,
+    SpaceLinkService,
     SubSpaceService,
     ValidationService,
     NewTagService,
@@ -123,6 +124,7 @@ import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/r
     SpaceProductAllocationService,
     SpaceLinkRepository,
     SubspaceRepository,
+    TagService,
     SubspaceDeviceService,
     SubspaceProductAllocationService,
     SpaceModelRepository,
@@ -133,6 +135,7 @@ import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/r
     SpaceModelProductAllocationService,
     SpaceProductAllocationRepository,
     SubspaceProductAllocationRepository,
+    TagRepository,
     SubspaceModelRepository,
     SubspaceModelProductAllocationService,
     SpaceModelProductAllocationRepoitory,
@@ -151,9 +154,6 @@ import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/r
     PowerClampMonthlyRepository,
     SqlLoaderService,
     OccupancyService,
-    AqiDataService,
-    PresenceSensorDailySpaceRepository,
-    AqiSpaceDailyPollutantStatsRepository,
   ],
   exports: [InviteUserService],
 })

src/invite-user/services/invite-user.service.ts

@@ -1,42 +1,36 @@
-import { RoleType } from '@app/common/constants/role.type.enum';
+import {
-import { UserStatusEnum } from '@app/common/constants/user-status.enum';
+  Injectable,
+  HttpException,
+  HttpStatus,
+  BadRequestException,
+} from '@nestjs/common';
+import { AddUserInvitationDto } from '../dtos';
 import { BaseResponseDto } from '@app/common/dto/base.response.dto';
+import { UserStatusEnum } from '@app/common/constants/user-status.enum';
 import { SuccessResponseDto } from '@app/common/dto/success.response.dto';
 import { generateRandomString } from '@app/common/helper/randomString';
-import { InviteUserEntity } from '@app/common/modules/Invite-user/entities';
+import { EntityManager, In, IsNull, Not, QueryRunner } from 'typeorm';
+import { DataSource } from 'typeorm';
+import { UserEntity } from '@app/common/modules/user/entities';
+import { RoleType } from '@app/common/constants/role.type.enum';
 import {
   InviteUserRepository,
   InviteUserSpaceRepository,
 } from '@app/common/modules/Invite-user/repositiories';
-import { RoleTypeRepository } from '@app/common/modules/role-type/repositories';
+import { CheckEmailDto } from '../dtos/check-email.dto';
-import { SpaceRepository } from '@app/common/modules/space';
-import { SpaceEntity } from '@app/common/modules/space/entities/space.entity';
-import { UserEntity } from '@app/common/modules/user/entities';
 import { UserRepository } from '@app/common/modules/user/repositories';
 import { EmailService } from '@app/common/util/email.service';
-import {
+import { SpaceRepository } from '@app/common/modules/space';
-  BadRequestException,
-  HttpException,
-  HttpStatus,
-  Injectable,
-} from '@nestjs/common';
-import { SpaceUserService } from 'src/space/services';
-import { UserSpaceService } from 'src/users/services';
-import {
-  DataSource,
-  EntityManager,
-  In,
-  IsNull,
-  Not,
-  QueryRunner,
-} from 'typeorm';
-import { AddUserInvitationDto } from '../dtos';
 import { ActivateCodeDto } from '../dtos/active-code.dto';
-import { CheckEmailDto } from '../dtos/check-email.dto';
+import { UserSpaceService } from 'src/users/services';
+import { SpaceUserService } from 'src/space/services';
 import {
   DisableUserInvitationDto,
   UpdateUserInvitationDto,
 } from '../dtos/update.invite-user.dto';
+import { RoleTypeRepository } from '@app/common/modules/role-type/repositories';
+import { InviteUserEntity } from '@app/common/modules/Invite-user/entities';
+import { SpaceEntity } from '@app/common/modules/space/entities/space.entity';
 
 @Injectable()
 export class InviteUserService {
@@ -664,12 +658,12 @@ export class InviteUserService {
           HttpStatus.BAD_REQUEST,
         );
       }
-      await this.emailService.sendEmailWithTemplate({
+      await this.emailService.sendEmailWithTemplate(
-        email: userData.email,
+        userData.email,
-        name: userData.firstName,
+        userData.firstName,
-        isEnable: !disable,
+        disable,
-        isDelete: false,
+        false,
-      });
+      );
       await queryRunner.commitTransaction();
 
       return new SuccessResponseDto({
@@ -803,12 +797,12 @@ export class InviteUserService {
           { isActive: false },
         );
       }
-      await this.emailService.sendEmailWithTemplate({
+      await this.emailService.sendEmailWithTemplate(
-        email: userData.email,
+        userData.email,
-        name: userData.firstName,
+        userData.firstName,
-        isEnable: false,
+        false,
-        isDelete: true,
+        true,
-      });
+      );
       await queryRunner.commitTransaction();
 
       return new SuccessResponseDto({

src/main.ts

@@ -1,13 +1,15 @@
-import { RequestContextMiddleware } from '@app/common/middleware/request-context.middleware';
-import { SeederService } from '@app/common/seed/services/seeder.service';
-import { Logger, ValidationPipe } from '@nestjs/common';
 import { NestFactory } from '@nestjs/core';
-import { json, urlencoded } from 'body-parser';
-import helmet from 'helmet';
-import { WINSTON_MODULE_NEST_PROVIDER } from 'nest-winston';
-import { setupSwaggerAuthentication } from '../libs/common/src/util/user-auth.swagger.utils';
 import { AppModule } from './app.module';
+import rateLimit from 'express-rate-limit';
+import helmet from 'helmet';
+import { setupSwaggerAuthentication } from '../libs/common/src/util/user-auth.swagger.utils';
+import { ValidationPipe } from '@nestjs/common';
+import { json, urlencoded } from 'body-parser';
+import { SeederService } from '@app/common/seed/services/seeder.service';
 import { HttpExceptionFilter } from './common/filters/http-exception/http-exception.filter';
+import { Logger } from '@nestjs/common';
+import { WINSTON_MODULE_NEST_PROVIDER } from 'nest-winston';
+import { RequestContextMiddleware } from '@app/common/middleware/request-context.middleware';
 
 async function bootstrap() {
   const app = await NestFactory.create(AppModule);
@@ -21,6 +23,13 @@ async function bootstrap() {
 
   app.use(new RequestContextMiddleware().use);
 
+  app.use(
+    rateLimit({
+      windowMs: 5 * 60 * 1000,
+      max: 500,
+    }),
+  );
+
   app.use(
     helmet({
       contentSecurityPolicy: false,

src/power-clamp/power-clamp.module.ts

@@ -1,67 +1,66 @@
-import { DeviceStatusFirebaseService } from '@app/common/firebase/devices-status/services/devices-status.service';
+import { Module } from '@nestjs/common';
-import { AqiDataService } from '@app/common/helper/services/aqi.data.service';
+import { ConfigModule } from '@nestjs/config';
-import { OccupancyService } from '@app/common/helper/services/occupancy.service';
+import { PowerClampService as PowerClamp } from './services/power-clamp.service';
-import { PowerClampService } from '@app/common/helper/services/power.clamp.service';
+import { PowerClampController } from './controllers';
-import { SqlLoaderService } from '@app/common/helper/services/sql-loader.service';
-import { TuyaService } from '@app/common/integrations/tuya/services/tuya.service';
-import { AutomationRepository } from '@app/common/modules/automation/repositories';
-import { CommunityRepository } from '@app/common/modules/community/repositories';
-import { DeviceStatusLogRepository } from '@app/common/modules/device-status-log/repositories';
-import { DeviceRepository } from '@app/common/modules/device/repositories';
 import {
   PowerClampDailyRepository,
   PowerClampHourlyRepository,
   PowerClampMonthlyRepository,
 } from '@app/common/modules/power-clamp/repositories';
-import { ProductRepository } from '@app/common/modules/product/repositories';
+import { DeviceRepository } from '@app/common/modules/device/repositories';
-import { ProjectRepository } from '@app/common/modules/project/repositiories';
-import { SceneDeviceRepository } from '@app/common/modules/scene-device/repositories';
 import {
-  SceneIconRepository,
+  SpaceDeviceService,
-  SceneRepository,
+  SpaceLinkService,
-} from '@app/common/modules/scene/repositories';
+  SpaceService,
+  SubspaceDeviceService,
+  SubSpaceService,
+  ValidationService,
+} from 'src/space/services';
+import { TuyaService } from '@app/common/integrations/tuya/services/tuya.service';
+import { DeviceService } from 'src/device/services';
 import {
   InviteSpaceRepository,
   SpaceLinkRepository,
   SpaceProductAllocationRepository,
   SpaceRepository,
+  TagRepository,
 } from '@app/common/modules/space';
+import { CommunityService } from 'src/community/services';
+import { ProjectRepository } from '@app/common/modules/project/repositiories';
+import { CommunityRepository } from '@app/common/modules/community/repositories';
 import {
   SpaceModelProductAllocationRepoitory,
   SpaceModelRepository,
   SubspaceModelProductAllocationRepoitory,
   SubspaceModelRepository,
 } from '@app/common/modules/space-model';
-import {
+import { SceneDeviceRepository } from '@app/common/modules/scene-device/repositories';
-  SubspaceProductAllocationRepository,
+import { ProductRepository } from '@app/common/modules/product/repositories';
-  SubspaceRepository,
+import { DeviceStatusFirebaseService } from '@app/common/firebase/devices-status/services/devices-status.service';
-} from '@app/common/modules/space/repositories/subspace.repository';
-import { NewTagRepository } from '@app/common/modules/tag/repositories/tag-repository';
-import { Module } from '@nestjs/common';
-import { ConfigModule } from '@nestjs/config';
-import { CommunityService } from 'src/community/services';
-import { DeviceService } from 'src/device/services';
 import { SceneService } from 'src/scene/services';
+import { PowerClampService } from '@app/common/helper/services/power.clamp.service';
+import { DeviceStatusLogRepository } from '@app/common/modules/device-status-log/repositories';
+import {
+  SceneIconRepository,
+  SceneRepository,
+} from '@app/common/modules/scene/repositories';
+import { AutomationRepository } from '@app/common/modules/automation/repositories';
+import { TagService } from 'src/tags/services';
 import {
   SpaceModelService,
   SubSpaceModelService,
 } from 'src/space-model/services';
+import { SpaceProductAllocationService } from 'src/space/services/space-product-allocation.service';
+import { SqlLoaderService } from '@app/common/helper/services/sql-loader.service';
+import {
+  SubspaceProductAllocationRepository,
+  SubspaceRepository,
+} from '@app/common/modules/space/repositories/subspace.repository';
+import { SubspaceProductAllocationService } from 'src/space/services/subspace/subspace-product-allocation.service';
+import { NewTagRepository } from '@app/common/modules/tag/repositories/tag-repository';
 import { SpaceModelProductAllocationService } from 'src/space-model/services/space-model-product-allocation.service';
 import { SubspaceModelProductAllocationService } from 'src/space-model/services/subspace/subspace-model-product-allocation.service';
-import {
+import { OccupancyService } from '@app/common/helper/services/occupancy.service';
-  SpaceDeviceService,
-  SpaceService,
-  SubspaceDeviceService,
-  SubSpaceService,
-  ValidationService,
-} from 'src/space/services';
-import { SpaceProductAllocationService } from 'src/space/services/space-product-allocation.service';
-import { SubspaceProductAllocationService } from 'src/space/services/subspace/subspace-product-allocation.service';
-import { TagService } from 'src/tags/services';
-import { PowerClampController } from './controllers';
-import { PowerClampService as PowerClamp } from './services/power-clamp.service';
-import { PresenceSensorDailySpaceRepository } from '@app/common/modules/presence-sensor/repositories';
-import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/repositories';
 @Module({
   imports: [ConfigModule],
   controllers: [PowerClampController],
@@ -91,6 +90,7 @@ import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/r
     SceneRepository,
     AutomationRepository,
     InviteSpaceRepository,
+    SpaceLinkService,
     SubSpaceService,
     TagService,
     SpaceModelService,
@@ -105,14 +105,12 @@ import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/r
     SpaceModelProductAllocationService,
     SpaceProductAllocationRepository,
     SubspaceProductAllocationRepository,
+    TagRepository,
     SubspaceModelRepository,
     SubspaceModelProductAllocationService,
     SpaceModelProductAllocationRepoitory,
     SubspaceModelProductAllocationRepoitory,
     OccupancyService,
-    AqiDataService,
-    PresenceSensorDailySpaceRepository,
-    AqiSpaceDailyPollutantStatsRepository,
   ],
   exports: [PowerClamp],
 })

src/project/project.module.ts

@@ -1,74 +1,73 @@
-import { DeviceStatusFirebaseService } from '@app/common/firebase/devices-status/services/devices-status.service';
+import { Global, Module } from '@nestjs/common';
-import { AqiDataService } from '@app/common/helper/services/aqi.data.service';
+import { CqrsModule } from '@nestjs/cqrs';
-import { OccupancyService } from '@app/common/helper/services/occupancy.service';
+import { ProjectController } from './controllers';
-import { PowerClampService } from '@app/common/helper/services/power.clamp.service';
+import { ProjectService } from './services';
-import { SqlLoaderService } from '@app/common/helper/services/sql-loader.service';
-import { TuyaService } from '@app/common/integrations/tuya/services/tuya.service';
-import { AutomationRepository } from '@app/common/modules/automation/repositories';
-import { CommunityRepository } from '@app/common/modules/community/repositories';
-import { DeviceStatusLogRepository } from '@app/common/modules/device-status-log/repositories';
-import { DeviceRepository } from '@app/common/modules/device/repositories';
-import { InviteUserRepository } from '@app/common/modules/Invite-user/repositiories';
-import {
-  PowerClampDailyRepository,
-  PowerClampHourlyRepository,
-  PowerClampMonthlyRepository,
-} from '@app/common/modules/power-clamp/repositories';
-import { ProductRepository } from '@app/common/modules/product/repositories';
 import { ProjectRepository } from '@app/common/modules/project/repositiories';
-import { SceneDeviceRepository } from '@app/common/modules/scene-device/repositories';
+import { CreateOrphanSpaceHandler } from './handler';
-import {
-  SceneIconRepository,
-  SceneRepository,
-} from '@app/common/modules/scene/repositories';
 import {
   InviteSpaceRepository,
   SpaceLinkRepository,
   SpaceProductAllocationRepository,
   SpaceRepository,
+  TagRepository,
 } from '@app/common/modules/space';
+import { CommunityRepository } from '@app/common/modules/community/repositories';
+import { InviteUserRepository } from '@app/common/modules/Invite-user/repositiories';
+import { ProjectUserController } from './controllers/project-user.controller';
+import { ProjectUserService } from './services/project-user.service';
+import {
+  UserRepository,
+  UserSpaceRepository,
+} from '@app/common/modules/user/repositories';
+import {
+  SpaceLinkService,
+  SpaceService,
+  SubspaceDeviceService,
+  SubSpaceService,
+  ValidationService,
+} from 'src/space/services';
+import { TagService } from 'src/tags/services';
+import {
+  SpaceModelService,
+  SubSpaceModelService,
+} from 'src/space-model/services';
+import { DeviceService } from 'src/device/services';
+import { SpaceProductAllocationService } from 'src/space/services/space-product-allocation.service';
+import {
+  SubspaceProductAllocationRepository,
+  SubspaceRepository,
+} from '@app/common/modules/space/repositories/subspace.repository';
+import { SubspaceProductAllocationService } from 'src/space/services/subspace/subspace-product-allocation.service';
+import { CommunityService } from 'src/community/services';
 import {
   SpaceModelProductAllocationRepoitory,
   SpaceModelRepository,
   SubspaceModelProductAllocationRepoitory,
   SubspaceModelRepository,
 } from '@app/common/modules/space-model';
-import {
+import { DeviceRepository } from '@app/common/modules/device/repositories';
-  SubspaceProductAllocationRepository,
-  SubspaceRepository,
-} from '@app/common/modules/space/repositories/subspace.repository';
 import { NewTagRepository } from '@app/common/modules/tag/repositories/tag-repository';
-import {
+import { ProductRepository } from '@app/common/modules/product/repositories';
-  UserRepository,
-  UserSpaceRepository,
-} from '@app/common/modules/user/repositories';
-import { Global, Module } from '@nestjs/common';
-import { CqrsModule } from '@nestjs/cqrs';
-import { CommunityService } from 'src/community/services';
-import { DeviceService } from 'src/device/services';
-import { SceneService } from 'src/scene/services';
-import {
-  SpaceModelService,
-  SubSpaceModelService,
-} from 'src/space-model/services';
 import { SpaceModelProductAllocationService } from 'src/space-model/services/space-model-product-allocation.service';
+import { SceneDeviceRepository } from '@app/common/modules/scene-device/repositories';
+import { DeviceStatusFirebaseService } from '@app/common/firebase/devices-status/services/devices-status.service';
+import { SceneService } from 'src/scene/services';
+import { TuyaService } from '@app/common/integrations/tuya/services/tuya.service';
 import { SubspaceModelProductAllocationService } from 'src/space-model/services/subspace/subspace-model-product-allocation.service';
+import { DeviceStatusLogRepository } from '@app/common/modules/device-status-log/repositories';
 import {
-  SpaceService,
+  SceneIconRepository,
-  SubspaceDeviceService,
+  SceneRepository,
-  SubSpaceService,
+} from '@app/common/modules/scene/repositories';
-  ValidationService,
+import { AutomationRepository } from '@app/common/modules/automation/repositories';
-} from 'src/space/services';
+import { PowerClampService } from '@app/common/helper/services/power.clamp.service';
-import { SpaceProductAllocationService } from 'src/space/services/space-product-allocation.service';
+import {
-import { SubspaceProductAllocationService } from 'src/space/services/subspace/subspace-product-allocation.service';
+  PowerClampDailyRepository,
-import { TagService } from 'src/tags/services';
+  PowerClampHourlyRepository,
-import { ProjectController } from './controllers';
+  PowerClampMonthlyRepository,
-import { ProjectUserController } from './controllers/project-user.controller';
+} from '@app/common/modules/power-clamp/repositories';
-import { CreateOrphanSpaceHandler } from './handler';
+import { SqlLoaderService } from '@app/common/helper/services/sql-loader.service';
-import { ProjectService } from './services';
+import { OccupancyService } from '@app/common/helper/services/occupancy.service';
-import { ProjectUserService } from './services/project-user.service';
-import { PresenceSensorDailySpaceRepository } from '@app/common/modules/presence-sensor/repositories';
-import { AqiSpaceDailyPollutantStatsRepository } from '@app/common/modules/aqi/repositories';
 
 const CommandHandlers = [CreateOrphanSpaceHandler];
 
@@ -88,6 +87,7 @@ const CommandHandlers = [CreateOrphanSpaceHandler];
     UserRepository,
     SpaceService,
     InviteSpaceRepository,
+    SpaceLinkService,
     SubSpaceService,
     ValidationService,
     TagService,
@@ -111,6 +111,7 @@ const CommandHandlers = [CreateOrphanSpaceHandler];
     DeviceStatusFirebaseService,
     SceneService,
     TuyaService,
+    TagRepository,
     SubspaceModelRepository,
     SubspaceModelProductAllocationService,
     SpaceModelProductAllocationRepoitory,
@@ -125,9 +126,6 @@ const CommandHandlers = [CreateOrphanSpaceHandler];
     PowerClampMonthlyRepository,
     SqlLoaderService,
     OccupancyService,
-    AqiDataService,
-    PresenceSensorDailySpaceRepository,
-    AqiSpaceDailyPollutantStatsRepository,
   ],
   exports: [ProjectService, CqrsModule],
 })

src/project/services/project.service.ts

@@ -1,17 +1,4 @@
-import { ORPHAN_COMMUNITY_NAME } from '@app/common/constants/orphan-constant';
-import { BaseResponseDto } from '@app/common/dto/base.response.dto';
-import { PageResponse } from '@app/common/dto/pagination.response.dto';
-import { SuccessResponseDto } from '@app/common/dto/success.response.dto';
-import {
-  TypeORMCustomModel,
-  TypeORMCustomModelFindAllQuery,
-} from '@app/common/models/typeOrmCustom.model';
-import { ProjectDto } from '@app/common/modules/project/dtos';
-import { ProjectEntity } from '@app/common/modules/project/entities';
 import { ProjectRepository } from '@app/common/modules/project/repositiories';
-import { SpaceEntity } from '@app/common/modules/space/entities/space.entity';
-import { UserRepository } from '@app/common/modules/user/repositories';
-import { format } from '@fast-csv/format';
 import {
   forwardRef,
   HttpException,
@@ -19,12 +6,24 @@ import {
   Inject,
   Injectable,
 } from '@nestjs/common';
-import { CommandBus } from '@nestjs/cqrs';
-import { SpaceService } from 'src/space/services';
-import { PassThrough } from 'stream';
-import { CreateOrphanSpaceCommand } from '../command/create-orphan-space-command';
 import { CreateProjectDto, GetProjectParam } from '../dto';
-import { QueryRunner } from 'typeorm';
+import { BaseResponseDto } from '@app/common/dto/base.response.dto';
+import { SuccessResponseDto } from '@app/common/dto/success.response.dto';
+import { ProjectEntity } from '@app/common/modules/project/entities';
+import {
+  TypeORMCustomModel,
+  TypeORMCustomModelFindAllQuery,
+} from '@app/common/models/typeOrmCustom.model';
+import { ProjectDto } from '@app/common/modules/project/dtos';
+import { PageResponse } from '@app/common/dto/pagination.response.dto';
+import { CommandBus } from '@nestjs/cqrs';
+import { CreateOrphanSpaceCommand } from '../command/create-orphan-space-command';
+import { UserRepository } from '@app/common/modules/user/repositories';
+import { format } from '@fast-csv/format';
+import { PassThrough } from 'stream';
+import { SpaceEntity } from '@app/common/modules/space/entities/space.entity';
+import { SpaceService } from 'src/space/services';
+import { ORPHAN_COMMUNITY_NAME } from '@app/common/constants/orphan-constant';
 
 @Injectable()
 export class ProjectService {
@@ -213,14 +212,8 @@ export class ProjectService {
     }
   }
 
-  async findOne(
+  async findOne(uuid: string): Promise<ProjectEntity> {
-    uuid: string,
+    const project = await this.projectRepository.findOne({ where: { uuid } });
-    queryRunner?: QueryRunner,
-  ): Promise<ProjectEntity> {
-    const projectRepository = queryRunner
-      ? queryRunner.manager.getRepository(ProjectEntity)
-      : this.projectRepository;
-    const project = await projectRepository.findOne({ where: { uuid } });
     if (!project) {
       throw new HttpException(
         `Invalid project with uuid ${uuid}`,
@@ -243,11 +236,11 @@ export class ProjectService {
         'communities.spaces.parent',
         'communities.spaces.productAllocations',
         'communities.spaces.productAllocations.product',
-        'communities.spaces.productAllocations.tag',
+        'communities.spaces.productAllocations.tags',
         'communities.spaces.subspaces',
         'communities.spaces.subspaces.productAllocations',
         'communities.spaces.subspaces.productAllocations.product',
-        'communities.spaces.subspaces.productAllocations.tag',
+        'communities.spaces.subspaces.productAllocations.tags',
       ],
     });
 
@@ -310,38 +303,52 @@ export class ProjectService {
         if (subspace.disabled) continue;
 
         for (const productAllocation of subspace.productAllocations || []) {
+          for (const tag of productAllocation.tags || []) {
+            csvStream.write({
+              'Device ID': '',
+              'Community Name': space.community?.name || '',
+              'Space Name': space.spaceName,
+              'Space Location': spaceLocation,
+              'Subspace Name': subspace.subspaceName || '',
+              Tag: tag.name,
+              'Product Name': productAllocation.product.name || '',
+              'Community UUID': space.community?.uuid || '',
+              'Space UUID': space.uuid,
+              'Subspace UUID': subspace.uuid,
+            });
+          }
+        }
+      }
+
+      for (const productAllocation of space.productAllocations || []) {
+        for (const tag of productAllocation.tags || []) {
           csvStream.write({
             'Device ID': '',
             'Community Name': space.community?.name || '',
             'Space Name': space.spaceName,
             'Space Location': spaceLocation,
-            'Subspace Name': subspace.subspaceName || '',
+            'Subspace Name': '',
-            Tag: productAllocation.tag.name,
+            Tag: tag.name,
             'Product Name': productAllocation.product.name || '',
             'Community UUID': space.community?.uuid || '',
             'Space UUID': space.uuid,
-            'Subspace UUID': subspace.uuid,
+            'Subspace UUID': '',
           });
         }
       }
-
-      for (const productAllocation of space.productAllocations || []) {
-        csvStream.write({
-          'Device ID': '',
-          'Community Name': space.community?.name || '',
-          'Space Name': space.spaceName,
-          'Space Location': spaceLocation,
-          'Subspace Name': '',
-          Tag: productAllocation.tag.name,
-          'Product Name': productAllocation.product.name || '',
-          'Community UUID': space.community?.uuid || '',
-          'Space UUID': space.uuid,
-          'Subspace UUID': '',
-        });
-      }
     }
 
     csvStream.end();
     return stream;
   }
+
+  getSpaceLocation(space: SpaceEntity): string {
+    const names = [];
+    let current = space.parent;
+    while (current) {
+      names.unshift(current.spaceName);
+      current = current.parent;
+    }
+    return names.join(' > ');
+  }
 }

src/schedule/constants/device-function-map.ts

@@ -1,32 +0,0 @@
-import {
-  ControlCur2AccurateCalibrationCommand,
-  ControlCur2Command,
-  ControlCur2PercentCommand,
-  ControlCur2QuickCalibrationCommand,
-  ControlCur2TDirectionConCommand,
-} from 'src/device/commands/cur2-commands';
-
-export enum ScheduleProductType {
-  CUR_2 = 'CUR_2',
-}
-export const DeviceFunctionMap: {
-  [T in ScheduleProductType]: (body: DeviceFunction[T]) => any;
-} = {
-  [ScheduleProductType.CUR_2]: ({ code, value }) => {
-    return [
-      {
-        code,
-        value,
-      },
-    ];
-  },
-};
-
-type DeviceFunction = {
-  [ScheduleProductType.CUR_2]:
-    | ControlCur2Command
-    | ControlCur2PercentCommand
-    | ControlCur2AccurateCalibrationCommand
-    | ControlCur2TDirectionConCommand
-    | ControlCur2QuickCalibrationCommand;
-};

src/schedule/services/schedule.service.ts

@@ -1,6 +1,6 @@
-import { HttpException, HttpStatus, Injectable } from '@nestjs/common';
+import { Injectable, HttpException, HttpStatus } from '@nestjs/common';
-import { ConfigService } from '@nestjs/config';
 import { TuyaContext } from '@tuya/tuya-connector-nodejs';
+import { ConfigService } from '@nestjs/config';
 import {
   AddScheduleDto,
   EnableScheduleDto,
@@ -11,14 +11,14 @@ import {
   getDeviceScheduleInterface,
 } from '../interfaces/get.schedule.interface';
 
-import { ProductType } from '@app/common/constants/product-type.enum';
 import { convertKeysToCamelCase } from '@app/common/helper/camelCaseConverter';
+import { DeviceRepository } from '@app/common/modules/device/repositories';
+import { ProductType } from '@app/common/constants/product-type.enum';
 import { convertTimestampToDubaiTime } from '@app/common/helper/convertTimestampToDubaiTime';
 import {
   getEnabledDays,
   getScheduleStatus,
 } from '@app/common/helper/getScheduleStatus';
-import { DeviceRepository } from '@app/common/modules/device/repositories';
 
 @Injectable()
 export class ScheduleService {
@@ -49,11 +49,22 @@ export class ScheduleService {
       }
 
       // Corrected condition for supported device types
-      this.ensureProductTypeSupportedForSchedule(
+      if (
-        deviceDetails.productDevice.prodType as ProductType,
+        deviceDetails.productDevice.prodType !== ProductType.THREE_G &&
-      );
+        deviceDetails.productDevice.prodType !== ProductType.ONE_G &&
-
+        deviceDetails.productDevice.prodType !== ProductType.TWO_G &&
-      return this.enableScheduleDeviceInTuya(
+        deviceDetails.productDevice.prodType !== ProductType.WH &&
+        deviceDetails.productDevice.prodType !== ProductType.ONE_1TG &&
+        deviceDetails.productDevice.prodType !== ProductType.TWO_2TG &&
+        deviceDetails.productDevice.prodType !== ProductType.THREE_3TG &&
+        deviceDetails.productDevice.prodType !== ProductType.GD
+      ) {
+        throw new HttpException(
+          'This device is not supported for schedule',
+          HttpStatus.BAD_REQUEST,
+        );
+      }
+      return await this.enableScheduleDeviceInTuya(
         deviceDetails.deviceTuyaUuid,
         enableScheduleDto,
       );
@@ -64,6 +75,29 @@ export class ScheduleService {
       );
     }
   }
+  async enableScheduleDeviceInTuya(
+    deviceId: string,
+    enableScheduleDto: EnableScheduleDto,
+  ): Promise<addScheduleDeviceInterface> {
+    try {
+      const path = `/v2.0/cloud/timer/device/${deviceId}/state`;
+      const response = await this.tuya.request({
+        method: 'PUT',
+        path,
+        body: {
+          enable: enableScheduleDto.enable,
+          timer_id: enableScheduleDto.scheduleId,
+        },
+      });
+
+      return response as addScheduleDeviceInterface;
+    } catch (error) {
+      throw new HttpException(
+        'Error while updating schedule from Tuya',
+        HttpStatus.INTERNAL_SERVER_ERROR,
+      );
+    }
+  }
   async deleteDeviceSchedule(deviceUuid: string, scheduleId: string) {
     try {
       const deviceDetails = await this.getDeviceByDeviceUuid(deviceUuid);
@@ -73,10 +107,21 @@ export class ScheduleService {
       }
 
       // Corrected condition for supported device types
-      this.ensureProductTypeSupportedForSchedule(
+      if (
-        deviceDetails.productDevice.prodType as ProductType,
+        deviceDetails.productDevice.prodType !== ProductType.THREE_G &&
-      );
+        deviceDetails.productDevice.prodType !== ProductType.ONE_G &&
-
+        deviceDetails.productDevice.prodType !== ProductType.TWO_G &&
+        deviceDetails.productDevice.prodType !== ProductType.WH &&
+        deviceDetails.productDevice.prodType !== ProductType.ONE_1TG &&
+        deviceDetails.productDevice.prodType !== ProductType.TWO_2TG &&
+        deviceDetails.productDevice.prodType !== ProductType.THREE_3TG &&
+        deviceDetails.productDevice.prodType !== ProductType.GD
+      ) {
+        throw new HttpException(
+          'This device is not supported for schedule',
+          HttpStatus.BAD_REQUEST,
+        );
+      }
       return await this.deleteScheduleDeviceInTuya(
         deviceDetails.deviceTuyaUuid,
         scheduleId,
@@ -88,6 +133,25 @@ export class ScheduleService {
       );
     }
   }
+  async deleteScheduleDeviceInTuya(
+    deviceId: string,
+    scheduleId: string,
+  ): Promise<addScheduleDeviceInterface> {
+    try {
+      const path = `/v2.0/cloud/timer/device/${deviceId}/batch?timer_ids=${scheduleId}`;
+      const response = await this.tuya.request({
+        method: 'DELETE',
+        path,
+      });
+
+      return response as addScheduleDeviceInterface;
+    } catch (error) {
+      throw new HttpException(
+        'Error while deleting schedule from Tuya',
+        HttpStatus.INTERNAL_SERVER_ERROR,
+      );
+    }
+  }
   async addDeviceSchedule(deviceUuid: string, addScheduleDto: AddScheduleDto) {
     try {
       const deviceDetails = await this.getDeviceByDeviceUuid(deviceUuid);
@@ -96,10 +160,22 @@ export class ScheduleService {
         throw new HttpException('Device Not Found', HttpStatus.NOT_FOUND);
       }
 
-      this.ensureProductTypeSupportedForSchedule(
+      // Corrected condition for supported device types
-        deviceDetails.productDevice.prodType as ProductType,
+      if (
-      );
+        deviceDetails.productDevice.prodType !== ProductType.THREE_G &&
-
+        deviceDetails.productDevice.prodType !== ProductType.ONE_G &&
+        deviceDetails.productDevice.prodType !== ProductType.TWO_G &&
+        deviceDetails.productDevice.prodType !== ProductType.WH &&
+        deviceDetails.productDevice.prodType !== ProductType.ONE_1TG &&
+        deviceDetails.productDevice.prodType !== ProductType.TWO_2TG &&
+        deviceDetails.productDevice.prodType !== ProductType.THREE_3TG &&
+        deviceDetails.productDevice.prodType !== ProductType.GD
+      ) {
+        throw new HttpException(
+          'This device is not supported for schedule',
+          HttpStatus.BAD_REQUEST,
+        );
+      }
       await this.addScheduleDeviceInTuya(
         deviceDetails.deviceTuyaUuid,
         addScheduleDto,
@@ -111,6 +187,40 @@ export class ScheduleService {
       );
     }
   }
+  async addScheduleDeviceInTuya(
+    deviceId: string,
+    addScheduleDto: AddScheduleDto,
+  ): Promise<addScheduleDeviceInterface> {
+    try {
+      const convertedTime = convertTimestampToDubaiTime(addScheduleDto.time);
+      const loops = getScheduleStatus(addScheduleDto.days);
+
+      const path = `/v2.0/cloud/timer/device/${deviceId}`;
+      const response = await this.tuya.request({
+        method: 'POST',
+        path,
+        body: {
+          time: convertedTime.time,
+          timezone_id: 'Asia/Dubai',
+          loops: `${loops}`,
+          functions: [
+            {
+              code: addScheduleDto.function.code,
+              value: addScheduleDto.function.value,
+            },
+          ],
+          category: `category_${addScheduleDto.category}`,
+        },
+      });
+
+      return response as addScheduleDeviceInterface;
+    } catch (error) {
+      throw new HttpException(
+        'Error adding schedule from Tuya',
+        HttpStatus.INTERNAL_SERVER_ERROR,
+      );
+    }
+  }
   async getDeviceScheduleByCategory(deviceUuid: string, category: string) {
     try {
       const deviceDetails = await this.getDeviceByDeviceUuid(deviceUuid);
@@ -119,9 +229,21 @@ export class ScheduleService {
         throw new HttpException('Device Not Found', HttpStatus.NOT_FOUND);
       }
       // Corrected condition for supported device types
-      this.ensureProductTypeSupportedForSchedule(
+      if (
-        deviceDetails.productDevice.prodType as ProductType,
+        deviceDetails.productDevice.prodType !== ProductType.THREE_G &&
-      );
+        deviceDetails.productDevice.prodType !== ProductType.ONE_G &&
+        deviceDetails.productDevice.prodType !== ProductType.TWO_G &&
+        deviceDetails.productDevice.prodType !== ProductType.WH &&
+        deviceDetails.productDevice.prodType !== ProductType.ONE_1TG &&
+        deviceDetails.productDevice.prodType !== ProductType.TWO_2TG &&
+        deviceDetails.productDevice.prodType !== ProductType.THREE_3TG &&
+        deviceDetails.productDevice.prodType !== ProductType.GD
+      ) {
+        throw new HttpException(
+          'This device is not supported for schedule',
+          HttpStatus.BAD_REQUEST,
+        );
+      }
       const schedules = await this.getScheduleDeviceInTuya(
         deviceDetails.deviceTuyaUuid,
         category,
@@ -148,82 +270,7 @@ export class ScheduleService {
       );
     }
   }
-  async updateDeviceSchedule(
+  async getScheduleDeviceInTuya(
-    deviceUuid: string,
-    updateScheduleDto: UpdateScheduleDto,
-  ) {
-    try {
-      const deviceDetails = await this.getDeviceByDeviceUuid(deviceUuid);
-
-      if (!deviceDetails || !deviceDetails.deviceTuyaUuid) {
-        throw new HttpException('Device Not Found', HttpStatus.NOT_FOUND);
-      }
-
-      // Corrected condition for supported device types
-      this.ensureProductTypeSupportedForSchedule(
-        deviceDetails.productDevice.prodType as ProductType,
-      );
-
-      await this.updateScheduleDeviceInTuya(
-        deviceDetails.deviceTuyaUuid,
-        updateScheduleDto,
-      );
-    } catch (error) {
-      throw new HttpException(
-        error.message || 'Error While Updating Schedule',
-        error.status || HttpStatus.INTERNAL_SERVER_ERROR,
-      );
-    }
-  }
-
-  private getDeviceByDeviceUuid(
-    deviceUuid: string,
-    withProductDevice: boolean = true,
-  ) {
-    return this.deviceRepository.findOne({
-      where: {
-        uuid: deviceUuid,
-        isActive: true,
-      },
-      ...(withProductDevice && { relations: ['productDevice'] }),
-    });
-  }
-
-  private async addScheduleDeviceInTuya(
-    deviceId: string,
-    addScheduleDto: AddScheduleDto,
-  ): Promise<addScheduleDeviceInterface> {
-    try {
-      const convertedTime = convertTimestampToDubaiTime(addScheduleDto.time);
-      const loops = getScheduleStatus(addScheduleDto.days);
-
-      const path = `/v2.0/cloud/timer/device/${deviceId}`;
-      const response = await this.tuya.request({
-        method: 'POST',
-        path,
-        body: {
-          time: convertedTime.time,
-          timezone_id: 'Asia/Dubai',
-          loops: `${loops}`,
-          functions: [
-            {
-              ...addScheduleDto.function,
-            },
-          ],
-          category: `category_${addScheduleDto.category}`,
-        },
-      });
-
-      return response as addScheduleDeviceInterface;
-    } catch (error) {
-      throw new HttpException(
-        'Error adding schedule from Tuya',
-        HttpStatus.INTERNAL_SERVER_ERROR,
-      );
-    }
-  }
-
-  private async getScheduleDeviceInTuya(
     deviceId: string,
     category: string,
   ): Promise<getDeviceScheduleInterface> {
@@ -244,8 +291,57 @@ export class ScheduleService {
       );
     }
   }
+  async getDeviceByDeviceUuid(
+    deviceUuid: string,
+    withProductDevice: boolean = true,
+  ) {
+    return await this.deviceRepository.findOne({
+      where: {
+        uuid: deviceUuid,
+        isActive: true,
+      },
+      ...(withProductDevice && { relations: ['productDevice'] }),
+    });
+  }
+  async updateDeviceSchedule(
+    deviceUuid: string,
+    updateScheduleDto: UpdateScheduleDto,
+  ) {
+    try {
+      const deviceDetails = await this.getDeviceByDeviceUuid(deviceUuid);
 
-  private async updateScheduleDeviceInTuya(
+      if (!deviceDetails || !deviceDetails.deviceTuyaUuid) {
+        throw new HttpException('Device Not Found', HttpStatus.NOT_FOUND);
+      }
+
+      // Corrected condition for supported device types
+      if (
+        deviceDetails.productDevice.prodType !== ProductType.THREE_G &&
+        deviceDetails.productDevice.prodType !== ProductType.ONE_G &&
+        deviceDetails.productDevice.prodType !== ProductType.TWO_G &&
+        deviceDetails.productDevice.prodType !== ProductType.WH &&
+        deviceDetails.productDevice.prodType !== ProductType.ONE_1TG &&
+        deviceDetails.productDevice.prodType !== ProductType.TWO_2TG &&
+        deviceDetails.productDevice.prodType !== ProductType.THREE_3TG &&
+        deviceDetails.productDevice.prodType !== ProductType.GD
+      ) {
+        throw new HttpException(
+          'This device is not supported for schedule',
+          HttpStatus.BAD_REQUEST,
+        );
+      }
+      await this.updateScheduleDeviceInTuya(
+        deviceDetails.deviceTuyaUuid,
+        updateScheduleDto,
+      );
+    } catch (error) {
+      throw new HttpException(
+        error.message || 'Error While Updating Schedule',
+        error.status || HttpStatus.INTERNAL_SERVER_ERROR,
+      );
+    }
+  }
+  async updateScheduleDeviceInTuya(
     deviceId: string,
     updateScheduleDto: UpdateScheduleDto,
   ): Promise<addScheduleDeviceInterface> {
@@ -280,69 +376,4 @@ export class ScheduleService {
       );
     }
   }
-
-  private async enableScheduleDeviceInTuya(
-    deviceId: string,
-    enableScheduleDto: EnableScheduleDto,
-  ): Promise<addScheduleDeviceInterface> {
-    try {
-      const path = `/v2.0/cloud/timer/device/${deviceId}/state`;
-      const response = await this.tuya.request({
-        method: 'PUT',
-        path,
-        body: {
-          enable: enableScheduleDto.enable,
-          timer_id: enableScheduleDto.scheduleId,
-        },
-      });
-
-      return response as addScheduleDeviceInterface;
-    } catch (error) {
-      throw new HttpException(
-        'Error while updating schedule from Tuya',
-        HttpStatus.INTERNAL_SERVER_ERROR,
-      );
-    }
-  }
-
-  private async deleteScheduleDeviceInTuya(
-    deviceId: string,
-    scheduleId: string,
-  ): Promise<addScheduleDeviceInterface> {
-    try {
-      const path = `/v2.0/cloud/timer/device/${deviceId}/batch?timer_ids=${scheduleId}`;
-      const response = await this.tuya.request({
-        method: 'DELETE',
-        path,
-      });
-
-      return response as addScheduleDeviceInterface;
-    } catch (error) {
-      throw new HttpException(
-        'Error while deleting schedule from Tuya',
-        HttpStatus.INTERNAL_SERVER_ERROR,
-      );
-    }
-  }
-
-  private ensureProductTypeSupportedForSchedule(deviceType: ProductType): void {
-    if (
-      ![
-        ProductType.THREE_G,
-        ProductType.ONE_G,
-        ProductType.TWO_G,
-        ProductType.WH,
-        ProductType.ONE_1TG,
-        ProductType.TWO_2TG,
-        ProductType.THREE_3TG,
-        ProductType.GD,
-        ProductType.CUR_2,
-      ].includes(deviceType)
-    ) {
-      throw new HttpException(
-        'This device is not supported for schedule',
-        HttpStatus.BAD_REQUEST,
-      );
-    }
-  }
 }

src/scheduler/scheduler.module.ts

@@ -1,25 +0,0 @@
-import { DatabaseModule } from '@app/common/database/database.module';
-import { SqlLoaderService } from '@app/common/helper/services/sql-loader.service';
-import { Module } from '@nestjs/common';
-import { TypeOrmModule } from '@nestjs/typeorm';
-import { SchedulerService } from './scheduler.service';
-import { ScheduleModule as NestScheduleModule } from '@nestjs/schedule';
-import { AqiDataService } from '@app/common/helper/services/aqi.data.service';
-import { OccupancyService } from '@app/common/helper/services/occupancy.service';
-import { PowerClampService } from '@app/common/helper/services/power.clamp.service';
-
-@Module({
-  imports: [
-    NestScheduleModule.forRoot(),
-    TypeOrmModule.forFeature([]),
-    DatabaseModule,
-  ],
-  providers: [
-    SchedulerService,
-    SqlLoaderService,
-    PowerClampService,
-    OccupancyService,
-    AqiDataService,
-  ],
-})
-export class SchedulerModule {}

src/scheduler/scheduler.service.ts

@@ -1,92 +0,0 @@
-import { AqiDataService } from '@app/common/helper/services/aqi.data.service';
-import { Injectable } from '@nestjs/common';
-import { Cron, CronExpression } from '@nestjs/schedule';
-import { OccupancyService } from '@app/common/helper/services/occupancy.service';
-import { PowerClampService } from '@app/common/helper/services/power.clamp.service';
-
-@Injectable()
-export class SchedulerService {
-  constructor(
-    private readonly powerClampService: PowerClampService,
-    private readonly occupancyService: OccupancyService,
-    private readonly aqiDataService: AqiDataService,
-  ) {
-    console.log('SchedulerService initialized!');
-  }
-
-  @Cron(CronExpression.EVERY_HOUR)
-  async runHourlyProcedures() {
-    console.log('\n======== Starting Procedures ========');
-    console.log(new Date().toISOString(), 'Scheduler running...');
-
-    try {
-      const results = await Promise.allSettled([
-        this.executeTask(
-          () => this.powerClampService.updateEnergyConsumedHistoricalData(),
-          'Energy Consumption',
-        ),
-        this.executeTask(
-          () => this.occupancyService.updateOccupancyDataProcedures(),
-          'Occupancy Data',
-        ),
-        this.executeTask(
-          () => this.aqiDataService.updateAQISensorHistoricalData(),
-          'AQI Data',
-        ),
-      ]);
-
-      this.logResults(results);
-    } catch (error) {
-      console.error('MAIN SCHEDULER ERROR:', error);
-      if (error.stack) {
-        console.error('Error stack:', error.stack);
-      }
-    }
-  }
-
-  private async executeTask(
-    task: () => Promise<void>,
-    name: string,
-  ): Promise<{ name: string; status: string }> {
-    try {
-      console.log(`[${new Date().toISOString()}] Starting ${name} task...`);
-      await task();
-      console.log(
-        `[${new Date().toISOString()}] ${name} task completed successfully`,
-      );
-      return { name, status: 'success' };
-    } catch (error) {
-      console.error(
-        `[${new Date().toISOString()}] ${name} task failed:`,
-        error.message,
-      );
-      if (error.stack) {
-        console.error('Task error stack:', error.stack);
-      }
-      return { name, status: 'failed' };
-    }
-  }
-
-  private logResults(results: PromiseSettledResult<any>[]) {
-    const successCount = results.filter((r) => r.status === 'fulfilled').length;
-    const failedCount = results.length - successCount;
-
-    console.log('\n======== Task Results ========');
-    console.log(`Successful tasks: ${successCount}`);
-    console.log(`Failed tasks: ${failedCount}`);
-
-    if (failedCount > 0) {
-      console.log('\n======== Failed Tasks Details ========');
-      results.forEach((result, index) => {
-        if (result.status === 'rejected') {
-          console.error(`Task ${index + 1} failed:`, result.reason);
-          if (result.reason.stack) {
-            console.error('Error stack:', result.reason.stack);
-          }
-        }
-      });
-    }
-
-    console.log('\n======== Scheduler Completed ========\n');
-  }
-}

src/space-model/dtos/index.ts

@@ -1,6 +1,7 @@
 export * from './create-space-model.dto';
-export * from './link-space-model.dto';
 export * from './project-param.dto';
+export * from './update-space-model.dto';
 export * from './space-model-param';
 export * from './subspaces-model-dtos';
-export * from './update-space-model.dto';
+export * from './tag-model-dtos';
+export * from './link-space-model.dto';

src/space-model/dtos/subspaces-model-dtos/modify-subspace-model.dto.ts

@@ -1,14 +1,14 @@
-import { ModifyAction } from '@app/common/constants/modify-action.enum';
 import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
 import { Type } from 'class-transformer';
 import {
-  IsArray,
-  IsEnum,
-  IsOptional,
   IsString,
+  IsOptional,
+  IsArray,
   ValidateNested,
+  IsEnum,
 } from 'class-validator';
-import { ModifyTagDto } from 'src/space/dtos/tag/modify-tag.dto';
+import { ModifyTagModelDto } from '../tag-model-dtos';
+import { ModifyAction } from '@app/common/constants/modify-action.enum';
 
 export class ModifySubspaceModelDto {
   @ApiProperty({
@@ -37,11 +37,11 @@ export class ModifySubspaceModelDto {
   @ApiPropertyOptional({
     description:
       'List of tag modifications (add/update/delete) for the subspace',
-    type: [ModifyTagDto],
+    type: [ModifyTagModelDto],
   })
   @IsOptional()
   @IsArray()
   @ValidateNested({ each: true })
-  @Type(() => ModifyTagDto)
+  @Type(() => ModifyTagModelDto)
-  tags?: ModifyTagDto[];
+  tags?: ModifyTagModelDto[];
 }

src/space-model/dtos/tag-model-dtos/create-tag-model.dto.ts

@@ -0,0 +1,28 @@
+import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
+import { IsNotEmpty, IsOptional, IsString } from 'class-validator';
+
+export class CreateTagModelDto {
+  @ApiProperty({
+    description: 'Tag associated with the space or subspace models',
+    example: 'Temperature Control',
+  })
+  @IsNotEmpty()
+  @IsString()
+  tag: string;
+
+  @ApiPropertyOptional({
+    description: 'UUID of the tag model (required for update/delete)',
+    example: '123e4567-e89b-12d3-a456-426614174000',
+  })
+  @IsOptional()
+  @IsString()
+  uuid?: string;
+
+  @ApiProperty({
+    description: 'ID of the product associated with the tag',
+    example: '123e4567-e89b-12d3-a456-426614174000',
+  })
+  @IsNotEmpty()
+  @IsString()
+  productUuid: string;
+}

src/space-model/dtos/tag-model-dtos/index.ts

@@ -0,0 +1,3 @@
+export * from './create-tag-model.dto';
+export * from './update-tag-model.dto';
+export * from './modify-tag-model.dto';

src/space-model/dtos/tag-model-dtos/modify-tag-model.dto.ts

@@ -0,0 +1,46 @@
+import { ModifyAction } from '@app/common/constants/modify-action.enum';
+import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
+import { IsString, IsOptional, IsEnum, IsUUID } from 'class-validator';
+
+export class ModifyTagModelDto {
+  @ApiProperty({
+    description: 'Action to perform: add, update, or delete',
+    example: ModifyAction.ADD,
+  })
+  @IsEnum(ModifyAction)
+  action: ModifyAction;
+
+  @ApiPropertyOptional({
+    description: 'UUID of the new tag',
+    example: '123e4567-e89b-12d3-a456-426614174000',
+  })
+  @IsOptional()
+  @IsUUID()
+  newTagUuid: string;
+
+  @ApiPropertyOptional({
+    description:
+      'UUID of an existing tag (required for update/delete, optional for add)',
+    example: 'a1b2c3d4-5678-90ef-abcd-1234567890ef',
+  })
+  @IsOptional()
+  @IsUUID()
+  tagUuid?: string;
+
+  @ApiPropertyOptional({
+    description: 'Name of the tag (required for add/update)',
+    example: 'Temperature Sensor',
+  })
+  @IsOptional()
+  @IsString()
+  name?: string;
+
+  @ApiPropertyOptional({
+    description:
+      'UUID of the product associated with the tag (required for add)',
+    example: 'c789a91e-549a-4753-9006-02f89e8170e0',
+  })
+  @IsOptional()
+  @IsUUID()
+  productUuid?: string;
+}

src/space-model/dtos/tag-model-dtos/update-tag-model.dto.ts

@@ -0,0 +1,21 @@
+import { ApiProperty } from '@nestjs/swagger';
+import { IsNotEmpty, IsOptional, IsString, IsUUID } from 'class-validator';
+
+export class UpdateTagModelDto {
+  @ApiProperty({
+    description: 'UUID of the tag to be updated',
+    example: '123e4567-e89b-12d3-a456-426614174000',
+  })
+  @IsNotEmpty()
+  @IsUUID()
+  uuid: string;
+
+  @ApiProperty({
+    description: 'Updated name of the tag',
+    example: 'Updated Tag Name',
+    required: false,
+  })
+  @IsOptional()
+  @IsString()
+  tag?: string;
+}

src/space-model/dtos/update-space-model.dto.ts

@@ -1,13 +1,48 @@
 import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
-import { Type } from 'class-transformer';
 import { IsArray, IsOptional, IsString, ValidateNested } from 'class-validator';
+import { CreateSubspaceModelDto } from './subspaces-model-dtos/create-subspace-model.dto';
+import { Type } from 'class-transformer';
 import {
   DeleteSubspaceModelDto,
   ModifySubspaceModelDto,
   UpdateSubspaceModelDto,
 } from './subspaces-model-dtos';
-import { CreateSubspaceModelDto } from './subspaces-model-dtos/create-subspace-model.dto';
+import { ModifyTagModelDto } from './tag-model-dtos';
-import { ModifyTagDto } from 'src/space/dtos/tag/modify-tag.dto';
+
+export class ModifySubspacesModelDto {
+  @ApiProperty({
+    description: 'List of subspaces to add',
+    type: [CreateSubspaceModelDto],
+    required: false,
+  })
+  @IsOptional()
+  @IsArray()
+  @ValidateNested({ each: true })
+  @Type(() => CreateSubspaceModelDto)
+  add?: CreateSubspaceModelDto[];
+
+  @ApiProperty({
+    description: 'List of subspaces to add',
+    type: [CreateSubspaceModelDto],
+    required: false,
+  })
+  @IsOptional()
+  @IsArray()
+  @ValidateNested({ each: true })
+  @Type(() => UpdateSubspaceModelDto)
+  update?: UpdateSubspaceModelDto[];
+
+  @ApiProperty({
+    description: 'List of subspaces to delete',
+    type: [DeleteSubspaceModelDto],
+    required: false,
+  })
+  @IsOptional()
+  @IsArray()
+  @ValidateNested({ each: true })
+  @Type(() => DeleteSubspaceModelDto)
+  delete?: DeleteSubspaceModelDto[];
+}
 
 export class UpdateSpaceModelDto {
   @ApiProperty({
@@ -31,11 +66,11 @@ export class UpdateSpaceModelDto {
   @ApiPropertyOptional({
     description:
       'List of tag modifications (add/update/delete) for the space model',
-    type: [ModifyTagDto],
+    type: [ModifyTagModelDto],
   })
   @IsOptional()
   @IsArray()
   @ValidateNested({ each: true })
-  @Type(() => ModifyTagDto)
+  @Type(() => ModifyTagModelDto)
-  tags?: ModifyTagDto[];
+  tags?: ModifyTagModelDto[];
 }

src/space-model/handlers/propogate-space-model-product-allocation.handler.ts

@@ -1,11 +1,11 @@
+import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
+import { PropogateUpdateSpaceModelProductAllocationCommand } from '../commands';
 import { SpaceProductAllocationRepository } from '@app/common/modules/space';
 import { SubspaceModelProductAllocationRepoitory } from '@app/common/modules/space-model';
 import {
-  SubspaceProductAllocationRepository,
   SubspaceRepository,
+  SubspaceProductAllocationRepository,
 } from '@app/common/modules/space/repositories/subspace.repository';
-import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
-import { PropogateUpdateSpaceModelProductAllocationCommand } from '../commands';
 
 @CommandHandler(PropogateUpdateSpaceModelProductAllocationCommand)
 export class PropogateUpdateSpaceModelProductAllocationHandler
@@ -31,89 +31,89 @@ export class PropogateUpdateSpaceModelProductAllocationHandler
 
       console.log(`Processing ${updatedAllocations.length} allocations...`);
 
-      // for (const allocation of updatedAllocations) {
+      for (const allocation of updatedAllocations) {
-      //   try {
+        try {
-      //     if (allocation.allocation) {
+          if (allocation.allocation) {
-      //       const spaceAllocations = await this.spaceProductRepository.find({
+            const spaceAllocations = await this.spaceProductRepository.find({
-      //         where: { uuid: allocation.allocation.uuid },
+              where: { uuid: allocation.allocation.uuid },
-      //         relations: ['tags'],
+              relations: ['tags'],
-      //       });
+            });
 
-      //       if (!spaceAllocations || spaceAllocations.length === 0) {
+            if (!spaceAllocations || spaceAllocations.length === 0) {
-      //         console.warn(
+              console.warn(
-      //           `No space allocations found for UUID: ${allocation.allocation.uuid}`,
+                `No space allocations found for UUID: ${allocation.allocation.uuid}`,
-      //         );
+              );
-      //         continue;
+              continue;
-      //       }
+            }
 
-      //       if (allocation.tagsAdded?.length) {
+            if (allocation.tagsAdded?.length) {
-      //         for (const spaceAllocation of spaceAllocations) {
+              for (const spaceAllocation of spaceAllocations) {
-      //           spaceAllocation.tags.push(...allocation.tagsAdded);
+                spaceAllocation.tags.push(...allocation.tagsAdded);
-      //         }
+              }
-      //         await this.spaceProductRepository.save(spaceAllocations);
+              await this.spaceProductRepository.save(spaceAllocations);
-      //         console.log(
+              console.log(
-      //           `Added tags to ${spaceAllocations.length} space allocations.`,
+                `Added tags to ${spaceAllocations.length} space allocations.`,
-      //         );
+              );
-      //       }
+            }
 
-      //       if (allocation.tagsRemoved?.length) {
+            if (allocation.tagsRemoved?.length) {
-      //         const tagsToRemoveUUIDs = new Set(
+              const tagsToRemoveUUIDs = new Set(
-      //           allocation.tagsRemoved.map((tag) => tag.uuid),
+                allocation.tagsRemoved.map((tag) => tag.uuid),
-      //         );
+              );
 
-      //         for (const spaceAllocation of spaceAllocations) {
+              for (const spaceAllocation of spaceAllocations) {
-      //           spaceAllocation.tags = spaceAllocation.tags.filter(
+                spaceAllocation.tags = spaceAllocation.tags.filter(
-      //             (tag) => !tagsToRemoveUUIDs.has(tag.uuid),
+                  (tag) => !tagsToRemoveUUIDs.has(tag.uuid),
-      //           );
+                );
-      //         }
+              }
-      //         await this.spaceProductRepository.save(spaceAllocations);
+              await this.spaceProductRepository.save(spaceAllocations);
-      //         console.log(
+              console.log(
-      //           `Removed tags from ${spaceAllocations.length} space allocations.`,
+                `Removed tags from ${spaceAllocations.length} space allocations.`,
-      //         );
+              );
-      //       }
+            }
-      //     }
+          }
 
-      //     if (allocation.deletedAllocation) {
+          if (allocation.deletedAllocation) {
-      //       const spaceAllocations = await this.spaceProductRepository.find({
+            const spaceAllocations = await this.spaceProductRepository.find({
-      //         where: { uuid: allocation.deletedAllocation.uuid },
+              where: { uuid: allocation.deletedAllocation.uuid },
-      //         relations: ['tags'],
+              relations: ['tags'],
-      //       });
+            });
 
-      //       if (!spaceAllocations || spaceAllocations.length === 0) {
+            if (!spaceAllocations || spaceAllocations.length === 0) {
-      //         console.warn(
+              console.warn(
-      //           `No space allocations found to delete for UUID: ${allocation.deletedAllocation.uuid}`,
+                `No space allocations found to delete for UUID: ${allocation.deletedAllocation.uuid}`,
-      //         );
+              );
-      //         continue;
+              continue;
-      //       }
+            }
 
-      //       await this.spaceProductRepository.remove(spaceAllocations);
+            await this.spaceProductRepository.remove(spaceAllocations);
-      //       console.log(
+            console.log(
-      //         `Deleted ${spaceAllocations.length} space allocations.`,
+              `Deleted ${spaceAllocations.length} space allocations.`,
-      //       );
+            );
-      //     }
+          }
 
-      //     if (allocation.newAllocation) {
+          if (allocation.newAllocation) {
-      //       const newAllocations = spaces.map((space) =>
+            const newAllocations = spaces.map((space) =>
-      //         this.spaceProductRepository.create({
+              this.spaceProductRepository.create({
-      //           space,
+                space,
-      //           product: allocation.newAllocation.product,
+                product: allocation.newAllocation.product,
-      //           tag: allocation.newAllocation.tag,
+                tags: allocation.newAllocation.tags,
-      //           inheritedFromModel: allocation.newAllocation,
+                inheritedFromModel: allocation.newAllocation,
-      //         }),
+              }),
-      //       );
+            );
 
-      //       await this.spaceProductRepository.save(newAllocations);
+            await this.spaceProductRepository.save(newAllocations);
-      //       console.log(
+            console.log(
-      //         `Created ${newAllocations.length} new space allocations.`,
+              `Created ${newAllocations.length} new space allocations.`,
-      //       );
+            );
-      //     }
+          }
-      //   } catch (error) {
+        } catch (error) {
-      //     console.error(
+          console.error(
-      //       `Error processing allocation update: ${JSON.stringify(allocation)}`,
+            `Error processing allocation update: ${JSON.stringify(allocation)}`,
-      //       error,
+            error,
-      //     );
+          );
-      //   }
+        }
-      // }
+      }
 
       console.log('Finished processing all allocations.');
     } catch (error) {

src/space-model/handlers/propogate-subspace-handler.ts

@@ -1,14 +1,15 @@
-import { ModifyAction } from '@app/common/constants/modify-action.enum';
+import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
+import { PropogateUpdateSpaceModelCommand } from '../commands';
 import { SpaceProductAllocationRepository } from '@app/common/modules/space';
-import { SubspaceModelProductAllocationRepoitory } from '@app/common/modules/space-model';
-import { SpaceEntity } from '@app/common/modules/space/entities/space.entity';
 import {
   SubspaceProductAllocationRepository,
   SubspaceRepository,
 } from '@app/common/modules/space/repositories/subspace.repository';
-import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
+import { SubspaceModelProductAllocationRepoitory } from '@app/common/modules/space-model';
-import { PropogateUpdateSpaceModelCommand } from '../commands';
+import { In } from 'typeorm';
 import { ISingleSubspaceModel } from '../interfaces';
+import { SpaceEntity } from '@app/common/modules/space/entities/space.entity';
+import { ModifyAction } from '@app/common/constants/modify-action.enum';
 import { IUpdatedAllocations } from '../interfaces/subspace-product-allocation-update-result.interface';
 
 @CommandHandler(PropogateUpdateSpaceModelCommand)
@@ -71,48 +72,48 @@ export class PropogateUpdateSpaceModelHandler
       for (const allocation of allocations) {
         if (!allocation) continue;
 
-        // if (allocation.allocation) {
+        if (allocation.allocation) {
-        //   try {
+          try {
-        //     const subspaceAllocations =
+            const subspaceAllocations =
-        //       await this.subspaceProductRepository.find({
+              await this.subspaceProductRepository.find({
-        //         where: {
+                where: {
-        //           inheritedFromModel: { uuid: allocation.allocation.uuid },
+                  inheritedFromModel: { uuid: allocation.allocation.uuid },
-        //         },
+                },
-        //         relations: ['tags'],
+                relations: ['tags'],
-        //       });
+              });
 
-        //     if (!subspaceAllocations || subspaceAllocations.length === 0)
+            if (!subspaceAllocations || subspaceAllocations.length === 0)
-        //       continue;
+              continue;
 
-        //     if (allocation.tagsAdded?.length) {
+            if (allocation.tagsAdded?.length) {
-        //       for (const subspaceAllocation of subspaceAllocations) {
+              for (const subspaceAllocation of subspaceAllocations) {
-        //         subspaceAllocation.tags.push(...allocation.tagsAdded);
+                subspaceAllocation.tags.push(...allocation.tagsAdded);
-        //       }
+              }
-        //       await this.subspaceProductRepository.save(subspaceAllocations);
+              await this.subspaceProductRepository.save(subspaceAllocations);
-        //       console.log(
+              console.log(
-        //         `Added tags to ${subspaceAllocations.length} subspace allocations.`,
+                `Added tags to ${subspaceAllocations.length} subspace allocations.`,
-        //       );
+              );
-        //     }
+            }
 
-        //     if (allocation.tagsRemoved?.length) {
+            if (allocation.tagsRemoved?.length) {
-        //       const tagsToRemoveUUIDs = allocation.tagsRemoved.map(
+              const tagsToRemoveUUIDs = allocation.tagsRemoved.map(
-        //         (tag) => tag.uuid,
+                (tag) => tag.uuid,
-        //       );
+              );
 
-        //       for (const subspaceAllocation of subspaceAllocations) {
+              for (const subspaceAllocation of subspaceAllocations) {
-        //         subspaceAllocation.tags = subspaceAllocation.tags.filter(
+                subspaceAllocation.tags = subspaceAllocation.tags.filter(
-        //           (tag) => !tagsToRemoveUUIDs.includes(tag.uuid),
+                  (tag) => !tagsToRemoveUUIDs.includes(tag.uuid),
-        //         );
+                );
-        //       }
+              }
-        //       await this.subspaceProductRepository.save(subspaceAllocations);
+              await this.subspaceProductRepository.save(subspaceAllocations);
-        //       console.log(
+              console.log(
-        //         `Removed tags from ${subspaceAllocations.length} subspace allocations.`,
+                `Removed tags from ${subspaceAllocations.length} subspace allocations.`,
-        //       );
+              );
-        //     }
+            }
-        //   } catch (error) {
+          } catch (error) {
-        //     console.error('Error processing allocation update:', error);
+            console.error('Error processing allocation update:', error);
-        //   }
+          }
-        // }
+        }
 
         if (allocation.newAllocation) {
           try {
@@ -126,7 +127,7 @@ export class PropogateUpdateSpaceModelHandler
             const newAllocations = subspaces.map((subspace) =>
               this.subspaceProductRepository.create({
                 product: allocation.newAllocation.product,
-                tag: allocation.newAllocation.tag,
+                tags: allocation.newAllocation.tags,
                 subspace,
                 inheritedFromModel: allocation.newAllocation,
               }),
@@ -197,7 +198,7 @@ export class PropogateUpdateSpaceModelHandler
           const subspaceAllocation = this.subspaceProductRepository.create({
             subspace: subspace,
             product: allocation.product,
-            tag: allocation.tag,
+            tags: allocation.tags,
             inheritedFromModel: allocation,
           });
           await this.subspaceProductRepository.save(subspaceAllocation);
@@ -210,59 +211,67 @@ export class PropogateUpdateSpaceModelHandler
     subspaceModel: ISingleSubspaceModel,
     spaces: SpaceEntity[],
   ) {
-    // const subspaces = await this.subspaceRepository.find({
+    const subspaces = await this.subspaceRepository.find({
-    //   where: {
+      where: {
-    //     subSpaceModel: { uuid: subspaceModel.subspaceModel.uuid },
+        subSpaceModel: { uuid: subspaceModel.subspaceModel.uuid },
-    //     disabled: false,
+        disabled: false,
-    //   },
+      },
-    //   relations: [
+      relations: [
-    //     'productAllocations',
+        'productAllocations',
-    //     'productAllocations.product',
+        'productAllocations.product',
-    //     'productAllocations.tags',
+        'productAllocations.tags',
-    //   ],
+      ],
-    // });
+    });
-    // if (!subspaces.length) {
+
-    //   return;
+    if (!subspaces.length) {
-    // }
+      return;
-    // const allocationUuidsToRemove = subspaces.flatMap((subspace) =>
+    }
-    //   subspace.productAllocations.map((allocation) => allocation.uuid),
+
-    // );
+    const allocationUuidsToRemove = subspaces.flatMap((subspace) =>
-    // if (allocationUuidsToRemove.length) {
+      subspace.productAllocations.map((allocation) => allocation.uuid),
-    //   await this.subspaceProductRepository.delete(allocationUuidsToRemove);
+    );
-    // }
+
-    // await this.subspaceRepository.update(
+    if (allocationUuidsToRemove.length) {
-    //   { uuid: In(subspaces.map((s) => s.uuid)) },
+      await this.subspaceProductRepository.delete(allocationUuidsToRemove);
-    //   { disabled: true },
+    }
-    // );
+
-    // const relocatedAllocations = subspaceModel.relocatedAllocations || [];
+    await this.subspaceRepository.update(
-    // if (!relocatedAllocations.length) {
+      { uuid: In(subspaces.map((s) => s.uuid)) },
-    //   return;
+      { disabled: true },
-    // }
+    );
-    // for (const space of spaces) {
+
-    //   for (const { allocation, tags = [] } of relocatedAllocations) {
+    const relocatedAllocations = subspaceModel.relocatedAllocations || [];
-    //     const spaceAllocation = await this.spaceProductRepository.findOne({
+
-    //       where: {
+    if (!relocatedAllocations.length) {
-    //         inheritedFromModel: { uuid: allocation.uuid },
+      return;
-    //         space: { uuid: space.uuid },
+    }
-    //       },
+
-    //       relations: ['tags'],
+    for (const space of spaces) {
-    //     });
+      for (const { allocation, tags = [] } of relocatedAllocations) {
-    //     if (spaceAllocation) {
+        const spaceAllocation = await this.spaceProductRepository.findOne({
-    //       if (tags.length) {
+          where: {
-    //         spaceAllocation.tags.push(...tags);
+            inheritedFromModel: { uuid: allocation.uuid },
-    //         await this.spaceProductRepository.save(spaceAllocation);
+            space: { uuid: space.uuid },
-    //       }
+          },
-    //     } else {
+          relations: ['tags'],
-    //       const newSpaceAllocation = this.spaceProductRepository.create({
+        });
-    //         space,
+
-    //         inheritedFromModel: allocation,
+        if (spaceAllocation) {
-    //         tag: allocation.tag,
+          if (tags.length) {
-    //         product: allocation.product,
+            spaceAllocation.tags.push(...tags);
-    //       });
+            await this.spaceProductRepository.save(spaceAllocation);
-    //       await this.spaceProductRepository.save(newSpaceAllocation);
+          }
-    //     }
+        } else {
-    //   }
+          const newSpaceAllocation = this.spaceProductRepository.create({
-    // }
+            space,
+            inheritedFromModel: allocation,
+            tags: allocation.tags,
+            product: allocation.product,
+          });
+          await this.spaceProductRepository.save(newSpaceAllocation);
+        }
+      }
+    }
   }
 
   async updateSubspaceModel(subspaceModel: ISingleSubspaceModel) {

src/space-model/interfaces/index.ts

@@ -1,3 +1,4 @@
+export * from './update-subspace.interface';
+export * from './modify-subspace.interface';
 export * from './single-subspace.interface';
 export * from './space-product-allocation.interface';
-export * from './update-subspace.interface';