OnWebSocketMsg.cs 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105
  1. using LiveKit.Proto;
  2. using Newtonsoft.Json.Linq;
  3. using System.Collections;
  4. using System.Collections.Generic;
  5. using UnityEngine;
  6. public class OnWebSocketMsg : MonoSingleton<OnWebSocketMsg>
  7. {
  8. private void Update()
  9. {
  10. if(SignalClient.SignalResponseList.Count>0)
  11. {
  12. int ct = SignalClient.SignalResponseList.Count;
  13. for (int i = 0; i < ct; i++)
  14. {
  15. OnWebSocketMessage(SignalClient.SignalResponseList.Dequeue());
  16. }
  17. }
  18. }
  19. public void OnWebSocketMessage(SignalResponse response)
  20. {
  21. Debug.Log("DGJ ===> OnWebSocketMessage " + response);
  22. switch (response.MessageCase)
  23. {
  24. case SignalResponse.MessageOneofCase.None:
  25. break;
  26. case SignalResponse.MessageOneofCase.Join:
  27. break;
  28. case SignalResponse.MessageOneofCase.Answer:
  29. break;
  30. case SignalResponse.MessageOneofCase.Offer:
  31. break;
  32. case SignalResponse.MessageOneofCase.Trickle:
  33. break;
  34. case SignalResponse.MessageOneofCase.Update:
  35. if(response.Update.Participants!=null)
  36. {
  37. string msg = response.Update.Participants.ToString();
  38. msg = msg.Remove(0, 1);
  39. msg = msg.Remove(msg.Length - 1, 1);
  40. Debug.Log("DGJ ==> "+ msg);
  41. JObject obj = JObject.Parse(msg);
  42. string metadata = obj["metadata"].ToString();
  43. Debug.Log("DGJ == > metadata " + metadata);
  44. metadata = metadata.Replace('\"', '"');
  45. Debug.Log("DGJ == > metadata "+ metadata);
  46. JObject obj2 = JObject.Parse(metadata);
  47. Debug.Log("DGJ ===> roleId " + obj2["roleId"].ToString());
  48. if (obj2["roleId"].ToString() == "2")
  49. {
  50. string uid = obj["sid"].ToString();
  51. if(ScenesManager.Instance.getWindow()== ScenesManager.SceneType.ShowRTC)
  52. {
  53. ScenesManager.Instance.showWindow(ScenesManager.SceneType.ShowRoom);
  54. }
  55. // 专家进入房间 并且当前是在远程协助页面
  56. RTCRoomManager.Instance.ExpertJonin(uid);
  57. RTCRoomManager.Instance.UserJoined(UserEnum.Expert , obj2);
  58. }
  59. if(obj2["roleId"].ToString()=="3")
  60. {
  61. RTCRoomManager.Instance.UserJoined(UserEnum.Conterl, obj2);
  62. }
  63. }
  64. break;
  65. case SignalResponse.MessageOneofCase.TrackPublished:
  66. break;
  67. case SignalResponse.MessageOneofCase.Leave:
  68. break;
  69. case SignalResponse.MessageOneofCase.Mute:
  70. break;
  71. case SignalResponse.MessageOneofCase.SpeakersChanged:
  72. break;
  73. case SignalResponse.MessageOneofCase.RoomUpdate:
  74. break;
  75. case SignalResponse.MessageOneofCase.ConnectionQuality:
  76. break;
  77. case SignalResponse.MessageOneofCase.StreamStateUpdate:
  78. break;
  79. case SignalResponse.MessageOneofCase.SubscribedQualityUpdate:
  80. break;
  81. case SignalResponse.MessageOneofCase.SubscriptionPermissionUpdate:
  82. break;
  83. case SignalResponse.MessageOneofCase.RefreshToken:
  84. break;
  85. case SignalResponse.MessageOneofCase.TrackUnpublished:
  86. break;
  87. case SignalResponse.MessageOneofCase.Pong:
  88. break;
  89. default:
  90. break;
  91. }
  92. }
  93. }