Core/Email/CampaignLogs/CampaignLog.php

+<?php
+
+namespace Minds\Core\Email\CampaignLogs;
+
+use Minds\Traits\MagicAttributes;
+
+/**
+ * @method int getReceiverGuid()
+ * @method CampaignLog setReceiverGuid(int $receiverGuid)
+ * @method int getTimeSent()
+ * @method CampaignLog setTimeSet(int $timeSent)
+ * @method string getEmailCampaignId()
+ * @method CampaignLog setEmailCampaignId(string $emailCampaignId)
+ */
+
+class CampaignLog
+{
+    use MagicAttributes;
+
+    /** @var int $receiverGuid the user guid who received the email */
+    protected $receiverGuid;
+
+    /** @var int $timeStamp the timestamp when the email was sent */
+    protected $timeSent;
+
+    /** @var string $emailCampaignId the class name of the email campaign */
+    protected $emailCampaignID;
+}

Core/Email/CampaignLogs/Repository.php

+<?php
+/**
+ * Email Campaign Log Repository.
+ */
+
+namespace Minds\Core\Email\CampaignLogs;
+
+use Minds\Core\Data\Cassandra\Client;
+use Minds\Core\Di\Di;
+use Cassandra\Varint;
+use Cassandra\Timestamp;
+use Minds\Core\Data\Cassandra\Prepared\Custom;
+use Minds\Core\Email\CampaignLogs\CampaignLog;
+
+class Repository
+{
+    /**
+     * @var Client
+     */
+    protected $db;
+
+    /**
+     * Repository constructor.
+     *
+     * @param null $db
+     */
+    public function __construct($db = null)
+    {
+        $this->db = $db ?: Di::_()->get('Database\Cassandra\Cql');
+    }
+
+    /**
+     * Gets the list of email states, they are clustered on time_sent, so they will be in descending order.
+     *
+     * @param array $options
+     *
+     * receiver_guid the user guid
+     * limit 10
+     *
+     * @return CampaignLog[]
+     */
+    public function getList(array $options = [])
+    {
+        $options = array_merge([
+            'limit' => 10,
+            'offset' => '',
+            'receiver_guid' => null,
+        ], $options);
+
+        $template = 'SELECT * FROM email_campaign_logs';
+        $where = "";
+        $values = [];
+
+        if (isset($options['receiver_guid'])) {
+            $where = 'receiver_guid = ?';
+            $values[] = new Varint($options['receiver_guid']);
+        }
+
+        if ($where) {
+            $template .= ' WHERE ' . $where;
+        }
+
+        $query = new Custom();
+        $query->query($template, $values);
+
+        $query->setOpts([
+            'page_size' => (int) $options['limit'],
+            'paging_state_token' => $options['offset'],
+        ]);
+
+        try {
+            $result = $this->db->request($query);
+        } catch (\Exception $e) {
+            error_log($e);
+        }
+
+        $campaignLog = [];
+        $token = '';
+        if ($result) {
+            foreach ($result as $row) {
+                $campaignLog = (new CampaignLog())
+                    ->setReceiverGuid($row['receiver_guid']->value())
+                    ->setTimeSent($row['time_sent'])
+                    ->setEmailCampaignId($row['email_campaign_id']);
+                $campaignLogs[] = $campaignLog;
+            }
+            $token = base64_encode($result->pagingStateToken());
+        }
+
+        return [
+            'data' => $campaignLogs,
+            'next' => $token,
+        ];
+    }
+
+    /**
+     * Inserts an email campaign log into cassandra.
+     *
+     * @param CampaignLog $campaignLog
+     *
+     * @return bool the write results
+     *
+     * @throws \Exception
+     */
+    public function add(CampaignLog $campaignLog)
+    {
+        $template = 'INSERT INTO email_campaign_logs (receiver_guid, time_sent, email_campaign_id) VALUES (?, ?, ?)';
+        $values = [
+            new Varint($campaignLog->getReceiverGuid()),
+            new Timestamp($campaignLog->getTimeSent()),
+            (string) $campaignLog->getEmailCampaignId(),
+        ];
+        $query = new Custom();
+        $query->query($template, $values);
+
+        return $this->db->request($query);
+    }
+}

Core/Email/Campaigns/EmailCampaign.php

