/*
    * Copyright 2010 Fraunhofer Gesellschaft, Munich, Germany,
    * for its Fraunhofer Institute for Computer Architecture and Software
    * Technology (FIRST), Berlin, Germany. All rights reserved.
    * http://www.first.fraunhofer.de/
    */
   
   package net.kwfgrid.gwes;
   
  import junit.framework.Test;
  import junit.framework.TestSuite;
  import junit.framework.Assert;
  import net.kwfgrid.gwes.exception.LoggingException;
  import net.kwfgrid.gwes.workflowgenerator.WorkflowGenerator;
  import net.kwfgrid.gwes.workflowgenerator.SingleJob;
  import net.kwfgrid.gworkflowdl.structure.WorkflowFormatException;
  import net.kwfgrid.gworkflowdl.structure.CapacityException;
  import org.apache.log4j.Logger;
  
  import java.io.IOException;
  import java.util.*;
  
  /**
   * <code>
   * maven -Dtestcase=net.kwfgrid.gwes.WorkflowGeneratorTest test:single
   * </code>
   *
   * @author Andreas Hoheisel
   *         (<a href="http://www.andreas-hoheisel.de">www.andreas-hoheisel.de</a>)
   * @version $Id: WorkflowGeneratorTest.java 1529 2011-06-22 16:37:19Z hoheisel $
   */
  public final class WorkflowGeneratorTest extends LocalGWESAbstractTestCase {
  
      static Logger logger = Logger.getLogger(WorkflowGeneratorTest.class);
  
      /**
       * Create the test case.
       *
       * @param testName name of the test case
       */
      public WorkflowGeneratorTest(String testName) throws LoggingException {
          super(testName);
      }
  
      /**
       * @return the suite of tests being tested
       */
      public static Test suite() {
          return new TestSuite(WorkflowGeneratorTest.class);
      }
  
      /**
       * *******************************************************************************************
       * Begin of public test classes.
       * ********************************************************************************************
       */
  
      /**
       * Test single job.
       */
      public void testSingleJobWithoutInputs() throws WorkflowFormatException, CapacityException, IOException {
  
          WorkflowGenerator generator = new SingleJob("date","wsgram", "/bin/date@software:date", "https://countess.first.fhrg.fraunhofer.de:8443/wsrf/services/ManagedJobFactoryService@hardware:countess.first.fhrg.fraunhofer.de",null,null);
          String workflowXml = generator.getXML();
          logger.info(workflowXml);
          Assert.assertEquals("<description>Single job invoking 'date'</description>\r\n" +
                  "  <place ID=\"start\">\r\n" +
                  "    <token ID=\"cX\">\r\n" +
                  "      <control>true</control>\r\n" +
                  "    </token>\r\n" +
                  "  </place>\r\n" +
                  "  <place ID=\"end\" />\r\n" +
                  "  <transition ID=\"date\">\r\n" +
                  "    <inputPlace placeID=\"start\" />\r\n" +
                  "    <outputPlace placeID=\"end\" />\r\n" +
                  "    <operation>\r\n" +
                  "      <oc:operationClass name=\"date\">\r\n" +
                  "        <oc:operationCandidate type=\"wsgram\" operationName=\"/bin/date@software:date\" resourceName=\"https://countess.first.fhrg.fraunhofer.de:8443/wsrf/services/ManagedJobFactoryService@hardware:countess.first.fhrg.fraunhofer.de\" quality=\"0.0\" selected=\"true\" />\r\n" +
                  "      </oc:operationClass>\r\n" +
                  "    </operation>\r\n" +
                  "  </transition>\r\n" +
                  "</workflow>\r\n\r\n",stripTokenIDs(workflowXml.substring(workflowXml.indexOf("<description>"))));
      }
  
      /**
       * Test single job with inputs and outputs.
       * @throws WorkflowFormatException
       * @throws CapacityException
       * @throws IOException
       */
      public void testSingleJobWithInputs() throws WorkflowFormatException, CapacityException, IOException {
          Map<String,String> inputs = new LinkedHashMap<String,String>();
          inputs.put("input1","value1");
          inputs.put("input2","value2");
          inputs.put("input3","value3");
          List<String> outputs = new ArrayList<String>();
          outputs.add("output1");
          WorkflowGenerator generator = new SingleJob("oclass1", "type1", "operation1", "resource1",inputs,outputs);
          String workflowXml = generator.getXML();
         logger.info(workflowXml);
 
         Assert.assertEquals("<description>Single job invoking 'oclass1'</description>\r\n" +
                 "  <place ID=\"input1\">\r\n" +
                 "    <token ID=\"dX\">\r\n" +
                 "      <data>\r\n" +
                 "        <input1 xmlns=\"\">value1</input1>\r\n" +
                 "      </data>\r\n" +
                 "    </token>\r\n" +
                 "  </place>\r\n" +
                 "  <place ID=\"input2\">\r\n" +
                 "    <token ID=\"dX\">\r\n" +
                 "      <data>\r\n" +
                 "        <input2 xmlns=\"\">value2</input2>\r\n" +
                 "      </data>\r\n" +
                 "    </token>\r\n" +
                 "  </place>\r\n" +
                 "  <place ID=\"input3\">\r\n" +
                 "    <token ID=\"dX\">\r\n" +
                 "      <data>\r\n" +
                 "        <input3 xmlns=\"\">value3</input3>\r\n" +
                 "      </data>\r\n" +
                 "    </token>\r\n" +
                 "  </place>\r\n" +
                 "  <place ID=\"output1\" />\r\n" +
                 "  <transition ID=\"oclass1\">\r\n" +
                 "    <inputPlace placeID=\"input1\" edgeExpression=\"input1\" />\r\n" +
                 "    <inputPlace placeID=\"input2\" edgeExpression=\"input2\" />\r\n" +
                 "    <inputPlace placeID=\"input3\" edgeExpression=\"input3\" />\r\n" +
                 "    <outputPlace placeID=\"output1\" edgeExpression=\"output1\" />\r\n" +
                 "    <operation>\r\n" +
                 "      <oc:operationClass name=\"oclass1\">\r\n" +
                 "        <oc:operationCandidate type=\"type1\" operationName=\"operation1\" resourceName=\"resource1\" quality=\"0.0\" selected=\"true\" />\r\n" +
                 "      </oc:operationClass>\r\n" +
                 "    </operation>\r\n" +
                 "  </transition>\r\n" +
                 "</workflow>\r\n\r\n",stripTokenIDs(workflowXml.substring(workflowXml.indexOf("<description>"))));
     }
 
 
     /**
      * *******************************************************************************************
      * End of public test classes.
      * ********************************************************************************************
      */
 
 }