Skip to content

Commit

Permalink
Ensure waiter names are unique across a service
Browse files Browse the repository at this point in the history
  • Loading branch information
mtdowling committed Dec 1, 2020
1 parent 130de40 commit c82e379
Show file tree
Hide file tree
Showing 5 changed files with 183 additions and 0 deletions.
5 changes: 5 additions & 0 deletions docs/source/1.0/spec/waiters.rst
Original file line number Diff line number Diff line change
Expand Up @@ -111,6 +111,11 @@ ABNF:
.. seealso:: :ref:`waiter-best-practices` for additional best practices
to follow when naming waiters.

Each waiter in the :ref:`closure of a service <service-closure>` MUST have
a case-insensitively unique waiter name. This limitation helps make it
easier to both understand a service and to generate code for a service
without needing to consider duplicate waiter names across operations.


Waiter workflow
===============
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,91 @@
/*
* Copyright 2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License").
* You may not use this file except in compliance with the License.
* A copy of the License is located at
*
* http://aws.amazon.com/apache2.0
*
* or in the "license" file accompanying this file. This file 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 software.amazon.smithy.waiters;

import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.Set;
import java.util.TreeMap;
import java.util.TreeSet;
import java.util.stream.Collectors;
import software.amazon.smithy.model.Model;
import software.amazon.smithy.model.knowledge.TopDownIndex;
import software.amazon.smithy.model.shapes.OperationShape;
import software.amazon.smithy.model.shapes.ServiceShape;
import software.amazon.smithy.model.shapes.Shape;
import software.amazon.smithy.model.shapes.ShapeId;
import software.amazon.smithy.model.validation.AbstractValidator;
import software.amazon.smithy.model.validation.ValidationEvent;
import software.amazon.smithy.utils.SmithyInternalApi;

/**
* Ensures that no two waiters use the same case-insensitive name in the
* closure of a service.
*/
@SmithyInternalApi
public final class UniqueWaiterNamesValidator extends AbstractValidator {
@Override
public List<ValidationEvent> validate(Model model) {
return model.shapes(ServiceShape.class)
.flatMap(service -> validateService(model, service).stream())
.collect(Collectors.toList());
}

private List<ValidationEvent> validateService(Model model, ServiceShape service) {
Map<String, Set<OperationShape>> waiterNamesToOperations = computeWaiterNamesToOperations(model, service);
List<ValidationEvent> events = new ArrayList<>();

for (Map.Entry<String, Set<OperationShape>> entry : waiterNamesToOperations.entrySet()) {
if (entry.getValue().size() > 1) {
for (OperationShape operation : entry.getValue()) {
Set<ShapeId> conflicts = entry.getValue().stream()
.filter(o -> !o.equals(operation))
.map(Shape::getId)
.collect(Collectors.toCollection(TreeSet::new));
events.add(error(operation, operation.expectTrait(WaitableTrait.class), String.format(
"`%s` trait waiter name `%s` case-insensitively conflicts with waiters on other "
+ "operations in the closure of service, `%s`: %s",
WaitableTrait.ID,
entry.getKey(),
service.getId(),
conflicts)));
}
}
}

return events;
}

private Map<String, Set<OperationShape>> computeWaiterNamesToOperations(Model model, ServiceShape service) {
TopDownIndex index = TopDownIndex.of(model);
Map<String, Set<OperationShape>> waiterNamesToOperations = new TreeMap<>();

for (OperationShape operation : index.getContainedOperations(service)) {
operation.getTrait(WaitableTrait.class).ifPresent(trait -> {
for (String name : trait.getWaiters().keySet()) {
Set<OperationShape> operations = waiterNamesToOperations.computeIfAbsent(
name.toLowerCase(Locale.ENGLISH), n -> new HashSet<>());
operations.add(operation);
}
});
}

return waiterNamesToOperations;
}
}
Original file line number Diff line number Diff line change
@@ -1 +1,2 @@
software.amazon.smithy.waiters.WaitableTraitValidator
software.amazon.smithy.waiters.UniqueWaiterNamesValidator
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
[ERROR] smithy.example#A: `smithy.waiters#waitable` trait waiter name `a` case-insensitively conflicts with waiters on other operations in the closure of service, `smithy.example#InvalidService`: [smithy.example#B] | UniqueWaiterNames
[ERROR] smithy.example#A: `smithy.waiters#waitable` trait waiter name `b` case-insensitively conflicts with waiters on other operations in the closure of service, `smithy.example#InvalidService`: [smithy.example#B] | UniqueWaiterNames
[ERROR] smithy.example#B: `smithy.waiters#waitable` trait waiter name `a` case-insensitively conflicts with waiters on other operations in the closure of service, `smithy.example#InvalidService`: [smithy.example#A] | UniqueWaiterNames
[ERROR] smithy.example#B: `smithy.waiters#waitable` trait waiter name `b` case-insensitively conflicts with waiters on other operations in the closure of service, `smithy.example#InvalidService`: [smithy.example#A] | UniqueWaiterNames
Original file line number Diff line number Diff line change
@@ -0,0 +1,82 @@
namespace smithy.example

use smithy.waiters#waitable

service InvalidService {
version: "2020-11-30",
operations: [A, B],
}

@waitable(
A: {
"documentation": "A",
"acceptors": [
{
"state": "success",
"matcher": {
"output": {
"path": "foo == 'hi'",
"comparator": "booleanEquals",
"expected": "true"
}
}
}
]
},
B: {
"acceptors": [
{
"state": "success",
"matcher": {
"output": {
"path": "foo == 'hey'",
"comparator": "booleanEquals",
"expected": "true"
}
}
}
]
}
)
operation A {
output: AOutput,
}

structure AOutput {
foo: String,
}

@waitable(
A: {
"documentation": "A",
"acceptors": [
{
"state": "success",
"matcher": {
"output": {
"path": "foo == 'hi'",
"comparator": "booleanEquals",
"expected": "true"
}
}
}
]
},
B: {
"acceptors": [
{
"state": "success",
"matcher": {
"output": {
"path": "foo == 'hey'",
"comparator": "booleanEquals",
"expected": "true"
}
}
}
]
}
)
operation B {
output: AOutput,
}

0 comments on commit c82e379

Please sign in to comment.