Scala FIT performer: Prevent scalafmt from overriding //?

scalafmt is changing "//?" to "// ?" which then breaks
the FIT tagger.  The only solution appears to be this:
disabling scalafmt around those sections.

Change-Id: If392e3e4c54c2bb8ea1422e56f887220499d0eae
Reviewed-on: https://review.couchbase.org/c/couchbase-jvm-clients/+/232107
Tested-by: Build Bot <[email protected]>
Reviewed-by: David Nault <[email protected]>

Author: programmatix

scala-fit-performer/src/main/scala/com/couchbase/client/performer/scala/ScalaPerformer.scala

@@ -38,7 +38,9 @@ import com.couchbase.client.scala.transactions.internal.TransactionsSupportedExt
 import com.couchbase.client.scala.transactions.internal.TransactionsSupportedExtensionsUtil.Supported
 // [end]
 // [if:<1.7.2]
+// format: off
 //? import com.couchbase.client.core.transaction.forwards.{Extension, Supported}
+// format: on
 // [end]
 // [end]
 
@@ -144,6 +146,7 @@ class ScalaPerformer extends CorePerformer {
 
     // [if:1.5.0]
     // [if:<1.7.2]
+    // format: off
 //?    response.addPerformerCaps(Caps.TRANSACTIONS_SUPPORT_1)
 //?    val supported = new Supported
 //?    val protocolVersion = supported.protocolMajor + "." + supported.protocolMinor
@@ -176,6 +179,7 @@ class ScalaPerformer extends CorePerformer {
 //?            else logger.warn("Could not find FIT extension for " + ext.name)
 //?        }
 //?      })
+    // format: on
     // [end]
     // [end]
   }
@@ -269,7 +273,9 @@ class ScalaPerformer extends CorePerformer {
     new ScalaTransactionCommandExecutor(connection, counters, Map.empty)
     // [end:1.5.0]
     // [if:<1.5.0]
+    // format: off
     //? null
+    // format: on
     // [end]
   }
 
@@ -300,7 +306,7 @@ class ScalaPerformer extends CorePerformer {
       val connection: ClusterConnection = getClusterConnection(request.getClusterConnectionId)
       logger.info("Starting transaction on cluster connection {}", request.getClusterConnectionId)
       val counters = new Counters()
-      val e = new ScalaTransactionCommandExecutor(connection, counters, Map.empty)
+      val e        = new ScalaTransactionCommandExecutor(connection, counters, Map.empty)
       val response = TransactionBlocking.run(connection, request, Some(e), false, Map.empty)
       responseObserver.onNext(response)
       responseObserver.onCompleted()
@@ -339,7 +345,9 @@ class ScalaPerformer extends CorePerformer {
       )
       // [end]
       // [if:<1.7.2]
-      //?val cleaner = new TransactionsCleaner(connection.cluster.async.core, cleanupHooks)
+      // format: off
+      //? val cleaner = new TransactionsCleaner(connection.cluster.async.core, cleanupHooks)
+      // format: on
       // [end]
       val l        = new CoreTransactionLogger(null, "")
       val merged   = new CoreMergedTransactionConfig(config.toCore)

scala-fit-performer/src/main/scala/com/couchbase/client/performer/scala/search/SearchHelper.scala

@@ -220,7 +220,9 @@ object SearchHelper {
       // [if:1.4.5]
       opts = opts.timeout(Duration(o.getTimeoutMillis, TimeUnit.MILLISECONDS))
       // [else]
+      // format: off
       //? throw new UnsupportedOperationException()
+      // format: on
       // [end]
     }
     if (o.hasParentSpanId) throw new UnsupportedOperationException()
@@ -538,8 +540,10 @@ object SearchHelper {
       com.couchbase.client.scala.search.vector.VectorQuery(vq.getVectorFieldName, query)
     }
     // [else]
+    // format: off
     //? val query: Array[Float] = vq.getVectorQueryList.asScala.toArray.map(v => v.asInstanceOf[Float])
     //? var out                 = com.couchbase.client.scala.search.vector.VectorQuery(vq.getVectorFieldName, query)
+    // format: on
     // [end]
     if (vq.hasOptions) {
       val opts = vq.getOptions
@@ -757,7 +761,9 @@ object SearchHelper {
       result.setElapsedNanos(System.nanoTime - start)
       setSuccess(result)
       // [else]
+      // format: off
       //? throw new UnsupportedOperationException()
+      // format: on
       // [end]
     } else if (command.hasDropIndex) {
       val req = command.getDropIndex

scala-fit-performer/src/main/scala/com/couchbase/client/performer/scala/transaction/TransactionBlocking.scala

@@ -110,7 +110,9 @@ class TransactionBlocking(executor: Option[TransactionCommandExecutor])
       ptcb.orNull
       // [end]
       // [if:<3.9.0]
+      // format: off
       //? Option(ptcb.orNull)
+      // format: on
       // [end]
     )
     if (TransactionMarkerOwner.get.block.isPresent)
@@ -187,12 +189,14 @@ class TransactionBlocking(executor: Option[TransactionCommandExecutor])
           }
           // [end]
           // [if:<1.9.0]
+          // format: off
           //? content match {
           //?   case ContentString(value) => ctx.insert(collection, request.getDocId.getDocId, value).get
           //?   case ContentJson(value) => ctx.insert(collection, request.getDocId.getDocId, value).get
           //?   case ContentByteArray(value) => ctx.insert(collection, request.getDocId.getDocId, value).get
           //?   case ContentNull(value) => ctx.insert(collection, request.getDocId.getDocId, value).get
           //? }
+          // format: on
           // [end]
         }
       )
