added commissioning endpoint

src/app.module.ts

@@ -30,6 +30,7 @@ import { TermsConditionsModule } from './terms-conditions/terms-conditions.modul
 import { PrivacyPolicyModule } from './privacy-policy/privacy-policy.module';
 import { TagModule } from './tags/tags.module';
 import { ClientModule } from './client/client.module';
+import { DeviceCommissionModule } from './commission-device/commission-device.module';
 @Module({
   imports: [
     ConfigModule.forRoot({
@@ -63,6 +64,8 @@ import { ClientModule } from './client/client.module';
     TermsConditionsModule,
     PrivacyPolicyModule,
     TagModule,
+
+    DeviceCommissionModule,
   ],
   providers: [
     {

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

@@ -0,0 +1,45 @@
+import { SpaceRepositoryModule } from '@app/common/modules/space/space.repository.module';
+import { Module } from '@nestjs/common';
+import { ConfigModule } from '@nestjs/config';
+import { DeviceCommissionController } from './controllers';
+import { UserRepository } from '@app/common/modules/user/repositories';
+import { DeviceRepository } from '@app/common/modules/device/repositories';
+import { DeviceCommissionService } from './services';
+import { TuyaService } from '@app/common/integrations/tuya/services/tuya.service';
+import { DeviceService } from 'src/device/services';
+import { SceneDeviceRepository } from '@app/common/modules/scene-device/repositories';
+import { ProductRepository } from '@app/common/modules/product/repositories';
+import { DeviceStatusFirebaseService } from '@app/common/firebase/devices-status/services/devices-status.service';
+import { SpaceRepository } from '@app/common/modules/space';
+import { SceneService } from 'src/scene/services';
+import { ProjectRepository } from '@app/common/modules/project/repositiories';
+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';
+
+@Module({
+  imports: [ConfigModule, SpaceRepositoryModule],
+  controllers: [DeviceCommissionController],
+  providers: [
+    UserRepository,
+    DeviceRepository,
+    DeviceCommissionService,
+    TuyaService,
+    DeviceService,
+    SceneDeviceRepository,
+    ProductRepository,
+    DeviceStatusFirebaseService,
+    SpaceRepository,
+    SceneService,
+    ProjectRepository,
+    DeviceStatusLogRepository,
+    SceneIconRepository,
+    SceneRepository,
+    AutomationRepository,
+  ],
+  exports: [],
+})
+export class DeviceCommissionModule {}

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

@@ -0,0 +1,74 @@
+import {
+  Controller,
+  Post,
+  Req,
+  UseGuards,
+  UploadedFile,
+  UseInterceptors,
+  UsePipes,
+  ValidationPipe,
+  Param,
+} from '@nestjs/common';
+import {
+  ApiBearerAuth,
+  ApiConsumes,
+  ApiOperation,
+  ApiTags,
+  ApiBody,
+} from '@nestjs/swagger';
+import { FileInterceptor } from '@nestjs/platform-express';
+import { diskStorage } from 'multer';
+import { ControllerRoute } from '@app/common/constants/controller-route';
+import { EnableDisableStatusEnum } from '@app/common/constants/days.enum';
+import { BaseResponseDto } from '@app/common/dto/base.response.dto';
+import { CommissionDeviceCsvDto } from '../dto';
+import { CommunityParam } from '@app/common/dto/community-space.param';
+import { DeviceCommissionService } from '../services';
+import { ProjectParam } from '@app/common/dto/project-param.dto';
+
+@ApiTags('Commission Devices Module')
+@Controller({
+  version: EnableDisableStatusEnum.ENABLED,
+  path: ControllerRoute.DEVICE_COMMISSION.ROUTE,
+})
+export class DeviceCommissionController {
+  constructor(private readonly commissionService: DeviceCommissionService) {}
+
+  @ApiBearerAuth()
+  @Post()
+  @ApiConsumes('multipart/form-data')
+  @UseInterceptors(
+    FileInterceptor('file', {
+      storage: diskStorage({
+        destination: './uploads',
+        filename: (req, file, cb) => {
+          cb(null, `${Date.now()}-${file.originalname}`);
+        },
+      }),
+      fileFilter: (req, file, cb) => {
+        if (!file.originalname.match(/\.(csv)$/)) {
+          return cb(new Error('Only CSV files are allowed!'), false);
+        }
+        cb(null, true);
+      },
+    }),
+  )
+  @ApiBody({ type: CommissionDeviceCsvDto })
+  @ApiOperation({
+    summary: ControllerRoute.DEVICE_COMMISSION.ACTIONS.ADD_ALL_DEVICES_SUMMARY,
+    description:
+      ControllerRoute.DEVICE_COMMISSION.ACTIONS.ADD_ALL_DEVICES_DESCRIPTION,
+  })
+  @UsePipes(new ValidationPipe({ transform: true }))
+  async addNewDevice(
+    @UploadedFile() file: Express.Multer.File,
+    @Param() param: ProjectParam,
+    @Req() req: any,
+  ): Promise<BaseResponseDto> {
+    await this.commissionService.processCsv(file.path);
+    return {
+      message: 'CSV file received and processing started',
+      success: true,
+    };
+  }
+}

src/commission-device/controllers/index.ts

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

src/commission-device/dto/commission-device.dto.ts

@@ -0,0 +1,18 @@
+// dto/commission-device.dto.ts
+
+import { ApiProperty } from '@nestjs/swagger';
+import { IsNotEmpty, Validate } from 'class-validator';
+import { FileValidator } from 'src/validators/file.validator';
+
+export class CommissionDeviceCsvDto {
+  @ApiProperty({
+    type: 'string',
+    format: 'binary',
+    description: 'CSV file containing device data',
+  })
+  @IsNotEmpty({ message: 'CSV file is required' })
+  @Validate(FileValidator, ['text/csv', 'application/vnd.ms-excel'], {
+    message: 'Only CSV files are allowed',
+  })
+  file: any;
+}

src/commission-device/dto/index.ts

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

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

@@ -0,0 +1,45 @@
+import * as fs from 'fs';
+import * as csv from 'csv-parser';
+
+import { TuyaService } from '@app/common/integrations/tuya/services/tuya.service';
+import { Injectable } from '@nestjs/common';
+import { DeviceService } from 'src/device/services';
+
+@Injectable()
+export class DeviceCommissionService {
+  constructor(
+    private readonly tuyaService: TuyaService,
+    private readonly deviceService: DeviceService,
+  ) {}
+
+  async processCsv(filePath: string): Promise<void> {
+    return new Promise((resolve, reject) => {
+      const results = [];
+
+      fs.createReadStream(filePath)
+        .pipe(csv())
+        .on('data', async (row) => {
+          console.log(`Device: ${JSON.stringify(row)}`);
+          const deviceId = row.deviceId?.trim();
+
+          if (!deviceId) {
+            console.error('Missing deviceId or deviceName in row:', row);
+            return;
+          } else {
+            const device = await this.tuyaService.getDeviceDetails(
+              row.deviceId,
+            );
+            console.log(device);
+          }
+        })
+        .on('end', () => {
+          console.log(`Finished processing ${results.length} devices.`);
+          resolve();
+        })
+        .on('error', (error) => {
+          console.error('Error reading CSV', error);
+          reject(error);
+        });
+    });
+  }
+}

src/commission-device/services/index.ts

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

src/validators/file.validator.ts

@@ -0,0 +1,19 @@
+import {
+  ValidatorConstraint,
+  ValidatorConstraintInterface,
+  ValidationArguments,
+} from 'class-validator';
+
+@ValidatorConstraint({ name: 'fileValidator', async: false })
+export class FileValidator implements ValidatorConstraintInterface {
+  constructor(private readonly allowedMimeTypes: string[]) {}
+
+  validate(file: Express.Multer.File, _args: ValidationArguments) {
+    if (!file || !file.mimetype) return false;
+    return this.allowedMimeTypes.includes(file.mimetype);
+  }
+
+  defaultMessage(_args: ValidationArguments) {
+    return 'Invalid file type';
+  }
+}