mirror of
https://github.com/Suwayomi/Suwayomi-Server.git
synced 2026-06-30 17:34:39 -05:00
Add Route to stop and reset the updater (#260)
This commit is contained in:
@@ -114,6 +114,7 @@ object MangaAPI {
|
|||||||
path("update") {
|
path("update") {
|
||||||
get("recentChapters/{pageNum}", UpdateController::recentChapters)
|
get("recentChapters/{pageNum}", UpdateController::recentChapters)
|
||||||
post("fetch", UpdateController::categoryUpdate)
|
post("fetch", UpdateController::categoryUpdate)
|
||||||
|
post("reset", UpdateController.reset)
|
||||||
get("summary", UpdateController::updateSummary)
|
get("summary", UpdateController::updateSummary)
|
||||||
ws("", UpdateController::categoryUpdateWS)
|
ws("", UpdateController::categoryUpdateWS)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -15,6 +15,8 @@ import suwayomi.tachidesk.manga.impl.update.IUpdater
|
|||||||
import suwayomi.tachidesk.manga.impl.update.UpdaterSocket
|
import suwayomi.tachidesk.manga.impl.update.UpdaterSocket
|
||||||
import suwayomi.tachidesk.manga.model.dataclass.CategoryDataClass
|
import suwayomi.tachidesk.manga.model.dataclass.CategoryDataClass
|
||||||
import suwayomi.tachidesk.server.JavalinSetup.future
|
import suwayomi.tachidesk.server.JavalinSetup.future
|
||||||
|
import suwayomi.tachidesk.server.util.handler
|
||||||
|
import suwayomi.tachidesk.server.util.withOperation
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Copyright (C) Contributors to the Suwayomi project
|
* Copyright (C) Contributors to the Suwayomi project
|
||||||
@@ -86,4 +88,25 @@ object UpdateController {
|
|||||||
val updater by DI.global.instance<IUpdater>()
|
val updater by DI.global.instance<IUpdater>()
|
||||||
ctx.json(updater.getStatus().value.getJsonSummary())
|
ctx.json(updater.getStatus().value.getJsonSummary())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
val reset = handler(
|
||||||
|
documentWith = {
|
||||||
|
withOperation {
|
||||||
|
summary("Stops and resets the Updater")
|
||||||
|
}
|
||||||
|
},
|
||||||
|
behaviorOf = { ctx ->
|
||||||
|
val updater by DI.global.instance<IUpdater>()
|
||||||
|
logger.info { "Resetting Updater" }
|
||||||
|
ctx.future(
|
||||||
|
future {
|
||||||
|
updater.reset()
|
||||||
|
}.thenApply {
|
||||||
|
ctx.status(HttpCode.OK)
|
||||||
|
}
|
||||||
|
)
|
||||||
|
},
|
||||||
|
withResults = {
|
||||||
|
}
|
||||||
|
)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user