Balloon\Filesystem\Node\Collection

Complexity

Total Complexity

117

Size/Duplication

Total Lines	1028
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	10

Importance

Changes

0

23 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	16	4
C	copyTo()	0	47	8
D	getShare()	0	38	9
A	getAttribute()	0	21	2
A	get()	0	4	1
D	getChildNodes()	0	63	11
A	getChildren()	0	4	1
A	isCustomFilter()	0	4	1
A	getSize()	0	8	2
A	getRealId()	0	8	3
A	getQuotaInfo()	0	9	1
B	getChild()	0	59	7
A	doRecursiveAction()	0	14	3
B	delete()	0	54	9
B	_forceDelete()	0	36	4
B	childExists()	0	30	5
C	share()	0	74	8
B	unshare()	0	65	6
D	getChildrenRecursive()	0	33	9
C	addDirectory()	0	74	10
D	addFile()	0	93	11
A	createFile()	0	4	1
A	createDirectory()	0	4	1

<?php
declare(strict_types=1);

/**
 * Balloon
 *
 * @author      Raffael Sahli <sahli@gyselroth.net>
 * @copyright   Copryright (c) 2012-2017 gyselroth GmbH (https://gyselroth.com)
 * @license     GPLv3 https://opensource.org/licenses/GPL-3.0
 */

namespace Balloon\Filesystem\Node;

use \Sabre\DAV;
use Balloon\Exception;
use Balloon\Helper;
use Balloon\User;
use Balloon\Resource;
use \Psr\Log\LoggerInterface as Logger;
use Balloon\Plugin;
use Balloon\Filesystem;
use \MongoDB\BSON\ObjectId;
use \MongoDB\BSON\UTCDateTime;
use \MongoDB\Model\BSONDocument;
use \MongoDB\BSON\Regex;
use \Generator;

class Collection extends Node implements INode, DAV\ICollection, DAV\IQuota
{
    /**
     * Root folder
     */
    const ROOT_FOLDER = '/';


    /**
     * Mime type
     *
     * @var string
     */
    protected $mime = 'inode/directory';

    
    /**
     * Children
     *
     * @var array
     */
    protected $children = [];


    /**
     * Share acl
     *
     * @var array
     */
    protected $acl;


    /**
     * filter
     *
     * @param array
     */
    protected $filter = [];


    /**
     * Initialize
     *
     * @param  BSONDocument $node
     * @param  Filesystem $fs
     * @param  bool $force
     * @return void

Adding a @return annotation to constructors is generally not recommended as a constructor does not have a meaningful return value.

     */
    public function __construct(?BSONDocument $node, Filesystem $fs, bool $force=false)
    {
        parent::__construct($node, $fs);
        
        if ($node === null) {
            $this->_id = null;

            if ($this->_user instanceof User) {
                $this->owner  = $this->_user->getId();
            }
        }
            
        if($force === false) {
            $this->_verifyAccess();
        }
    }


    /**
     * Copy node with children
     *
     * @param  Collection $parent
     * @param  int $conflict
     * @param  string $recursion
     * @param  bool $recursion_first
     * @return INode
     */
    public function copyTo(Collection $parent, int $conflict=INode::CONFLICT_NOACTION, ?string $recursion=null, bool $recursion_first=true): INode
    {
        if ($recursion === null) {
            $recursion_first = true;
            $recursion = uniqid();
        } else {
            $recursion_first = false;
        }

        $this->_pluginmgr->run('preCopyCollection',
            [$this, $parent, &$conflict, &$recursion, &$recursion_first]
        );

        if ($conflict === INode::CONFLICT_RENAME && $parent->childExists($this->name)) {
            $name = $this->_getDuplicateName();
        } else {
            $name = $this->name;
        }
        
        if ($this->_id == $parent->getId()) {
            throw new Exception\Conflict('can not copy node into itself',
                Exception\Conflict::CANT_COPY_INTO_ITSELF
            );
        }

        if ($conflict === INode::CONFLICT_MERGE && $parent->childExists($this->name)) {
            $new_parent = $parent->getChild($this->name);
        } else {
            $new_parent = $parent->addDirectory($name, [
                'created' => $this->created,
                'changed' => $this->changed,
                'deleted' => $this->deleted,
                'filter'  => $this->filter,
		'meta' => $this->meta
            ], INode::CONFLICT_NOACTION, true);
        }

        foreach ($this->getChildNodes(INode::DELETED_INCLUDE) as $child) {
            $child->copyTo($new_parent, $conflict, $recursion, false);
        }

        $this->_pluginmgr->run('postCopyCollection',
            [$this, $parent, $new_parent, $conflict, $recursion, $recursion_first]
        );

        return $new_parent;
    }


