user_id = $profile->id; $fave->notice_id = $notice->id; if (!$fave->insert()) { common_log_db_error($fave, 'INSERT', __FILE__); return false; } Event::handle('EndFavorNotice', array($profile, $notice)); } return $fave; } function delete() { $profile = Profile::staticGet('id', $this->user_id); $notice = Notice::staticGet('id', $this->notice_id); $result = null; if (Event::handle('StartDisfavorNotice', array($profile, $notice, &$result))) { $result = parent::delete(); if ($result) { Event::handle('EndDisfavorNotice', array($profile, $notice)); } } return $result; } function pkeyGet($kv) { return Memcached_DataObject::pkeyGet('Fave', $kv); } function stream($user_id, $offset=0, $limit=NOTICES_PER_PAGE, $own=false, $since_id=0, $max_id=0) { $ids = Notice::stream(array('Fave', '_streamDirect'), array($user_id, $own), ($own) ? 'fave:ids_by_user_own:'.$user_id : 'fave:ids_by_user:'.$user_id, $offset, $limit, $since_id, $max_id); return $ids; } function _streamDirect($user_id, $own, $offset, $limit, $since_id, $max_id) { $fav = new Fave(); $qry = null; if ($own) { $qry = 'SELECT fave.* FROM fave '; $qry .= 'WHERE fave.user_id = ' . $user_id . ' '; } else { $qry = 'SELECT fave.* FROM fave '; $qry .= 'INNER JOIN notice ON fave.notice_id = notice.id '; $qry .= 'WHERE fave.user_id = ' . $user_id . ' '; $qry .= 'AND notice.is_local != ' . Notice::GATEWAY . ' '; } if ($since_id != 0) { $qry .= 'AND notice_id > ' . $since_id . ' '; } if ($max_id != 0) { $qry .= 'AND notice_id <= ' . $max_id . ' '; } // NOTE: we sort by fave time, not by notice time! $qry .= 'ORDER BY modified DESC '; if (!is_null($offset)) { $qry .= "LIMIT $limit OFFSET $offset"; } $fav->query($qry); $ids = array(); while ($fav->fetch()) { $ids[] = $fav->notice_id; } $fav->free(); unset($fav); return $ids; } function asActivity() { $notice = Notice::staticGet('id', $this->notice_id); $profile = Profile::staticGet('id', $this->user_id); $act = new Activity(); $act->verb = ActivityVerb::FAVORITE; $act->id = TagURI::mint('favor:%d:%d:%s', $profile->id, $notice->id, common_date_iso8601($this->created)); $act->time = $this->created; $act->title = _("Favor"); $act->content = sprintf(_("%s marked notice %s as a favorite."), $profile->getBestName(), $notice->uri); $act->actor = ActivityObject::fromProfile($profile); $act->object = ActivityObject::fromNotice($notice); return $act; } }