aiproxy/core/common/mcpproxy/session.go

package mcpproxy

import "sync"

// SessionManager defines the interface for managing session information
type SessionManager interface {
	// Set stores a sessionID and its corresponding backend endpoint
	Set(sessionID, endpoint string)
	// Get retrieves the backend endpoint for a sessionID
	Get(sessionID string) (string, bool)
	// Delete removes a sessionID from the store
	Delete(sessionID string)
}

// MemStore implements the SessionManager interface
type MemStore struct {
	mu       sync.RWMutex
	sessions map[string]string // sessionID -> host+endpoint
}

// NewMemStore creates a new session store
func NewMemStore() *MemStore {
	return &MemStore{
		sessions: make(map[string]string),
	}
}

// Set stores a sessionID and its corresponding backend endpoint
func (s *MemStore) Set(sessionID, endpoint string) {
	s.mu.Lock()
	defer s.mu.Unlock()
	s.sessions[sessionID] = endpoint
}

// Get retrieves the backend endpoint for a sessionID
func (s *MemStore) Get(sessionID string) (string, bool) {
	s.mu.RLock()
	defer s.mu.RUnlock()
	endpoint, ok := s.sessions[sessionID]
	return endpoint, ok
}

// Delete removes a sessionID from the store
func (s *MemStore) Delete(sessionID string) {
	s.mu.Lock()
	defer s.mu.Unlock()
	delete(s.sessions, sessionID)
}