@@ -7,6 +7,7 @@ use Minds\Core\Email\EmailSubscription;
 use Minds\Core\Email\Manager;
 use Minds\Entities\User;
 use Minds\Traits\MagicAttributes;
+use Minds\Core\Email\CampaignLogs\CampaignLog;
 
 abstract class EmailCampaign
 {
@@ -65,4 +66,31 @@ abstract class EmailCampaign
 
         return true;
     }
+
+    /**
+     * Returns the short name of the class as the template name.
+     */
+    public function getEmailCampaignId()
+    {
+        return (new \ReflectionClass($this))->getShortName();
+    }
+
+    /**
+     * Saves when the user received the email campaign to the db.
+     *
+     * @var int defaults to the current time
+     */
+    public function saveCampaignLog(int $time = null)
+    {
+        $time = $time ?: time();
+        if (!$this->manager || !$this->user) {
+            return false;
+        }
+        $campaignLog = (new CampaignLog())
+            ->setReceiverGuid($this->user->guid)
+            ->setTimeSent($time)
+            ->setEmailCampaignId($this->getEmailCampaignId());
+
+        $this->manager->saveCampaignLog($campaignLog);
+    }
 }

Core/Email/Campaigns/UserRetention/GoneCold.php

@@ -70,11 +70,13 @@ class GoneCold extends EmailCampaign
         return $message;
     }
 
-    public function send()
-    {
+    public function send($time = null)
+    {   
+        $time = $time ?: time();
         //send email
         if ($this->canSend()) {
             $this->mailer->queue($this->build());
+            $this->saveCampaignLog($time);
         }
     }
 }

Core/Email/Campaigns/UserRetention/WelcomeComplete.php

@@ -70,11 +70,13 @@ class WelcomeComplete extends EmailCampaign
         return $message;
     }
 
-    public function send()
+    public function send($time = null)
     {
+        $time = $time ?: time();
         //send email
         if ($this->canSend()) {
             $this->mailer->queue($this->build());
+            $this->saveCampaignLog($time);
         }
     }
 }

Core/Email/Campaigns/UserRetention/WelcomeIncomplete.php

@@ -75,6 +75,7 @@ class WelcomeIncomplete extends EmailCampaign
         //send email
         if ($this->canSend()) {
             $this->mailer->queue($this->build());
+            $this->saveCampaignLog();
         }
     }
 }

Core/Email/Delegates/GoneColdSender.php

+<?php
+
+namespace Minds\Core\Email\Delegates;
+
+use Minds\Core\Suggestions\Manager;
+use Minds\Entities\User;
+use Minds\Core\Di\Di;
+use Minds\Interfaces\SenderInterface;
+use Minds\Core\Email\Campaigns\UserRetention\GoneCold;
+
+class GoneColdSender implements SenderInterface
+{
+    /** @var Manager */
+    private $manager;
+    /** @var GoneCold */
+    private $campaign;
+
+    public function __construct(Manager $manager = null, GoneCold $campaign = null)
+    {
+        $this->manager = $manager ?: Di::_()->get('Suggestions\Manager');
+        $this->campaign = $campaign ?: new GoneCold();
+
+    }
+
+    public function send(User $user)
+    {
+        $this->manager->setUser($user);
+        $suggestions = $this->manager->getList();
+        $this->campaign->setUser($user);
+        $this->campaign->setSuggestions($suggestions);
+        $this->campaign->send();
+    }
+}

Core/Email/Delegates/WelcomeSender.php

