| @@ -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 | } | 
| @@ -185,6 +185,9 @@ | ||
| 185 | 185 | |
| 186 | 186 | /** | 
| 187 | 187 | * Change stream. | 
| 188 | + * @param boolean $offset | |
| 189 | + * @param integer $limit | |
| 190 | + * @param integer $sort | |
| 188 | 191 | */ | 
| 189 | 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 | 
| 190 | 193 |      { | 
| @@ -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 | } | 
| @@ -133,6 +133,8 @@ discard block | ||
| 133 | 133 | |
| 134 | 134 | /** | 
| 135 | 135 |       * {@inheritdoc} | 
| 136 | + * @param integer $offset | |
| 137 | + * @param integer $limit | |
| 136 | 138 | */ | 
| 137 | 139 | public function getAll(ResourceNamespaceInterface $namespace, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator | 
| 138 | 140 |      { | 
| @@ -266,6 +268,7 @@ discard block | ||
| 266 | 268 | |
| 267 | 269 | /** | 
| 268 | 270 | * Build. | 
| 271 | + * @param DataObjectInterface $object | |
| 269 | 272 | */ | 
| 270 | 273 | public function build(array $resource, ?DataObjectInterface $object = null): DataObjectRelationInterface | 
| 271 | 274 |      { | 
| @@ -180,6 +180,8 @@ | ||
| 180 | 180 | |
| 181 | 181 | /** | 
| 182 | 182 | * Change stream. | 
| 183 | + * @param integer $offset | |
| 184 | + * @param integer $limit | |
| 183 | 185 | */ | 
| 184 | 186 | public function watch(ResourceNamespaceInterface $namespace, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator | 
| 185 | 187 |      { | 
| @@ -118,6 +118,8 @@ | ||
| 118 | 118 | |
| 119 | 119 | /** | 
| 120 | 120 | * Change stream. | 
| 121 | + * @param integer $offset | |
| 122 | + * @param integer $limit | |
| 121 | 123 | */ | 
| 122 | 124 | public function watch(ResourceNamespaceInterface $namespace, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator | 
| 123 | 125 |      { | 
| @@ -177,6 +177,8 @@ | ||
| 177 | 177 | |
| 178 | 178 | /** | 
| 179 | 179 | * Change stream. | 
| 180 | + * @param integer $offset | |
| 181 | + * @param integer $limit | |
| 180 | 182 | */ | 
| 181 | 183 | public function watch(ResourceNamespaceInterface $namespace, ?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator | 
| 182 | 184 |      { | 
| @@ -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 | } | 
| @@ -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 { |