/**
    * 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.ken.service.impl;
  
  import org.apache.commons.lang.StringUtils;
  import org.kuali.rice.ken.bo.NotificationMessageDelivery;
  import org.kuali.rice.ken.document.kew.NotificationWorkflowDocument;
  import org.kuali.rice.ken.service.NotificationMessageContentService;
  import org.kuali.rice.ken.service.NotificationWorkflowDocumentService;
  import org.kuali.rice.ken.util.NotificationConstants;
  import org.kuali.rice.kew.api.WorkflowDocument;
  import org.kuali.rice.kew.api.WorkflowRuntimeException;
  import org.kuali.rice.kew.api.action.ActionRequest;
  import org.kuali.rice.kew.api.action.ActionRequestType;
  import org.kuali.rice.kim.api.identity.principal.Principal;
  import org.kuali.rice.kim.api.services.KimApiServiceLocator;
  
  import java.util.List;
  
  /**
   * This class is responsible for interacting with KEW - this is the default implementation that
   * leverages the KEW client API.
   * @author Kuali Rice Team (rice.collab@kuali.org)
   */
  public class NotificationWorkflowDocumentServiceImpl implements NotificationWorkflowDocumentService {
      private static org.apache.log4j.Logger LOG = org.apache.log4j.Logger
              .getLogger(NotificationWorkflowDocumentServiceImpl.class);
  
      private NotificationMessageContentService messageContentService;
  
      /**
       * Constructs a NotificationWorkflowDocumentServiceImpl instance.
       * @param messageContentService
       */
      public NotificationWorkflowDocumentServiceImpl(NotificationMessageContentService messageContentService) {
          this.messageContentService = messageContentService;
      }
  
      /**
       * Implements by instantiating a NotificationWorkflowDocument, which in turn interacts with
       * Workflow to set it up with an initiator of the passed in user id.
       * @see org.kuali.rice.ken.service.NotificationWorkflowDocumentService#createAndAdHocRouteNotificationWorkflowDocument(org.kuali.rice.ken.bo.NotificationMessageDelivery,
       *      java.lang.String, java.lang.String, java.lang.String)
       */
      public String createAndAdHocRouteNotificationWorkflowDocument(NotificationMessageDelivery messageDelivery,
              String initiatorUserId,
              String recipientUserId, String annotation) {
          // obtain a workflow user object first
          //WorkflowIdDTO initiator = new WorkflowIdDTO(initiatorUserId);
  
          // now construct the workflow document, which will interact with workflow
          WorkflowDocument document;
          if (StringUtils.isNotBlank(messageDelivery.getNotification().getDocTypeName())) {
              document = NotificationWorkflowDocument.createNotificationDocument(initiatorUserId,
                      messageDelivery.getNotification().getDocTypeName());
          } else {
              document = NotificationWorkflowDocument.createNotificationDocument(initiatorUserId);
          }
  
          // this is our loose foreign key to our message delivery record in notification
          document.setApplicationDocumentId(messageDelivery.getId().toString());
          //document.setAppDocId(messageDelivery.getId().toString());
  
          // now add the content of the notification as XML to the document
          document.setApplicationContent(messageContentService.generateNotificationMessage(
                  messageDelivery.getNotification(), messageDelivery.getUserRecipientId()));
  
          if (!StringUtils.isBlank(messageDelivery.getNotification().getTitle())) {
              document.setTitle(messageDelivery.getNotification().getTitle());
          } else {
              LOG.error("Encountered notification with no title set: Message Delivery #" + messageDelivery.getId()
                      + ", Notification #" + messageDelivery.getNotification().getId());
          }
  
          // now set up the ad hoc route
          String actionRequested;
          if (NotificationConstants.DELIVERY_TYPES.ACK.equals(messageDelivery.getNotification().getDeliveryType())) {
              actionRequested = NotificationConstants.KEW_CONSTANTS.ACK_AD_HOC_ROUTE;
          } else {
              actionRequested = NotificationConstants.KEW_CONSTANTS.FYI_AD_HOC_ROUTE;
          }
  
          // Clarification of ad hoc route call
          // param 1 - actionRequested will be either ACK or FYI
          // param 2 - annotation is whatever text we pass in to describe the transaction - this will be system generated
          // param 3 - recipient is the person who will receive this request
         // param 4 - this is the responsibilityParty (a.k.a the system that produced this request), so we'll put the producer name in there
         // param 5 - this is the "force action" requests - if set to true, this will be delivered to the recipients list regardless of
         //           whether the recipient has already taken action on this request; in our case, this doesn't really apply at this point in time,
         //           so we'll set to true just to be safe
         
         // recipientUserId will always be a principal ID due to code changes in NotificationMessageDeliveryResolverServiceImpl.buildCompleteRecipientList()
         Principal principal = KimApiServiceLocator.getIdentityService().getPrincipal(recipientUserId);
         
         document.adHocToPrincipal(ActionRequestType.fromCode(actionRequested), annotation, principal.getPrincipalId(),
                 messageDelivery.getNotification().getProducer().getName(), true);
 
         // now actually route it along its way
         document.route(annotation);
 
         return document.getDocumentId();
     }
 
     /**
      * This service method is implemented by constructing a NotificationWorkflowDocument using the
      * pre-existing document Id that is passed in.
      * @see org.kuali.rice.ken.service.NotificationWorkflowDocumentService#findNotificationWorkflowDocumentByDocumentId(java.lang.String,
      *      java.lang.String)
      */
     public WorkflowDocument getNotificationWorkflowDocumentByDocumentId(String initiatorUserId,
             String workflowDocumentId) {
         // construct the workflow id value object
         //WorkflowIdDTO initiator = new WorkflowIdDTO(initiatorUserId);
 
         // now return the actual document instance
         // this handles going out and getting the workflow document
         return NotificationWorkflowDocument.loadNotificationDocument(initiatorUserId, workflowDocumentId);
     }
 
     /**
      * @see org.kuali.rice.ken.service.NotificationWorkflowDocumentService#clearAllFyisAndAcknowledgeNotificationWorkflowDocument(java.lang.String,
      *      org.kuali.rice.ken.document.kew.NotificationWorkflowDocument, java.lang.String)
      */
     public void clearAllFyisAndAcknowledgeNotificationWorkflowDocument(String initiatorUserId,
             WorkflowDocument workflowDocument, String annotation) {
         List<ActionRequest> reqs = workflowDocument.getRootActionRequests();
         for (int i = 0; i < reqs.size(); i++) {
             LOG.info("Action Request[" + i + "] = " + reqs.get(i).getActionRequested());
             if (reqs.get(i).getActionRequested().equals(ActionRequestType.ACKNOWLEDGE)) {
                 workflowDocument.acknowledge(annotation);
             } else if (reqs.get(i).getActionRequested().equals(ActionRequestType.FYI)) {
                 workflowDocument.logAnnotation(annotation);
                 workflowDocument.fyi();
             } else {
                 throw new WorkflowRuntimeException("Invalid notification action request in workflow document ("
                         + workflowDocument.getDocumentId()
                         + ") was encountered.  Should be either an acknowledge or fyi and was not.");
             }
         }
     }
 
     /** 
      * @see org.kuali.rice.ken.service.NotificationWorkflowDocumentService#terminateWorkflowDocument(org.kuali.rice.kew.api.WorkflowDocument)
      */
     public void terminateWorkflowDocument(WorkflowDocument document) {
         document.superUserCancel("terminating document: documentId=" + document.getDocumentId() + ", appDocId="
                 + document.getApplicationDocumentId());
     }
 }