config.go

// Copyright (c) 2021 Terminus, 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
//
//      http://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 servicehub

import (
	"fmt"
	"os"
	"reflect"
	"strings"

	"github.com/erda-project/erda-infra/pkg/config"
)

func (h *Hub) loadConfigWithArgs(file string, cfg map[string]interface{}, args ...string) (map[string]interface{}, error) {
	if len(args) > 0 {
		args = args[1:]
		var idx int
		var arg string
		for idx, arg = range args {
			if !strings.HasPrefix(arg, "-") {
				cfg[arg] = nil
			} else {
				break
			}
		}
		args, num, idx := args[idx:], len(args[idx:]), 0
		for ; idx < num; idx++ {
			arg := args[idx]
			if strings.HasPrefix(arg, "-") {
				if arg == "-c" || arg == "--config" || arg == "-config" {
					idx++
					if idx < len(args) && len(args[idx]) > 0 {
						file = args[idx]
					}
				} else if strings.HasPrefix(arg, "-c=") {
					arg = arg[len("-c="):]
					if len(arg) > 0 {
						file = arg
					}
				} else if strings.HasPrefix(arg, "--config=") {
					arg = arg[len("--config="):]
					if len(arg) > 0 {
						file = arg
					}
				} else if strings.HasPrefix(arg, "-config=") {
					arg = arg[len("-config="):]
					if len(arg) > 0 {
						file = arg
					}
				}
			}
		}
	}
	if len(file) <= 0 {
		return cfg, nil
	}
	err := config.LoadToMap(file, cfg)
	if err != nil {
		if os.IsNotExist(err) {
			if len(cfg) <= 0 {
				h.logger.Warnf("config file %s not exist", file)
			} else {
				h.logger.Debugf("config file %s not exist", file)
			}
			return cfg, nil
		}
		h.logger.Errorf("fail to load config: %s", err)
		return nil, err
	}
	h.logger.Debugf("using config file: %s", file)
	return cfg, nil
}

func (h *Hub) loadProviders(config map[string]interface{}) error {
	h.providersMap = map[string][]*providerContext{}
	err := h.doLoadProviders(config, "providers")
	if err != nil {
		return err
	}
	list := config["providers"]
	if list != nil {
		switch providers := list.(type) {
		case []interface{}:
			for _, item := range providers {
				if cfg, ok := item.(map[string]interface{}); ok {
					err = h.addProvider("", cfg)
					if err != nil {
						return nil
					}
				} else {
					return fmt.Errorf("invalid provider config type: %v", reflect.TypeOf(cfg))
				}
			}
		case map[string]interface{}:
			err = h.doLoadProviders(providers, "")
			if err != nil {
				return err
			}
		}
	}
	return nil
}

func (h *Hub) doLoadProviders(config map[string]interface{}, filter string) error {
	for key, cfg := range config {
		if key == filter {
			continue
		}
		err := h.addProvider(key, cfg)
		if err != nil {
			return err
		}
	}
	return nil
}

func (h *Hub) addProvider(key string, cfg interface{}) error {
	name, label := key, ""
	idx := strings.Index(key, "@")
	if idx > 0 {
		name = key[0:idx]
		label = key[idx+1:]
	}
	if cfg != nil {
		if v, ok := cfg.(map[string]interface{}); ok {
			if val, ok := v["_name"]; ok {
				if n, ok := val.(string); ok {
					name = n
				}
			}
			if val, ok := v["_enable"]; ok {
				if enable, ok := val.(bool); ok && !enable {
					return nil
				}
			}
		}
	}
	if len(name) <= 0 {
		return fmt.Errorf("provider name must not be empty")
	}
	define, ok := serviceProviders[name]
	if !ok {
		return fmt.Errorf("provider %s not exist", name)
	}
	provider := define.Creator()()
	pctx := &providerContext{
		Context:  h.ctx,
		hub:      h,
		key:      key,
		label:    label,
		name:     name,
		cfg:      cfg,
		provider: provider,
		define:   define,
	}
	if provider != nil {
		value := reflect.ValueOf(provider)
		typ := value.Type()
		for typ.Kind() == reflect.Ptr {
			value = value.Elem()
			typ = value.Type()
		}
		if typ.Kind() == reflect.Struct {
			pctx.structValue = value
			pctx.structType = typ
		}
	}
	h.providersMap[name] = append(h.providersMap[name], pctx)
	return nil
}