Brian Hatchet · @brianhatchet · 3cecc956 · Brian Hatchet · Brian Hatchet
--- a/Controllers/api/v2/admin/firehose.php
+++ b/Controllers/api/v2/admin/firehose.php
+ 
+ return Factory::response([ 
+ 'status' => 'success', 
+ 'entities' => Exportable::_($activities), 
+ ]); 
+ } 
+ 
+ public function post($pages) 
+ { 
+ if (!is_numeric($pages[0])) { 
+ header('X-Minds-Exception: activity guid required'); 
+ http_response_code(400); 
+ return Factory::response([]); 
+ } 
+  
+ $activity = new Activity($pages[0]); 
--- a/Controllers/api/v2/admin/firehose.php
+++ b/Controllers/api/v2/admin/firehose.php
+use Minds\Entities\Activity; 
+ 
+class firehose implements Interfaces\Api, Interfaces\ApiAdminPam 
+{ 
+ /** 
+ * Gets a list of entities sorted for admin approval. 
+ * 
+ * @param array $pages 
+ * 
+ * @throws \Exception 
+ */ 
+ public function get($pages) 
+ { 
+ /** @var Core\Feeds\Firehose\Manager $manager */ 
+ $manager = Di::_()->get('Feeds\Firehose\Manager'); 
+ $activities = $manager->getList(Session::getLoggedinUser()); 
--- a/Core/Feeds/Firehose/Manager.php
+++ b/Core/Feeds/Firehose/Manager.php
+ Repository $repository = null, 
+ EntitiesBuilder $entitiesBuilder = null, 
+ UserReportManager $reportManager = null 
+ ) { 
+ $this->repository = $repository ?: new Repository(); 
+ $this->entitiesBuilder = $entitiesBuilder ?: new EntitiesBuilder(); 
+ $this->reportManager = $reportManager ?: Di::_()->get('Moderation\Reports\Manager'); 
+ } 
+ 
+ /** 
+ * @param User $user the user who own the cached keys. No user, no caching 
+ * @param array $opts filtering options 
+ * 
+ * @return array entities that don't contain moderator_guids 
+ */ 
+ public function getList(User $user = null, array $opts = []) 
--- a/Core/Feeds/Firehose/Repository.php
+++ b/Core/Feeds/Firehose/Repository.php
+ Config $config = null, 
+ ModerationCache $cache = null) 
+ { 
+ $this->client = $client ?: Di::_()->get('Database\ElasticSearch'); 
+ $this->config = $config ?: Di::_()->get('Config'); 
+ $this->cache = $cache ?: new ModerationCache(); 
+ $this->index = $this->config->get('elasticsearch')['index']; 
+ } 
+ 
+ /** 
+ * @param User $user the user who own the cached keys. No user, no caching 
+ * @param array $opts filtering options 
+ * 
+ * @return Response $reponse Response object containing activity guids 
+ */ 
+ public function getList(User $user = null, array $opts = []) 
--- a/Core/Search/Mappings/ActivityMapping.php
+++ b/Core/Search/Mappings/ActivityMapping.php
 public function __construct() 
 { 
 $this->mappings = array_merge($this->mappings, [ 
- 'rating' => [ 'type' => 'integer', '$exportField' => 'rating' ], 
- 'custom_type' => [ 'type' => 'text', '$exportField' => 'custom_type' ], 
- 'entity_guid' => [ 'type' => 'text', '$exportField' => 'entity_guid' ], 
+ 'rating' => ['type' => 'integer', '$exportField' => 'rating'], 
+ 'custom_type' => ['type' => 'text', '$exportField' => 'custom_type'], 
--- a/Entities/Activity.php
+++ b/Entities/Activity.php
 return $this->ownerObj; 
 } 
 
+ public function setModeratorGuid($moderatorGuid) { 
+ $this->moderator_guid = $moderatorGuid; 
+ } 
--- a/Entities/Activity.php
+++ b/Entities/Activity.php
 return $this->ownerObj; 
 } 
 
+ public function setModeratorGuid($moderatorGuid) {