MikoPBX\Core\System\UploadAndConvertFiles::uploadResumable()

Complexity

Conditions	9
Paths	10

Size

Total Lines	87
Code Lines	63

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public static function uploadResumable($parameters): array
    {
        $data['result'] = 'ERROR';

$data was never initialized. Although not strictly required by PHP, it is generally a good practice to add $data = array(); before regardless.

        $di             = Di::getDefault();
        if ($di === null) {
            return ['result' => 'ERROR', 'data' => 'Dependency injector not initialized'];
        }
        $upload_id            = $parameters['upload_id'];
        $resumableFilename    = $parameters['resumableFilename'];
        $resumableIdentifier  = $parameters['resumableIdentifier'];
        $resumableChunkNumber = $parameters['resumableChunkNumber'];
        $resumableTotalSize   = $parameters['resumableTotalSize'];
        $uploadPath              = $di->getShared('config')->path('core.uploadPath');

        $factory = new StreamFactory();

        foreach ($parameters['files'] as $file_data) {
            $stream   = $factory->createStreamFromFile($file_data['file_path'], 'r');
            $file = new UploadedFile(
                $stream,
                $file_data['file_size'],
                $file_data['file_error'],
                $file_data['file_name'],
                $file_data['file_type']
            );

            if (isset($resumableIdentifier) && trim($resumableIdentifier) !== '') {
                $temp_dir         = $uploadPath . '/' . Util::trimExtensionForFile(basename($resumableFilename));
                $temp_dst_file    = $uploadPath . '/' . $upload_id . '/' . basename($resumableFilename);
                $chunks_dest_file = $temp_dir . '/' . $resumableFilename . '.part' . $resumableChunkNumber;
            } else {
                $temp_dir         = $uploadPath . '/' . $upload_id;
                $temp_dst_file    = $temp_dir . '/' . basename($file->getClientFilename());
                $chunks_dest_file = $temp_dst_file;
            }
            if ( ! Util::mwMkdir($temp_dir) || ! Util::mwMkdir(dirname($temp_dst_file))) {
                Util::sysLogMsg('UploadFile', "Error create dir '$temp_dir'");
                return ['result' => 'ERROR', 'data' => "Error create dir 'temp_dir'"];
            }
            $file->moveTo($chunks_dest_file);
            // if (file_exists($file->))
            if ($resumableFilename) {
                $data['result'] = 'Success';
                // Передача файлов частями.
                $result = Util::createFileFromChunks($temp_dir, $resumableTotalSize);
                if ($result === true) {
                    $merge_settings = [
                        'data'   => [
                            'result_file'          => $temp_dst_file,
                            'temp_dir'             => $temp_dir,
                            'resumableFilename'    => $resumableFilename,
                            'resumableTotalChunks' => $resumableChunkNumber,
                        ],
                        'action' => 'merge',
                    ];
                    $settings_file  = "{$temp_dir}/merge_settings";
                    file_put_contents(
                        $settings_file,
                        json_encode($merge_settings, JSON_UNESCAPED_SLASHES | JSON_PRETTY_PRINT)
                    );

                    // Отправляем задачу на склеивание файла.
                    $phpPath              = Util::which('php');
                    $workerFilesMergerPath = Util::getFilePathByClassName(WorkerMergeUploadedFile::class);
                    Util::mwExecBg("{$phpPath} -f {$workerFilesMergerPath} '{$settings_file}'");

                    $data['upload_id'] = $upload_id;
                    $data['filename']  = $temp_dst_file;
                    $data['d_status']  = 'INPROGRESS';
                }
            } else {
                $data['result'] = 'Success';
                // Передача файла целиком.
                $data['upload_id'] = $upload_id;
                $data['filename']  = $temp_dst_file;
                $data['d_status']  = 'UPLOAD_COMPLETE';
                file_put_contents($temp_dir . '/progress', '100');

                Util::mwExecBg(
                    '/etc/rc/shell_functions.sh killprocesses ' . $temp_dir . ' -TERM 0;rm -rf ' . $temp_dir,
                    '/dev/null',
                    120
                );
            }
        }

        return $data;
    }
}