@@ -531,7 +531,7 @@ discard block |
||
531 | 531 | |
532 | 532 | $this->identity = $user; |
533 | 533 | $user->updateIdentity($identity) |
534 | - ->updateShares(); |
|
534 | + ->updateShares(); |
|
535 | 535 | $this->hook->run('postServerIdentity', [$user]); |
536 | 536 | |
537 | 537 | return true; |
@@ -662,7 +662,7 @@ discard block |
||
662 | 662 | public function getGroupByName(string $name): Group |
663 | 663 | { |
664 | 664 | $group = $this->db->group->findOne([ |
665 | - 'name' => $name, |
|
665 | + 'name' => $name, |
|
666 | 666 | ]); |
667 | 667 | |
668 | 668 | if (null === $group) { |
@@ -682,7 +682,7 @@ discard block |
||
682 | 682 | public function getGroupById(ObjectId $id): Group |
683 | 683 | { |
684 | 684 | $group = $this->db->group->findOne([ |
685 | - '_id' => $id, |
|
685 | + '_id' => $id, |
|
686 | 686 | ]); |
687 | 687 | |
688 | 688 | if (null === $group) { |
@@ -49,8 +49,8 @@ |
||
49 | 49 | $this->db->storage->updateOne( |
50 | 50 | ['_id' => $object['_id']], |
51 | 51 | [ |
52 | - '$unset' => ['sharelink' => 1], |
|
53 | - '$set' => ['app.Balloon\App\Sharelink' => $object['sharelink']], |
|
52 | + '$unset' => ['sharelink' => 1], |
|
53 | + '$set' => ['app.Balloon\App\Sharelink' => $object['sharelink']], |
|
54 | 54 | ] |
55 | 55 | ); |
56 | 56 | } |
@@ -341,7 +341,7 @@ |
||
341 | 341 | } |
342 | 342 | |
343 | 343 | $this->logger->debug('elasticsarch blob document ['.$result['_id'].'] has no references left, remove completely', [ |
344 | - 'category' => get_class($this), |
|
344 | + 'category' => get_class($this), |
|
345 | 345 | ]); |
346 | 346 | |
347 | 347 | return $this->deleteBlob($result['_id']); |
@@ -75,7 +75,7 @@ |
||
75 | 75 | |
76 | 76 | $this->logger->info('new group ['.$result.'] created', [ |
77 | 77 | 'category' => get_class($this), |
78 | - ]); |
|
78 | + ]); |
|
79 | 79 | |
80 | 80 | return true; |
81 | 81 | } |
@@ -49,7 +49,7 @@ |
||
49 | 49 | 'foreignField' => '_id', |
50 | 50 | 'localField' => 'history.storage._id', |
51 | 51 | 'as' => 'blob', |
52 | - ]], |
|
52 | + ]], |
|
53 | 53 | ]); |
54 | 54 | |
55 | 55 | foreach ($cursor as $object) { |
@@ -273,37 +273,37 @@ discard block |
||
273 | 273 | } |
274 | 274 | |
275 | 275 | return $response |
276 | - ->setOutputFormat(null) |
|
277 | - ->setBody(function () use ($node, $offset, $limit) { |
|
278 | - $stream = $node->get(); |
|
279 | - $name = $node->getName(); |
|
280 | - |
|
281 | - if (null === $stream) { |
|
282 | - return; |
|
283 | - } |
|
284 | - |
|
285 | - if (0 !== $offset) { |
|
286 | - if (fseek($stream, $offset) === -1) { |
|
287 | - throw new Exception\Conflict( |
|
276 | + ->setOutputFormat(null) |
|
277 | + ->setBody(function () use ($node, $offset, $limit) { |
|
278 | + $stream = $node->get(); |
|
279 | + $name = $node->getName(); |
|
280 | + |
|
281 | + if (null === $stream) { |
|
282 | + return; |
|
283 | + } |
|
284 | + |
|
285 | + if (0 !== $offset) { |
|
286 | + if (fseek($stream, $offset) === -1) { |
|
287 | + throw new Exception\Conflict( |
|
288 | 288 | 'invalid offset requested', |
289 | 289 | Exception\Conflict::INVALID_OFFSET |
290 | 290 | ); |
291 | - } |
|
292 | - } |
|
293 | - |
|
294 | - $read = 0; |
|
295 | - while (!feof($stream)) { |
|
296 | - if (0 !== $limit && $read + 8192 > $limit) { |
|
297 | - echo fread($stream, $limit - $read); |
|
298 | - exit(); |
|
299 | - } |
|
300 | - |
|
301 | - echo fread($stream, 8192); |
|
302 | - $read += 8192; |
|
303 | - } |
|
304 | - |
|
305 | - exit(); |
|
306 | - }); |
|
291 | + } |
|
292 | + } |
|
293 | + |
|
294 | + $read = 0; |
|
295 | + while (!feof($stream)) { |
|
296 | + if (0 !== $limit && $read + 8192 > $limit) { |
|
297 | + echo fread($stream, $limit - $read); |
|
298 | + exit(); |
|
299 | + } |
|
300 | + |
|
301 | + echo fread($stream, 8192); |
|
302 | + $read += 8192; |
|
303 | + } |
|
304 | + |
|
305 | + exit(); |
|
306 | + }); |
|
307 | 307 | } |
308 | 308 | |
309 | 309 | /** |
@@ -1053,9 +1053,9 @@ discard block |
||
1053 | 1053 | $node->zip($archive); |
1054 | 1054 | } catch (\Exception $e) { |
1055 | 1055 | $this->logger->debug('failed zip node in multi node request ['.$node->getId().']', [ |
1056 | - 'category' => get_class($this), |
|
1057 | - 'exception' => $e, |
|
1058 | - ]); |
|
1056 | + 'category' => get_class($this), |
|
1057 | + 'exception' => $e, |
|
1058 | + ]); |
|
1059 | 1059 | } |
1060 | 1060 | } |
1061 | 1061 |
@@ -101,7 +101,7 @@ |
||
101 | 101 | break; |
102 | 102 | default: |
103 | 103 | throw new InvalidArgumentException('invalid option '.$option.' given'); |
104 | - } |
|
104 | + } |
|
105 | 105 | } |
106 | 106 | |
107 | 107 | return $this; |
@@ -114,10 +114,10 @@ |
||
114 | 114 | $body->setParts([$html, $plain]); |
115 | 115 | |
116 | 116 | $mail = (new Message()) |
117 | - ->setSubject($message->getSubject($receiver)) |
|
118 | - ->setBody($body) |
|
119 | - ->setTo($address) |
|
120 | - ->setEncoding('UTF-8'); |
|
117 | + ->setSubject($message->getSubject($receiver)) |
|
118 | + ->setBody($body) |
|
119 | + ->setTo($address) |
|
120 | + ->setEncoding('UTF-8'); |
|
121 | 121 | |
122 | 122 | $type = $mail->getHeaders()->get('Content-Type'); |
123 | 123 | $type->setType('multipart/alternative'); |
@@ -256,9 +256,9 @@ |
||
256 | 256 | $body->setParts([$html, $plain]); |
257 | 257 | |
258 | 258 | $mail = (new Message()) |
259 | - ->setSubject($message->getSubject()) |
|
260 | - ->setBody($body) |
|
261 | - ->setEncoding('UTF-8'); |
|
259 | + ->setSubject($message->getSubject()) |
|
260 | + ->setBody($body) |
|
261 | + ->setEncoding('UTF-8'); |
|
262 | 262 | |
263 | 263 | $type = $mail->getHeaders()->get('Content-Type'); |
264 | 264 | $type->setType('multipart/alternative'); |