    /**
     * Get share
     *
     * @return array|bool
     */
    public function getShare()
    {
        if (!$this->isShared()) {
            return false;
        } else {
            if (is_array($this->acl)) {
                $resource = new Resource($this->_user, $this->_logger, $this->_fs);
                $return = [];
                if (array_key_exists('user', $this->acl)) {
                    foreach ((array)$this->acl['user'] as $user) {
                        $data = $resource->searchUser($user['user'], true);

                        if (empty($data)) {
                            continue;
                        }

                        $data['priv'] = $user['priv'];
                        $return[] = $data;
                    }
                }
                if (array_key_exists('group', $this->acl)) {
                    foreach ((array)$this->acl['group'] as $group) {
                        $data = $resource->searchGroup($group['group'], true);

                        if (empty($data)) {
                            continue;
                        }

                        $data['priv'] = $group['priv'];
                        $return[] = $data;
                    }
                }
                return $return;
            } else {
                return false;
            }
        }
    }


    /**
     * Get Attribute
     *
     * @param  array|string $attribute
     * @return array|string
     */
    public function getAttribute($attribute=[])
    {
        if (empty($attribute)) {
            $attribute = [
                'id',
                'name',
                'meta',
                'mime',
                'size',
                'sharelink',
                'reference',
                'deleted',
                'changed',
                'created',
                'share',
                'directory'
            ];
        }
    
        return $this->_getAttribute($attribute);
    }

    
    /**
     * Get collection
     *
     * @return void
     */
    public function get(): void
    {
        $this->getZip();
    }

    
    /**
     * Fetch children items of this collection
     *
     * Deleted:
     *  0 - Exclude deleted
     *  1 - Only deleted
     *  2 - Include deleted
     *
     * @param   int $deleted
     * @param   array $filter
     * @return  Generator
     */
    public function getChildNodes(int $deleted=INode::DELETED_EXCLUDE, array $filter=[]): Generator
    {
        if ($this->_user instanceof User) {
            $this->_user->findNewShares();
        }

        $search = [
            'parent' => $this->getRealId(),
        ];

        if ($deleted === INode::DELETED_EXCLUDE) {
            $search['deleted'] = false;
        } elseif ($deleted === INode::DELETED_ONLY) {
            $search['deleted'] = ['$type' => 9];
        }

        $search = array_merge($filter, $search);

        if ($this->shared) {
            $node = $this->_db->storage->find([
                '$and' => [
                    $search,
                    [
                        '$or' => [
                            ['shared' => $this->reference],
                            ['shared' => $this->shared],
                            ['shared' => $this->_id],
                        ]
                    ]
                ]
            ]);
        } else {
            if ($this->_user !== null) {
                $search['owner'] = $this->_user->getId();
            }
            
            $node = $this->_db->storage->find($search);
        }
        
        $list = [];

$list is not used, you could remove the assignment.

        foreach ($node as $child) {
            try {
                yield $this->getChild($child);
            } catch (\Exception $e) {
                $this->_logger->info('remove node from children list, failed load node', [
                    'category'  => get_class($this),
                    'exception' => $e
                ]);
            }
        }
        
        if (!empty($this->filter)) {
            if(is_string($this->filter)) {
                $filter = json_decode($this->filter, true);
            } else {
                $filter = $this->filter;
            }

            foreach ($this->_fs->findNodesWithCustomFilterUser($deleted, $filter) as $node) {
                yield $node;
            }
        }
    }


