3 files changed, 90 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
+}
diff --git a/src/main/scala/xyz/driver/common/db/repositories/Repository.scala b/src/main/scala/xyz/driver/common/db/repositories/Repository.scala
new file mode 100644
index 0000000..ae2a3e6
--- /dev/null
+++ b/src/main/scala/xyz/driver/common/db/repositories/Repository.scala
@@ -0,0 +1,4 @@
+package xyz.driver.common.db.repositories
+
+// For further usage and migration to Postgres and slick
+trait Repository extends RepositoryLogging
diff --git a/src/main/scala/xyz/driver/common/db/repositories/RepositoryLogging.scala b/src/main/scala/xyz/driver/common/db/repositories/RepositoryLogging.scala
new file mode 100644
index 0000000..cb2c438
--- /dev/null
+++ b/src/main/scala/xyz/driver/common/db/repositories/RepositoryLogging.scala
@@ -0,0 +1,62 @@
+package xyz.driver.common.db.repositories
+
+import xyz.driver.common.logging._
+
+trait RepositoryLogging extends PhiLogging {
+
+  protected def logCreatedOne[T](x: T)(implicit toPhiString: T => PhiString): T = {
+    logger.info(phi"An entity was created: $x")
+    x
+  }
+
+  protected def logCreatedMultiple[T <: Iterable[_]](xs: T)(implicit toPhiString: T => PhiString): T = {
+    if (xs.nonEmpty) {
+      logger.info(phi"Entities were created: $xs")
+    }
+    xs
+  }
+
+  protected def logUpdatedOne(rowsAffected: Long): Long = {
+    rowsAffected match {
+      case 0 => logger.trace(phi"The entity is up to date")
+      case 1 => logger.info(phi"The entity was updated")
+      case x => logger.warn(phi"The ${Unsafe(x)} entities were updated")
+    }
+    rowsAffected
+  }
+
+  protected def logUpdatedOneUnimportant(rowsAffected: Long): Long = {
+    rowsAffected match {
+      case 0 => logger.trace(phi"The entity is up to date")
+      case 1 => logger.trace(phi"The entity was updated")
+      case x => logger.warn(phi"The ${Unsafe(x)} entities were updated")
+    }
+    rowsAffected
+  }
+
+  protected def logUpdatedMultiple(rowsAffected: Long): Long = {
+    rowsAffected match {
+      case 0 => logger.trace(phi"All entities are up to date")
+      case x => logger.info(phi"The ${Unsafe(x)} entities were updated")
+    }
+    rowsAffected
+  }
+
+  protected def logDeletedOne(rowsAffected: Long): Long = {
+    rowsAffected match {
+      case 0 => logger.trace(phi"The entity does not exist")
+      case 1 => logger.info(phi"The entity was deleted")
+      case x => logger.warn(phi"Deleted ${Unsafe(x)} entities, expected one")
+    }
+    rowsAffected
+  }
+
+  protected def logDeletedMultiple(rowsAffected: Long): Long = {
+    rowsAffected match {
+      case 0 => logger.trace(phi"Entities do not exist")
+      case x => logger.info(phi"Deleted ${Unsafe(x)} entities")
+    }
+    rowsAffected
+  }
+
+}