+<?php
+
+namespace Minds\Core\Email\Delegates;
+
+use Minds\Entities\User;
+use Minds\Core\Di\Di;
+use Minds\Core\Suggestions\Manager as SuggestionsManager;
+use Minds\Core\Onboarding\Manager as OnboardingManager;
+use Minds\Interfaces\SenderInterface;
+use Minds\Core\Email\Campaigns\UserRetention\WelcomeComplete;
+use Minds\Core\Email\Campaigns\UserRetention\WelcomeIncomplete;
+
+class WelcomeSender implements SenderInterface
+{
+    /** @var SuggestionsManager */
+    private $suggestionsManager;
+    /** @var OnboardingManager */
+    private $onboardingManager;
+    /** @var WelcomeComplete */
+    private $welcomeComplete;
+    /** @var WelcomeIncomplete */
+    private $welcomeIncomplete;
+
+    public function __construct(
+        SuggestionsManager $suggestionsManager = null,
+        OnboardingManager $onboardingManager = null,
+        WelcomeComplete $welcomeComplete = null,
+        WelcomeIncomplete $welcomeIncomplete = null
+    ) {
+        $this->suggestionsManager = $suggestionsManager ?: Di::_()->get('Suggestions\Manager');
+        $this->onboardingManager = $onboardingManager ?: Di::_()->get('Onboarding\Manager');
+        $this->welcomeComplete = $welcomeComplete ?: new WelcomeComplete();
+        $this->welcomeIncomplete = $welcomeIncomplete ?: new WelcomeIncomplete();
+    }
+
+    public function send(User $user)
+    {
+        $this->onboardingManager->setUser($user);
+        $campaign = $this->welcomeComplete;
+        if ($this->onboardingManager->isComplete()) {
+            $this->suggestionsManager->setUser($user);
+            $suggestions = $this->suggestionsManager->getList();
+            $campaign->setSuggestions($suggestions);
+        } else {
+            $campaign = $this->welcomeIncomplete;
+        }
+        $campaign->setUser($user);
+        $campaign->send();
+    }
+}

Core/Email/Events.php

@@ -8,11 +8,13 @@ namespace Minds\Core\Email;
 use Minds\Core\Di\Di;
 use Minds\Core\Events\Dispatcher;
 use Minds\Core\Analytics\UserStates\UserActivityBuckets;
-use Minds\Core\Email\Campaigns\UserRetention\GoneCold;
+
 use Minds\Core\Email\Campaigns\UserRetention\WelcomeComplete;
 use Minds\Core\Email\Campaigns\UserRetention\WelcomeIncomplete;
 use Minds\Entities\User;
+use Minds\Core\Email\Manager;
 use Minds\Core\Suggestions\Manager as SuggestionManager;
+use Minds\Interfaces\SenderInterface;
 
 class Events
 {
@@ -36,6 +38,7 @@ class Events
 
         Dispatcher::register('user_state_change', UserActivityBuckets::STATE_NEW, function ($opts) {
             error_log('user_state_change new');
+            $this->sendCampaign(new Delegates\WelcomeSender(), $opts->getParameters());
         });
 
         Dispatcher::register('user_state_change', UserActivityBuckets::STATE_RESURRECTED, function ($opts) {
@@ -43,37 +46,17 @@ class Events
         });
 
         Dispatcher::register('user_state_change', UserActivityBuckets::STATE_COLD, function ($opts) {
-            error_log('user_state_change cold');
-            $params = $opts->getParameters();
-            $user = new User($params['user_guid']);
-            $manager = new SuggestionManager();
-            $manager->setUser($user);
-            $suggestions = $manager->getList();
-            $campaign = (new GoneCold())
-                ->setUser($user)
-                ->setSuggestions($suggestions);
-            $campaign->send();
+            $this->sendCampaign(new Delegates\GoneColdSender(), $opts->getParameters()); 
         });
 
         Dispatcher::register('welcome_email', 'all', function ($opts) {
-            error_log('welcome_email');
-            $params = $opts->getParameters();
-            $user = new User($params['user_guid']);
-            $onboardingManager = Di::_()->get('Onboarding\Manager');
-            $onboardingManager->setUser($user);
-
-            if ($onboardingManager->isComplete()) {
-                $campaign = (new WelcomeComplete());
-                $suggestionManager = Di::_()->get('Suggestions\Manager');
-                $suggestionManager->setUser($user);
-                $suggestions = $suggestionManager->getList();
-                $campaign->setSuggestions($suggestions);
-            } else {
-                $campaign = (new WelcomeIncomplete());
-                error_log('Sending Welcome Incomplete');
-            }
-            $campaign->setUser($user);
-            $campaign->send();
+            $this->sendCampaign(new Delegates\WelcomeSender(), $opts->getParameters());
         });
+
+    }
+
+    private function sendCampaign (SenderInterface $sender, $params) {
+        $user = new User($params['user_guid']);
+        $sender->send($user);
     }
 }

Core/Email/Manager.php

@@ -7,15 +7,24 @@ namespace Minds\Core\Email;
 use Minds\Core\Di\Di;
 use Minds\Core\Email\EmailSubscription;
 use Minds\Core\Entities;
