online.php

Go to the documentation of this file.

<?php
use Xoops\Core\Database\Connection;
use Xoops\Core\Kernel\Criteria;
use Xoops\Core\Kernel\XoopsObject;
use Xoops\Core\Kernel\XoopsPersistableObjectHandler;

class XoopsOnline extends XoopsObject
{
    public function __construct()
    {
        $this->initVar('online_uid', XOBJ_DTYPE_INT, null, false);
        $this->initVar('online_uname', XOBJ_DTYPE_TXTBOX, null, true);
        $this->initVar('online_updated', XOBJ_DTYPE_INT, null, true);
        $this->initVar('online_module', XOBJ_DTYPE_INT, null, true);
        $this->initVar('online_ip', XOBJ_DTYPE_TXTBOX, null, true);
    }

    public function id($format = 'n')
    {
        return $this->online_uid($format);
    }

    public function online_uid($format = 'n')
    {
        return $this->getVar('online_uid', $format);
    }

    public function online_uname($format = '')
    {
        return $this->getVar('online_uname', $format);
    }

    public function online_updated($format = '')
    {
        return $this->getVar('online_updated', $format);
    }

    public function online_module($format = '')
    {
        return $this->getVar('online_module', $format);
    }

    public function online_ip($format = '')
    {
        return $this->getVar('online_ip', $format);
    }
}

class XoopsOnlineHandler extends XoopsPersistableObjectHandler
{
    public function __construct(Connection $db = null)
    {
        parent::__construct($db, 'online', 'XoopsOnline', 'online_uid', 'online_uname');
    }

    public function write($uid, $uname, $time, $module, $ip)
    {
        $criteria = array();
        $criteria['online_uid'] = $uid;
        if ($uid == 0) {
            $criteria['online_ip'] = $ip;
        }
        $rows = $this->db2->updatePrefix(
            'online',
            array(
               'online_uname'   => $uname,
               'online_updated' => $time,
               'online_module'  => $module,
            ),
            $criteria
        );
        if ($rows === false) {
            return false;
        }
        if ($rows == 0) {
            $rows = $this->db2->insertPrefix(
                'online',
                array(
                    'online_uid'     => $uid,
                    'online_uname'   => $uname,
                    'online_updated' => $time,
                    'online_ip'      => $ip,
                    'online_module'  => $module,
                )
            );
        }
        if ($rows === false) {
            return false;
        }
        return ($rows>0);
    }

    public function destroy($uid)
    {
        $criteria = new Criteria('online_uid', intval($uid));
        if (false === $this->deleteAll($criteria)) {
            return false;
        }
        return true;
    }

    public function gc($expire)
    {
        $criteria = new Criteria('online_updated', time() - intval($expire), '<');
        if (false === $this->deleteAll($criteria)) {
            return false;
        }
        return true;
    }
}