/home/edulekha/studygroup.edulekha.com/ow_plugins/forum/bol/text_search_service.php
<?php

/**
 * This software is intended for use with Oxwall Free Community Software http://www.oxwall.org/ and is
 * licensed under The BSD license.

 * ---
 * Copyright (c) 2011, Oxwall Foundation
 * All rights reserved.

 * Redistribution and use in source and binary forms, with or without modification, are permitted provided that the
 * following conditions are met:
 *
 *  - Redistributions of source code must retain the above copyright notice, this list of conditions and
 *  the following disclaimer.
 *
 *  - Redistributions in binary form must reproduce the above copyright notice, this list of conditions and
 *  the following disclaimer in the documentation and/or other materials provided with the distribution.
 *
 *  - Neither the name of the Oxwall Foundation nor the names of its contributors may be used to endorse or promote products
 *  derived from this software without specific prior written permission.

 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES,
 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
 * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */

/**
 * Text search service
 *
 * @author Alex Ermashev <alexermashev@gmail.com>
 * @package ow.ow_plugins.forum.bol
 * @since 1.0
 */
class FORUM_BOL_TextSearchService
{
    /**
     * @var FORUM_BOL_TextSearchService
     */
    private static $classInstance;

    /**
     * Search entity topic
     */
    const SEARCH_ENTITY_TYPE_TOPIC = 'forum_topic';

    /**
     * Search entity post
     */
    const SEARCH_ENTITY_TYPE_POST = 'forum_post';

    /**
     * Class constructor
     */
    private function __construct()
    {}

    /**
     * Get forum service
     * 
     * @return FORUM_BOL_ForumService
     */
    private function getForumService()
    {
        return FORUM_BOL_ForumService::getInstance();
    }

    /**
     * Returns class instance
     *
     * @return FORUM_BOL_TextSearchService
     */
    public static function getInstance()
    {
        if ( !isset(self::$classInstance) )
            self::$classInstance = new self();

        return self::$classInstance;
    }

    /**
     * Delete post
     * 
     * @param integer $postId
     * @return void
     */
    public function deletePost( $postId )
    {
        OW::getTextSearchManager()->deleteAllEntitiesByTags(array(
            'forum_post_id_' . $postId
        ));   
    }

    /**
     * Delete topic posts
     * 
     * @param integer $topicId
     * @return void
     */
    public function deleteTopicPosts( $topicId )
    {
        OW::getTextSearchManager()->deleteAllEntitiesByTags(array(
            'forum_post_topic_id_' . $topicId,
            'forum_post_duplicate_topic_id_' . $topicId 
        ));
    }

    /**
     * Save or update group
     * 
     * @param FORUM_BOL_Group $groupDto
     */
    public function saveOrUpdateGroup( $groupDto )
    {
        if ( !empty($groupDto->id) && 
                (in_array('sectionId', $groupDto->getEntinyUpdatedFields()) 
                || in_array('isPrivate', $groupDto->getEntinyUpdatedFields())) )
        {
            FORUM_BOL_UpdateSearchIndexDao::getInstance()->
                    addQueue($groupDto->id, FORUM_BOL_UpdateSearchIndexDao::DELETE_GROUP);
        }
    }

