mirror of
https://0xacab.org/sutty/sutty
synced 2025-03-15 23:28:20 +00:00

closes #15775 closes #15773 closes #15772 closes #15771 closes #15770 closes #15767 closes #15766 closes #15765 closes #15764
47 lines
1.7 KiB
Ruby
47 lines
1.7 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
# Obtiene o actualiza el contenido de un objeto, usando las credenciales
|
|
# del sitio.
|
|
#
|
|
# XXX: Esto usa las credenciales del sitio para volver el objeto
|
|
# disponible para todo el CMS. Asumimos que el objeto devuelto es el
|
|
# mismo para todo el mundo y las credenciales solo son para
|
|
# autenticación.
|
|
class ActivityPub
|
|
class FetchJob < ApplicationJob
|
|
self.priority = 50
|
|
|
|
def perform(site:, object_id:)
|
|
ActivityPub::Object.transaction do
|
|
object = ::ActivityPub::Object.find(object_id)
|
|
|
|
return if object.blank?
|
|
return if object.activity_pubs.where(aasm_state: 'removed').count.positive?
|
|
|
|
response = site.social_inbox.dereferencer.get(uri: object.uri)
|
|
|
|
# @todo Fallar cuando la respuesta no funcione?
|
|
# @todo Eliminar en 410 Gone
|
|
return unless response.success?
|
|
# Ignorar si ya la caché fue revalidada y ya teníamos el
|
|
# contenido
|
|
return if response.hit? && object.content.present?
|
|
|
|
current_type = object.type
|
|
content = FastJsonparser.parse(response.body)
|
|
|
|
# Modificar atómicamente
|
|
::ActivityPub::Object.lock.find(object_id).update!(content: content, type: ActivityPub::Object.type_from(content).name)
|
|
|
|
object = ::ActivityPub::Object.find(object_id)
|
|
# Actualiza la mención
|
|
object.actor&.save! if object.actor_type?
|
|
|
|
# Arreglar las relaciones con actividades también
|
|
ActivityPub.where(object_id: object.id).update_all(object_type: object.type, updated_at: Time.now)
|
|
rescue FastJsonparser::ParseError => e
|
|
ExceptionNotifier.notify_exception(e, data: { site: site.name, object: object.uri, body: response.body })
|
|
end
|
|
end
|
|
end
|
|
end
|