/**
    * Copyright 2005-2014 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.postprocessor;
  
  import static org.junit.Assert.assertEquals;
  import static org.junit.Assert.assertNotNull;
  import static org.junit.Assert.assertNull;
  import static org.junit.Assert.assertTrue;
  import static org.junit.Assert.fail;
  
  import java.util.ArrayList;
  import java.util.List;
  
  import org.apache.commons.lang.StringUtils;
  import org.custommonkey.xmlunit.XMLAssert;
  import org.custommonkey.xmlunit.XMLUnit;
  import org.junit.Test;
  import org.kuali.rice.kew.api.WorkflowDocument;
  import org.kuali.rice.kew.api.WorkflowDocumentFactory;
  import org.kuali.rice.kew.api.action.ActionRequestType;
  import org.kuali.rice.kew.doctype.bo.DocumentType;
  import org.kuali.rice.kew.framework.postprocessor.AfterProcessEvent;
  import org.kuali.rice.kew.framework.postprocessor.DocumentLockingEvent;
  import org.kuali.rice.kew.framework.postprocessor.DocumentRouteLevelChange;
  import org.kuali.rice.kew.framework.postprocessor.DocumentRouteStatusChange;
  import org.kuali.rice.kew.framework.postprocessor.ProcessDocReport;
  import org.kuali.rice.kew.routeheader.DocumentRouteHeaderValue;
  import org.kuali.rice.kew.service.KEWServiceLocator;
  import org.kuali.rice.kew.test.KEWTestCase;
  import org.kuali.rice.kew.api.KewApiConstants;
  import org.kuali.rice.test.BaselineTestCase;
  import org.springframework.transaction.TransactionStatus;
  import org.springframework.transaction.support.TransactionCallback;
  import org.springframework.transaction.support.TransactionTemplate;
  
  @BaselineTestCase.BaselineMode(BaselineTestCase.Mode.NONE)
  public class PostProcessorTest extends KEWTestCase {
  
  	private static final String APPLICATION_CONTENT = "<some><application>content</application></some>";
  	private static final String DOC_TITLE = "The Doc Title";
  	
  	protected void loadTestData() throws Exception {
          loadXmlFile("PostProcessorConfig.xml");
      }
  	
  	/**
  	 * Tests that modifying a document in the post processor works.  This test will do a few things:
  	 * 
  	 * 1) Change the document content in the post processor
  	 * 2) Send an app specific FYI request to the initiator of the document
  	 * 3) Modify the document title.
  	 * 
  	 * This test is meant to expose the bug KULWF-668 where it appears an OptimisticLockException is
  	 * being thrown after returning from the EPIC post processor.
  	 */
  	@Test public void testModifyDocumentInPostProcessor() throws Exception {
          XMLUnit.setIgnoreWhitespace(true);
  		WorkflowDocument document = WorkflowDocumentFactory.createDocument(getPrincipalIdForName("ewestfal"), "testModifyDocumentInPostProcessor");
  		document.saveDocument("");
          assertEquals("application content should be empty initially", "", document.getApplicationContent());
  		assertTrue("Doc title should be empty initially", StringUtils.isBlank(document.getTitle()));
  
          document.adHocToPrincipal(ActionRequestType.APPROVE, "AdHoc", "", "2002", "", true);
  		document.complete("");
          document = WorkflowDocumentFactory.loadDocument("2002", document.getDocumentId());
  
          // now approve the document, it should through a 2 nodes, then go PROCESSED then FINAL
          document.approve("");
  
          assertEquals("Should have transitioned nodes twice", 2, DocumentModifyingPostProcessor.levelChanges);
  		assertTrue("SHould have called the processed status change", DocumentModifyingPostProcessor.processedChange);
  		assertTrue("Document should be final.", document.isFinal());
  		XMLAssert.assertXMLEqual("Application content should have been sucessfully modified.", APPLICATION_CONTENT, document.getApplicationContent());
  				
  		// check that the title was modified successfully
  		assertEquals("Wrong doc title", DOC_TITLE, document.getTitle());
  		
  		// check that the document we routed from the post processor exists
  		assertNotNull("SHould have routed a document from the post processor.", DocumentModifyingPostProcessor.routedDocumentId);
  		document = WorkflowDocumentFactory.loadDocument(getPrincipalIdForName("ewestfal"), DocumentModifyingPostProcessor.routedDocumentId);
  		assertTrue("document should be enroute", document.isEnroute());
  		assertEquals("Document should have 1 pending request.", 1, KEWServiceLocator.getActionRequestService().findPendingByDoc(document.getDocumentId()).size());
  		assertTrue("ewestfal should have an approve request.", document.isApprovalRequested());
  		document.approve("");
  		assertTrue("Document should be final.", document.isFinal());
  	}
 	/**
      * Tests that modifying a document in the post processor works.  This test will do a few things:
      * 
      * 1) Change the document content in the post processor
      * 2) Send an app specific FYI request to the initiator of the document
      * 3) Modify the document title.
      * 
      * This test is meant to test that an empty post processor works.  The empty post processor should be handled as a DefaultPostProcessor.
      */
     
 	@Test public void testEmptyPostProcessor() throws Exception {
         WorkflowDocument document = WorkflowDocumentFactory.createDocument(getPrincipalIdForName("ewestfal"), "testEmptyPostProcessor");
         document.saveDocument("");
         assertEquals("application content should be empty initially", "", document.getApplicationContent());
         assertTrue("Doc title should be empty initially", StringUtils.isBlank(document.getTitle()));
         
         assertTrue("Document should be final.", document.isFinal());
                
         DocumentType testEmptyDocType = KEWServiceLocator.getDocumentTypeService().findByName("testEmptyPostProcessor");
         assertTrue("Post Processor should be set to 'none'",  StringUtils.equals("none", testEmptyDocType.getPostProcessorName()));
         assertTrue("Post Processor should be of type DefaultPostProcessor", testEmptyDocType.getPostProcessor() instanceof org.kuali.rice.kew.postprocessor.DefaultPostProcessor);
     }
     
 	private static boolean shouldReturnDocumentIdsToLock = false;
 	private static String documentAId = null;
 	private static String documentBId = null;
 	private static UpdateDocumentThread updateDocumentThread = null;
 	
 	protected String getPrincipalIdForName(String principalName) {
         return KEWServiceLocator.getIdentityHelperService()
                 .getIdForPrincipalName(principalName);
     }
 	/**
 	 * Tests the locking of additional documents from the Post Processor.
 	 * 
 	 * @author Kuali Rice Team (rice.collab@kuali.org)
 	 */
 	@Test public void RtestGetDocumentIdsToLock() throws Exception {
 		
 		/**
 		 * Let's recreate the original optimistic lock scenario that caused this issue to crop up, essentially:
 		 * 
 		 * 1) Thread one locks and processes document A in the workflow engine
 		 * 2) Thread one loads document B
 		 * 3) Thread two locks and processes document B from document A's post processor, doing an update which increments the version number of document B
 		 * 4) Thread A attempts to update document B and gets an optimistic lock exception 
 		 */
 		
 		WorkflowDocument documentB = WorkflowDocumentFactory.createDocument(getPrincipalIdForName("ewestfal"), "TestDocumentType");
 		documentB.saveDocument("");
 		documentBId = documentB.getDocumentId();
 		updateDocumentThread = new UpdateDocumentThread(documentBId);
 		
 		// this is the document with the post processor
 		WorkflowDocument documentA = WorkflowDocumentFactory.createDocument(getPrincipalIdForName("ewestfal"), "testGetDocumentIdsToLock");
 		documentA.adHocToPrincipal(ActionRequestType.APPROVE, "", getPrincipalIdForName("rkirkend"), "", true);
 		
 		try {
 			documentA.route(""); // this should trigger our post processor and our optimistic lock exception
 			fail("An exception should have been thrown as the result of an optimistic lock!");
 		} catch (Exception e) {
 			e.printStackTrace();
 		}
 
 		/**
 		 * Now let's try the same thing again, this time returning document B's id as a document to lock, the error should not happen this time
 		 */
 		
 		shouldReturnDocumentIdsToLock = true;
 		
 		documentB = WorkflowDocumentFactory.createDocument(getPrincipalIdForName("ewestfal"), "TestDocumentType");
 		documentB.saveDocument("");
 		documentBId = documentB.getDocumentId();
 		updateDocumentThread = new UpdateDocumentThread(documentBId);
 		
 		// this is the document with the post processor
 		documentA = WorkflowDocumentFactory.createDocument(getPrincipalIdForName("ewestfal"), "testGetDocumentIdsToLock");
 		documentA.adHocToPrincipal(ActionRequestType.APPROVE, "", getPrincipalIdForName("rkirkend"), "", true);
 		
 		documentA.route(""); // this should trigger our post processor and our optimistic lock exception
 		documentA = WorkflowDocumentFactory.loadDocument(getPrincipalIdForName("rkirkend"), documentA.getDocumentId());
 		assertTrue("rkirkend should have approve request", documentA.isApprovalRequested());
 		
 	}
 	
 	public static class DocumentModifyingPostProcessor extends DefaultPostProcessor {
 
 		public static boolean processedChange = false;
 		public static int levelChanges = 0;
 		public static String routedDocumentId;
 		
 		protected String getPrincipalIdForName(String principalName) {
 	        return KEWServiceLocator.getIdentityHelperService()
 	                .getIdForPrincipalName(principalName);
 	    }
 		
 		public ProcessDocReport doRouteStatusChange(DocumentRouteStatusChange statusChangeEvent) throws Exception {
 			if (KewApiConstants.ROUTE_HEADER_PROCESSED_CD.equals(statusChangeEvent.getNewRouteStatus())) {
 				WorkflowDocument document = WorkflowDocumentFactory.loadDocument(getPrincipalIdForName("ewestfal"), statusChangeEvent.getDocumentId());
 				document.setApplicationContent(APPLICATION_CONTENT);
 				document.setTitle(DOC_TITLE);
 				document.saveDocumentData();
 				// now route another document from the post processor, sending it an adhoc request
 				WorkflowDocument ppDocument = WorkflowDocumentFactory.createDocument(getPrincipalIdForName("user1"), "testModifyDocumentInPostProcessor");
 				routedDocumentId = ppDocument.getDocumentId();
 				// principal id 1 = ewestfal
 				ppDocument.adHocToPrincipal(ActionRequestType.APPROVE, "AdHoc", "", "2001", "", true);
 				ppDocument.route("");
 				processedChange = true;
 			}
 			return new ProcessDocReport(true);
 		}
 
 		public ProcessDocReport doRouteLevelChange(DocumentRouteLevelChange levelChangeEvent) throws Exception {
 			levelChanges++;
 			WorkflowDocument document = WorkflowDocumentFactory.loadDocument(getPrincipalIdForName("ewestfal"), levelChangeEvent.getDocumentId());
 			document.setTitle("Current level change: " + levelChanges);
 			document.saveDocumentData();
 			return new ProcessDocReport(true);
 		}
 		
 	}
 	
 	public static class GetDocumentIdsToLockPostProcessor extends DefaultPostProcessor {
 
 	    protected String getPrincipalIdForName(String principalName) {
 	        return KEWServiceLocator.getIdentityHelperService()
 	                .getIdForPrincipalName(principalName);
 	    }
 	    
 		@Override
 		public List<String> getDocumentIdsToLock(DocumentLockingEvent lockingEvent) throws Exception {
 			WorkflowDocument document = WorkflowDocumentFactory.loadDocument(getPrincipalIdForName("ewestfal"), lockingEvent.getDocumentId());
 			if (shouldReturnDocumentIdsToLock) {
 				List<String> docIds = new ArrayList<String>();
 				docIds.add(documentBId);
 				return docIds;
 			}
 			return null;
 		}
 
 		@Override
 		public ProcessDocReport afterProcess(AfterProcessEvent event) throws Exception {
 			WorkflowDocument wfDocument = WorkflowDocumentFactory.loadDocument(getPrincipalIdForName("ewestfal"), event.getDocumentId());
 			if (wfDocument.isEnroute()) {
 				// first, let's load document B in this thread
 				DocumentRouteHeaderValue document = KEWServiceLocator.getRouteHeaderService().getRouteHeader(documentBId);
 				// now let's execute the thread
 				new Thread(updateDocumentThread).start();
 				// let's wait for a few seconds to either let the thread process or let it acquire the lock
 				Thread.sleep(5000);
 				// now update document B
                 document.setDocTitle(document.getDocTitle() + "...making a change...");
 				KEWServiceLocator.getRouteHeaderService().saveRouteHeader(document);
 			}
 			return super.afterProcess(event);
 		}
 		
 		
 		
 	}
 	
 	/**
 	 * A Thread which simply locks and updates the document
 	 * 
 	 * @author Kuali Rice Team (rice.collab@kuali.org)
 	 */
 	private class UpdateDocumentThread implements Runnable {
 		private String documentId;
 		public UpdateDocumentThread(String documentId) {
 			this.documentId = documentId;
 		}
 		public void run() {
 			TransactionTemplate template = new TransactionTemplate(KEWServiceLocator.getPlatformTransactionManager());
 			template.execute(new TransactionCallback() {
 				public Object doInTransaction(TransactionStatus status) {
 					KEWServiceLocator.getRouteHeaderService().lockRouteHeader(documentId);
 					DocumentRouteHeaderValue document = KEWServiceLocator.getRouteHeaderService().getRouteHeader(documentId);
                     // have to actually change something on the doc to get this work
                     document.setDocTitle(document.getDocTitle() + "UDT");
 					KEWServiceLocator.getRouteHeaderService().saveRouteHeader(document);
 					return null;
 				}
 			});
 		}
 	}
 	
 }