Controllers/api/v2/boost/fetch/campaigns.php

+<?php
+/**
+ * Boost & Boost Campaigns fetch
+ * @author: eiennohi.
+ */
+
+namespace Minds\Controllers\api\v2\boost\fetch;
+
+use Minds\Api\Exportable;
+use Minds\Api\Factory;
+use Minds\Common\Urn;
+use Minds\Core\Boost\Campaigns;
+use Minds\Core\Boost\Campaigns\Campaign;
+use Minds\Core\Boost\Network;
+use Minds\Core\Di\Di;
+use Minds\Core\Feeds\FeedSyncEntity;
+use Minds\Core\Session;
+use Minds\Entities;
+use Minds\Interfaces;
+
+class campaigns implements Interfaces\Api
+{
+    public function get($pages)
+    {
+        Factory::isLoggedIn();
+
+        /** @var Entities\User $currentUser */
+        $currentUser = Session::getLoggedinUser();
+
+        if ($currentUser->disabled_boost && $currentUser->isPlus()) {
+            return Factory::response([
+                'boosts' => [],
+            ]);
+        }
+
+        // Parse parameters
+
+        $type = $pages[0] ?? 'newsfeed';
+        $limit = abs(intval($_GET['limit'] ?? 2));
+        $offset = $_GET['offset'] ?? 0;
+        $rating = intval($_GET['rating'] ?? $currentUser->getBoostRating());
+        $platform = $_GET['platform'] ?? 'other';
+        $quality = 0;
+        $sync = (bool) ($_GET['sync'] ?? true);
+
+        if ($limit === 0) {
+            return Factory::response([
+                'boosts' => [],
+            ]);
+        } elseif ($sync && $limit > 500) {
+            $limit = 500;
+        } elseif (!$sync && $limit > 50) {
+            $limit = 50;
+        }
+
+        // Options specific to newly created users (<=1 hour) and iOS users
+
+        if ($platform === 'ios') {
+            $rating = 1; // they can only see safe content
+            $quality = 90;
+        } elseif (time() - $currentUser->getTimeCreated() <= 3600) {
+            $rating = 1; // they can only see safe content
+            $quality = 75;
+        }
+
+        /** @var Campaigns\Manager $manager */
+        $manager = Di::_()->get('Boost\Campaigns\Manager');
+
+        $data = [];
+
+
+        try{
+            $result = $manager->fetch([
+                'limit' => $limit,
+                'from' => $offset,
+                'rating' => $rating,
+                'quality' => $quality,
+                'type' => $type,
+            ]);
+
+            foreach ($result as $entity) {
+                $feedSyncEntity = (new FeedSyncEntity())
+                    ->setGuid((string) $entity->getGuid())
+                    ->setOwnerGuid((string) $entity->getOwnerGuid());
+
+                if ($entity instanceof Campaign) {
+                    $feedSyncEntity->setUrn($entity->getUrn());
+                } elseif ($entity instanceof Network\Boost) {
+                    $feedSyncEntity->setUrn(new Urn("urn:boost:{$entity->getType()}:{$entity->getGuid()}"));
+                }
+
+                $data[] = $feedSyncEntity;
+            }
+        } catch(\Exception $e) {
+            error_log($e);
+        }
+
+        return Factory::response([
+            'boosts' => Exportable::_($data),
+            'load-next' => $data->getPagingToken() ?: null,
+        ]);
+    }
+
+    public function post($pages)
+    {
+        return Factory::response([]);
+    }
+
+    public function put($pages)
+    {
+        return Factory::response([]);
+    }
+
+    public function delete($pages)
+    {
+        return Factory::response([]);
+    }
+
+}

Core/Boost/Campaigns/Campaign.php

@@ -46,6 +46,10 @@ use Minds\Traits\MagicAttributes;
  * @method Campaign setImpressions(int $impressions)
  * @method int getImpressionsMet()
  * @method Campaign setImpressionsMet(int $impressionsMet)
+ * @method int getRating()
+ * @method Campaign setRating(int $value)
+ * @method int getQuality()
+ * @method Campaign setQuality(int $value)
  * @method int getCreatedTimestamp()
  * @method Campaign setCreatedTimestamp(int $createdTimestamp)
  * @method int getReviewedTimestamp()
@@ -124,6 +128,12 @@ class Campaign implements JsonSerializable
     /** @var int */
     protected $impressionsMet;
 
+    /** @var int */
+    protected $rating;
+
+    /** @var int */
+    protected $quality;
+
     /** @var int */
     protected $createdTimestamp;
 

Core/Boost/Campaigns/ElasticRepository.php

