Changeset 8770

Timestamp:

2004-12-09T16:26:32+13:00 (19 years ago)

Author:

schweer

Message:

have to use http post because of classpath problems with soap; use correct sql query for finding out the title of the document

File:

• trunk/gsdl3/src/java/org/greenstone/gsdl3/gs3build/notifier/NotifierManager.java (modified) (5 diffs)

trunk/gsdl3/src/java/org/greenstone/gsdl3/gs3build/notifier/NotifierManager.java

@@ -33 +33 @@
             // AccessionDate >= CollectionLastRebuiltDate
             ResultSet results = statement.executeQuery("SELECT DocID FROM document WHERE DocType != 'GSMETADATA' AND AccessionDate >= " + lastBuild);
-            notify(collectionName, host, results, collManager.getDatabase(), "new_document");
+            notify(collectionName, host, results, collManager.getDatabase(), collManager.getBuildDate(), "new_document");
             
             // detect modified documents. A document is modified if and only if
@@ -39 +39 @@
             // ModifiedDate >= IndexedDate
             results = statement.executeQuery("SELECT DocID FROM document WHERE DocType != 'GSMETADATA' AND AccessionDate < " + lastBuild + " AND ModifiedDate >= IndexedDate");
-            notify(collectionName, host, results, collManager.getDatabase(), "document_modified");
+            notify(collectionName, host, results, collManager.getDatabase(), collManager.getBuildDate(), "document_modified");
         } catch (SQLException e) {
             // TODO Auto-generated catch block
@@ -50 +50 @@
      * @param hostURL
      * @param results
+     * @param date
      * @param eventType TODO
      * @throws MalformedURLException
@@ -56 +57 @@
      * @throws SQLException
      */
-    private void notify(String collName, String hostURL, ResultSet results, GS3SQLConnection database, String eventType) {
+    private void notify(String collName, String hostURL, ResultSet results, GS3SQLConnection database, Date date, String eventType) {
         try {
-            URL url = new URL(hostURL);
-            System.out.println("trying to send (via SOAP) to " + url);
+            URL url = new URL("http://localhost:8080/alerting/service");
+            System.out.println("trying to send to " + url);
             
             while(results.next()) {
                 System.out.println("new document: " + results.getString("DocID"));
-                Map event = new TreeMap();
                 
                 String documentID = results.getString("DocID");
                 
-                event.put("documentID", documentID);
-                event.put("type", eventType);
-                event.put("collectionID", collName);
-                event.put("host_url", hostURL);
-                event.put("document_title", getDocumentTitle(documentID, database));
-                
-                Call call = new Call();
-                call.setTargetObjectURI("alerting");
-                call.setMethodName("receiveEvent");
-                call.setEncodingStyleURI(Constants.NS_URI_SOAP_ENC);
-                Vector params = new Vector();
-                params.addElement(new Parameter("event", Map.class, event, null));
-                call.setParams(params);
                 try {
-                    Response resp = call.invoke(url, "");
-                    if (!resp.generatedFault()) {
-                        System.out.println("successfully posted event");
-                        return;
+                    HttpURLConnection conn = (HttpURLConnection) url.openConnection(); // TODO what about proxies?
+                    conn.setUseCaches(false);
+                    conn.setDoInput(true);
+                    conn.setDoOutput(true);
+                    conn.setRequestMethod("POST");
+                    conn.connect();
+                    // Construct data
+                    OutputStreamWriter writer = new OutputStreamWriter(conn.getOutputStream());
+                    
+                    writer.write("action=receiveEvent&");
+                    writer.write("documentID=");
+                    writer.write(URLEncoder.encode(documentID, "UTF-8"));
+                    writer.write("&type=");
+                    writer.write(URLEncoder.encode(eventType, "UTF-8"));
+                    writer.write("&collectionID=");
+                    writer.write(URLEncoder.encode(collName, "UTF-8"));
+                    writer.write("&host_url=");
+                    writer.write(URLEncoder.encode(hostURL, "UTF-8"));
+                    writer.write("&document_title=");
+                    writer.write(URLEncoder.encode(getDocumentTitle(documentID, database), "UTF-8"));
+                    writer.write("&document_url=");
+                    writer.write(URLEncoder.encode("http://localhost:8080/gsdl3/library?a=d&c=" + collName + "&d=" + documentID, "UTF-8"));
+                    writer.write("&timestamp=");
+                    writer.write(URLEncoder.encode(new SimpleDateFormat("yyyy-MM-dd HH:mm z").format(date), "UTF-8"));
+                    writer.flush();
+                    System.out.println(conn.getResponseCode());
+                    InputStream fromReceiver = conn.getInputStream();
+                    int i;
+                    while ((i = fromReceiver.read()) != -1) {
+                        System.out.write(i);
                     }
-                    System.err.println("Posting event was unsuccessful:");
-                    System.err.println(resp.getFault().getFaultString());
-                } catch (SOAPException e1) {
-                    System.err.println("Exception while posting event: ");
+                    conn.disconnect();
+                } catch (ProtocolException e1) {
+                    // TODO Auto-generated catch block
+                    e1.printStackTrace();
+                } catch (UnsupportedEncodingException e1) {
+                    // TODO Auto-generated catch block
+                    e1.printStackTrace();
+                } catch (IOException e1) {
+                    // TODO Auto-generated catch block
                     e1.printStackTrace();
                 }
+//              
+//              Call call = new Call();
+//              call.setTargetObjectURI("alerting");
+//              call.setMethodName("receiveEvent");
+//              call.setEncodingStyleURI(Constants.NS_URI_SOAP_ENC);
+//              Vector params = new Vector();
+//              params.addElement(new Parameter("event", Map.class, event, null));
+//              call.setParams(params);
+//              try {
+//                    Response resp = call.invoke(url, "");
+//                    if (!resp.generatedFault()) {
+//                        System.out.println("successfully posted event");
+//                        return;
+//                    }
+//                    System.err.println("Posting event was unsuccessful:");
+//                    System.err.println(resp.getFault().getFaultString());
+//                    
+//                    Vector entries = resp.getFault().getDetailEntries();
+//                    for (Iterator i = entries.iterator(); i.hasNext(); ) {
+//                      org.w3c.dom.Element entry = (org.w3c.dom.Element)i.next( );
+//                      System.err.println(entry.getFirstChild().getNodeValue( ));
+//                    }
+//                } catch (SOAPException e1) {
+//                    System.err.println("Exception while posting event: ");
+//                    e1.printStackTrace();
+//                }
             }
-        } catch (IOException e) {
-            // TODO Auto-generated catch block
-            e.printStackTrace();
         } catch (SQLException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
-        }
+        } catch (MalformedURLException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        }
     }
 
@@ -107 +151 @@
      * @throws SQLException
      */
-    private String getDocumentTitle(String documentID, GS3SQLConnection database) throws SQLException {
+    private String getDocumentTitle(String documentID, GS3SQLConnection database) {
         Statement statement = database.createStatement();
-        ResultSet results = statement.executeQuery("select mdvalues.value " +
-                "from mdvalues join namespaces on (mdvalues.namespaceref = namespaces.namespaceid) " +
-                "join metadata on (metadata.metadataref = namespaces.metadataref) " +
-                "where label like 'Title' and metadata.docID = '" + documentID +"';");
-        return results.getString(0);
+        ResultSet results;
+        try {
+            String sqlString = "SELECT mdvalues.value " +
+                    "FROM structure s JOIN divisions d ON (s.structureref = d.parentref) " +
+                    "                 JOIN divisionmetarefs USING (divisionref) " + 
+                    "                 JOIN metadata m USING (metaid) " +
+                    "                 JOIN namespaces USING (metadataref) " + 
+                    "                 JOIN mdvalues USING (namespaceref) " +
+                    "  WHERE mdvalues.label = 'Title' AND s.docid = '" + documentID + "'" + 
+                    "                                 AND s.structureType = 'Whole Document' " +
+                    "                                 AND d.parenttype = 'Structure' " + 
+                    "                                 AND m.docID = s.docid;";
+            results = statement.executeQuery(sqlString);
+            return results.getString(0);
+        } catch (SQLException e) {
+            return "";
+        }
     }