dns-updater/cmd/dnsupdater/main.go

package main

import (
	"flag"
	"os"
	"time"

	"dnsupdater/app"

	"github.com/rs/zerolog"
	"github.com/rs/zerolog/log"
)

func main() {
	configFile := flag.String("config", "./config.yml", "configuration file")

	flag.Parse()

	log.Logger = log.Output(zerolog.ConsoleWriter{
		Out:        os.Stderr,
		TimeFormat: time.RFC3339,
	})

	config, err := app.LoadConfig(*configFile)
	if err != nil {
		log.Fatal().Err(err).Str("file", *configFile).Msg("Failed to load config")
	}

	app, err := app.NewApp(config)
	if err != nil {
		log.Fatal().Err(err).Msg("Failed to initialize application")
	}

	for service_name, domains := range config.Updates {

		// Get service
		service := app.ProviderManager.Get(service_name)

		if service == nil {
			log.Warn().Str("service", service_name).Msg("Invalid service")
			continue
		}

		log.Info().Str("service", service_name).Msg("Begin update for service")

		for domain, records := range domains {
			for name, data := range records {

				logger := log.With().
					Str("service", service_name).
					Str("domain", domain).
					Str("record", name).
					Str("interface", data).
					Logger()

				ip, err := app.GetIP(data)
				if err != nil {
					logger.Error().Err(err).Msg("Failed to fetch ip")
					continue
				}

				logger = logger.With().IPAddr("ip", ip).Logger()

				err = service.Update(domain, name, ip)
				if err != nil {
					logger.Error().Err(err).Msg("Failed to update record")
				} else {
					logger.Info().Msg("Record updated")
				}
			}
		}
	}
}