GHZMRSupportXR/Assets/Scripts/VideoAudioManager.cs

using SC.XR.Unity;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using UnityEngine;
using UnityEngine.UI;

public class VideoAudioManager : SingletonMono<VideoAudioManager>
{
    public Dictionary<string, uint> dicPeeridAndUid;
    public List<CustomPeer> listCustomPeer;
    public string mainViewPeerId;

    private void Start()
    {
        dicPeeridAndUid = new Dictionary<string, uint>();
        listCustomPeer = new List<CustomPeer>();
        mainViewPeerId = "";
        RTCManager.Instance.Init();
        RTCManager.Instance.OnRemoteAudioStateChanged += RemoteAudioStateChanged;
        RTCManager.Instance.OnRemoteVideoStateChanged += RemoteVideoStateChanged;
        
    }

    public void  InitData()
    {
        dicPeeridAndUid.Clear();
        listCustomPeer.Clear();
        dicPeeridAndUid = new Dictionary<string, uint>();
        listCustomPeer = new List<CustomPeer>();
        mainViewPeerId = "";
    }

    public void SetUid( uint uid)
    {
        RTCManager.Instance.SetUid(uid.ToString());
    }

    public void SetChannelName(string channelName)
    {
        RTCManager.Instance.SetChannelName(channelName);
    }

    public void AddPeeridUid(string peerid, uint uid)
    {
        if (dicPeeridAndUid.ContainsKey(peerid))
            return;
        dicPeeridAndUid.Add(peerid, uid);
    }

    public void RemAtPeeridUid(string peerid)
    {
        if (!dicPeeridAndUid.ContainsKey(peerid))
            return;
        dicPeeridAndUid.Remove(peerid);

        for (int i = 0; i < listCustomPeer.Count; i++)
        {
            if(listCustomPeer[i].peerId == peerid)
            {
                listCustomPeer.RemoveAt(i);
                break;
            }
        }
    }

    public void JoinChannel()
    {
        RTCManager.Instance.JoinChannel();
        RTCManager.Instance.MuteLocalAudioStream(CustomInfo.isSendAudio);
        RTCManager.Instance.MuteLocalVideoStream(CustomInfo.isSendVideo);
    }

    public void LeaveChannel()
    {
        RTCManager.Instance.LeaveChannel();
        InitData();
        RoomMain.Instance.agoraRawImage.gameObject.SetActive(false);
        RoomMain.Instance.agoraRawImage.texture = null;
    }

    public void ShowViewRawImage(string peerId, RawImage rawImage)
    {
        if (!dicPeeridAndUid.ContainsKey(peerId))
            return;
        Debug.Log(" AddListShowView " + peerId);

        if (rawImage.name == "AgoraRawImage")
            mainViewPeerId = peerId;

        rawImage.gameObject.SetActive(true);
        rawImage.rectTransform.localEulerAngles = new Vector3(0, 180, 180);

        RTCManager.Instance.ShowViewRawImage(dicPeeridAndUid[peerId].ToString(), rawImage);
    }

    public void ShowOneView(RawImage rawImage)
    {
        if (dicPeeridAndUid.Count < 2)
            return;
        //  rawImage.gameObject.SetActive(true);
        rawImage.rectTransform.localEulerAngles = new Vector3(0, 180, 180);
        RTCManager.Instance.ShowViewRawImage(dicPeeridAndUid.Values.Skip(1).First().ToString(), rawImage);
    }

    public void UserJoined(uint uid)
    {
        if (uid == dicPeeridAndUid.Values.Skip(1).First())
        {

            //  RoomMain.Instance.agoraRawImage.gameObject.SetActive(true);
            RoomMain.Instance.agoraRawImage.rectTransform.localEulerAngles = new Vector3(0, 180, 180);
            RTCManager.Instance.ShowViewRawImage(dicPeeridAndUid.Values.Skip(1).First().ToString(), RoomMain.Instance.agoraRawImage);

            foreach (var item in dicPeeridAndUid)
            {
                if (item.Value == uid)
                    mainViewPeerId = item.Key;
            }
        }

    }

    public void MuteLocalAudioStream(bool isAudio)
    {
        RTCManager.Instance.MuteLocalAudioStream(isAudio);
    }

    public void MuteLocalVideoStream(bool isVideo)
    {
        RTCManager.Instance.MuteLocalVideoStream(isVideo);
    }

    public void MuteRemoteAudioStream(string peerid,bool isAudio)
    {
        if (!dicPeeridAndUid.ContainsKey(peerid))
            return;
        RTCManager.Instance.MuteRemoteAudioStream(dicPeeridAndUid[peerid].ToString(), isAudio);

    }

    public void MuteRemoteVideoStream(string peerid,bool isVideo)
    {
        if (!dicPeeridAndUid.ContainsKey(peerid))
            return;
        RTCManager.Instance.MuteRemoteVideoStream(dicPeeridAndUid[peerid].ToString(), isVideo);
    }

