gyselroth / balloon

src/lib/Filesystem/Node/File.php

Spacing +7 added lines, -7 removed lines

@@ -45,14 +45,14 @@
      * @param array
      **/
     protected $temp_files = [
-        '/^\._(.*)$/',     // OS/X resource forks
-        '/^.DS_Store$/',   // OS/X custom folder settings
+        '/^\._(.*)$/', // OS/X resource forks
+        '/^.DS_Store$/', // OS/X custom folder settings
         '/^desktop.ini$/', // Windows custom folder settings
-        '/^Thumbs.db$/',   // Windows thumbnail cache
-        '/^.(.*).swpx$/',  // ViM temporary files
-        '/^.(.*).swx$/',   // ViM temporary files
-        '/^.(.*).swp$/',   // ViM temporary files
-        '/^\.dat(.*)$/',   // Smultron seems to create these
+        '/^Thumbs.db$/', // Windows thumbnail cache
+        '/^.(.*).swpx$/', // ViM temporary files
+        '/^.(.*).swx$/', // ViM temporary files
+        '/^.(.*).swp$/', // ViM temporary files
+        '/^\.dat(.*)$/', // Smultron seems to create these
         '/^~lock.(.*)#$/', // Windows 7 lockfiles
     ];
 

src/app/Balloon.App.Notification/Constructor/Http.php

Spacing +3 added lines, -3 removed lines

@@ -32,7 +32,7 @@ 
             ->prependRoute(new Route('/api/v2/nodes|files|collections/subscription(/|\z)', v2\Subscription::class))
             ->prependRoute(new Route('/api/v2/nodes|files|collections/{id:#([0-9a-z]{24})#}/subscription(/|\z)', v2\Subscription::class));
 
