org.argeo.slc.webapp/src/test/java/org/argeo/slc/ws/SlcExecutionWsIntegrationTest.java

   1 package org.argeo.slc.ws;
   2
   3 import java.util.List;
   4 import java.util.Vector;
   5
   6 import org.springframework.ws.client.core.WebServiceTemplate;
   7 import org.springframework.ws.soap.client.SoapFaultClientException;
   8
   9 import org.apache.commons.logging.Log;
  10 import org.apache.commons.logging.LogFactory;
  11
  12 import org.argeo.slc.msg.process.SlcExecutionRequest;
  13 import org.argeo.slc.msg.process.SlcExecutionStatusRequest;
  14 import org.argeo.slc.msg.process.SlcExecutionStepsRequest;
  15 import org.argeo.slc.process.SlcExecution;
  16 import org.argeo.slc.process.SlcExecutionStep;
  17 import org.argeo.slc.unit.AbstractSpringTestCase;
  18 import org.argeo.slc.unit.process.SlcExecutionTestUtils;
  19 import org.argeo.slc.ws.client.WebServiceUtils;
  20
  21 public class SlcExecutionWsIntegrationTest extends AbstractSpringTestCase {
  22         private Log log = LogFactory.getLog(getClass());
  23
  24         private WebServiceTemplate template;
  25
  26         public void setUp() {
  27                 template = getBean(WebServiceTemplate.class);
  28         }
  29
  30         public void testSlcExecutionRequests() {
  31                 SlcExecution slcExec = createAndSendSlcExecution();
  32
  33                 slcExec.setUser("otherUser");
  34                 log.info("Send update SlcExecutionRequest for SlcExecution #"
  35                                 + slcExec.getUuid());
  36                 template.marshalSendAndReceive(new SlcExecutionRequest(slcExec));
  37         }
  38
  39         public void testSlcExecutionStatusRequest() {
  40                 SlcExecution slcExec = createAndSendSlcExecution();
  41
  42                 slcExec.setStatus(SlcExecution.STATUS_FINISHED);
  43                 log.info("Send SlcExecutionStatusRequest for SlcExecution #"
  44                                 + slcExec.getUuid());
  45                 template.marshalSendAndReceive(new SlcExecutionStatusRequest(slcExec
  46                                 .getUuid(), slcExec.getStatus()));
  47         }
  48
  49         public void testSendSlcExecutionStepRequest() {
  50                 SlcExecution slcExec = createAndSendSlcExecution();
  51
  52                 SlcExecutionStep step1 = new SlcExecutionStep(
  53                                 "Logline\nAnother log line.");
  54                 SlcExecutionStep step2 = new SlcExecutionStep(
  55                                 "Logline2\nAnother log line2.");
  56                 List<SlcExecutionStep> steps = new Vector<SlcExecutionStep>();
  57                 steps.add(step1);
  58                 steps.add(step2);
  59
  60                 log.info("Send SlcExecutionStepsRequest for SlcExecution #"
  61                                 + slcExec.getUuid());
  62                 try {
  63                         template.marshalSendAndReceive(new SlcExecutionStepsRequest(slcExec
  64                                         .getUuid(), steps));
  65                 } catch (SoapFaultClientException e) {
  66                         WebServiceUtils.manageSoapException(e);
  67                         throw e;
  68                 }
  69         }
  70
  71         protected SlcExecution createAndSendSlcExecution() {
  72                 SlcExecution slcExec = SlcExecutionTestUtils.createSimpleSlcExecution();
  73
  74                 log.info("Send create SlcExecutionRequest for SlcExecution #"
  75                                 + slcExec.getUuid());
  76                 template.marshalSendAndReceive(new SlcExecutionRequest(slcExec));
  77                 return slcExec;
  78         }
  79 }