db->transStart(); $this->insert([ 'actor_id' => $actor->id, 'post_id' => $post->id, ]); model('PostModel') ->where('id', service('uuid') ->fromString($post->id) ->getBytes()) ->increment('favourites_count'); if ($registerActivity) { $likeActivity = new LikeActivity(); $likeActivity->set('actor', $actor->uri) ->set('object', $post->uri); $activityId = model('ActivityModel') ->newActivity( 'Like', $actor->id, null, $post->id, $likeActivity->toJSON(), $post->published_at, 'queued', ); $likeActivity->set('id', url_to('activity', $actor->username, $activityId)); model('ActivityModel') ->update($activityId, [ 'payload' => $likeActivity->toJSON(), ]); } Events::trigger('on_post_favourite', $actor, $post); model('PostModel') ->clearCache($post); $this->db->transComplete(); } public function removeFavourite(Actor $actor, Post $post, bool $registerActivity = true): void { $this->db->transStart(); model('PostModel') ->where('id', service('uuid') ->fromString($post->id) ->getBytes()) ->decrement('favourites_count'); $this->where([ 'actor_id' => $actor->id, 'post_id' => service('uuid') ->fromString($post->id) ->getBytes(), ]) ->delete(); if ($registerActivity) { $undoActivity = new UndoActivity(); // get like activity $activity = model('ActivityModel') ->where([ 'type' => 'Like', 'actor_id' => $actor->id, 'post_id' => service('uuid') ->fromString($post->id) ->getBytes(), ]) ->first(); $likeActivity = new LikeActivity(); $likeActivity ->set('id', url_to('activity', $actor->username, $activity->id)) ->set('actor', $actor->uri) ->set('object', $post->uri); $undoActivity ->set('actor', $actor->uri) ->set('object', $likeActivity); $activityId = model('ActivityModel') ->newActivity( 'Undo', $actor->id, null, $post->id, $undoActivity->toJSON(), $post->published_at, 'queued', ); $undoActivity->set('id', url_to('activity', $actor->username, $activityId)); model('ActivityModel') ->update($activityId, [ 'payload' => $undoActivity->toJSON(), ]); } Events::trigger('on_post_undo_favourite', $actor, $post); model('PostModel') ->clearCache($post); $this->db->transComplete(); } /** * Adds or removes favourite from database */ public function toggleFavourite(Actor $actor, Post $post): void { if ( $this->where([ 'actor_id' => $actor->id, 'post_id' => service('uuid') ->fromString($post->id) ->getBytes(), ])->first() ) { $this->removeFavourite($actor, $post); } else { $this->addFavourite($actor, $post); } } }