    /**
     * Save or update post
     * 
     * @param FORUM_BOL_Post $postDto
     * @param boolean $forceAdd
     * @return void
     */
    public function saveOrUpdatePost( FORUM_BOL_Post $postDto, $forceAdd = false )
    {
        if ( $forceAdd || in_array('text', $postDto->getEntinyUpdatedFields()) )
        {
            // get topic, group and section info
            $topicInfo = $this->getForumService()->getTopicInfo($postDto->topicId);
            $groupInfo = $this->getForumService()->getGroupInfo($topicInfo['groupId']);
            $sectionInfo = $this->getForumService()->findSectionById($groupInfo->sectionId);

            // delete old posts by tags
            $this->deletePost($postDto->id);

            // add a new one
            $postTags = array(
                'forum_post', // global search
                'forum_post_user_id_' . $postDto->userId, // global search by a specific user
                'forum_post_group_id_' . $topicInfo['groupId'], // search into a specific forum
                'forum_post_group_id_' . $topicInfo['groupId'] . '_user_id_' . $postDto->userId, // search into a specific forum
                'forum_post_section_id_' . $groupInfo->sectionId, // search into a specific section,
                'forum_post_section_id_' . $groupInfo->sectionId . '_user_id_' . $postDto->userId, // search into a specific section and specific user
                'forum_post_topic_id_'   . $topicInfo['id'], // search into a specific topic
                'forum_post_topic_id_'   . $topicInfo['id'] . '_user_id_' . $postDto->userId, //  search into a specific topic and specific user
                'forum_post_id_' . $postDto->id
            );

            if ( !$groupInfo->isPrivate && !$sectionInfo->isHidden ) 
            {
                $postTags = array_merge($postTags, array(
                    'forum_post_public', // visible everywhere
                    'forum_post_public_user_id_'    . $postDto->userId,
                    'forum_post_public_section_id_' . $groupInfo->sectionId,
                    'forum_post_public_section_id_' . $groupInfo->sectionId . '_user_id_' . $postDto->userId,
                    'forum_post_public_group_id_'   . $topicInfo['groupId'],
                    'forum_post_public_group_id_'   . $topicInfo['groupId'] . '_user_id_' . $postDto->userId,
                ));
            }

            if ( $topicInfo['status'] == FORUM_BOL_ForumService::STATUS_APPROVED )
            {
                OW::getTextSearchManager()->
                        addEntity(self::SEARCH_ENTITY_TYPE_POST, $postDto->id, $postDto->text, $postDto->createStamp, $postTags);
            }
            else
            {
                OW::getTextSearchManager()->addEntity(self::SEARCH_ENTITY_TYPE_POST, 
                        $postDto->id, $postDto->text, $postDto->createStamp, $postTags, OW_TextSearchManager::ENTITY_STATUS_NOT_ACTIVE);
            }

            // duplicate this post as a part of topic
            $topicTags = array(
               'forum_topic', // global search
               'forum_topic_user_id_' . $postDto->userId, // global search by a specific user
               'forum_topic_group_id_' . $topicInfo['groupId'], // search into a specific forum
               'forum_topic_group_id_' . $topicInfo['groupId'] . '_user_id_' . $postDto->userId, // search into a specific forum and specific user              
               'forum_topic_section_id_' . $groupInfo->sectionId, // search into a specific section
               'forum_topic_section_id_' . $groupInfo->sectionId . '_user_id_' . $postDto->userId, // search into a specific section and specific user
               'forum_post_duplicate_topic_id_'   . $topicInfo['id'], // needed for global delete
               'forum_post_id_' . $postDto->id
            );

            if ( !$groupInfo->isPrivate && !$sectionInfo->isHidden ) 
            {
                $topicTags = array_merge($topicTags, array(
                    'forum_topic_public', // visible everywhere
                    'forum_topic_public_user_id_' . $postDto->userId,
                    'forum_topic_public_group_id_' . $topicInfo['groupId'],
                    'forum_topic_public_group_id_' . $topicInfo['groupId'] . '_user_id_' . $postDto->userId,
                    'forum_topic_public_section_id_' . $groupInfo->sectionId,
                    'forum_topic_public_section_id_' . $groupInfo->sectionId . '_user_id_' . $postDto->userId,
                ));
            }

            if ( $topicInfo['status'] == FORUM_BOL_ForumService::STATUS_APPROVED )
            {
                OW::getTextSearchManager()->addEntity(self::SEARCH_ENTITY_TYPE_TOPIC, 
                        $topicInfo['id'], $postDto->text, $postDto->createStamp, $topicTags);
            }
            else
            {
                OW::getTextSearchManager()->addEntity(self::SEARCH_ENTITY_TYPE_TOPIC, 
                        $topicInfo['id'], $postDto->text, $postDto->createStamp, $topicTags, OW_TextSearchManager::ENTITY_STATUS_NOT_ACTIVE);
            }
        }
    }

