@@ -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 { |
@@ -656,6 +656,7 @@ |
||
| 656 | 656 | |
| 657 | 657 | /** |
| 658 | 658 | * Create new file as a child from this collection. |
| 659 | + * @param string $name |
|
| 659 | 660 | */ |
| 660 | 661 | public function addFile($name, ?ObjectId $session = null, array $attributes = [], int $conflict = NodeInterface::CONFLICT_NOACTION, bool $clone = false): File |
| 661 | 662 | { |
@@ -348,6 +348,7 @@ |
||
| 348 | 348 | |
| 349 | 349 | /** |
| 350 | 350 | * Get stored file. |
| 351 | + * @param string $hash |
|
| 351 | 352 | */ |
| 352 | 353 | protected function getFileByHash(?string $hash): ?array |
| 353 | 354 | { |
@@ -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 |