1 /** 2 * Copyright 2005-2013 The Kuali Foundation 3 * 4 * Licensed under the Educational Community License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * http://www.opensource.org/licenses/ecl2.php 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 package org.kuali.rice.edl.impl; 17 18 import static org.junit.Assert.assertTrue; 19 20 import org.apache.log4j.Logger; 21 import org.junit.Test; 22 import org.kuali.rice.edl.framework.workflow.EDocLitePostProcessor; 23 import org.kuali.rice.kew.test.KEWTestCase; 24 25 26 /** 27 * This is a Test class to verify the edoc lite post processor. 28 * 29 * @author Kuali Rice Team (rice.collab@kuali.org) 30 * 31 */ 32 public class EDocLitePostProcessorTest extends KEWTestCase { 33 private static final Logger LOG = Logger.getLogger(EDocLitePostProcessorTest.class); 34 35 private static final String CONTEXT_NAME = "/edl-test"; 36 37 @Test 38 public void junk() { 39 40 } 41 /* 42 @Test 43 public void testPostEvent() throws Exception { 44 String dummyData = "testing this stuff"; 45 Integer testServerPort = Integer.valueOf(getJettyServerPort() + 1); 46 WorkflowDocument document = new WorkflowDocument(getPrincipalIdForName("ewestfal"), "TestDocumentType"); 47 String applicationContent = "<data><edlContent><edl><eventNotificationURL>" + ConfigContext.getCurrentContextConfig().getProperty(KewApiConstants.KEW_URL_HOST) + ":" + testServerPort + CONTEXT_NAME + "</eventNotificationURL><testThisData>" + dummyData + "</testThisData></edl></edlContent></data>"; 48 document.setApplicationContent(applicationContent); 49 document.saveDocumentData(); 50 51 JettyServer server = null; 52 try { 53 server = new JettyServer(testServerPort.intValue(), CONTEXT_NAME, EDocLiteTestServlet.class); 54 server.setTestMode(true); 55 server.setFailOnContextFailure(true); 56 server.start(); 57 58 EDocLitePostProcessor postProcessor = new EDocLitePostProcessor(); 59 postProcessor.doActionTaken(new ActionTakenEvent(document.getDocumentId(), document.getAppDocId(), new ActionTakenValue())); 60 String eventType = EDocLitePostProcessor.EVENT_TYPE_ACTION_TAKEN; 61 testPostProcessorMethod(document.getDocumentId(), dummyData, eventType); 62 63 postProcessor = new EDocLitePostProcessor(); 64 postProcessor.doRouteLevelChange(new DocumentRouteLevelChange(document.getDocumentId(), document.getAppDocId(), 1, 2, null, null, null, null)); 65 eventType = EDocLitePostProcessor.EVENT_TYPE_ROUTE_LEVEL_CHANGE; 66 testPostProcessorMethod(document.getDocumentId(), dummyData, eventType); 67 68 postProcessor = new EDocLitePostProcessor(); 69 postProcessor.doRouteStatusChange(new DocumentRouteStatusChange(document.getDocumentId(), document.getAppDocId(), KewApiConstants.ROUTE_HEADER_INITIATED_CD, KewApiConstants.ROUTE_HEADER_ENROUTE_CD)); 70 eventType = EDocLitePostProcessor.EVENT_TYPE_ROUTE_STATUS_CHANGE; 71 testPostProcessorMethod(document.getDocumentId(), dummyData, eventType); 72 73 postProcessor = new EDocLitePostProcessor(); 74 postProcessor.doDeleteRouteHeader(new DeleteEvent(document.getDocumentId(), document.getAppDocId())); 75 eventType = EDocLitePostProcessor.EVENT_TYPE_DELETE_ROUTE_HEADER; 76 testPostProcessorMethod(document.getDocumentId(), dummyData, eventType); 77 78 } finally { 79 if (server != null) { 80 try { 81 server.stop(); 82 } catch (Exception e) { 83 LOG.warn("Failed to shutdown one of the lifecycles!", e); 84 } 85 } 86 } 87 } */ 88 89 private void testPostProcessorMethod(String documentId, String dummyData, String eventType) { 90 int maxWaitSeconds = EDocLitePostProcessor.SUBMIT_URL_MILLISECONDS_WAIT + 10000; 91 assertTrue("Test Servlet data map should not be null after wait period", waitForData(maxWaitSeconds, 5000)); 92 testForStringExistence("Document Id", documentId); 93 testForStringExistence("Dummy Data", dummyData); 94 testForStringExistence("Event Type '" + eventType + "'", eventType); 95 } 96 97 private void testForStringExistence(String dataDescriptor, String dataToFind) { 98 assertTrue(dataDescriptor = " should come back as part of the post data but didn't", EDocLiteTestServlet.postData.contains(dataToFind)); 99 } 100 101 public static boolean waitForData(int maxWaitMilliseconds, int pauseMilliseconds) { 102 boolean valueNotNull = false; 103 boolean interrupted = false; 104 long startTimeMs = System.currentTimeMillis(); 105 long endTimeMs = startTimeMs + maxWaitMilliseconds; 106 107 try { 108 Thread.sleep(pauseMilliseconds / 10); // the first time through, sleep a fraction of the specified time 109 } catch (InterruptedException e) { 110 interrupted = true; 111 } 112 valueNotNull = EDocLiteTestServlet.postData != null; 113 LOG.debug("starting wait loop"); 114 while (!interrupted && !valueNotNull && (System.currentTimeMillis() < endTimeMs)) { 115 try { 116 if (LOG.isDebugEnabled()) { 117 LOG.debug("sleeping for " + pauseMilliseconds + " ms"); 118 } 119 Thread.sleep(pauseMilliseconds); 120 } catch (InterruptedException e) { 121 interrupted = true; 122 } 123 LOG.debug("checking wait loop sentinel"); 124 valueNotNull = EDocLiteTestServlet.postData != null; 125 } 126 LOG.debug("finished wait loop (" + valueNotNull + ")"); 127 128 return valueNotNull; 129 } 130 }