main.go

package main

import (
	"os"

	"github.com/cosmos-sajal/go_boilerplate/controllers"
	"github.com/cosmos-sajal/go_boilerplate/initializers"
	logger "github.com/cosmos-sajal/go_boilerplate/logger"
	authservice "github.com/cosmos-sajal/go_boilerplate/services/auth"
	"github.com/cosmos-sajal/go_boilerplate/worker"
	sentrygin "github.com/getsentry/sentry-go/gin"
	"github.com/gin-gonic/gin"
)

func init() {
	initializers.LoadEnvVariables()
	initializers.ConnectToDB()
	initializers.ConnectToRedis()
	initializers.ConnectToAsyncClient()
	initializers.InitialiseErrorLogger()
}

func main() {
	appType := os.Getenv("APP_TYPE")
	if appType == "server" {
		r := gin.Default()
		r.Use(logger.RequestResponseLoggerMiddleware())
		r.Use(sentrygin.New(sentrygin.Options{}))

		r.POST("/api/v1/user/signin/", controllers.SignInController)
		r.POST("/api/v1/otp/validate/", controllers.OTPValidateController)
		r.POST("/api/v1/token/refresh/", controllers.RefreshTokenController)

		authGroup := r.Group("")
		authGroup.Use(authservice.JWTAuthMiddleware())
		authGroup.POST("/api/v1/user/", controllers.CreateUser)
		authGroup.GET("/api/v1/user/", controllers.GetUserList)
		authGroup.PATCH("/api/v1/user/:user_id/", controllers.UpdateUser)

		r.Run() // listen and serve on 0.0.0.0:3000
	} else if appType == "worker" {
		worker.StartWorker(initializers.TaskServer, os.Getenv("QUEUE_NAME"))
	} else {
		initializers.InitialiseCron()
		select {}
	}
}