test: convert socket event/messages to TypeScript

Author: aminya

test/unit/compat/socket-events-test.js renamed to test/unit/compat/socket-events-test.ts

@@ -1,15 +1,15 @@
-if (process.env.INCLUDE_COMPAT_TESTS) {
-  const zmq = require("./load")
-  const {assert} = require("chai")
-  const {testProtos, uniqAddress} = require("../helpers")
+import * as zmq from "../../../v5-compat"
+import {assert} from "chai"
+import {testProtos, uniqAddress} from "../helpers"
 
+if (process.env.INCLUDE_COMPAT_TESTS) {
   for (const proto of testProtos("tcp", "inproc")) {
     describe(`compat socket with ${proto} events`, function () {
-      it("should support events", function (done) {
+      it("should support events", async function (done) {
         const rep = zmq.socket("rep")
         const req = zmq.socket("req")
 
-        const address = uniqAddress(proto)
+        const address = await uniqAddress(proto)
 
         rep.on("message", function (msg) {
           assert.instanceOf(msg, Buffer)

test/unit/compat/socket-messages-test.js renamed to test/unit/compat/socket-messages-test.ts

@@ -1,20 +1,20 @@
-if (process.env.INCLUDE_COMPAT_TESTS) {
-  const zmq = require("./load")
-  const {assert} = require("chai")
-  const {testProtos, uniqAddress} = require("../helpers")
+import * as zmq from "../../../v5-compat"
+import {assert} from "chai"
+import {testProtos, uniqAddress} from "../helpers"
 
+if (process.env.INCLUDE_COMPAT_TESTS) {
   for (const proto of testProtos("tcp", "inproc")) {
     describe(`compat socket with ${proto} messages`, function () {
-      let push
-      let pull
+      let push: zmq.Socket
+      let pull: zmq.Socket
 
       beforeEach(function () {
         push = zmq.socket("push")
         pull = zmq.socket("pull")
       })
 
-      it("should support messages", function (done) {
-        const address = uniqAddress(proto)
+      it("should support messages", async function (done) {
+        const address = await uniqAddress(proto)
 
         let n = 0
 
@@ -43,8 +43,8 @@ if (process.env.INCLUDE_COMPAT_TESTS) {
         push.send(Buffer.from("buffer"))
       })
 
-      it("should support multipart messages", function (done) {
-        const address = uniqAddress(proto)
+      it("should support multipart messages", async function (done) {
+        const address = await uniqAddress(proto)
 
         pull.on("message", function (msg1, msg2, msg3) {
           assert.equal(msg1.toString(), "string")
@@ -60,8 +60,8 @@ if (process.env.INCLUDE_COMPAT_TESTS) {
         push.send(["string", 15.99, Buffer.from("buffer")])
       })
 
-      it("should support sndmore", function (done) {
-        const address = uniqAddress(proto)
+      it("should support sndmore", async function (done) {
+        const address = await uniqAddress(proto)
 
         pull.on("message", function (a, b, c, d, e) {
           assert.equal(a.toString(), "tobi")
@@ -82,8 +82,8 @@ if (process.env.INCLUDE_COMPAT_TESTS) {
       })
 
       if (proto != "inproc") {
-        it("should handle late connect", function (done) {
-          const address = uniqAddress(proto)
+        it("should handle late connect", async function (done) {
+          const address = await uniqAddress(proto)
           let n = 0
 
           pull.on("message", function (msg) {
@@ -115,8 +115,8 @@ if (process.env.INCLUDE_COMPAT_TESTS) {
         })
       }
 
-      it("should call send callbacks", function (done) {
-        const address = uniqAddress(proto)
+      it("should call send callbacks", async function (done) {
+        const address = await uniqAddress(proto)
         let received = 0
         let callbacks = 0