OutputAreaReplay.kt

src/jvmMain/kotlin/afield/ui/output/OutputAreaReplay.kt · 75 lines

package afield.ui.output

import afield.app.protocol.put
import afield.data.table.div
import afield.data.table.get
import afield.data.table.minus
import afield.data.table.plus
import afield.data.table.rem
import afield.data.table.times
import afield.document.graph.box
import afield.runtime.execution.plus
import afield.runtime.lifecycle.plus
import afield.runtime.lifecycle.rem

import afield.app.protocol.Message
import afield.app.protocol.OutputControl
import afield.app.protocol.Set_output
import afield.app.protocol.payload
import afield.audio.synth.*
import afield.graphics.vulkan.*
import afield.media.stream.*
import afield.media.video.*

The panels a live box has shown, kept so that a page attaching after the box ran still sees them.

Every DefaultOutput holds one as retainedAreas: display(...) puts the rendered HTML in under its channel name, displayOpen and displayClose record whether a panel was open, and snapshot replays both as the set-output and output-control messages a client would have received live. A client asks for them with replay-output-areas on attaching, which is also what lets a capture run a box first and look at its output later.

Only the latest HTML per channel is held, bounded at 128 channels and eight million characters with the earliest channel dropped first, and none of it is written to disk.

internal class OutputAreaReplay(private val maxCharacters: Int = 8_000_000)

Latest rendered panels owned by a live box; never persisted or used to execute code.

internal class OutputAreaReplay(private val maxCharacters: Int = 8_000_000) {
    private data class Panel(val html: String, var open: Boolean? = null)
    private val panels = linkedMapOf<String, Panel>()
    private val visibility = mutableMapOf<String, Boolean>()

@Synchronized fun put(channel: String, html: String)

    @Synchronized fun put(channel: String, html: String) {
        val open = panels[channel]?.open ?: visibility[channel]
        panels[channel] = Panel(html, open)
        while (panels.values.sumOf { it.html.length.toLong() } > maxCharacters || panels.size > 128) {
            panels.remove(panels.keys.first())
        }
    }

@Synchronized fun control(action: String, channel: String?)

    @Synchronized fun control(action: String, channel: String?) {
        when (action) {
            "clear-all" -> { panels.clear(); visibility.clear() }
            "clear" -> { panels.remove(channel); visibility.remove(channel) }
            "open", "close" -> if (channel != null) {
                visibility[channel] = action == "open"
                panels[channel]?.open = action == "open"
            }
        }
    }

fun channels(): List<String>

Channels that currently hold a panel, in insertion order.

    @Synchronized
    fun channels(): List<String> = panels.keys.toList()

@Synchronized fun snapshot(uid: String): List<Message>

    @Synchronized fun snapshot(uid: String): List<Message> = buildList {
        panels.forEach { (channel, panel) ->
            add(Message("set-output").payload(Set_output(uid, "outputarea", channel, panel.html)))
            panel.open?.let { open ->
                add(Message("output-control").payload(OutputControl(uid, if (open) "open" else "close", channel)))
            }
        }
    }
}