Playing binary data stream? about aurora.js HOT 11 CLOSED

// create a buffer
var buf = new Buffer(YOUR_BUFFER);

// the known format (usually embedded in the container format)
var format = {
    formatID: 'flac',
    sampleRate: 44100,
    channelsPerFrame: 2,
    bitsPerChannel: 16
};

// the cookie used by the decoder (usually embedded in the container)
var cookie = {
    maxBlockSize: 4096,
    maxFrameSize: 14323,
    minBlockSize: 4096,
    minFrameSize: 1751
};

// create a fake source event emitter
var source = new EventEmitter;

// create the decoder
var decoder = new FLACDecoder(source, format);

// emit the cookie
source.emit('cookie', cookie);

// emit the buffer of audio data to the decoder
source.emit('data', buf);

// create a queue to hold decoded chunks
var queue = new Queue(decoder);

// create an AudioDevice for playback
var device = AudioDevice.create(format.sampleRate, format.channelsPerFrame);

// read the first frame
var frame = queue.read();
var frameOffset = 0;
var div = decoder.floatingPoint ? 1 : Math.pow(2, format.bitsPerChannel - 1);

// start listening for the device's refill event
device.on('refill', function(buffer) {
    var bufferOffset = 0;

    // write the decoded frames into the buffer
    while (frame && bufferOffset < buffer.length) {
        var max = Math.min(frame.length - frameOffset, buffer.length - bufferOffset);
        for (var i = 0; i < max; i++) {
            buffer[bufferOffset++] = frame[frameOffset++] / div;
        }

        if (frameOffset === frame.length) {
            frame = queue.read();
            frameOffset = 0;
        }
    }

    // if we ran out of data, stop the device
    if (!frame) {
        device.off('refill', arguments.callee);
    }
});

// Implement a source (see https://github.com/ofmlabs/aurora.js/wiki/Source-Interface-Reference)
var MySource = EventEmitter.extend({
    start: function() {
        // emit some data
        this.emit('data', YOUR_BUFFER);
        this.emit('end');
    },

    pause: function() {
        // stop
    },

    reset: function() {}
});

// create a source, asset and player
var source = new MySource();
var asset = new Asset(source);
var player = new Player(asset);

player.play();

var BASE64_MARKER = ';base64,';

function convertDataURIToBinary(dataURI) {
  var base64Index = dataURI.indexOf(BASE64_MARKER) + BASE64_MARKER.length;
  var base64 = dataURI.substring(base64Index);
  var raw = window.atob(base64);
  var rawLength = raw.length;
  var array = new Uint8Array(new ArrayBuffer(rawLength));

  for(i = 0; i < rawLength; i++) {
    array[i] = raw.charCodeAt(i);
  }
  return array;
}

var socket = io.connect('/');
var num = 0;
var source;
var asset;
var player;
socket.on('message', function(data) {
    var abData = new Buffer(convertDataURIToBinary(data));
    if (num == 0) {
        // Implement a source (see https://github.com/ofmlabs/aurora.js/wiki/Source-Interface-Reference)
        var MySource = EventEmitter.extend({
            start: function() {
                // emit some data
                this.emit('data', abData);
                this.emit('end');
            },

            pause: function() {
                // stop
            },

            reset: function() {}
        });

        // create a source, asset and player
        source = new MySource();
        asset = new Asset(source);
        player = new Player(asset);
        console.log(source);
        player.play();
        console.log(player);
    } else {
        source.emit('data', abData);
        this.emit('end');
    }
    num++;
});

var array = new Uint8Array(rawLength);
for(var i = 0; i < rawLength; i++) {
    array[i] = raw.charCodeAt(i) & 0xff;
}

var MySource = EventEmitter.extend({
    start: function() {
        var source = this
        source.socket = io.connect('/');
        source.socket.on('message', function(data) {
            var abData = new Buffer(convertDataURIToBinary(data));
            source.emit('data', abData);

            if (LAST_CHUNK) {
                source.emit('end');
            }
        });
    },

    pause: function() {
        this.socket.disconnect();
        delete this.socket;
    },

    reset: function() {}
});

// create a source, asset and player
var source = new MySource();
var asset = new Asset(source);
var player = new Player(asset);

player.play();