config/rateLimiter.go

@@ -32,7 +32,7 @@ type RateLimiter struct {
 var rateLimiterInstance *RateLimiter
 var rateOnce sync.Once
 
-func SetRateLimit(cfg *config.ServerConfig) {
+func SetupRateLimiter(cfg *config.ServerConfig) {
 	rateLimiter := NewRateLimiter(
 		rate.Limit(cfg.RateLimit.WsLimit),
 		cfg.RateLimit.WsBurst,

config/sizeLimiter.go

@@ -12,13 +12,13 @@ type SizeLimiter struct {
 	mu             sync.RWMutex
 }
 
-func SetSizeLimit(cfg *config.ServerConfig) {
+func SetupSizeLimiter(cfg *config.ServerConfig) {
 	sizeLimiter := NewSizeLimiter(cfg.RateLimit.MaxEventSize)
 	for _, kindSizeLimit := range cfg.RateLimit.KindSizeLimits {
 		sizeLimiter.AddKindSizeLimit(kindSizeLimit.Kind, kindSizeLimit.MaxSize)
 	}
 
-	SizeLimit(sizeLimiter)
+	SetSizeLimiter(sizeLimiter)
 }
 
 func NewSizeLimiter(globalMaxSize int) *SizeLimiter {
@@ -35,7 +35,7 @@ func GetSizeLimiter() *SizeLimiter {
 	return sizeLimiterInstance
 }
 
-func SizeLimit(sl *SizeLimiter) {
+func SetSizeLimiter(sl *SizeLimiter) {
 	sizeOnce.Do(func() {
 		sizeLimiterInstance = sl
 	})

main.go

@@ -25,7 +25,7 @@ func main() {
 	utils.EnsureFileExists("relay_metadata.json", "app/static/examples/relay_metadata.example.json")
 
 	restartChan := make(chan struct{})
-	go config.WatchConfigFile("config.yml", restartChan) // Critical goroutine
+	go utils.WatchConfigFile("config.yml", restartChan) // Critical goroutine
 
 	signalChan := make(chan os.Signal, 1)
 	signal.Notify(signalChan, syscall.SIGINT, syscall.SIGTERM)
@@ -39,15 +39,15 @@ func main() {
 			log.Fatal("Error loading config: ", err)
 		}
 
-		config.SetResourceLimit(&cfg.ResourceLimits) // Apply limits once before starting the server
+		utils.ApplyResourceLimits(&cfg.ResourceLimits) // Apply limits once before starting the server
 
 		client, err := db.InitDB(cfg)
 		if err != nil {
 			log.Fatal("Error initializing database: ", err)
 		}
 
-		config.SetRateLimit(cfg)
+		config.SetupRateLimiter(cfg)
-		config.SetSizeLimit(cfg)
+		config.SetupSizeLimiter(cfg)
 
 		config.ClearTemporaryBans()
 

server/handlers/event.go

@@ -16,7 +16,7 @@ import (
 )
 
 func HandleEvent(ws *websocket.Conn, message []interface{}) {
-	config.LimitedGoRoutine(func() {
+	utils.LimitedGoRoutine(func() {
 		if len(message) != 2 {
 			fmt.Println("Invalid EVENT message format")
 			response.SendNotice(ws, "", "Invalid EVENT message format")

server/handlers/req.go

@@ -17,7 +17,7 @@ var subscriptions = make(map[string]relay.Subscription)
 var mu sync.Mutex // Protect concurrent access to subscriptions map
 
 func HandleReq(ws *websocket.Conn, message []interface{}, subscriptions map[string][]relay.Filter) {
-	config.LimitedGoRoutine(func() {
+	utils.LimitedGoRoutine(func() {
 		if len(message) < 3 {
 			fmt.Println("Invalid REQ message format")
 			response.SendClosed(ws, "", "invalid: invalid REQ message format")

server/utils/applyResourceLimits.go

@@ -1,4 +1,4 @@
-package config
+package utils
 
 import (
 	"log"
@@ -17,7 +17,7 @@ var (
 	goroutineQueueMutex sync.Mutex
 )
 
-func SetResourceLimit(cfg *configTypes.ResourceLimits) {
+func ApplyResourceLimits(cfg *configTypes.ResourceLimits) {
 	// Set CPU cores
 	runtime.GOMAXPROCS(cfg.CPUCores)
 

server/utils/watchConfig.go

@@ -1,4 +1,4 @@
-package config
+package utils
 
 import (
 	"fmt"