finished update schedule endpoint

This commit is contained in:
faris Aljohari
2024-10-01 17:16:50 -05:00
parent e69b5a44d7
commit c387c5984d
3 changed files with 148 additions and 3 deletions

View File

@ -17,6 +17,7 @@ import {
AddScheduleDto,
EnableScheduleDto,
GetScheduleDeviceDto,
UpdateScheduleDto,
} from '../dtos/schedule.dto';
import { JwtAuthGuard } from '@app/common/guards/jwt.auth.guard';
@ -36,7 +37,7 @@ export class ScheduleController {
@Body() addScheduleDto: AddScheduleDto,
) {
try {
const device = await this.scheduleService.addDeviceSchedule(
const schedule = await this.scheduleService.addDeviceSchedule(
deviceUuid,
addScheduleDto,
);
@ -45,7 +46,7 @@ export class ScheduleController {
statusCode: HttpStatus.CREATED,
success: true,
message: 'schedule added successfully',
data: device,
data: schedule,
};
} catch (error) {
throw new HttpException(
@ -118,4 +119,30 @@ export class ScheduleController {
);
}
}
@ApiBearerAuth()
@UseGuards(JwtAuthGuard)
@Put(':deviceUuid')
async updateDeviceSchedule(
@Param('deviceUuid') deviceUuid: string,
@Body() updateScheduleDto: UpdateScheduleDto,
) {
try {
const schedule = await this.scheduleService.updateDeviceSchedule(
deviceUuid,
updateScheduleDto,
);
return {
statusCode: HttpStatus.CREATED,
success: true,
message: 'schedule updated successfully',
data: schedule,
};
} catch (error) {
throw new HttpException(
error.message || 'Internal server error',
error.status || HttpStatus.INTERNAL_SERVER_ERROR,
);
}
}
}

View File

@ -91,3 +91,48 @@ export class GetScheduleDeviceDto {
@IsNotEmpty()
public category: string;
}
export class UpdateScheduleDto {
@ApiProperty({
description: 'scheduleId',
required: true,
})
@IsString()
@IsNotEmpty()
public scheduleId: string;
@ApiProperty({
description: 'category',
required: true,
})
@IsString()
@IsNotEmpty()
public category: string;
@ApiProperty({
description: 'time',
required: true,
})
@IsString()
@IsNotEmpty()
public time: string;
@ApiProperty({
description: 'function',
required: true,
type: FunctionDto,
})
@ValidateNested()
@Type(() => FunctionDto)
public function: FunctionDto;
@ApiProperty({
description: 'days',
enum: WorkingDays,
isArray: true,
required: true,
})
@IsArray()
@IsEnum(WorkingDays, { each: true })
@IsNotEmpty()
public days: WorkingDays[];
}

View File

@ -1,7 +1,11 @@
import { Injectable, HttpException, HttpStatus } from '@nestjs/common';
import { TuyaContext } from '@tuya/tuya-connector-nodejs';
import { ConfigService } from '@nestjs/config';
import { AddScheduleDto, EnableScheduleDto } from '../dtos/schedule.dto';
import {
AddScheduleDto,
EnableScheduleDto,
UpdateScheduleDto,
} from '../dtos/schedule.dto';
import {
addScheduleDeviceInterface,
getDeviceScheduleInterface,
@ -282,4 +286,73 @@ export class ScheduleService {
...(withProductDevice && { relations: ['productDevice'] }),
});
}
async updateDeviceSchedule(
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
if (
deviceDetails.productDevice.prodType !== ProductType.THREE_G &&
deviceDetails.productDevice.prodType !== ProductType.ONE_G &&
deviceDetails.productDevice.prodType !== ProductType.TWO_G &&
deviceDetails.productDevice.prodType !== ProductType.WH
) {
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> {
try {
const convertedTime = convertTimestampToDubaiTime(updateScheduleDto.time);
const loops = getScheduleStatus(updateScheduleDto.days);
const path = `/v2.0/cloud/timer/device/${deviceId}`;
const response = await this.tuya.request({
method: 'PUT',
path,
body: {
timer_id: updateScheduleDto.scheduleId,
time: convertedTime.time,
timezone_id: 'Asia/Dubai',
loops: `${loops}`,
functions: [
{
code: updateScheduleDto.function.code,
value: updateScheduleDto.function.value,
},
],
category: `category_${updateScheduleDto.category}`,
},
});
return response as addScheduleDeviceInterface;
} catch (error) {
throw new HttpException(
'Error updating schedule from Tuya',
HttpStatus.INTERNAL_SERVER_ERROR,
);
}
}
}