Content-Type: application/json Authorization: Bearer pn_ak_live_xxxxxxxxxxxxxxxxxxxx

复制代码

curl -X POST "https://pushnova.stream/v1/dispatch"   -H "Content-Type: application/json"   -H "Authorization: Bearer pn_ak_live_simulator_demo"   -d '{
    "title": "生产环境集群应急扩容审批",
    "message": "检测到高峰流量突发，AI Agent 建议扩容 10 个 Pod 节点，请确认：",
    "type": "HITL",
    "priority": "EMERGENCY",
    "to": "pn_tok_live_sec99a74b12c8e3f",
    "actions": [
      {"key": "APPROVE", "label": "准许扩容", "style": "PRIMARY"},
      {"key": "REJECT", "label": "驳回请求", "style": "DESTRUCTIVE"}
    ],
    "callback_url": "https://samplecallback.ezcloud.ltd/v1//callback"
  }'

复制代码

import requests

url = "https://pushnova.stream/v1/dispatch"
headers = {
    "Authorization": "Bearer pn_ak_live_simulator_demo",
    "Content-Type": "application/json"
}
payload = {
    "title": "生产环境集群应急扩容审批",
    "message": "检测到高峰流量突发，AI Agent 建议扩容 10 个 Pod 节点，请确认：",
    "type": "HITL",
    "priority": "EMERGENCY",
    "topic": "ops_alerts",  # 或使用 "to": "pn_tok_live_..."
    "actions": [
        {"key": "APPROVE", "label": "准许扩容", "style": "PRIMARY"},
        {"key": "REJECT", "label": "驳回请求", "style": "DESTRUCTIVE"}
    ],
    "callback_url": "https://your-server.com/api/hitl-callback",
    "timeout_seconds": 120
}

response = requests.post(url, json=payload, headers=headers)
print("Response:", response.status_code, response.json())

复制代码

const payload = {
  title: "生产环境集群应急扩容审批",
  message: "检测到高峰流量突发，AI Agent 建议扩容 10 个 Pod 节点，请确认：",
  type: "HITL",
  priority: "EMERGENCY",
  topic: "ops_alerts",
  actions: [
    { key: "APPROVE", label: "准许扩容", style: "PRIMARY" },
    { key: "REJECT", label: "驳回请求", style: "DESTRUCTIVE" }
  ],
  callback_url: "https://samplecallback.ezcloud.ltd/v1//callback"
};

const resp = await fetch("https://pushnova.stream/v1/dispatch", {
  method: "POST",
  headers: {
    "Content-Type": "application/json",
    "Authorization": "Bearer pn_ak_live_simulator_demo"
  },
  body: JSON.stringify(payload)
});
console.log(await resp.json());

Headers: Content-Type: application/json X-PushNova-Signature: 3c8e9f2a4b1d0c... (HMAC-SHA256 raw Hex signature) User-Agent: PushNova-Gateway/3.2 Body JSON: { "notification_id": "hitl_k8s_scale_01", "action_key": "SHUTDOWN_NOW", "user_input": "", "device_token": "pn_tok_live_sec99a74b12c8e3f", "timestamp": 1725782900, "signature": "3c8e9f2a4b1d0c..." }

pushnova-ops config set --gateway "https://pushnova.stream"                         --key "pn_ak_live_your_api_key_here"                         --secret "pn_wh_your_webhook_secret_here"

const { PushNova, verifyWebhookSignature } = require('pushnova');

// 1. 初始化客户端（自动读取环境变量或 ~/.pushnovarc）
const client = new PushNova({
  gateway: 'https://pushnova.stream',
  apiKey: process.env.PUSHNOVA_API_KEY // 或传入 'pn_ak_live_...'
});

// 2. 发送普通告警通知
async function sendAlert() {
  await client.send({
    title: '生产环境内存告警',
    body: '节点 web-02 内存占用超过 88%',
    priority: 'HIGH',
    topic: 'ops_alerts' // 广播到频道，或使用 to: 'pn_tok_live_...'
  });
}

// 3. 发起人机协同（HITL）交互审批
async function requestApproval() {
  const result = await client.sendHitl({
    title: '数据库扩容审批请求',
    body: '在线会话数激增，AI Agent 建议扩容至 16 副本，请审批：',
    actions: [
      { key: 'APPROVE', label: '✅ 批准扩容', style: 'PRIMARY' },
      { key: 'REJECT', label: '❌ 驳回申请', style: 'DESTRUCTIVE' }
    ],
    allowInput: true,
    inputPlaceholder: '若驳回请输入原因...'
  });
  console.log('HITL Dispatched:', result);
}

// 4. 自建 Callback 接收端一键验签与防重放中间件
function handleWebhook(req, res) {
  const check = verifyWebhookSignature({
    rawBody: req.rawBody,                               // 未解析的原始报文 Buffer/String
    signature: req.headers['x-pushnova-signature'],     // 'sha256=...'
    secret: process.env.PUSHNOVA_WEBHOOK_SECRET,        // 'pn_wh_...'
    timestamp: req.body.timestamp,                      // 秒级时间戳防重放校验
    maxDriftSec: 300
  });

  if (!check.valid) {
    return res.status(403).json({ error: check.reason });
  }

  // 校验通过，安全处理手机端回传动作
  const { action_key, user_input } = req.body;
  console.log('收到审批回执: ' + action_key + ', 用户输入: ' + user_input);
  res.status(200).json({ status: 'success', action: action_key });
}