-
Notifications
You must be signed in to change notification settings - Fork 120
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
4e2198a
commit 4aac24c
Showing
4 changed files
with
96 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,91 @@ | ||
| package modules | ||
|
|
||
| import ( | ||
| "encoding/json" | ||
| "fmt" | ||
| "io" | ||
| "net/http" | ||
|
|
||
| "github.com/kyma-project/cli.v3/internal/clierror" | ||
| "github.com/spf13/cobra" | ||
| ) | ||
|
|
||
| type modulesConfig struct { | ||
| catalog bool | ||
| managed bool | ||
| installed bool | ||
| } | ||
|
|
||
| func NewModulesCMD() *cobra.Command { | ||
|
|
||
| config := modulesConfig{} | ||
|
|
||
| cmd := &cobra.Command{ | ||
| Use: "modules", | ||
| Short: "List modules.", | ||
| Long: `List either installed, managed or available Kyma modules.`, | ||
| Run: func(_ *cobra.Command, _ []string) { | ||
| clierror.Check(runModules(&config)) | ||
| }, | ||
| } | ||
|
|
||
| cmd.Flags().BoolVar(&config.catalog, "catalog", false, "List of al available Kyma modules.") | ||
| cmd.Flags().BoolVar(&config.managed, "managed", false, "List of all Kyma modules managed by central control-plane.") | ||
| cmd.Flags().BoolVar(&config.installed, "installed", false, "List of all currently installed Kyma modules.") | ||
|
|
||
| cmd.MarkFlagsOneRequired("catalog", "managed", "installed") | ||
| cmd.MarkFlagsMutuallyExclusive("catalog", "managed") | ||
| cmd.MarkFlagsMutuallyExclusive("catalog", "installed") | ||
| cmd.MarkFlagsMutuallyExclusive("managed", "installed") | ||
|
|
||
| return cmd | ||
| } | ||
|
|
||
| func runModules(config *modulesConfig) clierror.Error { | ||
| var err error | ||
| if config.catalog { | ||
| modules, err := listAllModules() | ||
| if err != nil { | ||
| return clierror.WrapE(err, clierror.New("failed to list all Kyma modules")) | ||
| } | ||
| fmt.Println("Available modules:\n") | ||
| for _, rec := range modules { | ||
| fmt.Println(rec) | ||
| } | ||
| return nil | ||
| } | ||
|
|
||
| if config.managed || config.installed { | ||
| clierror.Wrap(err, clierror.New("not implemented yet, please use the catalog flag")) | ||
| } | ||
| //TODO: installed and managed to implement | ||
|
|
||
| return clierror.Wrap(err, clierror.New("failed to get modules", "please use one of: catalog, managed or installed flags")) | ||
| } | ||
|
|
||
| func listAllModules() ([]string, clierror.Error) { | ||
| resp, err := http.Get("https://raw.githubusercontent.com/kyma-project/community-modules/main/model.json") | ||
| if err != nil { | ||
| return nil, clierror.Wrap(err, clierror.New("while getting modules list")) | ||
| } | ||
| defer resp.Body.Close() | ||
|
|
||
| var template []struct { | ||
| Name string `json:"name"` | ||
| } | ||
|
|
||
| bodyText, err := io.ReadAll(resp.Body) | ||
| if err != nil { | ||
| return nil, clierror.Wrap(err, clierror.New("while reading http response")) | ||
| } | ||
| err = json.Unmarshal(bodyText, &template) | ||
| if err != nil { | ||
| return nil, clierror.Wrap(err, clierror.New("while unmarshalling")) | ||
| } | ||
|
|
||
| var out []string | ||
| for _, rec := range template { | ||
| out = append(out, rec.Name) | ||
| } | ||
| return out, nil | ||
| } |