Core/Boost/Exceptions/EntityAlreadyBoostedException.php

+<?php
+
+namespace Minds\Core\Boost\Exceptions;
+
+use Throwable;
+
+class EntityAlreadyBoostedException extends \Exception
+{
+    public function __construct($code = 0, Throwable $previous = null)
+    {
+        parent::__construct("There's already an ongoing boost for this entity", $code, $previous);
+    }
+}

Core/Boost/Network/Boost.php

@@ -11,6 +11,7 @@ use Minds\Traits\MagicAttributes;
  * @package Minds\Core\Boost\Network
  * @method Boost setGuid(long $guid)
  * @method long getGuid()
+ * @method string getEntityGuid()
  * @method Boost setEntiyGuid()
  * @method Boost setEntity()
  * @method Entity getEntity()
@@ -30,7 +31,9 @@ use Minds\Traits\MagicAttributes;
  * @method Boost setRejectedTimestamp(int $ts)
  * @method Boost setCreatedTimestamp(int $ts)
  * @method Boost setRevokedTimestamp(int $ts)
- * @method string getState()
+ * @method array getTags()
+ * @method Boost setTags(array $value)
+ * @method string getType()
  */
 class Boost
 {

Core/Boost/Network/ElasticRepository.php

@@ -58,6 +58,14 @@ class ElasticRepository
             ];
         }
 
