@@ -52,7 +52,7 @@ |
||
52 | 52 | $object = $this->object; |
53 | 53 | |
54 | 54 | if ($object !== null) { |
55 | - $resource['status']['object'] = function () use ($object, $request) { |
|
55 | + $resource['status']['object'] = function() use ($object, $request) { |
|
56 | 56 | return $object->decorate($request); |
57 | 57 | }; |
58 | 58 | } |
@@ -66,7 +66,7 @@ discard block |
||
66 | 66 | ]; |
67 | 67 | } |
68 | 68 | |
69 | - return $this->getAllFrom($this->db->{$this->scheduler->getJobQueue()}, $filter, $offset, $limit, $sort, function (array $resource) use ($namespace) { |
|
69 | + return $this->getAllFrom($this->db->{$this->scheduler->getJobQueue()}, $filter, $offset, $limit, $sort, function(array $resource) use ($namespace) { |
|
70 | 70 | return $this->build($resource, $namespace); |
71 | 71 | }); |
72 | 72 | } |
@@ -109,7 +109,7 @@ discard block |
||
109 | 109 | */ |
110 | 110 | public function watch(ResourceNamespaceInterface $namespace, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator |
111 | 111 | { |
112 | - return $this->watchFrom($this->db->{$this->scheduler->getJobQueue()}, $after, $existing, $query, function (array $resource) use ($namespace) { |
|
112 | + return $this->watchFrom($this->db->{$this->scheduler->getJobQueue()}, $after, $existing, $query, function(array $resource) use ($namespace) { |
|
113 | 113 | return $this->build($resource, $namespace); |
114 | 114 | }, $offset, $limit, $sort); |
115 | 115 | } |
@@ -114,7 +114,7 @@ discard block |
||
114 | 114 | ]; |
115 | 115 | } |
116 | 116 | |
117 | - return $this->getAllFrom($this->db->{self::COLLECTION_NAME}, $filter, $offset, $limit, $sort, function (array $resource) use ($object, $relation) { |
|
117 | + return $this->getAllFrom($this->db->{self::COLLECTION_NAME}, $filter, $offset, $limit, $sort, function(array $resource) use ($object, $relation) { |
|
118 | 118 | $object_1 = $resource['data']['relation'][0]; |
119 | 119 | $object_2 = $resource['data']['relation'][1]; |
120 | 120 | $related = $object_1; |
@@ -144,7 +144,7 @@ discard block |
||
144 | 144 | ]; |
145 | 145 | } |
146 | 146 | |
147 | - return $this->getAllFrom($this->db->{self::COLLECTION_NAME}, $filter, $offset, $limit, $sort, function (array $resource) { |
|
147 | + return $this->getAllFrom($this->db->{self::COLLECTION_NAME}, $filter, $offset, $limit, $sort, function(array $resource) { |
|
148 | 148 | return $this->build($resource); |
149 | 149 | }); |
150 | 150 | } |
@@ -238,7 +238,7 @@ discard block |
||
238 | 238 | */ |
239 | 239 | public function watch(ResourceNamespaceInterface $namespace, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator |
240 | 240 | { |
241 | - return $this->watchFrom($this->db->{self::COLLECTION_NAME}, $after, $existing, $query, function (array $resource) { |
|
241 | + return $this->watchFrom($this->db->{self::COLLECTION_NAME}, $after, $existing, $query, function(array $resource) { |
|
242 | 242 | return $this->build($resource); |
243 | 243 | }, $offset, $limit, $sort); |
244 | 244 | } |
@@ -83,7 +83,7 @@ |
||
83 | 83 | 'kind' => 'Job', |
84 | 84 | 'namespace' => $this->namespace->getName(), |
85 | 85 | 'data' => $this->getData(), |
86 | - 'status' => function () use ($resource, $scheduler) { |
|
86 | + 'status' => function() use ($resource, $scheduler) { |
|
87 | 87 | $process = iterator_to_array($scheduler->getJobs([ |
88 | 88 | 'data.job' => $resource->getId(), |
89 | 89 | ])); |
@@ -117,7 +117,7 @@ discard block |
||
117 | 117 | */ |
118 | 118 | public function getAll(CollectionInterface $collection, ?array $query = null, bool $include_dataset = true, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator |
119 | 119 | { |
120 | - return $this->getAllFrom($this->db->{$collection->getCollection()}, $query, $offset, $limit, $sort, function (array $resource) use ($collection) { |
|
120 | + return $this->getAllFrom($this->db->{$collection->getCollection()}, $query, $offset, $limit, $sort, function(array $resource) use ($collection) { |
|
121 | 121 | return $this->build($resource, $collection); |
122 | 122 | }); |
123 | 123 | } |
@@ -191,7 +191,7 @@ discard block |
||
191 | 191 | */ |
192 | 192 | public function watch(CollectionInterface $collection, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator |
193 | 193 | { |
194 | - return $this->watchFrom($this->db->{$collection->getCollection()}, $after, $existing, $query, function (array $resource) use ($collection) { |
|
194 | + return $this->watchFrom($this->db->{$collection->getCollection()}, $after, $existing, $query, function(array $resource) use ($collection) { |
|
195 | 195 | return $this->build($collection, $resource); |
196 | 196 | }, $offset, $limit, $sort); |
197 | 197 | } |
@@ -31,7 +31,7 @@ |
||
31 | 31 | $request = Zend\Diactoros\ServerRequestFactory::fromGlobals(); |
32 | 32 | $logger = $dic->get(Psr\Log\LoggerInterface::class); |
33 | 33 | |
34 | -set_exception_handler(function ($e) use ($logger) { |
|
34 | +set_exception_handler(function($e) use ($logger) { |
|
35 | 35 | http_response_code(500); |
36 | 36 | $logger->emergency('uncaught exception: '.$e->getMessage(), [ |
37 | 37 | 'category' => 'Http', |