/*

  * Copyright 2005-2007 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.superuser.web;

 import java.util.Collection;

 import java.util.Iterator;

 import javax.servlet.http.HttpServletRequest;

 import javax.servlet.http.HttpServletResponse;

 import javax.xml.namespace.QName;

 import org.apache.commons.lang.ArrayUtils;

 import org.apache.commons.lang.StringUtils;

 import org.apache.struts.action.ActionForm;

 import org.apache.struts.action.ActionForward;

 import org.apache.struts.action.ActionMapping;

 import org.kuali.rice.core.resourceloader.GlobalResourceLoader;

 import org.kuali.rice.core.util.JSTLConstants;

 import org.kuali.rice.kew.actionrequest.ActionRequestValue;

 import org.kuali.rice.kew.doctype.bo.DocumentType;

 import org.kuali.rice.kew.dto.AdHocRevokeDTO;

 import org.kuali.rice.kew.dto.DTOConverter;

 import org.kuali.rice.kew.dto.RouteNodeInstanceDTO;

 import org.kuali.rice.kew.exception.WorkflowException;

 import org.kuali.rice.kew.exception.WorkflowServiceErrorException;

 import org.kuali.rice.kew.exception.WorkflowServiceErrorImpl;

 import org.kuali.rice.kew.routeheader.DocumentRouteHeaderValue;

 import org.kuali.rice.kew.service.KEWServiceLocator;

 import org.kuali.rice.kew.service.WorkflowDocument;

 import org.kuali.rice.kew.service.WorkflowDocumentActions;

 import org.kuali.rice.kew.service.WorkflowInfo;

 import org.kuali.rice.kew.util.KEWConstants;

 import org.kuali.rice.kew.web.AppSpecificRouteRecipient;

 import org.kuali.rice.kew.web.KewKualiAction;

 import org.kuali.rice.kew.web.session.UserSession;

 import org.kuali.rice.kim.bo.entity.KimPrincipal;

 import org.kuali.rice.kim.service.IdentityManagementService;

 import org.kuali.rice.kim.service.KIMServiceLocator;

 import org.kuali.rice.kns.exception.ValidationException;

 import org.kuali.rice.kns.util.GlobalVariables;

 import org.kuali.rice.kns.util.KNSConstants;

 /**

  * A Struts Action which provides super user functionality.

  *

  * @author Kuali Rice Team (rice.collab@kuali.org)

  */

 public class SuperUserAction extends KewKualiAction {

     private static final org.apache.log4j.Logger LOG = org.apache.log4j.Logger.getLogger(SuperUserAction.class);

     public static final String UNAUTHORIZED = "authorizationFailure";

     //public ActionForward start(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {

     //        defaultDispatch(mapping, form, request, response);

     //}

     @Override

     public ActionForward execute(ActionMapping mapping, ActionForm form,

             HttpServletRequest request, HttpServletResponse response)

             throws Exception {

         initForm(request, form);

         return super.execute(mapping, form, request, response);

     }

     @Override

     public ActionForward refresh(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {

             ((SuperUserForm) form).getActionRequests().clear();

             initForm(request, form);

             return defaultDispatch(mapping, form, request, response);

     }

     public ActionForward displaySuperUserDocument(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {

         SuperUserForm superUserForm = (SuperUserForm) form;

         superUserForm.setDocHandlerUrl(KEWConstants.DOC_HANDLER_REDIRECT_PAGE + "?docId=" + superUserForm.getRouteHeaderId() + "&" + KEWConstants.COMMAND_PARAMETER + "=" + KEWConstants.SUPERUSER_COMMAND);

         return defaultDispatch(mapping, form, request, response);

     }

     public ActionForward routeLevelApprove(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {

         LOG.info("entering routeLevelApprove()...");

         SuperUserForm superUserForm = (SuperUserForm) form;

         Long documentId = superUserForm.getRouteHeader().getRouteHeaderId();

         WorkflowDocumentActions documentActions = getWorkflowDocumentActions(documentId);

         documentActions.superUserNodeApproveAction(getUserSession(request).getPrincipalId(), documentId, superUserForm.getDestNodeName(), superUserForm.getAnnotation(), superUserForm.isRunPostProcessorLogic());

         saveDocumentMessage("general.routing.superuser.routeLevelApproved", request, superUserForm.getRouteHeaderIdString(), null);

         LOG.info("exiting routeLevelApprove()...");

         superUserForm.getActionRequests().clear();

         initForm(request, form);

         return defaultDispatch(mapping, form, request, response);

     }

     public ActionForward approve(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {

         LOG.info("entering approve() ...");

         SuperUserForm superUserForm = (SuperUserForm) form;

         Long documentId = superUserForm.getRouteHeader().getRouteHeaderId();

         WorkflowDocumentActions documentActions = getWorkflowDocumentActions(documentId);

         documentActions.superUserApprove(getUserSession(request).getPrincipalId(), DTOConverter.convertRouteHeader(superUserForm.getRouteHeader(), null), superUserForm.getAnnotation(), superUserForm.isRunPostProcessorLogic());

         saveDocumentMessage("general.routing.superuser.approved", request, superUserForm.getRouteHeaderIdString(), null);

         LOG.info("exiting approve() ...");

         superUserForm.getActionRequests().clear();

         initForm(request, form);

         return defaultDispatch(mapping, form, request, response);

     }

     public ActionForward disapprove(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {

         LOG.info("entering disapprove() ...");

         SuperUserForm superUserForm = (SuperUserForm) form;

         Long documentId = superUserForm.getRouteHeader().getRouteHeaderId();

         WorkflowDocumentActions documentActions = getWorkflowDocumentActions(documentId);

         documentActions.superUserDisapprove(getUserSession(request).getPrincipalId(), DTOConverter.convertRouteHeader(superUserForm.getRouteHeader(), null), superUserForm.getAnnotation(), superUserForm.isRunPostProcessorLogic());

         saveDocumentMessage("general.routing.superuser.disapproved", request, superUserForm.getRouteHeaderIdString(), null);

         LOG.info("exiting disapprove() ...");

         superUserForm.getActionRequests().clear();

         initForm(request, form);

         return defaultDispatch(mapping, form, request, response);

     }

     public ActionForward cancel(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {

         LOG.info("entering cancel() ...");

         SuperUserForm superUserForm = (SuperUserForm) form;

         Long documentId = superUserForm.getRouteHeader().getRouteHeaderId();

         WorkflowDocumentActions documentActions = getWorkflowDocumentActions(documentId);

         documentActions.superUserCancel(getUserSession(request).getPrincipalId(), DTOConverter.convertRouteHeader(superUserForm.getRouteHeader(), null), superUserForm.getAnnotation(), superUserForm.isRunPostProcessorLogic());

         saveDocumentMessage("general.routing.superuser.canceled", request, superUserForm.getRouteHeaderIdString(), null);

         LOG.info("exiting cancel() ...");

         superUserForm.getActionRequests().clear();

         initForm(request, form);

         return defaultDispatch(mapping, form, request, response);

     }

     public ActionForward returnToPreviousNode(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {

         LOG.info("entering returnToPreviousNode() ...");

         SuperUserForm superUserForm = (SuperUserForm) form;

         Long documentId = superUserForm.getRouteHeader().getRouteHeaderId();

         WorkflowDocumentActions documentActions = getWorkflowDocumentActions(documentId);

         documentActions.superUserReturnToPreviousNode(getUserSession(request).getPrincipalId(), documentId, superUserForm.getReturnDestNodeName(), superUserForm.getAnnotation(), superUserForm.isRunPostProcessorLogic());

         saveDocumentMessage("general.routing.returnedToPreviousNode", request, "document", superUserForm.getReturnDestNodeName().toString());

         LOG.info("exiting returnToPreviousRouteLevel() ...");

         superUserForm.getActionRequests().clear();

         initForm(request, form);

         return defaultDispatch(mapping, form, request, response);

     }

     public ActionForward actionRequestApprove(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {

         LOG.info("entering actionRequestApprove() ...");

         SuperUserForm superUserForm = (SuperUserForm) form;

         // Retrieve the relevant arguments from the "methodToCall" parameter.

         String methodToCallAttr = (String) request.getAttribute(KNSConstants.METHOD_TO_CALL_ATTRIBUTE);

         superUserForm.setActionTakenRecipientCode(StringUtils.substringBetween(methodToCallAttr, KNSConstants.METHOD_TO_CALL_PARM1_LEFT_DEL, KNSConstants.METHOD_TO_CALL_PARM1_RIGHT_DEL));

         superUserForm.setActionTakenNetworkId(StringUtils.substringBetween(methodToCallAttr, KNSConstants.METHOD_TO_CALL_PARM2_LEFT_DEL, KNSConstants.METHOD_TO_CALL_PARM2_RIGHT_DEL));

         superUserForm.setActionTakenWorkGroupId(StringUtils.substringBetween(methodToCallAttr, KNSConstants.METHOD_TO_CALL_PARM4_LEFT_DEL, KNSConstants.METHOD_TO_CALL_PARM4_RIGHT_DEL));

         superUserForm.setActionTakenActionRequestId(StringUtils.substringBetween(methodToCallAttr, KNSConstants.METHOD_TO_CALL_PARM5_LEFT_DEL, KNSConstants.METHOD_TO_CALL_PARM5_RIGHT_DEL));

         LOG.debug("Routing super user action request approve action");

         boolean runPostProcessorLogic = ArrayUtils.contains(superUserForm.getActionRequestRunPostProcessorCheck(), superUserForm.getActionTakenActionRequestId());

         Long documentId = superUserForm.getRouteHeader().getRouteHeaderId();

         WorkflowDocumentActions documentActions = getWorkflowDocumentActions(documentId);

         documentActions.superUserActionRequestApproveAction(getUserSession(request).getPrincipalId(), documentId, new Long(superUserForm.getActionTakenActionRequestId()), superUserForm.getAnnotation(), runPostProcessorLogic);

         String messageString;

         String actionReqest = StringUtils.substringBetween(methodToCallAttr, KNSConstants.METHOD_TO_CALL_PARM6_LEFT_DEL, KNSConstants.METHOD_TO_CALL_PARM6_RIGHT_DEL);

         if (actionReqest.equalsIgnoreCase("acknowledge")){

                 messageString = "general.routing.superuser.actionRequestAcknowledged";

         }else if (actionReqest.equalsIgnoreCase("FYI")){

                 messageString = "general.routing.superuser.actionRequestFYI";

         }else if (actionReqest.equalsIgnoreCase("complete")){

                 messageString = "general.routing.superuser.actionRequestCompleted";

         }else if (actionReqest.equalsIgnoreCase("approved")){

                 messageString = "general.routing.superuser.actionRequestApproved";

         }else {

                 messageString = "general.routing.superuser.actionRequestApproved";

         }

         saveDocumentMessage(messageString, request, superUserForm.getRouteHeaderIdString(), superUserForm.getActionTakenActionRequestId());

         LOG.info("exiting actionRequestApprove() ...");

         superUserForm.getActionRequests().clear();

         initForm(request, form);

         // If the action request was also an app specific request, remove it from the app specific route recipient list.

         int removalIndex = findAppSpecificRecipientIndex(superUserForm, Long.parseLong(superUserForm.getActionTakenActionRequestId()));

         if (removalIndex >= 0) {

                 superUserForm.getAppSpecificRouteList().remove(removalIndex);

         }

         return defaultDispatch(mapping, form, request, response);

     }

     /**

      * Finds the index in the app specific route recipient list of the recipient whose routing was handled by the given action request.

      * 

      * @param superUserForm The SuperUserForm currently being processed.

      * @param actionRequestId The ID of the action request that handled the routing of the app specific recipient that is being removed.

      * @return The index of the app specific route recipient that was handled by the given action request, or -1 if no such recipient was found.

      */

     private int findAppSpecificRecipientIndex(SuperUserForm superUserForm, long actionRequestId) {

             int tempIndex = 0;

             for (Iterator<?> appRouteIter = superUserForm.getAppSpecificRouteList().iterator(); appRouteIter.hasNext();) {

                     Long tempActnReqId = ((AppSpecificRouteRecipient) appRouteIter.next()).getActionRequestId();

                     if (tempActnReqId != null && tempActnReqId.longValue() == actionRequestId) {

                             return tempIndex;

                     }

                     tempIndex++;

             }

             return -1;

     }

     public ActionForward initForm(HttpServletRequest request, ActionForm form) throws Exception {

         request.setAttribute("Constants", new JSTLConstants(KEWConstants.class));

         SuperUserForm superUserForm = (SuperUserForm) form;

         DocumentRouteHeaderValue routeHeader = KEWServiceLocator.getRouteHeaderService().getRouteHeader(superUserForm.getRouteHeaderId());

         superUserForm.setRouteHeader(routeHeader);

         String principalId = getUserSession(request).getPrincipalId();

         boolean isAuthorized = KEWServiceLocator.getDocumentTypePermissionService().canAdministerRouting(principalId, routeHeader.getDocumentType());

         superUserForm.setAuthorized(isAuthorized);

         if (!isAuthorized) {

             saveDocumentMessage("general.routing.superuser.notAuthorized", request, superUserForm.getRouteHeaderIdString(), null);

             return null;

         }

         superUserForm.setFutureNodeNames(KEWServiceLocator.getRouteNodeService().findFutureNodeNames(routeHeader.getRouteHeaderId()));

         Collection actionRequests = KEWServiceLocator.getActionRequestService().findPendingByDoc(routeHeader.getRouteHeaderId());

         Iterator requestIterator = actionRequests.iterator();

         while (requestIterator.hasNext()) {

             ActionRequestValue req = (ActionRequestValue) requestIterator.next();

            // if (KEWConstants.ACTION_REQUEST_APPROVE_REQ.equalsIgnoreCase(req.getActionRequested())) {

                 superUserForm.getActionRequests().add(req);

            // }

         }

         superUserForm.setDocId(superUserForm.getRouteHeaderId());

         if (superUserForm.getDocId() != null) {

             superUserForm.setWorkflowDocument(new WorkflowDocument(getUserSession(request).getPrincipalId(), superUserForm.getDocId()));

             superUserForm.establishVisibleActionRequestCds();

         }

         return null;

     }

     private void saveDocumentMessage(String messageKey, HttpServletRequest request, String subVariable1, String subVariable2) {

         if (subVariable2 == null) {

             GlobalVariables.getMessageMap().putInfo("document", messageKey, subVariable1);

         } else {

             GlobalVariables.getMessageMap().putInfo("document", messageKey, subVariable1, subVariable2);

         }

     }

     public ActionForward routeToAppSpecificRecipient(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {

             SuperUserForm superUserForm = (SuperUserForm) form;

             //super.routeToAppSpecificRecipient(mapping, form, request, response);

             //WorkflowRoutingForm routingForm = (WorkflowRoutingForm) form;

         String routeType = StringUtils.substringBetween((String) request.getAttribute(KNSConstants.METHOD_TO_CALL_ATTRIBUTE),

                         KNSConstants.METHOD_TO_CALL_PARM1_LEFT_DEL, KNSConstants.METHOD_TO_CALL_PARM1_RIGHT_DEL);

         AppSpecificRouteRecipient recipient = null;

         if (KEWConstants.PERSON.equals(routeType)) {

                 recipient = superUserForm.getAppSpecificRouteRecipient();

                 recipient.setActionRequested(superUserForm.getAppSpecificRouteActionRequestCd());

                 superUserForm.setAppSpecificPersonId(recipient.getId());

         }

         else {

                 recipient = superUserForm.getAppSpecificRouteRecipient2();

                 recipient.setActionRequested(superUserForm.getAppSpecificRouteActionRequestCd2());

                 superUserForm.setAppSpecificWorkgroupId(recipient.getId());

         }

         validateAppSpecificRoute(recipient);

         // Make sure that the requested action is still available.

         superUserForm.establishVisibleActionRequestCds();

         if (superUserForm.getAppSpecificRouteActionRequestCds().get(recipient.getActionRequested()) == null) {

                 GlobalVariables.getMessageMap().putError("appSpecificRouteRecipient" +

                             ((KEWConstants.WORKGROUP.equals(recipient.getType())) ? "2" : "") + ".id", "appspecificroute.actionrequested.invalid");

                 throw new ValidationException("The requested action of '" + recipient.getActionRequested() + "' is no longer available for this document");

         }

         try {

             String routeNodeName = getAdHocRouteNodeName(superUserForm.getWorkflowDocument().getRouteHeaderId());

             //if (KEWConstants.PERSON.equals(recipient.getType())) {

             if (KEWConstants.PERSON.equals(routeType)) {

                 String recipientPrincipalId = KEWServiceLocator.getIdentityHelperService().getIdForPrincipalName(recipient.getId());

                 superUserForm.getWorkflowDocument().adHocRouteDocumentToPrincipal(recipient.getActionRequested(), routeNodeName, superUserForm.getAnnotation(), recipientPrincipalId, "", true);

             } else {

                     String recipientGroupId = KEWServiceLocator.getIdentityHelperService().getIdForGroupName(recipient.getNamespaceCode(), recipient.getId());

                 superUserForm.getWorkflowDocument().adHocRouteDocumentToGroup(recipient.getActionRequested(), routeNodeName, superUserForm.getAnnotation(), recipientGroupId, "", true);

             }

         } catch (Exception e) {

             LOG.error("Error generating app specific route request", e);

             throw new WorkflowServiceErrorException("AppSpecific Route Error", new WorkflowServiceErrorImpl("AppSpecific Route Error", "appspecificroute.systemerror"));

         }

             superUserForm.getActionRequests().clear();

             initForm(request, form);

             // Retrieve the ID of the latest action request and store it with the app specific route recipient.

             ActionRequestValue latestActnReq = getLatestActionRequest(superUserForm);

             if (latestActnReq != null) {

                     recipient.setActionRequestId(latestActnReq.getActionRequestId());

             }

             // Add the recipient to the list.

         superUserForm.getAppSpecificRouteList().add(recipient);

         superUserForm.resetAppSpecificRoute();

         return start(mapping, form, request, response);

     }

     /**

      * Searches the current action requests list for the most recent request, which is the one with the highest ID.

      * @param superUserForm The SuperUserForm currently being processed.

      * @return The action request on the form with the highest ID, or null if no action requests exist in the list.

      */

     private ActionRequestValue getLatestActionRequest(SuperUserForm superUserForm) {

             ActionRequestValue latestActnReq = null;

             long latestId = -1;

             // Search the list for the action request with the highest action request value.

             for (Iterator<?> actnReqIter = superUserForm.getActionRequests().iterator(); actnReqIter.hasNext();) {

                     ActionRequestValue tmpActnReq = (ActionRequestValue) actnReqIter.next();

                     if (tmpActnReq.getActionRequestId().longValue() > latestId) {

                             latestActnReq = tmpActnReq;

                             latestId = tmpActnReq.getActionRequestId().longValue();

                     }

             }

             return latestActnReq;

     }

     /**

      * Removes an existing AppSpecificRouteRecipient from the list.

      */

     public ActionForward removeAppSpecificRecipient(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {

             SuperUserForm superUserForm = (SuperUserForm) form;

             // Make sure a valid route recipient index was specified in the "methodToCall" attribute.

         String strIndex = StringUtils.substringBetween((String) request.getAttribute(KNSConstants.METHOD_TO_CALL_ATTRIBUTE),

                         KNSConstants.METHOD_TO_CALL_PARM1_LEFT_DEL, KNSConstants.METHOD_TO_CALL_PARM1_RIGHT_DEL);

         if (StringUtils.isBlank(strIndex)) {

                 throw new WorkflowException("No adhoc route recipient index specified");

         }

         int removeIndex = Integer.parseInt(strIndex);

         if (removeIndex < 0 || removeIndex >= superUserForm.getAppSpecificRouteList().size()) {

                 throw new WorkflowException("Invalid adhoc route recipient index specified");

         }

         // Remove the specified recipient from the routing, based on the recipient's ID and the ID of the action request that handled the recipient.

         AppSpecificRouteRecipient removedRec = (AppSpecificRouteRecipient) superUserForm.getAppSpecificRouteList().get(removeIndex);

         AdHocRevokeDTO adHocRevokeDTO = new AdHocRevokeDTO();

         if (removedRec.getActionRequestId() != null) {

                 adHocRevokeDTO.setActionRequestId(removedRec.getActionRequestId());

         }

         // Set the ID according to whether the recipient is a person or a group.

         if (KEWConstants.PERSON.equals(removedRec.getType())) {

                 adHocRevokeDTO.setPrincipalId(KEWServiceLocator.getIdentityHelperService().getIdForPrincipalName(removedRec.getId()));

         }

         else {

                 adHocRevokeDTO.setGroupId(KEWServiceLocator.getIdentityHelperService().getIdForGroupName(removedRec.getNamespaceCode(), removedRec.getId()));

         }

         superUserForm.getWorkflowDocument().revokeAdHocRequests(adHocRevokeDTO, "");

         superUserForm.getAppSpecificRouteList().remove(removeIndex);

             superUserForm.getActionRequests().clear();

             initForm(request, form);

             return start(mapping, form, request, response);

     }

     private WorkflowDocumentActions getWorkflowDocumentActions(Long documentId) {

             DocumentType documentType = KEWServiceLocator.getDocumentTypeService().findByDocumentId(documentId);

             String serviceNamespace = documentType.getServiceNamespace();

             WorkflowDocumentActions service = (WorkflowDocumentActions)GlobalResourceLoader.getService(new QName(serviceNamespace, "WorkflowDocumentActionsService"));

             if (service == null) {

                 service = KEWServiceLocator.getWorkflowDocumentActionsService();

             }

             return service;

     }

     protected void validateAppSpecificRoute(AppSpecificRouteRecipient recipient) {

         if (recipient.getId() == null || recipient.getId().trim().equals("")) {

             GlobalVariables.getMessageMap().putError("appSpecificRouteRecipient" +

                             ((KEWConstants.WORKGROUP.equals(recipient.getType())) ? "2" : "") + ".id", "appspecificroute.recipient.required");

         }

         else {

                 if (KEWConstants.PERSON.equals(recipient.getType())) {

                         KimPrincipal principal = KIMServiceLocator.getIdentityManagementService().getPrincipalByPrincipalName(recipient.getId());

                         if (principal == null) {

                                 LOG.error("App Specific user recipient not found");

                                 GlobalVariables.getMessageMap().putError("appSpecificRouteRecipient.id", "appspecificroute.user.invalid");

                         }

                 }

                 else if (KEWConstants.WORKGROUP.equals(recipient.getType())) {

                         //if (getIdentityManagementService().getGroup(recipient.getId()) == null) {

                         if (getIdentityManagementService().getGroupByName(recipient.getNamespaceCode(), recipient.getId()) == null) {

                                 GlobalVariables.getMessageMap().putError("appSpecificRouteRecipient2.id", "appspecificroute.workgroup.invalid");

                         }

                 }

         }

         if (GlobalVariables.getMessageMap().hasErrors()) {

             throw new ValidationException("AppSpecific Route validation Errors");

         }

     }

     protected String getAdHocRouteNodeName(Long routeHeaderId) throws WorkflowException {

         WorkflowInfo info = new WorkflowInfo();

         RouteNodeInstanceDTO[] nodeInstances = info.getActiveNodeInstances(routeHeaderId);

         if (nodeInstances == null || nodeInstances.length == 0) {

             nodeInstances = info.getTerminalNodeInstances(routeHeaderId);

         }

         if (nodeInstances == null || nodeInstances.length == 0) {

             throw new WorkflowException("Could not locate a node on the document to send the ad hoc request to.");

         }

         return nodeInstances[0].getName();

     }

     private IdentityManagementService getIdentityManagementService() {

         return (IdentityManagementService) KIMServiceLocator.getService(KIMServiceLocator.KIM_IDENTITY_MANAGEMENT_SERVICE);

     }

     public static UserSession getUserSession(HttpServletRequest request) {

         return UserSession.getAuthenticatedUser();

     }

 }