@crvouga/ mockingbird-service-aha (英语)

本地模拟器。 真正的API合同. 部分 嘲笑鸟。 。 。 .

国家模拟器 AHA (高级卫生学院) 在家理发 用于测试的 API 套接字:HMAC署名的创建顺序并取消,以及——其主要工作——订单状态webhooks AHA 邮递员 销售商没有拉API,所以每个下游效应(EMR预约, storefront status, "blood draw") 起始为 webhook; 仿真器按需发出一个, 每一个 字段,我们的处理器读取, 所以ZIP路线的血液工作路径 终于可以测试.

• 行动范围: 支助
• 供应商不公布具体内容:合同openapi.yaml由我们手写 消费者的zod计划 和电线形状.

安装

npm install -D @crvouga/mockingbird-service-aha

仅限无害环境管理。 节点 22或 Bun 1.2. 无土生属地. 给它服务 npx mockingbird-aha serve, (中文(简体) ), createServer 从 ./server (节点),或 createRuntime 带有任意 获取服务器 .

使用量

将应用程序指向模拟器:

npx mockingbird-aha serve --port 8799 \
  --webhook-url http://127.0.0.1:3000/bloodwork/aha-webhook \
  --webhook-secret "$AHA_WEBHOOK_SECRET" \
  --api-key "$AHA_API_KEY" --api-secret "$AHA_API_SECRET" \
  --envelope raw --auto-schedule 2000

import { createHmac } from "node:crypto"
import { createServer } from "@crvouga/mockingbird-service-aha/server"

// Test setup: the emulator, posting order-status webhooks to the app's handler.
const server = await createServer({
  webhooks: { url: "http://127.0.0.1:3000/bloodwork/aha-webhook", secret: "aha-webhook-secret" },
})

// Application code: its usual signed request, with AHA_API_URL set to server.url.
const [apiUrl, apiKey, apiSecret] = [server.url, "aha-key", "aha-secret"]
const path = "/v1/acme/create-order"
const timestamp = Date.now().toString()
const signature = createHmac("sha256", apiSecret)
  .update(`${apiKey}:${path}:${timestamp}`)
  .digest("base64")
const created = await fetch(`${apiUrl}${path}`, {
  method: "POST",
  headers: {
    "content-type": "application/json",
    "X-API-KEY": apiKey,
    "X-TIMESTAMP": timestamp,
    "X-SIGNATURE": signature,
  },
  body: JSON.stringify({
    partner_order_id: "AC-101", patient_id: "pat-1", biological_sex: "Female",
    patient_first_name: "Ada", patient_last_name: "Lovelace", patient_dob: "1990-12-10",
    patient_phone_number: "5555550100", patient_address_line1: "501 N 5th St",
    patient_city: "Phoenix", patient_state: "AZ", patient_zipcode: "85004",
    service_type: "Full Service", npi: "1234567893", ordering_physician: "Dr. Grace Hopper",
    test_codes: [{ test_code: "CBC", test_description: "Complete blood count" }],
  }),
})
// → {content: {partner_order_id: "AC-101", order_number: "AHA-…"}, message, status: "SUCCESS"}

// Test control: move the order as AHA would. Each transition posts a webhook to the app.
const transition = (body: unknown) =>
  fetch(`${server.url}/__admin/orders/AC-101/transition`, {
    method: "POST",
    headers: { "content-type": "application/json" },
    body: JSON.stringify(body),
  })
// AHA books the draw: our handler books the EMR appointment for 10:30 Denver time.
await transition({
  status: "Scheduled",
  scheduledAt: "2026-10-01T16:30:00Z",
  timeZone: "America/Denver",
})
// The phlebotomist checks out with a sample: our handler sets vitalBloodDrawn.
await transition({ status: "Check Out", drawStatus: "Sample Collected" })
await server.close()

路线

这个 {partner} 路径段是您的账户的 sult( 例如) . acme);模拟器接受任何.

奥特. HMAC 模式 : X-API-KEY, (中文(简体) ), X-TIMESTAMP (划时代,在相隔5分钟后), X-SIGNATURE = 基数64 HMAC-SHA256(机密, "<apiKey>:<path>:<timestamp>"),在其中 path 这是 请求没有主机、正机或路径 /__admin/ns/<name> 前缀。 带有已知密钥 + 密钥 (单位:千美元)--api-key/--api-secret 或者说 credentials (b) 准确核实签名; 未配置任何密钥的签名会被接受,签名只检查形状。 遗产 模式 : X-<Partner>-Auth-Key (+ 数) X-API-Version: 1.0),例如. X-Acme-Auth-Key; 任何伙伴名称为 已接受。 失败者为401人 {status: "ERROR", message}。 。 。 .

信封 (G- A1). AhaService 期待原始数据 {content, message, status}· ; AhaLabProvider 预期 {success: true, data: {…}}。 Raw 是默认值;选择使用 --envelope raw|wrapped 或每个命名空间 PUT /__admin/settings {"envelope": "wrapped"}。 。 。 .

