main.go

package main

import (
	"context"
	"fmt"
	"log"
	"os"
	"strings"
	"time"

	"github.com/microcosm-cc/bluemonday"
)

func main() {
	var f = os.Stdout
	p := bluemonday.StrictPolicy()
	p.AddSpaceWhenStrippingTag(false)

	ctx := context.Background()

	cfgPath, err := ParseFlags()
	if err != nil {
		log.Fatal(err)
	}

	cfg, err := NewConfig(cfgPath)
	if err != nil {
		log.Fatal(err)
	}

	if cfg.LogFile != "" {
		f, err = os.OpenFile(cfg.LogFile, os.O_APPEND|os.O_CREATE|os.O_RDWR, 0644)
		if err != nil {
			fmt.Fprintln(os.Stderr, err)
			os.Exit(1)
		}
		defer f.Close()
	}

	logger := log.New(f, "", log.LstdFlags)

	clientGoogle := oauthClient(ctx, cfg.Credentail)

	clientTarget := NewClient(cfg.Target.URL, cfg.Target.ApiKey)

	chkevent := eventList(ctx, logger, clientGoogle, cfg.Calendar.Id)

	for {
		var nats bool = false
		events, err := chkevent.Do()
		if err != nil {
			logger.Printf("Unable to retrieve the events: %v", err)
		}
		for _, item := range events.Items {

			start, _ := time.Parse(time.RFC3339, item.Start.DateTime)
			now, _ := time.Parse(time.RFC3339, time.Now().Format(time.RFC3339))

			if item.Summary == cfg.Calendar.Event && start.Equal(now) {
				time.Sleep(5 * time.Second)
				logger.Println(item.Summary, " Event is Starting...........")
				description := p.Sanitize(item.Description)
				description = strings.TrimSpace(description)
				commit := fmt.Sprintf("%s-%s", item.Summary, description)
				p.Sanitize(item.Description)

				switch description {
				case "c1Up", "c1Down", "c2Up", "c2Down":
					if description == "c2Up" {
						nats = true
					}
					scaleData := cfg.getScaleData(ctx, logger, clientGoogle, nats, commit, description)
					req := cfg.postRequest(scaleData, logger)

					if err := clientTarget.sendRequest(req, logger); err != nil {
						logger.Printf("Unable to send request: %v", err)
					}
				case "multiClusterUp":
					nats = true
					scaleData := cfg.getScaleData(ctx, logger, clientGoogle, nats, commit, "c1Up,c2Up")
					req := cfg.postRequest(scaleData, logger)

					if err := clientTarget.sendRequest(req, logger); err != nil {
						logger.Printf("Unable to send request: %v", err)
					}
				case "multiClusterDown", "multiClusterDownWithoutNats":
					if description == "multiClusterDownWithoutNats" {
						nats = true
					}

					scaleData := cfg.getScaleData(ctx, logger, clientGoogle, nats, commit, "c1Down,c2Down")
					req := cfg.postRequest(scaleData, logger)
					if err := clientTarget.sendRequest(req, logger); err != nil {
						logger.Printf("Unable to send request: %v", err)
					}
				default:
					logger.Printf("Wrong Event instruction: %s", description)
				}
			}
		}
	}
}