!7

set flag OpusFromStream_debug.

set flag OggStreamPage_debug.

cm TestOpusFromStream > DynPrintLog {

  S oggSnippetID = #1400517;

  transient SimulatedPartialInputStream in;

  transient OpusFromStream opusReader;

  transient L<short[]> samples;

  // We simulate bytes trickling in with these variables

  switchable int firstChunk = 0;

  switchable int chunkSize = 512;

  start-thread {

    File f = loadLibrary(#1400517);

    printFileInfo(f);

    in = new SimulatedPartialInputStream(bufferedFileInputStream(f, OpusFromStream.bufferSizeNeeded()));

    in.cutOffPoint = firstChunk;

    samples = new L;

    temp opusReader = new OpusFromStream(in, 1);

    int safety = 0;

    while true {

      if (safety++ >= 1000) fail("SAFETY");

      var samples = opusReader.nextSamples();

      if (samples == null && in.streamEnded()) {

        print("Stream ended: " + in);

        break;

      }

      if (samples == null)

        in.cutOffPoint += chunkSize;

      print("samples", samples);

      addIfNotNull(TestOpusFromStream.this.samples, samples);

    }

    print("Iterations: " + safety);

    File wavFile = programFile("output.wav");

    multiShortArraysToWAVE(samples, wavFile, format := javaSound_opusMono());

    printFileInfo(wavFile);

    assertEqualsVerbose(355244L, fileSize(wavFile));

    showGraph();

  }

  void showGraph {

    var pcm = random(samples);

    if (empty(pcm)) ret;

    print("Chose PCM: " + l(pcm));

    dm_showImageAs("Decoded Audio Sample", shortArrayToGraph(pcm));

  }

}