GHZMRSpace/Assets/GHZAlter/Agora/AgoraTestVideoNotToken.cs

using UnityEngine;
using UnityEngine.UI;
using UnityEngine.Serialization;
using Agora.Rtc;
using Agora.Util;
using Logger = Agora.Util.Logger;
using System.Collections.Generic;

public class AgoraTestVideoNotToken : MonoBehaviour
{
    [FormerlySerializedAs("appIdInput")]
    [SerializeField]
    private AppIdInput _appIdInput;

    [Header("_____________Basic Configuration_____________")]
    [FormerlySerializedAs("APP_ID")]
    [SerializeField]
    private string _appID = "";

    [FormerlySerializedAs("TOKEN")]
    [SerializeField]
    private string _token = "";

    [FormerlySerializedAs("CHANNEL_NAME")]
    [SerializeField]
    private string _channelName = "";

    public Text LogText;
    internal Logger Log;
    internal IRtcEngine RtcEngine = null;

    private Button _stopPublishButton;
    public Button _startPublishButton;


    public InputField inputChannel;
    public Button joinChannel;
    public Button leaveChannel;
    public Button audioBtn;
    public Button videoBtn;
    private bool isAudio;
    private bool isVideo;

    private static Dictionary<string, Agora.Rtc.UserInfo> disUserPeer_Uid;
    // Use this for initialization
    private void Start()
    {
        LoadAssetData();
        if (CheckAppId())
        {
            InitEngine();
           // JoinChannel();
            SetupUI();
        }
        disUserPeer_Uid = new Dictionary<string, Agora.Rtc.UserInfo>();
    }

    // Update is called once per frame
    private void Update()
    {
        PermissionHelper.RequestMicrophontPermission();
        PermissionHelper.RequestCameraPermission();
    }

    //Show data in AgoraBasicProfile
    [ContextMenu("ShowAgoraBasicProfileData")]
    private void LoadAssetData()
    {
        if (_appIdInput == null) return;
        _appID = _appIdInput.appID;
        _token = _appIdInput.token;
        _channelName = _appIdInput.channelName;
    }


    private bool CheckAppId()
    {
        Log = new Logger(LogText);
        return Log.DebugAssert(_appID.Length > 10, "Please fill in your appId in API-Example/profile/appIdInput.asset");
    }

    private void InitEngine()
    {
        RtcEngine = Agora.Rtc.RtcEngine.CreateAgoraRtcEngine();
        AgoraVideoTestEventHandler handler = new AgoraVideoTestEventHandler(this);
        RtcEngineContext context = new RtcEngineContext(_appID, 0,
                                    CHANNEL_PROFILE_TYPE.CHANNEL_PROFILE_LIVE_BROADCASTING,
                                    AUDIO_SCENARIO_TYPE.AUDIO_SCENARIO_DEFAULT);
        RtcEngine.Initialize(context);
        RtcEngine.InitEventHandler(handler);
    }

    private void JoinChannel()
    {
        RtcEngine.EnableAudio();
        RtcEngine.EnableVideo();
        VideoEncoderConfiguration config = new VideoEncoderConfiguration();
        config.dimensions = new VideoDimensions(640, 360);
        config.frameRate = 15;
        config.bitrate = 0;
        RtcEngine.SetVideoEncoderConfiguration(config);
        RtcEngine.SetChannelProfile(CHANNEL_PROFILE_TYPE.CHANNEL_PROFILE_COMMUNICATION);
        RtcEngine.SetClientRole(CLIENT_ROLE_TYPE.CLIENT_ROLE_BROADCASTER);
        _channelName = inputChannel.text;
        RtcEngine.JoinChannel(_token, _channelName);
    }

