Compare commits

...

15 Commits

Author SHA1 Message Date
4b9127676e add pagination to device API 2025-07-21 14:10:07 +03:00
212d0d1974 change month format from MM/YYYY to MM-YYYY
change month format from MM/YYYY to MM-YYYY
2025-07-20 13:28:25 +03:00
6d529ee0ae change month format from MM/YYYY to MM-YYYY 2025-07-17 15:22:20 +04:00
85687e7950 fix: refactor device status logging and improve property handling in batch processing 2025-07-16 20:05:58 -06:00
7e2c3136cf fix: update workflow to use OpenAI for PR description generation 2025-07-16 00:28:20 -06:00
61348aa351 fix: update workflow to use HuggingFace Falcon model for PR description generation 2025-07-16 00:08:08 -06:00
dea942f11e fix: update workflow to use HuggingFace for PR description generation 2025-07-16 00:05:33 -06:00
d62e620828 fix: update workflow name and enhance OpenAI request handling in AI PR Description 2025-07-15 23:47:45 -06:00
f0556813ac fix: update workflow name and enhance commit message handling in AI PR Description 2025-07-15 23:45:16 -06:00
6d2252a403 fix: add debug information to AI PR Description workflow 2025-07-15 23:43:00 -06:00
8d265c9105 fix: update workflow name and change GitHub token secret 2025-07-15 23:38:57 -06:00
a4095c837b fix: rename workflow and update AI description generation method 2025-07-15 23:19:22 -06:00
65d4a56135 fix: update GitHub CLI installation method and refine AI PR description prompt 2025-07-15 19:00:23 -06:00
fffa27b6ee Add AI PR Description Action 2025-07-15 18:48:43 -06:00
12579fcd6e fix nodemailer import (#473) 2025-07-15 16:46:50 +03:00
17 changed files with 243 additions and 105 deletions

64
.github/workflows/pr-description.yml vendored Normal file
View File

@ -0,0 +1,64 @@
name: 🤖 AI PR Description Commenter (100% Safe with jq)
on:
pull_request:
types: [opened, edited]
jobs:
generate-description:
runs-on: ubuntu-latest
steps:
- name: Checkout Repo
uses: actions/checkout@v4
- name: Install GitHub CLI and jq
run: |
sudo apt-get update
sudo apt-get install gh jq -y
- name: Fetch PR Commits
id: fetch_commits
run: |
COMMITS=$(gh pr view ${{ github.event.pull_request.number }} --json commits --jq '.commits[].message' | sed 's/^/- /')
echo "commits<<EOF" >> $GITHUB_ENV
echo "$COMMITS" >> $GITHUB_ENV
echo "EOF" >> $GITHUB_ENV
env:
GH_TOKEN: ${{ secrets.GH_PERSONAL_TOKEN }}
- name: Generate PR Description with OpenAI (Safe JSON with jq)
run: |
REQUEST_BODY=$(jq -n \
--arg model "gpt-4o" \
--arg content "Given the following commit messages:\n\n${commits}\n\nGenerate a clear and professional pull request description." \
'{
model: $model,
messages: [{ role: "user", content: $content }]
}'
)
RESPONSE=$(curl -s https://api.openai.com/v1/chat/completions \
-H "Authorization: Bearer $OPENAI_API_KEY" \
-H "Content-Type: application/json" \
-d "$REQUEST_BODY")
DESCRIPTION=$(echo "$RESPONSE" | jq -r '.choices[0].message.content')
echo "---------- OpenAI Raw Response ----------"
echo "$RESPONSE"
echo "---------- Extracted Description ----------"
echo "$DESCRIPTION"
echo "description<<EOF" >> $GITHUB_ENV
echo "$DESCRIPTION" >> $GITHUB_ENV
echo "EOF" >> $GITHUB_ENV
env:
OPENAI_API_KEY: ${{ secrets.OPENAI_API_KEY }}
commits: ${{ env.commits }}
- name: Post AI Generated Description as Comment
run: |
gh pr comment ${{ github.event.pull_request.number }} --body "${{ env.description }}"
env:
GH_TOKEN: ${{ secrets.GH_PERSONAL_TOKEN }}

View File

