From ea9085bcc941a5ea566432be42943f0a323a5b63 Mon Sep 17 00:00:00 2001
From: Henri Herscher <henri@oreka.org>
Date: Mon, 24 Oct 2005 18:46:23 +0000
Subject: Enums now employ uppercase values

git-svn-id: https://oreka.svn.sourceforge.net/svnroot/oreka/trunk@10 09dcff7a-b715-0410-9601-b79a96267cd0
---
 orktrack/src/net/sf/oreka/orktrack/CommandServlet.java    | 15 +++++++++++----
 orktrack/src/net/sf/oreka/orktrack/Port.java              | 12 ++++++------
 orktrack/src/net/sf/oreka/orktrack/ProgramManager.java    | 12 +++++++++---
 .../net/sf/oreka/orktrack/messages/MetadataMessage.java   |  2 +-
 .../src/net/sf/oreka/orktrack/messages/TapeMessage.java   | 12 ++++++------
 .../net/sf/oreka/orktrack/messages/UserStateMessage.java  |  8 ++++----
 orktrack/src/net/sf/oreka/orktrack/test/PortTest.java     |  8 ++++----
 7 files changed, 41 insertions(+), 28 deletions(-)

(limited to 'orktrack')

diff --git a/orktrack/src/net/sf/oreka/orktrack/CommandServlet.java b/orktrack/src/net/sf/oreka/orktrack/CommandServlet.java
index cf8fc1a..5a4dddd 100644
--- a/orktrack/src/net/sf/oreka/orktrack/CommandServlet.java
+++ b/orktrack/src/net/sf/oreka/orktrack/CommandServlet.java
@@ -39,7 +39,7 @@ public class CommandServlet extends HttpServlet {
     public void doGet(HttpServletRequest request, HttpServletResponse response)
     throws IOException, ServletException
     {
-		OrkObjectFactory.instance().registerOrkObject(new TestMessage());
+		//#####OrkObjectFactory.instance().registerOrkObject(new TestMessage());
 		
 		ServletRequestSerializer ser = new ServletRequestSerializer();
 		
@@ -47,20 +47,27 @@ public class CommandServlet extends HttpServlet {
 			SyncMessage obj = (SyncMessage)ser.deSerialize(request);
 			AsyncMessage rsp = obj.process();
 			SingleLineSerializer ser2 = new SingleLineSerializer();
+			String req = ser2.serialize(obj);
+			logger.debug("Request: " + req);			
 			PrintWriter out = response.getWriter();
-			out.println(ser2.serialize(rsp));
+			String resp = ser2.serialize(rsp);
+			logger.debug("Reponse: " + resp);
+			out.println(resp);
 		}
 		catch (Exception e) {
+			logger.debug("Request: " + request.getQueryString());
 			SimpleResponseMessage rsp = new SimpleResponseMessage();
 			rsp.setComment(e.getMessage());
 			rsp.setSuccess(false);
 			SingleLineSerializer ser2 = new SingleLineSerializer();
 			PrintWriter out = response.getWriter();
 			try {
-				out.println(ser2.serialize(rsp));
+				String resp = ser2.serialize(rsp);
+				logger.debug("Reponse: " + resp);
+				out.println(resp);
 			}
 			catch (OrkException ae) {
-				out.println("Error:" + ae.getMessage());
+				logger.error("Error:" + ae.getMessage());
 			}
 		}
 		
diff --git a/orktrack/src/net/sf/oreka/orktrack/Port.java b/orktrack/src/net/sf/oreka/orktrack/Port.java
index 5831841..e786c75 100644
--- a/orktrack/src/net/sf/oreka/orktrack/Port.java
+++ b/orktrack/src/net/sf/oreka/orktrack/Port.java
@@ -138,17 +138,17 @@ public class Port {
 		long duration = 0;
 		Date startDate = null;
 		
-		if (metadataMessage.getStage() == TapeMessage.CaptureStage.start) {
+		if (metadataMessage.getStage() == TapeMessage.CaptureStage.START) {
 			lastMetadataMessage = metadataMessage;
 		}
-		else if (metadataMessage.getStage() == TapeMessage.CaptureStage.stop) {
+		else if (metadataMessage.getStage() == TapeMessage.CaptureStage.STOP) {
 			
 			if (lastMetadataMessage != null) {
 				duration = ((long)metadataMessage.getTimestamp() - (long)lastMetadataMessage.getTimestamp())*1000;
 				startDate = new Date((long)lastMetadataMessage.getTimestamp()*1000);
 			}
 		}
-		else if (metadataMessage.getStage() == TapeMessage.CaptureStage.complete) {
+		else if (metadataMessage.getStage() == TapeMessage.CaptureStage.COMPLETE) {
 			duration = (long)metadataMessage.getDuration()*1000;
 			startDate = new Date(metadataMessage.getTimestamp()*1000);
 		}
@@ -188,7 +188,7 @@ public class Port {
 	
 	public void notifyTapeMessage(TapeMessage tapeMessage, Session hbnSession, Service srv) {
 		
-		if (tapeMessage.getStage() == TapeMessage.CaptureStage.start) {
+		if (tapeMessage.getStage() == TapeMessage.CaptureStage.START) {
 			lastTapeMessage = tapeMessage;
 		}
 		else {
@@ -196,10 +196,10 @@ public class Port {
 			if (lastTapeMessage == null) {
 				log.warn("Port: notifyTapeMessage: stop without a previous tape message");
 			}
-			else if (lastTapeMessage.getStage() != TapeMessage.CaptureStage.start) {
+			else if (lastTapeMessage.getStage() != TapeMessage.CaptureStage.START) {
 				log.warn("Port: notifyTapeMessage: stop without a start");	
 			}
-			else if (tapeMessage.getStage() == TapeMessage.CaptureStage.stop){
+			else if (tapeMessage.getStage() == TapeMessage.CaptureStage.STOP){
 				boolean generateSegment = false;
 				if (portFaces.size() == 1 || srv.isRecordMaster()) {
 					generateSegment = true;
diff --git a/orktrack/src/net/sf/oreka/orktrack/ProgramManager.java b/orktrack/src/net/sf/oreka/orktrack/ProgramManager.java
index 6b8a54c..e95a238 100644
--- a/orktrack/src/net/sf/oreka/orktrack/ProgramManager.java
+++ b/orktrack/src/net/sf/oreka/orktrack/ProgramManager.java
@@ -81,9 +81,15 @@ public class ProgramManager {
 		boolean result = false;
 		// Iterate over programs
 		ArrayList<RecProgram> progs = recPrograms;
-		for(int i=0; i<progs.size(); i++) {
-			if(filterSegmentAgainstProgram(seg, progs.get(i), hbnSession)) {
-				result = true;
+		if(recPrograms.size() == 0) {
+			// If there are no programs specified, keep everything
+			result = true;
+		}
+		else {
+			for(int i=0; i<progs.size(); i++) {
+				if(filterSegmentAgainstProgram(seg, progs.get(i), hbnSession)) {
+					result = true;
+				}
 			}
 		}
 		return result;
diff --git a/orktrack/src/net/sf/oreka/orktrack/messages/MetadataMessage.java b/orktrack/src/net/sf/oreka/orktrack/messages/MetadataMessage.java
index d6a2062..e8847ba 100644
--- a/orktrack/src/net/sf/oreka/orktrack/messages/MetadataMessage.java
+++ b/orktrack/src/net/sf/oreka/orktrack/messages/MetadataMessage.java
@@ -36,7 +36,7 @@ public class MetadataMessage  extends SyncMessage {
 
 	Logger log = null;
 	
-	CaptureStage stage = CaptureStage.unkn;
+	CaptureStage stage = CaptureStage.UNKN;
 	int timestamp = 0;
 	int duration = 0;
 	String capturePort = "";
diff --git a/orktrack/src/net/sf/oreka/orktrack/messages/TapeMessage.java b/orktrack/src/net/sf/oreka/orktrack/messages/TapeMessage.java
index 12c66b2..982f707 100644
--- a/orktrack/src/net/sf/oreka/orktrack/messages/TapeMessage.java
+++ b/orktrack/src/net/sf/oreka/orktrack/messages/TapeMessage.java
@@ -33,11 +33,11 @@ import org.hibernate.Transaction;
 
 public class TapeMessage extends SyncMessage {
 
-	public enum CaptureStage {start , stop, complete, unkn};
+	public enum CaptureStage {START , STOP, COMPLETE, UNKN};
 	
 	Logger log = null;
 	
-	CaptureStage stage = CaptureStage.unkn;
+	CaptureStage stage = CaptureStage.UNKN;
 	int timestamp = 0;
 	int duration = 0;
 	String filename = "";
@@ -101,10 +101,10 @@ public class TapeMessage extends SyncMessage {
 		timestamp = serializer.intValue("timestamp", timestamp, true);
 		duration = serializer.intValue("duration", duration, true);		
 		filename = serializer.stringValue("filename", filename, true);
-		capturePort = serializer.stringValue("capturePort", capturePort, true);
-		localParty = serializer.stringValue("localParty", localParty, false);
-		localEntryPoint = serializer.stringValue("localEntryPoint", localEntryPoint, false);
-		remoteParty = serializer.stringValue("remoteParty", remoteParty, false);
+		capturePort = serializer.stringValue("captureport", capturePort, true);
+		localParty = serializer.stringValue("localparty", localParty, false);
+		localEntryPoint = serializer.stringValue("localentrypoint", localEntryPoint, false);
+		remoteParty = serializer.stringValue("remoteparty", remoteParty, false);
 		direction = (Direction)serializer.enumValue("direction", direction, false);
 		loginString = serializer.stringValue("loginString", loginString, false);
 		service = serializer.stringValue("service", service, true);
diff --git a/orktrack/src/net/sf/oreka/orktrack/messages/UserStateMessage.java b/orktrack/src/net/sf/oreka/orktrack/messages/UserStateMessage.java
index 9800e24..1e2da84 100644
--- a/orktrack/src/net/sf/oreka/orktrack/messages/UserStateMessage.java
+++ b/orktrack/src/net/sf/oreka/orktrack/messages/UserStateMessage.java
@@ -31,11 +31,11 @@ import org.hibernate.Transaction;
 
 public class UserStateMessage extends SyncMessage {
 
-	public enum UserState {login, logout, unkn};
+	public enum UserState {LOGIN, LOGOUT, UNKN};
 	
 	private Logger log = null;
 	
-	private UserState userState = UserState.unkn;
+	private UserState userState = UserState.UNKN;
 	private String loginString = "";
 	private String recPort = "";
 	
@@ -69,12 +69,12 @@ public class UserStateMessage extends SyncMessage {
 		        	log.warn(comment);
 	        	}
 	        	else {
-	        		if(userState == UserState.login) {
+	        		if(userState == UserState.LOGIN) {
 	        			port.setUser(user);
 	        			UserManager.instance().setUserLocation(user, port);
 	        			log.info("user:" + loginString + " logging onto:" + recPort);
 	        		}
-	        		else if (userState == UserState.logout) {
+	        		else if (userState == UserState.LOGOUT) {
 	        			port.setUser(null);
 	        			UserManager.instance().setUserLocation(user, null);
 	        			log.info("user:" + loginString + " logging out of:" + recPort);
diff --git a/orktrack/src/net/sf/oreka/orktrack/test/PortTest.java b/orktrack/src/net/sf/oreka/orktrack/test/PortTest.java
index 2c16784..ca08581 100644
--- a/orktrack/src/net/sf/oreka/orktrack/test/PortTest.java
+++ b/orktrack/src/net/sf/oreka/orktrack/test/PortTest.java
@@ -219,7 +219,7 @@ public class PortTest extends TestCase {
 		TapeMessage startMsg = new TapeMessage();
 		startMsg.setCapturePort("recport");
 		startMsg.setService("recservice");
-		startMsg.setStage(TapeMessage.CaptureStage.start);
+		startMsg.setStage(TapeMessage.CaptureStage.START);
 		long startTime = new Date().getTime();
 		int startTimestamp = (int)(startTime/1000);
 		startMsg.setTimestamp(startTimestamp);
@@ -234,14 +234,14 @@ public class PortTest extends TestCase {
 		stopMsg.setLocalEntryPoint("dnis1");
 		stopMsg.setLocalParty("9833");
 		stopMsg.setRemoteParty("514-425-5678");
-		stopMsg.setStage(TapeMessage.CaptureStage.stop);
+		stopMsg.setStage(TapeMessage.CaptureStage.STOP);
 		stopMsg.setTimestamp(startTimestamp + 10);
 		
 		stopMsg.process();
 		
 		// Generate metadata start and stop messages
 		MetadataMessage mdStartMsg = new MetadataMessage();
-		mdStartMsg.setStage(TapeMessage.CaptureStage.start);
+		mdStartMsg.setStage(TapeMessage.CaptureStage.START);
 		mdStartMsg.setTimestamp(startTimestamp + 3);
 		mdStartMsg.setCapturePort("ctiport");
 		mdStartMsg.setService("ctiservice");
@@ -249,7 +249,7 @@ public class PortTest extends TestCase {
 		mdStartMsg.process();
 		
 		MetadataMessage mdStopMsg = new MetadataMessage();
-		mdStopMsg.setStage(TapeMessage.CaptureStage.stop);
+		mdStopMsg.setStage(TapeMessage.CaptureStage.STOP);
 		mdStopMsg.setLocalParty("1973");
 		mdStopMsg.setTimestamp(startTimestamp + 5);
 		mdStopMsg.setCapturePort("ctiport");
-- 
cgit v1.2.3