castopod/modules/Fediverse/Commands/Broadcast.php

<?php

declare(strict_types=1);

namespace Modules\Fediverse\Commands;

use CodeIgniter\CLI\BaseCommand;
use Modules\Fediverse\Models\ActivityModel;

class Broadcast extends BaseCommand
{
    protected $group = 'fediverse';

    protected $name = 'fediverse:broadcast';

    protected $description = 'Broadcasts new outgoing activity to followers.';

    public function run(array $params): void
    {
        helper('fediverse');

        // retrieve scheduled activities from database
        $scheduledActivities = model(ActivityModel::class, false)
            ->getScheduledActivities();

        // Send activity to all followers
        foreach ($scheduledActivities as $scheduledActivity) {
            if ($scheduledActivity->target_actor_id !== null) {
                if ($scheduledActivity->actor_id !== $scheduledActivity->target_actor_id) {
                    // send activity to targeted actor
                    send_activity_to_actor(
                        $scheduledActivity->actor,
                        $scheduledActivity->targetActor,
                        json_encode($scheduledActivity->payload, JSON_THROW_ON_ERROR)
                    );
                }
            } else {
                // send activity to all actor followers
                send_activity_to_followers(
                    $scheduledActivity->actor,
                    json_encode($scheduledActivity->payload, JSON_THROW_ON_ERROR),
                );
            }

            // set activity post to delivered
            model(ActivityModel::class, false)
                ->update($scheduledActivity->id, [
                    'status' => 'delivered',
                ]);
        }
    }
}