pixelfed/app/Jobs/StatusPipeline/StatusRemoteUpdatePipeline.php

<?php

namespace App\Jobs\StatusPipeline;

use App\Media;
use App\Models\StatusEdit;
use App\ModLog;
use App\Profile;
use App\Services\StatusService;
use App\Status;
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\Http;
use Purify;

class StatusRemoteUpdatePipeline implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public $activity;

    /**
     * Create a new job instance.
     */
    public function __construct($activity)
    {
        $this->activity = $activity;
    }

    /**
     * Execute the job.
     */
    public function handle(): void
    {
        $activity = $this->activity;
        $status = Status::with('media')->whereObjectUrl($activity['id'])->first();
        if (! $status) {
            return;
        }
        $this->createPreviousEdit($status);
        $this->updateMedia($status, $activity);
        $this->updateImmediateAttributes($status, $activity);
        $this->createEdit($status, $activity);
    }

    protected function createPreviousEdit($status)
    {
        if (! $status->edits()->count()) {
            StatusEdit::create([
                'status_id' => $status->id,
                'profile_id' => $status->profile_id,
                'caption' => $status->caption,
                'spoiler_text' => $status->cw_summary,
                'is_nsfw' => $status->is_nsfw,
                'ordered_media_attachment_ids' => $status->media()->orderBy('order')->pluck('id')->toArray(),
                'created_at' => $status->created_at,
            ]);
        }
    }

    protected function updateMedia($status, $activity)
    {
        if (! isset($activity['attachment'])) {
            return;
        }
        $ogm = $status->media->count() ? $status->media()->orderBy('order')->get() : collect([]);
        $nm = collect($activity['attachment'])->filter(function ($nm) {
            return isset(
                $nm['type'],
                $nm['mediaType'],
                $nm['url']
            ) &&
            in_array($nm['type'], ['Document', 'Image', 'Video']) &&
            in_array($nm['mediaType'], explode(',', config_cache('pixelfed.media_types')));
        });

        // Skip when no media
        if (! $ogm->count() && ! $nm->count()) {
            return;
        }

        Media::whereProfileId($status->profile_id)
            ->whereStatusId($status->id)
            ->update([
                'status_id' => null,
            ]);

        $nm->each(function ($n, $key) use ($status) {
            $res = Http::withOptions(['allow_redirects' => false])->retry(3, 100, throw: false)->head($n['url']);

            if (! $res->successful()) {
                return;
            }

            if (! in_array($res->header('content-type'), explode(',', config_cache('pixelfed.media_types')))) {
                return;
            }

            $m = new Media;
            $m->status_id = $status->id;
            $m->profile_id = $status->profile_id;
            $m->remote_media = true;
            $m->media_path = $n['url'];
            $m->mime = $res->header('content-type');
            $m->size = $res->hasHeader('content-length') ? $res->header('content-length') : null;
            $m->caption = isset($n['name']) && ! empty($n['name']) ? Purify::clean($n['name']) : null;
            $m->remote_url = $n['url'];
            $m->blurhash = isset($n['blurhash']) && (strlen($n['blurhash']) < 50) ? $n['blurhash'] : null;
            $m->width = isset($n['width']) && ! empty($n['width']) ? $n['width'] : null;
            $m->height = isset($n['height']) && ! empty($n['height']) ? $n['height'] : null;
            $m->skip_optimize = true;
            $m->order = $key + 1;
            $m->save();
        });
    }

    protected function updateImmediateAttributes($status, $activity)
    {
        if (isset($activity['content'])) {
            $status->caption = strip_tags(Purify::clean($activity['content']));
        }

        if (isset($activity['sensitive'])) {
            if ((bool) $activity['sensitive'] == false) {
                $status->is_nsfw = false;
                $exists = ModLog::whereObjectType('App\Status::class')
                    ->whereObjectId($status->id)
                    ->whereAction('admin.status.moderate')
                    ->exists();
                if ($exists == true) {
                    $status->is_nsfw = true;
                }
                $profile = Profile::find($status->profile_id);
                if (! $profile || $profile->cw == true) {
                    $status->is_nsfw = true;
                }
            } else {
                $status->is_nsfw = true;
            }
        }

        if (isset($activity['summary'])) {
            $status->cw_summary = Purify::clean($activity['summary']);
        } else {
            $status->cw_summary = null;
        }

        $status->edited_at = now();
        $status->save();
        StatusService::del($status->id);
    }

    protected function createEdit($status, $activity)
    {
        $cleaned = isset($activity['content']) ? Purify::clean($activity['content']) : null;
        $spoiler_text = isset($activity['summary']) ? Purify::clean($activity['summary']) : null;
        $sensitive = isset($activity['sensitive']) ? $activity['sensitive'] : null;
        $mids = $status->media()->count() ? $status->media()->orderBy('order')->pluck('id')->toArray() : null;
        StatusEdit::create([
            'status_id' => $status->id,
            'profile_id' => $status->profile_id,
            'caption' => $cleaned,
            'spoiler_text' => $spoiler_text,
            'is_nsfw' => $sensitive,
            'ordered_media_attachment_ids' => $mids,
        ]);
    }
}