ncaron
/
ad
mirror of https://gitlab.com/mobicoop/v3/service/ad.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

updating internal dependencies

This commit is contained in:
Grégoire Chevalier 2023-06-19 17:14:38 +02:00
parent fe7d948fd1
commit 64c5a3690a
4 changed files with 733 additions and 863 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1518
package-lock.json generated
View File

File diff suppressed because it is too large Load Diff

4
package.json
View File

@ -40,8 +40,8 @@
"@grpc/grpc-js": "^1.8.14", "@grpc/grpc-js": "^1.8.14",
"@grpc/proto-loader": "^0.7.6", "@grpc/proto-loader": "^0.7.6",
"@liaoliaots/nestjs-redis": "^9.0.5", "@liaoliaots/nestjs-redis": "^9.0.5",
"@mobicoop/configuration-module": "^1.1.0", "@mobicoop/configuration-module": "^1.2.0",
"@mobicoop/message-broker-module": "^1.0.5", "@mobicoop/message-broker-module": "^1.2.0",
"@nestjs/common": "^9.0.0", "@nestjs/common": "^9.0.0",
"@nestjs/config": "^2.3.1", "@nestjs/config": "^2.3.1",
"@nestjs/core": "^9.0.0", "@nestjs/core": "^9.0.0",

73
src/app.module.ts
View File

@ -17,49 +17,40 @@ import {
imports: [ imports: [
ConfigModule.forRoot({ isGlobal: true }), ConfigModule.forRoot({ isGlobal: true }),
AutomapperModule.forRoot({ strategyInitializer: classes() }), AutomapperModule.forRoot({ strategyInitializer: classes() }),
MessageBrokerModule.forRootAsync( MessageBrokerModule.forRootAsync({
{ imports: [ConfigModule],
imports: [ConfigModule], inject: [ConfigService],
inject: [ConfigService], useFactory: async (
useFactory: async ( configService: ConfigService,
configService: ConfigService, ): Promise<MessageBrokerModuleOptions> => ({
): Promise<MessageBrokerModuleOptions> => ({ uri: configService.get<string>('MESSAGE_BROKER_URI'),
exchange: configService.get<string>('MESSAGE_BROKER_EXCHANGE'),
name: 'ad',
}),
}),
ConfigurationModule.forRootAsync({
imports: [ConfigModule],
inject: [ConfigService],
useFactory: async (
configService: ConfigService,
): Promise<ConfigurationModuleOptions> => ({
domain: configService.get<string>('SERVICE_CONFIGURATION_DOMAIN'),
messageBroker: {
uri: configService.get<string>('MESSAGE_BROKER_URI'), uri: configService.get<string>('MESSAGE_BROKER_URI'),
exchange: configService.get<string>('MESSAGE_BROKER_EXCHANGE'), exchange: configService.get<string>('MESSAGE_BROKER_EXCHANGE'),
}), },
}, redis: {
false, host: configService.get<string>('REDIS_HOST'),
), password: configService.get<string>('REDIS_PASSWORD'),
ConfigurationModule.forRootAsync( port: configService.get<number>('REDIS_PORT'),
{ },
imports: [ConfigModule],
inject: [ConfigService], propagateConfigurationRoutingKey: 'configuration.propagate',
useFactory: async ( setConfigurationBrokerQueue: 'ad-configuration-create-update',
configService: ConfigService, deleteConfigurationQueue: 'ad-configuration-delete',
): Promise<ConfigurationModuleOptions> => ({ propagateConfigurationQueue: 'ad-configuration-propagate',
domain: configService.get<string>('SERVICE_CONFIGURATION_DOMAIN'), }),
messageBroker: { }),
uri: configService.get<string>('MESSAGE_BROKER_URI'),
exchange: configService.get<string>('MESSAGE_BROKER_EXCHANGE'),
},
redis: {
host: configService.get<string>('REDIS_HOST'),
password: configService.get<string>('REDIS_PASSWORD'),
port: configService.get<number>('REDIS_PORT'),
},
setConfigurationBrokerRoutingKeys: [
'configuration.create',
'configuration.update',
],
deleteConfigurationRoutingKey: 'configuration.delete',
propagateConfigurationRoutingKey: 'configuration.propagate',
setConfigurationBrokerQueue: 'ad-configuration-create-update',
deleteConfigurationQueue: 'ad-configuration-delete',
propagateConfigurationQueue: 'ad-configuration-propagate',
}),
},
true,
),
HealthModule, HealthModule,
AdModule, AdModule,
], ],

1
src/modules/ad/adapters/primaries/ad.controller.ts
View File

@ -41,6 +41,7 @@ export class AdController {
@GrpcMethod('AdsService', 'Create') @GrpcMethod('AdsService', 'Create')
async createAd(data: CreateAdRequest): Promise<AdPresenter> { async createAd(data: CreateAdRequest): Promise<AdPresenter> {
console.log('call');
try { try {
const ad = await this.commandBus.execute(new CreateAdCommand(data)); const ad = await this.commandBus.execute(new CreateAdCommand(data));
return this.mapper.map(ad, Ad, AdPresenter); return this.mapper.map(ad, Ad, AdPresenter);