Add user activity system

src/Api/Actions/Activity/IndexAction.php

@@ -0,0 +1,47 @@
+<?php namespace Flarum\Api\Actions\Activity;
+
+use Flarum\Core\Repositories\UserRepositoryInterface;
+use Flarum\Core\Repositories\ActivityRepositoryInterface;
+use Flarum\Core\Support\Actor;
+use Flarum\Api\Actions\BaseAction;
+use Flarum\Api\Actions\ApiParams;
+use Flarum\Api\Serializers\ActivitySerializer;
+
+class IndexAction extends BaseAction
+{
+    /**
+     * Instantiate the action.
+     *
+     * @param  \Flarum\Core\Search\Discussions\UserSearcher  $searcher
+     */
+    public function __construct(Actor $actor, UserRepositoryInterface $users, ActivityRepositoryInterface $activity)
+    {
+        $this->actor = $actor;
+        $this->users = $users;
+        $this->activity = $activity;
+    }
+
+    /**
+     * Show a user's activity feed.
+     *
+     * @return \Illuminate\Http\Response
+     */
+    protected function run(ApiParams $params)
+    {
+        $start = $params->start();
+        $count = $params->count(20, 50);
+        $type  = $params->get('type');
+        $id    = $params->get('users');
+
+        $user = $this->users->findOrFail($id, $this->actor->getUser());
+
+        $activity = $this->activity->findByUser($user->id, $this->actor->getUser(), $count, $start, $type);
+
+        // Finally, we can set up the activity serializer and use it to create
+        // a collection of activity results.
+        $serializer = new ActivitySerializer(['sender', 'post', 'post.discussion', 'post.user', 'post.discussion.startUser', 'post.discussion.lastUser'], ['user']);
+        $document = $this->document()->setPrimaryElement($serializer->collection($activity));
+
+        return $this->respondWithDocument($document);
+    }
+}

src/Api/Actions/Discussions/ShowAction.php

@@ -5,12 +5,12 @@ use Flarum\Core\Repositories\DiscussionRepositoryInterface as DiscussionReposito
 use Flarum\Core\Repositories\PostRepositoryInterface as PostRepository;
 use Flarum\Api\Actions\BaseAction;
 use Flarum\Api\Actions\ApiParams;
