mirror of https://github.com/hashicorp/boundary
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
309 lines
6.7 KiB
309 lines
6.7 KiB
// Code generated by "make cli"; DO NOT EDIT.
|
|
// Copyright (c) HashiCorp, Inc.
|
|
// SPDX-License-Identifier: BUSL-1.1
|
|
|
|
package authmethodscmd
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"sync"
|
|
|
|
"github.com/hashicorp/boundary/api"
|
|
"github.com/hashicorp/boundary/api/authmethods"
|
|
"github.com/hashicorp/boundary/internal/cmd/base"
|
|
"github.com/hashicorp/boundary/internal/cmd/common"
|
|
"github.com/hashicorp/go-secure-stdlib/strutil"
|
|
"github.com/mitchellh/cli"
|
|
"github.com/posener/complete"
|
|
)
|
|
|
|
func initFlags() {
|
|
flagsOnce.Do(func() {
|
|
extraFlags := extraActionsFlagsMapFunc()
|
|
for k, v := range extraFlags {
|
|
flagsMap[k] = append(flagsMap[k], v...)
|
|
}
|
|
})
|
|
}
|
|
|
|
var (
|
|
_ cli.Command = (*Command)(nil)
|
|
_ cli.CommandAutocomplete = (*Command)(nil)
|
|
)
|
|
|
|
type Command struct {
|
|
*base.Command
|
|
|
|
Func string
|
|
|
|
plural string
|
|
}
|
|
|
|
func (c *Command) AutocompleteArgs() complete.Predictor {
|
|
initFlags()
|
|
return complete.PredictAnything
|
|
}
|
|
|
|
func (c *Command) AutocompleteFlags() complete.Flags {
|
|
initFlags()
|
|
return c.Flags().Completions()
|
|
}
|
|
|
|
func (c *Command) Synopsis() string {
|
|
if extra := extraSynopsisFunc(c); extra != "" {
|
|
return extra
|
|
}
|
|
|
|
synopsisStr := "auth-method"
|
|
|
|
return common.SynopsisFunc(c.Func, synopsisStr)
|
|
}
|
|
|
|
func (c *Command) Help() string {
|
|
initFlags()
|
|
|
|
var helpStr string
|
|
helpMap := common.HelpMap("auth method")
|
|
|
|
switch c.Func {
|
|
|
|
case "read":
|
|
helpStr = helpMap[c.Func]() + c.Flags().Help()
|
|
|
|
case "delete":
|
|
helpStr = helpMap[c.Func]() + c.Flags().Help()
|
|
|
|
case "list":
|
|
helpStr = helpMap[c.Func]() + c.Flags().Help()
|
|
|
|
default:
|
|
|
|
helpStr = c.extraHelpFunc(helpMap)
|
|
|
|
}
|
|
|
|
// Keep linter from complaining if we don't actually generate code using it
|
|
_ = helpMap
|
|
return helpStr
|
|
}
|
|
|
|
var flagsMap = map[string][]string{
|
|
|
|
"read": {"id"},
|
|
|
|
"delete": {"id"},
|
|
|
|
"list": {"scope-id", "filter", "recursive"},
|
|
}
|
|
|
|
func (c *Command) Flags() *base.FlagSets {
|
|
if len(flagsMap[c.Func]) == 0 {
|
|
return c.FlagSet(base.FlagSetNone)
|
|
}
|
|
|
|
set := c.FlagSet(base.FlagSetHTTP | base.FlagSetClient | base.FlagSetOutputFormat)
|
|
f := set.NewFlagSet("Command Options")
|
|
common.PopulateCommonFlags(c.Command, f, "auth method", flagsMap, c.Func)
|
|
|
|
extraFlagsFunc(c, set, f)
|
|
|
|
return set
|
|
}
|
|
|
|
func (c *Command) Run(args []string) int {
|
|
initFlags()
|
|
|
|
switch c.Func {
|
|
case "":
|
|
return cli.RunResultHelp
|
|
|
|
case "create":
|
|
return cli.RunResultHelp
|
|
|
|
case "update":
|
|
return cli.RunResultHelp
|
|
|
|
}
|
|
|
|
c.plural = "auth method"
|
|
switch c.Func {
|
|
case "list":
|
|
c.plural = "auth methods"
|
|
}
|
|
|
|
f := c.Flags()
|
|
|
|
if err := f.Parse(args); err != nil {
|
|
c.PrintCliError(err)
|
|
return base.CommandUserError
|
|
}
|
|
|
|
if strutil.StrListContains(flagsMap[c.Func], "id") && c.FlagId == "" {
|
|
c.PrintCliError(errors.New("ID is required but not passed in via -id"))
|
|
return base.CommandUserError
|
|
}
|
|
|
|
var opts []authmethods.Option
|
|
|
|
if strutil.StrListContains(flagsMap[c.Func], "scope-id") {
|
|
switch c.Func {
|
|
|
|
case "list":
|
|
if c.FlagScopeId == "" {
|
|
c.PrintCliError(errors.New("Scope ID must be passed in via -scope-id or BOUNDARY_SCOPE_ID"))
|
|
return base.CommandUserError
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
client, err := c.Client()
|
|
if c.WrapperCleanupFunc != nil {
|
|
defer func() {
|
|
if err := c.WrapperCleanupFunc(); err != nil {
|
|
c.PrintCliError(fmt.Errorf("Error cleaning kms wrapper: %w", err))
|
|
}
|
|
}()
|
|
}
|
|
if err != nil {
|
|
c.PrintCliError(fmt.Errorf("Error creating API client: %w", err))
|
|
return base.CommandCliError
|
|
}
|
|
authmethodsClient := authmethods.NewClient(client)
|
|
|
|
switch c.FlagRecursive {
|
|
case true:
|
|
opts = append(opts, authmethods.WithRecursive(true))
|
|
}
|
|
|
|
if c.FlagFilter != "" {
|
|
opts = append(opts, authmethods.WithFilter(c.FlagFilter))
|
|
}
|
|
|
|
var version uint32
|
|
|
|
if ok := extraFlagsHandlingFunc(c, f, &opts); !ok {
|
|
return base.CommandUserError
|
|
}
|
|
|
|
var resp *api.Response
|
|
var item *authmethods.AuthMethod
|
|
|
|
var items []*authmethods.AuthMethod
|
|
|
|
var readResult *authmethods.AuthMethodReadResult
|
|
|
|
var deleteResult *authmethods.AuthMethodDeleteResult
|
|
|
|
var listResult *authmethods.AuthMethodListResult
|
|
|
|
switch c.Func {
|
|
|
|
case "read":
|
|
readResult, err = authmethodsClient.Read(c.Context, c.FlagId, opts...)
|
|
if exitCode := c.checkFuncError(err); exitCode > 0 {
|
|
return exitCode
|
|
}
|
|
resp = readResult.GetResponse()
|
|
item = readResult.GetItem()
|
|
|
|
case "delete":
|
|
deleteResult, err = authmethodsClient.Delete(c.Context, c.FlagId, opts...)
|
|
if exitCode := c.checkFuncError(err); exitCode > 0 {
|
|
return exitCode
|
|
}
|
|
resp = deleteResult.GetResponse()
|
|
|
|
case "list":
|
|
listResult, err = authmethodsClient.List(c.Context, c.FlagScopeId, opts...)
|
|
if exitCode := c.checkFuncError(err); exitCode > 0 {
|
|
return exitCode
|
|
}
|
|
resp = listResult.GetResponse()
|
|
items = listResult.GetItems()
|
|
|
|
}
|
|
|
|
resp, item, items, err = executeExtraActions(c, resp, item, items, err, authmethodsClient, version, opts)
|
|
if exitCode := c.checkFuncError(err); exitCode > 0 {
|
|
return exitCode
|
|
}
|
|
|
|
output, err := printCustomActionOutput(c)
|
|
if err != nil {
|
|
c.PrintCliError(err)
|
|
return base.CommandUserError
|
|
}
|
|
if output {
|
|
return base.CommandSuccess
|
|
}
|
|
|
|
switch c.Func {
|
|
|
|
case "delete":
|
|
switch base.Format(c.UI) {
|
|
case "json":
|
|
if ok := c.PrintJsonItem(resp); !ok {
|
|
return base.CommandCliError
|
|
}
|
|
|
|
case "table":
|
|
c.UI.Output("The delete operation completed successfully.")
|
|
}
|
|
|
|
return base.CommandSuccess
|
|
|
|
case "list":
|
|
switch base.Format(c.UI) {
|
|
case "json":
|
|
if ok := c.PrintJsonItems(resp); !ok {
|
|
return base.CommandCliError
|
|
}
|
|
|
|
case "table":
|
|
c.UI.Output(c.printListTable(items))
|
|
}
|
|
|
|
return base.CommandSuccess
|
|
|
|
}
|
|
|
|
switch base.Format(c.UI) {
|
|
case "table":
|
|
c.UI.Output(printItemTable(item, resp))
|
|
|
|
case "json":
|
|
if ok := c.PrintJsonItem(resp); !ok {
|
|
return base.CommandCliError
|
|
}
|
|
}
|
|
|
|
return base.CommandSuccess
|
|
}
|
|
|
|
func (c *Command) checkFuncError(err error) int {
|
|
if err == nil {
|
|
return 0
|
|
}
|
|
if apiErr := api.AsServerError(err); apiErr != nil {
|
|
c.PrintApiError(apiErr, fmt.Sprintf("Error from controller when performing %s on %s", c.Func, c.plural))
|
|
return base.CommandApiError
|
|
}
|
|
c.PrintCliError(fmt.Errorf("Error trying to %s %s: %s", c.Func, c.plural, err.Error()))
|
|
return base.CommandCliError
|
|
}
|
|
|
|
var (
|
|
flagsOnce = new(sync.Once)
|
|
|
|
extraActionsFlagsMapFunc = func() map[string][]string { return nil }
|
|
extraSynopsisFunc = func(*Command) string { return "" }
|
|
extraFlagsFunc = func(*Command, *base.FlagSets, *base.FlagSet) {}
|
|
extraFlagsHandlingFunc = func(*Command, *base.FlagSets, *[]authmethods.Option) bool { return true }
|
|
executeExtraActions = func(_ *Command, inResp *api.Response, inItem *authmethods.AuthMethod, inItems []*authmethods.AuthMethod, inErr error, _ *authmethods.Client, _ uint32, _ []authmethods.Option) (*api.Response, *authmethods.AuthMethod, []*authmethods.AuthMethod, error) {
|
|
return inResp, inItem, inItems, inErr
|
|
}
|
|
printCustomActionOutput = func(*Command) (bool, error) { return false, nil }
|
|
)
|