feat: add couch-db adapter

Author: anbraten

README.md

@@ -26,7 +26,7 @@ spec:
 
 - mongo :white_check_mark:
 - mysql :hammer:
-- couchdb :hammer:
+- couchdb :white_check_mark:
 - postgres :clock1:
 
 ## Installation

adapters/couchdb_adapter.go

@@ -1,45 +1,98 @@
 package adapters
 
 import (
+	"fmt"
+
 	"github.com/leesper/couchdb-golang"
 )
 
+type securityConfig struct{
+	names []string
+	roles []string
+}
+
 type couchdbAdapter struct {
 	db *couchdb.Server
 }
 
 func (adapter couchdbAdapter) HasDatabase(database string) (bool, error) {
-	return false, nil
+	return adapter.db.Contains(database), nil
 }
 
 func (adapter couchdbAdapter) CreateDatabase(database string) error {
-	// TODO create if not exists
 	_, err := adapter.db.Create(database)
 	return err
 }
 
 func (adapter couchdbAdapter) DeleteDatabase(database string) error {
-	// TODO delete if exists
 	return adapter.db.Delete(database)
 }
 
+func (adapter couchdbAdapter) getDatabaseAdmins(database string) ([]string, error) {
+	db, err := adapter.db.Get(database)
+	if err != nil {
+		return nil, err
+	}
+
+	sc, err := db.GetSecurity()
+	if err != nil {
+		return nil, err
+	}
+
+	admins, ok := sc["admins"].(securityConfig)
+	if !ok {
+		return nil, fmt.Errorf("can't find admin users in security context")
+	}
+
+	return admins.names, nil
+}
+
 func (adapter couchdbAdapter) HasDatabaseUserWithAccess(username string, database string) (bool, error) {
-	// TODO implement
+	admins, err := adapter.getDatabaseAdmins(database)
+	if err != nil {
+		return false, err
+	}
+
+	for _, name := range admins {
+		if name == username {
+			return true, nil
+		}
+	}
+
 	return false, nil
 }
 
 func (adapter couchdbAdapter) CreateDatabaseUser(database string, username string, password string) error {
-	// TODO implement
-	return nil
+	adapter.db.AddUser(username, password, nil)
+	db, err := adapter.db.Get(database)
+	if err != nil {
+		return err
+	}
+
+	sc, err := db.GetSecurity()
+	if err != nil {
+		return err
+	}
+
+	admins, err := adapter.getDatabaseAdmins(database)
+	if err != nil {
+		return err
+	}
+
+	sc["admins"] = &securityConfig{
+		names: append(admins, username),
+		roles: nil,
+	}
+
+	return db.SetSecurity(sc)
 }
 
 func (adapter couchdbAdapter) DeleteDatabaseUser(database string, username string) error {
-	// TODO implement
-	return nil
+	return adapter.db.RemoveUser(username)
 }
 
 func (adapter couchdbAdapter) Close() error {
-	// TODO implement
+	// couchdb is using single http calls and has no active connection we could close
 	return nil
 }