    /**
     * Set topic status
     * 
     * @param integer $topicId
     * @return void
     */
    public function setTopicStatus( $topicId, $isActive = true )
    {
        $status = $isActive 
            ? OW_TextSearchManager::ENTITY_STATUS_ACTIVE 
            : OW_TextSearchManager::ENTITY_STATUS_NOT_ACTIVE;

        OW::getTextSearchManager()->setEntitiesStatusByTags(array(
            'forum_topic_id_' . $topicId,
            'forum_post_topic_id_' . $topicId,
            'forum_post_duplicate_topic_id_' . $topicId 
        ), $status);
    }

    /**
     * Activate entities
     * 
     * @return void
     */
    public function activateEntities()
    {
        OW::getTextSearchManager()->activateAllEntities('forum_topic');
        OW::getTextSearchManager()->activateAllEntities('forum_post');
    }

    /**
     * Deactivate entities
     * 
     * @return void
     */
    public function deactivateEntities()
    {
        OW::getTextSearchManager()->deactivateAllEntities('forum_topic');
        OW::getTextSearchManager()->deactivateAllEntities('forum_post');
    }

    /**
     * Delete all entities
     * 
     * @return void
     */
    public function deleteAllEntities()
    {
        OW::getTextSearchManager()->deleteAllEntities('forum_topic');
        OW::getTextSearchManager()->deleteAllEntities('forum_post');
    }

    /**
     * Get count of topics in all sections
     * 
     * @param string $token
     * @param integer $userId
     * @return integer
     */
    public function countGlobalTopics( $text, $userId = null )
    {
        $tags = $userId
            ? array('forum_topic_public_user_id_' . $userId)
            : array('forum_topic_public');

        return OW::getTextSearchManager()->searchEntitiesCount($text, $tags);
    }

    /**
     * Find topics in all sections
     * 
     * @param string $token
     * @param integer $page
     * @param string $sortBy
     * @param integer $userId
     * @return array
     */
    public function findGlobalTopics( $text, $first, $limit, $sortBy = null, $userId = null )
    {
        $sort =  $sortBy == 'rel' 
            ? OW_TextSearchManager::SORT_BY_RELEVANCE
            : OW_TextSearchManager::SORT_BY_DATE;

        $tags = $userId
            ? array('forum_topic_public_user_id_' . $userId)
            : array('forum_topic_public');

        return OW::getTextSearchManager()->searchEntities( $text, $first, $limit, $tags, $sort);
    }

    /**
     * Get count of topics in all sections
     * 
     * @param integer $userId
     * @return integer
     */
    public function countGlobalTopicsByUser( $userId )
    {
        return OW::getTextSearchManager()->searchEntitiesCountByTags(array(
            'forum_topic_public_user_id_' . $userId
        ));
    }

    /**
     * Find topics in all sections
     * 
     * @param integer $userId
     * @param integer $page
     * @param string $sortBy
     * @return array
     */
    public function findGlobalTopicsByUser( $userId, $first, $limit, $sortBy = null )
    {
        // we can only sort by date here
        $sort = OW_TextSearchManager::SORT_BY_DATE;

        return OW::getTextSearchManager()->searchEntitiesByTags(array(
            'forum_topic_public_user_id_' . $userId
        ), $first, $limit, $sort);
    }

    /**
     * Get count of topics in section
     * 
     * @param string $token
     * @param integer $sectionId
     * @param integer $userId
     * @return integer
     */
    public function countTopicsInSection( $text, $sectionId, $userId = null )
    {
        $tags = $userId
            ? array('forum_topic_section_id_' . $sectionId . '_user_id_' . $userId)
            : array('forum_topic_section_id_' . $sectionId);

        return OW::getTextSearchManager()->searchEntitiesCount($text, $tags);
    }

    /**
     * Find topics in section
     * 
     * @param string $text
     * @param integer $sectionId
     * @param integer $first
     * @param integer $limit
     * @param string $sortBy
     * @param integer $userId
     * @return array
     */
    public function findTopicsInSection( $text, $sectionId, $first, $limit, $sortBy = null, $userId = null )
    {
        $sort =  $sortBy == 'rel' 
            ? OW_TextSearchManager::SORT_BY_RELEVANCE
            : OW_TextSearchManager::SORT_BY_DATE;

        $tags = $userId
            ? array('forum_topic_section_id_' . $sectionId . '_user_id_' . $userId)
            : array('forum_topic_section_id_' . $sectionId);

        return OW::getTextSearchManager()->searchEntities( $text, $first, $limit, $tags, $sort);
    }

