5817270c35
Introduced a two-tier media pipeline with dynamic disks, asset tracking, admin controls, and alerting around
upload/archival workflows.
- Added storage metadata + asset tables and models so every photo/variant knows where it lives
(database/migrations/2025_10_20_090000_create_media_storage_targets_table.php, database/ migrations/2025_10_20_090200_create_event_media_assets_table.php, app/Models/MediaStorageTarget.php:1, app/
Models/EventMediaAsset.php:1, app/Models/EventStorageAssignment.php:1, app/Models/Event.php:27).
- Rewired guest and tenant uploads to pick the event’s hot disk, persist EventMediaAsset records, compute
checksums, and clean up on delete (app/Http/Controllers/Api/EventPublicController.php:243, app/Http/
Controllers/Api/Tenant/PhotoController.php:25, app/Models/Photo.php:25).
- Implemented storage services, archival job scaffolding, monitoring config, and queue-failure notifications for upload issues (app/Services/Storage/EventStorageManager.php:16, app/Services/Storage/
StorageHealthService.php:9, app/Jobs/ArchiveEventMediaAssets.php:16, app/Providers/AppServiceProvider.php:39, app/Notifications/UploadPipelineFailed.php:8, config/storage-monitor.php:1).
- Seeded default hot/cold targets and exposed super-admin tooling via a Filament resource and capacity widget (database/seeders/MediaStorageTargetSeeder.php:13, database/seeders/DatabaseSeeder.php:17, app/Filament/Resources/MediaStorageTargetResource.php:1, app/Filament/Widgets/StorageCapacityWidget.php:12, app/Providers/Filament/SuperAdminPanelProvider.php:47).
- Dropped cron skeletons and artisan placeholders to schedule storage monitoring, archival dispatch, and upload queue health checks (cron/storage_monitor.sh, cron/archive_dispatcher.sh, cron/upload_queue_health.sh, routes/console.php:9).
104 lines
3.2 KiB
PHP
104 lines
3.2 KiB
PHP
<?php
|
|
|
|
namespace App\Jobs;
|
|
|
|
use App\Models\Event;
|
|
use App\Models\EventMediaAsset;
|
|
use App\Services\Storage\EventStorageManager;
|
|
use Illuminate\Bus\Queueable;
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|
use Illuminate\Foundation\Bus\Dispatchable;
|
|
use Illuminate\Queue\InteractsWithQueue;
|
|
use Illuminate\Queue\SerializesModels;
|
|
use Illuminate\Support\Facades\Log;
|
|
use Illuminate\Support\Facades\Storage;
|
|
|
|
class ArchiveEventMediaAssets implements ShouldQueue
|
|
{
|
|
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
|
|
|
public function __construct(
|
|
public int $eventId,
|
|
public bool $deleteSource = true,
|
|
public ?int $initiatorId = null,
|
|
) {
|
|
$this->onQueue('media-storage');
|
|
}
|
|
|
|
public function handle(EventStorageManager $storageManager): void
|
|
{
|
|
$event = Event::with('storageAssignments.storageTarget')->find($this->eventId);
|
|
|
|
if (! $event) {
|
|
Log::warning('Archive job aborted: event missing', ['event_id' => $this->eventId]);
|
|
return;
|
|
}
|
|
|
|
$archiveDisk = $storageManager->getArchiveDiskForEvent($event);
|
|
|
|
if (! $archiveDisk) {
|
|
Log::warning('Archive job aborted: no archive disk configured', ['event_id' => $event->id]);
|
|
return;
|
|
}
|
|
|
|
$archiveAssignment = $storageManager->ensureAssignment($event, null, 'archive');
|
|
$archiveTargetId = $archiveAssignment->media_storage_target_id;
|
|
|
|
$assets = EventMediaAsset::where('event_id', $event->id)
|
|
->whereIn('status', ['hot', 'pending', 'restoring'])
|
|
->orderBy('id')
|
|
->get();
|
|
|
|
foreach ($assets as $asset) {
|
|
$sourceDisk = $asset->disk;
|
|
|
|
if ($sourceDisk === $archiveDisk && $asset->status === 'archived') {
|
|
continue;
|
|
}
|
|
|
|
$archivePath = $asset->path;
|
|
|
|
$stream = null;
|
|
|
|
try {
|
|
$stream = Storage::disk($sourceDisk)->readStream($asset->path);
|
|
|
|
if (! $stream) {
|
|
throw new \RuntimeException('Source stream is null');
|
|
}
|
|
|
|
Storage::disk($archiveDisk)->put($archivePath, $stream);
|
|
|
|
$asset->fill([
|
|
'disk' => $archiveDisk,
|
|
'media_storage_target_id' => $archiveTargetId,
|
|
'status' => 'archived',
|
|
'archived_at' => now(),
|
|
'error_message' => null,
|
|
])->save();
|
|
|
|
if ($this->deleteSource) {
|
|
Storage::disk($sourceDisk)->delete($asset->path);
|
|
}
|
|
} catch (\Throwable $e) {
|
|
Log::error('Failed to archive media asset', [
|
|
'asset_id' => $asset->id,
|
|
'event_id' => $event->id,
|
|
'source_disk' => $sourceDisk,
|
|
'archive_disk' => $archiveDisk,
|
|
'error' => $e->getMessage(),
|
|
]);
|
|
|
|
$asset->update([
|
|
'status' => 'failed',
|
|
'error_message' => $e->getMessage(),
|
|
]);
|
|
} finally {
|
|
if (is_resource($stream)) {
|
|
fclose($stream);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|