class

ActivityPub::Object

Inherits ActivityPub < Ktistec::Model::Blockable < Ktistec::Model::Deletable < Ktistec::Model::Polymorphic < Ktistec::Model::Linked < Ktistec::Model::Common < Ktistec::Model < Reference < Object

Constants

ALIASES = ["ActivityPub::Object::Audio", "ActivityPub::Object::Event", "ActivityPub::Object::Image", "ActivityPub::Object::Page", "ActivityPub::Object::Place", "ActivityPub::Object::Video"]

Log = ::Log.for(self)

OBSERVERS = Ktistec::Observable::Registry(ActivityPub::Object).new

PROJECTION_METADATA = { id: Int64, iri: String, attributed_to_iri: ::Union(String, ::Nil), in_reply_to_iri: ::Union(String, ::Nil), thread: ::Union(String, ::Nil), published: ::Union(Time, ::Nil), deleted: Bool, blocked: Bool, hashtags: ::Union(String, ::Nil), mentions: ::Union(String, ::Nil), depth: Int32, }

PROJECTION_MINIMAL = { id: Int64, iri: String, in_reply_to_iri: ::Union(String, ::Nil), thread: ::Union(String, ::Nil), depth: Int32, }

Predefined thread query projection definitions.

Constructors

dereference(key_pair, iri, *, ignore_cached = false, include_deleted = false, deadline : Time::Instant | Nil, **options) : self

Class methods

all_subtypes

Returns type and all concrete (non-abstract) subtypes, including any aliases defined on the type.

count_by_attributed_to(iri : String)

Returns the count of objects attributed to the actor.

Intended as an approximate posts count, so it deliberately skips the visibility/deletion filtering that the exact post queries apply.

dereference?(key_pair, iri, *, ignore_cached = false, include_deleted = false, deadline : Time::Instant | Nil = nil, **options) : self | Nil

federated_posts(*, max_id = nil, min_id = nil, limit = 10)

Returns federated posts with cursor-based pagination.

Includes local posts. Does not include private (not visible) posts.

federated_posts_count

Returns the count of federated posts.

Includes local posts. Does not include private (not visible) posts.

find(_iri iri : String | Nil, include_deleted : Bool = false, include_undone : Bool = false)

find?(_iri iri : String | Nil, include_deleted : Bool = false, include_undone : Bool = false)

from_json_ld(json, **options)

from_json_ld?(json, **options)

latest_public_post

Returns an identifier associated with the latest public post.

Skips many joins and filters in the interest of speed.

It is intended for use in expiring cached results from the two methods above. If the identifier changes, the cached results are probably stale.

NB: The "identifier" is not necessarily the id of the latest post!

map(json, **options)

public_posts(*, max_id = nil, min_id = nil, limit = 10)

Returns the site's public posts with cursor-based pagination.

Does not include private (not visible) posts and replies.

public_posts_count

Returns the count of the site's public posts.

Does not include private (not visible) posts and replies.

Instance methods

_append_to_emojis(model_ : Tag::Emoji) : Nil

_append_to_hashtags(model_ : Tag::Hashtag) : Nil

_append_to_mentions(model_ : Tag::Mention) : Nil

_append_to_translations(model_ : Translation) : Nil

_association_attributed_to

_association_emojis

_association_hashtags

_association_in_reply_to

_association_mentions

_association_quote

_association_quote_authorization

_association_translations

_belongs_to_setter_for_attributed_to(attributed_to_ : ActivityPub::Actor, update_associations = true) : ActivityPub::Actor

_belongs_to_setter_for_in_reply_to(in_reply_to_ : ActivityPub::Object, update_associations = true) : ActivityPub::Object

_belongs_to_setter_for_quote(quote_ : ActivityPub::Object, update_associations = true) : ActivityPub::Object

_belongs_to_setter_for_quote_authorization(quote_authorization_ : QuoteAuthorization, update_associations = true) : QuoteAuthorization

_has_many_setter_for_emojis(emojis_ : Enumerable(Tag::Emoji), update_associations = true) : Enumerable(Tag::Emoji)

_has_many_setter_for_hashtags(hashtags_ : Enumerable(Tag::Hashtag), update_associations = true) : Enumerable(Tag::Hashtag)

_has_many_setter_for_mentions(mentions_ : Enumerable(Tag::Mention), update_associations = true) : Enumerable(Tag::Mention)

_has_many_setter_for_translations(translations_ : Enumerable(Translation), update_associations = true) : Enumerable(Translation)

