Search for subscription using criteria

src/Domain/Event/Subscription/Criteria.php

@@ -0,0 +1,24 @@
+<?php
+
+/**
+ * This file is part of the streak package.
+ *
+ * (C) Alan Gabriel Bem <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Streak\Domain\Event\Subscription;
+
+use Streak\Domain\Event\Subscription\Criteria\Visitor;
+
+/**
+ * @author Alan Gabriel Bem <[email protected]>
+ */
+interface Criteria
+{
+    public function accept(Visitor $visitor);
+}

src/Domain/Event/Subscription/Criteria/AndCriteria.php

@@ -0,0 +1,38 @@
+<?php
+
+/**
+ * This file is part of the streak package.
+ *
+ * (C) Alan Gabriel Bem <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Streak\Domain\Event\Subscription\Criteria;
+
+use Streak\Domain\Event\Subscription\Criteria;
+
+/**
+ * @author Alan Gabriel Bem <[email protected]>
+ */
+class AndCriteria implements Criteria
+{
+    private $criteria;
+
+    public function __construct(Criteria... $criteria)
+    {
+        $this->criteria = $criteria;
+    }
+
+    public function accept(Visitor $visitor)
+    {
+        foreach ($this->criteria as $criterion) {
+            $criterion->accept($visitor);
+        }
+
+        $visitor->visitAnd($this);
+    }
+}

src/Domain/Event/Subscription/Criteria/CompletedCriteria.php

@@ -0,0 +1,28 @@
+<?php
+
+/**
+ * This file is part of the streak package.
+ *
+ * (C) Alan Gabriel Bem <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Streak\Domain\Event\Subscription\Criteria;
+
+use Streak\Domain\Event\Subscription\Criteria;
+
+/**
+ * @author Alan Gabriel Bem <[email protected]>
+ */
+class CompletedCriteria implements Criteria
+{
+    public function accept(Visitor $visitor)
+    {
+
+    }
+
+}

src/Domain/Event/Subscription/Criteria/NotCriteria.php

@@ -0,0 +1,36 @@
+<?php
+
+/**
+ * This file is part of the streak package.
+ *
+ * (C) Alan Gabriel Bem <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Streak\Domain\Event\Subscription\Criteria;
+
+use Streak\Domain\Event\Subscription\Criteria;
+
+/**
+ * @author Alan Gabriel Bem <[email protected]>
+ */
+class NotCriteria implements Criteria
+{
+    private $criteria;
+
+    public function __construct(Criteria $criteria)
+    {
+        $this->criteria = $criteria;
+    }
+
+    public function accept(Visitor $visitor)
+    {
+        $this->criteria->accept($visitor);
+
+        $visitor->visitNot($this);
+    }
+}

src/Domain/Event/Subscription/Criteria/OrCriteria.php

@@ -0,0 +1,38 @@
+<?php
+
+/**
+ * This file is part of the streak package.
+ *
+ * (C) Alan Gabriel Bem <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Streak\Domain\Event\Subscription\Criteria;
+
+use Streak\Domain\Event\Subscription\Criteria;
+
+/**
+ * @author Alan Gabriel Bem <[email protected]>
+ */
+class OrCriteria implements Criteria
+{
+    private $criteria;
+
+    public function __construct(Criteria... $criteria)
+    {
+        $this->criteria = $criteria;
+    }
+
+    public function accept(Visitor $visitor)
+    {
+        foreach ($this->criteria as $criterion) {
+            $criterion->accept($visitor);
+        }
+
+        $visitor->visitOr($this);
+    }
+}

src/Domain/Event/Subscription/Criteria/TypeEqualsToCriteria.php

@@ -0,0 +1,59 @@
+<?php
+
+/**
+ * This file is part of the streak package.
+ *
+ * (C) Alan Gabriel Bem <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Streak\Domain\Event\Subscription\Criteria;
+
+use Streak\Domain\Event\Listener;
+use Streak\Domain\Event\Subscription\Criteria;
+
+/**
+ * @author Alan Gabriel Bem <[email protected]>
+ */
+class TypeEqualsToCriteria implements Criteria
+{
+    private $type;
+
+    public function __construct(string $type)
+    {
+        $this->validate($type);
+
+        $this->type = $type;
+    }
+
+    public function type() : string
+    {
+        return $this->type;
+    }
+
+    public function accept(Visitor $visitor)
+    {
+        $visitor->visitTypeEqualsTo($this);
+    }
+
+    private function validate(string $type) : void
+    {
+        try {
+            $reflection = new \ReflectionClass($type);
+        } catch (\ReflectionException $exception) {
+            throw new \InvalidArgumentException(
+                sprintf('Given argument "%s" is not a type of "%s"', $type, Listener\Id::class)
+            );
+        }
+
+        if (false === $reflection->implementsInterface(Listener\Id::class)) {
+            throw new \InvalidArgumentException(
+                sprintf('Given argument "%s" is not a type of "%s"', $type, Listener\Id::class)
+            );
+        }
+    }
+}

src/Domain/Event/Subscription/Criteria/Visitor.php

@@ -0,0 +1,28 @@
+<?php
+
+/**
+ * This file is part of the streak package.
+ *
+ * (C) Alan Gabriel Bem <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Streak\Domain\Event\Subscription\Criteria;
+
+/**
+ * @author Alan Gabriel Bem <[email protected]>
+ */
+interface Visitor
+{
+    public function visitAnd(AndCriteria $criteria);
+
+    public function visitOr(OrCriteria $criteria);
+
+    public function visitNot(NotCriteria $criteria);
+
+    public function visitTypeEqualsTo(TypeEqualsToCriteria $criteria);
+}

src/Domain/Event/Subscription/Repository.php

@@ -39,5 +39,5 @@ public function add(Event\Subscription $subscription) : void;
     /**
      * @return iterable|Event\Subscription[]
      */
-    public function all(?Repository\Filter $filter = null) : iterable;
+    public function all(Criteria $criteria) : iterable;
 }

src/Infrastructure/Event/Subscription/DAO.php

@@ -32,5 +32,5 @@ public function exists(Listener\Id $id) : bool;
      *
      * @return DAO\Subscription[]
      */
-    public function all(array $types = [], ?bool $completed = null) : iterable;
+    public function all(Subscription\Criteria $criteria) : iterable;
 }