conf.go

package main

import (
	"fmt"
	"strconv"
	"strings"

	"github.com/fsnotify/fsnotify"
	"github.com/spf13/viper"
)

func (interestApp *InterestApplication) readCurrentConfiguration() {
	viper.SetDefault("role", "unknown")
	viper.SetDefault("rabbitHost", "localhost")
	viper.SetDefault("rabbitPort", "5672")
	viper.SetDefault("rabbitQueue", "devReadQueue")

	viper.SetConfigName("labels")
	viper.SetConfigType("properties") //Java properties style

	//Development mode
	viper.AddConfigPath(".")

	//This is injected from the Kubernetes downward API that maps
	// all labels as a file in the pod
	// See https://kubernetes.io/docs/concepts/workloads/pods/downward-api/
	viper.AddConfigPath("/etc/podinfo/")

	err := viper.ReadInConfig() // Find and read the config file
	if err != nil {             // Handle errors reading the config file
		panic(fmt.Errorf("fatal error config file: %w", err))
	}

	//Reload configuration when file changes
	viper.OnConfigChange(func(e fsnotify.Event) {
		fmt.Println("Config file changed:", e.Name)
		interestApp.stopNow()
		interestApp.reloadSettings()

	})

	interestApp.reloadSettings()

	viper.WatchConfig()

}

func (interestApp *InterestApplication) reloadSettings() {

	fmt.Printf("Role is set %t\n", viper.IsSet("role"))

	interestApp.CurrentRole = unQuoteIfNeeded(viper.GetString("role"))

	interestApp.RabbitHost = unQuoteIfNeeded(viper.GetString("rabbitHost"))
	interestApp.RabbitPort = unQuoteIfNeeded(viper.GetString("rabbitPort"))
	interestApp.RabbitReadQueue = unQuoteIfNeeded(viper.GetString("rabbitQueue"))

	fmt.Printf("Role is %s\n", interestApp.CurrentRole)
	fmt.Printf("RabbitHost is %s\n", interestApp.RabbitHost)
	fmt.Printf("RabbitPort is %s\n", interestApp.RabbitPort)
	fmt.Printf("Queue is %s\n", interestApp.RabbitReadQueue)

	interestApp.retryConnecting()
}

func unQuoteIfNeeded(input string) string {
	result := ""
	if strings.HasPrefix(input, "\"") {
		result, _ = strconv.Unquote(input)
	}
	return result
}