dbclient

type Clienter interface {
	Creater
	Updater
	Remover
	Exister
	DBCloser

	GetDB() *sql.DB
	Ping() error
	SanitizeDSN() string

	ManageReplicationRole(username string, enableReplicationRole bool) error
	ManageSuperUserRole(username string, enableSuperUser bool) error
	ManageCreateRole(username string, enableCreateRole bool) error
	ManageSystemFunctions(dbName string, functions map[string]string) error

	GetUserRoles(username string) ([]string, error)
}

type Config struct {
	// Cloud is `aws` or `gcp`
	Cloud  string
	Log    logr.Logger
	DBType string // type of DB, only postgres
	// connection string to connect to DB ie. postgres://username:password@1.2.3.4:5432/mydb?sslmode=verify-full
	// FQDN to connect to database including username and password if not using an IAM enabled user
	DSN string
	// UseIAM bool
	UseIAM bool // attempt to connect with IAM user provided in DSN
}

type Creater interface {
	CreateDatabase(dbName string) (bool, error)
	//Creates a user in the the database
	CreateUser(username, role, userPassword string) (bool, error)
	//Creates a role in the specified DB and SCHEMA - with access to this specific SCHEMA only
	CreateRole(dbName, rolename, schema string) (bool, error)
	CreateAdminRole(dbName, rolename, schema string) (bool, error)
	CreateRegularRole(dbName, rolename, schema string) (bool, error)
	CreateReadOnlyRole(dbName, rolename, schema string) (bool, error)
	CreateDefaultExtensions(dbName string) error
	CreateSpecialExtensions(dbName string, role string) error
	CreateSchema(schemaName string) (bool, error)
}

type CredentialsProviderFunc aws.CredentialsProviderFunc

type DBClient interface {
	Clienter
	CreateDataBase(name string) (bool, error)
}

type DBCloser interface {
	Close() error
}

type Exister interface {
	// Checks if a schema exists in the database
	SchemaExists(schemaName string) (bool, error)
	// Checks if a usedr exists in the database
	UserExists(userName string) (bool, error)
	// Checks if a role exists in the database
	RoleExists(roleName string) (bool, error)
}

type Remover interface {
	DeleteUser(dbName, username, reassignToUser string) error
	RevokeAccessToRole(username, rolename string) error
}

type Updater interface {
	RenameUser(oldUsername string, newUsername string) error
	UpdateUser(oldUsername, newUsername, rolename, password string) error
	UpdatePassword(username string, userPassword string) error
	AssignRoleToUser(username, rolename string) error
}