引证无能. X-Idempotency-Key (实验室提供路径):同一键和身体重放 存储的响应( e)idempotent-replayed: true; 不同身体的同一键为409.

网络呼号

POST <webhook-url> (我们的路线 : POST /bloodwork/aha-webhook与 Authorization: Token <AHA_WEBHOOK_SECRET>每一个身体都有 status, (中文(简体) ), partnerOrderId, (中文(简体) ), ahaOrderId, (中文(简体) ), 加上,按地位(顺序的IANA区所有当地时间):

drawStatus 值 : Sample Collected, (中文(简体) ), Completed (拖动), Patient Refused, (中文(简体) ), UTO, (中文(简体) ), Patient Not Home, (中文(简体) ), Patient Rescheduled, (中文(简体) ), Order Cancelled, (中文(简体) ), Others, (中文(简体) ), Patient Asked to Reschedule (拖曳失败). 非-2xx 的答案被重审(立即,5 s, 5分30分2小时); GET /__admin/webhooks, (中文(简体) ), …/events, (中文(简体) ), …/replay, (中文(简体) ), …/flush 和往常一样.

管理员(超过标准合同)

错误预设( E)POST /__admin/faults {"preset": "<name>", "count"?: n}: bad_signature (401个), rate_limited (429个) rate_limit, (中文(简体) ), server_error (500个), order_error (200个带内 status: "ERROR", (中文(简体) ), invalid_response (200个身体,zod计划不接受), webhook_duplicate, (中文(简体) ), webhook_reorder, (中文(简体) ), webhook_drop。 。 。 .

命名空间

x-mockingbird-namespace页:1 /__admin/ns/<name> 前缀在 AHA_API_URL (签名仍涵盖 或 API 键: PUT /__admin/credentials {"credentials": {"<AHA_API_KEY>": "<namespace>"}}。 。 。 .

SFTP 结果交付

createAhaSftpServer 从 ./sftp 在麻黄端口启动真实的SSH/SFTP服务器并共享命令状态 createRuntime它支持密码或公用钥匙认证,主机钥匙验证, list编号 :stat, 二进制上下载, 原子临时文件重命名, 删除, 嵌入目录, 稳定的 POSIX 权限和仿真器时钟时间戳 。 决定性的 Ed25519 主机密钥在运行间稳定.

import { Client } from "ssh2"
import { createRuntime } from "@crvouga/mockingbird-service-aha"
import { createAhaSftpServer } from "@crvouga/mockingbird-service-aha/sftp"

// Test setup: the SFTP endpoint, sharing order state with the HTTP emulator, and one result.
const runtime = createRuntime()
const sftp = await createAhaSftpServer({
  runtime,
  accounts: [{ username: "aha", password: "local-test-password" }],
})
sftp.seed("/outbox/AHA-1001_result.pdf", new TextEncoder().encode("%PDF-1.4"))

// Application code: the ssh2 client it already uses. Only host, port and host key change.
const client = new Client()
await new Promise<void>((resolve, reject) =>
  client.once("ready", resolve).once("error", reject).connect({
    host: sftp.host,
    port: sftp.port,
    username: "aha",
    password: "local-test-password",
    hostVerifier: (key: Buffer) => key.equals(sftp.hostPublicKey),
  }),
)
const pdf = await new Promise<Buffer>((resolve, reject) =>
  client.sftp((error, session) => {
    if (error) return reject(error)
    session.readFile("/outbox/AHA-1001_result.pdf", (error, bytes) =>
      error ? reject(error) : resolve(bytes),
    )
  }),
)
client.end()
await sftp.close()

使用 seed() 安装任意的二进制固定件或 publishResult(orderId, bytes) 摆放一个稳定 AHA-…_result.pdf 内 /outbox。第一个完整的下载将链接的 HTTP 命令移动到 Lab Testing In Progress 并发布其网页;重复投票/倒数不重复这一过渡. fault() 强制下一场行动断开、拒绝许可、报告磁盘完整或只接受部分写入. journal() 曝光路径、 操作名称、 字节计数和结果—— 绝不是证书或文件内容 . reset(namespace?) 清除决定性文件系统状态。 复制目的地名称失败, 所以 .tmp ——最终更名为原子.

故意不模拟

• 下游S3摄入和 aha_results_queue sFTP 交接后处理.
• 真正的调度: AHA 联系病人; 除非测试转换顺序, 任何动作都不要动 或组合 autoSchedule。 。 。 .
• 可用- ZIP 列表(我们的应用程序在呼叫 AHA 之前,先决定资格).
• 患者细节经过验证,从未被存储或回放.
• 真正销售商使用的哪个信封(G-A1):两者都得到服务,每个命名空间一个.

API 密码

部分 嘲笑鸟。 。 。 .