crash-processor/htdocs/lib/CrashStats.php

<?php

class CrashStats
{
    var $filter;
    
    function __construct($filter = null)
    {
        if ($filter)
        {
            $this->filter = $filter;
        }
        else
        {
            $this->filter = new SearchFilter;
        }
    }
    
    function setFilter($filter)
    {
        $this->filter = $filter;
    }
    
    function getTopCrashers()
    {
        $ret = array();
        $where = $this->filter->getWhere();
        $q = "select count(r.id) as nr, s.id as signature_id, s.signature as signature_text, s.has_comments from reports r join signature s on r.signature_id = s.id $where group by signature_id order by nr desc";
        $q .= kl_str_sql(" limit !i", 100);
        if (false !== $cached = Memc::getq($q)) return $cached;

        if (!$res = DBH::$db->query($q))
        {
            return $ret;
        }
        
        while ($row = DBH::$db->fetchRow($res))
        {
            $r = new stdClass;
            DBH::$db->loadFromDbRow($r, $res, $row);
            $ret[] = $r;
        }
        
        Memc::setq($q, $ret);
        return $ret;
    }
    
    function getSignature($id)
    {
        $ret = new stdClass;
        $q = kl_str_sql("select * from signature where id=!i", $id);

        if (!$res = DBH::$db->query($q))
        {
            return false;
        }
        
        if ($row = DBH::$db->fetchRow($res))
        {
            DBH::$db->loadFromDbRow($ret, $res, $row);
            return $ret;
        }
        
        return false;
    }
    
    function getGPUStats()
    {
        $ret = array();
        $where = $this->filter->getWhere();
        if ($where)
        {
            $where .= " and ";
        }
        else
        {
            $where = "where ";
        }
        $where .= "gpu is not null";
        $q = "select count(id) as nr, gpu from reports $where group by gpu order by nr desc";
        $q .= kl_str_sql(" limit !i", $this->filter->limit);
        if (false !== $cached = Memc::getq($q)) return $cached;
        
        if (!$res = DBH::$db->query($q)) return $ret;
        
        while ($row = DBH::$db->fetchRow($res))
        {
            $o = new stdClass;
            DBH::$db->loadFromDbRow($o, $res, $row);
            $ret[] = $o;
        }
        
        Memc::setq($q, $ret);
        return $ret;
    }    

    function getOSStats()
    {
        $ret = array();
        $where = $this->filter->getWhere();
        if ($where)
        {
            $where .= " and ";
        }
        else
        {
            $where = "where ";
        }
        $where .= "os_type is not null";
        $q = "select count(id) as nr, os_type from reports $where group by os_type order by nr desc";
        $q .= kl_str_sql(" limit !i", $this->filter->limit);
        if (false !== $cached = Memc::getq($q)) return $cached;
        
        if (!$res = DBH::$db->query($q)) return $ret;
        
        while ($row = DBH::$db->fetchRow($res))
        {
            $o = new stdClass;
            DBH::$db->loadFromDbRow($o, $res, $row);
            $ret[] = $o;
        }
        
        Memc::setq($q, $ret);
        return $ret;
    }    

    function getRegionStats()
    {
        $ret = array();
        $where = $this->filter->getWhere();
        if ($where)
        {
            $where .= " and ";
        }
        else
        {
            $where = "where ";
        }
        $where .= "region is not null and grid is not null";
        $q = "select count(id) as nr, region, grid from reports $where group by region, grid order by nr desc";
        $q .= kl_str_sql(" limit !i", $this->filter->limit);
        if (false !== $cached = Memc::getq($q)) return $cached;
        
        if (!$res = DBH::$db->query($q)) return $ret;
        
        while ($row = DBH::$db->fetchRow($res))
        {
            $o = new stdClass;
            DBH::$db->loadFromDbRow($o, $res, $row);
            $ret[] = $o;
        }
        
        Memc::setq($q, $ret);
        return $ret;
    }
    
    function updateCommentCount($id)
    {
        $q = kl_str_sql("update signature set has_comments=(select count(*) as count from comment where signature_id=!i) where id=!i", $id, $id);
        DBH::$db->query($q);
    }
    
    function addSignatureComment($id, $text)
    {
        global $S;
        $q = kl_str_sql("insert into comment (signature_id, user_id, comment) values (!i, !i, !s)", $id, $S->user_id, $text);
        DBH::$db->query($q);
        self::updateCommentCount($id);
    }
    
    function getSignatureComments($id)
    {
        $ret = array();
        $q = kl_str_sql("select c.*, u.name, u.email from comment c join users u on c.user_id = u.user_id where signature_id=!i order by id asc;", $id);
        if (!$res = DBH::$db->query($q)) return;
        
        while ($row = DBH::$db->fetchRow($res))
        {
            $c = new stdClass;
            DBH::$db->loadFromDbRow($c, $res, $row);
            $ret[] = $c;
        }
        
        return $ret;
    }
    
    function delSignatureComment($id, $del_id)
    {
        $q = kl_str_sql("delete from comment where id=!i", $del_id);
        DBH::$db->query($q);
        self::updateCommentCount($id);
    }
}