    /**
     * Fetch children items of this collection (as array)
     *
     * Deleted:
     *  0 - Exclude deleted
     *  1 - Only deleted
     *  2 - Include deleted
     *
     * @param   int $deleted
     * @param   array $filter
     * @return  Generator
     */
    public function getChildren(int $deleted=INode::DELETED_EXCLUDE, array $filter=[]): array
    {
        return iterator_to_array($this->getChildNodes($deleted, $filter));
    }


    /**
     * Is custom filter node
     *
     * @return bool
     */
    public function isCustomFilter(): bool
    {
        return !empty($this->filter);
    }

    
    /**
     * Get number of children
     *
     * @return int
     */
    public function getSize(): int
    {
        if ($this->isDeleted()) {
            return count(iterator_to_array($this->getChildNodes(INode::DELETED_INCLUDE)));
        } else {
            return count(iterator_to_array($this->getChildNodes()));
        }
    }


    /**
     * Get real id (reference)
     *
     * @return ObjectId
     */
    public function getRealId(): ?ObjectId
    {
        if ($this->shared == true && $this->isReference()) {

It seems like you are loosely comparing two booleans. Considering using the strict comparison === instead.

            return $this->reference;
        } else {
            return $this->_id;
        }
    }


    /**
     * Get user quota information
     *
     * @return array
     */
    public function getQuotaInfo(): array
    {
        $quota = $this->_user->getQuotaUsage();
        
        return [
            $quota['used'],
            $quota['available']
        ];
    }


    /**
     * Fetch children items of this collection
     *
     * @param  Collection|File|string $node
     * @param  int $deleted
     * @param  array $filter
     * @return INode
     */
    public function getChild($node, int $deleted=INode::DELETED_EXCLUDE, array $filter=[]): INode
    {
        //if $node is string load the object from the backend based on the current parent (the name
        //is unique per depth, so we can load the object)
        if (is_string($node)) {
            $name = $node;
            $search = [
                'name'    => new Regex('^'.preg_quote($name).'$', 'i'),
                'parent'  => $this->getRealId(),
            ];
    
            switch ($deleted) {
                case INode::DELETED_EXCLUDE:
                    $search['deleted'] = false;
                    break;
                case INode::DELETED_ONLY:
                    $search['deleted'] = ['$type' => '9'];
                    break;
            }


            $search = array_merge($filter, $search);

            if ($this->shared) {
                $node = $this->_db->storage->findOne([
                    '$and' => [
                        $search,
                        [
                            '$or' => [
                                ['shared' => $this->reference],
                                ['shared' => $this->shared],
                                ['shared' => $this->_id]
                            ]
                        ]
                    ]
                ]);
            } else {
                $search['owner'] = $this->_user->getId();
                $node = $this->_db->storage->findOne($search);
            }

            if ($node === null) {
                throw new Exception\NotFound('node called '.$name.' does not exists here',
                    Exception\NotFound::NODE_NOT_FOUND
                );
            }
        }

        $this->_logger->debug('loaded node ['.$node['_id'].' (directory='.$node['directory'].')] from parent node ['.$this->getRealId().']', [
            'category' => get_class($this),
        ]);
        
        //if the item has the directory flag we create a collection else the item is file
        if ($node['directory'] == true) {
            return new Collection($node, $this->_fs);
        } else {
            return new File($node, $this->_fs);
        }
    }


