Whether a service resolves endpoints through the BDD provider is decided by whether {@code endpoint-bdd-1.json} is + * checked in. Upstream publishes the model for every service that has one, so copying it unconditionally would move + * every service onto the BDD provider on the first release that carried it. Adding the file by hand is the act of + * opting a service in; the release script only keeps an existing one up to date. + * + *
Driven through {@code main} rather than by calling the copy helper directly, so the option registration and the
+ * destination path are covered too. An unregistered option would leave the argument silently ignored, which no test of
+ * the helper alone would catch.
+ */
+class UpdateServiceMainTest {
+
+ @Test
+ void endpointBddJson_notAlreadyPresent_isNotCopied(@TempDir Path tmp) throws Exception {
+ Fixture fixture = new Fixture(tmp);
+
+ fixture.run();
+
+ assertThat(fixture.destination("endpoint-bdd-1.json"))
+ .as("a service without a checked-in BDD model must not be opted in by a release")
+ .doesNotExist();
+ }
+
+ @Test
+ void endpointBddJson_alreadyPresent_isOverwritten(@TempDir Path tmp) throws Exception {
+ Fixture fixture = new Fixture(tmp);
+ fixture.writeDestination("endpoint-bdd-1.json", "{\"stale\": true}");
+
+ fixture.run();
+
+ assertThat(fixture.destination("endpoint-bdd-1.json")).hasContent(Fixture.BDD_CONTENT);
+ }
+
+ /**
+ * An empty file still counts as present. It is a checked-in file, so the service is opted in, and refusing to
+ * refresh it would leave it stale forever.
+ */
+ @Test
+ void endpointBddJson_presentButEmpty_isStillOverwritten(@TempDir Path tmp) throws Exception {
+ Fixture fixture = new Fixture(tmp);
+ fixture.writeDestination("endpoint-bdd-1.json", "");
+
+ fixture.run();
+
+ assertThat(fixture.destination("endpoint-bdd-1.json")).hasContent(Fixture.BDD_CONTENT);
+ }
+
+ /**
+ * The gate is on the destination, not the source, so omitting the argument leaves an opted-in service's model
+ * alone rather than deleting or emptying it.
+ */
+ @Test
+ void endpointBddJson_argumentOmitted_leavesAnExistingModelAlone(@TempDir Path tmp) throws Exception {
+ Fixture fixture = new Fixture(tmp);
+ fixture.writeDestination("endpoint-bdd-1.json", "{\"kept\": true}");
+
+ fixture.withoutEndpointBddArgument().run();
+
+ assertThat(fixture.destination("endpoint-bdd-1.json")).hasContent("{\"kept\": true}");
+ }
+
+ @Test
+ void endpointBddJson_isOptionalAndAbsenceIsNotAnError(@TempDir Path tmp) throws Exception {
+ Fixture fixture = new Fixture(tmp);
+
+ fixture.withoutEndpointBddArgument().run();
+
+ assertThat(fixture.destination("service-2.json")).hasContent(Fixture.SERVICE_CONTENT);
+ assertThat(fixture.destination("endpoint-bdd-1.json")).doesNotExist();
+ }
+
+ /**
+ * The other model files keep their unconditional behaviour. A service legitimately gains waiters or endpoint tests
+ * for the first time, and those must land on the release that carries them.
+ */
+ @Test
+ void otherModelFiles_areCopiedEvenWhenNotAlreadyPresent(@TempDir Path tmp) throws Exception {
+ Fixture fixture = new Fixture(tmp);
+
+ fixture.run();
+
+ assertThat(fixture.destination("service-2.json")).hasContent(Fixture.SERVICE_CONTENT);
+ assertThat(fixture.destination("paginators-1.json")).exists();
+ assertThat(fixture.destination("waiters-2.json")).exists();
+ assertThat(fixture.destination("endpoint-rule-set.json")).exists();
+ assertThat(fixture.destination("endpoint-tests.json")).exists();
+ }
+
+ /**
+ * DynamoDB's models live in a nested directory, so this checks the gate is applied against the same resolved
+ * destination the copy uses rather than the module root.
+ */
+ @Test
+ void endpointBddJson_gateAppliesToTheResolvedNestedDestination(@TempDir Path tmp) throws Exception {
+ Fixture fixture = new Fixture(tmp, "dynamodb", "DynamoDB", "dynamodb");
+ fixture.writeDestination("endpoint-bdd-1.json", "{\"stale\": true}");
+
+ fixture.run();
+
+ assertThat(fixture.destination("endpoint-bdd-1.json")).hasContent(Fixture.BDD_CONTENT);
+ assertThat(tmp.resolve("services/dynamodb/src/main/resources/codegen-resources/endpoint-bdd-1.json"))
+ .as("the nested service must not also get a copy at the module root")
+ .doesNotExist();
+ }
+
+ private static final class Fixture {
+ private static final String BDD_CONTENT = "{\"version\": \"1.0\", \"nodes\": \"AAAA\"}";
+ private static final String SERVICE_CONTENT = "{\"metadata\": {}}";
+
+ private final Path projectRoot;
+ private final Path sourceDir;
+ private final Path destinationDir;
+ private final String serviceModuleName;
+ private final String serviceId;
+ private boolean includeEndpointBddArgument = true;
+
+ private Fixture(Path tmp) throws IOException {
+ this(tmp, "myservice", "MyService", null);
+ }
+
+ private Fixture(Path tmp, String serviceModuleName, String serviceId, String nestedDir) throws IOException {
+ this.projectRoot = tmp.resolve("project");
+ this.sourceDir = tmp.resolve("source");
+ this.serviceModuleName = serviceModuleName;
+ this.serviceId = serviceId;
+
+ Path codegenResources = projectRoot.resolve("services")
+ .resolve(serviceModuleName)
+ .resolve("src")
+ .resolve("main")
+ .resolve("resources")
+ .resolve("codegen-resources");
+ this.destinationDir = nestedDir == null ? codegenResources : codegenResources.resolve(nestedDir);
+ Files.createDirectories(destinationDir);
+ Files.createDirectories(sourceDir);
+
+ write(sourceDir.resolve("service-2.json"), SERVICE_CONTENT);
+ write(sourceDir.resolve("paginators-1.json"), "{\"pagination\": {}}");
+ write(sourceDir.resolve("waiters-2.json"), "{\"waiters\": {}}");
+ write(sourceDir.resolve("endpoint-rule-set.json"), "{\"version\": \"1.0\"}");
+ write(sourceDir.resolve("endpoint-tests.json"), "{\"testCases\": []}");
+ write(sourceDir.resolve("endpoint-bdd-1.json"), BDD_CONTENT);
+ }
+
+ private Fixture withoutEndpointBddArgument() {
+ this.includeEndpointBddArgument = false;
+ return this;
+ }
+
+ private void writeDestination(String name, String content) throws IOException {
+ write(destinationDir.resolve(name), content);
+ }
+
+ private Path destination(String name) {
+ return destinationDir.resolve(name);
+ }
+
+ private void run() {
+ List