usbharu
/
Hideout
mirror of https://github.com/usbharu/Hideout.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

refactor: 不要な依存を削除

This commit is contained in:
usbharu 2023-11-27 15:03:26 +09:00
parent a3adba6813
commit e40e2c0d96
2 changed files with 0 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/kotlin/dev/usbharu/hideout/activitypub/service/common/ApJobService.kt
View File

@ -1,8 +0,0 @@
package dev.usbharu.hideout.activitypub.service.common
import dev.usbharu.hideout.core.external.job.HideoutJob
import kjob.core.dsl.JobContextWithProps
interface ApJobService {
suspend fun <T, R : HideoutJob<T, R>> processActivity(job: JobContextWithProps<R>, hideoutJob: HideoutJob<T, R>)
}

16
src/main/kotlin/dev/usbharu/hideout/application/config/JobQueueRunner.kt
View File

@ -1,6 +1,5 @@
package dev.usbharu.hideout.application.config package dev.usbharu.hideout.application.config
import dev.usbharu.hideout.activitypub.service.common.ApJobService
import dev.usbharu.hideout.core.external.job.HideoutJob import dev.usbharu.hideout.core.external.job.HideoutJob
import dev.usbharu.hideout.core.service.job.JobQueueParentService import dev.usbharu.hideout.core.service.job.JobQueueParentService
import dev.usbharu.hideout.core.service.job.JobQueueWorkerService import dev.usbharu.hideout.core.service.job.JobQueueWorkerService
@ -29,24 +28,9 @@ class JobQueueRunner(
@Component @Component
class JobQueueWorkerRunner( class JobQueueWorkerRunner(
private val jobQueueWorkerService: JobQueueWorkerService, private val jobQueueWorkerService: JobQueueWorkerService,
private val jobs: List<HideoutJob<*, *>>,
private val apJobService: ApJobService
) : ApplicationRunner { ) : ApplicationRunner {
override fun run(args: ApplicationArguments?) { override fun run(args: ApplicationArguments?) {
LOGGER.info("Init job queue worker.") LOGGER.info("Init job queue worker.")
// jobQueueWorkerService.init<Any?, HideoutJob<*, *>>(
// jobs.map {
// it to {
// execute {
// LOGGER.debug("excute job ${it.name}")
// apJobService.processActivity(
// job = this,
// hideoutJob = it
// )
// }
// }
// }
// )
jobQueueWorkerService.init<Any?, HideoutJob<*, *>>(emptyList()) jobQueueWorkerService.init<Any?, HideoutJob<*, *>>(emptyList())
} }