encode.ts

import { fileExists } from "./utils.ts"

export async function encode(key: number, segment: number[], crf: number, segmentPath: string, outPath: string, retries = 0): Promise<void> {
    if (await fileExists(`${outPath}/${key}/${crf}.webm`)) {
        console.log(`Skipping encoding ${key} with crf ${crf} because file already exists`)
        return
    }

    const pSvt = Deno.run({
        cmd: [
            "SvtAv1EncApp",
            "-i",
            segmentPath,
            "-b",
            `/dev/stdout`,
            "-w",
            "1920",
            "-h",
            "1080",
            "--fps",
            "23.98",
            "--color-primaries",
            "bt709",
            "--transfer-characteristics",
            "bt709",
            "--matrix-coefficients",
            "bt709",
            "--lp",
            retries ? "32" : "1",
            "--rc",
            "0",
            "--qp",
            `${crf}`,
            "--preset",
            "12",
        ],
        stdout: "piped",
        stdin: "piped",
        stderr: "piped",
    })

    // ffmpeg -y -i - -c copy -an out.webm
    const pFfmpeg = Deno.run({
        cmd: [
            "ffmpeg",
            "-y",
            "-i",
            "-",
            "-c",
            "copy",
            "-an",
            `${outPath}/${key}/${crf}.webm`
        ],
        stdin: "piped",
        stdout: "piped",
        stderr: "piped",
    })

    pSvt.stdout.readable.pipeTo(pFfmpeg.stdin.writable)

    const { code } = await pFfmpeg.status()

    if (code !== 0) {
        console.log(`Encoding segment ${key} with crf ${crf} failed`)

        // console.log(new TextDecoder().decode(await pSvt.stderrOutput()))
        // console.log(new TextDecoder().decode(await pFfmpeg.stderrOutput()))

        if (retries > 1) {
            return
        }

        Deno.remove(`${outPath}/${key}/${crf}.webm`)

        return await encode(key, segment, crf, segmentPath, outPath, retries + 1)
    }

    console.log(`Encoding segment ${key} with crf ${crf} successful`)
}