<?php
/**
 * Table Definition for reply
 */
require_once INSTALLDIR.'/classes/Memcached_DataObject.php';

class Reply extends Memcached_DataObject
{
    ###START_AUTOCODE
    /* the code below is auto generated do not remove the above tag */

    public $__table = 'reply';                           // table name
    public $notice_id;                       // int(4)  primary_key not_null
    public $profile_id;                      // int(4)  primary_key not_null
    public $modified;                        // timestamp()   not_null default_CURRENT_TIMESTAMP
    public $replied_id;                      // int(4)

    /* Static get */
    function staticGet($k,$v=null)
    { return Memcached_DataObject::staticGet('Reply',$k,$v); }

    /* the code above is auto generated do not remove the tag below */
    ###END_AUTOCODE

    function stream($user_id, $offset=0, $limit=NOTICES_PER_PAGE, $since_id=0, $before_id=0, $since=null)
    {
        $ids = Notice::stream(array('Reply', '_streamDirect'),
                              array($user_id),
                              'reply:stream:' . $user_id,
                              $offset, $limit, $since_id, $before_id, $since);
        return $ids;
    }

    function _streamDirect($user_id, $offset=0, $limit=NOTICES_PER_PAGE, $since_id=0, $before_id=0, $since=null)
    {
        $reply = new Reply();
        $reply->profile_id = $user_id;

        if ($since_id != 0) {
            $reply->whereAdd('notice_id > ' . $since_id);
        }

        if ($before_id != 0) {
            $reply->whereAdd('notice_id < ' . $before_id);
        }

        if (!is_null($since)) {
            $reply->whereAdd('modified > \'' . date('Y-m-d H:i:s', $since) . '\'');
        }

        $reply->orderBy('notice_id DESC');

        if (!is_null($offset)) {
            $reply->limit($offset, $limit);
        }

        $ids = array();

        if ($reply->find()) {
            while ($reply->fetch()) {
                $ids[] = $reply->notice_id;
            }
        }

        return $ids;
    }
}