Controllers/Cli/BoostCampaigns.php

+<?php
+
+namespace Minds\Controllers\Cli;
+
+use DateTime;
+use Elasticsearch\ClientBuilder;
+use Minds\Cli;
+use Minds\Core;
+use Minds\Core\Di\Di;
+use Minds\Entities;
+use Minds\Helpers\Flags;
+use Minds\Interfaces;
+use Minds\Core\Rewards\Contributions\UsersIterator;
+
+class BoostCampaigns extends Cli\Controller implements Interfaces\CliControllerInterface
+{
+ public function help($command = null)
+ {
+ $this->out('Syntax usage: cli trending <type>');
+ }
+
+ public function exec()
+ {
+ }
+
+ public function start()
+ {
+ error_reporting(E_ALL);
+ ini_set('display_errors', 1);
+
+ $offset = $this->getOpt('offset') ?? null;
+ $type = $this->getOpt('type') ?? 'newsfeed';
+
+ $ownerGuid = $this->getOpt('ownerGuid') ?? null;
+
+ /** @var Core\Boost\Campaigns\Manager $manager */
+ $manager = Di::_()->get('Boost\Campaigns\Manager');
+
+ $iterator = (new Core\Boost\Campaigns\Iterator())
+ ->setOffset($offset)
+ ->setState(Core\Boost\Campaigns\Campaign::CREATED_STATUS)
+ ->setOwnerGuid($ownerGuid)
+ ->setType($type);
+
+ foreach ($iterator as $campaign) {
+ try {
+ $manager->start($campaign);
+ } catch (\Exception $e) {
+ error_log(get_class($e) . ': ' . $e->getMessage());
+ continue;
+ }
+ }
+ }
+}

Core/Boost/Campaigns/Iterator.php

+<?php
+/**
+ * @author: eiennohi.
+ */
+
+namespace Minds\Core\Boost\Campaigns;
+
+
+use Minds\Core\Di\Di;
+
+class Iterator implements \Iterator
+{
+ /** @var Manager */
+ protected $manager;
+
+ protected $limit = 12;
+ protected $from = 0;
+ protected $offset = null;
+ protected $sort = 'asc';
+ protected $type = 'newsfeed';
+ protected $ownerGuid = null;
+ protected $state = null;
+
+ /** @var array */
+ protected $list = null;
+
+ public function __construct(
+ $manager = null
+ )
+ {
+ $this->manager = $manager ?: Di::_()->get('Boost\Campaigns\Manager');
+ }
+
+ /**
+ * @param int $limit
+ * @return Iterator
+ */
+ public function setLimit(int $limit)
+ {
+ $this->limit = $limit;
+ return $this;
+ }
+
+ /**
+ * @param int $from
+ * @return Iterator
+ */
+ public function setFrom(int $from)
+ {
+ $this->from = $from;
+ return $this;
+ }
+
+ /**
+ * @return int|null
+ */
+ public function getOffset()
+ {
+ return $this->offset;
+ }
+
+ /**
+ * @param int|null $offset
+ * @return Iterator
+ */
+ public function setOffset($offset)
+ {
+ $this->offset = $offset;
+ return $this;
+ }
+
+ /**
+ * @param string $sort
+ * @return Iterator
+ */
+ public function setSort(string $sort)
+ {
+ $this->sort = $sort;
+ return $this;
+ }
+
+ /**
+ * @param mixed $type
+ * @return Iterator
+ */
+ public function setType($type)
+ {
+ $this->type = $type;
+ return $this;
+ }
+
+ /**
+ * @param null $ownerGuid
+ * @return Iterator
+ */
+ public function setOwnerGuid($ownerGuid)
+ {
+ $this->ownerGuid = $ownerGuid;
+ return $this;
+ }
+
+ /**
+ * @param mixed $state
+ * @return Iterator
+ */
+ public function setState($state)
+ {
+ $this->state = $state;
+ 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,
+ ]);
+
+ $this->offset = $response->getPagingToken();
+
+ $this->list = $response;
+ }
+
+ public function current()
+ {
+ return current($this->list);
+ }
+
+ public function next()
+ {
+ next($this->list);
+ }
+
+ public function key()
+ {
+ return key($this->list);
+ }
+
+ public function valid()
+ {
+ if (!$this->list) {
+ return false;
+ }
+ return key($this->list) !== null;
+ }
+
+ public function rewind()
+ {
+ if ($this->list) {
+ reset($this->list);
+ }
+ $this->getList();
+ }
+}

Core/Boost/Campaigns/Manager.php

@@ -13,10 +13,10 @@ use Minds\Entities\User;
 
 class Manager
 {
- /** @var Repository  */
+ /** @var Repository */
  protected $repository;
 
- /** @var ElasticRepository  */
+ /** @var ElasticRepository */
  protected $elasticRepository;
 
  /** @var Delegates\CampaignUrnDelegate */
@@ -387,19 +387,23 @@ class Manager
  throw new CampaignException('Campaign should be in [approved] state in order to complete it');
  }
 
- // Update
+ // Check for completion
 
- $campaign
- ->setCompletedTimestamp(time() * 1000);
+ if (time() * 1000 >= $campaign->getEnd() || $campaign->getImpressionsMet() >= $campaign->getImpressions()) {
+ // Update
 
- // Write
+ $campaign
+ ->setCompletedTimestamp(time() * 1000);
 
- $this->repository->update($campaign);
- $this->elasticRepository->update($campaign);
+ // Write
 
- // Budget update
+ $this->repository->update($campaign);
+ $this->elasticRepository->update($campaign);
 
- $this->budgetDelegate->onStateChange($campaign);
+ // Budget update
+
+ $this->budgetDelegate->onStateChange($campaign);
+ }
 
  return $campaign;
  }

Core/Queue/Runners/BoostCampaignChecker.php

+<?php
+
+namespace Minds\Core\Queue\Runners;
+
+use Minds\Core\Boost\Campaigns\Manager;
+use Minds\Core\Queue;
+use Minds\Core\Queue\Interfaces;
+use Minds\Core\Di\Di;
+
+class BoostCampaignChecker implements Interfaces\QueueRunner
+{
+ public function run()
+ {
+ $client = Queue\Client::Build();
+ $client->setQueue("BoostCampaignChecker")
+ ->receive(function ($msg) {
+ $data = $msg->getData();
+
+ $campaignRef = $data['campaignRef'];
+
+ echo "Checking boost campaign {$campaignRef->getUrn()}\n";
+
+ /** @var Manager $manager */
+ $manager = Di::_()->get('Boost\Campaigns\Manager');
+ $manager->complete($campaignRef);
+ });
+ }
+
+}

containers/php-runners/minds.conf

@@ -157,3 +157,13 @@ numprocs=4
 redirect_stderr=true
 stdout_logfile=/dev/stdout
 stdout_logfile_maxbytes=0
+
+[program:minds-boost-campaing-checker]
+process_name=%(program_name)s_%(process_num)02d
+command=php /var/www/Minds/engine/cli.php QueueRunner run --runner=BoostCampaignChecker
+autostart=true
+autorestart=true
+numprocs=2
+redirect_stderr=true
+stdout_logfile=/dev/stdout
+stdout_logfile_maxbytes=0