@@ -143,7 +143,7 @@ discard block |
||
143 | 143 | public function getAllFrom(Collection $collection, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null, ?Closure $build = null): Generator |
144 | 144 | { |
145 | 145 | if ($build === null) { |
146 | - $build = function ($resource) { |
|
146 | + $build = function($resource) { |
|
147 | 147 | return $this->build($resource); |
148 | 148 | }; |
149 | 149 | } |
@@ -170,7 +170,7 @@ discard block |
||
170 | 170 | 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 |
171 | 171 | { |
172 | 172 | if ($build === null) { |
173 | - $build = function ($resource) { |
|
173 | + $build = function($resource) { |
|
174 | 174 | return $this->build($resource); |
175 | 175 | }; |
176 | 176 | } |
@@ -79,7 +79,7 @@ |
||
79 | 79 | ]; |
80 | 80 | } |
81 | 81 | |
82 | - return $this->getAllFrom($this->db->{self::COLLECTION_NAME}, $filter, $offset, $limit, $sort, function (array $resource) use ($namespace) { |
|
82 | + return $this->getAllFrom($this->db->{self::COLLECTION_NAME}, $filter, $offset, $limit, $sort, function(array $resource) use ($namespace) { |
|
83 | 83 | return $this->build($resource, $namespace); |
84 | 84 | }); |
85 | 85 | } |
@@ -116,7 +116,7 @@ discard block |
||
116 | 116 | */ |
117 | 117 | public function getAll(CollectionInterface $collection, ?array $query = null, bool $include_dataset = true, ?int $offset = 0, ?int $limit = 0, ?array $sort = ['$natural' => -1]): Generator |
118 | 118 | { |
119 | - return $this->getAllFrom($this->db->{$collection->getCollection()}, $query, $offset, $limit, $sort, function (array $resource) use ($collection) { |
|
119 | + return $this->getAllFrom($this->db->{$collection->getCollection()}, $query, $offset, $limit, $sort, function(array $resource) use ($collection) { |
|
120 | 120 | return $this->build($resource, $collection); |
121 | 121 | }); |
122 | 122 | } |
@@ -188,7 +188,7 @@ discard block |
||
188 | 188 | */ |
189 | 189 | public function watch(CollectionInterface $collection, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator |
190 | 190 | { |
191 | - return $this->watchFrom($this->db->{$collection->getCollection()}, $after, $existing, $query, function (array $resource) use ($collection) { |
|
191 | + return $this->watchFrom($this->db->{$collection->getCollection()}, $after, $existing, $query, function(array $resource) use ($collection) { |
|
192 | 192 | return $this->build($collection, $resource); |
193 | 193 | }, $offset, $limit, $sort); |
194 | 194 | } |
@@ -178,7 +178,7 @@ discard block |
||
178 | 178 | 'namespace' => $namespace, |
179 | 179 | 'collection' => $collection, |
180 | 180 | 'data' => $this->getData(), |
181 | - 'status' => function ($endpoint) { |
|
181 | + 'status' => function($endpoint) { |
|
182 | 182 | try { |
183 | 183 | $endpoint->setup(); |
184 | 184 | |
@@ -334,7 +334,7 @@ discard block |
||
334 | 334 | */ |
335 | 335 | private function parseAttribute(string $string, array $data): string |
336 | 336 | { |
337 | - return preg_replace_callback('/(\{(([^\}\{\"]*)+)\})/', function ($match) use ($string, $data) { |
|
337 | + return preg_replace_callback('/(\{(([^\}\{\"]*)+)\})/', function($match) use ($string, $data) { |
|
338 | 338 | if (substr($match[0], 0, 2) === '{{' && $match[4][0] === '}') { |
339 | 339 | return $match[2].$match[4]; |
340 | 340 | } |
@@ -93,7 +93,7 @@ |
||
93 | 93 | protected function registerFunctions(): void |
94 | 94 | { |
95 | 95 | $this->crypt = [ |
96 | - 'hash' => function ($algo, $data, $raw_output = false) { |
|
96 | + 'hash' => function($algo, $data, $raw_output = false) { |
|
97 | 97 | return hash($algo, $data, $raw_output); |
98 | 98 | }, |
99 | 99 | ]; |
@@ -73,7 +73,7 @@ discard block |
||
73 | 73 | $query = $request->getQueryParams(); |
74 | 74 | $options = isset($query['pretty']) ? JSON_PRETTY_PRINT : 0; |
75 | 75 | |
76 | - $stream = new StreamIterator($cursor, function ($resource) use ($request, $options) { |
|
76 | + $stream = new StreamIterator($cursor, function($resource) use ($request, $options) { |
|
77 | 77 | if ($this->tell() === 0) { |
78 | 78 | echo '['; |
79 | 79 | } else { |
@@ -106,7 +106,7 @@ discard block |
||
106 | 106 | $query = $request->getQueryParams(); |
107 | 107 | $options = isset($query['pretty']) ? JSON_PRETTY_PRINT : 0; |
108 | 108 | |
109 | - $stream = new StreamIterator($cursor, function ($event) use ($request, $options) { |
|
109 | + $stream = new StreamIterator($cursor, function($event) use ($request, $options) { |
|
110 | 110 | if ($this->tell() === 0) { |
111 | 111 | echo '['; |
112 | 112 | } else { |
@@ -84,7 +84,7 @@ |
||
84 | 84 | 'kind' => 'Job', |
85 | 85 | 'namespace' => $this->namespace->getName(), |
86 | 86 | 'data' => $this->getData(), |
87 | - 'status' => function () use ($resource, $scheduler) { |
|
87 | + 'status' => function() use ($resource, $scheduler) { |
|
88 | 88 | $process = iterator_to_array($scheduler->getJobs([ |
89 | 89 | 'data.job' => $resource->getName(), |
90 | 90 | 'data.parent' => ['$exists' => false], |