deploying mp2 player

assets/disk0/tvdos/bin/playmp2.js

@@ -0,0 +1,220 @@
+const pcm = require("pcm")
+const interactive = exec_args[2] && exec_args[2].toLowerCase() == "/i"
+function printdbg(s) { if (0) serial.println(s) }
+
+
+class SequentialFileBuffer {
+
+    constructor(path, offset, length) {
+        if (Array.isArray(path)) throw Error("arg #1 is path(string), not array")
+
+        this.path = path
+        this.file = files.open(path)
+
+        this.offset = offset || 0
+        this.originalOffset = offset
+        this.length = length || this.file.size
+
+        this.seq = require("seqread")
+        this.seq.prepare(path)
+    }
+
+    readBytes(size, ptr) {
+        return this.seq.readBytes(size, ptr)
+    }
+
+    readStr(n) {
+        let ptr = this.seq.readBytes(n)
+        let s = ''
+        for (let i = 0; i < n; i++) {
+            if (i >= this.length) break
+            s += String.fromCharCode(sys.peek(ptr + i))
+        }
+        sys.free(ptr)
+        return s
+    }
+
+    unread(diff) {
+        let newSkipLen = this.seq.getReadCount() - diff
+        this.seq.prepare(this.path)
+        this.seq.skip(newSkipLen)
+    }
+
+    rewind() {
+        this.seq.prepare(this.path)
+    }
+
+    seek(p) {
+        this.seq.prepare(this.path)
+        this.seq.skip(p)
+    }
+
+    get byteLength() {
+        return this.length
+    }
+
+    get fileHeader() {
+        return this.seq.fileHeader
+    }
+
+    /*get remaining() {
+        return this.length - this.getReadCount()
+    }*/
+}
+
+
+
+
+
+let filebuf = new SequentialFileBuffer(_G.shell.resolvePathInput(exec_args[1]).full)
+const FILE_SIZE = filebuf.length - 100
+let FRAME_SIZE = audio.mp2GetInitialFrameSize(filebuf.fileHeader)
+
+
+let bytes_left = FILE_SIZE
+let decodedLength = 0
+
+
+//serial.println(`Frame size: ${FRAME_SIZE}`)
+
+
+
+function decodeAndResample(inPtrL, inPtrR, outPtr, inputLen) {
+    // TODO resample
+    for (let k = 0; k < inputLen; k+=2) {
+        let sample = [
+            pcm.u16Tos16(sys.peek(inPtrL + k + 0) | (sys.peek(inPtrL + k + 1) << 8)),
+            pcm.u16Tos16(sys.peek(inPtrR + k + 0) | (sys.peek(inPtrR + k + 1) << 8))
+        ]
+        sys.poke(outPtr + k, pcm.s16Tou8(sample[0]))
+        sys.poke(outPtr + k + 1, pcm.s16Tou8(sample[1]))
+    }
+}
+function decodeEvent(frameSize, len) {
+
+    let t2 = sys.nanoTime()
+
+//    printdbg(`Audio queue size: ${audio.getPosition(0)}/${QUEUE_MAX}`)
+
+    if (audio.getPosition(0) >= QUEUE_MAX) {
+        while (audio.getPosition(0) >= (QUEUE_MAX >>> 1)) {
+            printdbg(`Queue full, waiting until the queue has some space (${audio.getPosition(0)}/${QUEUE_MAX})`)
+            sys.sleep(bufRealTimeLen)
+        }
+    }
+
+
+    decodeAndResample(samplePtrL, samplePtrR, decodePtr, len)
+    audio.putPcmDataByPtr(decodePtr, len, 0)
+    audio.setSampleUploadLength(0, len)
+    audio.startSampleUpload(0)
+
+    sys.sleep(10)
+
+    let decodingTime = (t2 - t1) / 1000000.0
+    bufRealTimeLen = (len) / 64000.0 * 1000
+    t1 = t2
+
+//    println(`Decoded ${decodedLength} bytes; target: ${bufRealTimeLen} ms, lag: ${decodingTime - bufRealTimeLen} ms`)
+}
+
+
+con.curs_set(0)
+con.curs_set(0)
+if (interactive) {
+    println("Push and hold Backspace to exit")
+}
+let [cy, cx] = con.getyx()
+let [__, CONSOLE_WIDTH] = con.getmaxyx()
+let paintWidth = CONSOLE_WIDTH - 16
+function bytesToSec(i) {
+    // using fixed value: FRAME_SIZE(216) bytes for 36 ms on sampling rate 32000 Hz
+    return i / (FRAME_SIZE * 1000 / bufRealTimeLen)
+}
+function secToReadable(n) {
+    let mins = ''+((n/60)|0)
+    let secs = ''+(n % 60)
+    return `${mins.padStart(2,'0')}:${secs.padStart(2,'0')}`
+}
+function printPlayBar(currently) {
+    if (interactive) {
+        let currently = decodedLength
+        let total = FILE_SIZE
+
+        let currentlySec = Math.round(bytesToSec(currently))
+        let totalSec = Math.round(bytesToSec(total))
+
+        con.move(cy, 1)
+        print(' '.repeat(15))
+        con.move(cy, 1)
+
+        print(`${secToReadable(currentlySec)} / ${secToReadable(totalSec)}`)
+
+        con.move(cy, 15)
+        print(' ')
+        let progressbar = '\x84205u'.repeat(paintWidth + 1)
+        print(progressbar)
+
+        con.mvaddch(cy, 16 + Math.round(paintWidth * (currently / total)), 0xDB)
+    }
+}
+
+
+
+audio.resetParams(0)
+audio.purgeQueue(0)
+audio.setPcmMode(0)
+audio.setPcmQueueCapacityIndex(0, 2) // queue size is now 8
+const QUEUE_MAX = audio.getPcmQueueCapacity(0)
+audio.setMasterVolume(0, 255)
+audio.play(0)
+
+
+let mp2context = audio.mp2Init()
+
+// decode frame
+let frame = sys.malloc(FRAME_SIZE)
+let samplePtrL = sys.malloc(2304) // 16b samples
+let samplePtrR = sys.malloc(2304) // 16b samples
+let decodePtr = sys.malloc(2304) // 8b samples
+let t1 = sys.nanoTime()
+let bufRealTimeLen = 36
+let stopPlay = false
+let errorlevel = 0
+try {
+    while (bytes_left >= 0 && !stopPlay) {
+
+        if (interactive) {
+            sys.poke(-40, 1)
+            if (sys.peek(-41) == 67) {
+                stopPlay = true
+            }
+        }
+
+        printPlayBar()
+
+        filebuf.readBytes(FRAME_SIZE, frame)
+        bytes_left -= FRAME_SIZE
+        decodedLength += FRAME_SIZE
+
+        let [frameSize, samples] = audio.mp2DecodeFrame(mp2context, frame, true, samplePtrL, samplePtrR)
+        if (frameSize) {
+//            println(samples)
+            // play using decodedLR
+            decodeEvent(frameSize, samples)
+            FRAME_SIZE = frameSize // JUST IN CASE when a vbr mp2 is not filtered and played thru
+        }
+    }
+}
+catch (e) {
+    printerrln(e)
+    errorlevel = 1
+}
+finally {
+    sys.free(frame)
+    sys.free(decodePtr)
+    sys.free(samplePtrL)
+    sys.free(samplePtrR)
+}
+
+return errorlevel

