relay-client.js

var WebSocketStream = require("websocket-stream")
var split = require("split")
var through = require("through")
var location = require("global/window").location

var EngineIOClient = require("./engine.io-client")

module.exports = RelayClient

function RelayClient(uri) {
    var socket = EngineIOClient("ws://" + location.host, {
        transports: ["polling", "websocket"],
        path: "/relay/engine.io",
        query: { uri: uri }
    })

    // socket.on("open", function () {
    //     console.log("OPEN SOCKET")
    // })

    // socket.on("close", function () {
    //     console.log("CLOSED SOCKET")
    // })

    // socket.on("end", function () {
    //     console.log("ENDED SOCKET")
    // })

    return WebSocketStream(socket)
        .pipe(split())
        .pipe(through(function (chunk) {
            if (chunk === "") {
                return
            }

            this.push(JSON.parse(String(chunk)))
        }))
}