Method cleanup

internal/sessions/manager.go:409–436

()

}

func (m *Manager) cleanup() {
	cutoff := time.Now().Add(-m.expiry)
	m.mu.Lock()
	defer m.mu.Unlock()
	for id, sess := range m.sessions {
		sess.mu.Lock()
		pinned := sess.BridgePinned
		expired := sess.LastActivity.Before(cutoff)
		sess.mu.Unlock()
		if pinned {
			continue // bridge-registered sessions are never expired
		}
		if expired {
			// Close all subscriber and observer channels before removing.
			sess.mu.Lock()
			for subID, ch := range sess.subscribers {
				close(ch)
				delete(sess.subscribers, subID)
			}
			for subID, ch := range sess.observers {
				close(ch)
				delete(sess.observers, subID)
			}
			sess.mu.Unlock()
			delete(m.sessions, id)
		}
	}
}

func hashKey(apiKey string) string {
	b := make([]byte, 16)