-use Flarum\Api\Actions\Posts\GetsPostsForDiscussion;
+use Flarum\Api\Actions\Posts\GetsPosts;
 use Flarum\Api\Serializers\DiscussionSerializer;
 
 class ShowAction extends BaseAction
 {
-    use GetsPostsForDiscussion;
+    use GetsPosts;
 
     /**
      * The discussion repository.
@@ -51,7 +51,7 @@ class ShowAction extends BaseAction
 
         if (in_array('posts', $include)) {
             $relations = ['user', 'user.groups', 'editUser', 'hideUser'];
-            $discussion->posts = $this->getPostsForDiscussion($params, $discussion->id)->load($relations);
+            $discussion->posts = $this->getPosts($params, ['discussion_id' => $discussion->id])->load($relations);
 
             $include = array_merge($include, array_map(function ($relation) {
                 return 'posts.'.$relation;

src/Api/Actions/Posts/GetsPosts.php

@@ -3,23 +3,23 @@
 use Flarum\Core\Models\User;
 use Flarum\Api\Actions\ApiParams;
 
-trait GetsPostsForDiscussion
+trait GetsPosts
 {
-	protected function getPostsForDiscussion(ApiParams $params, $discussionId)
+	protected function getPosts(ApiParams $params, $where)
 	{
 		$sort = $params->sort(['time']);
         $count = $params->count(20, 50);
         $user = $this->actor->getUser();
 
-        if (($near = $params->get('near')) > 1) {
-            $start = $this->posts->getIndexForNumber($discussionId, $near, $user);
+        if (isset($where['discussion_id']) && ($near = $params->get('near')) > 1) {
+            $start = $this->posts->getIndexForNumber($where['discussion_id'], $near, $user);
             $start = max(0, $start - $count / 2);
         } else {
             $start = 0;
         }
 
-        return $this->posts->findByDiscussion(
-            $discussionId,
+        return $this->posts->findWhere(
+            $where,
             $user,
             $sort['field'],
             $sort['order'] ?: 'asc',

src/Api/Actions/Posts/IndexAction.php

@@ -9,7 +9,7 @@ use Flarum\Api\Serializers\PostSerializer;
 
 class IndexAction extends BaseAction
 {
-    use GetsPostsForDiscussion;
+    use GetsPosts;
 
     /**
      * The post repository.
@@ -37,14 +37,19 @@ class IndexAction extends BaseAction
     protected function run(ApiParams $params)
     {
         $postIds = (array) $params->get('ids');
-        $include = ['user', 'user.groups', 'editUser', 'hideUser'];
+        $include = ['user', 'user.groups', 'editUser', 'hideUser', 'discussion'];
         $user = $this->actor->getUser();
 
         if (count($postIds)) {
             $posts = $this->posts->findByIds($postIds, $user);
         } else {
-            $discussionId = $params->get('discussions');
-            $posts = $this->getPostsForDiscussion($params, $discussionId, $user);
+            if ($discussionId = $params->get('discussions')) {
+                $where['discussion_id'] = $discussionId;
+            }
+            if ($userId = $params->get('users')) {
+                $where['user_id'] = $userId;
+            }
+            $posts = $this->getPosts($params, $where, $user);
         }
 
         if (! count($posts)) {

src/Api/Serializers/ActivitySerializer.php

@@ -1,19 +1,65 @@
 <?php namespace Flarum\Api\Serializers;
 
 use Flarum\Core\Models\Activity;
-use Event;
 
-class ActivitySerializer extends BaseSerializer {
-	
-	public function serialize(Activity $activity)
-	{
-		$serialized = [
-			'id' => (int) $activity->id
-		];
+class ActivitySerializer extends BaseSerializer
+{
+    /**
+     * The resource type.
+     * @var string
+     */
+    protected $type = 'activity';
 
-		Event::fire('flarum.api.serialize.activity', [&$serialized]);
+    /**
+     * Serialize attributes of an Activity model for JSON output.
+     *
+     * @param Activity $activity The Activity model to serialize.
+     * @return array
+     */
+    protected function attributes(Activity $activity)
+    {
+        $attributes = [
+            'id'   => ((int) $activity->id) ?: str_random(5),
+            'type' => $activity->type,
+            'content' => json_encode($activity->data),
+            'time' => $activity->time->toRFC3339String()
+        ];
 
-		return $serialized;
-	}
+        return $this->attributesEvent($activity, $attributes);
+    }
 
+    /**
+     * Get a resource containing an activity's sender.
+     *
+     * @param Activity $activity
+     * @return Tobscure\JsonApi\Resource
+     */
+    public function linkUser(Activity $activity)
+    {
+        return (new UserBasicSerializer)->resource($activity->user_id);
+    }
+
+    /**
+     * Get a resource containing an activity's sender.
+     *
+     * @param Activity $activity
+     * @param array $relations
+     * @return Tobscure\JsonApi\Resource
+     */
+    public function includeSender(Activity $activity, $relations)
+    {
+        return (new UserBasicSerializer($relations))->resource($activity->sender);
+    }
+
+    /**
+     * Get a resource containing an activity's sender.
+     *
+     * @param Activity $activity
+     * @param array $relations
+     * @return Tobscure\JsonApi\Resource
+     */
+    public function includePost(Activity $activity, $relations)
+    {
+        return (new PostSerializer($relations))->resource($activity->post);
+    }
 }

src/Api/Serializers/PostSerializer.php

@@ -79,7 +79,7 @@ class PostSerializer extends PostBasicSerializer
      */
     public function includeDiscussion(Post $post, $relations = [])
     {
-        return (new DiscussionBasicSerializer($relations))->resource($post->discussion);
+        return (new DiscussionSerializer($relations))->resource($post->discussion);
     }
 
     /**