Controllers/api/v2/boost.php

@@ -290,13 +290,20 @@ class boost implements Interfaces\Api
                         ->setType(lcfirst($pages[0]))
                         ->setPriority(false);
 
-                if ($manager->checkExisting($boost)) {
-                    return Factory::response([
-                        'status' => 'error',
-                        'message' => "There's already an ongoing boost for this entity"
-                    ]);
-                }
-
+                    if ($manager->checkExisting($boost)) {
+                        return Factory::response([
+                            'status' => 'error',
+                            'message' => "There's already an ongoing boost for this entity"
+                        ]);
+                    }
+                  
+                    if ($manager->boostLimitReached($boost)) {
+                        return Factory::response([
+                            'status' => 'error',
+                            'message' => "Maximum of 10 offchain tokens per day exceeded."
+                        ]);
+                    }   
+                    
                     // Pre-set GUID
 
                     if ($bidType == 'tokens' && isset($_POST['guid'])) {

Core/Boost/Network/ElasticRepository.php

@@ -22,6 +22,7 @@ class ElasticRepository
     /**
      * Return a list of boosts
      * @param array $opts
+     * @param array $order - optional - null, asc, desc.
      * @return Response
      */
     public function getList($opts = [])
@@ -30,11 +31,13 @@ class ElasticRepository
             'rating' => 3,
             'token' => 0,
             'offset' => null,
+            'order' => null,
+            'offchain' => null
         ], $opts);
-        
+
         $must = [];
         $must_not = [];
-        $sort = [ '@timestamp' => 'asc' ];
+        $sort = [ '@timestamp' => $opts['order'] ?? 'asc' ];
 
         $must[] = [
             'term' => [
@@ -66,6 +69,14 @@ class ElasticRepository
             ];
         }
 
+        if ($opts['owner_guid']) {
+            $must[] = [
+                'term' => [
+                    'owner_guid' => $opts['owner_guid']
+                ]
+            ];
+        }
+
         if ($opts['state'] === 'approved') {
             $must[] = [
                 'exists' => [
@@ -81,6 +92,14 @@ class ElasticRepository
             ];
         }
 
+        if ($opts['offchain']) {
+            $must[] = [
+                "term" => [
+                    "token_method" => "offchain"
+                ]
+            ];
+        }
+
         if ($opts['state'] === 'review') {
             $must_not[] = [
                 'exists' => [

Core/Boost/Network/Manager.php

@@ -157,4 +157,36 @@ class Manager
 
         return $existingBoost->count() > 0;
     }
+    /**
+     * True if the boost is invalid due to the offchain boost limit being reached
+     *
+     * @param Boost $type the Boost object.
+     * @return boolean true if the boost limit has been reached.
+     */
+    public function boostLimitReached($boost) {
+        $offchain = $this->getOffchainBoosts($boost);
+        $offlineToday = array_filter($offchain->toArray(), function($result) {
+            return $result->getCreatedTimestamp() > time() - (60*60*24);
+        });
+        return count($offlineToday) >= 10;
+    }
+    /**
+     * Gets the users last offchain boosts, from the most recent boost backwards in time.
+     *
+     * @param string $type the type of the boost
+     * @param integer $limit default to 10.
+     * @return $existingBoosts
+     */
+    public function getOffchainBoosts($boost, $limit = 10) {
+        $existingBoosts = $this->getList([
+            'useElastic' => true,
+            'state' => 'review',
+            'type' => $boost->getType(),
+            'limit' => $limit,
+            'order' => 'desc',
+            'offchain' => true,
+            'owner_guid' => $boost->getOwnerGuid(),
+        ]);
+        return $existingBoosts;
+    }
 }

Spec/Core/Boost/Network/ElasticRepositorySpec.php

@@ -65,5 +65,5 @@ class ElasticRepositorySpec extends ObjectBehavior
         $this->add($boost)
             ->shouldReturn(true);
     }
-
+    
 }

Spec/Core/Boost/Network/ManagerSpec.php

