Method onNewSession

internal/bridge/register.go:15–36

onNewSession registers a CLIProxyAPI session as a C2 implant session.

(sess *sessions.Session)

// onNewSession registers a CLIProxyAPI session as a C2 implant session.
func (b *Bridge) onNewSession(sess *sessions.Session) {
	if _, loaded := b.registered.LoadOrStore(sess.ID, true); loaded {
		return
	}

	info := parseUserAgentFull(sess.UserAgent)
	if err := b.registerSessionRPC(sess, info); err != nil {
		log.Errorf("[bridge] failed to register session %s: %v", sess.ID, err)
		b.registered.Delete(sess.ID)
		return
	}

	// Pin session so the local session manager won't garbage collect it.
	sessions.Global().PinSession(sess.ID)

	// Notify any goroutines waiting for this session (e.g. modules dispatched
	// before the session was registered).
	b.notifySessionReady(sess.ID)

	// Start observing this session's events.
	go b.observeSession(sess.ID)
}

func (b *Bridge) registerSessionRPC(sess *sessions.Session, info agentInfo) error {
	// Use detected agent type as name if available (more accurate than UA parsing).