/**
    * Copyright 2005-2015 The Kuali Foundation
    *
    * Licensed under the Educational Community 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.opensource.org/licenses/ecl2.php
    *
   * 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.
   */
  package org.kuali.rice.kew.engine.node;
  
  import org.apache.log4j.MDC;
  import org.kuali.rice.kew.actionrequest.ActionRequestValue;
  import org.kuali.rice.kew.api.exception.WorkflowException;
  import org.kuali.rice.kew.engine.RouteContext;
  import org.kuali.rice.kew.engine.RouteHelper;
  import org.kuali.rice.kew.routeheader.DocumentRouteHeaderValue;
  import org.kuali.rice.kew.service.KEWServiceLocator;
  import org.kuali.rice.kew.api.KewApiConstants;
  import org.kuali.rice.kew.util.PerformanceLogger;
  import org.kuali.rice.kew.util.Utilities;
  
  import java.util.ArrayList;
  import java.util.Collections;
  import java.util.Iterator;
  import java.util.List;
  
  
  /**
   * A node which will iteratively activate any requests pending on it.  Subclasses are responsible for generating the requests
   * to be activated, and then delegating to superclass {@link #process(RouteContext, RouteHelper)} to activate
   * those requests.
   *
   * This node can be used to serve multiple batches of requests, and can be re-entered multiple times.  The algorithm it implements is:
   * 
   * <ol>
   *   <li>activate any existing requests (requests may have been generated by an external party)
   *   <li>while request fulfillment criteria indicates that any pending requests have been satisfied
   *     <ol>
   *       <li>generate new requests</li>
   *       <li><b>if no requests were generated, we are done, return and transition</b></li>
   *       <li>otherwise if requests were generated
   *         <ol>
   *           <li>activate requests (depending on activation policy, serial or parallel, <i>NOT ALL GENERATED REQUESTS MAY BE ACTIVATED AT THIS POINT</i>)</li>
   *           <li>determine a request fulfillment criteria</li>
   *           <li>continue in loop</li>
   *         </ol>
   *       </li>
   *   </li>
   *   <li>otherwise if pending requests have not been satisfied, block until invoked again</li>
   * </ol>
   * This node transitions/completes when there are no remaining <i>blocking</i> action requests (i.e., no approval or
   * completion requests).
   *
   * @author Kuali Rice Team (rice.collab@kuali.org)
   */
  public class IteratedRequestActivationNode implements SimpleNode {
  
      protected final org.apache.log4j.Logger LOG = org.apache.log4j.Logger.getLogger(getClass());
      private static long generatedRequestPriority = 0;
  
      protected static interface RequestFulfillmentCriteria {
          public boolean pendingRequestsAreFulfilled(boolean activatedBlockingRequests, RouteContext routeContext);
      }
  
      private static class AllBlockingRequestsCompleteCriteria implements RequestFulfillmentCriteria {
          public boolean pendingRequestsAreFulfilled(boolean activatedBlockingRequests, RouteContext routeContext) {
              // determine whether there are any pending blocking requests
              if (activatedBlockingRequests) {
                  // if we just activated blocking requests then surely there are pending blocking requests
                  assert(activatedBlockingRequests == blockingRequestsArePending(routeContext.getDocument(), routeContext.getNodeInstance())) : "Blocking requests were activated but none were subsequently found";
                  return false;
              } else {
                  // otherwise let's see if there are any pre-existing blocking requests associated with this node instance
                  return !blockingRequestsArePending(routeContext.getDocument(), routeContext.getNodeInstance());
              }
          }
      }
  
      private static class SimulatingCriteria implements RequestFulfillmentCriteria {
          public boolean pendingRequestsAreFulfilled(boolean activatedBlockingRequests, RouteContext routeContext) {
              // when simulating, never block for requests to be fulfilled
              return true;
          }
      }
  
      public SimpleResult process(RouteContext routeContext, RouteHelper routeHelper) throws Exception {
          // if previous requests were satisfied (if no requests have been generated yet, this should return true
          RequestFulfillmentCriteria criteria = getRequestFulfillmentCriteria(routeContext);
          // generate new requests until they are not satisfied or none are generated
          // if none are generated then we should transition immediately
          boolean activatedBlockingRequests = activateRequests(routeContext); // activation should always occur as something might have generated unactived requests
          boolean initialRequestGeneration = routeContext.getNodeInstance().isInitial();
         while (criteria.pendingRequestsAreFulfilled(activatedBlockingRequests, routeContext)) {
             boolean newRequestsGenerated = generateNewRequests(initialRequestGeneration, routeContext, routeHelper);
             initialRequestGeneration = false;
 
             if (!newRequestsGenerated) {
                 // if the pending requests were fulfilled
                 // ...and we didn't generate any new requests
                 // ...then there are no further requests to activate (XXX: WRONG)
                 // ...and we have no more processing to do
                 return new SimpleResult(true);
             }
 
             // activate any requests that were generated
             activatedBlockingRequests = activateRequests(routeContext);
 
             // set the request fulfillment criteria for the new set of requests
             // if we are simulating, always set a criteria that indicates fulfillment
             if (routeContext.isSimulation()) {
                 criteria = new SimulatingCriteria();
             } else {
                 criteria = getRequestFulfillmentCriteria(routeContext);
             }
         }
         // if we got here, then for some reason pending requests have not been fulfilled
         // so wait/block for request fulfillment
         return new SimpleResult(false);
     }
 
     /**
      * Template method that subclasses should override to indicate when activated requests have been fulfilled.
      * The default implementation is that all pending blocking requests must be fulfilled.
      * @return a RequestFulfillmentCriteria that indicates when activated requests have been fulfilled.
      */
     protected RequestFulfillmentCriteria getRequestFulfillmentCriteria(RouteContext routeContext) {
         return new AllBlockingRequestsCompleteCriteria();
     }
 
     /**
      * Template method that subclasses should override to generates new requests
      * @param initial whether this is the very first request generation, that is, the first generation in the first invocation of the node
      * @return whether new requests were generated
      * @throws Exception 
      */
     protected boolean generateNewRequests(boolean initial, RouteContext context, RouteHelper routeHelper) throws WorkflowException, Exception {
         return false;
     }
 
     /**
      * Activates any pending requests and returns whether there are outstanding blocking requests
      * @param context the RouteContext
      * @throws org.kuali.rice.kew.api.exception.WorkflowException if anything goes wrong...
      * @return whether there are outstanding blocking requests
      */
     protected boolean activateRequests(RouteContext routeContext) throws WorkflowException {
         DocumentRouteHeaderValue document = routeContext.getDocument();
         RouteNodeInstance nodeInstance = routeContext.getNodeInstance();
         if (routeContext.isSimulation()) {
             // this seems to indicate whether, when we are simulating, to activate requests...
             if (routeContext.getActivationContext().isActivateRequests()) {
                 activateRequests(routeContext, document, nodeInstance);
             }
             // if we are in simulation, don't block, just transition out
             return false;
         } else {
             // activate any unactivated pending requests on this node instance
             return activateRequests(routeContext, document, nodeInstance);
         }
     }
 
     /**
      * @return whether there are any pending requests at the given route node instance which are blocking (i.e., 'approve' or 'complete')
      */
     private static boolean blockingRequestsArePending(DocumentRouteHeaderValue document, RouteNodeInstance nodeInstance) {
         // returns blocking requests that are *activated*
         List<ActionRequestValue> requests = KEWServiceLocator.getActionRequestService().findPendingRootRequestsByDocIdAtRouteNode(document.getDocumentId(), nodeInstance.getRouteNodeInstanceId());
         boolean blockingRequestsArePending = false;
         for (ActionRequestValue request: requests) {
             if (request.isApproveOrCompleteRequest()) {
                 blockingRequestsArePending = true;
                 break;
             }
         }
         return blockingRequestsArePending;
     }
 
     /**
      * Activates the action requests that are pending at this routelevel of the document. The requests are processed by priority and then request ID.
      * It is implicit in the access that the requests are activated according to the route level above all.
      * <p>
      * FYI and acknowledgement requests do not cause the processing to stop. Only action requests for approval or completion cause the processing to
      * stop and then only for route level with a serialized activation policy. Only requests at the current document's current route level are activated.
      * Inactive requests at a lower level cause a routing exception.
      * <p>
      * Exception routing and adhoc routing are processed slightly differently.
      * 
      * 
      * @param context the RouteContext
      * @param document the document we are processing
      * @param nodeInstance the node instance we are processing
      * @return True if the any blocking actions requests (approve or complete) were activated.
      * @throws org.kuali.rice.kew.api.exception.ResourceUnavailableException
      * @throws org.kuali.rice.kew.api.exception.WorkflowException
      */
     private boolean activateRequests(RouteContext context, DocumentRouteHeaderValue document, RouteNodeInstance nodeInstance) throws WorkflowException {
         MDC.put("docId", document.getDocumentId());
         PerformanceLogger performanceLogger = new PerformanceLogger(document.getDocumentId());
         List generatedActionItems = new ArrayList();
         List<ActionRequestValue> requests = KEWServiceLocator.getActionRequestService().findPendingRootRequestsByDocIdAtRouteNode(document.getDocumentId(), nodeInstance.getRouteNodeInstanceId());
         if (context.isSimulation()) {
             requests.addAll(context.getEngineState().getGeneratedRequests());
         }
         // this will sort higher priority requests to the front
         // blocking requests are higher priority, so all blocking requests will be
         // activated before non-blocking requests
         Collections.sort(requests, new Utilities.PrioritySorter());
         LOG.info("Pending Root Requests " + requests.size());
         String activationType = nodeInstance.getRouteNode().getActivationType();
         boolean isParallel = KewApiConstants.ROUTE_LEVEL_PARALLEL.equals(activationType);
         boolean activatedApproveRequest = false;
         for (Iterator iter = requests.iterator(); iter.hasNext();) {
             if (activatedApproveRequest && !isParallel) {
                 LOG.info("Already activated an apprve request and serial, so not activating any more");
                 break;
             }
             ActionRequestValue request = (ActionRequestValue) iter.next();
             LOG.info("ActionRequestValue: " + request);
             if (request.getParentActionRequest() != null || request.getNodeInstance() == null) {
                 // 1. disregard request if it's not a top-level request
                 // 2. disregard request if it's a "future" request and hasn't been attached to a node instance yet
                 continue; 
             }
             if (request.isActive()) {
                 activatedApproveRequest = activatedApproveRequest || request.isApproveOrCompleteRequest();
                 continue;
             }
             logProcessingMessage(request);   
             LOG.info("Activating request. " + request);
             activatedApproveRequest = activateRequest(context, request, nodeInstance, generatedActionItems) || activatedApproveRequest;
         }
         // now let's send notifications, since this code needs to be able to activate each request individually, we need
         // to collection all action items and then notify after all have been generated
         if (!context.isSimulation()) {
             KEWServiceLocator.getNotificationService().notify(generatedActionItems);
         }
         performanceLogger.log("Time to activate requests.");
         return activatedApproveRequest;
     }
 
     private boolean activateRequest(RouteContext context, ActionRequestValue actionRequest, RouteNodeInstance nodeInstance, List generatedActionItems) {
         if (actionRequest.isRoleRequest()) {
             List actionRequests = KEWServiceLocator.getActionRequestService().findPendingRootRequestsByDocIdAtRouteNode(actionRequest.getDocumentId(), nodeInstance.getRouteNodeInstanceId());
             for (Iterator iterator = actionRequests.iterator(); iterator.hasNext();) {
                 ActionRequestValue siblingRequest = (ActionRequestValue) iterator.next();
                 if (actionRequest.getRoleName().equals(siblingRequest.getRoleName())) {
                     KEWServiceLocator.getActionRequestService().activateRequestNoNotification(siblingRequest, context.getActivationContext());
                     // the generated action items can be found in the activation context
                     generatedActionItems.addAll(context.getActivationContext().getGeneratedActionItems());
                 }
             }
         }
         KEWServiceLocator.getActionRequestService().activateRequestNoNotification(actionRequest, context.getActivationContext());
         // the generated action items can be found in the activation context
         generatedActionItems.addAll(context.getActivationContext().getGeneratedActionItems());
         return actionRequest.isApproveOrCompleteRequest() && ! actionRequest.isDone();
     }
     
     protected ActionRequestValue saveActionRequest(RouteContext context, ActionRequestValue actionRequest) {
         if (!context.isSimulation()) {
             return KEWServiceLocator.getActionRequestService().saveActionRequest(actionRequest);
         } else {
             actionRequest.setActionRequestId(String.valueOf(generatedRequestPriority++));
             context.getEngineState().getGeneratedRequests().add(actionRequest);
             return actionRequest;
         }
         
     }
     
     private void logProcessingMessage(ActionRequestValue request) {
         //if (LOG.isDebugEnabled()) {
                 RouteNodeInstance nodeInstance = request.getNodeInstance();
             StringBuffer buffer = new StringBuffer();
             buffer.append("Processing AR: ").append(request.getActionRequestId()).append("\n");
             buffer.append("AR Node Name: ").append(nodeInstance != null ? nodeInstance.getName() : "null").append("\n");
             buffer.append("AR RouteLevel: ").append(request.getRouteLevel()).append("\n");
             buffer.append("AR Request Code: ").append(request.getActionRequested()).append("\n");
             buffer.append("AR Request priority: ").append(request.getPriority()).append("\n");
             LOG.info(buffer);
         //}
     }
             
 }