Advertisement
hungcuong21891

Connect TelephoneWebSocket

May 30th, 2019
372
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.49 KB | None | 0 0
  1. public void ConnectSocket()
  2. {
  3. //try to check if has telephone interface or not, and not connect that socket if don't have telephone
  4. Debug.Log("Check telephone interface " + OGContentLoader.HASTELEPHONEINTERFACE);
  5.  
  6. if ((OGContentLoader.STAFFMODE && OGContentLoader.instance.permits.Contains("Phone"))
  7. || (!OGContentLoader.STAFFMODE && OGContentLoader.HASTELEPHONEINTERFACE)) {
  8. WebSocket lastSocket = ws;
  9. var secretToken = OGContentLoader.instance.getSecretToken ();
  10. var identity = OGContentLoader.instance.getIdentity ();
  11. // var socketURL = "wss://call-dev.poshiemedia.com/ws/" + secretToken + "/" + identity + "/";
  12. var socketURL = "wss://" + OGContentLoader.DOMAIN_CALLSERVER + "/ws/" + secretToken + "/" + identity + "/";
  13. //var socketURL = "ws://" + OGContentLoader.DOMAIN + "/cable?token=" + OGContentLoader.Deviceid;
  14. ws = new WebSocket (new System.Uri (socketURL));
  15. WebSocket thisWs = ws;
  16. if (lastSocket != null) {
  17. if (lastSocket.IsOpen) {
  18. lastSocket.Close ();
  19. }
  20. }
  21. //set callback OnError
  22. try {
  23. ws.OnError += (sender, e) => {
  24. if (thisWs != ws) {
  25. return;
  26. }
  27.  
  28.  
  29. if (e != null)
  30. Debug.Log ("TelephoneWebSocket - kji ERROR ERROR " + e.ToString ());
  31. else
  32. Debug.Log ("TelephoneWebSocket - ws.OnError " + sender);
  33.  
  34.  
  35. };
  36. } catch (Exception e) {
  37. Debug.Log ("TelephoneWebSocket - kji " + e.ToString ());
  38. }
  39. //set callback OnClosed
  40. ws.OnClosed += (WebSocket webSocket, UInt16 code, string message) => {
  41. Debug.Log ("TelephoneWebSocket- onClose ");
  42. if (thisWs != ws) {
  43.  
  44. return;
  45. }
  46.  
  47. ws = null;
  48.  
  49. };
  50. //set callback OnOpen
  51. ws.OnOpen += (WebSocket webSocket) => {
  52. if (thisWs != ws) {
  53. print ("TelephoneWebSocket - kji wrong socket");
  54. return;
  55. }
  56. socketState = SOCKET_STATE.CONNECTED;
  57. running = true;
  58.  
  59. };
  60. //set call back OnMessage
  61. ws.OnMessage += (WebSocket webSocket, string message) => {
  62. // l("kji server onMessage " + message);
  63. if (webSocket != ws) {
  64. print ("TelephoneWebSocket- kji wrong socket");
  65. return;
  66. }
  67. Debug.Log ("Cuong - Received Message - " + message);
  68. // l("kji server onMessage " + message);
  69. //handleMessage(sender, e);
  70. Enqueue (handleMessage (message));
  71. //
  72. };
  73. //Open Socket
  74. try {
  75. socketState = SOCKET_STATE.CONNECTING;
  76.  
  77. ws.Open ();
  78. } catch (Exception e) {
  79. print ("TelephoneWebSocket - kji " + e.ToString ());
  80. }
  81. }
  82. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement