main.go

package main

import (
	"flag"

	"github.com/uesteibar/scribano/asyncapi/repos/messagesrepo"
	"github.com/uesteibar/scribano/storage/db"
	"github.com/uesteibar/scribano/watcher"
	"github.com/uesteibar/scribano/watcher/config"
	yamlconfig "github.com/uesteibar/scribano/watcher/config/parsers/yaml_config"
	"github.com/uesteibar/scribano/web/api"
)

func getLoader() config.Loader {
	var url string
	flag.StringVar(&url, "u", "", "url to the config file.")
	var path string
	flag.StringVar(&path, "f", "", "path to the config file.")
	flag.Parse()

	if url != "" {
		return &config.URLLoader{Source: url}
	} else if path != "" {
		return &config.PathLoader{Source: path}
	} else {
		panic("Missing configuration")
	}
}

func main() {
	repo := messagesrepo.New(db.DB{})
	repo.Migrate()

	loader := getLoader()
	configParser := yamlconfig.New(loader)

	configs, err := configParser.Parse()

	if err != nil {
		panic(err)
	}

	for _, c := range configs {
		w := watcher.New(c, 5) // consume 5% of messages
		go w.Watch()

	}

	api.Start()
}