JS Runtime 外部注入能力

注入入口：crates/ng-js-runtime/src/server_runtime.rs 的 init_js_runtime_globals。

自定义注入

全局函数

• globalThis.nodeget(json) — 调用 NodeGet JSON-RPC API，支持以下调用方式：
  • nodeget(json) — 传入完整的 JSON-RPC 请求（string 或 object），返回解析后的 JS 对象
  • nodeget(method, params) — 快捷方式，自动构造 { jsonrpc: "2.0", method, params, id: randomUUID() }
  • nodeget(method, params, id) — 同上，但指定请求 id
• globalThis.db — 内置数据库实例操作对象，提供以下异步方法：
  • db.create(token, name) — 创建数据库实例，调用 db_create
  • db.read(token, name) — 读取数据库实例信息，调用 db_read
  • db.update(token, name, newName) — 重命名数据库实例（newName 映射为 new_name），调用 db_update
  • db.remove(token, name) — 删除数据库实例，调用 db_delete
  • db.list(token) — 列出所有数据库实例，调用 db_list
  • db.execSql(token, name, sql, params?) — 在指定实例上执行 SQL，调用 db_exec_sql，占位符使用 $1, $2 格式 所有方法内部通过 nodeget() 发起 JSON-RPC 调用，返回 result；遇 error 时抛出异常
• globalThis.inlineCall(js_worker_name, params, timeout_sec?) — 调用其他 JS Worker。timeout_sec 为可选的软超时（秒，正有限数），最终生效超时取 timeout_sec 与目标 Worker max_run_time 中较小者；不传时仅受目标 Worker max_run_time 约束。
• globalThis.execSql(token, sql, params?) — 执行原始 SQL 语句，参数化查询，返回 JSON 格式结果。 需要 NodeGet::ExecSql 权限。详见下方说明。
• globalThis.getDatabaseType(token) — 获取当前节点使用的数据库类型（sqlite/postgres）。 需要 NodeGet::ExecSql 权限。
• globalThis.randomUUID() — 生成随机 UUID v4 字符串
• globalThis.nodegetLog — 将日志桥接到 Server 端 Rust tracing 日志系统。详见 JS Worker 日志。
  • nodegetLog.trace(namespace, message)
  • nodegetLog.debug(namespace, message)
  • nodegetLog.info(namespace, message)
  • nodegetLog.warn(namespace, message)
  • nodegetLog.error(namespace, message)
  • nodegetLog.log(namespace, message)（info 别名）
  • namespace 为空/null/undefined 时落到 default 空间；message 会强制 String() 转换。
  • 输出 target 为 js_worker，并携带 worker、namespace 结构化字段；通过 RUST_LOG=js_worker=debug 等环境变量控制级别。

execSql 使用说明

需要传入拥有 NodeGet::ExecSql 权限的 token。 SQL 占位符使用 $1, $2 格式（SQLite 和 PostgreSQL 均支持）。

// ── SELECT 查询 ──
const res = await execSql(token, "SELECT id, name, age FROM users WHERE age > $1", [18]);
// res: { success: true, data: [{id: 1, name: "Alice", age: 25}, ...], row_count: 2 }

// ── INSERT / UPDATE / DELETE ──
const res = await execSql(token, "UPDATE users SET status = $1 WHERE id = $2", ["active", 1]);
// res: { success: true, data: [], row_count: 0 }
// DML 语句不返回行数据，data 始终为空数组

// ── 无参数查询 ──
const res = await execSql(token, "SELECT * FROM users");

// ── PRAGMA 命令（SQLite） ──
const res = await execSql(token, "PRAGMA table_info(users)");

// ── JSON 参数 ──
const res = await execSql(token,
    'INSERT INTO users (name, data) VALUES ($1, $2)',
    ["Alice", { role: "admin", tags: ["a", "b"] }]
);

getDatabaseType 使用说明

const { data: dbType } = await getDatabaseType(token);
// dbType: "sqlite" | "postgres"
// 注：若底层数据库为其他类型可能返回 "mysql" 或 "unknown"

runtimeCtx（handler 第三参数）

脚本 handler 签名为 handler(input, env, runtimeCtx)，其中 runtimeCtx 包含以下属性：

• runtimeCtx.runType — 当前运行类型字符串："onCall" / "onInlineCall" / "onCron" / "onRoute"
• runtimeCtx.workerName — 当前 Worker 的名字
• runtimeCtx.inlineCall(js_worker_name, params, timeout_sec?) — 等价于 globalThis.inlineCall（软超时与目标 Worker max_run_time 取较小者）
• runtimeCtx.inlineCaller — 调用当前脚本的调用者脚本名；顶层调用时为 null

llrt_* 模块支持

• llrt_fetch::init
  • fetch、Request、Response、Headers、FormData
• llrt_buffer::init
  • Buffer、Blob、File、atob、btoa
• llrt_stream_web::init
  • ReadableStream、WritableStream、TransformStream
• llrt_url::init
  • URL、URLSearchParams
• llrt_util::init
  • TextEncoder、TextDecoder
• llrt_timers::init
  • setTimeout、clearTimeout、setInterval、clearInterval、setImmediate、queueMicrotask