gyselroth / balloon

src/lib/Server/Group.php

Doc Comments +2 added lines

@@ -265,6 +265,8 @@
     /**
      * Get resolved member.
      *
+     * @param integer $offset
+     * @param integer $limit
      * @return Generator
      */
     public function getResolvedMembers(?int $offset = null, ?int $limit = null): ?Generator

src/app/Balloon.App.Notification/Api/v2/Notifications.php

Indentation +4 added lines, -4 removed lines

@@ -221,10 +221,10 @@
     {
         $mail = new Message();
         $mail->setBody($body)
-          ->setFrom($this->user->getAttributes()['mail'], $this->user->getAttributes()['username'])
-          ->setSubject($subject)
-          ->setTo($this->user->getAttributes()['mail'], 'Undisclosed Recipients')
-          ->setBcc($receiver);
+            ->setFrom($this->user->getAttributes()['mail'], $this->user->getAttributes()['username'])
+            ->setSubject($subject)
+            ->setTo($this->user->getAttributes()['mail'], 'Undisclosed Recipients')
+            ->setBcc($receiver);
         $this->async->addJob(Mail::class, $mail->toString());
 
         return (new Response())->setCode(202);

src/app/Balloon.App.Sharelink/Migration/Delta/SharelinkIntoApp.php

Indentation +2 added lines, -2 removed lines

@@ -49,8 +49,8 @@
             $this->db->storage->updateOne(
                 ['_id' => $object['_id']],
                 [
-                  '$unset' => ['sharelink' => 1],
-                  '$set' => ['app.Balloon\App\Sharelink' => $object['sharelink']],
+                    '$unset' => ['sharelink' => 1],
+                    '$set' => ['app.Balloon\App\Sharelink' => $object['sharelink']],
                 ]
             );
         }

src/app/Balloon.App.Api/v2/Nodes.php

Indentation +44 added lines, -44 removed lines

@@ -279,50 +279,50 @@ 
         }
 
         return $response
