Add backward compatibility test

Author: giabao

build.sbt

@@ -2,6 +2,35 @@ val emptyDoc = Compile / packageDoc / mappings := Seq(
   (ThisBuild / baseDirectory).value / "README.md" -> "README.md"
 )
 
+def resourcePrepare(extra: Def.Initialize[Task[String]]) =
+  resourceGenerators += Def.task {
+    val f = managedResourceDirectories.value.head / "application.conf"
+    val host = java.net.InetAddress.getLocalHost.getHostAddress
+    IO.write(
+      f,
+      s"""com.sandinh.couchbase {
+         |  connectionString="couchbase://$host"
+         |  user="cb"
+         |  password="cb_password"
+         |}
+         |${extra.value}
+         |""".stripMargin
+    )
+    Seq(f)
+  }
+
+// util project to test couchbase-scala backward compatibility
+lazy val `compat-test` = project
+  .settings(
+    skipPublish,
+    scalaVersion := scala213,
+    resolvers += Resolver.sonatypeRepo("public"),
+    libraryDependencies ++= Seq(
+      "com.sandinh" %% "couchbase-scala" % "9.1.0+2-c1c4b4d4-SNAPSHOT",
+    ),
+    inConfig(Compile)(resourcePrepare(Def.task(""))),
+  )
+
 lazy val `couchbase-scala` = projectMatrix
   .in(file("core"))
   .configAxis(config13, Seq(scala212, scala213))
@@ -15,6 +44,15 @@ lazy val `couchbase-scala` = projectMatrix
       "com.google.inject" % "guice" % "5.0.1" % Test,
     ) ++ specs2("-core").value,
     emptyDoc,
+    inConfig(Test)(resourcePrepare(Def.task {
+      val cp = (`compat-test` / Runtime / fullClasspath).value
+        .map(_.data.getAbsolutePath)
+        .mkString(":")
+      s"""compat-test.classpath="$cp""""
+    })),
+    Test / test := (Test / test)
+      .dependsOn(`compat-test` / Compile / compile)
+      .value,
   )
 
 lazy val `couchbase-play` = projectMatrix
@@ -51,6 +89,7 @@ lazy val `couchbase-play` = projectMatrix
         "ch.qos.logback" % "logback-classic" % "1.2.7" % Test,
       ),
     emptyDoc,
+    inConfig(Test)(resourcePrepare(Def.task(""))),
   )
 
 // only aggregating project
@@ -85,15 +124,7 @@ inThisBuild(
   )
 )
 
-inThisBuild(
-  // In Test code: com.sandinh.couchbase.GuiceSpecBase.setup
-  // We use Guice's injectMembers that inject value for the GuiceSpecBase's private var `_cb`
-  // using reflection which is deny by default in java 16+
-  addOpensForTest() ++ Seq(
-    Test / fork := true,
-    Test / javaOptions += {
-      val host = java.net.InetAddress.getLocalHost.getHostAddress
-      s"-Dcom.sandinh.couchbase.connectionString=$host"
-    },
-  )
-)
+// In Test code: com.sandinh.couchbase.GuiceSpecBase.setup
+// We use Guice's injectMembers that inject value for the GuiceSpecBase's private var `_cb`
+// using reflection which is deny by default in java 16+
+inThisBuild(addOpensForTest())

compat-test/src/main/scala/com/sandinh/couchbase/Main.scala

@@ -0,0 +1,29 @@
+package com.sandinh.couchbase
+import com.couchbase.client.java.document.JsonLongDocument
+import com.sandinh.couchbase.Implicits.DocNotExistFuture
+import com.typesafe.config.ConfigFactory
+
+import scala.concurrent.Await
+import scala.concurrent.ExecutionContext.Implicits.global
+import scala.concurrent.duration._
+
+object Main {
+  def main(args: Array[String]): Unit = {
+    val cluster = new CBCluster(ConfigFactory.load())
+    val bucket = cluster.openBucketSync("fodi")
+
+    val f = args match {
+      case Array("set", "counter", key, value) =>
+        bucket.counter(key, 0, value.toLong)
+      case Array("get", "counter", key) =>
+        bucket
+          .get[JsonLongDocument](key)
+          .map(_.content.longValue)
+          .recoverNotExist(0L)
+      case _ => ???
+    }
+
+    val v = Await.result(f, 5.seconds)
+    print(v)
+  }
+}

core/src/test/resources/application.conf

@@ -0,0 +1,29 @@
+package com.sandinh.couchbase
+
+import com.typesafe.config.Config
+import javax.inject.Inject
+import scala.util.Random
+import scala.sys.process._
+
+class BackwardCompatSpec extends GuiceSpecBase {
+  @Inject private var conf: Config = _
+  private lazy val cp = conf.getString("compat-test.classpath")
+
+  private def run(args: String) =
+    s"java -cp $cp com.sandinh.couchbase.Main $args".!!.trim
+  private def rndKv() =
+    ("compat" + Random.nextLong(), Random.nextLong().abs + 1)
+
+  "counter" should {
+    "backward compat: new set, old get" in {
+      val (k, v) = rndKv()
+      cb.bk1.counter(k, 0, v).map(_.content) must beEqualTo(v).await
+      run(s"get counter $k") === v.toString
+    }
+    "backward compat: old set, new get" in {
+      val (k, v) = rndKv()
+      run(s"set counter $k $v") === v.toString
+      cb.bk1.getCounter(k) must beEqualTo(v).await
+    }
+  }
+}