gerrit.onap Code Review - so.git/blob

   1 package org.onap.so.simulator.scenarios.openstack;
   2
   3 import org.springframework.core.io.ClassPathResource;
   4 import org.springframework.http.HttpStatus;
   5 import org.springframework.web.bind.annotation.RequestMapping;
   6 import org.springframework.web.bind.annotation.RequestMethod;
   7 import org.onap.so.simulator.actions.aai.DeleteVServers;
   8 import com.consol.citrus.endpoint.resolver.DynamicEndpointUriResolver;
   9 import com.consol.citrus.simulator.scenario.AbstractSimulatorScenario;
  10 import com.consol.citrus.simulator.scenario.Scenario;
  11 import com.consol.citrus.simulator.scenario.ScenarioDesigner;
  12
  13 @Scenario("Double-Failure-Stack-Endpoint")
  14 @RequestMapping(value = "/sim/mockPublicUrl/stacks/double_failure_id/stackId")
  15 public class QueryStackByIdDoubleFailure extends AbstractSimulatorScenario {
  16
  17
  18     @Override
  19     public void run(ScenarioDesigner scenario) {
  20         // Create Poll Service
  21         scenario.scenarioEndpoint().getEndpointConfiguration().setTimeout(300000L);
  22         scenario.http().receive().get().extractFromHeader(DynamicEndpointUriResolver.REQUEST_PATH_HEADER_NAME,
  23                 "correlationId");
  24         scenario.echo("${correlationId}"); // step 2
  25         scenario.correlation().start().onHeader(DynamicEndpointUriResolver.REQUEST_PATH_HEADER_NAME,
  26                 "${correlationId}");
  27
  28         scenario.variable("stackName", "double_failure_id");
  29         scenario.variable("cloudOwner", "cloudOwner");
  30         scenario.variable("cloudRegion", "regionTwo");
  31         scenario.variable("tenantId", "872f331350c54e59991a8de2cbffb40c");
  32         scenario.variable("vServerId", "d29f3151-592d-4011-9356-ad047794e236");
  33         scenario.variable("stack_failure_message", "The Flavor ID (nd.c6r16d20) could not be found.");
  34         scenario.http().send().response(HttpStatus.OK) // step 4
  35                 .payload(new ClassPathResource("openstack/gr_api/Stack_Failure.json"));
  36
  37         // Create Poll Retry
  38         scenario.http().receive().get(); // step 5
  39         scenario.http().send().response(HttpStatus.OK)
  40                 .payload(new ClassPathResource("openstack/gr_api/Stack_Failure.json"));
  41
  42         // Rollback Poll
  43         scenario.http().receive().get(); // step 7
  44         scenario.http().send().response(HttpStatus.OK)
  45                 .payload(new ClassPathResource("openstack/gr_api/Stack_Failure.json"));
  46
  47         // Rollback Poll Retry
  48         scenario.http().receive().get(); // step 9
  49         scenario.http().send().response(HttpStatus.OK)
  50                 .payload(new ClassPathResource("openstack/gr_api/Stack_Failure.json"));
  51
  52         // Create Poll
  53         scenario.http().receive().get(); // step 11
  54         scenario.http().send().response(HttpStatus.OK)
  55                 .payload(new ClassPathResource("openstack/gr_api/Stack_Failure.json"));
  56
  57         // Create Poll Retry
  58         scenario.http().receive().get();
  59         scenario.http().send().response(HttpStatus.OK)
  60                 .payload(new ClassPathResource("openstack/gr_api/Stack_Failure.json"));
  61
  62         // Rollback Poll
  63         scenario.http().receive().get(); // step 15
  64         scenario.http().send().response(HttpStatus.OK)
  65                 .payload(new ClassPathResource("openstack/gr_api/Stack_Failure.json"));
  66
  67         // Rollback Poll Retry
  68         scenario.http().receive().get(); // step 17
  69         scenario.http().send().response(HttpStatus.OK)
  70                 .payload(new ClassPathResource("openstack/gr_api/Stack_Failure.json"));
  71
  72     }
  73
  74 }