From fb32886d4ad4f06c418c3b042a9caf41c0decfe3 Mon Sep 17 00:00:00 2001 From: d3m0k1d Date: Thu, 22 Jan 2026 21:08:55 +0300 Subject: [PATCH] refactoring: rename func writer --- cmd/banforge/command/daemon.go | 2 +- internal/storage/writer.go | 2 +- internal/storage/writer_test.go | 10 +++++----- 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/cmd/banforge/command/daemon.go b/cmd/banforge/command/daemon.go index 125075a..86efb04 100644 --- a/cmd/banforge/command/daemon.go +++ b/cmd/banforge/command/daemon.go @@ -67,7 +67,7 @@ var DaemonCmd = &cobra.Command{ j.LoadRules(r) go j.UnbanChecker() go j.Tribunal() - go storage.Write(reqDb_w, resultCh) + go storage.WriteReq(reqDb_w, resultCh) var scanners []*parser.Scanner for _, svc := range cfg.Service { diff --git a/internal/storage/writer.go b/internal/storage/writer.go index 41ccb46..8b63be1 100644 --- a/internal/storage/writer.go +++ b/internal/storage/writer.go @@ -4,7 +4,7 @@ import ( "time" ) -func Write(db *Request_Writer, resultCh <-chan *LogEntry) { +func WriteReq(db *Request_Writer, resultCh <-chan *LogEntry) { db.logger.Info("Starting log writer") const batchSize = 100 const flushInterval = 1 * time.Second diff --git a/internal/storage/writer_test.go b/internal/storage/writer_test.go index 256d657..5b1be20 100644 --- a/internal/storage/writer_test.go +++ b/internal/storage/writer_test.go @@ -28,7 +28,7 @@ func TestWrite_BatchInsert(t *testing.T) { done := make(chan bool) go func() { - Write(writer, resultCh) + WriteReq(writer, resultCh) close(done) }() @@ -115,7 +115,7 @@ func TestWrite_BatchSizeTrigger(t *testing.T) { resultCh := make(chan *LogEntry, 100) done := make(chan bool) go func() { - Write(writer, resultCh) + WriteReq(writer, resultCh) close(done) }() @@ -167,7 +167,7 @@ func TestWrite_FlushInterval(t *testing.T) { done := make(chan bool) go func() { - Write(writer, resultCh) + WriteReq(writer, resultCh) close(done) }() @@ -216,7 +216,7 @@ func TestWrite_EmptyBatch(t *testing.T) { done := make(chan bool) go func() { - Write(writer, resultCh) + WriteReq(writer, resultCh) close(done) }() @@ -250,7 +250,7 @@ func TestWrite_ChannelClosed(t *testing.T) { done := make(chan bool) go func() { - Write(writer, resultCh) + WriteReq(writer, resultCh) close(done) }()