+use Minds\Entities\User;
+use Minds\Core\Email\Repository;
+use Minds\Core\Email\CampaignLogs\Repository as CampaignLogsRepository;
+use Minds\Core\Email\CampaignLogs\CampaignLog;
 
 class Manager
 {
     /** @var Repository */
     protected $repository;
 
-    public function __construct($repository = null)
+    /** @var CampaignLogsRepository */
+    protected $campaignLogsRepository;
+
+
+    public function __construct(Repository $repository = null, CampaignLogsRepository $campaignLogsRepository = null)
     {
         $this->repository = $repository ?: Di::_()->get('Email\Repository');
+        $this->campaignLogsRepository = $campaignLogsRepository ?: Di::_()->get('Email\CampaignLogs\Repository');
     }
 
     public function getSubscribers($options = [])
@@ -108,4 +117,20 @@ class Manager
         return true;
     }
 
+    /**
+     * Saves a log when we send a user a campaign email
+     * Used to select subsequent mailings and send different emails
+     * @param CampaignLog $campaignLog the receiver, time and campaign class name
+     * @return boolean the add result
+     */
+    public function saveCampaignLog(CampaignLog $campaignLog) {
+        $this->campaignLogsRepository->add($campaignLog);
+    }
+
+    public function getCampaignLogs(User $receiver) {
+        $options = [
+            'receiver_guid' => $receiver->guid
+        ];
+        return $this->campaignLogsRepository->getList($options);
+    }
 }

Core/Email/Provider.php

@@ -37,5 +37,9 @@ class Provider extends DiProvider
         $this->di->bind('Email\EmailStyles', function ($di) {
             return new EmailStyles();
         }, ['useFactory' => false]);
+
+        $this->di->bind('Email\CampaignLogs\Repository', function ($di) {
+            return new CampaignLogs\Repository();
+        }, ['useFactory' => true]);
     }
 }

Core/Provisioner/Provisioners/cassandra-provision.cql

@@ -1429,3 +1429,10 @@ CREATE TABLE minds.user_snapshots (
   json_data text,
   PRIMARY KEY (user_guid, type, key)
 ) WITH CLUSTERING ORDER BY (type ASC, key ASC);
+
+CREATE TABLE minds.email_campaign_logs (
+  receiver_guid varint,
+  time_sent timestamp,
+  email_campaign_id text,
+  PRIMARY KEY (receiver_guid, time_sent)
+) WITH CLUSTERING ORDER BY (time_sent desc);

Interfaces/SenderInterface.php

+<?php
+namespace Minds\Interfaces;
+
+use Minds\Entities\User;
+
+/** 
+ * Delegate interface for sending emails
+*/
+
+interface SenderInterface
+{
+
+    /**
+     * sending campaign emails to a user
+     * @return void
+     */
+    public function send(User $user);
+
+}
\ No newline at end of file

Spec/Core/Email/CampaignLogs/RepositorySpec.php

+<?php
+
+namespace Spec\Minds\Core\Email\CampaignLogs;
+
+
+use Minds\Core\Data\Cassandra\Client;
+use Minds\Core\Email\CampaignLogs\Repository;
+use Minds\Core\Email\CampaignLogs\CampaignLog;
+use PhpSpec\ObjectBehavior;
+use Prophecy\Argument;
+use Spec\Minds\Mocks\Cassandra\Rows;
+use Cassandra\Varint;
+
+class RepositorySpec extends ObjectBehavior
+{
+    protected $db;
+
+    public function let(Client $db)
+    {
+        $this->db = $db;
+        $this->beConstructedWith($db);
+    }
+
+    public function it_is_initializable()
+    {
+        $this->shouldHaveType(Repository::class);
+    }
+
+    public function it_should_write_a_log ()
+    {
+        $campaignLog = (new CampaignLog())
+            ->setReceiverGuid(123)
+            ->setTimeSent(0)
+            ->setEmailCampaignId('test');
+
+        $this->db->request(Argument::that(function ($query) {
+            $built = $query->build();
+            return $built['string'] === 'INSERT INTO email_campaign_logs (receiver_guid, time_sent, email_campaign_id) VALUES (?, ?, ?)';
+        }))
+        ->shouldBeCalled()
+        ->willReturn(true);
+
+        $this->add($campaignLog)->shouldReturn(true);
+    }
+
+    public function it_should_get_a_list_of_logs()
+    {
+        $opts = [
+           'receiver_guid' => 123,
+           'limit' => 10,
+           'offset' => '',
+       ];
+        $this->db->request(Argument::that(function ($query) {
+            $built = $query->build();
+
+            return $built['string'] === 'SELECT * FROM email_campaign_logs WHERE receiver_guid = ?';
+        }))
+        ->shouldBeCalled()
+        ->willReturn(new Rows([
+                [
+                    'receiver_guid' => new Varint(123),
+                    'time_sent' => 1,
+                    'email_campaign_id' => 'test' 
+                ],
+                [
+                    'receiver_guid' => new Varint(123),
+                    'time_sent' => 1,
+                    'email_campaign_id' => 'test2' 
+                ],
+            ], ''));
+
+        $this->getList($opts)->shouldBeArray();
+    }
+}

