gyselroth / tubee

src/lib/V8/Engine.php

Spacing +1 added lines, -1 removed lines

@@ -93,7 +93,7 @@
     protected function registerFunctions(): void
     {
         $this->crypt = [
-            'hash' => function ($algo, $data, $raw_output = false) {
+            'hash' => function($algo, $data, $raw_output = false) {
                 return hash($algo, $data, $raw_output);
             },
         ];

src/lib/Rest/Helper.php

Spacing +2 added lines, -2 removed lines

@@ -73,7 +73,7 @@ 
         $query = $request->getQueryParams();
         $options = isset($query['pretty']) ? JSON_PRETTY_PRINT : 0;
 
-        $stream = new StreamIterator($cursor, function ($resource) use ($request, $options) {
+        $stream = new StreamIterator($cursor, function($resource) use ($request, $options) {
             if ($this->tell() === 0) {
                 echo  '[';
             } else {
@@ -106,7 +106,7 @@ 
         $query = $request->getQueryParams();
         $options = isset($query['pretty']) ? JSON_PRETTY_PRINT : 0;
 
-        $stream = new StreamIterator($cursor, function ($event) use ($request, $options) {
+        $stream = new StreamIterator($cursor, function($event) use ($request, $options) {
             if ($this->tell() === 0) {
                 echo  '[';
             } else {

src/lib/Job.php

Spacing +1 added lines, -1 removed lines

@@ -84,7 +84,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->getName(),
                     'data.parent' => ['$exists' => false],

src/lib/Secret.php

Indentation +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
             'kind' => 'Secret',
             'namespace' => $this->namespace->getName(),
             'data' => $this->getData(),
-       ];
+        ];
 
         return AttributeResolver::resolve($request, $this, $resource);
     }

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

@@ -82,7 +82,7 @@ 
 
         $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);
         });
     }
@@ -140,7 +140,7 @@ 
     {
         $that = $this;
 
-        return $this->resource_factory->watchFrom($this->db->{$this->scheduler->getJobQueue()}, $after, $existing, $query, function (array $resource) use ($namespace, $that) {
+        return $this->resource_factory->watchFrom($this->db->{$this->scheduler->getJobQueue()}, $after, $existing, $query, function(array $resource) use ($namespace, $that) {
             return $that->build($resource, $namespace);
         }, $offset, $limit, $sort);
     }

src/lib/Endpoint/Ucs.php

Doc Comments +2 added lines

@@ -375,6 +375,7 @@ 
 
     /**
      * Parse response.
+     * @param \Psr\Http\Message\ResponseInterface $response
      */
     protected function parse($response): array
     {
@@ -409,6 +410,7 @@ 
 
     /**
      * Get identifier.
+     * @return string
      */
     protected function getResourceId(array $object, array $endpoint_object = []): ?string
     {

src/lib/Job/Factory.php

Doc Comments +4 added lines

@@ -64,6 +64,8 @@ 
 
     /**
      * Get all.
+     * @param integer $offset
+     * @param integer $limit
      */
     public function getAll(ResourceNamespaceInterface $namespace, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
     {
@@ -183,6 +185,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

@@ -93,7 +93,7 @@ 
 
         $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);
         });
     }
@@ -204,7 +204,7 @@ 
     {
         $that = $this;
 
-        return $this->resource_factory->watchFrom($this->db->{self::COLLECTION_NAME}, $after, $existing, $query, function (array $resource) use ($namespace, $that) {
+        return $this->resource_factory->watchFrom($this->db->{self::COLLECTION_NAME}, $after, $existing, $query, 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,