Changeset 8888 for trunk/gsdl3/extensions/gsdl-as/src/org/greenstone/gsdlas/AlertingService.java

Timestamp:

2005-01-12T11:39:22+13:00 (19 years ago)

Author:

schweer

Message:

notifications

File:

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

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

@@ -10 +10 @@
 
 import java.lang.reflect.Method;
-import java.net.MalformedURLException;
 import java.net.URL;
 import java.sql.SQLException;
@@ -24 +23 @@
 import org.greenstone.gsdlas.database.DatabaseException;
 import org.greenstone.gsdlas.profiles.Predicate;
+import org.greenstone.gsdlas.profiles.Subscription;
 import org.greenstone.gsdlas.users.UserManagementException;
 import org.greenstone.gsdlas.users.UserManager;
@@ -58 +58 @@
             "deleteSubscription",
             "editSubscription",
+            "showEvents",
             "showFeed",
             "listSubscriptions",
@@ -175 +176 @@
     }
     
-    public String showFeed(Map arguments, Context context) {
-        context.put("list", ""/* TODO pass subscription list */);
+    public String showFeed(Map arguments, Context context) throws NumberFormatException, DatabaseException, SQLException {
+        HttpSession session = ((HttpServletRequest)context.get(REQUEST)).getSession(true);
+        if (!UserManager.getInstance().isLoggedIn(session)) {
+            session.setAttribute("next_action", "showFeed");
+            return showLoginForm(arguments, context);
+        }
+        String subscriptionID = (String) arguments.get("subscriptionID");
+        Integer subID = new Integer(subscriptionID);
+        Set events = EventStore.getInstance().getEvents(subID);
+        context.put("list", events);
+        context.put("subscription", ProfileStore.getInstance().getSubscription(subID.intValue()));
+        HttpServletResponse res = (HttpServletResponse) context.get(RESPONSE);
+        res.setContentType("text/xml");
         return "feed.vm";
+    }
+    
+    public String showEvents(Map arguments, Context context) throws NumberFormatException, DatabaseException, SQLException {
+        HttpSession session = ((HttpServletRequest)context.get(REQUEST)).getSession(true);
+        if (!UserManager.getInstance().isLoggedIn(session)) {
+            session.setAttribute("next_action", "showEvents");
+            return showLoginForm(arguments, context);
+        }
+        String subscriptionID = (String) arguments.get("subscriptionID");
+        Integer subID = new Integer(subscriptionID);
+        Set events = EventStore.getInstance().getEvents(subID);
+        context.put("list", events);
+        context.put("subscription", ProfileStore.getInstance().getSubscription(subID.intValue()));
+        return "events.vm";
     }
     
@@ -250 +276 @@
         for (Iterator iter = rawEvent.keySet().iterator(); iter.hasNext();) {
             String key = (String) iter.next();
+            if (key.equals("action")) continue; // we don't want this
             String[] value = (String[]) rawEvent.get(key);
             event.put(key, value[0]);
@@ -259 +286 @@
             String hostID = (String) event.get(Constants.HOST_ID_FIELD);
             gsComm = new GreenstoneCommunicator(new URL(hostID));
-        } catch (MalformedURLException e) {
-            // TODO Auto-generated catch block
+        } catch (Exception e) {
+            System.err.println("Can't communicate to Greenstone: " + e.getMessage());
             e.printStackTrace();
+        }
+        
+        Set matchedSubscriptions = ProfileStore.getInstance().filter(event, gsComm);
+        
+        try {
+            EventStore.getInstance().add(event, matchedSubscriptions);
+            Notifier.getInstance().sendNotifications(event, matchedSubscriptions);
         } catch (Exception e) {
-            // TODO Auto-generated catch block
+            System.err.println("Couldn't save events: " + e.getMessage());
             e.printStackTrace();
         }
-        Set matchedSubscriptions = ProfileStore.getInstance().filter(event, gsComm);
         System.out.println(matchedSubscriptions.size() + " matching subscriptions: " + matchedSubscriptions);
-        // TODO do something with the matched subscriptions
     }
 
@@ -322 +354 @@
      */
     private String showSubscriptionWizardPage(Map arguments, Context context, boolean create) throws Exception {
+        HttpSession session = ((HttpServletRequest)context.get(REQUEST)).getSession(true);
         if (create) {
             context.put(Constants.ACTION_PARAM, "createSubscription");
         } else {
+            // prefill from existing subscription
             context.put(Constants.ACTION_PARAM, "editSubscription");
+            String subscriptionID = (String) arguments.get("subscriptionID");
+            int subID = Integer.parseInt(subscriptionID);
+            prefillFromSubscription(session, subID);
         }
         if (!arguments.containsKey("current_page")) {
@@ -331 +368 @@
         }
         
-        HttpSession session = ((HttpServletRequest)context.get(REQUEST)).getSession(true);
         String currentPage = (String) arguments.get("current_page");
         String direction = (String) arguments.get("next_page");
@@ -412 +448 @@
 
     /**
+     * @param session
+     * @param subID
+     */
+    private void prefillFromSubscription(HttpSession session, int subID) {
+        Subscription sub = ProfileStore.getInstance().getSubscription(subID);
+        Map typeArgs = new HashMap();
+        // TODO really fill stuff
+        savePageArgsToSession("type-details", typeArgs, session);
+        Map hostArgs = new HashMap();
+        savePageArgsToSession("host", hostArgs, session);
+        Map collArgs = new HashMap();
+        savePageArgsToSession("collection", collArgs, session);
+        Map notificationArgs = new HashMap();
+        savePageArgsToSession("notification", notificationArgs, session);
+    }
+
+    /**
      * @param nextPage
      * @param session