create_config.go

/*
	Copyright NetFoundry Inc.

	Licensed under the Apache License, Version 2.0 (the "License");
	you may not use this file except in compliance with the License.
	You may obtain a copy of the License at

	https://www.apache.org/licenses/LICENSE-2.0

	Unless required by applicable law or agreed to in writing, software
	distributed under the License is distributed on an "AS IS" BASIS,
	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	See the License for the specific language governing permissions and
	limitations under the License.
*/

package edge

import (
	"encoding/json"
	"fmt"
	"github.com/openziti/ziti/ziti/cmd/api"
	cmdhelper "github.com/openziti/ziti/ziti/cmd/helpers"
	"github.com/pkg/errors"
	"io"
	"os"

	"github.com/Jeffail/gabs"
	"github.com/spf13/cobra"
)

type createConfigOptions struct {
	api.EntityOptions
	jsonFile string
}

// newCreateConfigCmd creates the 'edge controller create service-policy' command
func newCreateConfigCmd(out io.Writer, errOut io.Writer) *cobra.Command {
	options := &createConfigOptions{
		EntityOptions: api.NewEntityOptions(out, errOut),
	}

	cmd := &cobra.Command{
		Use:   "config <name> <type> [JSON configuration data]",
		Short: "creates a config managed by the Ziti Edge Controller",
		Long:  "creates a config managed by the Ziti Edge Controller",
		Args:  cobra.RangeArgs(2, 3),
		Run: func(cmd *cobra.Command, args []string) {
			options.Cmd = cmd
			options.Args = args
			err := runCreateConfig(options)
			cmdhelper.CheckErr(err)
		},
		SuggestFor: []string{},
	}

	// allow interspersing positional args and flags
	cmd.Flags().SetInterspersed(true)
	cmd.Flags().StringVarP(&options.jsonFile, "json-file", "f", "", "Read config JSON from a file instead of the command line")
	options.AddCommonFlags(cmd)

	return cmd
}

// runCreateConfig create a new config on the Ziti Edge Controller
func runCreateConfig(o *createConfigOptions) error {
	var jsonBytes []byte

	if len(o.Args) == 3 {
		jsonBytes = []byte(o.Args[2])
	}

	if o.Cmd.Flags().Changed("json-file") {
		if len(o.Args) == 3 {
			return errors.New("config json specified both in file and on command line. please pick one")
		}
		var err error
		if jsonBytes, err = os.ReadFile(o.jsonFile); err != nil {
			return fmt.Errorf("failed to read config json file %v: %w", o.jsonFile, err)
		}
	}

	if len(jsonBytes) == 0 {
		return errors.New("no config json specified")
	}

	dataMap := map[string]interface{}{}
	if err := json.Unmarshal(jsonBytes, &dataMap); err != nil {
		fmt.Printf("Attempted to parse: %v\n", string(jsonBytes))
		fmt.Printf("Failing parsing JSON: %+v\n", err)
		return errors.Errorf("unable to parse data as json: %v", err)
	}

	configTypeId, err := mapNameToID("config-types", o.Args[1], o.Options)
	if err != nil {
		return err
	}

	entityData := gabs.New()
	api.SetJSONValue(entityData, o.Args[0], "name")
	api.SetJSONValue(entityData, configTypeId, "configTypeId")
	api.SetJSONValue(entityData, dataMap, "data")
	o.SetTags(entityData)
	result, err := CreateEntityOfType("configs", entityData.String(), &o.Options)
	return o.LogCreateResult("config", result, err)
}