    /**
     * Do recursive Action
     *
     * @param   string $method
     * @param   array $params
     * @param   int $deleted
     * @return  bool
     */
    protected function doRecursiveAction(string $method, array $params=[], int $deleted=INode::DELETED_EXCLUDE): bool
    {
        if (!is_callable([$this, $method])) {
            throw new Exception("method $method is not callable in ".__CLASS__);
        }

        $children = $this->getChildNodes($deleted);

        foreach ($children as $child) {
            call_user_func_array([$child, $method], $params);
        }

        return true;
    }


    /**
     * Delete node
     *
     * Actually the node will not be deleted (Just set a delete flag), set $force=true to
     * delete finally
     *
     * @param   bool $force
     * @param   string $recursion Identifier to identify a recursive action
     * @param   bool $recursion_first
     * @return  bool
     */
    public function delete(bool $force=false, ?string $recursion=null, bool $recursion_first=true): bool
    {
        if (!$this->isAllowed('w') && !$this->isReference()) {
            throw new Exception\Forbidden('not allowed to delete node '.$this->name,
                Exception\Forbidden::NOT_ALLOWED_TO_DELETE
            );
        }

        if ($recursion === null) {
            $recursion_first = true;
            $recursion = uniqid();
        } else {
            $recursion_first = false;
        }

        $this->_pluginmgr->run('preDeleteCollection',
            [$this, &$force, &$recursion, &$recursion_first]
        );
        
        if ($this->readonly && $this->_user !== null) {
            throw new Exception\Conflict('node is marked as readonly, it is not possible to delete it',
                Exception\Conflict::READONLY
            );
        }
        
        if ($force === true) {
            return $this->_forceDelete($recursion, $recursion_first);
        }
        
        $this->deleted = new UTCDateTime();
        

        if (!$this->isReference()) {
            $this->doRecursiveAction('delete', [
                'force'     => false,
                'recursion' => $recursion,
                'recursion_first' => false,
            ]);
        }

        if ($this->_id !== null) {
            $result = $this->save([
                'deleted',
            ], [], $recursion, false);
        } else {
            $result = true;
        }

        $this->_pluginmgr->run('postDeleteCollection',
            [$this, $force, $recursion, $recursion_first]
        );

        return $result;
    }


    /**
     * Completely remove node
     *
     * @param   string $recursion Identifier to identify a recursive action
     * @param   bool $recursion_first
     * @return  bool
     */
    protected function _forceDelete(?string $recursion=null, bool $recursion_first=true): bool
    {
        if (!$this->isReference()) {
            $this->doRecursiveAction('delete', [
                'force'     => true,
                'recursion' => $recursion,
                'recursion_first' => false,
            ], INode::DELETED_INCLUDE);
        }
  
        try {
            $result = $this->_db->storage->deleteOne(['_id' => $this->_id]);

$result is not used, you could remove the assignment.

            if ($this->isShared()) {
                $result = $this->_db->storage->deleteMany(['reference' => $this->_id]);

$result is not used, you could remove the assignment.

            }

            $this->_logger->info('force removed collection ['.$this->_id.']', [
                'category' => get_class($this),
            ]);
        

            $this->_pluginmgr->run('postDeleteCollection',
                [$this, true, $recursion, $recursion_first]
            );
        } catch (\Exception $e) {
            $this->_logger->error('failed force remove collection ['.$this->_id.']', [
                'category' => get_class($this),
                'exception' => $e,
            ]);
            
            throw $e;
        }

        return true;
    }


    /**
     * Check if this collection has child named $name
     *
     * deleted:
     *
     *  0 - Exclude deleted
     *  1 - Only deleted
     *  2 - Include deleted
     *
     * @param   string $name
     * @param   int $deleted
     * @param   array $filter
     * @return  bool
     */
    public function childExists($name, $deleted=INode::DELETED_EXCLUDE, array $filter=[]): bool
    {
        $find = [
            'parent'  => $this->getRealId(),
            'name'    => new Regex('^'.preg_quote($name).'$', 'i'),
        ];

        if ($this->_user !== null) {
            $find['owner'] = $this->_user->getId();
        }

        switch ($deleted) {
            case INode::DELETED_EXCLUDE:
                $find['deleted'] = false;
                break;
            case INode::DELETED_ONLY:
                $find['deleted'] = ['$type' => 9];
                break;
        }

        $find = array_merge($filter, $find);

        if ($this->isSpecial()) {
            unset($find['owner']);
        }
        
        $node = $this->_db->storage->findOne($find);
    
        return (bool)$node;
    }
    

