Merge pull request #209 from SyncrowIOT/SP-989-be-modify-the-invite-space-member-to-unit-flow-implementation-in-the-application

Sp 989 be modify the invite space member to unit flow implementation in the application
This commit is contained in:
hannathkadher
2025-01-10 21:07:41 +04:00
committed by GitHub
19 changed files with 340 additions and 175 deletions

View File

@ -46,6 +46,7 @@ export const RolePermissions = {
'VISITOR_PASSWORD_VIEW', 'VISITOR_PASSWORD_VIEW',
'VISITOR_PASSWORD_ADD', 'VISITOR_PASSWORD_ADD',
'USER_ADD', 'USER_ADD',
'SPACE_MEMBER_ADD',
], ],
[RoleType.ADMIN]: [ [RoleType.ADMIN]: [
'DEVICE_SINGLE_CONTROL', 'DEVICE_SINGLE_CONTROL',
@ -92,6 +93,7 @@ export const RolePermissions = {
'VISITOR_PASSWORD_VIEW', 'VISITOR_PASSWORD_VIEW',
'VISITOR_PASSWORD_ADD', 'VISITOR_PASSWORD_ADD',
'USER_ADD', 'USER_ADD',
'SPACE_MEMBER_ADD',
], ],
[RoleType.SPACE_MEMBER]: [ [RoleType.SPACE_MEMBER]: [
'DEVICE_SINGLE_CONTROL', 'DEVICE_SINGLE_CONTROL',

View File

@ -36,6 +36,7 @@ import {
InviteUserEntity, InviteUserEntity,
InviteUserSpaceEntity, InviteUserSpaceEntity,
} from '../modules/Invite-user/entities'; } from '../modules/Invite-user/entities';
import { InviteSpaceEntity } from '../modules/space/entities/invite-space.entity';
@Module({ @Module({
imports: [ imports: [
TypeOrmModule.forRootAsync({ TypeOrmModule.forRootAsync({
@ -80,6 +81,7 @@ import {
TagModel, TagModel,
InviteUserEntity, InviteUserEntity,
InviteUserSpaceEntity, InviteUserSpaceEntity,
InviteSpaceEntity,
], ],
namingStrategy: new SnakeNamingStrategy(), namingStrategy: new SnakeNamingStrategy(),
synchronize: Boolean(JSON.parse(configService.get('DB_SYNC'))), synchronize: Boolean(JSON.parse(configService.get('DB_SYNC'))),

View File

@ -18,7 +18,7 @@ import { InviteUserDto, InviteUserSpaceDto } from '../dtos';
import { ProjectEntity } from '../../project/entities'; import { ProjectEntity } from '../../project/entities';
@Entity({ name: 'invite-user' }) @Entity({ name: 'invite-user' })
@Unique(['email', 'invitationCode']) @Unique(['email', 'invitationCode', 'project'])
export class InviteUserEntity extends AbstractEntity<InviteUserDto> { export class InviteUserEntity extends AbstractEntity<InviteUserDto> {
@Column({ @Column({
type: 'uuid', type: 'uuid',
@ -29,7 +29,6 @@ export class InviteUserEntity extends AbstractEntity<InviteUserDto> {
@Column({ @Column({
nullable: false, nullable: false,
unique: true,
}) })
email: string; email: string;

View File

@ -0,0 +1,35 @@
import { Column, Entity, ManyToOne, Unique } from 'typeorm';
import { UserSpaceDto } from '../../user/dtos';
import { AbstractEntity } from '../../abstract/entities/abstract.entity';
import { SpaceEntity } from './space.entity';
@Entity({ name: 'invite-space' })
@Unique(['invitationCode'])
export class InviteSpaceEntity extends AbstractEntity<UserSpaceDto> {
@Column({
type: 'uuid',
default: () => 'gen_random_uuid()', // Use gen_random_uuid() for default value
nullable: false,
})
public uuid: string;
@ManyToOne(() => SpaceEntity, (space) => space.userSpaces, {
nullable: false,
})
space: SpaceEntity;
@Column({
nullable: true,
})
public invitationCode: string;
@Column({
nullable: false,
default: true,
})
public isActive: boolean;
constructor(partial: Partial<InviteSpaceEntity>) {
super();
Object.assign(this, partial);
}
}

View File

@ -1,11 +1,4 @@
import { import { Column, Entity, JoinColumn, ManyToOne, OneToMany } from 'typeorm';
Column,
Entity,
JoinColumn,
ManyToOne,
OneToMany,
Unique,
} from 'typeorm';
import { SpaceDto } from '../dtos'; import { SpaceDto } from '../dtos';
import { AbstractEntity } from '../../abstract/entities/abstract.entity'; import { AbstractEntity } from '../../abstract/entities/abstract.entity';
import { UserSpaceEntity } from '../../user/entities'; import { UserSpaceEntity } from '../../user/entities';
@ -19,7 +12,6 @@ import { InviteUserSpaceEntity } from '../../Invite-user/entities';
import { TagEntity } from './tag.entity'; import { TagEntity } from './tag.entity';
@Entity({ name: 'space' }) @Entity({ name: 'space' })
@Unique(['invitationCode'])
export class SpaceEntity extends AbstractEntity<SpaceDto> { export class SpaceEntity extends AbstractEntity<SpaceDto> {
@Column({ @Column({
type: 'uuid', type: 'uuid',
@ -44,10 +36,6 @@ export class SpaceEntity extends AbstractEntity<SpaceDto> {
@JoinColumn({ name: 'community_id' }) @JoinColumn({ name: 'community_id' })
community: CommunityEntity; community: CommunityEntity;
@Column({
nullable: true,
})
public invitationCode: string;
@ManyToOne(() => SpaceEntity, (space) => space.children, { nullable: true }) @ManyToOne(() => SpaceEntity, (space) => space.children, { nullable: true })
parent: SpaceEntity; parent: SpaceEntity;

View File

@ -1,6 +1,7 @@
import { DataSource, Repository } from 'typeorm'; import { DataSource, Repository } from 'typeorm';
import { Injectable } from '@nestjs/common'; import { Injectable } from '@nestjs/common';
import { SpaceEntity, SpaceLinkEntity, TagEntity } from '../entities'; import { SpaceEntity, SpaceLinkEntity, TagEntity } from '../entities';
import { InviteSpaceEntity } from '../entities/invite-space.entity';
@Injectable() @Injectable()
export class SpaceRepository extends Repository<SpaceEntity> { export class SpaceRepository extends Repository<SpaceEntity> {
@ -22,3 +23,10 @@ export class TagRepository extends Repository<TagEntity> {
super(TagEntity, dataSource.createEntityManager()); super(TagEntity, dataSource.createEntityManager());
} }
} }
@Injectable()
export class InviteSpaceRepository extends Repository<InviteSpaceEntity> {
constructor(private dataSource: DataSource) {
super(InviteSpaceEntity, dataSource.createEntityManager());
}
}

View File

@ -1,11 +1,19 @@
import { Module } from '@nestjs/common'; import { Module } from '@nestjs/common';
import { TypeOrmModule } from '@nestjs/typeorm'; import { TypeOrmModule } from '@nestjs/typeorm';
import { SpaceEntity, SubspaceEntity, TagEntity } from './entities'; import { SpaceEntity, SubspaceEntity, TagEntity } from './entities';
import { InviteSpaceEntity } from './entities/invite-space.entity';
@Module({ @Module({
providers: [], providers: [],
exports: [], exports: [],
controllers: [], controllers: [],
imports: [TypeOrmModule.forFeature([SpaceEntity, SubspaceEntity, TagEntity])], imports: [
TypeOrmModule.forFeature([
SpaceEntity,
SubspaceEntity,
TagEntity,
InviteSpaceEntity,
]),
],
}) })
export class SpaceRepositoryModule {} export class SpaceRepositoryModule {}

View File

@ -1,4 +1,8 @@
import { Injectable, ExecutionContext } from '@nestjs/common'; import {
Injectable,
ExecutionContext,
UnauthorizedException,
} from '@nestjs/common';
import { AuthGuard } from '@nestjs/passport'; import { AuthGuard } from '@nestjs/passport';
import { Reflector } from '@nestjs/core'; import { Reflector } from '@nestjs/core';
import { RolePermissions } from '@app/common/constants/role-permissions'; import { RolePermissions } from '@app/common/constants/role-permissions';
@ -30,14 +34,34 @@ export class PermissionsGuard extends AuthGuard('jwt') {
const request = context.switchToHttp().getRequest(); const request = context.switchToHttp().getRequest();
const user = request.user; // User is now available after AuthGuard const user = request.user; // User is now available after AuthGuard
const userRole = user?.role.type as RoleType; const userRole = user?.role?.type as RoleType;
if (!userRole || !RolePermissions[userRole]) { if (!userRole || !RolePermissions[userRole]) {
return false; // Deny if role or permissions are missing throw new UnauthorizedException({
message: `Only ${this.getAllowedRoles(requiredPermissions)} role(s) can access this route.`,
});
} }
const userPermissions = RolePermissions[userRole]; const userPermissions = RolePermissions[userRole];
const hasRequiredPermissions = requiredPermissions.every((perm) =>
userPermissions.includes(perm),
);
// Check if the user has the required permissions if (!hasRequiredPermissions) {
return requiredPermissions.every((perm) => userPermissions.includes(perm)); throw new UnauthorizedException({
message: `Only ${this.getAllowedRoles(requiredPermissions)} role(s) can access this route.`,
});
}
return true;
}
private getAllowedRoles(requiredPermissions: string[]): string {
const allowedRoles = Object.entries(RolePermissions)
.filter(([, permissions]) =>
requiredPermissions.every((perm) => permissions.includes(perm)),
)
.map(([role]) => role);
return allowedRoles.join(', ');
} }
} }

View File

@ -76,9 +76,7 @@ export class InviteUserController {
async activationCodeController( async activationCodeController(
@Body() activateCodeDto: ActivateCodeDto, @Body() activateCodeDto: ActivateCodeDto,
): Promise<BaseResponseDto> { ): Promise<BaseResponseDto> {
return await this.inviteUserService.activationCodeController( return await this.inviteUserService.activationCode(activateCodeDto);
activateCodeDto,
);
} }
@ApiBearerAuth() @ApiBearerAuth()
@UseGuards(JwtAuthGuard) @UseGuards(JwtAuthGuard)

View File

@ -15,17 +15,22 @@ import {
import { EmailService } from '@app/common/util/email.service'; import { EmailService } from '@app/common/util/email.service';
import { SpaceUserService, ValidationService } from 'src/space/services'; import { SpaceUserService, ValidationService } from 'src/space/services';
import { CommunityService } from 'src/community/services'; import { CommunityService } from 'src/community/services';
import { SpaceRepository } from '@app/common/modules/space'; import {
InviteSpaceRepository,
SpaceRepository,
} from '@app/common/modules/space';
import { SpaceModelRepository } from '@app/common/modules/space-model'; import { SpaceModelRepository } from '@app/common/modules/space-model';
import { CommunityRepository } from '@app/common/modules/community/repositories'; import { CommunityRepository } from '@app/common/modules/community/repositories';
import { ProjectRepository } from '@app/common/modules/project/repositiories'; import { ProjectRepository } from '@app/common/modules/project/repositiories';
import { TuyaService } from '@app/common/integrations/tuya/services/tuya.service'; import { TuyaService } from '@app/common/integrations/tuya/services/tuya.service';
import { UserSpaceService } from 'src/users/services'; import { UserService, UserSpaceService } from 'src/users/services';
import { UserDevicePermissionService } from 'src/user-device-permission/services'; import { UserDevicePermissionService } from 'src/user-device-permission/services';
import { DeviceUserPermissionRepository } from '@app/common/modules/device/repositories'; import { DeviceUserPermissionRepository } from '@app/common/modules/device/repositories';
import { PermissionTypeRepository } from '@app/common/modules/permission/repositories'; import { PermissionTypeRepository } from '@app/common/modules/permission/repositories';
import { ProjectUserService } from 'src/project/services/project-user.service'; import { ProjectUserService } from 'src/project/services/project-user.service';
import { RoleTypeRepository } from '@app/common/modules/role-type/repositories'; import { RoleTypeRepository } from '@app/common/modules/role-type/repositories';
import { RegionRepository } from '@app/common/modules/region/repositories';
import { TimeZoneRepository } from '@app/common/modules/timezone/repositories';
@Module({ @Module({
imports: [ConfigModule, InviteUserRepositoryModule], imports: [ConfigModule, InviteUserRepositoryModule],
@ -51,6 +56,10 @@ import { RoleTypeRepository } from '@app/common/modules/role-type/repositories';
PermissionTypeRepository, PermissionTypeRepository,
ProjectUserService, ProjectUserService,
RoleTypeRepository, RoleTypeRepository,
InviteSpaceRepository,
UserService,
RegionRepository,
TimeZoneRepository,
], ],
exports: [InviteUserService], exports: [InviteUserService],
}) })

View File

@ -29,6 +29,7 @@ import {
UpdateUserInvitationDto, UpdateUserInvitationDto,
} from '../dtos/update.invite-user.dto'; } from '../dtos/update.invite-user.dto';
import { RoleTypeRepository } from '@app/common/modules/role-type/repositories'; import { RoleTypeRepository } from '@app/common/modules/role-type/repositories';
import { InviteUserEntity } from '@app/common/modules/Invite-user/entities';
@Injectable() @Injectable()
export class InviteUserService { export class InviteUserService {
@ -188,76 +189,35 @@ export class InviteUserService {
); );
} }
} }
async activationCodeController( async activationCode(dto: ActivateCodeDto): Promise<BaseResponseDto> {
dto: ActivateCodeDto, const { activationCode, userUuid } = dto;
): Promise<BaseResponseDto> {
try { try {
const { activationCode, userUuid } = dto; const user = await this.getUser(userUuid);
const user = await this.userRepository.findOne({
where: { uuid: userUuid, isActive: true, isUserVerified: true },
});
if (!user) {
throw new HttpException('User not found', HttpStatus.NOT_FOUND);
}
const { email } = user;
const invitedUser = await this.inviteUserRepository.findOne({ const invitedUser = await this.inviteUserRepository.findOne({
where: { where: {
email, email: user.email,
invitationCode: activationCode,
status: UserStatusEnum.INVITED, status: UserStatusEnum.INVITED,
isActive: true, isActive: true,
}, },
relations: ['project', 'spaces.space.community', 'roleType'], relations: ['project', 'spaces.space.community', 'roleType'],
}); });
if (!invitedUser) { if (invitedUser) {
throw new HttpException( if (invitedUser.invitationCode !== activationCode) {
'Invalid activation code', throw new HttpException(
HttpStatus.BAD_REQUEST, 'Invalid activation code',
); HttpStatus.BAD_REQUEST,
}
for (const invitedSpace of invitedUser.spaces) {
try {
const deviceUUIDs =
await this.userSpaceService.getDeviceUUIDsForSpace(
invitedSpace.space.uuid,
);
await this.userSpaceService.addUserPermissionsToDevices(
userUuid,
deviceUUIDs,
); );
await this.spaceUserService.associateUserToSpace({
communityUuid: invitedSpace.space.community.uuid,
spaceUuid: invitedSpace.space.uuid,
userUuid: user.uuid,
projectUuid: invitedUser.project.uuid,
});
} catch (spaceError) {
console.error(
`Error processing space ${invitedSpace.space.uuid}:`,
spaceError,
);
// Skip to the next space
continue;
} }
}
await this.inviteUserRepository.update( // Handle invited user with valid activation code
{ uuid: invitedUser.uuid }, await this.handleInvitedUser(user, invitedUser);
{ status: UserStatusEnum.ACTIVE }, } else {
); // Handle case for non-invited user
await this.userRepository.update( await this.handleNonInvitedUser(activationCode, userUuid);
{ uuid: userUuid }, }
{
project: { uuid: invitedUser.project.uuid },
inviteUser: { uuid: invitedUser.uuid },
roleType: { uuid: invitedUser.roleType.uuid },
},
);
return new SuccessResponseDto({ return new SuccessResponseDto({
statusCode: HttpStatus.OK, statusCode: HttpStatus.OK,
success: true, success: true,
@ -272,6 +232,73 @@ export class InviteUserService {
); );
} }
} }
private async getUser(userUuid: string): Promise<UserEntity> {
const user = await this.userRepository.findOne({
where: { uuid: userUuid, isActive: true, isUserVerified: true },
});
if (!user) {
throw new HttpException('User not found', HttpStatus.NOT_FOUND);
}
return user;
}
private async handleNonInvitedUser(
activationCode: string,
userUuid: string,
): Promise<void> {
await this.userSpaceService.verifyCodeAndAddUserSpace(
{ inviteCode: activationCode },
userUuid,
);
}
private async handleInvitedUser(
user: UserEntity,
invitedUser: InviteUserEntity,
): Promise<void> {
for (const invitedSpace of invitedUser.spaces) {
try {
const deviceUUIDs = await this.userSpaceService.getDeviceUUIDsForSpace(
invitedSpace.space.uuid,
);
await this.userSpaceService.addUserPermissionsToDevices(
user.uuid,
deviceUUIDs,
);
await this.spaceUserService.associateUserToSpace({
communityUuid: invitedSpace.space.community.uuid,
spaceUuid: invitedSpace.space.uuid,
userUuid: user.uuid,
projectUuid: invitedUser.project.uuid,
});
} catch (spaceError) {
console.error(
`Error processing space ${invitedSpace.space.uuid}:`,
spaceError,
);
continue; // Skip to the next space
}
}
// Update invited user and associated user data
await this.inviteUserRepository.update(
{ uuid: invitedUser.uuid },
{ status: UserStatusEnum.ACTIVE },
);
await this.userRepository.update(
{ uuid: user.uuid },
{
project: { uuid: invitedUser.project.uuid },
inviteUser: { uuid: invitedUser.uuid },
roleType: { uuid: invitedUser.roleType.uuid },
},
);
}
async updateUserInvitation( async updateUserInvitation(
dto: UpdateUserInvitationDto, dto: UpdateUserInvitationDto,
invitedUserUuid: string, invitedUserUuid: string,

View File

@ -20,6 +20,7 @@ import {
} from './handlers'; } from './handlers';
import { CqrsModule } from '@nestjs/cqrs'; import { CqrsModule } from '@nestjs/cqrs';
import { import {
InviteSpaceRepository,
SpaceLinkRepository, SpaceLinkRepository,
SpaceRepository, SpaceRepository,
TagRepository, TagRepository,
@ -70,6 +71,7 @@ const CommandHandlers = [
CommunityRepository, CommunityRepository,
SpaceLinkService, SpaceLinkService,
SpaceLinkRepository, SpaceLinkRepository,
InviteSpaceRepository,
], ],
exports: [CqrsModule, SpaceModelService], exports: [CqrsModule, SpaceModelService],
}) })

View File

@ -112,7 +112,6 @@ export class SpaceController {
return this.spaceService.getSpacesHierarchyForSpace(params); return this.spaceService.getSpacesHierarchyForSpace(params);
} }
//should it be post?
@ApiBearerAuth() @ApiBearerAuth()
@UseGuards(PermissionsGuard) @UseGuards(PermissionsGuard)
@Permissions('SPACE_MEMBER_ADD') @Permissions('SPACE_MEMBER_ADD')
@ -121,10 +120,10 @@ export class SpaceController {
description: description:
ControllerRoute.SPACE.ACTIONS.CREATE_INVITATION_CODE_SPACE_DESCRIPTION, ControllerRoute.SPACE.ACTIONS.CREATE_INVITATION_CODE_SPACE_DESCRIPTION,
}) })
@Get(':spaceUuid/invitation-code') @Post(':spaceUuid/invitation-code')
async generateSpaceInvitationCode( async generateSpaceInvitationCode(
@Param() params: GetSpaceParam, @Param() params: GetSpaceParam,
): Promise<BaseResponseDto> { ): Promise<BaseResponseDto> {
return this.spaceService.getSpaceInvitationCode(params); return this.spaceService.generateSpaceInvitationCode(params);
} }
} }

View File

@ -1,4 +1,7 @@
import { SpaceRepository } from '@app/common/modules/space/repositories'; import {
InviteSpaceRepository,
SpaceRepository,
} from '@app/common/modules/space/repositories';
import { import {
BadRequestException, BadRequestException,
HttpException, HttpException,
@ -34,6 +37,7 @@ export class SpaceService {
constructor( constructor(
private readonly dataSource: DataSource, private readonly dataSource: DataSource,
private readonly spaceRepository: SpaceRepository, private readonly spaceRepository: SpaceRepository,
private readonly inviteSpaceRepository: InviteSpaceRepository,
private readonly spaceLinkService: SpaceLinkService, private readonly spaceLinkService: SpaceLinkService,
private readonly subSpaceService: SubSpaceService, private readonly subSpaceService: SubSpaceService,
private readonly validationService: ValidationService, private readonly validationService: ValidationService,
@ -437,7 +441,7 @@ export class SpaceService {
} }
} }
async getSpaceInvitationCode(params: GetSpaceParam): Promise<any> { async generateSpaceInvitationCode(params: GetSpaceParam): Promise<any> {
const { communityUuid, spaceUuid, projectUuid } = params; const { communityUuid, spaceUuid, projectUuid } = params;
try { try {
const invitationCode = generateRandomString(6); const invitationCode = generateRandomString(6);
@ -448,13 +452,18 @@ export class SpaceService {
projectUuid, projectUuid,
spaceUuid, spaceUuid,
); );
await this.inviteSpaceRepository.save({
space.invitationCode = invitationCode; space: { uuid: spaceUuid },
await this.spaceRepository.save(space); invitationCode,
});
return new SuccessResponseDto({ return new SuccessResponseDto({
message: `Invitation code has been successfuly added to the space`, message: `Invitation code has been successfuly added to the space`,
data: space, data: {
invitationCode,
spaceName: space.spaceName,
spaceUuid: space.uuid,
},
}); });
} catch (err) { } catch (err) {
if (err instanceof BadRequestException) { if (err instanceof BadRequestException) {

View File

@ -22,6 +22,7 @@ import {
SpaceRepository, SpaceRepository,
SpaceLinkRepository, SpaceLinkRepository,
TagRepository, TagRepository,
InviteSpaceRepository,
} from '@app/common/modules/space/repositories'; } from '@app/common/modules/space/repositories';
import { CommunityRepository } from '@app/common/modules/community/repositories'; import { CommunityRepository } from '@app/common/modules/community/repositories';
import { import {
@ -58,11 +59,14 @@ import {
SubSpaceModelService, SubSpaceModelService,
TagModelService, TagModelService,
} from 'src/space-model/services'; } from 'src/space-model/services';
import { UserSpaceService } from 'src/users/services'; import { UserService, UserSpaceService } from 'src/users/services';
import { UserDevicePermissionService } from 'src/user-device-permission/services'; import { UserDevicePermissionService } from 'src/user-device-permission/services';
import { PermissionTypeRepository } from '@app/common/modules/permission/repositories'; import { PermissionTypeRepository } from '@app/common/modules/permission/repositories';
import { CqrsModule } from '@nestjs/cqrs'; import { CqrsModule } from '@nestjs/cqrs';
import { DisableSpaceHandler } from './handlers'; import { DisableSpaceHandler } from './handlers';
import { RegionRepository } from '@app/common/modules/region/repositories';
import { TimeZoneRepository } from '@app/common/modules/timezone/repositories';
import { InviteUserRepository } from '@app/common/modules/Invite-user/repositiories';
export const CommandHandlers = [DisableSpaceHandler]; export const CommandHandlers = [DisableSpaceHandler];
@ -114,7 +118,12 @@ export const CommandHandlers = [DisableSpaceHandler];
UserDevicePermissionService, UserDevicePermissionService,
DeviceUserPermissionRepository, DeviceUserPermissionRepository,
PermissionTypeRepository, PermissionTypeRepository,
InviteSpaceRepository,
...CommandHandlers, ...CommandHandlers,
UserService,
RegionRepository,
TimeZoneRepository,
InviteUserRepository,
], ],
exports: [SpaceService], exports: [SpaceService],
}) })

View File

@ -1,20 +1,11 @@
import { ControllerRoute } from '@app/common/constants/controller-route'; import { ControllerRoute } from '@app/common/constants/controller-route';
import { EnableDisableStatusEnum } from '@app/common/constants/days.enum'; import { EnableDisableStatusEnum } from '@app/common/constants/days.enum';
import { import { Controller, Get, Param, UseGuards } from '@nestjs/common';
Body,
Controller,
Get,
HttpException,
HttpStatus,
Param,
Post,
UseGuards,
} from '@nestjs/common';
import { ApiBearerAuth, ApiOperation, ApiTags } from '@nestjs/swagger'; import { ApiBearerAuth, ApiOperation, ApiTags } from '@nestjs/swagger';
import { UserSpaceService } from '../services'; import { UserSpaceService } from '../services';
import { JwtAuthGuard } from '@app/common/guards/jwt.auth.guard'; import { JwtAuthGuard } from '@app/common/guards/jwt.auth.guard';
import { BaseResponseDto } from '@app/common/dto/base.response.dto'; import { BaseResponseDto } from '@app/common/dto/base.response.dto';
import { AddUserSpaceUsingCodeDto, UserParamDto } from '../dtos'; import { UserParamDto } from '../dtos';
@ApiTags('User Module') @ApiTags('User Module')
@Controller({ @Controller({
@ -36,36 +27,4 @@ export class UserSpaceController {
): Promise<BaseResponseDto> { ): Promise<BaseResponseDto> {
return this.userSpaceService.getSpacesForUser(params.userUuid); return this.userSpaceService.getSpacesForUser(params.userUuid);
} }
@ApiBearerAuth()
@UseGuards(JwtAuthGuard)
@Post('/verify-code')
@ApiOperation({
summary:
ControllerRoute.USER_SPACE.ACTIONS.VERIFY_CODE_AND_ADD_USER_SPACE_SUMMARY,
description:
ControllerRoute.USER_SPACE.ACTIONS
.VERIFY_CODE_AND_ADD_USER_SPACE_DESCRIPTION,
})
async verifyCodeAndAddUserSpace(
@Body() dto: AddUserSpaceUsingCodeDto,
@Param() params: UserParamDto,
) {
try {
await this.userSpaceService.verifyCodeAndAddUserSpace(
dto,
params.userUuid,
);
return {
statusCode: HttpStatus.CREATED,
success: true,
message: 'user space added successfully',
};
} catch (error) {
throw new HttpException(
error.message || 'Internal server error',
error.status || HttpStatus.INTERNAL_SERVER_ERROR,
);
}
}
} }

View File

@ -1,19 +1,34 @@
import { HttpException, HttpStatus, Injectable } from '@nestjs/common'; import {
BadRequestException,
HttpException,
HttpStatus,
Injectable,
} from '@nestjs/common';
import { UserSpaceRepository } from '@app/common/modules/user/repositories'; import { UserSpaceRepository } from '@app/common/modules/user/repositories';
import { SuccessResponseDto } from '@app/common/dto/success.response.dto'; import { SuccessResponseDto } from '@app/common/dto/success.response.dto';
import { BaseResponseDto } from '@app/common/dto/base.response.dto'; import { BaseResponseDto } from '@app/common/dto/base.response.dto';
import { AddUserSpaceDto, AddUserSpaceUsingCodeDto } from '../dtos'; import { AddUserSpaceDto, AddUserSpaceUsingCodeDto } from '../dtos';
import { SpaceRepository } from '@app/common/modules/space/repositories'; import {
InviteSpaceRepository,
SpaceRepository,
} from '@app/common/modules/space/repositories';
import { CommonErrorCodes } from '@app/common/constants/error-codes.enum'; import { CommonErrorCodes } from '@app/common/constants/error-codes.enum';
import { UserDevicePermissionService } from 'src/user-device-permission/services'; import { UserDevicePermissionService } from 'src/user-device-permission/services';
import { PermissionType } from '@app/common/constants/permission-type.enum'; import { PermissionType } from '@app/common/constants/permission-type.enum';
import { SpaceEntity } from '@app/common/modules/space/entities'; import { InviteSpaceEntity } from '@app/common/modules/space/entities/invite-space.entity';
import { UserService } from './user.service';
import { RoleType } from '@app/common/constants/role.type.enum';
import { InviteUserRepository } from '@app/common/modules/Invite-user/repositiories';
import { UserStatusEnum } from '@app/common/constants/user-status.enum';
@Injectable() @Injectable()
export class UserSpaceService { export class UserSpaceService {
constructor( constructor(
private readonly userSpaceRepository: UserSpaceRepository, private readonly userSpaceRepository: UserSpaceRepository,
private readonly spaceRepository: SpaceRepository, private readonly spaceRepository: SpaceRepository,
private readonly inviteSpaceRepository: InviteSpaceRepository,
private readonly userService: UserService,
private readonly inviteUserRepository: InviteUserRepository,
private readonly userDevicePermissionService: UserDevicePermissionService, private readonly userDevicePermissionService: UserDevicePermissionService,
) {} ) {}
@ -37,16 +52,25 @@ export class UserSpaceService {
params: AddUserSpaceUsingCodeDto, params: AddUserSpaceUsingCodeDto,
userUuid: string, userUuid: string,
) { ) {
const { inviteCode } = params;
try { try {
const space = await this.findSpaceByInviteCode(params.inviteCode); const inviteSpace = await this.findInviteSpaceByInviteCode(inviteCode);
const user = await this.userService.getUserDetailsByUserUuid(
userUuid,
true,
);
await this.checkSpaceMemberRole(user);
await this.addUserToSpace(userUuid, inviteSpace.space.uuid);
await this.addUserToSpace(userUuid, space.uuid); const deviceUUIDs = await this.getDeviceUUIDsForSpace(inviteSpace.uuid);
await this.clearUnitInvitationCode(space.uuid);
const deviceUUIDs = await this.getDeviceUUIDsForSpace(space.uuid);
await this.addUserPermissionsToDevices(userUuid, deviceUUIDs); await this.addUserPermissionsToDevices(userUuid, deviceUUIDs);
await this.addUserAsActiveInvitation(
user,
inviteSpace.space.uuid,
inviteCode,
);
await this.clearSpaceInvitationCode(inviteSpace.uuid);
} catch (err) { } catch (err) {
if (err instanceof HttpException) { if (err instanceof HttpException) {
throw err; throw err;
@ -58,25 +82,86 @@ export class UserSpaceService {
} }
} }
} }
private async checkSpaceMemberRole(user: any) {
private async findSpaceByInviteCode(
inviteCode: string,
): Promise<SpaceEntity> {
try { try {
const space = await this.spaceRepository.findOneOrFail({ if (user.role.type !== RoleType.SPACE_MEMBER) {
where: { throw new BadRequestException(
invitationCode: inviteCode, 'You have to be a space member to join this space',
}, );
}); }
return space; } catch (err) {
} catch (error) {
throw new HttpException( throw new HttpException(
'Space with the provided invite code not found', err.message || 'User not found',
HttpStatus.NOT_FOUND, err.status || HttpStatus.NOT_FOUND,
); );
} }
} }
private async findInviteSpaceByInviteCode(
inviteCode: string,
): Promise<InviteSpaceEntity> {
try {
const inviteSpace = await this.inviteSpaceRepository.findOneOrFail({
where: {
invitationCode: inviteCode,
isActive: true,
},
relations: ['space'],
});
return inviteSpace;
} catch (error) {
throw new HttpException(
'Invalid invitation code',
HttpStatus.BAD_REQUEST,
);
}
}
private async clearSpaceInvitationCode(inviteSpaceUuid: string) {
await this.inviteSpaceRepository.update(
{ uuid: inviteSpaceUuid },
{ isActive: false },
);
}
async getProjectBySpaceUuid(spaceUuid: string) {
try {
const project = await this.spaceRepository.findOne({
where: {
uuid: spaceUuid,
},
relations: ['community.project'],
});
return project;
} catch (error) {
throw new HttpException('Space not found', HttpStatus.NOT_FOUND);
}
}
private async addUserAsActiveInvitation(
user: any,
spaceUuid: string,
inviteCode: string,
) {
try {
const space = await this.getProjectBySpaceUuid(spaceUuid);
const inviteUser = this.inviteUserRepository.create({
firstName: user.firstName,
lastName: user.lastName,
email: user.email,
jobTitle: null,
phoneNumber: null,
roleType: { uuid: user.role.uuid },
status: UserStatusEnum.ACTIVE,
invitationCode: inviteCode,
invitedBy: RoleType.SPACE_OWNER,
project: { uuid: space.community.project.uuid },
});
await this.inviteUserRepository.save(inviteUser);
} catch (err) {
throw new HttpException(
err.message || 'Internal Server Error',
HttpStatus.INTERNAL_SERVER_ERROR,
);
}
}
private async addUserToSpace(userUuid: string, spaceUuid: string) { private async addUserToSpace(userUuid: string, spaceUuid: string) {
try { try {
const user = await this.addUserSpace({ userUuid, spaceUuid }); const user = await this.addUserSpace({ userUuid, spaceUuid });
@ -110,13 +195,6 @@ export class UserSpaceService {
} }
} }
private async clearUnitInvitationCode(spaceUuid: string) {
await this.spaceRepository.update(
{ uuid: spaceUuid },
{ invitationCode: null },
);
}
async getDeviceUUIDsForSpace(unitUuid: string): Promise<{ uuid: string }[]> { async getDeviceUUIDsForSpace(unitUuid: string): Promise<{ uuid: string }[]> {
const devices = await this.spaceRepository.find({ const devices = await this.spaceRepository.find({
where: { uuid: unitUuid }, where: { uuid: unitUuid },

View File

@ -23,13 +23,15 @@ export class UserService {
private readonly regionRepository: RegionRepository, private readonly regionRepository: RegionRepository,
private readonly timeZoneRepository: TimeZoneRepository, private readonly timeZoneRepository: TimeZoneRepository,
) {} ) {}
async getUserDetailsByUserUuid(userUuid: string) { async getUserDetailsByUserUuid(userUuid: string, withRole = false) {
try { try {
const user = await this.userRepository.findOne({ const user = await this.userRepository.findOne({
where: { where: {
uuid: userUuid, uuid: userUuid,
}, },
relations: ['region', 'timezone'], ...(withRole
? { relations: ['roleType'] }
: { relations: ['region', 'timezone'] }),
}); });
if (!user) { if (!user) {
throw new BadRequestException('Invalid room UUID'); throw new BadRequestException('Invalid room UUID');
@ -39,13 +41,14 @@ export class UserService {
const cleanedProfilePicture = removeBase64Prefix(user.profilePicture); const cleanedProfilePicture = removeBase64Prefix(user.profilePicture);
return { return {
uuid: user.uuid, uuid: user?.uuid,
email: user.email, email: user?.email,
firstName: user.firstName, firstName: user?.firstName,
lastName: user.lastName, lastName: user?.lastName,
profilePicture: cleanedProfilePicture, profilePicture: cleanedProfilePicture,
region: user.region, region: user?.region,
timeZone: user.timezone, timeZone: user?.timezone,
...(withRole && { role: user?.roleType }),
}; };
} catch (err) { } catch (err) {
if (err instanceof BadRequestException) { if (err instanceof BadRequestException) {

View File

@ -12,10 +12,14 @@ import { UserSpaceController } from './controllers';
import { CommunityModule } from 'src/community/community.module'; import { CommunityModule } from 'src/community/community.module';
import { UserSpaceService } from './services'; import { UserSpaceService } from './services';
import { CommunityRepository } from '@app/common/modules/community/repositories'; import { CommunityRepository } from '@app/common/modules/community/repositories';
import { SpaceRepository } from '@app/common/modules/space/repositories'; import {
InviteSpaceRepository,
SpaceRepository,
} from '@app/common/modules/space/repositories';
import { UserDevicePermissionService } from 'src/user-device-permission/services'; import { UserDevicePermissionService } from 'src/user-device-permission/services';
import { DeviceUserPermissionRepository } from '@app/common/modules/device/repositories'; import { DeviceUserPermissionRepository } from '@app/common/modules/device/repositories';
import { PermissionTypeRepository } from '@app/common/modules/permission/repositories'; import { PermissionTypeRepository } from '@app/common/modules/permission/repositories';
import { InviteUserRepository } from '@app/common/modules/Invite-user/repositiories';
@Module({ @Module({
imports: [ConfigModule, CommunityModule], imports: [ConfigModule, CommunityModule],
@ -32,6 +36,8 @@ import { PermissionTypeRepository } from '@app/common/modules/permission/reposit
DeviceUserPermissionRepository, DeviceUserPermissionRepository,
PermissionTypeRepository, PermissionTypeRepository,
UserSpaceService, UserSpaceService,
InviteSpaceRepository,
InviteUserRepository,
], ],
exports: [UserService], exports: [UserService],
}) })