@ -1,24 +1,9 @@
import { ApiProperty } from '@nestjs/swagger'; import { ApiProperty } from '@nestjs/swagger';
import { Transform } from 'class-transformer'; import { IsOptional } from 'class-validator';
import { IsBoolean, IsOptional } from 'class-validator';
import { BooleanValues } from '../constants/boolean-values.enum';
import { IsPageRequestParam } from '../validators/is-page-request-param.validator'; import { IsPageRequestParam } from '../validators/is-page-request-param.validator';
import { IsSizeRequestParam } from '../validators/is-size-request-param.validator'; import { IsSizeRequestParam } from '../validators/is-size-request-param.validator';
export class PaginationRequestGetListDto { export class PaginationRequestGetListDto {
@ApiProperty({
example: true,
description: 'include spaces',
required: false,
default: false,
})
@IsOptional()
@IsBoolean()
@Transform((value) => {
return value.obj.includeSpaces === BooleanValues.TRUE;
})
public includeSpaces?: boolean = false;
@IsOptional() @IsOptional()
@IsPageRequestParam({ @IsPageRequestParam({
message: 'Page must be bigger than 0', message: 'Page must be bigger than 0',

View File

@ -1,15 +1,13 @@
import { DeviceStatusLogRepository } from '@app/common/modules/device-status-log/repositories';
import { DeviceRepository } from '@app/common/modules/device/repositories';
import { import {
HttpException, HttpException,
HttpStatus, HttpStatus,
Injectable, Injectable,
NotFoundException, NotFoundException,
} from '@nestjs/common'; } from '@nestjs/common';
import { AddDeviceStatusDto } from '../dtos/add.devices-status.dto';
import { DeviceRepository } from '@app/common/modules/device/repositories';
import { GetDeviceDetailsFunctionsStatusInterface } from 'src/device/interfaces/get.device.interface';
import { TuyaContext } from '@tuya/tuya-connector-nodejs';
import { ConfigService } from '@nestjs/config'; import { ConfigService } from '@nestjs/config';
import { firebaseDataBase } from '../../firebase.config'; import { TuyaContext } from '@tuya/tuya-connector-nodejs';
import { import {
Database, Database,
DataSnapshot, DataSnapshot,
@ -17,7 +15,9 @@ import {
ref, ref,
runTransaction, runTransaction,
} from 'firebase/database'; } from 'firebase/database';
import { DeviceStatusLogRepository } from '@app/common/modules/device-status-log/repositories'; import { GetDeviceDetailsFunctionsStatusInterface } from 'src/device/interfaces/get.device.interface';
import { firebaseDataBase } from '../../firebase.config';
import { AddDeviceStatusDto } from '../dtos/add.devices-status.dto';
@Injectable() @Injectable()
export class DeviceStatusFirebaseService { export class DeviceStatusFirebaseService {
private tuya: TuyaContext; private tuya: TuyaContext;
@ -79,64 +79,77 @@ export class DeviceStatusFirebaseService {
device: any; device: any;
}[], }[],
): Promise<void> { ): Promise<void> {
const allLogs = [];
console.log(`🔁 Preparing logs from batch of ${batch.length} items...`); console.log(`🔁 Preparing logs from batch of ${batch.length} items...`);
const allLogs = [];
for (const item of batch) { for (const item of batch) {
const device = item.device; const device = item.device;
if (!device?.uuid) { if (!device?.uuid) {
console.log(`⛔ Skipped unknown device: ${item.deviceTuyaUuid}`); console.log(`⛔ Skipped unknown device: ${item.deviceTuyaUuid}`);
continue; continue;
} }
const logs = item.log.properties.map((property) => // Determine properties based on environment
const properties =
this.isDevEnv && Array.isArray(item.log?.properties)
? item.log.properties
: Array.isArray(item.status)
? item.status
: null;
if (!properties) {
console.log(
`⛔ Skipped invalid status/properties for device: ${item.deviceTuyaUuid}`,
);
continue;
}
const logs = properties.map((property) =>
this.deviceStatusLogRepository.create({ this.deviceStatusLogRepository.create({
deviceId: device.uuid, deviceId: device.uuid,
deviceTuyaId: item.deviceTuyaUuid, deviceTuyaId: item.deviceTuyaUuid,
productId: item.log.productId, productId: device.productDevice?.uuid,
log: item.log, log: item.log,
code: property.code, code: property.code,
value: property.value, value: property.value,
eventId: item.log.dataId, eventId: item.log?.dataId,
eventTime: new Date(property.time).toISOString(), eventTime: new Date(
this.isDevEnv ? property.time : property.t,
).toISOString(),
}), }),
); );
allLogs.push(...logs); allLogs.push(...logs);
} }
console.log(`📝 Total logs to insert: ${allLogs.length}`); console.log(`📝 Total logs to insert: ${allLogs.length}`);
const insertLogsPromise = (async () => { const chunkSize = 300;
const chunkSize = 300; let insertedCount = 0;
let insertedCount = 0;
for (let i = 0; i < allLogs.length; i += chunkSize) { for (let i = 0; i < allLogs.length; i += chunkSize) {
const chunk = allLogs.slice(i, i + chunkSize); const chunk = allLogs.slice(i, i + chunkSize);
try { try {
const result = await this.deviceStatusLogRepository const result = await this.deviceStatusLogRepository
.createQueryBuilder() .createQueryBuilder()
.insert() .insert()
.into('device-status-log') // or use DeviceStatusLogEntity .into('device-status-log')
.values(chunk) .values(chunk)
.orIgnore() // skip duplicates .orIgnore()
.execute(); .execute();
insertedCount += result.identifiers.length; insertedCount += result.identifiers.length;
console.log( console.log(
`✅ Inserted ${result.identifiers.length} / ${chunk.length} logs (chunk)`, `✅ Inserted ${result.identifiers.length} / ${chunk.length} logs (chunk)`,
); );
} catch (error) { } catch (error) {
console.error('❌ Insert error (skipped chunk):', error.message); console.error('❌ Insert error (skipped chunk):', error.message);
}
} }
}
console.log( console.log(`✅ Total logs inserted: ${insertedCount} / ${allLogs.length}`);
`✅ Total logs inserted: ${insertedCount} / ${allLogs.length}`,
);
})();
await insertLogsPromise;
} }
async addDeviceStatusToFirebase( async addDeviceStatusToFirebase(

View File

@ -1,9 +1,9 @@
import { Injectable, OnModuleInit } 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 { DeviceStatusFirebaseService } from '@app/common/firebase/devices-status/services/devices-status.service';
import { SosHandlerService } from './sos.handler.service'; import { Injectable, OnModuleInit } from '@nestjs/common';
import { ConfigService } from '@nestjs/config';
import * as NodeCache from 'node-cache'; import * as NodeCache from 'node-cache';
import TuyaWebsocket from '../../config/tuya-web-socket-config';
import { SosHandlerService } from './sos.handler.service';
@Injectable() @Injectable()
export class TuyaWebSocketService implements OnModuleInit { export class TuyaWebSocketService implements OnModuleInit {
@ -74,7 +74,12 @@ export class TuyaWebSocketService implements OnModuleInit {
this.client.message(async (ws: WebSocket, message: any) => { this.client.message(async (ws: WebSocket, message: any) => {
try { try {
const { devId, status, logData } = this.extractMessageData(message); const { devId, status, logData } = this.extractMessageData(message);
if (!Array.isArray(logData?.properties)) { // console.log(
// `📬 Received message for device: ${devId}, status:`,
// status,
// logData,
// );
if (!Array.isArray(status)) {
this.client.ackMessage(message.messageId); this.client.ackMessage(message.messageId);
return; return;
} }
@ -162,6 +167,8 @@ export class TuyaWebSocketService implements OnModuleInit {
status: any; status: any;
logData: any; logData: any;
} { } {
// console.log('Received message:', message);
const payloadData = message.payload.data; const payloadData = message.payload.data;
if (this.isDevEnv) { if (this.isDevEnv) {

View File

@ -1,7 +1,7 @@
import { HttpException, HttpStatus, Injectable } from '@nestjs/common'; import { HttpException, HttpStatus, Injectable } from '@nestjs/common';
import { ConfigService } from '@nestjs/config'; import { ConfigService } from '@nestjs/config';
import axios from 'axios'; import axios from 'axios';
import nodemailer from 'nodemailer'; import * as nodemailer from 'nodemailer';
import Mail from 'nodemailer/lib/mailer'; import Mail from 'nodemailer/lib/mailer';
import { BatchEmailData } from './batch-email.interface'; import { BatchEmailData } from './batch-email.interface';
import { SingleEmailData } from './single-email.interface'; import { SingleEmailData } from './single-email.interface';

View File

@ -1,13 +1,10 @@
import { BooleanValues } from '@app/common/constants/boolean-values.enum'; import { BooleanValues } from '@app/common/constants/boolean-values.enum';
import { PaginationRequestWithSearchGetListDto } from '@app/common/dto/pagination-with-search.request.dto'; import { PaginationRequestWithSearchGetListDto } from '@app/common/dto/pagination-with-search.request.dto';
import { ApiProperty, OmitType } from '@nestjs/swagger'; import { ApiProperty } from '@nestjs/swagger';
import { Transform } from 'class-transformer'; import { Transform } from 'class-transformer';
import { IsBoolean, IsNotEmpty, IsOptional } from 'class-validator'; import { IsBoolean, IsNotEmpty, IsOptional } from 'class-validator';
export class BookableSpaceRequestDto extends OmitType( export class BookableSpaceRequestDto extends PaginationRequestWithSearchGetListDto {
PaginationRequestWithSearchGetListDto,
['includeSpaces'],
) {
@ApiProperty({ @ApiProperty({
type: Boolean, type: Boolean,
required: false, required: false,

View File

@ -3,12 +3,12 @@ import { IsNotEmpty, IsOptional, IsUUID, Matches } from 'class-validator';
export class BookingRequestDto { export class BookingRequestDto {
@ApiProperty({ @ApiProperty({
description: 'Month in MM/YYYY format', description: 'Month in MM-YYYY format',
example: '07/2025', example: '07-2025',
}) })
@IsNotEmpty() @IsNotEmpty()
@Matches(/^(0[1-9]|1[0-2])\/\d{4}$/, { @Matches(/^(0[1-9]|1[0-2])\/\d{4}$/, {
message: 'Date must be in MM/YYYY format', message: 'Date must be in MM-YYYY format',
}) })
month: string; month: string;

View File

@ -51,7 +51,7 @@ export class BookingService {
} }
async findAll({ month, space }: BookingRequestDto, project: string) { async findAll({ month, space }: BookingRequestDto, project: string) {
const [monthNumber, year] = month.split('/').map(Number); const [monthNumber, year] = month.split('-').map(Number);
const fromDate = new Date(year, monthNumber - 1, 1); const fromDate = new Date(year, monthNumber - 1, 1);
const toDate = new Date(year, monthNumber, 0, 23, 59, 59); const toDate = new Date(year, monthNumber, 0, 23, 59, 59);
return this.bookingEntityRepository.find({ return this.bookingEntityRepository.find({

View File

@ -17,10 +17,10 @@ import { CommunityService } from '../services/community.service';
// import { CheckUserCommunityGuard } from 'src/guards/user.community.guard'; // import { CheckUserCommunityGuard } from 'src/guards/user.community.guard';
import { ControllerRoute } from '@app/common/constants/controller-route'; import { ControllerRoute } from '@app/common/constants/controller-route';
import { BaseResponseDto } from '@app/common/dto/base.response.dto'; 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 { Permissions } from 'src/decorators/permissions.decorator';
import { PermissionsGuard } from 'src/guards/permissions.guard'; import { PermissionsGuard } from 'src/guards/permissions.guard';
import { ProjectParam } from '../dtos'; import { ProjectParam } from '../dtos';
import { CommunityFilterDto } from '../dtos/community-filter.dto';
@ApiTags('Community Module') @ApiTags('Community Module')
@Controller({ @Controller({
@ -55,7 +55,7 @@ export class CommunityController {
@Get('v2') @Get('v2')
async getCommunitiesV2( async getCommunitiesV2(
@Param() param: ProjectParam, @Param() param: ProjectParam,
@Query() query: PaginationRequestWithSearchGetListDto, @Query() query: CommunityFilterDto,
): Promise<any> { ): Promise<any> {
return this.communityService.getCommunitiesV2(param, query); return this.communityService.getCommunitiesV2(param, query);
} }
@ -85,7 +85,7 @@ export class CommunityController {
@Get() @Get()
async getCommunities( async getCommunities(
@Param() param: ProjectParam, @Param() param: ProjectParam,
@Query() query: PaginationRequestWithSearchGetListDto, @Query() query: CommunityFilterDto,
): Promise<BaseResponseDto> { ): Promise<BaseResponseDto> {
return this.communityService.getCommunities(param, query); return this.communityService.getCommunities(param, query);
} }

View File

@ -0,0 +1,20 @@
import { BooleanValues } from '@app/common/constants/boolean-values.enum';
import { PaginationRequestWithSearchGetListDto } from '@app/common/dto/pagination-with-search.request.dto';
import { ApiProperty } from '@nestjs/swagger';
import { Transform } from 'class-transformer';
import { IsBoolean, IsOptional } from 'class-validator';
export class CommunityFilterDto extends PaginationRequestWithSearchGetListDto {
@ApiProperty({
example: true,
description: 'include spaces',
required: false,
default: false,
})
@IsOptional()
@IsBoolean()
@Transform((value) => {
return value.obj.includeSpaces === BooleanValues.TRUE;
})
public includeSpaces?: boolean = false;
}

View File

@ -1,4 +1,5 @@
import { DeviceTypeEnum } from '@app/common/constants/device-type.enum'; import { DeviceTypeEnum } from '@app/common/constants/device-type.enum';
import { PaginationRequestGetListDto } from '@app/common/dto/pagination.request.dto';
import { ApiProperty } from '@nestjs/swagger'; import { ApiProperty } from '@nestjs/swagger';
import { Transform } from 'class-transformer'; import { Transform } from 'class-transformer';
import { import {
@ -65,7 +66,7 @@ export class GetDevicesBySpaceOrCommunityDto {
requireEither?: never; // This ensures at least one of them is provided requireEither?: never; // This ensures at least one of them is provided
} }
export class GetDevicesFilterDto { export class GetDevicesFilterDto extends PaginationRequestGetListDto {
@ApiProperty({ @ApiProperty({
description: 'Device Type', description: 'Device Type',
enum: DeviceTypeEnum, enum: DeviceTypeEnum,

View File

@ -7,6 +7,7 @@ import { CommonErrorCodes } from '@app/common/constants/error-codes.enum';
import { ProductType } from '@app/common/constants/product-type.enum'; import { ProductType } from '@app/common/constants/product-type.enum';
import { SceneSwitchesTypeEnum } from '@app/common/constants/scene-switch-type.enum'; import { SceneSwitchesTypeEnum } from '@app/common/constants/scene-switch-type.enum';
import { BaseResponseDto } from '@app/common/dto/base.response.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 { SuccessResponseDto } from '@app/common/dto/success.response.dto';
import { DeviceStatusFirebaseService } from '@app/common/firebase/devices-status/services/devices-status.service'; import { DeviceStatusFirebaseService } from '@app/common/firebase/devices-status/services/devices-status.service';
import { convertKeysToCamelCase } from '@app/common/helper/camelCaseConverter'; import { convertKeysToCamelCase } from '@app/common/helper/camelCaseConverter';
@ -20,6 +21,7 @@ import { SceneDeviceRepository } from '@app/common/modules/scene-device/reposito
import { SpaceEntity } from '@app/common/modules/space/entities/space.entity'; import { SpaceEntity } from '@app/common/modules/space/entities/space.entity';
import { SpaceRepository } from '@app/common/modules/space/repositories'; import { SpaceRepository } from '@app/common/modules/space/repositories';
import { addSpaceUuidToDevices } from '@app/common/util/device-utils'; import { addSpaceUuidToDevices } from '@app/common/util/device-utils';
import { getPaginationResponseDto } from '@app/common/util/getPaginationResponseDto';
import { import {
BadRequestException, BadRequestException,
forwardRef, forwardRef,
@ -100,7 +102,7 @@ export class DeviceService {
async getAllDevices( async getAllDevices(
param: ProjectParam, param: ProjectParam,
{ deviceType, spaces, communities }: GetDevicesFilterDto, { deviceType, spaces, communities, page, size }: GetDevicesFilterDto,
): Promise<BaseResponseDto> { ): Promise<BaseResponseDto> {
try { try {
await this.validateProject(param.projectUuid); await this.validateProject(param.projectUuid);
@ -108,9 +110,12 @@ export class DeviceService {
return await this.getDoorLockDevices(param.projectUuid, { return await this.getDoorLockDevices(param.projectUuid, {
spaces, spaces,
communities, communities,
deviceType,
page,
size,
}); });
} else if (!deviceType) { } else if (!deviceType) {
const devices = await this.deviceRepository.find({ const [devices, count] = await this.deviceRepository.findAndCount({
where: { where: {
isActive: true, isActive: true,
spaceDevice: { spaceDevice: {
@ -133,6 +138,8 @@ export class DeviceService {
'permission.permissionType', 'permission.permissionType',
'subspace', 'subspace',
], ],
take: size ?? 10,
skip: (page ? page - 1 : 0) * (size ?? 10),
}); });
const devicesData = await Promise.allSettled( const devicesData = await Promise.allSettled(
@ -234,11 +241,14 @@ export class DeviceService {
.value, .value,
); );
return new SuccessResponseDto({ return new PageResponse(
message: `Devices fetched successfully`, {
data: fulfilledDevices, message: `Devices fetched successfully`,
statusCode: HttpStatus.OK, data: fulfilledDevices,
}); statusCode: HttpStatus.OK,
},
getPaginationResponseDto(count, page ?? 1, size ?? 10),
);
} }
} catch (error) { } catch (error) {
if (error instanceof HttpException) { if (error instanceof HttpException) {
@ -1301,11 +1311,11 @@ export class DeviceService {
private async getDoorLockDevices( private async getDoorLockDevices(
projectUuid: string, projectUuid: string,
{ communities, spaces }: { spaces?: string[]; communities?: string[] }, { communities, spaces, page, size }: GetDevicesFilterDto,
) { ) {
await this.validateProject(projectUuid); await this.validateProject(projectUuid);
const devices = await this.deviceRepository.find({ const [devices, count] = await this.deviceRepository.findAndCount({
where: { where: {
productDevice: { productDevice: {
prodType: ProductType.DL, prodType: ProductType.DL,
@ -1324,6 +1334,8 @@ export class DeviceService {
isActive: true, isActive: true,
}, },
relations: ['productDevice', 'spaceDevice'], relations: ['productDevice', 'spaceDevice'],
take: size ?? 10,
skip: (page ? page - 1 : 0) * (size ?? 10),
}); });
const devicesData = await Promise.all( const devicesData = await Promise.all(
@ -1355,11 +1367,14 @@ export class DeviceService {
(deviceData) => deviceData !== null, (deviceData) => deviceData !== null,
); );
return new SuccessResponseDto({ return new PageResponse(
message: 'Successfully retrieved all pass devices', {
data: filteredDevicesData, message: 'Successfully retrieved all pass devices',
statusCode: HttpStatus.OK, data: filteredDevicesData,
}); statusCode: HttpStatus.OK,
},
getPaginationResponseDto(count, page ?? 1, size ?? 10),
);
} }
private async controlDeviceTuya( private async controlDeviceTuya(

View File

@ -1,7 +1,3 @@
import { PaginationRequestGetListDto } from '@app/common/dto/pagination.request.dto'; import { PaginationRequestGetListDto } from '@app/common/dto/pagination.request.dto';
import { PickType } from '@nestjs/swagger';
export class ListProjectsDto extends PickType(PaginationRequestGetListDto, [ export class ListProjectsDto extends PaginationRequestGetListDto {}
'page',
'size',
]) {}

View File

@ -1,4 +1,5 @@
import { ControllerRoute } from '@app/common/constants/controller-route'; import { ControllerRoute } from '@app/common/constants/controller-route';
import { BaseResponseDto } from '@app/common/dto/base.response.dto';
import { import {
Body, Body,
Controller, Controller,
@ -11,18 +12,17 @@ import {
UseGuards, UseGuards,
} from '@nestjs/common'; } from '@nestjs/common';
import { ApiBearerAuth, ApiOperation, ApiTags } from '@nestjs/swagger'; import { ApiBearerAuth, ApiOperation, ApiTags } from '@nestjs/swagger';
import { SpaceModelService } from '../services'; import { ProjectParam } from 'src/community/dtos';
import { Permissions } from 'src/decorators/permissions.decorator';
import { PermissionsGuard } from 'src/guards/permissions.guard';
import { import {
CreateSpaceModelDto, CreateSpaceModelDto,
LinkSpacesToModelDto, LinkSpacesToModelDto,
SpaceModelParam, SpaceModelParam,
UpdateSpaceModelDto, UpdateSpaceModelDto,
} from '../dtos'; } from '../dtos';
import { ProjectParam } from 'src/community/dtos'; import { SpaceModelFilterDto } from '../dtos/space-model-filter.dto';
import { BaseResponseDto } from '@app/common/dto/base.response.dto'; import { SpaceModelService } from '../services';
import { PermissionsGuard } from 'src/guards/permissions.guard';
import { Permissions } from 'src/decorators/permissions.decorator';
import { PaginationRequestGetListDto } from '@app/common/dto/pagination.request.dto';
@ApiTags('Space Model Module') @ApiTags('Space Model Module')
@Controller({ @Controller({
@ -62,7 +62,7 @@ export class SpaceModelController {
@Get() @Get()
async listSpaceModel( async listSpaceModel(
@Param() projectParam: ProjectParam, @Param() projectParam: ProjectParam,
@Query() query: PaginationRequestGetListDto, @Query() query: SpaceModelFilterDto,
): Promise<BaseResponseDto> { ): Promise<BaseResponseDto> {
return await this.spaceModelService.list(projectParam, query); return await this.spaceModelService.list(projectParam, query);
} }

View File

@ -0,0 +1,20 @@
import { BooleanValues } from '@app/common/constants/boolean-values.enum';
import { PaginationRequestGetListDto } from '@app/common/dto/pagination.request.dto';
import { ApiProperty } from '@nestjs/swagger';
import { Transform } from 'class-transformer';
import { IsBoolean, IsOptional } from 'class-validator';
export class SpaceModelFilterDto extends PaginationRequestGetListDto {
@ApiProperty({
example: true,
description: 'include spaces',
required: false,
default: false,
})
@IsOptional()
@IsBoolean()
@Transform((value) => {
return value.obj.includeSpaces === BooleanValues.TRUE;
})
public includeSpaces?: boolean = false;
}

View File

@ -1,4 +1,5 @@
import { ControllerRoute } from '@app/common/constants/controller-route'; import { ControllerRoute } from '@app/common/constants/controller-route';
import { BaseResponseDto } from '@app/common/dto/base.response.dto';
import { import {
Body, Body,
Controller, Controller,
@ -10,13 +11,12 @@ import {
Query, Query,
UseGuards, UseGuards,
} from '@nestjs/common'; } from '@nestjs/common';
import { SubSpaceService } from '../../services';
import { ApiBearerAuth, ApiOperation, ApiTags } from '@nestjs/swagger'; import { ApiBearerAuth, ApiOperation, ApiTags } from '@nestjs/swagger';
import { AddSubspaceDto, GetSpaceParam, GetSubSpaceParam } from '../../dtos';
import { BaseResponseDto } from '@app/common/dto/base.response.dto';
import { PaginationRequestGetListDto } from '@app/common/dto/pagination.request.dto';
import { PermissionsGuard } from 'src/guards/permissions.guard';
import { Permissions } from 'src/decorators/permissions.decorator'; import { Permissions } from 'src/decorators/permissions.decorator';
import { PermissionsGuard } from 'src/guards/permissions.guard';
import { SubspaceFilterDto } from 'src/space/dtos/subspace-filter.dto';
import { AddSubspaceDto, GetSpaceParam, GetSubSpaceParam } from '../../dtos';
import { SubSpaceService } from '../../services';
@ApiTags('Space Module') @ApiTags('Space Module')
@Controller({ @Controller({
@ -51,7 +51,7 @@ export class SubSpaceController {
@Get() @Get()
async list( async list(
@Param() params: GetSpaceParam, @Param() params: GetSpaceParam,
@Query() query: PaginationRequestGetListDto, @Query() query: SubspaceFilterDto,
): Promise<BaseResponseDto> { ): Promise<BaseResponseDto> {
return this.subSpaceService.list(params, query); return this.subSpaceService.list(params, query);
} }

View File

@ -0,0 +1,20 @@
import { BooleanValues } from '@app/common/constants/boolean-values.enum';
import { PaginationRequestGetListDto } from '@app/common/dto/pagination.request.dto';
import { ApiProperty } from '@nestjs/swagger';
import { Transform } from 'class-transformer';
import { IsBoolean, IsOptional } from 'class-validator';
export class SubspaceFilterDto extends PaginationRequestGetListDto {
@ApiProperty({
example: true,
description: 'include spaces',
required: false,
default: false,
})
@IsOptional()
@IsBoolean()
@Transform((value) => {
return value.obj.includeSpaces === BooleanValues.TRUE;
})
public includeSpaces?: boolean = false;
}