-
Notifications
You must be signed in to change notification settings - Fork 464
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
WFCORE-6663 Add new AttributeDefinition implementations that resolves…
… a model directly to a ServiceDependency.
- Loading branch information
Showing
13 changed files
with
1,113 additions
and
55 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
115 changes: 115 additions & 0 deletions
115
subsystem/src/main/java/org/wildfly/subsystem/resource/SimpleResource.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,115 @@ | ||
| /* | ||
| * Copyright The WildFly Authors | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| */ | ||
|
|
||
| package org.wildfly.subsystem.resource; | ||
|
|
||
| import java.util.Set; | ||
|
|
||
| import org.jboss.as.controller.PathAddress; | ||
| import org.jboss.as.controller.PathElement; | ||
| import org.jboss.as.controller.registry.Resource; | ||
| import org.jboss.dmr.ModelNode; | ||
|
|
||
| /** | ||
| * A resource facade for an existing resource model, i.e. with no children | ||
| */ | ||
| public class SimpleResource implements Resource { | ||
| private final ModelNode model; | ||
|
|
||
| public SimpleResource(ModelNode model) { | ||
| this.model = model; | ||
| } | ||
|
|
||
| @Override | ||
| public ModelNode getModel() { | ||
| return this.model; | ||
| } | ||
|
|
||
| @Override | ||
| public void writeModel(ModelNode newModel) { | ||
| throw new UnsupportedOperationException(); | ||
| } | ||
|
|
||
| @Override | ||
| public boolean isModelDefined() { | ||
| return this.model.isDefined(); | ||
| } | ||
|
|
||
| @Override | ||
| public boolean hasChild(PathElement element) { | ||
| return false; | ||
| } | ||
|
|
||
| @Override | ||
| public Resource getChild(PathElement element) { | ||
| return null; | ||
| } | ||
|
|
||
| @Override | ||
| public Resource requireChild(PathElement element) { | ||
| throw new NoSuchResourceException(element); | ||
| } | ||
|
|
||
| @Override | ||
| public boolean hasChildren(String childType) { | ||
| return false; | ||
| } | ||
|
|
||
| @Override | ||
| public Resource navigate(PathAddress address) { | ||
| if (address.size() == 0) return this; | ||
| throw new NoSuchResourceException(address.getElement(0)); | ||
| } | ||
|
|
||
| @Override | ||
| public Set<String> getChildTypes() { | ||
| return Set.of(); | ||
| } | ||
|
|
||
| @Override | ||
| public Set<String> getChildrenNames(String childType) { | ||
| return Set.of(); | ||
| } | ||
|
|
||
| @Override | ||
| public Set<ResourceEntry> getChildren(String childType) { | ||
| return Set.of(); | ||
| } | ||
|
|
||
| @Override | ||
| public void registerChild(PathElement address, Resource resource) { | ||
| throw new UnsupportedOperationException(); | ||
| } | ||
|
|
||
| @Override | ||
| public void registerChild(PathElement address, int index, Resource resource) { | ||
| throw new UnsupportedOperationException(); | ||
| } | ||
|
|
||
| @Override | ||
| public Resource removeChild(PathElement address) { | ||
| throw new UnsupportedOperationException(); | ||
| } | ||
|
|
||
| @Override | ||
| public Set<String> getOrderedChildTypes() { | ||
| return Set.of(); | ||
| } | ||
|
|
||
| @Override | ||
| public boolean isRuntime() { | ||
| return false; | ||
| } | ||
|
|
||
| @Override | ||
| public boolean isProxy() { | ||
| return false; | ||
| } | ||
|
|
||
| @Override | ||
| public Resource clone() { | ||
| return new SimpleResource(this.model.clone()); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
86 changes: 86 additions & 0 deletions
86
...ava/org/wildfly/subsystem/resource/capability/CapabilityReferenceAttributeDefinition.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,86 @@ | ||
| /* | ||
| * Copyright The WildFly Authors | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| */ | ||
|
|
||
| package org.wildfly.subsystem.resource.capability; | ||
|
|
||
| import java.util.Map; | ||
|
|
||
| import org.jboss.as.controller.AbstractAttributeDefinitionBuilder; | ||
| import org.jboss.as.controller.AttributeParser; | ||
| import org.jboss.as.controller.OperationContext; | ||
| import org.jboss.as.controller.OperationFailedException; | ||
| import org.jboss.as.controller.SimpleAttributeDefinition; | ||
| import org.jboss.as.controller.operations.validation.StringLengthValidator; | ||
| import org.jboss.as.controller.registry.AttributeAccess.Flag; | ||
| import org.jboss.dmr.ModelNode; | ||
| import org.jboss.dmr.ModelType; | ||
| import org.wildfly.subsystem.resource.SimpleResource; | ||
| import org.wildfly.subsystem.resource.ResourceModelResolver; | ||
| import org.wildfly.subsystem.service.ServiceDependency; | ||
|
|
||
| /** | ||
| * An attribute definition referencing some capability. | ||
| * Resolves directly to a {@link ServiceDependency} via {@link #resolve(OperationContext, ModelNode)}. | ||
| */ | ||
| public class CapabilityReferenceAttributeDefinition<T> extends SimpleAttributeDefinition implements ResourceModelResolver<ServiceDependency<T>> { | ||
|
|
||
| private final CapabilityReferenceResolver<T> resolver; | ||
|
|
||
| CapabilityReferenceAttributeDefinition(Builder<T> builder) { | ||
| super(builder); | ||
| this.resolver = builder.resolver; | ||
| } | ||
|
|
||
| @Override | ||
| public ServiceDependency<T> resolve(OperationContext context, ModelNode model) throws OperationFailedException { | ||
| String value = this.resolveModelAttribute(context, model).asStringOrNull(); | ||
| Map.Entry<String, String[]> resolved = this.resolver.resolve(context, new SimpleResource(model), value); | ||
| return (resolved != null) ? ServiceDependency.on(resolved.getKey(), this.resolver.getRequirement().getType(), resolved.getValue()) : ServiceDependency.of(null); | ||
| } | ||
|
|
||
| public static class Builder<T> extends AbstractAttributeDefinitionBuilder<Builder<T>, CapabilityReferenceAttributeDefinition<T>> { | ||
|
|
||
| final CapabilityReferenceResolver<T> resolver; | ||
|
|
||
| public Builder(String attributeName, CapabilityReference<T> reference) { | ||
| super(attributeName, ModelType.STRING); | ||
| // Capability references never allow expressions | ||
| this.setAllowExpression(false); | ||
| this.setAttributeParser(AttributeParser.SIMPLE); | ||
| this.setCapabilityReference(reference); | ||
| this.setFlags(Flag.RESTART_RESOURCE_SERVICES); | ||
| this.setValidator(new StringLengthValidator(1)); | ||
| this.resolver = reference; | ||
| } | ||
|
|
||
| public Builder(String attributeName, CapabilityReferenceAttributeDefinition<T> basis) { | ||
| super(attributeName, basis); | ||
| this.resolver = basis.resolver; | ||
| } | ||
|
|
||
| @Override | ||
| public Builder<T> setDefaultValue(ModelNode defaultValue) { | ||
| // A capability reference must not specify a default value | ||
| if ((defaultValue != null) && defaultValue.isDefined()) { | ||
| throw new UnsupportedOperationException(); | ||
| } | ||
| return this; | ||
| } | ||
|
|
||
| @Override | ||
| public Builder<T> setAllowExpression(boolean allowExpression) { | ||
| // A capability reference must not allow expressions | ||
| if (allowExpression) { | ||
| throw new UnsupportedOperationException(); | ||
| } | ||
| return this; | ||
| } | ||
|
|
||
| @Override | ||
| public CapabilityReferenceAttributeDefinition<T> build() { | ||
| return new CapabilityReferenceAttributeDefinition<>(this); | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.