使用

import { isTrustedApiRequest, readJsonBody, writeJson, createWriteScheduler, atomicWriteJson } from 'dsh-shared'

// 路由注册时用信任围栏过滤非可信来源
const fence = (request) => isTrustedApiRequest(request, ctx.webRuntime.trustedHosts)

// 状态快照落盘：调度器保证节奏，护栏兜底
const scheduler = createWriteScheduler({
  logger: ctx.logger,
  write: ({ force }) => atomicWriteJson(file, state, ctx.logger, '[my-plugin]', { force, maxBytes: 4 * 1024 * 1024 }),
})
scheduler.schedule() // 变更后调度（防抖合并）
await scheduler.drain() // 就绪信号：确定已落盘（测试用它替掉 sleep）
await scheduler.flush() // teardown：立即强写
dsh-shared

AI 分析

安装

说明文档

使用
