Yuki Takei 5 лет назад
Родитель
Сommit
8b7109992e

+ 1 - 1
src/server/service/config-manager.js

@@ -326,7 +326,7 @@ class ConfigManager extends ConfigPubsubMessageHandlable {
   /**
   /**
    * @inheritdoc
    * @inheritdoc
    */
    */
-  souldHandleConfigPubsubMessage(configPubsubMessage) {
+  shouldHandleConfigPubsubMessage(configPubsubMessage) {
     const { eventName, updatedAt } = configPubsubMessage;
     const { eventName, updatedAt } = configPubsubMessage;
     return eventName === 'configUpdated' && updatedAt != null;
     return eventName === 'configUpdated' && updatedAt != null;
   }
   }

+ 1 - 1
src/server/service/config-pubsub/handlable.js

@@ -1,7 +1,7 @@
 // TODO: make interface with TS
 // TODO: make interface with TS
 class ConfigPubsubMessageHandlable {
 class ConfigPubsubMessageHandlable {
 
 
-  souldHandleConfigPubsubMessage(configPubsubMessage) {
+  shouldHandleConfigPubsubMessage(configPubsubMessage) {
     throw new Error('implement this');
     throw new Error('implement this');
   }
   }
 
 

+ 4 - 1
src/server/service/config-pubsub/nchan.js

@@ -146,7 +146,10 @@ class NchanDelegator extends ConfigPubsubDelegator {
     try {
     try {
       const configPubsubMessage = ConfigPubsubMessage.parse(message.utf8Data);
       const configPubsubMessage = ConfigPubsubMessage.parse(message.utf8Data);
 
 
-      if (handlable.souldHandleConfigPubsubMessage(configPubsubMessage)) {
+      const shouldHandle = handlable.shouldHandleConfigPubsubMessage(configPubsubMessage);
+      logger.debug(`shouldHandle: ${shouldHandle}`, configPubsubMessage);
+
+      if (handlable.shouldHandleConfigPubsubMessage(configPubsubMessage)) {
         handlable.handleConfigPubsubMessage(configPubsubMessage);
         handlable.handleConfigPubsubMessage(configPubsubMessage);
       }
       }
     }
     }