queue.js

var WebSocket = require("@oznu/ws-connect");
var config = require("./config.json");

var debugFlag = false;

var serverid = "devserver";

var url = config.settings.server;
console.log("Connecting to %s", url);
var ws = new WebSocket(url);

var readline = require("readline");
var rl = readline.createInterface({
    input: process.stdin,
    output: process.stdout,
    terminal: false
});

rl.on("line", function (line) {
    if (line == "") {
        return;
    }

    try {
        var track = JSON.parse(line);
    } catch (e) {
        console.log("INVALID", e);
        return;
    }

    track.serverid = serverid;
    track.channel = config.settings.channel;
    track.nickname = "fakeuser";

    ws.send(JSON.stringify(track));
});

ws.on("open", function open() {
    console.log("Connection open");
});

ws.on("message", function incoming(data) {
    if (debugFlag || data.action == "PLAYING") {
        console.log(data);
    }
});