Spec/Core/Email/Campaigns/UserRetention/GoneColdSpec.php

@@ -8,6 +8,7 @@ use Minds\Core\Email\Mailer;
 use Minds\Core\Email\Manager;
 use Minds\Core\Email\EmailSubscription;
 use Minds\Core\Suggestions\Suggestion;
+use Minds\Core\Email\CampaignLogs\CampaignLog;
 use Minds\Entities\User;
 use Prophecy\Argument;
 
@@ -57,15 +58,24 @@ class GoneColdSpec extends ObjectBehavior
         $data['username']->shouldEqual($this->testUsername);
 
         $this->mailer->queue(Argument::any())->shouldBeCalled();
-
+        
         $testEmailSubscription = (new EmailSubscription())
             ->setUserGuid($this->testGUID)
             ->setCampaign('global')
             ->setTopic('minds_tips')
             ->setValue(true);
 
+        $time = time();
+
+        $campaignLog = (new CampaignLog())
+            ->setReceiverGuid($this->testGUID)
+            ->setTimeSent($time)
+            ->setEmailCampaignId($this->getEmailCampaignId()->getWrappedObject());
+
+        $this->manager->saveCampaignLog($campaignLog)->shouldBeCalled();
         $this->manager->isSubscribed($testEmailSubscription)->shouldBeCalled()->willReturn(true);
-        $this->send();
+        
+        $this->send($time);
     }
 
     public function it_should_not_send_unsubscribed(User $user)

Spec/Core/Email/Campaigns/UserRetention/WelcomeCompleteSpec.php

@@ -8,6 +8,7 @@ use Minds\Core\Email\Mailer;
 use Minds\Core\Email\Manager;
 use Minds\Core\Email\EmailSubscription;
 use Minds\Core\Suggestions\Suggestion;
+use Minds\Core\Email\CampaignLogs\CampaignLog;
 use Minds\Entities\User;
 use Prophecy\Argument;
 
@@ -66,6 +67,15 @@ class WelcomeCompleteSpec extends ObjectBehavior
             ->setTopic('minds_tips')
             ->setValue(true);
 
+        
+        $time = time();
+
+        $campaignLog = (new CampaignLog())
+            ->setReceiverGuid($this->testGUID)
+            ->setTimeSent($time)
+            ->setEmailCampaignId($this->getEmailCampaignId()->getWrappedObject());
+
+        $this->manager->saveCampaignLog($campaignLog)->shouldBeCalled();
         $this->manager->isSubscribed($testEmailSubscription)->shouldBeCalled()->willReturn(true);
         $this->send();
     }

Spec/Core/Email/Campaigns/UserRetention/WelcomeIncompleteSpec.php

@@ -7,6 +7,7 @@ use PhpSpec\ObjectBehavior;
 use Minds\Core\Email\Mailer;
 use Minds\Core\Email\Manager;
 use Minds\Core\Email\EmailSubscription;
+use Minds\Core\Email\CampaignLogs\CampaignLog;
 use Minds\Entities\User;
 use Prophecy\Argument;
 
@@ -63,8 +64,17 @@ class WelcomeIncompleteSpec extends ObjectBehavior
             ->setTopic('minds_tips')
             ->setValue(true);
 
+        $time = time();
+
+        $campaignLog = (new CampaignLog())
+            ->setReceiverGuid($this->testGUID)
+            ->setTimeSent($time)
+            ->setEmailCampaignId($this->getEmailCampaignId()->getWrappedObject());
+
+        $this->manager->saveCampaignLog($campaignLog)->shouldBeCalled();
         $this->manager->isSubscribed($testEmailSubscription)->shouldBeCalled()->willReturn(true);
