<?php

//require_once(KPATH_ADMIN.'/libraries/forum/topic/helper.php');
require_once(MBQ_PARENT_PATH.'libraries/kunena/forum/topic/helper.php');  //for kunena 3.0.0

/**
 * for kunena 2.0.1/2.0.2/2.0.3/2.0.4
 * ExttMbqKunenaForumTopicHelper extended from KunenaForumTopicHelper
 * add method exttMbqGetLatestTopics() modified from method getLatestTopics().
 * add method exttMbqFetchNewStatus() modified from method fetchNewStatus().
 */
abstract class ExttMbqKunenaForumTopicHelper extends KunenaForumTopicHelper {

    static public function exttMbqGetLatestTopics($categories=false, $limitstart=0, $limit=0, $params=array()) {
        KUNENA_PROFILER ? KunenaProfiler::instance()->start('function '.__CLASS__.'::'.__FUNCTION__.'()') : null;
        $db = JFactory::getDBO ();
        $config = KunenaFactory::getConfig ();
        //if ($limit < 1) $limit = $config->threads_per_page;       //from kunena 2.0.1
        if ($limit < 1 && empty($params['nolimit'])) $limit = $config->threads_per_page;        //from kunena 2.0.2

        $reverse = isset($params['reverse']) ? (int) $params['reverse'] : 0;
        $orderby = isset($params['orderby']) ? (string) $params['orderby'] : 'tt.last_post_time DESC';
        $starttime = isset($params['starttime']) ? (int) $params['starttime'] : 0;
        $user = isset($params['user']) ? KunenaUserHelper::get($params['user']) : KunenaUserHelper::getMyself();
        $hold = isset($params['hold']) ? (string) $params['hold'] : 0;
        $moved = isset($params['moved']) ? (string) $params['moved'] : 0;
        $where = isset($params['where']) ? (string) $params['where'] : '';
        $mbqWhere = $where;

        if ($user) {
            if (isset($params['unread'])) {
                $session = KunenaFactory::getSession ();
                /* ref KunenaForumTopicHelper::fetchNewStatus */
                //mbqTt.last_post_time > {$db->Quote($session->lasttime)} AND
                $sqlInUnreadTopicId = "
                SELECT mbqTt.id as id
                FROM #__kunena_topics AS mbqTt
                LEFT JOIN #__kunena_user_read AS mbqUr ON mbqTt.id=mbqUr.topic_id AND mbqUr.user_id={$db->Quote($user->userid)}
                WHERE mbqTt.last_post_time > {$db->Quote($session->lasttime)} AND (mbqUr.time IS NULL OR mbqTt.last_post_time>mbqUr.time)
                ";
            }
        }

        if (strstr('ut.last_', $orderby)) {
            $post_time_field = 'ut.last_post_time';
        } elseif (strstr('tt.first_', $orderby)) {
            $post_time_field = 'tt.first_post_time';
        } else {
            $post_time_field = 'tt.last_post_time';
        }

        $categories = KunenaForumCategoryHelper::getCategories($categories, $reverse);
        $catlist = array();
        foreach ($categories as $category) {
            $catlist += $category->getChannels();
        }
        if (empty($catlist)) {
            KUNENA_PROFILER ? KunenaProfiler::instance()->stop('function '.__CLASS__.'::'.__FUNCTION__.'()') : null;
            return array(0, array());
        }
        $catlist = implode(',', array_keys($catlist));

        $whereuser = array();
        if (!empty($params['started'])) $whereuser[] = 'ut.owner=1';
        if (!empty($params['replied'])) $whereuser[] = '(ut.owner=0 AND ut.posts>0)';
        if (!empty($params['posted'])) $whereuser[] = 'ut.posts>0';
        if (!empty($params['favorited'])) $whereuser[] = 'ut.favorite=1';
        if (!empty($params['subscribed'])) $whereuser[] = 'ut.subscribed=1';

        if ($config->keywords || $config->userkeywords) {
            $kwids = array();
            if (!empty($params['keywords'])) {
                $keywords = KunenaKeywordHelper::getByKeywords($params['keywords']);
                foreach ($keywords as $keyword) {
                    //$kwids[] = $keyword->$id;
                    $kwids[] = $keyword->id;    //for kunena 3.0.0
                }
                $kwids = implode(',', $kwids);
            }
            //TODO: add support for keywords (example:)
            /* SELECT tt.*, COUNT(*) AS score FROM #__kunena_keywords_map AS km
            INNER JOIN #__kunena_topics` AS tt ON km.topic_id=tt.id
            WHERE km.keyword_id IN (1,2) AND km.user_id IN (0,62)
            GROUP BY topic_id
            ORDER BY score DESC, tt.last_post_time DESC */
        }

        $wheretime = ($starttime ? " AND {$post_time_field}>{$db->Quote($starttime)}" : '');
        $whereuser = ($whereuser ? " AND ut.user_id={$db->Quote($user->userid)} AND (".implode(' OR ',$whereuser).')' : '');
        $where = "tt.hold IN ({$hold}) AND tt.category_id IN ({$catlist}) {$whereuser} {$wheretime} {$where}";
        if (!$moved) $where .= " AND tt.moved_id='0'";

        // Get total count
        /*
        if ($whereuser)
            $query = "SELECT COUNT(*) FROM #__kunena_user_topics AS ut INNER JOIN #__kunena_topics AS tt ON tt.id=ut.topic_id WHERE {$where}";
        else
            $query = "SELECT COUNT(*) FROM #__kunena_topics AS tt WHERE {$where}";
        */
        if (isset($params['unread'])) {
            //$where = "tt.hold IN ({$hold}) AND tt.category_id IN ({$catlist}) {$whereuser} {$wheretime} {$where}";
            $whereUnread = "tt.hold IN ({$hold}) AND tt.category_id IN ({$catlist}) {$wheretime} {$mbqWhere} and tt.id in ({$sqlInUnreadTopicId})";
            $query = "SELECT COUNT(*) FROM #__kunena_topics AS tt WHERE {$whereUnread}";
        } elseif ($whereuser) {
            $query = "SELECT COUNT(*) FROM #__kunena_user_topics AS ut INNER JOIN #__kunena_topics AS tt ON tt.id=ut.topic_id WHERE {$where}";
        }
        else
            $query = "SELECT COUNT(*) FROM #__kunena_topics AS tt WHERE {$where}";
        $db->setQuery ( $query );
        $total = ( int ) $db->loadResult ();


        if (KunenaError::checkDatabaseError() || !$total) {
            KUNENA_PROFILER ? KunenaProfiler::instance()->stop('function '.__CLASS__.'::'.__FUNCTION__.'()') : null;
            return array(0, array());
        }

        // If out of range, use last page
        //if ($total < $limitstart)     //from kunena 2.0.1
        if ($limit && $total < $limitstart)     //from kunena 2.0.2
            $limitstart = intval($total / $limit) * $limit;

        // Get items
        /*
        if ($whereuser)
            $query = "SELECT tt.*, ut.posts AS myposts, ut.last_post_id AS my_last_post_id, ut.favorite, tt.last_post_id AS lastread, 0 AS unread
                FROM #__kunena_user_topics AS ut
                INNER JOIN #__kunena_topics AS tt ON tt.id=ut.topic_id
                WHERE {$where} ORDER BY {$orderby}";
        else
            $query = "SELECT tt.*, ut.posts AS myposts, ut.last_post_id AS my_last_post_id, ut.favorite, tt.last_post_id AS lastread, 0 AS unread
                FROM #__kunena_topics AS tt
                LEFT JOIN #__kunena_user_topics AS ut ON tt.id=ut.topic_id AND ut.user_id={$db->Quote($user->userid)}
                WHERE {$where} ORDER BY {$orderby}";
        */
        if (isset($params['unread'])) {
            $query1 = "SELECT tt.*, ut.posts AS myposts, ut.last_post_id AS my_last_post_id, ut.favorite, tt.last_post_id AS lastread, 0 AS unread
                FROM #__kunena_user_topics AS ut
                INNER JOIN #__kunena_topics AS tt ON tt.id=ut.topic_id and ut.user_id = {$db->Quote($user->userid)}
                WHERE {$whereUnread}";
            $query2 = "SELECT tt.*, 0 AS myposts, 0 AS my_last_post_id, 0 as favorite, tt.last_post_id AS lastread, 0 AS unread
                FROM #__kunena_topics AS tt
                WHERE {$whereUnread} and tt.id not in (SELECT topic_id from #__kunena_user_topics where user_id = {$db->Quote($user->userid)})";
            $query = "({$query1}) UNION ({$query2}) ORDER BY last_post_time DESC";
        } elseif ($whereuser) {
            $query = "SELECT tt.*, ut.posts AS myposts, ut.last_post_id AS my_last_post_id, ut.favorite, tt.last_post_id AS lastread, 0 AS unread
                FROM #__kunena_user_topics AS ut
                INNER JOIN #__kunena_topics AS tt ON tt.id=ut.topic_id
                WHERE {$where} ORDER BY {$orderby}";
        }
        else
            $query = "SELECT tt.*, ut.posts AS myposts, ut.last_post_id AS my_last_post_id, ut.favorite, tt.last_post_id AS lastread, 0 AS unread
                FROM #__kunena_topics AS tt
                LEFT JOIN #__kunena_user_topics AS ut ON tt.id=ut.topic_id AND ut.user_id={$db->Quote($user->userid)}
                WHERE {$where} ORDER BY {$orderby}";
        $db->setQuery ( $query, $limitstart, $limit );
        $results = (array) $db->loadAssocList ('id');
        if (KunenaError::checkDatabaseError()) {
            KUNENA_PROFILER ? KunenaProfiler::instance()->stop('function '.__CLASS__.'::'.__FUNCTION__.'()') : null;
            return array(0, array());
        }

        $topics = array();
        foreach ( $results as $id=>$result ) {
            $instance = new KunenaForumTopic ($result);
            $instance->exists(true);
            self::$_instances [$id] = $instance;
            $topics[$id] = $instance;
        }
        unset ($results);
        KUNENA_PROFILER ? KunenaProfiler::instance()->stop('function '.__CLASS__.'::'.__FUNCTION__.'()') : null;
        return array($total, $topics);
    }

    static public function exttMbqFetchNewStatus($topics, $user = null) {
        $user = KunenaUserHelper::get($user);
		/*
		if (!KunenaFactory::getConfig()->shownew || empty($topics) || !$user->exists()) {
			return array();
		}
		*/
		if (!KunenaFactory::getConfig()->shownew) { /* get_unread_topic and mark_all_as_read methods will be invalid if Show New posts is No in site backend setting */
			return $topics;
		} elseif (empty($topics) || !$user->exists()) {
		    return array();
		}
		$session = KunenaFactory::getSession ();


		$ids = array();
		foreach ($topics as $topic) {
			if ($topic->last_post_time < $session->lasttime) continue;
			$allreadtime = $topic->getCategory()->getUserInfo()->allreadtime;
			if ($allreadtime && $topic->last_post_time < JFactory::getDate($allreadtime)->toUnix()) continue;
			$ids[] = $topic->id;
		}

		if ($ids) {
			//$topiclist = array();   //removed for kunena 3.0.1
			$idstr = implode ( ",", $ids );

			$db = JFactory::getDBO ();
                        //AND m.time>{$db->Quote($session->lasttime)}
			$db->setQuery ( "SELECT m.thread AS id, MIN(m.id) AS lastread, SUM(1) AS unread
				FROM #__kunena_messages AS m
				LEFT JOIN #__kunena_user_read AS ur ON ur.topic_id=m.thread AND user_id={$db->Quote($user->userid)}
				WHERE m.hold=0 AND  m.moved=0 AND m.thread IN ({$idstr}) AND (ur.time IS NULL OR m.time>ur.time) AND m.time>{$db->Quote($session->lasttime)}
				GROUP BY thread" );
			$topiclist = (array) $db->loadObjectList ('id');
			KunenaError::checkDatabaseError ();
		}
		$list = array();
		//foreach ( $topics as $topic ) {
                $total = 0;
		foreach ( $topics as &$topic ) {

			if (isset($topiclist[$topic->id])) {
				$topic->lastread = $topiclist[$topic->id]->lastread;
				$topic->unread = $topiclist[$topic->id]->unread;
                                $total++;
			} else {
				$topic->lastread = $topic->last_post_id;
				$topic->unread = 0;
			}
			$list[$topic->id] = $topic->lastread;
		}
                //foreach ($topics as &$topic) $topic->totalPosts = $total;
		return $topics;
	}
}