Function initReceive

server/api/connect.ts:81–105

(peer: any, code: string)

// 初始化接收端
function initReceive(peer: any, code: string) {
  if (peer.pairPeer) {
    // throw new Error('Already paired')
    return
  }
  const targetPeer = waitConnectPool.get(code)
  if (!targetPeer || targetPeer.pairPeer) {
    peer.send(JSON.stringify({ type: 'status', code: 404 }))
    disposePeer(peer)
    return
  }
  targetPeer.pairPeer = peer
  peer.pairPeer = targetPeer

  waitConnectPool.delete(code)

  peer.isInited = true
  initedPool.set(peer.id, peer)
  initPool.delete(peer.id)
  initedPool.set(targetPeer.id, targetPeer)
  // 配对成功
  peer.send(JSON.stringify({ type: 'status', code: 0 }))
  heartbeat(peer)
  increaseTransCount()
}

export default defineWebSocketHandler({
  open(peer) {