prorochestvo · prorochestvo · Aug 13, 2026 · Aug 13, 2026
diff --git a/gateway/router/nokia.go b/gateway/router/nokia.go
@@ -126,7 +126,7 @@ func (d *NokiaDriver) Reboot(ctx context.Context) error {
 	if err != nil {
 		return fmt.Errorf("router: reboot request: %w", err)
 	}
-	defer resp.Body.Close()
+	defer func() { _ = resp.Body.Close() }()
 	body, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return fmt.Errorf("router: read reboot response: %w", err)
@@ -167,7 +167,7 @@ func (d *NokiaDriver) fetchCSRFToken(ctx context.Context) (string, error) {
 	if err != nil {
 		return "", fmt.Errorf("fetch reboot page: %w", err)
 	}
-	defer resp.Body.Close()
+	defer func() { _ = resp.Body.Close() }()
 
 	body, err := io.ReadAll(resp.Body)
 	if err != nil {
@@ -231,7 +231,7 @@ func (d *NokiaDriver) login(ctx context.Context) error {
 	if err != nil {
 		return fmt.Errorf("router: login request: %w", err)
 	}
-	defer resp.Body.Close()
+	defer func() { _ = resp.Body.Close() }()
 	if _, err := io.Copy(io.Discard, resp.Body); err != nil {
 		return fmt.Errorf("router: drain login response: %w", err)
 	}

diff --git a/gateway/router/nokia_test.go b/gateway/router/nokia_test.go
@@ -392,10 +392,10 @@ func newRouterServer(t *testing.T, cfg routerServerConfig) (*httptest.Server, *r
 				return
 			}
 			if cfg.noTokenPage {
-				fmt.Fprint(w, "<html><body>no token here</body></html>")
+				_, _ = fmt.Fprint(w, "<html><body>no token here</body></html>")
 				return
 			}
-			fmt.Fprintf(w, `<html><body><form></form><script>$("form").prepend('<input type="hidden" name="csrf_token" value="%s" />');</script></body></html>`, token)
+			_, _ = fmt.Fprintf(w, `<html><body><form></form><script>$("form").prepend('<input type="hidden" name="csrf_token" value="%s" />');</script></body></html>`, token)
 		case http.MethodPost:
 			obs.rebootCalled = true
 			obs.rebootCT = r.Header.Get("Content-Type")
@@ -416,7 +416,7 @@ func newRouterServer(t *testing.T, cfg routerServerConfig) (*httptest.Server, *r
 			}
 			w.WriteHeader(http.StatusOK)
 			if !cfg.emptyRebootBody {
-				fmt.Fprint(w, dto.RebootDoneMarker) // confirmed reboot marker
+				_, _ = fmt.Fprint(w, dto.RebootDoneMarker) // confirmed reboot marker
 			}
 		default:
 			w.WriteHeader(http.StatusMethodNotAllowed)
@@ -444,11 +444,11 @@ func newRouterServerRecordingPaths(t *testing.T, paths *[]string) *httptest.Serv
 	mux.HandleFunc("/reboot.cgi", func(w http.ResponseWriter, r *http.Request) {
 		*paths = append(*paths, r.URL.Path)
 		if r.Method == http.MethodGet {
-			fmt.Fprintf(w, `<input type="hidden" name="csrf_token" value="%s" />`, defaultTestCSRF)
+			_, _ = fmt.Fprintf(w, `<input type="hidden" name="csrf_token" value="%s" />`, defaultTestCSRF)
 			return
 		}
 		w.WriteHeader(http.StatusOK)
-		fmt.Fprint(w, dto.RebootDoneMarker)
+		_, _ = fmt.Fprint(w, dto.RebootDoneMarker)
 	})
 
 	srv := httptest.NewServer(mux)

diff --git a/gateway/telegram/telegram.go b/gateway/telegram/telegram.go
@@ -126,7 +126,7 @@ func (c *Client) sendMessage(ctx context.Context, text string) error {
 	if err != nil {
 		return fmt.Errorf("telegram: send request: %w", err)
 	}
-	defer resp.Body.Close()
+	defer func() { _ = resp.Body.Close() }()
 
 	if resp.StatusCode != http.StatusOK {
 		respBody, readErr := io.ReadAll(io.LimitReader(resp.Body, 1024))

diff --git a/infrastructure/check.go b/infrastructure/check.go
@@ -116,7 +116,7 @@ func (c *Checker) probeHTTP(ctx context.Context, target string) domain.TargetRes
 	if err != nil {
 		return domain.TargetResult{Target: target, Kind: domain.CheckKindDomain, OK: false, Latency: latency, Error: stage.annotate(err)}
 	}
-	defer resp.Body.Close()
+	defer func() { _ = resp.Body.Close() }()
 
 	if resp.StatusCode < 200 || resp.StatusCode >= 300 {
 		return domain.TargetResult{
@@ -143,7 +143,7 @@ func (c *Checker) probeTCP(ctx context.Context, target, kind string) domain.Targ
 	if err != nil {
 		return domain.TargetResult{Target: target, Kind: kind, OK: false, Latency: latency, Error: err.Error()}
 	}
-	defer conn.Close()
+	defer func() { _ = conn.Close() }()
 
 	return domain.TargetResult{Target: target, Kind: kind, OK: true, Latency: latency}
 }

diff --git a/infrastructure/env.go b/infrastructure/env.go
@@ -22,7 +22,7 @@ func loadEnvFile(path string) (map[string]string, error) {
 	if err != nil {
 		return nil, fmt.Errorf("open env file %q: %w", path, err)
 	}
-	defer f.Close()
+	defer func() { _ = f.Close() }()
 
 	values := map[string]string{}
 	scanner := bufio.NewScanner(f)

diff --git a/infrastructure/store.go b/infrastructure/store.go
@@ -369,7 +369,7 @@ func (s *Store) LatestMetrics(ctx context.Context) ([]domain.MetricRecord, error
 	if err != nil {
 		return nil, fmt.Errorf("latest metrics: %w", err)
 	}
-	defer rows.Close()
+	defer func() { _ = rows.Close() }()
 
 	out, err := scanMetricRecords(rows)
 	if err != nil {
@@ -403,7 +403,7 @@ func (s *Store) ListChecksByRun(ctx context.Context, runID string) ([]domain.Che
 	if err != nil {
 		return nil, fmt.Errorf("list checks for run %s: %w", runID, err)
 	}
-	defer rows.Close()
+	defer func() { _ = rows.Close() }()
 
 	var out []domain.Check
 	for rows.Next() {
@@ -476,7 +476,7 @@ func (s *Store) ListMetrics(ctx context.Context, f services.MetricsFilter) ([]do
 	if err != nil {
 		return nil, fmt.Errorf("list metrics: %w", err)
 	}
-	defer rows.Close()
+	defer func() { _ = rows.Close() }()
 
 	out, err := scanMetricRecords(rows)
 	if err != nil {
@@ -498,7 +498,7 @@ func (s *Store) ListMetricsByRun(ctx context.Context, runID string) ([]domain.Me
 	if err != nil {
 		return nil, fmt.Errorf("list metrics for run %s: %w", runID, err)
 	}
-	defer rows.Close()
+	defer func() { _ = rows.Close() }()
 
 	var out []domain.MetricSample
 	for rows.Next() {
@@ -563,7 +563,7 @@ func (s *Store) ListPings(ctx context.Context, f services.PingFilter) ([]domain.
 	if err != nil {
 		return nil, fmt.Errorf("list pings: %w", err)
 	}
-	defer rows.Close()
+	defer func() { _ = rows.Close() }()
 
 	out, err := scanPingRecords(rows)
 	if err != nil {
@@ -585,7 +585,7 @@ func (s *Store) ListPingsByRun(ctx context.Context, runID string) ([]domain.Ping
 	if err != nil {
 		return nil, fmt.Errorf("list pings for run %s: %w", runID, err)
 	}
-	defer rows.Close()
+	defer func() { _ = rows.Close() }()
 
 	var out []domain.PingResult
 	for rows.Next() {
@@ -624,7 +624,7 @@ func (s *Store) ListRuns(ctx context.Context, limit int) ([]domain.Run, error) {
 	if err != nil {
 		return nil, fmt.Errorf("list runs: %w", err)
 	}
-	defer rows.Close()
+	defer func() { _ = rows.Close() }()
 
 	var out []domain.Run
 	for rows.Next() {
@@ -653,7 +653,7 @@ func (s *Store) ListUnsentOutboxMessages(ctx context.Context) ([]domain.OutboxMe
 	if err != nil {
 		return nil, fmt.Errorf("list unsent outbox messages: %w", err)
 	}
-	defer rows.Close()
+	defer func() { _ = rows.Close() }()
 
 	var out []domain.OutboxMessage
 	for rows.Next() {
@@ -795,7 +795,7 @@ func (s *Store) OverviewMetrics(ctx context.Context, since time.Time, bucket tim
 	if err != nil {
 		return nil, fmt.Errorf("overview metrics: %w", err)
 	}
-	defer rows.Close()
+	defer func() { _ = rows.Close() }()
 
 	var out []domain.MetricSeries
 	var cur *domain.MetricSeries
@@ -863,7 +863,7 @@ func (s *Store) OverviewPings(ctx context.Context, since time.Time, bucket time.
 	if err != nil {
 		return nil, fmt.Errorf("overview pings: %w", err)
 	}
-	defer rows.Close()
+	defer func() { _ = rows.Close() }()
 
 	var out []domain.PingSeries
 	var cur *domain.PingSeries
@@ -921,7 +921,7 @@ func (s *Store) PingSamples(ctx context.Context, since time.Time) ([]domain.Ping
 	if err != nil {
 		return nil, fmt.Errorf("ping samples: %w", err)
 	}
-	defer rows.Close()
+	defer func() { _ = rows.Close() }()
 
 	out, err := scanPingRecords(rows)
 	if err != nil {
@@ -1005,7 +1005,7 @@ func (s *Store) RecentRuns(ctx context.Context, beforeID string, limit int) ([]d
 	if err != nil {
 		return nil, fmt.Errorf("recent runs before %s: %w", beforeID, err)
 	}
-	defer rows.Close()
+	defer func() { _ = rows.Close() }()
 
 	var out []domain.RunSummary
 	for rows.Next() {

diff --git a/infrastructure/store_test.go b/infrastructure/store_test.go
@@ -1405,7 +1405,7 @@ func TestStore_ListMetrics(t *testing.T) {
 		if err != nil {
 			t.Fatalf("EXPLAIN QUERY PLAN: %v", err)
 		}
-		defer rows.Close()
+		defer func() { _ = rows.Close() }()
 
 		var plan strings.Builder
 		for rows.Next() {
@@ -1596,7 +1596,7 @@ func TestStore_ListPings(t *testing.T) {
 		if err != nil {
 			t.Fatalf("EXPLAIN QUERY PLAN: %v", err)
 		}
-		defer rows.Close()
+		defer func() { _ = rows.Close() }()
 
 		var plan strings.Builder
 		for rows.Next() {

diff --git a/plans/plan_review_20260718.txt b/plans/plan_review_20260718.txt
@@ -0,0 +1,28 @@
+Все задачи надо прочитать и спланировать планы по каждой таске. Планы можно сгруппировать так, чтобы можно было запустить их параллельно, если такая возможность присутствует.
+NOTE: Тут в задачах, есть ключевые моменты, которые важны для любого моего проекта. Так что добавь в CLAUDE правило что надо вычленять мои паттерны работы и требования к коду и записывать в rules нового агента (агент глобальный уже должен быть создан надо расширить). То есть тебе нужно создать нового суб агента которые будет хранить список требований к коду мы будем его запускать в ручную по требованию и проверять кода на этим ключевые моменты.
+
+
+
+"Ower" замечания:
+
+- проект должен быть стиле DDD, можешь глянуть структуру проекта ~/projects/developments/com_lingocrm_api.
+Там я старался придерживаться концепций DDD, тут я бы тоже все положил в internal пакет а не держал все к корне.
+
+
+- логирование надо делать через мою библиотеку - loginjector
+запись в файл с ротированием логов за 7 дней думаю будет нормально
+
+
+- infrastructure/testdata для кого это создано? если для тестов то надо перенести данные в тесты.
+тесты не должны портить структуру проекта. если это проблема давай сделаем пакет ./test для глобальных тестов.
+там будем собирать итоговые решения скажем сервисы или репозитории и тестировать и работу
+
+
+- infrastructure/uuid.go - это страное расположение, давай сделаем tools и туда перенесем подобные решения.
+а лучшее вообще удалить и заменить на готовую библиотеку github.com/twinj/uuid или гугловую.
+
+
+- infrastructure - давай разделим на подгруппы, скажем тут много связанно с "os" или "system"
+
+
+- gateway/httpapi/web давай вынесем это в root проекта я думаю это будет более канонично.