aboutsummaryrefslogtreecommitdiff
path: root/test/js/node/net/node-net.test.ts
diff options
context:
space:
mode:
authorGravatar Colin McDonnell <colinmcd94@gmail.com> 2023-03-22 15:01:01 -0700
committerGravatar GitHub <noreply@github.com> 2023-03-22 15:01:01 -0700
commita5f92224b586289fc72f0abdb68b08eef9f017db (patch)
tree6092397858776820b431b0dffa635d8bc3b3185e /test/js/node/net/node-net.test.ts
parent2bdaa81b1c2325687c5115b4e97627533cb3646b (diff)
downloadbun-a5f92224b586289fc72f0abdb68b08eef9f017db.tar.gz
bun-a5f92224b586289fc72f0abdb68b08eef9f017db.tar.zst
bun-a5f92224b586289fc72f0abdb68b08eef9f017db.zip
Fix types (#2453)
* WIP * WIP * WIP * WIP * Improve typechecking in type files * Fix typechecking * Update * Update submodule * CI for typechecking * Add ci * Update commands * Format after build * Dont use bunx * Rename job * Use nodemodules prettier * Update workflow * Use symlink * Debug * Debug * Clean up and rename jobs
Diffstat (limited to 'test/js/node/net/node-net.test.ts')
-rw-r--r--test/js/node/net/node-net.test.ts80
1 files changed, 40 insertions, 40 deletions
diff --git a/test/js/node/net/node-net.test.ts b/test/js/node/net/node-net.test.ts
index 02348487f..cccada5c0 100644
--- a/test/js/node/net/node-net.test.ts
+++ b/test/js/node/net/node-net.test.ts
@@ -1,3 +1,4 @@
+import { ServerWebSocket, TCPSocket, Socket as _BunSocket, TCPSocketListener } from "bun";
import { afterAll, afterEach, beforeAll, beforeEach, describe, expect, it } from "bun:test";
import { connect, isIP, isIPv4, isIPv6, Socket } from "net";
import { realpathSync, mkdtempSync } from "fs";
@@ -38,9 +39,9 @@ describe("net.Socket read", () => {
["Hello!", "short message"],
]) {
describe(label, () => {
- function runWithServer(cb, unix_domain_path) {
- return done => {
- function drain(socket) {
+ function runWithServer(cb: (..._: any[]) => void, unix_domain_path?: any) {
+ return (done: (_: any) => void) => {
+ function drain(socket: _BunSocket<{ message: string }>) {
const message = socket.data.message;
const written = socket.write(message);
if (written < message.length) {
@@ -50,44 +51,42 @@ describe("net.Socket read", () => {
}
}
- var server = Bun.listen(
- unix_domain_path
- ? {
- unix: join(unix_domain_path, `${unix_servers++}.sock`),
- socket: {
- open(socket) {
- socket.data.message = message;
- drain(socket);
- },
- drain,
- error(socket, err) {
- done(err);
- },
+ var server = unix_domain_path
+ ? Bun.listen({
+ unix: join(unix_domain_path, `${unix_servers++}.sock`),
+ socket: {
+ open(socket) {
+ socket.data.message = message;
+ drain(socket);
},
- data: {
- message: "",
+ drain,
+ error(socket, err) {
+ done(err);
},
- }
- : {
- hostname: "localhost",
- port: 0,
- socket: {
- open(socket) {
- socket.data.message = message;
- drain(socket);
- },
- drain,
- error(socket, err) {
- done(err);
- },
+ },
+ data: {
+ message: "",
+ },
+ })
+ : Bun.listen({
+ hostname: "localhost",
+ port: 0,
+ socket: {
+ open(socket) {
+ socket.data.message = message;
+ drain(socket);
},
- data: {
- message: "",
+ drain,
+ error(socket, err) {
+ done(err);
},
},
- );
+ data: {
+ message: "",
+ },
+ });
- function onDone(err) {
+ function onDone(err: any) {
server.stop();
done(err);
}
@@ -237,11 +236,11 @@ describe("net.Socket write", () => {
const message = "Hello World!".repeat(1024);
let port = 53213;
- function runWithServer(cb) {
- return done => {
- let server;
+ function runWithServer(cb: (..._: any[]) => void) {
+ return (done: (_?: any) => void) => {
+ let server: TCPSocketListener<unknown>;
- function close(socket) {
+ function close(socket: _BunSocket<Buffer[]>) {
expect(Buffer.concat(socket.data).toString("utf8")).toBe(message);
done();
}
@@ -273,7 +272,7 @@ describe("net.Socket write", () => {
data: [] as Buffer[],
});
- function onDone(err) {
+ function onDone(err: any) {
server.stop();
done(err);
}
@@ -334,6 +333,7 @@ describe("net.Socket write", () => {
it("should handle connection error", done => {
var data = {};
+ // @ts-ignore
connect(55555, () => {
done(new Error("Should not have connected"));
}).on("error", error => {