Merge pull request #5697 from DanielHemmati/feat/manage-db-using-api
[Enhancement]: See and manage DB backups via API
This commit is contained in:
@@ -9,8 +9,10 @@ use App\Actions\Database\StopDatabase;
|
|||||||
use App\Actions\Database\StopDatabaseProxy;
|
use App\Actions\Database\StopDatabaseProxy;
|
||||||
use App\Enums\NewDatabaseTypes;
|
use App\Enums\NewDatabaseTypes;
|
||||||
use App\Http\Controllers\Controller;
|
use App\Http\Controllers\Controller;
|
||||||
|
use App\Jobs\DatabaseBackupJob;
|
||||||
use App\Jobs\DeleteResourceJob;
|
use App\Jobs\DeleteResourceJob;
|
||||||
use App\Models\Project;
|
use App\Models\Project;
|
||||||
|
use App\Models\ScheduledDatabaseBackup;
|
||||||
use App\Models\Server;
|
use App\Models\Server;
|
||||||
use App\Models\StandalonePostgresql;
|
use App\Models\StandalonePostgresql;
|
||||||
use Illuminate\Http\Request;
|
use Illuminate\Http\Request;
|
||||||
@@ -79,13 +81,88 @@ class DatabasesController extends Controller
|
|||||||
foreach ($projects as $project) {
|
foreach ($projects as $project) {
|
||||||
$databases = $databases->merge($project->databases());
|
$databases = $databases->merge($project->databases());
|
||||||
}
|
}
|
||||||
$databases = $databases->map(function ($database) {
|
|
||||||
|
$databaseIds = $databases->pluck('id')->toArray();
|
||||||
|
|
||||||
|
$backupConfigs = ScheduledDatabaseBackup::with('latest_log')
|
||||||
|
->whereIn('database_id', $databaseIds)
|
||||||
|
->get()
|
||||||
|
->groupBy('database_id');
|
||||||
|
|
||||||
|
$databases = $databases->map(function ($database) use ($backupConfigs) {
|
||||||
|
$database->backup_configs = $backupConfigs->get($database->id, collect())->values();
|
||||||
|
|
||||||
return $this->removeSensitiveData($database);
|
return $this->removeSensitiveData($database);
|
||||||
});
|
});
|
||||||
|
|
||||||
return response()->json($databases);
|
return response()->json($databases);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[OA\Get(
|
||||||
|
summary: 'Get',
|
||||||
|
description: 'Get backups details by database UUID.',
|
||||||
|
path: '/databases/{uuid}/backups',
|
||||||
|
operationId: 'get-database-backups-by-uuid',
|
||||||
|
security: [
|
||||||
|
['bearerAuth' => []],
|
||||||
|
],
|
||||||
|
tags: ['Databases'],
|
||||||
|
parameters: [
|
||||||
|
new OA\Parameter(
|
||||||
|
name: 'uuid',
|
||||||
|
in: 'path',
|
||||||
|
description: 'UUID of the database.',
|
||||||
|
required: true,
|
||||||
|
schema: new OA\Schema(
|
||||||
|
type: 'string',
|
||||||
|
format: 'uuid',
|
||||||
|
)
|
||||||
|
),
|
||||||
|
],
|
||||||
|
responses: [
|
||||||
|
new OA\Response(
|
||||||
|
response: 200,
|
||||||
|
description: 'Get all backups for a database',
|
||||||
|
content: new OA\JsonContent(
|
||||||
|
type: 'string',
|
||||||
|
example: 'Content is very complex. Will be implemented later.',
|
||||||
|
),
|
||||||
|
),
|
||||||
|
new OA\Response(
|
||||||
|
response: 401,
|
||||||
|
ref: '#/components/responses/401',
|
||||||
|
),
|
||||||
|
new OA\Response(
|
||||||
|
response: 400,
|
||||||
|
ref: '#/components/responses/400',
|
||||||
|
),
|
||||||
|
new OA\Response(
|
||||||
|
response: 404,
|
||||||
|
ref: '#/components/responses/404',
|
||||||
|
),
|
||||||
|
]
|
||||||
|
)]
|
||||||
|
public function database_backup_details_uuid(Request $request)
|
||||||
|
{
|
||||||
|
$teamId = getTeamIdFromToken();
|
||||||
|
if (is_null($teamId)) {
|
||||||
|
return invalidTokenResponse();
|
||||||
|
}
|
||||||
|
if (! $request->uuid) {
|
||||||
|
return response()->json(['message' => 'UUID is required.'], 404);
|
||||||
|
}
|
||||||
|
$database = queryDatabaseByUuidWithinTeam($request->uuid, $teamId);
|
||||||
|
if (! $database) {
|
||||||
|
return response()->json(['message' => 'Database not found.'], 404);
|
||||||
|
}
|
||||||
|
|
||||||
|
$this->authorize('view', $database);
|
||||||
|
|
||||||
|
$backupConfig = ScheduledDatabaseBackup::with('executions')->where('database_id', $database->id)->get();
|
||||||
|
|
||||||
|
return response()->json($backupConfig);
|
||||||
|
}
|
||||||
|
|
||||||
#[OA\Get(
|
#[OA\Get(
|
||||||
summary: 'Get',
|
summary: 'Get',
|
||||||
description: 'Get database by UUID.',
|
description: 'Get database by UUID.',
|
||||||
@@ -217,6 +294,19 @@ class DatabasesController extends Controller
|
|||||||
'mysql_user' => ['type' => 'string', 'description' => 'MySQL user'],
|
'mysql_user' => ['type' => 'string', 'description' => 'MySQL user'],
|
||||||
'mysql_database' => ['type' => 'string', 'description' => 'MySQL database'],
|
'mysql_database' => ['type' => 'string', 'description' => 'MySQL database'],
|
||||||
'mysql_conf' => ['type' => 'string', 'description' => 'MySQL conf'],
|
'mysql_conf' => ['type' => 'string', 'description' => 'MySQL conf'],
|
||||||
|
'save_s3' => ['type' => 'boolean', 'description' => 'Whether data is saved in s3 or not'],
|
||||||
|
's3_storage_uuid' => ['type' => 'string', 'description' => 'S3 storage UUID'],
|
||||||
|
'backup_now' => ['type' => 'boolean', 'description' => 'Whether to take a backup now or not'],
|
||||||
|
'enabled' => ['type' => 'boolean', 'description' => 'Whether the backup is enabled or not'],
|
||||||
|
'databases_to_backup' => ['type' => 'string', 'description' => 'Comma separated list of databases to backup'],
|
||||||
|
'dump_all' => ['type' => 'boolean', 'description' => 'Whether all databases are dumped or not'],
|
||||||
|
'frequency' => ['type' => 'string', 'description' => 'Frequency of the backup'],
|
||||||
|
'database_backup_retention_amount_locally' => ['type' => 'integer', 'description' => 'Retention amount of the backup locally'],
|
||||||
|
'database_backup_retention_days_locally' => ['type' => 'integer', 'description' => 'Retention days of the backup locally'],
|
||||||
|
'database_backup_retention_max_storage_locally' => ['type' => 'integer', 'description' => 'Max storage of the backup locally'],
|
||||||
|
'database_backup_retention_amount_s3' => ['type' => 'integer', 'description' => 'Retention amount of the backup in s3'],
|
||||||
|
'database_backup_retention_days_s3' => ['type' => 'integer', 'description' => 'Retention days of the backup in s3'],
|
||||||
|
'database_backup_retention_max_storage_s3' => ['type' => 'integer', 'description' => 'Max storage of the backup in S3'],
|
||||||
],
|
],
|
||||||
),
|
),
|
||||||
)
|
)
|
||||||
@@ -248,6 +338,7 @@ class DatabasesController extends Controller
|
|||||||
return invalidTokenResponse();
|
return invalidTokenResponse();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// this check if the request is a valid json
|
||||||
$return = validateIncomingRequest($request);
|
$return = validateIncomingRequest($request);
|
||||||
if ($return instanceof \Illuminate\Http\JsonResponse) {
|
if ($return instanceof \Illuminate\Http\JsonResponse) {
|
||||||
return $return;
|
return $return;
|
||||||
@@ -499,6 +590,7 @@ class DatabasesController extends Controller
|
|||||||
$whatToDoWithDatabaseProxy = 'start';
|
$whatToDoWithDatabaseProxy = 'start';
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Only update database fields, not backup configuration
|
||||||
$database->update($request->all());
|
$database->update($request->all());
|
||||||
|
|
||||||
if ($whatToDoWithDatabaseProxy === 'start') {
|
if ($whatToDoWithDatabaseProxy === 'start') {
|
||||||
@@ -512,6 +604,174 @@ class DatabasesController extends Controller
|
|||||||
]);
|
]);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[OA\Patch(
|
||||||
|
summary: 'Update',
|
||||||
|
description: 'Update a specific backup configuration for a given database, identified by its UUID and the backup ID',
|
||||||
|
path: '/databases/{uuid}/backups/{scheduled_backup_uuid}',
|
||||||
|
operationId: 'update-database-backup',
|
||||||
|
security: [
|
||||||
|
['bearerAuth' => []],
|
||||||
|
],
|
||||||
|
tags: ['Databases'],
|
||||||
|
parameters: [
|
||||||
|
new OA\Parameter(
|
||||||
|
name: 'uuid',
|
||||||
|
in: 'path',
|
||||||
|
description: 'UUID of the database.',
|
||||||
|
required: true,
|
||||||
|
schema: new OA\Schema(
|
||||||
|
type: 'string',
|
||||||
|
format: 'uuid',
|
||||||
|
)
|
||||||
|
),
|
||||||
|
new OA\Parameter(
|
||||||
|
name: 'scheduled_backup_uuid',
|
||||||
|
in: 'path',
|
||||||
|
description: 'UUID of the backup configuration.',
|
||||||
|
required: true,
|
||||||
|
schema: new OA\Schema(
|
||||||
|
type: 'string',
|
||||||
|
format: 'uuid',
|
||||||
|
)
|
||||||
|
),
|
||||||
|
],
|
||||||
|
requestBody: new OA\RequestBody(
|
||||||
|
description: 'Database backup configuration data',
|
||||||
|
required: true,
|
||||||
|
content: new OA\MediaType(
|
||||||
|
mediaType: 'application/json',
|
||||||
|
schema: new OA\Schema(
|
||||||
|
type: 'object',
|
||||||
|
properties: [
|
||||||
|
'save_s3' => ['type' => 'boolean', 'description' => 'Whether data is saved in s3 or not'],
|
||||||
|
's3_storage_uuid' => ['type' => 'string', 'description' => 'S3 storage UUID'],
|
||||||
|
'backup_now' => ['type' => 'boolean', 'description' => 'Whether to take a backup now or not'],
|
||||||
|
'enabled' => ['type' => 'boolean', 'description' => 'Whether the backup is enabled or not'],
|
||||||
|
'databases_to_backup' => ['type' => 'string', 'description' => 'Comma separated list of databases to backup'],
|
||||||
|
'dump_all' => ['type' => 'boolean', 'description' => 'Whether all databases are dumped or not'],
|
||||||
|
'frequency' => ['type' => 'string', 'description' => 'Frequency of the backup'],
|
||||||
|
'database_backup_retention_amount_locally' => ['type' => 'integer', 'description' => 'Retention amount of the backup locally'],
|
||||||
|
'database_backup_retention_days_locally' => ['type' => 'integer', 'description' => 'Retention days of the backup locally'],
|
||||||
|
'database_backup_retention_max_storage_locally' => ['type' => 'integer', 'description' => 'Max storage of the backup locally'],
|
||||||
|
'database_backup_retention_amount_s3' => ['type' => 'integer', 'description' => 'Retention amount of the backup in s3'],
|
||||||
|
'database_backup_retention_days_s3' => ['type' => 'integer', 'description' => 'Retention days of the backup in s3'],
|
||||||
|
'database_backup_retention_max_storage_s3' => ['type' => 'integer', 'description' => 'Max storage of the backup in S3'],
|
||||||
|
],
|
||||||
|
),
|
||||||
|
)
|
||||||
|
),
|
||||||
|
responses: [
|
||||||
|
new OA\Response(
|
||||||
|
response: 200,
|
||||||
|
description: 'Database backup configuration updated',
|
||||||
|
),
|
||||||
|
new OA\Response(
|
||||||
|
response: 401,
|
||||||
|
ref: '#/components/responses/401',
|
||||||
|
),
|
||||||
|
new OA\Response(
|
||||||
|
response: 400,
|
||||||
|
ref: '#/components/responses/400',
|
||||||
|
),
|
||||||
|
new OA\Response(
|
||||||
|
response: 404,
|
||||||
|
ref: '#/components/responses/404',
|
||||||
|
),
|
||||||
|
]
|
||||||
|
)]
|
||||||
|
public function update_backup(Request $request)
|
||||||
|
{
|
||||||
|
$backupConfigFields = ['save_s3', 'enabled', 'dump_all', 'frequency', 'databases_to_backup', 'database_backup_retention_amount_locally', 'database_backup_retention_days_locally', 'database_backup_retention_max_storage_locally', 'database_backup_retention_amount_s3', 'database_backup_retention_days_s3', 'database_backup_retention_max_storage_s3', 's3_storage_uuid'];
|
||||||
|
|
||||||
|
$teamId = getTeamIdFromToken();
|
||||||
|
if (is_null($teamId)) {
|
||||||
|
return invalidTokenResponse();
|
||||||
|
}
|
||||||
|
// this check if the request is a valid json
|
||||||
|
$return = validateIncomingRequest($request);
|
||||||
|
if ($return instanceof \Illuminate\Http\JsonResponse) {
|
||||||
|
return $return;
|
||||||
|
}
|
||||||
|
$validator = customApiValidator($request->all(), [
|
||||||
|
'save_s3' => 'boolean',
|
||||||
|
'backup_now' => 'boolean|nullable',
|
||||||
|
'enabled' => 'boolean',
|
||||||
|
'dump_all' => 'boolean',
|
||||||
|
's3_storage_uuid' => 'string|exists:s3_storages,uuid|nullable',
|
||||||
|
'databases_to_backup' => 'string|nullable',
|
||||||
|
'frequency' => 'string|in:every_minute,hourly,daily,weekly,monthly,yearly',
|
||||||
|
'database_backup_retention_amount_locally' => 'integer|min:0',
|
||||||
|
'database_backup_retention_days_locally' => 'integer|min:0',
|
||||||
|
'database_backup_retention_max_storage_locally' => 'integer|min:0',
|
||||||
|
'database_backup_retention_amount_s3' => 'integer|min:0',
|
||||||
|
'database_backup_retention_days_s3' => 'integer|min:0',
|
||||||
|
'database_backup_retention_max_storage_s3' => 'integer|min:0',
|
||||||
|
]);
|
||||||
|
if ($validator->fails()) {
|
||||||
|
return response()->json([
|
||||||
|
'message' => 'Validation failed.',
|
||||||
|
'errors' => $validator->errors(),
|
||||||
|
], 422);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (! $request->uuid) {
|
||||||
|
return response()->json(['message' => 'UUID is required.'], 404);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Validate scheduled_backup_uuid is provided
|
||||||
|
if (! $request->scheduled_backup_uuid) {
|
||||||
|
return response()->json(['message' => 'Scheduled backup UUID is required.'], 400);
|
||||||
|
}
|
||||||
|
|
||||||
|
$uuid = $request->uuid;
|
||||||
|
removeUnnecessaryFieldsFromRequest($request);
|
||||||
|
$database = queryDatabaseByUuidWithinTeam($uuid, $teamId);
|
||||||
|
if (! $database) {
|
||||||
|
return response()->json(['message' => 'Database not found.'], 404);
|
||||||
|
}
|
||||||
|
|
||||||
|
$backupConfig = ScheduledDatabaseBackup::where('database_id', $database->id)
|
||||||
|
->where('uuid', $request->scheduled_backup_uuid)
|
||||||
|
->first();
|
||||||
|
if (! $backupConfig) {
|
||||||
|
return response()->json(['message' => 'Backup config not found.'], 404);
|
||||||
|
}
|
||||||
|
|
||||||
|
$extraFields = array_diff(array_keys($request->all()), $backupConfigFields, ['backup_now']);
|
||||||
|
if (! empty($extraFields)) {
|
||||||
|
$errors = $validator->errors();
|
||||||
|
foreach ($extraFields as $field) {
|
||||||
|
$errors->add($field, 'This field is not allowed.');
|
||||||
|
}
|
||||||
|
|
||||||
|
return response()->json([
|
||||||
|
'message' => 'Validation failed.',
|
||||||
|
'errors' => $errors,
|
||||||
|
], 422);
|
||||||
|
}
|
||||||
|
|
||||||
|
$backupData = $request->only($backupConfigFields);
|
||||||
|
|
||||||
|
// Convert s3_storage_uuid to s3_storage_id
|
||||||
|
if (isset($backupData['s3_storage_uuid'])) {
|
||||||
|
$s3Storage = \App\Models\S3Storage::where('uuid', $backupData['s3_storage_uuid'])->first();
|
||||||
|
if ($s3Storage) {
|
||||||
|
$backupData['s3_storage_id'] = $s3Storage->id;
|
||||||
|
}
|
||||||
|
unset($backupData['s3_storage_uuid']);
|
||||||
|
}
|
||||||
|
|
||||||
|
$backupConfig->update($backupData);
|
||||||
|
|
||||||
|
if ($request->backup_now) {
|
||||||
|
DatabaseBackupJob::dispatch($backupConfig);
|
||||||
|
}
|
||||||
|
|
||||||
|
return response()->json([
|
||||||
|
'message' => 'Database backup configuration updated',
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
|
||||||
#[OA\Post(
|
#[OA\Post(
|
||||||
summary: 'Create (PostgreSQL)',
|
summary: 'Create (PostgreSQL)',
|
||||||
description: 'Create a new PostgreSQL database.',
|
description: 'Create a new PostgreSQL database.',
|
||||||
@@ -1630,6 +1890,336 @@ class DatabasesController extends Controller
|
|||||||
]);
|
]);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[OA\Delete(
|
||||||
|
summary: 'Delete backup configuration',
|
||||||
|
description: 'Deletes a backup configuration and all its executions.',
|
||||||
|
path: '/databases/{uuid}/backups/{scheduled_backup_uuid}',
|
||||||
|
operationId: 'delete-backup-configuration-by-uuid',
|
||||||
|
security: [
|
||||||
|
['bearerAuth' => []],
|
||||||
|
],
|
||||||
|
tags: ['Databases'],
|
||||||
|
parameters: [
|
||||||
|
new OA\Parameter(
|
||||||
|
name: 'uuid',
|
||||||
|
in: 'path',
|
||||||
|
required: true,
|
||||||
|
description: 'UUID of the database',
|
||||||
|
schema: new OA\Schema(type: 'string')
|
||||||
|
),
|
||||||
|
new OA\Parameter(
|
||||||
|
name: 'scheduled_backup_uuid',
|
||||||
|
in: 'path',
|
||||||
|
required: true,
|
||||||
|
description: 'UUID of the backup configuration to delete',
|
||||||
|
schema: new OA\Schema(type: 'string', format: 'uuid')
|
||||||
|
),
|
||||||
|
new OA\Parameter(
|
||||||
|
name: 'delete_s3',
|
||||||
|
in: 'query',
|
||||||
|
required: false,
|
||||||
|
description: 'Whether to delete all backup files from S3',
|
||||||
|
schema: new OA\Schema(type: 'boolean', default: false)
|
||||||
|
),
|
||||||
|
],
|
||||||
|
responses: [
|
||||||
|
new OA\Response(
|
||||||
|
response: 200,
|
||||||
|
description: 'Backup configuration deleted.',
|
||||||
|
content: new OA\JsonContent(
|
||||||
|
type: 'object',
|
||||||
|
properties: [
|
||||||
|
'message' => new OA\Schema(type: 'string', example: 'Backup configuration and all executions deleted.'),
|
||||||
|
]
|
||||||
|
)
|
||||||
|
),
|
||||||
|
new OA\Response(
|
||||||
|
response: 404,
|
||||||
|
description: 'Backup configuration not found.',
|
||||||
|
content: new OA\JsonContent(
|
||||||
|
type: 'object',
|
||||||
|
properties: [
|
||||||
|
'message' => new OA\Schema(type: 'string', example: 'Backup configuration not found.'),
|
||||||
|
]
|
||||||
|
)
|
||||||
|
),
|
||||||
|
]
|
||||||
|
)]
|
||||||
|
public function delete_backup_by_uuid(Request $request)
|
||||||
|
{
|
||||||
|
$teamId = getTeamIdFromToken();
|
||||||
|
if (is_null($teamId)) {
|
||||||
|
return invalidTokenResponse();
|
||||||
|
}
|
||||||
|
|
||||||
|
// Validate scheduled_backup_uuid is provided
|
||||||
|
if (! $request->scheduled_backup_uuid) {
|
||||||
|
return response()->json(['message' => 'Scheduled backup UUID is required.'], 400);
|
||||||
|
}
|
||||||
|
|
||||||
|
$database = queryDatabaseByUuidWithinTeam($request->uuid, $teamId);
|
||||||
|
if (! $database) {
|
||||||
|
return response()->json(['message' => 'Database not found.'], 404);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Find the backup configuration by its UUID
|
||||||
|
$backup = ScheduledDatabaseBackup::where('database_id', $database->id)
|
||||||
|
->where('uuid', $request->scheduled_backup_uuid)
|
||||||
|
->first();
|
||||||
|
|
||||||
|
if (! $backup) {
|
||||||
|
return response()->json(['message' => 'Backup configuration not found.'], 404);
|
||||||
|
}
|
||||||
|
|
||||||
|
$deleteS3 = filter_var($request->query->get('delete_s3', false), FILTER_VALIDATE_BOOLEAN);
|
||||||
|
|
||||||
|
try {
|
||||||
|
// Get all executions for this backup configuration
|
||||||
|
$executions = $backup->executions()->get();
|
||||||
|
|
||||||
|
// Delete all execution files (locally and optionally from S3)
|
||||||
|
foreach ($executions as $execution) {
|
||||||
|
if ($execution->filename) {
|
||||||
|
deleteBackupsLocally($execution->filename, $database->destination->server);
|
||||||
|
|
||||||
|
if ($deleteS3 && $backup->s3) {
|
||||||
|
deleteBackupsS3($execution->filename, $backup->s3);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$execution->delete();
|
||||||
|
}
|
||||||
|
|
||||||
|
// Delete the backup configuration itself
|
||||||
|
$backup->delete();
|
||||||
|
|
||||||
|
return response()->json([
|
||||||
|
'message' => 'Backup configuration and all executions deleted.',
|
||||||
|
]);
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
return response()->json(['message' => 'Failed to delete backup: '.$e->getMessage()], 500);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[OA\Delete(
|
||||||
|
summary: 'Delete backup execution',
|
||||||
|
description: 'Deletes a specific backup execution.',
|
||||||
|
path: '/databases/{uuid}/backups/{scheduled_backup_uuid}/executions/{execution_uuid}',
|
||||||
|
operationId: 'delete-backup-execution-by-uuid',
|
||||||
|
security: [
|
||||||
|
['bearerAuth' => []],
|
||||||
|
],
|
||||||
|
tags: ['Databases'],
|
||||||
|
parameters: [
|
||||||
|
new OA\Parameter(
|
||||||
|
name: 'uuid',
|
||||||
|
in: 'path',
|
||||||
|
required: true,
|
||||||
|
description: 'UUID of the database',
|
||||||
|
schema: new OA\Schema(type: 'string')
|
||||||
|
),
|
||||||
|
new OA\Parameter(
|
||||||
|
name: 'scheduled_backup_uuid',
|
||||||
|
in: 'path',
|
||||||
|
required: true,
|
||||||
|
description: 'UUID of the backup configuration',
|
||||||
|
schema: new OA\Schema(type: 'string', format: 'uuid')
|
||||||
|
),
|
||||||
|
new OA\Parameter(
|
||||||
|
name: 'execution_uuid',
|
||||||
|
in: 'path',
|
||||||
|
required: true,
|
||||||
|
description: 'UUID of the backup execution to delete',
|
||||||
|
schema: new OA\Schema(type: 'string', format: 'uuid')
|
||||||
|
),
|
||||||
|
new OA\Parameter(
|
||||||
|
name: 'delete_s3',
|
||||||
|
in: 'query',
|
||||||
|
required: false,
|
||||||
|
description: 'Whether to delete the backup from S3',
|
||||||
|
schema: new OA\Schema(type: 'boolean', default: false)
|
||||||
|
),
|
||||||
|
],
|
||||||
|
responses: [
|
||||||
|
new OA\Response(
|
||||||
|
response: 200,
|
||||||
|
description: 'Backup execution deleted.',
|
||||||
|
content: new OA\JsonContent(
|
||||||
|
type: 'object',
|
||||||
|
properties: [
|
||||||
|
'message' => new OA\Schema(type: 'string', example: 'Backup execution deleted.'),
|
||||||
|
]
|
||||||
|
)
|
||||||
|
),
|
||||||
|
new OA\Response(
|
||||||
|
response: 404,
|
||||||
|
description: 'Backup execution not found.',
|
||||||
|
content: new OA\JsonContent(
|
||||||
|
type: 'object',
|
||||||
|
properties: [
|
||||||
|
'message' => new OA\Schema(type: 'string', example: 'Backup execution not found.'),
|
||||||
|
]
|
||||||
|
)
|
||||||
|
),
|
||||||
|
]
|
||||||
|
)]
|
||||||
|
public function delete_execution_by_uuid(Request $request)
|
||||||
|
{
|
||||||
|
$teamId = getTeamIdFromToken();
|
||||||
|
if (is_null($teamId)) {
|
||||||
|
return invalidTokenResponse();
|
||||||
|
}
|
||||||
|
|
||||||
|
// Validate parameters
|
||||||
|
if (! $request->scheduled_backup_uuid) {
|
||||||
|
return response()->json(['message' => 'Scheduled backup UUID is required.'], 400);
|
||||||
|
}
|
||||||
|
if (! $request->execution_uuid) {
|
||||||
|
return response()->json(['message' => 'Execution UUID is required.'], 400);
|
||||||
|
}
|
||||||
|
|
||||||
|
$database = queryDatabaseByUuidWithinTeam($request->uuid, $teamId);
|
||||||
|
if (! $database) {
|
||||||
|
return response()->json(['message' => 'Database not found.'], 404);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Find the backup configuration by its UUID
|
||||||
|
$backup = ScheduledDatabaseBackup::where('database_id', $database->id)
|
||||||
|
->where('uuid', $request->scheduled_backup_uuid)
|
||||||
|
->first();
|
||||||
|
|
||||||
|
if (! $backup) {
|
||||||
|
return response()->json(['message' => 'Backup configuration not found.'], 404);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Find the specific execution
|
||||||
|
$execution = $backup->executions()->where('uuid', $request->execution_uuid)->first();
|
||||||
|
if (! $execution) {
|
||||||
|
return response()->json(['message' => 'Backup execution not found.'], 404);
|
||||||
|
}
|
||||||
|
|
||||||
|
$deleteS3 = filter_var($request->query->get('delete_s3', false), FILTER_VALIDATE_BOOLEAN);
|
||||||
|
|
||||||
|
try {
|
||||||
|
if ($execution->filename) {
|
||||||
|
deleteBackupsLocally($execution->filename, $database->destination->server);
|
||||||
|
|
||||||
|
if ($deleteS3 && $backup->s3) {
|
||||||
|
deleteBackupsS3($execution->filename, $backup->s3);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$execution->delete();
|
||||||
|
|
||||||
|
return response()->json([
|
||||||
|
'message' => 'Backup execution deleted.',
|
||||||
|
]);
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
return response()->json(['message' => 'Failed to delete backup execution: '.$e->getMessage()], 500);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[OA\Get(
|
||||||
|
summary: 'List backup executions',
|
||||||
|
description: 'Get all executions for a specific backup configuration.',
|
||||||
|
path: '/databases/{uuid}/backups/{scheduled_backup_uuid}/executions',
|
||||||
|
operationId: 'list-backup-executions',
|
||||||
|
security: [
|
||||||
|
['bearerAuth' => []],
|
||||||
|
],
|
||||||
|
tags: ['Databases'],
|
||||||
|
parameters: [
|
||||||
|
new OA\Parameter(
|
||||||
|
name: 'uuid',
|
||||||
|
in: 'path',
|
||||||
|
required: true,
|
||||||
|
description: 'UUID of the database',
|
||||||
|
schema: new OA\Schema(type: 'string')
|
||||||
|
),
|
||||||
|
new OA\Parameter(
|
||||||
|
name: 'scheduled_backup_uuid',
|
||||||
|
in: 'path',
|
||||||
|
required: true,
|
||||||
|
description: 'UUID of the backup configuration',
|
||||||
|
schema: new OA\Schema(type: 'string', format: 'uuid')
|
||||||
|
),
|
||||||
|
],
|
||||||
|
responses: [
|
||||||
|
new OA\Response(
|
||||||
|
response: 200,
|
||||||
|
description: 'List of backup executions',
|
||||||
|
content: new OA\JsonContent(
|
||||||
|
type: 'object',
|
||||||
|
properties: [
|
||||||
|
'executions' => new OA\Schema(
|
||||||
|
type: 'array',
|
||||||
|
items: new OA\Schema(
|
||||||
|
type: 'object',
|
||||||
|
properties: [
|
||||||
|
'uuid' => ['type' => 'string'],
|
||||||
|
'filename' => ['type' => 'string'],
|
||||||
|
'size' => ['type' => 'integer'],
|
||||||
|
'created_at' => ['type' => 'string'],
|
||||||
|
'message' => ['type' => 'string'],
|
||||||
|
'status' => ['type' => 'string'],
|
||||||
|
]
|
||||||
|
)
|
||||||
|
),
|
||||||
|
]
|
||||||
|
)
|
||||||
|
),
|
||||||
|
new OA\Response(
|
||||||
|
response: 404,
|
||||||
|
description: 'Backup configuration not found.',
|
||||||
|
),
|
||||||
|
]
|
||||||
|
)]
|
||||||
|
public function list_backup_executions(Request $request)
|
||||||
|
{
|
||||||
|
$teamId = getTeamIdFromToken();
|
||||||
|
if (is_null($teamId)) {
|
||||||
|
return invalidTokenResponse();
|
||||||
|
}
|
||||||
|
|
||||||
|
// Validate scheduled_backup_uuid is provided
|
||||||
|
if (! $request->scheduled_backup_uuid) {
|
||||||
|
return response()->json(['message' => 'Scheduled backup UUID is required.'], 400);
|
||||||
|
}
|
||||||
|
|
||||||
|
$database = queryDatabaseByUuidWithinTeam($request->uuid, $teamId);
|
||||||
|
if (! $database) {
|
||||||
|
return response()->json(['message' => 'Database not found.'], 404);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Find the backup configuration by its UUID
|
||||||
|
$backup = ScheduledDatabaseBackup::where('database_id', $database->id)
|
||||||
|
->where('uuid', $request->scheduled_backup_uuid)
|
||||||
|
->first();
|
||||||
|
|
||||||
|
if (! $backup) {
|
||||||
|
return response()->json(['message' => 'Backup configuration not found.'], 404);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Get all executions for this backup configuration
|
||||||
|
$executions = $backup->executions()
|
||||||
|
->orderBy('created_at', 'desc')
|
||||||
|
->get()
|
||||||
|
->map(function ($execution) {
|
||||||
|
return [
|
||||||
|
'uuid' => $execution->uuid,
|
||||||
|
'filename' => $execution->filename,
|
||||||
|
'size' => $execution->size,
|
||||||
|
'created_at' => $execution->created_at->toIso8601String(),
|
||||||
|
'message' => $execution->message,
|
||||||
|
'status' => $execution->status,
|
||||||
|
];
|
||||||
|
});
|
||||||
|
|
||||||
|
return response()->json([
|
||||||
|
'executions' => $executions,
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
|
||||||
#[OA\Get(
|
#[OA\Get(
|
||||||
summary: 'Start',
|
summary: 'Start',
|
||||||
description: 'Start database. `Post` request is also accepted.',
|
description: 'Start database. `Post` request is also accepted.',
|
||||||
|
@@ -23,6 +23,7 @@ Route::group([
|
|||||||
});
|
});
|
||||||
|
|
||||||
Route::post('/feedback', [OtherController::class, 'feedback']);
|
Route::post('/feedback', [OtherController::class, 'feedback']);
|
||||||
|
|
||||||
Route::group([
|
Route::group([
|
||||||
'middleware' => ['auth:sanctum', 'api.ability:write'],
|
'middleware' => ['auth:sanctum', 'api.ability:write'],
|
||||||
'prefix' => 'v1',
|
'prefix' => 'v1',
|
||||||
@@ -113,8 +114,13 @@ Route::group([
|
|||||||
Route::post('/databases/keydb', [DatabasesController::class, 'create_database_keydb'])->middleware(['api.ability:write']);
|
Route::post('/databases/keydb', [DatabasesController::class, 'create_database_keydb'])->middleware(['api.ability:write']);
|
||||||
|
|
||||||
Route::get('/databases/{uuid}', [DatabasesController::class, 'database_by_uuid'])->middleware(['api.ability:read']);
|
Route::get('/databases/{uuid}', [DatabasesController::class, 'database_by_uuid'])->middleware(['api.ability:read']);
|
||||||
|
Route::get('/databases/{uuid}/backups', [DatabasesController::class, 'database_backup_details_uuid'])->middleware(['api.ability:read']);
|
||||||
|
Route::get('/databases/{uuid}/backups/{scheduled_backup_uuid}/executions', [DatabasesController::class, 'list_backup_executions'])->middleware(['api.ability:read']);
|
||||||
Route::patch('/databases/{uuid}', [DatabasesController::class, 'update_by_uuid'])->middleware(['api.ability:write']);
|
Route::patch('/databases/{uuid}', [DatabasesController::class, 'update_by_uuid'])->middleware(['api.ability:write']);
|
||||||
|
Route::patch('/databases/{uuid}/backups/{scheduled_backup_uuid}', [DatabasesController::class, 'update_backup'])->middleware(['api.ability:write']);
|
||||||
Route::delete('/databases/{uuid}', [DatabasesController::class, 'delete_by_uuid'])->middleware(['api.ability:write']);
|
Route::delete('/databases/{uuid}', [DatabasesController::class, 'delete_by_uuid'])->middleware(['api.ability:write']);
|
||||||
|
Route::delete('/databases/{uuid}/backups/{scheduled_backup_uuid}', [DatabasesController::class, 'delete_backup_by_uuid'])->middleware(['api.ability:write']);
|
||||||
|
Route::delete('/databases/{uuid}/backups/{scheduled_backup_uuid}/executions/{execution_uuid}', [DatabasesController::class, 'delete_execution_by_uuid'])->middleware(['api.ability:write']);
|
||||||
|
|
||||||
Route::match(['get', 'post'], '/databases/{uuid}/start', [DatabasesController::class, 'action_deploy'])->middleware(['api.ability:write']);
|
Route::match(['get', 'post'], '/databases/{uuid}/start', [DatabasesController::class, 'action_deploy'])->middleware(['api.ability:write']);
|
||||||
Route::match(['get', 'post'], '/databases/{uuid}/restart', [DatabasesController::class, 'action_restart'])->middleware(['api.ability:write']);
|
Route::match(['get', 'post'], '/databases/{uuid}/restart', [DatabasesController::class, 'action_restart'])->middleware(['api.ability:write']);
|
||||||
|
Reference in New Issue
Block a user