/*
    * Copyright 2007-2009 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.kim.service.impl;
  
  import java.util.ArrayList;
  import java.util.Collections;
  import java.util.HashSet;
  import java.util.List;
  import java.util.Set;
  
  import javax.xml.namespace.QName;
  
  import org.kuali.rice.kew.exception.WorkflowRuntimeException;
  import org.kuali.rice.kew.messaging.MessageServiceNames;
  import org.kuali.rice.kew.responsibility.ResponsibilityChangeProcessor;
  import org.kuali.rice.kim.bo.role.dto.RoleResponsibilityInfo;
  import org.kuali.rice.kim.bo.role.impl.RoleMemberImpl;
  import org.kuali.rice.kim.bo.role.impl.RoleResponsibilityImpl;
  import org.kuali.rice.kim.service.ResponsibilityInternalService;
  import org.kuali.rice.kim.util.KimConstants;
  import org.kuali.rice.kns.service.BusinessObjectService;
  import org.kuali.rice.kns.service.KNSServiceLocator;
  import org.kuali.rice.ksb.messaging.service.KSBXMLService;
  import org.kuali.rice.ksb.service.KSBServiceLocator;
  
  /**
   * This is a description of what this class does - Garey don't forget to fill this in.
   *
   * @author Kuali Rice Team (rice.collab@kuali.org)
   *
   */
  public class ResponsibilityInternalServiceImpl implements ResponsibilityInternalService {
  
  	private BusinessObjectService businessObjectService;
  
  	public void saveRoleMember(RoleMemberImpl roleMember){
  
  		//need to find what responsibilities changed so we can notify interested clients.  Like workflow.
      	List<RoleResponsibilityInfo> oldRoleResp = getRoleResponsibilities(roleMember.getRoleId());
  
      	// add row to member table
      	getBusinessObjectService().save( roleMember );
  
      	//need to find what responsibilities changed so we can notify interested clients.  Like workflow.
      	// the new member has been added
      	List<RoleResponsibilityInfo> newRoleResp = getRoleResponsibilities(roleMember.getRoleId());
  
      	updateActionRequestsForResponsibilityChange(getChangedRoleResponsibilityIds(oldRoleResp, newRoleResp));
  	}
  
  	public void removeRoleMember(RoleMemberImpl roleMember){
  		//need to find what responsibilities changed so we can notify interested clients.  Like workflow.
      	List<RoleResponsibilityInfo> oldRoleResp = getRoleResponsibilities(roleMember.getRoleId());
  
      	// add row to member table
      	getBusinessObjectService().delete( roleMember );
  
      	//need to find what responsibilities changed so we can notify interested clients.  Like workflow.
      	// the new member has been added
      	List<RoleResponsibilityInfo> newRoleResp = getRoleResponsibilities(roleMember.getRoleId());
  
      	updateActionRequestsForResponsibilityChange(getChangedRoleResponsibilityIds(oldRoleResp, newRoleResp));
  	}
  
  	@SuppressWarnings("unchecked")
  	public void updateActionRequestsForRoleChange(String roleId) {
      	List<RoleResponsibilityInfo> newRoleResp = getRoleResponsibilities(roleId);
  		
      	updateActionRequestsForResponsibilityChange(getChangedRoleResponsibilityIds(Collections.EMPTY_LIST, newRoleResp));
  	}
  	
  
  	/**
  	 * This overridden method ...
  	 *
  	 * @see org.kuali.rice.kim.service.ResponsibilityInternalService#updateActionRequestsForResponsibilityChange(java.util.Set)
  	 */
  	public void updateActionRequestsForResponsibilityChange(Set<String> responsibilityIds) {
  
  		KSBXMLService responsibilityChangeProcessor = (KSBXMLService) KSBServiceLocator.getMessageHelper()
          .getServiceAsynchronously(new QName(MessageServiceNames.RESPONSIBILITY_CHANGE_SERVICE));
          try {
          	responsibilityChangeProcessor.invoke(ResponsibilityChangeProcessor.getResponsibilityChangeContents(responsibilityIds));
  
          } catch (Exception e) {
              throw new WorkflowRuntimeException(e);
         }
 
 	}
 
 	@SuppressWarnings("unchecked")
 	public List<RoleResponsibilityInfo> getRoleResponsibilities(String roleId){		
 		List<RoleResponsibilityImpl> roleResponsibilities = 
 				(List<RoleResponsibilityImpl>)getBusinessObjectService()
 				.findMatching(RoleResponsibilityImpl.class, Collections.singletonMap(KimConstants.PrimaryKeyConstants.ROLE_ID, roleId));
 		List<RoleResponsibilityInfo> result = new ArrayList<RoleResponsibilityInfo>( roleResponsibilities.size() );
 		for ( RoleResponsibilityImpl roleResp : roleResponsibilities ) {
 			result.add( roleResp.toSimpleInfo() );
 		}
 
 		return result;
     }
 
 	 /**
     *
     * This method compares the two lists of responsibilitiy IDs and does a union.  returns a unique list of responsibility ids.
     *
     * @param oldRespList
     * @param newRespList
     * @return
     */
    protected Set<String> getChangedRoleResponsibilityIds(
 			List<RoleResponsibilityInfo> oldRespList,
 			List<RoleResponsibilityInfo> newRespList) {
 		Set<String> lRet = new HashSet<String>();
 
 		for (RoleResponsibilityInfo resp : oldRespList) {
 			lRet.add(resp.getResponsibilityId());
 		}
 		for (RoleResponsibilityInfo resp : newRespList) {
 			lRet.add(resp.getResponsibilityId());
 		}
 
 		return lRet;
 	}
 
 	protected BusinessObjectService getBusinessObjectService() {
 		if ( businessObjectService == null ) {
 			businessObjectService = KNSServiceLocator.getBusinessObjectService();
 		}
 		return businessObjectService;
 	}
 
 }