Controllers/Cli/Test.php.orig

+<?php
+
+namespace Minds\Controllers\Cli;
+
+use Minds\Cli;
+use Minds\Core;
+use Minds\Core\Data\ElasticSearch;
+use Minds\Core\Di\Di;
+use Minds\Interfaces;
+
+class Test extends Cli\Controller implements Interfaces\CliControllerInterface
+{
+ public function __construct()
+ {
+ define('__MINDS_INSTALLING__', true);
+ }
+
+ public function help($command = null)
+ {
+ $this->out('TBD');
+ }
+
+ public function exec()
+ {
+ $client = Di::_()->get('Database\ElasticSearch');
+
+ $query = [
+ 'index' => 'minds-boost-campaigns',
+ //'type' => 'activity',
+ '_source' => true,
+ 'size' => 100,
+ 'body' => [
+ 'query' => [
+ 'bool' => [
+ 'must_not' => [
+ [
+ 'exists' => [
+ 'field' => '@completed',
+ ],
+ ],
+ [
+ 'exists' => [
+ 'field' => '@rejected',
+ ],
+ ],
+ [
+ 'exists' => [
+ 'field' => '@revoked',
+ ],
+ ],
+ ],
+ 'filter' => [
+ 'script' => [
+ 'script' => [
+ "inline" => "
+ if(doc._index.value == 'minds-boost')
+ return true;
+ 
+ ZonedDateTime start = ZonedDateTime.ofInstant(doc.start.value.toInstant(), ZoneId.systemDefault());
+ ZonedDateTime end = ZonedDateTime.ofInstant(doc.end.value.toInstant(), ZoneId.systemDefault());
+ 
+ def totalAmountOfDays = ChronoUnit.DAYS.between(start, end);
+ def impressionsPerDay = doc.impressions.value / totalAmountOfDays;
+ 
+ ZonedDateTime now = ZonedDateTime.ofInstant(Instant.ofEpochMilli(params.nowMillis), ZoneId.systemDefault());
+ 
+ def passedDays = ChronoUnit.DAYS.between(now, end);
+ def impressionsMetPerDay = (doc.impressions_met.value ?: doc.impressions.value) / passedDays;
+Debug.explain(impressionsPerDay);
+ return impressionsMetPerDay <= impressionsPerDay;
+ ",
+ 'lang' => 'painless',
+ 'params' => [
+ 'nowMillis' => time() * 1000,
+ ],
+ ],
+ ],
+
+ ],
+ ],
+ ],
+ ],
+ ];
+
+ $prepared = new ElasticSearch\Prepared\Search();
+ $prepared->query($query);
+
+ try {
+ $result = $client->request($prepared);
+ var_dump($result);
+ } catch (\Exception $e) {
+ var_dump(str_replace("\\n", "\r\n", $e->getMessage()));
+ }
+
+<<<<<<< Updated upstream
+ $this->out($namespace);
+=======
+ // var_dump($result);
+ // die();
+
+>>>>>>> Stashed changes
+ }
+
+ private function getTrendingActivities()
+ {
+ $result = Core\Di\Di::_()->get('Trending\Repository')->getList([
+ 'type' => 'newsfeed',
+ 'limit' => 12,
+ ]);
+ ksort($result['guids']);
+ $options['guids'] = $result['guids'];
+
+ $activities = Core\Entities::get(array_merge([
+<<<<<<< Updated upstream
+ 'type' => 'activity'
+ ], $options));
+=======
+ 'type' => 'activity',
+ ]
+ , $options));
+>>>>>>> Stashed changes
+
+ $activities = array_filter($activities, function ($activity) {
+ if ($activity->paywall) {
+ return false;
+ }
+
+ if ($activity->remind_object && $activity->remind_object['paywall']) {
+ return false;
+ }
+
+ return true;
+ });
+
+ return $activities;
+ }
+}

Core/Permissions/Manager.php

@@ -10,6 +10,7 @@ use Minds\Core\Permissions\Roles\Roles;
 /*
 * Manager for managing role based permissions
 */
+
 class Manager
 {
  /** @var EntitiesBuilder */
@@ -43,9 +44,15 @@ class Manager
  throw new \InvalidArgumentException('user_guid is required');
  }
 
+ $guids = $opts['guids'] ?: array_map(function ($item) { return $item['guid']; }, $opts['entities']);
+
  $user = $this->entitiesBuilder->single($opts['user_guid']);
- $entities = $this->entitiesBuilder->get($opts) ?: [];
- 
+ $entities = $this->entitiesBuilder->get(['guids' => $guids]);
+
+ if (!$user) {
+ throw new \InvalidArgumentException('User does not exist');
+ }
+
  if ($user && $user->getType() !== 'user') {
  throw new \InvalidArgumentException('Entity is not a user');
  }