online.php

<?php
 
 
class XoopsOnlineHandler
{

    public $db;

    public function __construct(&$db)
    {
        $this->db =& $db;
    }
    public function XoopsOnlineHandler(&$db)
    {
        return self::__construct($db);
    }

    public function write($uid, $uname, $time, $module, $ip)
    {
        $uid = (int)$uid;
        $ip = $this->db->quoteString($ip);
        if ($uid > 0) {
            $sql = 'SELECT COUNT(*) FROM ' . $this->db->prefix('online') . ' WHERE online_uid=' . $uid;
        } else {
            $sql = 'SELECT COUNT(*) FROM ' . $this->db->prefix('online') . ' WHERE online_uid=' . $uid . ' AND online_ip=' . $ip;
        }
        [$count] = $this->db->fetchRow($this->db->queryF($sql));
        if ($count > 0) {
            $sql = 'UPDATE ' . $this->db->prefix('online') . ' SET online_updated=' . $time . ', online_module = ' . $module . ' WHERE online_uid = ' . $uid;
            if (0 == $uid) {
                $sql .= ' AND online_ip=' . $ip;
            }
        } else {
            $sql = sprintf('INSERT INTO %s (online_uid, online_uname, online_updated, online_ip, online_module) VALUES (%u, %s, %u, %s, %u)', $this->db->prefix('online'), $uid, $this->db->quoteString($uname), $time, $ip, $module);
        }
        if (!$this->db->queryF($sql)) {
            return false;
        }
        return true;
    }

    public function destroy($uid)
    {
        $sql = sprintf('DELETE FROM %s WHERE online_uid = %u', $this->db->prefix('online'), $uid);
        if (!$result = $this->db->queryF($sql)) {
            return false;
        }
        return true;
    }

    public function gc($expire)
    {
        $sql = sprintf('DELETE FROM %s WHERE online_updated < %u', $this->db->prefix('online'), time() - (int)$expire);
        $this->db->queryF($sql);
    }

    public function &getAll($criteria = null)
    {
        $ret = [];
        $limit = $start = 0;
        $sql = 'SELECT * FROM '.$this->db->prefix('online');
        if (is_object($criteria) && $criteria instanceof \criteriaelement) {
            $sql .= ' '.$criteria->renderWhere();
            $limit = $criteria->getLimit();
            $start = $criteria->getStart();
        }
        $result =& $this->db->query($sql, $limit, $start);
        if (!$result) {
            $ret = false;
            return $ret;
        }
        while ($myrow = $this->db->fetchArray($result)) {
            $ret[] =& $myrow;
            unset($myrow);
        }
        return $ret;
    }

    public function getCount($criteria = null)
    {
        $sql = 'SELECT COUNT(*) FROM '.$this->db->prefix('online');
        if (is_object($criteria) && $criteria instanceof \criteriaelement) {
            $sql .= ' '.$criteria->renderWhere();
        }
        if (!$result =& $this->db->query($sql)) {
            $ret = false;
            return $ret;
        }
        [$ret] = $this->db->fetchRow($result);
        return $ret;
    }
}