XoopsModules\Newbb\DigestHandler

Complexity

Total Complexity

36

Size/Duplication

Total Lines	262
Duplicated Lines	0 %

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	process()	0	25	6
A	delete()	0	13	3
A	notify()	0	11	1
A	getDigestCount()	0	11	2
A	checkStatus()	0	9	3
A	getLastDigest()	0	9	2
C	buildDigest()	0	79	14
A	insert()	0	6	1
A	getAllDigests()	0	17	3

<?php declare(strict_types=1);

namespace XoopsModules\Newbb;

/**
 * NewBB,  the forum module for XOOPS project
 *
 * @copyright      XOOPS Project (https://xoops.org)
 * @license        GNU GPL 2.0 or later (https://www.gnu.org/licenses/gpl-2.0.html)
 * @author         Taiwen Jiang (phppp or D.J.) <phppp@users.sourceforge.net>
 * @since          4.00
 */

use Xmf\Metagen;
use XoopsModules\Newbb;

/**
 * Class DigestHandler
 */
class DigestHandler extends \XoopsPersistableObjectHandler
{
    public int $last_digest;

    /**
     * Constructor
     *
     * @param null|\XoopsDatabase $db database connection
     */
    public function __construct(\XoopsDatabase $db = null)
    {
        parent::__construct($db, 'newbb_digest', Digest::class, 'digest_id');
    }

    /**
     * @param bool $isForced
     * @return int
     */
    public function process(bool $isForced = false): int
    {
        $this->getLastDigest();
        if (!$isForced) {
            $status = $this->checkStatus();
            if ($status < 1) {
                return 1;
            }
        }
        /** @var Digest $digest */
        $digest = $this->create();
        $status = $this->buildDigest($digest);
        if (!$status) {
            return 2;
        }
        $status = $this->insert($digest);
        if (!$status) {
            return 3;
        }
        $status = $this->notify($digest);
        if (!$status) {

The condition $status is always true.

            return 4;
        }

        return 0;
    }

    /**
     * @param \XoopsObject $digest
     * @return bool
     */
    public function notify(\XoopsObject $digest): bool
    {
        $tags = [];
        //$content                = $digest->getVar('digest_content');
        /** @var \XoopsNotificationHandler $notificationHandler */
        $notificationHandler    = \xoops_getHandler('notification');
        $tags['DIGEST_ID']      = $digest->getVar('digest_id');
        $tags['DIGEST_CONTENT'] = $digest->getVar('digest_content', 'E');
        $notificationHandler->triggerEvent('global', 0, 'digest', $tags);

        return true;
    }

    /**
     * @param int $start
     * @param int $perpage
     * @return array
     */
    public function getAllDigests(int $start = 0, int $perpage = 5): array
    {
        //        if (empty($start)) {
        //            $start = 0;
        //        }

        $sql    = 'SELECT * FROM ' . $this->db->prefix('newbb_digest') . ' ORDER BY digest_id DESC';
        $result = $this->db->query($sql, $perpage, $start);
        $ret    = [];
        //        $reportHandler =  Newbb\Helper::getInstance()->getHandler('Report');
        if ($this->db->isResultSet($result)) {
            while (false !== ($myrow = $this->db->fetchArray($result))) {
                $ret[] = $myrow; // return as array
            }
        }

        return $ret;
    }

    /**
     * @return int
     */
    public function getDigestCount(): int
    {
        $sql    = 'SELECT COUNT(*) AS count FROM ' . $this->db->prefix('newbb_digest');
        $result = $this->db->query($sql);
        if (!$this->db->isResultSet($result)) {
//            \trigger_error("Query Failed! SQL: $sql- Error: " . $xoopsDB->error(), E_USER_ERROR);
            return 0;
        }
        $array = $this->db->fetchArray($result);

        return (int)$array['count'];
    }

    public function getLastDigest(): void
    {
        $sql    = 'SELECT MAX(digest_time) AS last_digest FROM ' . $this->db->prefix('newbb_digest');
        $result = $this->db->query($sql);
        if ($this->db->isResultSet($result)) {
            $array             = $this->db->fetchArray($result);
            $this->last_digest = $array['last_digest'] ?? 0;
        } else {
            $this->last_digest = 0;
            // echo "<br>no data:".$sql;
        }
    }

    /**
     * @return int
     */
    public function checkStatus(): int
    {
        if (!isset($this->last_digest)) {
            $this->getLastDigest();
        }
        $deadline  = (1 == $GLOBALS['xoopsModuleConfig']['email_digest']) ? 60 * 60 * 24 : 60 * 60 * 24 * 7;
        $time_diff = \time() - $this->last_digest;

        return $time_diff - $deadline;
    }

