diff options
Diffstat (limited to 'test-apis-ci/src/test/java/org/openecomp/sdc/cucumber/steps/StepsTenantIsolationCI.java')
| -rw-r--r-- | test-apis-ci/src/test/java/org/openecomp/sdc/cucumber/steps/StepsTenantIsolationCI.java | 606 |
1 files changed, 0 insertions, 606 deletions
diff --git a/test-apis-ci/src/test/java/org/openecomp/sdc/cucumber/steps/StepsTenantIsolationCI.java b/test-apis-ci/src/test/java/org/openecomp/sdc/cucumber/steps/StepsTenantIsolationCI.java deleted file mode 100644 index e19280aa46..0000000000 --- a/test-apis-ci/src/test/java/org/openecomp/sdc/cucumber/steps/StepsTenantIsolationCI.java +++ /dev/null @@ -1,606 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * SDC - * ================================================================================ - * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * ============LICENSE_END========================================================= - */ - -package org.openecomp.sdc.cucumber.steps; - -import com.google.common.base.Strings; -import com.google.common.net.HttpHeaders; -import com.google.gson.JsonElement; -import com.google.gson.JsonParser; -import io.cucumber.java.After; -import io.cucumber.java.Before; -import io.cucumber.java.en.Given; -import io.cucumber.java.en.Then; -import io.cucumber.java.en.When; -import fj.data.Either; -import org.apache.commons.collections.CollectionUtils; -import org.apache.commons.lang3.StringUtils; -import org.apache.http.HttpStatus; -import org.apache.http.entity.ContentType; -import org.apache.http.entity.StringEntity; -import org.mockserver.integration.ClientAndServer; -import org.mockserver.model.Header; -import org.mockserver.model.HttpRequest; -import org.openecomp.sdc.api.IDistributionClient; -import org.openecomp.sdc.api.consumer.IConfiguration; -import org.openecomp.sdc.api.consumer.IFinalDistrStatusMessage; -import org.openecomp.sdc.api.consumer.INotificationCallback; -import org.openecomp.sdc.api.notification.IArtifactInfo; -import org.openecomp.sdc.api.notification.INotificationData; -import org.openecomp.sdc.api.results.IDistributionClientDownloadResult; -import org.openecomp.sdc.api.results.IDistributionClientResult; -import org.openecomp.sdc.be.dao.cassandra.CassandraOperationStatus; -import org.openecomp.sdc.be.dao.cassandra.OperationalEnvironmentDao; -import org.openecomp.sdc.be.datatypes.enums.EnvironmentStatusEnum; -import org.openecomp.sdc.be.resources.data.OperationalEnvironmentEntry; -import org.openecomp.sdc.common.datastructure.FunctionalInterfaces; -import org.openecomp.sdc.common.datastructure.Wrapper; -import org.openecomp.sdc.cucumber.spring.ImportTableConfig; -import org.openecomp.sdc.http.HttpAsdcClient; -import org.openecomp.sdc.http.HttpAsdcResponse; -import org.openecomp.sdc.http.IHttpAsdcClient; -import org.openecomp.sdc.impl.DistributionClientFactory; -import org.openecomp.sdc.utils.ArtifactTypeEnum; -import org.openecomp.sdc.utils.DistributionActionResultEnum; -import org.openecomp.sdc.utils.DistributionStatusEnum; -import org.springframework.context.annotation.AnnotationConfigApplicationContext; - -import java.util.*; -import java.util.function.Function; -import java.util.stream.Collectors; - -import static org.hamcrest.MatcherAssert.assertThat; -import static org.hamcrest.Matchers.is; -import static org.mockserver.model.HttpClassCallback.callback; -import static org.mockserver.model.HttpRequest.request; -import static org.mockserver.model.HttpResponse.response; -import static org.openecomp.sdc.common.datastructure.FunctionalInterfaces.retryMethodOnResult; -import static org.testng.Assert.assertEquals; -import static org.testng.Assert.assertNotNull; - -//import org.openecomp.sdc.dmaap.DmaapPublisher; - -public class StepsTenantIsolationCI { - - private Map<String, OperationalEnvironmentEntry> recordMap = new HashMap<>(); - private OperationalEnvironmentDao operationalEnvironmentDao; - private ClientAndServer aaiMockServer; - private ClientAndServer msoMockServer; - private List<IDistributionClient> distributionClients = new ArrayList<>(); - - private List<String> wdFinalStatusSent = new ArrayList<>(); - - private HttpRequest msoHttpRequest; - private List<String> uuidServicesList; - private boolean cleanFlag = true; - private int maxStepWaitTimeMs; - - private List<String> envIds = new ArrayList<>(); - private List<OperationalEnvironmentEntry> envList = new ArrayList<>(); - private String asdcAddress; - private volatile int numberOfFinalDistributionsSentByASDC; - private int numOfArtifactsToDownload; - private volatile int totalNumOfArtifactsToDownload; - private List<String> envNames = new ArrayList<>(Arrays.asList("Apple", "Orange", "Grape", "Pear", "Watermelon", "Bannana", "Cherry", "Coconut", "Fig", "Mango", "Peach", "Pineapple", "Plum", "Strawberries", "Apricot")); - - private static final String AAI_RESPONSE_BODY_FMT = "{\"operational-environment-id\":\"UUID of Operational Environment\"," - + "\"operational-environment-name\":\"Op Env Name\"," + "\"operational-environment-type\":\"ECOMP\"," - + "\"operational-environment-status\":\"Activate\"," + "\"tenant-context\":\"%s\"," - + "\"workload-context\":\"%s\"," + "\"resource-version\":\"1505228226913\"," + "\"relationship-list\":{}}"; - - private static final String AAI_PATH_REGEX = "/aai/v12/cloud-infrastructure/operational-environments/.*"; - - private static final String MSO_PATH_REGEX = "/onap/mso/infra/modelDistributions/v1/distributions/.*"; - - @Before - public void beforeScenario() { - Collections.shuffle(envNames); - aaiMockServer = ClientAndServer.startClientAndServer(1111); - msoMockServer = ClientAndServer.startClientAndServer(1112); - - this.operationalEnvironmentDao = createDaoObj(); - } - - @After - public void afterScenario() { - System.out.println("Cleaning Up After Scenario..."); - aaiMockServer.stop(); - msoMockServer.stop(); - if (cleanFlag) { - envIds.stream().forEach(operationalEnvironmentDao::delete); - } - distributionClients.stream().forEach(IDistributionClient::stop); - System.out.println("Cleaning Up After Scenario Done"); - } - - // ############################# Given - Start ############################# - - @Given("^clean db after test is (.*)$") - public void clean_db_after_test_is(boolean cleanFlag) { - this.cleanFlag = cleanFlag; - } - - @Given("^AAI returns (.*) and aai_body contains (.*) and (.*)$") - public void aai_returns(int retCode, String tenant, String workload) throws Throwable { - String aaiResponseBody = String.format(AAI_RESPONSE_BODY_FMT, tenant, workload); - - setAaiMockServer(aaiResponseBody); - - System.out.println(aaiMockServer.getClass()); - } - - @Given("^MSO-WD Simulators Started with topic name (.*)$") - public void notification_listner_simulators_started(String topicName) throws Throwable { - envList.forEach(env -> { - final IDistributionClient distClientSim = simulateDistributionClientWD(topicName, env); - distributionClients.add(distClientSim); - }); - - } - - @Given("^MSO Final Distribution Simulator is UP$") - public void mso_Final_Distribution_Simulator_is_UP() throws Throwable { - msoHttpRequest = request().withPath(MSO_PATH_REGEX); - msoMockServer.when(msoHttpRequest).forward( - callback().withCallbackClass("org.openecomp.sdc.cucumber.steps.PrecannedTestExpectationCallback")); - } - - @Given("^ASDC Address is (.*)$") - public void asdc_Address_is(String asdcAddress) throws Throwable { - this.asdcAddress = asdcAddress; - - } - - @Given("^ASDC Contains the following services (.*)$") - public void asdc_Contains_the_following_services(String listOfServicesUUID) throws Throwable { - uuidServicesList = Arrays.asList(listOfServicesUUID.split(",")).stream().map(String::trim) - .collect(Collectors.toList()); - - int maxMinWait = uuidServicesList.size() * envIds.size(); - this.maxStepWaitTimeMs = 60000 * maxMinWait; - System.out.println(String.format("Set Max Step Wait Time To: %s Minutes", maxMinWait)); - } - - @Given("^The number of complete environments is (.*)$") - public void the_number_of_complete_environments_is(int envNum) throws Throwable { - - int counter = 1; - while( envNum > envNames.size()){ - envNames.add(String.valueOf(counter)); - counter++; - } - - - for (int i = 0; i < envNum; i++) { - OperationalEnvironmentEntry preSaveEntry = new OperationalEnvironmentEntry(); - - preSaveEntry.setStatus(EnvironmentStatusEnum.COMPLETED); - preSaveEntry.setLastModified(new Date(System.currentTimeMillis())); - - Set<String> uebAdresses = new HashSet<>(); - uebAdresses.add("uebsb92sfdc.it.att.com"); - preSaveEntry.setDmaapUebAddress(uebAdresses); - preSaveEntry.setIsProduction(false); - preSaveEntry.setUebApikey("sSJc5qiBnKy2qrlc"); - preSaveEntry.setUebSecretKey("4ZRPzNJfEUK0sSNBvccd2m7X"); - preSaveEntry.setTenant("TEST"); - preSaveEntry.setEcompWorkloadContext("ECOMP_E2E-IST"); - - // String envId = UUID.randomUUID().toString(); - String envId = envNames.get(i); - preSaveEntry.setEnvironmentId(envId); - envIds.add(envId); - envList.add(preSaveEntry); - operationalEnvironmentDao.save(preSaveEntry); - } - } - - @Given("^The number of artifacts each Simulator downloads from a service is (.*)$") - public void number_of_artifacts_each_simulator_downloads(int numOfArtifactsToDownload) throws Throwable { - this.numOfArtifactsToDownload = numOfArtifactsToDownload; - } - - // ############################# Given - End ############################# - - // ############################# When - Start ############################# - @When("^Distribution Requests are Sent By MSO$") - public void distribution_Requests_are_Sent_By_MSO() throws Throwable { - envList.stream().forEach(this::distributeServiceInEnv); - - } - - @When("^The Number Of Operational Envrinoments that created is (.*) and Records are added with data (.*)$") - public void operational_envrinoments_records_are_added_with_data(int numOfRecords, String recordData) - throws Throwable { - for (int i = 0; i < numOfRecords; i++) { - OperationalEnvironmentEntry preSaveEntry = new OperationalEnvironmentEntry(); - JsonElement root = new JsonParser().parse(recordData); - - String originalStatus = root.getAsJsonObject().get("status").getAsString(); - int delta = root.getAsJsonObject().get("last_modified_delta").getAsInt(); - preSaveEntry.setStatus(EnvironmentStatusEnum.getByName(originalStatus)); - long last_modified = System.currentTimeMillis() + delta * 1000; - preSaveEntry.setLastModified(new Date(last_modified)); - String envId = UUID.randomUUID().toString(); - preSaveEntry.setEnvironmentId(envId); - envIds.add(envId); - // envrionmentIds.add(envId); - operationalEnvironmentDao.save(preSaveEntry); - - } - - } - - // ############################# When - End ############################# - - // ############################# Then - Start ############################# - @Then("^Operational Environment record contains tenant field (.*$)") - public void operational_environment_record_contains_tenant(boolean tenantExist) throws Throwable { - envIds.forEach(envId -> { - validateStringFieldPresent(tenantExist, OperationalEnvironmentEntry::getTenant, envId, - "Tenant is not as expected"); - }); - } - - @Then("^Operational Environment record contains workload field (.*$)") - public void operational_environment_record_contains_workload(boolean workloadExist) throws Throwable { - envIds.forEach(envId -> { - validateStringFieldPresent(workloadExist, OperationalEnvironmentEntry::getEcompWorkloadContext, envId, - "Workload is not as expected"); - }); - } - - @Then("^Operational Environment record contains UEB Address field (.*$)") - public void operational_environment_record_contains_ueb_address(boolean uebAddresExist) throws Throwable { - envIds.forEach(envId -> { - validateStringFieldPresent(uebAddresExist, this::convertUebAddressToList, envId, - "UEB Address is not as expected"); - }); - } - - @Then("^The Number Of Environment is (.*) with status (.*)$") - public void the_Number_Of_Environment_Created_is(int numberOfEnvsCreated, String status) throws Throwable { - // Write code here that turns the phrase above into concrete actions - - retryMethodOnResult(() -> getCurrentEnvironmets(status), envList -> envList.size() == numberOfEnvsCreated, - 40000, 500); - - List<OperationalEnvironmentEntry> environmentsFound = getCurrentEnvironmets(status); - - assertThat(environmentsFound.size(), is(numberOfEnvsCreated)); - - environmentsFound.forEach(env -> recordMap.put(env.getEnvironmentId(), env)); - envList.addAll(environmentsFound); - } - - @Then("^MSO Final Distribution Recieved Correct Number Of Request$") - public void mso_final_distribution_recieved_request() throws Throwable { - int expectedNumberOfRequestsSentByASDC = calculateExcpectedNumberOfDistributionRequets(); - Function<Integer, Boolean> resultVerifier = actualStatusList -> actualStatusList >= expectedNumberOfRequestsSentByASDC; - retryMethodOnResult(() -> numberOfFinalDistributionsSentByASDC(expectedNumberOfRequestsSentByASDC), - resultVerifier, maxStepWaitTimeMs, 500); - int actualNumberOfRequestsSentByASDC = numberOfFinalDistributionsSentByASDC(expectedNumberOfRequestsSentByASDC); - assertThat(actualNumberOfRequestsSentByASDC, is(expectedNumberOfRequestsSentByASDC)); - } - - @Then("^All MSO-WD Simulators Sent The Distribution Complete Notifications$") - public void all_mso_wd_simulators_sent_the_distribution_complete_notifications() { - // Wait Watch Dogs To Send Final Distribution - int excpectedNumberOfDistributionCompleteNotifications = calculateExcpectedNumberOfDistributionRequets(); - final Function<List<String>, Boolean> resultVerifier = actualStatusList -> actualStatusList - .size() == excpectedNumberOfDistributionCompleteNotifications; - retryMethodOnResult(() -> wdFinalStatusSent, resultVerifier, maxStepWaitTimeMs, 500); - assertThat(wdFinalStatusSent.size(), is(excpectedNumberOfDistributionCompleteNotifications)); - } - @Then("^All Artifacts were downloaded by Simulators$") - public void all_artifacts_downloaded() { - // Wait Watch Dogs To Send Final Distribution - int excpectedNumberOfArtifactsToDownload = numOfArtifactsToDownload * envIds.size() * uuidServicesList.size(); - assertThat(totalNumOfArtifactsToDownload, is(excpectedNumberOfArtifactsToDownload)); - } - // ############################# Then - End ############################# - - private List<OperationalEnvironmentEntry> getCurrentEnvironmets(String status) { - Either<List<OperationalEnvironmentEntry>, CassandraOperationStatus> eitherStatus = operationalEnvironmentDao - .getByEnvironmentsStatus(EnvironmentStatusEnum.getByName(status)); - assertThat(eitherStatus.isLeft(), is(true)); - - List<OperationalEnvironmentEntry> environmentsRetrieved = eitherStatus.left().value(); - - List<OperationalEnvironmentEntry> environmentsFound = environmentsRetrieved.stream() - .filter(env -> envIds.contains(env.getEnvironmentId())).collect(Collectors.toList()); - return environmentsFound; - } - - private int numberOfFinalDistributionsSentByASDC(int expectedNumberOfRequestsSentByASDC) { - final int newVal = msoMockServer.retrieveRecordedRequests(msoHttpRequest).length; - if (newVal != numberOfFinalDistributionsSentByASDC) { - System.out.println(String.format( - "MSO Server Simulator Recieved %s/%s Final Distribution Complete Rest Reports From ASDC", newVal, - expectedNumberOfRequestsSentByASDC)); - numberOfFinalDistributionsSentByASDC = newVal; - } - - return newVal; - } - - private int calculateExcpectedNumberOfDistributionRequets() { - int numberOfDistributionRequests = envList.size() * uuidServicesList.size(); - return numberOfDistributionRequests; - } - - private static OperationalEnvironmentDao createDaoObj() { - AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(ImportTableConfig.class); - final OperationalEnvironmentDao openvDao = (OperationalEnvironmentDao) context - .getBean("operational-environment-dao"); - return openvDao; - } - - private OperationalEnvironmentEntry getRecord(String environmentId) { - Either<OperationalEnvironmentEntry, CassandraOperationStatus> result = operationalEnvironmentDao - .get(environmentId); - return result.isLeft() ? result.left().value() : null; - } - - private void validateStringFieldPresent(boolean fieldExist, - Function<OperationalEnvironmentEntry, String> getFieldFunc, String envId, String msg) { - OperationalEnvironmentEntry record = recordMap.computeIfAbsent(envId, this::getRecord); - - assertNotNull(record, "Expected DB record was not found"); - - String actualValue = getFieldFunc.apply(record); - - assertEquals(fieldExist, !Strings.isNullOrEmpty(actualValue), msg); - } - - private void setAaiMockServer(String aaiResponseBody) { - HttpRequest httpRequest = request().withMethod("GET").withPath(AAI_PATH_REGEX) - .withHeaders(new Header(HttpHeaders.CONTENT_TYPE, ContentType.APPLICATION_JSON.getMimeType())); - - aaiMockServer.when(httpRequest) - .respond(response() - .withHeaders(new Header(HttpHeaders.CONTENT_TYPE, ContentType.APPLICATION_JSON.getMimeType())) - .withBody(aaiResponseBody)); - } - - private IDistributionClient simulateDistributionClientWD(String topicName, OperationalEnvironmentEntry opEnv) { - - IDistributionClient client = DistributionClientFactory.createDistributionClient(); - final IConfiguration buildDistributionClientConfiguration = buildDistributionClientConfiguration(topicName, - opEnv); - IDistributionClientResult initResult = client.init(buildDistributionClientConfiguration, - new INotificationCallback() { - - @Override - public void activateCallback(INotificationData data) { - buildWdSimulatorCallback(opEnv, client, buildDistributionClientConfiguration, data); - - } - - }); - assertThat(initResult.getDistributionActionResult(), is(DistributionActionResultEnum.SUCCESS)); - IDistributionClientResult startResult = client.start(); - assertThat(startResult.getDistributionActionResult(), is(DistributionActionResultEnum.SUCCESS)); - System.out.println(String.format("WD Simulator On Environment:\"%s\" Started Successfully", - buildDistributionClientConfiguration.getConsumerID())); - return client; - } - - private IFinalDistrStatusMessage buildFinalDistribution() { - return new IFinalDistrStatusMessage() { - - @Override - public long getTimestamp() { - return System.currentTimeMillis(); - } - - @Override - public DistributionStatusEnum getStatus() { - return DistributionStatusEnum.DISTRIBUTION_COMPLETE_OK; - } - - @Override - public String getDistributionID() { - return "FakeDistributionId"; - } - }; - } - - private IConfiguration buildDistributionClientConfiguration(String topicName, OperationalEnvironmentEntry opEnv) { - return new IConfiguration() { - - public String getUser() { - return "ci"; - } - - public int getPollingTimeout() { - return 20; - } - - public int getPollingInterval() { - return 20; - } - - public String getPassword() { - return "123456"; - } - - public String getEnvironmentName() { - return topicName; - } - - public String getConsumerID() { - return opEnv.getEnvironmentId(); - } - - public String getConsumerGroup() { - return String.format("BenchMarkDistributionClientConsumerGroup%s", opEnv.getEnvironmentId()); - } - - public String getAsdcAddress() { - return String.format("%s:8443", asdcAddress); - } - - @Override - public String getKeyStorePath() { - // TODO Auto-generated method stub - return null; - } - - @Override - public String getKeyStorePassword() { - // TODO Auto-generated method stub - return null; - } - - @Override - public boolean activateServerTLSAuth() { - // TODO Auto-generated method stub - return false; - } - - @Override - public List<String> getRelevantArtifactTypes() { - return Arrays.asList(ArtifactTypeEnum.values()).stream() - .map(artifactTypeEnum -> artifactTypeEnum.name()).collect(Collectors.toList()); - } - - @Override - public boolean isFilterInEmptyResources() { - // TODO Auto-generated method stub - return false; - } - - @Override - public Boolean isUseHttpsWithDmaap() { - return null; - } - - @Override - public List<String> getMsgBusAddress() { - return opEnv.getDmaapUebAddress().stream().map(this::extractHost).collect(Collectors.toList()); - } - - private String extractHost(String url) { - return url.split(":")[0]; - } - }; - } - - private void distributeServiceInEnv(OperationalEnvironmentEntry env) { - uuidServicesList.stream().forEach(serviceUUID -> distributeSingleService(env, serviceUUID)); - } - - private void distributeSingleService(OperationalEnvironmentEntry env, String serviceUUID) { - IHttpAsdcClient client = new HttpAsdcClient(buildDistributionClientConfiguration(StringUtils.EMPTY, env)); - String pattern = "/sdc/v1/catalog/services/%s/distribution/%s/activate"; - String requestUrl = String.format(pattern, serviceUUID, env.getEnvironmentId()); - String requestBody = String.format("{\"workloadContext\":\"%s\"}", env.getEnvironmentId()); - StringEntity body = new StringEntity(requestBody, ContentType.APPLICATION_JSON); - Map<String, String> headersMap = new HashMap<>(); - headersMap.put("USER_ID", "cs0008"); - headersMap.put("X-ECOMP-InstanceID", "test"); - headersMap.put("Content-Type", "application/json"); - - HttpAsdcResponse postRequest = FunctionalInterfaces.retryMethodOnResult( - () -> distributeMethod(client, requestUrl, serviceUUID, body, headersMap, env.getEnvironmentId()), - resp -> resp.getStatus() == HttpStatus.SC_ACCEPTED); - assertThat(postRequest.getStatus(), is(HttpStatus.SC_ACCEPTED)); - - } - - private HttpAsdcResponse distributeMethod(IHttpAsdcClient client, String requestUrl, String serviceUUID, - StringEntity body, Map<String, String> headersMap, String envId) { - - final HttpAsdcResponse postRequest = client.postRequest(requestUrl, body, headersMap); - final String message = String.format( - "MSO Client Simulator Distributes Service:%s On Environment:\"%s\" - Recieved Response: %s", serviceUUID, envId, - postRequest.getStatus()); - if (postRequest.getStatus() != HttpStatus.SC_ACCEPTED) { - System.err.println(message); - } else { - System.out.println(message); - } - - return postRequest; - } - - private String convertUebAddressToList(OperationalEnvironmentEntry op) { - Set<String> dmaapUebAddress = op.getDmaapUebAddress(); - Wrapper<String> resultWrapper = new Wrapper<>(StringUtils.EMPTY); - if (!CollectionUtils.isEmpty(dmaapUebAddress)) { - dmaapUebAddress.stream() - .forEach(uebAddress -> resultWrapper.setInnerElement(resultWrapper.getInnerElement() + uebAddress)); - } - - return resultWrapper.getInnerElement(); - } - - private void buildWdSimulatorCallback(OperationalEnvironmentEntry opEnv, IDistributionClient client, - final IConfiguration buildDistributionClientConfiguration, INotificationData data) { - if (StringUtils.equals(data.getWorkloadContext(), opEnv.getEnvironmentId())) { - - final String expectedArtifactType = org.openecomp.sdc.common.api.ArtifactTypeEnum.MODEL_INVENTORY_PROFILE.name(); - Optional<IArtifactInfo> optional = data.getServiceArtifacts().stream().filter( artifact -> { - return StringUtils.equals(artifact.getArtifactType(), expectedArtifactType); - }).findAny(); - - for (int i = 0; i < numOfArtifactsToDownload; i++) { - optional.ifPresent( artifactInfo -> simulateDownload(client , artifactInfo, data) ); - optional.orElseThrow( () -> handleArtifactNotFound(expectedArtifactType, data)); - - } - if( numOfArtifactsToDownload > 0 ){ - System.out.println(String.format( - "ASDC Consumer Simulator On Environment:\"%s\" Downloaded %s Artifacts From ASDC Service with UUID:%s Total Artifacts Downloaded from ASDC is: %s", - data.getWorkloadContext(), numOfArtifactsToDownload, - data.getServiceUUID(), totalNumOfArtifactsToDownload)); - } - - IDistributionClientResult finalDistrStatus = client.sendFinalDistrStatus(buildFinalDistribution()); - assertThat(finalDistrStatus.getDistributionActionResult(), is(DistributionActionResultEnum.SUCCESS)); - wdFinalStatusSent.add(data.getWorkloadContext()); - - System.out.println(String.format( - "WD Simulator On Environment:\"%s\" Recieved Notification From ASDC On WorkLoad: %s And Service UUID:%s And Sends Distribution Complete Notification", - buildDistributionClientConfiguration.getConsumerID(), data.getWorkloadContext(), - data.getServiceUUID())); - } - } - - private IllegalStateException handleArtifactNotFound(String expectedArtifactType, INotificationData data ){ - final String stringMessage = String.format("Did Not Find Artifact of type: %s to download from service with UUID:%s", expectedArtifactType, data.getServiceUUID()); - System.err.println(stringMessage); - return new IllegalStateException(stringMessage); - - } - - private void simulateDownload(IDistributionClient client, IArtifactInfo info, INotificationData data){ - IDistributionClientDownloadResult downloadResult = client.download(info); - if( downloadResult.getDistributionActionResult() != DistributionActionResultEnum.SUCCESS ){ - System.err.println(String.format("Client Simulator %s Failed to download artifact from service : %s", client.getConfiguration().getConsumerID(), data.getServiceUUID())); - assertThat(downloadResult.getDistributionActionResult(), is(DistributionActionResultEnum.SUCCESS)); - } - else{ - totalNumOfArtifactsToDownload++; - - } - } -} |