Stream management to read sequentially

backend/database.js

@@ -49,29 +49,38 @@ sbp('sbp/selectors/register', {
     let counter = 0
     let currentHash = await sbp('chelonia/db/get', `_private_hidx=${contractID}#${height}`)
     let prefix = '['
+    let ended = false
     // NOTE: if this ever stops working you can also try Readable.from():
     // https://nodejs.org/api/stream.html#stream_stream_readable_from_iterable_options
     const stream = new Readable({
       read (): void {
+        if (ended) {
+          this.destroy()
+          return
+        }
         if (currentHash && counter < limit) {
           sbp('chelonia/db/getEntry', currentHash).then(async entry => {
             if (entry) {
-              this.push(`${prefix}"${strToB64(entry.serialize())}"`)
+              const currentPrefix = prefix
               prefix = ','
               counter++
               currentHash = await sbp('chelonia/db/get', `_private_hidx=${contractID}#${entry.height() + 1}`)
+              this.push(`${currentPrefix}"${strToB64(entry.serialize())}"`)
             } else {
               this.push(counter > 0 ? ']' : '[]')
               this.push(null)
+              ended = true
             }
           }).catch(e => {
             console.error(`[backend] streamEntriesAfter: read(): ${e.message}:`, e)
             this.push(counter > 0 ? ']' : '[]')
             this.push(null)
+            ended = true
           })
         } else {
           this.push(counter > 0 ? ']' : '[]')
           this.push(null)
+          ended = true
         }
       }
     })

frontend/views/containers/chatroom/ChatMain.vue

@@ -722,6 +722,7 @@ export default ({
 
           for (;;) {
             const { done, value: event } = await newEventsStreamReader.read()
+            console.error({ done, event })
             if (done) break
 
             const state = this.messageState.contract