From ea992e6ea7c5712653f600a9fc1fd332d6674375 Mon Sep 17 00:00:00 2001
From: bskjon <bskjon@outlook.com>
Date: Mon, 22 Apr 2024 01:01:00 +0200
Subject: [PATCH] Creating a cache of "consumed" eventIds

---
 .../main/kotlin/no/iktdev/mediaprocessing/converter/Task.kt  | 5 +++++
 .../main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt  | 4 ++++
 2 files changed, 9 insertions(+)

diff --git a/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/Task.kt b/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/Task.kt
index 8b15eea5..d289e085 100644
--- a/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/Task.kt
+++ b/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/Task.kt
@@ -39,4 +39,9 @@ abstract class TaskCreator(coordinator: ConverterCoordinator) :
     override fun prerequisiteRequired(event: PersistentProcessDataMessage): List<() -> Boolean> {
         return listOf()
     }
+
+    override fun containsUnprocessedEvents(events: List<PersistentProcessDataMessage>): Boolean {
+        return true
+    }
+
 }
\ No newline at end of file
diff --git a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt
index 22312561..1fb34da5 100644
--- a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt
+++ b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt
@@ -37,4 +37,8 @@ abstract class TaskCreator(coordinator: Coordinator) :
     override fun prerequisiteRequired(event: PersistentProcessDataMessage): List<() -> Boolean> {
         return listOf()
     }
+
+    override fun containsUnprocessedEvents(events: List<PersistentProcessDataMessage>): Boolean {
+        return true
+    }
 }
\ No newline at end of file