feat: support config event (#598)

Author: shedfreewu

polaris-common/polaris-client/src/main/java/com/tencent/polaris/client/flow/BaseFlow.java

@@ -27,6 +27,7 @@
 import com.tencent.polaris.api.plugin.compose.DefaultRouterChainGroup;
 import com.tencent.polaris.api.plugin.compose.Extensions;
 import com.tencent.polaris.api.plugin.compose.RouterChainGroup;
+import com.tencent.polaris.api.plugin.event.ConfigEvent;
 import com.tencent.polaris.api.plugin.event.EventReporter;
 import com.tencent.polaris.api.plugin.event.FlowEvent;
 import com.tencent.polaris.api.plugin.loadbalance.LoadBalancer;
@@ -368,4 +369,23 @@ public static void reportFlowEvent(Extensions extensions, FlowEvent flowEvent) {
             }
         }
     }
+
+    public static void reportConfigEvent(Extensions extensions, ConfigEvent flowEvent) {
+        List<EventReporter> eventReporterList = extensions.getEventReporterList();
+        if (LOG.isDebugEnabled()) {
+            LOG.debug("Reporting config event: {}", flowEvent);
+        }
+        for (EventReporter eventReporter : eventReporterList) {
+            try {
+                if (!eventReporter.isEnabled()) {
+                    continue;
+                }
+                if (!eventReporter.reportEvent(flowEvent)) {
+                    LOG.warn("Report event by {} failed. Config event detail: {}", eventReporter.getName(), flowEvent);
+                }
+            } catch (Throwable throwable) {
+                LOG.warn("Report event by {} failed. Config event detail: {}", eventReporter.getName(), flowEvent, throwable);
+            }
+        }
+    }
 }

polaris-configuration/polaris-configuration-api/src/main/java/com/tencent/polaris/configuration/api/core/ConfigFileMetadata.java

@@ -29,4 +29,6 @@ public interface ConfigFileMetadata {
     String getFileGroup();
 
     String getFileName();
+
+    String getFileVersion();
 }

polaris-configuration/polaris-configuration-api/src/main/java/com/tencent/polaris/configuration/api/core/ConfigKVFileChangeEvent.java

@@ -20,15 +20,20 @@
 import java.util.Map;
 import java.util.Set;
 
