package main

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

func lookupDoc(clusterAddress, bucketName, docId string) (exists bool, err error) {
	exists = false
	cluster, err := gocb.Connect(clusterAddress)
	if err != nil {
		fmt.Printf("Unable to connect to cluster, err : %v\n", err)
		return
	}

	err = cluster.Authenticate(gocb.PasswordAuthenticator{
		Username:"cbadminbucket",
		Password:"password",
	})

	if err != nil {
		fmt.Printf("Unable to authenticate , err : %v\n", err)
		return
	}

	bucket, err := cluster.OpenBucket(bucketName, "")
	defer bucket.Close()
	if err != nil {
		fmt.Printf("Error connecting to bucket %s, err : %v\n", bucketName, err)
		return
	}

	var value interface{}
	_, err = bucket.Get(docId, &value)
	if err != nil {
		return
	}

	exists = true
	return
}

func main() {
	fmt.Println(lookupDoc("couchbase://172.23.107.182", "src_bucket", "query-testemployee10153.1877827-0"))
}