@@ -8,6 +8,7 @@ namespace Minds\Core\Boost\Campaigns;
 
 use Exception;
 use Minds\Common\Repository\Response;
+use Minds\Core\Boost\Network\Boost;
 use Minds\Core\Data\ElasticSearch\Client as ElasticSearchClient;
 use Minds\Core\Data\ElasticSearch\Prepared\Search;
 use Minds\Core\Data\ElasticSearch\Prepared\Update;
@@ -48,6 +49,8 @@ class ElasticRepository
             'owner_guid' => null,
             'entity_urn' => null,
             'state' => null,
+            'rating' => null,
+            'quality' => null,
         ], $opts);
 
         $must = [];
@@ -124,6 +127,22 @@ class ElasticRepository
             ];
         }
 
+        if ($opts['rating']) {
+            $must[] = [
+                'term' => [
+                    'rating' => $opts['rating']
+                ]
+            ];
+        }
+
+        if ($opts['quality']) {
+            $must[] = [
+                'term' => [
+                    'rating' => $opts['quality']
+                ]
+            ];
+        }
+
         if ($opts['offset']) {
             $rangeKey = $opts['sort'] === 'asc' ? 'gt' : 'lt';
 
@@ -181,6 +200,8 @@ class ElasticRepository
                 ->setChecksum($doc['_source']['checksum'])
                 ->setImpressions((int) $doc['_source']['impressions'])
                 ->setImpressionsMet($doc['_source']['impressions_met'])
+                ->setRating($doc['_source']['rating'])
+                ->setQuality($doc['_source']['quality'])
                 ->setCreatedTimestamp(((int) $doc['_source']['@timestamp']) ?: null)
                 ->setReviewedTimestamp(((int) $doc['_source']['@reviewed']) ?: null)
                 ->setRejectedTimestamp(((int) $doc['_source']['@rejected']) ?: null)
@@ -196,6 +217,96 @@ class ElasticRepository
         return $response;
     }
 
+    public function fetch(array $opts = [])
+    {
+        $opts = array_merge([
+            'limit' => 24,
+            'from' => 0,
+            'rating' => null,
+            'quality' => null,
+            'type' => null,
+            'sort' => 'asc',
+        ], $opts);
+
+        $must = [];
+
+        if ($opts['offset']) {
+            $rangeKey = $opts['sort'] === 'asc' ? 'gt' : 'lt';
+
+            $must[] = [
+                'range' => [
+                    '@timestamp' => [
+                        $rangeKey => $opts['offset'],
+                    ],
+                ],
+            ];
+        }
+
+
+        $prepared = new Search();
+        $body = [
+            'query' => [
+                'bool' => [
+                    'must' => $must,
+                ]
+            ]
+        ];
+        $prepared->query([
+            'index' => 'minds-boost,minds-boost-campaigns',
+            'type' => '_doc',
+            'body' => $body,
+            'from' => $opts['from'] ?? 0,
+            'size' => $opts['limit'],
+        ]);
+
+        $result = $this->es->request($prepared);
+
+        $next = [];
+
+        $data = [];
+
+        foreach ($result['hits']['hits'] as $doc) {
+            $entity = null;
+
+            switch ($doc['index']) {
+                case 'minds-boost':
+                    $entity = (new Boost())
+                        ->setGuid($doc['_id'])
+                        ->setOwnerGuid($doc['_source']['owner_guid'])
+                        ->setCreatedTimestamp($doc['_source']['@timestamp'])
+                        ->setType($doc['_source']['type']);
+
+                    $next[0] = $entity->getCreatedTimestamp();
+                    break;
+                case 'minds-boost-campaigns':
+                    $entity = (new Campaign())
+                        ->setUrn("urn:campaign:{$doc['_id']}")
+                        ->setType($doc['_source']['type'])
+                        ->setOwnerGuid($doc['_source']['owner_guid'])
+                        ->setCreatedTimestamp(((int) $doc['_source']['@timestamp']) ?: null);
+
+                        $next[1] = $entity->getCreatedTimestamp();
+                    break;
+                default:
+                    continue;
+            }
+
+            $data[] = $entity;
+        }
+
+        uasort($data, function ($a, $b) {
+            $aTime = $a instanceof Campaign ? $a->getCreatedTimestamp() : $a->getTimeCreated();
+            $bTime = $b instanceof Campaign ? $b->getCreatedTimestamp() : $b->getTimeCreated();
+            return $aTime > $bTime;
+        });
+
+        $data = array_slice($data, 0, $opts['limit']);
+
+        $response = new Response($data, count($data));
+
+        return $response;
+    }
+
     /**
      * @param Campaign $campaign
      * @return bool
@@ -226,6 +337,14 @@ class ElasticRepository
             $body['doc']['impressions_met'] = $campaign->getImpressionsMet();
         }
 
+        if ($campaign->getRating()) {
+            $body['doc']['rating'] = $campaign->getRating();
+        }
+
+        if ($campaign->getQuality()) {
+            $body['doc']['quality'] = $campaign->getQuality();
+        }
+
         if ($campaign->getReviewedTimestamp()) {
             $body['doc']['@reviewed'] = $campaign->getReviewedTimestamp();
         }

Core/Boost/Campaigns/Iterator.php

@@ -5,7 +5,6 @@
 
 namespace Minds\Core\Boost\Campaigns;
 
-
 use Minds\Core\Di\Di;
 
 class Iterator implements \Iterator
@@ -20,13 +19,13 @@ class Iterator implements \Iterator
     protected $type = 'newsfeed';
     protected $ownerGuid = null;
     protected $state = null;
+    protected $rating = null;
+    protected $quality = null;
 
     /** @var array */
     protected $list = null;
 
