UnifiedSearchForumListener.java

package org.exoplatform.commons.search.indexing.listeners;

import org.exoplatform.commons.api.indexing.IndexingService;
import org.exoplatform.commons.api.indexing.data.SearchEntry;
import org.exoplatform.commons.api.indexing.data.SearchEntryId;
import org.exoplatform.forum.service.*;
import org.exoplatform.services.log.ExoLogger;
import org.exoplatform.services.log.Log;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * Indexing with :
 * - collection : "forum"
 * - type : (category|forum|topic|post)
 * - name : object id
 *
 * TODO No method for category and forum deletion
 */
public class UnifiedSearchForumListener extends ForumEventListener {

  private static Log log = ExoLogger.getLogger(UnifiedSearchForumListener.class);

  private final IndexingService indexingService;

  public UnifiedSearchForumListener(IndexingService indexingService) {
    this.indexingService = indexingService;
  }

  @Override
  public void saveCategory(Category category) {
    // TODO How to know of it is a new category or an update ?

    if(indexingService != null) {
      Map<String, Object> content = new HashMap<String, Object>();
      content.put("category", category);
      SearchEntry searchEntry = new SearchEntry("forum", "category", category.getId(), content);
      indexingService.add(searchEntry);
    }
  }

  @Override
  public void saveForum(Forum forum) {
    // TODO How to know of it is a new forum or an update ?

    if(indexingService != null) {
      Map<String, Object> content = new HashMap<String, Object>();
      content.put("forum", forum);
      SearchEntry searchEntry = new SearchEntry("forum", "forum", forum.getId(), content);
      indexingService.add(searchEntry);
    }
  }

  @Override
  public void addTopic(Topic topic) {
    if(indexingService != null) {
      Map<String, Object> content = new HashMap<String, Object>();
      content.put("topic", topic);
      SearchEntry searchEntry = new SearchEntry("forum", "topic", topic.getId(), content);
      indexingService.add(searchEntry);
    }
  }

  @Override
  public void updateTopic(Topic topic) {
    if(indexingService != null) {
      Map<String, Object> content = new HashMap<String, Object>();
      content.put("topic", topic);
      SearchEntryId searchEntryId = new SearchEntryId("forum", "topic", topic.getId());
      indexingService.update(searchEntryId, content);
    }
  }

  @Override
  public void updateTopics(List<Topic> topics, boolean isLock) {
    for(Topic topic: topics) {
      updateTopic(topic);
    }
  }

  @Override
  public void moveTopic(Topic topic, String toCategoryName, String toForumName) {
    // TODO No setCategoryId neither setForumId on Topic object. How to update it ?
  }

  public void movePost(List <Post> posts, List<String> srcPostActivityIds, String desTopicPath) {
  }
  
  @Override
  public void mergeTopic(Topic topic, String removeActivityId1, String removeActivityId2) {
    // TODO No mergeTopic(Topic topic1, Topic topic2, Topic mergedTopic) ...
  }

  @Override
  public void splitTopic(Topic newTopic, Topic splitedTopic, String removeActivityId) {
    if(indexingService != null) {
      Map<String, Object> content = new HashMap<String, Object>();
      content.put("topic", splitedTopic);
      SearchEntryId searchEntryId = new SearchEntryId("forum", "topic", splitedTopic.getId());
      indexingService.update(searchEntryId, content);

      Map<String, Object> contentNewTopic = new HashMap<String, Object>();
      contentNewTopic.put("topic", newTopic);
      SearchEntry searchEntry = new SearchEntry("forum", "topic", newTopic.getId(), contentNewTopic);
      indexingService.add(searchEntry);
    }
  }

  @Override
  public void addPost(Post post) {
    if(indexingService != null) {
      Map<String, Object> content = new HashMap<String, Object>();
      content.put("post", post);
      SearchEntry searchEntry = new SearchEntry("forum", "post", post.getId(), content);
      indexingService.add(searchEntry);
    }
  }

  @Override
  public void updatePost(Post post) {
    if(indexingService != null) {
      Map<String, Object> content = new HashMap<String, Object>();
      content.put("post", post);
      SearchEntryId searchEntryId = new SearchEntryId("forum", "post", post.getId());
      indexingService.update(searchEntryId, content);
    }
  }

  @Override
  public void updatePost(Post post, int type) {
    updatePost(post);
  }

  @Override
  public void removeActivity(String activityId) {
    // TODO No removeTopic(Topic topic) ...
  }

  @Override
  public void removeComment(String activityId, String commentId) {
    // TODO No removeTopic(Post post) ...
  }
}