Initial extraction of Driver non-specific utilities

1 files changed, 24 insertions, 0 deletions

diff --git a/src/main/scala/xyz/driver/common/db/repositories/BridgeUploadQueueRepository.scala b/src/main/scala/xyz/driver/common/db/repositories/BridgeUploadQueueRepository.scala
new file mode 100644
index 0000000..e0d6ff2
--- /dev/null
+++ b/src/main/scala/xyz/driver/common/db/repositories/BridgeUploadQueueRepository.scala
@@ -0,0 +1,24 @@
+package xyz.driver.common.db.repositories
+
+import xyz.driver.common.concurrent.BridgeUploadQueue
+import xyz.driver.common.domain.LongId
+
+import scala.concurrent.Future
+
+trait BridgeUploadQueueRepository extends Repository {
+
+  type EntityT = BridgeUploadQueue.Item
+  type IdT = LongId[EntityT]
+
+  def add(draft: EntityT): EntityT
+
+  def getById(id: LongId[EntityT]): Option[EntityT]
+
+  def isCompleted(kind: String, tag: String): Future[Boolean]
+
+  def getOne(kind: String): Future[Option[BridgeUploadQueue.Item]]
+
+  def update(entity: EntityT): EntityT
+
+  def delete(id: IdT): Unit
+}