package xyz.driver import scalaz.{Equal, Monad, OptionT} import eu.timepit.refined.api.{Refined, Validate} import eu.timepit.refined.collection.NonEmpty import xyz.driver.core.rest.errors.ExternalServiceException import scala.concurrent.{ExecutionContext, Future} // TODO: this package seems too complex, look at all the features we need! import scala.language.reflectiveCalls import scala.language.higherKinds import scala.language.implicitConversions package object core { def make[T](v: => T)(f: T => Unit): T = { val value = v f(value) value } def using[R <: { def close() }, P](r: => R)(f: R => P): P = { val resource = r try { f(resource) } finally { resource.close() } } object tagging { private[core] trait Tagged[+V, +Tag] implicit class Taggable[V <: Any](val v: V) extends AnyVal { def tagged[Tag]: V @@ Tag = v.asInstanceOf[V @@ Tag] } } type @@[+V, +Tag] = V with tagging.Tagged[V, Tag] implicit class OptionTExtensions[H[_]: Monad, T](optionTValue: OptionT[H, T]) { def returnUnit: H[Unit] = optionTValue.fold[Unit](_ => (), ()) def continueIgnoringNone: OptionT[H, Unit] = optionTValue.map(_ => ()).orElse(OptionT.some[H, Unit](())) def subflatMap[B](f: T => Option[B]): OptionT[H, B] = OptionT.optionT[H](implicitly[Monad[H]].map(optionTValue.run)(_.flatMap(f))) } implicit class MonadicExtensions[H[_]: Monad, T](monadicValue: H[T]) { private implicit val monadT = implicitly[Monad[H]] def returnUnit: H[Unit] = monadT(monadicValue)(_ => ()) def toOptionT: OptionT[H, T] = OptionT.optionT[H](monadT(monadicValue)(value => Option(value))) def toUnitOptionT: OptionT[H, Unit] = OptionT.optionT[H](monadT(monadicValue)(_ => Option(()))) } implicit class FutureExtensions[T](future: Future[T]) { def passThroughExternalServiceException(implicit executionContext: ExecutionContext): Future[T] = future.transform(identity, { case ExternalServiceException(_, _, Some(e)) => e case t: Throwable => t }) } } package core { final case class Id[+Tag](value: String) extends AnyVal { @inline def length: Int = value.length override def toString: String = value } @SuppressWarnings(Array("org.wartremover.warts.ImplicitConversion")) object Id { implicit def idEqual[T]: Equal[Id[T]] = Equal.equal[Id[T]](_ == _) implicit def idOrdering[T]: Ordering[Id[T]] = Ordering.by[Id[T], String](_.value) sealed class Mapper[E, R] { def apply[T >: E](id: Id[R]): Id[T] = Id[E](id.value) def apply[T >: R](id: Id[E])(implicit dummy: DummyImplicit): Id[T] = Id[R](id.value) } object Mapper { def apply[E, R] = new Mapper[E, R] } implicit def convertRE[R, E](id: Id[R])(implicit mapper: Mapper[E, R]): Id[E] = mapper[E](id) implicit def convertER[E, R](id: Id[E])(implicit mapper: Mapper[E, R]): Id[R] = mapper[R](id) } final case class Name[+Tag](value: String) extends AnyVal { @inline def length: Int = value.length override def toString: String = value } object Name { implicit def nameEqual[T]: Equal[Name[T]] = Equal.equal[Name[T]](_ == _) implicit def nameOrdering[T]: Ordering[Name[T]] = Ordering.by(_.value) implicit def nameValidator[T, P](implicit stringValidate: Validate[String, P]): Validate[Name[T], P] = { Validate.instance[Name[T], P, stringValidate.R]( name => stringValidate.validate(name.value), name => stringValidate.showExpr(name.value)) } } final case class NonEmptyName[+Tag](value: String Refined NonEmpty) { @inline def length: Int = value.value.length override def toString: String = value.value } object NonEmptyName { implicit def nonEmptyNameEqual[T]: Equal[NonEmptyName[T]] = Equal.equal[NonEmptyName[T]](_.value.value == _.value.value) implicit def nonEmptyNameOrdering[T]: Ordering[NonEmptyName[T]] = Ordering.by(_.value.value) } final case class Revision[T](id: String) object Revision { implicit def revisionEqual[T]: Equal[Revision[T]] = Equal.equal[Revision[T]](_.id == _.id) } final case class Base64(value: String) trait Trimmed object Trimmed { import tagging._ implicit def string2Trimmed(str: String): String @@ Trimmed = str.trim().tagged[Trimmed] implicit def name2Trimmed[T](name: Name[T]): Name[T] @@ Trimmed = Name[T](name.value.trim()).tagged[Trimmed] } }