main.go

package main

import (
	"fmt"
	"log"
	"os"
	"strconv"
	"sync"

	"github.com/badico-cloud-hub/pubsub/api"
	"github.com/badico-cloud-hub/pubsub/infra"
	"github.com/badico-cloud-hub/pubsub/setup"
	"github.com/joho/godotenv"
)

func main() {
	if err := godotenv.Load(); err != nil {
		log.Fatal(err)
	}
	isServerEnv := os.Getenv("IS_SERVER")
	isServer, err := strconv.ParseBool(isServerEnv)
	if err != nil {
		log.Fatal(err)
	}

	// logManager := infra.NewLogManager()
	// logManager.StartProducer()
	// defer func() {
	// logManager.StopProducer()
	// }()

	if isServer {
		fmt.Printf("RUNNING API PUBSUB\n")
		port := os.Getenv("PORT")
		api := api.NewServer(port)
		// api.LogManager = logManager
		api.AllRouters()
		if err := api.Run(); err != nil {
			log.Fatal(err)
		}
	} else {
		fmt.Printf("RUNNING CONSUMER PUBSUB\n")
		wg := &sync.WaitGroup{}
		sqs := infra.NewSqsClient()
		if err := sqs.Setup(); err != nil {
			log.Fatal(err)
		}

		setup.SetupNotifyEventConsumer(sqs.Client, wg)
		wg.Wait()
	}

}