mirror of
				https://github.com/optim-enterprises-bv/vault.git
				synced 2025-11-02 19:47:54 +00:00 
			
		
		
		
	
		
			
				
	
	
		
			102 lines
		
	
	
		
			2.4 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			102 lines
		
	
	
		
			2.4 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
// Copyright (c) HashiCorp, Inc.
 | 
						|
// SPDX-License-Identifier: MPL-2.0
 | 
						|
 | 
						|
package api
 | 
						|
 | 
						|
import (
 | 
						|
	"context"
 | 
						|
	"errors"
 | 
						|
	"fmt"
 | 
						|
	"net/http"
 | 
						|
 | 
						|
	"github.com/mitchellh/mapstructure"
 | 
						|
)
 | 
						|
 | 
						|
func (c *Sys) ListAuth() (map[string]*AuthMount, error) {
 | 
						|
	return c.ListAuthWithContext(context.Background())
 | 
						|
}
 | 
						|
 | 
						|
func (c *Sys) ListAuthWithContext(ctx context.Context) (map[string]*AuthMount, error) {
 | 
						|
	ctx, cancelFunc := c.c.withConfiguredTimeout(ctx)
 | 
						|
	defer cancelFunc()
 | 
						|
 | 
						|
	r := c.c.NewRequest(http.MethodGet, "/v1/sys/auth")
 | 
						|
 | 
						|
	resp, err := c.c.rawRequestWithContext(ctx, r)
 | 
						|
	if err != nil {
 | 
						|
		return nil, err
 | 
						|
	}
 | 
						|
	defer resp.Body.Close()
 | 
						|
 | 
						|
	secret, err := ParseSecret(resp.Body)
 | 
						|
	if err != nil {
 | 
						|
		return nil, err
 | 
						|
	}
 | 
						|
	if secret == nil || secret.Data == nil {
 | 
						|
		return nil, errors.New("data from server response is empty")
 | 
						|
	}
 | 
						|
 | 
						|
	mounts := map[string]*AuthMount{}
 | 
						|
	err = mapstructure.Decode(secret.Data, &mounts)
 | 
						|
	if err != nil {
 | 
						|
		return nil, err
 | 
						|
	}
 | 
						|
 | 
						|
	return mounts, nil
 | 
						|
}
 | 
						|
 | 
						|
// DEPRECATED: Use EnableAuthWithOptions instead
 | 
						|
func (c *Sys) EnableAuth(path, authType, desc string) error {
 | 
						|
	return c.EnableAuthWithOptions(path, &EnableAuthOptions{
 | 
						|
		Type:        authType,
 | 
						|
		Description: desc,
 | 
						|
	})
 | 
						|
}
 | 
						|
 | 
						|
func (c *Sys) EnableAuthWithOptions(path string, options *EnableAuthOptions) error {
 | 
						|
	return c.EnableAuthWithOptionsWithContext(context.Background(), path, options)
 | 
						|
}
 | 
						|
 | 
						|
func (c *Sys) EnableAuthWithOptionsWithContext(ctx context.Context, path string, options *EnableAuthOptions) error {
 | 
						|
	ctx, cancelFunc := c.c.withConfiguredTimeout(ctx)
 | 
						|
	defer cancelFunc()
 | 
						|
 | 
						|
	r := c.c.NewRequest(http.MethodPost, fmt.Sprintf("/v1/sys/auth/%s", path))
 | 
						|
	if err := r.SetJSONBody(options); err != nil {
 | 
						|
		return err
 | 
						|
	}
 | 
						|
 | 
						|
	resp, err := c.c.rawRequestWithContext(ctx, r)
 | 
						|
	if err != nil {
 | 
						|
		return err
 | 
						|
	}
 | 
						|
	defer resp.Body.Close()
 | 
						|
 | 
						|
	return nil
 | 
						|
}
 | 
						|
 | 
						|
func (c *Sys) DisableAuth(path string) error {
 | 
						|
	return c.DisableAuthWithContext(context.Background(), path)
 | 
						|
}
 | 
						|
 | 
						|
func (c *Sys) DisableAuthWithContext(ctx context.Context, path string) error {
 | 
						|
	ctx, cancelFunc := c.c.withConfiguredTimeout(ctx)
 | 
						|
	defer cancelFunc()
 | 
						|
 | 
						|
	r := c.c.NewRequest(http.MethodDelete, fmt.Sprintf("/v1/sys/auth/%s", path))
 | 
						|
 | 
						|
	resp, err := c.c.rawRequestWithContext(ctx, r)
 | 
						|
	if err == nil {
 | 
						|
		defer resp.Body.Close()
 | 
						|
	}
 | 
						|
	return err
 | 
						|
}
 | 
						|
 | 
						|
// Rather than duplicate, we can use modern Go's type aliasing
 | 
						|
type (
 | 
						|
	EnableAuthOptions = MountInput
 | 
						|
	AuthConfigInput   = MountConfigInput
 | 
						|
	AuthMount         = MountOutput
 | 
						|
	AuthConfigOutput  = MountConfigOutput
 | 
						|
)
 |