From e8a5be21d33d5f20381192a3ed66343c650652d1 Mon Sep 17 00:00:00 2001
From: Levente Batuska <mr.levente97@gmail.com>
Date: Sat, 26 Oct 2024 15:25:14 +0200
Subject: [PATCH] fix(Logger): make buffer size user customizable

---
 logger/consolelogger.go | 2 +-
 logger/filelogger.go    | 2 +-
 logger/logger.go        | 5 ++++-
 3 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/logger/consolelogger.go b/logger/consolelogger.go
index bcaeec6..d0c3256 100644
--- a/logger/consolelogger.go
+++ b/logger/consolelogger.go
@@ -6,7 +6,7 @@ import (
 )
 
 func (lgr *ConsoleLoggerImpl) init() {
-	lgr.messages = make(chan string, logbuffersize)
+	lgr.messages = make(chan string, Logbuffersize)
 }
 
 func (logger *ConsoleLoggerImpl) StartLogger() {
diff --git a/logger/filelogger.go b/logger/filelogger.go
index 63b4b2b..da9b3db 100644
--- a/logger/filelogger.go
+++ b/logger/filelogger.go
@@ -9,7 +9,7 @@ import (
 
 func (lgr *FileLoggerImpl) init() {
 	lgr.filepath = "./log"
-	lgr.messages = make(chan string, logbuffersize)
+	lgr.messages = make(chan string, Logbuffersize)
 	envfp, envexist := os.LookupEnv("LOGFILE_GO_LOGGER")
 	if envexist {
 		if len(envfp) > 0 {
diff --git a/logger/logger.go b/logger/logger.go
index 65ebeb9..29fd474 100644
--- a/logger/logger.go
+++ b/logger/logger.go
@@ -6,10 +6,12 @@ import (
 	"net/http"
 	"reflect"
 	"sync"
+
+	Assert "github.com/lbatuska/goutils/assert"
 )
 
 // Use this in the init() function to initialize the size of the buffered channel
-const logbuffersize int32 = 200
+const Logbuffersize int32 = 200
 
 var DEBUG bool = true
 
@@ -27,6 +29,7 @@ func Create(instance Logger) {
 }
 
 func LoggerInstance() Logger {
+	Assert.NotNil(loggerInstance)
 	return loggerInstance
 }