    /**
     * @param \XoopsObject $object Digest
     * @param bool $force flag to force the query execution despite security settings
     * @return mixed       object ID or false
     */
    public function insert(\XoopsObject $object, $force = true)
    {
        $digest = $object;
        $digest->setVar('digest_time', \time());

        return parent::insert($digest, $force);
        /*
        $content = $digest->getVar('digest_content', 'E');

        $id  = $this->db->genId($digest->table . '_digest_id_seq');
        $sql = 'INSERT INTO ' . $digest->table . ' (digest_id, digest_time, digest_content)    VALUES (' . $id . ', ' . time() . ', ' . $this->db->quoteString($content) . ' )';

        if (!$this->db->queryF($sql)) {
            //echo "<br>digest insert error::" . $sql;
            return false;
        }
        if (empty($id)) {
            $id = $this->db->getInsertId();
        }
        $digest->setVar('digest_id', $id);

        return true;
        */
    }

    /**
     * @param \XoopsObject $object Digest
     * @param bool $force (ignored)
     * @return bool        FALSE if failed.
     */
    public function delete(\XoopsObject $object, $force = false): bool
    {
        $digest = $object;
        $digest_id = $digest->getVar('digest_id');

        if (!isset($this->last_digest)) {
            $this->getLastDigest();
        }
        if ($this->last_digest == $digest_id) {
            return false;
        } // It is not allowed to delete the last digest

        return parent::delete($digest, true);
    }

    /**
     * @param Digest $digest
     * @return bool
     */
    public function buildDigest(Digest $digest): bool
    {
        global $xoopsModule;

        if (!\defined('SUMMARY_LENGTH')) {
            \define('SUMMARY_LENGTH', 100);
        }

        /** @var ForumHandler $forumHandler */
        $forumHandler         = Helper::getInstance()->getHandler('Forum');
        $thisUser             = $GLOBALS['xoopsUser'];
        $GLOBALS['xoopsUser'] = null; // To get posts accessible by anonymous
        $GLOBALS['xoopsUser'] = $thisUser;

        $accessForums    = $forumHandler->getIdsByPermission(); // get all accessible forums
        $forumCriteria   = ' AND t.forum_id IN (' . \implode(',', $accessForums) . ')';
        $approveCriteria = ' AND t.approved = 1 AND p.approved = 1';
        $time_criteria   = ' AND t.digest_time > ' . $this->last_digest;

        $karma_criteria = $GLOBALS['xoopsModuleConfig']['enable_karma'] ? ' AND p.post_karma=0' : '';
        $reply_criteria = $GLOBALS['xoopsModuleConfig']['allow_require_reply'] ? ' AND p.require_reply=0' : '';

        $sql = 'SELECT t.topic_id, t.forum_id, t.topic_title, t.topic_time, t.digest_time, p.uid, p.poster_name, pt.post_text FROM '
                 . $this->db->prefix('newbb_topics')
                 . ' t, '
                 . $this->db->prefix('newbb_posts_text')
                 . ' pt, '
                 . $this->db->prefix('newbb_posts')
                 . ' p WHERE t.topic_digest = 1 AND p.topic_id=t.topic_id AND p.pid=0 '
                 . $forumCriteria
                 . $approveCriteria
                 . $time_criteria
                 . $karma_criteria
                 . $reply_criteria
                 . ' AND pt.post_id=p.post_id ORDER BY t.digest_time DESC';
        $result = $this->db->query($sql);
        if (!$this->db->isResultSet($result)) {
            //echo "<br>No result:<br>$sql";
            return false;
        }
        $rows  = [];
        $users = [];
        while (false !== ($row = $this->db->fetchArray($result))) {
            $users[$row['uid']] = 1;
            $rows[]             = $row;
        }
        if (\count($rows) < 1) {
            return false;
        }
        $uids = \array_keys($users);
        if (\count($uids) > 0) {
            /** @var \XoopsMemberHandler $memberHandler */
            $memberHandler = \xoops_getHandler('member');
            $user_criteria = new \Criteria('uid', '(' . \implode(',', $uids) . ')', 'IN');
            $users         = $memberHandler->getUsers($user_criteria, true);
        } else {
            $users = [];
        }

        foreach ($rows as $topic) {
            if ($topic['uid'] > 0) {
                if (isset($users[$topic['uid']]) && \is_object($users[$topic['uid']])
                    && $users[$topic['uid']]->isActive()) {
                    $topic['uname'] = $users[$topic['uid']]->getVar('uname');
                } else {
                    $topic['uname'] = $GLOBALS['xoopsConfig']['anonymous'];
                }
            } else {
                $topic['uname'] = $topic['poster_name'] ?: $GLOBALS['xoopsConfig']['anonymous'];
            }
            $summary = Metagen::generateDescription($topic['post_text'], \SUMMARY_LENGTH);
            $author  = $topic['uname'] . ' (' . \formatTimestamp($topic['topic_time']) . ')';
            $link    = XOOPS_URL . '/modules/' . $xoopsModule->dirname() . '/viewtopic.php?topic_id=' . $topic['topic_id'] . '&amp;forum=' . $topic['forum_id'];
            $title   = $topic['topic_title'];
            $digest->addItem($title, $link, $author, $summary);
        }
        $digest->buildContent();

        return true;
    }
}