Nemcio/Grav-Admin-Plugin
1
0
Fork 0
mirror of https://github.com/getgrav/grav-plugin-admin.git synced 2025-11-04 20:36:03 +01:00
Code Issues Packages Projects Releases Activity

create adhoc snapshot

Browse Source
This commit is contained in:
Andy Miller
2025-10-18 18:41:39 -06:00
parent c4fb1f7fd8
commit 419fcc3f13
6 changed files with 379 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files

105
classes/plugin/SafeUpgradeManager.php
View File

@@ -223,6 +223,22 @@ class SafeUpgradeManager
]);
}
public function queueSnapshot(?string $label = null): array
{
$options = [
'operation' => 'snapshot',
];
if (null !== $label) {
$label = trim((string)$label);
if ($label !== '') {
$options['label'] = $label;
}
}
return $this->queue($options);
}
/**
* @param array<int, string> $snapshotIds
* @return array<int, array{id:string,status:string,message:?string}>
@@ -515,8 +531,25 @@ class SafeUpgradeManager
$this->log(sprintf('Queued safe upgrade job %s', $jobId));
$queueMessage = $operation === 'restore' ? 'Waiting for restore worker...' : 'Waiting for upgrade worker...';
$this->setProgress('queued', $queueMessage, 0, ['job_id' => $jobId, 'status' => 'queued', 'operation' => $operation]);
if ($operation === 'restore') {
$queueMessage = 'Waiting for restore worker...';
} elseif ($operation === 'snapshot') {
$queueMessage = 'Waiting for snapshot worker...';
} else {
$queueMessage = 'Waiting for upgrade worker...';
}
$queuedExtras = [
'job_id' => $jobId,
'status' => 'queued',
'operation' => $operation,
];
if ($operation === 'snapshot') {
if (isset($options['label']) && is_string($options['label'])) {
$queuedExtras['label'] = $options['label'];
}
$queuedExtras['mode'] = 'manual';
}
$this->setProgress('queued', $queueMessage, 0, $queuedExtras);
if (!function_exists('proc_open')) {
$message = 'proc_open() is disabled on this server; unable to run safe upgrade worker.';
@@ -701,6 +734,10 @@ class SafeUpgradeManager
return $this->runRestore($options);
}
if ($operation === 'snapshot') {
return $this->runSnapshot($options);
}
$force = (bool)($options['force'] ?? false);
$timeout = (int)($options['timeout'] ?? 30);
$overwrite = (bool)($options['overwrite'] ?? false);
@@ -888,6 +925,7 @@ class SafeUpgradeManager
'snapshot' => $snapshotId,
'version' => $version,
'manifest' => $manifest,
'label' => $label,
],
]);
}
@@ -897,6 +935,69 @@ class SafeUpgradeManager
'snapshot' => $snapshotId,
'version' => $version,
'manifest' => $manifest,
'label' => $label,
'context' => $this->buildStatusContext(),
];
}
public function runSnapshot(array $options): array
{
$label = isset($options['label']) ? (string)$options['label'] : null;
if ($label !== null) {
$label = trim($label);
if ($label === '') {
$label = null;
}
}
$this->setProgress('snapshot', 'Creating manual snapshot...', null, [
'operation' => 'snapshot',
'label' => $label,
'mode' => 'manual',
]);
try {
$safeUpgrade = $this->getSafeUpgradeService();
$manifest = $safeUpgrade->createSnapshot($label);
} catch (RuntimeException $e) {
return $this->errorResult($e->getMessage(), [
'operation' => 'snapshot',
]);
} catch (Throwable $e) {
return $this->errorResult($e->getMessage(), [
'operation' => 'snapshot',
]);
}
$snapshotId = $manifest['id'] ?? null;
$version = $manifest['source_version'] ?? $manifest['target_version'] ?? null;
$this->setProgress('complete', sprintf('Snapshot %s created.', $snapshotId ?? '(unknown)'), 100, [
'operation' => 'snapshot',
'snapshot' => $snapshotId,
'version' => $version,
'label' => $label,
'mode' => 'manual',
]);
if ($this->jobManifestPath) {
$this->updateJob([
'result' => [
'status' => 'success',
'snapshot' => $snapshotId,
'version' => $version,
'manifest' => $manifest,
'label' => $label,
],
]);
}
return [
'status' => 'success',
'snapshot' => $snapshotId,
'version' => $version,
'manifest' => $manifest,
'label' => $label,
'context' => $this->buildStatusContext(),
];
}