assets/disk0/tvdos/bin/playmp3.js

@@ -170,6 +170,7 @@ function printPlayBar(currently) {
     }
 }
 let t1 = sys.nanoTime()
+let errorlevel = 0
 let bufRealTimeLen = 36
 try {
     decoder.decode((ptr, len, pos)=>{
@@ -217,10 +218,15 @@ try {
     }) // now you got decoded PCM data
 }
 catch (e) {
-    if (e != "STOP") throw e
+    if (e != "STOP") {
+        printerrln(e)
+        errorlevel = 1
+    }
 }
 finally {
     //audio.stop(0)
     sys.free(readPtr)
     sys.free(decodePtr)
-}
+}
+
+return errorlevel

assets/disk0/tvdos/bin/playpcm.js

@@ -108,6 +108,8 @@ function printPlayBar() {
         con.mvaddch(cy, 16 + Math.round(paintWidth * (currently / total)), 0xDB)
     }
 }
+let errorlevel = 0
+try {
 while (!stopPlay && seqread.getReadCount() < FILE_SIZE && readLength > 0) {
     if (interactive) {
         sys.poke(-40, 1)
@@ -155,8 +157,16 @@ while (!stopPlay && seqread.getReadCount() < FILE_SIZE && readLength > 0) {
 
     sys.sleep(10)
 }
+}
+catch (e) {
+    printerrln(e)
+    errorlevel = 1
+}
+finally {
+    //audio.stop(0)
+    if (readPtr !== undefined) sys.free(readPtr)
+    if (decodePtr !== undefined) sys.free(decodePtr)
+}
 
+return errorlevel
 
-//audio.stop(0)
-if (readPtr !== undefined) sys.free(readPtr)
-if (decodePtr !== undefined) sys.free(decodePtr)

assets/disk0/tvdos/bin/playwav.js

@@ -127,7 +127,9 @@ function printPlayBar(startOffset) {
         con.mvaddch(cy, 16 + Math.round(paintWidth * (currently / total)), 0xDB)
     }
 }
+let errorlevel = 0
 // read chunks loop
+try {
 while (!stopPlay && seqread.getReadCount() < FILE_SIZE - 8) {
     let chunkName = seqread.readFourCC()
     let chunkSize = seqread.readInt()
@@ -267,7 +269,15 @@ while (!stopPlay && seqread.getReadCount() < FILE_SIZE - 8) {
     printdbg(`remainingBytes2 = ${remainingBytes}`)
     sys.spin()
 }
+}
+catch (e) {
+    printerrln(e)
+    errorlevel = 1
+}
+finally {
+    //audio.stop(0)
+    if (readPtr !== undefined) sys.free(readPtr)
+    if (decodePtr !== undefined) sys.free(decodePtr)
+}
 
-//audio.stop(0)
-if (readPtr !== undefined) sys.free(readPtr)
-if (decodePtr !== undefined) sys.free(decodePtr)
+return errorlevel