+++ /dev/null
-/*
- * Copyright (c) 2013 Cisco Systems, Inc. and others. All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,
- * and is available at http://www.eclipse.org/legal/epl-v10.html
- */
-package org.opendaylight.controller.config.yangjmxgenerator;
-
-import static com.google.common.base.Preconditions.checkNotNull;
-import static com.google.common.base.Preconditions.checkState;
-import static java.lang.String.format;
-import static org.opendaylight.controller.config.yangjmxgenerator.ConfigConstants.createConfigQName;
-
-import com.google.common.annotations.VisibleForTesting;
-import com.google.common.base.Function;
-import com.google.common.base.Optional;
-import com.google.common.collect.Collections2;
-import com.google.common.collect.Maps;
-import com.google.common.collect.Sets;
-import java.util.Collection;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Objects;
-import java.util.Set;
-import java.util.regex.Matcher;
-import java.util.regex.Pattern;
-import javax.annotation.Nullable;
-import org.opendaylight.controller.config.yangjmxgenerator.attribute.AbstractDependencyAttribute;
-import org.opendaylight.controller.config.yangjmxgenerator.attribute.AttributeIfc;
-import org.opendaylight.controller.config.yangjmxgenerator.attribute.DependencyAttribute;
-import org.opendaylight.controller.config.yangjmxgenerator.attribute.JavaAttribute;
-import org.opendaylight.controller.config.yangjmxgenerator.attribute.ListAttribute;
-import org.opendaylight.controller.config.yangjmxgenerator.attribute.ListDependenciesAttribute;
-import org.opendaylight.controller.config.yangjmxgenerator.attribute.TOAttribute;
-import org.opendaylight.controller.config.yangjmxgenerator.plugin.util.NameConflictException;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.config.rev130405.ServiceRef;
-import org.opendaylight.yangtools.yang.common.QName;
-import org.opendaylight.yangtools.yang.model.api.AugmentationSchemaNode;
-import org.opendaylight.yangtools.yang.model.api.CaseSchemaNode;
-import org.opendaylight.yangtools.yang.model.api.ContainerSchemaNode;
-import org.opendaylight.yangtools.yang.model.api.DataNodeContainer;
-import org.opendaylight.yangtools.yang.model.api.DataSchemaNode;
-import org.opendaylight.yangtools.yang.model.api.IdentitySchemaNode;
-import org.opendaylight.yangtools.yang.model.api.LeafListSchemaNode;
-import org.opendaylight.yangtools.yang.model.api.LeafSchemaNode;
-import org.opendaylight.yangtools.yang.model.api.ListSchemaNode;
-import org.opendaylight.yangtools.yang.model.api.Module;
-import org.opendaylight.yangtools.yang.model.api.ModuleImport;
-import org.opendaylight.yangtools.yang.model.api.RevisionAwareXPath;
-import org.opendaylight.yangtools.yang.model.api.SchemaContext;
-import org.opendaylight.yangtools.yang.model.api.SchemaNode;
-import org.opendaylight.yangtools.yang.model.api.SchemaPath;
-import org.opendaylight.yangtools.yang.model.api.UnknownSchemaNode;
-import org.opendaylight.yangtools.yang.model.api.UsesNode;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-final class ModuleMXBeanEntryBuilder {
-
- private static final String TYPE = "type";
-
- private Module currentModule;
- private Map<QName, ServiceInterfaceEntry> qNamesToSIEs;
- private SchemaContext schemaContext;
- private TypeProviderWrapper typeProviderWrapper;
- private String packageName;
-
- public ModuleMXBeanEntryBuilder setModule(final Module module) {
- this.currentModule = module;
- return this;
- }
-
- public ModuleMXBeanEntryBuilder setqNamesToSIEs(final Map<QName, ServiceInterfaceEntry> qNamesToSIEs) {
- this.qNamesToSIEs = qNamesToSIEs;
- return this;
- }
-
- public ModuleMXBeanEntryBuilder setSchemaContext(final SchemaContext schemaContext) {
- this.schemaContext = schemaContext;
- return this;
- }
-
- public ModuleMXBeanEntryBuilder setTypeProviderWrapper(final TypeProviderWrapper typeProviderWrapper) {
- this.typeProviderWrapper = typeProviderWrapper;
- return this;
- }
-
- public ModuleMXBeanEntryBuilder setPackageName(final String packageName) {
- this.packageName = packageName;
- return this;
- }
-
- private static final Logger LOG = LoggerFactory
- .getLogger(ModuleMXBeanEntryBuilder.class);
-
- // TODO: the XPath should be parsed by code generator IMO
- private static final String MAGIC_STRING = "MAGIC_STRING";
- private static final String MODULE_CONDITION_XPATH_TEMPLATE = "^/MAGIC_STRING:modules/MAGIC_STRING:module/MAGIC_STRING:type\\s*=\\s*['\"](.+)['\"]$";
-
- private static final SchemaPath AUGMENT_SCHEMAPATH = SchemaPath.create(true,
- createConfigQName("modules"), createConfigQName("module"));
-
- private static final SchemaPath EXPECTED_CONFIGURATION_AUGMENTATION_SCHEMA_PATH =
- AUGMENT_SCHEMAPATH.createChild(createConfigQName("configuration"));
- private static final SchemaPath EXPECTED_STATE_AUGMENTATION_SCHEMA_PATH =
- AUGMENT_SCHEMAPATH.createChild(createConfigQName("state"));
- private static final Pattern PREFIX_COLON_LOCAL_NAME = Pattern.compile("^(.+):(.+)$");
-
- public Map<String, ModuleMXBeanEntry> build() {
- LOG.debug("Generating ModuleMXBeans of {} to package {}",
- currentModule.getNamespace(), packageName);
-
- String configModulePrefix;
- try {
- configModulePrefix = getConfigModulePrefixFromImport(currentModule);
- } catch (IllegalArgumentException e) {
- // this currentModule does not import config currentModule
- return Collections.emptyMap();
- }
-
- // get identities of base config:currentModule-type
- Map<String, IdentitySchemaNode> moduleIdentities = getIdentityMap();
-
- Map<String, QName> uniqueGeneratedClassesNames = new HashMap<>();
-
- // each currentModule name should have an augmentation defined
- Map<String, IdentitySchemaNode> unaugmentedModuleIdentities = new HashMap<>(
- moduleIdentities);
-
- Map<String, ModuleMXBeanEntry> result = new HashMap<>();
-
- for (AugmentationSchemaNode augmentation : currentModule.getAugmentations()) {
- Collection<DataSchemaNode> childNodes = augmentation.getChildNodes();
- if (areAllChildrenCaseSchemaNodes(childNodes)) {
- for (CaseSchemaNode childCase : castChildNodesToChoiceCases(childNodes)) {
- // TODO refactor, extract to standalone builder class
- processCaseSchemaNode(result, uniqueGeneratedClassesNames, configModulePrefix, moduleIdentities,
- unaugmentedModuleIdentities, augmentation, childCase);
- }
- } // skip if child nodes are not all cases
- }
- // clean up nulls
- cleanUpNulls(result);
- // check attributes name uniqueness
- checkAttributeNamesUniqueness(uniqueGeneratedClassesNames, result);
- checkUnaugumentedIdentities(unaugmentedModuleIdentities);
-
- LOG.debug("Number of ModuleMXBeans to be generated: {}", result.size());
-
- return result;
- }
-
- private static void cleanUpNulls(final Map<String, ModuleMXBeanEntry> result) {
- for (Map.Entry<String, ModuleMXBeanEntry> entry : result.entrySet()) {
- ModuleMXBeanEntry module = entry.getValue();
- if (module.getAttributes() == null) {
- module.setYangToAttributes(Collections
- .<String, AttributeIfc> emptyMap());
- } else if (module.getRuntimeBeans() == null) {
- module.setRuntimeBeans(Collections
- .<RuntimeBeanEntry> emptyList());
- }
- }
- }
-
- private static void checkUnaugumentedIdentities(final Map<String, IdentitySchemaNode> unaugmentedModuleIdentities) {
- if (unaugmentedModuleIdentities.size() > 0) {
- LOG.warn("Augmentation not found for all currentModule identities: {}",
- unaugmentedModuleIdentities.keySet());
- }
- }
-
- private static void checkAttributeNamesUniqueness(final Map<String, QName> uniqueGeneratedClassesNames,
- final Map<String, ModuleMXBeanEntry> result) {
- for (Map.Entry<String, ModuleMXBeanEntry> entry : result.entrySet()) {
- checkUniqueRuntimeBeanAttributesName(entry.getValue(),
- uniqueGeneratedClassesNames);
- }
- }
-
- private Map<String, IdentitySchemaNode> getIdentityMap() {
- Map<String, IdentitySchemaNode> moduleIdentities = Maps.newHashMap();
-
- for (IdentitySchemaNode id : currentModule.getIdentities()) {
- if (!id.getBaseIdentities().isEmpty()
- && ConfigConstants.MODULE_TYPE_Q_NAME.equals(id.getBaseIdentities().iterator().next().getQName())) {
- String identityLocalName = id.getQName().getLocalName();
- if (moduleIdentities.containsKey(identityLocalName)) {
- throw new IllegalStateException("Module name already defined in this currentModule: "
- + identityLocalName);
- } else {
- moduleIdentities.put(identityLocalName, id);
- LOG.debug("Found identity {}", identityLocalName);
- }
- // validation check on unknown schema nodes
- boolean providedServiceWasSet = false;
- for (UnknownSchemaNode unknownNode : id.getUnknownSchemaNodes()) {
- // TODO: test this
- boolean unknownNodeIsProvidedServiceExtension = ConfigConstants.PROVIDED_SERVICE_EXTENSION_QNAME.equals(unknownNode.getNodeType());
- // true => no op: 0 or more provided identities are allowed
-
- if (ConfigConstants.JAVA_NAME_PREFIX_EXTENSION_QNAME.equals(unknownNode.getNodeType())) {
- // 0..1 allowed
- checkState(
- providedServiceWasSet == false,
- format("More than one language extension %s is not allowed here: %s",
- ConfigConstants.JAVA_NAME_PREFIX_EXTENSION_QNAME, id));
- providedServiceWasSet = true;
- } else if (unknownNodeIsProvidedServiceExtension == false) {
- throw new IllegalStateException("Unexpected language extension " + unknownNode.getNodeType());
- }
- }
- }
- }
-
- return moduleIdentities;
- }
-
- private static Collection<CaseSchemaNode> castChildNodesToChoiceCases(final Collection<DataSchemaNode> childNodes) {
- return Collections2.transform(childNodes, new Function<DataSchemaNode, CaseSchemaNode>() {
- @Nullable
- @Override
- public CaseSchemaNode apply(@Nullable final DataSchemaNode input) {
- return (CaseSchemaNode) input;
- }
- });
- }
-
- private static boolean areAllChildrenCaseSchemaNodes(final Iterable<DataSchemaNode> childNodes) {
- for (DataSchemaNode childNode : childNodes) {
- if (childNode instanceof CaseSchemaNode == false) {
- return false;
- }
- }
- return true;
- }
-
- private <HAS_CHILDREN_AND_QNAME extends DataNodeContainer & SchemaNode> void processCaseSchemaNode(
- final Map<String, ModuleMXBeanEntry> result,
- final Map<String, QName> uniqueGeneratedClassesNames, final String configModulePrefix,
- final Map<String, IdentitySchemaNode> moduleIdentities,
- final Map<String, IdentitySchemaNode> unaugmentedModuleIdentities,
- final AugmentationSchemaNode augmentation, final DataSchemaNode when) {
-
- CaseSchemaNode choiceCaseNode = (CaseSchemaNode) when;
- if (!choiceCaseNode.getWhenCondition().isPresent()) {
- return;
- }
- java.util.Optional<RevisionAwareXPath> xPath = choiceCaseNode.getWhenCondition();
- checkState(xPath.isPresent(), "Choice node %s does not have a when condition", choiceCaseNode);
- Matcher matcher = getWhenConditionMatcher(configModulePrefix, xPath.get());
- if (matcher.matches() == false) {
- return;
- }
- String moduleLocalNameFromXPath = matcher.group(1);
- IdentitySchemaNode moduleIdentity = moduleIdentities.get(moduleLocalNameFromXPath);
- unaugmentedModuleIdentities.remove(moduleLocalNameFromXPath);
- checkState(moduleIdentity != null, "Cannot find identity %s matching augmentation %s", moduleLocalNameFromXPath, augmentation);
- Map<String, QName> providedServices = findProvidedServices(moduleIdentity, currentModule, qNamesToSIEs,
- schemaContext);
-
- String javaNamePrefix = TypeProviderWrapper.findJavaNamePrefix(moduleIdentity);
-
- Map<String, AttributeIfc> yangToAttributes = null;
- // runtime-data
- Collection<RuntimeBeanEntry> runtimeBeans = null;
-
- HAS_CHILDREN_AND_QNAME dataNodeContainer = getDataNodeContainer(choiceCaseNode);
-
- if (EXPECTED_CONFIGURATION_AUGMENTATION_SCHEMA_PATH.equals(augmentation.getTargetPath())) {
- LOG.debug("Parsing configuration of {}", moduleLocalNameFromXPath);
- yangToAttributes = fillConfiguration(dataNodeContainer, currentModule, typeProviderWrapper, qNamesToSIEs,
- schemaContext, packageName);
- checkUniqueAttributesWithGeneratedClass(uniqueGeneratedClassesNames, when.getQName(), yangToAttributes);
- } else if (EXPECTED_STATE_AUGMENTATION_SCHEMA_PATH.equals(augmentation.getTargetPath())) {
- LOG.debug("Parsing state of {}", moduleLocalNameFromXPath);
- try {
- runtimeBeans = fillRuntimeBeans(dataNodeContainer, currentModule, typeProviderWrapper, packageName,
- moduleLocalNameFromXPath, javaNamePrefix);
- } catch (NameConflictException e) {
- throw new NameConflictException(e.getConflictingName(), when.getQName(), when.getQName());
- }
- checkUniqueRuntimeBeansGeneratedClasses(uniqueGeneratedClassesNames, when, runtimeBeans);
- Set<RuntimeBeanEntry> runtimeBeanEntryValues = Sets.newHashSet(runtimeBeans);
- for (RuntimeBeanEntry entry : runtimeBeanEntryValues) {
- checkUniqueAttributesWithGeneratedClass(uniqueGeneratedClassesNames, when.getQName(),
- entry.getYangPropertiesToTypesMap());
- }
-
- } else {
- throw new IllegalArgumentException("Cannot parse augmentation " + augmentation);
- }
- boolean hasDummyContainer = choiceCaseNode.equals(dataNodeContainer) == false;
-
- String nullableDummyContainerName = hasDummyContainer ? dataNodeContainer.getQName().getLocalName() : null;
- if (result.containsKey(moduleLocalNameFromXPath)) {
- // either fill runtimeBeans or yangToAttributes, merge
- ModuleMXBeanEntry moduleMXBeanEntry = result.get(moduleLocalNameFromXPath);
- if (yangToAttributes != null && moduleMXBeanEntry.getAttributes() == null) {
- moduleMXBeanEntry.setYangToAttributes(yangToAttributes);
- } else if (runtimeBeans != null && moduleMXBeanEntry.getRuntimeBeans() == null) {
- moduleMXBeanEntry.setRuntimeBeans(runtimeBeans);
- }
- checkState(Objects.equals(nullableDummyContainerName, moduleMXBeanEntry.getNullableDummyContainerName()),
- "Mismatch in module " + moduleMXBeanEntry.toString() + " - dummy container must be present/missing in" +
- " both state and configuration");
- } else {
- ModuleMXBeanEntry.ModuleMXBeanEntryInitial initial = new ModuleMXBeanEntry.ModuleMXBeanEntryInitialBuilder()
- .setIdSchemaNode(moduleIdentity).setPackageName(packageName).setJavaNamePrefix(javaNamePrefix)
- .setNamespace(currentModule.getNamespace().toString()).setqName(ModuleUtil.getQName(currentModule))
- .build();
-
- // construct ModuleMXBeanEntry
- ModuleMXBeanEntry moduleMXBeanEntry = new ModuleMXBeanEntry(initial, yangToAttributes, providedServices,
- runtimeBeans);
-
- moduleMXBeanEntry.setYangModuleName(currentModule.getName());
- moduleMXBeanEntry.setYangModuleLocalname(moduleLocalNameFromXPath);
- moduleMXBeanEntry.setNullableDummyContainerName(nullableDummyContainerName);
- result.put(moduleLocalNameFromXPath, moduleMXBeanEntry);
- }
- }
-
- private static void checkUniqueRuntimeBeansGeneratedClasses(final Map<String, QName> uniqueGeneratedClassesNames,
- final DataSchemaNode when, final Collection<RuntimeBeanEntry> runtimeBeans) {
- for (RuntimeBeanEntry runtimeBean : runtimeBeans) {
- final String javaNameOfRuntimeMXBean = runtimeBean.getJavaNameOfRuntimeMXBean();
- if (uniqueGeneratedClassesNames.containsKey(javaNameOfRuntimeMXBean)) {
- QName firstDefinedQName = uniqueGeneratedClassesNames.get(javaNameOfRuntimeMXBean);
- throw new NameConflictException(javaNameOfRuntimeMXBean, firstDefinedQName, when.getQName());
- }
- uniqueGeneratedClassesNames.put(javaNameOfRuntimeMXBean, when.getQName());
- }
- }
-
- private static void checkUniqueRuntimeBeanAttributesName(final ModuleMXBeanEntry mxBeanEntry,
- final Map<String, QName> uniqueGeneratedClassesNames) {
- for (RuntimeBeanEntry runtimeBeanEntry : mxBeanEntry.getRuntimeBeans()) {
- for (String runtimeAttName : runtimeBeanEntry.getYangPropertiesToTypesMap().keySet()) {
- if (mxBeanEntry.getAttributes().keySet().contains(runtimeAttName)) {
- QName qName1 = uniqueGeneratedClassesNames.get(runtimeBeanEntry.getJavaNameOfRuntimeMXBean());
- QName qName2 = uniqueGeneratedClassesNames.get(mxBeanEntry.getGloballyUniqueName());
- throw new NameConflictException(runtimeAttName, qName1, qName2);
- }
- }
- }
- }
-
- private static void checkUniqueAttributesWithGeneratedClass(final Map<String, QName> uniqueGeneratedClassNames,
- final QName parentQName, final Map<String, AttributeIfc> yangToAttributes) {
- for (Map.Entry<String, AttributeIfc> attr : yangToAttributes.entrySet()) {
- if (attr.getValue() instanceof TOAttribute) {
- checkUniqueTOAttr(uniqueGeneratedClassNames, parentQName, (TOAttribute) attr.getValue());
- } else if (attr.getValue() instanceof ListAttribute
- && ((ListAttribute) attr.getValue()).getInnerAttribute() instanceof TOAttribute) {
- checkUniqueTOAttr(uniqueGeneratedClassNames, parentQName,
- (TOAttribute) ((ListAttribute) attr.getValue()).getInnerAttribute());
- }
- }
- }
-
- private static void checkUniqueTOAttr(final Map<String, QName> uniqueGeneratedClassNames, final QName parentQName, final TOAttribute attr) {
- final String upperCaseCamelCase = attr.getUpperCaseCammelCase();
- if (uniqueGeneratedClassNames.containsKey(upperCaseCamelCase)) {
- QName firstDefinedQName = uniqueGeneratedClassNames.get(upperCaseCamelCase);
- throw new NameConflictException(upperCaseCamelCase, firstDefinedQName, parentQName);
- } else {
- uniqueGeneratedClassNames.put(upperCaseCamelCase, parentQName);
- }
- }
-
- private Collection<RuntimeBeanEntry> fillRuntimeBeans(final DataNodeContainer dataNodeContainer, final Module currentModule,
- final TypeProviderWrapper typeProviderWrapper, final String packageName, final String moduleLocalNameFromXPath,
- final String javaNamePrefix) {
-
- return RuntimeBeanEntry.extractClassNameToRuntimeBeanMap(packageName, dataNodeContainer, moduleLocalNameFromXPath,
- typeProviderWrapper, javaNamePrefix, currentModule, schemaContext).values();
-
- }
-
- /**
- * Since each case statement within a module must provide unique child nodes, it is allowed to wrap
- * the actual configuration with a container node with name equal to case name.
- *
- * @param choiceCaseNode state or configuration case statement
- * @return either choiceCaseNode or its only child container
- */
- private static <HAS_CHILDREN_AND_QNAME extends DataNodeContainer & SchemaNode> HAS_CHILDREN_AND_QNAME getDataNodeContainer(final CaseSchemaNode choiceCaseNode) {
- Collection<DataSchemaNode> childNodes = choiceCaseNode.getChildNodes();
- if (childNodes.size() == 1) {
- DataSchemaNode onlyChild = childNodes.iterator().next();
- if (onlyChild instanceof ContainerSchemaNode) {
- ContainerSchemaNode onlyContainer = (ContainerSchemaNode) onlyChild;
- if (Objects.equals(onlyContainer.getQName().getLocalName(), choiceCaseNode.getQName().getLocalName())) {
- // the actual configuration is inside dummy container
- return (HAS_CHILDREN_AND_QNAME) onlyContainer;
- }
- }
- }
- return (HAS_CHILDREN_AND_QNAME) choiceCaseNode;
- }
-
- private static Map<String, AttributeIfc> fillConfiguration(final DataNodeContainer dataNodeContainer, final Module currentModule,
- final TypeProviderWrapper typeProviderWrapper, final Map<QName, ServiceInterfaceEntry> qNamesToSIEs,
- final SchemaContext schemaContext, final String packageName) {
- Map<String, AttributeIfc> yangToAttributes = new HashMap<>();
- for (DataSchemaNode attrNode : dataNodeContainer.getChildNodes()) {
- AttributeIfc attributeValue = getAttributeValue(attrNode, currentModule, qNamesToSIEs, typeProviderWrapper,
- schemaContext, packageName);
- yangToAttributes.put(attributeValue.getAttributeYangName(), attributeValue);
- }
- return yangToAttributes;
- }
-
- private static Map<String, QName> findProvidedServices(final IdentitySchemaNode moduleIdentity, final Module currentModule,
- final Map<QName, ServiceInterfaceEntry> qNamesToSIEs, final SchemaContext schemaContext) {
- Map<String, QName> result = new HashMap<>();
- for (UnknownSchemaNode unknownNode : moduleIdentity.getUnknownSchemaNodes()) {
- if (ConfigConstants.PROVIDED_SERVICE_EXTENSION_QNAME.equals(unknownNode.getNodeType())) {
- String prefixAndIdentityLocalName = unknownNode.getNodeParameter();
- ServiceInterfaceEntry sie = findSIE(prefixAndIdentityLocalName, currentModule, qNamesToSIEs,
- schemaContext);
- result.put(sie.getFullyQualifiedName(), sie.getQName());
- }
- }
- return result;
- }
-
- private static AttributeIfc getAttributeValue(final DataSchemaNode attrNode, final Module currentModule,
- final Map<QName, ServiceInterfaceEntry> qNamesToSIEs, final TypeProviderWrapper typeProviderWrapper,
- final SchemaContext schemaContext, final String packageName) {
-
- if (attrNode instanceof LeafSchemaNode) {
- // simple type
- LeafSchemaNode leaf = (LeafSchemaNode) attrNode;
- return new JavaAttribute(leaf, typeProviderWrapper);
- } else if (attrNode instanceof ContainerSchemaNode) {
- // reference or TO
- ContainerSchemaNode containerSchemaNode = (ContainerSchemaNode) attrNode;
- Optional<? extends AbstractDependencyAttribute> dependencyAttributeOptional = extractDependency(
- containerSchemaNode, attrNode, currentModule, qNamesToSIEs, schemaContext);
- if (dependencyAttributeOptional.isPresent()) {
- return dependencyAttributeOptional.get();
- } else {
- return TOAttribute.create(containerSchemaNode, typeProviderWrapper, packageName);
- }
-
- } else if (attrNode instanceof LeafListSchemaNode) {
- return ListAttribute.create((LeafListSchemaNode) attrNode, typeProviderWrapper);
- } else if (attrNode instanceof ListSchemaNode) {
- ListSchemaNode listSchemaNode = (ListSchemaNode) attrNode;
- Optional<? extends AbstractDependencyAttribute> dependencyAttributeOptional = extractDependency(
- listSchemaNode, attrNode, currentModule, qNamesToSIEs, schemaContext);
- if (dependencyAttributeOptional.isPresent()) {
- return dependencyAttributeOptional.get();
- } else {
- return ListAttribute.create(listSchemaNode, typeProviderWrapper, packageName);
- }
- } else {
- throw new UnsupportedOperationException("Unknown configuration node " + attrNode.toString());
- }
- }
-
- private static Optional<? extends AbstractDependencyAttribute> extractDependency(final DataNodeContainer dataNodeContainer,
- final DataSchemaNode attrNode, final Module currentModule, final Map<QName, ServiceInterfaceEntry> qNamesToSIEs,
- final SchemaContext schemaContext) {
- if (isDependencyContainer(dataNodeContainer)) {
- // reference
- UsesNode usesNode = dataNodeContainer.getUses().iterator().next();
- for (SchemaNode refineNode : usesNode.getRefines().values()) {
- // this will ignore name nodes, since they are not needed here
- if (TYPE.equals(refineNode.getQName().getLocalName())){
- checkState(refineNode.getUnknownSchemaNodes().size() == 1, "Unexpected unknown schema node size of " + refineNode);
- UnknownSchemaNode requiredIdentity = refineNode.getUnknownSchemaNodes().iterator().next();
- checkState(ConfigConstants.REQUIRED_IDENTITY_EXTENSION_QNAME.equals(requiredIdentity.getNodeType()),
- "Unexpected language extension " + requiredIdentity);
- String prefixAndIdentityLocalName = requiredIdentity.getNodeParameter();
- // import should point to a module
- ServiceInterfaceEntry serviceInterfaceEntry = findSIE(prefixAndIdentityLocalName, currentModule,
- qNamesToSIEs, schemaContext);
- LeafSchemaNode refine = (LeafSchemaNode) usesNode.getRefines().values().iterator().next();
-
- boolean mandatory = refine.isMandatory();
- AbstractDependencyAttribute reference;
- if (dataNodeContainer instanceof ContainerSchemaNode) {
- reference = new DependencyAttribute(attrNode, serviceInterfaceEntry, mandatory,
- attrNode.getDescription().orElse(null));
- } else {
- reference = new ListDependenciesAttribute(attrNode, serviceInterfaceEntry, mandatory,
- attrNode.getDescription().orElse(null));
- }
- return Optional.of(reference);
- }
- }
- }
- return Optional.absent();
- }
-
- private static boolean isDependencyContainer(final DataNodeContainer dataNodeContainer) {
- if(dataNodeContainer.getUses().size() != 1) {
- return false;
- }
- UsesNode onlyUses = dataNodeContainer.getUses().iterator().next();
- if(onlyUses.getGroupingPath().getLastComponent().equals(ServiceRef.QNAME) == false) {
- return false;
- }
-
- return getChildNodeSizeWithoutUses(dataNodeContainer) == 0;
- }
-
- private static int getChildNodeSizeWithoutUses(final DataNodeContainer csn) {
- int result = 0;
- for (DataSchemaNode dsn : csn.getChildNodes()) {
- if (dsn.isAddedByUses() == false) {
- result++;
- }
- }
- return result;
- }
-
- private static ServiceInterfaceEntry findSIE(final String prefixAndIdentityLocalName, final Module currentModule,
- final Map<QName, ServiceInterfaceEntry> qNamesToSIEs, final SchemaContext schemaContext) {
-
- Matcher m = PREFIX_COLON_LOCAL_NAME.matcher(prefixAndIdentityLocalName);
- Module foundModule;
- String localSIName;
- if (m.matches()) {
- // if there is a prefix, look for ModuleImport with this prefix. Get
- // Module from SchemaContext
- String prefix = m.group(1);
- ModuleImport moduleImport = findModuleImport(currentModule, prefix);
- foundModule = schemaContext.findModule(moduleImport.getModuleName(), moduleImport.getRevision()).orElse(null);
- checkNotNull(foundModule, format("Module not found in SchemaContext by %s", moduleImport));
- localSIName = m.group(2);
- } else {
- foundModule = currentModule; // no prefix => SIE is in currentModule
- localSIName = prefixAndIdentityLocalName;
- }
- QName siQName = QName.create(foundModule.getNamespace(), foundModule.getRevision(), localSIName);
- ServiceInterfaceEntry sie = qNamesToSIEs.get(siQName);
- checkState(sie != null, "Cannot find referenced Service Interface by " + prefixAndIdentityLocalName);
- return sie;
- }
-
- private static ModuleImport findModuleImport(final Module module, final String prefix) {
- for (ModuleImport moduleImport : module.getImports()) {
- if (moduleImport.getPrefix().equals(prefix)) {
- return moduleImport;
- }
- }
- throw new IllegalStateException(format("Import not found with prefix %s in %s", prefix, module));
- }
-
- @VisibleForTesting
- static Matcher getWhenConditionMatcher(final String prefix, final RevisionAwareXPath whenConstraint) {
- String xpathRegex = MODULE_CONDITION_XPATH_TEMPLATE.replace(MAGIC_STRING, prefix);
- Pattern pattern = Pattern.compile(xpathRegex);
- return pattern.matcher(whenConstraint.toString());
- }
-
- private static String getConfigModulePrefixFromImport(final Module currentModule) {
- for (ModuleImport currentImport : currentModule.getImports()) {
- if (currentImport.getModuleName().equals(ConfigConstants.CONFIG_MODULE)) {
- return currentImport.getPrefix();
- }
- }
- throw new IllegalArgumentException("Cannot find import " + ConfigConstants.CONFIG_MODULE + " in "
- + currentModule);
- }
-
-}
Code Review / controller.git / blobdiff