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

app/jobs/activity_pub/actor_fetch_job.rb

@@ -16,7 +16,7 @@ class ActivityPub
         response = site.social_inbox.dereferencer.get(uri: actor.uri)
 
         # @todo Fallar cuando la respuesta no funcione?
-        return unless response.ok?
+        return unless response.success?
         return if response.miss? && actor.content.present?
 
         actor.object.update(content: FastJsonparser.parse(response.body))

app/jobs/activity_pub/fetch_job.rb

@@ -22,7 +22,7 @@ class ActivityPub
 
         # @todo Fallar cuando la respuesta no funcione?
         # @todo Eliminar en 410 Gone
-        return unless response.ok?
+        return unless response.success?
         # Ignorar si ya la caché fue revalidada y ya teníamos el
         # contenido
         return if response.hit? && object.content.present?

app/jobs/activity_pub/inbox_job.rb

@@ -10,7 +10,7 @@ class ActivityPub
     def perform(site:, activity:, action:)
       response = site.social_inbox.inbox.public_send(action, id: activity)
 
-      raise response.body unless response.ok?
+      raise response.body unless response.success?
     end
   end
 end

app/jobs/activity_pub/instance_fetch_job.rb

@@ -15,7 +15,7 @@ class ActivityPub
 
         response = site.social_inbox.dereferencer.get(uri: uri)
 
-        next unless response.ok?
+        next unless response.success?
         # @todo Validate schema
         next unless response.parsed_response.is_a?(DistributedPress::V1::Social::ReferencedObject)
 

app/jobs/activity_pub/remote_flag_job.rb

@@ -25,11 +25,12 @@ class ActivityPub
       client = remote_flag.main_site.social_inbox.client_for(uri.origin)
       response = client.post(endpoint: uri.path, body: remote_flag.content)
 
-      raise 'No se pudo enviar el reporte' unless response.ok?
+      raise 'No se pudo enviar el reporte' unless response.success?
 
       remote_flag.report!
     rescue Exception => e
       ExceptionNotifier.notify_exception(e, data: { remote_flag: remote_flag.id, response: response.parsed_response })
+      remote_flag.resend!
       raise
     end
   end

app/jobs/activity_pub/sync_lists_job.rb

@@ -53,7 +53,7 @@ class ActivityPub
     def process(stage)
       response = yield
 
-      return if response.ok?
+      return if response.success?
 
       logs[stage] ||= []
       logs[stage] << { body: response.body, code: response.code }

app/models/activity_pub/fediblock.rb

@@ -52,7 +52,7 @@ class ActivityPub
     def process!
       response = client.get(download_url)
 
-      raise FediblockDownloadError unless response.ok?
+      raise FediblockDownloadError unless response.success?
 
       Fediblock.transaction do
         csv = response.parsed_response

app/models/deploy_social_distributed_press.rb

@@ -84,7 +84,7 @@ class DeploySocialDistributedPress < Deploy
 
       response = hook_client.put(event: event, hook: webhook)
 
-      raise ArgumentError, response.body unless response.ok?
+      raise ArgumentError, response.body unless response.success?
     rescue ArgumentError => e
       ExceptionNotifier.notify_exception(e, data: { site_id: site.name, usuarie_id: rol.usuarie_id })
     end