andersundsehr/aus_driver_amazon_s3

<?php
 
/***
 *
 * This file is part of an extension for TYPO3 CMS.
 *
 * For the full copyright and license information, please read the
 * LICENSE.txt file that was distributed with this source code.
 *
 * (c) 2020 Markus Hölzle <typo3@markus-hoelzle.de>
 *
 ***/
 
namespace AUS\AusDriverAmazonS3\S3Adapter;
 
use Aws\Exception\MultipartUploadException;
use Aws\S3\MultipartUploader;
use TYPO3\CMS\Core\Resource\MimeTypeDetector;
use TYPO3\CMS\Core\Utility\GeneralUtility;
 
/**
 * Class MultipartUploaderAdapter
 *
 * @author Markus Hölzle <typo3@markus-hoelzle.de>
 * @package AUS\AusDriverAmazonS3\S3Adapter
 */
class MultipartUploaderAdapter extends AbstractS3Adapter
{
    const MAX_RETRIES = 10;
 
    /**
     * @param string $localFilePath File path and name on local storage
     * @param string $targetFilePath File path and name on target S3 bucket
     * @param string $bucket S3 bucket name
     * @param string $cacheControl Cache control header
     */
Method `upload` has 27 lines of code (exceeds 25 allowed). Consider refactoring.
    public function upload(string $localFilePath, string $targetFilePath, string $bucket, string $cacheControl): void
    {
        $contentType = $this->detectContentType($localFilePath, $targetFilePath);
 
        $uploader = new MultipartUploader($this->s3Client, $localFilePath, [
            'bucket' => $bucket,
            'key' => $targetFilePath,
            'params' => [
                'ContentType' => $contentType,
                'CacheControl' => $cacheControl,
            ],
        ]);
 
        // Upload and recover from errors
        $errorCount = 0;
        do {
            try {
                $result = $uploader->upload();
            } catch (MultipartUploadException $e) {
                $uploader = new MultipartUploader($this->s3Client, $localFilePath, [
                    'state' => $e->getState(),
                ]);
                $errorCount++;
            }
        } while (!isset($result) && $errorCount < self::MAX_RETRIES);
 
        // Abort a multipart upload if failed
        try {
            $uploader->upload();
        } catch (MultipartUploadException $e) {
            // State contains the "Bucket", "Key", and "UploadId"
            $params = $e->getState()->getId();
            $this->s3Client->abortMultipartUpload($params);
            throw $e;
        }
    }
 
    public function detectContentType(string $localFilePath, string $targetFilePath): string
    {
        $fileInfo = finfo_open(FILEINFO_MIME_TYPE);
        $contentType = finfo_file($fileInfo, $localFilePath);
        finfo_close($fileInfo);
 
        $mimeDetector = GeneralUtility::makeInstance(MimeTypeDetector::class);
        if (
            $contentType === 'text/plain'
            || $contentType === 'application/octet-stream'
            || $contentType === 'image/svg'
        ) {
            // file's magic database often fails to detect plain text files
            // we manually fix the mime type here.
            $ext = pathinfo($targetFilePath, PATHINFO_EXTENSION);
            $mimeTypes = $mimeDetector->getMimeTypesForFileExtension($ext) ;
            return $mimeTypes ? $mimeTypes[0] : $contentType;
        }
        return $contentType;
    }
}