Skip to content

Commit 214927e

Browse files
ArtuomkaArtuomka
committed
feat: add GetConnectionsInfoByIds use case and corresponding API endpoint
1 parent eb44093 commit 214927e

6 files changed

Lines changed: 81 additions & 0 deletions

File tree

‎backend/src/common/data-injection.tokens.ts‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -118,6 +118,7 @@ export enum UseCaseType {
118118
SAAS_CREATE_CONNECTION_FOR_HOSTED_DB = 'SAAS_CREATE_CONNECTION_FOR_HOSTED_DB',
119119
SAAS_DELETE_CONNECTION_FOR_HOSTED_DB = 'SAAS_DELETE_CONNECTION_FOR_HOSTED_DB',
120120
SAAS_UPDATE_HOSTED_CONNECTION_PASSWORD = 'SAAS_UPDATE_HOSTED_CONNECTION_PASSWORD',
121+
SAAS_GET_CONNECTIONS_INFO_BY_IDS = 'SAAS_GET_CONNECTIONS_INFO_BY_IDS',
121122

122123
INVITE_USER_IN_COMPANY_AND_CONNECTION_GROUP = 'INVITE_USER_IN_COMPANY_AND_CONNECTION_GROUP',
123124
VERIFY_INVITE_USER_IN_COMPANY_AND_CONNECTION_GROUP = 'VERIFY_INVITE_USER_IN_COMPANY_AND_CONNECTION_GROUP',

‎backend/src/microservices/saas-microservice/data-structures/get-connections-info-by-ids.ds.ts‎

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
import { ApiProperty } from '@nestjs/swagger';
2+
import { IsArray, IsNotEmpty, IsString } from 'class-validator';
3+
4+
export class GetConnectionsInfoByIdsDS {
5+
@ApiProperty({ type: [String] })
6+
@IsArray()
7+
@IsNotEmpty()
8+
@IsString({ each: true })
9+
connectionIds: Array<string>;
10+
}

‎backend/src/microservices/saas-microservice/saas.controller.ts‎

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,9 +24,11 @@ import { UserEntity } from '../../entities/user/user.entity.js';
2424
import { InTransactionEnum } from '../../enums/in-transaction.enum.js';
2525
import { Messages } from '../../exceptions/text/messages.js';
2626
import { SentryInterceptor } from '../../interceptors/sentry.interceptor.js';
27+
import { ConnectionEntity } from '../../entities/connection/connection.entity.js';
2728
import { CreatedConnectionResponse, SuccessResponse } from './data-structures/common-responce.ds.js';
2829
import { CreateConnectionForHostedDbDto } from './data-structures/create-connecttion-for-selfhosted-db.dto.js';
2930
import { DeleteConnectionForHostedDbDto } from './data-structures/delete-connection-for-hosted-db.dto.js';
31+
import { GetConnectionsInfoByIdsDS } from './data-structures/get-connections-info-by-ids.ds.js';
3032
import { RegisterCompanyWebhookDS } from './data-structures/register-company.ds.js';
3133
import { RegisteredCompanyDS } from './data-structures/registered-company.ds.js';
3234
import { SaasRegisterUserWithGithub } from './data-structures/saas-register-user-with-github.js';
@@ -38,6 +40,7 @@ import {
3840
ICreateConnectionForHostedDb,
3941
IDeleteConnectionForHostedDb,
4042
IFreezeConnectionsInCompany,
43+
IGetConnectionsInfoByIds,
4144
IGetUserInfo,
4245
ILoginUserWithGitHub,
4346
ILoginUserWithGoogle,
@@ -95,6 +98,8 @@ export class SaasController {
9598
private readonly deleteConnectionForHostedDbUseCase: IDeleteConnectionForHostedDb,
9699
@Inject(UseCaseType.SAAS_UPDATE_HOSTED_CONNECTION_PASSWORD)
97100
private readonly updateHostedConnectionPasswordUseCase: IUpdateHostedConnectionPassword,
101+
@Inject(UseCaseType.SAAS_GET_CONNECTIONS_INFO_BY_IDS)
102+
private readonly getConnectionsInfoByIdsUseCase: IGetConnectionsInfoByIds,
98103
) {}
99104

100105
@ApiOperation({ summary: 'Company registered webhook' })
@@ -326,4 +331,17 @@ export class SaasController {
326331
): Promise<SuccessResponse> {
327332
return await this.updateHostedConnectionPasswordUseCase.execute(updatePasswordData);
328333
}
334+
335+
@ApiOperation({ summary: 'Get connections info by ids' })
336+
@ApiBody({ type: GetConnectionsInfoByIdsDS })
337+
@ApiResponse({
338+
status: 200,
339+
type: [ConnectionEntity],
340+
})
341+
@Post('/connections/info')
342+
async getConnectionsInfoByIds(
343+
@Body() connectionsData: GetConnectionsInfoByIdsDS,
344+
): Promise<Array<ConnectionEntity>> {
345+
return await this.getConnectionsInfoByIdsUseCase.execute(connectionsData);
346+
}
329347
}

‎backend/src/microservices/saas-microservice/saas.module.ts‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@ import { SaasUsualRegisterUseCase } from './use-cases/saas-usual-register-user.u
2323
import { SuspendUsersUseCase } from './use-cases/suspend-users.use.case.js';
2424
import { SuspendUsersOverLimitUseCase } from './use-cases/suspend-users-over-limit.use.case.js';
2525
import { UnFreezeConnectionsInCompanyUseCase } from './use-cases/unfreeze-connections-in-company-use.case.js';
26+
import { GetConnectionsInfoByIdsUseCase } from './use-cases/get-connections-info-by-ids.use.case.js';
2627
import { UpdateHostedConnectionPasswordUseCase } from './use-cases/update-hosted-connection-password.use.case.js';
2728

2829
@Module({
@@ -100,6 +101,10 @@ import { UpdateHostedConnectionPasswordUseCase } from './use-cases/update-hosted
100101
provide: UseCaseType.SAAS_UPDATE_HOSTED_CONNECTION_PASSWORD,
101102
useClass: UpdateHostedConnectionPasswordUseCase,
102103
},
104+
{
105+
provide: UseCaseType.SAAS_GET_CONNECTIONS_INFO_BY_IDS,
106+
useClass: GetConnectionsInfoByIdsUseCase,
107+
},
103108
SignInAuditService,
104109
],
105110
controllers: [SaasController],
@@ -126,6 +131,7 @@ export class SaasModule {
126131
{ path: 'saas/connection/hosted', method: RequestMethod.POST },
127132
{ path: 'saas/connection/hosted/delete', method: RequestMethod.POST },
128133
{ path: 'saas/connection/hosted/password', method: RequestMethod.POST },
134+
{ path: 'saas/connections/info', method: RequestMethod.POST },
129135
);
130136
}
131137
}