    /**
     * Share collection
     *
     * @param   array $acl
     * @return  bool
     */
    public function share(array $acl): bool
    {
        if ($this->isReference()) {
            throw new Exception('a collection reference can not be shared');
        }
        
        if ($this->isShareMember()) {
            throw new Exception('a sub node of a share can not be shared');
        }
        
        if (!$this->isAllowed('w')) {
            throw new Exception\Forbidden('not allowed to share node',
                Exception\Forbidden::NOT_ALLOWED_TO_SHARE
            );
        }

        $this->shared = true;

        $this->acl = $acl;
        $action = [
            '$set' => [
                'shared' => $this->_id
            ]
        ];
    
        $toset = $this->getChildrenRecursive($this->getRealId(), $shares, $files);
        
        if (!empty($shares)) {
            throw new Exception('child folder contains a shared folder');
        }
        
        $this->_db->storage->updateMany([
            '_id' => [
                '$in' => $toset,
            ],
        ], $action);

        $this->_db->delta->updateMany([
            '_id' => [
                '$in' => $toset,
            ],
        ], $action);
        
        $list = [];

$list is not used, you could remove the assignment.

        $result = $this->save(['shared', 'acl']);

$result is not used, you could remove the assignment.

        if (!is_array($files)) {
            return true;
        }

        foreach ($files as $node) {
            if ($node['file'] === null) {
                continue;
            }

            $share_ref = [
                'id'    => $node['id'],
                'share' => $this->_id,
            ];

            $this->_db->{'fs.files'}->updateOne(
                [
                    '_id' => $node['file']
                ],
                [
                    '$addToSet' => [
                        'metadata.share_ref' => $share_ref,
                    ]
                ]
            );
        }

        return true;
    }


    /**
     * Unshare collection
     *
     * @return  bool
     */
    public function unshare(): bool
    {
        if (!$this->isAllowed('w')) {
            throw new Exception\Forbidden('not allowed to share node',
                Exception\Forbidden::NOT_ALLOWED_TO_SHARE
            );
        }

        if ($this->shared !== true) {
            throw new Exception\Conflict('Can not unshare a none shared collection',
                Exception\Conflict::NOT_SHARED
            );
        }

        $this->shared = false;
        $this->acl   = null;

It seems like null of type null is incompatible with the declared type array of property $acl.

        $action = [
            '$unset' => [
                'shared' => $this->_id
            ],
            '$set' => [
                'owner' => $this->_user->getId()
            ]
        ];
    
        $toset = $this->getChildrenRecursive($this->getRealId(), $shares, $files);
        
        
        $this->_db->storage->updateMany([
            '_id' => [
                '$in' => $toset,
            ],
        ], $action);
        
        $list = [];

$list is not used, you could remove the assignment.

        $result = $this->save(['shared'], ['acl']);

$result is not used, you could remove the assignment.

        if (!is_array($files)) {
            return true;
        }

        foreach ($files as $node) {
            if ($node['file'] === null) {
                continue;
            }

            $share_ref = [
                'id'    => $node['id'],
                'share' => $this->_id,
            ];

            $this->_db->{'fs.files'}->updateOne(
                [
                    '_id' => $node['file']
                ],
                [
                '$pull' => [
                    'metadata.share_ref' => $share_ref,
                    ]
                ]
            );
        }

        return true;
    }

    
    /**
     * Get children
     *
     * @param   ObjectId $id
     * @param   array $shares
     * @param   arary $files
     * @return  array
     */
    public function getChildrenRecursive(?ObjectId $id=null, ?array &$shares=[], ?array &$files=[]): array
    {
        $list = [];
        $result = $this->_db->storage->find([
            'parent' => $id,
        ], [
            '_id' => 1,
            'directory' => 1,
            'reference' => 1,
            'shared'    => 1,
            'file'      => 1
        ]);
        
        foreach ($result as $node) {
            $list[] = $node['_id'];

            if ($node['directory'] === false) {
                $files[] = [
                    'id'    => $node['_id'],
                    'file'  => isset($node['file']) ? $node['file'] : null,
                ];
            } else {
                if (isset($node['reference']) || isset($node['shared']) && $node['shared'] === true) {
                    $shares[] = $node['_id'];
                }
        
                if ($node['directory'] === true && !isset($node['reference'])) {
                    $list = array_merge($list, $this->getChildrenRecursive($node['_id'], $shares, $files));
                }
            }
        }
        return $list;
    }


