Subchapter 40.14

Record Iai

N8n:public API

N8n:telemetry

N8n:testmax Assistant UI

scripts/record_iai.mjs

JavaScript82 lines3 KB

1#!/usr/bin/env node
2// Record a video of an Instance AI thread in the n8n UI while the run continues.
3//
4//   node record_iai.mjs <out-dir> [--live]
5//
6// --live also saves the screen to <out-dir>/live.png every few seconds, for the live page.
7//
8// Protocol on stdin and stdout, one line each:
9//   prints "ready" after sign-in
10//   reads  "open <thread-url>" and opens the thread
11//   reads  "stop", or stdin closes: keeps the last screen for a moment, then saves <out-dir>/screen.webm
12//                                   and the last screen as <out-dir>/screen-poster.png
13// The sign-in happens in a separate context, so the video starts at the thread.
14import

record_iai.mjs on GitHub

{ copyFileSync, mkdtempSync, renameSync, rmSync }

from

'node:fs'

;

import { tmpdir } from 'node:os';

import { join, resolve } from 'node:path';

import { createInterface } from 'node:readline';

import { launchBrowser, signIn } from './n8n_browser.mjs';

const outDir = resolve(process.argv[2] ?? '.');

const live = process.argv.includes('--live');

const SIZE = { width: 1600, height: 1000 };

const LIVE_SHOT_MS = 2500;

const browser = await launchBrowser();

const login = await browser.newContext();

const loginPage = await login.newPage();

await signIn(loginPage);

const storageState = await login.storageState();

await login.close();

const videoDir = mkdtempSync(join(tmpdir(), 'cwb-video-'));

const context = await browser.newContext({

viewport: SIZE,

storageState,

recordVideo: { dir: videoDir, size: SIZE },

});

const page = await context.newPage();

console.log('ready');

let liveTimer;

let shooting = false;

async function saveLiveShot() {

if (shooting) return;

shooting = true;

// The live page can read the file at any time, so it gets only complete images.

const partial = join(outDir, 'live.tmp.png');

try {

await page.screenshot({ path: partial });

renameSync(partial, join(outDir, 'live.png'));

} catch {

// The page can be in the middle of a navigation. The next interval tries again.

} finally {

shooting = false;

}

const lines = createInterface({ input: process.stdin });

for await (const line of lines) {

if (line.startsWith('open ')) {

await page.goto(line.slice(5).trim(), { waitUntil: 'domcontentloaded' });

console.log('opened');

if (live && !liveTimer) liveTimer = setInterval(saveLiveShot, LIVE_SHOT_MS);

} else if (line.trim() === 'stop') {

break;

}

clearInterval(liveTimer);

await page.waitForTimeout(3000);

if (live) await saveLiveShot();

// The video starts on a blank page, so the report shows the last screen until playback starts.

await page.screenshot({ path: join(outDir, 'screen-poster.png') }).catch(() => {});

const video = page.video();

await context.close();

if (video) {

copyFileSync(await video.path(), join(outDir, 'screen.webm'));

console.log('saved screen.webm');

}

await browser.close();

rmSync(videoDir, { recursive: true, force: true });