63 lines
2.0 KiB
PHP
63 lines
2.0 KiB
PHP
<?php
|
|
|
|
namespace App\Services\Backups;
|
|
|
|
use Carbon\CarbonImmutable;
|
|
use App\Models\User;
|
|
use App\Models\Backup;
|
|
use App\Services\Nodes\NodeJWTService;
|
|
use App\Extensions\Backups\BackupManager;
|
|
|
|
class DownloadLinkService
|
|
{
|
|
/**
|
|
* DownloadLinkService constructor.
|
|
*/
|
|
public function __construct(private BackupManager $backupManager, private NodeJWTService $jwtService)
|
|
{
|
|
}
|
|
|
|
/**
|
|
* Returns the URL that allows for a backup to be downloaded by an individual
|
|
* user, or by the daemon control software.
|
|
*/
|
|
public function handle(Backup $backup, User $user): string
|
|
{
|
|
if ($backup->disk === Backup::ADAPTER_AWS_S3) {
|
|
return $this->getS3BackupUrl($backup);
|
|
}
|
|
|
|
$token = $this->jwtService
|
|
->setExpiresAt(CarbonImmutable::now()->addMinutes(15))
|
|
->setUser($user)
|
|
->setClaims([
|
|
'backup_uuid' => $backup->uuid,
|
|
'server_uuid' => $backup->server->uuid,
|
|
])
|
|
->handle($backup->server->node, $user->id . $backup->server->uuid);
|
|
|
|
return sprintf('%s/download/backup?token=%s', $backup->server->node->getConnectionAddress(), $token->toString());
|
|
}
|
|
|
|
/**
|
|
* Returns a signed URL that allows us to download a file directly out of a non-public
|
|
* S3 bucket by using a signed URL.
|
|
*/
|
|
protected function getS3BackupUrl(Backup $backup): string
|
|
{
|
|
/** @var \App\Extensions\Filesystem\S3Filesystem $adapter */
|
|
$adapter = $this->backupManager->adapter(Backup::ADAPTER_AWS_S3);
|
|
|
|
$request = $adapter->getClient()->createPresignedRequest(
|
|
$adapter->getClient()->getCommand('GetObject', [
|
|
'Bucket' => $adapter->getBucket(),
|
|
'Key' => sprintf('%s/%s.tar.gz', $backup->server->uuid, $backup->uuid),
|
|
'ContentType' => 'application/x-gzip',
|
|
]),
|
|
CarbonImmutable::now()->addMinutes(5)
|
|
);
|
|
|
|
return $request->getUri()->__toString();
|
|
}
|
|
}
|