101 lines
3.3 KiB
PHP
101 lines
3.3 KiB
PHP
<?php
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
use App\Models\Media;
|
|
use App\Models\Note;
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Support\Facades\DB;
|
|
use Illuminate\Support\Facades\Storage;
|
|
|
|
class MigrateMedia extends Command
|
|
{
|
|
/**
|
|
* The name and signature of the console command.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $signature = 'app:migrate-media';
|
|
|
|
/**
|
|
* The console command description.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $description = 'Migrate media';
|
|
|
|
/**
|
|
* Execute the console command.
|
|
*/
|
|
public function handle(): void
|
|
{
|
|
// First check new `media_note` table exists
|
|
if (! DB::getSchemaBuilder()->hasTable('media_note')) {
|
|
$this->error('The table "media_note" does not exist.');
|
|
|
|
exit(1);
|
|
}
|
|
|
|
// Load all media already saved in `media_endpoint` table
|
|
$this->line('Updating existing local media');
|
|
$mediaEndpointMedia = Media::all();
|
|
// Save relationship in new `media_note` table based on `media_endpoint.note_id`
|
|
$this->withProgressBar($mediaEndpointMedia, function (Media $mediaEndpointMediaItem) {
|
|
$note = Note::find($mediaEndpointMediaItem->note_id);
|
|
if ($note) {
|
|
$note->media()->syncWithoutDetaching($mediaEndpointMediaItem->id);
|
|
}
|
|
});
|
|
|
|
// Load all media records from `media` table
|
|
$this->line('');
|
|
$this->line('Migrating old media from S3');
|
|
$oldMedia = DB::table('media')->get();
|
|
foreach ($oldMedia as $oldMediaItem) {
|
|
// We only want to process the S3 media
|
|
if ($oldMediaItem->disk !== 's3') {
|
|
$this->warn('Original media item never stored in S3');
|
|
|
|
continue;
|
|
}
|
|
|
|
// Check media exists in S3
|
|
if (! Storage::disk('s3')->exists($oldMediaItem->id.DIRECTORY_SEPARATOR.$oldMediaItem->file_name)) {
|
|
$this->warn('Original media item not found in S3');
|
|
|
|
continue;
|
|
}
|
|
// We want to just copy the file, check it does not already exist locally
|
|
if (Storage::disk('public')->exists('media'.DIRECTORY_SEPARATOR.$oldMediaItem->file_name)) {
|
|
$this->warn('File already exists locally with filename of original media item');
|
|
|
|
continue;
|
|
}
|
|
|
|
// Save relationship based on `media.model_id`
|
|
// I have already checked they are all notes
|
|
$noteId = $oldMediaItem->model_id;
|
|
$note = Note::find($noteId);
|
|
if (! $note) {
|
|
$this->warn('Note no longer exists');
|
|
|
|
continue;
|
|
}
|
|
|
|
// Create media entry in database and attach to note
|
|
$newMediaItem = Media::create([
|
|
'path' => 'media'.DIRECTORY_SEPARATOR.$oldMediaItem->file_name,
|
|
'type' => 'image',
|
|
]);
|
|
$note->media()->syncWithoutDetaching($newMediaItem->id);
|
|
|
|
// Copy the file
|
|
Storage::disk('public')->writeStream('media'.DIRECTORY_SEPARATOR.$oldMediaItem->file_name, Storage::disk('s3')->readStream($oldMediaItem->id.DIRECTORY_SEPARATOR.$oldMediaItem->file_name));
|
|
|
|
$this->info('Media item migrated from S3');
|
|
}
|
|
|
|
$this->line('');
|
|
$this->line('Migration finished');
|
|
}
|
|
}
|