From e850ba8e47d330c486c097d169aa99a61147f0d3 Mon Sep 17 00:00:00 2001
From: usbharu <64310155+usbharu@users.noreply.github.com>
Date: Sun, 10 Dec 2023 17:58:55 +0900
Subject: [PATCH] =?UTF-8?q?feat:=20JobProcessor=E3=82=92=E8=BF=BD=E5=8A=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../accept/APDeliverAcceptJobProcessor.kt     | 22 +++++++++++++++++++
 .../reject/APDeliverRejectJobProcessor.kt     | 22 +++++++++++++++++++
 .../undo/APDeliverUndoJobProcessor.kt         | 21 ++++++++++++++++++
 3 files changed, 65 insertions(+)
 create mode 100644 src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/accept/APDeliverAcceptJobProcessor.kt
 create mode 100644 src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/reject/APDeliverRejectJobProcessor.kt
 create mode 100644 src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/undo/APDeliverUndoJobProcessor.kt

diff --git a/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/accept/APDeliverAcceptJobProcessor.kt b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/accept/APDeliverAcceptJobProcessor.kt
new file mode 100644
index 00000000..e9d240a9
--- /dev/null
+++ b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/accept/APDeliverAcceptJobProcessor.kt
@@ -0,0 +1,22 @@
+package dev.usbharu.hideout.activitypub.service.activity.accept
+
+import dev.usbharu.hideout.activitypub.service.common.APRequestService
+import dev.usbharu.hideout.core.external.job.DeliverAcceptJob
+import dev.usbharu.hideout.core.external.job.DeliverAcceptJobParam
+import dev.usbharu.hideout.core.query.UserQueryService
+import dev.usbharu.hideout.core.service.job.JobProcessor
+import org.springframework.stereotype.Service
+
+@Service
+class APDeliverAcceptJobProcessor(
+    private val apRequestService: APRequestService,
+    private val userQueryService: UserQueryService,
+    private val deliverAcceptJob: DeliverAcceptJob
+) :
+    JobProcessor<DeliverAcceptJobParam, DeliverAcceptJob> {
+    override suspend fun process(param: DeliverAcceptJobParam) {
+        apRequestService.apPost(param.inbox, param.accept, userQueryService.findById(param.signer))
+    }
+
+    override fun job(): DeliverAcceptJob = deliverAcceptJob
+}
diff --git a/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/reject/APDeliverRejectJobProcessor.kt b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/reject/APDeliverRejectJobProcessor.kt
new file mode 100644
index 00000000..8e271288
--- /dev/null
+++ b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/reject/APDeliverRejectJobProcessor.kt
@@ -0,0 +1,22 @@
+package dev.usbharu.hideout.activitypub.service.activity.reject
+
+import dev.usbharu.hideout.activitypub.service.common.APRequestService
+import dev.usbharu.hideout.core.external.job.DeliverRejectJob
+import dev.usbharu.hideout.core.external.job.DeliverRejectJobParam
+import dev.usbharu.hideout.core.query.UserQueryService
+import dev.usbharu.hideout.core.service.job.JobProcessor
+import org.springframework.stereotype.Component
+
+@Component
+class APDeliverRejectJobProcessor(
+    private val apRequestService: APRequestService,
+    private val userQueryService: UserQueryService,
+    private val deliverRejectJob: DeliverRejectJob
+) :
+    JobProcessor<DeliverRejectJobParam, DeliverRejectJob> {
+    override suspend fun process(param: DeliverRejectJobParam) {
+        apRequestService.apPost(param.inbox, param.reject, userQueryService.findById(param.signer))
+    }
+
+    override fun job(): DeliverRejectJob = deliverRejectJob
+}
diff --git a/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/undo/APDeliverUndoJobProcessor.kt b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/undo/APDeliverUndoJobProcessor.kt
new file mode 100644
index 00000000..800f6ca5
--- /dev/null
+++ b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/undo/APDeliverUndoJobProcessor.kt
@@ -0,0 +1,21 @@
+package dev.usbharu.hideout.activitypub.service.activity.undo
+
+import dev.usbharu.hideout.activitypub.service.common.APRequestService
+import dev.usbharu.hideout.core.external.job.DeliverUndoJob
+import dev.usbharu.hideout.core.external.job.DeliverUndoJobParam
+import dev.usbharu.hideout.core.query.UserQueryService
+import dev.usbharu.hideout.core.service.job.JobProcessor
+import org.springframework.stereotype.Service
+
+@Service
+class APDeliverUndoJobProcessor(
+    private val deliverUndoJob: DeliverUndoJob,
+    private val apRequestService: APRequestService,
+    private val userQueryService: UserQueryService
+) : JobProcessor<DeliverUndoJobParam, DeliverUndoJob> {
+    override suspend fun process(param: DeliverUndoJobParam) {
+        apRequestService.apPost(param.inbox, param.undo, userQueryService.findById(param.signer))
+    }
+
+    override fun job(): DeliverUndoJob = deliverUndoJob
+}