+        if ($opts['entity_guid']) {
+            $must[] = [
+                'term' => [
+                    'entity_guid' => $opts['entity_guid']
+                ]
+            ];
+        }
+
         if ($opts['state'] === 'approved') {
             $must[] = [
                 'exists' => [
@@ -79,7 +87,7 @@ class ElasticRepository
                     'field' => '@reviewed',
                 ],
             ];
-            $sort = [ '@timestamp' => 'asc' ];
+            $sort = ['@timestamp' => 'asc'];
         }
 
         if ($opts['state'] === 'approved' || $opts['state'] === 'review') {
@@ -164,6 +172,7 @@ class ElasticRepository
      * Add a boost
      * @param Boost $boost
      * @return bool
+     * @throws \Exception
      */
     public function add($boost)
     {
@@ -223,6 +232,7 @@ class ElasticRepository
      * Update a boost
      * @param Boost $boost
      * @return bool
+     * @throws \Exception
      */
     public function update($boost, $fields = [])
     {

Core/Boost/Network/Manager.php

@@ -2,9 +2,13 @@
 /**
  * Network boost manager
  */
+
 namespace Minds\Core\Boost\Network;
 
+use Minds\Common\Repository\Response;
+use Minds\Core\Boost\Exceptions\EntityAlreadyBoostedException;
 use Minds\Core\Di\Di;
+use Minds\Core\EntitiesBuilder;
 use Minds\Core\GuidBuilder;
 
 class Manager
@@ -15,7 +19,11 @@ class Manager
     /** @var ElasticRepository $repository */
     private $elasticRepository;
 
+    /** @var EntitiesBuilder $entitiesBuilder */
+    private $entitiesBuilder;
+
     /** @var GuidBuilder $guidBuilder */
+    private $guidBuilder;
 
     public function __construct(
         $repository = null,
@@ -51,7 +59,7 @@ class Manager
             $response = $this->elasticRepository->getList($opts);
 
             if ($opts['state'] === 'review') {
-                $opts['guids'] = array_map(function($boost) {
+                $opts['guids'] = array_map(function ($boost) {
                     return $boost->getGuid();
                 }, $response->toArray());
 
@@ -80,7 +88,7 @@ class Manager
             //    unset($response[$i]);
             }
         }
-        
+
         return $response;
     }
 
@@ -109,9 +117,22 @@ class Manager
      * Add a boost
      * @param Boost $boost
      * @return bool
+     * @throws EntityAlreadyBoostedException
      */
     public function add($boost)
     {
+        $existingBoost = $this->getList([
+            'useElastic' => true,
+            'state' => 'review',
+            'type' => $boost->getType(),
+            'entity_guid' => $boost->getEntityGuid(),
+            'limit' => 1
+        ]);
+
+        if ($existingBoost->count() > 0) {
+            throw new EntityAlreadyBoostedException();
+        }
+
         if (!$boost->getGuid()) {
             $boost->setGuid($this->guidBuilder->build());
         }

Spec/Core/Boost/Network/ManagerSpec.php

@@ -2,15 +2,16 @@
 
 namespace Spec\Minds\Core\Boost\Network;
 
-use Minds\Core\Boost\Network\Manager;
+use Minds\Common\Repository\Response;
+use Minds\Core\Boost\Exceptions\EntityAlreadyBoostedException;
 use Minds\Core\Boost\Network\Boost;
-use Minds\Core\Boost\Network\Repository;
 use Minds\Core\Boost\Network\ElasticRepository;
+use Minds\Core\Boost\Network\Manager;
+use Minds\Core\Boost\Network\Repository;
 use Minds\Core\EntitiesBuilder;
 use Minds\Core\GuidBuilder;
 use Minds\Entities\Activity;
 use Minds\Entities\User;
-use Minds\Common\Repository\Response;
 use PhpSpec\ObjectBehavior;
 use Prophecy\Argument;
 
@@ -67,7 +68,7 @@ class ManagerSpec extends ObjectBehavior
             'state' => 'review',
             'hydrate' => true,
             'useElastic' => true,
-            'guids' => [ 1, 2 ],
+            'guids' => [1, 2],
         ])
             ->shouldBeCalled()
             ->willReturn($response);
@@ -81,7 +82,7 @@ class ManagerSpec extends ObjectBehavior
             ->shouldBeCalled()
             ->willReturn((new User)
                 ->set('guid', 1));
-         
+
         $this->entitiesBuilder->single(456)
             ->shouldBeCalled()
             ->willReturn((new Activity)
@@ -139,7 +140,7 @@ class ManagerSpec extends ObjectBehavior
             ->shouldBeCalled()
             ->willReturn((new User)
                 ->set('guid', 1));
-         
+
         $this->entitiesBuilder->single(456)
             ->shouldBeCalled()
             ->willReturn((new Activity)
@@ -174,7 +175,7 @@ class ManagerSpec extends ObjectBehavior
     {
         $this->repository->getList([
             'state' => null,
-            'guids' => [ 123, 456 ],
+            'guids' => [123, 456],
             'hydrate' => true,
             'useElastic' => false,
         ])
@@ -199,7 +200,7 @@ class ManagerSpec extends ObjectBehavior
             ->shouldBeCalled()
             ->willReturn((new User)
                 ->set('guid', 1));
-         
+
         $this->entitiesBuilder->single(456)
             ->shouldBeCalled()
             ->willReturn((new Activity)
@@ -211,7 +212,7 @@ class ManagerSpec extends ObjectBehavior
                 ->set('guid', 2));
 
         $response = $this->getList([
-            'guids' => [ 123, 456 ],
+            'guids' => [123, 456],
         ]);
 
         $response[0]->getEntity()->getGuid()
@@ -231,10 +232,22 @@ class ManagerSpec extends ObjectBehavior
 
     function it_should_add_a_boost(Boost $boost)
     {
+        $boost->getType()
+            ->shouldBeCalled()
+            ->willReturn('network');
+
+        $boost->getEntityGuid()
+            ->shouldBeCalled()
+            ->willReturn('2');
+
+        $this->elasticRepository->getList(Argument::any())
+            ->shouldBeCalled()
+            ->willReturn(new Response());
+
         $this->guidBuilder->build()
             ->shouldBeCalled()
             ->willReturn(1);
-    
+
         $boost->getGuid()
             ->shouldbeCalled()
             ->willReturn(null);
@@ -251,21 +264,42 @@ class ManagerSpec extends ObjectBehavior
             ->shouldReturn(true);
     }
 
+    function it_should_not_add_a_boost_if_the_entity_has_already_been_boosted(Boost $boost, Boost $oldBoost)
+    {
+        $boost->getType()
+            ->shouldBeCalled()
+            ->willReturn('network');
+
+        $boost->getEntityGuid()
+            ->shouldBeCalled()
+            ->willReturn('2');
+
+        $this->elasticRepository->getList(Argument::any())
+            ->shouldBeCalled()
+            ->willReturn(new Response([$oldBoost]));
+
+        $this->repository->getList(Argument::any())
+            ->shouldBeCalled()
+            ->willReturn(new Response([$oldBoost]));
+
+        $this->shouldThrow(new EntityAlreadyBoostedException())->during('add', [$boost]);
+    }
+
     function it_should_update_a_boost(Boost $boost)
     {
-        $this->repository->update($boost, [ '@timestamp' ])
+        $this->repository->update($boost, ['@timestamp'])
             ->shouldBeCalled();
-        $this->elasticRepository->update($boost, [ '@timestamp' ])
+        $this->elasticRepository->update($boost, ['@timestamp'])
             ->shouldBeCalled();
 
-        $this->update($boost, [ '@timestamp' ] );
+        $this->update($boost, ['@timestamp']);
     }
 
     function it_should_resync_a_boost_on_elasticsearch(Boost $boost)
     {
-        $this->elasticRepository->update($boost, [ '@timestamp' ])
+        $this->elasticRepository->update($boost, ['@timestamp'])
             ->shouldBeCalled();
 
-        $this->resync($boost, [ '@timestamp' ] );
+        $this->resync($boost, ['@timestamp']);
     }
 }