Merge pull request #22 from ggiamarchi/config-show

API & command for configuration show

api/api.go

@@ -55,6 +55,7 @@ func api(appConfig *model.AppConfig) *gin.Engine {
 	healthcheck(v1, appConfig)
 
 	readConfigurations(v1, appConfig)
+	showConfiguration(v1, appConfig)
 	deployConfiguration(v1, appConfig)
 
 	readHosts(v1, appConfig)

api/configurations.go

@@ -14,6 +14,25 @@ func readConfigurations(api *gin.RouterGroup, appConfig *model.AppConfig) {
 	})
 }
 
+func showConfiguration(api *gin.RouterGroup, appConfig *model.AppConfig) {
+	api.GET("/configurations/:name", func(c *gin.Context) {
+		name := c.Param("name")
+		config, err := service.ReadConfigurationContent(appConfig, name)
+
+		if err != nil {
+			switch v := err.(type) {
+			case *service.PXEError:
+				pxeErrorResponse(c, v)
+			default:
+				c.Writer.WriteHeader(500)
+			}
+			return
+		}
+
+		c.JSON(200, config)
+	})
+}
+
 func deployConfiguration(api *gin.RouterGroup, appConfig *model.AppConfig) {
 	api.PUT("/configurations/:name/deploy", func(c *gin.Context) {
 

cli.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"bytes"
+	"fmt"
 	"os"
 
 	"github.com/ggiamarchi/pxe-pilot/api"
@@ -31,6 +32,32 @@ func setupCLI() {
 	})
 
 	app.Command("config", "PXE configuration commands", func(cmd *cli.Cmd) {
+		cmd.Command("show", "Show PXE configurations", func(cmd *cli.Cmd) {
+
+			cmd.Spec = "NAME"
+
+			var (
+				name = cmd.StringArg("NAME", "", "Configuration to show")
+			)
+
+			cmd.Action = func() {
+				logger.Init(!*debug)
+
+				var configuration = &model.ConfigurationDetails{}
+				statusCode, err := http.Request("GET", *serverURL, fmt.Sprintf("/v1/configurations/%s", *name), nil, configuration)
+				if err != nil || statusCode != 200 {
+					panic(err)
+				}
+
+				fmt.Println(configuration.Content)
+				// Print data table
+				// table := tablewriter.NewWriter(os.Stdout)
+				// table.SetAutoWrapText(false)
+				// table.SetHeader([]string{"Name", "Content"})
+				// table.Append([]string{configuration.Name, configuration.Content})
+				// table.Render()
+			}
+		})
 		cmd.Command("list", "List available PXE configurations", func(cmd *cli.Cmd) {
 			cmd.Action = func() {
 				logger.Init(!*debug)

model/configuration.go

@@ -11,3 +11,12 @@ type Configuration struct {
 func (c *Configuration) String() string {
 	return fmt.Sprintf("%+v", *c)
 }
+
+type ConfigurationDetails struct {
+	Name    string `json:"name"`
+	Content string `json:"content"`
+}
+
+func (c *ConfigurationDetails) String() string {
+	return fmt.Sprintf("%+v", *c)
+}

service/service.go

@@ -154,6 +154,35 @@ func newPXEError(kind, msg string, a ...interface{}) *PXEError {
 	return &err
 }
 
+func ReadConfigurationContent(appConfig *model.AppConfig, name string) (*model.ConfigurationDetails, error) {
+	logger.Info("Show configuration :: %s", name)
+
+	configExists := false
+	for _, c := range ReadConfigurations(appConfig) {
+		if name == c.Name {
+			configExists = true
+			break
+		}
+	}
+	if !configExists {
+		return nil, newPXEError("NOT_FOUND", "Configuration '%s' does not exists", name)
+	}
+
+	file := fmt.Sprintf("%s/%s", appConfig.Configuration.Directory, name)
+
+	f, err := ioutil.ReadFile(file)
+	if err != nil {
+		return nil, err
+	}
+
+	c := &model.ConfigurationDetails{
+		Name:    name,
+		Content: string(f),
+	}
+
+	return c, nil
+}
+
 func DeployConfiguration(appConfig *model.AppConfig, name string, hosts []*model.HostQuery) error {
 	logger.Info("Deploy configuration :: %s :: %+v", name, hosts)
 

test/tftp_root/pxelinux.cfg/conf/local

@@ -0,0 +1,4 @@
+default local
+
+label local
+    localboot 0

test/tftp_root/pxelinux.cfg/conf/sheep

@@ -0,0 +1,5 @@
+DEFAULT sheeplive
+
+label sheeplive
+    kernel /sheep-live/vmlinuz
+    append boot=live fetch=http://1.2.3.4/sheep-live.squashfs initrd=/sheep-live/initrd.img ssh=sheep console=ttyS1,57600n8 sheep.script=http://1.2.3.4/sheep sheep.config=http://1.2.3.4/config.yml