[jboss-svn-commits] JBL Code SVN: r26973 - in labs/jbosslabs/labs-3.0-build/integration/cs-nfm/trunk/src/main/java/org/jboss/labs/clearspace/plugin/nfm: dao and 1 other directory.

[jboss-svn-commits at lists.jboss.org]

Author: lkrzyzanek
Date: 2009-06-15 10:08:54 -0400 (Mon, 15 Jun 2009)
New Revision: 26973

Modified:
   labs/jbosslabs/labs-3.0-build/integration/cs-nfm/trunk/src/main/java/org/jboss/labs/clearspace/plugin/nfm/DbNukesForumsManager.java
   labs/jbosslabs/labs-3.0-build/integration/cs-nfm/trunk/src/main/java/org/jboss/labs/clearspace/plugin/nfm/dao/DbNukesForumsDAOImpl.java
   labs/jbosslabs/labs-3.0-build/integration/cs-nfm/trunk/src/main/java/org/jboss/labs/clearspace/plugin/nfm/dao/NukesForumsDAO.java
Log:
added watching topics

Modified: labs/jbosslabs/labs-3.0-build/integration/cs-nfm/trunk/src/main/java/org/jboss/labs/clearspace/plugin/nfm/DbNukesForumsManager.java
===================================================================
--- labs/jbosslabs/labs-3.0-build/integration/cs-nfm/trunk/src/main/java/org/jboss/labs/clearspace/plugin/nfm/DbNukesForumsManager.java	2009-06-15 13:33:36 UTC (rev 26972)
+++ labs/jbosslabs/labs-3.0-build/integration/cs-nfm/trunk/src/main/java/org/jboss/labs/clearspace/plugin/nfm/DbNukesForumsManager.java	2009-06-15 14:08:54 UTC (rev 26973)
@@ -350,6 +350,9 @@
           viewCountDAO.insertViewCount(JiveConstants.THREAD, thread.getID(),
               community.getID(), topic.getViewCount());
         }
+
+        migrateTopicWatches(topic.getTopicID(), thread);
+
         topic = null;
         replies = null;
 
@@ -407,31 +410,31 @@
     return userManager.getUser(userTemplate);
   }
 
-  private void migrateForumWatches(Long forumID, Community community) {
+  private void migrateForumWatches(Long forumID, JiveObject objectToWatch) {
     List<String> users = nukesForumsDAO.getForumWatchingUses(forumID);
     for (String username : users) {
       try {
         User user = userManager.getUser(username);
-        watchManager.createWatch(user, community);
+        watchManager.createWatch(user, objectToWatch);
       } catch (UserNotFoundException e) {
         log.error("Unknown user for watching forum " + forumID + " username: "
-            + username);
+            + username + ". Ommiting this watch.");
       }
     }
   }
 
-  // private void migrateTopicWatches(Long topicID, Community community) {
-  // List<String> users = nukesForumsDAO.getForumWatchingUses(forumID);
-  // for (String username : users) {
-  // try {
-  // User user = userManager.getUser(username);
-  // watchManager.createWatch(user, community);
-  // } catch (UserNotFoundException e) {
-  // log.error("Unknown user for watching forum " + forumID + " username: "
-  // + username);
-  // }
-  // }
-  // }
+  private void migrateTopicWatches(Long topicID, JiveObject objectToWatch) {
+    List<String> users = nukesForumsDAO.getForumWatchingUses(topicID);
+    for (String username : users) {
+      try {
+        User user = userManager.getUser(username);
+        watchManager.createWatch(user, objectToWatch);
+      } catch (UserNotFoundException e) {
+        log.error("Unknown user for watching topic " + topicID + " username: "
+            + username + ". Ommiting this watch.");
+      }
+    }
+  }
 
   /**
    * Create document from string. body of document is converted via converters

Modified: labs/jbosslabs/labs-3.0-build/integration/cs-nfm/trunk/src/main/java/org/jboss/labs/clearspace/plugin/nfm/dao/DbNukesForumsDAOImpl.java
===================================================================
--- labs/jbosslabs/labs-3.0-build/integration/cs-nfm/trunk/src/main/java/org/jboss/labs/clearspace/plugin/nfm/dao/DbNukesForumsDAOImpl.java	2009-06-15 13:33:36 UTC (rev 26972)
+++ labs/jbosslabs/labs-3.0-build/integration/cs-nfm/trunk/src/main/java/org/jboss/labs/clearspace/plugin/nfm/dao/DbNukesForumsDAOImpl.java	2009-06-15 14:08:54 UTC (rev 26973)
@@ -59,6 +59,10 @@
       + "from phpbb_forums_watch w join nuke_users u on u.pn_uid = w.user_id "
       + "where forum_id = ?";
 
+  private static final String SELECT_WATCHING_TOPIC_USERS_BY_FORUMID = "select u.pn_uname "
+      + "from phpbb_topics_watch w join nuke_users u on u.pn_uid = w.user_id "
+      + "where topic_id = ?";
+
   private static final String SELECT_NUKES_USER_BY_USERNAME = "SELECT * FROM nuke_users WHERE pn_uname = ?";
 
   public List<NukesForumsForumBean> getAllForumsByCategoryID(Long categoryID) {
@@ -98,6 +102,16 @@
         }, forumID);
   }
 
+  public List<String> getTopicWatchingUses(Long forumID) {
+    return getSimpleJdbcTemplate().query(
+        SELECT_WATCHING_TOPIC_USERS_BY_FORUMID,
+        new ParameterizedRowMapper<String>() {
+          public String mapRow(ResultSet rs, int rowNum) throws SQLException {
+            return rs.getString(1);
+          };
+        }, forumID);
+  }
+
   public NukesUserBean getNukesUser(String username) {
     return getSimpleJdbcTemplate().queryForObject(
         SELECT_NUKES_USER_BY_USERNAME, new NukesUserBeanMapper(), username);

Modified: labs/jbosslabs/labs-3.0-build/integration/cs-nfm/trunk/src/main/java/org/jboss/labs/clearspace/plugin/nfm/dao/NukesForumsDAO.java
===================================================================
--- labs/jbosslabs/labs-3.0-build/integration/cs-nfm/trunk/src/main/java/org/jboss/labs/clearspace/plugin/nfm/dao/NukesForumsDAO.java	2009-06-15 13:33:36 UTC (rev 26972)
+++ labs/jbosslabs/labs-3.0-build/integration/cs-nfm/trunk/src/main/java/org/jboss/labs/clearspace/plugin/nfm/dao/NukesForumsDAO.java	2009-06-15 14:08:54 UTC (rev 26973)
@@ -73,6 +73,14 @@
    * @return list of username
    */
   public List<String> getForumWatchingUses(Long forumID);
+  
+  /**
+   * Get topic watching users for specified topic_id
+   * 
+   * @param topicID
+   * @return list of username
+   */
+  public List<String> getTopicWatchingUses(Long topicID);
 
   /**
    * Get nukes user.