    private void SetupUI()
    {
        _stopPublishButton = GameObject.Find("StopButton").GetComponent<Button>();
        _stopPublishButton.onClick.AddListener(StopPublish);

        _startPublishButton = GameObject.Find("StartButton").GetComponent<Button>();
        _startPublishButton.onClick.AddListener(StartPublish);
        _startPublishButton.gameObject.SetActive(false);

        joinChannel.onClick.AddListener(JoinChannel);
        leaveChannel.onClick.AddListener(LeaveChannel);

        isAudio = true;
        isVideo = true;
        audioBtn.onClick.AddListener(() =>
        {
            isAudio = !isAudio;
            int msg = RtcEngine.EnableLocalAudio(isAudio);
            switch (msg)
            {
                case 0:
                    LogText.text = isAudio?"打开本地音频成功":"关闭本地音频成功 ";
                    break;
                default:
                    LogText.text = "开关本地音频失败： " + msg;
                    break;
            }
        });

        videoBtn.onClick.AddListener(() =>
        {
            isVideo = !isVideo;
            int msg = RtcEngine.EnableLocalVideo(isVideo);
            switch (msg)
            {
                case 0:
                    LogText.text = isVideo?"打开本地视频成功 ": "关闭本地视频成功 ";
                    break;
                default:
                    LogText.text = "开关本地视频失败： " + msg;
                    break;
            }
        });

        //取消或恢复订阅指定远端用户的音频流。
        //RtcEngine.MuteRemoteAudioStream();

        //取消或恢复订阅指定远端用户的视频流。
        //RtcEngine.MuteRemoteVideoStream();

       
    }

    public void LeaveChannel()
    {
        int msg = RtcEngine.LeaveChannel();
        switch (msg)
        {
            case 0:
                LogText.text = "成功退出频道： "+_channelName;
                break;
            default:
                LogText.text = "退出频道失败： " + msg;
                break;
        }
    }

    private void StopPublish()
    {
        var options = new ChannelMediaOptions();
        options.publishMicrophoneTrack.SetValue(false);
        options.publishCameraTrack.SetValue(false);
        var nRet = RtcEngine.UpdateChannelMediaOptions(options);
        this.Log.UpdateLog("UpdateChannelMediaOptions: " + nRet);

        _stopPublishButton.gameObject.SetActive(false);
        _startPublishButton.gameObject.SetActive(true);
    }

    private void StartPublish()
    {
        var options = new ChannelMediaOptions();
        options.publishMicrophoneTrack.SetValue(true);
        options.publishCameraTrack.SetValue(true);
        var nRet = RtcEngine.UpdateChannelMediaOptions(options);
        this.Log.UpdateLog("UpdateChannelMediaOptions: " + nRet);

        _stopPublishButton.gameObject.SetActive(true);
        _startPublishButton.gameObject.SetActive(false);
    }

    private void OnDestroy()
    {
        Debug.Log("OnDestroy");
        if (RtcEngine == null) return;
        RtcEngine.InitEventHandler(null);
        RtcEngine.LeaveChannel();
        RtcEngine.Dispose();
    }

    internal string GetChannelName()
    {
        return _channelName;
    }

    internal static void MakeVideoView(uint uid, string channelId = "")
    {
        var go = GameObject.Find(uid.ToString());
        if (!ReferenceEquals(go, null))
        {
            return; // reuse
        }

        // create a GameObject and assign to this new user
        var videoSurface = MakeImageSurface(uid.ToString());
        if (ReferenceEquals(videoSurface, null)) return;
        // configure videoSurface
        if (uid == 0)
        {
            videoSurface.SetForUser(uid, channelId);
        }
        else
        {
            videoSurface.SetForUser(uid, channelId, VIDEO_SOURCE_TYPE.VIDEO_SOURCE_REMOTE);
        }

        videoSurface.OnTextureSizeModify += (int width, int height) =>
        {
            float scale = (float)height / (float)width;
            videoSurface.transform.localScale = new Vector3(-5, 5 * scale, 1);
            Debug.Log("OnTextureSizeModify: " + width + "  " + height);
        };

        videoSurface.SetEnable(true);
    }

    internal static void OnUserInfoUpdated(uint uid, Agora.Rtc.UserInfo info)
    {
        Debug.Log(info.uid);
        disUserPeer_Uid.Add("", info);
    }

    #region -- Video Render UI Logic ---

    // VIDEO TYPE 1: 3D Object
    private static VideoSurface MakePlaneSurface(string goName)
    {
        var go = GameObject.CreatePrimitive(PrimitiveType.Plane);

        if (go == null)
        {
            return null;
        }

        go.name = goName;
        // set up transform
        go.transform.Rotate(-90.0f, 0.0f, 0.0f);
        var yPos = Random.Range(3.0f, 5.0f);
        var xPos = Random.Range(-2.0f, 2.0f);
        go.transform.position = Vector3.zero;
        go.transform.localScale = new Vector3(0.25f, 0.5f, 0.5f);

        // configure videoSurface
        var videoSurface = go.AddComponent<VideoSurface>();
        return videoSurface;
    }