-    public function __construct(
-        $manager = null
-    )
+    public function __construct($manager = null)
     {
         $this->manager = $manager ?: Di::_()->get('Boost\Campaigns\Manager');
     }
@@ -109,23 +108,36 @@ class Iterator implements \Iterator
         return $this;
     }
 
+    /**
+     * @param int $rating
+     * @return Iterator
+     */
+    public function setRating(int $rating)
+    {
+        $this->rating = $rating;
+        return $this;
+    }
 
-    public function getList()
+    /**
+     * @param int $quality
+     * @return Iterator
+     */
+    public function setQuality(int $quality)
     {
-        $response = $this->manager->getList([
-            'limit' => $this->limit,
-            'from' => $this->from,
-            'offset' => $this->offset,
-            'type' => $this->type,
-            'owner_guid' => $this->ownerGuid,
-            'state' => $this->state,
-        ]);
+        $this->quality = $quality;
+        return $this;
+    }
 
+    public function getList()
+    {
+        $response = $this->manager->getList(['limit' => $this->limit, 'from' => $this->from, 'offset' => $this->offset, 'type' => $this->type, 'owner_guid' => $this->ownerGuid, 'state' => $this->state, 'rating' => $this->rating, 'quality' => $this->quality,]);
         $this->offset = $response->getPagingToken();
-
         $this->list = $response;
     }
 
+    /**
+     * @return Campaign
+     */
     public function current()
     {
         return current($this->list);

Core/Boost/Campaigns/Manager.php

@@ -119,6 +119,21 @@ class Manager
         });
     }
 
+    /**
+     * @param array $opts
+     * @return Response|null
+     */
+    public function fetch(array $opts = [])
+    {
+        $response = null;
+        try {
+            $response = $this->elasticRepository->fetch($opts);
+        } catch (Exception $e) {
+            error_log("[BoostCampaignsManager] {$e}");
+        }
+        return $response;
+    }
+
     /**
      * @param $urn
      * @return Campaign|null

Core/Boost/Campaigns/Repository.php

@@ -66,6 +66,8 @@ class Repository
                 'checksum' => $campaign->getChecksum(),
                 'impressions' => $campaign->getImpressions(),
                 'impressions_met' => $campaign->getImpressionsMet(),
+                'rating' => $campaign->getRating(),
+                'quality' => $campaign->getQuality(),
                 'created_timestamp' => $campaign->getCreatedTimestamp(),
                 'reviewed_timestamp' => $campaign->getReviewedTimestamp(),
                 'rejected_timestamp' => $campaign->getRejectedTimestamp(),

Core/Boost/Network/Boost.php

@@ -23,17 +23,23 @@ use Minds\Traits\MagicAttributes;
  * @method long getOwnerGuid()
  * @method Boost setOwner()
  * @method User getOwner()
- * 
- * @method Boost setRejectedReason(int $reason)
+ *
  * @method int getRejectedReason()
+ * @method Boost setRejectedReason(int $reason)
+ * @method int getCompletedTimestamp()
  * @method Boost setCompletedTimestamp(int $ts)
+ * @method int getReviewedTimestamp()
  * @method Boost setReviewedTimestamp(int $ts)
+ * @method int getRejectedTimestamp()
  * @method Boost setRejectedTimestamp(int $ts)
+ * @method int getCreatedTimestamp()
  * @method Boost setCreatedTimestamp(int $ts)
+ * @method int getRevokedTimestamp()
  * @method Boost setRevokedTimestamp(int $ts)
  * @method array getTags()
  * @method Boost setTags(array $value)
  * @method string getType()
+ * @method Boost setType(string $value)
  */
 class Boost
 {