hotfix port discovery

executor/package.json

@@ -1,7 +1,7 @@
 {
 	"name": "@acala-network/chopsticks-executor",
 	"description": "Chopsticks executor",
-	"version": "0.9.11",
+	"version": "0.9.12",
 	"license": "Apache-2.0",
 	"type": "module",
 	"repository": {

packages/chopsticks/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@acala-network/chopsticks",
-	"version": "0.9.11",
+	"version": "0.9.12",
 	"author": "Acala Developers <[email protected]>",
 	"license": "Apache-2.0",
 	"bin": "./chopsticks.cjs",

packages/chopsticks/src/server.ts

@@ -57,6 +57,27 @@ const respond = (res: http.ServerResponse, data?: any) => {
   res.end()
 }
 
+const portInUse = async (port: number) => {
+  const server = http.createServer()
+  const inUse = await new Promise<boolean>((resolve) => {
+    server.once('error', (e: any) => {
+      if (e.code === 'EADDRINUSE') {
+        resolve(true)
+      } else {
+        resolve(false)
+      }
+    })
+    server.once('listening', () => {
+      server.close()
+      resolve(false)
+    })
+    server.listen(port)
+  })
+  server.removeAllListeners()
+  server.unref()
+  return inUse
+}
+
 export const createServer = async (handler: Handler, port: number) => {
   let wss: WebSocketServer | undefined
   let listenPort: number | undefined
@@ -118,24 +139,25 @@ export const createServer = async (handler: Handler, port: number) => {
   })
 
   for (let i = 0; i < 10; i++) {
+    if (port && (await portInUse(port + i))) {
+      continue
+    }
     const preferPort = port ? port + i : undefined
     wsLogger.debug('Try starting on port %d', preferPort)
-    const success = await new Promise<boolean>((resolve) => {
-      server.once('error', (e: any) => {
-        if (e.code === 'EADDRINUSE') {
-          server.close()
-          resolve(false)
-        }
-      })
+    await new Promise<void>((resolve, reject) => {
+      const onError = (e: Error) => {
+        server.close()
+        reject(e)
+      }
+      server.once('error', onError)
       server.listen(preferPort, () => {
         wss = new WebSocketServer({ server, maxPayload: 1024 * 1024 * 100 })
         listenPort = (server.address() as AddressInfo).port
-        resolve(true)
+        server.removeListener('error', onError)
+        resolve()
       })
     })
-    if (success) {
-      break
-    }
+    break
   }
 
   if (!wss || !listenPort) {

packages/core/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@acala-network/chopsticks-core",
-	"version": "0.9.11",
+	"version": "0.9.12",
 	"author": "Acala Developers <[email protected]>",
 	"license": "Apache-2.0",
 	"type": "module",

packages/db/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@acala-network/chopsticks-db",
-	"version": "0.9.11",
+	"version": "0.9.12",
 	"author": "Acala Developers <[email protected]>",
 	"license": "Apache-2.0",
 	"type": "module",

packages/e2e/src/genesis-provider.test.ts

@@ -13,7 +13,7 @@ describe.each([
   ['Asset Hub Kusama', new URL('../blobs/asset-hub-kusama.json', import.meta.url).pathname],
 ])(`genesis provider works %s`, async (name, genesis) => {
   const { chain, dev, api, teardown } = await setupContextWithConfig({
-    port: 0,
+    port: 1234,
     genesis,
     'build-block-mode': BuildBlockMode.Manual,
   })

packages/testing/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@acala-network/chopsticks-testing",
-	"version": "0.9.11",
+	"version": "0.9.12",
 	"author": "Acala Developers <[email protected]>",
 	"license": "Apache-2.0",
 	"type": "module",

packages/utils/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@acala-network/chopsticks-utils",
-	"version": "0.9.11",
+	"version": "0.9.12",
 	"author": "Acala Developers <[email protected]>",
 	"license": "Apache-2.0",
 	"type": "module",