camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [07/18] camel git commit: CAMEL-10866: platforms/catalog - rename folders to match their artifact id name
Date Wed, 22 Feb 2017 10:12:39 GMT
http://git-wip-us.apache.org/repos/asf/camel/blob/b23fbb46/platforms/catalog/src/main/java/org/apache/camel/catalog/DefaultCamelCatalog.java
----------------------------------------------------------------------
diff --git a/platforms/catalog/src/main/java/org/apache/camel/catalog/DefaultCamelCatalog.java b/platforms/catalog/src/main/java/org/apache/camel/catalog/DefaultCamelCatalog.java
deleted file mode 100644
index e6a159b..0000000
--- a/platforms/catalog/src/main/java/org/apache/camel/catalog/DefaultCamelCatalog.java
+++ /dev/null
@@ -1,2451 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.catalog;
-
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.lang.reflect.InvocationTargetException;
-import java.lang.reflect.Method;
-import java.net.URI;
-import java.net.URISyntaxException;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.LinkedHashMap;
-import java.util.LinkedHashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.SortedSet;
-import java.util.TreeMap;
-import java.util.TreeSet;
-import java.util.regex.Matcher;
-import java.util.regex.Pattern;
-import java.util.regex.PatternSyntaxException;
-import javax.xml.parsers.DocumentBuilderFactory;
-import javax.xml.xpath.XPathConstants;
-import javax.xml.xpath.XPathFactory;
-
-import org.w3c.dom.Document;
-
-import static org.apache.camel.catalog.CatalogHelper.after;
-import static org.apache.camel.catalog.JSonSchemaHelper.getNames;
-import static org.apache.camel.catalog.JSonSchemaHelper.getPropertyDefaultValue;
-import static org.apache.camel.catalog.JSonSchemaHelper.getPropertyEnum;
-import static org.apache.camel.catalog.JSonSchemaHelper.getPropertyKind;
-import static org.apache.camel.catalog.JSonSchemaHelper.getPropertyNameFromNameWithPrefix;
-import static org.apache.camel.catalog.JSonSchemaHelper.getPropertyPrefix;
-import static org.apache.camel.catalog.JSonSchemaHelper.getRow;
-import static org.apache.camel.catalog.JSonSchemaHelper.isComponentConsumerOnly;
-import static org.apache.camel.catalog.JSonSchemaHelper.isComponentLenientProperties;
-import static org.apache.camel.catalog.JSonSchemaHelper.isComponentProducerOnly;
-import static org.apache.camel.catalog.JSonSchemaHelper.isPropertyBoolean;
-import static org.apache.camel.catalog.JSonSchemaHelper.isPropertyConsumerOnly;
-import static org.apache.camel.catalog.JSonSchemaHelper.isPropertyInteger;
-import static org.apache.camel.catalog.JSonSchemaHelper.isPropertyMultiValue;
-import static org.apache.camel.catalog.JSonSchemaHelper.isPropertyNumber;
-import static org.apache.camel.catalog.JSonSchemaHelper.isPropertyObject;
-import static org.apache.camel.catalog.JSonSchemaHelper.isPropertyProducerOnly;
-import static org.apache.camel.catalog.JSonSchemaHelper.isPropertyRequired;
-import static org.apache.camel.catalog.JSonSchemaHelper.stripOptionalPrefixFromName;
-import static org.apache.camel.catalog.URISupport.createQueryString;
-import static org.apache.camel.catalog.URISupport.isEmpty;
-import static org.apache.camel.catalog.URISupport.normalizeUri;
-import static org.apache.camel.catalog.URISupport.stripQuery;
-
-/**
- * Default {@link CamelCatalog}.
- */
-public class DefaultCamelCatalog implements CamelCatalog {
-
-	// CHECKSTYLE:OFF
-
-    private static final String MODELS_CATALOG = "org/apache/camel/catalog/models.properties";
-    private static final String MODEL_DIR = "org/apache/camel/catalog/models";
-    private static final String DOC_DIR = "org/apache/camel/catalog/docs";
-    private static final String ARCHETYPES_CATALOG = "org/apache/camel/catalog/archetypes/archetype-catalog.xml";
-    private static final String SCHEMAS_XML = "org/apache/camel/catalog/schemas";
-
-    private static final Pattern SYNTAX_PATTERN = Pattern.compile("(\\w+)");
-
-    private final VersionHelper version = new VersionHelper();
-
-    // 3rd party components/data-formats
-    private final Map<String, String> extraComponents = new HashMap<String, String>();
-    private final Map<String, String> extraComponentsJSonSchema = new HashMap<String, String>();
-    private final Map<String, String> extraDataFormats = new HashMap<String, String>();
-    private final Map<String, String> extraDataFormatsJSonSchema = new HashMap<String, String>();
-
-    // cache of operation -> result
-    private final Map<String, Object> cache = new HashMap<String, Object>();
-
-    private boolean caching;
-    private SuggestionStrategy suggestionStrategy;
-    private VersionManager versionManager = new DefaultVersionManager(this);
-    private RuntimeProvider runtimeProvider = new DefaultRuntimeProvider(this);
-
-    /**
-     * Creates the {@link CamelCatalog} without caching enabled.
-     */
-    public DefaultCamelCatalog() {
-    }
-
-    /**
-     * Creates the {@link CamelCatalog}
-     *
-     * @param caching  whether to use cache
-     */
-    public DefaultCamelCatalog(boolean caching) {
-        this.caching = caching;
-    }
-
-    @Override
-    public RuntimeProvider getRuntimeProvider() {
-        return runtimeProvider;
-    }
-
-    @Override
-    public void setRuntimeProvider(RuntimeProvider runtimeProvider) {
-        this.runtimeProvider = runtimeProvider;
-        // inject CamelCatalog to the provider
-        this.runtimeProvider.setCamelCatalog(this);
-        // invalidate the cache
-        cache.remove("findComponentNames");
-        cache.remove("listComponentsAsJson");
-        cache.remove("findDataFormatNames");
-        cache.remove("listDataFormatsAsJson");
-        cache.remove("findLanguageNames");
-        cache.remove("listLanguagesAsJson");
-    }
-
-    @Override
-    public void enableCache() {
-        caching = true;
-    }
-
-    @Override
-    public boolean isCaching() {
-        return caching;
-    }
-
-    @Override
-    public void setSuggestionStrategy(SuggestionStrategy suggestionStrategy) {
-        this.suggestionStrategy = suggestionStrategy;
-    }
-
-    @Override
-    public SuggestionStrategy getSuggestionStrategy() {
-        return suggestionStrategy;
-    }
-
-    @Override
-    public void setVersionManager(VersionManager versionManager) {
-        this.versionManager = versionManager;
-    }
-
-    @Override
-    public VersionManager getVersionManager() {
-        return versionManager;
-    }
-
-    @Override
-    public void addComponent(String name, String className) {
-        extraComponents.put(name, className);
-        // invalidate the cache
-        cache.remove("findComponentNames");
-        cache.remove("findComponentLabels");
-        cache.remove("listComponentsAsJson");
-    }
-
-    @Override
-    public void addComponent(String name, String className, String jsonSchema) {
-        addComponent(name, className);
-        if (jsonSchema != null) {
-            extraComponentsJSonSchema.put(name, jsonSchema);
-        }
-    }
-
-    @Override
-    public void addDataFormat(String name, String className) {
-        extraDataFormats.put(name, className);
-        // invalidate the cache
-        cache.remove("findDataFormatNames");
-        cache.remove("findDataFormatLabels");
-        cache.remove("listDataFormatsAsJson");
-    }
-
-    @Override
-    public void addDataFormat(String name, String className, String jsonSchema) {
-        addDataFormat(name, className);
-        if (jsonSchema != null) {
-            extraDataFormatsJSonSchema.put(name, jsonSchema);
-        }
-    }
-
-    @Override
-    public String getCatalogVersion() {
-        return version.getVersion();
-    }
-
-    @Override
-    public boolean loadVersion(String version) {
-        if (version.equals(versionManager.getLoadedVersion())) {
-            return true;
-        } else if (versionManager.loadVersion(version)) {
-            // invalidate existing cache if we loaded a new version
-            cache.clear();
-            return true;
-        }
-        return false;
-    }
-
-    @Override
-    public String getLoadedVersion() {
-        return versionManager.getLoadedVersion();
-    }
-
-    @Override
-    public String getRuntimeProviderLoadedVersion() {
-        return versionManager.getRuntimeProviderLoadedVersion();
-    }
-
-    @Override
-    public boolean loadRuntimeProviderVersion(String groupId, String artifactId, String version) {
-        return versionManager.loadRuntimeProviderVersion(groupId, artifactId, version);
-    }
-
-    @Override
-    @SuppressWarnings("unchecked")
-    public List<String> findComponentNames() {
-        List<String> names = null;
-        if (caching) {
-            names = (List<String>) cache.get("findComponentNames");
-        }
-
-        if (names == null) {
-            names = runtimeProvider.findComponentNames();
-
-            // include third party components
-            for (Map.Entry<String, String> entry : extraComponents.entrySet()) {
-                names.add(entry.getKey());
-            }
-            // sort the names
-            Collections.sort(names);
-
-            if (caching) {
-                cache.put("findComponentNames", names);
-            }
-        }
-        return names;
-    }
-
-    @Override
-    @SuppressWarnings("unchecked")
-    public List<String> findDataFormatNames() {
-        List<String> names = null;
-        if (caching) {
-            names = (List<String>) cache.get("findDataFormatNames");
-        }
-
-        if (names == null) {
-            names = runtimeProvider.findDataFormatNames();
-
-            // include third party data formats
-            for (Map.Entry<String, String> entry : extraDataFormats.entrySet()) {
-                names.add(entry.getKey());
-            }
-            // sort the names
-            Collections.sort(names);
-
-            if (caching) {
-                cache.put("findDataFormatNames", names);
-            }
-        }
-        return names;
-    }
-
-    @Override
-    @SuppressWarnings("unchecked")
-    public List<String> findLanguageNames() {
-        List<String> names = null;
-        if (caching) {
-            names = (List<String>) cache.get("findLanguageNames");
-        }
-
-        if (names == null) {
-            names = runtimeProvider.findLanguageNames();
-
-            if (caching) {
-                cache.put("findLanguageNames", names);
-            }
-        }
-        return names;
-    }
-
-    @Override
-    @SuppressWarnings("unchecked")
-    public List<String> findModelNames() {
-        List<String> names = null;
-        if (caching) {
-            names = (List<String>) cache.get("findModelNames");
-        }
-
-        if (names == null) {
-            names = new ArrayList<String>();
-            InputStream is = versionManager.getResourceAsStream(MODELS_CATALOG);
-            if (is != null) {
-                try {
-                    CatalogHelper.loadLines(is, names);
-                } catch (IOException e) {
-                    // ignore
-                }
-            }
-            if (caching) {
-                cache.put("findModelNames", names);
-            }
-        }
-        return names;
-    }
-
-    @Override
-    @SuppressWarnings("unchecked")
-    public List<String> findOtherNames() {
-        List<String> names = null;
-        if (caching) {
-            names = (List<String>) cache.get("findOtherNames");
-        }
-
-        if (names == null) {
-            names = runtimeProvider.findOtherNames();
-
-            if (caching) {
-                cache.put("findOtherNames", names);
-            }
-        }
-        return names;
-    }
-
-    @Override
-    public List<String> findModelNames(String filter) {
-        // should not cache when filter parameter can by any kind of value
-        List<String> answer = new ArrayList<String>();
-
-        List<String> names = findModelNames();
-        for (String name : names) {
-            String json = modelJSonSchema(name);
-            if (json != null) {
-                List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("model", json, false);
-                for (Map<String, String> row : rows) {
-                    if (row.containsKey("label")) {
-                        String label = row.get("label");
-                        String[] parts = label.split(",");
-                        for (String part : parts) {
-                            try {
-                                if (part.equalsIgnoreCase(filter) || CatalogHelper.matchWildcard(part, filter) || part.matches(filter)) {
-                                    answer.add(name);
-                                }
-                            } catch (PatternSyntaxException e) {
-                                // ignore as filter is maybe not a pattern
-                            }
-                        }
-                    }
-                }
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public List<String> findComponentNames(String filter) {
-        // should not cache when filter parameter can by any kind of value
-        List<String> answer = new ArrayList<String>();
-
-        List<String> names = findComponentNames();
-        for (String name : names) {
-            String json = componentJSonSchema(name);
-            if (json != null) {
-                List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("component", json, false);
-                for (Map<String, String> row : rows) {
-                    if (row.containsKey("label")) {
-                        String label = row.get("label");
-                        String[] parts = label.split(",");
-                        for (String part : parts) {
-                            try {
-                                if (part.equalsIgnoreCase(filter) || CatalogHelper.matchWildcard(part, filter) || part.matches(filter)) {
-                                    answer.add(name);
-                                }
-                            } catch (PatternSyntaxException e) {
-                                // ignore as filter is maybe not a pattern
-                            }
-                        }
-                    }
-                }
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public List<String> findDataFormatNames(String filter) {
-        // should not cache when filter parameter can by any kind of value
-        List<String> answer = new ArrayList<String>();
-
-        List<String> names = findDataFormatNames();
-        for (String name : names) {
-            String json = dataFormatJSonSchema(name);
-            if (json != null) {
-                List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("dataformat", json, false);
-                for (Map<String, String> row : rows) {
-                    if (row.containsKey("label")) {
-                        String label = row.get("label");
-                        String[] parts = label.split(",");
-                        for (String part : parts) {
-                            try {
-                                if (part.equalsIgnoreCase(filter) || CatalogHelper.matchWildcard(part, filter) || part.matches(filter)) {
-                                    answer.add(name);
-                                }
-                            } catch (PatternSyntaxException e) {
-                                // ignore as filter is maybe not a pattern
-                            }
-                        }
-                    }
-                }
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public List<String> findLanguageNames(String filter) {
-        // should not cache when filter parameter can by any kind of value
-        List<String> answer = new ArrayList<String>();
-
-        List<String> names = findLanguageNames();
-        for (String name : names) {
-            String json = languageJSonSchema(name);
-            if (json != null) {
-                List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("language", json, false);
-                for (Map<String, String> row : rows) {
-                    if (row.containsKey("label")) {
-                        String label = row.get("label");
-                        String[] parts = label.split(",");
-                        for (String part : parts) {
-                            try {
-                                if (part.equalsIgnoreCase(filter) || CatalogHelper.matchWildcard(part, filter) || part.matches(filter)) {
-                                    answer.add(name);
-                                }
-                            } catch (PatternSyntaxException e) {
-                                // ignore as filter is maybe not a pattern
-                            }
-                        }
-                    }
-                }
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public List<String> findOtherNames(String filter) {
-        // should not cache when filter parameter can by any kind of value
-        List<String> answer = new ArrayList<String>();
-
-        List<String> names = findOtherNames();
-        for (String name : names) {
-            String json = otherJSonSchema(name);
-            if (json != null) {
-                List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("other", json, false);
-                for (Map<String, String> row : rows) {
-                    if (row.containsKey("label")) {
-                        String label = row.get("label");
-                        String[] parts = label.split(",");
-                        for (String part : parts) {
-                            try {
-                                if (part.equalsIgnoreCase(filter) || CatalogHelper.matchWildcard(part, filter) || part.matches(filter)) {
-                                    answer.add(name);
-                                }
-                            } catch (PatternSyntaxException e) {
-                                // ignore as filter is maybe not a pattern
-                            }
-                        }
-                    }
-                }
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String modelJSonSchema(String name) {
-        String file = MODEL_DIR + "/" + name + ".json";
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("model-" + file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            }
-            if (caching) {
-                cache.put("model-" + file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String componentJSonSchema(String name) {
-        String file = runtimeProvider.getComponentJSonSchemaDirectory() + "/" + name + ".json";
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("component-" + file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            } else {
-                // its maybe a third party so try to see if we have the json schema already
-                answer = extraComponentsJSonSchema.get(name);
-                if (answer == null) {
-                    // or if we can load it from the classpath
-                    String className = extraComponents.get(name);
-                    if (className != null) {
-                        String packageName = className.substring(0, className.lastIndexOf('.'));
-                        packageName = packageName.replace('.', '/');
-                        String path = packageName + "/" + name + ".json";
-                        is = versionManager.getResourceAsStream(path);
-                        if (is != null) {
-                            try {
-                                answer = CatalogHelper.loadText(is);
-                            } catch (IOException e) {
-                                // ignore
-                            }
-                        }
-                    }
-                }
-            }
-            if (caching) {
-                cache.put("component-" + file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String dataFormatJSonSchema(String name) {
-        String file = runtimeProvider.getDataFormatJSonSchemaDirectory() + "/" + name + ".json";
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("dataformat-" + file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            } else {
-                // its maybe a third party so try to see if we have the json schema already
-                answer = extraDataFormatsJSonSchema.get(name);
-                if (answer == null) {
-                    // or if we can load it from the classpath
-                    String className = extraDataFormats.get(name);
-                    if (className != null) {
-                        String packageName = className.substring(0, className.lastIndexOf('.'));
-                        packageName = packageName.replace('.', '/');
-                        String path = packageName + "/" + name + ".json";
-                        is = versionManager.getResourceAsStream(path);
-                        if (is != null) {
-                            try {
-                                answer = CatalogHelper.loadText(is);
-                            } catch (IOException e) {
-                                // ignore
-                            }
-                        }
-                    }
-                }
-            }
-            if (caching) {
-                cache.put("dataformat-" + file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String languageJSonSchema(String name) {
-        // if we try to look method then its in the bean.json file
-        if ("method".equals(name)) {
-            name = "bean";
-        }
-
-        String file = runtimeProvider.getLanguageJSonSchemaDirectory() + "/" + name + ".json";
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("language-" + file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            }
-            if (caching) {
-                cache.put("language-" + file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String otherJSonSchema(String name) {
-        String file = runtimeProvider.getOtherJSonSchemaDirectory() + "/" + name + ".json";
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("other-" + file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            }
-            if (caching) {
-                cache.put("other-" + file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String componentAsciiDoc(String name) {
-        String answer = doComponentAsciiDoc(name);
-        if (answer == null) {
-            // maybe the name is an alternative scheme name, and then we need to find the component that
-            // has the name as alternative, and use the first scheme as the name to find the documentation
-            List<String> names = findComponentNames();
-            for (String alternative : names) {
-                String schemes = getAlternativeComponentName(alternative);
-                if (schemes != null && schemes.contains(name)) {
-                    String first = schemes.split(",")[0];
-                    return componentAsciiDoc(first);
-                }
-            }
-        }
-        return answer;
-    }
-
-    @Override
-    public String componentHtmlDoc(String name) {
-        String answer = doComponentHtmlDoc(name);
-        if (answer == null) {
-            // maybe the name is an alternative scheme name, and then we need to find the component that
-            // has the name as alternative, and use the first scheme as the name to find the documentation
-            List<String> names = findComponentNames();
-            for (String alternative : names) {
-                String schemes = getAlternativeComponentName(alternative);
-                if (schemes != null && schemes.contains(name)) {
-                    String first = schemes.split(",")[0];
-                    return componentHtmlDoc(first);
-                }
-            }
-        }
-        return answer;
-    }
-
-    private String getAlternativeComponentName(String componentName) {
-        String json = componentJSonSchema(componentName);
-        if (json != null) {
-            List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("component", json, false);
-            for (Map<String, String> row : rows) {
-                if (row.containsKey("alternativeSchemes")) {
-                    return row.get("alternativeSchemes");
-                }
-            }
-        }
-        return null;
-    }
-
-    private String doComponentAsciiDoc(String name) {
-        // special for mail component
-        if (name.equals("imap") || name.equals("imaps") || name.equals("pop3") || name.equals("pop3s") || name.equals("smtp") || name.equals("smtps")) {
-            name = "mail";
-        }
-
-        String file = DOC_DIR + "/" + name + "-component.adoc";
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("component-" + file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            } else {
-                // its maybe a third party so try load it
-                String className = extraComponents.get(name);
-                if (className != null) {
-                    String packageName = className.substring(0, className.lastIndexOf('.'));
-                    packageName = packageName.replace('.', '/');
-                    String path = packageName + "/" + name + "-component.adoc";
-                    is = versionManager.getResourceAsStream(path);
-                    if (is != null) {
-                        try {
-                            answer = CatalogHelper.loadText(is);
-                        } catch (IOException e) {
-                            // ignore
-                        }
-                    }
-                }
-            }
-            if (caching) {
-                cache.put("component-" + file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    private String doComponentHtmlDoc(String name) {
-        // special for mail component
-        if (name.equals("imap") || name.equals("imaps") || name.equals("pop3") || name.equals("pop3s") || name.equals("smtp") || name.equals("smtps")) {
-            name = "mail";
-        }
-
-        String file = DOC_DIR + "/" + name + "-component.html";
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("component-" + file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            } else {
-                // its maybe a third party so try load it
-                String className = extraComponents.get(name);
-                if (className != null) {
-                    String packageName = className.substring(0, className.lastIndexOf('.'));
-                    packageName = packageName.replace('.', '/');
-                    String path = packageName + "/" + name + "-component.html";
-                    is = versionManager.getResourceAsStream(path);
-                    if (is != null) {
-                        try {
-                            answer = CatalogHelper.loadText(is);
-                        } catch (IOException e) {
-                            // ignore
-                        }
-                    }
-                }
-            }
-            if (caching) {
-                cache.put("component-" + file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String dataFormatAsciiDoc(String name) {
-        // special for some name data formats
-        if (name.startsWith("bindy")) {
-            name = "bindy";
-        } else if (name.startsWith("univocity")) {
-            name = "univocity";
-        }
-
-        String file = DOC_DIR + "/" + name + "-dataformat.adoc";
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("dataformat-" + file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            } else {
-                // its maybe a third party so try load it
-                String className = extraDataFormats.get(name);
-                if (className != null) {
-                    String packageName = className.substring(0, className.lastIndexOf('.'));
-                    packageName = packageName.replace('.', '/');
-                    String path = packageName + "/" + name + "-dataformat.adoc";
-                    is = versionManager.getResourceAsStream(path);
-                    if (is != null) {
-                        try {
-                            answer = CatalogHelper.loadText(is);
-                        } catch (IOException e) {
-                            // ignore
-                        }
-                    }
-                }
-            }
-            if (caching) {
-                cache.put("dataformat-" + file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String dataFormatHtmlDoc(String name) {
-        // special for some name data formats
-        if (name.startsWith("bindy")) {
-            name = "bindy";
-        } else if (name.startsWith("univocity")) {
-            name = "univocity";
-        }
-
-        String file = DOC_DIR + "/" + name + "-dataformat.html";
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("dataformat-" + file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            } else {
-                // its maybe a third party so try load it
-                String className = extraDataFormats.get(name);
-                if (className != null) {
-                    String packageName = className.substring(0, className.lastIndexOf('.'));
-                    packageName = packageName.replace('.', '/');
-                    String path = packageName + "/" + name + "-dataformat.html";
-                    is = versionManager.getResourceAsStream(path);
-                    if (is != null) {
-                        try {
-                            answer = CatalogHelper.loadText(is);
-                        } catch (IOException e) {
-                            // ignore
-                        }
-                    }
-                }
-            }
-            if (caching) {
-                cache.put("dataformat-" + file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String languageAsciiDoc(String name) {
-        // if we try to look method then its in the bean.adoc file
-        if ("method".equals(name)) {
-            name = "bean";
-        }
-
-        String file = DOC_DIR + "/" + name + "-language.adoc";
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("language-" + file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            }
-            if (caching) {
-                cache.put("language-" + file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String languageHtmlDoc(String name) {
-        // if we try to look method then its in the bean.html file
-        if ("method".equals(name)) {
-            name = "bean";
-        }
-
-        String file = DOC_DIR + "/" + name + "-language.html";
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("language-" + file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            }
-            if (caching) {
-                cache.put("language-" + file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String otherAsciiDoc(String name) {
-        String file = DOC_DIR + "/" + name + ".adoc";
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("other-" + file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            }
-            if (caching) {
-                cache.put("other-" + file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String otherHtmlDoc(String name) {
-        String file = DOC_DIR + "/" + name + "-other.html";
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("language-" + file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            }
-            if (caching) {
-                cache.put("language-" + file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    @SuppressWarnings("unchecked")
-    public Set<String> findModelLabels() {
-        SortedSet<String> answer = null;
-        if (caching) {
-            answer = (TreeSet<String>) cache.get("findModelLabels");
-        }
-
-        if (answer == null) {
-            answer = new TreeSet<String>();
-            List<String> names = findModelNames();
-            for (String name : names) {
-                String json = modelJSonSchema(name);
-                if (json != null) {
-                    List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("model", json, false);
-                    for (Map<String, String> row : rows) {
-                        if (row.containsKey("label")) {
-                            String label = row.get("label");
-                            String[] parts = label.split(",");
-                            for (String part : parts) {
-                                answer.add(part);
-                            }
-                        }
-                    }
-                }
-            }
-            if (caching) {
-                cache.put("findModelLabels", answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    @SuppressWarnings("unchecked")
-    public Set<String> findComponentLabels() {
-        SortedSet<String> answer = null;
-        if (caching) {
-            answer = (TreeSet<String>) cache.get("findComponentLabels");
-        }
-
-        if (answer == null) {
-            answer = new TreeSet<String>();
-            List<String> names = findComponentNames();
-            for (String name : names) {
-                String json = componentJSonSchema(name);
-                if (json != null) {
-                    List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("component", json, false);
-                    for (Map<String, String> row : rows) {
-                        if (row.containsKey("label")) {
-                            String label = row.get("label");
-                            String[] parts = label.split(",");
-                            for (String part : parts) {
-                                answer.add(part);
-                            }
-                        }
-                    }
-                }
-            }
-            if (caching) {
-                cache.put("findComponentLabels", answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    @SuppressWarnings("unchecked")
-    public Set<String> findDataFormatLabels() {
-        SortedSet<String> answer = null;
-        if (caching) {
-            answer = (TreeSet<String>) cache.get("findDataFormatLabels");
-        }
-
-        if (answer == null) {
-            answer = new TreeSet<String>();
-            List<String> names = findDataFormatNames();
-            for (String name : names) {
-                String json = dataFormatJSonSchema(name);
-                if (json != null) {
-                    List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("dataformat", json, false);
-                    for (Map<String, String> row : rows) {
-                        if (row.containsKey("label")) {
-                            String label = row.get("label");
-                            String[] parts = label.split(",");
-                            for (String part : parts) {
-                                answer.add(part);
-                            }
-                        }
-                    }
-                }
-            }
-            if (caching) {
-                cache.put("findDataFormatLabels", answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    @SuppressWarnings("unchecked")
-    public Set<String> findLanguageLabels() {
-        SortedSet<String> answer = null;
-        if (caching) {
-            answer = (TreeSet<String>) cache.get("findLanguageLabels");
-        }
-
-        if (answer == null) {
-            answer = new TreeSet<String>();
-            List<String> names = findLanguageNames();
-            for (String name : names) {
-                String json = languageJSonSchema(name);
-                if (json != null) {
-                    List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("language", json, false);
-                    for (Map<String, String> row : rows) {
-                        if (row.containsKey("label")) {
-                            String label = row.get("label");
-                            String[] parts = label.split(",");
-                            for (String part : parts) {
-                                answer.add(part);
-                            }
-                        }
-                    }
-                }
-            }
-            if (caching) {
-                cache.put("findLanguageLabels", answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    @SuppressWarnings("unchecked")
-    public Set<String> findOtherLabels() {
-        SortedSet<String> answer = null;
-        if (caching) {
-            answer = (TreeSet<String>) cache.get("findOtherLabels");
-        }
-
-        if (answer == null) {
-            answer = new TreeSet<String>();
-            List<String> names = findOtherNames();
-            for (String name : names) {
-                String json = otherJSonSchema(name);
-                if (json != null) {
-                    List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("other", json, false);
-                    for (Map<String, String> row : rows) {
-                        if (row.containsKey("label")) {
-                            String label = row.get("label");
-                            String[] parts = label.split(",");
-                            for (String part : parts) {
-                                answer.add(part);
-                            }
-                        }
-                    }
-                }
-            }
-            if (caching) {
-                cache.put("findOtherLabels", answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String archetypeCatalogAsXml() {
-        String file = ARCHETYPES_CATALOG;
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get(file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            }
-            if (caching) {
-                cache.put(file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String springSchemaAsXml() {
-        String file = SCHEMAS_XML + "/camel-spring.xsd";
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get(file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            }
-            if (caching) {
-                cache.put(file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String blueprintSchemaAsXml() {
-        String file = SCHEMAS_XML + "/camel-blueprint.xsd";
-
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get(file);
-        }
-
-        if (answer == null) {
-            InputStream is = versionManager.getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    answer = CatalogHelper.loadText(is);
-                } catch (IOException e) {
-                    // ignore
-                }
-            }
-            if (caching) {
-                cache.put(file, answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public boolean validateTimePattern(String pattern) {
-        return validateInteger(pattern);
-    }
-
-    @Override
-    public EndpointValidationResult validateEndpointProperties(String uri) {
-        return validateEndpointProperties(uri, false, false, false);
-    }
-
-    @Override
-    public EndpointValidationResult validateEndpointProperties(String uri, boolean ignoreLenientProperties) {
-        return validateEndpointProperties(uri, ignoreLenientProperties,false, false);
-    }
-
-    @Override
-    public EndpointValidationResult validateEndpointProperties(String uri, boolean ignoreLenientProperties, boolean consumerOnly, boolean producerOnly) {
-        EndpointValidationResult result = new EndpointValidationResult(uri);
-
-        Map<String, String> properties;
-        List<Map<String, String>> rows;
-        boolean lenientProperties;
-        String scheme;
-
-        try {
-            // parse the uri
-            URI u = normalizeUri(uri);
-            scheme = u.getScheme();
-            String json = componentJSonSchema(scheme);
-            if (json == null) {
-                // if the uri starts with a placeholder then we are also incapable of parsing it as we wasn't able to resolve the component name
-                if (uri.startsWith("{{")) {
-                    result.addIncapable(uri);
-                } else if (scheme != null) {
-                    result.addUnknownComponent(scheme);
-                } else {
-                    result.addUnknownComponent(uri);
-                }
-                return result;
-            }
-
-            rows = JSonSchemaHelper.parseJsonSchema("component", json, false);
-
-            // is the component capable of both consumer and producer?
-            boolean canConsumeAndProduce = false;
-            if (!isComponentConsumerOnly(rows) && !isComponentProducerOnly(rows)) {
-                canConsumeAndProduce = true;
-            }
-
-            if (canConsumeAndProduce && consumerOnly) {
-                // lenient properties is not support in consumer only mode if the component can do both of them
-                lenientProperties = false;
-            } else {
-                // only enable lenient properties if we should not ignore
-                lenientProperties = !ignoreLenientProperties && isComponentLenientProperties(rows);
-            }
-            rows = JSonSchemaHelper.parseJsonSchema("properties", json, true);
-            properties = endpointProperties(uri);
-        } catch (URISyntaxException e) {
-            if (uri.startsWith("{{")) {
-                // if the uri starts with a placeholder then we are also incapable of parsing it as we wasn't able to resolve the component name
-                result.addIncapable(uri);
-            } else {
-                result.addSyntaxError(e.getMessage());
-            }
-
-            return result;
-        }
-
-        // the dataformat component refers to a data format so lets add the properties for the selected
-        // data format to the list of rows
-        if ("dataformat".equals(scheme)) {
-            String dfName = properties.get("name");
-            if (dfName != null) {
-                String dfJson = dataFormatJSonSchema(dfName);
-                List<Map<String, String>> dfRows = JSonSchemaHelper.parseJsonSchema("properties", dfJson, true);
-                if (dfRows != null && !dfRows.isEmpty()) {
-                    rows.addAll(dfRows);
-                }
-            }
-        }
-
-        for (Map.Entry<String, String> property : properties.entrySet()) {
-            String value = property.getValue();
-            String originalName = property.getKey();
-            String name = property.getKey();
-            // the name may be using an optional prefix, so lets strip that because the options
-            // in the schema are listed without the prefix
-            name = stripOptionalPrefixFromName(rows, name);
-            // the name may be using a prefix, so lets see if we can find the real property name
-            String propertyName = getPropertyNameFromNameWithPrefix(rows, name);
-            if (propertyName != null) {
-                name = propertyName;
-            }
-
-            String prefix = getPropertyPrefix(rows, name);
-            String kind = getPropertyKind(rows, name);
-            boolean namePlaceholder = name.startsWith("{{") && name.endsWith("}}");
-            boolean valuePlaceholder = value.startsWith("{{") || value.startsWith("${") || value.startsWith("$simple{");
-            boolean lookup = value.startsWith("#") && value.length() > 1;
-            // we cannot evaluate multi values as strict as the others, as we don't know their expected types
-            boolean mulitValue = prefix != null && originalName.startsWith(prefix) && isPropertyMultiValue(rows, name);
-
-            Map<String, String> row = getRow(rows, name);
-            if (row == null) {
-                // unknown option
-
-                // only add as error if the component is not lenient properties, or not stub component
-                // and the name is not a property placeholder for one or more values
-                if (!namePlaceholder && !"stub".equals(scheme)) {
-                    if (lenientProperties) {
-                        // as if we are lenient then the option is a dynamic extra option which we cannot validate
-                        result.addLenient(name);
-                    } else {
-                        // its unknown
-                        result.addUnknown(name);
-                        if (suggestionStrategy != null) {
-                            String[] suggestions = suggestionStrategy.suggestEndpointOptions(getNames(rows), name);
-                            if (suggestions != null) {
-                                result.addUnknownSuggestions(name, suggestions);
-                            }
-                        }
-                    }
-                }
-            } else {
-                if ("parameter".equals(kind)) {
-                    // consumer only or producer only mode for parameters
-                    if (consumerOnly) {
-                        boolean producer = isPropertyProducerOnly(rows, name);
-                        if (producer) {
-                            // the option is only for producer so you cannot use it in consumer mode
-                            result.addNotConsumerOnly(name);
-                        }
-                    } else if (producerOnly) {
-                        boolean consumer = isPropertyConsumerOnly(rows, name);
-                        if (consumer) {
-                            // the option is only for consumer so you cannot use it in producer mode
-                            result.addNotProducerOnly(name);
-                        }
-                    }
-                }
-
-                // default value
-                String defaultValue = getPropertyDefaultValue(rows, name);
-                if (defaultValue != null) {
-                    result.addDefaultValue(name, defaultValue);
-                }
-
-                // is required but the value is empty
-                boolean required = isPropertyRequired(rows, name);
-                if (required && isEmpty(value)) {
-                    result.addRequired(name);
-                }
-
-                // is enum but the value is not within the enum range
-                // but we can only check if the value is not a placeholder
-                String enums = getPropertyEnum(rows, name);
-                if (!mulitValue && !valuePlaceholder && !lookup && enums != null) {
-                    String[] choices = enums.split(",");
-                    boolean found = false;
-                    for (String s : choices) {
-                        if (value.equalsIgnoreCase(s)) {
-                            found = true;
-                            break;
-                        }
-                    }
-                    if (!found) {
-                        result.addInvalidEnum(name, value);
-                        result.addInvalidEnumChoices(name, choices);
-                        if (suggestionStrategy != null) {
-                            Set<String> names = new LinkedHashSet<>();
-                            names.addAll(Arrays.asList(choices));
-                            String[] suggestions = suggestionStrategy.suggestEndpointOptions(names, value);
-                            if (suggestions != null) {
-                                result.addInvalidEnumSuggestions(name, suggestions);
-                            }
-                        }
-
-                    }
-                }
-
-                // is reference lookup of bean (not applicable for @UriPath, enums, or multi-valued)
-                if (!mulitValue && enums == null && !"path".equals(kind) && isPropertyObject(rows, name)) {
-                    // must start with # and be at least 2 characters
-                    if (!value.startsWith("#") || value.length() <= 1) {
-                        result.addInvalidReference(name, value);
-                    }
-                }
-
-                // is boolean
-                if (!mulitValue && !valuePlaceholder && !lookup && isPropertyBoolean(rows, name)) {
-                    // value must be a boolean
-                    boolean bool = "true".equalsIgnoreCase(value) || "false".equalsIgnoreCase(value);
-                    if (!bool) {
-                        result.addInvalidBoolean(name, value);
-                    }
-                }
-
-                // is integer
-                if (!mulitValue && !valuePlaceholder && !lookup && isPropertyInteger(rows, name)) {
-                    // value must be an integer
-                    boolean valid = validateInteger(value);
-                    if (!valid) {
-                        result.addInvalidInteger(name, value);
-                    }
-                }
-
-                // is number
-                if (!mulitValue && !valuePlaceholder && !lookup && isPropertyNumber(rows, name)) {
-                    // value must be an number
-                    boolean valid = false;
-                    try {
-                        valid = !Double.valueOf(value).isNaN() || !Float.valueOf(value).isNaN();
-                    } catch (Exception e) {
-                        // ignore
-                    }
-                    if (!valid) {
-                        result.addInvalidNumber(name, value);
-                    }
-                }
-            }
-        }
-
-        // now check if all required values are there, and that a default value does not exists
-        for (Map<String, String> row : rows) {
-            String name = row.get("name");
-            boolean required = isPropertyRequired(rows, name);
-            if (required) {
-                String value = properties.get(name);
-                if (isEmpty(value)) {
-                    value = getPropertyDefaultValue(rows, name);
-                }
-                if (isEmpty(value)) {
-                    result.addRequired(name);
-                }
-            }
-        }
-
-        return result;
-    }
-
-    private static boolean validateInteger(String value) {
-        boolean valid = false;
-        try {
-            valid = Integer.valueOf(value) != null;
-        } catch (Exception e) {
-            // ignore
-        }
-        if (!valid) {
-            // it may be a time pattern, such as 5s for 5 seconds = 5000
-            try {
-                TimePatternConverter.toMilliSeconds(value);
-                valid = true;
-            } catch (Exception e) {
-                // ignore
-            }
-        }
-        return valid;
-    }
-
-    @Override
-    public Map<String, String> endpointProperties(String uri) throws URISyntaxException {
-        // NOTICE: This logic is similar to org.apache.camel.util.EndpointHelper#endpointProperties
-        // as the catalog also offers similar functionality (without having camel-core on classpath)
-
-        // need to normalize uri first
-
-        // parse the uri
-        URI u = normalizeUri(uri);
-        String scheme = u.getScheme();
-
-        String json = componentJSonSchema(scheme);
-        if (json == null) {
-            throw new IllegalArgumentException("Cannot find endpoint with scheme " + scheme);
-        }
-
-        // grab the syntax
-        String syntax = null;
-        String alternativeSyntax = null;
-        List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("component", json, false);
-        for (Map<String, String> row : rows) {
-            if (row.containsKey("syntax")) {
-                syntax = row.get("syntax");
-            }
-            if (row.containsKey("alternativeSyntax")) {
-                alternativeSyntax = row.get("alternativeSyntax");
-            }
-        }
-        if (syntax == null) {
-            throw new IllegalArgumentException("Endpoint with scheme " + scheme + " has no syntax defined in the json schema");
-        }
-
-        // only if we support alternative syntax, and the uri contains the username and password in the authority
-        // part of the uri, then we would need some special logic to capture that information and strip those
-        // details from the uri, so we can continue parsing the uri using the normal syntax
-        Map<String, String> userInfoOptions = new LinkedHashMap<String, String>();
-        if (alternativeSyntax != null && alternativeSyntax.contains("@")) {
-            // clip the scheme from the syntax
-            alternativeSyntax = after(alternativeSyntax, ":");
-            // trim so only userinfo
-            int idx = alternativeSyntax.indexOf("@");
-            String fields = alternativeSyntax.substring(0, idx);
-            String[] names = fields.split(":");
-
-            // grab authority part and grab username and/or password
-            String authority = u.getAuthority();
-            if (authority != null && authority.contains("@")) {
-                String username = null;
-                String password = null;
-
-                // grab unserinfo part before @
-                String userInfo = authority.substring(0, authority.indexOf("@"));
-                String[] parts = userInfo.split(":");
-                if (parts.length == 2) {
-                    username = parts[0];
-                    password = parts[1];
-                } else {
-                    // only username
-                    username = userInfo;
-                }
-
-                // remember the username and/or password which we add later to the options
-                if (names.length == 2) {
-                    userInfoOptions.put(names[0], username);
-                    if (password != null) {
-                        // password is optional
-                        userInfoOptions.put(names[1], password);
-                    }
-                }
-            }
-        }
-
-        // clip the scheme from the syntax
-        syntax = after(syntax, ":");
-        // clip the scheme from the uri
-        uri = after(uri, ":");
-        String uriPath = stripQuery(uri);
-
-        // strip user info from uri path
-        if (!userInfoOptions.isEmpty()) {
-            int idx = uriPath.indexOf('@');
-            if (idx > -1) {
-                uriPath = uriPath.substring(idx + 1);
-            }
-        }
-
-        // strip double slash in the start
-        if (uriPath != null && uriPath.startsWith("//")) {
-            uriPath = uriPath.substring(2);
-        }
-
-        // parse the syntax and find the names of each option
-        Matcher matcher = SYNTAX_PATTERN.matcher(syntax);
-        List<String> word = new ArrayList<String>();
-        while (matcher.find()) {
-            String s = matcher.group(1);
-            if (!scheme.equals(s)) {
-                word.add(s);
-            }
-        }
-        // parse the syntax and find each token between each option
-        String[] tokens = SYNTAX_PATTERN.split(syntax);
-
-        // find the position where each option start/end
-        List<String> word2 = new ArrayList<String>();
-        int prev = 0;
-        int prevPath = 0;
-
-        // special for activemq/jms where the enum for destinationType causes a token issue as it includes a colon
-        // for 'temp:queue' and 'temp:topic' values
-        if ("activemq".equals(scheme) || "jms".equals(scheme)) {
-            if (uriPath.startsWith("temp:")) {
-                prevPath = 5;
-            }
-        }
-
-        for (String token : tokens) {
-            if (token.isEmpty()) {
-                continue;
-            }
-
-            // special for some tokens where :// can be used also, eg http://foo
-            int idx = -1;
-            int len = 0;
-            if (":".equals(token)) {
-                idx = uriPath.indexOf("://", prevPath);
-                len = 3;
-            }
-            if (idx == -1) {
-                idx = uriPath.indexOf(token, prevPath);
-                len = token.length();
-            }
-
-            if (idx > 0) {
-                String option = uriPath.substring(prev, idx);
-                word2.add(option);
-                prev = idx + len;
-                prevPath = prev;
-            }
-        }
-        // special for last or if we did not add anyone
-        if (prev > 0 || word2.isEmpty()) {
-            String option = uriPath.substring(prev);
-            word2.add(option);
-        }
-
-        rows = JSonSchemaHelper.parseJsonSchema("properties", json, true);
-
-        boolean defaultValueAdded = false;
-
-        // now parse the uri to know which part isw what
-        Map<String, String> options = new LinkedHashMap<String, String>();
-
-        // include the username and password from the userinfo section
-        if (!userInfoOptions.isEmpty()) {
-            options.putAll(userInfoOptions);
-        }
-
-        // word contains the syntax path elements
-        Iterator<String> it = word2.iterator();
-        for (int i = 0; i < word.size(); i++) {
-            String key = word.get(i);
-
-            boolean allOptions = word.size() == word2.size();
-            boolean required = isPropertyRequired(rows, key);
-            String defaultValue = getPropertyDefaultValue(rows, key);
-
-            // we have all options so no problem
-            if (allOptions) {
-                String value = it.next();
-                options.put(key, value);
-            } else {
-                // we have a little problem as we do not not have all options
-                if (!required) {
-                    String value = null;
-
-                    boolean last = i == word.size() - 1;
-                    if (last) {
-                        // if its the last value then use it instead of the default value
-                        value = it.hasNext() ? it.next() : null;
-                        if (value != null) {
-                            options.put(key, value);
-                        } else {
-                            value = defaultValue;
-                        }
-                    }
-                    if (value != null) {
-                        options.put(key, value);
-                        defaultValueAdded = true;
-                    }
-                } else {
-                    String value = it.hasNext() ? it.next() : null;
-                    if (value != null) {
-                        options.put(key, value);
-                    }
-                }
-            }
-        }
-
-        Map<String, String> answer = new LinkedHashMap<String, String>();
-
-        // remove all options which are using default values and are not required
-        for (Map.Entry<String, String> entry : options.entrySet()) {
-            String key = entry.getKey();
-            String value = entry.getValue();
-
-            if (defaultValueAdded) {
-                boolean required = isPropertyRequired(rows, key);
-                String defaultValue = getPropertyDefaultValue(rows, key);
-
-                if (!required && defaultValue != null) {
-                    if (defaultValue.equals(value)) {
-                        continue;
-                    }
-                }
-            }
-
-            // we should keep this in the answer
-            answer.put(key, value);
-        }
-
-        // now parse the uri parameters
-        Map<String, Object> parameters = URISupport.parseParameters(u);
-
-        // and covert the values to String so its JMX friendly
-        while (!parameters.isEmpty()) {
-            Map.Entry<String, Object> entry = parameters.entrySet().iterator().next();
-            String key = entry.getKey();
-            String value = entry.getValue() != null ? entry.getValue().toString() : "";
-
-            boolean multiValued = isPropertyMultiValue(rows, key);
-            if (multiValued) {
-                String prefix = getPropertyPrefix(rows, key);
-                // extra all the multi valued options
-                Map<String, Object> values = URISupport.extractProperties(parameters, prefix);
-                // build a string with the extra multi valued options with the prefix and & as separator
-                CollectionStringBuffer csb = new CollectionStringBuffer("&");
-                for (Map.Entry<String, Object> multi : values.entrySet()) {
-                    String line = prefix + multi.getKey() + "=" + (multi.getValue() != null ? multi.getValue().toString() : "");
-                    csb.append(line);
-                }
-                // append the extra multi-values to the existing (which contains the first multi value)
-                if (!csb.isEmpty()) {
-                    value = value + "&" + csb.toString();
-                }
-            }
-
-            answer.put(key, value);
-            // remove the parameter as we run in a while loop until no more parameters
-            parameters.remove(key);
-        }
-
-        return answer;
-    }
-
-    @Override
-    public Map<String, String> endpointLenientProperties(String uri) throws URISyntaxException {
-        // need to normalize uri first
-
-        // parse the uri
-        URI u = normalizeUri(uri);
-        String scheme = u.getScheme();
-
-        String json = componentJSonSchema(scheme);
-        if (json == null) {
-            throw new IllegalArgumentException("Cannot find endpoint with scheme " + scheme);
-        }
-
-        List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("properties", json, true);
-
-        // now parse the uri parameters
-        Map<String, Object> parameters = URISupport.parseParameters(u);
-
-        // all the known options
-        Set<String> names = getNames(rows);
-
-        Map<String, String> answer = new LinkedHashMap<>();
-
-        // and covert the values to String so its JMX friendly
-        parameters.forEach((k, v) -> {
-            String key = k;
-            String value = v != null ? v.toString() : "";
-
-            // is the key a prefix property
-            int dot = key.indexOf('.');
-            if (dot != -1) {
-                String prefix = key.substring(0, dot + 1); // include dot in prefix
-                String option = getPropertyNameFromNameWithPrefix(rows, prefix);
-                if (option == null || !isPropertyMultiValue(rows, option)) {
-                    answer.put(key, value);
-                }
-            } else if (!names.contains(key)) {
-                answer.put(key, value);
-            }
-        });
-
-        return answer;
-    }
-
-    @Override
-    public String endpointComponentName(String uri) {
-        if (uri != null) {
-            int idx = uri.indexOf(":");
-            if (idx > 0) {
-                return uri.substring(0, idx);
-            }
-        }
-        return null;
-    }
-
-    @Override
-    public String asEndpointUri(String scheme, String json, boolean encode) throws URISyntaxException {
-        return doAsEndpointUri(scheme, json, "&", encode);
-    }
-
-    @Override
-    public String asEndpointUriXml(String scheme, String json, boolean encode) throws URISyntaxException {
-        return doAsEndpointUri(scheme, json, "&amp;", encode);
-    }
-
-    private String doAsEndpointUri(String scheme, String json, String ampersand, boolean encode) throws URISyntaxException {
-        List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("properties", json, true);
-
-        Map<String, String> copy = new HashMap<String, String>();
-        for (Map<String, String> row : rows) {
-            String name = row.get("name");
-            String required = row.get("required");
-            String value = row.get("value");
-            String defaultValue = row.get("defaultValue");
-
-            // only add if either required, or the value is != default value
-            String valueToAdd = null;
-            if ("true".equals(required)) {
-                valueToAdd = value != null ? value : defaultValue;
-                if (valueToAdd == null) {
-                    valueToAdd = "";
-                }
-            } else {
-                // if we have a value and no default then add it
-                if (value != null && defaultValue == null) {
-                    valueToAdd = value;
-                }
-                // otherwise only add if the value is != default value
-                if (value != null && defaultValue != null && !value.equals(defaultValue)) {
-                    valueToAdd = value;
-                }
-            }
-
-            if (valueToAdd != null) {
-                copy.put(name, valueToAdd);
-            }
-        }
-
-        return doAsEndpointUri(scheme, copy, ampersand, encode);
-    }
-
-    @Override
-    public String asEndpointUri(String scheme, Map<String, String> properties, boolean encode) throws URISyntaxException {
-        return doAsEndpointUri(scheme, properties, "&", encode);
-    }
-
-    @Override
-    public String asEndpointUriXml(String scheme, Map<String, String> properties, boolean encode) throws URISyntaxException {
-        return doAsEndpointUri(scheme, properties, "&amp;", encode);
-    }
-
-    private String doAsEndpointUri(String scheme, Map<String, String> properties, String ampersand, boolean encode) throws URISyntaxException {
-        String json = componentJSonSchema(scheme);
-        if (json == null) {
-            throw new IllegalArgumentException("Cannot find endpoint with scheme " + scheme);
-        }
-
-        // grab the syntax
-        String syntax = null;
-        List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("component", json, false);
-        for (Map<String, String> row : rows) {
-            if (row.containsKey("syntax")) {
-                syntax = row.get("syntax");
-                break;
-            }
-        }
-        if (syntax == null) {
-            throw new IllegalArgumentException("Endpoint with scheme " + scheme + " has no syntax defined in the json schema");
-        }
-
-        // do any properties filtering which can be needed for some special components
-        properties = filterProperties(scheme, properties);
-
-        rows = JSonSchemaHelper.parseJsonSchema("properties", json, true);
-
-        // clip the scheme from the syntax
-        syntax = after(syntax, ":");
-
-        String originalSyntax = syntax;
-
-        // build at first according to syntax (use a tree map as we want the uri options sorted)
-        Map<String, String> copy = new TreeMap<String, String>();
-        for (Map.Entry<String, String> entry : properties.entrySet()) {
-            String key = entry.getKey();
-            String value = entry.getValue() != null ? entry.getValue() : "";
-            if (syntax != null && syntax.contains(key)) {
-                syntax = syntax.replace(key, value);
-            } else {
-                copy.put(key, value);
-            }
-        }
-
-        // the tokens between the options in the path
-        String[] tokens = syntax.split("\\w+");
-
-        // parse the syntax into each options
-        Matcher matcher = SYNTAX_PATTERN.matcher(originalSyntax);
-        List<String> options = new ArrayList<String>();
-        while (matcher.find()) {
-            String s = matcher.group(1);
-            options.add(s);
-        }
-
-        // need to preserve {{ and }} from the syntax
-        // (we need to use words only as its provisional placeholders)
-        syntax = syntax.replaceAll("\\{\\{", "BEGINCAMELPLACEHOLDER");
-        syntax = syntax.replaceAll("\\}\\}", "ENDCAMELPLACEHOLDER");
-
-        // parse the syntax into each options
-        Matcher matcher2 = SYNTAX_PATTERN.matcher(syntax);
-        List<String> options2 = new ArrayList<String>();
-        while (matcher2.find()) {
-            String s = matcher2.group(1);
-            s = s.replaceAll("BEGINCAMELPLACEHOLDER", "\\{\\{");
-            s = s.replaceAll("ENDCAMELPLACEHOLDER", "\\}\\}");
-            options2.add(s);
-        }
-
-        // build the endpoint
-        StringBuilder sb = new StringBuilder();
-        sb.append(scheme);
-        sb.append(":");
-
-        int range = 0;
-        boolean first = true;
-        boolean hasQuestionmark = false;
-        for (int i = 0; i < options.size(); i++) {
-            String key = options.get(i);
-            String key2 = options2.get(i);
-            String token = null;
-            if (tokens.length > i) {
-                token = tokens[i];
-            }
-
-            boolean contains = properties.containsKey(key);
-            if (!contains) {
-                // if the key are similar we have no explicit value and can try to find a default value if the option is required
-                if (isPropertyRequired(rows, key)) {
-                    String value = getPropertyDefaultValue(rows, key);
-                    if (value != null) {
-                        properties.put(key, value);
-                        key2 = value;
-                    }
-                }
-            }
-
-            // was the option provided?
-            if (properties.containsKey(key)) {
-                if (!first && token != null) {
-                    sb.append(token);
-                }
-                hasQuestionmark |= key.contains("?") || (token != null && token.contains("?"));
-                sb.append(key2);
-                first = false;
-            }
-            range++;
-        }
-        // append any extra options that was in surplus for the last
-        while (range < options2.size()) {
-            String token = null;
-            if (tokens.length > range) {
-                token = tokens[range];
-            }
-            String key2 = options2.get(range);
-            sb.append(token);
-            sb.append(key2);
-            hasQuestionmark |= key2.contains("?") || (token != null && token.contains("?"));
-            range++;
-        }
-
-        if (!copy.isEmpty()) {
-            // the last option may already contain a ? char, if so we should use & instead of ?
-            sb.append(hasQuestionmark ? ampersand : '?');
-            String query = createQueryString(copy, ampersand, encode);
-            sb.append(query);
-        }
-
-        return sb.toString();
-    }
-
-    @Override
-    public SimpleValidationResult validateSimpleExpression(String simple) {
-        return doValidateSimple(null, simple, false);
-    }
-
-    @Override
-    public SimpleValidationResult validateSimpleExpression(ClassLoader classLoader, String simple) {
-        return doValidateSimple(classLoader, simple, false);
-    }
-
-    @Override
-    public SimpleValidationResult validateSimplePredicate(String simple) {
-        return doValidateSimple(null, simple, true);
-    }
-
-    @Override
-    public SimpleValidationResult validateSimplePredicate(ClassLoader classLoader, String simple) {
-        return doValidateSimple(classLoader, simple, true);
-    }
-
-    private SimpleValidationResult doValidateSimple(ClassLoader classLoader, String simple, boolean predicate) {
-        if (classLoader == null) {
-            classLoader = DefaultCamelCatalog.class.getClassLoader();
-        }
-
-        // if there are {{ }}} property placeholders then we need to resolve them to something else
-        // as the simple parse cannot resolve them before parsing as we dont run the actual Camel application
-        // with property placeholders setup so we need to dummy this by replace the {{ }} to something else
-        // therefore we use an more unlikely character: {{XXX}} to ~^XXX^~
-        String resolved = simple.replaceAll("\\{\\{(.+)\\}\\}", "~^$1^~");
-
-        SimpleValidationResult answer = new SimpleValidationResult(simple);
-
-        Object instance = null;
-        Class clazz = null;
-        try {
-            clazz = classLoader.loadClass("org.apache.camel.language.simple.SimpleLanguage");
-            instance = clazz.newInstance();
-        } catch (Exception e) {
-            // ignore
-        }
-
-        if (clazz != null && instance != null) {
-            Throwable cause = null;
-            try {
-                if (predicate) {
-                    instance.getClass().getMethod("createPredicate", String.class).invoke(instance, resolved);
-                } else {
-                    instance.getClass().getMethod("createExpression", String.class).invoke(instance, resolved);
-                }
-            } catch (InvocationTargetException e) {
-                cause = e.getTargetException();
-            } catch (Exception e) {
-                cause = e;
-            }
-
-            if (cause != null) {
-
-                // reverse ~^XXX^~ back to {{XXX}}
-                String errMsg = cause.getMessage();
-                errMsg = errMsg.replaceAll("\\~\\^(.+)\\^\\~", "{{$1}}");
-
-                answer.setError(errMsg);
-
-                // is it simple parser exception then we can grab the index where the problem is
-                if (cause.getClass().getName().equals("org.apache.camel.language.simple.types.SimpleIllegalSyntaxException")
-                    || cause.getClass().getName().equals("org.apache.camel.language.simple.types.SimpleParserException")) {
-                    try {
-                        // we need to grab the index field from those simple parser exceptions
-                        Method method = cause.getClass().getMethod("getIndex");
-                        Object result = method.invoke(cause);
-                        if (result != null) {
-                            int index = (int) result;
-                            answer.setIndex(index);
-                        }
-                    } catch (Throwable i) {
-                        // ignore
-                    }
-                }
-
-                // we need to grab the short message field from this simple syntax exception
-                if (cause.getClass().getName().equals("org.apache.camel.language.simple.types.SimpleIllegalSyntaxException")) {
-                    try {
-                        Method method = cause.getClass().getMethod("getShortMessage");
-                        Object result = method.invoke(cause);
-                        if (result != null) {
-                            String msg = (String) result;
-                            answer.setShortError(msg);
-                        }
-                    } catch (Throwable i) {
-                        // ignore
-                    }
-
-                    if (answer.getShortError() == null) {
-                        // fallback and try to make existing message short instead
-                        String msg = answer.getError();
-                        // grab everything before " at location " which would be regarded as the short message
-                        int idx = msg.indexOf(" at location ");
-                        if (idx > 0) {
-                            msg = msg.substring(0, idx);
-                            answer.setShortError(msg);
-                        }
-                    }
-                }
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public LanguageValidationResult validateLanguagePredicate(ClassLoader classLoader, String language, String text) {
-        return doValidateLanguage(classLoader, language, text, true);
-    }
-
-    @Override
-    public LanguageValidationResult validateLanguageExpression(ClassLoader classLoader, String language, String text) {
-        return doValidateLanguage(classLoader, language, text, false);
-    }
-
-    private LanguageValidationResult doValidateLanguage(ClassLoader classLoader, String language, String text, boolean predicate) {
-        if (classLoader == null) {
-            classLoader = DefaultCamelCatalog.class.getClassLoader();
-        }
-
-        SimpleValidationResult answer = new SimpleValidationResult(text);
-
-        String json = languageJSonSchema(language);
-        if (json == null) {
-            answer.setError("Unknown language " + language);
-            return answer;
-        }
-
-        List<Map<String, String>> rows = JSonSchemaHelper.parseJsonSchema("language", json, false);
-        String className = null;
-        for (Map<String, String> row : rows) {
-            if (row.containsKey("javaType")) {
-                className = row.get("javaType");
-            }
-        }
-
-        if (className == null) {
-            answer.setError("Cannot find javaType for language " + language);
-            return answer;
-        }
-
-        Object instance = null;
-        Class clazz = null;
-        try {
-            clazz = classLoader.loadClass(className);
-            instance = clazz.newInstance();
-        } catch (Exception e) {
-            // ignore
-        }
-
-        if (clazz != null && instance != null) {
-            Throwable cause = null;
-            try {
-                if (predicate) {
-                    instance.getClass().getMethod("createPredicate", String.class).invoke(instance, text);
-                } else {
-                    instance.getClass().getMethod("createExpression", String.class).invoke(instance, text);
-                }
-            } catch (InvocationTargetException e) {
-                cause = e.getTargetException();
-            } catch (Exception e) {
-                cause = e;
-            }
-
-            if (cause != null) {
-                answer.setError(cause.getMessage());
-            }
-        }
-
-        return answer;
-    }
-
-    /**
-     * Special logic for log endpoints to deal when showAll=true
-     */
-    private Map<String, String> filterProperties(String scheme, Map<String, String> options) {
-        if ("log".equals(scheme)) {
-            String showAll = options.get("showAll");
-            if ("true".equals(showAll)) {
-                Map<String, String> filtered = new LinkedHashMap<String, String>();
-                // remove all the other showXXX options when showAll=true
-                for (Map.Entry<String, String> entry : options.entrySet()) {
-                    String key = entry.getKey();
-                    boolean skip = key.startsWith("show") && !key.equals("showAll");
-                    if (!skip) {
-                        filtered.put(key, entry.getValue());
-                    }
-                }
-                return filtered;
-            }
-        }
-        // use as-is
-        return options;
-    }
-
-    @Override
-    public String listComponentsAsJson() {
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("listComponentsAsJson");
-        }
-
-        if (answer == null) {
-            StringBuilder sb = new StringBuilder();
-            sb.append("[");
-            List<String> names = findComponentNames();
-            for (int i = 0; i < names.size(); i++) {
-                String scheme = names.get(i);
-                String json = componentJSonSchema(scheme);
-                // skip first line
-                json = CatalogHelper.between(json, "\"component\": {", "\"componentProperties\": {");
-                json = json != null ? json.trim() : "";
-                // skip last comma if not the last
-                if (i == names.size() - 1) {
-                    json = json.substring(0, json.length() - 1);
-                }
-                sb.append("\n");
-                sb.append("  {\n");
-                sb.append("    ");
-                sb.append(json);
-            }
-            sb.append("\n]");
-            answer = sb.toString();
-            if (caching) {
-                cache.put("listComponentsAsJson", answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String listDataFormatsAsJson() {
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("listDataFormatsAsJson");
-        }
-
-        if (answer == null) {
-            StringBuilder sb = new StringBuilder();
-            sb.append("[");
-            List<String> names = findDataFormatNames();
-            for (int i = 0; i < names.size(); i++) {
-                String scheme = names.get(i);
-                String json = dataFormatJSonSchema(scheme);
-                // skip first line
-                json = CatalogHelper.between(json, "\"dataformat\": {", "\"properties\": {");
-                json = json != null ? json.trim() : "";
-                // skip last comma if not the last
-                if (i == names.size() - 1) {
-                    json = json.substring(0, json.length() - 1);
-                }
-                sb.append("\n");
-                sb.append("  {\n");
-                sb.append("    ");
-                sb.append(json);
-            }
-            sb.append("\n]");
-            answer = sb.toString();
-            if (caching) {
-                cache.put("listDataFormatsAsJson", answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String listLanguagesAsJson() {
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("listLanguagesAsJson");
-        }
-
-        if (answer == null) {
-            StringBuilder sb = new StringBuilder();
-            sb.append("[");
-            List<String> names = findLanguageNames();
-            for (int i = 0; i < names.size(); i++) {
-                String scheme = names.get(i);
-                String json = languageJSonSchema(scheme);
-                // skip first line
-                json = CatalogHelper.between(json, "\"language\": {", "\"properties\": {");
-                json = json != null ? json.trim() : "";
-                // skip last comma if not the last
-                if (i == names.size() - 1) {
-                    json = json.substring(0, json.length() - 1);
-                }
-                sb.append("\n");
-                sb.append("  {\n");
-                sb.append("    ");
-                sb.append(json);
-            }
-            sb.append("\n]");
-            answer = sb.toString();
-            if (caching) {
-                cache.put("listLanguagesAsJson", answer);
-            }
-        }
-
-        return answer;
-    }
-
-    @Override
-    public String listModelsAsJson() {
-        String answer = null;
-        if (caching) {
-            answer = (String) cache.get("listModelsAsJson");
-        }
-
-        if (answer 

<TRUNCATED>

Mime
View raw message