main.go

package main

import (
	_ "embed"
	"net/http"
	"time"

	"github.com/gorilla/handlers"
	"github.com/gorilla/mux"
	"github.com/sirupsen/logrus"

	iago "github.com/sanojsubran/iago/pkg/iago"
)

//go:embed config.json
var cfg string

func main() {
	r := mux.NewRouter()
	var news iago.NewsHandler

	news.Init()

	sources := news.GetConfiguredSources(cfg)

	go func() {
		for {

			for _, source := range sources {
				err := news.UpdateFeed(source)
				if err != nil {
					logrus.Errorf("unable to fetch the data from %s at %v", source.Topic, time.Now().UTC())
				}
			}
			time.Sleep(60 * time.Minute)

		}
	}()

	header := handlers.AllowedHeaders([]string{"X-Requested-With", "Content-Type", "Authorization"})
	methods := handlers.AllowedMethods([]string{"GET", "POST", "PUT", "HEAD", "OPTIONS"})
	origins := handlers.AllowedOrigins([]string{"*"})

	logrus.Info("Starting IAGO. Waiting for requests...")
	r.HandleFunc("/", news.HandleNewsRequests)

	logrus.Fatal(http.ListenAndServe(":8080", handlers.CORS(header, methods, origins)(r)))

}