Changeset 8717 for trunk/greenstone3-extensions

Timestamp:

2004-12-02T09:50:37+13:00 (19 years ago)

Author:

schweer

Message:

started to rework control flow, user authentication

Location:

trunk/greenstone3-extensions/gsdl-as

Files:

• src/org/greenstone/gsdlas/AlertingService.java (modified) (9 diffs)
• src/org/greenstone/gsdlas/ProfileStore.java (modified) (3 diffs)
• src/org/greenstone/gsdlas/database (added)
• src/org/greenstone/gsdlas/database/DatabaseException.java (added)
• src/org/greenstone/gsdlas/database/DatabaseManager.java (added)
• src/org/greenstone/gsdlas/users (added)
• src/org/greenstone/gsdlas/users/UserManager.java (added)
• test-src/org/greenstone/gsdlas/ProfileStoreTest.java (modified) (1 diff)

trunk/greenstone3-extensions/gsdl-as/src/org/greenstone/gsdlas/AlertingService.java

@@ -9 +9 @@
 package org.greenstone.gsdlas;
 
-import java.io.IOException;
 import java.lang.reflect.Method;
 import java.net.MalformedURLException;
@@ -15 +14 @@
 import java.util.*;
 
-import javax.servlet.ServletException;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
+import javax.servlet.http.*;
 
 import org.apache.velocity.Template;
 import org.apache.velocity.context.Context;
-import org.apache.velocity.exception.ParseErrorException;
-import org.apache.velocity.exception.ResourceNotFoundException;
 import org.apache.velocity.servlet.VelocityServlet;
-import org.greenstone.gsdlas.profiles.*;
+import org.greenstone.gsdlas.users.UserManager;
 
 /**
@@ -36 +31 @@
     public static final Set actions = new TreeSet();
     static {
-        actions.add("subscribe");
+        actions.add("createSubscription");
+        actions.add("deleteSubscription");
+        actions.add("editSubscription");
         actions.add("showFeed");
-        actions.add("listSubscriptions"); // TODO remove (just for debugging)
-    }
+        actions.add("listSubscriptions");
+        actions.add("login");
+        actions.add("register");
+    }
+    
     
     protected Template handleRequest(HttpServletRequest req,
@@ -47 +47 @@
         
         if (action == null || !actions.contains(action)) {
-            context.put("title", "Unknown action");
-            context.put("message", "I don't know how to " + action);
-            context.put("details", "The only actions I know are " + actions);
-            try {
-                return getTemplate("error.vm");
-            } catch (ResourceNotFoundException e1) {
-                // TODO Auto-generated catch block
-                e1.printStackTrace();
-            } catch (ParseErrorException e1) {
-                // TODO Auto-generated catch block
-                e1.printStackTrace();
-            } catch (Exception e1) {
-                // TODO Auto-generated catch block
-                e1.printStackTrace();
-            }
-            return null;
+            String title = "Unknown action";
+            String message = "I don't know how to " + action;
+            String details = "The only actions I know are " + actions;
+            return showError(context, message, details);
         }
         
 
         Map args = req.getParameterMap();
+        // TODO stop this, we need multi-valued stuff
         args = normalise(args);
         
@@ -75 +64 @@
             templateString = (String) method.invoke(this, new Object[] {args, context});
         } catch (Exception e) {
-            templateString = "error.vm";
-            context.put("title", "Error");
-            context.put("message", "A general error has occured, I couldn't do what you told me to do.");
-            context.put("details", e.getMessage() + " (" + e.getClass().getName() + "), action is " + action);
+            String message = "An error has occured, I couldn't do what you told me to do.";
+            String details = e.getMessage() + " (" + e.getClass().getName() + "), action is " + action;
+            return showError(context, message, details);
         }
         
@@ -88 +76 @@
             e.printStackTrace();
             try {
-                error(req, res, e);
-            } catch (ServletException e2) {
-                // TODO Auto-generated catch block
-                e2.printStackTrace();
-            } catch (IOException e2) {
+                error((HttpServletRequest)context.get(REQUEST), 
+                        (HttpServletResponse)context.get(RESPONSE),
+                        e);
+            } catch (Exception e2) {
                 // TODO Auto-generated catch block
                 e2.printStackTrace();
@@ -104 +91 @@
      * @param context
      * @return the Velocity template to use
+     * @throws Exception
      */
