Logger

cmd/app/main.go

@@ -1,25 +1,34 @@
 package main
 
 import (
-	"log"
-
 	"github.com/cinenetwork/videoprocessing/cmd/config"
 	"github.com/cinenetwork/videoprocessing/internal/http/server"
 	"github.com/cinenetwork/videoprocessing/internal/logger"
+	"go.uber.org/zap"
 )
 
 func main() {
 
 	//Подгружаем конфигурацию
 	cfg, err := config.LoadConfig()
 	if err != nil {
-		log.Fatalf("[ CONFIG ] Ошибка загрузки конфигурации сервера: %v", err)
+		tmpLogger, _ := zap.NewProduction()
+		tmpLogger.Fatal("Ошибка загрузки конфигурации сервера", zap.Error(err))
 	}
 
 	//Инициализируем zap-логер
 	logger := logger.NewLogger(cfg.Logger.Mode)
 	defer logger.Sync()
 
+	logger.Info("Запуск приложение", zap.String("mode", cfg.Logger.Mode), zap.String("port", cfg.HTTP.Port))
+
+	logger.Info("Конфигурация загружена",
+		zap.String("http_port", cfg.HTTP.Port),
+		zap.Int("max_header_bytes", cfg.HTTP.MaxHeaderBytes),
+		zap.Duration("write_timeout", cfg.HTTP.WriteTimeout),
+		zap.Duration("read_timeout", cfg.HTTP.ReadTimeout),
+		zap.Int("shutdown_timeout_seconds", cfg.HTTP.ShutDownTime))
+
 	//Запускаем сервер
 	server.Run(cfg, logger)
 

internal/http/server/server.go

@@ -3,7 +3,6 @@ package server
 import (
 	"context"
 	"errors"
-	"log"
 	"net"
 	"net/http"
 	"os"
@@ -18,10 +17,12 @@ import (
 func Run(cfg *config.Config, logger *zap.Logger) {
 
 	listener, err := net.Listen("tcp", cfg.HTTP.Port)
-	if err != nil && listener == nil {
-		logger.Error("")
+	if err != nil {
+		logger.Fatal("Ошибка при попытке прослушивания порта.", zap.String("port", cfg.HTTP.Port), zap.Error(err))
 	}
 
+	logger.Info("Сервер запущен на порту", zap.String("port", cfg.HTTP.Port))
+
 	srv := &http.Server{
 		Handler:        cfg.HTTP.Handler,
 		MaxHeaderBytes: cfg.HTTP.MaxHeaderBytes,
@@ -32,47 +33,48 @@ func Run(cfg *config.Config, logger *zap.Logger) {
 	errCh := make(chan error, 1)
 
 	go func() {
-		logger.Info("")
+		logger.Info("Сервер начинает обслуживать запросы")
 		errCh <- srv.Serve(listener)
 	}()
 
 	quit := make(chan os.Signal, 1)
-	signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM, os.Interrupt)
+	signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)
 
 	select {
 
 	case sig := <-quit:
-		logger.Info("")
-		log.Printf("%v", sig)
+		logger.Info("Получен сигнал на завершение работы", zap.String("signal", sig.String()))
 	case srvErr := <-errCh:
 
 		if !errors.Is(srvErr, http.ErrServerClosed) {
-			logger.Fatal("")
+			logger.Fatal("Ошибка HTTP сервера", zap.Error(srvErr))
 		}
-		logger.Info("")
+		logger.Info("HTTP-сервер завершил работу неожиданно")
 		return
 	}
-
+	logger.Info("Инициация корректного завершения работы...")
 	if err = listener.Close(); err != nil {
-		logger.Info("")
+		logger.Warn("Не удалось закрыть listener", zap.Error(err))
 	}
 
 	ctx, cancel := context.WithTimeout(
 		context.Background(),
 		time.Duration(cfg.HTTP.ShutDownTime)*time.Second,
 	)
-	logger.Info("")
+	defer cancel() // передвинул defer сюда
+	logger.Info("Ожидание завершения работы сервера", zap.Duration("таймаут", time.Duration(cfg.HTTP.ShutDownTime)*time.Second))
 	for j := cfg.HTTP.ShutDownTime; j > 0; j-- {
-		logger.Info("")
+		logger.Debug("Отсчёт до закрытия", zap.Int("осталось секунд:", j))
 		time.Sleep(1 * time.Second)
 	}
-	defer cancel()
 
 	if err := srv.Shutdown(ctx); err != nil {
 		if errors.Is(err, context.DeadlineExceeded) {
-			logger.Error("")
+			logger.Error("Ошибка: превышен таймаут при завершении работы сервера", zap.Error(err))
 		}
 	}
-	logger.Info("")
+	logger.Info("Сервер успешно завершил работу")
 
 }
+
+// проверка