Sutty/panel
5
0
Fork 0
mirror of https://0xacab.org/sutty/sutty synced 2024-10-10 12:06:56 +00:00
Code Issues Projects Releases Wiki Activity

Merge branch 'issue-15109-1' of https://0xacab.org/sutty/sutty into production.panel.sutty.nl

Browse source
This commit is contained in:
Sutty 2024-03-15 21:05:57 +00:00
commit 80f37eeed4
2 changed files with 22 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
app/models/activity_pub.rb
View file

@ -6,6 +6,12 @@
# una actividad, puede estar destinada a varies actores dentro de Sutty, # una actividad, puede estar destinada a varies actores dentro de Sutty,
# con lo que generamos una cola para cada une. # con lo que generamos una cola para cada une.
# #
#
# @todo Ya que une actore puede hacer varias actividades sobre el mismo
# objeto, lo correcto sería que la actividad a moderar sea una sola en
# lugar de una lista acumulativa. Es decir cada ActivityPub representa
# el estado del conjunto (Actor, Object, Activity)
#
# @see {https://www.w3.org/TR/activitypub/#client-to-server-interactions} # @see {https://www.w3.org/TR/activitypub/#client-to-server-interactions}
class ActivityPub < ApplicationRecord class ActivityPub < ApplicationRecord
IGNORED_EVENTS = %i[pause remove].freeze IGNORED_EVENTS = %i[pause remove].freeze
@ -105,10 +111,16 @@ class ActivityPub < ApplicationRecord
# disponible, que según el scope por defecto, va a ser la primera de # disponible, que según el scope por defecto, va a ser la primera de
# la lista. # la lista.
def reject_remotely! def reject_remotely!
raise unless site.social_inbox.inbox.reject(id: activities.first.uri).ok? fail! unless site.social_inbox.inbox.reject(id: activities.first.uri).ok?
end end
def allow_remotely! def allow_remotely!
raise unless site.social_inbox.inbox.accept(id: activities.first.uri).ok? with_failure_handling(activity: activities.first.uri) do
fail! unless site.social_inbox.inbox.accept(id: activities.first.uri).ok?
end
end
def fail_message
activities.first&.uri || 'Activity missing'
end end
end end

9
app/processors/activity_pub_processor.rb
View file

@ -6,7 +6,14 @@ class ActivityPubProcessor < Rubanok::Processor
# #
# Por ahora solo queremos moderar comentarios. # Por ahora solo queremos moderar comentarios.
prepare do prepare do
raw.where(object_type: %w[ActivityPub::Object::Note ActivityPub::Object::Article]).order(updated_at: :desc) raw
.joins(:activities)
.where(
activity_pub_activities: {
type: %w[ActivityPub::Activity::Create ActivityPub::Activity::Update]
},
object_type: %w[ActivityPub::Object::Note ActivityPub::Object::Article]
).order(updated_at: :desc)
end end
map :activity_pub_state, activate_always: true do |activity_pub_state: 'paused'| map :activity_pub_state, activate_always: true do |activity_pub_state: 'paused'|