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

import (
	"context"
	"os"

	"git.threesix.ai/jordan/sp4-debug-1770477266/pkg/app"
	"git.threesix.ai/jordan/sp4-debug-1770477266/pkg/database"
	"git.threesix.ai/jordan/sp4-debug-1770477266/pkg/logging"
	"git.threesix.ai/jordan/sp4-debug-1770477266/pkg/queue"
	"git.threesix.ai/jordan/sp4-debug-1770477266/services/chat-svc/internal/adapter/memory"
	"git.threesix.ai/jordan/sp4-debug-1770477266/services/chat-svc/internal/api"
	"git.threesix.ai/jordan/sp4-debug-1770477266/services/chat-svc/internal/config"
	"git.threesix.ai/jordan/sp4-debug-1770477266/services/chat-svc/internal/service"
	"git.threesix.ai/jordan/sp4-debug-1770477266/services/chat-svc/internal/taskqueue"
)

func main() {
	// Create logger
	logger := logging.Default()

	// Load config
	cfg := config.Load()

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

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

	// Connect to database for queue producer (shared with worker-svc)
	var producer *taskqueue.Producer
	if cfg.Database.URL != "" {
		pool, err := database.Connect(context.Background(), cfg.Database.URL, database.Options{})
		if err != nil {
			logger.Error("failed to connect to database for queue", "error", err)
			os.Exit(1)
		}
		defer pool.Close()

		jobQueue := queue.NewPostgresQueue(pool.DB, logger)
		producer = taskqueue.NewProducer(jobQueue, logger)
		logger.Info("task queue producer initialized")
	} else {
		logger.Warn("DATABASE_URL not set, chat task queue disabled")
	}

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

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

	// Start server
	application.Run()
}