Merge pull request #109 from erdun/show

Show command
This commit is contained in:
Sun Jianbo
2020-08-08 15:05:30 +08:00
committed by GitHub
3 changed files with 131 additions and 0 deletions

View File

@@ -107,6 +107,7 @@ func newCommand() *cobra.Command {
cmd.NewAppsCommand(commandArgs, ioStream),
cmd.NewDeleteCommand(commandArgs, ioStream, os.Args[1:]),
cmd.NewAppStatusCommand(commandArgs, ioStream),
cmd.NewAppShowCommand(commandArgs, ioStream),
// Others
cmd.NewAddonConfigCommand(ioStream),

101
pkg/cmd/app_show.go Normal file
View File

@@ -0,0 +1,101 @@
package cmd
import (
"context"
"fmt"
"os"
"github.com/cloud-native-application/rudrx/api/types"
cmdutil "github.com/cloud-native-application/rudrx/pkg/cmd/util"
corev1alpha2 "github.com/crossplane/oam-kubernetes-runtime/apis/core/v1alpha2"
"github.com/ghodss/yaml"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"github.com/spf13/cobra"
"sigs.k8s.io/controller-runtime/pkg/client"
)
func NewAppShowCommand(c types.Args, ioStreams cmdutil.IOStreams) *cobra.Command {
ctx := context.Background()
cmd := &cobra.Command{
Use: "app:show",
Short: "get detail spec of your app",
Long: "get detail spec of your app, including its workload and trait",
Example: `vela app:show <APPLICATION-NAME>`,
RunE: func(cmd *cobra.Command, args []string) error {
argsLength := len(args)
if argsLength == 0 {
ioStreams.Errorf("Hint: please specify an application")
os.Exit(1)
}
appName := args[0]
env, err := GetEnv()
if err != nil {
ioStreams.Errorf("Error: failed to get Env: %s", err)
return err
}
newClient, err := client.New(c.Config, client.Options{Scheme: c.Schema})
if err != nil {
return err
}
return showApplication(ctx, newClient, cmd, env, appName)
},
}
cmd.SetOut(ioStreams.Out)
return cmd
}
type Unkown struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
Spec interface{} `json:"spec"`
Status interface{} `json:"status"`
}
func showApplication(ctx context.Context, c client.Client, cmd *cobra.Command, env *types.EnvMeta, appName string) error {
var (
application corev1alpha2.ApplicationConfiguration
)
namespace := env.Namespace
if err := c.Get(ctx, client.ObjectKey{Name: appName, Namespace: namespace}, &application); err != nil {
return fmt.Errorf("Fetch application with Err: %s", err)
}
if len(application.Spec.Components) == 0 {
cmd.Println("About:")
cmd.Printf(" Appset: %s", appName)
cmd.Printf(" ENV: %s", namespace)
return nil
}
// current only support one component
componentName := application.Spec.Components[0].ComponentName
component, err := cmdutil.GetComponent(ctx, c, componentName, namespace)
if err != nil {
return fmt.Errorf("Fetch component %s with Err: %s", componentName, err)
}
if component.Labels == nil {
return fmt.Errorf("Can't get workloadDef, please check component %s label \"%s\" is correct.",
componentName, ComponentWorkloadDefLabel)
}
traitDefinitions := cmdutil.ListTraitDefinitionsByApplicationConfiguration(application)
componentOut, _ := yaml.JSONToYAML(component.Spec.Workload.Raw)
cmd.Println("About:")
cmd.Printf(" Appset: %s\n", appName)
cmd.Printf(" ENV: %s\n", namespace)
cmd.Printf("%s", string(componentOut))
if len(traitDefinitions) != 0 {
cmd.Println("Traits:")
traitOut, _ := yaml.Marshal(application.Spec.Components[0].Traits)
cmd.Println(string(traitOut))
}
return nil
}

View File

@@ -41,6 +41,35 @@ func Eval(templatePath, workloadType string, value map[string]interface{}) (stri
return data, nil
}
func Parse(templatePath, workloadType string, value map[string]interface{}) error {
r := cue.Runtime{}
template, err := r.Compile(templatePath, nil)
if err != nil {
return err
}
tempValue := template.Value()
appValue, err := tempValue.Fill(value, workloadType).Eval().Struct()
if err != nil {
return err
}
final, err := appValue.FieldByName(Template, true)
if err != nil {
return err
}
if err := final.Value.Validate(cue.Concrete(true), cue.Final()); err != nil {
return err
}
data, err := json.Marshal(final.Value)
if err != nil {
return err
}
println(string(data))
return nil
}
func GetParameters(templatePath string) ([]types.Parameter, string, error) {
r := cue.Runtime{}
template, err := r.Compile(templatePath, nil)