-          ->setOutputFormat(null)
-          ->setBody(function () use ($node, $encode, $offset, $limit) {
-              $stream = $node->get();
-              $name = $node->getName();
-
-              if (null === $stream) {
-                  return;
-              }
-
-              if (0 !== $offset) {
-                  if (fseek($stream, $offset) === -1) {
-                      throw new Exception\Conflict(
+            ->setOutputFormat(null)
+            ->setBody(function () use ($node, $encode, $offset, $limit) {
+                $stream = $node->get();
+                $name = $node->getName();
+
+                if (null === $stream) {
+                    return;
+                }
+
+                if (0 !== $offset) {
+                    if (fseek($stream, $offset) === -1) {
+                        throw new Exception\Conflict(
                         'invalid offset requested',
                         Exception\Conflict::INVALID_OFFSET
                     );
-                  }
-              }
-
-              $read = 0;
-              if ('base64' === $encode) {
-                  header('Content-Encoding: base64');
-                  while (!feof($stream)) {
-                      if (0 !== $limit && $read + 8192 > $limit) {
-                          echo base64_encode(fread($stream, $limit - $read));
-                          exit();
-                      }
-
-                      echo base64_encode(fread($stream, 8192));
-                      $read += 8192;
-                  }
-              } else {
-                  while (!feof($stream)) {
-                      if (0 !== $limit && $read + 8192 > $limit) {
-                          echo fread($stream, $limit - $read);
-                          exit();
-                      }
-
-                      echo fread($stream, 8192);
-                      $read += 8192;
-                  }
-
-                  exit();
-              }
-          });
+                    }
+                }
+
+                $read = 0;
+                if ('base64' === $encode) {
+                    header('Content-Encoding: base64');
+                    while (!feof($stream)) {
+                        if (0 !== $limit && $read + 8192 > $limit) {
+                            echo base64_encode(fread($stream, $limit - $read));
+                            exit();
+                        }
+
+                        echo base64_encode(fread($stream, 8192));
+                        $read += 8192;
+                    }
+                } else {
+                    while (!feof($stream)) {
+                        if (0 !== $limit && $read + 8192 > $limit) {
+                            echo fread($stream, $limit - $read);
+                            exit();
+                        }
+
+                        echo fread($stream, 8192);
+                        $read += 8192;
+                    }
+
+                    exit();
+                }
+            });
     }
 
     /**
@@ -1073,9 +1073,9 @@ 
                 $node->zip($archive);
             } catch (\Exception $e) {
                 $this->logger->debug('failed zip node in multi node request ['.$node->getId().']', [
-                   'category' => get_class($this),
-                   'exception' => $e,
-               ]);
+                    'category' => get_class($this),
+                    'exception' => $e,
+                ]);
             }
         }
 

Spacing +8 added lines, -8 removed lines

@@ -187,7 +187,7 @@ 
             }
         }
 
-        return $this->bulk($id, $p, function ($node) use ($parent, $conflict, $move) {
+        return $this->bulk($id, $p, function($node) use ($parent, $conflict, $move) {
             if (true === $move) {
                 $node = $node->setParent($parent, $conflict);
             }
@@ -280,7 +280,7 @@ 
 
         return $response
           ->setOutputFormat(null)
-          ->setBody(function () use ($node, $encode, $offset, $limit) {
+          ->setBody(function() use ($node, $encode, $offset, $limit) {
               $stream = $node->get();
               $name = $node->getName();
 
@@ -429,7 +429,7 @@ 
             return (new Response())->setCode(200)->setBody($result);
         }
 
-        return $this->bulk($id, $p, function ($node) use ($attributes) {
+        return $this->bulk($id, $p, function($node) use ($attributes) {
             return [
                 'code' => 200,
                 'data' => $this->node_decorator->decorate($node, $attributes),
@@ -543,9 +543,9 @@ 
     public function patch(?string $name = null, ?array $meta = null, ?bool $readonly = null, ?array $filter = null, ?string $id = null, ?string $p = null): Response
     {
         $attributes = compact('name', 'meta', 'readonly', 'filter');
-        $attributes = array_filter($attributes, function ($attribute) {return !is_null($attribute); });
+        $attributes = array_filter($attributes, function($attribute) {return !is_null($attribute); });
 
-        return $this->bulk($id, $p, function ($node) use ($attributes) {
+        return $this->bulk($id, $p, function($node) use ($attributes) {
             foreach ($attributes as $attribute => $value) {
                 switch ($attribute) {
                     case 'name':
@@ -627,7 +627,7 @@ 
             );
         }
 
-        return $this->bulk($id, $p, function ($node) use ($parent, $conflict) {
+        return $this->bulk($id, $p, function($node) use ($parent, $conflict) {
             $result = $node->copyTo($parent, $conflict);
 
             return [
@@ -691,7 +691,7 @@ 
             );
         }
 
-        return $this->bulk($id, $p, function ($node) use ($parent, $conflict) {
+        return $this->bulk($id, $p, function($node) use ($parent, $conflict) {
             $result = $node->setParent($parent, $conflict);
 
             return [
@@ -745,7 +745,7 @@ 
             $at = $this->_verifyAttributes(['destroy' => $at])['destroy'];
         }
 
-        return $this->bulk($id, $p, function ($node) use ($force, $ignore_flag, $at) {
+        return $this->bulk($id, $p, function($node) use ($force, $ignore_flag, $at) {
             if (null === $at) {
                 $node->delete($force && $node->isDeleted() || $force && $ignore_flag);
             } else {

src/app/Balloon.App.Notification/Notifier.php

Doc Comments +3 added lines, -5 removed lines

@@ -116,9 +116,7 @@ 
      *
      * @param iterable $receiver
      * @param User     $sender
-     * @param string   $subject
-     * @param string   $body
-     * @param array    $context
+     * @param string    $context
      *
      * @return bool
      */
@@ -226,10 +224,10 @@ 
     /**
      * Add notification.
      *
-     * @param array            $receiver
-     * @param User             $user
+     * @param User            $receiver
      * @param MessageInterface $message
      * @param array            $context
+     * @param User $sender
      *
      * @return ObjectId
      */

Spacing +2 added lines, -2 removed lines

