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"));