Control socket pause.

Author: zobo

package.json

@@ -48,6 +48,7 @@
     "@xmldom/xmldom": "^0.9.8",
     "buffer-crc32": "^1.0.0",
     "dotenv": "^17.2.1",
+    "abstract-socket": "^2.1.1",
     "file-url": "^3.0.0",
     "iconv-lite": "^0.6.3",
     "minimatch": "^10.0.3",

src/abstract-socket.d.ts

@@ -0,0 +1,13 @@
+/// <reference types="node" />
+declare module "abstract-socket" {
+    export function createServer(listener: any): AbstractSocketServer;
+    export function connect(name: any, connectListener: any): net.Socket;
+    export function createConnection(name: any, connectListener: any): net.Socket;
+    class AbstractSocketServer extends net.Server {
+        // constructor(listener: any);
+        // listen(path: string, listener: () => void): net.Socket;
+        // listen(path: string, listeningListener?: () => void): this;
+    }
+    import net = require("net");
+    export {};
+}

src/phpDebug.ts

@@ -21,6 +21,7 @@ import { shouldIgnoreException } from './ignore'
 import { varExportProperty } from './varExport'
 import { supportedEngine } from './xdebugUtils'
 import { varJsonProperty } from './varJson'
+import * as abs from 'abstract-socket'
 
 if (process.env['VSCODE_NLS_CONFIG']) {
     try {
@@ -1432,10 +1433,47 @@ class PhpDebugSession extends vscode.DebugSession {
         }
     }
 
-    protected pauseRequest(
+    protected async pauseRequest(
         response: VSCodeDebugProtocol.PauseResponse,
         args: VSCodeDebugProtocol.PauseArguments
-    ): void {
+    ): Promise<void> {
+        // test
+        let connection: xdebug.Connection | undefined
+        connection = this._connections.get(args.threadId)
+        if (!connection) {
+            return this.sendErrorResponse(response, new Error(`Unknown thread ID ${args.threadId}`))
+        }
+
+        let initPacket = await connection.waitForInitPacket()
+        const supportedControl =
+            process.platform === 'linux' &&
+            initPacket.engineName === 'Xdebug' &&
+            semver.valid(initPacket.engineVersion, { loose: true }) &&
+            (semver.gte(initPacket.engineVersion, '3.4.0', { loose: true }) || initPacket.engineVersion === '3.4.0-dev')
+
+        if (supportedControl) {
+            let cs = `\0xdebug-ctrl.${initPacket.appId}y`.padEnd(108, 'x')
+            try {
+                const sock = abs.connect(cs, () => {
+                    sock.write("pause\0")
+                    if (this._skippingFiles.has(args.threadId)) {
+                        this._skippingFiles.set(args.threadId, false)
+                    }
+                    this.sendResponse(response)
+                })
+                sock.on('data', (data) => {
+                    // todo
+                })
+                sock.on('error', (error) => {
+                    this.sendErrorResponse(response, new Error('Cannot connect to Xdebug control socket'))    
+                })
+                return
+            } catch (error) {
+                this.sendErrorResponse(response, new Error('Cannot connect to Xdebug control socket'))
+                return
+            }
+        }
+        // test
         if (this._skippingFiles.has(args.threadId)) {
             this._skippingFiles.set(args.threadId, false)
             this.sendResponse(response)