Refactor session state validator to support serialization

Author: malaqueueit

QueueIT.Security.Examples/web/simple.jsp

@@ -1,7 +1,13 @@
+<%@page import="java.util.concurrent.Callable"%>
 <%@page import="queueit.security.*"%>
 <%@page contentType="text/html" pageEncoding="UTF-8"%>
 <%@taglib prefix="t" tagdir="/WEB-INF/tags" %>
 <%
+    SessionValidationController.Configure(null, new Callable<IValidateResultRepository>() {
+        public IValidateResultRepository call() {
+            return new SessionValidateResultRepository();
+        }
+    });
     try
     {
         IValidateResult result = SessionValidationController.validateRequest();

QueueIT.Security/src/queueit/security/SessionStateModel.java

@@ -0,0 +1,13 @@
+package queueit.security;
+
+import java.net.URI;
+import java.util.Date;
+import java.util.UUID;
+
+public class SessionStateModel implements java.io.Serializable {
+    public UUID QueueId;
+    public URI OriginalUrl;
+    public Date TimeStamp;
+    public RedirectType RedirectType;
+    public Integer PlaceInQueue;
+}

QueueIT.Security/src/queueit/security/SessionValidateResultRepository.java

@@ -4,23 +4,51 @@
 import javax.servlet.http.HttpSession;
 
 public class SessionValidateResultRepository extends ValidateResultRepositoryBase {
-    
-        
+            
     @Override
     public IValidateResult getValidationResult(IQueue queue) {
         HttpServletRequest request = RequestContext.getCurrentInstance().getRequest();
         HttpSession session = request.getSession(true);
 
         String key = generateKey(queue.getCustomerId(), queue.getEventId());
-        return (IValidateResult)session.getAttribute(key);
+        SessionStateModel model = (SessionStateModel)session.getAttribute(key);
+        
+        if (model == null)
+            return null;
+        
+        return new AcceptedConfirmedResult(
+            queue, 
+            new Md5KnownUser(
+                model.QueueId, 
+                model.PlaceInQueue, 
+                model.TimeStamp, 
+                queue.getCustomerId(), 
+                queue.getEventId(), 
+                model.RedirectType, 
+                model.OriginalUrl), 
+            true);
     }
 
     @Override
     public void setValidationResult(IQueue queue, IValidateResult validationResult) {
-        HttpServletRequest request = RequestContext.getCurrentInstance().getRequest();
-        HttpSession session = request.getSession(true);
 
-        String key = generateKey(queue.getCustomerId(), queue.getEventId());
-        session.setAttribute(key, validationResult);
+        if (validationResult instanceof AcceptedConfirmedResult)
+        {
+            AcceptedConfirmedResult confirmedResult = (AcceptedConfirmedResult)validationResult;
+            
+            HttpServletRequest request = RequestContext.getCurrentInstance().getRequest();
+            HttpSession session = request.getSession(true);
+        
+            String key = generateKey(queue.getCustomerId(), queue.getEventId());
+            
+            SessionStateModel model = new SessionStateModel();
+            model.QueueId = confirmedResult.getKnownUser().getQueueId();
+            model.OriginalUrl = confirmedResult.getKnownUser().getOriginalUrl();
+            model.TimeStamp = confirmedResult.getKnownUser().getTimeStamp();
+            model.RedirectType = confirmedResult.getKnownUser().getRedirectType();
+            model.PlaceInQueue = confirmedResult.getKnownUser().getPlaceInQueue();
+            
+            session.setAttribute(key, model);
+        }
     }       
 }

QueueIT.Security/test/queueit/security/SessionStateModelTest.java

@@ -0,0 +1,56 @@
+
+package queueit.security;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.ObjectOutputStream;
+import java.net.URI;
+import java.util.Date;
+import java.util.UUID;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+import org.junit.*;
+import org.junit.Test;
+import static org.junit.Assert.*;
+
+public class SessionStateModelTest {
+    @BeforeClass
+    public static void setUpClass() {
+    }
+    
+    @AfterClass
+    public static void tearDownClass() {
+    }
+    
+    @Before
+    public void setUp() {
+    }
+    
+    @After
+    public void tearDown() {
+    }
+
+    
+    @Test
+    public void SessionStateModel_Serialize_Test(){
+        SessionStateModel model = new SessionStateModel();
+        model.OriginalUrl = URI.create("http://www.queue-it.net");
+        model.PlaceInQueue = 1574;
+        model.QueueId = UUID.randomUUID();
+        model.RedirectType = RedirectType.AfterEvent;
+        model.TimeStamp = new Date();
+
+         ByteArrayOutputStream stream = new ByteArrayOutputStream(1024);
+         ObjectOutputStream out;
+        try {
+            out = new ObjectOutputStream(stream);
+             out.writeObject(model);
+             out.close();
+             stream.close();        
+        } catch (IOException ex) {
+            assertTrue(false);
+        }
+
+        assertTrue(true);
+    }
+}