diff --git a/src/main/kotlin/dev/usbharu/hideout/activitypub/service/tmp/InboxJobProcessor.kt b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/tmp/InboxJobProcessor.kt index 99ad3fb9..e33da23b 100644 --- a/src/main/kotlin/dev/usbharu/hideout/activitypub/service/tmp/InboxJobProcessor.kt +++ b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/tmp/InboxJobProcessor.kt @@ -7,7 +7,9 @@ import dev.usbharu.hideout.activitypub.service.common.ActivityType import dev.usbharu.hideout.activitypub.service.objects.user.APUserService import dev.usbharu.hideout.core.domain.exception.FailedToGetResourcesException import dev.usbharu.hideout.core.external.job.InboxJob +import dev.usbharu.hideout.core.external.job.InboxJobParam import dev.usbharu.hideout.core.query.UserQueryService +import dev.usbharu.hideout.core.service.job.JobProcessor import dev.usbharu.hideout.util.RsaUtil import dev.usbharu.httpsignature.common.HttpHeaders import dev.usbharu.httpsignature.common.HttpRequest @@ -27,7 +29,7 @@ class InboxJobProcessor( private val signatureVerifier: HttpSignatureVerifier, private val userQueryService: UserQueryService, private val apUserService: APUserService -) { +) : JobProcessor { suspend fun process(props: JobProps) { val type = ActivityType.valueOf(props[InboxJob.type]) @@ -90,6 +92,13 @@ class InboxJobProcessor( } } + override suspend fun process(param: InboxJobParam) { + println(param) + System.err.println("aaaaaaaaaaaaaaaaaaaaaaaaaaa") + } + + override fun job(): InboxJob = InboxJob + companion object { private val logger = LoggerFactory.getLogger(InboxJobProcessor::class.java) } diff --git a/src/main/kotlin/dev/usbharu/hideout/application/config/JobQueueRunner.kt b/src/main/kotlin/dev/usbharu/hideout/application/config/JobQueueRunner.kt index bb22e6d6..cc1580ea 100644 --- a/src/main/kotlin/dev/usbharu/hideout/application/config/JobQueueRunner.kt +++ b/src/main/kotlin/dev/usbharu/hideout/application/config/JobQueueRunner.kt @@ -34,19 +34,20 @@ class JobQueueWorkerRunner( ) : ApplicationRunner { override fun run(args: ApplicationArguments?) { LOGGER.info("Init job queue worker.") - jobQueueWorkerService.init( - jobs.map { - it to { - execute { - LOGGER.debug("excute job ${it.name}") - apJobService.processActivity( - job = this, - hideoutJob = it - ) - } - } - } - ) +// jobQueueWorkerService.init>( +// jobs.map { +// it to { +// execute { +// LOGGER.debug("excute job ${it.name}") +// apJobService.processActivity( +// job = this, +// hideoutJob = it +// ) +// } +// } +// } +// ) + jobQueueWorkerService.init>(emptyList()) } companion object {