From f8d576c56a6930b0a9068e9fbe9b0cc0f1763f0d Mon Sep 17 00:00:00 2001 From: Jorka2099 Date: Wed, 2 Jul 2025 19:18:20 +0400 Subject: [PATCH 1/3] logs: added new run http server logs --- internal/http/server/server.go | 32 ++++++++++++++++---------------- 1 file changed, 16 insertions(+), 16 deletions(-) diff --git a/internal/http/server/server.go b/internal/http/server/server.go index 35e13da..af25665 100644 --- a/internal/http/server/server.go +++ b/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,46 @@ 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("Сервер успешно завершил работу") } From 8cc1bc0b1c120b634dec23e6fbeeb5be02fa0e38 Mon Sep 17 00:00:00 2001 From: Jorka2099 Date: Wed, 2 Jul 2025 19:19:18 +0400 Subject: [PATCH 2/3] logs: added new run http server logs --- cmd/app/main.go | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/cmd/app/main.go b/cmd/app/main.go index 50882e7..21ca3a4 100644 --- a/cmd/app/main.go +++ b/cmd/app/main.go @@ -1,11 +1,10 @@ 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() { @@ -13,13 +12,23 @@ 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) From 3af800925e5650390aedfdbf58cb274754a3efe8 Mon Sep 17 00:00:00 2001 From: Jorka2099 Date: Wed, 2 Jul 2025 19:21:47 +0400 Subject: [PATCH 3/3] test. added comment --- internal/http/server/server.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/internal/http/server/server.go b/internal/http/server/server.go index af25665..b0750ca 100644 --- a/internal/http/server/server.go +++ b/internal/http/server/server.go @@ -76,3 +76,5 @@ func Run(cfg *config.Config, logger *zap.Logger) { logger.Info("Сервер успешно завершил работу") } + +// проверка