oc-schedulerd/main.go

package main

import (
	"fmt"
	"os"

	conf "oc-scheduler/conf"
	"oc-scheduler/models"

	"oc-scheduler/daemons"
	"oc-scheduler/logger"
)

// var log zerolog.Logger

func main() {
	// output := zerolog.ConsoleWriter{Out: os.Stdout, TimeFormat: time.RFC3339}
	// log = zerolog.New(output).With().Timestamp().Logger()

	app_conf := conf.GetConfig()
	apiurl := app_conf.OcCatalogUrl
	
	if _, err := os.Stat("./argo_workflows/"); os.IsNotExist(err) {
		os.Mkdir("./argo_workflows/",0755)
		logger.Logger.Info().Msg("Created argo_workflows/")
	}

	var bookings models.ScheduledBooking

	sch_mngr := daemons.ScheduleManager{Api_url: apiurl}
	sch_mngr.SetBookings(&bookings)
	exe_mngr := daemons.ExecutionManager{}
	exe_mngr.SetBookings(&bookings)

	go sch_mngr.SchedulePolling()
	go exe_mngr.RetrieveNextExecutions()

	sch_mngr.ListenForWorkflowSubmissions()

	// method in Schedule manager that checks the first Schedule object for its start date and exe 

	// var g Graph

	// list, err := g.GetGraphList(apiurl)
	// if err != nil {
	// 	log.Fatal().Msg("Failed to get the workspaces list, check api url and that api server is up : " + apiurl)
	// }
	
	// println("Available workspaces :")
	// for workspace, _ := range list {
	// 	println(workspace)
	// }
	

	// g.LoadFrom(list["test-alpr"])
	// g.ExportToArgo("test-alpr")

 	fmt.Print("stop")

}