From c08b3b43b441a02da68f8e4ecc78b72642f0e53d Mon Sep 17 00:00:00 2001 From: "Lawrence, Rendall" Date: Wed, 15 Jul 2026 10:39:32 +0300 Subject: [PATCH] (minor) fix lint warnings --- frontend/udp/frontend.go | 3 ++- middleware/torrentapproval/container/s3/s3.go | 6 ++++-- storage/mdb/storage.go | 14 ++++++++++---- 3 files changed, 16 insertions(+), 7 deletions(-) diff --git a/frontend/udp/frontend.go b/frontend/udp/frontend.go index 0e16da4..c0b7460 100644 --- a/frontend/udp/frontend.go +++ b/frontend/udp/frontend.go @@ -233,7 +233,8 @@ func (f *udpFE) serve(ctx context.Context, socket *net.UDPConn) error { if f.collectTimings && metrics.Enabled() { start = time.Now() } - action, err := f.handleRequest(ctx, + action, err := f.handleRequest( + ctx, Request{(*buffer)[:n], addr}, ResponseWriter{socket, addrPort}, ) diff --git a/middleware/torrentapproval/container/s3/s3.go b/middleware/torrentapproval/container/s3/s3.go index 81bfa2e..8a12cd3 100644 --- a/middleware/torrentapproval/container/s3/s3.go +++ b/middleware/torrentapproval/container/s3/s3.go @@ -91,8 +91,10 @@ func build(conf conf.MapConfig, st storage.DataStorage) (container.Container, er } if len(c.KeyID) > 0 || len(c.KeySecret) > 0 || len(c.SessionToken) > 0 { - modifiers = append(modifiers, config.WithCredentialsProvider( - credentials.NewStaticCredentialsProvider(c.KeyID, c.KeySecret, c.SessionToken)), + modifiers = append( + modifiers, config.WithCredentialsProvider( + credentials.NewStaticCredentialsProvider(c.KeyID, c.KeySecret, c.SessionToken), + ), ) } diff --git a/storage/mdb/storage.go b/storage/mdb/storage.go index f749362..e8c7c40 100644 --- a/storage/mdb/storage.go +++ b/storage/mdb/storage.go @@ -143,7 +143,8 @@ func newStorage(cfg config) (*mdb, error) { } var env lmdbEnv - if env, err = lmdbsync.NewEnv(lmEnv, + if env, err = lmdbsync.NewEnv( + lmEnv, lmdbsync.MapResizedHandler(lmdbsync.MapResizedDefaultRetry, lmdbsync.MapResizedDefaultDelay), ); err != nil { return nil, err @@ -457,7 +458,9 @@ func (m *mdb) scanPeers(ctx context.Context, prefix []byte, readRaw bool, fn fun return err } -func (m *mdb) AnnouncePeers(ctx context.Context, ih bittorrent.InfoHash, forSeeder bool, numWant int, v6 bool) (peers []bittorrent.Peer, err error) { +func (m *mdb) AnnouncePeers( + ctx context.Context, ih bittorrent.InfoHash, forSeeder bool, numWant int, v6 bool, +) (peers []bittorrent.Peer, err error) { peers = make([]bittorrent.Peer, 0, numWant) prefix, prefixLen := composeIHKeyPrefix(ih.Bytes(), false, v6, 0) appendFn := func(k, _ []byte) bool { @@ -491,7 +494,8 @@ func (m *mdb) countPeers(ctx context.Context, scanPrefix []byte) (cnt uint32, er return ctx.Err() default: k := scanner.Key() - if len(k) == len(scanPrefix)+packedPeerLen && bytes.HasPrefix(scanPrefix, k[:len(k)-packedPeerLen]) { + if len(k) == len(scanPrefix)+packedPeerLen && bytes.HasPrefix(scanPrefix, + k[:len(k)-packedPeerLen]) { if !bytes.Equal(k, prevKey) { cnt++ prevKey = k @@ -516,7 +520,9 @@ func (m *mdb) countPeers(ctx context.Context, scanPrefix []byte) (cnt uint32, er return cnt, err } -func (m *mdb) ScrapeSwarm(ctx context.Context, ih bittorrent.InfoHash) (leechers uint32, seeders uint32, snatched uint32, err error) { +func (m *mdb) ScrapeSwarm(ctx context.Context, ih bittorrent.InfoHash) ( + leechers uint32, seeders uint32, snatched uint32, err error, +) { scanPrefix, _ := composeIHKeyPrefix(ih.Bytes(), false, false, 0) if leechers, err = m.countPeers(ctx, scanPrefix); err != nil { return leechers, seeders, snatched, err