update tests to skip replica reads if not supported

Author: thejcfactor

test/test_integration_subdoc.cxx

@@ -1832,15 +1832,17 @@ TEST_CASE("integration: subdoc invalid_argument if empty specs", "[integration]"
     auto lookupin_resp = test::utils::execute(integration.cluster, lookupin_req);
     REQUIRE(lookupin_resp.ctx.ec() == couchbase::errc::common::invalid_argument);
 
-    couchbase::core::operations::lookup_in_any_replica_request lookupin_any_replica_req{ id };
-    auto lookupin_any_replica_resp =
-      test::utils::execute(integration.cluster, lookupin_any_replica_req);
-    REQUIRE(lookupin_any_replica_resp.ctx.ec() == couchbase::errc::common::invalid_argument);
-
-    couchbase::core::operations::lookup_in_all_replicas_request lookup_in_all_replicas_req{ id };
-    auto lookup_in_all_replicas_resp =
-      test::utils::execute(integration.cluster, lookup_in_all_replicas_req);
-    REQUIRE(lookup_in_all_replicas_resp.ctx.ec() == couchbase::errc::common::invalid_argument);
+    if (integration.has_bucket_capability("subdoc.ReplicaRead")) {
+      couchbase::core::operations::lookup_in_any_replica_request lookupin_any_replica_req{ id };
+      auto lookupin_any_replica_resp =
+        test::utils::execute(integration.cluster, lookupin_any_replica_req);
+      REQUIRE(lookupin_any_replica_resp.ctx.ec() == couchbase::errc::common::invalid_argument);
+
+      couchbase::core::operations::lookup_in_all_replicas_request lookup_in_all_replicas_req{ id };
+      auto lookup_in_all_replicas_resp =
+        test::utils::execute(integration.cluster, lookup_in_all_replicas_req);
+      REQUIRE(lookup_in_all_replicas_resp.ctx.ec() == couchbase::errc::common::invalid_argument);
+    }
 
     couchbase::core::operations::mutate_in_request mutatein_req{ id };
     auto mutatein_resp = test::utils::execute(integration.cluster, mutatein_req);
@@ -1860,14 +1862,16 @@ TEST_CASE("integration: subdoc invalid_argument if empty specs", "[integration]"
     auto [lookupin_err, lookupin_resp] = collection.lookup_in(key, {}).get();
     REQUIRE(lookupin_err.ec() == couchbase::errc::common::invalid_argument);
 
-    auto [lookup_in_any_replica_err, lookup_in_any_replica_resp] =
-      collection.lookup_in_any_replica(key, {}).get();
-    REQUIRE(lookup_in_any_replica_err.ec() == couchbase::errc::common::invalid_argument);
+    if (integration.has_bucket_capability("subdoc.ReplicaRead")) {
+      auto [lookup_in_any_replica_err, lookup_in_any_replica_resp] =
+        collection.lookup_in_any_replica(key, {}).get();
+      REQUIRE(lookup_in_any_replica_err.ec() == couchbase::errc::common::invalid_argument);
 
-    auto [lookup_in_all_replicas_err, lookup_in_all_replicas_resp] =
-      collection.lookup_in_all_replicas(key, {}).get();
-    REQUIRE(lookup_in_all_replicas_err.ec() == couchbase::errc::common::invalid_argument);
-    REQUIRE(lookup_in_all_replicas_resp.empty());
+      auto [lookup_in_all_replicas_err, lookup_in_all_replicas_resp] =
+        collection.lookup_in_all_replicas(key, {}).get();
+      REQUIRE(lookup_in_all_replicas_err.ec() == couchbase::errc::common::invalid_argument);
+      REQUIRE(lookup_in_all_replicas_resp.empty());
+    }
 
     auto [mutate_in_err, mutate_in_resp] = collection.mutate_in(key, {}).get();
     REQUIRE(mutate_in_err.ec() == couchbase::errc::common::invalid_argument);