Fix backward compatibility with older version

Author: tchlyah

src/main/java/org/testcontainers/couchbase/AbstractCouchbaseTest.java

@@ -15,15 +15,15 @@
  */
 public abstract class AbstractCouchbaseTest {
 
-    public static final String DEFAULT_BUCKET = "default";
+    public static final String TEST_BUCKET = "test";
 
     public static final String DEFAULT_PASSWORD = "password";
 
     @Getter(lazy = true)
     private final static CouchbaseContainer couchbaseContainer = initCouchbaseContainer();
 
     @Getter(lazy = true)
-    private final static Bucket bucket = openBucket(DEFAULT_BUCKET, DEFAULT_PASSWORD);
+    private final static Bucket bucket = openBucket(TEST_BUCKET, DEFAULT_PASSWORD);
 
     @After
     public void clear() {
@@ -40,7 +40,7 @@ private static CouchbaseContainer initCouchbaseContainer() {
         CouchbaseContainer couchbaseContainer = new CouchbaseContainer()
                 .withNewBucket(DefaultBucketSettings.builder()
                         .enableFlush(true)
-                        .name(DEFAULT_BUCKET)
+                        .name(TEST_BUCKET)
                         .password(DEFAULT_PASSWORD)
                         .quota(100)
                         .replicas(0)

src/main/java/org/testcontainers/couchbase/CouchbaseContainer.java

@@ -37,7 +37,7 @@
 
 /**
  * Based on Laurent Doguin version
- *
+ * <p>
  * Optimized by ctayeb
  */
 public class CouchbaseContainer<SELF extends CouchbaseContainer<SELF>> extends GenericContainer<SELF> {
@@ -254,7 +254,11 @@ public void createBucket(BucketSettings bucketSetting, boolean primaryIndex) {
         UserSettings userSettings = UserSettings.build()
                 .password(bucketSetting.password())
                 .roles(Collections.singletonList(new UserRole("bucket_admin", bucketSetting.name())));
-        clusterManager.upsertUser(AuthDomain.LOCAL, bucketSetting.name(), userSettings);
+        try {
+            clusterManager.upsertUser(AuthDomain.LOCAL, bucketSetting.name(), userSettings);
+        } catch (Exception e) {
+            logger().warn("Unable to insert user '" + bucketSetting.name() + "', maybe you are using older version");
+        }
         if (index) {
             Bucket bucket = getCouchbaseCluster().openBucket(bucketSettings.name(), bucketSettings.password());
             new CouchbaseQueryServiceWaitStrategy(bucket).waitUntilReady(this);

src/test/java/org/testcontainers/couchbase/CouchbaseContainerTest.java

@@ -29,13 +29,13 @@ public void should_insert_document() {
 
     @Test
     public void should_execute_n1ql() {
-        getBucket().query(N1qlQuery.simple("INSERT INTO " + DEFAULT_BUCKET + " (KEY, VALUE) VALUES ('" + ID + "', " + DOCUMENT + ")"));
+        getBucket().query(N1qlQuery.simple("INSERT INTO " + TEST_BUCKET + " (KEY, VALUE) VALUES ('" + ID + "', " + DOCUMENT + ")"));
 
-        N1qlQueryResult query = getBucket().query(N1qlQuery.simple("SELECT * FROM " + DEFAULT_BUCKET + " USE KEYS '" + ID + "'"));
+        N1qlQueryResult query = getBucket().query(N1qlQuery.simple("SELECT * FROM " + TEST_BUCKET + " USE KEYS '" + ID + "'"));
         Assert.assertTrue(query.parseSuccess());
         Assert.assertTrue(query.finalSuccess());
         List<N1qlQueryRow> n1qlQueryRows = query.allRows();
         Assert.assertEquals(1, n1qlQueryRows.size());
-        Assert.assertEquals(DOCUMENT, n1qlQueryRows.get(0).value().get(DEFAULT_BUCKET).toString());
+        Assert.assertEquals(DOCUMENT, n1qlQueryRows.get(0).value().get(TEST_BUCKET).toString());
     }
 }