chore(lint): настроить golangci-lint v2, gofumpt и форматирование в make
- .golangci.yml: набор линтеров под требования §14 (gosec, gocritic, sloglint, noctx, revive, depguard для запрета циклических зависимостей internal/*) - gofumpt вынесен из formatters golangci-lint v2.13 (сообщал о расхождениях, которые сам же не устранял) и применяется отдельным инструментом - make fmt/go-lint: проверка gofumpt + golangci-lint fmt --diff - scripts/gitleaks-scan.sh: поддержка gitleaks 8.19+ (dir) и старых версий (detect) - исправлены замечания линтеров: обработка ошибок Close, контекст в логах, NewRequestWithContext в тестах, комментарий к blank-import драйвера SQLite
This commit is contained in:
@@ -6,6 +6,7 @@ import (
|
||||
"embed"
|
||||
"errors"
|
||||
"fmt"
|
||||
"io"
|
||||
"log/slog"
|
||||
"os"
|
||||
"path/filepath"
|
||||
@@ -13,6 +14,7 @@ import (
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
// Регистрирует драйвер "sqlite3" для database/sql (CGO, AGENT.md 5.1).
|
||||
_ "github.com/mattn/go-sqlite3"
|
||||
"github.com/pressly/goose/v3"
|
||||
)
|
||||
@@ -59,38 +61,38 @@ func Open(ctx context.Context, opts Options) (*DB, error) {
|
||||
writer.SetConnMaxLifetime(connMaxLifetime)
|
||||
|
||||
if err := applyPragmas(ctx, writer, opts); err != nil {
|
||||
writer.Close()
|
||||
closeQuietly(writer)
|
||||
return nil, err
|
||||
}
|
||||
if err := writer.PingContext(ctx); err != nil {
|
||||
writer.Close()
|
||||
closeQuietly(writer)
|
||||
return nil, fmt.Errorf("ping writer connection: %w", err)
|
||||
}
|
||||
|
||||
db := &DB{Writer: writer, path: opts.Path}
|
||||
if opts.Migrate {
|
||||
if err := db.Migrate(ctx); err != nil {
|
||||
db.Close()
|
||||
closeQuietly(db.Writer)
|
||||
return nil, err
|
||||
}
|
||||
}
|
||||
|
||||
reader, err := sql.Open("sqlite3", dsn(opts, false))
|
||||
if err != nil {
|
||||
db.Close()
|
||||
closeQuietly(db.Writer)
|
||||
return nil, fmt.Errorf("open reader connection: %w", err)
|
||||
}
|
||||
reader.SetMaxOpenConns(opts.ReadPool)
|
||||
reader.SetMaxIdleConns(opts.ReadPool)
|
||||
reader.SetConnMaxLifetime(connMaxLifetime)
|
||||
if err := applyPragmas(ctx, reader, opts); err != nil {
|
||||
reader.Close()
|
||||
db.Close()
|
||||
closeQuietly(reader)
|
||||
closeQuietly(db.Writer)
|
||||
return nil, err
|
||||
}
|
||||
if err := reader.PingContext(ctx); err != nil {
|
||||
reader.Close()
|
||||
db.Close()
|
||||
closeQuietly(reader)
|
||||
closeQuietly(db.Writer)
|
||||
return nil, fmt.Errorf("ping reader connection: %w", err)
|
||||
}
|
||||
db.Reader = reader
|
||||
@@ -226,6 +228,12 @@ func (db *DB) Close() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func closeQuietly(closer io.Closer) {
|
||||
if err := closer.Close(); err != nil {
|
||||
slog.Debug("close sql handle", slog.Any("error", err))
|
||||
}
|
||||
}
|
||||
|
||||
func EnsureDir(path string) error {
|
||||
if err := os.MkdirAll(filepath.Dir(path), 0o750); err != nil {
|
||||
return fmt.Errorf("create data directory: %w", err)
|
||||
|
||||
Reference in New Issue
Block a user