Controllers/Cli/Moderation.php

@@ -5,6 +5,7 @@ namespace Minds\Controllers\Cli;
 use Minds\Core;
 use Minds\Core\Di\Di;
 use Minds\Cli;
+use Minds\Core\Reports\Summons\Summon;
 use Minds\Interfaces;
 use Minds\Entities;
 
@@ -47,9 +48,16 @@ class Moderation extends Cli\Controller implements Interfaces\CliControllerInter
 
         $userId = $this->getOpt('user');
         $reportUrn = $this->getOpt('report');
+        $juryType = $this->getOpt('jury-type') ?? null;
+        $respond = $this->getOpt('respond') ?? null;
 
         if (!$userId || !$reportUrn) {
-            $this->out('Usage: cli.php moderation summon --user=<username_or_guid> --report=<report_urn>');
+            $this->out([
+                'Usage:',
+                '- Summoning: cli.php moderation summon --user=<username_or_guid> --report=<report_urn>',
+                '- Responding: cli.php moderation summon --user=<username_or_guid> --report=<report_urn> --jury-type=<initial_jury|appeal_jury> --respond=<accepted|declined>',
+            ]);
+
             exit(1);
         }
 
@@ -60,6 +68,54 @@ class Moderation extends Cli\Controller implements Interfaces\CliControllerInter
             exit(1);
         }
 
+        if (!$respond) {
+            $report = $reportsRepository->get($reportUrn);
+
+            if (!$report) {
+                $this->out('Error: Invalid report');
+                exit(1);
+            }
+
+            $appeal = new Core\Reports\Appeals\Appeal();
+            $appeal->setReport($report);
+
+            $summonsManager->summon($appeal, [ $user->guid ]);
+
+            $this->out("Summoned {$user->guid} to {$reportUrn}");
+        } else {
+            $summon = new Summon();
+            $summon
+                ->setReportUrn($reportUrn)
+                ->setJuryType($juryType)
+                ->setJurorGuid((string) $user->guid)
+                ->setStatus($respond);
+
+                $summonsManager->respond($summon);
+
+            $this->out("Responded to {$user->guid}'s summon to {$reportUrn} with {$respond}");
+        }
+    }
+
+    public function dev_only_simulate_summon()
+    {
+        error_reporting(E_ALL);
+        ini_set('display_errors', 1);
+
+        /** @var Core\Reports\Repository $reportsRepository */
+        $reportsRepository = Di::_()->get('Reports\Repository');
+
+        /** @var Core\Reports\Summons\Manager $summonsManager */
+        $summonsManager = Di::_()->get('Moderation\Summons\Manager');
+
+        $reportUrn = $this->getOpt('report');
+
+        if (!$reportUrn) {
+            $this->out([
+                'Usage: cli.php moderation dev_only_simulate_summon --report=<report_urn>',
+            ]);
+
+            exit(1);
+        }
         $report = $reportsRepository->get($reportUrn);
 
         if (!$report) {
@@ -68,8 +124,12 @@ class Moderation extends Cli\Controller implements Interfaces\CliControllerInter
         }
 
         $appeal = new Core\Reports\Appeals\Appeal();
-        $appeal->setReport($report);
+        $appeal
+            ->setReport($report)
+            ->setOwnerGuid($report->getEntityOwnerGuid());
+
+        $cohort = $summonsManager->summon($appeal, null);
 
-        $summonsManager->summon($appeal, [ $user->guid ]);
+        var_dump($cohort);
     }
 }

Controllers/api/v2/moderation/summons.php

@@ -53,6 +53,8 @@ class summons implements Interfaces\Api
                 ->setJuryType($juryType)
                 ->setJurorGuid((string) $userGuid)
                 ->setStatus($status);
+
+            $summonsManager->respond($summon);
         } catch (\Exception $e) {
             return Factory::response([
                 'status' => 'error',
@@ -60,15 +62,6 @@ class summons implements Interfaces\Api
             ]);
         }
 