    /**
     * Get count of topics in section
     * 
     * @param integer $userId
     * @param integer $sectionId
     * @return integer
     */
    public function countTopicsInSectionByUser( $userId, $sectionId )
    {
        return OW::getTextSearchManager()->searchEntitiesCountByTags(array(
            'forum_topic_section_id_' . $sectionId . '_user_id_' . $userId
        ));
    }

    /**
     * Find topics in section
     * 
     * @param integer $userId
     * @param integer $sectionId
     * @param integer $first
     * @param integer $limit
     * @param string $sortBy
     * @return array
     */
    public function findTopicsInSectionByUser( $userId, $sectionId, $first, $limit, $sortBy = null )
    {
        // we can only sort by date here
        $sort =  OW_TextSearchManager::SORT_BY_DATE;

        return OW::getTextSearchManager()->searchEntitiesByTags( array(
            'forum_topic_section_id_' . $sectionId . '_user_id_' . $userId
        ), $first, $limit, $sort);
    }

    /**
     * Get count of topics in group
     * 
     * @param string $token
     * @param integer $groupId
     * @param integer $userId
     * @return integer
     */
    public function countTopicsInGroup( $text, $groupId, $userId = null )
    {
        $tags = $userId
            ? array('forum_topic_group_id_' . $groupId . '_user_id_' . $userId)
            : array('forum_topic_group_id_' . $groupId);

        return OW::getTextSearchManager()->searchEntitiesCount($text, $tags);
    }

    /**
     * Find topics in group
     * 
     * @param string $text
     * @param integer $sectionId
     * @param integer $first
     * @param integer $limit
     * @param string $sortBy
     * @param integer $userId
     * @return array
     */
    public function findTopicsInGroup( $text, $groupId, $first, $limit, $sortBy = null, $userId = null )
    {
        $sort =  $sortBy == 'rel' 
            ? OW_TextSearchManager::SORT_BY_RELEVANCE
            : OW_TextSearchManager::SORT_BY_DATE;

        $tags = $userId
            ? array('forum_topic_group_id_' . $groupId . '_user_id_' . $userId)
            : array('forum_topic_group_id_' . $groupId);

        return OW::getTextSearchManager()->searchEntities( $text, $first, $limit, $tags, $sort);
    }

    /**
     * Get count of topics in group
     * 
     * @param integer $userId
     * @param integer $groupId
     * @return integer
     */
    public function countTopicsInGroupByUser( $userId, $groupId )
    {
        return OW::getTextSearchManager()->searchEntitiesCountByTags(array(
            'forum_topic_group_id_' . $groupId . '_user_id_' . $userId
        ));
    }

    /**
     * Find topics in group
     * 
     * @param integer $userId
     * @param integer $sectionId
     * @param integer $first
     * @param integer $limit
     * @param string $sortBy
     * @return array
     */
    public function findTopicsInGroupByUser( $userId, $groupId, $first, $limit, $sortBy = null )
    {
        // we can only sort by date here
        $sort =  OW_TextSearchManager::SORT_BY_DATE;

        return OW::getTextSearchManager()->searchEntitiesByTags( array(
            'forum_topic_group_id_' . $groupId . '_user_id_' . $userId
        ), $first, $limit, $sort);
    }

    /**
     * Get count of entities in advanced search
     * 
     * @param string $keyword
     * @param integer $userId
     * @param array $parts
     * @param string $period
     * @param boolean $searchPosts
     * @return integer
     */
    public function countAdvancedFindEntities( $keyword, $userId = null, $parts = array(), $period = null, $searchPosts = true )
    {
        // get tags list
        $tags = $this->processAdvancedSearchTags($parts, $userId, $searchPosts);

        // filter by period
        if ( $period )
        {
            list($timeStart, $timeEnd) = $this->getAdvancedSearchPeriod($period);
            return OW::getTextSearchManager()->searchEntitiesCount($keyword, $tags, $timeStart, $timeEnd); 
        }

        return OW::getTextSearchManager()->searchEntitiesCount($keyword, $tags);
    }
    
