lint: fix some of the eslint errors

Author: aminya

.eslintrc

@@ -7,7 +7,20 @@
     "eslint-config-atomic"
   ],
   "rules": {
-    "@typescript-eslint/quotes": ["error", "double"]
+    "@typescript-eslint/quotes": [
+      "error",
+      "double"
+    ],
+    "require-await": "off"
   },
-  "ignorePatterns": ["node_modules/", "build/", "lib/", "libzmq/", "tmp/", "zmq/", "v5-compat.d.ts", "draft.d.ts"]
+  "ignorePatterns": [
+    "node_modules/",
+    "build/",
+    "lib/",
+    "libzmq/",
+    "tmp/",
+    "zmq/",
+    "v5-compat.d.ts",
+    "draft.d.ts"
+  ]
 }

package.json

@@ -86,9 +86,9 @@
     "build.debug": "run-p build.js build.native.debug",
     "test": "run-s build && mocha",
     "test.skip_gc_tests": "run-s build.debug && cross-env SKIP_GC_TESTS=true mocha",
-    "lint.clang-format": "clang-format -i -style=file src/*.{cc,h} src/*/*.h",
+    "lint.clang-format": "clang-format -i -style=file ./src/*.cc ./src/*.h ./src/util/*.h",
     "lint-test.eslint": "eslint **/*.{ts,tsx,js,jsx,cjs,mjs,json,yaml} --no-error-on-unmatched-pattern --cache --cache-location ./.cache/eslint/",
-    "lint.eslint": "run-s lint-test.eslint -- --fix",
+    "lint.eslint": "pnpm run lint-test.eslint -- --fix",
     "lint": "run-p lint.eslint lint.clang-format",
     "lint-test": "run-s lint-test.eslint",
     "bench": "node --expose-gc test/bench"

test/.eslintrc

@@ -10,6 +10,7 @@
     "@typescript-eslint/no-explicit-any": "off",
     "@typescript-eslint/no-unused-vars": "off",
     "@typescript-eslint/explicit-function-return-type": "off",
-    "no-await-in-loop": "off"
+    "no-await-in-loop": "off",
+    "require-await": "off"
   }
 }

test/unit/compat/socket-monitor-test.js

@@ -3,6 +3,7 @@ if (process.env.INCLUDE_COMPAT_TESTS) {
   const semver = require("semver")
   const {assert} = require("chai")
   const {testProtos, uniqAddress} = require("../helpers")
+  const {isFullError} = require("../../src/errors")
 
   /* This test case only seems to work reliably with TCP. */
   for (const proto of testProtos("tcp")) {

test/unit/socket-draft-radio-dish-test.ts

@@ -48,7 +48,9 @@ if (zmq.capability.draft) {
 
           const send = async () => {
             /* Wait briefly before publishing to avoid slow joiner syndrome. */
-            await new Promise(resolve => setTimeout(resolve, 25))
+            await new Promise(resolve => {
+              setTimeout(resolve, 25)
+            })
             for (const msg of messages) {
               await radio.send(msg, {group: uuid})
             }
@@ -92,7 +94,9 @@ if (zmq.capability.draft) {
 
           const send = async () => {
             /* Wait briefly before publishing to avoid slow joiner syndrome. */
-            await new Promise(resolve => setTimeout(resolve, 25))
+            await new Promise(resolve => {
+              setTimeout(resolve, 25)
+            })
             for (const msg of messages) {
               await radio.send(msg, {group: msg.slice(0, 2)})
             }

test/unit/socket-pub-sub-test.ts

@@ -39,7 +39,9 @@ for (const proto of testProtos("tcp", "ipc", "inproc")) {
 
         const send = async () => {
           /* Wait briefly before publishing to avoid slow joiner syndrome. */
-          await new Promise(resolve => setTimeout(resolve, 25))
+          await new Promise(resolve => {
+            setTimeout(resolve, 25)
+          })
           for (const msg of messages) {
             await pub.send(msg)
           }
@@ -80,7 +82,9 @@ for (const proto of testProtos("tcp", "ipc", "inproc")) {
 
         const send = async () => {
           /* Wait briefly before publishing to avoid slow joiner syndrome. */
-          await new Promise(resolve => setTimeout(resolve, 25))
+          await new Promise(resolve => {
+            setTimeout(resolve, 25)
+          })
           for (const msg of messages) {
             await pub.send(msg)
           }

test/unit/socket-xpub-xsub-test.ts

@@ -50,7 +50,9 @@ for (const proto of testProtos("tcp", "ipc", "inproc")) {
 
         const send = async () => {
           /* Wait briefly before publishing to avoid slow joiner syndrome. */
-          await new Promise(resolve => setTimeout(resolve, 25))
+          await new Promise(resolve => {
+            setTimeout(resolve, 25)
+          })
           for (const msg of messages) {
             await pub.send(msg)
           }
@@ -117,7 +119,9 @@ for (const proto of testProtos("tcp", "ipc", "inproc")) {
 
         const send = async () => {
           /* Wait briefly before publishing to avoid slow joiner syndrome. */
-          await new Promise(resolve => setTimeout(resolve, 25))
+          await new Promise(resolve => {
+            setTimeout(resolve, 25)
+          })
 
           for (const msg of messages) {
             await pub.send(msg)
@@ -176,7 +180,9 @@ for (const proto of testProtos("tcp", "ipc", "inproc")) {
         await sub2.connect(address)
 
         const subscribe = async () => {
-          await new Promise(resolve => setTimeout(resolve, 25))
+          await new Promise(resolve => {
+            setTimeout(resolve, 25)
+          })
           sub1.subscribe("fo")
           sub2.subscribe("fo")
           sub2.unsubscribe("fo")
@@ -213,7 +219,9 @@ for (const proto of testProtos("tcp", "ipc", "inproc")) {
         await sub2.connect(address)
 
         const subscribe = async () => {
-          await new Promise(resolve => setTimeout(resolve, 25))
+          await new Promise(resolve => {
+            setTimeout(resolve, 25)
+          })
           sub1.subscribe("fo")
           sub2.subscribe("fo")
           sub2.unsubscribe("fo")
@@ -258,7 +266,9 @@ for (const proto of testProtos("tcp", "ipc", "inproc")) {
         await sub2.connect(address)
 
         const subscribe = async () => {
-          await new Promise(resolve => setTimeout(resolve, 25))
+          await new Promise(resolve => {
+            setTimeout(resolve, 25)
+          })
           sub1.subscribe("fo")
           sub2.subscribe("fo")
           sub2.unsubscribe("fo")