-        if (!$summonsManager->isSummoned($summon)) {
-            return Factory::response([
-                'status' => 'error',
-                'message' => 'You\'re not summoned',
-            ]);
-        }
-
-        $summonsManager->respond($summon);
-
         $response = [
             'summon' => $summon->getStatus(),
             'expires_in' => $summon->getTtl(),

Core/Queue/Runners/ReportsAppealSummon.php

@@ -12,6 +12,7 @@ use Minds\Core\Queue\Message;
 use Minds\Core\Queue\Client;
 use Minds\Core\Queue\Interfaces\QueueClient;
 use Minds\Core\Queue\Interfaces\QueueRunner;
+use Minds\Core\Reports\Appeals\Appeal;
 use Minds\Core\Reports\Summons\Manager;
 
 class ReportsAppealSummon implements QueueRunner
@@ -31,7 +32,10 @@ class ReportsAppealSummon implements QueueRunner
             ->receive(function (Message $data) {
                 $params = $data->getData();
 
+                /** @var Appeal $appeal */
                 $appeal = $params['appeal'] ?? null;
+
+                /** @var string[] $cohort */
                 $cohort = $params['cohort'] ?? null;
 
                 if (!$appeal) {
@@ -39,9 +43,18 @@ class ReportsAppealSummon implements QueueRunner
                     return;
                 }
 
+                echo "Summoning for {$appeal->getReport()->getUrn()}..." . PHP_EOL;
+
                 /** @var Manager $manager */
                 $manager = Di::_()->get('Moderation\Summons\Manager');
-                $manager->summon($appeal, $cohort);
+                $missing = $manager->summon($appeal, $cohort);
+
+                if ($missing > 0) {
+                    echo "Missing {$missing} juror(s). Deferring..." . PHP_EOL;
+                    $manager->defer($appeal);
+                }
+
+                echo "Done!" . PHP_EOL;
             });
     }
 }

Core/Reports/Summons/Cohort.php

@@ -7,149 +7,91 @@
 
 namespace Minds\Core\Reports\Summons;
 