    public void RemoteAudioStateChanged(string uid, REMOTE_AUDIO_STATE_RTC state, REMOTE_AUIDO_STATE_REASON_RTC reason)
    {
        if (!dicPeeridAndUid.ContainsValue(StringToUint(uid)))
            return;

        for (int i = 0; i < listCustomPeer.Count; i++)
        {
            if (dicPeeridAndUid[listCustomPeer[i].peerId] == StringToUint(uid))
            {
                 switch (reason)
                {
                 
                    case REMOTE_AUIDO_STATE_REASON_RTC.REMOTE_AUDIO_REASON_NETWORK_CONGESTION:
                        //  listCustomPeer[i].isAudio = false;
                        break;
                    case REMOTE_AUIDO_STATE_REASON_RTC.REMOTE_AUDIO_REASON_NETWORK_RECOVERY:
                        //  listCustomPeer[i].isAudio = true;
                        break;
                    case REMOTE_AUIDO_STATE_REASON_RTC.REMOTE_AUDIO_REASON_LOCAL_MUTED:
                        listCustomPeer[i].isCloseAudio = true;
                        break;
                    case REMOTE_AUIDO_STATE_REASON_RTC.REMOTE_AUDIO_REASON_LOCAL_UNMUTED:
                        listCustomPeer[i].isCloseAudio = false;
                        break;
                    case REMOTE_AUIDO_STATE_REASON_RTC.REMOTE_AUDIO_REASON_REMOTE_MUTED:
                        listCustomPeer[i].isAudio = false;
                        break;
                    case REMOTE_AUIDO_STATE_REASON_RTC.REMOTE_AUDIO_REASON_REMOTE_UNMUTED:
                        listCustomPeer[i].isAudio = true;
                        break;
                    case REMOTE_AUIDO_STATE_REASON_RTC.REMOTE_AUDIO_REASON_REMOTE_OFFLINE:
                        listCustomPeer[i].isAudio = false;
                        break;
                    default:
                        break;
                }
                break;
            }
        }
    }

    public void RemoteVideoStateChanged(string uid, REMOTE_VIDEO_STATE_RTC state , REMOTE_VIDEO_STATE_REASON_RTC reason)
    {
        if (!dicPeeridAndUid.ContainsValue(StringToUint(uid)))
            return;
        for (int i = 0; i < listCustomPeer.Count; i++)
        {
            if (dicPeeridAndUid[listCustomPeer[i].peerId] == StringToUint(uid))
            {
                switch (state)
                {
                    case REMOTE_VIDEO_STATE_RTC.REMOTE_VIDEO_STATE_STOPPED:
                        break;
                    case REMOTE_VIDEO_STATE_RTC.REMOTE_VIDEO_STATE_STARTING:
                        listCustomPeer[i].isVideo = true;
                        CloseAgoraMainImage(listCustomPeer[i].peerId, true);
                        break;
                    case REMOTE_VIDEO_STATE_RTC.REMOTE_VIDEO_STATE_DECODING:
                        listCustomPeer[i].isCloseVideo = false;
                        CloseAgoraMainImage(listCustomPeer[i].peerId, true);
                        break;
                    case REMOTE_VIDEO_STATE_RTC.REMOTE_VIDEO_STATE_FROZEN:
                        break;
                    case REMOTE_VIDEO_STATE_RTC.REMOTE_VIDEO_STATE_FAILED:
                        break;
                    default:
                        break;
                }

                switch (reason)
                {                  
                    case REMOTE_VIDEO_STATE_REASON_RTC.REMOTE_VIDEO_STATE_REASON_NETWORK_CONGESTION://网络阻塞。

                        //  listCustomPeer[i].isVideo = false;
                        break;
                    case REMOTE_VIDEO_STATE_REASON_RTC.REMOTE_VIDEO_STATE_REASON_NETWORK_RECOVERY:// 网络恢复正常。

                        //  listCustomPeer[i].isVideo = true;
                        break;
                    case REMOTE_VIDEO_STATE_REASON_RTC.REMOTE_VIDEO_STATE_REASON_LOCAL_MUTED://本地用户停止接收远端视频流或本地用户禁用视频模块

                        listCustomPeer[i].isCloseVideo = true;
                        CloseAgoraMainImage(listCustomPeer[i].peerId, false);
                        break;
                    case REMOTE_VIDEO_STATE_REASON_RTC.REMOTE_VIDEO_STATE_REASON_LOCAL_UNMUTED://本地用户恢复接收远端视频流或本地用户启动视频模块

                        listCustomPeer[i].isCloseVideo = false;
                        CloseAgoraMainImage(listCustomPeer[i].peerId, true);
                        break;
                    case REMOTE_VIDEO_STATE_REASON_RTC.REMOTE_VIDEO_STATE_REASON_REMOTE_MUTED://远端用户停止发送视频流或远端用户禁用视频模块。

                        listCustomPeer[i].isVideo = false;
                        CloseAgoraMainImage(listCustomPeer[i].peerId, false);
                        break;
                    case REMOTE_VIDEO_STATE_REASON_RTC.REMOTE_VIDEO_STATE_REASON_REMOTE_UNMUTED://远端用户恢复发送视频流或远端用户启用视频模块。

                        listCustomPeer[i].isVideo = true;
                        CloseAgoraMainImage(listCustomPeer[i].peerId, true);
                        break;
                    case REMOTE_VIDEO_STATE_REASON_RTC.REMOTE_VIDEO_STATE_REASON_REMOTE_OFFLINE: //远端用户离开频道。

                        listCustomPeer[i].isVideo = false;
                        break;
                }
                break;
            }
        }
    }

    private void CloseAgoraMainImage(string peerid, bool isOpen)
    {
        if (peerid == mainViewPeerId)
            RoomMain.Instance.agoraRawImage.gameObject.SetActive(isOpen);
    }


    private uint StringToUint(string value)
    {
        //byte[] bytes = Encoding.ASCII.GetBytes(value);

        return (uint)int.Parse(value);
        // return BitConverter.ToUInt32(bytes);
    }
}