Balloon\Rest\v1\File::putChunk()

Complexity

Conditions	13
Paths	56

Size

Total Lines	83
Code Lines	57

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function putChunk(
        string $chunkgroup,
        ?string $id=null,
        ?string $p=null,
        ?string $collection=null,
        ?string $name=null,
        int $index=1,
        int $chunks=0,
        int $size=0,
        array $attributes=[],
        int $conflict=0)
    {
        ini_set('auto_detect_line_endings', '1');
        $input_handler = fopen('php://input', 'rb');
        if (!is_string($chunkgroup) || empty($chunkgroup)) {
            throw new Exception\InvalidArgument('chunkgroup must be valid unique string');
        }
        
        if ($index > $chunks) {
            throw new Exception\InvalidArgument('chunk index can not be greater than the total number of chunks');
        }

        $chunkgroup = Helper::filter($chunkgroup);
        $folder     = $this->config->dir->temp.DIRECTORY_SEPARATOR.'upload'.DIRECTORY_SEPARATOR.$this->user->getId();

The property dir does not exist on object<Balloon\Config>. Since you implemented __get, maybe consider adding a @property annotation.

        if (!file_exists($folder)) {
            mkdir($folder, 0700, true);
        }

        $file = $folder.DIRECTORY_SEPARATOR.$chunkgroup;

        $tmp_size = 0;
        if (file_exists($file)) {
            $tmp_size = filesize($file);
        } elseif ($index > 1) {
            throw new Exception\Conflict('chunks lost, reupload all chunks',
                Exception\Conflict::CHUNKS_LOST
            );
        }
        
        $chunkgroup_handler = fopen($file, 'a+');
        while (!feof($input_handler)) {
            $data  = fread($input_handler, 1024);
            $wrote = fwrite($chunkgroup_handler, $data);
            $tmp_size += $wrote;

            if ($tmp_size > (int)$this->config->file->max_size) {

The property file does not exist on object<Balloon\Config>. Since you implemented __get, maybe consider adding a @property annotation.

                fclose($input_handler);
                fclose($chunkgroup_handler);
                unlink($file);
                throw new Exception\InsufficientStorage('file size exceeded limit',
                    Exception\InsufficientStorage::FILE_SIZE_LIMIT
                );
            }
        }
    
        if ($index == $chunks) {
            clearstatcache();
            if (!is_readable($file)) {
                throw new Exception\Conflict('chunks lost, reupload all chunks',
                    Exception\Conflict::CHUNKS_LOST
                );
            }
            
            if ($tmp_size != $size) {
                fclose($chunkgroup_handler);
                unlink($file);
                throw new Exception\Conflict('merged chunks temp file size is not as expected',
                    Exception\Conflict::CHUNKS_INVALID_SIZE
                );
            }
            
            try {
                $attributes = $this->_verifyAttributes($attributes);
                return $this->_put($file, $id, $p, $collection, $name, $attributes, $conflict);
            } catch (\Exception $e) {
                unlink($file);
                throw $e;
            }
        } else {
            return (new Response())->setCode(206)->setBody($index);
        }
    }