-    public String subscribe(Map arguments, Context context) {
-        context.put("title", "Adding Subscription");
-        if (arguments.size() == 0) {
-            context.put("message", "Empty subscription, not added");
-            context.put("details", "A subscription has to define at least one predicate.");
-            return "error.vm";
-        }
-        try {
-            // TODO pass user information to profile store
-            Subscription sub = new Subscription(arguments);
-            // TODO this should probably be somewhere else
-            for (Iterator iter = sub.getPredicates().iterator(); iter.hasNext();) {
-                Predicate predicate = (Predicate) iter.next();
-                if (predicate != null) {
-                    predicate.addSubscription(sub);
-                }
-            }
-            ProfileStore.getInstance().addSubscription(sub);
-        } catch (ParseException e) {
-            context.put("message", "Eror in subscription creation, not added");
-            context.put("details", e.getMessage());
-            return "error.vm";
-        }
-        context.put("message", "Subscription added successfully");
-        return "general.vm";
+    public String createSubscription(Map arguments, Context context) throws Exception {
+        HttpSession session = ((HttpServletRequest)context.get(REQUEST)).getSession(true);
+        if (!UserManager.getInstance().isLoggedIn(session)) {
+            session.setAttribute("next_action", "createSubscription");
+            return "login.vm";
+        }
+        // TODO handle wizard-style stuff 
+        // if "finish"
+        ProfileStore.getInstance().createSubscription(arguments);
+        return listSubscriptions(arguments, context);
+        // else show next page
+    }
+
+    public String deleteSubscription(Map arguments, Context context) {
+        HttpSession session = ((HttpServletRequest)context.get(REQUEST)).getSession(true);
+        if (!UserManager.getInstance().isLoggedIn(session)) {
+            session.setAttribute("next_action", "deleteSubscription");
+            return "login.vm";
+        }
+        String subscriptionID = (String) arguments.get("subscriptionID");
+        ProfileStore.getInstance().deleteSubscription(subscriptionID);
+        return listSubscriptions(arguments, context);
+    }
+    
+    public String editSubscription(Map arguments, Context context) {
+        HttpSession session = ((HttpServletRequest)context.get(REQUEST)).getSession(true);
+        if (!UserManager.getInstance().isLoggedIn(session)) {
+            session.setAttribute("next_action", "editSubscription");
+            return "login.vm";
+        }
+        // TODO handle wizard-style stuff
+        // if "finish"
+        ProfileStore.getInstance().changeSubscription(arguments, session);
+        return listSubscriptions(arguments, context);
+        // else show next page
     }
     
@@ -136 +134 @@
         return "feed.vm";
     }
-    
+
     public String listSubscriptions(Map arguments, Context context) {
         context.put("title", "List of Subscriptions");
         context.put("list", ProfileStore.getInstance().getAllSubscriptions());
         return "list.vm";
+    }
+    
+    public String login(Map arguments, Context context) throws Exception {
+        HttpSession session = ((HttpServletRequest)context.get(REQUEST)).getSession(true);
+        UserManager.getInstance().loginUser(arguments, session);
+        if (session.getAttribute("next_action") != null) {
+            String nextAction = (String) session.getAttribute("next_action");
+            Method method = AlertingService.class.getDeclaredMethod(nextAction, new Class[] {Map.class, Context.class});
+            return (String) method.invoke(this, new Object[] {arguments, context});
+        }
+        return listSubscriptions(arguments, context);
+    }
+    
+    public String register(Map arguments, Context context) throws Exception {
+        HttpSession session = ((HttpServletRequest)context.get(REQUEST)).getSession(true);
+        UserManager.getInstance().createUser(arguments, session);
+        return login(arguments, context);
     }
     
@@ -172 +187 @@
         return result;
     }
+
+    /**
+     * @param context
+     * @param message
+     * @param details
+     * @return
+     */
+    private Template showError(Context context, String message, String details) {
+        context.put("title", "Error");
+        context.put("message", message);
+        context.put("details", details);
+        try {
+            return getTemplate("error.vm");
+        } catch (Exception e) {
+            try {
+                super.error((HttpServletRequest)context.get("req"), 
+                        (HttpServletResponse)context.get("res"), 
+                        e);
+            } catch (Exception e2) {
+                e2.printStackTrace();
+            }
+        }
+        return null;
+    }
 }

trunk/greenstone3-extensions/gsdl-as/src/org/greenstone/gsdlas/ProfileStore.java

@@ -11 +11 @@
 import java.util.*;
 
+import javax.servlet.http.HttpSession;
+
 import org.greenstone.gsdlas.profiles.*;
 import org.greenstone.gsdlas.profiles.IdEqualsPredicate;
@@ -48 +50 @@
      *            the subscription to add to the profile store.
      */
-    public void addSubscription(Subscription subscription) {
+    private void addSubscription(Subscription subscription) {
         Predicate documentIdPredicate = subscription.getPredicate("documentID");
         Predicate collectionIdPredicate = subscription.getPredicate("collectionID");
@@ -267 +269 @@
         return Collections.unmodifiableSet(allSubscriptions);
     }
+
+
+    /**
+     * @param arguments
+     * @throws ParseException
+     */
+    public void createSubscription(Map arguments) throws ParseException {
+        // TODO pass user information to profile store
+        Subscription sub = new Subscription(arguments);
+        // TODO this should probably be somewhere else
+        for (Iterator iter = sub.getPredicates().iterator(); iter.hasNext();) {
+            Predicate predicate = (Predicate) iter.next();
+            if (predicate != null) {
+                predicate.addSubscription(sub);
+            }
+        }
+        addSubscription(sub);
+    }
+
+    
+    /**
+     * @param subscriptionID
+     */
+    public void deleteSubscription(String subscriptionID) {
+        // TODO Auto-generated method stub
+        
+    }
+
+    /**
+     * @param arguments
+     * @param session
+     */
+    public void changeSubscription(Map arguments, HttpSession session) {
+        String subscriptionID = (String) arguments.get("subscriptionID");
+        // TODO Auto-generated method stub
+        
+    }
     
 }

trunk/greenstone3-extensions/gsdl-as/test-src/org/greenstone/gsdlas/ProfileStoreTest.java

@@ -83 +83 @@
     }
     
-    private void addSubscription(Map valueMap) throws ParseException {    
-        Subscription sub = new Subscription(valueMap);
-        // TODO this should probably be somewhere else
-        for (Iterator iter = sub.getPredicates().iterator(); iter.hasNext();) {
-            Predicate predicate = (Predicate) iter.next();
-            if (predicate != null) {
-                predicate.addSubscription(sub);
-            }
-        }
-        ProfileStore.getInstance().addSubscription(sub);    
+    private void addSubscription(Map valueMap) throws ParseException {  
+        ProfileStore.getInstance().createSubscription(valueMap);    
     }