package main

import (
	"fmt"
	"github.com/couchbase/gocb"
)

var (
	cbConnStr = "couchbase://10.143.170.101"
	cbBucket = "test-bucket"
	cbUsername = "darren"
	cbPassword = "asdasd"
)

type testDoc struct {
	Name string `json:"name"`
	Count int `json:"count"`
}

var globalCluster *gocb.Cluster = nil
var globalBucket *gocb.Bucket = nil

var key = "TestDoc"

func main() {
	var err error
	fmt.Print("Starting tests...\n")
	globalCluster, err = gocb.Connect(cbConnStr)
	if err != nil {
		panic(err)
	}

	auth := gocb.RbacAuthenticator{cbUsername, cbPassword}

	err = globalCluster.Authenticate(auth)

	if err != nil {
		panic(err)
	}

	globalBucket, err = globalCluster.OpenBucket(cbBucket, "")

	_, err = globalBucket.Upsert(key, testDoc{Name:"Test", Count:45}, 0)

	if err != nil {
		panic(err)
	}

	_, err = globalBucket.MutateIn(key, 0, 0).UpsertEx("sync", testDoc{Name:"Derrick", Count:67}, gocb.SubdocFlagXattr).Execute()


	if err != nil {
		panic(err)
	}

	var doc *gocb.DocumentFragment
	doc, err = globalBucket.LookupInEx(key, gocb.SubdocDocFlagAccessDeleted).GetEx("sync", gocb.SubdocFlagXattr).Execute()

	var value interface{}
	err = doc.ContentByIndex(0, &value)
	fmt.Print(value)

	if err != nil {
		panic(err)
	}
  }