package main

import (
	"context"
	"fmt"
	"net"
	"os"
	"os/signal"
	"syscall"
	"time"

	"lendry-erp/media/internal/application/usecases"
	"lendry-erp/media/internal/config"
	infrastructureGrpc "lendry-erp/media/internal/infrastructure/grpc"
	"lendry-erp/media/internal/infrastructure/images"
	"lendry-erp/media/internal/infrastructure/storage"
	"lendry-erp/media/pkg/logger"
)

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

	logger.Init(cfg.Logging.Level)
	logger.Info("🚀 Starting media-service (gRPC only) in %s mode", cfg.App.Env)

	// 1. Инициализация хранилища
	mediaStorage, err := storage.NewS3Storage(cfg)
	if err != nil {
		logger.Fatal("failed to init S3 storage: %v", err)
	}
	logger.Info("✅ S3 storage connected (bucket: %s)", cfg.Storage.Bucket)

	// 2. Инициализация UseCases (Бизнес-логика)
	imgProcessor := images.NewImageProcessor()
	uploadUC := usecases.NewUploadUseCase(mediaStorage, imgProcessor)
	presignUC := usecases.NewPresignUseCase(mediaStorage)

	// 3. Создание gRPC сервера
	grpcServer := infrastructureGrpc.NewServer(uploadUC, presignUC)

	// 4. Запуск прослушивания порта
	grpcListener, err := net.Listen("tcp", fmt.Sprintf(":%s", cfg.GRPC.Port))
	if err != nil {
		logger.Fatal("failed to listen gRPC: %v", err)
	}

	go func() {
		logger.Info("gRPC listening on :%s", cfg.GRPC.Port)
		if err := grpcServer.Serve(grpcListener); err != nil {
			logger.Fatal("gRPC serve error: %v", err)
		}
	}()

	// 5. Ожидание сигнала остановки
	waitForShutdown(func() {
		logger.Warn("🛑 Graceful shutdown started...")
		grpcServer.GracefulStop()
		mediaStorage.Close()
		logger.Info("✅ Shutdown complete")
	})
}

func waitForShutdown(cleanup func()) {
	quit := make(chan os.Signal, 1)
	signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)
	<-quit

	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()

	cleanup()
	<-ctx.Done()
}