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

Timestamp:

2004-12-06T11:44:03+13:00 (19 years ago)

Author:

schweer

Message:

user authentication works; user information and subscriptions/predicates are stored to thedatabase

File:

• trunk/greenstone3-extensions/gsdl-as/src/org/greenstone/gsdlas/AlertingService.java (modified) (13 diffs)

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

@@ -14 +14 @@
 import java.util.*;
 
-import javax.mail.Session;
 import javax.servlet.http.*;
 
@@ -20 +19 @@
 import org.apache.velocity.context.Context;
 import org.apache.velocity.servlet.VelocityServlet;
+import org.greenstone.gsdlas.users.UserManagementException;
 import org.greenstone.gsdlas.users.UserManager;
 
@@ -30 +30 @@
 public class AlertingService extends VelocityServlet {
     
-    public static final Set actions = new TreeSet();
+    public static final Set actions;
     static {
-        actions.add("createSubscription");
-        actions.add("deleteSubscription");
-        actions.add("editSubscription");
-        actions.add("showFeed");
-        actions.add("listSubscriptions");
-        actions.add("login");
-        actions.add("register");
-        actions.add("logout");
+        Set set = new TreeSet();
+        set.add("createSubscription");
+        set.add("deleteSubscription");
+        set.add("editSubscription");
+        set.add("showFeed");
+        set.add("listSubscriptions");
+        
+        set.add("login");
+        set.add("register");
+        set.add("logout");
+        set.add("showLoginForm");
+        set.add("showRegistrationForm");
+        actions = Collections.unmodifiableSet(set);
     }
     
@@ -67 +72 @@
         } catch (Exception e) {
             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;
+            String details = e.getMessage() + " (" + e.getClass().getName() + "); "
+                + e.getCause() 
+                + " ; action is " + action;
             return showError(context, message, details);
         }
@@ -99 +106 @@
         if (!UserManager.getInstance().isLoggedIn(session)) {
             session.setAttribute("next_action", "createSubscription");
-            return "login.vm";
+            return showLoginForm(arguments, context);
         }
         if (arguments.containsKey("next_page") && arguments.get("next_page").equals("finish")) {
+            arguments.putAll(getPageArgsFromSession(session));
             ProfileStore.getInstance().createSubscription(arguments);
             return listSubscriptions(arguments, context);
@@ -113 +121 @@
         if (!UserManager.getInstance().isLoggedIn(session)) {
             session.setAttribute("next_action", "deleteSubscription");
-            return "login.vm";
+            return showLoginForm(arguments, context);
         }
         String subscriptionID = (String) arguments.get("subscriptionID");
@@ -124 +132 @@
         if (!UserManager.getInstance().isLoggedIn(session)) {
             session.setAttribute("next_action", "editSubscription");
-            return "login.vm";
+            return showLoginForm(arguments, context);
         }
         if (arguments.containsKey("next_page") && arguments.get("next_page").equals("finish")) {
@@ -138 +146 @@
         return "feed.vm";
     }
+    
+    public String showLoginForm(Map arguments, Context context) {
+        return "login.vm";
+    }
+    
+    public String showRegistrationForm(Map arguments, Context context) {
+        return "register.vm";
+    }
 
     public String listSubscriptions(Map arguments, Context context) {
-        context.put("title", "List of Subscriptions");
+        HttpSession session = ((HttpServletRequest)context.get(REQUEST)).getSession(true);
+        if (!UserManager.getInstance().isLoggedIn(session)) {
+            session.setAttribute("next_action", "listSubscriptions");
+            return showLoginForm(arguments, context);
+        }
+        String username = (String) session.getAttribute("username");
+        context.put("title", "List of Subscriptions for " + username);
         context.put("list", ProfileStore.getInstance().getAllSubscriptions());
         return "list.vm";
@@ -147 +169 @@
     public String login(Map arguments, Context context) throws Exception {
         HttpSession session = ((HttpServletRequest)context.get(REQUEST)).getSession(true);
-        UserManager.getInstance().loginUser(arguments, session);
+        try {
+            UserManager.getInstance().loginUser(arguments, session);
+        } catch (UserManagementException e) {
+            context.put("error", Boolean.TRUE);
+            context.put("errormessage", e.getMessage());
+            return showLoginForm(arguments, context); 
+        }
         if (session.getAttribute("next_action") != null) {
             String nextAction = (String) session.getAttribute("next_action");
@@ -158 +186 @@
     public String register(Map arguments, Context context) throws Exception {
         HttpSession session = ((HttpServletRequest)context.get(REQUEST)).getSession(true);
-        UserManager.getInstance().createUser(arguments, session);
+        try {
+            UserManager.getInstance().createUser(arguments, session);
+        } catch (UserManagementException e) {
+            context.put("error", Boolean.TRUE);
+            context.put("errormessage", e.getMessage());
+            return showRegistrationForm(arguments, context);
+        }
         return login(arguments, context);
     }
@@ -194 +228 @@
         for (Iterator iter = args.keySet().iterator(); iter.hasNext();) {
             String key = (String) iter.next();
-            if (!key.equals("action")) {
-                String firstValue = ((String[]) args.get(key))[0];
+            if (key.equals("type") || key.equals("host") 
+                    || key.equals("collection") || key.equals("way")) {
+                // multi-valued attributes
+                String[] values = ((String[]) args.get(key));
+                result.put(key, Arrays.asList(values));
+            } else {
+                String firstValue = ((String[])args.get(key))[0];
                 result.put(key, firstValue);
             }
@@ -260 +299 @@
         // get page-specific stuff
         if (nextPage.equals("host")) {
-            
+            GreenstoneCommunicator gsComm = null;
+            String[] hostNames;
+            try {
+                gsComm = new GreenstoneCommunicator();
+                hostNames = gsComm.getHostNames();
+            } catch (Exception e) {
+                hostNames = new String[] { "localhost" };
+            }
+            context.put("hostnames", hostNames);
         } else if (nextPage.equals("collection")) {
-            
+            // TODO might be query instead of just name
+            List hostNames = (List) arguments.get("host");
+            GreenstoneCommunicator gsComm = null;
+            Map collNames = new TreeMap();
+            for (Iterator iter = hostNames.iterator(); iter.hasNext();) {
+                String host = (String) iter.next();
+                Set collNamesForHost = new TreeSet();   
+                try {
+                    gsComm = new GreenstoneCommunicator(new URL("http://" + host + ":8080/soap/servlet/rpcrouter"));
+                    collNamesForHost.addAll(Arrays.asList(gsComm.getCollectionNames()));
+                } catch (Exception e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }   
+                collNames.put(host, collNamesForHost);
+            }
+            context.put("collectionnames", collNames);
+            context.put("hostnames", hostNames);
         }
         
@@ -324 +388 @@
     }
 
+    private Map getPageArgsFromSession(HttpSession session) {
+        Map result = new TreeMap();
+        Map pageArgs = (Map) session.getAttribute("page_args");
+        if (pageArgs != null) {
+            for (Iterator iter = pageArgs.values().iterator(); iter.hasNext();) {
+                Map args = (Map) iter.next();
+                result.putAll(args);
+            }
+        }
+        return result;
+    }
+    
     /**
      * @param page