+import com.tencent.polaris.api.plugin.configuration.ConfigFile;
+
 /**
  * @author lepdou 2022-03-01
  */
 public class ConfigKVFileChangeEvent {
 
     private final Map<String, ConfigPropertyChangeInfo> propertyChangeInfos;
 
-    public ConfigKVFileChangeEvent(Map<String, ConfigPropertyChangeInfo> changeInfos) {
+    private final com.tencent.polaris.api.plugin.configuration.ConfigFile configFile;
+
+    public ConfigKVFileChangeEvent(Map<String, ConfigPropertyChangeInfo> changeInfos, com.tencent.polaris.api.plugin.configuration.ConfigFile configFile) {
         this.propertyChangeInfos = changeInfos;
+        this.configFile = configFile;
     }
 
     public Set<String> changedKeys() {
@@ -67,4 +72,7 @@ public ChangeType getPropertiesChangeType(String propertyKey) {
         return ChangeType.NOT_CHANGED;
     }
 
+    public ConfigFile getConfigFile() {
+        return configFile;
+    }
 }

polaris-configuration/polaris-configuration-client/src/main/java/com/tencent/polaris/configuration/client/internal/AbstractConfigFileRepo.java

@@ -18,6 +18,7 @@
 package com.tencent.polaris.configuration.client.internal;
 
 import com.google.common.collect.Lists;
+import com.tencent.polaris.api.plugin.configuration.ConfigFile;
 import com.tencent.polaris.client.api.SDKContext;
 import com.tencent.polaris.configuration.api.core.ConfigFileMetadata;
 import com.tencent.polaris.logging.LoggerFactory;
@@ -65,10 +66,10 @@ public void removeChangeListener(ConfigFileRepoChangeListener listener) {
         listeners.remove(listener);
     }
 
-    protected void fireChangeEvent(String newContent) {
+    protected void fireChangeEvent(ConfigFile configFile) {
         for (ConfigFileRepoChangeListener listener : listeners) {
             try {
-                listener.onChange(configFileMetadata, newContent);
+                listener.onChange(configFileMetadata, configFile);
             } catch (Throwable t) {
                 LOGGER.error("[Config] invoke config file repo change listener failed. config file = {}, listener = {}",
                         configFileMetadata, listener.getClass(), t);

polaris-configuration/polaris-configuration-client/src/main/java/com/tencent/polaris/configuration/client/internal/CompositeConfigFile.java

@@ -193,4 +193,9 @@ public String getFileGroup() {
     public String getFileName() {
         return "";
     }
+
+    @Override
+    public String getFileVersion() {
+        return "";
+    }
 }

polaris-configuration/polaris-configuration-client/src/main/java/com/tencent/polaris/configuration/client/internal/ConfigFileRepoChangeListener.java

@@ -17,13 +17,14 @@
 
 package com.tencent.polaris.configuration.client.internal;
 
+import com.tencent.polaris.api.plugin.configuration.ConfigFile;
 import com.tencent.polaris.configuration.api.core.ConfigFileMetadata;
 
 /**
  * @author lepdou 2022-03-02
  */
 public interface ConfigFileRepoChangeListener {
 
-    void onChange(ConfigFileMetadata configFileMetadata, String newContent);
+    void onChange(ConfigFileMetadata configFileMetadata, ConfigFile configFile);
 
 }

polaris-configuration/polaris-configuration-client/src/main/java/com/tencent/polaris/configuration/client/internal/ConfigPropertiesFile.java

@@ -23,6 +23,7 @@
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.tencent.polaris.api.config.configuration.ConfigFileConfig;
+import com.tencent.polaris.api.plugin.configuration.ConfigFile;
 import com.tencent.polaris.configuration.api.core.*;
 import com.tencent.polaris.configuration.client.util.ConfigFileUtils;
 import com.tencent.polaris.configuration.client.util.ConvertFunctions;
@@ -321,9 +322,9 @@ public void removeChangeListener(ConfigKVFileChangeListener listener) {
     }
 
     @Override
-    public void onChange(ConfigFileMetadata configFileMetadata, String newContent) {
-        super.onChange(configFileMetadata, newContent);
-
+    public void onChange(ConfigFileMetadata configFileMetadata, ConfigFile configFile) {
+        super.onChange(configFileMetadata, configFile);
+        String newContent = Optional.ofNullable(configFile).map(ConfigFile::getContent).orElse(null);
         Properties oldProperties = this.properties.get();
         if (oldProperties == null) {
             oldProperties = new Properties();
@@ -358,7 +359,7 @@ public void onChange(ConfigFileMetadata configFileMetadata, String newContent) {
 
         clearConfigCache();
 
-        ConfigKVFileChangeEvent event = new ConfigKVFileChangeEvent(changeInfos);
+        ConfigKVFileChangeEvent event = new ConfigKVFileChangeEvent(changeInfos, configFile);
 
         fireChangeEvent(event);
     }

polaris-configuration/polaris-configuration-client/src/main/java/com/tencent/polaris/configuration/client/internal/DefaultConfigFile.java

@@ -33,6 +33,7 @@
 import java.lang.reflect.Type;
 import java.util.List;
 import java.util.Objects;
+import java.util.Optional;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
@@ -170,8 +171,9 @@ public void removeChangeListener(ConfigFileChangeListener listener) {
     }
 
     @Override
-    public void onChange(ConfigFileMetadata configFileMetadata, String newContent) {
+    public void onChange(ConfigFileMetadata configFileMetadata, com.tencent.polaris.api.plugin.configuration.ConfigFile configFile) {
         String oldContent = this.content;
+        String newContent = Optional.ofNullable(configFile).map(com.tencent.polaris.api.plugin.configuration.ConfigFile::getContent).orElse(null);
         this.content = newContent;
 
         ChangeType changeType = ChangeType.MODIFIED;

polaris-configuration/polaris-configuration-client/src/main/java/com/tencent/polaris/configuration/client/internal/DefaultConfigFileMetadata.java

@@ -29,11 +29,20 @@ public class DefaultConfigFileMetadata implements ConfigFileMetadata {
     private final String namespace;
     private final String fileGroup;
     private final String fileName;
+    private final String fileVersion;
 
     public DefaultConfigFileMetadata(String namespace, String fileGroup, String fileName) {
         this.namespace = namespace;
         this.fileGroup = fileGroup;
         this.fileName = fileName;
+        this.fileVersion = null;
+    }
+
+    public DefaultConfigFileMetadata(String namespace, String fileGroup, String fileName, String fileVersion) {
+        this.namespace = namespace;
+        this.fileGroup = fileGroup;
+        this.fileName = fileName;
+        this.fileVersion = fileVersion;
     }
 
     @Override
@@ -51,6 +60,11 @@ public String getFileName() {
         return fileName;
     }
 
+    @Override
+    public String getFileVersion() {
+        return fileVersion;
+    }
+
     @Override
     public int hashCode() {
         return Objects.hash(namespace, fileGroup, fileName);

polaris-configuration/polaris-configuration-client/src/main/java/com/tencent/polaris/configuration/client/internal/DefaultRevisableConfigFileGroupPullService.java

@@ -134,7 +134,8 @@ private void pullAll() {
 
                         List<ConfigFileMetadata> configFileMetadataList = new ArrayList<>();
                         for (ConfigFile configFile : configFileList) {
-                            ConfigFileMetadata configFileMetadata = new DefaultConfigFileMetadata(configFile.getNamespace(), configFile.getFileGroup(), configFile.getFileName());
+                            ConfigFileMetadata configFileMetadata = new DefaultConfigFileMetadata(configFile.getNamespace(),
+                                    configFile.getFileGroup(), configFile.getFileName(), configFile.getName());
                             configFileMetadataList.add(configFileMetadata);
                         }
                         if (configFileGroupCache.containsKey(metadata)) {