Scala FIT performer minor fix

The tests require FAILED_PRECONDITION GRPC error code
to be raised in specific content validation failure
situations.

Change-Id: I69c61ecdee3b3600b64e08dc3c769e70430909a1
Reviewed-on: https://review.couchbase.org/c/couchbase-jvm-clients/+/233431
Tested-by: Build Bot <[email protected]>
Reviewed-by: Dimitris Christodoulou <[email protected]>

Author: programmatix

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

@@ -311,6 +311,10 @@ class ScalaPerformer extends CorePerformer {
       responseObserver.onNext(response)
       responseObserver.onCompleted()
     } catch {
+      case err: com.couchbase.client.performer.scala.transaction.TestFailureRaiseFailedPrecondition =>
+        logger.error("Operation failed during transactionCreate due to :  " + err)
+        err.printStackTrace()
+        responseObserver.onError(Status.FAILED_PRECONDITION.withDescription(err.toString).asException)
       case err: RuntimeException =>
         logger.error("Operation failed during transactionCreate due to :  " + err)
         err.printStackTrace()

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

@@ -104,10 +104,8 @@ object GetMultiHelper {
           )
 
           if (expectedContent.getExpectSuccess != actualContent.isSuccess) {
-            throw new TestFailure(
-              new RuntimeException(
-                s"ContentAs result $actualContent did not equal expected result ${expectedContent.getExpectSuccess}"
-              )
+            throw new TestFailureRaiseFailedPrecondition(
+              s"ContentAs result $actualContent did not equal expected result ${expectedContent.getExpectSuccess}"
             )
           }
 
@@ -116,10 +114,8 @@ object GetMultiHelper {
             if (
               !java.util.Arrays.equals(expectedContent.getExpectedContentBytes.toByteArray, bytes)
             ) {
-              throw new TestFailure(
-                new RuntimeException(
-                  s"Content bytes ${java.util.Arrays.toString(bytes)} did not equal expected bytes ${expectedContent.getExpectedContentBytes}"
-                )
+              throw new TestFailureRaiseFailedPrecondition(
+                s"Content bytes ${java.util.Arrays.toString(bytes)} did not equal expected bytes ${expectedContent.getExpectedContentBytes}"
               )
             }
           }
@@ -164,10 +160,8 @@ object GetMultiHelper {
           )
 
           if (expectedContent.getExpectSuccess != actualContent.isSuccess) {
-            throw new TestFailure(
-              new RuntimeException(
-                s"ContentAs result $actualContent did not equal expected result ${expectedContent.getExpectSuccess}"
-              )
+            throw new TestFailureRaiseFailedPrecondition(
+              s"ContentAs result $actualContent did not equal expected result ${expectedContent.getExpectSuccess}"
             )
           }
 
@@ -176,10 +170,8 @@ object GetMultiHelper {
             if (
               !java.util.Arrays.equals(expectedContent.getExpectedContentBytes.toByteArray, bytes)
             ) {
-              throw new TestFailure(
-                new RuntimeException(
-                  s"Content bytes ${java.util.Arrays.toString(bytes)} did not equal expected bytes ${expectedContent.getExpectedContentBytes}"
-                )
+              throw new TestFailureRaiseFailedPrecondition(
+                s"Content bytes ${java.util.Arrays.toString(bytes)} did not equal expected bytes ${expectedContent.getExpectedContentBytes}"
               )
             }
           }

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

@@ -0,0 +1,27 @@
+/*
+ * Copyright 2025 Couchbase, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.couchbase.client.performer.scala.transaction;
+
+/**
+ * Signals that the performer should fail the RPC with gRPC FAILED_PRECONDITION.
+ */
+public class TestFailureRaiseFailedPrecondition extends TestFailure {
+    public TestFailureRaiseFailedPrecondition(String message) {
+        super(message);
+    }
+}
+
+

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

@@ -241,20 +241,16 @@ abstract class TransactionShared(
       )
 
       if (cas.getExpectSuccess != content.isSuccess) {
-        throw new TestFailure(
-          new RuntimeException(
-            s"ContentAs result $content did not equal expected result ${cas.getExpectSuccess}"
-          )
+        throw new TestFailureRaiseFailedPrecondition(
+          s"ContentAs result $content did not equal expected result ${cas.getExpectSuccess}"
         )
       }
 
       if (cas.hasExpectedContentBytes) {
         val bytes = ContentAsUtil.convert(content.get)
         if (!java.util.Arrays.equals(cas.getExpectedContentBytes.toByteArray, bytes)) {
-          throw new TestFailure(
-            new RuntimeException(
-              s"Content bytes ${java.util.Arrays.toString(bytes)} did not equal expected bytes ${cas.getExpectedContentBytes}"
-            )
+          throw new TestFailureRaiseFailedPrecondition(
+            s"Content bytes ${java.util.Arrays.toString(bytes)} did not equal expected bytes ${cas.getExpectedContentBytes}"
           )
         }
       }
@@ -296,21 +292,17 @@ abstract class TransactionShared(
       )
 
       if (contentAs.getExpectSuccess != content.isSuccess)
-        throw new TestFailure(
-          new RuntimeException(
-            "ContentAs result " + content + " did not equal expected result " + contentAs.getExpectSuccess
-          )
+        throw new com.couchbase.client.performer.scala.transaction.TestFailureRaiseFailedPrecondition(
+          "ContentAs result " + content + " did not equal expected result " + contentAs.getExpectSuccess
         )
 
       if (contentAs.hasExpectedContentBytes) {
         val bytes: Array[Byte] = ContentAsUtil.convert(content.get)
         if (!java.util.Arrays.equals(contentAs.getExpectedContentBytes.toByteArray, bytes))
-          throw new TestFailure(
-            new RuntimeException(
-              "Content bytes " + java.util.Arrays.toString(
-                bytes
-              ) + " did not equal expected bytes " + contentAs.getExpectedContentBytes
-            )
+          throw new com.couchbase.client.performer.scala.transaction.TestFailureRaiseFailedPrecondition(
+            "Content bytes " + java.util.Arrays.toString(
+              bytes
+            ) + " did not equal expected bytes " + contentAs.getExpectedContentBytes
           )
       }
     }