manager_factory.go

package vault

import (
	"fmt"

	"github.com/pf-qiu/concourse/v6/atc/creds"
	"github.com/jessevdk/go-flags"
)

type vaultManagerFactory struct{}

func init() {
	creds.Register("vault", NewVaultManagerFactory())
}

func NewVaultManagerFactory() creds.ManagerFactory {
	return &vaultManagerFactory{}
}

func (factory *vaultManagerFactory) AddConfig(group *flags.Group) creds.Manager {
	manager := &VaultManager{}

	subGroup, err := group.AddGroup("Vault Credential Management", "", manager)
	if err != nil {
		panic(err)
	}

	subGroup.Namespace = "vault"

	return manager
}

func (factory *vaultManagerFactory) NewInstance(config interface{}) (creds.Manager, error) {
	if c, ok := config.(map[string]interface{}); !ok {
		return nil, fmt.Errorf("invalid vault config format")
	} else {
		manager := &VaultManager{}

		err := manager.Config(c)
		if err != nil {
			return nil, err
		}

		return manager, nil
	}
}