From 78e377bb53b9e9a2dde298a6ebd616e63dadb7c5 Mon Sep 17 00:00:00 2001 From: kkopanidis Date: Tue, 23 Aug 2022 16:54:01 +0300 Subject: [PATCH] fix(core): admin config update channel inconsistency fix(admin): admin config update inconsistency --- packages/admin/src/index.ts | 2 +- packages/core/src/config-manager/index.ts | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/admin/src/index.ts b/packages/admin/src/index.ts index f7174e338..4173ae25b 100644 --- a/packages/admin/src/index.ts +++ b/packages/admin/src/index.ts @@ -149,7 +149,7 @@ export default class AdminModule extends IConduitAdmin { } async subscribeToBusEvents() { - this.grpcSdk.bus!.subscribe('config:update:admin', (config: string) => { + this.grpcSdk.bus!.subscribe('admin:config:update', (config: string) => { const cfg: convict.Config = JSON.parse(config); this.handleConfigUpdate(cfg); }); diff --git a/packages/core/src/config-manager/index.ts b/packages/core/src/config-manager/index.ts index a2c55dbef..4a1a73894 100644 --- a/packages/core/src/config-manager/index.ts +++ b/packages/core/src/config-manager/index.ts @@ -196,7 +196,7 @@ export default class ConfigManager implements IConfigManager { try { await this._configStorage.setConfig(moduleName, JSON.stringify(moduleConfig)); if (moduleName === 'admin') { - this.grpcSdk.bus!.publish('config:update:admin', JSON.stringify(moduleConfig)); + this.grpcSdk.bus!.publish('admin:config:update', JSON.stringify(moduleConfig)); this.sdk.getAdmin().handleConfigUpdate(moduleConfig); } return moduleConfig;