diff --git a/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/follow/APReceiveFollowJobProcessor.kt b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/follow/APReceiveFollowJobProcessor.kt index 91b88b79..a6aae23b 100644 --- a/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/follow/APReceiveFollowJobProcessor.kt +++ b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/follow/APReceiveFollowJobProcessor.kt @@ -29,7 +29,6 @@ class APReceiveFollowJobProcessor( val person = apUserService.fetchPerson(param.actor, param.targetActor) val follow = objectMapper.readValue(param.follow) - logger.info("START Follow from: {} to {}", param.targetActor, param.actor) val signer = userQueryService.findByUrl(param.targetActor) diff --git a/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/like/ApRemoveReactionJobProcessor.kt b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/like/ApRemoveReactionJobProcessor.kt index dadbe66e..307f0c16 100644 --- a/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/like/ApRemoveReactionJobProcessor.kt +++ b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/activity/like/ApRemoveReactionJobProcessor.kt @@ -21,7 +21,6 @@ class ApRemoveReactionJobProcessor( private val applicationConfig: ApplicationConfig ) : JobProcessor { override suspend fun process(param: DeliverRemoveReactionJobParam): Unit = transaction.transaction { - val like = objectMapper.readValue(param.like) val signer = userQueryService.findByUrl(param.actor) diff --git a/src/main/kotlin/dev/usbharu/hideout/activitypub/service/common/AbstractActivityPubProcessor.kt b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/common/AbstractActivityPubProcessor.kt index bfc7d24e..329941b2 100644 --- a/src/main/kotlin/dev/usbharu/hideout/activitypub/service/common/AbstractActivityPubProcessor.kt +++ b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/common/AbstractActivityPubProcessor.kt @@ -30,5 +30,4 @@ abstract class AbstractActivityPubProcessor( } abstract suspend fun internalProcess(activity: ActivityPubProcessContext) - } diff --git a/src/main/kotlin/dev/usbharu/hideout/activitypub/service/inbox/InboxJobProcessor.kt b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/inbox/InboxJobProcessor.kt index 71614aca..51a49af9 100644 --- a/src/main/kotlin/dev/usbharu/hideout/activitypub/service/inbox/InboxJobProcessor.kt +++ b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/inbox/InboxJobProcessor.kt @@ -35,7 +35,6 @@ class InboxJobProcessor( private val transaction: Transaction ) : JobProcessor { suspend fun process(props: JobProps) { - val type = ActivityType.valueOf(props[InboxJob.type]) val jsonString = objectMapper.readTree(props[InboxJob.json]) val httpRequestString = props[InboxJob.httpRequest] diff --git a/src/main/kotlin/dev/usbharu/hideout/core/external/job/HideoutJob.kt b/src/main/kotlin/dev/usbharu/hideout/core/external/job/HideoutJob.kt index 7ca2a630..8cd3647f 100644 --- a/src/main/kotlin/dev/usbharu/hideout/core/external/job/HideoutJob.kt +++ b/src/main/kotlin/dev/usbharu/hideout/core/external/job/HideoutJob.kt @@ -29,7 +29,6 @@ object ReceiveFollowJob : HideoutJob("R props[follow] = value.follow props[actor] = value.actor props[targetActor] = value.targetActor - } override fun convert(props: JobProps): ReceiveFollowJobParam = ReceiveFollowJobParam( @@ -78,7 +77,9 @@ object DeliverReactionJob : HideoutJob = string("actor") val inbox: Prop = string("inbox") val id: Prop = string("id") - override fun convert(value: DeliverReactionJobParam): ScheduleContext.(DeliverReactionJob) -> Unit = + override fun convert( + value: DeliverReactionJobParam + ): ScheduleContext.(DeliverReactionJob) -> Unit = { props[reaction] = value.reaction props[postUrl] = value.postUrl diff --git a/src/main/kotlin/dev/usbharu/hideout/core/infrastructure/kjobexposed/KJobJobQueueWorkerService.kt b/src/main/kotlin/dev/usbharu/hideout/core/infrastructure/kjobexposed/KJobJobQueueWorkerService.kt index 872a3249..a03272c4 100644 --- a/src/main/kotlin/dev/usbharu/hideout/core/infrastructure/kjobexposed/KJobJobQueueWorkerService.kt +++ b/src/main/kotlin/dev/usbharu/hideout/core/infrastructure/kjobexposed/KJobJobQueueWorkerService.kt @@ -24,7 +24,10 @@ class KJobJobQueueWorkerService(private val jobQueueProcessorList: List> init(defines: List>.(R) -> KJobFunctions>>>) { + override fun > init( + defines: + List>.(R) -> KJobFunctions>>> + ) { defines.forEach { job -> kjob.register(job.first, job.second) } diff --git a/src/main/kotlin/dev/usbharu/hideout/core/infrastructure/kjobmongodb/KJobMongoJobQueueWorkerService.kt b/src/main/kotlin/dev/usbharu/hideout/core/infrastructure/kjobmongodb/KJobMongoJobQueueWorkerService.kt index 25fbdefe..5017fd0d 100644 --- a/src/main/kotlin/dev/usbharu/hideout/core/infrastructure/kjobmongodb/KJobMongoJobQueueWorkerService.kt +++ b/src/main/kotlin/dev/usbharu/hideout/core/infrastructure/kjobmongodb/KJobMongoJobQueueWorkerService.kt @@ -23,7 +23,8 @@ class KJobMongoJobQueueWorkerService(private val mongoClient: MongoClient) : Job }.start() } - override fun > init(defines: List>.(R) -> KJobFunctions>>>) { + override fun > init(defines: + List>.(R) -> KJobFunctions>>>) { defines.forEach { job -> kjob.register(job.first, job.second) }