Version adjustment + correct status updates

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

@@ -9,12 +9,11 @@ import no.iktdev.eventi.tasks.TaskPollerImplementation
 import no.iktdev.eventi.tasks.TaskReporter
 import no.iktdev.mediaprocessing.shared.database.stores.EventStore
 import no.iktdev.mediaprocessing.shared.database.stores.TaskStore
-
 import org.springframework.boot.ApplicationArguments
 import org.springframework.boot.ApplicationRunner
 import org.springframework.stereotype.Component
 import org.springframework.stereotype.Service
-import java.util.UUID
+import java.util.*
 
 @Component
 class PollerAdministrator(
@@ -49,10 +48,16 @@ class DefaultTaskReporter() : TaskReporter {
         TaskStore.heartbeat(taskId)
     }
 
-    override fun markConsumed(taskId: UUID) {
+    override fun markCompleted(taskId: UUID) {
         TaskStore.markConsumed(taskId, TaskStatus.Completed)
+
     }
 
+    override fun markFailed(taskId: UUID) {
+        TaskStore.markConsumed(taskId, TaskStatus.Failed)
+    }
+
+
     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

@@ -107,7 +107,9 @@ class ConvertTaskListenerTest {
     val overrideReporter = object : TaskReporter {
         override fun markClaimed(taskId: UUID, workerId: String) {}
         override fun updateLastSeen(taskId: UUID) {}
-        override fun markConsumed(taskId: UUID) {}
+        override fun markCompleted(taskId: UUID) {}
+        override fun markFailed(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

@@ -48,10 +48,14 @@ class DefaultTaskReporter() : TaskReporter {
         TaskStore.heartbeat(taskId)
     }
 
-    override fun markConsumed(taskId: UUID) {
+    override fun markCompleted(taskId: UUID) {
         TaskStore.markConsumed(taskId, TaskStatus.Completed)
     }
 
+    override fun markFailed(taskId: UUID) {
+        TaskStore.markConsumed(taskId, TaskStatus.Failed)
+    }
+
     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

@@ -38,7 +38,8 @@ class DownloadCoverTaskListenerTest: TestBase() {
     private val overrideReporter = object : TaskReporter {
         override fun markClaimed(taskId: UUID, workerId: String) {}
         override fun updateLastSeen(taskId: UUID) {}
-        override fun markConsumed(taskId: UUID) {}
+        override fun markCompleted(taskId: UUID) {}
+        override fun markFailed(taskId: UUID) {}
         override fun updateProgress(taskId: UUID, progress: Int) {}
         override fun log(taskId: UUID, message: String) {}
         override fun publishEvent(event: Event) {}

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

@@ -44,7 +44,8 @@ class MediaStreamReadTaskListenerTest: TestBase() {
     val overrideReporter = object : TaskReporter {
         override fun markClaimed(taskId: UUID, workerId: String) {}
         override fun updateLastSeen(taskId: UUID) {}
-        override fun markConsumed(taskId: UUID) {}
+        override fun markCompleted(taskId: UUID) {}
+        override fun markFailed(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

@@ -52,11 +52,16 @@ class DefaultTaskReporter() : TaskReporter {
         TaskStore.heartbeat(taskId)
     }
 
-    override fun markConsumed(taskId: UUID) {
+    override fun markCompleted(taskId: UUID) {
         log.info { "Marking task $taskId as completed" }
         TaskStore.markConsumed(taskId, TaskStatus.Completed)
     }
 
+    override fun markFailed(taskId: UUID) {
+        log.info { "Marking task $taskId as failed" }
+        TaskStore.markConsumed(taskId, TaskStatus.Failed)
+    }
+
     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

@@ -38,7 +38,8 @@ class SubtitleTaskListenerTest {
     val overrideReporter = object : TaskReporter {
         override fun markClaimed(taskId: UUID, workerId: String) {}
         override fun updateLastSeen(taskId: UUID) {}
-        override fun markConsumed(taskId: UUID) {}
+        override fun markCompleted(taskId: UUID) {}
+        override fun markFailed(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

@@ -40,7 +40,8 @@ class VideoTaskListenerTest {
     val overrideReporter = object : TaskReporter {
         override fun markClaimed(taskId: UUID, workerId: String) {}
         override fun updateLastSeen(taskId: UUID) {}
-        override fun markConsumed(taskId: UUID) {}
+        override fun markCompleted(taskId: UUID) {}
+        override fun markFailed(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-rc30"
+eventi = "1.0-rc31"
 exfl = "1.0-rc1"
 
 [libraries]

shared/database/src/main/kotlin/no/iktdev/mediaprocessing/shared/database/stores/TaskStore.kt

@@ -180,6 +180,7 @@ object TaskStore: TaskStore {
                 it[claimed] = true
                 it[claimedBy] = workerId
                 it[lastCheckIn] = UtcNow()
+                it[status] = TaskStatus.InProgress
             }
         }.isSuccess
     }