-        $this->send();
+
+        $this->send($time);
     }
 
     public function it_should_not_send_unsubscribed(User $user)

Spec/Core/Email/Delegates/GoneColdSenderSpec.php

+<?php
+
+namespace Spec\Minds\Core\Email\Delegates;
+
+use Minds\Core\Email\Delegates\GoneColdSender;
+use PhpSpec\ObjectBehavior;
+use Minds\Core\Suggestions\Manager as SuggestionsManager;
+use Minds\Core\Email\EmailSubscription;
+use Minds\Core\Email\Manager;
+use Minds\Core\Email\Mailer;
+use Minds\Entities\User;
+use Minds\Core\Email\Campaigns\UserRetention\GoneCold;
+use Minds\Core\Email\CampaignLogs\CampaignLog;
+
+class GoneColdSenderSpec extends ObjectBehavior
+{
+    /** @var Manager $manager */
+    private $manager;
+    /** @var SuggestionsManager $manager */
+    private $suggestionsManager;
+    /** @var Mailer $mailer */
+    private $mailer;
+    /** @var GoneCold $campaign */
+    private $campaign;
+    private $testGUID = 123;
+    private $testName = 'test_name';
+    private $testEmail = 'test@minds.com';
+    private $testUsername = 'testUsername';
+    private $testBriefDescription = 'test brief description';
+
+    public function let(Manager $manager, SuggestionsManager $suggestionsManager, Mailer $mailer)
+    {
+        $this->manager = $manager;
+        $this->suggestionsManager = $suggestionsManager;
+        $this->mailer = $mailer;
+        $campaign = new GoneCold(null, $mailer->getWrappedObject(), $manager->getWrappedObject());
+        $this->campaign = $campaign;
+        $this->beConstructedWith($suggestionsManager, $campaign);
+    }
+
+    public function it_is_initializable()
+    {
+        $this->shouldHaveType(GoneColdSender::class);
+    }
+
+    public function it_should_send(User $user)
+    {
+        $user->getGUID()->shouldBeCalled()->willReturn($this->testGUID);
+        $user->get('enabled')->shouldBeCalled()->willReturn('yes');
+        $user->get('name')->shouldBeCalled()->willReturn($this->testName);
+        $user->get('guid')->shouldBeCalled()->willReturn($this->testGUID);
+        $user->getEmail()->shouldBeCalled()->willReturn($this->testEmail);
+        $user->get('username')->shouldBeCalled()->willReturn($this->testUsername);
+
+        $this->suggestionsManager->setUser($user)->shouldBeCalled();
+        $this->suggestionsManager->getList()->shouldBeCalled();
+
+        $emailSubscription = (new EmailSubscription())
+            ->setUserGuid(123)
+            ->setCampaign('global')
+            ->setTopic('minds_tips')
+            ->setValue('true');
+
+        $time = time();
+
+        $campaignLog = (new CampaignLog())
+            ->setReceiverGuid($this->testGUID)
+            ->setTimeSent($time)
+            ->setEmailCampaignId($this->campaign->getEmailCampaignId());
+
+        $this->manager->saveCampaignLog($campaignLog)->shouldBeCalled();
+        $this->manager->isSubscribed($emailSubscription)->shouldBeCalled()->willReturn(true);
+        $this->send($user);
+    }
+}

Spec/Core/Email/Delegates/WelcomeSenderSpec.php

