I have refactored the storage, api

cmd/api/main.go

@@ -5,8 +5,8 @@ import (
 	"log"
 	"os"
 
-	"cis-engine/internal/api"
 	"cis-engine/internal/search"
+	"cis-engine/internal/server"
 	"cis-engine/internal/storage/postgres"
 
 	"github.com/joho/godotenv"
@@ -31,12 +31,12 @@ func main() {
 	log.Println("Успешное подключение к базе данных.")
 
 	searchService := search.NewService(db)
-	apiHandler := api.NewHandler(searchService)
-	router := api.NewRouter(apiHandler)
+	apiHandler := server.NewHandler(searchService)
+	router := server.NewRouter(apiHandler)
 
 	serverAddr := ":8080"
 	log.Printf("Запуск API сервера на http://localhost%s", serverAddr)
 	if err := router.Run(serverAddr); err != nil {
 		log.Fatalf("Не удалось запустить сервер: %v", err)
 	}
-}
+}

go.mod

@@ -75,6 +75,7 @@ require (
 	github.com/shirou/gopsutil/v4 v4.25.1 // indirect
 	github.com/sirupsen/logrus v1.9.3 // indirect
 	github.com/spf13/pflag v1.0.6 // indirect
+	github.com/stretchr/objx v0.5.2 // indirect
 	github.com/tklauser/go-sysconf v0.3.12 // indirect
 	github.com/tklauser/numcpus v0.6.1 // indirect
 	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect

internal/api/api.go → internal/server/server.go

@@ -1,12 +1,12 @@
-package api
+package server
 
 import (
 	"context"
-	"log"
-	"net/http"
-
 	"cis-engine/internal/search"
 	"cis-engine/internal/storage"
+	"log"
+	"net/http"
+	"net/url"
 
 	"github.com/gin-gonic/gin"
 )
@@ -29,6 +29,8 @@ func NewRouter(h *Handler) *gin.Engine {
 	gin.SetMode(gin.ReleaseMode)
 	router := gin.Default()
 
+	router.Use(errorHandler)
+
 	apiV1 := router.Group("/api/v1")
 	{
 		apiV1.GET("/search", h.searchHandler)
@@ -42,14 +44,14 @@ func NewRouter(h *Handler) *gin.Engine {
 func (h *Handler) searchHandler(c *gin.Context) {
 	query := c.Query("q")
 	if query == "" {
-		c.JSON(http.StatusBadRequest, gin.H{"error": "Параметр 'q' не может быть пустым"})
+		c.JSON(http.StatusBadRequest, gin.H{"error": "query parameter 'q' cannot be empty"})
 		return
 	}
 
 	results, err := h.searchService.Search(c.Request.Context(), query)
 	if err != nil {
 		log.Printf("ERROR: search service failed for query '%s': %v", query, err)
-		c.JSON(http.StatusInternalServerError, gin.H{"error": "Внутренняя ошибка сервера"})
+		c.JSON(http.StatusInternalServerError, gin.H{"error": "internal server error"})
 		return
 	}
 
@@ -62,31 +64,47 @@ func (h *Handler) crawlHandler(c *gin.Context) {
 	}
 
 	if err := c.ShouldBindJSON(&request); err != nil {
-		c.JSON(http.StatusBadRequest, gin.H{"error": "Неверный формат запроса. Ожидается JSON с полем 'url'."})
+		c.JSON(http.StatusBadRequest, gin.H{"error": "invalid request format, expected JSON with 'url' field"})
 		return
 	}
 
-	if request.URL == "" {
-		c.JSON(http.StatusBadRequest, gin.H{"error": "Поле 'url' не может быть пустым."})
+	if _, err := url.ParseRequestURI(request.URL); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "invalid URL format"})
 		return
 	}
 
 	if err := h.searchService.ScheduleCrawl(c.Request.Context(), request.URL); err != nil {
 		log.Printf("ERROR: failed to schedule crawl for url '%s': %v", request.URL, err)
-		c.JSON(http.StatusInternalServerError, gin.H{"error": "Не удалось добавить URL в очередь"})
+		c.JSON(http.StatusInternalServerError, gin.H{"error": "failed to add URL to the queue"})
 		return
 	}
 
-	c.JSON(http.StatusAccepted, gin.H{"message": "URL принят в очередь на сканирование."})
+	c.JSON(http.StatusAccepted, gin.H{"message": "URL accepted for scanning"})
 }
 
 func (h *Handler) statusHandler(c *gin.Context) {
 	stats, err := h.searchService.GetStats(c.Request.Context())
 	if err != nil {
 		log.Printf("ERROR: failed to get system stats: %v", err)
-		c.JSON(http.StatusInternalServerError, gin.H{"error": "Не удалось получить статистику системы"})
+		c.JSON(http.StatusInternalServerError, gin.H{"error": "failed to get system statistics"})
 		return
 	}
 
 	c.JSON(http.StatusOK, stats)
 }
+
+func errorHandler(c *gin.Context) {
+	c.Next()
+
+	if len(c.Errors) > 0 {
+		// Log errors
+		for _, e := range c.Errors {
+			log.Printf("ERROR: %v", e.Err)
+		}
+
+		// Return a generic error message
+		c.JSON(http.StatusInternalServerError, gin.H{
+			"error": "internal server error",
+		})
+	}
+}