How I would go about sending offers/answers with hyperswarm

index.js

let HyperSwarm = require("hyperswarm");
let sodium = require("sodium-universal");
let ndjson = require("ndjson");
let { RTCPeerConnection, RTCSessionDescription } = require("wrtc");

let swarm = HyperSwarm();
let { crypto_generichash, crypto_generichash_BYTES } = sodium;
let rtcConnection = new RTCPeerConnection();

(() => {
  let channelKey = Buffer.alloc(crypto_generichash_BYTES);

  crypto_generichash(channelKey, Buffer.from("test-webrtc"));

  //   let channelKeyString = channelKey.toString("hex");

  swarm.join(channelKey, {
    announce: true,
    lookup: true,
  });

  swarm.once("connection", (connection, information) => {
    let incoming = ndjson.parse();
    let outgoing = ndjson.stringify();

    connection.pipe(incoming);
    outgoing.pipe(connection);

    rtcConnection
      .createOffer()
      .then((offer) =>
        rtcConnection.setLocalDescription(new RTCSessionDescription(offer))
      )
      .then(() =>
        outgoing.write({
          type: "offerDescription",
          offerDescription: rtcConnection.localDescription,
        })
      );

    incoming.on("data", (chunk) => {
      let { type } = chunk;

      switch (type) {
        case "offerDescription":
          let { offerDescription } = chunk;

          rtcConnection.setRemoteDescription(offerDescription);
          rtcConnection
            .createAnswer()
            .then((answer) =>
              rtcConnection.setLocalDescription(
                new RTCSessionDescription(answer)
              )
            )
            .then(() => {
              outgoing.write({
                type: "answerDescription",
                answerDescription: rtcConnection.localDescription,
              });

              console.log(rtcConnection.signalingState);

              swarm.leave();
            });

          break;

        case "answerDescription":
          let { answerDescription } = chunk;

          rtcConnection.setRemoteDescription(answerDescription);

          console.log(rtcConnection.signalingState);

          swarm.leave();

          break;

        default:
          break;
      }
    });
  });
})();