+<?php
+
+namespace Spec\Minds\Core\Email\Delegates;
+
+use Minds\Core\Email\Delegates\WelcomeSender;
+use PhpSpec\ObjectBehavior;
+use Minds\Core\Suggestions\Manager as SuggestionsManager;
+use Minds\Core\Onboarding\Manager as OnboardingManager;
+use Minds\Core\Email\EmailSubscription;
+use Minds\Core\Email\Manager;
+use Minds\Core\Email\Mailer;
+use Minds\Entities\User;
+use Minds\Core\Email\Campaigns\UserRetention\WelcomeComplete;
+use Minds\Core\Email\Campaigns\UserRetention\WelcomeIncomplete;
+use Minds\Core\Email\CampaignLogs\CampaignLog;
+
+class WelcomeSenderSpec extends ObjectBehavior
+{
+    /** @var Manager $manager */
+    private $manager;
+    /** @var SuggestionsManager */
+    private $suggestionsManager;
+    /** @var OnboardingManager */
+    private $onboardingManager;
+    /** @var WelcomeComplete */
+    private $welcomeComplete;
+    /** @var WelcomeIncomplete */
+    private $welcomeIncomplete;
+    private $testGUID = 123;
+    private $testName = 'test_name';
+    private $testEmail = 'test@minds.com';
+    private $testUsername = 'testUsername';
+    private $testBriefDescription = 'test brief description';
+
+    public function let(
+        Manager $manager,
+        SuggestionsManager $suggestionsManager,
+        OnboardingManager $onboardingManager,
+        Mailer $mailer
+    ) {
+        $welcomeComplete = new WelcomeComplete(null, $mailer->getWrappedObject(), $manager->getWrappedObject());
+        $welcomeIncomplete = new WelcomeIncomplete(null, $mailer->getWrappedObject(), $manager->getWrappedObject());
+        $this->manager = $manager;
+        $this->suggestionsManager = $suggestionsManager;
+        $this->onboardingManager = $onboardingManager;
+        $this->welcomeComplete = $welcomeComplete;
+        $this->welcomeIncomplete = $welcomeIncomplete;
+        $this->beConstructedWith($suggestionsManager, $onboardingManager, $welcomeComplete, $welcomeIncomplete);
+    }
+
+    public function it_is_initializable()
+    {
+        $this->shouldHaveType(WelcomeSender::class);
+    }
+
+    public function it_should_send_a_welcome_complete(User $user)
+    {
+        $user->getGUID()->shouldBeCalled()->willReturn($this->testGUID);
+        $user->get('enabled')->shouldBeCalled()->willReturn('yes');
+        $user->get('name')->shouldBeCalled()->willReturn($this->testName);
+        $user->get('guid')->shouldBeCalled()->willReturn($this->testGUID);
+        $user->getEmail()->shouldBeCalled()->willReturn($this->testEmail);
+        $user->get('username')->shouldBeCalled()->willReturn($this->testUsername);
+
+        $this->onboardingManager->setUser($user)->shouldBeCalled();
+        $this->onboardingManager->isComplete()->shouldBeCalled()->willReturn(true);
+        $this->suggestionsManager->setUser($user)->shouldBeCalled();
+        $this->suggestionsManager->getList()->shouldBeCalled();
+
+        $emailSubscription = (new EmailSubscription())
+        ->setUserGuid(123)
+        ->setCampaign('global')
+        ->setTopic('minds_tips')
+        ->setValue('true');
+
+        $time = time();
+
+        $campaignLog = (new CampaignLog())
+        ->setReceiverGuid($this->testGUID)
+        ->setTimeSent($time)
+        ->setEmailCampaignId($this->welcomeComplete->getEmailCampaignId());
+
+        $this->manager->saveCampaignLog($campaignLog)->shouldBeCalled();
+        $this->manager->isSubscribed($emailSubscription)->shouldBeCalled()->willReturn(true);
+        $this->send($user);
+    }
+
+    public function it_should_send_a_welcome_incomplete(User $user)
+    {
+        $user->getGUID()->shouldBeCalled()->willReturn($this->testGUID);
+        $user->get('enabled')->shouldBeCalled()->willReturn('yes');
+        $user->get('name')->shouldBeCalled()->willReturn($this->testName);
+        $user->get('guid')->shouldBeCalled()->willReturn($this->testGUID);
+        $user->getEmail()->shouldBeCalled()->willReturn($this->testEmail);
+        $user->get('username')->shouldBeCalled()->willReturn($this->testUsername);
+
+        $this->onboardingManager->setUser($user)->shouldBeCalled();
+        $this->onboardingManager->isComplete()->shouldBeCalled()->willReturn(false);
+        $this->suggestionsManager->setUser($user)->shouldNotBeCalled();
+        $this->suggestionsManager->getList()->shouldNotBeCalled();
+
+        $emailSubscription = (new EmailSubscription())
+        ->setUserGuid(123)
+        ->setCampaign('global')
+        ->setTopic('minds_tips')
+        ->setValue('true');
+
+        $time = time();
+
+        $campaignLog = (new CampaignLog())
+        ->setReceiverGuid($this->testGUID)
+        ->setTimeSent($time)
+        ->setEmailCampaignId($this->welcomeIncomplete->getEmailCampaignId());
+
+        $this->manager->saveCampaignLog($campaignLog)->shouldBeCalled();
+        $this->manager->isSubscribed($emailSubscription)->shouldBeCalled()->willReturn(true);
+        $this->send($user);
+    }
+}

