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

Merge branch 'fixBrokerSubscription' into 'main' 

fix typo

See merge request v3/service/auth!25
This commit is contained in:
Sylvain Briat 2023-03-24 09:34:45 +00:00
parent b8308cfe37 7818ce2d0a
commit dd557c78f7
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
package-lock.json generated
View File

@ -1,11 +1,11 @@
{ {
"name": "mobicoop-v3-auth", "name": "@mobicoop/auth",
"version": "0.0.1", "version": "0.0.1",
"lockfileVersion": 2, "lockfileVersion": 2,
"requires": true, "requires": true,
"packages": { "packages": {
"": { "": {
"name": "mobicoop-v3-auth", "name": "@mobicoop/auth",
"version": "0.0.1", "version": "0.0.1",
"license": "AGPL", "license": "AGPL",
"dependencies": { "dependencies": {

4
src/modules/authentication/adapters/primaries/authentication-messager.controller.ts
View File

@ -12,7 +12,7 @@ export class AuthenticationMessagerController {
constructor(private readonly _commandBus: CommandBus) {} constructor(private readonly _commandBus: CommandBus) {}
@RabbitSubscribe({ @RabbitSubscribe({
name: 'user-update', name: 'userUpdate',
}) })
public async userUpdatedHandler(message: string) { public async userUpdatedHandler(message: string) {
const updatedUser = JSON.parse(message); const updatedUser = JSON.parse(message);
@ -38,7 +38,7 @@ export class AuthenticationMessagerController {
} }
@RabbitSubscribe({ @RabbitSubscribe({
name: 'user-delete', name: 'userDelete',
}) })
public async userDeletedHandler(message: string) { public async userDeletedHandler(message: string) {
const deletedUser = JSON.parse(message); const deletedUser = JSON.parse(message);

2
src/modules/authentication/authentication.module.ts
View File

@ -23,7 +23,6 @@ import { Messager } from './adapters/secondaries/messager';
CqrsModule, CqrsModule,
RabbitMQModule.forRootAsync(RabbitMQModule, { RabbitMQModule.forRootAsync(RabbitMQModule, {
imports: [ConfigModule], imports: [ConfigModule],
inject: [ConfigService],
useFactory: async (configService: ConfigService) => ({ useFactory: async (configService: ConfigService) => ({
exchanges: [ exchanges: [
{ {
@ -45,6 +44,7 @@ import { Messager } from './adapters/secondaries/messager';
connectionInitOptions: { wait: false }, connectionInitOptions: { wait: false },
enableControllerDiscovery: true, enableControllerDiscovery: true,
}), }),
inject: [ConfigService],
}), }),
], ],
controllers: [AuthenticationController, AuthenticationMessagerController], controllers: [AuthenticationController, AuthenticationMessagerController],