    /**
     * Create new directory
     *
     * @param   string $name
     * @param   arracy $attributes
     * @param   int $conflict
     * @param   bool $clone
     * @return  Collection
     */
    public function addDirectory($name, array $attributes=[], int $conflict=INode::CONFLICT_NOACTION, bool $clone=false): Collection
    {
        if (!$this->isAllowed('w')) {
            throw new Exception\Forbidden('not allowed to create new node here',
                Exception\Forbidden::NOT_ALLOWED_TO_CREATE
            );
        }

        $this->_pluginmgr->run('preCreateCollection', [$this, &$name, &$attributes, &$clone]);

        if ($this->readonly) {
            throw new Exception\Conflict('node is set as readonly, it is not possible to add new sub nodes',
                Exception\Conflict::READONLY
            );
        }

        $name = $this->checkName($name);

        if ($this->childExists($name)) {
            if ($conflict === INode::CONFLICT_NOACTION) {
                throw new Exception\Conflict('a node called '.$name.' does already exists in this collection',
                    Exception\Conflict::NODE_WITH_SAME_NAME_ALREADY_EXISTS
                );
            } elseif ($conflict === INode::CONFLICT_RENAME) {
                $name = $this->getDuplicateName($name);

The method getDuplicateName() does not exist on Balloon\Filesystem\Node\Collection. Did you maybe mean _getDuplicateName()?

            }
        }
        
        if ($this->isDeleted()) {
            throw new Exception\Conflict('could not add node '.$name.' into a deleted parent collection',
                Exception\Conflict::DELETED_PARENT
            );
        }
        
        try {
            $meta = [
                'name'      => $name,
                'deleted'   => false,
                'parent'    => $this->getRealId(),
                'directory' => true,
                'meta'      => [],
                'created'   => new UTCDateTime(),
                'changed'   => new UTCDateTime(),
                'owner'     => $this->_user->getId(),
                'shared'    => ($this->shared === true ? $this->getRealId() : $this->shared)
            ];

            $save  = array_merge($meta, $attributes);

            $result = $this->_db->storage->insertOne($save);
            $save['_id'] = $result->getInsertedId();

            $this->_logger->info('added new collection ['.$save['_id'].'] under parent ['.$this->_id.']', [
                'category' => get_class($this),
            ]);
            
	    if(!$this->isRoot()) {
                $this->changed = $save['changed'];
                $this->save('changed');
            }            

            $new = new Collection(new BSONDocument($save), $this->_fs, true);
            $this->_pluginmgr->run('postCreateCollection', [$this, $new, $clone]);
     
            return $new;
        } catch (\Exception $e) {
            $this->_logger->error('failed create new collection under parent ['.$this->_id.']', [
                'category' => get_class($this),
                'exception'=> $e,
            ]);

            throw $e;
        }
    }

