gyselroth / tubee

src/lib/Process/Factory.php

Doc Comments +2 added lines

@@ -180,6 +180,8 @@
 
     /**
      * Change stream.
+     * @param integer $offset
+     * @param integer $limit
      */
     public function watch(ResourceNamespaceInterface $namespace, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
     {

Spacing +2 added lines, -2 removed lines

@@ -72,7 +72,7 @@ 
         $filter = $this->prepareQuery($namespace, $query);
         $that = $this;
 
-        return $this->resource_factory->getAllFrom($this->db->{$this->scheduler->getJobQueue()}, $filter, $offset, $limit, $sort, function (array $resource) use ($namespace, $that) {
+        return $this->resource_factory->getAllFrom($this->db->{$this->scheduler->getJobQueue()}, $filter, $offset, $limit, $sort, function(array $resource) use ($namespace, $that) {
             return $that->build($resource, $namespace);
         });
     }
@@ -131,7 +131,7 @@ 
         $filter = $this->prepareQuery($namespace, $query);
         $that = $this;
 
-        return $this->resource_factory->watchFrom($this->db->{$this->scheduler->getJobQueue()}, $after, $existing, $filter, function (array $resource) use ($namespace, $that) {
+        return $this->resource_factory->watchFrom($this->db->{$this->scheduler->getJobQueue()}, $after, $existing, $filter, function(array $resource) use ($namespace, $that) {
             return $that->build($resource, $namespace);
         }, $offset, $limit, $sort);
     }

src/lib/Rest/Middlewares/QueryDecoder.php

Unused Use Statements -1 removed lines

@@ -18,7 +18,6 @@
 use Psr\Http\Server\MiddlewareInterface;
 use Psr\Http\Server\RequestHandlerInterface;
 use Tubee\Rest\Exception;
-use Zend\Diactoros\Response;
 
 class QueryDecoder implements MiddlewareInterface
 {

src/lib/Workflow.php

Unused Use Statements -1 removed lines

@@ -18,7 +18,6 @@
 use Tubee\Resource\AbstractResource;
 use Tubee\Resource\AttributeResolver;
 use Tubee\V8\Engine as V8Engine;
-use Tubee\Workflow\Map;
 use Tubee\Workflow\WorkflowInterface;
 use V8Js;
 

Indentation +1 added lines, -1 removed lines

@@ -121,7 +121,7 @@
                 'namespace' => ['href' => (string) $request->getUri()->withPath('/api/v1/namespaces/'.$namespace)],
                 'collection' => ['href' => (string) $request->getUri()->withPath('/api/v1/namespaces/'.$namespace.'/collections/'.$collection)],
                 'endpoint' => ['href' => (string) $request->getUri()->withPath('/api/v1/namespaces/'.$namespace.'/collections/'.$collection.'/endpoints/'.$endpoint)],
-           ],
+            ],
             'namespace' => $namespace,
             'collection' => $collection,
             'endpoint' => $endpoint,

src/lib/Workflow/Factory.php

Doc Comments +2 added lines

@@ -146,6 +146,8 @@
 
     /**
      * Change stream.
+     * @param integer $offset
+     * @param integer $limit
      */
     public function watch(EndpointInterface $endpoint, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
     {

Spacing +2 added lines, -2 removed lines

@@ -88,7 +88,7 @@ 
         $filter = $this->prepareQuery($endpoint, $query);
         $that = $this;
 
-        return $this->resource_factory->getAllFrom($this->db->{self::COLLECTION_NAME}, $filter, $offset, $limit, $sort, function (array $resource) use ($endpoint, $that) {
+        return $this->resource_factory->getAllFrom($this->db->{self::COLLECTION_NAME}, $filter, $offset, $limit, $sort, function(array $resource) use ($endpoint, $that) {
             return $that->build($resource, $endpoint);
         });
     }
@@ -166,7 +166,7 @@ 
         $filter = $this->prepareQuery($endpoint, $query);
         $that = $this;
 
-        return $this->resource_factory->watchFrom($this->db->{self::COLLECTION_NAME}, $after, $existing, $filter, function (array $resource) use ($endpoint, $that) {
+        return $this->resource_factory->watchFrom($this->db->{self::COLLECTION_NAME}, $after, $existing, $filter, function(array $resource) use ($endpoint, $that) {
             return $that->build($resource, $endpoint);
         }, $offset, $limit, $sort);
     }

src/lib/Resource/Factory.php

Doc Comments +2 added lines

@@ -191,6 +191,7 @@ 
 
     /**
      * Get all.
+     * @param Closure $build
      */
     public function getAllFrom(Collection $collection, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null, ?Closure $build = null): Generator
     {
@@ -217,6 +218,7 @@ 
 
     /**
      * Change stream.
+     * @param Closure $build
      */
     public function watchFrom(Collection $collection, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = [], ?Closure $build = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
     {

src/lib/User/Factory.php

Spacing +2 added lines, -2 removed lines

@@ -101,7 +101,7 @@ 
     {
         $that = $this;
 
-        return $this->resource_factory->getAllFrom($this->db->{self::COLLECTION_NAME}, $query, $offset, $limit, $sort, function (array $resource) use ($that) {
+        return $this->resource_factory->getAllFrom($this->db->{self::COLLECTION_NAME}, $query, $offset, $limit, $sort, function(array $resource) use ($that) {
             return $that->build($resource);
         });
     }
@@ -173,7 +173,7 @@ 
     {
         $that = $this;
 
-        return $this->resource_factory->watchFrom($this->db->{self::COLLECTION_NAME}, $after, $existing, $query, function (array $resource) use ($that) {
+        return $this->resource_factory->watchFrom($this->db->{self::COLLECTION_NAME}, $after, $existing, $query, function(array $resource) use ($that) {
             return $that->build($resource);
         }, $offset, $limit, $sort);
     }

src/lib/AccessRule/Factory.php

Spacing +2 added lines, -2 removed lines

@@ -62,7 +62,7 @@ 
     {
         $that = $this;
 
-        return $this->resource_factory->getAllFrom($this->db->{self::COLLECTION_NAME}, $query, $offset, $limit, $sort, function ($resource) use ($that) {
+        return $this->resource_factory->getAllFrom($this->db->{self::COLLECTION_NAME}, $query, $offset, $limit, $sort, function($resource) use ($that) {
             return $that->build($resource);
         });
     }
@@ -130,7 +130,7 @@ 
     {
         $that = $this;
 
-        return $this->resource_factory->watchFrom($this->db->{self::COLLECTION_NAME}, $after, $existing, $query, function ($resource) use ($that) {
+        return $this->resource_factory->watchFrom($this->db->{self::COLLECTION_NAME}, $after, $existing, $query, function($resource) use ($that) {
             return $that->build($resource);
         }, $offset, $limit, $sort);
     }

src/lib/DataObject/Factory.php

Doc Comments +2 added lines

@@ -216,6 +216,8 @@
 
     /**
      * Change stream.
+     * @param integer $offset
+     * @param integer $limit
      */
     public function watch(CollectionInterface $collection, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
     {

Spacing +2 added lines, -2 removed lines

@@ -141,7 +141,7 @@ 
     {
         $that = $this;
 
-        return $this->resource_factory->getAllFrom($this->db->{$collection->getCollection()}, $query, $offset, $limit, $sort, function (array $resource) use ($collection, $that) {
+        return $this->resource_factory->getAllFrom($this->db->{$collection->getCollection()}, $query, $offset, $limit, $sort, function(array $resource) use ($collection, $that) {
             return $that->build($resource, $collection);
         });
     }
@@ -221,7 +221,7 @@ 
     {
         $that = $this;
 
-        return $this->resource_factory->watchFrom($this->db->{$collection->getCollection()}, $after, $existing, $query, function (array $resource) use ($collection, $that) {
+        return $this->resource_factory->watchFrom($this->db->{$collection->getCollection()}, $after, $existing, $query, function(array $resource) use ($collection, $that) {
             return $that->build($resource, $collection);
         }, $offset, $limit, $sort);
     }

src/lib/Job/Factory.php

Spacing +2 added lines, -2 removed lines

@@ -93,7 +93,7 @@ 
         $filter = $this->prepareQuery($namespace, $query);
         $that = $this;
 
-        return $this->resource_factory->getAllFrom($this->db->{self::COLLECTION_NAME}, $filter, $offset, $limit, $sort, function (array $resource) use ($namespace, $that) {
+        return $this->resource_factory->getAllFrom($this->db->{self::COLLECTION_NAME}, $filter, $offset, $limit, $sort, function(array $resource) use ($namespace, $that) {
             return $that->build($resource, $namespace);
         });
     }
@@ -230,7 +230,7 @@ 
         $filter = $this->prepareQuery($namespace, $query);
         $that = $this;
 
-        return $this->resource_factory->watchFrom($this->db->{self::COLLECTION_NAME}, $after, $existing, $filter, function (array $resource) use ($namespace, $that) {
+        return $this->resource_factory->watchFrom($this->db->{self::COLLECTION_NAME}, $after, $existing, $filter, function(array $resource) use ($namespace, $that) {
             return $that->build($resource, $namespace);
         }, $offset, $limit, $sort);
     }