gyselroth / tubee

src/lib/DataObjectRelation/Factory.php

Doc Comments +8 added lines

@@ -131,6 +131,10 @@ 
 
     /**
      * {@inheritdoc}
+     * @param integer $query
+     * @param integer $offset
+     * @param integer $limit
+     * @param integer $sort
      */
     public function getAll(ResourceNamespaceInterface $namespace, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
     {
@@ -235,6 +239,9 @@ 
 
     /**
      * Change stream.
+     * @param boolean $after
+     * @param boolean $query
+     * @param boolean $offset
      */
     public function watch(ResourceNamespaceInterface $namespace, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
     {
@@ -245,6 +252,7 @@ 
 
     /**
      * Build.
+     * @param DataObjectInterface $object
      */
     public function build(array $resource, ?DataObjectInterface $object = null): DataObjectRelationInterface
     {

Spacing +3 added lines, -3 removed lines

@@ -114,7 +114,7 @@ 
             ];
         }
 
-        return $this->getAllFrom($this->db->{self::COLLECTION_NAME}, $filter, $offset, $limit, $sort, function (array $resource) use ($object, $relation) {
+        return $this->getAllFrom($this->db->{self::COLLECTION_NAME}, $filter, $offset, $limit, $sort, function(array $resource) use ($object, $relation) {
             $object_1 = $resource['data']['relation'][0];
             $object_2 = $resource['data']['relation'][1];
             $related = $object_1;
@@ -144,7 +144,7 @@ 
             ];
         }
 
-        return $this->getAllFrom($this->db->{self::COLLECTION_NAME}, $filter, $offset, $limit, $sort, function (array $resource) {
+        return $this->getAllFrom($this->db->{self::COLLECTION_NAME}, $filter, $offset, $limit, $sort, function(array $resource) {
             return $this->build($resource);
         });
     }
@@ -238,7 +238,7 @@ 
      */
     public function watch(ResourceNamespaceInterface $namespace, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
     {
-        return $this->watchFrom($this->db->{self::COLLECTION_NAME}, $after, $existing, $query, function (array $resource) {
+        return $this->watchFrom($this->db->{self::COLLECTION_NAME}, $after, $existing, $query, function(array $resource) {
             return $this->build($resource);
         }, $offset, $limit, $sort);
     }

src/lib/Endpoint/Ucs.php

Doc Comments +1 added lines

@@ -409,6 +409,7 @@
 
     /**
      * Get identifier.
+     * @return string
      */
     protected function getResourceId(array $object, array $endpoint_object = []): ?string
     {

src/lib/Job/Factory.php

Doc Comments +8 added lines

@@ -64,6 +64,10 @@ 
 
     /**
      * Get all.
+     * @param integer $query
+     * @param integer $offset
+     * @param integer $limit
+     * @param integer $sort
      */
     public function getAll(ResourceNamespaceInterface $namespace, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
     {
@@ -174,6 +178,10 @@ 
 
     /**
      * Change stream.
+     * @param boolean $query
+     * @param boolean $offset
+     * @param boolean $limit
+     * @param boolean $sort
      */
     public function watch(ResourceNamespaceInterface $namespace, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
     {

src/lib/Process/Factory.php

Doc Comments +4 added lines

@@ -106,6 +106,10 @@
 
     /**
      * Change stream.
+     * @param boolean $query
+     * @param boolean $offset
+     * @param boolean $limit
+     * @param boolean $sort
      */
     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

@@ -66,7 +66,7 @@ 
             ];
         }
 
-        return $this->getAllFrom($this->db->{$this->scheduler->getJobQueue()}, $filter, $offset, $limit, $sort, function (array $resource) use ($namespace) {
+        return $this->getAllFrom($this->db->{$this->scheduler->getJobQueue()}, $filter, $offset, $limit, $sort, function(array $resource) use ($namespace) {
             return $this->build($resource, $namespace);
         });
     }
@@ -109,7 +109,7 @@ 
      */
     public function watch(ResourceNamespaceInterface $namespace, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
     {
-        return $this->watchFrom($this->db->{$this->scheduler->getJobQueue()}, $after, $existing, $query, function (array $resource) use ($namespace) {
+        return $this->watchFrom($this->db->{$this->scheduler->getJobQueue()}, $after, $existing, $query, function(array $resource) use ($namespace) {
             return $this->build($resource, $namespace);
         }, $offset, $limit, $sort);
     }

src/lib/DataObjectRelation.php

Indentation +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
     {
         $resource = [
             '_links' => [
-                 'self' => ['href' => (string) $request->getUri()],
+                    'self' => ['href' => (string) $request->getUri()],
             ],
             'kind' => 'DataObjectRelation',
             'namespace' => $this->resource['namespace'],

Spacing +1 added lines, -1 removed lines

@@ -52,7 +52,7 @@
         $object = $this->object;
 
         if ($object !== null) {
-            $resource['status']['object'] = function () use ($object, $request) {
+            $resource['status']['object'] = function() use ($object, $request) {
                 return $object->decorate($request);
             };
         }

src/lib/Job.php

Spacing +1 added lines, -1 removed lines

@@ -83,7 +83,7 @@
             'kind' => 'Job',
             'namespace' => $this->namespace->getName(),
             'data' => $this->getData(),
-            'status' => function () use ($resource, $scheduler) {
+            'status' => function() use ($resource, $scheduler) {
                 $process = iterator_to_array($scheduler->getJobs([
                     'data.job' => $resource->getId(),
                 ]));

src/lib/DataObject/Factory.php

Spacing +2 added lines, -2 removed lines

@@ -117,7 +117,7 @@ 
      */
     public function getAll(CollectionInterface $collection, ?array $query = null, bool $include_dataset = true, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
     {
-        return $this->getAllFrom($this->db->{$collection->getCollection()}, $query, $offset, $limit, $sort, function (array $resource) use ($collection) {
+        return $this->getAllFrom($this->db->{$collection->getCollection()}, $query, $offset, $limit, $sort, function(array $resource) use ($collection) {
             return $this->build($resource, $collection);
         });
     }
@@ -191,7 +191,7 @@ 
      */
     public function watch(CollectionInterface $collection, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
     {
-        return $this->watchFrom($this->db->{$collection->getCollection()}, $after, $existing, $query, function (array $resource) use ($collection) {
+        return $this->watchFrom($this->db->{$collection->getCollection()}, $after, $existing, $query, function(array $resource) use ($collection) {
             return $this->build($collection, $resource);
         }, $offset, $limit, $sort);
     }

src/httpdocs/index.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
 $request = Zend\Diactoros\ServerRequestFactory::fromGlobals();
 $logger = $dic->get(Psr\Log\LoggerInterface::class);
 
-set_exception_handler(function ($e) use ($logger) {
+set_exception_handler(function($e) use ($logger) {
     http_response_code(500);
     $logger->emergency('uncaught exception: '.$e->getMessage(), [
         'category' => 'Http',