package test;

import com.couchbase.client.java.Bucket;
import com.couchbase.client.java.Cluster;
import com.couchbase.client.java.CouchbaseCluster;
import com.couchbase.client.java.document.StringDocument;
import com.couchbase.client.java.env.CouchbaseEnvironment;
import com.couchbase.client.java.env.DefaultCouchbaseEnvironment;
import java.util.UUID;

// 4 node cluster
public class MainTest {

    public static void main(String... args) throws Exception {
        CouchbaseEnvironment env = DefaultCouchbaseEnvironment.builder().build();
        Cluster cluster = CouchbaseCluster.create(env, "127.0.0.1");
        final Bucket bucket = cluster.openBucket("default", "");


        String id = UUID.randomUUID().toString();

        System.err.println(id);

        bucket.upsert(StringDocument.create(id, "Hello "));

        // lock the document
        StringDocument oldDoc = bucket.getAndLock(id, 10, StringDocument.class);

        // create the one to append with the
        StringDocument newDoc = StringDocument.create(oldDoc.id(), "World!", oldDoc.cas());

        // blows up with tmpfail
        bucket.append(newDoc);

        bucket.unlock(oldDoc);

    }

}