推送接入

curl -sS -X POST http://127.0.0.1:8080/api/admin/apps/demo/push \
  -H 'X-Admin-Secret: dev-admin' \
  -H 'content-type: application/json' \
  -d '{"webhookUrl":"http://127.0.0.1:9000/hook","enabled":true}'

# 查询当前配置
curl -sS http://127.0.0.1:8080/api/admin/apps/demo/push \
  -H 'X-Admin-Secret: dev-admin'

import { createServer } from 'node:http';

const seen = new Set();

createServer((req, res) => {
  if (req.method !== 'POST' || req.url !== '/hook') {
    res.writeHead(404).end();
    return;
  }
  let raw = '';
  req.on('data', (chunk) => { raw += chunk; });
  req.on('end', () => {
    const payload = JSON.parse(raw);
    const message = payload.message;
    // 幂等：同一条消息只处理一次
    if (!seen.has(message.messageId)) {
      seen.add(message.messageId);
      console.log('[offline]', payload.userId, message.content);
      // 在这里调用 APNs/FCM/厂商通道（本项目尚未实现）
    }
    res.writeHead(200, { 'content-type': 'application/json' });
    res.end('{"ok":true}');
  });
}).listen(9000, '127.0.0.1', () => console.log('webhook listening on :9000'));

import { createHash, randomBytes } from 'node:crypto';

const BASE = 'https://im.example.com';
const APP_KEY = 'demo';
const APP_SECRET = 'YOUR_APP_SECRET';
const nonce = randomBytes(16).toString('hex');
const timestamp = String(Date.now());
const signature = createHash('sha1').update(APP_SECRET + nonce + timestamp).digest('hex');

const res = await fetch(BASE + '/im/v2/push/send', {
  method: 'POST',
  headers: {
    'content-type': 'application/json',
    'App-Key': APP_KEY,
    Nonce: nonce,
    Timestamp: timestamp,
    Signature: signature,
  },
  body: JSON.stringify({
    scope: 'user',
    target: 'user2',
    title: '系统通知',
    content: '你有一条新的业务提醒',
    extras: { route: '/orders/9f2a' },
  }),
});
console.log(await res.json());