From 51321129339fa464e01a9f393f7429729d53aa3e Mon Sep 17 00:00:00 2001
From: oli <oli@hlmpn.dev>
Date: Mon, 27 Jan 2025 15:40:21 +0100
Subject: [PATCH] Added mutex:es to map writes which were causing concurrent
 map writes under certain conditions

---
 sessions.go | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/sessions.go b/sessions.go
index c052b28..45c12e0 100644
--- a/sessions.go
+++ b/sessions.go
@@ -9,6 +9,7 @@ import (
 	"encoding/gob"
 	"fmt"
 	"net/http"
+	"sync"
 	"time"
 )
 
@@ -124,6 +125,7 @@ func GetRegistry(r *http.Request) *Registry {
 type Registry struct {
 	request  *http.Request
 	sessions map[string]sessionInfo
+	mu       sync.RWMutex // Protects concurrent access to sessions map
 }
 
 // Get registers and returns a session for the given name and session store.
@@ -133,6 +135,10 @@ func (s *Registry) Get(store Store, name string) (session *Session, err error) {
 	if !isCookieNameValid(name) {
 		return nil, fmt.Errorf("sessions: invalid character in cookie name: %s", name)
 	}
+
+	s.mu.Lock()
+	defer s.mu.Unlock()
+
 	if info, ok := s.sessions[name]; ok {
 		session, err = info.s, info.e
 	} else {
@@ -147,6 +153,10 @@ func (s *Registry) Get(store Store, name string) (session *Session, err error) {
 // Save saves all sessions registered for the current request.
 func (s *Registry) Save(w http.ResponseWriter) error {
 	var errMulti MultiError
+
+	s.mu.RLock()
+	defer s.mu.RUnlock()
+
 	for name, info := range s.sessions {
 		session := info.s
 		if session.store == nil {