Balloon\App\Api\v2\Files::putChunk()

Complexity

Conditions	12
Paths	109

Size

Total Lines	94
Code Lines	63

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function putChunk(
        ?ObjectId $session = null,
        ?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 ($index > $chunks) {
            throw new Exception\InvalidArgument('chunk index can not be greater than the total number of chunks');
        }

        if ($session === null) {
            $session = new ObjectId();
        }

        $folder = $this->server->getTempDir().DIRECTORY_SEPARATOR.'upload'.DIRECTORY_SEPARATOR.$this->user->getId();

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

        $file = $folder.DIRECTORY_SEPARATOR.$session;

        $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
            );
        }

        $session_handler = fopen($file, 'a+');
        while (!feof($input_handler)) {
            $data = fread($input_handler, 1024);
            $wrote = fwrite($session_handler, $data);
            $tmp_size += $wrote;

            if ($tmp_size > (int) $this->server->getMaxFileSize()) {
                fclose($input_handler);
                fclose($session_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($session_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([
                'session' => (string) $session,
                'size' => $tmp_size,
                'chunks_left' => $chunks - $index,
            ]);
        }
    }