activities(inclusion = nil, exclusion = nil)

addressed?(actor : ActivityPub::Actor) : Bool

Returns true if the object is addressed to the given actor.

after_create

after_delete

after_destroy

after_save

analyze_thread(*, for_actor : ActivityPub::Actor) : ThreadAnalysisService::ThreadAnalysis

Analyzes thread structure and participation patterns.

Returns comprehensive analysis including statistics, key participants, notable branches, and timeline histogram.

ancestors(*, include_deleted = false, include_blocked = false)

Returns the ancestors from self up to the root.

Deleted/blocked ancestors are omitted from the result. Pass include_deleted: true or include_blocked: true to include those rows. special objects are always excluded.

announces_count

announces_count=(announces_count : Int64)

approved_by?(approved_by)

attachments

attachments=(attachments : Array(Attachment) | Nil)

attributed_to(include_deleted : Bool = false, include_undone : Bool = false) : ActivityPub::Actor

attributed_to(key_pair, *, dereference = false, ignore_cached = false, ignore_changed = false, include_deleted = false, include_undone = false, deadline : Time::Instant | Nil, **options)

attributed_to=(attributed_to_ : ActivityPub::Actor) : ActivityPub::Actor

attributed_to?(include_deleted : Bool = false, include_undone : Bool = false) : ActivityPub::Actor | Nil

attributed_to?(key_pair, *, dereference = false, ignore_cached = false, ignore_changed = false, include_deleted = false, include_undone = false, deadline : Time::Instant | Nil = nil, **options)

attributed_to_iri

attributed_to_iri=(attributed_to_iri : String | Nil)

audience

audience=(audience : Array(String) | Nil)

before_destroy

before_save

before_validate

canonical_path

canonical_path=(canonical_path : Nil | String)

cc

cc=(cc : Array(String) | Nil)

content

content=(content : String | Nil)

delayed?

depth

depth=(depth : Int32)

descendants(*, include_deleted = false, include_blocked = false)

Returns the subtree rooted at self.

Deleted/blocked descendants are omitted from the result. Pass include_deleted: true or include_blocked: true to include those rows. special objects are always excluded.

dislikes_count

dislikes_count=(dislikes_count : Int64)

display_attachments

Returns the media to present for this object.

display_date(timezone = nil)

display_link

draft?

emojis(include_deleted : Bool = false, include_undone : Bool = false) : Enumerable(Tag::Emoji)

emojis=(emojis_ : Enumerable(Tag::Emoji)) : Enumerable(Tag::Emoji)

external?

from_json_ld(json)

hashtags(include_deleted : Bool = false, include_undone : Bool = false) : Enumerable(Tag::Hashtag)

hashtags=(hashtags_ : Enumerable(Tag::Hashtag)) : Enumerable(Tag::Hashtag)

in_reply_to(include_deleted : Bool = false, include_undone : Bool = false) : ActivityPub::Object

in_reply_to(key_pair, *, dereference = false, ignore_cached = false, ignore_changed = false, include_deleted = false, include_undone = false, deadline : Time::Instant | Nil, **options)

in_reply_to=(in_reply_to_ : ActivityPub::Object) : ActivityPub::Object

in_reply_to?(include_deleted : Bool = false, include_undone : Bool = false) : ActivityPub::Object | Nil

in_reply_to?(key_pair, *, dereference = false, ignore_cached = false, ignore_changed = false, include_deleted = false, include_undone = false, deadline : Time::Instant | Nil = nil, **options)

in_reply_to_iri

in_reply_to_iri=(in_reply_to_iri : String | Nil)

iri

iri=(iri : String)

language

language=(language : String | Nil)

likes_count

likes_count=(likes_count : Int64)

make_delete_activity

media_type

media_type=(media_type : String | Nil)

mentions(include_deleted : Bool = false, include_undone : Bool = false) : Enumerable(Tag::Mention)

mentions=(mentions_ : Enumerable(Tag::Mention)) : Enumerable(Tag::Mention)

name

name=(name : String | Nil)

optional_properties?

Returns true if any of the object's optional properties are set.

preview

Returns the text to use for the preview of the object with fallback.

The method checks for text in the following order:

Summary from translation
Summary from the object
Content from translation
Content from the object

Returns the first non-blank value found, or nil.

published

published=(published : Time | Nil)

quote(include_deleted : Bool = false, include_undone : Bool = false) : ActivityPub::Object