-use Minds\Core\Data\ElasticSearch\Client as ElasticsearchClient;
-use Minds\Core\Data\ElasticSearch\Prepared\Search;
-use Minds\Core\Di\Di;
-use Minds\Helpers\Text;
+use Exception;
 
 class Cohort
 {
-    /** @var ElasticsearchClient */
-    protected $elasticsearch;
+    /** @var Repository */
+    protected $repository;
 
-    /** @var string */
-    protected $index;
+    /** @var Pool */
+    protected $pool;
 
     /**
-     * Repository constructor.
-     * @param ElasticsearchClient $elasticsearch
-     * @param string $index
+     * Cohort constructor.
+     * @param Repository $repository
+     * @param Pool $pool
      */
     public function __construct(
-        $elasticsearch = null,
-        $index = null
+        $repository = null,
+        $pool = null
     )
     {
-        $this->elasticsearch = $elasticsearch ?: Di::_()->get('Database\ElasticSearch');
-        $this->index = $index ?: 'minds-metrics-*';
+        $this->repository = $repository ?: new Repository();
+        $this->pool = $pool ?: new Pool();
     }
 
     /**
      * @param array $opts
-     * @return \Generator
-     * @yields string
+     * @return string[]
+     * @throws Exception
      */
-    public function getList(array $opts = [])
+    public function pick($opts)
     {
         $opts = array_merge([
+            'size' => 0,
             'for' => null,
-            'active_threshold' => 0,
-            'platform' => null,
-            'validated' => false,
-            'limit' => 10,
-            'offset' => 0,
+            'except' => [],
+            'active_threshold' => null,
         ], $opts);
 
-        $now = (int) (microtime(true) * 1000);
-        $fromTimestamp = $now - ($opts['active_threshold'] * 1000);
-
-        $body = [
-            '_source' => [
-                'user_guid',
-            ],
-            'query' => [
-                'bool' => [
-                    'must' => [
-                        [
-                            'range' => [
-                                '@timestamp' => [
-                                    'gte' => $fromTimestamp,
-                                ],
-                            ],
-                        ],
-                        [
-                            'term' => [
-                                'type' => 'action',
-                            ],
-                        ],
-                    ],
-                ],
-            ],
-            'aggs' => [
-                'entities' => [
-                    'terms' => [
-                        'field' => 'user_guid.keyword',
-                        'size' => $opts['limit'],
-                    ],
-                ],
-            ],
-            'size' => 0,
-        ];
-
-        if ($opts['platform']) {
-            $body['query']['bool']['must'][] = [
-                'terms' => [
-                    'platform' => Text::buildArray($opts['platform']),
-                ],
-            ];
-        }
-
-        if ($opts['for']) {
-            if (!isset($body['query']['bool']['must_not'])) {
-                $body['query']['bool']['must_not'] = [];
-            }
+        $cohort = [];
 
-            $body['query']['bool']['must_not'][] = [
-                'term' => [
-                    'user_guid' => (string) $opts['for'],
-                ],
-            ];
-
-            $body['query']['bool']['must_not'][] = [
-                'terms' => [
-                    'user_guid' => [
-                        'index' => 'minds-graph',
-                        'type' => 'subscriptions',
-                        'id' => (string) $opts['for'],
-                        'path' => 'guids',
-                    ],
-                ],
-            ];
-        }
+        // Uncomment below to scale
+        // $poolSize = $opts['size'] * 5;
+        // $max_pages = 20; // NOTE: Normally capped to 20.
 
-        if ($opts['validated']) {
-            $body['query']['bool']['must'][] = [
-                'exists' => [
-                    'field' => 'user_phone_number_hash',
-                ],
-            ];
+        $poolSize = 400;
+        $max_pages = 1; // NOTE: Normally capped to 20.
+        $page = 0;
 
-            if (!isset($body['query']['bool']['must_not'])) {
-                $body['query']['bool']['must_not'] = [];
+        while (true) {
+            if ($page > $max_pages) {
+                // Max = PoolSize * MaxPages
+                error_log('Cannot gather a cohort');
+                break;
             }
 
-            $body['query']['bool']['must_not'][] = [
-                'term' => [
-                    'user_phone_number_hash' => '',
-                ],
-            ];
-        }
-
-        $query = [
-            'index' => $this->index,
-            'type' => 'action',
-            'body' => $body,
-            'size' => $opts['limit'],
-            'from' => $opts['offset'],
-        ];
-
-        $prepared = new Search();
-        $prepared->query($query);
+            $pool = $this->pool->getList([
+                'active_threshold' => $opts['active_threshold'],
+                'platform' => 'browser',
+                'for' => $opts['for'],
+                'except' => $opts['except'],
+                'validated' => false,
+                'size' => $poolSize,
+                'page' => $page,
+                'max_pages' => $max_pages,
+            ]);
+
+            $j = 0;
+            foreach ($pool as $userGuid) {
+                $j++;
+
+                // TODO: Check subs
+                $cohort[] = $userGuid;
+
+                if (count($cohort) >= $opts['size']) {
+                    break;
+                }
+            }
 
-        $result = $this->elasticsearch->request($prepared);
+            if ($j === 0 || count($cohort) >= $opts['size']) {
+                break;
+            }
 
-        foreach ($result['aggregations']['entities']['buckets'] as $bucket) {
-            yield $bucket['key'];
+            $page++;
         }
+
+        return $cohort;
     }
 }

Core/Reports/Summons/Delegates/SocketDelegate.php

@@ -7,6 +7,7 @@
 
 namespace Minds\Core\Reports\Summons\Delegates;
 
+use Exception;
 use Minds\Core\Reports\Summons\Summon;
 use Minds\Core\Sockets\Events as SocketEvents;
 
@@ -28,7 +29,7 @@ class SocketDelegate
 
     /**
      * @param Summon $summon
-     * @throws \Exception
+     * @throws Exception
      */
     public function onSummon(Summon $summon)
     {

Core/Reports/Summons/Manager.php

@@ -7,6 +7,10 @@
 
 namespace Minds\Core\Reports\Summons;
 
+use Exception;
+use Minds\Core\Queue\Client as QueueClient;
+use Minds\Core\Queue\Client;
+use Minds\Core\Queue\Runners\ReportsAppealSummon;
 use Minds\Core\Reports\Appeals\Appeal;
 use Minds\Core\Reports\Summons\Delegates;
 
@@ -15,9 +19,12 @@ class Manager
     /** @var Cohort $cohort */
     protected $cohort;
 
-    /** @vat Repository $repository */
+    /** @var Repository $repository */
     protected $repository;
 
+    /** @var QueueClient */
+    protected $queueClient;
+
     /** @var Delegates\SocketDelegate $socketDelegate */
     protected $socketDelegate;
 
@@ -25,39 +32,75 @@ class Manager
      * Manager constructor.
      * @param Cohort $cohort
      * @param Repository $repository
+     * @param QueueClient $queueClient
      * @param Delegates\SocketDelegate $socketDelegate
+     * @throws Exception
      */
     public function __construct(
         $cohort = null,
         $repository = null,
+        $queueClient = null,
         $socketDelegate = null
     )
     {
         $this->cohort = $cohort ?: new Cohort();
         $this->repository = $repository ?: new Repository();
+        $this->queueClient = $queueClient ?: Client::build();
         $this->socketDelegate = $socketDelegate ?: new Delegates\SocketDelegate();
     }
 
     /**
      * @param Appeal $appeal
      * @param array $cohort
-     * @throws \Exception
+     * @return int
+     * @throws Exception
      */
     public function summon(Appeal $appeal, $cohort = null)
     {
-        $cohort = $cohort ?: $this->cohort->getList([
-            'active_threshold' => 5 * 60,
-            'platform' => 'browser',
-            'for' => $appeal->getOwnerGuid(),
-            'validated' => true,
-            'limit' => 12,
-        ]);
+        $reportUrn = $appeal->getReport()->getUrn();
+        $juryType = 'appeal_jury';
+
+        $missing = 0;
+
+        if (!$cohort) {
+            $jury = iterator_to_array($this->repository->getList([
+                'report_urn' => $reportUrn,
+                'jury_type' => $juryType,
+            ]));
+
+            // Check how many are missing
+
+            $notDeclined = array_filter($jury, function (Summon $summon) {
+                return $summon->isAccepted() || $summon->isAwaiting();
+            });
+
+            $missing = 12 - count($notDeclined);
+
+            // If we have a full jury, don't summon
+
+            if ($missing <= 0) {
+                return 0;
+            }
+
+            // Reduce jury to juror guids and try to pick up to missing size
+
+            $juryGuids = array_map(function (Summon $summon) {
+                return (string) $summon->getJurorGuid();
+            }, $jury);
+
+            $cohort = $this->cohort->pick([
+                'size' => $missing,
+                'for' => $appeal->getOwnerGuid(),
+                'except' => $juryGuids,
+                'active_threshold' => 5 * 60,
+            ]);
+        }
 
         foreach ($cohort as $juror) {
             $summon = new Summon();
             $summon
-                ->setReportUrn($appeal->getReport()->getUrn())
-                ->setJuryType('appeal_jury')
+                ->setReportUrn($reportUrn)
+                ->setJuryType($juryType)
                 ->setJurorGuid($juror)
                 ->setTtl(120)
                 ->setStatus('awaiting');
@@ -65,6 +108,8 @@ class Manager
             $this->repository->add($summon);
             $this->socketDelegate->onSummon($summon);
         }
+
+        return $missing;
     }
 
     /**
@@ -79,9 +124,14 @@ class Manager
     /**
      * @param Summon $summon
      * @return Summon
+     * @throws Exception
      */
     public function respond(Summon $summon)
     {
+        if (!$this->isSummoned($summon)) {
+            throw new Exception('User is not summoned');
+        }
+
         $summon
             ->setTtl(10 * 60);
 
@@ -89,4 +139,30 @@ class Manager
 
         return $summon;
     }
+
+    /**
+     * @param string $reportUrn
+     * @param string $juryType
+     * @return bool
+     * @throws Exception
+     */
+    public function release($reportUrn, $juryType)
+    {
+        return $this->repository->deleteAll([
+            'report_urn' => $reportUrn,
+            'jury_type' => $juryType,
+        ]);
+    }
+
+    /**
+     * @param Appeal $appeal
+     */
+    public function defer(Appeal $appeal)
+    {
+        $this->queueClient
+            ->setQueue(ReportsAppealSummon::class)
+            ->send([
+                'appeal' => $appeal,
+            ], 600);
+    }
 }

Core/Reports/Summons/Pool.php

+<?php
+/**
+ * User Pool for Cohort
+ *
+ * @author edgebal
+ */
+
+namespace Minds\Core\Reports\Summons;
+
+use Generator;
+use Minds\Core\Data\ElasticSearch\Client as ElasticsearchClient;
+use Minds\Core\Data\ElasticSearch\Prepared\Search;
+use Minds\Core\Di\Di;
+use Minds\Helpers\Text;
+
+class Pool
+{
+    /** @var ElasticsearchClient */
+    protected $elasticsearch;
+
+    /** @var string */
+    protected $index;
+
+    /**
+     * Repository constructor.
+     * @param ElasticsearchClient $elasticsearch
+     * @param string $index
+     */
+    public function __construct(
+        $elasticsearch = null,
+        $index = null
+    )
+    {
+        $this->elasticsearch = $elasticsearch ?: Di::_()->get('Database\ElasticSearch');
+        $this->index = $index ?: 'minds-metrics-*';
+    }
+
+    /**
+     * @param array $opts
+     * @return Generator
+     * @yields string
+     */
+    public function getList(array $opts = [])
+    {
+        $opts = array_merge([
+            'for' => null,
+            'active_threshold' => 0,
+            'platform' => null,
+            'validated' => false,
+            'size' => 10,
+            'page' => 0,
+            'max_pages' => 20,
+        ], $opts);
+
+        $now = (int) (microtime(true) * 1000);
+        $fromTimestamp = $now - ($opts['active_threshold'] * 1000);
+
+        $body = [
+            '_source' => [
+                'user_guid',
+            ],
+            'query' => [
+                'bool' => [
+                    'must' => [
+                        [
+                            'range' => [
+                                '@timestamp' => [
+                                    'gte' => $fromTimestamp,
+                                ],
+                            ],
+                        ],
+                        [
+                            'term' => [
+                                'type' => 'action',
+                            ],
+                        ],
+                    ],
+                ],
+            ],
+            'aggs' => [
+                'entities' => [
+                    'terms' => [
+                        'field' => 'user_guid.keyword',
+                        'size' => $opts['size'],
+                        'include' => [
+                            'partition' => $opts['page'],
+                            'num_partitions' => $opts['max_pages'],
+                        ],
+                    ],
+                ],
+            ],
+            'size' => 0,
+        ];
+
+        if ($opts['platform']) {
+            $body['query']['bool']['must'][] = [
+                'terms' => [
+                    'platform' => Text::buildArray($opts['platform']),
+                ],
+            ];
+        }
+
+        if ($opts['for']) {
+            if (!isset($body['query']['bool']['must_not'])) {
+                $body['query']['bool']['must_not'] = [];
+            }
+
+            $body['query']['bool']['must_not'][] = [
+                'term' => [
+                    'user_guid' => (string) $opts['for'],
+                ],
+            ];
+
+            $body['query']['bool']['must_not'][] = [
+                'terms' => [
+                    'user_guid' => [
+                        'index' => 'minds-graph',
+                        'type' => 'subscriptions',
+                        'id' => (string) $opts['for'],
+                        'path' => 'guids',
+                    ],
+                ],
+            ];
+        }
+
+        if ($opts['except']) {
+            $body['query']['bool']['must_not'][] = [
+                'terms' => [
+                    'user_guid' => $opts['except'],
+                ],
+            ];
+        }
+
+        if ($opts['validated']) {
+            $body['query']['bool']['must'][] = [
+                'exists' => [
+                    'field' => 'user_phone_number_hash',
+                ],
+            ];
+
+            if (!isset($body['query']['bool']['must_not'])) {
+                $body['query']['bool']['must_not'] = [];
+            }
+
+            $body['query']['bool']['must_not'][] = [
+                'term' => [
+                    'user_phone_number_hash' => '',
+                ],
+            ];
+        }
+
+        $query = [
+            'index' => $this->index,
+            'type' => 'action',
+            'body' => $body,
+        ];
+
+        $prepared = new Search();
+        $prepared->query($query);
+
+        $result = $this->elasticsearch->request($prepared);
+
+        foreach ($result['aggregations']['entities']['buckets'] as $bucket) {
+            yield $bucket['key'];
+        }
+    }
+}

Core/Reports/Summons/Repository.php

@@ -8,6 +8,8 @@
 namespace Minds\Core\Reports\Summons;
 
 use Cassandra\Bigint;
+use Exception;
+use Generator;
 use Minds\Core\Data\Cassandra\Client as CassandraClient;
 use Minds\Core\Data\Cassandra\Prepared\Custom;
 use Minds\Core\Di\Di;
@@ -30,11 +32,70 @@ class Repository
 
     /**
      * @param array $opts
-     * @throws \NotImplementedException
+     * @return Generator
+     * @yields array
+     * @throws Exception
      */
     public function getList(array $opts = [])
     {
-        throw new \NotImplementedException();
+        $opts = array_merge([
+            'report_urn' => null,
+            'jury_type' => null,
+            'juror_guid' => null,
+            'limit' => 10000,
+            'offset' => null,
+        ], $opts);
+
+        if (!$opts['report_urn']) {
+            throw new Exception('Invalid Report URN');
+        }
+
+        if (!$opts['jury_type']) {
+            throw new Exception('Invalid Jury type');
+        }
+
+        $cql = "SELECT * FROM moderation_summons WHERE report_urn = ? AND jury_type = ?";
+        $values = [
+            $opts['report_urn'],
+            $opts['jury_type'],
+        ];
+        $cqlOpts = [];
+
+        if ($opts['juror_guid']) {
+            $cql .= " AND juror_guid = ?";
+            $values[] = new Bigint($opts['juror_guid']);
+        }
+
+        if ($opts['offset']) {
+            $cqlOpts['paging_state_token'] = base64_decode($opts['offset']);
+        }
+
+        if ($opts['limit']) {
+            $cqlOpts['page_size'] = (int) $opts['limit'];
+        }
+
+        $prepared = new Custom();
+        $prepared->query($cql, $values);
+        $prepared->setOpts($cqlOpts);
+
+        try {
+            $rows = $this->db->request($prepared);
+
+            foreach ($rows as $row) {
+                $summon = new Summon();
+                $summon
+                    ->setReportUrn($row['report_urn'])
+                    ->setJuryType($row['jury_type'])
+                    ->setJurorGuid($row['juror_guid']->toInt())
+                    ->setStatus($row['status'])
+                    ->setTtl($row['expires'] - time());
+
+                yield $summon;
+            }
+        } catch (Exception $e) {
+            error_log($e);
+            return [];
+        }
     }
 
     /**
@@ -60,7 +121,7 @@ class Repository
 
         try {
             return (bool) $this->db->request($prepared, true);
-        } catch (\Exception $e) {
+        } catch (Exception $e) {
             error_log($e);
             return false;
         }
@@ -86,7 +147,7 @@ class Repository
             $response = $this->db->request($prepared);
 
             return $response[0]['total'] > 0;
-        } catch (\Exception $e) {
+        } catch (Exception $e) {
             error_log($e);
             return false;
         }
@@ -94,10 +155,59 @@ class Repository
 
     /**
      * @param Summon $summon
-     * @throws \NotImplementedException
+     * @return bool
+     * @throws Exception
      */
     public function delete(Summon $summon)
     {
-        throw new \NotImplementedException();
+        return $this->deleteAll([
+            'report_urn' => $summon->getReportUrn(),
+            'jury_type' => $summon->getJuryType(),
+            'juror_guid' => $summon->getJurorGuid(),
+        ]);
+    }
+
+    /**
+     * @param array $opts
+     * @return bool
+     * @throws Exception
+     * @yields array
+     */
+    public function deleteAll(array $opts = [])
+    {
+        $opts = array_merge([
+            'report_urn' => null,
+            'jury_type' => null,
+            'juror_guid' => null,
+        ], $opts);
+
+        if (!$opts['report_urn']) {
+            throw new Exception('Invalid Report URN');
+        }
+
+        if (!$opts['jury_type']) {
+            throw new Exception('Invalid Jury type');
+        }
+
+        $cql = "DELETE FROM moderation_summons WHERE report_urn = ? AND jury_type = ?";
+        $values = [
+            $opts['report_urn'],
+            $opts['jury_type'],
+        ];
+
+        if ($opts['juror_guid']) {
+            $cql .= " AND juror_guid = ?";
+            $values[] = new Bigint($opts['juror_guid']);
+        }
+
+        $prepared = new Custom();
+        $prepared->query($cql, $values);
+
+        try {
+            return (bool) $this->db->request($prepared, true);
+        } catch (Exception $e) {
+            error_log($e);
+            return false;
+        }
     }
 }

Core/Reports/Summons/Summon.php

@@ -7,6 +7,8 @@
 
 namespace Minds\Core\Reports\Summons;
 
+use Exception;
+use JsonSerializable;
 use Minds\Traits\MagicAttributes;
 
 /**
@@ -22,7 +24,7 @@ use Minds\Traits\MagicAttributes;
  * @method int getTtl()
  * @method Summon setTtl(int $ttl)
  */
-class Summon implements \JsonSerializable
+class Summon implements JsonSerializable
 {
     use MagicAttributes;
 
@@ -44,12 +46,12 @@ class Summon implements \JsonSerializable
     /**
      * @param string $status
      * @return $this
-     * @throws \Exception
+     * @throws Exception
      */
     public function setStatus($status)
     {
         if (!in_array($status, ['awaiting', 'accepted', 'declined'])) {
-            throw new \Exception('Invalid status');
+            throw new Exception('Invalid status');
         }
 
         $this->status = $status;

Core/Reports/Verdict/Delegates/ReleaseSummonsesDelegate.php

+<?php
+/**
+ * ReleaseSummonsesDelegate
+ *
+ * @author edgebal
+ */
+
+namespace Minds\Core\Reports\Verdict\Delegates;
+
+use Minds\Core\Di\Di;
+use Minds\Core\Reports\Summons\Manager;
+use Minds\Core\Reports\Verdict\Verdict;
+
+class ReleaseSummonsesDelegate
+{
+    /** @var Manager */
+    protected $summonsManager;
+
+    /**
+     * ReleaseSummonsesDelegate constructor.
+     * @param Manager $summonsManager
+     */
+    public function __construct(
+        $summonsManager = null
+    )
+    {
+        $this->summonsManager = $summonsManager ?: Di::_()->get('Moderation\Summons\Manager');
+    }
+
+    /**
+     * @param Verdict $verdict
+     * @throws \Exception
+     */
+    public function onCast(Verdict $verdict)
+    {
+        $juryType = $verdict->isAppeal() ? 'appeal_jury' : 'initial_jury';
+
+        $this->summonsManager->release(
+            $verdict->getReport()->getUrn(),
+            $juryType
+        );
+    }
+}

Core/Reports/Verdict/Manager.php

@@ -32,17 +32,22 @@ class Manager
     /** @var Delegates\NotificationDelegate $notificationDelegate */
     private $notificationDelegate;
 
+    /** @var Delegates\ReleaseSummonsesDelegate $releaseSummonsesDelegate */
+    private $releaseSummonsesDelegate;
+
     public function __construct(
         $repository = null,
         $actionDelegate = null,
         $reverseActionDelegate = null,
-        $notificationDelegate = null
+        $notificationDelegate = null,
+        $releaseSummonsesDelegate = null
     )
     {
         $this->repository = $repository ?: new Repository;
         $this->actionDelegate = $actionDelegate ?: new Delegates\ActionDelegate;
         $this->reverseActionDelegate = $reverseActionDelegate ?: new Delegates\ReverseActionDelegate;
         $this->notificationDelegate = $notificationDelegate ?: new Delegates\NotificationDelegate;
+        $this->releaseSummonsesDelegate = $releaseSummonsesDelegate ?: new Delegates\ReleaseSummonsesDelegate;
     }
 
     /**
@@ -119,6 +124,7 @@ class Manager
      * Cast a verdict
      * @param Verdict $verdict
      * @return boolean
+     * @throws \Exception
      */
     public function cast(Verdict $verdict)
     {
@@ -133,6 +139,9 @@ class Manager
         // Send a notification to the reported user
         $this->notificationDelegate->onAction($verdict);
 
+        // Release summonses
+        $this->releaseSummonsesDelegate->onCast($verdict);
+
         // Send rewards to reporters
 
         return $added;

Core/Reports/Verdict/Verdict.php

@@ -4,16 +4,16 @@
  */
 namespace Minds\Core\Reports\Verdict;
 
+use Minds\Core\Reports\Jury\Decision;
+use Minds\Core\Reports\Report;
 use Minds\Traits\MagicAttributes;
 
 /**
- * @method Report getReport(): Report
- * @method Report getDecisions(): array<Decision>
- * @method Report isAppeal(): boolean
- * @method Report isUphold(): boolean
- * @method Report getAction(): string
- * @method Report getInitialJuryAction(): string
- * @method Report getTimestamp: int
+ * @method Report getReport()
+ * @method boolean isUphold()
+ * @method string getAction()
+ * @method string getInitialJuryAction()
+ * @method int getTimestamp()
  */
 class Verdict
 {
@@ -36,7 +36,7 @@ class Verdict
 
     /**
      * Decisions
-     * @return array<Decision>
+     * @return Decision[]
      */
     public function getDecisions()
     {

Spec/Core/Reports/Verdict/ManagerSpec.php

@@ -18,19 +18,22 @@ class ManagerSpec extends ObjectBehavior
     private $actionDelegate;
     private $reverseDelegate;
     private $notificationDelegate;
+    private $releaseSummonsesDelegate;
 
     function let(
         Repository $repository,
         Delegates\ActionDelegate $actionDelegate,
         Delegates\ReverseActionDelegate $reverseDelegate,
-        Delegates\NotificationDelegate $notificationDelegate
+        Delegates\NotificationDelegate $notificationDelegate,
+        Delegates\ReleaseSummonsesDelegate $releaseSummonsesDelegate
     )
     {
-        $this->beConstructedWith($repository, $actionDelegate, $reverseDelegate, $notificationDelegate);
+        $this->beConstructedWith($repository, $actionDelegate, $reverseDelegate, $notificationDelegate, $releaseSummonsesDelegate);
         $this->repository = $repository;
         $this->actionDelegate = $actionDelegate;
         $this->reverseDelegate = $reverseDelegate;
         $this->notificationDelegate = $notificationDelegate;
+        $this->releaseSummonsesDelegate = $releaseSummonsesDelegate;
 
     }
 
@@ -60,6 +63,9 @@ class ManagerSpec extends ObjectBehavior
         $this->notificationDelegate->onAction($verdict)
             ->shouldBeCalled();
 
+        $this->releaseSummonsesDelegate->onCast($verdict)
+            ->shouldBeCalled();
+
         $this->cast($verdict->getWrappedObject());
     }