aboutsummaryrefslogtreecommitdiff
path: root/test/bun.js/socket/echo.js
diff options
context:
space:
mode:
Diffstat (limited to 'test/bun.js/socket/echo.js')
-rw-r--r--test/bun.js/socket/echo.js76
1 files changed, 0 insertions, 76 deletions
diff --git a/test/bun.js/socket/echo.js b/test/bun.js/socket/echo.js
deleted file mode 100644
index f02637739..000000000
--- a/test/bun.js/socket/echo.js
+++ /dev/null
@@ -1,76 +0,0 @@
-function createOptions(type, message, closeOnDone) {
- let buffers = [];
- let report = function () {
- report = function () {};
- const data = new Uint8Array(
- buffers.reduce(function (sum, buffer) {
- return sum + buffer.length;
- }, 0),
- );
- buffers.reduce(function (offset, buffer) {
- data.set(buffer, offset);
- return offset + buffer.length;
- }, 0);
- console.log(type, "GOT", new TextDecoder().decode(data));
- };
-
- let done = closeOnDone
- ? function (socket, sent) {
- socket.data[sent ? "sent" : "received"] = true;
- if (socket.data.sent && socket.data.received) {
- done = function () {};
- closeOnDone(socket);
- }
- }
- : function () {};
-
- function drain(socket) {
- const message = socket.data.message;
- const written = socket.write(message);
- if (written < message.length) {
- socket.data.message = message.slice(written);
- } else {
- done(socket, true);
- }
- }
-
- return {
- hostname: "localhost",
- port: 12345,
- socket: {
- close() {
- report();
- console.log(type, "CLOSED");
- },
- data(socket, buffer) {
- buffers.push(buffer);
- done(socket);
- },
- drain: drain,
- // end() {
- // report();
- // console.log(type, "ENDED");
- // },
- error(socket, err) {
- console.log(type, "ERRED", err);
- },
- open(socket) {
- console.log(type, "OPENED");
- drain(socket);
- },
- },
- data: {
- sent: false,
- received: false,
- message: message,
- },
- };
-}
-
-const server = Bun.listen(
- createOptions("[Server]", "response", socket => {
- server.stop();
- socket.end();
- }),
-);
-Bun.connect(createOptions("[Client]", "request"));