Method GetCurrent

internal/manager/manager.go:318–362

GetCurrent returns the current primary session

()

// GetCurrent returns the current primary session
func (cm *ConnManager) GetCurrent() *Session {
	cm.mu.RLock()
	defer cm.mu.RUnlock()
	
	var selectedSession *Session
	
	// First, look for a healthy primary session
	for _, session := range cm.sessions {
		if session.IsPrimary() && session.IsHealthy() {
			selectedSession = session
			break
		}
	}
	
	// If no healthy primary, look for any healthy secondary (during transition)
	if selectedSession == nil {
		for _, session := range cm.sessions {
			if session.IsSecondary() && session.IsHealthy() {
				selectedSession = session
				break
			}
		}
	}
	
	// Last resort: return any healthy session (but not draining)
	if selectedSession == nil {
		for _, session := range cm.sessions {
			if session.IsHealthy() && !session.IsDraining() {
				selectedSession = session
				break
			}
		}
	}
	
	// Only log when no session is found and we have sessions (unusual condition)
	if selectedSession == nil && len(cm.sessions) > 0 {
		shared.LogNetworkf("GetCurrent: No suitable session found among %d sessions", len(cm.sessions))
		for i, session := range cm.sessions {
			shared.LogNetworkf("  Session %d: %s (role: %s, healthy: %v, draining: %v)", 
				i, session.ID, session.Role, session.IsHealthy(), session.IsDraining())
		}
	}
	
	return selectedSession
}

// GetAllSessions returns all sessions for dashboard display
func (cm *ConnManager) GetAllSessions() []*Session {