sentinel commercialization feature

spring-cloud-alibaba-sentinel-datasource/src/main/java/org/springframework/cloud/alibaba/sentinel/datasource/SentinelDataSourceConstants.java

@@ -31,4 +31,6 @@ public interface SentinelDataSourceConstants {
 
 	String NACOS_DATASOURCE_ENDPOINT = PROPERTY_PREFIX + ".nacos.config.endpoint";
 
+	String PROJECT_NAME = PROPERTY_PREFIX + ".nacos.config.project-name";
+
 }

spring-cloud-alibaba-sentinel-datasource/src/main/java/org/springframework/cloud/alibaba/sentinel/datasource/config/DataSourcePropertiesConfiguration.java

@@ -28,6 +28,25 @@ public class DataSourcePropertiesConfiguration {
 
 	private ApolloDataSourceProperties apollo;
 
+	public DataSourcePropertiesConfiguration() {
+	}
+
+	public DataSourcePropertiesConfiguration(FileDataSourceProperties file) {
+		this.file = file;
+	}
+
+	public DataSourcePropertiesConfiguration(NacosDataSourceProperties nacos) {
+		this.nacos = nacos;
+	}
+
+	public DataSourcePropertiesConfiguration(ZookeeperDataSourceProperties zk) {
+		this.zk = zk;
+	}
+
+	public DataSourcePropertiesConfiguration(ApolloDataSourceProperties apollo) {
+		this.apollo = apollo;
+	}
+
 	public FileDataSourceProperties getFile() {
 		return file;
 	}

spring-cloud-alibaba-sentinel-datasource/src/main/java/org/springframework/cloud/alibaba/sentinel/datasource/config/NacosDataSourceProperties.java

@@ -101,4 +101,31 @@ public class NacosDataSourceProperties extends AbstractDataSourceProperties {
 	public void setSecretKey(String secretKey) {
 		this.secretKey = secretKey;
 	}
+
+	public static NacosDataSourceProperties buildFlowByEDAS() {
+		return buildByEDAS("flow");
+	}
+
+	public static NacosDataSourceProperties buildDegradeByEDAS() {
+		return buildByEDAS("degrade");
+	}
+
+	public static NacosDataSourceProperties buildByEDAS(String type) {
+		NacosDataSourceProperties result = new NacosDataSourceProperties();
+		result.setFactoryBeanName(
+				NacosDataSourceWithAuthorizationFactoryBean.class.getName());
+		result.setEndpoint(System.getProperties()
+				.getProperty(SentinelDataSourceConstants.NACOS_DATASOURCE_ENDPOINT));
+		result.setNamespace(System.getProperties()
+				.getProperty(SentinelDataSourceConstants.NACOS_DATASOURCE_NAMESPACE));
+		result.setAccessKey(System.getProperties()
+				.getProperty(SentinelDataSourceConstants.NACOS_DATASOURCE_AK));
+		result.setSecretKey(System.getProperties()
+				.getProperty(SentinelDataSourceConstants.NACOS_DATASOURCE_SK));
+		result.setDataType("json");
+		result.setDataId(System.getProperties()
+				.getProperty(SentinelDataSourceConstants.PROJECT_NAME) + "-" + type);
+		result.setGroupId("nacos-sentinel");
+		return result;
+	}
 }

spring-cloud-alibaba-sentinel/src/main/java/org/springframework/cloud/alibaba/sentinel/SentinelConstants.java

@@ -23,4 +23,9 @@ public interface SentinelConstants {
 
 	String PROPERTY_PREFIX = "spring.cloud.sentinel";
 
+	// commercialization
+
+	String FLOW_DATASOURCE_NAME = "edas-flow";
+	String DEGRADE_DATASOURCE_NAME = "edas-degrade";
+
 }

spring-cloud-alibaba-sentinel/src/main/java/org/springframework/cloud/alibaba/sentinel/custom/SentinelDataSourceHandler.java

@@ -8,6 +8,7 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
+import java.util.TreeMap;
 import java.util.stream.Collectors;
 
 import org.slf4j.Logger;
@@ -16,8 +17,12 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.support.BeanDefinitionBuilder;
 import org.springframework.beans.factory.support.DefaultListableBeanFactory;
 import org.springframework.boot.context.event.ApplicationStartedEvent;
+import org.springframework.cloud.alibaba.sentinel.SentinelConstants;
 import org.springframework.cloud.alibaba.sentinel.SentinelProperties;
+import org.springframework.cloud.alibaba.sentinel.datasource.SentinelDataSourceConstants;
 import org.springframework.cloud.alibaba.sentinel.datasource.config.AbstractDataSourceProperties;
+import org.springframework.cloud.alibaba.sentinel.datasource.config.DataSourcePropertiesConfiguration;
+import org.springframework.cloud.alibaba.sentinel.datasource.config.NacosDataSourceProperties;
 import org.springframework.cloud.alibaba.sentinel.datasource.converter.JsonConverter;
 import org.springframework.cloud.alibaba.sentinel.datasource.converter.XmlConverter;
 import org.springframework.context.event.EventListener;
@@ -73,6 +78,27 @@ public class SentinelDataSourceHandler {
 		DefaultListableBeanFactory beanFactory = (DefaultListableBeanFactory) event
 				.getApplicationContext().getAutowireCapableBeanFactory();
 
+		// commercialization
+		if (!StringUtils.isEmpty(System.getProperties()
+				.getProperty(SentinelDataSourceConstants.NACOS_DATASOURCE_ENDPOINT))) {
+			Map<String, DataSourcePropertiesConfiguration> newDataSourceMap = new TreeMap<>(
+					String.CASE_INSENSITIVE_ORDER);
+			for (Map.Entry<String, DataSourcePropertiesConfiguration> entry : sentinelProperties
+					.getDatasource().entrySet()) {
+				if (entry.getValue().getValidDataSourceProperties()
+						.getClass() != NacosDataSourceProperties.class) {
+					newDataSourceMap.put(entry.getKey(), entry.getValue());
+				}
+			}
+			newDataSourceMap.put(SentinelConstants.FLOW_DATASOURCE_NAME,
+					new DataSourcePropertiesConfiguration(
+							NacosDataSourceProperties.buildFlowByEDAS()));
+			newDataSourceMap.put(SentinelConstants.DEGRADE_DATASOURCE_NAME,
+					new DataSourcePropertiesConfiguration(
+							NacosDataSourceProperties.buildDegradeByEDAS()));
+			sentinelProperties.setDatasource(newDataSourceMap);
+		}
+
 		sentinelProperties.getDatasource()
 				.forEach((dataSourceName, dataSourceProperties) -> {
 					List<String> validFields = dataSourceProperties.getValidField();

spring-cloud-alicloud-context/src/main/java/org/springframework/cloud/alicloud/context/Constants.java

@@ -21,12 +21,13 @@ package org.springframework.cloud.alicloud.context;
  */
 public interface Constants {
 
-    interface Sentinel {
-        String PROPERTY_PREFIX = "spring.cloud.sentinel";
-        String NACOS_DATASOURCE_AK = PROPERTY_PREFIX + ".nacos.config.access-key";
-        String NACOS_DATASOURCE_SK = PROPERTY_PREFIX + ".nacos.config.secret-key";
-        String NACOS_DATASOURCE_NAMESPACE = PROPERTY_PREFIX + ".nacos.config.namespace";
-        String NACOS_DATASOURCE_ENDPOINT = PROPERTY_PREFIX + ".nacos.config.endpoint";
-    }
+	interface Sentinel {
+		String PROPERTY_PREFIX = "spring.cloud.sentinel";
+		String NACOS_DATASOURCE_AK = PROPERTY_PREFIX + ".nacos.config.access-key";
+		String NACOS_DATASOURCE_SK = PROPERTY_PREFIX + ".nacos.config.secret-key";
+		String NACOS_DATASOURCE_NAMESPACE = PROPERTY_PREFIX + ".nacos.config.namespace";
+		String NACOS_DATASOURCE_ENDPOINT = PROPERTY_PREFIX + ".nacos.config.endpoint";
+		String PROJECT_NAME = PROPERTY_PREFIX + ".nacos.config.project-name";
+	}
 
 }

spring-cloud-alicloud-context/src/main/java/org/springframework/cloud/alicloud/context/sentinel/SentinelAliCloudListener.java

@@ -52,6 +52,8 @@ public class SentinelAliCloudListener
 				edasChangeOrderConfiguration.getDauthAccessKey());
 		System.getProperties().setProperty(Constants.Sentinel.NACOS_DATASOURCE_SK,
 				edasChangeOrderConfiguration.getDauthSecretKey());
+		System.getProperties().setProperty(Constants.Sentinel.PROJECT_NAME,
+				edasChangeOrderConfiguration.getProjectName());
 	}
 
 	@Override