Cancelled handling

apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/TaskPoller.kt

@@ -57,6 +57,10 @@ class DefaultTaskReporter() : TaskReporter {
         TaskStore.markConsumed(taskId, TaskStatus.Failed)
     }
 
+    override fun markCancelled(taskId: UUID) {
+        TaskStore.markConsumed(taskId, TaskStatus.Cancelled)
+    }
+
 
     override fun updateProgress(taskId: UUID, progress: Int) {
         // Not to be implemented for this application

apps/converter/src/test/kotlin/no/iktdev/mediaprocessing/converter/listeners/ConvertTaskListenerTest.kt

@@ -109,7 +109,7 @@ class ConvertTaskListenerTest {
         override fun updateLastSeen(taskId: UUID) {}
         override fun markCompleted(taskId: UUID) {}
         override fun markFailed(taskId: UUID) {}
-
+        override fun markCancelled(taskId: UUID) {}
         override fun updateProgress(taskId: UUID, progress: Int) {}
         override fun log(taskId: UUID, message: String) {}
         override fun publishEvent(event: Event) {

apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/TaskPoller.kt

@@ -56,6 +56,10 @@ class DefaultTaskReporter() : TaskReporter {
         TaskStore.markConsumed(taskId, TaskStatus.Failed)
     }
 
+    override fun markCancelled(taskId: UUID) {
+        TaskStore.markConsumed(taskId, TaskStatus.Cancelled)
+    }
+
     override fun updateProgress(taskId: UUID, progress: Int) {
         // Not to be implemented for this application
     }

apps/coordinator/src/test/kotlin/no/iktdev/mediaprocessing/coordinator/listeners/tasks/DownloadCoverTaskListenerTest.kt

@@ -39,6 +39,7 @@ class DownloadCoverTaskListenerTest: TestBase() {
         override fun markClaimed(taskId: UUID, workerId: String) {}
         override fun updateLastSeen(taskId: UUID) {}
         override fun markCompleted(taskId: UUID) {}
+        override fun markCancelled(taskId: UUID) {}
         override fun markFailed(taskId: UUID) {}
         override fun updateProgress(taskId: UUID, progress: Int) {}
         override fun log(taskId: UUID, message: String) {}

apps/coordinator/src/test/kotlin/no/iktdev/mediaprocessing/coordinator/listeners/tasks/MediaStreamReadTaskListenerTest.kt

@@ -46,6 +46,7 @@ class MediaStreamReadTaskListenerTest: TestBase() {
         override fun updateLastSeen(taskId: UUID) {}
         override fun markCompleted(taskId: UUID) {}
         override fun markFailed(taskId: UUID) {}
+        override fun markCancelled(taskId: UUID) {}
         override fun updateProgress(taskId: UUID, progress: Int) {}
         override fun log(taskId: UUID, message: String) {}
         override fun publishEvent(event: Event) {

apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/TaskPoller.kt

@@ -62,6 +62,11 @@ class DefaultTaskReporter() : TaskReporter {
         TaskStore.markConsumed(taskId, TaskStatus.Failed)
     }
 
+    override fun markCancelled(taskId: UUID) {
+        log.info { "Margin task $taskId as cancelled"}
+        TaskStore.markConsumed(taskId, TaskStatus.Cancelled)
+    }
+
     override fun updateProgress(taskId: UUID, progress: Int) {
         // Not to be implemented for this application
     }

apps/processer/src/test/kotlin/no/iktdev/mediaprocessing/processer/listeners/SubtitleTaskListenerTest.kt

@@ -40,6 +40,8 @@ class SubtitleTaskListenerTest {
         override fun updateLastSeen(taskId: UUID) {}
         override fun markCompleted(taskId: UUID) {}
         override fun markFailed(taskId: UUID) {}
+        override fun markCancelled(taskId: UUID) {}
+
         override fun updateProgress(taskId: UUID, progress: Int) {}
         override fun log(taskId: UUID, message: String) {}
         override fun publishEvent(event: Event) {

apps/processer/src/test/kotlin/no/iktdev/mediaprocessing/processer/listeners/VideoTaskListenerTest.kt

@@ -42,6 +42,7 @@ class VideoTaskListenerTest {
         override fun updateLastSeen(taskId: UUID) {}
         override fun markCompleted(taskId: UUID) {}
         override fun markFailed(taskId: UUID) {}
+        override fun markCancelled(taskId: UUID) {}
         override fun updateProgress(taskId: UUID, progress: Int) {}
         override fun log(taskId: UUID, message: String) {}
         override fun publishEvent(event: Event) {

gradle/libs.versions.toml

@@ -1,5 +1,5 @@
 [versions]
-eventi = "1.0-rc31"
+eventi = "1.0-rc33"
 exfl = "1.0-rc1"
 
 [libraries]