keySet = properties.keySet();
- return keySet.toArray(new String[keySet.size()]);
- }
-
- @Override
- public Object getProperty(String name) {
- return properties.get(name);
- }
-
- /**
- *
- * Gets settings from Azure/Cache to set as configurations. Updates the cache.
- *
- *
- *
- * Note: Doesn't update Feature Management, just stores values in cache. Call {@code initFeatures} to update
- * Feature Management, but make sure its done in the last {@code AppConfigurationPropertySource}
- * AppConfigurationPropertySource}
- *
- *
- * @param featureSet The set of Feature Management Flags from various config stores.
- * @return Updated Feature Set from Property Source
- * @throws IOException Thrown when processing key/value failed when reading feature flags
- * @throws AppConfigurationStatusException An error occurred in connecting, and should be retried on a replica if
- * possible.
- */
- FeatureSet initProperties(FeatureSet featureSet) throws IOException, AppConfigurationStatusException {
- SettingSelector settingSelector = new SettingSelector();
-
- List features = null;
- // Reading In Features
- if (featureStore.getEnabled()) {
- settingSelector.setKeyFilter(featureStore.getKeyFilter()).setLabelFilter(featureStore.getLabelFilter());
-
- features = replicaClient.listConfigurationSettings(settingSelector);
- }
-
- List labels = Arrays.asList(selectedKeys.getLabelFilter(profiles));
- Collections.reverse(labels);
-
- for (String label : labels) {
- settingSelector = new SettingSelector().setKeyFilter(selectedKeys.getKeyFilter() + "*")
- .setLabelFilter(label);
-
- // * for wildcard match
- List settings = replicaClient.listConfigurationSettings(settingSelector);
- for (ConfigurationSetting setting : settings) {
- String key = setting.getKey().trim().substring(selectedKeys.getKeyFilter().length()).replace('/', '.');
- if (setting instanceof SecretReferenceConfigurationSetting) {
- String entry = getKeyVaultEntry((SecretReferenceConfigurationSetting) setting);
-
- // Null in the case of failFast is false, will just skip entry.
- if (entry != null) {
- properties.put(key, entry);
- }
- } else if (StringUtils.hasText(setting.getContentType())
- && JsonConfigurationParser.isJsonContentType(setting.getContentType())) {
- Map jsonSettings = JsonConfigurationParser.parseJsonSetting(setting);
- for (Entry jsonSetting : jsonSettings.entrySet()) {
- key = jsonSetting.getKey().trim().substring(selectedKeys.getKeyFilter().length());
- properties.put(key, jsonSetting.getValue());
- }
- } else {
- properties.put(key, setting.getValue());
- }
- }
- }
- return addToFeatureSet(featureSet, features);
- }
-
- /**
- * Given a Setting's Key Vault Reference stored in the Settings value, it will get its entry in Key Vault.
- *
- * @param secretReference {"uri": "<your-vault-url>/secret/<secret>/<version>"}
- * @return Key Vault Secret Value
- */
- private String getKeyVaultEntry(SecretReferenceConfigurationSetting secretReference) {
- String secretValue = null;
- try {
- URI uri = null;
-
- // Parsing Key Vault Reference for URI
- try {
- uri = new URI(secretReference.getSecretId());
- } catch (URISyntaxException e) {
- LOGGER.error("Error Processing Key Vault Entry URI.");
- ReflectionUtils.rethrowRuntimeException(e);
- }
-
- // Check if we already have a client for this key vault, if not we will make
- // one
- if (!keyVaultClients.containsKey(uri.getHost())) {
- KeyVaultClient client = new KeyVaultClient(appConfigurationProperties, uri, keyVaultCredentialProvider,
- keyVaultClientProvider, keyVaultSecretProvider);
- keyVaultClients.put(uri.getHost(), client);
- }
- KeyVaultSecret secret = keyVaultClients.get(uri.getHost()).getSecret(uri, appProperties.getMaxRetryTime());
- if (secret == null) {
- throw new IOException("No Key Vault Secret found for Reference.");
- }
- secretValue = secret.getValue();
- } catch (RuntimeException | IOException e) {
- LOGGER.error("Error Retrieving Key Vault Entry");
- ReflectionUtils.rethrowRuntimeException(e);
- }
- return secretValue;
- }
-
- /**
- * Initializes Feature Management configurations. Only one {@code AppConfigurationPropertySource} can call this, and
- * it needs to be done after the rest have run initProperties.
- *
- * @param featureSet Feature Flag info to be set to this property source.
- */
- void initFeatures(FeatureSet featureSet) {
- properties.put(FEATURE_MANAGEMENT_KEY,
- FEATURE_MAPPER.convertValue(featureSet.getFeatureManagement(), LinkedHashMap.class));
- }
-
- private FeatureSet addToFeatureSet(FeatureSet featureSet, List features)
- throws IOException {
- if (features == null) {
- return featureSet;
- }
- // Reading In Features
- for (ConfigurationSetting setting : features) {
- if (setting instanceof FeatureFlagConfigurationSetting) {
- Object feature = createFeature((FeatureFlagConfigurationSetting) setting);
- featureSet.addFeature(setting.getKey().trim().substring(FEATURE_FLAG_PREFIX.length()), feature);
- }
- }
- return featureSet;
- }
-
- /**
- * Creates a {@code Feature} from a {@code KeyValueItem}
- *
- * @param item Used to create Features before being converted to be set into properties.
- * @return Feature created from KeyValueItem
- */
- @SuppressWarnings("unchecked")
- private Object createFeature(FeatureFlagConfigurationSetting item) {
- String key = getFeatureSimpleName(item);
- Feature feature = new Feature(key, item);
- Map featureEnabledFor = feature.getEnabledFor();
-
- // Setting Enabled For to null, but enabled = true will result in the feature
- // being on. This is the case of a feature is on/off and set to on. This is to
- // tell the difference between conditional/off which looks exactly the same...
- // It should never be the case of Conditional On, and no filters coming from
- // Azure, but it is a valid way from the config file, which should result in
- // false being returned.
- if (featureEnabledFor.size() == 0 && item.isEnabled()) {
- return true;
- } else if (!item.isEnabled()) {
- return false;
- }
- for (int filter = 0; filter < feature.getEnabledFor().size(); filter++) {
- FeatureFlagFilter featureFilterEvaluationContext = featureEnabledFor.get(filter);
- Map parameters = featureFilterEvaluationContext.getParameters();
-
- if (parameters == null || !TARGETING_FILTER.equals(featureEnabledFor.get(filter).getName())) {
- continue;
- }
-
- Object audienceObject = parameters.get(AUDIENCE);
- if (audienceObject != null) {
- parameters = (Map) audienceObject;
- }
-
- List