网站接入文档

import crypto from 'node:crypto';

// saved = 用户连接时你保存的 { relay, deviceId, sourceId, pushKey }
export async function pushActivity(saved, body) {
  const path = `/v1/devices/${saved.deviceId}/push`;
  const raw = JSON.stringify({ timestamp: Math.floor(Date.now() / 1000), ...body });
  const seconds = String(Math.floor(Date.now() / 1000));
  const requestId = crypto.randomUUID();
  const digest = crypto.createHash('sha256').update(raw).digest('hex');
  const signature = crypto.createHmac('sha256', Buffer.from(saved.pushKey, 'base64url'))
    .update(`POST\n${path}\n${seconds}\n${requestId}\n${digest}`).digest('base64url');
  const response = await fetch(saved.relay.replace(/\/$/, '') + path, {
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
      'X-Pulse-Source': saved.sourceId,
      'X-Pulse-Auth': `v2 ${seconds} ${requestId} ${signature}`,
    },
    body: raw,
  });
  return response.status; // 401/403/410：删除 saved
}

// 例：订单进入第 3 步，并提醒用户
await pushActivity(saved, {
  ref: 'order-1024', event: 'update', alert: { body: '骑手已取餐' },
  contentState: { template: 'steps', step: 3, steps: ['已下单', '备餐中', '配送中', '已送达'],
                  title: '订单 #1024', summary: '骑手已取餐', status: 'running', revision: Date.now() },
});

import base64, hashlib, hmac, json, time, uuid, urllib.request, urllib.error

def b64url_decode(text):
    return base64.urlsafe_b64decode(text + "=" * (-len(text) % 4))

def push_activity(saved, body):
    path = f"/v1/devices/{saved['deviceId']}/push"
    raw = json.dumps({"timestamp": int(time.time()), **body}, ensure_ascii=False).encode()
    seconds, request_id = str(int(time.time())), str(uuid.uuid4())
    message = f"POST\n{path}\n{seconds}\n{request_id}\n{hashlib.sha256(raw).hexdigest()}".encode()
    signature = base64.urlsafe_b64encode(
        hmac.new(b64url_decode(saved["pushKey"]), message, hashlib.sha256).digest()).rstrip(b"=").decode()
    request = urllib.request.Request(saved["relay"].rstrip("/") + path, data=raw, method="POST", headers={
        "Content-Type": "application/json",
        "X-Pulse-Source": saved["sourceId"],
        "X-Pulse-Auth": f"v2 {seconds} {request_id} {signature}",
    })
    try:
        with urllib.request.urlopen(request, timeout=10) as response:
            return response.status
    except urllib.error.HTTPError as error:
        return error.code  # 401/403/410：删除 saved

# 例：上传进度 42%，预计 5 分钟后完成
push_activity(saved, {
    "ref": "upload-77", "event": "update",
    "contentState": {"template": "progress", "progress": 0.42, "endsAt": int(time.time()) + 300,
                     "title": "上传 4 个文件", "summary": "已传 1.2 GB", "status": "running",
                     "revision": int(time.time() * 1000)},
})

RELAY=https://relay.crsyounen.com DEVICE=… SOURCE=… KEY=…
BODY='{"ref":"demo","event":"update","timestamp":'$(date +%s)',"contentState":{"title":"测试","summary":"","status":"running","revision":'$(date +%s)'000'}}'
P=/v1/devices/$DEVICE/push; T=$(date +%s); R=$(uuidgen | tr A-Z a-z)
D=$(printf %s "$BODY" | openssl dgst -sha256 -hex | awk '{print $NF}')
PAD=$(printf %s "$KEY" | awk '{ n = (4 - length($0) % 4) % 4; s = $0; for (i = 0; i < n; i++) s = s "="; print s }')
HEXKEY=$(printf %s "$PAD" | tr '_-' '/+' | base64 -d | xxd -p -c 256)
S=$(printf 'POST\n%s\n%s\n%s\n%s' "$P" "$T" "$R" "$D" | openssl dgst -sha256 -mac HMAC -macopt hexkey:$HEXKEY -binary | base64 | tr '+/' '-_' | tr -d '=')
curl -s -w '\n%{http_code}\n' "$RELAY$P" -H 'Content-Type: application/json' -H "X-Pulse-Source: $SOURCE" -H "X-Pulse-Auth: v2 $T $R $S" -d "$BODY"