test: add helper for cleaning ipc temp files

Author: aminya

test/unit/helpers.ts

@@ -84,6 +84,19 @@ export async function uniqAddress(proto: Proto) {
   }
 }
 
+export async function cleanSocket(address: string) {
+  const [proto, path] = address.split("://")[1]
+  if (proto !== "ipc" || !path) {
+    return
+  }
+  const exists = await fs.promises
+    .access(path, fs.constants.F_OK)
+    .catch(() => false)
+  if (exists) {
+    await fs.promises.rm(path)
+  }
+}
+
 export function testProtos(...requested: Proto[]) {
   const set = new Set(requested)
 

test/unit/proxy-router-dealer-test.ts

@@ -2,7 +2,7 @@ import * as semver from "semver"
 import * as zmq from "../../src"
 
 import {assert} from "chai"
-import {testProtos, uniqAddress} from "./helpers"
+import {cleanSocket, testProtos, uniqAddress} from "./helpers"
 
 for (const proto of testProtos("tcp", "ipc", "inproc")) {
   describe(`proxy with ${proto} router/dealer`, function () {
@@ -29,14 +29,15 @@ for (const proto of testProtos("tcp", "ipc", "inproc")) {
       rep = new zmq.Reply()
     })
 
-    afterEach(function () {
+    afterEach(async function () {
       /* Closing proxy sockets is only necessary if run() fails. */
       proxy.frontEnd.close()
       proxy.backEnd.close()
 
       req.close()
       rep.close()
       global.gc?.()
+      await Promise.all([cleanSocket(frontAddress), cleanSocket(backAddress)])
     })
 
     describe("run", function () {