Fix Cats Effect IO type inference

build.sbt

@@ -189,13 +189,13 @@ lazy val clientsSniffed = (project in file("elastic4s-client-sniffed"))
   .settings(libraryDependencies ++= Seq(elasticsearchRestClientSniffer))
 
 lazy val cats_effect = (project in file("elastic4s-effect-cats"))
-  .dependsOn(core)
+  .dependsOn(core, testkit % "test")
   .settings(name := "elastic4s-effect-cats")
   .settings(allSettings)
   .settings(libraryDependencies += cats)
 
 lazy val cats_effect_2 = (project in file("elastic4s-effect-cats-2"))
-  .dependsOn(core)
+  .dependsOn(core, testkit % "test")
   .settings(name := "elastic4s-effect-cats-2")
   .settings(allSettings)
   .settings(libraryDependencies += cats2)

elastic4s-effect-cats-2/src/main/scala/com/sksamuel/elastic4s/cats/effect/instances/CatsEffectInstances.scala

@@ -1,6 +1,6 @@
 package com.sksamuel.elastic4s.cats.effect.instances
 
-import cats.effect.Async
+import cats.effect.{Async, IO}
 import cats.{Functor => CatsFunctor}
 import com.sksamuel.elastic4s.cats.effect.CatsEffectExecutor
 import com.sksamuel.elastic4s.{Executor, Functor}
@@ -12,6 +12,9 @@ trait CatsEffectInstances {
 
   implicit def catsEffectExecutor[F[_]: Async]: Executor[F] =
     new CatsEffectExecutor[F]
+
+  //this needs to be at the bottom
+  implicit val ioExecutor: Executor[IO] = new CatsEffectExecutor[IO]
 }
 
 @deprecated("Use CatsEffectInstances instead")

elastic4s-effect-cats-2/src/test/scala/com.sksamuel.elastic4s.cats.effect/CatsEffectTest.scala

@@ -0,0 +1,48 @@
+package com.sksamuel.elastic4s.cats.effect
+
+import cats.data.OptionT
+import cats.effect.IO
+import com.sksamuel.elastic4s.{ElasticClient, ElasticProperties}
+import com.sksamuel.elastic4s.ElasticDsl._
+import org.scalatest.flatspec.AnyFlatSpec
+import com.sksamuel.elastic4s.cats.effect.instances._
+import com.sksamuel.elastic4s.http.JavaClient
+import com.sksamuel.elastic4s.requests.indexes.admin.DeleteIndexResponse
+import com.sksamuel.elastic4s.requests.indexes.{CreateIndexRequest, CreateIndexResponse, DeleteIndexRequest}
+
+import scala.concurrent.Future
+import scala.concurrent.ExecutionContext.Implicits.global
+
+class CatsEffectTest extends AnyFlatSpec {
+  type OptionIO[A] = OptionT[IO, A]
+
+  val client: ElasticClient = ElasticClient(JavaClient(ElasticProperties("http://dummy")))
+  val index = "index"
+
+  "ElasticClient#execute" should "compile and infer effect type as `IO`" in {
+    for {
+      r1 <- client.execute(createIndex(index))
+      _ <- IO(println(r1))
+      r2 <- client.execute(deleteIndex(index))
+      _ <- IO(println(r2))
+    } yield (r1, r2)
+  }
+
+  it should "still compile with other Cats `Async` instances with explicit type annotations" in {
+    for {
+      r1 <- client.execute[CreateIndexRequest, CreateIndexResponse, OptionIO](createIndex(index))
+      _ <- IO(println(r1)).to[OptionIO]
+      r2 <- client.execute[DeleteIndexRequest, DeleteIndexResponse, OptionIO](deleteIndex(index))
+      _ <- IO(println(r2)).to[OptionIO]
+    } yield (r1, r2)
+  }
+
+  it should "still compile with `Future` with explicit type annotations" in {
+    for {
+      r1 <- client.execute[CreateIndexRequest, CreateIndexResponse, Future](createIndex(index))
+      _ <- Future(println(r1))
+      r2 <- client.execute[DeleteIndexRequest, DeleteIndexResponse, Future](deleteIndex(index))
+      _ <- Future(println(r2))
+    } yield (r1, r2)
+  }
+}

elastic4s-effect-cats/src/main/scala/com/sksamuel/elastic4s/cats/effect/instances/CatsEffectInstances.scala

@@ -1,6 +1,6 @@
 package com.sksamuel.elastic4s.cats.effect.instances
 
-import cats.effect.Async
+import cats.effect.{Async, IO}
 import cats.{Functor => CatsFunctor}
 import com.sksamuel.elastic4s.cats.effect.CatsEffectExecutor
 import com.sksamuel.elastic4s.{Executor, Functor}
@@ -12,6 +12,9 @@ trait CatsEffectInstances {
 
   implicit def catsEffectExecutor[F[_]: Async]: Executor[F] =
     new CatsEffectExecutor[F]
+
+  //this needs to be at the bottom
+  implicit val ioExecutor: Executor[IO] = new CatsEffectExecutor[IO]
 }
 
 @deprecated("Use CatsEffectInstances instead")

elastic4s-effect-cats/src/test/scala/com.sksamuel.elastic4s.cats.effect/CatsEffectTest.scala

@@ -0,0 +1,48 @@
+package com.sksamuel.elastic4s.cats.effect
+
+import cats.data.OptionT
+import cats.effect.IO
+import com.sksamuel.elastic4s.{ElasticClient, ElasticProperties}
+import com.sksamuel.elastic4s.ElasticDsl._
+import org.scalatest.flatspec.AnyFlatSpec
+import com.sksamuel.elastic4s.cats.effect.instances._
+import com.sksamuel.elastic4s.http.JavaClient
+import com.sksamuel.elastic4s.requests.indexes.admin.DeleteIndexResponse
+import com.sksamuel.elastic4s.requests.indexes.{CreateIndexRequest, CreateIndexResponse, DeleteIndexRequest}
+
+import scala.concurrent.Future
+import scala.concurrent.ExecutionContext.Implicits.global
+
+class CatsEffectTest extends AnyFlatSpec {
+  type OptionIO[A] = OptionT[IO, A]
+
+  val client: ElasticClient = ElasticClient(JavaClient(ElasticProperties("http://dummy")))
+  val index = "index"
+
+  "ElasticClient#execute" should "compile and infer effect type as `IO`" in {
+    for {
+      r1 <- client.execute(createIndex(index))
+      _ <- IO(println(r1))
+      r2 <- client.execute(deleteIndex(index))
+      _ <- IO(println(r2))
+    } yield (r1, r2)
+  }
+
+  it should "still compile with other Cats `Async` instances with explicit type annotations" in {
+    for {
+      r1 <- client.execute[CreateIndexRequest, CreateIndexResponse, OptionIO](createIndex(index))
+      _ <- IO(println(r1)).to[OptionIO]
+      r2 <- client.execute[DeleteIndexRequest, DeleteIndexResponse, OptionIO](deleteIndex(index))
+      _ <- IO(println(r2)).to[OptionIO]
+    } yield (r1, r2)
+  }
+
+  it should "still compile with `Future` with explicit type annotations" in {
+    for {
+      r1 <- client.execute[CreateIndexRequest, CreateIndexResponse, Future](createIndex(index))
+      _ <- Future(println(r1))
+      r2 <- client.execute[DeleteIndexRequest, DeleteIndexResponse, Future](deleteIndex(index))
+      _ <- Future(println(r2))
+    } yield (r1, r2)
+  }
+}