mirror of
https://github.com/pixelfed/pixelfed.git
synced 2024-12-23 08:14:10 +00:00
153 lines
4.7 KiB
PHP
153 lines
4.7 KiB
PHP
<?php
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
use Illuminate\Console\Command;
|
|
use App\Models\ImportPost;
|
|
use App\Services\ImportService;
|
|
use App\Media;
|
|
use App\Profile;
|
|
use App\Status;
|
|
use Storage;
|
|
use App\Services\AccountService;
|
|
use App\Services\MediaPathService;
|
|
use Illuminate\Support\Str;
|
|
use App\Util\Lexer\Autolink;
|
|
|
|
class TransformImports extends Command
|
|
{
|
|
/**
|
|
* The name and signature of the console command.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $signature = 'app:transform-imports';
|
|
|
|
/**
|
|
* The console command description.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $description = 'Transform imports into statuses';
|
|
|
|
/**
|
|
* Execute the console command.
|
|
*/
|
|
public function handle()
|
|
{
|
|
if(!config('import.instagram.enabled')) {
|
|
return;
|
|
}
|
|
|
|
$ips = ImportPost::whereNull('status_id')->where('skip_missing_media', '!=', true)->take(500)->get();
|
|
|
|
if(!$ips->count()) {
|
|
return;
|
|
}
|
|
|
|
foreach($ips as $ip) {
|
|
$id = $ip->user_id;
|
|
$pid = $ip->profile_id;
|
|
$profile = Profile::find($pid);
|
|
if(!$profile) {
|
|
$ip->skip_missing_media = true;
|
|
$ip->save();
|
|
continue;
|
|
}
|
|
|
|
$exists = ImportPost::whereUserId($id)
|
|
->whereNotNull('status_id')
|
|
->where('filename', $ip->filename)
|
|
->where('creation_year', $ip->creation_year)
|
|
->where('creation_month', $ip->creation_month)
|
|
->where('creation_day', $ip->creation_day)
|
|
->exists();
|
|
|
|
if($exists == true) {
|
|
$ip->skip_missing_media = true;
|
|
$ip->save();
|
|
continue;
|
|
}
|
|
|
|
$idk = ImportService::getId($ip->user_id, $ip->creation_year, $ip->creation_month, $ip->creation_day);
|
|
if(!$idk) {
|
|
$ip->skip_missing_media = true;
|
|
$ip->save();
|
|
continue;
|
|
}
|
|
|
|
if(Storage::exists('imports/' . $id . '/' . $ip->filename) === false) {
|
|
ImportService::clearAttempts($profile->id);
|
|
ImportService::getPostCount($profile->id, true);
|
|
$ip->skip_missing_media = true;
|
|
$ip->save();
|
|
continue;
|
|
}
|
|
|
|
$missingMedia = false;
|
|
foreach($ip->media as $ipm) {
|
|
$fileName = last(explode('/', $ipm['uri']));
|
|
$og = 'imports/' . $id . '/' . $fileName;
|
|
if(!Storage::exists($og)) {
|
|
$missingMedia = true;
|
|
}
|
|
}
|
|
|
|
if($missingMedia === true) {
|
|
$ip->skip_missing_media = true;
|
|
$ip->save();
|
|
continue;
|
|
}
|
|
|
|
$caption = $ip->caption;
|
|
$status = new Status;
|
|
$status->profile_id = $pid;
|
|
$status->caption = $caption;
|
|
$status->rendered = strlen(trim($caption)) ? Autolink::create()->autolink($ip->caption) : null;
|
|
$status->type = $ip->post_type;
|
|
|
|
$status->scope = 'unlisted';
|
|
$status->visibility = 'unlisted';
|
|
$status->id = $idk['id'];
|
|
$status->created_at = now()->parse($ip->creation_date);
|
|
$status->save();
|
|
|
|
foreach($ip->media as $ipm) {
|
|
$fileName = last(explode('/', $ipm['uri']));
|
|
$ext = last(explode('.', $fileName));
|
|
$basePath = MediaPathService::get($profile);
|
|
$og = 'imports/' . $id . '/' . $fileName;
|
|
if(!Storage::exists($og)) {
|
|
$ip->skip_missing_media = true;
|
|
$ip->save();
|
|
continue;
|
|
}
|
|
$size = Storage::size($og);
|
|
$mime = Storage::mimeType($og);
|
|
$newFile = Str::random(40) . '.' . $ext;
|
|
$np = $basePath . '/' . $newFile;
|
|
Storage::move($og, $np);
|
|
$media = new Media;
|
|
$media->profile_id = $pid;
|
|
$media->user_id = $id;
|
|
$media->status_id = $status->id;
|
|
$media->media_path = $np;
|
|
$media->mime = $mime;
|
|
$media->size = $size;
|
|
$media->save();
|
|
}
|
|
|
|
$ip->status_id = $status->id;
|
|
$ip->creation_id = $idk['incr'];
|
|
$ip->save();
|
|
|
|
$profile->status_count = $profile->status_count + 1;
|
|
$profile->save();
|
|
|
|
AccountService::del($profile->id);
|
|
|
|
ImportService::clearAttempts($profile->id);
|
|
ImportService::getPostCount($profile->id, true);
|
|
}
|
|
}
|
|
}
|