From 0000a65ab4479a2a40e2d6468036438e9705b4aa Mon Sep 17 00:00:00 2001
From: vlad <vlad@driver.xyz>
Date: Tue, 13 Jun 2017 10:25:55 -0700
Subject: Initial extraction of Driver non-specific utilities

---
 .../common/db/repositories/RepositoryLogging.scala | 62 ++++++++++++++++++++++
 1 file changed, 62 insertions(+)
 create mode 100644 src/main/scala/xyz/driver/common/db/repositories/RepositoryLogging.scala

(limited to 'src/main/scala/xyz/driver/common/db/repositories/RepositoryLogging.scala')

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
+  }
+
+}
-- 
cgit v1.2.3