koel/app/Services/UploadService.php
2020-12-22 21:11:22 +01:00

80 lines
2.3 KiB
PHP

<?php
namespace App\Services;
use App\Exceptions\MediaPathNotSetException;
use App\Exceptions\SongUploadFailedException;
use App\Models\Setting;
use App\Models\Song;
use Illuminate\Http\UploadedFile;
use function Functional\memoize;
class UploadService
{
private const UPLOAD_DIRECTORY = '__KOEL_UPLOADS__';
private $fileSynchronizer;
public function __construct(FileSynchronizer $fileSynchronizer)
{
$this->fileSynchronizer = $fileSynchronizer;
}
/**
* @throws MediaPathNotSetException
* @throws SongUploadFailedException
*/
public function handleUploadedFile(UploadedFile $file): Song
{
$targetFileName = $this->getTargetFileName($file);
$file->move($this->getUploadDirectory(), $targetFileName);
$targetPathName = $this->getUploadDirectory() . $targetFileName;
$this->fileSynchronizer->setFile($targetPathName);
$result = $this->fileSynchronizer->sync(MediaSyncService::APPLICABLE_TAGS);
if ($result !== FileSynchronizer::SYNC_RESULT_SUCCESS) {
@unlink($targetPathName);
throw new SongUploadFailedException($this->fileSynchronizer->getSyncError());
}
return $this->fileSynchronizer->getSong();
}
/**
* @throws MediaPathNotSetException
*/
private function getUploadDirectory(): string
{
return memoize(static function (): string {
$mediaPath = Setting::get('media_path');
if (!$mediaPath) {
throw new MediaPathNotSetException();
}
return $mediaPath . DIRECTORY_SEPARATOR . self::UPLOAD_DIRECTORY . DIRECTORY_SEPARATOR;
});
}
/**
* @throws MediaPathNotSetException
*/
private function getTargetFileName(UploadedFile $file): string
{
// If there's no existing file with the same name in the upload directory, use the original name.
// Otherwise, prefix the original name with a hash.
// The whole point is to keep a readable file name when we can.
if (!file_exists($this->getUploadDirectory() . $file->getClientOriginalName())) {
return $file->getClientOriginalName();
}
return $this->getUniqueHash() . '_' . $file->getClientOriginalName();
}
private function getUniqueHash(): string
{
return substr(sha1(uniqid()), 0, 6);
}
}