Added tuya space to community

libs/common/src/common.module.ts

@@ -7,10 +7,12 @@ import { ConfigModule } from '@nestjs/config';
 import config from './config';
 import { EmailService } from './util/email.service';
 import { ErrorMessageService } from 'src/error-message/error-message.service';
+import { TuyaService } from './integrations/tuya/tuya.service';
 @Module({
-  providers: [CommonService, EmailService, ErrorMessageService],
+  providers: [CommonService, EmailService, ErrorMessageService, TuyaService],
   exports: [
     CommonService,
+    TuyaService,
     HelperModule,
     AuthModule,
     EmailService,

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

@@ -13,10 +13,10 @@ export class ControllerRoute {
     public static readonly ROUTE = 'community';
     static ACTIONS = class {
       public static readonly GET_COMMUNITY_BY_ID_SUMMARY =
-        'Get community by community id';
+        'Get community by community community uuid';
 
       public static readonly GET_COMMUNITY_BY_ID_DESCRIPTION =
-        'Get community by community id - ( [a-zA-Z0-9]{10} )';
+        'Get community by community community uuid - ( [a-zA-Z0-9]{10} )';
 
       public static readonly LIST_COMMUNITY_SUMMARY = 'Get list of community';
 
@@ -40,7 +40,7 @@ export class ControllerRoute {
   };
 
   static COMMUNITY_SPACE = class {
-    public static readonly ROUTE = 'community/:id/spaces';
+    public static readonly ROUTE = 'community/:communityUuid/space';
     static ACTIONS = class {
       public static readonly GET_COMMUNITY_SPACES_HIERARCHY_SUMMARY =
         'Fetch hierarchical structure of spaces within a community.';

libs/common/src/integrations/tuya/tuya.service.ts

@@ -0,0 +1,38 @@
+import { HttpException, HttpStatus, Injectable } from '@nestjs/common';
+import { ConfigService } from '@nestjs/config';
+import { TuyaContext } from '@tuya/tuya-connector-nodejs';
+
+@Injectable()
+export class TuyaService {
+  private tuya: TuyaContext;
+
+  constructor(private readonly configService: ConfigService) {
+    const accessKey = this.configService.get<string>('auth-config.ACCESS_KEY');
+    const secretKey = this.configService.get<string>('auth-config.SECRET_KEY');
+    const tuyaEuUrl = this.configService.get<string>('tuya-config.TUYA_EU_URL');
+    this.tuya = new TuyaContext({
+      baseUrl: tuyaEuUrl,
+      accessKey,
+      secretKey,
+    });
+  }
+  async createSpace({ name }: { name: string }) {
+    const path = '/v2.0/cloud/space/creation';
+    const body = { name };
+
+    const response = await this.tuya.request({
+      method: 'POST',
+      path,
+      body,
+    });
+
+    if (response.success) {
+      return response.result as string;
+    } else {
+      throw new HttpException(
+        'Error creating space in Tuya',
+        HttpStatus.INTERNAL_SERVER_ERROR,
+      );
+    }
+  }
+}

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

@@ -1,7 +1,6 @@
-import { Column, Entity, ManyToOne, OneToMany, Unique } from 'typeorm';
+import { Column, Entity, OneToMany, Unique } from 'typeorm';
 import { AbstractEntity } from '../../abstract/entities/abstract.entity';
 import { CommunityDto } from '../dtos';
-import { RegionEntity } from '../../region/entities';
 import { SpaceEntity } from '../../space/entities';
 
 @Entity({ name: 'community' })
@@ -23,12 +22,6 @@ export class CommunityEntity extends AbstractEntity<CommunityDto> {
   @Column({ length: 255, nullable: true })
   description: string;
 
-  @ManyToOne(() => RegionEntity, (region) => region.communities, {
-    nullable: false,
-    onDelete: 'CASCADE',
-  })
-  region: RegionEntity;
-
   @OneToMany(() => SpaceEntity, (space) => space.community)
   spaces: SpaceEntity[];
 

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

@@ -2,7 +2,6 @@ import { Column, Entity, OneToMany } from 'typeorm';
 import { RegionDto } from '../dtos';
 import { AbstractEntity } from '../../abstract/entities/abstract.entity';
 import { UserEntity } from '../../user/entities';
-import { CommunityEntity } from '../../community/entities';
 
 @Entity({ name: 'region' })
 export class RegionEntity extends AbstractEntity<RegionDto> {
@@ -14,9 +13,6 @@ export class RegionEntity extends AbstractEntity<RegionDto> {
   @OneToMany(() => UserEntity, (user) => user.region)
   users: UserEntity[];
 
-  @OneToMany(() => CommunityEntity, (community) => community.region)
-  communities: CommunityEntity[];
-
   constructor(partial: Partial<RegionEntity>) {
     super();
     Object.assign(this, partial);

src/community/community.module.ts

@@ -11,7 +11,7 @@ import { SpacePermissionService } from '@app/common/helper/services';
 import { CommunitySpaceService } from './services';
 import { CommunitySpaceController } from './controllers';
 import { CommunityRepository } from '@app/common/modules/community/repositories';
-import { RegionRepository } from '@app/common/modules/region/repositories';
+import { TuyaService } from '@app/common/integrations/tuya/tuya.service';
 
 @Module({
   imports: [ConfigModule, SpaceRepositoryModule, UserRepositoryModule],
@@ -22,7 +22,7 @@ import { RegionRepository } from '@app/common/modules/region/repositories';
     SpaceRepository,
     SpaceTypeRepository,
     UserSpaceRepository,
-    RegionRepository,
+    TuyaService,
     CommunityRepository,
     SpacePermissionService,
   ],

src/community/dtos/add.community.dto.ts

@@ -20,14 +20,6 @@ export class AddCommunityDto {
   @IsOptional()
   public description?: string;
 
-  @ApiProperty({
-    description: 'The UUID of the region this community belongs to',
-    example: 'b6fa62c5-4fcf-4872-89a0-571cf431a6c7',
-  })
-  @IsUUID()
-  @IsNotEmpty()
-  public regionId: string;
-
   constructor(dto: Partial<AddCommunityDto>) {
     Object.assign(this, dto);
   }

src/community/services/community.service.ts

@@ -1,7 +1,6 @@
 import { Injectable, HttpException, HttpStatus } from '@nestjs/common';
 import { AddCommunityDto } from '../dtos';
 import { UpdateCommunityNameDto } from '../dtos/update.community.dto';
-import { RegionRepository } from '@app/common/modules/region/repositories';
 import { BaseResponseDto } from '@app/common/dto/base.response.dto';
 import {
   TypeORMCustomModel,
@@ -11,23 +10,25 @@ import { PageResponse } from '@app/common/dto/pagination.response.dto';
 import { CommunityRepository } from '@app/common/modules/community/repositories';
 import { CommunityDto } from '@app/common/modules/community/dtos';
 import { SuccessResponseDto } from '@app/common/dto/success.response.dto';
+import { TuyaService } from '@app/common/integrations/tuya/tuya.service';
 
 @Injectable()
 export class CommunityService {
   constructor(
     private readonly communityRepository: CommunityRepository,
-    private readonly regionRepository: RegionRepository,
+    private readonly tuyaService: TuyaService,
   ) {}
 
   async createCommunity(dto: AddCommunityDto): Promise<BaseResponseDto> {
-    const { regionId, name, description } = dto;
-    // Find the region by the provided regionId
-    const region = await this.regionRepository.findOneBy({ uuid: regionId });
+    const { name, description } = dto;
 
-    if (!region) {
+    const existingCommunity = await this.communityRepository.findOneBy({
+      name,
+    });
+    if (existingCommunity) {
       throw new HttpException(
-        `Region with ID ${dto.regionId} not found.`,
-        HttpStatus.NOT_FOUND,
+        `A community with the name '${name}' already exists.`,
+        HttpStatus.BAD_REQUEST,
       );
     }
 
@@ -35,11 +36,12 @@ export class CommunityService {
     const community = this.communityRepository.create({
       name: name,
       description: description,
-      region: region, // Associate with the found region
     });
 
     // Save the community to the database
     try {
+      const externalId = await this.createTuyaSpace(name);
+      community.externalId = externalId;
       await this.communityRepository.save(community);
       return new SuccessResponseDto({
         statusCode: HttpStatus.CREATED,
@@ -52,13 +54,15 @@ export class CommunityService {
     }
   }
 
-  async getCommunityById(id: string): Promise<BaseResponseDto> {
-    const community = await this.communityRepository.findOneBy({ uuid: id });
+  async getCommunityById(communityUuid: string): Promise<BaseResponseDto> {
+    const community = await this.communityRepository.findOneBy({
+      uuid: communityUuid,
+    });
 
     // If the community is not found, throw a 404 NotFoundException
     if (!community) {
       throw new HttpException(
-        `Community with ID ${id} not found.`,
+        `Community with ID ${communityUuid} not found.`,
         HttpStatus.NOT_FOUND,
       );
     }
@@ -87,17 +91,17 @@ export class CommunityService {
   }
 
   async updateCommunity(
-    id: string,
+    communityUuid: string,
     updateCommunityDto: UpdateCommunityNameDto,
   ): Promise<BaseResponseDto> {
     const community = await this.communityRepository.findOne({
-      where: { uuid: id },
+      where: { uuid: communityUuid },
     });
 
     // If the community doesn't exist, throw a 404 error
     if (!community) {
       throw new HttpException(
-        `Community with ID ${id} not found`,
+        `Community with ID ${communityUuid} not found`,
         HttpStatus.NOT_FOUND,
       );
     }
@@ -129,15 +133,15 @@ export class CommunityService {
     }
   }
 
-  async deleteCommunity(id: string): Promise<BaseResponseDto> {
+  async deleteCommunity(communityUuid: string): Promise<BaseResponseDto> {
     const community = await this.communityRepository.findOne({
-      where: { uuid: id },
+      where: { uuid: communityUuid },
     });
 
     // If the community is not found, throw an error
     if (!community) {
       throw new HttpException(
-        `Community with ID ${id} not found`,
+        `Community with ID ${communityUuid} not found`,
         HttpStatus.NOT_FOUND,
       );
     }
@@ -145,11 +149,10 @@ export class CommunityService {
       // Find the community by its uuid
 
       // Remove the community from the database
-      await this.communityRepository.remove(community);
 
       // Return success response
       return new SuccessResponseDto({
-        message: `Community with ID ${id} successfully deleted`,
+        message: `Community with ID ${communityUuid} successfully deleted`,
         data: null,
       });
     } catch (err) {
@@ -164,4 +167,16 @@ export class CommunityService {
       }
     }
   }
+
+  private async createTuyaSpace(name: string): Promise<string> {
+    try {
+      const response = await this.tuyaService.createSpace({ name });
+      return response;
+    } catch (error) {
+      throw new HttpException(
+        'Failed to create a Tuya space',
+        HttpStatus.INTERNAL_SERVER_ERROR,
+      );
+    }
+  }
 }