From fc0c6d5e3af1bd091e398968db4b7a394fb490e0 Mon Sep 17 00:00:00 2001 From: Jon Bratseth Date: Mon, 7 Oct 2019 17:26:59 +0200 Subject: Revert "Bratseth/instances in deployment xml rebased" --- config-model-api/abi-spec.json | 54 +- .../application/api/DeploymentInstanceSpec.java | 254 ------- .../config/application/api/DeploymentSpec.java | 383 +++++----- .../api/xml/DeploymentSpecXmlReader.java | 278 +++---- .../api/DeploymentSpecDeprecatedAPITest.java | 572 --------------- .../config/application/api/DeploymentSpecTest.java | 811 ++++++--------------- .../api/DeploymentSpecWithoutInstanceTest.java | 526 ------------- 7 files changed, 536 insertions(+), 2342 deletions(-) delete mode 100644 config-model-api/src/main/java/com/yahoo/config/application/api/DeploymentInstanceSpec.java delete mode 100644 config-model-api/src/test/java/com/yahoo/config/application/api/DeploymentSpecDeprecatedAPITest.java delete mode 100644 config-model-api/src/test/java/com/yahoo/config/application/api/DeploymentSpecWithoutInstanceTest.java (limited to 'config-model-api') diff --git a/config-model-api/abi-spec.json b/config-model-api/abi-spec.json index 315b03c301a..32c9e433157 100644 --- a/config-model-api/abi-spec.json +++ b/config-model-api/abi-spec.json @@ -187,35 +187,6 @@ ], "fields": [] }, - "com.yahoo.config.application.api.DeploymentInstanceSpec": { - "superClass": "com.yahoo.config.application.api.DeploymentSpec$Step", - "interfaces": [], - "attributes": [ - "public" - ], - "methods": [ - "public void (com.yahoo.config.provision.InstanceName, java.util.List, com.yahoo.config.application.api.DeploymentSpec$UpgradePolicy, java.util.List, java.util.Optional, java.util.Optional, java.util.Optional, com.yahoo.config.application.api.Notifications, java.util.List)", - "public com.yahoo.config.provision.InstanceName name()", - "public java.time.Duration delay()", - "public java.util.List steps()", - "public com.yahoo.config.application.api.DeploymentSpec$UpgradePolicy upgradePolicy()", - "public java.util.List changeBlocker()", - "public java.util.Optional globalServiceId()", - "public boolean canUpgradeAt(java.time.Instant)", - "public boolean canChangeRevisionAt(java.time.Instant)", - "public java.util.List zones()", - "public boolean deploysTo(com.yahoo.config.provision.Environment, java.util.Optional)", - "public java.util.Optional athenzDomain()", - "public java.util.Optional athenzService(com.yahoo.config.provision.Environment, com.yahoo.config.provision.RegionName)", - "public com.yahoo.config.application.api.Notifications notifications()", - "public java.util.List endpoints()", - "public boolean includes(com.yahoo.config.provision.Environment, java.util.Optional)", - "public boolean equals(java.lang.Object)", - "public int hashCode()", - "public java.lang.String toString()" - ], - "fields": [] - }, "com.yahoo.config.application.api.DeploymentSpec$ChangeBlocker": { "superClass": "java.lang.Object", "interfaces": [], @@ -226,8 +197,7 @@ "public void (boolean, boolean, com.yahoo.config.application.api.TimeWindow)", "public boolean blocksRevisions()", "public boolean blocksVersions()", - "public com.yahoo.config.application.api.TimeWindow window()", - "public java.lang.String toString()" + "public com.yahoo.config.application.api.TimeWindow window()" ], "fields": [] }, @@ -264,9 +234,7 @@ "methods": [ "public void (java.time.Duration)", "public java.time.Duration duration()", - "public java.time.Duration delay()", - "public boolean deploysTo(com.yahoo.config.provision.Environment, java.util.Optional)", - "public java.lang.String toString()" + "public boolean deploysTo(com.yahoo.config.provision.Environment, java.util.Optional)" ], "fields": [] }, @@ -279,11 +247,9 @@ "methods": [ "public void (java.util.List)", "public java.util.List zones()", - "public java.util.List steps()", "public boolean deploysTo(com.yahoo.config.provision.Environment, java.util.Optional)", "public boolean equals(java.lang.Object)", - "public int hashCode()", - "public java.lang.String toString()" + "public int hashCode()" ], "fields": [] }, @@ -298,9 +264,7 @@ "public void ()", "public final boolean deploysTo(com.yahoo.config.provision.Environment)", "public abstract boolean deploysTo(com.yahoo.config.provision.Environment, java.util.Optional)", - "public java.util.List zones()", - "public java.time.Duration delay()", - "public java.util.List steps()" + "public java.util.List zones()" ], "fields": [] }, @@ -329,7 +293,6 @@ "public" ], "methods": [ - "public void (java.util.List, java.util.Optional, java.lang.String)", "public void (java.util.Optional, com.yahoo.config.application.api.DeploymentSpec$UpgradePolicy, java.util.Optional, java.util.List, java.util.List, java.lang.String, java.util.Optional, java.util.Optional, com.yahoo.config.application.api.Notifications, java.util.List)", "public java.util.Optional globalServiceId()", "public com.yahoo.config.application.api.DeploymentSpec$UpgradePolicy upgradePolicy()", @@ -339,21 +302,16 @@ "public java.util.List changeBlocker()", "public java.util.List steps()", "public java.util.List zones()", - "public java.util.Optional athenzDomain()", - "public java.util.Optional athenzService(com.yahoo.config.provision.Environment, com.yahoo.config.provision.RegionName)", "public com.yahoo.config.application.api.Notifications notifications()", "public java.util.List endpoints()", "public java.lang.String xmlForm()", "public boolean includes(com.yahoo.config.provision.Environment, java.util.Optional)", - "public com.yahoo.config.application.api.DeploymentInstanceSpec instance(java.lang.String)", - "public com.yahoo.config.application.api.DeploymentInstanceSpec instance(com.yahoo.config.provision.InstanceName)", - "public com.yahoo.config.application.api.DeploymentInstanceSpec requireInstance(java.lang.String)", - "public com.yahoo.config.application.api.DeploymentInstanceSpec requireInstance(com.yahoo.config.provision.InstanceName)", - "public java.util.List instances()", "public static com.yahoo.config.application.api.DeploymentSpec fromXml(java.io.Reader)", "public static com.yahoo.config.application.api.DeploymentSpec fromXml(java.lang.String)", "public static com.yahoo.config.application.api.DeploymentSpec fromXml(java.lang.String, boolean)", "public static java.lang.String toMessageString(java.lang.Throwable)", + "public java.util.Optional athenzDomain()", + "public java.util.Optional athenzService(com.yahoo.config.provision.Environment, com.yahoo.config.provision.RegionName)", "public boolean equals(java.lang.Object)", "public int hashCode()", "public static void main(java.lang.String[])" diff --git a/config-model-api/src/main/java/com/yahoo/config/application/api/DeploymentInstanceSpec.java b/config-model-api/src/main/java/com/yahoo/config/application/api/DeploymentInstanceSpec.java deleted file mode 100644 index df611d66b87..00000000000 --- a/config-model-api/src/main/java/com/yahoo/config/application/api/DeploymentInstanceSpec.java +++ /dev/null @@ -1,254 +0,0 @@ -// Copyright 2019 Oath Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -package com.yahoo.config.application.api; - -import com.yahoo.config.provision.AthenzDomain; -import com.yahoo.config.provision.AthenzService; -import com.yahoo.config.provision.Environment; -import com.yahoo.config.provision.InstanceName; -import com.yahoo.config.provision.RegionName; - -import java.time.Duration; -import java.time.Instant; -import java.util.ArrayList; -import java.util.HashSet; -import java.util.List; -import java.util.Objects; -import java.util.Optional; -import java.util.Set; -import java.util.stream.Collectors; - -/** - * The deployment spec for an application instance - * - * @author bratseth - */ -public class DeploymentInstanceSpec extends DeploymentSpec.Step { - - /** The name of the instance this step deploys */ - private final InstanceName name; - - private final List steps; - private final DeploymentSpec.UpgradePolicy upgradePolicy; - private final List changeBlockers; - private final Optional globalServiceId; - private final Optional athenzDomain; - private final Optional athenzService; - private final Notifications notifications; - private final List endpoints; - - public DeploymentInstanceSpec(InstanceName name, - List steps, - DeploymentSpec.UpgradePolicy upgradePolicy, - List changeBlockers, - Optional globalServiceId, - Optional athenzDomain, - Optional athenzService, - Notifications notifications, - List endpoints) { - this.name = name; - this.steps = steps; - this.upgradePolicy = upgradePolicy; - this.changeBlockers = changeBlockers; - this.globalServiceId = globalServiceId; - this.athenzDomain = athenzDomain; - this.athenzService = athenzService; - this.notifications = notifications; - this.endpoints = List.copyOf(validateEndpoints(endpoints, this.steps)); - validateZones(this.steps); - validateEndpoints(this.steps, globalServiceId, this.endpoints); - validateAthenz(); - } - - public InstanceName name() { return name; } - - /** Throw an IllegalArgumentException if any production zone is declared multiple times */ - private void validateZones(List steps) { - Set zones = new HashSet<>(); - - for (DeploymentSpec.Step step : steps) - for (DeploymentSpec.DeclaredZone zone : step.zones()) - ensureUnique(zone, zones); - } - - private void ensureUnique(DeploymentSpec.DeclaredZone zone, Set zones) { - if ( ! zones.add(zone)) - throw new IllegalArgumentException(zone + " is listed twice in deployment.xml"); - } - - /** Validates the endpoints and makes sure default values are respected */ - private List validateEndpoints(List endpoints, List steps) { - Objects.requireNonNull(endpoints, "Missing endpoints parameter"); - - var productionRegions = steps.stream() - .filter(step -> step.deploysTo(Environment.prod)) - .flatMap(step -> step.zones().stream()) - .flatMap(zone -> zone.region().stream()) - .map(RegionName::value) - .collect(Collectors.toSet()); - - var rebuiltEndpointsList = new ArrayList(); - - for (var endpoint : endpoints) { - if (endpoint.regions().isEmpty()) { - var rebuiltEndpoint = endpoint.withRegions(productionRegions); - rebuiltEndpointsList.add(rebuiltEndpoint); - } else { - rebuiltEndpointsList.add(endpoint); - } - } - - return List.copyOf(rebuiltEndpointsList); - } - - /** Throw an IllegalArgumentException if an endpoint refers to a region that is not declared in 'prod' */ - private void validateEndpoints(List steps, Optional globalServiceId, List endpoints) { - if (globalServiceId.isPresent() && ! endpoints.isEmpty()) { - throw new IllegalArgumentException("Providing both 'endpoints' and 'global-service-id'. Use only 'endpoints'."); - } - - var stepZones = steps.stream() - .flatMap(s -> s.zones().stream()) - .flatMap(z -> z.region().stream()) - .collect(Collectors.toSet()); - - for (var endpoint : endpoints){ - for (var endpointRegion : endpoint.regions()) { - if (! stepZones.contains(endpointRegion)) { - throw new IllegalArgumentException("Region used in endpoint that is not declared in 'prod': " + endpointRegion); - } - } - } - } - - /** - * Throw an IllegalArgumentException if Athenz configuration violates: - * domain not configured -> no zone can configure service - * domain configured -> all zones must configure service - */ - private void validateAthenz() { - // If athenz domain is not set, athenz service cannot be set on any level - if (athenzDomain.isEmpty()) { - for (DeploymentSpec.DeclaredZone zone : zones()) { - if(zone.athenzService().isPresent()) { - throw new IllegalArgumentException("Athenz service configured for zone: " + zone + ", but Athenz domain is not configured"); - } - } - // if athenz domain is not set, athenz service must be set implicitly or directly on all zones. - } else if (athenzService.isEmpty()) { - for (DeploymentSpec.DeclaredZone zone : zones()) { - if (zone.athenzService().isEmpty()) { - throw new IllegalArgumentException("Athenz domain is configured, but Athenz service not configured for zone: " + zone); - } - } - } - } - - @Override - public Duration delay() { - return Duration.ofSeconds(steps.stream().mapToLong(step -> (step.delay().getSeconds())).sum()); - } - - /** Returns the deployment steps inside this in the order they will be performed */ - @Override - public List steps() { return steps; } - - /** Returns the upgrade policy of this, which is defaultPolicy if none is specified */ - public DeploymentSpec.UpgradePolicy upgradePolicy() { return upgradePolicy; } - - /** Returns time windows where upgrades are disallowed for these instances */ - public List changeBlocker() { return changeBlockers; } - - /** Returns the ID of the service to expose through global routing, if present */ - public Optional globalServiceId() { return globalServiceId; } - - /** Returns whether the instances in this step can upgrade at the given instant */ - public boolean canUpgradeAt(Instant instant) { - return changeBlockers.stream().filter(block -> block.blocksVersions()) - .noneMatch(block -> block.window().includes(instant)); - } - - /** Returns whether an application revision change for these instances can occur at the given instant */ - public boolean canChangeRevisionAt(Instant instant) { - return changeBlockers.stream().filter(block -> block.blocksRevisions()) - .noneMatch(block -> block.window().includes(instant)); - } - - /** Returns all the deployment steps which are zones in the order they are declared */ - public List zones() { - return steps.stream() - .flatMap(step -> step.zones().stream()) - .collect(Collectors.toList()); - } - - /** Returns whether this deployment spec specifies the given zone, either implicitly or explicitly */ - @Override - public boolean deploysTo(Environment environment, Optional region) { - for (DeploymentSpec.Step step : steps) - if (step.deploysTo(environment, region)) return true; - return false; - } - - /** Returns the athenz domain if configured */ - public Optional athenzDomain() { return athenzDomain; } - - /** Returns the athenz service for environment/region if configured */ - public Optional athenzService(Environment environment, RegionName region) { - AthenzService athenzService = zones().stream() - .filter(zone -> zone.deploysTo(environment, Optional.of(region))) - .findFirst() - .flatMap(DeploymentSpec.DeclaredZone::athenzService) - .orElse(this.athenzService.orElse(null)); - return Optional.ofNullable(athenzService); - } - - /** Returns the notification configuration of these instances */ - public Notifications notifications() { return notifications; } - - /** Returns the rotations configuration of these instances */ - public List endpoints() { return endpoints; } - - /** Returns whether this instances deployment specifies the given zone, either implicitly or explicitly */ - public boolean includes(Environment environment, Optional region) { - for (DeploymentSpec.Step step : steps) - if (step.deploysTo(environment, region)) return true; - return false; - } - - DeploymentInstanceSpec withSteps(List steps) { - return new DeploymentInstanceSpec(name, - steps, - upgradePolicy, - changeBlockers, - globalServiceId, - athenzDomain, - athenzService, - notifications, - endpoints); - } - - @Override - public boolean equals(Object o) { - if (this == o) return true; - if (o == null || getClass() != o.getClass()) return false; - DeploymentInstanceSpec other = (DeploymentInstanceSpec) o; - return globalServiceId.equals(other.globalServiceId) && - upgradePolicy == other.upgradePolicy && - changeBlockers.equals(other.changeBlockers) && - steps.equals(other.steps) && - athenzDomain.equals(other.athenzDomain) && - athenzService.equals(other.athenzService) && - notifications.equals(other.notifications) && - endpoints.equals(other.endpoints); - } - - @Override - public int hashCode() { - return Objects.hash(globalServiceId, upgradePolicy, changeBlockers, steps, athenzDomain, athenzService, notifications, endpoints); - } - - @Override - public String toString() { - return "instance '" + name + "'"; - } - -} diff --git a/config-model-api/src/main/java/com/yahoo/config/application/api/DeploymentSpec.java b/config-model-api/src/main/java/com/yahoo/config/application/api/DeploymentSpec.java index 71af050174b..efe75d191b8 100644 --- a/config-model-api/src/main/java/com/yahoo/config/application/api/DeploymentSpec.java +++ b/config-model-api/src/main/java/com/yahoo/config/application/api/DeploymentSpec.java @@ -5,7 +5,6 @@ import com.yahoo.config.application.api.xml.DeploymentSpecXmlReader; import com.yahoo.config.provision.AthenzDomain; import com.yahoo.config.provision.AthenzService; import com.yahoo.config.provision.Environment; -import com.yahoo.config.provision.InstanceName; import com.yahoo.config.provision.RegionName; import java.io.BufferedReader; @@ -15,9 +14,11 @@ import java.time.Duration; import java.time.Instant; import java.util.ArrayList; import java.util.Collections; +import java.util.HashSet; import java.util.List; import java.util.Objects; import java.util.Optional; +import java.util.Set; import java.util.stream.Collectors; /** @@ -45,195 +46,218 @@ public class DeploymentSpec { Optional.empty(), Notifications.none(), List.of()); - - private final List steps; + + private final Optional globalServiceId; + private final UpgradePolicy upgradePolicy; private final Optional majorVersion; + private final List changeBlockers; + private final List steps; private final String xmlForm; + private final Optional athenzDomain; + private final Optional athenzService; + private final Notifications notifications; + private final List endpoints; - public DeploymentSpec(List steps, - Optional majorVersion, - String xmlForm) { - if (singleInstance(steps)) { // TODO: Remove this clause after November 2019 - var singleInstance = (DeploymentInstanceSpec)steps.get(0); - this.steps = List.of(singleInstance.withSteps(completeSteps(singleInstance.steps()))); - } - else { - this.steps = List.copyOf(completeSteps(steps)); - } + public DeploymentSpec(Optional globalServiceId, UpgradePolicy upgradePolicy, Optional majorVersion, + List changeBlockers, List steps, String xmlForm, + Optional athenzDomain, Optional athenzService, Notifications notifications, + List endpoints) { + validateTotalDelay(steps); + this.globalServiceId = globalServiceId; + this.upgradePolicy = upgradePolicy; this.majorVersion = majorVersion; + this.changeBlockers = changeBlockers; + this.steps = List.copyOf(completeSteps(new ArrayList<>(steps))); this.xmlForm = xmlForm; - validateTotalDelay(steps); + this.athenzDomain = athenzDomain; + this.athenzService = athenzService; + this.notifications = notifications; + this.endpoints = List.copyOf(validateEndpoints(endpoints, this.steps)); + validateZones(this.steps); + validateAthenz(); + validateEndpoints(this.steps, globalServiceId, this.endpoints); } - // TODO: Remove after October 2019 - public DeploymentSpec(Optional globalServiceId, UpgradePolicy upgradePolicy, Optional majorVersion, - List changeBlockers, List steps, String xmlForm, - Optional athenzDomain, Optional athenzService, - Notifications notifications, - List endpoints) { - this(List.of(new DeploymentInstanceSpec(InstanceName.from("default"), - steps, - upgradePolicy, - changeBlockers, - globalServiceId, - athenzDomain, - athenzService, - notifications, - endpoints)), - majorVersion, - xmlForm); + /** Validates the endpoints and makes sure default values are respected */ + private List validateEndpoints(List endpoints, List steps) { + Objects.requireNonNull(endpoints, "Missing endpoints parameter"); + + var productionRegions = steps.stream() + .filter(step -> step.deploysTo(Environment.prod)) + .flatMap(step -> step.zones().stream()) + .flatMap(zone -> zone.region().stream()) + .map(RegionName::value) + .collect(Collectors.toSet()); + + var rebuiltEndpointsList = new ArrayList(); + + for (var endpoint : endpoints) { + if (endpoint.regions().isEmpty()) { + var rebuiltEndpoint = endpoint.withRegions(productionRegions); + rebuiltEndpointsList.add(rebuiltEndpoint); + } else { + rebuiltEndpointsList.add(endpoint); + } + } + + return List.copyOf(rebuiltEndpointsList); + } + + /** Throw an IllegalArgumentException if the total delay exceeds 24 hours */ + private void validateTotalDelay(List steps) { + long totalDelaySeconds = steps.stream().filter(step -> step instanceof Delay) + .mapToLong(delay -> ((Delay)delay).duration().getSeconds()) + .sum(); + if (totalDelaySeconds > Duration.ofHours(24).getSeconds()) + throw new IllegalArgumentException("The total delay specified is " + Duration.ofSeconds(totalDelaySeconds) + + " but max 24 hours is allowed"); } - /** Adds missing required steps and reorders steps to a permissible order */ - private static List completeSteps(List inputSteps) { - List steps = new ArrayList<>(inputSteps); + /** Throw an IllegalArgumentException if any production zone is declared multiple times */ + private void validateZones(List steps) { + Set zones = new HashSet<>(); + + for (Step step : steps) + for (DeclaredZone zone : step.zones()) + ensureUnique(zone, zones); + } + + /** Throw an IllegalArgumentException if an endpoint refers to a region that is not declared in 'prod' */ + private void validateEndpoints(List steps, Optional globalServiceId, List endpoints) { + if (globalServiceId.isPresent() && ! endpoints.isEmpty()) { + throw new IllegalArgumentException("Providing both 'endpoints' and 'global-service-id'. Use only 'endpoints'."); + } + + var stepZones = steps.stream() + .flatMap(s -> s.zones().stream()) + .flatMap(z -> z.region.stream()) + .collect(Collectors.toSet()); + for (var endpoint : endpoints){ + for (var endpointRegion : endpoint.regions()) { + if (! stepZones.contains(endpointRegion)) { + throw new IllegalArgumentException("Region used in endpoint that is not declared in 'prod': " + endpointRegion); + } + } + } + } + + /* + * Throw an IllegalArgumentException if Athenz configuration violates: + * domain not configured -> no zone can configure service + * domain configured -> all zones must configure service + */ + private void validateAthenz() { + // If athenz domain is not set, athenz service cannot be set on any level + if (athenzDomain.isEmpty()) { + for (DeclaredZone zone : zones()) { + if(zone.athenzService().isPresent()) { + throw new IllegalArgumentException("Athenz service configured for zone: " + zone + ", but Athenz domain is not configured"); + } + } + // if athenz domain is not set, athenz service must be set implicitly or directly on all zones. + } else if (athenzService.isEmpty()) { + for (DeclaredZone zone : zones()) { + if (zone.athenzService().isEmpty()) { + throw new IllegalArgumentException("Athenz domain is configured, but Athenz service not configured for zone: " + zone); + } + } + } + } + + private void ensureUnique(DeclaredZone zone, Set zones) { + if ( ! zones.add(zone)) + throw new IllegalArgumentException(zone + " is listed twice in deployment.xml"); + } + + /** Adds missing required steps and reorders steps to a permissible order */ + private static List completeSteps(List steps) { // Add staging if required and missing if (steps.stream().anyMatch(step -> step.deploysTo(Environment.prod)) && steps.stream().noneMatch(step -> step.deploysTo(Environment.staging))) { - steps.add(new DeploymentSpec.DeclaredZone(Environment.staging)); + steps.add(new DeclaredZone(Environment.staging)); } - + // Add test if required and missing if (steps.stream().anyMatch(step -> step.deploysTo(Environment.staging)) && steps.stream().noneMatch(step -> step.deploysTo(Environment.test))) { - steps.add(new DeploymentSpec.DeclaredZone(Environment.test)); + steps.add(new DeclaredZone(Environment.test)); } - + // Enforce order test, staging, prod - DeploymentSpec.DeclaredZone testStep = remove(Environment.test, steps); + DeclaredZone testStep = remove(Environment.test, steps); if (testStep != null) steps.add(0, testStep); - DeploymentSpec.DeclaredZone stagingStep = remove(Environment.staging, steps); + DeclaredZone stagingStep = remove(Environment.staging, steps); if (stagingStep != null) steps.add(1, stagingStep); - + return steps; } - /** + /** * Removes the first occurrence of a deployment step to the given environment and returns it. - * + * * @return the removed step, or null if it is not present */ - private static DeploymentSpec.DeclaredZone remove(Environment environment, List steps) { + private static DeclaredZone remove(Environment environment, List steps) { for (int i = 0; i < steps.size(); i++) { - if ( ! (steps.get(i) instanceof DeploymentSpec.DeclaredZone)) continue; - DeploymentSpec.DeclaredZone zoneStep = (DeploymentSpec.DeclaredZone)steps.get(i); - if (zoneStep.environment() == environment) { - steps.remove(i); - return zoneStep; - } + if (steps.get(i).deploysTo(environment)) + return (DeclaredZone)steps.remove(i); } return null; } - /** Throw an IllegalArgumentException if the total delay exceeds 24 hours */ - private void validateTotalDelay(List steps) { - long totalDelaySeconds = steps.stream().mapToLong(step -> (step.delay().getSeconds())).sum(); - if (totalDelaySeconds > Duration.ofHours(24).getSeconds()) - throw new IllegalArgumentException("The total delay specified is " + Duration.ofSeconds(totalDelaySeconds) + - " but max 24 hours is allowed"); + /** Returns the ID of the service to expose through global routing, if present */ + public Optional globalServiceId() { + return globalServiceId; } - // TODO: Remove after October 2019 - private DeploymentInstanceSpec defaultInstance() { - if (singleInstance(steps)) return (DeploymentInstanceSpec)steps.get(0); - throw new IllegalArgumentException("This deployment spec does not support the legacy API " + - "as it has multiple instances: " + - instances().stream().map(Step::toString).collect(Collectors.joining(","))); - } - - // TODO: Remove after October 2019 - public Optional globalServiceId() { return defaultInstance().globalServiceId(); } - - // TODO: Remove after October 2019 - public UpgradePolicy upgradePolicy() { return defaultInstance().upgradePolicy(); } + /** Returns the upgrade policy of this, which is defaultPolicy if none is specified */ + public UpgradePolicy upgradePolicy() { return upgradePolicy; } /** Returns the major version this application is pinned to, or empty (default) to allow all major versions */ public Optional majorVersion() { return majorVersion; } - // TODO: Remove after November 2019 - public boolean canUpgradeAt(Instant instant) { return defaultInstance().canUpgradeAt(instant); } + /** Returns whether upgrade can occur at the given instant */ + public boolean canUpgradeAt(Instant instant) { + return changeBlockers.stream().filter(block -> block.blocksVersions()) + .noneMatch(block -> block.window().includes(instant)); + } - // TODO: Remove after November 2019 - public boolean canChangeRevisionAt(Instant instant) { return defaultInstance().canChangeRevisionAt(instant); } + /** Returns whether an application revision change can occur at the given instant */ + public boolean canChangeRevisionAt(Instant instant) { + return changeBlockers.stream().filter(block -> block.blocksRevisions()) + .noneMatch(block -> block.window().includes(instant)); + } - // TODO: Remove after November 2019 - public List changeBlocker() { return defaultInstance().changeBlocker(); } + /** Returns time windows where upgrades are disallowed */ + public List changeBlocker() { return changeBlockers; } /** Returns the deployment steps of this in the order they will be performed */ - public List steps() { - if (singleInstance(steps)) return defaultInstance().steps(); // TODO: Remove line after November 2019 - return steps; - } + public List steps() { return steps; } - // TODO: Remove after November 2019 + /** Returns all the DeclaredZone deployment steps in the order they are declared */ public List zones() { - return defaultInstance().steps().stream() - .flatMap(step -> step.zones().stream()) - .collect(Collectors.toList()); - } - - // TODO: Remove after November 2019 - public Optional athenzDomain() { return defaultInstance().athenzDomain(); } - - // TODO: Remove after November 2019 - public Optional athenzService(Environment environment, RegionName region) { - return defaultInstance().athenzService(environment, region); + return steps.stream() + .flatMap(step -> step.zones().stream()) + .collect(Collectors.toList()); } - // TODO: Remove after November 2019 - public Notifications notifications() { return defaultInstance().notifications(); } + /** Returns the notification configuration */ + public Notifications notifications() { return notifications; } - // TODO: Remove after November 2019 - public List endpoints() { return defaultInstance().endpoints(); } + /** Returns the rotations configuration */ + public List endpoints() { return endpoints; } /** Returns the XML form of this spec, or null if it was not created by fromXml, nor is empty */ public String xmlForm() { return xmlForm; } - // TODO: Remove after November 2019 + /** Returns whether this deployment spec specifies the given zone, either implicitly or explicitly */ public boolean includes(Environment environment, Optional region) { - return defaultInstance().deploysTo(environment, region); - } - - // TODO: Remove after November 2019 - private static boolean singleInstance(List steps) { - return steps.size() == 1 && steps.get(0) instanceof DeploymentInstanceSpec; - } - - /** Returns the instance step containing the given instance name, or null if not present */ - public DeploymentInstanceSpec instance(String name) { - return instance(InstanceName.from(name)); - } - - /** Returns the instance step containing the given instance name, or null if not present */ - public DeploymentInstanceSpec instance(InstanceName name) { - for (DeploymentInstanceSpec instance : instances()) { - if (instance.name().equals(name)) - return instance; - } - return null; - } - - /** Returns the instance step containing the given instance name, or throws an IllegalArgumentException if not present */ - public DeploymentInstanceSpec requireInstance(String name) { - return requireInstance(InstanceName.from(name)); - } - - public DeploymentInstanceSpec requireInstance(InstanceName name) { - DeploymentInstanceSpec instance = instance(name); - if (instance == null) - throw new IllegalArgumentException("No instance '" + name + "' in deployment.xml'. Instances: " + - instances().stream().map(spec -> spec.name().toString()).collect(Collectors.joining(","))); - return instance; - } - - /** Returns the steps of this which are instances */ - public List instances() { - return steps.stream() - .filter(step -> step instanceof DeploymentInstanceSpec).map(DeploymentInstanceSpec.class::cast) - .collect(Collectors.toList()); + for (Step step : steps) + if (step.deploysTo(environment, region)) return true; + return false; } /** @@ -280,19 +304,40 @@ public class DeploymentSpec { return b.toString(); } + /** Returns the athenz domain if configured */ + public Optional athenzDomain() { + return athenzDomain; + } + + /** Returns the athenz service for environment/region if configured */ + public Optional athenzService(Environment environment, RegionName region) { + AthenzService athenzService = zones().stream() + .filter(zone -> zone.deploysTo(environment, Optional.of(region))) + .findFirst() + .flatMap(DeclaredZone::athenzService) + .orElse(this.athenzService.orElse(null)); + return Optional.ofNullable(athenzService); + } + @Override public boolean equals(Object o) { if (this == o) return true; if (o == null || getClass() != o.getClass()) return false; - DeploymentSpec other = (DeploymentSpec) o; - return majorVersion.equals(other.majorVersion) && - steps.equals(other.steps) && - xmlForm.equals(other.xmlForm); + DeploymentSpec that = (DeploymentSpec) o; + return globalServiceId.equals(that.globalServiceId) && + upgradePolicy == that.upgradePolicy && + majorVersion.equals(that.majorVersion) && + changeBlockers.equals(that.changeBlockers) && + steps.equals(that.steps) && + xmlForm.equals(that.xmlForm) && + athenzDomain.equals(that.athenzDomain) && + athenzService.equals(that.athenzService) && + notifications.equals(that.notifications); } @Override public int hashCode() { - return Objects.hash(majorVersion, steps, xmlForm); + return Objects.hash(globalServiceId, upgradePolicy, majorVersion, changeBlockers, steps, xmlForm, athenzDomain, athenzService, notifications); } /** This may be invoked by a continuous build */ @@ -320,7 +365,7 @@ public class DeploymentSpec { /** A deployment step */ public abstract static class Step { - + /** Returns whether this step deploys to the given region */ public final boolean deploysTo(Environment environment) { return deploysTo(environment, Optional.empty()); @@ -332,12 +377,6 @@ public class DeploymentSpec { /** Returns the zones deployed to in this step */ public List zones() { return Collections.emptyList(); } - /** The delay introduced by this step (beyond the time it takes to execute the step). Default is zero. */ - public Duration delay() { return Duration.ZERO; } - - /** Returns all the steps nested in this. This default implementatiino returns an empty list. */ - public List steps() { return List.of(); } - } /** A deployment step which is to wait for some time before progressing to the next step */ @@ -348,21 +387,12 @@ public class DeploymentSpec { public Delay(Duration duration) { this.duration = duration; } - - // TODO: Remove after October 2019 + public Duration duration() { return duration; } - @Override - public Duration delay() { return duration; } - @Override public boolean deploysTo(Environment environment, Optional region) { return false; } - @Override - public String toString() { - return "delay " + duration; - } - } /** A deployment step which is to run deployment in a particular zone */ @@ -443,31 +473,21 @@ public class DeploymentSpec { } - /** A deployment step which is to run multiple steps (zones or instances) in parallel */ + /** A deployment step which is to run deployment to multiple zones in parallel */ public static class ParallelZones extends Step { - private final List steps; - - public ParallelZones(List steps) { - this.steps = List.copyOf(steps); - } + private final List zones; - /** Returns the steps inside this which are zones */ - @Override - public List zones() { - return this.steps.stream() - .filter(step -> step instanceof DeclaredZone) - .map(DeclaredZone.class::cast) - .collect(Collectors.toList()); + public ParallelZones(List zones) { + this.zones = List.copyOf(zones); } - /** Returns all the steps nested in this */ @Override - public List steps() { return steps; } + public List zones() { return this.zones; } @Override public boolean deploysTo(Environment environment, Optional region) { - return steps().stream().anyMatch(zone -> zone.deploysTo(environment, region)); + return zones.stream().anyMatch(zone -> zone.deploysTo(environment, region)); } @Override @@ -475,19 +495,13 @@ public class DeploymentSpec { if (this == o) return true; if (!(o instanceof ParallelZones)) return false; ParallelZones that = (ParallelZones) o; - return Objects.equals(steps, that.steps); + return Objects.equals(zones, that.zones); } @Override public int hashCode() { - return Objects.hash(steps); + return Objects.hash(zones); } - - @Override - public String toString() { - return steps.size() + " parallel steps"; - } - } /** Controls when this application will be upgraded to new Vespa versions */ @@ -516,11 +530,6 @@ public class DeploymentSpec { public boolean blocksRevisions() { return revision; } public boolean blocksVersions() { return version; } public TimeWindow window() { return window; } - - @Override - public String toString() { - return "change blocker revision=" + revision + " version=" + version + " window=" + window; - } } diff --git a/config-model-api/src/main/java/com/yahoo/config/application/api/xml/DeploymentSpecXmlReader.java b/config-model-api/src/main/java/com/yahoo/config/application/api/xml/DeploymentSpecXmlReader.java index cb645813290..72a806bb7be 100644 --- a/config-model-api/src/main/java/com/yahoo/config/application/api/xml/DeploymentSpecXmlReader.java +++ b/config-model-api/src/main/java/com/yahoo/config/application/api/xml/DeploymentSpecXmlReader.java @@ -1,7 +1,6 @@ // Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. package com.yahoo.config.application.api.xml; -import com.yahoo.config.application.api.DeploymentInstanceSpec; import com.yahoo.config.application.api.DeploymentSpec; import com.yahoo.config.application.api.DeploymentSpec.DeclaredZone; import com.yahoo.config.application.api.DeploymentSpec.Delay; @@ -15,7 +14,6 @@ import com.yahoo.config.application.api.TimeWindow; import com.yahoo.config.provision.AthenzDomain; import com.yahoo.config.provision.AthenzService; import com.yahoo.config.provision.Environment; -import com.yahoo.config.provision.InstanceName; import com.yahoo.config.provision.RegionName; import com.yahoo.io.IOUtils; import com.yahoo.text.XML; @@ -40,36 +38,27 @@ import java.util.stream.Collectors; */ public class DeploymentSpecXmlReader { - private static final String instanceTag = "instance"; private static final String majorVersionTag = "major-version"; private static final String testTag = "test"; private static final String stagingTag = "staging"; - private static final String upgradeTag = "upgrade"; private static final String blockChangeTag = "block-change"; private static final String prodTag = "prod"; - private static final String regionTag = "region"; - private static final String delayTag = "delay"; - private static final String parallelTag = "parallel"; private static final String endpointsTag = "endpoints"; private static final String endpointTag = "endpoint"; - private static final String notificationsTag = "notifications"; - - private static final String idAttribute = "id"; - private static final String athenzServiceAttribute = "athenz-service"; - private static final String athenzDomainAttribute = "athenz-domain"; - private static final String testerFlavorAttribute = "tester-flavor"; private final boolean validate; - /** Creates a validating reader */ + /** + * Creates a validating reader + */ public DeploymentSpecXmlReader() { this(true); } /** - * Creates a deployment spec reader + * Creates a reader * - * @param validate true to validate the input, false to accept any input which can be unambiguously parsed + * @param validate true to validate the input, false to accept any input which can be unabiguously parsed */ public DeploymentSpecXmlReader(boolean validate) { this.validate = validate; @@ -84,135 +73,67 @@ public class DeploymentSpecXmlReader { } } - /** Reads a deployment spec from XML */ - public DeploymentSpec read(String xmlForm) { - Element root = XML.getDocument(xmlForm).getDocumentElement(); - - List steps = new ArrayList<>(); - if ( ! containsTag(instanceTag, root)) { // deployment spec skipping explicit instance -> "default" instance - steps.addAll(readInstanceContent("default", root, new MutableOptional<>(), root)); - } - else { - if (XML.getChildren(root).stream().anyMatch(child -> child.getTagName().equals(prodTag))) - throw new IllegalArgumentException("A deployment spec cannot have both a tag and an " + - " tag under the root: " + - "Wrap the prod tags inside the appropriate instance"); - - for (Element topLevelTag : XML.getChildren(root)) { - if (topLevelTag.getTagName().equals(instanceTag)) - steps.addAll(readInstanceContent(topLevelTag.getAttribute(idAttribute), topLevelTag, new MutableOptional<>(), root)); - else - steps.addAll(readNonInstanceSteps(topLevelTag, new MutableOptional<>(), topLevelTag)); // (No global service id here) - } - } - - return new DeploymentSpec(steps, - optionalIntegerAttribute(majorVersionTag, root), - xmlForm); - } - /** - * Reads the content of an (implicit or explicit) instance tag producing an instances step - * - * @param instanceNameString a comma-separated list of the names of the instances this is for - * @param instanceTag the element having the content of this instance - * @param parentTag the parent of instanceTag (or the same, if this instances is implicitly defined which means instanceTag is the root) - * @return the instances specified, one for each instance name element + * Reads a deployment spec from XML */ - private List readInstanceContent(String instanceNameString, - Element instanceTag, - MutableOptional globalServiceId, - Element parentTag) { - if (validate) - validateTagOrder(instanceTag); - - // Values where the parent may provide a default - DeploymentSpec.UpgradePolicy upgradePolicy = readUpgradePolicy(instanceTag, parentTag); - List changeBlockers = readChangeBlockers(instanceTag, parentTag); - Optional athenzDomain = stringAttribute(athenzDomainAttribute, instanceTag) - .or(() -> stringAttribute(athenzDomainAttribute, parentTag)) - .map(AthenzDomain::from); - Optional athenzService = stringAttribute(athenzServiceAttribute, instanceTag) - .or(() -> stringAttribute(athenzServiceAttribute, parentTag)) - .map(AthenzService::from); - Notifications notifications = readNotifications(instanceTag, parentTag); - - // Values where there is no default + public DeploymentSpec read(String xmlForm) { List steps = new ArrayList<>(); - for (Element instanceChild : XML.getChildren(instanceTag)) - steps.addAll(readNonInstanceSteps(instanceChild, globalServiceId, instanceChild)); - List endpoints = readEndpoints(instanceTag); - - // Build and return instances with these values - return Arrays.stream(instanceNameString.split(",")) - .map(name -> name.trim()) - .map(name -> new DeploymentInstanceSpec(InstanceName.from(name), - steps, - upgradePolicy, - changeBlockers, - globalServiceId.asOptional(), - athenzDomain, - athenzService, - notifications, - endpoints)) - .collect(Collectors.toList()); - } - - private List readSteps(Element stepTag, MutableOptional globalServiceId, Element parentTag) { - if (stepTag.getTagName().equals(instanceTag)) - return new ArrayList<>(readInstanceContent(stepTag.getAttribute(idAttribute), stepTag, globalServiceId, parentTag)); - else - return readNonInstanceSteps(stepTag, globalServiceId, parentTag); - - } + Optional globalServiceId = Optional.empty(); + Element root = XML.getDocument(xmlForm).getDocumentElement(); + if (validate) + validateTagOrder(root); + for (Element environmentTag : XML.getChildren(root)) { + if (!isEnvironmentName(environmentTag.getTagName())) continue; + + Environment environment = Environment.from(environmentTag.getTagName()); + Optional athenzService = stringAttribute("athenz-service", environmentTag).map(AthenzService::from); + Optional testerFlavor = stringAttribute("tester-flavor", environmentTag); + + if (environment == Environment.prod) { + for (Element stepTag : XML.getChildren(environmentTag)) { + if (stepTag.getTagName().equals("delay")) { + steps.add(new Delay(Duration.ofSeconds(longAttribute("hours", stepTag) * 60 * 60 + + longAttribute("minutes", stepTag) * 60 + + longAttribute("seconds", stepTag)))); + } + else if (stepTag.getTagName().equals("parallel")) { + List zones = new ArrayList<>(); + for (Element regionTag : XML.getChildren(stepTag)) { + zones.add(readDeclaredZone(environment, athenzService, testerFlavor, regionTag)); + } + steps.add(new ParallelZones(zones)); + } + else { // a region: deploy step + steps.add(readDeclaredZone(environment, athenzService, testerFlavor, stepTag)); + } + } + } + else { + steps.add(new DeclaredZone(environment, Optional.empty(), false, athenzService, testerFlavor)); + } - // Consume the given tag as 0-N steps. 0 if it is not a step, >1 if it contains multiple nested steps that should be flattened - private List readNonInstanceSteps(Element stepTag, MutableOptional globalServiceId, Element parentTag) { - Optional athenzService = stringAttribute(athenzServiceAttribute, stepTag) - .or(() -> stringAttribute(athenzServiceAttribute, parentTag)) - .map(AthenzService::from); - Optional testerFlavor = stringAttribute(testerFlavorAttribute, stepTag) - .or(() -> stringAttribute(testerFlavorAttribute, parentTag)); - - if (prodTag.equals(stepTag.getTagName())) - globalServiceId.set(readGlobalServiceId(stepTag)); - else if (readGlobalServiceId(stepTag).isPresent()) - throw new IllegalArgumentException("Attribute 'global-service-id' is only valid on 'prod' tag."); - - switch (stepTag.getTagName()) { - case testTag: case stagingTag: - return List.of(new DeclaredZone(Environment.from(stepTag.getTagName()), Optional.empty(), false, athenzService, testerFlavor)); - case prodTag: // regions, delay and parallel may be nested within, but we can flatten them - return XML.getChildren(stepTag).stream() - .flatMap(child -> readNonInstanceSteps(child, globalServiceId, stepTag).stream()) - .collect(Collectors.toList()); - case delayTag: - return List.of(new Delay(Duration.ofSeconds(longAttribute("hours", stepTag) * 60 * 60 + - longAttribute("minutes", stepTag) * 60 + - longAttribute("seconds", stepTag)))); - case parallelTag: // regions and instances may be nested within - return List.of(new ParallelZones(XML.getChildren(stepTag).stream() - .flatMap(child -> readSteps(child, globalServiceId, stepTag).stream()) - .collect(Collectors.toList()))); - case regionTag: - return List.of(readDeclaredZone(Environment.prod, athenzService, testerFlavor, stepTag)); - default: - return List.of(); - } - } + if (environment == Environment.prod) + globalServiceId = readGlobalServiceId(environmentTag); + else if (readGlobalServiceId(environmentTag).isPresent()) + throw new IllegalArgumentException("Attribute 'global-service-id' is only valid on 'prod' tag."); - private boolean containsTag(String childTagName, Element parent) { - for (Element child : XML.getChildren(parent)) { - if (child.getTagName().equals(childTagName) || containsTag(childTagName, child)) - return true; } - return false; + Optional athenzDomain = stringAttribute("athenz-domain", root).map(AthenzDomain::from); + Optional athenzService = stringAttribute("athenz-service", root).map(AthenzService::from); + return new DeploymentSpec(globalServiceId, + readUpgradePolicy(root), + optionalIntegerAttribute(majorVersionTag, root), + readChangeBlockers(root), + steps, + xmlForm, + athenzDomain, + athenzService, + readNotifications(root), + readEndpoints(root)); } - private Notifications readNotifications(Element parent, Element fallbackParent) { - Element notificationsElement = XML.getChild(parent, notificationsTag); - if (notificationsElement == null) - notificationsElement = XML.getChild(fallbackParent, notificationsTag); + private Notifications readNotifications(Element root) { + Element notificationsElement = XML.getChild(root, "notifications"); if (notificationsElement == null) return Notifications.none(); @@ -237,17 +158,16 @@ public class DeploymentSpecXmlReader { return Notifications.of(emailAddresses, emailRoles); } - private List readEndpoints(Element parent) { - var endpointsElement = XML.getChild(parent, endpointsTag); - if (endpointsElement == null) - return Collections.emptyList(); + private List readEndpoints(Element root) { + final var endpointsElement = XML.getChild(root, endpointsTag); + if (endpointsElement == null) { return Collections.emptyList(); } - var endpoints = new LinkedHashMap(); + final var endpoints = new LinkedHashMap(); for (var endpointElement : XML.getChildren(endpointsElement, endpointTag)) { - Optional rotationId = stringAttribute("id", endpointElement); - Optional containerId = stringAttribute("container-id", endpointElement); - var regions = new HashSet(); + final Optional rotationId = stringAttribute("id", endpointElement); + final Optional containerId = stringAttribute("container-id", endpointElement); + final var regions = new HashSet(); if (containerId.isEmpty()) { throw new IllegalArgumentException("Missing 'container-id' from 'endpoint' tag."); @@ -335,6 +255,10 @@ public class DeploymentSpecXmlReader { return Optional.ofNullable(value).filter(s -> !s.equals("")); } + private boolean isEnvironmentName(String tagName) { + return tagName.equals(testTag) || tagName.equals(stagingTag) || tagName.equals(prodTag); + } + private DeclaredZone readDeclaredZone(Environment environment, Optional athenzService, Optional testerFlavor, Element regionTag) { return new DeclaredZone(environment, Optional.of(RegionName.from(XML.getValue(regionTag).trim())), @@ -343,44 +267,44 @@ public class DeploymentSpecXmlReader { private Optional readGlobalServiceId(Element environmentTag) { String globalServiceId = environmentTag.getAttribute("global-service-id"); - if (globalServiceId == null || globalServiceId.isEmpty()) return Optional.empty(); - return Optional.of(globalServiceId); + if (globalServiceId == null || globalServiceId.isEmpty()) { + return Optional.empty(); + } + else { + return Optional.of(globalServiceId); + } } - private List readChangeBlockers(Element parent, Element globalBlockersParent) { + private List readChangeBlockers(Element root) { List changeBlockers = new ArrayList<>(); - if (globalBlockersParent != parent) { - for (Element tag : XML.getChildren(globalBlockersParent, blockChangeTag)) - changeBlockers.add(readChangeBlocker(tag)); - } - for (Element tag : XML.getChildren(parent, blockChangeTag)) - changeBlockers.add(readChangeBlocker(tag)); - return Collections.unmodifiableList(changeBlockers); - } + for (Element tag : XML.getChildren(root)) { + if (!blockChangeTag.equals(tag.getTagName())) continue; - private DeploymentSpec.ChangeBlocker readChangeBlocker(Element tag) { - boolean blockVersions = trueOrMissing(tag.getAttribute("version")); - boolean blockRevisions = trueOrMissing(tag.getAttribute("revision")); + boolean blockVersions = trueOrMissing(tag.getAttribute("version")); + boolean blockRevisions = trueOrMissing(tag.getAttribute("revision")); - String daySpec = tag.getAttribute("days"); - String hourSpec = tag.getAttribute("hours"); - String zoneSpec = tag.getAttribute("time-zone"); - if (zoneSpec.isEmpty()) zoneSpec = "UTC"; // default - return new DeploymentSpec.ChangeBlocker(blockRevisions, blockVersions, - TimeWindow.from(daySpec, hourSpec, zoneSpec)); + String daySpec = tag.getAttribute("days"); + String hourSpec = tag.getAttribute("hours"); + String zoneSpec = tag.getAttribute("time-zone"); + if (zoneSpec.isEmpty()) { // Default to UTC time zone + zoneSpec = "UTC"; + } + changeBlockers.add(new DeploymentSpec.ChangeBlocker(blockRevisions, blockVersions, + TimeWindow.from(daySpec, hourSpec, zoneSpec))); + } + return Collections.unmodifiableList(changeBlockers); } - /** Returns true if the given value is "true", or if it is missing */ + /** + * Returns true if the given value is "true", or if it is missing + */ private boolean trueOrMissing(String value) { return value == null || value.isEmpty() || value.equals("true"); } - private DeploymentSpec.UpgradePolicy readUpgradePolicy(Element parent, Element fallbackParent) { - Element upgradeElement = XML.getChild(parent, upgradeTag); - if (upgradeElement == null) - upgradeElement = XML.getChild(fallbackParent, upgradeTag); - if (upgradeElement == null) - return DeploymentSpec.UpgradePolicy.defaultPolicy; + private DeploymentSpec.UpgradePolicy readUpgradePolicy(Element root) { + Element upgradeElement = XML.getChild(root, "upgrade"); + if (upgradeElement == null) return DeploymentSpec.UpgradePolicy.defaultPolicy; String policy = upgradeElement.getAttribute("policy"); switch (policy) { @@ -400,14 +324,4 @@ public class DeploymentSpecXmlReader { "to control whether the region should receive production traffic"); } - private static class MutableOptional { - - private Optional value = Optional.empty(); - - public void set(Optional value) { this.value = value; } - - public Optional asOptional() { return value; } - - } - } diff --git a/config-model-api/src/test/java/com/yahoo/config/application/api/DeploymentSpecDeprecatedAPITest.java b/config-model-api/src/test/java/com/yahoo/config/application/api/DeploymentSpecDeprecatedAPITest.java deleted file mode 100644 index dabdd0c4a69..00000000000 --- a/config-model-api/src/test/java/com/yahoo/config/application/api/DeploymentSpecDeprecatedAPITest.java +++ /dev/null @@ -1,572 +0,0 @@ -// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -package com.yahoo.config.application.api; - -import com.google.common.collect.ImmutableSet; -import com.yahoo.config.provision.Environment; -import com.yahoo.config.provision.RegionName; -import org.junit.Test; - -import java.io.StringReader; -import java.time.Instant; -import java.time.ZoneId; -import java.util.Collections; -import java.util.List; -import java.util.Optional; -import java.util.Set; -import java.util.stream.Collectors; - -import static com.yahoo.config.application.api.Notifications.Role.author; -import static com.yahoo.config.application.api.Notifications.When.failing; -import static com.yahoo.config.application.api.Notifications.When.failingCommit; -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertFalse; -import static org.junit.Assert.assertTrue; -import static org.junit.Assert.fail; - -/** - * @author bratseth - */ -// TODO: Remove after October 2019 -public class DeploymentSpecDeprecatedAPITest { - - @Test - public void testSpec() { - String specXml = "" + - " " + - ""; - - StringReader r = new StringReader(specXml); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(specXml, spec.xmlForm()); - assertEquals(1, spec.steps().size()); - assertFalse(spec.majorVersion().isPresent()); - assertTrue(spec.steps().get(0).deploysTo(Environment.test)); - assertTrue(spec.includes(Environment.test, Optional.empty())); - assertFalse(spec.includes(Environment.test, Optional.of(RegionName.from("region1")))); - assertFalse(spec.includes(Environment.staging, Optional.empty())); - assertFalse(spec.includes(Environment.prod, Optional.empty())); - assertFalse(spec.globalServiceId().isPresent()); - } - - @Test - public void testSpecPinningMajorVersion() { - String specXml = "" + - " " + - ""; - - StringReader r = new StringReader(specXml); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(specXml, spec.xmlForm()); - assertEquals(1, spec.steps().size()); - assertTrue(spec.majorVersion().isPresent()); - assertEquals(6, (int)spec.majorVersion().get()); - } - - @Test - public void stagingSpec() { - StringReader r = new StringReader( - "" + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(2, spec.steps().size()); - assertTrue(spec.steps().get(0).deploysTo(Environment.test)); - assertTrue(spec.steps().get(1).deploysTo(Environment.staging)); - assertTrue(spec.includes(Environment.test, Optional.empty())); - assertFalse(spec.includes(Environment.test, Optional.of(RegionName.from("region1")))); - assertTrue(spec.includes(Environment.staging, Optional.empty())); - assertFalse(spec.includes(Environment.prod, Optional.empty())); - assertFalse(spec.globalServiceId().isPresent()); - } - - @Test - public void minimalProductionSpec() { - StringReader r = new StringReader( - "" + - " " + - " us-east1" + - " us-west1" + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(4, spec.steps().size()); - - assertTrue(spec.steps().get(0).deploysTo(Environment.test)); - - assertTrue(spec.steps().get(1).deploysTo(Environment.staging)); - - assertTrue(spec.steps().get(2).deploysTo(Environment.prod, Optional.of(RegionName.from("us-east1")))); - assertFalse(((DeploymentSpec.DeclaredZone)spec.steps().get(2)).active()); - - assertTrue(spec.steps().get(3).deploysTo(Environment.prod, Optional.of(RegionName.from("us-west1")))); - assertTrue(((DeploymentSpec.DeclaredZone)spec.steps().get(3)).active()); - - assertTrue(spec.includes(Environment.test, Optional.empty())); - assertFalse(spec.includes(Environment.test, Optional.of(RegionName.from("region1")))); - assertTrue(spec.includes(Environment.staging, Optional.empty())); - assertTrue(spec.includes(Environment.prod, Optional.of(RegionName.from("us-east1")))); - assertTrue(spec.includes(Environment.prod, Optional.of(RegionName.from("us-west1")))); - assertFalse(spec.includes(Environment.prod, Optional.of(RegionName.from("no-such-region")))); - assertFalse(spec.globalServiceId().isPresent()); - - assertEquals(DeploymentSpec.UpgradePolicy.defaultPolicy, spec.upgradePolicy()); - } - - @Test - public void maximalProductionSpec() { - StringReader r = new StringReader( - "" + - " " + - " " + - " " + - " us-east1" + - " " + - " us-west1" + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(5, spec.steps().size()); - assertEquals(4, spec.zones().size()); - - assertTrue(spec.steps().get(0).deploysTo(Environment.test)); - - assertTrue(spec.steps().get(1).deploysTo(Environment.staging)); - - assertTrue(spec.steps().get(2).deploysTo(Environment.prod, Optional.of(RegionName.from("us-east1")))); - assertFalse(((DeploymentSpec.DeclaredZone)spec.steps().get(2)).active()); - - assertTrue(spec.steps().get(3) instanceof DeploymentSpec.Delay); - assertEquals(3 * 60 * 60 + 30 * 60, ((DeploymentSpec.Delay)spec.steps().get(3)).duration().getSeconds()); - - assertTrue(spec.steps().get(4).deploysTo(Environment.prod, Optional.of(RegionName.from("us-west1")))); - assertTrue(((DeploymentSpec.DeclaredZone)spec.steps().get(4)).active()); - - assertTrue(spec.includes(Environment.test, Optional.empty())); - assertFalse(spec.includes(Environment.test, Optional.of(RegionName.from("region1")))); - assertTrue(spec.includes(Environment.staging, Optional.empty())); - assertTrue(spec.includes(Environment.prod, Optional.of(RegionName.from("us-east1")))); - assertTrue(spec.includes(Environment.prod, Optional.of(RegionName.from("us-west1")))); - assertFalse(spec.includes(Environment.prod, Optional.of(RegionName.from("no-such-region")))); - assertFalse(spec.globalServiceId().isPresent()); - } - - @Test - public void productionSpecWithGlobalServiceId() { - StringReader r = new StringReader( - "" + - " " + - " us-east-1" + - " us-west-1" + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(spec.globalServiceId(), Optional.of("query")); - } - - @Test(expected=IllegalArgumentException.class) - public void globalServiceIdInTest() { - StringReader r = new StringReader( - "" + - " " + - "" - ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - } - - @Test(expected=IllegalArgumentException.class) - public void globalServiceIdInStaging() { - StringReader r = new StringReader( - "" + - " " + - "" - ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - } - - @Test - public void productionSpecWithGlobalServiceIdBeforeStaging() { - StringReader r = new StringReader( - "" + - " " + - " " + - " us-west-1" + - " us-central-1" + - " us-east-3" + - " " + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals("qrs", spec.globalServiceId().get()); - } - - @Test - public void productionSpecWithUpgradePolicy() { - StringReader r = new StringReader( - "" + - " " + - " " + - " us-west-1" + - " us-central-1" + - " us-east-3" + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals("canary", spec.upgradePolicy().toString()); - } - - @Test - public void maxDelayExceeded() { - try { - StringReader r = new StringReader( - "" + - " " + - " " + - " us-west-1" + - " " + - " us-central-1" + - " " + - " us-east-3" + - " " + - "" - ); - DeploymentSpec.fromXml(r); - fail("Expected exception due to exceeding the max total delay"); - } - catch (IllegalArgumentException e) { - // success - assertEquals("The total delay specified is PT24H1S but max 24 hours is allowed", e.getMessage()); - } - } - - @Test - public void testEmpty() { - assertFalse(DeploymentSpec.empty.globalServiceId().isPresent()); - assertEquals(DeploymentSpec.UpgradePolicy.defaultPolicy, DeploymentSpec.empty.upgradePolicy()); - assertTrue(DeploymentSpec.empty.steps().isEmpty()); - assertEquals("", DeploymentSpec.empty.xmlForm()); - } - - @Test - public void productionSpecWithParallelDeployments() { - StringReader r = new StringReader( - "\n" + - " \n" + - " us-west-1\n" + - " \n" + - " us-central-1\n" + - " us-east-3\n" + - " \n" + - " \n" + - "" - ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - DeploymentSpec.ParallelZones parallelZones = ((DeploymentSpec.ParallelZones) spec.steps().get(3)); - assertEquals(2, parallelZones.zones().size()); - assertEquals(RegionName.from("us-central-1"), parallelZones.zones().get(0).region().get()); - assertEquals(RegionName.from("us-east-3"), parallelZones.zones().get(1).region().get()); - } - - @Test - public void productionSpecWithDuplicateRegions() { - StringReader r = new StringReader( - "\n" + - " \n" + - " us-west-1\n" + - " \n" + - " us-west-1\n" + - " us-central-1\n" + - " us-east-3\n" + - " \n" + - " \n" + - "" - ); - try { - DeploymentSpec.fromXml(r); - fail("Expected exception"); - } catch (IllegalArgumentException e) { - assertEquals("prod.us-west-1 is listed twice in deployment.xml", e.getMessage()); - } - } - - @Test(expected = IllegalArgumentException.class) - public void deploymentSpecWithIllegallyOrderedDeploymentSpec1() { - StringReader r = new StringReader( - "\n" + - " \n" + - " \n" + - " us-west-1\n" + - " \n" + - " \n" + - "" - ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - } - - @Test(expected = IllegalArgumentException.class) - public void deploymentSpecWithIllegallyOrderedDeploymentSpec2() { - StringReader r = new StringReader( - "\n" + - " \n" + - " \n" + - " \n" + - " us-west-1\n" + - " \n" + - "" - ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - } - - @Test - public void deploymentSpecWithChangeBlocker() { - StringReader r = new StringReader( - "\n" + - " \n" + - " \n" + - " \n" + - " us-west-1\n" + - " \n" + - "" - ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(2, spec.changeBlocker().size()); - assertTrue(spec.changeBlocker().get(0).blocksVersions()); - assertFalse(spec.changeBlocker().get(0).blocksRevisions()); - assertEquals(ZoneId.of("UTC"), spec.changeBlocker().get(0).window().zone()); - - assertTrue(spec.changeBlocker().get(1).blocksVersions()); - assertTrue(spec.changeBlocker().get(1).blocksRevisions()); - assertEquals(ZoneId.of("CET"), spec.changeBlocker().get(1).window().zone()); - - assertTrue(spec.canUpgradeAt(Instant.parse("2017-09-18T14:15:30.00Z"))); - assertFalse(spec.canUpgradeAt(Instant.parse("2017-09-18T15:15:30.00Z"))); - assertFalse(spec.canUpgradeAt(Instant.parse("2017-09-18T16:15:30.00Z"))); - assertTrue(spec.canUpgradeAt(Instant.parse("2017-09-18T17:15:30.00Z"))); - - assertTrue(spec.canUpgradeAt(Instant.parse("2017-09-23T09:15:30.00Z"))); - assertFalse(spec.canUpgradeAt(Instant.parse("2017-09-23T08:15:30.00Z"))); // 10 in CET - assertTrue(spec.canUpgradeAt(Instant.parse("2017-09-23T10:15:30.00Z"))); - } - - @Test - public void athenz_config_is_read_from_deployment() { - StringReader r = new StringReader( - "\n" + - " \n" + - " us-west-1\n" + - " \n" + - "" - ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(spec.athenzDomain().get().value(), "domain"); - assertEquals(spec.athenzService(Environment.prod, RegionName.from("us-west-1")).get().value(), "service"); - } - - @Test - public void athenz_service_is_overridden_from_environment() { - StringReader r = new StringReader( - "\n" + - " \n" + - " \n" + - " us-west-1\n" + - " \n" + - "" - ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(spec.athenzDomain().get().value(), "domain"); - assertEquals(spec.athenzService(Environment.prod, RegionName.from("us-west-1")).get().value(), "prod-service"); - } - - @Test(expected = IllegalArgumentException.class) - public void it_fails_when_athenz_service_is_not_defined() { - StringReader r = new StringReader( - "\n" + - " \n" + - " us-west-1\n" + - " \n" + - "" - ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - } - - @Test(expected = IllegalArgumentException.class) - public void it_fails_when_athenz_service_is_configured_but_not_athenz_domain() { - StringReader r = new StringReader( - "\n" + - " \n" + - " us-west-1\n" + - " \n" + - "" - ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - } - - @Test - public void noNotifications() { - assertEquals(Notifications.none(), - DeploymentSpec.fromXml("").notifications()); - } - - @Test - public void emptyNotifications() { - DeploymentSpec spec = DeploymentSpec.fromXml("\n" + - " " + - ""); - assertEquals(Notifications.none(), - spec.notifications()); - } - - @Test - public void someNotifications() { - DeploymentSpec spec = DeploymentSpec.fromXml("\n" + - " \n" + - " \n" + - " \n" + - " \n" + - " \n" + - ""); - assertEquals(ImmutableSet.of(author), spec.notifications().emailRolesFor(failing)); - assertEquals(ImmutableSet.of(author), spec.notifications().emailRolesFor(failingCommit)); - assertEquals(ImmutableSet.of("john@dev", "jane@dev"), spec.notifications().emailAddressesFor(failingCommit)); - assertEquals(ImmutableSet.of("jane@dev"), spec.notifications().emailAddressesFor(failing)); - } - - @Test - public void customTesterFlavor() { - DeploymentSpec spec = DeploymentSpec.fromXml("\n" + - " \n" + - " \n" + - " us-north-7\n" + - " \n" + - ""); - assertEquals(Optional.of("d-1-4-20"), spec.steps().get(0).zones().get(0).testerFlavor()); - assertEquals(Optional.empty(), spec.steps().get(1).zones().get(0).testerFlavor()); - assertEquals(Optional.of("d-2-8-50"), spec.steps().get(2).zones().get(0).testerFlavor()); - } - - @Test - public void noEndpoints() { - assertEquals(Collections.emptyList(), DeploymentSpec.fromXml("").endpoints()); - } - - @Test - public void emptyEndpoints() { - final var spec = DeploymentSpec.fromXml(""); - assertEquals(Collections.emptyList(), spec.endpoints()); - } - - @Test - public void someEndpoints() { - final var spec = DeploymentSpec.fromXml("" + - "" + - " " + - " us-east" + - " " + - " " + - " " + - " us-east" + - " " + - " " + - " " + - " " + - ""); - - assertEquals( - List.of("foo", "nalle", "default"), - spec.endpoints().stream().map(Endpoint::endpointId).collect(Collectors.toList()) - ); - - assertEquals( - List.of("bar", "frosk", "quux"), - spec.endpoints().stream().map(Endpoint::containerId).collect(Collectors.toList()) - ); - - assertEquals(Set.of(RegionName.from("us-east")), spec.endpoints().get(0).regions()); - } - @Test - public void invalidEndpoints() { - assertInvalid(""); // Uppercase - assertInvalid(""); // Starting with non-character - assertInvalid(""); // Non-alphanumeric - assertInvalid(""); - assertInvalid(""); // Multiple consecutive dashes - assertInvalid(""); // Trailing dash - assertInvalid(""); // Too long - assertInvalid(""); // Duplicate - } - - @Test - public void validEndpoints() { - assertEquals(List.of("default"), endpointIds("")); - assertEquals(List.of("default"), endpointIds("")); - assertEquals(List.of("f"), endpointIds("")); - assertEquals(List.of("foo"), endpointIds("")); - assertEquals(List.of("foo-bar"), endpointIds("")); - assertEquals(List.of("foo", "bar"), endpointIds("")); - assertEquals(List.of("fooooooooooo"), endpointIds("")); - } - - @Test - public void endpointDefaultRegions() { - var spec = DeploymentSpec.fromXml("" + - "" + - " " + - " us-east" + - " us-west" + - " " + - " " + - " " + - " us-east" + - " " + - " " + - " " + - " " + - ""); - - assertEquals(Set.of("us-east"), endpointRegions("foo", spec)); - assertEquals(Set.of("us-east", "us-west"), endpointRegions("nalle", spec)); - assertEquals(Set.of("us-east", "us-west"), endpointRegions("default", spec)); - } - - private static void assertInvalid(String endpointTag) { - try { - endpointIds(endpointTag); - fail("Expected exception for input '" + endpointTag + "'"); - } catch (IllegalArgumentException ignored) {} - } - - private static Set endpointRegions(String endpointId, DeploymentSpec spec) { - return spec.endpoints().stream() - .filter(endpoint -> endpoint.endpointId().equals(endpointId)) - .flatMap(endpoint -> endpoint.regions().stream()) - .map(RegionName::value) - .collect(Collectors.toSet()); - } - - private static List endpointIds(String endpointTag) { - var xml = "" + - " " + - " us-east" + - " " + - " " + - endpointTag + - " " + - ""; - - return DeploymentSpec.fromXml(xml).endpoints().stream() - .map(Endpoint::endpointId) - .collect(Collectors.toList()); - } - -} diff --git a/config-model-api/src/test/java/com/yahoo/config/application/api/DeploymentSpecTest.java b/config-model-api/src/test/java/com/yahoo/config/application/api/DeploymentSpecTest.java index b75801de7ea..47eaf7a515a 100644 --- a/config-model-api/src/test/java/com/yahoo/config/application/api/DeploymentSpecTest.java +++ b/config-model-api/src/test/java/com/yahoo/config/application/api/DeploymentSpecTest.java @@ -14,6 +14,7 @@ import java.util.List; import java.util.Optional; import java.util.Set; import java.util.stream.Collectors; +import java.util.stream.Stream; import static com.yahoo.config.application.api.Notifications.Role.author; import static com.yahoo.config.application.api.Notifications.When.failing; @@ -31,36 +32,32 @@ public class DeploymentSpecTest { @Test public void testSpec() { String specXml = "" + - " " + - " " + - " " + + " " + ""; StringReader r = new StringReader(specXml); DeploymentSpec spec = DeploymentSpec.fromXml(r); assertEquals(specXml, spec.xmlForm()); - assertEquals(1, spec.instance("default").steps().size()); + assertEquals(1, spec.steps().size()); assertFalse(spec.majorVersion().isPresent()); - assertTrue(spec.instance("default").steps().get(0).deploysTo(Environment.test)); - assertTrue(spec.instance("default").includes(Environment.test, Optional.empty())); - assertFalse(spec.instance("default").includes(Environment.test, Optional.of(RegionName.from("region1")))); - assertFalse(spec.instance("default").includes(Environment.staging, Optional.empty())); - assertFalse(spec.instance("default").includes(Environment.prod, Optional.empty())); - assertFalse(spec.instance("default").globalServiceId().isPresent()); + assertTrue(spec.steps().get(0).deploysTo(Environment.test)); + assertTrue(spec.includes(Environment.test, Optional.empty())); + assertFalse(spec.includes(Environment.test, Optional.of(RegionName.from("region1")))); + assertFalse(spec.includes(Environment.staging, Optional.empty())); + assertFalse(spec.includes(Environment.prod, Optional.empty())); + assertFalse(spec.globalServiceId().isPresent()); } @Test public void testSpecPinningMajorVersion() { String specXml = "" + - " " + - " " + - " " + + " " + ""; StringReader r = new StringReader(specXml); DeploymentSpec spec = DeploymentSpec.fromXml(r); assertEquals(specXml, spec.xmlForm()); - assertEquals(1, spec.instance("default").steps().size()); + assertEquals(1, spec.steps().size()); assertTrue(spec.majorVersion().isPresent()); assertEquals(6, (int)spec.majorVersion().get()); } @@ -69,256 +66,164 @@ public class DeploymentSpecTest { public void stagingSpec() { StringReader r = new StringReader( "" + - " " + - " " + - " " + + " " + "" ); DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(2, spec.instance("default").steps().size()); - assertTrue(spec.instance("default").steps().get(0).deploysTo(Environment.test)); - assertTrue(spec.instance("default").steps().get(1).deploysTo(Environment.staging)); - assertTrue(spec.instance("default").includes(Environment.test, Optional.empty())); - assertFalse(spec.instance("default").includes(Environment.test, Optional.of(RegionName.from("region1")))); - assertTrue(spec.instance("default").includes(Environment.staging, Optional.empty())); - assertFalse(spec.instance("default").includes(Environment.prod, Optional.empty())); - assertFalse(spec.instance("default").globalServiceId().isPresent()); + assertEquals(2, spec.steps().size()); + assertTrue(spec.steps().get(0).deploysTo(Environment.test)); + assertTrue(spec.steps().get(1).deploysTo(Environment.staging)); + assertTrue(spec.includes(Environment.test, Optional.empty())); + assertFalse(spec.includes(Environment.test, Optional.of(RegionName.from("region1")))); + assertTrue(spec.includes(Environment.staging, Optional.empty())); + assertFalse(spec.includes(Environment.prod, Optional.empty())); + assertFalse(spec.globalServiceId().isPresent()); } @Test public void minimalProductionSpec() { StringReader r = new StringReader( - "" + - " " + - " " + - " us-east1" + - " us-west1" + - " " + - " " + - "" + "" + + " " + + " us-east1" + + " us-west1" + + " " + + "" ); DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(4, spec.instance("default").steps().size()); - - assertTrue(spec.instance("default").steps().get(0).deploysTo(Environment.test)); + assertEquals(4, spec.steps().size()); - assertTrue(spec.instance("default").steps().get(1).deploysTo(Environment.staging)); + assertTrue(spec.steps().get(0).deploysTo(Environment.test)); - assertTrue(spec.instance("default").steps().get(2).deploysTo(Environment.prod, Optional.of(RegionName.from("us-east1")))); - assertFalse(((DeploymentSpec.DeclaredZone)spec.instance("default").steps().get(2)).active()); + assertTrue(spec.steps().get(1).deploysTo(Environment.staging)); - assertTrue(spec.instance("default").steps().get(3).deploysTo(Environment.prod, Optional.of(RegionName.from("us-west1")))); - assertTrue(((DeploymentSpec.DeclaredZone)spec.instance("default").steps().get(3)).active()); + assertTrue(spec.steps().get(2).deploysTo(Environment.prod, Optional.of(RegionName.from("us-east1")))); + assertFalse(((DeploymentSpec.DeclaredZone)spec.steps().get(2)).active()); - assertTrue(spec.instance("default").includes(Environment.test, Optional.empty())); - assertFalse(spec.instance("default").includes(Environment.test, Optional.of(RegionName.from("region1")))); - assertTrue(spec.instance("default").includes(Environment.staging, Optional.empty())); - assertTrue(spec.instance("default").includes(Environment.prod, Optional.of(RegionName.from("us-east1")))); - assertTrue(spec.instance("default").includes(Environment.prod, Optional.of(RegionName.from("us-west1")))); - assertFalse(spec.instance("default").includes(Environment.prod, Optional.of(RegionName.from("no-such-region")))); - assertFalse(spec.instance("default").globalServiceId().isPresent()); + assertTrue(spec.steps().get(3).deploysTo(Environment.prod, Optional.of(RegionName.from("us-west1")))); + assertTrue(((DeploymentSpec.DeclaredZone)spec.steps().get(3)).active()); - assertEquals(DeploymentSpec.UpgradePolicy.defaultPolicy, spec.instance("default").upgradePolicy()); + assertTrue(spec.includes(Environment.test, Optional.empty())); + assertFalse(spec.includes(Environment.test, Optional.of(RegionName.from("region1")))); + assertTrue(spec.includes(Environment.staging, Optional.empty())); + assertTrue(spec.includes(Environment.prod, Optional.of(RegionName.from("us-east1")))); + assertTrue(spec.includes(Environment.prod, Optional.of(RegionName.from("us-west1")))); + assertFalse(spec.includes(Environment.prod, Optional.of(RegionName.from("no-such-region")))); + assertFalse(spec.globalServiceId().isPresent()); + + assertEquals(DeploymentSpec.UpgradePolicy.defaultPolicy, spec.upgradePolicy()); } @Test public void maximalProductionSpec() { StringReader r = new StringReader( - "" + - " " + // The block checked by assertCorrectFirstInstance - " " + - " " + - " " + - " us-east1" + - " " + - " us-west1" + - " " + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertCorrectFirstInstance(spec.instance("default")); - } - - @Test - public void maximalProductionSpecMultipleInstances() { - StringReader r = new StringReader( - "" + - " " + // The block checked by assertCorrectFirstInstance - " " + - " " + - " " + - " us-east1" + - " " + - " us-west1" + - " " + - " " + - " " + - " " + - " us-central1" + - " " + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - - assertCorrectFirstInstance(spec.instance("instance1")); - - DeploymentInstanceSpec instance2 = spec.instance("instance2"); - assertEquals(1, instance2.steps().size()); - assertEquals(1, instance2.zones().size()); - - assertTrue(instance2.steps().get(0).deploysTo(Environment.prod, Optional.of(RegionName.from("us-central1")))); - } - - @Test - public void testMultipleInstancesShortForm() { - StringReader r = new StringReader( - "" + - " " + // The block checked by assertCorrectFirstInstance - " " + - " " + - " " + - " us-east1" + - " " + - " us-west1" + - " " + - " " + - "" + "" + + " " + + " " + + " " + + " us-east1" + + " " + + " us-west1" + + " " + + "" ); DeploymentSpec spec = DeploymentSpec.fromXml(r); + assertEquals(5, spec.steps().size()); + assertEquals(4, spec.zones().size()); - assertCorrectFirstInstance(spec.instance("instance1")); - assertCorrectFirstInstance(spec.instance("instance2")); - } - - private void assertCorrectFirstInstance(DeploymentInstanceSpec instance) { - assertEquals(5, instance.steps().size()); - assertEquals(4, instance.zones().size()); - - assertTrue(instance.steps().get(0).deploysTo(Environment.test)); + assertTrue(spec.steps().get(0).deploysTo(Environment.test)); - assertTrue(instance.steps().get(1).deploysTo(Environment.staging)); + assertTrue(spec.steps().get(1).deploysTo(Environment.staging)); - assertTrue(instance.steps().get(2).deploysTo(Environment.prod, Optional.of(RegionName.from("us-east1")))); - assertFalse(((DeploymentSpec.DeclaredZone)instance.steps().get(2)).active()); + assertTrue(spec.steps().get(2).deploysTo(Environment.prod, Optional.of(RegionName.from("us-east1")))); + assertFalse(((DeploymentSpec.DeclaredZone)spec.steps().get(2)).active()); - assertTrue(instance.steps().get(3) instanceof DeploymentSpec.Delay); - assertEquals(3 * 60 * 60 + 30 * 60, instance.steps().get(3).delay().getSeconds()); + assertTrue(spec.steps().get(3) instanceof DeploymentSpec.Delay); + assertEquals(3 * 60 * 60 + 30 * 60, ((DeploymentSpec.Delay)spec.steps().get(3)).duration().getSeconds()); - assertTrue(instance.steps().get(4).deploysTo(Environment.prod, Optional.of(RegionName.from("us-west1")))); - assertTrue(((DeploymentSpec.DeclaredZone)instance.steps().get(4)).active()); + assertTrue(spec.steps().get(4).deploysTo(Environment.prod, Optional.of(RegionName.from("us-west1")))); + assertTrue(((DeploymentSpec.DeclaredZone)spec.steps().get(4)).active()); - assertTrue(instance.includes(Environment.test, Optional.empty())); - assertFalse(instance.includes(Environment.test, Optional.of(RegionName.from("region1")))); - assertTrue(instance.includes(Environment.staging, Optional.empty())); - assertTrue(instance.includes(Environment.prod, Optional.of(RegionName.from("us-east1")))); - assertTrue(instance.includes(Environment.prod, Optional.of(RegionName.from("us-west1")))); - assertFalse(instance.includes(Environment.prod, Optional.of(RegionName.from("no-such-region")))); - assertFalse(instance.globalServiceId().isPresent()); + assertTrue(spec.includes(Environment.test, Optional.empty())); + assertFalse(spec.includes(Environment.test, Optional.of(RegionName.from("region1")))); + assertTrue(spec.includes(Environment.staging, Optional.empty())); + assertTrue(spec.includes(Environment.prod, Optional.of(RegionName.from("us-east1")))); + assertTrue(spec.includes(Environment.prod, Optional.of(RegionName.from("us-west1")))); + assertFalse(spec.includes(Environment.prod, Optional.of(RegionName.from("no-such-region")))); + assertFalse(spec.globalServiceId().isPresent()); } @Test public void productionSpecWithGlobalServiceId() { StringReader r = new StringReader( "" + - " " + - " " + - " us-east-1" + - " us-west-1" + - " " + - " " + + " " + + " us-east-1" + + " us-west-1" + + " " + "" ); DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(spec.instance("default").globalServiceId(), Optional.of("query")); + assertEquals(spec.globalServiceId(), Optional.of("query")); } @Test(expected=IllegalArgumentException.class) public void globalServiceIdInTest() { StringReader r = new StringReader( "" + - " " + - " " + - " " + + " " + "" ); - DeploymentSpec.fromXml(r); + DeploymentSpec spec = DeploymentSpec.fromXml(r); } @Test(expected=IllegalArgumentException.class) public void globalServiceIdInStaging() { StringReader r = new StringReader( "" + - " " + - " " + - " " + + " " + "" ); - DeploymentSpec.fromXml(r); + DeploymentSpec spec = DeploymentSpec.fromXml(r); } @Test public void productionSpecWithGlobalServiceIdBeforeStaging() { StringReader r = new StringReader( "" + - " " + - " " + - " " + - " us-west-1" + - " us-central-1" + - " us-east-3" + - " " + - " " + - " " + + " " + + " " + + " us-west-1" + + " us-central-1" + + " us-east-3" + + " " + + " " + "" ); DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals("qrs", spec.instance("default").globalServiceId().get()); + assertEquals("qrs", spec.globalServiceId().get()); } @Test public void productionSpecWithUpgradePolicy() { StringReader r = new StringReader( "" + - " " + - " " + - " " + - " us-west-1" + - " us-central-1" + - " us-east-3" + - " " + - " " + + " " + + " " + + " us-west-1" + + " us-central-1" + + " us-east-3" + + " " + "" ); DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals("canary", spec.instance("default").upgradePolicy().toString()); - } - - @Test - public void upgradePolicyDefault() { - StringReader r = new StringReader( - "" + - " " + - " " + - " " + - " " + - " " + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals("conservative", spec.instance("instance1").upgradePolicy().toString()); - assertEquals("canary", spec.instance("instance2").upgradePolicy().toString()); + assertEquals("canary", spec.upgradePolicy().toString()); } @Test @@ -326,16 +231,14 @@ public class DeploymentSpecTest { try { StringReader r = new StringReader( "" + - " " + - " " + - " " + - " us-west-1" + - " " + - " us-central-1" + - " " + - " us-east-3" + - " " + - " " + + " " + + " " + + " us-west-1" + + " " + + " us-central-1" + + " " + + " us-east-3" + + " " + "" ); DeploymentSpec.fromXml(r); @@ -349,7 +252,7 @@ public class DeploymentSpecTest { @Test public void testEmpty() { - assertFalse(DeploymentSpec.empty.instance("default").globalServiceId().isPresent()); + assertFalse(DeploymentSpec.empty.globalServiceId().isPresent()); assertEquals(DeploymentSpec.UpgradePolicy.defaultPolicy, DeploymentSpec.empty.upgradePolicy()); assertTrue(DeploymentSpec.empty.steps().isEmpty()); assertEquals("", DeploymentSpec.empty.xmlForm()); @@ -358,139 +261,36 @@ public class DeploymentSpecTest { @Test public void productionSpecWithParallelDeployments() { StringReader r = new StringReader( - "" + - " " + - " " + - " us-west-1" + - " " + - " us-central-1" + - " us-east-3" + - " " + - " " + - " " + - "" + "\n" + + " \n" + + " us-west-1\n" + + " \n" + + " us-central-1\n" + + " us-east-3\n" + + " \n" + + " \n" + + "" ); DeploymentSpec spec = DeploymentSpec.fromXml(r); - DeploymentSpec.ParallelZones parallelZones = ((DeploymentSpec.ParallelZones) spec.instance("default").steps().get(3)); + DeploymentSpec.ParallelZones parallelZones = ((DeploymentSpec.ParallelZones) spec.steps().get(3)); assertEquals(2, parallelZones.zones().size()); assertEquals(RegionName.from("us-central-1"), parallelZones.zones().get(0).region().get()); assertEquals(RegionName.from("us-east-3"), parallelZones.zones().get(1).region().get()); } - @Test - public void testTestAndStagingOutsideAndInsideInstance() { - StringReader r = new StringReader( - "" + - " " + - " " + - " " + - " " + - " us-west-1" + - " " + - " " + - " " + - " " + - " " + - " " + - " us-west-1" + - " " + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - List steps = spec.steps(); - assertEquals(4, steps.size()); - assertEquals("test", steps.get(0).toString()); - assertEquals("staging", steps.get(1).toString()); - assertEquals("instance 'instance0'", steps.get(2).toString()); - assertEquals("instance 'instance1'", steps.get(3).toString()); - - List instance0Steps = ((DeploymentInstanceSpec)steps.get(2)).steps(); - assertEquals(1, instance0Steps.size()); - assertEquals("prod.us-west-1", instance0Steps.get(0).toString()); - - List instance1Steps = ((DeploymentInstanceSpec)steps.get(3)).steps(); - assertEquals(3, instance1Steps.size()); - assertEquals("test", instance1Steps.get(0).toString()); - assertEquals("staging", instance1Steps.get(1).toString()); - assertEquals("prod.us-west-1", instance1Steps.get(2).toString()); - } - - @Test - public void testParallelInstances() { - StringReader r = new StringReader( - "" + - " " + - " " + - " " + - " us-west-1" + - " " + - " " + - " " + - " " + - " us-east-3" + - " " + - " " + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - List steps = spec.steps(); - assertEquals(3, steps.size()); - assertEquals("test", steps.get(0).toString()); - assertEquals("staging", steps.get(1).toString()); - assertEquals("2 parallel steps", steps.get(2).toString()); - - List parallelSteps = steps.get(2).steps(); - assertEquals("instance 'instance0'", parallelSteps.get(0).toString()); - assertEquals("instance 'instance1'", parallelSteps.get(1).toString()); - } - - @Test - public void testInstancesWithDelay() { - StringReader r = new StringReader( - "" + - " " + - " " + - " us-west-1" + - " " + - " " + - " " + - " " + - " " + - " us-east-3" + - " " + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - List steps = spec.steps(); - assertEquals(5, steps.size()); - assertEquals("test", steps.get(0).toString()); - assertEquals("staging", steps.get(1).toString()); - assertEquals("instance 'instance0'", steps.get(2).toString()); - assertEquals("delay PT12H", steps.get(3).toString()); - assertEquals("instance 'instance1'", steps.get(4).toString()); - } - @Test public void productionSpecWithDuplicateRegions() { StringReader r = new StringReader( - "" + - " " + - " " + - " us-west-1" + - " " + - " us-west-1" + - " us-central-1" + - " us-east-3" + - " " + - " " + - " " + - "" + "\n" + + " \n" + + " us-west-1\n" + + " \n" + + " us-west-1\n" + + " us-central-1\n" + + " us-east-3\n" + + " \n" + + " \n" + + "" ); try { DeploymentSpec.fromXml(r); @@ -503,328 +303,197 @@ public class DeploymentSpecTest { @Test(expected = IllegalArgumentException.class) public void deploymentSpecWithIllegallyOrderedDeploymentSpec1() { StringReader r = new StringReader( - "" + - " " + - " " + - " " + - " us-west-1" + - " " + - " " + - " " + + "\n" + + " \n" + + " \n" + + " us-west-1\n" + + " \n" + + " \n" + "" ); - DeploymentSpec.fromXml(r); + DeploymentSpec spec = DeploymentSpec.fromXml(r); } @Test(expected = IllegalArgumentException.class) public void deploymentSpecWithIllegallyOrderedDeploymentSpec2() { StringReader r = new StringReader( "\n" + - " " + - " " + - " " + - " " + - " us-west-1" + - " " + - " " + - "" - ); - DeploymentSpec.fromXml(r); - } - - @Test - public void deploymentSpecWithChangeBlocker() { - StringReader r = new StringReader( - "" + - " " + - " " + - " " + - " " + - " us-west-1" + - " " + - " " + + " \n" + + " \n" + + " \n" + + " us-west-1\n" + + " \n" + "" ); DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(2, spec.instance("default").changeBlocker().size()); - assertTrue(spec.instance("default").changeBlocker().get(0).blocksVersions()); - assertFalse(spec.instance("default").changeBlocker().get(0).blocksRevisions()); - assertEquals(ZoneId.of("UTC"), spec.instance("default").changeBlocker().get(0).window().zone()); - - assertTrue(spec.instance("default").changeBlocker().get(1).blocksVersions()); - assertTrue(spec.instance("default").changeBlocker().get(1).blocksRevisions()); - assertEquals(ZoneId.of("CET"), spec.instance("default").changeBlocker().get(1).window().zone()); - - assertTrue(spec.instance("default").canUpgradeAt(Instant.parse("2017-09-18T14:15:30.00Z"))); - assertFalse(spec.instance("default").canUpgradeAt(Instant.parse("2017-09-18T15:15:30.00Z"))); - assertFalse(spec.instance("default").canUpgradeAt(Instant.parse("2017-09-18T16:15:30.00Z"))); - assertTrue(spec.instance("default").canUpgradeAt(Instant.parse("2017-09-18T17:15:30.00Z"))); - - assertTrue(spec.instance("default").canUpgradeAt(Instant.parse("2017-09-23T09:15:30.00Z"))); - assertFalse(spec.instance("default").canUpgradeAt(Instant.parse("2017-09-23T08:15:30.00Z"))); // 10 in CET - assertTrue(spec.instance("default").canUpgradeAt(Instant.parse("2017-09-23T10:15:30.00Z"))); } @Test - public void testChangeBlockerInheritance() { + public void deploymentSpecWithChangeBlocker() { StringReader r = new StringReader( - "" + - " " + - " " + - " " + - " " + - " " + - " " + + "\n" + + " \n" + + " \n" + + " \n" + + " us-west-1\n" + + " \n" + "" ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); + assertEquals(2, spec.changeBlocker().size()); + assertTrue(spec.changeBlocker().get(0).blocksVersions()); + assertFalse(spec.changeBlocker().get(0).blocksRevisions()); + assertEquals(ZoneId.of("UTC"), spec.changeBlocker().get(0).window().zone()); - String inheritedChangeBlocker = "change blocker revision=false version=true window=time window for hour(s) [15, 16] on [monday, tuesday] in UTC"; + assertTrue(spec.changeBlocker().get(1).blocksVersions()); + assertTrue(spec.changeBlocker().get(1).blocksRevisions()); + assertEquals(ZoneId.of("CET"), spec.changeBlocker().get(1).window().zone()); - assertEquals(2, spec.instance("instance1").changeBlocker().size()); - assertEquals(inheritedChangeBlocker, spec.instance("instance1").changeBlocker().get(0).toString()); - assertEquals("change blocker revision=true version=true window=time window for hour(s) [10] on [saturday] in CET", - spec.instance("instance1").changeBlocker().get(1).toString()); + assertTrue(spec.canUpgradeAt(Instant.parse("2017-09-18T14:15:30.00Z"))); + assertFalse(spec.canUpgradeAt(Instant.parse("2017-09-18T15:15:30.00Z"))); + assertFalse(spec.canUpgradeAt(Instant.parse("2017-09-18T16:15:30.00Z"))); + assertTrue(spec.canUpgradeAt(Instant.parse("2017-09-18T17:15:30.00Z"))); - assertEquals(1, spec.instance("instance2").changeBlocker().size()); - assertEquals(inheritedChangeBlocker, spec.instance("instance2").changeBlocker().get(0).toString()); + assertTrue(spec.canUpgradeAt(Instant.parse("2017-09-23T09:15:30.00Z"))); + assertFalse(spec.canUpgradeAt(Instant.parse("2017-09-23T08:15:30.00Z"))); // 10 in CET + assertTrue(spec.canUpgradeAt(Instant.parse("2017-09-23T10:15:30.00Z"))); } @Test public void athenz_config_is_read_from_deployment() { StringReader r = new StringReader( - "" + - " " + - " " + - " us-west-1" + - " " + - " " + + "\n" + + " \n" + + " us-west-1\n" + + " \n" + "" ); DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(spec.instance("instance1").athenzDomain().get().value(), "domain"); - assertEquals(spec.instance("instance1").athenzService(Environment.prod, RegionName.from("us-west-1")).get().value(), "service"); - } - - @Test - public void athenz_config_is_read_from_instance() { - StringReader r = new StringReader( - "" + - " " + - " " + - " us-west-1" + - " " + - " " + - "" - ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(spec.instance("default").athenzDomain().get().value(), "domain"); - assertEquals(spec.instance("default").athenzService(Environment.prod, RegionName.from("us-west-1")).get().value(), "service"); + assertEquals(spec.athenzDomain().get().value(), "domain"); + assertEquals(spec.athenzService(Environment.prod, RegionName.from("us-west-1")).get().value(), "service"); } @Test public void athenz_service_is_overridden_from_environment() { StringReader r = new StringReader( - "" + - " " + - " " + - " " + - " us-west-1" + - " " + - " " + + "\n" + + " \n" + + " \n" + + " us-west-1\n" + + " \n" + "" ); DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(spec.instance("default").athenzDomain().get().value(), "domain"); - assertEquals(spec.instance("default").athenzService(Environment.prod, RegionName.from("us-west-1")).get().value(), "prod-service"); + assertEquals(spec.athenzDomain().get().value(), "domain"); + assertEquals(spec.athenzService(Environment.prod, RegionName.from("us-west-1")).get().value(), "prod-service"); } @Test(expected = IllegalArgumentException.class) public void it_fails_when_athenz_service_is_not_defined() { StringReader r = new StringReader( - "" + - " " + - " " + - " us-west-1" + - " " + - " " + + "\n" + + " \n" + + " us-west-1\n" + + " \n" + "" ); - DeploymentSpec.fromXml(r); + DeploymentSpec spec = DeploymentSpec.fromXml(r); } @Test(expected = IllegalArgumentException.class) public void it_fails_when_athenz_service_is_configured_but_not_athenz_domain() { StringReader r = new StringReader( - "" + - " " + - " " + - " us-west-1" + - " " + - " " + + "\n" + + " \n" + + " us-west-1\n" + + " \n" + "" ); - DeploymentSpec.fromXml(r); + DeploymentSpec spec = DeploymentSpec.fromXml(r); } @Test public void noNotifications() { assertEquals(Notifications.none(), - DeploymentSpec.fromXml("" + - " " + - "").instance("default").notifications()); + DeploymentSpec.fromXml("").notifications()); } @Test public void emptyNotifications() { - DeploymentSpec spec = DeploymentSpec.fromXml("" + - " " + - " " + - " " + + DeploymentSpec spec = DeploymentSpec.fromXml("\n" + + " " + ""); - assertEquals(Notifications.none(), spec.instance("default").notifications()); + assertEquals(Notifications.none(), + spec.notifications()); } @Test public void someNotifications() { DeploymentSpec spec = DeploymentSpec.fromXml("\n" + - " " + - " " + - " " + - " " + - " " + - " " + - " " + + " \n" + + " \n" + + " \n" + + " \n" + + " \n" + ""); - assertEquals(ImmutableSet.of(author), spec.instance("default").notifications().emailRolesFor(failing)); - assertEquals(ImmutableSet.of(author), spec.instance("default").notifications().emailRolesFor(failingCommit)); - assertEquals(ImmutableSet.of("john@dev", "jane@dev"), spec.instance("default").notifications().emailAddressesFor(failingCommit)); - assertEquals(ImmutableSet.of("jane@dev"), spec.instance("default").notifications().emailAddressesFor(failing)); - } - - @Test - public void notificationsWithMultipleInstances() { - StringReader r = new StringReader( - "" + - " " + - " " + - " " + - " " + - " " + - " " + - " " + - " " + - " " + - " " + - " " + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - DeploymentInstanceSpec instance1 = spec.instance("instance1"); - assertEquals(Set.of(author), instance1.notifications().emailRolesFor(failing)); - assertEquals(Set.of("john@operator"), instance1.notifications().emailAddressesFor(failing)); - - DeploymentInstanceSpec instance2 = spec.instance("instance2"); - assertEquals(Set.of(author), instance2.notifications().emailRolesFor(failingCommit)); - assertEquals(Set.of("mary@dev"), instance2.notifications().emailAddressesFor(failingCommit)); - } - - @Test - public void notificationsDefault() { - StringReader r = new StringReader( - "" + - " " + - " " + - " " + - " " + - " " + - " " + - " " + - " " + - " " + - " " + - " " + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - DeploymentInstanceSpec instance1 = spec.instance("instance1"); - assertEquals(Set.of(author), instance1.notifications().emailRolesFor(failing)); - assertEquals(Set.of("john@operator"), instance1.notifications().emailAddressesFor(failing)); - - DeploymentInstanceSpec instance2 = spec.instance("instance2"); - assertEquals(Set.of(author), instance2.notifications().emailRolesFor(failingCommit)); - assertEquals(Set.of("mary@dev"), instance2.notifications().emailAddressesFor(failingCommit)); + assertEquals(ImmutableSet.of(author), spec.notifications().emailRolesFor(failing)); + assertEquals(ImmutableSet.of(author), spec.notifications().emailRolesFor(failingCommit)); + assertEquals(ImmutableSet.of("john@dev", "jane@dev"), spec.notifications().emailAddressesFor(failingCommit)); + assertEquals(ImmutableSet.of("jane@dev"), spec.notifications().emailAddressesFor(failing)); } @Test public void customTesterFlavor() { - DeploymentSpec spec = DeploymentSpec.fromXml("" + - " " + - " " + - " " + - " us-north-7" + - " " + - " " + + DeploymentSpec spec = DeploymentSpec.fromXml("\n" + + " \n" + + " \n" + + " us-north-7\n" + + " \n" + ""); - assertEquals(Optional.of("d-1-4-20"), spec.instance("default").steps().get(0).zones().get(0).testerFlavor()); - assertEquals(Optional.empty(), spec.instance("default").steps().get(1).zones().get(0).testerFlavor()); - assertEquals(Optional.of("d-2-8-50"), spec.instance("default").steps().get(2).zones().get(0).testerFlavor()); + assertEquals(Optional.of("d-1-4-20"), spec.steps().get(0).zones().get(0).testerFlavor()); + assertEquals(Optional.empty(), spec.steps().get(1).zones().get(0).testerFlavor()); + assertEquals(Optional.of("d-2-8-50"), spec.steps().get(2).zones().get(0).testerFlavor()); } @Test public void noEndpoints() { - assertEquals(Collections.emptyList(), - DeploymentSpec.fromXml("" + - " " + - "").instance("default").endpoints()); + assertEquals(Collections.emptyList(), DeploymentSpec.fromXml("").endpoints()); } @Test public void emptyEndpoints() { - var spec = DeploymentSpec.fromXml("" + - " " + - " " + - " " + - ""); - assertEquals(Collections.emptyList(), spec.instance("default").endpoints()); + final var spec = DeploymentSpec.fromXml(""); + assertEquals(Collections.emptyList(), spec.endpoints()); } @Test public void someEndpoints() { - var spec = DeploymentSpec.fromXml("" + - "" + - " " + - " " + - " us-east" + - " " + - " " + - " " + - " us-east" + - " " + - " " + - " " + - " " + - " " + - ""); + final var spec = DeploymentSpec.fromXml("" + + "" + + " " + + " us-east" + + " " + + " " + + " " + + " us-east" + + " " + + " " + + " " + + " " + + ""); assertEquals( List.of("foo", "nalle", "default"), - spec.instance("default").endpoints().stream().map(Endpoint::endpointId).collect(Collectors.toList()) + spec.endpoints().stream().map(Endpoint::endpointId).collect(Collectors.toList()) ); assertEquals( List.of("bar", "frosk", "quux"), - spec.instance("default").endpoints().stream().map(Endpoint::containerId).collect(Collectors.toList()) + spec.endpoints().stream().map(Endpoint::containerId).collect(Collectors.toList()) ); - assertEquals(Set.of(RegionName.from("us-east")), spec.instance("default").endpoints().get(0).regions()); + assertEquals(Set.of(RegionName.from("us-east")), spec.endpoints().get(0).regions()); } - @Test public void invalidEndpoints() { assertInvalid(""); // Uppercase @@ -851,21 +520,19 @@ public class DeploymentSpecTest { @Test public void endpointDefaultRegions() { var spec = DeploymentSpec.fromXml("" + - "" + - " " + - " " + - " us-east" + - " us-west" + - " " + - " " + - " " + - " us-east" + - " " + - " " + - " " + - " " + - " " + - ""); + "" + + " " + + " us-east" + + " us-west" + + " " + + " " + + " " + + " us-east" + + " " + + " " + + " " + + " " + + ""); assertEquals(Set.of("us-east"), endpointRegions("foo", spec)); assertEquals(Set.of("us-east", "us-west"), endpointRegions("nalle", spec)); @@ -880,7 +547,7 @@ public class DeploymentSpecTest { } private static Set endpointRegions(String endpointId, DeploymentSpec spec) { - return spec.instance("default").endpoints().stream() + return spec.endpoints().stream() .filter(endpoint -> endpoint.endpointId().equals(endpointId)) .flatMap(endpoint -> endpoint.regions().stream()) .map(RegionName::value) @@ -889,17 +556,15 @@ public class DeploymentSpecTest { private static List endpointIds(String endpointTag) { var xml = "" + - " " + - " " + - " us-east" + - " " + - " " + + " " + + " us-east" + + " " + + " " + endpointTag + - " " + - " " + + " " + ""; - return DeploymentSpec.fromXml(xml).instance("default").endpoints().stream() + return DeploymentSpec.fromXml(xml).endpoints().stream() .map(Endpoint::endpointId) .collect(Collectors.toList()); } diff --git a/config-model-api/src/test/java/com/yahoo/config/application/api/DeploymentSpecWithoutInstanceTest.java b/config-model-api/src/test/java/com/yahoo/config/application/api/DeploymentSpecWithoutInstanceTest.java deleted file mode 100644 index 33ef3f4bea8..00000000000 --- a/config-model-api/src/test/java/com/yahoo/config/application/api/DeploymentSpecWithoutInstanceTest.java +++ /dev/null @@ -1,526 +0,0 @@ -// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -package com.yahoo.config.application.api; - -import com.google.common.collect.ImmutableSet; -import com.yahoo.config.provision.Environment; -import com.yahoo.config.provision.RegionName; -import org.junit.Test; - -import java.io.StringReader; -import java.time.Instant; -import java.time.ZoneId; -import java.util.Collections; -import java.util.List; -import java.util.Optional; -import java.util.Set; -import java.util.stream.Collectors; - -import static com.yahoo.config.application.api.Notifications.Role.author; -import static com.yahoo.config.application.api.Notifications.When.failing; -import static com.yahoo.config.application.api.Notifications.When.failingCommit; -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertFalse; -import static org.junit.Assert.assertTrue; -import static org.junit.Assert.fail; - -/** - * @author bratseth - */ -public class DeploymentSpecWithoutInstanceTest { - - @Test - public void testSpec() { - String specXml = "" + - " " + - ""; - - StringReader r = new StringReader(specXml); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(specXml, spec.xmlForm()); - assertEquals(1, spec.steps().size()); - assertFalse(spec.majorVersion().isPresent()); - assertTrue(spec.steps().get(0).deploysTo(Environment.test)); - assertTrue(spec.instance("default").includes(Environment.test, Optional.empty())); - assertFalse(spec.instance("default").includes(Environment.test, Optional.of(RegionName.from("region1")))); - assertFalse(spec.instance("default").includes(Environment.staging, Optional.empty())); - assertFalse(spec.instance("default").includes(Environment.prod, Optional.empty())); - assertFalse(spec.instance("default").globalServiceId().isPresent()); - } - - @Test - public void testSpecPinningMajorVersion() { - String specXml = "" + - " " + - ""; - - StringReader r = new StringReader(specXml); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(specXml, spec.xmlForm()); - assertEquals(1, spec.steps().size()); - assertTrue(spec.majorVersion().isPresent()); - assertEquals(6, (int)spec.majorVersion().get()); - } - - @Test - public void stagingSpec() { - StringReader r = new StringReader( - "" + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(2, spec.steps().size()); - assertTrue(spec.instance("default").steps().get(0).deploysTo(Environment.test)); - assertTrue(spec.instance("default").steps().get(1).deploysTo(Environment.staging)); - assertTrue(spec.instance("default").includes(Environment.test, Optional.empty())); - assertFalse(spec.instance("default").includes(Environment.test, Optional.of(RegionName.from("region1")))); - assertTrue(spec.instance("default").includes(Environment.staging, Optional.empty())); - assertFalse(spec.instance("default").includes(Environment.prod, Optional.empty())); - assertFalse(spec.instance("default").globalServiceId().isPresent()); - } - - @Test - public void minimalProductionSpec() { - StringReader r = new StringReader( - "" + - " " + - " us-east1" + - " us-west1" + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(4, spec.instance("default").steps().size()); - - assertTrue(spec.instance("default").steps().get(0).deploysTo(Environment.test)); - - assertTrue(spec.instance("default").steps().get(1).deploysTo(Environment.staging)); - - assertTrue(spec.instance("default").steps().get(2).deploysTo(Environment.prod, Optional.of(RegionName.from("us-east1")))); - assertFalse(((DeploymentSpec.DeclaredZone)spec.instance("default").steps().get(2)).active()); - - assertTrue(spec.instance("default").steps().get(3).deploysTo(Environment.prod, Optional.of(RegionName.from("us-west1")))); - assertTrue(((DeploymentSpec.DeclaredZone)spec.instance("default").steps().get(3)).active()); - - assertTrue(spec.instance("default").includes(Environment.test, Optional.empty())); - assertFalse(spec.instance("default").includes(Environment.test, Optional.of(RegionName.from("region1")))); - assertTrue(spec.instance("default").includes(Environment.staging, Optional.empty())); - assertTrue(spec.instance("default").includes(Environment.prod, Optional.of(RegionName.from("us-east1")))); - assertTrue(spec.instance("default").includes(Environment.prod, Optional.of(RegionName.from("us-west1")))); - assertFalse(spec.instance("default").includes(Environment.prod, Optional.of(RegionName.from("no-such-region")))); - assertFalse(spec.instance("default").globalServiceId().isPresent()); - - assertEquals(DeploymentSpec.UpgradePolicy.defaultPolicy, spec.instance("default").upgradePolicy()); - } - - @Test - public void maximalProductionSpec() { - StringReader r = new StringReader( - "" + - " " + - " " + - " " + - " us-east1" + - " " + - " us-west1" + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(5, spec.instance("default").steps().size()); - assertEquals(4, spec.instance("default").zones().size()); - - assertTrue(spec.instance("default").steps().get(0).deploysTo(Environment.test)); - - assertTrue(spec.instance("default").steps().get(1).deploysTo(Environment.staging)); - - assertTrue(spec.instance("default").steps().get(2).deploysTo(Environment.prod, Optional.of(RegionName.from("us-east1")))); - assertFalse(((DeploymentSpec.DeclaredZone)spec.instance("default").steps().get(2)).active()); - - assertTrue(spec.instance("default").steps().get(3) instanceof DeploymentSpec.Delay); - assertEquals(3 * 60 * 60 + 30 * 60, spec.instance("default").steps().get(3).delay().getSeconds()); - - assertTrue(spec.instance("default").steps().get(4).deploysTo(Environment.prod, Optional.of(RegionName.from("us-west1")))); - assertTrue(((DeploymentSpec.DeclaredZone)spec.instance("default").steps().get(4)).active()); - - assertTrue(spec.instance("default").includes(Environment.test, Optional.empty())); - assertFalse(spec.instance("default").includes(Environment.test, Optional.of(RegionName.from("region1")))); - assertTrue(spec.instance("default").includes(Environment.staging, Optional.empty())); - assertTrue(spec.instance("default").includes(Environment.prod, Optional.of(RegionName.from("us-east1")))); - assertTrue(spec.instance("default").includes(Environment.prod, Optional.of(RegionName.from("us-west1")))); - assertFalse(spec.instance("default").includes(Environment.prod, Optional.of(RegionName.from("no-such-region")))); - assertFalse(spec.instance("default").globalServiceId().isPresent()); - } - - @Test - public void productionSpecWithGlobalServiceId() { - StringReader r = new StringReader( - "" + - " " + - " us-east-1" + - " us-west-1" + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(spec.instance("default").globalServiceId(), Optional.of("query")); - } - - @Test(expected=IllegalArgumentException.class) - public void globalServiceIdInTest() { - StringReader r = new StringReader( - "" + - " " + - "" - ); - DeploymentSpec.fromXml(r); - } - - @Test(expected=IllegalArgumentException.class) - public void globalServiceIdInStaging() { - StringReader r = new StringReader( - "" + - " " + - "" - ); - DeploymentSpec.fromXml(r); - } - - @Test - public void productionSpecWithGlobalServiceIdBeforeStaging() { - StringReader r = new StringReader( - "" + - " " + - " " + - " us-west-1" + - " us-central-1" + - " us-east-3" + - " " + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals("qrs", spec.instance("default").globalServiceId().get()); - } - - @Test - public void productionSpecWithUpgradePolicy() { - StringReader r = new StringReader( - "" + - " " + - " " + - " us-west-1" + - " us-central-1" + - " us-east-3" + - " " + - "" - ); - - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals("canary", spec.instance("default").upgradePolicy().toString()); - } - - @Test - public void maxDelayExceeded() { - try { - StringReader r = new StringReader( - "" + - " " + - " " + - " us-west-1" + - " " + - " us-central-1" + - " " + - " us-east-3" + - " " + - "" - ); - DeploymentSpec.fromXml(r); - fail("Expected exception due to exceeding the max total delay"); - } - catch (IllegalArgumentException e) { - // success - assertEquals("The total delay specified is PT24H1S but max 24 hours is allowed", e.getMessage()); - } - } - - @Test - public void testEmpty() { - assertFalse(DeploymentSpec.empty.instance("default").globalServiceId().isPresent()); - assertEquals(DeploymentSpec.UpgradePolicy.defaultPolicy, DeploymentSpec.empty.upgradePolicy()); - assertTrue(DeploymentSpec.empty.steps().isEmpty()); - assertEquals("", DeploymentSpec.empty.xmlForm()); - } - - @Test - public void productionSpecWithParallelDeployments() { - StringReader r = new StringReader( - "\n" + - " \n" + - " us-west-1\n" + - " \n" + - " us-central-1\n" + - " us-east-3\n" + - " \n" + - " \n" + - "" - ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - DeploymentSpec.ParallelZones parallelZones = ((DeploymentSpec.ParallelZones) spec.instance("default").steps().get(3)); - assertEquals(2, parallelZones.zones().size()); - assertEquals(RegionName.from("us-central-1"), parallelZones.zones().get(0).region().get()); - assertEquals(RegionName.from("us-east-3"), parallelZones.zones().get(1).region().get()); - } - - @Test - public void productionSpecWithDuplicateRegions() { - StringReader r = new StringReader( - "\n" + - " \n" + - " us-west-1\n" + - " \n" + - " us-west-1\n" + - " us-central-1\n" + - " us-east-3\n" + - " \n" + - " \n" + - "" - ); - try { - DeploymentSpec.fromXml(r); - fail("Expected exception"); - } catch (IllegalArgumentException e) { - assertEquals("prod.us-west-1 is listed twice in deployment.xml", e.getMessage()); - } - } - - @Test(expected = IllegalArgumentException.class) - public void deploymentSpecWithIllegallyOrderedDeploymentSpec1() { - StringReader r = new StringReader( - "\n" + - " \n" + - " \n" + - " us-west-1\n" + - " \n" + - " \n" + - "" - ); - DeploymentSpec.fromXml(r); - } - - @Test(expected = IllegalArgumentException.class) - public void deploymentSpecWithIllegallyOrderedDeploymentSpec2() { - StringReader r = new StringReader( - "\n" + - " \n" + - " \n" + - " \n" + - " us-west-1\n" + - " \n" + - "" - ); - DeploymentSpec.fromXml(r); - } - - @Test - public void deploymentSpecWithChangeBlocker() { - StringReader r = new StringReader( - "\n" + - " \n" + - " \n" + - " \n" + - " us-west-1\n" + - " \n" + - "" - ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(2, spec.instance("default").changeBlocker().size()); - assertTrue(spec.instance("default").changeBlocker().get(0).blocksVersions()); - assertFalse(spec.instance("default").changeBlocker().get(0).blocksRevisions()); - assertEquals(ZoneId.of("UTC"), spec.instance("default").changeBlocker().get(0).window().zone()); - - assertTrue(spec.instance("default").changeBlocker().get(1).blocksVersions()); - assertTrue(spec.instance("default").changeBlocker().get(1).blocksRevisions()); - assertEquals(ZoneId.of("CET"), spec.instance("default").changeBlocker().get(1).window().zone()); - - assertTrue(spec.instance("default").canUpgradeAt(Instant.parse("2017-09-18T14:15:30.00Z"))); - assertFalse(spec.instance("default").canUpgradeAt(Instant.parse("2017-09-18T15:15:30.00Z"))); - assertFalse(spec.instance("default").canUpgradeAt(Instant.parse("2017-09-18T16:15:30.00Z"))); - assertTrue(spec.instance("default").canUpgradeAt(Instant.parse("2017-09-18T17:15:30.00Z"))); - - assertTrue(spec.instance("default").canUpgradeAt(Instant.parse("2017-09-23T09:15:30.00Z"))); - assertFalse(spec.instance("default").canUpgradeAt(Instant.parse("2017-09-23T08:15:30.00Z"))); // 10 in CET - assertTrue(spec.instance("default").canUpgradeAt(Instant.parse("2017-09-23T10:15:30.00Z"))); - } - - @Test - public void athenz_config_is_read_from_deployment() { - StringReader r = new StringReader( - "\n" + - " \n" + - " us-west-1\n" + - " \n" + - "" - ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(spec.instance("default").athenzDomain().get().value(), "domain"); - assertEquals(spec.instance("default").athenzService(Environment.prod, RegionName.from("us-west-1")).get().value(), "service"); - } - - @Test - public void athenz_service_is_overridden_from_environment() { - StringReader r = new StringReader( - "\n" + - " \n" + - " \n" + - " us-west-1\n" + - " \n" + - "" - ); - DeploymentSpec spec = DeploymentSpec.fromXml(r); - assertEquals(spec.instance("default").athenzDomain().get().value(), "domain"); - assertEquals(spec.instance("default").athenzService(Environment.prod, RegionName.from("us-west-1")).get().value(), "prod-service"); - } - - @Test(expected = IllegalArgumentException.class) - public void it_fails_when_athenz_service_is_not_defined() { - StringReader r = new StringReader( - "\n" + - " \n" + - " us-west-1\n" + - " \n" + - "" - ); - DeploymentSpec.fromXml(r); - } - - @Test(expected = IllegalArgumentException.class) - public void it_fails_when_athenz_service_is_configured_but_not_athenz_domain() { - StringReader r = new StringReader( - "\n" + - " \n" + - " us-west-1\n" + - " \n" + - "" - ); - DeploymentSpec.fromXml(r); - } - - @Test - public void noNotifications() { - assertEquals(Notifications.none(), - DeploymentSpec.fromXml("").instance("default").notifications()); - } - - @Test - public void emptyNotifications() { - DeploymentSpec spec = DeploymentSpec.fromXml("\n" + - " " + - ""); - assertEquals(Notifications.none(), spec.instance("default").notifications()); - } - - @Test - public void someNotifications() { - DeploymentSpec spec = DeploymentSpec.fromXml("\n" + - " \n" + - " \n" + - " \n" + - " \n" + - " \n" + - ""); - assertEquals(ImmutableSet.of(author), spec.instance("default").notifications().emailRolesFor(failing)); - assertEquals(ImmutableSet.of(author), spec.instance("default").notifications().emailRolesFor(failingCommit)); - assertEquals(ImmutableSet.of("john@dev", "jane@dev"), spec.instance("default").notifications().emailAddressesFor(failingCommit)); - assertEquals(ImmutableSet.of("jane@dev"), spec.instance("default").notifications().emailAddressesFor(failing)); - } - - @Test - public void customTesterFlavor() { - DeploymentSpec spec = DeploymentSpec.fromXml("\n" + - " \n" + - " \n" + - " us-north-7\n" + - " \n" + - ""); - assertEquals(Optional.of("d-1-4-20"), spec.instance("default").steps().get(0).zones().get(0).testerFlavor()); - assertEquals(Optional.empty(), spec.instance("default").steps().get(1).zones().get(0).testerFlavor()); - assertEquals(Optional.of("d-2-8-50"), spec.instance("default").steps().get(2).zones().get(0).testerFlavor()); - } - - @Test - public void noEndpoints() { - assertEquals(Collections.emptyList(), DeploymentSpec.fromXml("").instance("default").endpoints()); - } - - @Test - public void emptyEndpoints() { - var spec = DeploymentSpec.fromXml(""); - assertEquals(Collections.emptyList(), spec.instance("default").endpoints()); - } - - @Test - public void someEndpoints() { - var spec = DeploymentSpec.fromXml("" + - "" + - " " + - " us-east" + - " " + - " " + - " " + - " us-east" + - " " + - " " + - " " + - " " + - ""); - - assertEquals( - List.of("foo", "nalle", "default"), - spec.instance("default").endpoints().stream().map(Endpoint::endpointId).collect(Collectors.toList()) - ); - - assertEquals( - List.of("bar", "frosk", "quux"), - spec.instance("default").endpoints().stream().map(Endpoint::containerId).collect(Collectors.toList()) - ); - - assertEquals(Set.of(RegionName.from("us-east")), spec.instance("default").endpoints().get(0).regions()); - } - - @Test - public void endpointDefaultRegions() { - var spec = DeploymentSpec.fromXml("" + - "" + - " " + - " us-east" + - " us-west" + - " " + - " " + - " " + - " us-east" + - " " + - " " + - " " + - " " + - ""); - - assertEquals(Set.of("us-east"), endpointRegions("foo", spec)); - assertEquals(Set.of("us-east", "us-west"), endpointRegions("nalle", spec)); - assertEquals(Set.of("us-east", "us-west"), endpointRegions("default", spec)); - } - - private static Set endpointRegions(String endpointId, DeploymentSpec spec) { - return spec.instance("default").endpoints().stream() - .filter(endpoint -> endpoint.endpointId().equals(endpointId)) - .flatMap(endpoint -> endpoint.regions().stream()) - .map(RegionName::value) - .collect(Collectors.toSet()); - } - -} -- cgit v1.2.3