    // Video TYPE 2: RawImage
    private static VideoSurface MakeImageSurface(string goName)
    {
        GameObject go = new GameObject();

        if (go == null)
        {
            return null;
        }

        go.name = goName;
        // to be renderered onto
        go.AddComponent<RawImage>();
        // make the object draggable
        go.AddComponent<UIElementDrag>();
        var canvas = GameObject.Find("VideoCanvas");
        if (canvas != null)
        {
            go.transform.parent = canvas.transform;
            Debug.Log("add video view");
        }
        else
        {
            Debug.Log("Canvas is null video view");
        }

        // set up transform
        go.transform.Rotate(0f, 0.0f, 180.0f);
        go.transform.localPosition = Vector3.zero;
        go.transform.localScale = new Vector3(2f, 3f, 1f);

        // configure videoSurface
        var videoSurface = go.AddComponent<VideoSurface>();
        return videoSurface;
    }

    internal static void DestroyVideoView(uint uid)
    {
        var go = GameObject.Find(uid.ToString());
        if (!ReferenceEquals(go, null))
        {
            Destroy(go);
        }
    }

    #endregion
}

#region -- Agora Event ---

public class AgoraVideoTestEventHandler : IRtcEngineEventHandler
{
    private readonly AgoraTestVideoNotToken _videoSample;

    internal AgoraVideoTestEventHandler(AgoraTestVideoNotToken videoSample)
    {
        _videoSample = videoSample;
    }

    public override void OnError(int err, string msg)
    {
        _videoSample.Log.UpdateLog(string.Format("OnError err: {0}, msg: {1}", err, msg));
    }

    public override void OnJoinChannelSuccess(RtcConnection connection, int elapsed)
    {
        int build = 0;
        Debug.Log("Agora: OnJoinChannelSuccess ");
        _videoSample.Log.UpdateLog(string.Format("sdk version: ${0}",
            _videoSample.RtcEngine.GetVersion(ref build)));
        _videoSample.Log.UpdateLog(string.Format("sdk build: ${0}",
          build));
        _videoSample.Log.UpdateLog(
            string.Format("OnJoinChannelSuccess channelName: {0}, uid: {1}, elapsed: {2}",
                            connection.channelId, connection.localUid, elapsed));

        AgoraTestVideoNotToken.MakeVideoView(0);
    }

    public override void OnRejoinChannelSuccess(RtcConnection connection, int elapsed)
    {
        _videoSample.Log.UpdateLog("OnRejoinChannelSuccess");
    }

    public override void OnLeaveChannel(RtcConnection connection, RtcStats stats)
    {
        _videoSample.Log.UpdateLog("OnLeaveChannel");
        AgoraTestVideoNotToken.DestroyVideoView(0);
    }

    public override void OnClientRoleChanged(RtcConnection connection, CLIENT_ROLE_TYPE oldRole, CLIENT_ROLE_TYPE newRole)
    {
        _videoSample.Log.UpdateLog("OnClientRoleChanged");
    }

    public override void OnUserJoined(RtcConnection connection, uint uid, int elapsed)
    {
        _videoSample.Log.UpdateLog(string.Format("OnUserJoined uid: ${0} elapsed: ${1}", uid, elapsed));
        AgoraTestVideoNotToken.MakeVideoView(uid, _videoSample.GetChannelName());
    }

    public override void OnUserOffline(RtcConnection connection, uint uid, USER_OFFLINE_REASON_TYPE reason)
    {
        _videoSample.Log.UpdateLog(string.Format("OnUserOffLine uid: ${0}, reason: ${1}", uid,
            (int)reason));
        AgoraTestVideoNotToken.DestroyVideoView(uid);
    }

    public override void OnUserInfoUpdated(uint uid, Agora.Rtc.UserInfo info)
    {
        _videoSample.Log.UpdateLog(string.Format(" 用户 :${0}  加入房间", uid));

        AgoraTestVideoNotToken.OnUserInfoUpdated(uid, info);
    }
   

    public override void OnUplinkNetworkInfoUpdated(UplinkNetworkInfo info)
    {
        _videoSample.Log.UpdateLog("OnUplinkNetworkInfoUpdated");
    }

    public override void OnDownlinkNetworkInfoUpdated(DownlinkNetworkInfo info)
    {
        _videoSample.Log.UpdateLog("OnDownlinkNetworkInfoUpdated");
    }
}

#endregion