Method Create

server-source-code/internal/rdpproxy/session.go:100–151

Create creates a new RDP proxy session. It starts a TCP listener and returns the session ID and port. Callers send rdp_proxy to the agent via SendToAgent. Session is ready once the agent confirms (WaitAgentReady).

(ctx context.Context, apiID, hostID string)

// the session ID and port. Callers send rdp_proxy to the agent via SendToAgent.
// Session is ready once the agent confirms (WaitAgentReady).
func (s *Sessions) Create(ctx context.Context, apiID, hostID string) (sessionID string, port int, err error) {
	s.mu.Lock()
	defer s.mu.Unlock()

	if s.maxSessions > 0 && len(s.sessions) >= s.maxSessions {
		return "", 0, ErrMaxSessionsReached
	}

	b := make([]byte, 16)
	if _, err := rand.Read(b); err != nil {
		return "", 0, err
	}
	sessionID = hex.EncodeToString(b)

	listener, err := net.Listen("tcp", "127.0.0.1:0")
	if err != nil {
		return "", 0, err
	}
	addr := listener.Addr().(*net.TCPAddr)
	port = addr.Port

	sessCtx, cancel := context.WithCancel(context.Background())
	sid := sessionID // capture for closure
	sess := &Session{
		SessionID:  sessionID,
		Port:       port,
		Listener:   listener,
		ApiID:      apiID,
		HostID:     hostID,
		cancel:     cancel,
		log:        s.log,
		sender:     s.sender,
		agentReady: make(chan AgentResult, 1),
		removeFromMap: func() {
			s.mu.Lock()
			delete(s.sessions, sid)
			s.mu.Unlock()
		},
	}
	sess.touchActivity()

	s.sessions[sessionID] = sess

	if s.log != nil {
		s.log.Info("rdp proxy session created", "session_id", sessionID, "port", port, "host_id", hostID)
	}

	go sess.acceptLoop(sessCtx)
	go sess.timeoutLoop(sessCtx)

	return sessionID, port, nil
}

// SendToAgent sends a message to the agent owning the named session. Writes
// are serialised by the registry's per-agent write mutex.