Newer
Older
<?php

Yassine Doghri
committed
declare(strict_types=1);
/**
* @copyright 2021 Podlibre
* @license https://www.gnu.org/licenses/agpl-3.0.en.html AGPL3
* @link https://castopod.org/
*/
namespace ActivityPub\Models;

Yassine Doghri
committed
use ActivityPub\Entities\Activity;
use CodeIgniter\Database\BaseResult;

Yassine Doghri
committed
use CodeIgniter\I18n\Time;
use DateTimeInterface;
use Michalsn\Uuid\UuidModel;
class ActivityModel extends UuidModel
{

Yassine Doghri
committed
/**
* @var string
*/
protected $table = 'activitypub_activities';

Yassine Doghri
committed
/**
* @var string
*/
protected $primaryKey = 'id';

Yassine Doghri
committed
/**
* @var string[]
*/
protected $uuidFields = ['id', 'status_id'];

Yassine Doghri
committed
/**
* @var string[]
*/
protected $allowedFields = [
'id',
'actor_id',
'target_actor_id',
'type',
'payload',
'scheduled_at',
];

Yassine Doghri
committed
/**
* @var string
*/
protected $returnType = Activity::class;

Yassine Doghri
committed
/**
* @var bool
*/
protected $useSoftDeletes = false;

Yassine Doghri
committed
/**
* @var bool
*/
protected $useTimestamps = true;

Yassine Doghri
committed
protected $updatedField;
public function getActivityById(string $activityId): ?Activity
{
$cacheName =
config('ActivityPub')
->cachePrefix . "activity#{$activityId}";
if (! ($found = cache($cacheName))) {
$found = $this->find($activityId);
cache()
->save($cacheName, $found, DECADE);
}
return $found;
}
/**
* Inserts a new activity record in the database
*

Yassine Doghri
committed
* @param Time $scheduledAt
*/
public function newActivity(

Yassine Doghri
committed
string $type,
int $actorId,
?int $targetActorId,

Yassine Doghri
committed
string $payload,
DateTimeInterface $scheduledAt = null,
?string $taskStatus = null
): BaseResult | int | string | false {
return $this->insert(
[
'actor_id' => $actorId,
'target_actor_id' => $targetActorId,
'status_id' => $statusId,
'type' => $type,
'payload' => $payload,
'scheduled_at' => $scheduledAt,
'task_status' => $taskStatus,
],
true,
);
}
* @return Activity[]
*/
public function getScheduledActivities(): array
{
return $this->where('`scheduled_at` <= NOW()', null, false)
->where('task_status', 'queued')
->orderBy('scheduled_at', 'ASC')
->findAll();
}
}