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, "&", 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, "&", 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>