    /**
     * Advanced find entites
     * 
     * @param string $keyword
     * @param integer $first
     * @param integer $limit
     * @param integer $userId
     * @param array $parts
     * @param string $period
     * @param string $sort (relevance|date)
     * @param string $sortDirection (decrease|increase)
     * @param boolean $searchPosts
     * @return array
     */
    public function advancedFindEntities( $keyword, $first, $limit, $userId = null, 
            $parts = array(), $period = null, $sort = null, $sortDirection = null, $searchPosts = true )
    {
        // get tags list
        $tags = $this->processAdvancedSearchTags($parts, $userId, $searchPosts);

        $sort = $sort == 'relevance' 
            ? OW_TextSearchManager::SORT_BY_RELEVANCE
            : OW_TextSearchManager::SORT_BY_DATE;

        $sortDesc = $sortDirection == 'decrease' 
            ? true 
            : false;

        // filter by period
        if ( $period )
        {
            list($timeStart, $timeEnd) = $this->getAdvancedSearchPeriod($period);
            return OW::getTextSearchManager()->
                    searchEntities($keyword, $first, $limit, $tags, $sort, $sortDesc, $timeStart, $timeEnd); 
        }

        return OW::getTextSearchManager()->searchEntities($keyword, $first, $limit, $tags, $sort, $sortDesc);
    }

    /**
     * Get count of entities in advanced search
     * 
     * @param integer $userId
     * @param array $parts
     * @param string $period
     * @param boolean $searchPosts
     * @return integer
     */
    public function countAdvancedFindEntitiesByUser( $userId = null, $parts = array(), $period = null, $searchPosts = true )
    {
        // get tags list
        $tags = $this->processAdvancedSearchTags($parts, $userId, $searchPosts);

        // filter by period
        if ( $period )
        {
            list($timeStart, $timeEnd) = $this->getAdvancedSearchPeriod($period);
            return OW::getTextSearchManager()->searchEntitiesCountByTags($tags, $timeStart, $timeEnd); 
        }

        return OW::getTextSearchManager()->searchEntitiesCountByTags($tags);
    }
  
    /**
     * Advanced find entites
     * 
     * @param integer $userId
     * @param integer $first
     * @param integer $limit
     * @param array $parts
     * @param string $period
     * @param string $sort (relevance|date)
     * @param string $sortDirection (decrease|increase)
     * @param boolean $searchPosts
     * @return array
     */
    public function advancedFindEntitiesByUser( $userId, $first, $limit,  
            $parts = array(), $period = null, $sort = null, $sortDirection = null, $searchPosts = true )
    {
        // get tags list
        $tags = $this->processAdvancedSearchTags($parts, $userId, $searchPosts);

        // we can sort here only by date
        $sort = OW_TextSearchManager::SORT_BY_DATE;

        $sortDesc = $sortDirection == 'decrease' 
            ? true 
            : false;

        // filter by period
        if ( $period )
        {
            list($timeStart, $timeEnd) = $this->getAdvancedSearchPeriod($period);
            return OW::getTextSearchManager()->
                    searchEntitiesByTags($tags, $first, $limit, $sort, $sortDesc, $timeStart, $timeEnd); 
        }

        return OW::getTextSearchManager()->searchEntitiesByTags($tags, $first, $limit, $sort, $sortDesc);
    }

    /**
     * Get advanced search period
     * 
     * @param string $period
     * @return array
     */
    protected function getAdvancedSearchPeriod($period)
    {
        switch ($period)
        {
            case 'last_six_months' :
                return array(
                    strtotime('first day of 6 months ago 00:00:00'),
                    strtotime('today 23:59:59')
                );

            case 'last_three_months' :
                return array(
                    strtotime('first day of 3 months ago 00:00:00'),
                    strtotime('today 23:59:59')
                );

            case 'last_two_months' :
                return array(
                    strtotime('first day of 2 months ago 00:00:00'),
                    strtotime('today 23:59:59')
                );

            case 'last_month' :
                return array(
                    strtotime('first day of last month 00:00:00'),
                    strtotime('today 23:59:59')
                );

            case 'last_week' :
                return array(
                    strtotime('monday last week'),
                    strtotime('today 23:59:59')
                );

            case 'today' :
            default      :
                return array(
                    strtotime('today'),
                    strtotime('today 23:59:59')
                );
        }
    }

