/*
    * 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.operationmapper;
   
   import net.kwfgrid.gworkflowdl.structure.Operation;
  import org.apache.log4j.Logger;
  import net.kwfgrid.gwes.GenericWorkflowHandler;
  import net.kwfgrid.gwes.Constants;
  import net.kwfgrid.gwes.exception.OperationMapperException;
  import net.kwfgrid.gwes.exception.StateTransitionException;
  import net.kwfgrid.gworkflowdl.structure.Transition;
  import net.kwfgrid.gworkflowdl.structure.Workflow;
  import net.kwfgrid.gworkflowdl.structure.OperationClass;
  import de.fraunhofer.first.resmatch.client.ResourceMatcherClient;
  
  import java.util.ArrayList;
  
  /**
   * Maps red operations to yellow ones, using the Resource Matcher service.
   * @author Andreas Hoheisel
   *         (<a href="http://www.andreas-hoheisel.de">www.andreas-hoheisel.de</a>)
   * @version $Id: Yellow2BlueResourceMatcherOperationMapper.java 1520 2011-02-28 16:44:35Z hoheisel $
   */
  public class Yellow2BlueResourceMatcherOperationMapper extends OperationMapper {
  
      /**
       * log4j logger.
       */
      final static Logger logger = Logger.getLogger(Yellow2BlueResourceMatcherOperationMapper.class);
  
      /**
       * Maps the operation contained in the specified transition to a less abstract level.
       *
       * @param transition
       * @return <code>true</code> if a mapping was possible, <code>false</code> otherwise.
       */
      public boolean processTransition(GenericWorkflowHandler handler, Transition transition) throws OperationMapperException {
          if (transition.getAbstractionLevel() != Operation.YELLOW) {
              logger.warn("Invoked Yellow2BlueResourceMatcherOperationMapper for operation on transition \""+transition.getID()+"\" that is not Yellow! ");
              return false;
          }
          boolean modification = false;
          if (!(handler.getWorkflow() instanceof Workflow))
              throw new OperationMapperException("Workflow class not supported.");
  
          Workflow workflow = (Workflow) handler.getWorkflow();
          String operationClass = ((OperationClass) transition.getOperation().get()).getName();
          logger.info("processing yellow transition \"" + transition.getID() + "\" ...");
  
          if (transition.getProperties().get(Constants.PROP_TRANSITION_RESOURCEMATCHER_REFINEMENT_FAILED) != null
                  || transition.getProperties().get(Constants.PROP_TRANSITION_YELLOW2BLUE_REFINEMENT_FAILED) != null) {
              logger.warn("This workflow contains yellow transitions that cannot be refined automatically. There are no matching operation and resource instances registered for operation class \"" + operationClass + "\"");
              workflow.getProperties().put(Constants.PROP_WARN_ + handler.createNewErrorID(),
                      "This workflow contains yellow transitions that cannot be refined automatically. There are no matching operation and resource instances registered for operation class \"" + operationClass + "\"");
              try {
                  handler.suspendWorkflowAsync();
              } catch (StateTransitionException e) {
                  logger.warn("exception:\n" + e, e);
              }
              // reset refinement failed in order transition be able transition refine again on next try
              transition.getProperties().remove("resourcematcher.refinement.failed");
              transition.getProperties().remove("yellow2blue.refinement.failed");
          } else {
              try {
                  logger.info("Workflow refinement: invoking ResourceMatcher (yellow -> blue) ...");
  
                  String newWorkflow = ResourceMatcherClient.getInstance().match(handler.getWorkflowDescription());
                  if (newWorkflow == null) {
                      logger.warn("This workflow contains yellow transitions that cannot be refined automatically. The resource matcher returned \"null\" for operation class \"" + operationClass + "\"");
                      workflow.getProperties().put(Constants.PROP_WARN_ + handler.createNewErrorID(),
                              "This workflow contains yellow transitions that cannot be refined automatically. The resource matcher returned \"null\" for operation class \"" + operationClass + "\"");
                      handler.suspendWorkflowAsync();
  //                } else if (handler.getWorkflowDescription().equals(newWorkflow)) {
  //                        logger.error("The ResourceMatcher was not able transition refine the workflow description");
  //                        workflow.getProperties().put(GWorkflowDLHandler.PROP_ERROR_ + handler.createNewErrorID(), "The ResourceMatcher was not able transition refine the workflow description");
  //                        handler.suspendWorkflowAsync();
                  } else if (newWorkflow.startsWith("<soapenv:Fault")) {
                      logger.warn("This workflow contains yellow transitions that cannot be refined automatically due transition an error with the resource matcher.");
                      workflow.getProperties().put(Constants.PROP_WARN_ + handler.createNewErrorID(),
                              "This workflow contains yellow transitions that cannot be refined automatically due transition an error with the resource matcher.");
                      handler.suspendWorkflowAsync();
                  } else {
                      // ToDo: FixMe: Problem when exchanging whole workflow while other transitions are still active! 
                      handler.setWorkflowDescription(newWorkflow);
                      modification = true;
                      logger.info("Workflow refinement by ResourceMatcher done.");
                      if (logger.isDebugEnabled())
                          logger.debug("==========> new ResourceMatcher Workflow <==========\n" + newWorkflow);
                  }
              } catch (Exception e) {
                  logger.error("Invocation of ResourceMatcher failed: " + e, e);
                  try {
                      handler.abortWorkflowAsync();
                  } catch (StateTransitionException e1) {
                      logger.error("exception:\n" + e1, e1);
                 }
                 workflow.getProperties().put(Constants.PROP_ERROR_ + handler.createNewErrorID(), "Invocation of ResourceMatcher failed: " + e);
             }
         }
 
         return modification;
     }
 
     /**
      * Maps the operation contained in the specified list of transitions to a less abstract level.
      *
      * @param handler     The parent workflow handler.
      * @param transitions The list of transitions.
      * @return <code>true</code> if a mapping was possible, <code>false</code> otherwise.
      * @throws net.kwfgrid.gwes.exception.OperationMapperException
      *
      */
     public boolean processTransitions(GenericWorkflowHandler handler, ArrayList<Transition> transitions) throws OperationMapperException {
         /// not impelemented.
         return false;
     }
 }