ls.go 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164
  1. /*
  2. Copyright 2020 Docker Compose CLI authors
  3. Licensed under the Apache License, Version 2.0 (the "License");
  4. you may not use this file except in compliance with the License.
  5. You may obtain a copy of the License at
  6. http://www.apache.org/licenses/LICENSE-2.0
  7. Unless required by applicable law or agreed to in writing, software
  8. distributed under the License is distributed on an "AS IS" BASIS,
  9. WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  10. See the License for the specific language governing permissions and
  11. limitations under the License.
  12. */
  13. package context
  14. import (
  15. "fmt"
  16. "io"
  17. "os"
  18. "sort"
  19. "strings"
  20. "github.com/pkg/errors"
  21. "github.com/spf13/cobra"
  22. apicontext "github.com/docker/compose-cli/api/context"
  23. "github.com/docker/compose-cli/api/context/store"
  24. "github.com/docker/compose-cli/cli/mobycli"
  25. "github.com/docker/compose-cli/formatter"
  26. )
  27. type lsOpts struct {
  28. quiet bool
  29. json bool
  30. format string
  31. }
  32. func (o lsOpts) validate() error {
  33. if o.quiet && o.json {
  34. return errors.New(`cannot combine "quiet" and "json" options`)
  35. }
  36. return nil
  37. }
  38. func listCommand() *cobra.Command {
  39. var opts lsOpts
  40. cmd := &cobra.Command{
  41. Use: "list",
  42. Short: "List available contexts",
  43. Aliases: []string{"ls"},
  44. Args: cobra.NoArgs,
  45. RunE: func(cmd *cobra.Command, args []string) error {
  46. return runList(cmd, opts)
  47. },
  48. }
  49. cmd.Flags().BoolVarP(&opts.quiet, "quiet", "q", false, "Only show context names")
  50. cmd.Flags().StringVar(&opts.format, "format", "", "Format the output. Values: [pretty | json]. (Default: pretty)")
  51. return cmd
  52. }
  53. func runList(cmd *cobra.Command, opts lsOpts) error {
  54. err := opts.validate()
  55. if err != nil {
  56. return err
  57. }
  58. format := strings.ToLower(strings.ReplaceAll(opts.format, " ", ""))
  59. if format != "" && format != formatter.JSON && format != formatter.PRETTY && format != formatter.TemplateLegacyJSON {
  60. mobycli.Exec(cmd.Root())
  61. return nil
  62. }
  63. ctx := cmd.Context()
  64. currentContext := apicontext.CurrentContext(ctx)
  65. s := store.ContextStore(ctx)
  66. contexts, err := s.List()
  67. if err != nil {
  68. return err
  69. }
  70. sort.Slice(contexts, func(i, j int) bool {
  71. return strings.Compare(contexts[i].Name, contexts[j].Name) == -1
  72. })
  73. if opts.quiet {
  74. for _, c := range contexts {
  75. fmt.Println(c.Name)
  76. }
  77. return nil
  78. }
  79. if opts.json || format == formatter.JSON {
  80. opts.format = formatter.JSON
  81. }
  82. if format == formatter.TemplateLegacyJSON {
  83. opts.format = formatter.TemplateLegacyJSON
  84. }
  85. view := viewFromContextList(contexts, currentContext)
  86. return formatter.Print(view, opts.format, os.Stdout,
  87. func(w io.Writer) {
  88. for _, c := range view {
  89. contextName := c.Name
  90. if c.Current {
  91. contextName += " *"
  92. }
  93. _, _ = fmt.Fprintf(w, "%s\t%s\t%s\t%s\t%s\t%s\n",
  94. contextName,
  95. c.ContextType,
  96. c.Description,
  97. c.DockerEndpoint,
  98. c.KubernetesEndpoint,
  99. c.StackOrchestrator)
  100. }
  101. },
  102. "NAME", "TYPE", "DESCRIPTION", "DOCKER ENDPOINT", "KUBERNETES ENDPOINT", "ORCHESTRATOR")
  103. }
  104. func getEndpoint(name string, meta map[string]interface{}) string {
  105. endpoints, ok := meta[name]
  106. if !ok {
  107. return ""
  108. }
  109. data, ok := endpoints.(*store.Endpoint)
  110. if !ok {
  111. return ""
  112. }
  113. result := data.Host
  114. if data.DefaultNamespace != "" {
  115. result += fmt.Sprintf(" (%s)", data.DefaultNamespace)
  116. }
  117. return result
  118. }
  119. type contextView struct {
  120. Current bool
  121. Description string
  122. DockerEndpoint string
  123. KubernetesEndpoint string
  124. ContextType string
  125. Name string
  126. StackOrchestrator string
  127. }
  128. func viewFromContextList(contextList []*store.DockerContext, currentContext string) []contextView {
  129. retList := make([]contextView, len(contextList))
  130. for i, c := range contextList {
  131. retList[i] = contextView{
  132. Current: c.Name == currentContext,
  133. Description: c.Metadata.Description,
  134. DockerEndpoint: getEndpoint("docker", c.Endpoints),
  135. KubernetesEndpoint: getEndpoint("kubernetes", c.Endpoints),
  136. Name: c.Name,
  137. ContextType: c.Type(),
  138. StackOrchestrator: c.Metadata.StackOrchestrator,
  139. }
  140. }
  141. return retList
  142. }