    /**
     * Process advanced search tags
     * 
     * @param array $parts
     * @param type $userId
     * @param boolean $searchPosts
     * @return array
     */
    protected function processAdvancedSearchTags( array $parts, $userId = null, $searchPosts = true )
    {
        $tags = array();

        foreach($parts as $part)
        {
            $id = preg_replace('/[^0-9]/', '', $part);

            if ( !$id )
            {
                continue;
            }

            // search in groups
            if ( substr($part, 0, 5) == 'group' )
            {
                if ( $searchPosts )
                {
                    $tags[] = $userId
                        ? 'forum_post_public_group_id_' . $id . '_user_id_' . $userId
                        : 'forum_post_public_group_id_' . $id; 
                }
                else
                {
                    // search in topics
                    $tags[] = $userId
                        ? 'forum_topic_public_group_id_' . $id . '_user_id_' . $userId
                        : 'forum_topic_public_group_id_' . $id; 
                }
            }
            else
            {
                // search in sections
                if ( $searchPosts )
                {
                    $tags[] = $userId
                        ? 'forum_post_public_section_id_' . $id . '_user_id_' . $userId
                        : 'forum_post_public_section_id_' . $id; 
                }
                else
                {
                    // search in topics
                    $tags[] = $userId
                        ? 'forum_topic_public_section_id_' . $id . '_user_id_' . $userId
                        : 'forum_topic_public_section_id_' . $id; 
                }
            }
        }

        // search in anywhere
        if ( !$tags )
        {
            if ( $searchPosts )
            {
                $tags[] = $userId
                   ? 'forum_post_public_user_id_' . $userId
                   : 'forum_post_public';
            }
            else 
            {
                $tags[] = $userId
                   ? 'forum_topic_public_user_id_' . $userId
                   : 'forum_topic_public';
            }
        }

        return $tags;
    }

    /**
     * Get count of posts in topic
     * 
     * @param string $token
     * @param integer $topicId
     * @param integer $userId
     * @return integer
     */
    public function countPostsInTopic( $text, $topicId, $userId = null )
    {
        $tags = $userId
            ? array('forum_post_topic_id_' . $topicId . '_user_id_' . $userId)
            : array('forum_post_topic_id_' . $topicId);

        return OW::getTextSearchManager()->searchEntitiesCount($text, $tags);
    }

    /**
     * Find posts in topic
     * 
     * @param string $text
     * @param integer $topicId
     * @param integer $first
     * @param integer $limit
     * @param string $sortBy
     * @param integer $userId
     * @return array
     */
    public function findPostsInTopic( $text, $topicId, $first, $limit, $sortBy = null, $userId = null )
    {
        $sort =  $sortBy == 'rel' 
            ? OW_TextSearchManager::SORT_BY_RELEVANCE
            : OW_TextSearchManager::SORT_BY_DATE;

        $tags = $userId
            ? array('forum_post_topic_id_' . $topicId . '_user_id_' . $userId)
            : array('forum_post_topic_id_' . $topicId);

        return OW::getTextSearchManager()->searchEntities( $text, $first, $limit, $tags, $sort);
    }

    /**
     * Get count of posts in topic
     * 
     * @param integer $userId
     * @param integer $topicId
     * @return integer
     */
    public function countPostsInTopicByUser( $userId, $topicId )
    {
        return OW::getTextSearchManager()->searchEntitiesCountByTags(array(
            'forum_post_topic_id_' . $topicId . '_user_id_' . $userId
        ));
    }

