Test your AI Agents with the all-new Agent to Agent Testing Platform.Learn More

How to use checkSuccessfulResponse method of org.testcontainers.couchbase.CouchbaseContainer class

Best Testcontainers-java code snippet using org.testcontainers.couchbase.CouchbaseContainer.checkSuccessfulResponse

Source:CouchbaseContainer.java

...262        @Cleanup Response response = doHttpRequest(MGMT_PORT, "/node/controller/rename", "POST", new FormBody.Builder()263            .add("hostname", getInternalIpAddress())264            .build(), false265        );266        checkSuccessfulResponse(response, "Could not rename couchbase node");267    }268    /**269     * Initializes services based on the configured enabled services.270     */271    private void initializeServices() {272        logger().debug("Initializing couchbase services on host: {}", enabledServices);273        final String services = enabledServices274            .stream()275            .map(CouchbaseService::getIdentifier)276            .collect(Collectors.joining(","));277        @Cleanup Response response = doHttpRequest(MGMT_PORT, "/node/controller/setupServices", "POST", new FormBody.Builder()278            .add("services", services)279            .build(), false280        );281        checkSuccessfulResponse(response, "Could not enable couchbase services");282    }283    /**284     * Configures the admin user on the couchbase node.285     * <p>286     * After this stage, all subsequent API calls need to have the basic auth header set.287     */288    private void configureAdminUser() {289        logger().debug("Configuring couchbase admin user with username: \"{}\"", username);290        @Cleanup Response response = doHttpRequest(MGMT_PORT, "/settings/web", "POST", new FormBody.Builder()291            .add("username", username)292            .add("password", password)293            .add("port", Integer.toString(MGMT_PORT))294            .build(), false);295        checkSuccessfulResponse(response, "Could not configure couchbase admin user");296    }297    /**298     * Configures the external ports for SDK access.299     * <p>300     * Since the internal ports are not accessible from outside the container, this code configures the "external"301     * hostname and services to align with the mapped ports. The SDK will pick it up and then automatically connect302     * to those ports. Note that for all services non-ssl and ssl ports are configured.303     */304    private void configureExternalPorts() {305        logger().debug("Mapping external ports to the alternate address configuration");306        final FormBody.Builder builder = new FormBody.Builder();307        builder.add("hostname", getHost());308        builder.add("mgmt", Integer.toString(getMappedPort(MGMT_PORT)));309        builder.add("mgmtSSL", Integer.toString(getMappedPort(MGMT_SSL_PORT)));310        if (enabledServices.contains(CouchbaseService.KV)) {311            builder.add("kv", Integer.toString(getMappedPort(KV_PORT)));312            builder.add("kvSSL", Integer.toString(getMappedPort(KV_SSL_PORT)));313            builder.add("capi", Integer.toString(getMappedPort(VIEW_PORT)));314            builder.add("capiSSL", Integer.toString(getMappedPort(VIEW_SSL_PORT)));315        }316        if (enabledServices.contains(CouchbaseService.QUERY)) {317            builder.add("n1ql", Integer.toString(getMappedPort(QUERY_PORT)));318            builder.add("n1qlSSL", Integer.toString(getMappedPort(QUERY_SSL_PORT)));319        }320        if (enabledServices.contains(CouchbaseService.SEARCH)) {321            builder.add("fts", Integer.toString(getMappedPort(SEARCH_PORT)));322            builder.add("ftsSSL", Integer.toString(getMappedPort(SEARCH_SSL_PORT)));323        }324        if (enabledServices.contains(CouchbaseService.ANALYTICS)) {325            builder.add("cbas", Integer.toString(getMappedPort(ANALYTICS_PORT)));326            builder.add("cbasSSL", Integer.toString(getMappedPort(ANALYTICS_SSL_PORT)));327        }328        @Cleanup Response response = doHttpRequest(329            MGMT_PORT,330            "/node/controller/setupAlternateAddresses/external",331            "PUT",332            builder.build(),333            true334        );335        checkSuccessfulResponse(response, "Could not configure external ports");336    }337    /**338     * Configures the indexer service so that indexes can be created later on the bucket.339     */340    private void configureIndexer() {341        logger().debug("Configuring the indexer service");342        @Cleanup Response response = doHttpRequest(MGMT_PORT, "/settings/indexes", "POST", new FormBody.Builder()343            .add("storageMode", isEnterprise ? "memory_optimized" : "forestdb")344            .build(), true345        );346        checkSuccessfulResponse(response, "Could not configure the indexing service");347    }348    /**349     * Based on the user-configured bucket definitions, creating buckets and corresponding indexes if needed.350     */351    private void createBuckets() {352        logger().debug("Creating {} buckets (and corresponding indexes).", buckets.size());353        for (BucketDefinition bucket : buckets) {354            logger().debug("Creating bucket \"{}\"", bucket.getName());355            @Cleanup Response response = doHttpRequest(MGMT_PORT, "/pools/default/buckets", "POST", new FormBody.Builder()356                .add("name", bucket.getName())357                .add("ramQuotaMB", Integer.toString(bucket.getQuota()))358                .add("flushEnabled", bucket.hasFlushEnabled() ? "1" : "0")359                .build(), true);360            checkSuccessfulResponse(response, "Could not create bucket " + bucket.getName());361            timePhase("createBucket:" + bucket.getName() + ":waitForAllServicesEnabled", () ->362                new HttpWaitStrategy()363                .forPath("/pools/default/b/" + bucket.getName())364                .forPort(MGMT_PORT)365                .withBasicCredentials(username, password)366                .forStatusCode(200)367                .forResponsePredicate(new AllServicesEnabledPredicate())368                .waitUntilReady(this)369            );370            if (enabledServices.contains(CouchbaseService.QUERY)) {371                // If the query service is enabled, make sure that we only proceed if the query engine also372                // knows about the bucket in its metadata configuration.373                timePhase(374                    "createBucket:" + bucket.getName() + ":queryKeyspacePresent",375                    () -> Unreliables.retryUntilTrue(1, TimeUnit.MINUTES, () -> {376                        @Cleanup Response queryResponse = doHttpRequest(QUERY_PORT, "/query/service", "POST", new FormBody.Builder()377                            .add("statement", "SELECT COUNT(*) > 0 as present FROM system:keyspaces WHERE name = \"" + bucket.getName() + "\"")378                            .build(), true);379                        String body = queryResponse.body() != null ? queryResponse.body().string() : null;380                        checkSuccessfulResponse(queryResponse, "Could not poll query service state for bucket: " + bucket.getName());381                        return Optional.of(MAPPER.readTree(body))382                            .map(n -> n.at("/results/0/present"))383                            .map(JsonNode::asBoolean)384                            .orElse(false);385                }));386            }387            if (bucket.hasPrimaryIndex()) {388                if (enabledServices.contains(CouchbaseService.QUERY)) {389                    @Cleanup Response queryResponse = doHttpRequest(QUERY_PORT, "/query/service", "POST", new FormBody.Builder()390                        .add("statement", "CREATE PRIMARY INDEX on `" + bucket.getName() + "`")391                        .build(), true);392                    try {393                        checkSuccessfulResponse(queryResponse, "Could not create primary index for bucket " + bucket.getName());394                    } catch (IllegalStateException ex) {395                        // potentially ignore the error, the index will be eventually built.396                        if (!ex.getMessage().contains("Index creation will be retried in background")) {397                            throw ex;398                        }399                    }400                    timePhase(401                        "createBucket:" + bucket.getName() + ":primaryIndexOnline",402                        () ->  Unreliables.retryUntilTrue(1, TimeUnit.MINUTES, () -> {403                            @Cleanup Response stateResponse = doHttpRequest(QUERY_PORT, "/query/service", "POST", new FormBody.Builder()404                                .add("statement", "SELECT count(*) > 0 AS online FROM system:indexes where keyspace_id = \"" + bucket.getName() + "\" and is_primary = true and state = \"online\"")405                                .build(), true);406                            String body = stateResponse.body() != null ? stateResponse.body().string() : null;407                            checkSuccessfulResponse(stateResponse, "Could not poll primary index state for bucket: " + bucket.getName());408                            return Optional.of(MAPPER.readTree(body))409                                .map(n -> n.at("/results/0/online"))410                                .map(JsonNode::asBoolean)411                                .orElse(false);412                    }));413                } else {414                    logger().info("Primary index creation for bucket {} ignored, since QUERY service is not present.", bucket.getName());415                }416            }417        }418    }419    /**420     * Helper method to extract the internal IP address based on the network configuration.421     */422    private String getInternalIpAddress() {423        return getContainerInfo().getNetworkSettings().getNetworks().values().stream()424            .findFirst()425            .map(ContainerNetwork::getIpAddress)426            .orElseThrow(() -> new IllegalStateException("No network available to extract the internal IP from!"));427    }428    /**429     * Helper method to check if the response is successful and release the body if needed.430     *431     * @param response the response to check.432     * @param message the message that should be part of the exception of not successful.433     */434    private void checkSuccessfulResponse(final Response response, final String message) {435        if (!response.isSuccessful()) {436            String body = null;437            if (response.body() != null) {438                try {439                    body = response.body().string();440                } catch (IOException e) {441                    logger().debug("Unable to read body of response: {}", response, e);442                }443            }444            throw new IllegalStateException(message + ": " + response + ", body=" + (body == null ? "<null>" : body));445        }446    }447    /**448     * Checks if already running and if so raises an exception to prevent too-late setters....

checkSuccessfulResponse

Using AI Code Generation

1import com.couchbase.client.java.Bucket;2import com.couchbase.client.java.Cluster;3import com.couchbase.client.java.CouchbaseCluster;4import com.couchbase.client.java.document.JsonDocument;5import com.couchbase.client.java.document.json.JsonObject;6import com.couchbase.client.java.query.N1qlQuery;7import com.couchbase.client.java.query.N1qlQueryResult;8import com.couchbase.client.java.query.N1qlQueryRow;9import com.couchbase.client.java.query.consistency.ScanConsistency;10import com.couchbase.client.java.query.dsl.Expression;11import com.couchbase.client.java.query.dsl.path.DefaultLimitPath;12import org.testcontainers.couchbase.BucketDefinition;13import org.testcontainers.couchbase.CouchbaseContainer;14import java.util.ArrayList;15import java.util.List;16import java.util.Map;17import java.util.stream.Collectors;18public class CouchbaseTest {19    public static final String COUCHBASE = "couchbase";20    public static final String BUCKET = "test";21    public static final String PASSWORD = "password";22    public static final String USERNAME = "Administrator";23    public static final String PRIMARY_INDEX = "CREATE PRIMARY INDEX ON `test` USING GSI";24    public static final String INDEX = "CREATE INDEX `test` ON `test`(`test`) WHERE `test` IS NOT MISSING";25    public static void main(String[] args) {26        CouchbaseContainer couchbase = new CouchbaseContainer()27                .withClusterUsername(USERNAME)28                .withClusterPassword(PASSWORD)29                .withBucket(new BucketDefinition(BUCKET).withQuota(100));30        couchbase.start();31        Cluster cluster = CouchbaseCluster.create(couchbase.getContainerIpAddress());32        cluster.authenticate(USERNAME, PASSWORD);33        Bucket bucket = cluster.openBucket(BUCKET);34        bucket.upsert(JsonDocument.create("id1", JsonObject.create().put("test", "test1")));35        bucket.upsert(JsonDocument.create("id2", JsonObject.create().put("test", "test2")));36        bucket.upsert(JsonDocument.create("id3", JsonObject.create().put("test", "test3")));37        N1qlQueryResult result = cluster.query(N1qlQuery.simple(PRIMARY_INDEX, N1qlQuery.Consistency.REQUEST_PLUS));

checkSuccessfulResponse

Using AI Code Generation

1package org.testcontainers.couchbase;2import com.couchbase.client.java.Bucket;3import com.couchbase.client.java.CouchbaseCluster;4import com.couchbase.client.java.cluster.BucketSettings;5import com.couchbase.client.java.cluster.ClusterManager;6import com.couchbase.client.java.cluster.DefaultBucketSettings;7import com.couchbase.client.java.env.CouchbaseEnvironment;8import com.couchbase.client.java.env.DefaultCouchbaseEnvironment;9import com.couchbase.client.java.query.N1qlQuery;10import com.couchbase.client.java.query.N1qlQueryResult;11import com.couchbase.client.java.query.N1qlQueryRow;12import com.couchbase.client.java.query.N1qlParams;13import com.couchbase.client.java.query.dsl.path.IndexType;14import com.couchbase.client.java.query.dsl.path.IndexesPath;15import com.couchbase.client.java.query.dsl.path.KeysPath;16import com.couchbase.client.java.query.dsl.path.LimitPath;17import com.couchbase.client.java.query.dsl.path.SelectPath;18import com.couchbase.client.java.query.dsl.path.WherePath;19import com.couchbase.client.java.query.dsl.path.WithPath;20import com.couchbase.client.java.query.dsl.path.WithPath.WithPathFinal;21import com.couchbase.client.java.query.dsl.path.WithPath.WithPathFinal.WithPathFinalLimit;22import com.couchbase.client.java.query.dsl.path.WithPath.WithPathFinal.WithPathFinalLimit.WithPathFinalLimitOffset;23import com.couchbase.client.java.query.dsl.path.WithPath.WithPathFinal.WithPathFinalLimit.WithPathFinalLimitOffset.WithPathFinalLimitOffsetOrderBy;24import com.couchbase.client.java.query.dsl.path.WithPath.WithPathFinal.WithPathFinalLimit.WithPathFinalLimitOffset.WithPathFinalLimitOffsetOrderBy.WithPathFinalLimitOffsetOrderByWhere;25import com.couchbase.client.java.query.dsl.path.WithPath.WithPathFinal.WithPathFinalLimit.WithPathFinalLimitOffset.WithPathFinalLimitOffsetOrderBy.WithPathFinalLimitOffsetOrderByWhere.WithPathFinalLimitOffsetOrderByWhereGroupBy;26import com.couchbase.client.java.query.dsl.path.WithPath.WithPathFinal.WithPathFinalLimit.WithPathFinalLimitOffset.WithPathFinalLimitOffsetOrderBy.WithPathFinalLimitOffsetOrderByWhere.WithPathFinalLimit

checkSuccessfulResponse

Using AI Code Generation

1[INFO] --- maven-resources-plugin:2.6:testResources (default-testResources) @ testcontainers-couchbase ---2[INFO] --- maven-compiler-plugin:3.1:testCompile (default-testCompile) @ testcontainers-couchbase ---3[INFO] --- maven-surefire-plugin:2.22.1:test (default-test) @ testcontainers-couchbase ---4[ERROR] shouldStart(org.testcontainers.couchbase.CouchbaseContainerTest)  Time elapsed: 0.002 s  <<< ERROR!5	at org.testcontainers.couchbase.CouchbaseContainerTest.shouldStart(CouchbaseContainerTest.java:32)6	at org.testcontainers.couchbase.CouchbaseContainerTest.shouldStart(CouchbaseContainerTest.java:32)7	at org.testcontainers.couchbase.CouchbaseContainerTest.shouldStart(CouchbaseContainerTest.java:32)8	at org.testcontainers.couchbase.CouchbaseContainerTest.shouldStart(CouchbaseContainerTest.java:32)9	at org.testcontainers.couchbase.CouchbaseContainerTest.shouldStart(Couch

checkSuccessfulResponse

Using AI Code Generation

1public static void checkSuccessfulResponse(HttpResponse response) {2    if (response.getStatusLine().getStatusCode() >= 400) {3        throw new RuntimeException("Got response " + response.getStatusLine().getStatusCode() + " " + response.getStatusLine().getReasonPhrase());4    }5}6public static Bucket getBucket() {7    CouchbaseEnvironment env = DefaultCouchbaseEnvironment.builder()8            .bootstrapCarrierDirectPort(container.getMappedPort(CouchbaseContainer.COUCHBASE_PORT))9            .bootstrapCarrierSslPort(container.getMappedPort(CouchbaseContainer.COUCHBASE_SSL_PORT))10            .bootstrapHttpDirectPort(container.getMappedPort(CouchbaseContainer.COUCHBASE_MGMT_PORT))11            .bootstrapHttpSslPort(container.getMappedPort(CouchbaseContainer.COUCHBASE_MGMT_SSL_PORT))12            .build();13    Cluster cluster = CouchbaseCluster.create(env, container.getContainerIpAddress());14    cluster.authenticate(container.getUsername(), container.getPassword());15    return cluster.openBucket(container.getBucketName());16}17public static Bucket getBucket() {18    CouchbaseEnvironment env = DefaultCouchbaseEnvironment.builder()19            .bootstrapCarrierDirectPort(container.getMappedPort(CouchbaseContainer.COUCHBASE_PORT))20            .bootstrapCarrierSslPort(container.getMappedPort(CouchbaseContainer.COUCHBASE_SSL_PORT))21            .bootstrapHttpDirectPort(container.getMappedPort(CouchbaseContainer.COUCHBASE_MGMT_PORT))22            .bootstrapHttpSslPort(container.getMappedPort(CouchbaseContainer.COUCHBASE_MGMT_SSL_PORT))23            .build();24    Cluster cluster = CouchbaseCluster.create(env, container.getContainerIpAddress());25    cluster.authenticate(container.getUsername(), container.getPassword());26    return cluster.openBucket(container.getBucketName());27}28public static Bucket getBucket() {29    CouchbaseEnvironment env = DefaultCouchbaseEnvironment.builder()30            .bootstrapCarrierDirectPort(container.getMappedPort(CouchbaseContainer.COUCH

checkSuccessfulResponse

Using AI Code Generation

1import org.testcontainers.containers.CouchbaseContainer2import com.couchbase.client.java.Cluster3import com.couchbase.client.java.Bucket4import com.couchbase.client.java.document.JsonDocument5import com.couchbase.client.java.document.json.JsonObject6CouchbaseContainer couchbase = new CouchbaseContainer()7couchbase.start()8assert couchbase.checkSuccessfulResponse()9Cluster cluster = couchbase.getCluster()10Bucket bucket = cluster.openBucket()11def doc = JsonObject.create()12doc.put("name", "test")13bucket.upsert(JsonDocument.create("test", doc))14assert bucket.get("test").content().get("name") == "test"15couchbase.stop()16import org.testcontainers.containers.CouchbaseContainer17import com.couchbase.client.java.Cluster18import com.couchbase.client.java.Bucket19import com.couchbase.client.java.document.JsonDocument20import com.couchbase.client.java.document.json.JsonObject21CouchbaseContainer couchbase = new CouchbaseContainer()22couchbase.start()23assert couchbase.checkSuccessfulResponse()24Cluster cluster = couchbase.getCluster()25Bucket bucket = cluster.openBucket()26def doc = JsonObject.create()27doc.put("name", "test")28bucket.upsert(JsonDocument.create("test", doc))29assert bucket.get("test").content().get("name") == "test"30couchbase.stop()31import org.testcontainers.containers.CouchbaseContainer32import com.couchbase.client.java.Cluster33import com.couchbase.client.java.Bucket34import com.couchbase.client.java.document.JsonDocument35import com.couchbase.client.java.document.json.JsonObject36CouchbaseContainer couchbase = new CouchbaseContainer()37couchbase.start()38assert couchbase.checkSuccessfulResponse()39Cluster cluster = couchbase.getCluster()40Bucket bucket = cluster.openBucket()41def doc = JsonObject.create()42doc.put("name", "test")43bucket.upsert(JsonDocument.create("test

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.