diff --git a/CHANGELOG.md b/CHANGELOG.md index f0659bb0..86629650 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -14,6 +14,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 - Added a missing `.ww` extension to the `70-ww4-netname.rules` template in the wwinit overlay. - Restrict access to `/warewulf/config` to root only. (#728, #742) +- KERNEL VERSION column is too short. #690 - Add support for resolving absolute path automatically. #493 ### Changed diff --git a/CONTRIBUTORS.md b/CONTRIBUTORS.md index 51b37bcf..45ee2d7d 100644 --- a/CONTRIBUTORS.md +++ b/CONTRIBUTORS.md @@ -25,3 +25,4 @@ * Jonathon Anderson @anderbubble * Brian Phan * Jeffrey Frey @jtfrey +* Xu Yang(Jason Yang) @JasonYangShadow diff --git a/go.mod b/go.mod index 7c791191..029e946d 100644 --- a/go.mod +++ b/go.mod @@ -13,6 +13,7 @@ require ( github.com/google/uuid v1.1.2 github.com/grpc-ecosystem/grpc-gateway/v2 v2.10.0 github.com/manifoldco/promptui v0.8.0 + github.com/olekukonko/tablewriter v0.0.5 github.com/opencontainers/image-spec v1.0.2-0.20190823105129-775207bd45b6 github.com/opencontainers/umoci v0.4.6 github.com/pkg/errors v0.9.1 diff --git a/go.sum b/go.sum index 940c14de..92d971f1 100644 --- a/go.sum +++ b/go.sum @@ -515,6 +515,8 @@ github.com/ncw/swift v1.0.47/go.mod h1:23YIA4yWVnGwv2dQlN4bB7egfYX6YLn0Yo/S6zZO/ github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e h1:fD57ERR4JtEqsWbfPhv4DMiApHyliiK5xCTNVSPiaAs= github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e/go.mod h1:zD1mROLANZcx1PVRCS0qkT7pwLkGfwJo4zjcN/Tysno= github.com/olekukonko/tablewriter v0.0.0-20170122224234-a0225b3f23b5/go.mod h1:vsDQFd/mU46D+Z4whnwzcISnGGzXWMclvtLoiIKAKIo= +github.com/olekukonko/tablewriter v0.0.5 h1:P2Ga83D34wi1o9J6Wh1mRuqd4mF/x/lgBS7N7AbDhec= +github.com/olekukonko/tablewriter v0.0.5/go.mod h1:hPp6KlRPjbx+hW8ykQs1w3UBbZlj6HuIJcUGPhkA7kY= github.com/onsi/ginkgo v0.0.0-20151202141238-7f8ab55aaf3b/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE= github.com/onsi/ginkgo v0.0.0-20170829012221-11459a886d9c/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE= github.com/onsi/ginkgo v1.6.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE= diff --git a/internal/app/wwctl/container/list/main.go b/internal/app/wwctl/container/list/main.go index 56b468d7..080c3632 100644 --- a/internal/app/wwctl/container/list/main.go +++ b/internal/app/wwctl/container/list/main.go @@ -1,34 +1,40 @@ package list import ( - "fmt" + "strconv" "time" + "github.com/hpcng/warewulf/internal/app/wwctl/helper" "github.com/hpcng/warewulf/internal/pkg/api/container" "github.com/hpcng/warewulf/internal/pkg/util" "github.com/hpcng/warewulf/internal/pkg/wwlog" "github.com/spf13/cobra" ) -func CobraRunE(cmd *cobra.Command, args []string) (err error) { +var containerList = container.ContainerList - containerInfo, err := container.ContainerList() - if err != nil { - wwlog.Error("%s", err) +func CobraRunE(vars *variables) func(cmd *cobra.Command, args []string) (err error) { + return func(cmd *cobra.Command, args []string) (err error) { + containerInfo, err := containerList() + if err != nil { + wwlog.Error("%s", err) + return + } + + ph := helper.NewPrintHelper([]string{"CONTAINER NAME", "NODES", "KERNEL VERSION", "CREATION TIME", "MODIFICATION TIME", "SIZE"}) + for i := 0; i < len(containerInfo); i++ { + createTime := time.Unix(int64(containerInfo[i].CreateDate), 0) + modTime := time.Unix(int64(containerInfo[i].ModDate), 0) + ph.Append([]string{ + containerInfo[i].Name, + strconv.FormatUint(uint64(containerInfo[i].NodeCount), 10), + containerInfo[i].KernelVersion, + createTime.Format(time.RFC822), + modTime.Format(time.RFC822), + util.ByteToString(int64(containerInfo[i].Size)), + }) + } + ph.Render() return } - - fmt.Printf("%-16s %-6s %-16s %-20s %-20s %-8s\n", "CONTAINER NAME", "NODES", "KERNEL VERSION", "CREATION TIME", "MODIFICATION TIME", "SIZE") - for i := 0; i < len(containerInfo); i++ { - createTime := time.Unix(int64(containerInfo[i].CreateDate), 0) - modTime := time.Unix(int64(containerInfo[i].ModDate), 0) - fmt.Printf("%-16s %-6d %-16s %-20s %-20s %-8s\n", - containerInfo[i].Name, - containerInfo[i].NodeCount, - containerInfo[i].KernelVersion, - createTime.Format(time.RFC822), - modTime.Format(time.RFC822), - util.ByteToString(int64(containerInfo[i].Size))) - } - return } diff --git a/internal/app/wwctl/container/list/main_test.go b/internal/app/wwctl/container/list/main_test.go new file mode 100644 index 00000000..fadfab81 --- /dev/null +++ b/internal/app/wwctl/container/list/main_test.go @@ -0,0 +1,100 @@ +package list + +import ( + "bytes" + "io" + "os" + "strings" + "testing" + "time" + + "github.com/hpcng/warewulf/internal/pkg/api/routes/wwapiv1" + "github.com/hpcng/warewulf/internal/pkg/node" + "github.com/hpcng/warewulf/internal/pkg/warewulfconf" + "github.com/hpcng/warewulf/internal/pkg/warewulfd" + "github.com/stretchr/testify/assert" +) + +func Test_List(t *testing.T) { + tests := []struct { + name string + args []string + stdout string + inDb string + mockFunc func() + }{ + { + name: "profile list test", + args: []string{}, + stdout: `CONTAINERNAMENODESKERNELVERSIONCREATIONTIMEMODIFICATIONTIMESIZE +test1kernel01Jan7000:00UTC01Jan7000:00UTC1B + `, + inDb: `WW_INTERNAL: 43 +nodeprofiles: + default: {} +nodes: + n01: + profiles: + - default +`, + mockFunc: func() { + containerList = func() (containerInfo []*wwapiv1.ContainerInfo, err error) { + containerInfo = append(containerInfo, &wwapiv1.ContainerInfo{ + Name: "test", + NodeCount: 1, + KernelVersion: "kernel", + CreateDate: uint64(time.Unix(0, 0).Unix()), + ModDate: uint64(time.Unix(0, 0).Unix()), + Size: uint64(1), + }) + return + } + }, + }, + } + + conf_yml := ` +WW_INTERNAL: 0 + ` + + conf := warewulfconf.New() + err := conf.Read([]byte(conf_yml)) + assert.NoError(t, err) + warewulfd.SetNoDaemon() + for _, tt := range tests { + _, err = node.TestNew([]byte(tt.inDb)) + assert.NoError(t, err) + t.Logf("Running test: %s\n", tt.name) + t.Run(tt.name, func(t *testing.T) { + tt.mockFunc() + baseCmd := GetCommand() + baseCmd.SetArgs(tt.args) + baseCmd.SetOut(nil) + baseCmd.SetErr(nil) + stdoutR, stdoutW, _ := os.Pipe() + os.Stdout = stdoutW + err = baseCmd.Execute() + if err != nil { + t.Errorf("Received error when running command, err: %v", err) + t.FailNow() + } + stdoutC := make(chan string) + go func() { + var buf bytes.Buffer + _, _ = io.Copy(&buf, stdoutR) + stdoutC <- buf.String() + }() + stdoutW.Close() + + stdout := <-stdoutC + stdout = strings.TrimSpace(stdout) + stdout = strings.ReplaceAll(stdout, " ", "") + assert.NotEmpty(t, stdout, "os.stdout should not be empty") + tt.stdout = strings.ReplaceAll(strings.TrimSpace(tt.stdout), " ", "") + if stdout != strings.ReplaceAll(strings.TrimSpace(tt.stdout), " ", "") { + t.Errorf("Got wrong output, got:\n '%s'\n, but want:\n '%s'\n", stdout, tt.stdout) + t.FailNow() + } + }) + } +} diff --git a/internal/app/wwctl/container/list/root.go b/internal/app/wwctl/container/list/root.go index 908aae77..e389fa95 100644 --- a/internal/app/wwctl/container/list/root.go +++ b/internal/app/wwctl/container/list/root.go @@ -2,18 +2,18 @@ package list import "github.com/spf13/cobra" -var ( - baseCmd = &cobra.Command{ - DisableFlagsInUseLine: true, - Use: "list [OPTIONS]", - Short: "List imported Warewulf containers", - Long: "This command will show you the containers that are imported into Warewulf.", - RunE: CobraRunE, - Aliases: []string{"ls"}, - } -) +type variables struct{} // GetRootCommand returns the root cobra.Command for the application. func GetCommand() *cobra.Command { + vars := variables{} + baseCmd := &cobra.Command{ + DisableFlagsInUseLine: true, + Use: "list [OPTIONS]", + Short: "List imported Warewulf containers", + Long: "This command will show you the containers that are imported into Warewulf.", + RunE: CobraRunE(&vars), + Aliases: []string{"ls"}, + } return baseCmd } diff --git a/internal/app/wwctl/helper/printhelper.go b/internal/app/wwctl/helper/printhelper.go new file mode 100644 index 00000000..2361ebd8 --- /dev/null +++ b/internal/app/wwctl/helper/printhelper.go @@ -0,0 +1,27 @@ +package helper + +import ( + "os" + + "github.com/olekukonko/tablewriter" +) + +type PrintHelper struct { + *tablewriter.Table +} + +func NewPrintHelper(header []string) *PrintHelper { + tb := tablewriter.NewWriter(os.Stdout) + tb.SetHeader(header) + tb.SetAutoWrapText(false) + tb.SetHeaderAlignment(tablewriter.ALIGN_LEFT) + tb.SetAlignment(tablewriter.ALIGN_LEFT) + tb.SetCenterSeparator("") + tb.SetColumnSeparator("") + tb.SetRowSeparator("") + tb.SetHeaderLine(false) + tb.SetBorder(false) + return &PrintHelper{ + Table: tb, + } +} diff --git a/internal/app/wwctl/node/list/main.go b/internal/app/wwctl/node/list/main.go index 0bbad793..f4e027c0 100644 --- a/internal/app/wwctl/node/list/main.go +++ b/internal/app/wwctl/node/list/main.go @@ -1,30 +1,37 @@ package list import ( - "fmt" + "strings" + "github.com/hpcng/warewulf/internal/app/wwctl/helper" apinode "github.com/hpcng/warewulf/internal/pkg/api/node" "github.com/hpcng/warewulf/internal/pkg/api/routes/wwapiv1" "github.com/spf13/cobra" ) -func CobraRunE(cmd *cobra.Command, args []string) (err error) { - req := wwapiv1.GetNodeList{ - Nodes: args, - Type: wwapiv1.GetNodeList_Simple, +func CobraRunE(vars *variables) func(cmd *cobra.Command, args []string) (err error) { + return func(cmd *cobra.Command, args []string) (err error) { + req := wwapiv1.GetNodeList{ + Nodes: args, + Type: wwapiv1.GetNodeList_Simple, + } + if vars.showAll { + req.Type = wwapiv1.GetNodeList_All + } else if vars.showIpmi { + req.Type = wwapiv1.GetNodeList_Ipmi + } else if vars.showNet { + req.Type = wwapiv1.GetNodeList_Network + } else if vars.showLong { + req.Type = wwapiv1.GetNodeList_Long + } + nodeInfo, err := apinode.NodeList(&req) + if len(nodeInfo.Output) > 0 { + ph := helper.NewPrintHelper(strings.Split(nodeInfo.Output[0], "=")) + for _, val := range nodeInfo.Output[1:] { + ph.Append(strings.Split(val, "=")) + } + ph.Render() + } + return } - if ShowAll { - req.Type = wwapiv1.GetNodeList_All - } else if ShowIpmi { - req.Type = wwapiv1.GetNodeList_Ipmi - } else if ShowNet { - req.Type = wwapiv1.GetNodeList_Network - } else if ShowLong { - req.Type = wwapiv1.GetNodeList_Long - } - nodeInfo, err := apinode.NodeList(&req) - for _, str := range nodeInfo.Output { - fmt.Printf("%s\n", str) - } - return } diff --git a/internal/app/wwctl/node/list/main_test.go b/internal/app/wwctl/node/list/main_test.go new file mode 100644 index 00000000..52eadfb4 --- /dev/null +++ b/internal/app/wwctl/node/list/main_test.go @@ -0,0 +1,80 @@ +package list + +import ( + "bytes" + "io" + "os" + "testing" + + "github.com/hpcng/warewulf/internal/pkg/node" + "github.com/hpcng/warewulf/internal/pkg/warewulfconf" + "github.com/hpcng/warewulf/internal/pkg/warewulfd" + "github.com/stretchr/testify/assert" +) + +func Test_List(t *testing.T) { + tests := []struct { + name string + args []string + wantErr bool + stdout string + inDb string + }{ + {name: "single node list", + args: []string{}, + wantErr: false, + stdout: ` NODE NAME PROFILES NETWORK + n01 default +`, + inDb: `WW_INTERNAL: 43 +nodeprofiles: + default: {} +nodes: + n01: + profiles: + - default +`}, + } + conf_yml := ` +WW_INTERNAL: 0 + ` + conf := warewulfconf.New() + err := conf.Read([]byte(conf_yml)) + assert.NoError(t, err) + assert.NoError(t, err) + warewulfd.SetNoDaemon() + for _, tt := range tests { + _, err = node.TestNew([]byte(tt.inDb)) + assert.NoError(t, err) + t.Logf("Running test: %s\n", tt.name) + t.Run(tt.name, func(t *testing.T) { + baseCmd := GetCommand() + baseCmd.SetArgs(tt.args) + buf := new(bytes.Buffer) + baseCmd.SetOut(buf) + baseCmd.SetErr(buf) + old := os.Stdout // keep backup of the real stdout + r, w, _ := os.Pipe() + os.Stdout = w + err = baseCmd.Execute() + if (err != nil) != tt.wantErr { + t.Errorf("Got unwanted error: %s", err) + t.FailNow() + } + outC := make(chan string) + go func() { + var buf bytes.Buffer + _, _ = io.Copy(&buf, r) + outC <- buf.String() + }() + // back to normal state + w.Close() + os.Stdout = old // restoring the real stdout + out := <-outC + if out != tt.stdout { + t.Errorf("Got wrong output, got:'%s'\nwant:'%s'", out, tt.stdout) + t.FailNow() + } + }) + } +} diff --git a/internal/app/wwctl/node/list/root.go b/internal/app/wwctl/node/list/root.go index b354c881..c3208a7d 100644 --- a/internal/app/wwctl/node/list/root.go +++ b/internal/app/wwctl/node/list/root.go @@ -5,14 +5,22 @@ import ( "github.com/spf13/cobra" ) -var ( - baseCmd = &cobra.Command{ +type variables struct { + showNet bool + showIpmi bool + showAll bool + showLong bool +} + +func GetCommand() *cobra.Command { + vars := variables{} + baseCmd := &cobra.Command{ DisableFlagsInUseLine: true, Use: "list [OPTIONS] [PATTERN]", Short: "List nodes", Long: "This command lists all configured nodes. Optionally, it will list only\n" + "nodes matching a glob PATTERN.", - RunE: CobraRunE, + RunE: CobraRunE(&vars), Aliases: []string{"ls"}, ValidArgsFunction: func(cmd *cobra.Command, args []string, toComplete string) ([]string, cobra.ShellCompDirective) { if len(args) != 0 { @@ -28,20 +36,10 @@ var ( return node_names, cobra.ShellCompDirectiveNoFileComp }, } - ShowNet bool - ShowIpmi bool - ShowAll bool - ShowLong bool -) + baseCmd.PersistentFlags().BoolVarP(&vars.showNet, "net", "n", false, "Show node network configurations") + baseCmd.PersistentFlags().BoolVarP(&vars.showIpmi, "ipmi", "i", false, "Show node IPMI configurations") + baseCmd.PersistentFlags().BoolVarP(&vars.showAll, "all", "a", false, "Show all node configurations") + baseCmd.PersistentFlags().BoolVarP(&vars.showLong, "long", "l", false, "Show long or wide format") -func init() { - baseCmd.PersistentFlags().BoolVarP(&ShowNet, "net", "n", false, "Show node network configurations") - baseCmd.PersistentFlags().BoolVarP(&ShowIpmi, "ipmi", "i", false, "Show node IPMI configurations") - baseCmd.PersistentFlags().BoolVarP(&ShowAll, "all", "a", false, "Show all node configurations") - baseCmd.PersistentFlags().BoolVarP(&ShowLong, "long", "l", false, "Show long or wide format") -} - -// GetRootCommand returns the root cobra.Command for the application. -func GetCommand() *cobra.Command { return baseCmd } diff --git a/internal/app/wwctl/profile/list/main.go b/internal/app/wwctl/profile/list/main.go index 516da680..3a984baf 100644 --- a/internal/app/wwctl/profile/list/main.go +++ b/internal/app/wwctl/profile/list/main.go @@ -1,25 +1,33 @@ package list import ( - "fmt" + "strings" + "github.com/hpcng/warewulf/internal/app/wwctl/helper" apiprofile "github.com/hpcng/warewulf/internal/pkg/api/profile" "github.com/hpcng/warewulf/internal/pkg/api/routes/wwapiv1" "github.com/spf13/cobra" ) -func CobraRunE(cmd *cobra.Command, args []string) (err error) { - req := wwapiv1.GetProfileList{ - ShowAll: ShowAll, - Profiles: args, - } - profileInfo, err := apiprofile.ProfileList(&req) - if err != nil { +func CobraRunE(vars *variables) func(cmd *cobra.Command, args []string) (err error) { + return func(cmd *cobra.Command, args []string) (err error) { + req := wwapiv1.GetProfileList{ + ShowAll: vars.showAll, + Profiles: args, + } + profileInfo, err := apiprofile.ProfileList(&req) + if err != nil { + return + } + + if len(profileInfo.Output) > 0 { + ph := helper.NewPrintHelper(strings.Split(profileInfo.Output[0], "=")) + for _, val := range profileInfo.Output[1:] { + ph.Append(strings.Split(val, "=")) + } + ph.Render() + } return } - for _, str := range profileInfo.Output { - fmt.Printf("%s\n", str) - } - return } diff --git a/internal/app/wwctl/profile/list/main_test.go b/internal/app/wwctl/profile/list/main_test.go new file mode 100644 index 00000000..4e61ef18 --- /dev/null +++ b/internal/app/wwctl/profile/list/main_test.go @@ -0,0 +1,84 @@ +package list + +import ( + "bytes" + "io" + "os" + "strings" + "testing" + + "github.com/hpcng/warewulf/internal/pkg/node" + "github.com/hpcng/warewulf/internal/pkg/warewulfconf" + "github.com/hpcng/warewulf/internal/pkg/warewulfd" + "github.com/stretchr/testify/assert" +) + +func Test_List(t *testing.T) { + tests := []struct { + name string + args []string + stdout string + inDb string + }{ + { + name: "profile list test", + args: []string{}, + stdout: `PROFILE NAME COMMENT/DESCRIPTION + default --`, + inDb: `WW_INTERNAL: 43 +nodeprofiles: + default: {} +nodes: + n01: + profiles: + - default +`, + }, + } + + conf_yml := ` +WW_INTERNAL: 0 + ` + + conf := warewulfconf.New() + err := conf.Read([]byte(conf_yml)) + assert.NoError(t, err) + warewulfd.SetNoDaemon() + for _, tt := range tests { + _, err = node.TestNew([]byte(tt.inDb)) + assert.NoError(t, err) + t.Logf("Running test: %s\n", tt.name) + t.Run(tt.name, func(t *testing.T) { + baseCmd := GetCommand() + baseCmd.SetArgs(tt.args) + baseCmd.SetOut(nil) + baseCmd.SetErr(nil) + stdoutR, stdoutW, _ := os.Pipe() + oriout := os.Stdout + os.Stdout = stdoutW + err = baseCmd.Execute() + if err != nil { + t.Errorf("Received error when running command, err: %v", err) + t.FailNow() + } + stdoutC := make(chan string) + go func() { + var buf bytes.Buffer + _, _ = io.Copy(&buf, stdoutR) + stdoutC <- buf.String() + }() + stdoutW.Close() + os.Stdout = oriout + + stdout := <-stdoutC + stdout = strings.TrimSpace(stdout) + stdout = strings.ReplaceAll(stdout, " ", "") + assert.NotEmpty(t, stdout, "os.stdout should not be empty") + tt.stdout = strings.ReplaceAll(strings.TrimSpace(tt.stdout), " ", "") + if stdout != strings.ReplaceAll(strings.TrimSpace(tt.stdout), " ", "") { + t.Errorf("Got wrong output, got:\n '%s'\n, but want:\n '%s'\n", stdout, tt.stdout) + t.FailNow() + } + }) + } +} diff --git a/internal/app/wwctl/profile/list/root.go b/internal/app/wwctl/profile/list/root.go index 1144d5c2..14689314 100644 --- a/internal/app/wwctl/profile/list/root.go +++ b/internal/app/wwctl/profile/list/root.go @@ -2,23 +2,22 @@ package list import "github.com/spf13/cobra" -var ( - baseCmd = &cobra.Command{ - DisableFlagsInUseLine: true, - Use: "list [OPTIONS] [PROFILE ...]", - Short: "List profiles and configurations", - Long: "This command will display configurations for PROFILE.", - RunE: CobraRunE, - Aliases: []string{"ls"}, - } - ShowAll bool -) - -func init() { - baseCmd.PersistentFlags().BoolVarP(&ShowAll, "all", "a", false, "Show all node configurations") +type variables struct { + showAll bool } // GetRootCommand returns the root cobra.Command for the application. func GetCommand() *cobra.Command { + vars := variables{} + baseCmd := &cobra.Command{ + DisableFlagsInUseLine: true, + Use: "list [OPTIONS] [PROFILE ...]", + Short: "List profiles and configurations", + Long: "This command will display configurations for PROFILE.", + RunE: CobraRunE(&vars), + Aliases: []string{"ls"}, + } + baseCmd.PersistentFlags().BoolVarP(&vars.showAll, "all", "a", false, "Show all node configurations") + return baseCmd } diff --git a/internal/pkg/api/node/list.go b/internal/pkg/api/node/list.go index 330aa7b9..5001638e 100644 --- a/internal/pkg/api/node/list.go +++ b/internal/pkg/api/node/list.go @@ -29,8 +29,7 @@ func NodeList(nodeGet *wwapiv1.GetNodeList) (nodeList wwapiv1.NodeList, err erro sort.Strings(nodeGet.Nodes) if nodeGet.Type == wwapiv1.GetNodeList_Simple { nodeList.Output = append(nodeList.Output, - fmt.Sprintf("%-22s %-26s %s", "NODE NAME", "PROFILES", "NETWORK")) - nodeList.Output = append(nodeList.Output, (strings.Repeat("=", 80))) + fmt.Sprintf("%s=%s=%s", "NODE NAME", "PROFILES", "NETWORK")) for _, n := range node.FilterByName(nodes, nodeGet.Nodes) { var netNames []string for k := range n.NetDevs { @@ -38,33 +37,31 @@ func NodeList(nodeGet *wwapiv1.GetNodeList) (nodeList wwapiv1.NodeList, err erro } sort.Strings(netNames) nodeList.Output = append(nodeList.Output, - fmt.Sprintf("%-22s %-26s %s", n.Id.Print(), n.Profiles.Print(), strings.Join(netNames, ", "))) + fmt.Sprintf("%s=%s=%s", n.Id.Print(), n.Profiles.Print(), strings.Join(netNames, ", "))) } } else if nodeGet.Type == wwapiv1.GetNodeList_Network { nodeList.Output = append(nodeList.Output, - fmt.Sprintf("%-22s %-8s %-18s %-15s %-15s %-15s", "NODE NAME", "NAME", "HWADDR", "IPADDR", "GATEWAY", "DEVICE"), - strings.Repeat("=", 90)) + fmt.Sprintf("%s=%s=%s=%s=%s=%s", "NODE NAME", "NAME", "HWADDR", "IPADDR", "GATEWAY", "DEVICE")) for _, n := range node.FilterByName(nodes, nodeGet.Nodes) { if len(n.NetDevs) > 0 { for name := range n.NetDevs { nodeList.Output = append(nodeList.Output, - fmt.Sprintf("%-22s %-8s %-18s %-15s %-15s %-15s", n.Id.Print(), name, + fmt.Sprintf("%s=%s=%s=%s=%s=%s", n.Id.Print(), name, n.NetDevs[name].Hwaddr.Print(), n.NetDevs[name].Ipaddr.Print(), n.NetDevs[name].Gateway.Print(), n.NetDevs[name].Device.Print())) } } else { - fmt.Printf("%-22s %-6s %-18s %-15s %-15s", n.Id.Print(), "--", "--", "--", "--") + fmt.Printf("%s=%s=%s=%s=%s=%s", n.Id.Print(), "--", "--", "--", "--", "--") } } } else if nodeGet.Type == wwapiv1.GetNodeList_Ipmi { nodeList.Output = append(nodeList.Output, - fmt.Sprintf("%-22s %-16s %-10s %-20s %-14s", "NODE NAME", "IPMI IPADDR", "IPMI PORT", "IPMI USERNAME", "IPMI INTERFACE"), - strings.Repeat("=", 98)) + fmt.Sprintf("%s=%s=%s=%s=%s", "NODE NAME", "IPMI IPADDR", "IPMI PORT", "IPMI USERNAME", "IPMI INTERFACE")) for _, n := range node.FilterByName(nodes, nodeGet.Nodes) { nodeList.Output = append(nodeList.Output, - fmt.Sprintf("%-22s %-16s %-10s %-20s %-14s", n.Id.Print(), + fmt.Sprintf("%s=%s=%s=%s=%s", n.Id.Print(), n.Ipmi.Ipaddr.Print(), n.Ipmi.Port.Print(), n.Ipmi.UserName.Print(), @@ -72,19 +69,18 @@ func NodeList(nodeGet *wwapiv1.GetNodeList) (nodeList wwapiv1.NodeList, err erro } } else if nodeGet.Type == wwapiv1.GetNodeList_Long { nodeList.Output = append(nodeList.Output, - fmt.Sprintf("%-22s %-16s %-16s %s", "NODE NAME", "KERNEL OVERRIDE", "CONTAINER", "OVERLAYS (S/R)"), - strings.Repeat("=", 85)) + fmt.Sprintf("%s=%s=%s=%s", "NODE NAME", "KERNEL OVERRIDE", "CONTAINER", "OVERLAYS (S/R)")) for _, n := range node.FilterByName(nodes, nodeGet.Nodes) { nodeList.Output = append(nodeList.Output, - fmt.Sprintf("%-22s %-16s %-16s %s", n.Id.Print(), + fmt.Sprintf("%s=%s=%s=%s", n.Id.Print(), n.Kernel.Override.Print(), n.ContainerName.Print(), n.SystemOverlay.Print()+"/"+n.RuntimeOverlay.Print())) } } else if nodeGet.Type == wwapiv1.GetNodeList_All { + nodeList.Output = append(nodeList.Output, + fmt.Sprintf("%s=%s=%s=%s", "NODE", "FIELD", "PROFILE", "VALUE")) for _, n := range node.FilterByName(nodes, nodeGet.Nodes) { - nodeList.Output = append(nodeList.Output, - fmt.Sprintf("%-20s %-18s %-12s %s", "NODE", "FIELD", "PROFILE", "VALUE"), strings.Repeat("=", 85)) nType := reflect.TypeOf(n) nVal := reflect.ValueOf(n) nConfType := reflect.TypeOf(node.NodeConf{}) @@ -101,12 +97,12 @@ func NodeList(nodeGet *wwapiv1.GetNodeList) (nodeList wwapiv1.NodeList, err erro fieldSource = entr.Source() fieldVal = entr.Print() nodeList.Output = append(nodeList.Output, - fmt.Sprintf("%-20s %-18s %-12s %s", n.Id.Print(), fieldName, fieldSource, fieldVal)) + fmt.Sprintf("%s=%s=%s=%s", n.Id.Print(), fieldName, fieldSource, fieldVal)) } else if nType.Field(i).Type == reflect.TypeOf(map[string]*node.Entry{}) { entrMap := nVal.Field(i).Interface().(map[string]*node.Entry) for key, val := range entrMap { nodeList.Output = append(nodeList.Output, - fmt.Sprintf("%-20s %-18s %-12s %s", n.Id.Print(), key, val.Source(), val.Print())) + fmt.Sprintf("%s=%s=%s=%s", n.Id.Print(), key, val.Source(), val.Print())) } } else if nType.Field(i).Type == reflect.TypeOf(map[string]*node.NetDevEntry{}) { netDevs := nVal.Field(i).Interface().(map[string]*node.NetDevEntry) @@ -132,7 +128,7 @@ func NodeList(nodeGet *wwapiv1.GetNodeList) (nodeList wwapiv1.NodeList, err erro // only print fields with lopt if netConfField.Tag.Get("lopt") != "" { nodeList.Output = append(nodeList.Output, - fmt.Sprintf("%-20s %-18s %-12s %s", n.Id.Print(), fieldName, fieldSource, fieldVal)) + fmt.Sprintf("%s=%s=%s=%s", n.Id.Print(), fieldName, fieldSource, fieldVal)) } } else if netInfoType.Field(j).Type == reflect.TypeOf(map[string]*node.Entry{}) { for key, val := range netInfoVal.Field(j).Interface().(map[string]*node.Entry) { @@ -140,7 +136,7 @@ func NodeList(nodeGet *wwapiv1.GetNodeList) (nodeList wwapiv1.NodeList, err erro fieldSource = val.Source() fieldVal = val.Print() nodeList.Output = append(nodeList.Output, - fmt.Sprintf("%-20s %-18s %-12s %s", n.Id.Print(), keyfieldName, fieldSource, fieldVal)) + fmt.Sprintf("%s=%s=%s=%s", n.Id.Print(), keyfieldName, fieldSource, fieldVal)) } } @@ -162,14 +158,14 @@ func NodeList(nodeGet *wwapiv1.GetNodeList) (nodeList wwapiv1.NodeList, err erro fieldSource = entr.Source() fieldVal = entr.Print() nodeList.Output = append(nodeList.Output, - fmt.Sprintf("%-20s %-18s %-12s %s", n.Id.Print(), fieldName, fieldSource, fieldVal)) + fmt.Sprintf("%s=%s=%s=%s", n.Id.Print(), fieldName, fieldSource, fieldVal)) } else if nestInfoType.Elem().Field(j).Type == reflect.TypeOf(map[string]*node.Entry{}) { for key, val := range nestInfoVal.Elem().Field(j).Interface().(map[string]*node.Entry) { fieldName = fieldName + ":" + key fieldSource = val.Source() fieldVal = val.Print() nodeList.Output = append(nodeList.Output, - fmt.Sprintf("%-20s %-18s %-12s %s", n.Id.Print(), fieldName, fieldSource, fieldVal)) + fmt.Sprintf("%s=%s=%s=%s", n.Id.Print(), fieldName, fieldSource, fieldVal)) } } } @@ -177,7 +173,6 @@ func NodeList(nodeGet *wwapiv1.GetNodeList) (nodeList wwapiv1.NodeList, err erro } } - } return } diff --git a/internal/pkg/api/profile/list.go b/internal/pkg/api/profile/list.go index 3044b3b6..a06a4c42 100644 --- a/internal/pkg/api/profile/list.go +++ b/internal/pkg/api/profile/list.go @@ -4,7 +4,6 @@ import ( "fmt" "reflect" "sort" - "strings" "github.com/hpcng/warewulf/internal/pkg/api/routes/wwapiv1" "github.com/hpcng/warewulf/internal/pkg/node" @@ -34,7 +33,7 @@ func ProfileList(ShowOpt *wwapiv1.GetProfileList) (profileList wwapiv1.ProfileLi if ShowOpt.ShowAll { for _, p := range profiles { profileList.Output = append(profileList.Output, - fmt.Sprintf("%-20s %-18s %-12s %s", "PROFILE", "FIELD", "PROFILE", "VALUE"), strings.Repeat("=", 85)) + fmt.Sprintf("%s=%s=%s=%s", "PROFILE", "FIELD", "PROFILE", "VALUE")) nType := reflect.TypeOf(p) nVal := reflect.ValueOf(p) nConfType := reflect.TypeOf(node.NodeConf{}) @@ -51,12 +50,12 @@ func ProfileList(ShowOpt *wwapiv1.GetProfileList) (profileList wwapiv1.ProfileLi fieldSource = entr.Source() fieldVal = entr.Print() profileList.Output = append(profileList.Output, - fmt.Sprintf("%-20s %-18s %-12s %s", p.Id.Print(), fieldName, fieldSource, fieldVal)) + fmt.Sprintf("%s=%s=%s=%s", p.Id.Print(), fieldName, fieldSource, fieldVal)) } else if nType.Field(i).Type == reflect.TypeOf(map[string]*node.Entry{}) { entrMap := nVal.Field(i).Interface().(map[string]*node.Entry) for key, val := range entrMap { profileList.Output = append(profileList.Output, - fmt.Sprintf("%-20s %-18s %-12s %s", p.Id.Print(), key, val.Source(), val.Print())) + fmt.Sprintf("%s=%s=%s=%s", p.Id.Print(), key, val.Source(), val.Print())) } } else if nType.Field(i).Type == reflect.TypeOf(map[string]*node.NetDevEntry{}) { netDevs := nVal.Field(i).Interface().(map[string]*node.NetDevEntry) @@ -82,7 +81,7 @@ func ProfileList(ShowOpt *wwapiv1.GetProfileList) (profileList wwapiv1.ProfileLi // only print fields with lopt if netConfField.Tag.Get("lopt") != "" { profileList.Output = append(profileList.Output, - fmt.Sprintf("%-20s %-18s %-12s %s", p.Id.Print(), fieldName, fieldSource, fieldVal)) + fmt.Sprintf("%s=%s=%s=%s", p.Id.Print(), fieldName, fieldSource, fieldVal)) } } else if netInfoType.Field(j).Type == reflect.TypeOf(map[string]*node.Entry{}) { for key, val := range netInfoVal.Field(j).Interface().(map[string]*node.Entry) { @@ -90,7 +89,7 @@ func ProfileList(ShowOpt *wwapiv1.GetProfileList) (profileList wwapiv1.ProfileLi fieldSource = val.Source() fieldVal = val.Print() profileList.Output = append(profileList.Output, - fmt.Sprintf("%-20s %-18s %-12s %s", p.Id.Print(), keyfieldName, fieldSource, fieldVal)) + fmt.Sprintf("%s=%s=%s=%s", p.Id.Print(), keyfieldName, fieldSource, fieldVal)) } } @@ -112,14 +111,14 @@ func ProfileList(ShowOpt *wwapiv1.GetProfileList) (profileList wwapiv1.ProfileLi fieldSource = entr.Source() fieldVal = entr.Print() profileList.Output = append(profileList.Output, - fmt.Sprintf("%-20s %-18s %-12s %s", p.Id.Print(), fieldName, fieldSource, fieldVal)) + fmt.Sprintf("%s=%s=%s=%s", p.Id.Print(), fieldName, fieldSource, fieldVal)) } else if nestInfoType.Elem().Field(j).Type == reflect.TypeOf(map[string]*node.Entry{}) { for key, val := range nestInfoVal.Elem().Field(j).Interface().(map[string]*node.Entry) { fieldName = fieldName + ":" + key fieldSource = val.Source() fieldVal = val.Print() profileList.Output = append(profileList.Output, - fmt.Sprintf("%-20s %-18s %-12s %s", p.Id.Print(), fieldName, fieldSource, fieldVal)) + fmt.Sprintf("%s=%s=%s=%s", p.Id.Print(), fieldName, fieldSource, fieldVal)) } } } @@ -128,12 +127,11 @@ func ProfileList(ShowOpt *wwapiv1.GetProfileList) (profileList wwapiv1.ProfileLi } } else { profileList.Output = append(profileList.Output, - fmt.Sprintf("%-20s %s", "PROFILE NAME", "COMMENT/DESCRIPTION")) - profileList.Output = append(profileList.Output, strings.Repeat("=", 80)) + fmt.Sprintf("%s=%s", "PROFILE NAME", "COMMENT/DESCRIPTION")) for _, profile := range profiles { profileList.Output = append(profileList.Output, - fmt.Sprintf("%-20s %s", profile.Id.Print(), profile.Comment.Print())) + fmt.Sprintf("%s=%s", profile.Id.Print(), profile.Comment.Print())) } } return