    /**
     * Find posts in topic
     * 
     * @param integer $userId
     * @param integer $topicId
     * @param integer $first
     * @param integer $limit
     * @param string $sortBy
     * @return array
     */
    public function findPostsInTopicByUser( $userId, $topicId, $first, $limit, $sortBy = null )
    {
        // we can sort here only by date
        $sort = OW_TextSearchManager::SORT_BY_DATE;

        return OW::getTextSearchManager()->searchEntitiesByTags( array(
            'forum_post_topic_id_' . $topicId . '_user_id_' . $userId
        ), $first, $limit, $sort);
    }

    /**
     * Add topic
     * 
     * @param FORUM_BOL_Topic $topicDto
     * @return void
     */
    public function addTopic( FORUM_BOL_Topic $topicDto )
    {
        $groupInfo = $this->getForumService()->getGroupInfo($topicDto->groupId);      
        $sectionInfo = $this->getForumService()->findSectionById($groupInfo->sectionId);

        $topicTags = array(
            'forum_topic', // global search
            'forum_topic_user_id_' . $topicDto->userId, // global search by a specific user
            'forum_topic_group_id_' . $topicDto->groupId, // search into a specific forum
            'forum_topic_group_id_' . $topicDto->groupId . '_user_id_' . $topicDto->userId, // search into a specific forum and specific user              
            'forum_topic_section_id_' . $groupInfo->sectionId, // search into a specific section
            'forum_topic_section_id_' . $groupInfo->sectionId . '_user_id_' . $topicDto->userId, // search into a specific section and specific user
            'forum_topic_id_' . $topicDto->id
        );

        if ( !$groupInfo->isPrivate && !$sectionInfo->isHidden ) 
        {
            $topicTags = array_merge($topicTags, array(
                'forum_topic_public', // visible everywhere
                'forum_topic_public_user_id_' . $topicDto->userId,
                'forum_topic_public_group_id_' . $topicDto->groupId,
                'forum_topic_public_group_id_' . $topicDto->groupId . '_user_id_' . $topicDto->userId,
                'forum_topic_public_section_id_' . $groupInfo->sectionId,
                'forum_topic_public_section_id_' . $groupInfo->sectionId . '_user_id_' . $topicDto->userId,
            ));
        }

        OW::getTextSearchManager()->
                addEntity(self::SEARCH_ENTITY_TYPE_TOPIC, $topicDto->id, $topicDto->title, time(), $topicTags);
    }

    /**
     * Save or update topic
     * 
     * @param FORUM_BOL_Topic $topicDto
     * @param boolean $refreshPosts
     * @return void
     */
    public function saveOrUpdateTopic( FORUM_BOL_Topic $topicDto, $refreshPosts = false )
    {
        // activate or deactivate topics and posts
        if ( in_array('status', $topicDto->getEntinyUpdatedFields()) )
        {
            $topicDto->status != FORUM_BOL_ForumService::STATUS_APPROVED
                ? $this->setTopicStatus($topicDto->id, false)
                : $this->setTopicStatus($topicDto->id);
        }

        // update topic title 
        if ( in_array('title', $topicDto->getEntinyUpdatedFields()) ) 
        {
            // delete old topic
            OW::getTextSearchManager()->deleteAllEntitiesByTags(array(
                'forum_topic_id_' . $topicDto->id
            ));

            $this->addTopic($topicDto);    
        }

        if ( $refreshPosts )
        {
            FORUM_BOL_UpdateSearchIndexDao::getInstance()->
                addQueue($topicDto->id, FORUM_BOL_UpdateSearchIndexDao::DELETE_TOPIC);
        }
    }

    /**
     * Delete topic 
     * 
     * @param integer $topicId
     * @return void
     */
    public function deleteTopic( $topicId )
    {
        OW::getTextSearchManager()->deleteAllEntitiesByTags(array(
            'forum_topic_id_' . $topicId, // delete the topic
            'forum_post_topic_id_' . $topicId, // delete all posts inside,
            'forum_post_duplicate_topic_id_' . $topicId 
        ));
    }

    /**
     * Delete group
     * 
     * @param integer $groupId
     * @return void
     */
    public function deleteGroup( $groupId )
    {
        // delete all topics and posts into the group
        OW::getTextSearchManager()->deleteAllEntitiesByTags(array(
            'forum_topic_group_id_' . $groupId,
            'forum_post_group_id_' . $groupId
        ));
    }
}