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 { + 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 { + 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 { + override suspend fun process(param: DeliverUndoJobParam) { + apRequestService.apPost(param.inbox, param.undo, userQueryService.findById(param.signer)) + } + + override fun job(): DeliverUndoJob = deliverUndoJob +}