-        $decorator->addDecorator('subscription', function ($node) use ($notifier, $server) {
+        $decorator->addDecorator('subscription', function($node) use ($notifier, $server) {
             $subscription = $notifier->getSubscription($node, $server->getIdentity());
             if ($subscription === null) {
                 return false;
@@ -41,7 +41,7 @@ 
             return true;
         });
 
-        $decorator->addDecorator('subscription_exclude_me', function ($node) use ($notifier, $server) {
+        $decorator->addDecorator('subscription_exclude_me', function($node) use ($notifier, $server) {
             $subscription = $notifier->getSubscription($node, $server->getIdentity());
             if ($subscription === null) {
                 return false;
@@ -50,7 +50,7 @@ 
             return $subscription['exclude_me'];
         });
 
-        $decorator->addDecorator('subscription_recursive', function ($node) use ($notifier, $server) {
+        $decorator->addDecorator('subscription_recursive', function($node) use ($notifier, $server) {
             if (!($node instanceof Collection)) {
                 return null;
             }

src/app/Balloon.App.Api/v1/AttributeDecorator/NodeDecorator.php

Doc Comments +1 added lines, -1 removed lines

@@ -86,7 +86,7 @@
      * Add decorator.
      *
      *
-     * @return AttributeDecorator
+     * @return NodeDecorator
      */
     public function addDecorator(string $attribute, Closure $decorator): self
     {

src/app/Balloon.App.Api/v1/AttributeDecorator/RoleDecorator.php

Doc Comments +1 added lines, -1 removed lines

@@ -73,7 +73,7 @@
      * Add decorator.
      *
      *
-     * @return AttributeDecorator
+     * @return RoleDecorator
      */
     public function addDecorator(string $attribute, Closure $decorator): self
     {

src/app/Balloon.App.Api/v1/Node.php

Spacing +8 added lines, -8 removed lines

@@ -183,7 +183,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);
             }
@@ -260,7 +260,7 @@ 
 
         $node = $this->_getNode($id, $p);
         if ($node instanceof Collection) {
-            return (new Response())->setBody(function () use ($node) {
+            return (new Response())->setBody(function() use ($node) {
                 $node->getZip();
             });
         }
@@ -278,7 +278,7 @@ 
         }
 
         return $response->setOutputFormat(null)
-          ->setBody(function () use ($node, $encode, $offset, $length) {
+          ->setBody(function() use ($node, $encode, $offset, $length) {
               $mime = $node->getContentType();
               $stream = $node->get();
               $name = $node->getName();
@@ -349,7 +349,7 @@ 
      */
     public function postReadonly($id = null, $p = null, bool $readonly = true): Response
     {
-        return $this->bulk($id, $p, function ($node) use ($readonly) {
+        return $this->bulk($id, $p, function($node) use ($readonly) {
             $node->setReadonly($readonly);
 
             return ['status' => 204];
@@ -594,7 +594,7 @@ 
      */
     public function postMetaAttributes(?string $id = null, ?string $p = null): Response
     {
-        return $this->bulk($id, $p, function ($node) {
+        return $this->bulk($id, $p, function($node) {
             $node->setMetaAttributes($_POST);
 
             return ['status' => 204];
@@ -676,7 +676,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 [
@@ -737,7 +737,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);
             if (NodeInterface::CONFLICT_RENAME === $conflict) {
                 return [
@@ -792,7 +792,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 {

Indentation +46 added lines, -46 removed lines

@@ -286,49 +286,49 @@ 
         }
 
         return $response->setOutputFormat(null)
-          ->setBody(function () use ($node, $encode, $offset, $length) {
-              $mime = $node->getContentType();
-              $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;
-              header('Content-Type: '.$mime.'');
-              if ('base64' === $encode) {
-                  header('Content-Encoding: base64');
-                  while (!feof($stream)) {
-                      if (0 !== $length && $read + 8192 > $length) {
-                          echo base64_encode(fread($stream, $length - $read));
-                          exit();
-                      }
-
-                      echo base64_encode(fread($stream, 8192));
-                      $read += 8192;
-                  }
-              } else {
-                  while (!feof($stream)) {
-                      if (0 !== $length && $read + 8192 > $length) {
-                          echo fread($stream, $length - $read);
-                          exit();
-                      }
-
-                      echo fread($stream, 8192);
-                      $read += 8192;
-                  }
-              }
-          });
+            ->setBody(function () use ($node, $encode, $offset, $length) {
+                $mime = $node->getContentType();
+                $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;
+                header('Content-Type: '.$mime.'');
+                if ('base64' === $encode) {
+                    header('Content-Encoding: base64');
+                    while (!feof($stream)) {
+                        if (0 !== $length && $read + 8192 > $length) {
+                            echo base64_encode(fread($stream, $length - $read));
+                            exit();
+                        }
+
+                        echo base64_encode(fread($stream, 8192));
+                        $read += 8192;
+                    }
+                } else {
+                    while (!feof($stream)) {
+                        if (0 !== $length && $read + 8192 > $length) {
+                            echo fread($stream, $length - $read);
+                            exit();
+                        }
+
+                        echo fread($stream, 8192);
+                        $read += 8192;
+                    }
+                }
+            });
     }
 
     /**
@@ -1329,9 +1329,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,
+                ]);
             }
         }
 

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

Spacing +2 added lines, -2 removed lines

@@ -348,7 +348,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'] = $child->getId();
                     $db->subscription->replaceOne(
                         [
@@ -374,7 +374,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,

Doc Comments +5 added lines

@@ -93,6 +93,7 @@ 
 
     /**
      * Send notification.
+     * @param User $sender
      */
     public function notify(iterable $receiver, ?User $sender, MessageInterface $message): bool
     {
@@ -180,6 +181,7 @@ 
 
     /**
      * Add notification.
+     * @param User $sender
      */
     public function postNotification(User $receiver, ?User $sender, MessageInterface $message): ObjectId
     {
@@ -206,6 +208,8 @@ 
 
     /**
      * Get notifications.
+     * @param integer $offset
+     * @param integer $limit
      */
     public function getNotifications(User $user, array $query = [], ?int $offset = null, ?int $limit = null, ?int &$total = null): iterable
     {
@@ -288,6 +292,7 @@ 
 
     /**
      * Get subscription.
+     * @return NodeInterface
      */
     public function getSubscription(NodeInterface $node, User $user): ?array
     {

src/app/Balloon.App.Api/v1/File.php

Doc Comments +4 added lines, -1 removed lines

@@ -117,7 +117,7 @@ 
      *
      * @param string $id
      * @param string $p
-     * @param string $version
+     * @param integer $version
      */
     public function postRestore(int $version, ?string $id = null, ?string $p = null): Response
     {
@@ -406,6 +406,9 @@ 
 
     /**
      * Get storage.
+     * @param string|null $id
+     * @param string|null $p
+     * @param string|null $collection
      */
     protected function getStorage($id, $p, $collection): StorageAdapterInterface
     {

src/app/Balloon.App.Api/Helper.php

Indentation +63 added lines, -63 removed lines

@@ -34,68 +34,68 @@
         }
 
         return $response
-          ->setOutputFormat(null)
-          ->setBody(function () use ($file) {
-              $stream = $file->get();
-              $name = $file->getName();
-
-              if (null === $stream) {
-                  return;
-              }
-
-              $size = $file->getSize();
-              $length = $size;
-              $start = 0;
-              $end = $size - 1;
-
-              if (isset($_SERVER['HTTP_RANGE'])) {
-                  header('Accept-Ranges: bytes');
-                  $c_start = $start;
-                  $c_end = $end;
-                  list(, $range) = explode('=', $_SERVER['HTTP_RANGE'], 2);
-
-                  if (strpos($range, ',') !== false) {
-                      header("Content-Range: bytes $start-$end/$size");
-
-                      throw new Exception\InvalidRange('invalid offset/limit requested');
-                  }
-
-                  if ($range == '-') {
-                      $c_start = $size - substr($range, 1);
-                  } else {
-                      $range = explode('-', $range);
-                      $c_start = $range[0];
-                      $c_end = (isset($range[1]) && is_numeric($range[1])) ? $range[1] : $size;
-                  }
-
-                  $c_end = ($c_end > $end) ? $end : $c_end;
-                  if ($c_start > $c_end || $c_start > $size - 1 || $c_end >= $size) {
-                      header("Content-Range: bytes $start-$end/$size");
-
-                      throw new Exception\InvalidRange('invalid offset/limit requested');
-                  }
-
-                  $start = (int) $c_start;
-                  $end = (int) $c_end;
-                  $length = (int) $end - $start + 1;
-                  fseek($stream, $start);
-                  header('HTTP/1.1 206 Partial Content');
-                  header("Content-Range: bytes $start-$end/$size");
-              }
-
-              header('Content-Length: '.$length);
-              $buffer = 1024 * 8;
-
-              while (!feof($stream) && ($p = ftell($stream)) <= $end) {
-                  if ($p + $buffer > $end) {
-                      $buffer = $end - $p + 1;
-                  }
-
-                  echo fread($stream, $buffer);
-                  flush();
-              }
-
-              fclose($stream);
-          });
+            ->setOutputFormat(null)
+            ->setBody(function () use ($file) {
+                $stream = $file->get();
+                $name = $file->getName();
+
+                if (null === $stream) {
+                    return;
+                }
+
+                $size = $file->getSize();
+                $length = $size;
+                $start = 0;
+                $end = $size - 1;
+
+                if (isset($_SERVER['HTTP_RANGE'])) {
+                    header('Accept-Ranges: bytes');
+                    $c_start = $start;
+                    $c_end = $end;
+                    list(, $range) = explode('=', $_SERVER['HTTP_RANGE'], 2);
+
+                    if (strpos($range, ',') !== false) {
+                        header("Content-Range: bytes $start-$end/$size");
+
+                        throw new Exception\InvalidRange('invalid offset/limit requested');
+                    }
+
+                    if ($range == '-') {
+                        $c_start = $size - substr($range, 1);
+                    } else {
+                        $range = explode('-', $range);
+                        $c_start = $range[0];
+                        $c_end = (isset($range[1]) && is_numeric($range[1])) ? $range[1] : $size;
+                    }
+
+                    $c_end = ($c_end > $end) ? $end : $c_end;
+                    if ($c_start > $c_end || $c_start > $size - 1 || $c_end >= $size) {
+                        header("Content-Range: bytes $start-$end/$size");
+
+                        throw new Exception\InvalidRange('invalid offset/limit requested');
+                    }
+
+                    $start = (int) $c_start;
+                    $end = (int) $c_end;
+                    $length = (int) $end - $start + 1;
+                    fseek($stream, $start);
+                    header('HTTP/1.1 206 Partial Content');
+                    header("Content-Range: bytes $start-$end/$size");
+                }
+
+                header('Content-Length: '.$length);
+                $buffer = 1024 * 8;
+
+                while (!feof($stream) && ($p = ftell($stream)) <= $end) {
+                    if ($p + $buffer > $end) {
+                        $buffer = $end - $p + 1;
+                    }
+
+                    echo fread($stream, $buffer);
+                    flush();
+                }
+
+                fclose($stream);
+            });
     }
 }

src/lib/Filesystem/Node/Collection.php

Doc Comments +1 added lines

@@ -656,6 +656,7 @@
 
     /**
      * Create new file as a child from this collection.
+     * @param string $name
      */
     public function addFile($name, ?ObjectId $session = null, array $attributes = [], int $conflict = NodeInterface::CONFLICT_NOACTION, bool $clone = false): File
     {

Unused Use Statements -1 removed lines

@@ -17,7 +17,6 @@
 use Balloon\Filesystem\Exception;
 use Balloon\Filesystem\Storage\Adapter\AdapterInterface as StorageAdapterInterface;
 use Balloon\Hook;
-use Balloon\Server\User;
 use Generator;
 use MimeType\MimeType;
 use function MongoDB\BSON\fromJSON;