@@ -404,7 +404,7 @@ 
 
             if ($node instanceof Collection && $recursive === true) {
                 $db = $this->db;
-                $node->doRecursiveAction(function ($child) use ($db, $subscription) {
+                $node->doRecursiveAction(function($child) use ($db, $subscription) {
                     $subscription['node_id'] = $child->getId();
                     $db->subscription->replaceOne(
                         [
@@ -430,7 +430,7 @@ 
 
             if ($node instanceof Collection && $recursive === true) {
                 $db = $this->db;
-                $node->doRecursiveAction(function ($child) use ($db, $node_id, $user_id) {
+                $node->doRecursiveAction(function($child) use ($db, $node_id, $user_id) {
                     $db->subscription->deleteOne([
                         'user' => $user_id,
                         'node' => $node_id,

src/app/Balloon.App.ClamAv/Scanner.php

Doc Comments +1 added lines, -2 removed lines

@@ -73,7 +73,6 @@ 
     /**
      * Constructor.
      *
-     * @param Database        $db
      * @param LoggerInterface $logger
      */
     public function __construct(SocketFactory $factory, LoggerInterface $logger, ?Iterable $config = null)
@@ -131,7 +130,7 @@ 
      *
      * @param File $file
      *
-     * @return array
+     * @return File
      */
     public function scan(File $file): array
     {

src/app/Balloon.App.Cli/Console/Jobs.php

Doc Comments -1 removed lines

@@ -50,7 +50,6 @@
     /**
      * Constructor.
      *
-     * @param App             $app
      * @param Async           $async
      * @param LoggerInterface $logger
      * @param GetOpt          $getopt

src/lib/Filesystem/Storage.php

Unused Use Statements -1 removed lines

@@ -14,7 +14,6 @@
 use Balloon\Filesystem\Node\File;
 use Balloon\Filesystem\Node\NodeInterface;
 use Balloon\Filesystem\Storage\Adapter\AdapterInterface;
-use Balloon\Filesystem\Storage\Adapter\Gridfs;
 use Psr\Log\LoggerInterface;
 
 class Storage

src/app/Balloon.App.Elasticsearch/Job.php

Indentation +1 added lines, -1 removed lines

@@ -341,7 +341,7 @@
         }
 
         $this->logger->debug('elasticsarch blob document ['.$result['_id'].'] has no references left, remove completely', [
-         'category' => get_class($this),
+            'category' => get_class($this),
         ]);
 
         return $this->deleteBlob($result['_id']);

Doc Comments +2 added lines, -7 removed lines

@@ -72,8 +72,7 @@ 
     /**
      * Constructor.
      *
-     * @param Elasticsarch           $es
-     * @param Storage                $storage
+     * @param Elasticsearch           $es
      * @param Server                 $server
      * @param NodeAttributeDecorator $decorator
      * @param LoggerInterface        $logger
@@ -368,7 +367,7 @@ 
      *
      * @param NodeInterface $node
      *
-     * @return array
+     * @return NodeInterface
      */
     protected function getParams(NodeInterface $node): array
     {
@@ -439,7 +438,6 @@ 
     /**
      * Add or update blob.
      *
-     * @param File $node
      *
      * @return bool
      */
@@ -480,8 +478,6 @@ 
      * Prepare references update.
      *
      * @param array $references
-     * @param array $new_references
-     * @param array $new_share_references
      *
      * @return array
      */
@@ -555,7 +551,6 @@ 
     /**
      * Update blob.
      *
-     * @param File  $file
      * @param array $meta
      *
      * @return bool

Spacing +2 added lines, -2 removed lines

@@ -271,7 +271,7 @@ 
     protected function addShare(Collection $collection): bool
     {
         $that = $this;
-        $collection->doRecursiveAction(function ($node) use ($that) {
+        $collection->doRecursiveAction(function($node) use ($that) {
             if ($node instanceof Collection) {
                 $that->addShare($node);
             } else {
@@ -292,7 +292,7 @@ 
     protected function deleteShare(Collection $collection): bool
     {
         $that = $this;
-        $collection->doRecursiveAction(function ($node) use ($that) {
+        $collection->doRecursiveAction(function($node) use ($that) {
             if ($node instanceof Collection) {
                 $that->deleteShare($node);
             } else {