quote(key_pair, *, dereference = false, ignore_cached = false, ignore_changed = false, include_deleted = false, include_undone = false, deadline : Time::Instant | Nil, **options)

quote=(quote_ : ActivityPub::Object) : ActivityPub::Object

quote?(include_deleted : Bool = false, include_undone : Bool = false) : ActivityPub::Object | Nil

quote?(key_pair, *, dereference = false, ignore_cached = false, ignore_changed = false, include_deleted = false, include_undone = false, deadline : Time::Instant | Nil = nil, **options)

quote_approved?(quoted_object : ActivityPub::Object) : Bool

Returns true if this object's quote of quoted_object is approved by the latter's author.

quote_authorization(include_deleted : Bool = false, include_undone : Bool = false) : QuoteAuthorization

quote_authorization(key_pair, *, dereference = false, ignore_cached = false, ignore_changed = false, include_deleted = false, include_undone = false, deadline : Time::Instant | Nil, **options)

quote_authorization=(quote_authorization_ : QuoteAuthorization) : QuoteAuthorization

quote_authorization?(include_deleted : Bool = false, include_undone : Bool = false) : QuoteAuthorization | Nil

quote_authorization?(key_pair, *, dereference = false, ignore_cached = false, ignore_changed = false, include_deleted = false, include_undone = false, deadline : Time::Instant | Nil = nil, **options)

quote_authorization_iri

quote_authorization_iri=(quote_authorization_iri : String | Nil)

quote_display_link

Returns the address of the quoted post in the content, for display.

quote_iri

quote_iri=(quote_iri : String | Nil)

quote_request?

replies

replies(*, for_actor)

Returns all replies to this object.

Intended for presenting an object's replies to an authorized user (one who may see all objects).

The for_actor parameter must be specified to disambiguate this method from the replies property getter, but is not currently used.

replies(*, approved_by)

Returns all replies to this object which have been approved by approved_by.

Intended for presenting an object's replies to an unauthorized user (one who may not see all objects e.g. an anonymous user).

replies=(replies : ActivityPub::Collection)

replies?

replies_count

replies_count=(replies_count : Int64)

replies_iri

replies_iri=(replies_iri : String | Nil)

reply?

root?

self_replies

Returns self-replies in threaded order.

Self-replies are replies to this object or its descendants that share the same author as this object. They are returned in thread ordered (parent before children).

The position string encodes the path through the reply tree, ensuring correct ordering even when posts are fetched out of order. The id distinguishes siblings when an author self-replies multiple times to the same parent.

sensitive

sensitive=(sensitive : Bool)

short_date(timezone = nil)

source

source=(source : Source | Nil)

special

special=(special : String | Nil)

summary

summary=(summary : String | Nil)

supported_editors

Returns the editor types supported for this object.

tags

thread

thread(*, for_actor)

Returns all objects in the thread to which this object belongs.

Intended for presenting a thread to an authorized user (one who may see all objects in a thread).

Filters out special objects (e.g. votes).

Does not filter out deleted or blocked objects. Leaves decisions about presentation of these objects and their replies to the caller.

The for_actor parameter must be specified to disambiguate this method from the thread property getter, but is not currently used.

thread(*, approved_by)

Returns all objects in the thread to which this object belongs which have been approved by approved_by.

Filters out special objects (e.g. votes).

Does not filter out deleted or blocked objects. Leaves decisions about presentation of these objects and their replies to the caller.

Intended for presenting a thread to an unauthorized user (one who may not see all objects in a thread e.g. an anonymous user).

thread!

Updates the thread and saves the object.

On older databases, threads are lazily migrated. This is a convenience method for triggering the update and save, and returning the value.

thread=(thread : String | Nil)

thread_query(*, projection : T) forall T

Returns projected fields for all objects in the thread.

The projection parameter accepts a NamedTuple that defines which fields to return. Predefined constants handle common use-cases:

PROJECTION_MINIMAL
PROJECTION_METADATA

Or specify a custom projection: projection: {id: Int64, iri: String, depth: Int32}

Returns Array(NamedTuple) with named fields.

to

to=(to : Array(String) | Nil)

to_json_ld(recursive = true)

translations(include_deleted : Bool = false, include_undone : Bool = false) : Enumerable(Translation)

translations=(translations_ : Enumerable(Translation)) : Enumerable(Translation)

updated

updated=(updated : Time | Nil)

urls

urls=(urls : Array(String) | Nil)

validate_model

visible

visible=(visible : Bool)

with_replies_count!(approved_by)

with_replies_count!

with_statistics!

Nested types