Spec/Core/Email/ManagerSpec.php

@@ -6,20 +6,30 @@ use PhpSpec\ObjectBehavior;
 use Prophecy\Argument;
 
 use Minds\Core\Email\Repository;
+use Minds\Core\Email\CampaignLogs\Repository as CampaignLogsRepository;
 use Minds\Entities\User;
 use Minds\Core\Email\EmailSubscription;
+use Minds\Core\Email\CampaignLogs\CampaignLog;
 
 class ManagerSpec extends ObjectBehavior
 {
+    private $repository;
+    private $campaignLogsRepository;
+
+    function let(Repository $repository, CampaignLogsRepository $campaignLogsRepository) {
+        $this->repository = $repository;
+        $this->campaignLogsRepository = $campaignLogsRepository;
+        $this->beConstructedWith($this->repository, $this->campaignLogsRepository);
+ 
+    }
+
     function it_is_initializable()
     {
         $this->shouldHaveType('Minds\Core\Email\Manager');
     }
 
-    function it_should_get_subscribers(Repository $repository)
+    function it_should_get_subscribers()
     {
-        $this->beConstructedWith($repository);
-
         $opts = [
             'campaign' => 'when',
             'topic' => 'boost_completed',
@@ -34,7 +44,7 @@ class ManagerSpec extends ObjectBehavior
         $user1->guid = '456';
         $user1->username = 'user2';
 
-        $repository->getList(Argument::type('array'))
+        $this->repository->getList(Argument::type('array'))
             ->shouldBeCalled()
             ->willReturn([
                 'data' => [
@@ -48,15 +58,13 @@ class ManagerSpec extends ObjectBehavior
 
     }
 
-    function it_should_unsubscribe_a_user_from_a_campaign(Repository $repository)
+    function it_should_unsubscribe_a_user_from_a_campaign()
     {
-        $this->beConstructedWith($repository);
-
         $user = new User();
         $user->guid = '123';
         $user->username = 'user1';
 
-        $repository->delete(Argument::type('Minds\Core\Email\EmailSubscription'))
+        $this->repository->delete(Argument::type('Minds\Core\Email\EmailSubscription'))
             ->shouldBeCalled()
             ->willReturn(true);
 
@@ -65,10 +73,8 @@ class ManagerSpec extends ObjectBehavior
 
     }
 
-    function it_should_unsubscribe_from_all_emails(Repository $repository)
+    function it_should_unsubscribe_from_all_emails()
     {
-        $this->beConstructedWith($repository);
-
         $user = new User();
         $user->guid = '123';
 
@@ -83,7 +89,7 @@ class ManagerSpec extends ObjectBehavior
                 ->setTopic('top_posts'),
         ];
 
-        $repository->getList([
+        $this->repository->getList([
             'campaigns' => [ 'when', 'with', 'global' ],
             'topics' => [ 
                 'unread_notifications',
@@ -102,14 +108,30 @@ class ManagerSpec extends ObjectBehavior
             ->shouldBeCalled()
             ->willReturn($subscriptions);
 
-        $repository->delete($subscriptions[0])
+        $this->repository->delete($subscriptions[0])
             ->shouldBeCalled();
 
-        $repository->delete($subscriptions[1])
+        $this->repository->delete($subscriptions[1])
             ->shouldBeCalled();
         
         $this->unsubscribe($user)
             ->shouldReturn(true);
     }
 
+    function it_should_save_a_campaign_log() {
+        $campaignLog = new CampaignLog();
+        $this->campaignLogsRepository->add($campaignLog)->shouldBeCalled();
+        $this->saveCampaignLog($campaignLog);
+    }
+
+    function it_should_get_campaign_logs() {
+        $user = new User();
+        $user->guid = '123';
+        $options = [
+            'receiver_guid' => $user->guid
+        ]; 
+        $this->campaignLogsRepository->getList($options)->shouldBeCalled();
+        $this->getCampaignLogs($user);
+    }
+
 }