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

---
 .../xyz/driver/common/utils/ServiceUtils.scala     | 32 ++++++++++++++++++++++
 1 file changed, 32 insertions(+)
 create mode 100644 src/main/scala/xyz/driver/common/utils/ServiceUtils.scala

(limited to 'src/main/scala/xyz/driver/common/utils/ServiceUtils.scala')

diff --git a/src/main/scala/xyz/driver/common/utils/ServiceUtils.scala b/src/main/scala/xyz/driver/common/utils/ServiceUtils.scala
new file mode 100644
index 0000000..dd309fb
--- /dev/null
+++ b/src/main/scala/xyz/driver/common/utils/ServiceUtils.scala
@@ -0,0 +1,32 @@
+package xyz.driver.common.utils
+
+import xyz.driver.common.db.SearchFilterBinaryOperation.Eq
+import xyz.driver.common.db.SearchFilterExpr
+import xyz.driver.common.db.SearchFilterExpr.{Atom, Dimension}
+import xyz.driver.common.logging._
+
+import scala.util.{Failure, Success, Try}
+
+
+object ServiceUtils extends PhiLogging {
+  def findEqFilter(filter: SearchFilterExpr, fieldName: String): Option[SearchFilterExpr] = {
+    findEqFilter(filter, Dimension(None, fieldName))
+  }
+
+  def findEqFilter(filter: SearchFilterExpr, dimension: Dimension): Option[SearchFilterExpr] = {
+    filter.find {
+      case Atom.Binary(dimension, Eq, _) => true
+      case _ => false
+    }
+  }
+
+  def convertIdInFilterToLong(value: AnyRef): Option[Long] = {
+    Try(value.toString.toLong) match {
+      case Success(id) =>
+        Option(id)
+      case Failure(e) =>
+        logger.error(phi"Incorrect id format in filter $e")
+        None
+    }
+  }
+}
-- 
cgit v1.2.3