Core/Boost/Campaigns/Stats.php

@@ -2,8 +2,18 @@
 
 namespace Minds\Core\Boost\Campaigns;
 
+use Elasticsearch\Client;
+
 class Stats
 {
+    /** @var Client */
+    protected $esClient;
+
+    public function __construct(Client $esClient)
+    {
+
+    }
+
     /**
      * @param Campaign $campaign
      * @return array

Spec/Core/Boost/Campaigns/ManagerSpec.php

@@ -63,8 +63,7 @@ class ManagerSpec extends ObjectBehavior
         NormalizeHashtagsDelegate $normalizeHashtagsDelegate,
         PaymentsDelegate $paymentsDelegate,
         User $user
-    )
-    {
+    ) {
         $this->beConstructedWith(
             $repository,
             $elasticRepository,
@@ -394,8 +393,24 @@ class ManagerSpec extends ObjectBehavior
         $this->completeCampaign($campaignRef)->shouldReturn($campaign);
     }
 
-    public function it_should_perform_actions_on_payment_success(Payment $payment)
+    public function it_should_perform_actions_on_payment_success(Payment $payment, Campaign $campaign, Response $response)
     {
         $payment->getCampaignGuid()->shouldBeCalled()->willReturn(1234);
+
+        $this->repository->getCampaignByGuid(Argument::type('array'))->shouldBeCalled()->willReturn($response);
+        $response->map(Argument::type('Callable'))->willReturn($response);
+        $response->toArray()->shouldBeCalled()->willReturn([
+            $campaign
+        ]);
+
+        $this->paymentsDelegate->onConfirm($campaign, $payment)->shouldBeCalled()->willReturn($campaign);
+
+        $this->repository->putCampaign($campaign)->shouldBeCalled();
+        $this->elasticRepository->putCampaign($campaign)->shouldBeCalled();
+
+        $this->queueClient->setQueue('BoostCampaignDispatcher')->shouldBeCalled()->willReturn($this->queueClient);
+        $this->queueClient->send(Argument::type('array'))->shouldBeCalled();
+
+        $this->onPaymentSuccess($payment);
     }
 }