Method runMainLoop

cli/src/cursor/cursorAcpRemoteLauncher.ts:53–219

()

    }

    protected async runMainLoop(): Promise<void> {
        const session = this.session;
        const messageBuffer = this.messageBuffer;

        const { server: happyServer, mcpServers } = await buildHapiMcpBridge(session.client);
        this.happyServer = happyServer;

        const backend = createCursorAcpBackend({ cwd: session.path, model: session.model });
        this.backend = backend;

        backend.setUsageUpdateListener((message) => this.handleAgentMessage(message));

        backend.onStderrError((error) => {
            logger.debug('[cursor-acp] stderr error', error);
            session.sendSessionEvent({ type: 'message', message: error.message });
            messageBuffer.addMessage(error.message, 'status');
        });

        try {
            await backend.initialize();
        } catch (error) {
            const errMsg = error instanceof Error ? error.message : String(error);
            throw new Error(`${CURSOR_ACP_REQUIRED_MESSAGE} (${errMsg})`);
        }

        await backend.authenticateIfAvailable('cursor_login');

        const extensionAdapter = new CursorExtensionAdapter(
            session.client,
            backend,
            (message) => this.handleAgentMessage(message)
        );
        this.extensionAdapter = extensionAdapter;

        this.permissionAdapter = new PermissionAdapter(
            session.client,
            backend,
            () => session.getPermissionMode(),
            (response) => extensionAdapter.handlePermissionResponse(response)
        );

        const resumeSessionId = session.sessionId;
        const mcpServerList = toAcpMcpServers(mcpServers);
        let acpSessionId: string;

        if (resumeSessionId && backend.supportsLoadSession()) {
            // Register pending cursorSessionId before awaiting session/load (Zed PR #54431).
            session.onSessionFoundWithProtocol(resumeSessionId, 'acp');
            try {
                acpSessionId = await backend.loadSession({
                    sessionId: resumeSessionId,
                    cwd: session.path,
                    mcpServers: mcpServerList
                });
            } catch (error) {
                logger.warn('[cursor-acp] session/load failed', error);
                throw new Error(
                    'Failed to resume Cursor ACP session. Legacy stream-json sessions cannot be loaded via ACP.'