From a65a9f2f504969755529bd51efc03934c4c51a81 Mon Sep 17 00:00:00 2001
From: f <f@sutty.nl>
Date: Sat, 16 Mar 2024 19:16:30 -0300
Subject: [PATCH] feat: aprobar o rechazar en segundo plano

---
 app/jobs/activity_pub/inbox_job.rb | 16 ++++++++++++++++
 app/models/activity_pub.rb         | 23 ++++++++++-------------
 2 files changed, 26 insertions(+), 13 deletions(-)
 create mode 100644 app/jobs/activity_pub/inbox_job.rb

diff --git a/app/jobs/activity_pub/inbox_job.rb b/app/jobs/activity_pub/inbox_job.rb
new file mode 100644
index 00000000..93216d44
--- /dev/null
+++ b/app/jobs/activity_pub/inbox_job.rb
@@ -0,0 +1,16 @@
+# frozen_string_literal: true
+
+class ActivityPub
+  class InboxJob < ApplicationJob
+    self.priority = 10
+
+    # @param :site [Site]
+    # @param :activity [String]
+    # @param :action [Symbol]
+    def perform(site:, activity:, action:)
+      response = site.social_inbox.inbox.public_send(action, id: activity)
+
+      raise response.body unless response.ok?
+    end
+  end
+end
diff --git a/app/models/activity_pub.rb b/app/models/activity_pub.rb
index 8142ecfb..55b48cd7 100644
--- a/app/models/activity_pub.rb
+++ b/app/models/activity_pub.rb
@@ -47,9 +47,9 @@ class ActivityPub < ApplicationRecord
     # Todavía no hay una decisión sobre el objeto
     state :paused, initial: true
     # Le usuarie aprobó el objeto
-    state :approved, before_enter: :allow_remotely!
+    state :approved
     # Le usuarie rechazó el objeto
-    state :rejected, before_enter: :reject_remotely!
+    state :rejected
     # Le usuarie reportó el objeto
     state :reported
     # Le actore eliminó el objeto
@@ -84,11 +84,19 @@ class ActivityPub < ApplicationRecord
     # webhook a modo de confirmación.
     event :approve do
       transitions from: %i[paused], to: :approved
+
+      after do
+        ActivityPub::InboxJob.perform_later(site: site, activity: activities.first.uri, action: :accept)
+      end
     end
 
     # La actividad fue rechazada
     event :reject do
       transitions from: %i[paused], to: :rejected
+
+      after do
+        ActivityPub::InboxJob.perform_later(site: site, activity: activities.first.uri, action: :reject)
+      end
     end
 
     # Solo podemos reportarla luego de rechazarla
@@ -103,15 +111,4 @@ class ActivityPub < ApplicationRecord
 
   # Definir eventos en masa
   include AasmEventsConcern
-
-  # Lo que tenemos que aprobar o rechazar es la última actividad
-  # disponible, que según el scope por defecto, va a ser la primera de
-  # la lista.
-  def reject_remotely!
-    raise unless site.social_inbox.inbox.reject(id: activities.first.uri).ok?
-  end
-
-  def allow_remotely!
-    raise unless site.social_inbox.inbox.accept(id: activities.first.uri).ok?
-  end
 end