@@ -319,6 +323,7 @@ class TransactionBlocking(executor: Option[TransactionCommandExecutor])
           }
           // [end]
           // [if:<1.9.0]
+          // format: off
           //? if (request.getUseStashedResult) {
           //?   content match {
           //?     case ContentString(value) => ctx.replace(stashedGet.get, value).get
@@ -353,6 +358,7 @@ class TransactionBlocking(executor: Option[TransactionCommandExecutor])
           //?     case ContentNull(value) => ctx.replace(r, value).get
           //?   }
           //? }
+          // format: on
           // [end]
 
         }
@@ -474,7 +480,9 @@ class TransactionBlocking(executor: Option[TransactionCommandExecutor])
           }
           // [end]
           // [if:<1.9.0]
+          // format: off
           //? val out = ctx.get(collection, request.getDocId.getDocId).get
+          // format: on
           // [end]
           val contentAsValidation =
             if (request.hasContentAsValidation) Some(request.getContentAsValidation) else None
@@ -501,7 +509,9 @@ class TransactionBlocking(executor: Option[TransactionCommandExecutor])
           }
           // [end]
           // [if:<1.9.0]
+          // format: off
           //? ctx.get(collection, executor.get.getDocId(request.getLocation)).get
+          // format: on
           // [end]
         }
       )
@@ -531,7 +541,9 @@ class TransactionBlocking(executor: Option[TransactionCommandExecutor])
           }
           // [end]
           // [if:<1.9.0]
+          // format: off
           //? val out = ctx.get(collection, request.getDocId.getDocId)
+          // format: on
           // [end]
           val contentAsValidation =
             if (request.hasContentAsValidation) Some(request.getContentAsValidation) else None
@@ -562,7 +574,9 @@ class TransactionBlocking(executor: Option[TransactionCommandExecutor])
           }
           // [end]
           // [if:<1.9.0]
+          // format: off
           //? val result = ctx.getReplicaFromPreferredServerGroup(collection, request.getDocId.getDocId).get
+          // format: on
           // [end]
           handleGetReplicaFromPreferredServerGroupResult(request, result, connection)
         }
@@ -691,7 +705,7 @@ class TransactionBlocking(executor: Option[TransactionCommandExecutor])
           ResultValidation.validateQueryResult(request, qr.get)
         }
       )
-    // [if:3.9.0]
+      // [if:3.9.0]
     } else if (op.hasGetMulti) {
       val request = op.getGetMulti
       if (!request.getGetMultiReplicasFromPreferredServerGroup) {