wx-starlock/pages/p2p/xp2pManager.js

import { getUserId, compareVersion } from './utils'

let xp2pManager = null
export const getXp2pManager = () => {
  if (!xp2pManager) {
    let xp2pPlugin = requirePlugin('xp2p')

    console.log(11111, xp2pPlugin)

    const iotExports = xp2pPlugin.iot
    const app = getApp()

    // 用户id，微信用户在此小程序中的唯一标识
    iotExports?.setUserId?.(getUserId() || 'demo')

    // 开发版才打插件log
    if (app.pluginLogger && uni.getAccountInfoSync().miniProgram.envVersion === 'develop') {
      iotExports?.setPluginLogger?.(app.pluginLogger)
    }

    // 设置优先使用的打洞协议
    if (
      compareVersion(uni.getSystemInfoSync().SDKVersion, '3.4.1') >= 0 &&
      xp2pPlugin.p2p.setTcpFirst
    ) {
      const tcpFirstKey = 'tcpFirst'
      const tcpFirstTime = parseInt(uni.getStorageSync(tcpFirstKey), 10)
      const tcpFirst = !!(tcpFirstTime && Date.now() - tcpFirstTime < 3600000 * 24) // 24小时内有效
      console.log('tcpFirst', tcpFirst)
      xp2pPlugin.p2p.setTcpFirst(tcpFirst)

      // 给index页用，方便测试时调整tcpFirst
      app.tcpFirst = tcpFirst
      app.toggleTcpFirst = async () => {
        const modalRes = await uni.showModal({
          title: '确定切换 tcpFirst 吗？',
          content: '切换后需要重新进入小程序'
        })
        if (!modalRes || !modalRes.confirm) {
          return
        }
        uni.setStorageSync(tcpFirstKey, tcpFirst ? '' : Date.now())
        app.restart()
      }
    }

    // 设置是否连接对端stun
    if (xp2pPlugin.p2p.setCrossStunTurn) {
      const crossStunTurnKey = 'crossStunTurn'
      const crossStunTurnTime = parseInt(uni.getStorageSync(crossStunTurnKey), 10)
      const crossStunTurn = !!(crossStunTurnTime && Date.now() - crossStunTurnTime < 3600000 * 24) // 24小时内有效
      xp2pPlugin.p2p.setCrossStunTurn(crossStunTurn)
      // 给index页用，方便测试时调整crossStunTurn
      app.crossStunTurn = crossStunTurn
      app.toggleCrossStunTurn = async () => {
        const modalRes = await uni.showModal({
          title: '确定切换 crossStunTurn 吗？',
          content: '切换后需要重新进入小程序'
        })
        if (!modalRes || !modalRes.confirm) {
          return
        }
        uni.setStorageSync(crossStunTurnKey, crossStunTurn ? '' : Date.now())
        app.restart()
      }
    }

    // 设置切换端口
    if (xp2pPlugin.p2p.updateStunPort) {
      const portKey = 'STUN_PORT'
      const stunPort = uni.getStorageSync(portKey) || 20002
      xp2pPlugin.p2p.updateStunPort(stunPort)
      app.stunPort = stunPort
      app.togglePort = async port => {
        const modalRes = await uni.showModal({
          title: '确定切换 stunPort 吗？',
          content: '切换后需要重新进入小程序'
        })
        if (!modalRes || !modalRes.confirm) {
          return
        }
        uni.setStorageSync(portKey, port)
        app.restart()
      }
    }

    // 设置切换配置跟随
    if (xp2pPlugin.p2p.setUseDeliveryConfig) {
      const useDeliveryConfigKey = 'useDeliveryConfig'
      const useDeliveryConfigTime = parseInt(uni.getStorageSync(useDeliveryConfigKey), 10)
      const useDeliveryConfig = !!(
        useDeliveryConfigTime && Date.now() - useDeliveryConfigTime < 3600000 * 24
      ) // 24小时内有效
      xp2pPlugin.p2p.setUseDeliveryConfig(useDeliveryConfig)
      app.useDeliveryConfig = useDeliveryConfig
      app.toggleUseDeliveryConfig = async () => {
        const modalRes = await uni.showModal({
          title: '确定切换 使用设备跟随 吗？',
          content: '切换后需要重新进入小程序'
        })
        if (!modalRes || !modalRes.confirm) {
          return
        }
        uni.setStorageSync(useDeliveryConfigKey, useDeliveryConfig ? '' : Date.now())
        app.restart()
      }
    }

    xp2pManager = iotExports.getXp2pManager()
    app.logger?.log('xp2pManager', {
      P2PPlayerVersion: xp2pManager.P2PPlayerVersion,
      XP2PVersion: xp2pManager.XP2PVersion,
      // uuid，插件随机生成的id，存储在小程序本地，删除小程序后会重新生成
      uuid: xp2pManager.uuid
    })
  }
  return xp2pManager
}