    /**
     * Create new file as a child from this collection
     *
     * @param   string $name
     * @param   ressource|string $data
     * @param   array $attributes
     * @param   int $conflict
     * @param   bool $clone
     * @return  File
     */
    public function addFile($name, $data=null, array $attributes=[], int $conflict=INode::CONFLICT_NOACTION, bool $clone=false): File
    {
        if (!$this->isAllowed('w')) {
            throw new Exception\Forbidden('not allowed to create new node here',
                Exception\Forbidden::NOT_ALLOWED_TO_CREATE
            );
        }

        $this->_pluginmgr->run('preCreateFile', [$this, &$name, &$attributes, &$clone]);

        if ($this->readonly) {
            throw new Exception\Conflict('node is set as readonly, it is not possible to add new sub nodes',
                Exception\Conflict::READONLY
            );
        }

        $name = $this->checkName($name);

        if ($this->childExists($name)) {
            if ($conflict === INode::CONFLICT_NOACTION) {
                throw new Exception\Conflict('a node called '.$name.' does already exists in this collection',
                    Exception\Conflict::NODE_WITH_SAME_NAME_ALREADY_EXISTS
                );
            } elseif ($conflict === INode::CONFLICT_RENAME) {
                $name = $this->getDuplicateName($name);

The method getDuplicateName() does not exist on Balloon\Filesystem\Node\Collection. Did you maybe mean _getDuplicateName()?

            }
        }

        if ($this->isDeleted()) {
            throw new Exception\Conflict('could not add node '.$name.' into a deleted parent collection',
                Exception\Conflict::DELETED_PARENT
            );
        }

        try {
            $meta = [
                'name'      => $name,
                'deleted'   => false,
                'parent'    => $this->getRealId(),
                'directory' => false,
                'hash'      => null,
                'meta'      => [],
                'created'   => new UTCDateTime(),
                'changed'   => new UTCDateTime(),
                'owner'     => $this->_user->getId(),
                'history'   => [],
                'version'   => 0,
                'shared'    => ($this->shared === true ? $this->getRealId() : $this->shared),
            ];

            $save  = array_merge($meta, $attributes);

            $result = $this->_db->storage->insertOne($save);
            $save['_id'] = $result->getInsertedId();

            $this->_logger->info('added new file ['.$save['_id'].'] under parent ['.$this->_id.']', [
                'category' => get_class($this),
            ]);

            if(!$this->isRoot()) {
                $this->changed = $save['changed'];
                $this->save('changed');
            }            

            $file = new File(new BSONDocument($save), $this->_fs, true);

            try {
                $file->put($data, true, $attributes);

It seems like $data defined by parameter $data on line 931 can also be of type null; however, Balloon\Filesystem\Node\File::put() does only seem to accept resource|string, maybe add an additional type check?

            } catch (Exception\InsufficientStorage $e) {
                $this->_logger->warning('failed add new file under parent ['.$this->_id.'], cause user quota is full', [
                    'category' => get_class($this),
                    'exception' => $e,
                ]);

                $this->_db->storage->deleteOne([
                    '_id' => $save['_id']
                ]);

                throw $e;
            }
            
            $this->_pluginmgr->run('postCreateFile', [$this, $file, $clone]);

            return $file;
        } catch (\Exception $e) {
            $this->_logger->error('failed add new file under parent ['.$this->_id.']', [
                'category' => get_class($this),
                'exception' => $e,
            ]);

            throw $e;
        }
    }


    /**
     * Create new file wrapper
     * (Sabe\DAV compatible method, elsewhere use addFile()
     *
     * Sabre\DAV requires that createFile() returns the ETag instead the newly created file instance
     *
     * @param   string $name
     * @param   string $data
     * @return  File
     */
    public function createFile($name, $data=null): String
    {
        return $this->addFile($name, $data)->getETag();
    }
    

    /**
     * Create new directory wrapper
     * (Sabe\DAV compatible method, elsewhere use addDirectory()
     *
     * Sabre\DAV requires that createDirectory() returns void
     *
     * @param   string $name
     * @return  void
     */
    public function createDirectory($name): void
    {
        $this->addDirectory($name);
    }
}