File size: 3,439 Bytes
3144483 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 | // FFmpeg exec helpers run ffmpeg and ffprobe with normalized errors.
import { normalizeLowercaseStringOrEmpty } from "@openclaw/normalization-core/string-coerce";
import { resolveSystemBin } from "../infra/resolve-system-bin.js";
import { runExec, type RunExecOptions } from "../process/exec.js";
import {
MEDIA_FFMPEG_MAX_BUFFER_BYTES,
MEDIA_FFMPEG_TIMEOUT_MS,
MEDIA_FFPROBE_TIMEOUT_MS,
} from "./ffmpeg-limits.js";
/** Process limits and optional stdin payload for ffmpeg/ffprobe helper calls. */
type MediaExecOptions = {
timeoutMs?: number;
maxBufferBytes?: number;
input?: Buffer | string;
stdinFileDescriptor?: number;
};
function resolveExecOptions(
defaultTimeoutMs: number,
options: MediaExecOptions | undefined,
): RunExecOptions {
if (options?.input !== undefined && options.stdinFileDescriptor !== undefined) {
throw new Error("media exec accepts either input or stdinFileDescriptor, not both");
}
return {
input: options?.input,
...(options?.stdinFileDescriptor !== undefined
? { stdinFileDescriptor: options.stdinFileDescriptor }
: {}),
logOutput: false,
maxBuffer: options?.maxBufferBytes ?? MEDIA_FFMPEG_MAX_BUFFER_BYTES,
timeoutMs: options?.timeoutMs ?? defaultTimeoutMs,
};
}
function requireSystemBin(name: string): string {
const resolved = resolveSystemBin(name, { trust: "standard" });
if (!resolved) {
const hint =
process.platform === "darwin"
? "e.g. brew install ffmpeg"
: "e.g. apt install ffmpeg / dnf install ffmpeg";
throw new Error(
`${name} not found in trusted system directories. ` +
`Install it via your system package manager (${hint}).`,
);
}
return resolved;
}
/** Resolves ffmpeg from trusted system paths before command execution. */
export function resolveFfmpegBin(): string {
return requireSystemBin("ffmpeg");
}
/** Runs ffprobe with optional stdin input. */
export async function runFfprobe(args: string[], options?: MediaExecOptions): Promise<string> {
const { stdout } = await runExec(
requireSystemBin("ffprobe"),
args,
resolveExecOptions(MEDIA_FFPROBE_TIMEOUT_MS, options),
);
return stdout;
}
/** Runs ffmpeg with bounded timeout and buffer settings. */
export async function runFfmpeg(args: string[], options?: MediaExecOptions): Promise<string> {
const { stdout } = await runExec(
resolveFfmpegBin(),
args,
resolveExecOptions(MEDIA_FFMPEG_TIMEOUT_MS, options),
);
return stdout;
}
/** Splits ffprobe CSV-ish output into normalized lowercase fields. */
function parseFfprobeCsvFields(stdout: string, maxFields: number): string[] {
return stdout
.trim()
.split(/[,\r\n]+/, maxFields)
.map((field) => normalizeLowercaseStringOrEmpty(field));
}
function parseFfprobeSampleRateHz(value: string | undefined): number | null {
if (!value || !/^\d+$/.test(value)) {
return null;
}
const sampleRate = Number(value);
return Number.isSafeInteger(sampleRate) && sampleRate > 0 ? sampleRate : null;
}
/** Parses codec and positive sample rate from compact ffprobe stream output. */
export function parseFfprobeCodecAndSampleRate(stdout: string): {
codec: string | null;
sampleRateHz: number | null;
} {
const [codecRaw, sampleRateRaw] = parseFfprobeCsvFields(stdout, 2);
const codec = codecRaw ? codecRaw : null;
return {
codec,
sampleRateHz: parseFfprobeSampleRateHz(sampleRateRaw),
};
}
|