// Package main is the entry point for the chat-api service.
package main

import (
	"context"

	"github.com/redis/go-redis/v9"

	"git.threesix.ai/jordan/sp3-verify-1770325830/pkg/app"
	"git.threesix.ai/jordan/sp3-verify-1770325830/pkg/logging"
	"git.threesix.ai/jordan/sp3-verify-1770325830/pkg/realtime"
	"git.threesix.ai/jordan/sp3-verify-1770325830/services/chat-api/internal/adapter/memory"
	"git.threesix.ai/jordan/sp3-verify-1770325830/services/chat-api/internal/api"
	"git.threesix.ai/jordan/sp3-verify-1770325830/services/chat-api/internal/config"
	"git.threesix.ai/jordan/sp3-verify-1770325830/services/chat-api/internal/service"
)

func main() {
	// Load configuration
	cfg := config.Load()

	// Create logger
	logger := logging.Default()

	// Create context for background goroutines
	ctx, cancel := context.WithCancel(context.Background())

	// Create realtime hub (local connection registry)
	hub := realtime.NewHub(logger)
	go hub.Run(ctx)

	// Create Redis broadcaster for multi-pod scaling (optional)
	var broadcaster realtime.Broadcaster
	if cfg.RedisURL != "" {
		opts, err := redis.ParseURL(cfg.RedisURL)
		if err != nil {
			logger.Error("invalid redis url", "error", err)
		} else {
			redisClient := redis.NewClient(opts)
			broadcaster = realtime.NewRedisBroadcaster(redisClient, hub, logger)
			go broadcaster.Run(ctx)
			logger.Info("redis broadcaster enabled", "url", cfg.RedisURL)
		}
	} else {
		logger.Info("redis broadcaster disabled, running in single-pod mode")
	}

	// Create adapters (repositories)
	exampleRepo := memory.NewExampleRepository()

	// Create services (business logic)
	exampleService := service.NewExampleService(exampleRepo, logger)

	// Create application
	application := app.New("chat-api", app.WithDefaultPort(8001))

	// Register shutdown hook to cancel context
	application.OnShutdown(func(_ context.Context) error {
		cancel()
		return nil
	})

	// Register routes with dependency injection
	api.RegisterRoutes(application, exampleService, hub, broadcaster)

	// Start server
	application.Run()
}