couchdb_test.go

Documentation: edge-infra.dev/pkg/edge/datasync/couchdb

     1  package couchdb
     2  
     3  import (
     4  	"fmt"
     5  	"testing"
     6  
     7  	"github.com/stretchr/testify/assert"
     8  )
     9  
    10  func TestURIFormatting(t *testing.T) {
    11  	uri := FormatURI("foo", "bar", "localhost", "5984")
    12  	assert.Equal(t, "http://localhost:5984", uri, fmt.Sprintf("test case value: %s", uri))
    13  
    14  	uri = FormatURI("foo", "bar", "data-sync-couchdb-master.data-sync-couchdb-master.svc.cluster.local", "5984")
    15  	assert.Equal(t, "http://data-sync-couchdb-master.data-sync-couchdb-master.svc.cluster.local:5984", uri, fmt.Sprintf("test case value: %s", uri))
    16  
    17  	uri = FormatFinishClusterURI("foo", "bar", "localhost", "5984")
    18  	assert.Equal(t, "http://foo:bar@localhost:5984/_cluster_setup", uri, fmt.Sprintf("test case value: %s", uri))
    19  
    20  	uri = FormatURI("foo", "bar", "data-sync-couchdb-master.data-sync-couchdb-master.svc.cluster.local", "5984")
    21  	assert.Equal(t, "http://data-sync-couchdb-master.data-sync-couchdb-master.svc.cluster.local:5984", uri, fmt.Sprintf("test case value: %s", uri))
    22  }
    23  
    24  func SpinUpTestServer() (u, p, uri, port string, err error) {
    25  	return "testuser", "testpass", "localhost", "43234", nil
    26  }
    27  
    28  // func TestReadOnlyDB(t *testing.T) {
    29  // 	cdb := CouchDB{}
    30  // 	u, p, uri, port, err := SpinUpTestServer()
    31  // 	assert.NoError(t, err)
    32  // 	err = cdb.New("couch", u, p, uri, port)
    33  // 	assert.NoError(t, err)
    34  // 	err = cdb.CreateDB(context.Background(), "rodb")
    35  // 	assert.NoError(t, err)
    36  // }
    37
View as plain text