@@ -272,12 +272,12 @@ class ManagerSpec extends ObjectBehavior
     function it_should_check_if_the_entity_was_already_boosted(Boost $boost)
     {
         $this->elasticRepository->getList([
-            'useElastic' => true,
-            'state' => 'review',
-            'type' => 'newsfeed',
-            'entity_guid' => '123',
-            'limit' => 1,
-            'hydrate' => true,
+            "hydrate" => true, 
+            "useElastic" => true, 
+            "state" => "review", 
+            "type" => "newsfeed", 
+            "entity_guid" => "123", 
+            "limit" => 1
         ])
             ->shouldBeCalled()
             ->willReturn(new Response([$boost], ''));
@@ -296,4 +296,79 @@ class ManagerSpec extends ObjectBehavior
 
         $this->checkExisting($boost)->shouldReturn(true);
     }
+
+    function it_should_request_offchain_boosts(Boost $boost)
+    {       
+        $this->elasticRepository->getList(["hydrate" => true, "useElastic" => true, "state" => "review", "type" => "newsfeed", "limit" => 10, "order" => "desc", "offchain" => true, "owner_guid" => "123"])
+            ->shouldBeCalled()
+            ->willReturn(new Response([$boost], ''));
+
+        $this->repository->getList(Argument::any())
+            ->shouldBeCalled()
+            ->willReturn(new Response([$boost]));
+
+        $boost->getType()
+            ->shouldBeCalled()
+            ->willReturn('newsfeed');
+
+        $boost->getOwnerGuid()
+            ->shouldBeCalled()
+            ->willReturn('123');
+
+        $this->getOffchainBoosts($boost)->shouldHaveType('Minds\Common\Repository\Response');
+    }
+
+    function it_should_recognise_a_user_has_reached_the_offchain_boost_limit(Boost $boost)
+    {  
+        $boostArray = [];
+        for ($i = 1; $i <= 10; $i++) {
+            $newBoost = new Boost();
+            $newBoost->setCreatedTimestamp('9999999999999999');
+            array_push($boostArray, $newBoost);
+        }
+        $this->elasticRepository->getList(["hydrate" => true, "useElastic" => true, "state" => "review", "type" => "newsfeed", "limit" => 10, "order" => "desc", "offchain" => true, "owner_guid" => "123"])
+            ->shouldBeCalled()
+            ->willReturn(new Response($boostArray, ''));
+            
+        $this->repository->getList(Argument::any())
+            ->shouldBeCalled()
+            ->willReturn(new Response($boostArray));
+
+        $boost->getType()
+            ->shouldBeCalled()
+            ->willReturn('newsfeed');
+
+        $boost->getOwnerGuid()
+            ->shouldBeCalled()
+            ->willReturn('123');
+
+        $this->boostLimitReached($boost)->shouldReturn(true);
+    }
+
+    function it_should_recognise_a_user_has_NOT_reached_the_offchain_boost_limit(Boost $boost)
+    {  
+        $boostArray = [];
+        for ($i = 1; $i <= 9; $i++) {
+            $newBoost = new Boost();
+            $newBoost->setCreatedTimestamp('9999999999999999');
+            array_push($boostArray, $newBoost);
+        }
+        $this->elasticRepository->getList(["hydrate" => true, "useElastic" => true, "state" => "review", "type" => "newsfeed", "limit" => 10, "order" => "desc", "offchain" => true, "owner_guid" => "123"])
+            ->shouldBeCalled()
+            ->willReturn(new Response($boostArray, ''));
+            
+        $this->repository->getList(Argument::any())
+            ->shouldBeCalled()
+            ->willReturn(new Response($boostArray));
+
+        $boost->getType()
+            ->shouldBeCalled()
+            ->willReturn('newsfeed');
+
+        $boost->getOwnerGuid()
+            ->shouldBeCalled()
+            ->willReturn('123');
+
+        $this->boostLimitReached($boost)->shouldReturn(false);
+    }
 }