. // }}} namespace App\Entity; use App\Core\DB; use App\Core\Entity; use Component\Notification\Entity\Attention; use Component\Notification\Entity\Notification; use DateTimeInterface; use Functional as F; /** * Entity for all activities we know about * * @category DB * @package GNUsocial * * @author Hugo Sales * @author Diogo Peralta Cordeiro <@diogo.site> * @copyright 2020-2021 Free Software Foundation, Inc http://www.fsf.org * @license https://www.gnu.org/licenses/agpl.html GNU AGPL v3 or later */ class Activity extends Entity { // {{{ Autocode // @codeCoverageIgnoreStart private int $id; private int $actor_id; private string $verb; private string $object_type; private int $object_id; private ?string $source = null; private \DateTimeInterface $created; public function setId(int $id): self { $this->id = $id; return $this; } public function getId(): int { return $this->id; } public function setActorId(int $actor_id): self { $this->actor_id = $actor_id; return $this; } public function getActorId(): int { return $this->actor_id; } public function setVerb(string $verb): self { $this->verb = \mb_substr($verb, 0, 32); return $this; } public function getVerb(): string { return $this->verb; } public function setObjectType(string $object_type): self { $this->object_type = \mb_substr($object_type, 0, 32); return $this; } public function getObjectType(): string { return $this->object_type; } public function setObjectId(int $object_id): self { $this->object_id = $object_id; return $this; } public function getObjectId(): int { return $this->object_id; } public function setSource(?string $source): self { $this->source = \is_null($source) ? null : \mb_substr($source, 0, 32); return $this; } public function getSource(): ?string { return $this->source; } public function setCreated(\DateTimeInterface $created): self { $this->created = $created; return $this; } public function getCreated(): \DateTimeInterface { return $this->created; } // @codeCoverageIgnoreEnd // }}} Autocode public function getActor(): Actor { return Actor::getById($this->getActorId()); } public function getObject(): mixed { return DB::findOneBy($this->getObjectType(), ['id' => $this->getObjectId()]); } /** * Actors that should be informed about this object. * * @return array int[] of Actor's id */ public function getAttentionTargetIds(): array { $answer = []; switch($this->getVerb()) { case 'undo': $answer = $this->getObject()->getAttentionTargetIds(); break; case 'create': $object_attention = $this->getObject()->getAttentionTargetIds(); foreach ($object_attention as $att) { $answer[$att] = $att; } // no break default: $attention = DB::findBy(Attention::class, [ 'object_type' => static::schemaName(), 'object_id' => $this->getId(), ]); foreach ($attention as $att) { $answer[$att->getTargetId()] = $att->getTargetId(); } } return $answer; } public static function getAllActivitiesByActor(Actor $actor): array { return DB::findBy(self::class, ['actor_id' => $actor->getId()], order_by: ['created' => 'DESC', 'id' => 'DESC']); } public static function schemaDef(): array { return [ 'name' => 'activity', 'fields' => [ 'id' => ['type' => 'serial', 'not null' => true], 'actor_id' => ['type' => 'int', 'not null' => true, 'description' => 'foreign key to actor table'], 'verb' => ['type' => 'varchar', 'length' => 32, 'not null' => true, 'description' => 'internal activity verb, influenced by activity pub verbs'], 'object_type' => ['type' => 'varchar', 'length' => 32, 'not null' => true, 'description' => 'the name of the table this object refers to'], 'object_id' => ['type' => 'int', 'not null' => true, 'description' => 'id in the referenced table'], 'source' => ['type' => 'varchar', 'length' => 32, 'description' => 'the source of this activity'], 'created' => ['type' => 'datetime', 'not null' => true, 'description' => 'date this record was created', 'default' => 'CURRENT_TIMESTAMP'], ], 'primary key' => ['id'], ]; } }