WIP new client build

Author: kiroco12

client/src/main/scala/org/scalaexercises/evaluator/ClientApp.scala

@@ -0,0 +1,26 @@
+/*
+ *
+ *  scala-exercises - evaluator-client
+ *  Copyright (C) 2015-2019 47 Degrees, LLC. <http://www.47deg.com>
+ *
+ */
+
+package org.scalaexercises.evaluator
+
+import cats.Monad.ops.toAllMonadOps
+import cats.effect.{ExitCode, IO, IOApp}
+import cats.syntax.applicative.catsSyntaxApplicativeId
+
+object ClientApp extends IOApp {
+
+  val validToken: String =
+    "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eW91ciBpZGVudGl0eQ.cfH43Wa7k_w1i0W2pQhV1k21t2JqER9lw5EpJcENRMI"
+
+  val req = EvalRequest(Nil, Nil, "{ 1 + 1 }")
+
+  override def run(args: List[String]): IO[ExitCode] =
+    EvaluatorClient[IO]("http://127.0.0.1:8080/eval", validToken)
+      .evaluates(req)
+      .map(println(_)) *> ExitCode.Success.pure[IO]
+
+}

client/src/main/scala/org/scalaexercises/evaluator/Decoders.scala

@@ -7,38 +7,21 @@
 
 package org.scalaexercises.evaluator
 
-import cats.data.EitherT
-import cats.~>
-import cats.implicits._
-import org.scalaexercises.evaluator.EvaluatorResponses.{
-  EvalIO,
-  EvaluationException,
-  EvaluationResponse,
-  EvaluationResult
-}
-import org.scalaexercises.evaluator.free.algebra.EvaluatorOp
-
-import scala.concurrent.Future
-import scala.concurrent.ExecutionContext.Implicits.global
-
-class EvaluatorClient(url: String, authKey: String) {
+import cats.effect.{ConcurrentEffect, Resource}
+import org.http4s.client.Client
+import org.http4s.client.blaze.BlazeClientBuilder
+import org.scalaexercises.evaluator.service.{HttpClientHandler, HttpClientService}
 
-  lazy val api: EvaluatorAPI[EvaluatorOp] = new EvaluatorAPI(url, authKey)
+import scala.concurrent.ExecutionContext
 
-}
+case class EvaluatorClient(url: String, authKey: String)
 
 object EvaluatorClient {
 
-  def apply(url: String, authKey: String) =
-    new EvaluatorClient(url, authKey)
-
-  implicit class EvaluationIOSyntaxEither[A](evalIO: EvalIO[EvaluationResponse[A]]) {
-
-    def exec(implicit I: (EvaluatorOp ~> Future)): Future[EvaluationResponse[A]] =
-      evalIO foldMap I
+  private def clientResource[F[_]: ConcurrentEffect]: Resource[F, Client[F]] =
+    BlazeClientBuilder[F](ExecutionContext.global).resource
 
-    def liftEvaluator: EitherT[EvalIO, EvaluationException, EvaluationResult[A]] =
-      EitherT[EvalIO, EvaluationException, EvaluationResult[A]](evalIO)
+  def apply[F[_]: ConcurrentEffect](url: String, authKey: String): HttpClientService[F] =
+    HttpClientHandler[F](url, authKey, clientResource[F])
 
-  }
 }