72 lines
2.0 KiB
Go
72 lines
2.0 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net/http"
|
|
"os"
|
|
"os/signal"
|
|
"syscall"
|
|
|
|
"github.com/prometheus/client_golang/prometheus/promhttp"
|
|
"github.com/tuusuario/go-sync-service/internal/config"
|
|
email "github.com/tuusuario/go-sync-service/internal/email"
|
|
"github.com/tuusuario/go-sync-service/internal/scheduler"
|
|
"github.com/tuusuario/go-sync-service/metrics"
|
|
)
|
|
|
|
func main() {
|
|
// Cargar configuración
|
|
conf, err := config.LoadConfig()
|
|
if err != nil {
|
|
fmt.Println("❌ Error cargando configuración:", err)
|
|
os.Exit(1)
|
|
}
|
|
|
|
// Inicializar logger con configuración
|
|
config.InitLogger(conf)
|
|
config.Log.Info("🚀 Iniciando servicio: go-sync-service")
|
|
|
|
emailService := email.NewSMTPEmailService(conf)
|
|
|
|
// Conexión a Redis
|
|
redisClient := config.GetRedisClient(conf)
|
|
if err := redisClient.Ping(context.Background()).Err(); err != nil {
|
|
config.Log.Fatalf("❌ Redis no disponible: %v", err)
|
|
}
|
|
config.Log.Info("✅ Redis conectado")
|
|
|
|
// Crear proveedor de configuración desde Redis
|
|
redisManager := config.NewRedisManager(redisClient)
|
|
redisConfigProvider := config.NewRedisProvider(redisManager, context.Background())
|
|
|
|
// Conexión a Base de Datos
|
|
database := config.GetDatabaseConnection(conf)
|
|
if database == nil {
|
|
config.Log.Fatal("❌ No se pudo establecer la conexión con la base de datos.")
|
|
}
|
|
config.Log.Info("✅ Conexión a base de datos establecida")
|
|
|
|
scheduler.Start(context.Background(), redisClient, redisConfigProvider, database, *emailService)
|
|
config.Log.Info("✅ Scheduler en ejecución y escuchando recargas")
|
|
|
|
//metrics Grafana
|
|
metrics.Register()
|
|
startMetricsServer()
|
|
|
|
// Esperar señal del sistema para cerrar ordenadamente
|
|
stop := make(chan os.Signal, 1)
|
|
signal.Notify(stop, os.Interrupt, syscall.SIGTERM)
|
|
<-stop
|
|
|
|
config.Log.Info("🛑 Señal de apagado recibida, cerrando servicio...")
|
|
}
|
|
|
|
func startMetricsServer() {
|
|
go func() {
|
|
http.Handle("/metrics", promhttp.Handler())
|
|
config.Log.Info("📊 Servidor de métricas en :9100/metrics")
|
|
http.ListenAndServe(":9100", nil)
|
|
}()
|
|
}
|