2719d66042
Enable scheduled ClickHouse backups across the job, API, and UI, and guard unsupported database types via isBackupSolutionAvailable(). Convert Stripe subscription sync from a job to an action with clearer discrepancy resolution, and add cloud:export-users plus cloud:cleanup-unverified-users with tests.
37 lines
1.3 KiB
PHP
37 lines
1.3 KiB
PHP
<?php
|
|
|
|
namespace App\Support;
|
|
|
|
final class ClickhouseBackupCommand
|
|
{
|
|
/** @return array<int, string> */
|
|
public static function make(
|
|
string $containerName,
|
|
string $database,
|
|
string $archiveName,
|
|
string $backupDirectory,
|
|
): array {
|
|
validateShellSafePath($database, 'database name');
|
|
validateFilenameSafe($archiveName, 'ClickHouse backup archive');
|
|
|
|
$backupDirectory = rtrim($backupDirectory, '/');
|
|
$containerBackupPath = '/var/lib/clickhouse/backups/'.$archiveName;
|
|
$backupLocation = $backupDirectory.'/'.$archiveName;
|
|
$query = "BACKUP DATABASE `{$database}` TO File('{$archiveName}')";
|
|
|
|
return [
|
|
'mkdir -p '.escapeshellarg($backupDirectory),
|
|
'docker exec '.escapeshellarg($containerName).' clickhouse-client --query '.escapeshellarg($query),
|
|
'docker cp '.escapeshellarg($containerName.':'.$containerBackupPath).' '.escapeshellarg($backupLocation),
|
|
];
|
|
}
|
|
|
|
public static function cleanup(string $containerName, string $archiveName): string
|
|
{
|
|
validateFilenameSafe($archiveName, 'ClickHouse backup archive');
|
|
|
|
$containerBackupPath = '/var/lib/clickhouse/backups/'.$archiveName;
|
|
|
|
return 'docker exec '.escapeshellarg($containerName).' rm -f '.escapeshellarg($containerBackupPath);
|
|
}
|
|
}
|