@@ -958,9 +958,9 @@ |
||
958 | 958 | $node->zip($archive); |
959 | 959 | } catch (\Exception $e) { |
960 | 960 | $this->logger->debug('failed zip node in multi node request ['.$node->getId().']', [ |
961 | - 'category' => get_class($this), |
|
962 | - 'exception' => $e, |
|
963 | - ]); |
|
961 | + 'category' => get_class($this), |
|
962 | + 'exception' => $e, |
|
963 | + ]); |
|
964 | 964 | } |
965 | 965 | } |
966 | 966 |
@@ -102,7 +102,7 @@ discard block |
||
102 | 102 | } |
103 | 103 | } |
104 | 104 | |
105 | - return $this->bulk($id, function ($node) use ($parent, $conflict, $move) { |
|
105 | + return $this->bulk($id, function($node) use ($parent, $conflict, $move) { |
|
106 | 106 | if (true === $move) { |
107 | 107 | $node = $node->setParent($parent, $conflict); |
108 | 108 | } |
@@ -169,7 +169,7 @@ discard block |
||
169 | 169 | return (new Response())->setCode(200)->setBody($result); |
170 | 170 | } |
171 | 171 | |
172 | - return $this->bulk($id, function ($node) use ($attributes) { |
|
172 | + return $this->bulk($id, function($node) use ($attributes) { |
|
173 | 173 | return [ |
174 | 174 | 'code' => 200, |
175 | 175 | 'data' => $this->node_decorator->decorate($node, $attributes), |
@@ -205,11 +205,11 @@ discard block |
||
205 | 205 | public function patch(string $id, ?string $name = null, ?array $meta = null, ?bool $readonly = null, ?array $filter = null, ?array $acl = null, $lock = null): Response |
206 | 206 | { |
207 | 207 | $attributes = compact('name', 'meta', 'readonly', 'filter', 'acl', 'lock'); |
208 | - $attributes = array_filter($attributes, function ($attribute) {return !is_null($attribute); }); |
|
208 | + $attributes = array_filter($attributes, function($attribute) {return !is_null($attribute); }); |
|
209 | 209 | |
210 | 210 | $lock = $_SERVER['HTTP_LOCK_TOKEN'] ?? null; |
211 | 211 | |
212 | - return $this->bulk($id, function ($node) use ($attributes, $lock) { |
|
212 | + return $this->bulk($id, function($node) use ($attributes, $lock) { |
|
213 | 213 | foreach ($attributes as $attribute => $value) { |
214 | 214 | switch ($attribute) { |
215 | 215 | case 'name': |
@@ -269,7 +269,7 @@ discard block |
||
269 | 269 | ); |
270 | 270 | } |
271 | 271 | |
272 | - return $this->bulk($id, function ($node) use ($parent, $conflict) { |
|
272 | + return $this->bulk($id, function($node) use ($parent, $conflict) { |
|
273 | 273 | $result = $node->copyTo($parent, $conflict); |
274 | 274 | |
275 | 275 | return [ |
@@ -296,7 +296,7 @@ discard block |
||
296 | 296 | ); |
297 | 297 | } |
298 | 298 | |
299 | - return $this->bulk($id, function ($node) use ($parent, $conflict) { |
|
299 | + return $this->bulk($id, function($node) use ($parent, $conflict) { |
|
300 | 300 | $result = $node->setParent($parent, $conflict); |
301 | 301 | |
302 | 302 | return [ |
@@ -321,7 +321,7 @@ discard block |
||
321 | 321 | $at = $this->_verifyAttributes(['destroy' => $at])['destroy']; |
322 | 322 | } |
323 | 323 | |
324 | - return $this->bulk($id, function ($node) use ($force, $ignore_flag, $at) { |
|
324 | + return $this->bulk($id, function($node) use ($force, $ignore_flag, $at) { |
|
325 | 325 | if (null === $at) { |
326 | 326 | $node->delete($force && $node->isDeleted() || $force && $ignore_flag); |
327 | 327 | } else { |
@@ -477,6 +477,8 @@ |
||
477 | 477 | |
478 | 478 | /** |
479 | 479 | * Get custom filtered children. |
480 | + * @param integer $offset |
|
481 | + * @param integer $limit |
|
480 | 482 | */ |
481 | 483 | public function findNodesByFilterUser(int $deleted, array $filter, ?int $offset = null, ?int $limit = null): Generator |
482 | 484 | { |
@@ -89,6 +89,8 @@ |
||
89 | 89 | |
90 | 90 | /** |
91 | 91 | * Get slaves. |
92 | + * @param integer $offset |
|
93 | + * @param integer $limit |
|
92 | 94 | */ |
93 | 95 | public function getSlaves(File $node, array $query = [], ?int $offset = null, ?int $limit = null, ?int &$total = null): iterable |
94 | 96 | { |
@@ -93,6 +93,7 @@ discard block |
||
93 | 93 | |
94 | 94 | /** |
95 | 95 | * Send notification. |
96 | + * @param User $sender |
|
96 | 97 | */ |
97 | 98 | public function notify(iterable $receiver, ?User $sender, MessageInterface $message): bool |
98 | 99 | { |
@@ -180,6 +181,7 @@ discard block |
||
180 | 181 | |
181 | 182 | /** |
182 | 183 | * Add notification. |
184 | + * @param User $sender |
|
183 | 185 | */ |
184 | 186 | public function postNotification(User $receiver, ?User $sender, MessageInterface $message): ObjectId |
185 | 187 | { |
@@ -206,6 +208,8 @@ discard block |
||
206 | 208 | |
207 | 209 | /** |
208 | 210 | * Get notifications. |
211 | + * @param integer $offset |
|
212 | + * @param integer $limit |
|
209 | 213 | */ |
210 | 214 | public function getNotifications(User $user, array $query = [], ?int $offset = null, ?int $limit = null, ?int &$total = null): iterable |
211 | 215 | { |
@@ -288,6 +292,7 @@ discard block |
||
288 | 292 | |
289 | 293 | /** |
290 | 294 | * Get subscription. |
295 | + * @return NodeInterface |
|
291 | 296 | */ |
292 | 297 | public function getSubscription(NodeInterface $node, User $user): ?array |
293 | 298 | { |
@@ -98,6 +98,7 @@ discard block |
||
98 | 98 | |
99 | 99 | /** |
100 | 100 | * Build a single dimension array with all nodes. |
101 | + * @param integer[] $cursor |
|
101 | 102 | */ |
102 | 103 | public function buildFeedFromCurrentState(?array $cursor = null, int $limit = 100, ?NodeInterface $node = null): array |
103 | 104 | { |
@@ -220,6 +221,7 @@ discard block |
||
220 | 221 | |
221 | 222 | /** |
222 | 223 | * Get delta feed with changes and cursor. |
224 | + * @param NodeInterface $node |
|
223 | 225 | */ |
224 | 226 | public function getDeltaFeed(?string $cursor = null, int $limit = 250, ?NodeInterface $node = null): array |
225 | 227 | { |
@@ -327,6 +329,7 @@ discard block |
||
327 | 329 | |
328 | 330 | /** |
329 | 331 | * Get event log. |
332 | + * @param NodeInterface $node |
|
330 | 333 | */ |
331 | 334 | public function getEventLog(array $query = [], int $limit = 100, int $skip = 0, ?NodeInterface $node = null, ?int &$total = null): iterable |
332 | 335 | { |
@@ -584,6 +587,7 @@ discard block |
||
584 | 587 | |
585 | 588 | /** |
586 | 589 | * Get children with custom filter. |
590 | + * @param integer $limit |
|
587 | 591 | */ |
588 | 592 | protected function findNodeAttributesWithCustomFilter( |
589 | 593 | ?array $filter = null, |
@@ -1113,6 +1113,8 @@ |
||
1113 | 1113 | |
1114 | 1114 | /** |
1115 | 1115 | * Duplicate name with a uniqid within name. |
1116 | + * @param string $name |
|
1117 | + * @param string $class |
|
1116 | 1118 | */ |
1117 | 1119 | public function getDuplicateName(?string $name = null, ?string $class = null): string |
1118 | 1120 | { |
@@ -1144,7 +1144,7 @@ |
||
1144 | 1144 | protected function prepareLock(string $identifier, int $ttl = 1800): array |
1145 | 1145 | { |
1146 | 1146 | return [ |
1147 | - 'owner' => $this->_user->getId(), |
|
1147 | + 'owner' => $this->_user->getId(), |
|
1148 | 1148 | 'created' => new UTCDateTime(), |
1149 | 1149 | 'id' => $identifier, |
1150 | 1150 | 'expire' => new UTCDateTime((time() + $ttl) * 1000), |
@@ -12,7 +12,6 @@ |
||
12 | 12 | namespace Balloon\Migration\Delta; |
13 | 13 | |
14 | 14 | use MongoDB\Database; |
15 | -use MongoDB\Driver\Exception\CommandException; |
|
16 | 15 | use MongoDB\Driver\Exception\RuntimeException; |
17 | 16 | |
18 | 17 | class CreateUniqueUserMailIndex implements DeltaInterface |
@@ -103,7 +103,7 @@ |
||
103 | 103 | //'FileSharingUrl' => null, |
104 | 104 | //'FileUrl' => null, |
105 | 105 | 'FileVersionPostMessage' => true, |
106 | - // 'FileSharingPostMessage' => null, |
|
106 | + // 'FileSharingPostMessage' => null, |
|
107 | 107 | 'PostMessageOrigin' => $this->session['client'], |
108 | 108 | 'OwnerId' => (string) $this->file->getOwner(), |
109 | 109 | 'ReadOnly' => $this->file->isReadonly(), |
@@ -263,7 +263,7 @@ |
||
263 | 263 | $response = (new Response()) |
264 | 264 | ->setCode(200) |
265 | 265 | ->setHeader('X-WOPI-ItemVersion', (string) $file->getVersion()) |
266 | - ->setBody(function () use ($stream) { |
|
266 | + ->setBody(function() use ($stream) { |
|
267 | 267 | if ($stream === null) { |
268 | 268 | echo ''; |
269 | 269 |