api/delete device

Author: huongdang0208

src/modules/authenticate/authenticate.module.ts

@@ -23,7 +23,7 @@ import { ConfigModule, ConfigService } from "@nestjs/config";
             imports: [ConfigModule],
             useFactory: async (configService: ConfigService) => ({
                 secret: configService.get<string>("JWT_SECRET"),
-                signOptions: { expiresIn: "60m" },
+                signOptions: { expiresIn: "2h" },
             }),
             inject: [ConfigService],
         }),

src/modules/authenticate/authenticate.service.ts

@@ -96,7 +96,7 @@ export class AuthenticateService {
                 },
                 {
                     secret: this.configService.get("JWT_SECRET"),
-                    expiresIn: "1h",
+                    expiresIn: "2h",
                 },
             ),
             this.jwtService.signAsync(

src/modules/device/device.resolver.ts

@@ -2,7 +2,7 @@ import { UseGuards } from "@nestjs/common";
 import { Args, Mutation, Query, Resolver } from "@nestjs/graphql";
 import { JwtAuthGuard } from "../../guards/auth/auth.guard";
 import { DeviceService } from "./device.service";
-import { CreateDeviceInput, UpdateItemInput, CreateDevicesInput } from "./dto/input.dto";
+import { CreateDeviceInput, UpdateItemInput, CreateDevicesInput, DeleteDeviceInput } from "./dto/input.dto";
 import { DeviceQueryInput } from "./dto/query.dto";
 import { DevicesResponse } from "./dto/response.dto";
 import { DeviceResponse } from "./entities/device.entity";
@@ -37,6 +37,12 @@ export class DeviceResolver {
         return this.deviceService.update(input);
     }
 
+    @Mutation(() => String)
+    @UseGuards(JwtAuthGuard)
+    async delete_device(@Args("input") input: DeleteDeviceInput) {
+        return this.deviceService.delete(input);
+    }
+
     @Query(() => DevicesResponse)
     async devices_by_license(@Args("license") license: string) {
         const data = await this.deviceService.findDevicesByLicense(license);

src/modules/device/device.service.ts

@@ -1,22 +1,61 @@
 import { Injectable } from "@nestjs/common";
 import { GraphQLError } from "graphql";
-import { CreateDeviceInput, UpdateItemInput, CreateDevicesInput } from "./dto/input.dto";
+import { CreateDeviceInput, UpdateItemInput, CreateDevicesInput, DeleteDeviceInput } from "./dto/input.dto";
 import { DeviceQueryInput } from "./dto/query.dto";
 import { PrismaService } from "../prisma/prisma.service";
 
 @Injectable()
 export class DeviceService {
+    private readonly esp32s3Pin = [2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 21, 22, 23, 25, 26, 27, 32, 33, 34, 35, 36, 39];
+    private readonly esp32DevKitPin = [2, 4, 12, 13, 14, 15, 16, 17, 18, 19, 21, 22, 23, 25, 26, 27, 32, 33];
+    private readonly esp32c6Pin = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40];
     constructor(private prisma: PrismaService) {}
 
     async create(input: CreateDeviceInput) {
         try {
+            var pin: number;
+            if (input.protocol === "BLE") {
+                const listBLEDevices = await this.prisma.device.findMany({
+                    where: {
+                        protocol: "BLE",
+                    },
+                });
+                this.esp32DevKitPin.forEach((element) => {
+                    if (!listBLEDevices.find((device) => device.pin === element)) {
+                        pin = element;
+                    }
+                });
+            } else if (input.protocol === "MQTT") {
+                const listMQTTDevices = await this.prisma.device.findMany({
+                    where: {
+                        protocol: "MQTT",
+                    },
+                });
+                this.esp32s3Pin.forEach((element) => {
+                    if (!listMQTTDevices.find((device) => device.pin === element)) {
+                        pin = element;
+                    }
+                });
+            } else {
+                const listDevices = await this.prisma.device.findMany({
+                    where: {
+                        protocol: "ZIGBEE",
+                    },
+                });
+                this.esp32c6Pin.forEach((element) => {
+                    if (!listDevices.find((device) => device.pin === element)) {
+                        pin = element;
+                    }
+                });
+            }
+
             const data = await this.prisma.device.create({
                 data: {
                     device_name: input.device_name,
                     current_state: input.current_state,
                     userID: input.userID,
                     protocol: input.protocol,
-                    pin: input.pin,
+                    pin: pin,
                 },
             });
             return data;
@@ -96,4 +135,15 @@ export class DeviceService {
             throw new GraphQLError(err);
         }
     }
+
+    async delete(input: DeleteDeviceInput) {
+        try {
+            const data = await this.prisma.device.delete({
+                where: { id: input.id },
+            });
+            return "Device deleted successfully";
+        } catch (err) {
+            throw new GraphQLError(err);
+        }
+    }
 }

src/modules/device/dto/input.dto.ts

@@ -20,7 +20,7 @@ export class CreateDeviceInput {
     @IsString()
     protocol: string;
 
-    @Field(() => Number, { nullable: false })
+    @Field(() => Number, { nullable: true })
     @IsNumber()
     pin: number;
 }
@@ -36,6 +36,13 @@ export class UpdateItemInput {
     current_state: number;
 }
 
+@InputType()
+export class DeleteDeviceInput {
+    @Field(() => Number, { nullable: false })
+    @IsNumber()
+    id: number;
+}
+
 @InputType()
 export class CreateDevicesInput {
     @Field(() => [CreateDeviceInput])

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

@@ -23,7 +23,7 @@ export class DeviceResponse {
     @IsString()
     protocol: string;
 
-    @Field(() => Number, { nullable: false })
+    @Field(() => Number, { nullable: true })
     @IsNumber()
     pin: number;