import { createAgentSdk, AgentEventType } from 'linksoul-agentsdk';

const appId = '您通过灵心开放平台创建的应用获取的appId';
const agentId = '您通过灵心平台创建的二开智能体获取的agentId';
const upstreamUrl = 'wss://open.agibot.com/api/V1/open-portal/app/wss/agent-sdk';

let sdk;
let session;

async function connect() {
  // 单例：切换连接前先释放旧实例
  sdk?.release();
  sdk = createAgentSdk(appId, {
    authProvider: async () => {
      const res = await fetch('/api/ws-auth', {
        method: 'POST',
        headers: { 'content-type': 'application/json' },
        body: JSON.stringify({ url: upstreamUrl, appId }),
      });
      const { url } = await res.json();
      return { url };
    },
    reconnect: true,
  });

  sdk.on('message', ({ data }) => {
    let msg;
    try { msg = JSON.parse(typeof data === 'string' ? data : ''); } catch { return; }
    if (msg.type === AgentEventType.TeleopEnterAck) {
      console.log('enter ack code =', msg.code);
    } else if (msg.type === AgentEventType.TeleopExitAck) {
      console.log('exit ack code =', msg.code);
    }
  });
  sdk.on('connected', () => console.log('connected'));
  sdk.on('disconnected', ({ willReconnect }) => console.log('closed, willReconnect=', willReconnect));

  await sdk.connect();
}

function enterTeleop() {
  session = sdk.createTeleopSession({ agentId });
  session.enter(); // ACK 在上面的 message 监听里
}

// 麦克风推流：24kHz / 单声道 / Int16 PCM
async function startRecording() {
  const startEventId = session.startAudio({ role: 'male', threshold: 0 });

  const stream = await navigator.mediaDevices.getUserMedia({ audio: true });
  const ctx = new AudioContext({ sampleRate: 24000 });
  await ctx.audioWorklet.addModule('pcm-processor.js');
  const src = ctx.createMediaStreamSource(stream);
  const node = new AudioWorkletNode(ctx, 'pcm-processor');
  node.port.onmessage = (e) => session.sendAudio(toBase64(e.data)); // e.data: ArrayBuffer(Int16)
  src.connect(node);
}

function stopRecording() {
  session.finishAudio();
}

function exitTeleop() {
  session.exit();
}

function toBase64(buffer) {
  const bytes = new Uint8Array(buffer);
  let binary = '';
  for (const b of bytes) binary += String.fromCharCode(b);
  return btoa(binary);
}

import { createHmac, randomUUID } from 'node:crypto';

app.post('/api/ws-auth', async (req, res) => {
  const { url, appId } = req.body;
  const appKey = process.env.APP_KEY;       // 凭证只在服务端
  const appSecret = process.env.APP_SECRET;
  const target = new URL(url);

  const timestamp = String(Date.now());
  const nonce = randomUUID().replace(/-/g, '');
  const signature = createHmac('sha256', appSecret)
    .update(`GET\n${target.pathname}\n${timestamp}\n${nonce}`)
    .digest('hex');

  // 用这些头连上游网关，握手成功后签发一次性票据 t，返回本地代理 URL
  const headers = {
    'X-App-Id': appId,
    'X-App-Key': appKey,
    'X-Timestamp': timestamp,
    'X-Nonce': nonce,
    'X-Signature': signature,
    'X-Callback-Types': JSON.stringify([]),
  };
  const ticket = issueTicket(target, headers);
  res.json({ url: `ws://localhost:${PORT}/api/ws?t=${ticket}` });
});

let online = true;
let timer;

function startKeepAlive() {
  timer = setInterval(() => { if (online) session.keepAlive(); }, 10_000);
}

sdk.on('message', ({ data }) => {
  let msg; try { msg = JSON.parse(String(data)); } catch { return; }
  if (msg.type === AgentEventType.TeleopKeepaliveAck && msg.code !== 0) {
    online = false;
    clearInterval(timer);
    session.exit(); // 掉线自动退出
  }
});