123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463 |
- <?php
- class Fave extends Managed_DataObject
- {
- public $__table = 'fave';
- public $notice_id;
- public $user_id;
- public $uri;
- public $created;
- public $modified;
- public static function schemaDef()
- {
- return array(
- 'fields' => array(
- 'notice_id' => array('type' => 'int', 'not null' => true, 'description' => 'notice that is the favorite'),
- 'user_id' => array('type' => 'int', 'not null' => true, 'description' => 'user who likes this notice'),
- 'uri' => array('type' => 'varchar', 'length' => 191, 'description' => 'universally unique identifier, usually a tag URI'),
- 'created' => array('type' => 'datetime', 'not null' => true, 'description' => 'date this record was created'),
- 'modified' => array('type' => 'timestamp', 'not null' => true, 'description' => 'date this record was modified'),
- ),
- 'primary key' => array('notice_id', 'user_id'),
- 'unique keys' => array(
- 'fave_uri_key' => array('uri'),
- ),
- 'foreign keys' => array(
- 'fave_notice_id_fkey' => array('notice', array('notice_id' => 'id')),
- 'fave_user_id_fkey' => array('profile', array('user_id' => 'id')),
- ),
- 'indexes' => array(
- 'fave_notice_id_idx' => array('notice_id'),
- 'fave_user_id_idx' => array('user_id', 'modified'),
- 'fave_modified_idx' => array('modified'),
- ),
- );
- }
-
- static function addNew(Profile $actor, Notice $target) {
- if (self::existsForProfile($target, $actor)) {
-
- throw new AlreadyFulfilledException(_('You have already favorited this!'));
- }
- $act = new Activity();
- $act->type = ActivityObject::ACTIVITY;
- $act->verb = ActivityVerb::FAVORITE;
- $act->time = time();
- $act->id = self::newUri($actor, $target, common_sql_date($act->time));
- $act->title = _("Favor");
-
-
- $act->content = sprintf(_('%1$s favorited something by %2$s: %3$s'),
- $actor->getNickname(), $target->getProfile()->getNickname(),
- $target->getRendered());
- $act->actor = $actor->asActivityObject();
- $act->target = $target->asActivityObject();
- $act->objects = array(clone($act->target));
- $url = common_local_url('AtomPubShowFavorite', array('profile'=>$actor->id, 'notice'=>$target->id));
- $act->selfLink = $url;
- $act->editLink = $url;
-
-
- $stored = Notice::saveActivity($act, $actor);
- return $stored;
- }
- static function removeEntry(Profile $actor, Notice $target)
- {
- $fave = new Fave();
- $fave->user_id = $actor->getID();
- $fave->notice_id = $target->getID();
- if (!$fave->find(true)) {
-
- throw new AlreadyFulfilledException(_('This is already not favorited.'));
- }
- $result = $fave->delete();
- if ($result === false) {
- common_log_db_error($fave, 'DELETE', __FILE__);
-
- throw new ServerException(_('Could not delete favorite.'));
- }
- Fave::blowCacheForProfileId($actor->getID());
- Fave::blowCacheForNoticeId($target->getID());
- }
-
- public function insert()
- {
- if (parent::insert()===false) {
- common_log_db_error($this, 'INSERT', __FILE__);
- throw new ServerException(sprintf(_m('Could not store new object of type %s'), get_called_class()));
- }
- self::blowCacheForProfileId($this->user_id);
- self::blowCacheForNoticeId($this->notice_id);
- return $this;
- }
- public function delete($useWhere=false)
- {
- $result = null;
- try {
- $profile = $this->getActor();
- $notice = $this->getTarget();
- if (Event::handle('StartDisfavorNotice', array($profile, $notice, &$result))) {
- $result = parent::delete($useWhere);
- if ($result !== false) {
- Event::handle('EndDisfavorNotice', array($profile, $notice));
- }
- }
- } catch (NoResultException $e) {
-
- common_log(LOG_INFO, '"'.get_class($e->obj).'" with id=='.var_export($e->obj->id, true).' object not found when deleting favorite, ignoring...');
- } catch (EmptyPkeyValueException $e) {
-
- common_log(LOG_INFO, _ve($e->getMessage()));
- }
-
- if (is_null($result)) {
-
- $result = parent::delete($useWhere);
- }
-
-
- self::blowCacheForProfileId($this->user_id);
- self::blowCacheForNoticeId($this->notice_id);
- self::blow('popular');
- return $result;
- }
-
-
- static function stream($user_id, $offset=0, $limit=NOTICES_PER_PAGE, $own=false, $since_id=0, $max_id=0)
- {
- $target = Profile::getByID($user_id);
- $stream = new FaveNoticeStream($target, ($own ? $target : null));
- return $stream->getNotices($offset, $limit, $since_id, $max_id);
- }
-
-
- function idStream($user_id, $offset=0, $limit=NOTICES_PER_PAGE, $own=false, $since_id=0, $max_id=0)
- {
- $target = Profile::getByID($user_id);
- $stream = new FaveNoticeStream($target, ($own ? $target : null));
- return $stream->getNoticeIds($offset, $limit, $since_id, $max_id);
- }
- function asActivity()
- {
- $target = $this->getTarget();
- $actor = $this->getActor();
- $act = new Activity();
- $act->verb = ActivityVerb::FAVORITE;
-
- $act->id = $this->getUri();
- $act->time = strtotime($this->created);
-
- $act->title = _("Favor");
-
-
- $act->content = sprintf(_('%1$s favorited something by %2$s: %3$s'),
- $actor->getNickname(), $target->getProfile()->getNickname(),
- $target->getRendered());
- $act->context = new ActivityContext();
- $act->context->replyToID = $target->getUri();
- try {
- $act->context->replyToURL = $target->getUrl();
- } catch (InvalidUrlException $e) {
-
- }
- $act->actor = $actor->asActivityObject();
- $act->target = $target->asActivityObject();
- $act->objects = array(clone($act->target));
- $url = common_local_url('AtomPubShowFavorite',
- array('profile' => $actor->id,
- 'notice' => $target->id));
- $act->selfLink = $url;
- $act->editLink = $url;
- return $act;
- }
- static function existsForProfile($notice, Profile $scoped)
- {
- $fave = self::pkeyGet(array('user_id'=>$scoped->id, 'notice_id'=>$notice->id));
- return ($fave instanceof Fave);
- }
-
- static function byProfile($profileId, $offset, $limit)
- {
- $fav = new Fave();
- $fav->user_id = $profileId;
- $fav->orderBy('modified DESC');
- $fav->limit($offset, $limit);
- $fav->find();
- return $fav;
- }
- static function countByProfile(Profile $profile)
- {
- $c = Cache::instance();
- if (!empty($c)) {
- $cnt = $c->get(Cache::key('fave:count_by_profile:'.$profile->id));
- if (is_integer($cnt)) {
- return $cnt;
- }
- }
- $faves = new Fave();
- $faves->user_id = $profile->id;
- $cnt = (int) $faves->count('notice_id');
- if (!empty($c)) {
- $c->set(Cache::key('fave:count_by_profile:'.$profile->id), $cnt);
- }
- return $cnt;
- }
- static protected $_faves = array();
-
- static public function byNotice($notice)
- {
- if (!isset(self::$_faves[$notice->id])) {
- self::fillFaves(array($notice->id));
- }
- return self::$_faves[$notice->id];
- }
- static public function fillFaves(array $notice_ids)
- {
- $faveMap = Fave::listGet('notice_id', $notice_ids);
- self::$_faves = array_replace(self::$_faves, $faveMap);
- }
- static public function blowCacheForProfileId($profile_id)
- {
- $cache = Cache::instance();
- if ($cache) {
-
-
- $cache->delete(Cache::key('fave:ids_by_user:'.$profile_id));
- $cache->delete(Cache::key('fave:ids_by_user:'.$profile_id.';last'));
- $cache->delete(Cache::key('fave:ids_by_user_own:'.$profile_id));
- $cache->delete(Cache::key('fave:ids_by_user_own:'.$profile_id.';last'));
- $cache->delete(Cache::key('fave:count_by_profile:'.$profile_id));
- }
- }
- static public function blowCacheForNoticeId($notice_id)
- {
- $cache = Cache::instance();
- if ($cache) {
- $cache->delete(Cache::key('fave:list-ids:notice_id:'.$notice_id));
- }
- }
-
-
- static public function fromStored(Notice $stored)
- {
- $class = get_called_class();
- $object = new $class;
- $object->uri = $stored->uri;
- if (!$object->find(true)) {
- throw new NoResultException($object);
- }
- return $object;
- }
-
- static public function getTargetFromStored(Notice $stored)
- {
- return self::fromStored($stored)->getTarget();
- }
- static public function getObjectType()
- {
- return ActivityObject::ACTIVITY;
- }
- public function asActivityObject(Profile $scoped=null)
- {
- $actobj = new ActivityObject();
- $actobj->id = $this->getUri();
- $actobj->type = ActivityUtils::resolveUri(self::getObjectType());
- $actobj->actor = $this->getActorObject();
- $actobj->target = $this->getTargetObject();
- $actobj->objects = array(clone($actobj->target));
- $actobj->verb = ActivityVerb::FAVORITE;
- $actobj->title = ActivityUtils::verbToTitle($actobj->verb);
- $actobj->content = $this->getTarget()->getRendered();
- return $actobj;
- }
-
- static public function parseActivityObject(ActivityObject $actobj, Notice $stored)
- {
-
-
- $local = ActivityUtils::findLocalObject($actobj->getIdentifiers());
- if (!$local instanceof Notice) {
-
- throw new Exception('Something other than a Notice was returned from findLocalObject');
- }
-
- $actor = $stored->getProfile();
- $object = new Fave();
- $object->user_id = $stored->getProfile()->id;
- $object->notice_id = $local->id;
- $object->uri = $stored->uri;
- $object->created = $stored->created;
- $object->modified = $stored->modified;
- return $object;
- }
- static public function extendActivity(Notice $stored, Activity $act, Profile $scoped=null)
- {
- $target = self::getTargetFromStored($stored);
-
- if (ActivityUtils::compareVerbs($target->verb, array(ActivityVerb::POST))) {
-
- $act->objects = $target->asActivity()->objects;
- } else {
-
- $act->target = $target->asActivityObject();
- $act->objects = array(clone($act->target));
- }
- $act->context->replyToID = $target->getUri();
- $act->context->replyToUrl = $target->getUrl();
- $act->title = ActivityUtils::verbToTitle($act->verb);
- }
- static function saveActivityObject(ActivityObject $actobj, Notice $stored)
- {
- $object = self::parseActivityObject($actobj, $stored);
- $object->insert();
- self::blowCacheForProfileId($object->user_id);
- self::blowCacheForNoticeId($object->notice_id);
- self::blow('popular');
- Event::handle('EndFavorNotice', array($stored->getProfile(), $object->getTarget()));
- return $object;
- }
- public function getTarget()
- {
- return Notice::getByID($this->notice_id);
- }
- public function getTargetObject()
- {
- return $this->getTarget()->asActivityObject();
- }
- protected $_stored = array();
- public function getStored()
- {
- if (!isset($this->_stored[$this->uri])) {
- $stored = new Notice();
- $stored->uri = $this->uri;
- if (!$stored->find(true)) {
- throw new NoResultException($stored);
- }
- $this->_stored[$this->uri] = $stored;
- }
- return $this->_stored[$this->uri];
- }
- public function getActor()
- {
- return Profile::getByID($this->user_id);
- }
- public function getActorObject()
- {
- return $this->getActor()->asActivityObject();
- }
- public function getUri()
- {
- if (!empty($this->uri)) {
- return $this->uri;
- }
-
- return self::newUri($this->getActor(), $this->getTarget(), $this->created);
- }
- }
|