Added raw packets for realtime encode/decode

example/encoder.html

@@ -105,6 +105,7 @@ <h2>Log</h2>
           recordingGain: parseInt(recordingGain.value, 10),
           numberOfChannels: parseInt(numberOfChannels.value, 10),
           encoderSampleRate: parseInt(encoderSampleRate.value, 10),
+          rawPacket:true,
           encoderPath: "../dist/encoderWorker.min.js"
           // sourceNode: sourceNode
         };

src/decoderWorker.js

@@ -14,6 +14,12 @@ global['onmessage'] = function( e ){
         }
         break;
 
+      case 'decodeRawPacket':
+          if (decoder){
+            decoder.decodeRawPacket( e['data']['rawPacket'] );
+          }
+          break;        
+
       case 'done':
         if (decoder) {
           decoder.sendLastBuffer();
@@ -26,6 +32,7 @@ global['onmessage'] = function( e ){
         break;
 
       default:
+        console.warn("Unsupported Message");
         // Ignore any unknown commands and continue recieving commands
     }
   });
@@ -60,6 +67,25 @@ var OggOpusDecoder = function( config, Module ){
   this.outputBuffers = [];
 };
 
+OggOpusDecoder.prototype.decodeRawPacket = function(typedArray) {
+    if (!this.inited) {
+      this.numberOfChannels = typedArray[0] & 0x04 ? 2 : 1;
+      this.init();
+      this.inited = true;
+    }
+    this.decoderBuffer.set( typedArray );
+
+    // Decode raw opus packet
+    var outputSampleLength = this._opus_decode_float( this.decoder, this.decoderBufferPointer, typedArray.length, this.decoderOutputPointer, this.decoderOutputMaxLength, 0);
+    var resampledLength = Math.ceil( outputSampleLength * this.config.outputBufferSampleRate / this.config.decoderSampleRate );
+    this.HEAP32[ this.decoderOutputLengthPointer >> 2 ] = outputSampleLength;
+    this.HEAP32[ this.resampleOutputLengthPointer >> 2 ] = resampledLength;
+    this._speex_resampler_process_interleaved_float( this.resampler, this.decoderOutputPointer, this.decoderOutputLengthPointer, this.resampleOutputBufferPointer, this.resampleOutputLengthPointer );
+    this.sendToOutputBuffers( this.HEAPF32.subarray( this.resampleOutputBufferPointer >> 2, (this.resampleOutputBufferPointer >> 2) + resampledLength * this.numberOfChannels ) );
+    this.decoderBufferIndex = 0;
+
+    return;  
+}
 
 OggOpusDecoder.prototype.decode = function( typedArray ) {
   var dataView = new DataView( typedArray.buffer );

src/encoderWorker.js

@@ -144,6 +144,7 @@ OggOpusEncoder.prototype.getChecksum = function( data ){
 };
 
 OggOpusEncoder.prototype.generateCommentPage = function(){
+  if ( this.config.rawPacket ) { return; }
   var segmentDataView = new DataView( this.segmentData.buffer );
   segmentDataView.setUint32( 0, 1937076303, true ) // Magic Signature 'Opus'
   segmentDataView.setUint32( 4, 1936154964, true ) // Magic Signature 'Tags'
@@ -159,6 +160,7 @@ OggOpusEncoder.prototype.generateCommentPage = function(){
 };
 
 OggOpusEncoder.prototype.generateIdPage = function(){
+  if ( this.config.rawPacket ) { return; }
   var segmentDataView = new DataView( this.segmentData.buffer );
   segmentDataView.setUint32( 0, 1937076303, true ) // Magic Signature 'Opus'
   segmentDataView.setUint32( 4, 1684104520, true ) // Magic Signature 'Head'
@@ -175,6 +177,7 @@ OggOpusEncoder.prototype.generateIdPage = function(){
 };
 
 OggOpusEncoder.prototype.generatePage = function(){
+  if ( this.config.rawPacket ) { return; }
   var granulePosition = ( this.lastPositiveGranulePosition === this.granulePosition) ? -1 : this.granulePosition;
   var pageBuffer = new ArrayBuffer(  27 + this.segmentTableIndex + this.segmentDataIndex );
   var pageBufferView = new DataView( pageBuffer );
@@ -282,6 +285,17 @@ OggOpusEncoder.prototype.interleave = function( buffers ) {
 };
 
 OggOpusEncoder.prototype.segmentPacket = function( packetLength ) {
+  if (this.config.rawPacket) {
+    if (packetLength > 0) {
+      var page = new Uint8Array( HEAPU8.subarray(this.encoderOutputPointer, this.encoderOutputPointer + packetLength) );
+      if (postMessage) {
+        postMessage(page, [page.buffer]);
+      }
+      return;
+    }
+  }
+
+
   var packetIndex = 0;
   var exportPages = [];