‎backend/src/microservices/saas-microservice/use-cases/get-connections-info-by-ids.use.case.ts‎

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,40 @@
1+
import { HttpException, HttpStatus, Inject, Injectable } from '@nestjs/common';
2+
import { In } from 'typeorm';
3+
import AbstractUseCase from '../../../common/abstract-use.case.js';
4+
import { IGlobalDatabaseContext } from '../../../common/application/global-database-context.interface.js';
5+
import { BaseType } from '../../../common/data-injection.tokens.js';
6+
import { ConnectionEntity } from '../../../entities/connection/connection.entity.js';
7+
import { Messages } from '../../../exceptions/text/messages.js';
8+
import { GetConnectionsInfoByIdsDS } from '../data-structures/get-connections-info-by-ids.ds.js';
9+
import { IGetConnectionsInfoByIds } from './saas-use-cases.interface.js';
10+
11+
@Injectable()
12+
export class GetConnectionsInfoByIdsUseCase
13+
extends AbstractUseCase<GetConnectionsInfoByIdsDS, Array<ConnectionEntity>>
14+
implements IGetConnectionsInfoByIds
15+
{
16+
constructor(
17+
@Inject(BaseType.GLOBAL_DB_CONTEXT)
18+
protected _dbContext: IGlobalDatabaseContext,
19+
) {
20+
super();
21+
}
22+
23+
protected async implementation(inputData: GetConnectionsInfoByIdsDS): Promise<Array<ConnectionEntity>> {
24+
const { connectionIds } = inputData;
25+
if (!connectionIds || connectionIds.length === 0) {
26+
throw new HttpException(
27+
{
28+
message: Messages.CONNECTION_ID_MISSING,
29+
},
30+
HttpStatus.BAD_REQUEST,
31+
);
32+
}
33+
34+
const connections = await this._dbContext.connectionRepository.findBy({
35+
id: In(connectionIds),
36+
});
37+
38+
return connections;
39+
}
40+
}

‎backend/src/microservices/saas-microservice/use-cases/saas-use-cases.interface.ts‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
import { CompanyInfoEntity } from '../../../entities/company-info/company-info.entity.js';
22
import { CreatedConnectionDTO } from '../../../entities/connection/application/dto/created-connection.dto.js';
3+
import { ConnectionEntity } from '../../../entities/connection/connection.entity.js';
34
import { SaaSRegisterDemoUserAccountDS } from '../../../entities/user/application/data-structures/demo-user-account-register.ds.js';
45
import { SaasUsualUserRegisterDS } from '../../../entities/user/application/data-structures/usual-register-user.ds.js';
56
import { FoundUserDto } from '../../../entities/user/dto/found-user.dto.js';
@@ -9,6 +10,7 @@ import { CreatedConnectionResponse, SuccessResponse } from '../data-structures/c
910
import { CreateConnectionForHostedDbDto } from '../data-structures/create-connecttion-for-selfhosted-db.dto.js';
1011
import { DeleteConnectionForHostedDbDto } from '../data-structures/delete-connection-for-hosted-db.dto.js';
1112
import { FreezeConnectionsInCompanyDS } from '../data-structures/freeze-connections-in-company.ds.js';
13+
import { GetConnectionsInfoByIdsDS } from '../data-structures/get-connections-info-by-ids.ds.js';
1214
import { GetUserInfoByIdDS } from '../data-structures/get-user-info.ds.js';
1315
import { GetUsersInfosByEmailDS } from '../data-structures/get-users-infos-by-email.ds.js';
1416
import { RegisterCompanyWebhookDS } from '../data-structures/register-company.ds.js';
@@ -82,3 +84,7 @@ export interface IDeleteConnectionForHostedDb {
8284
export interface IUpdateHostedConnectionPassword {
8385
execute(inputData: UpdateHostedConnectionPasswordDto): Promise<SuccessResponse>;
8486
}
87+
88+
export interface IGetConnectionsInfoByIds {
89+
execute(inputData: GetConnectionsInfoByIdsDS): Promise<Array<ConnectionEntity>>;
90+
}

0 commit comments

Comments
 (0)