Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public void ConnectSocket()
- {
- //try to check if has telephone interface or not, and not connect that socket if don't have telephone
- Debug.Log("Check telephone interface " + OGContentLoader.HASTELEPHONEINTERFACE);
- if ((OGContentLoader.STAFFMODE && OGContentLoader.instance.permits.Contains("Phone"))
- || (!OGContentLoader.STAFFMODE && OGContentLoader.HASTELEPHONEINTERFACE)) {
- WebSocket lastSocket = ws;
- var secretToken = OGContentLoader.instance.getSecretToken ();
- var identity = OGContentLoader.instance.getIdentity ();
- // var socketURL = "wss://call-dev.poshiemedia.com/ws/" + secretToken + "/" + identity + "/";
- var socketURL = "wss://" + OGContentLoader.DOMAIN_CALLSERVER + "/ws/" + secretToken + "/" + identity + "/";
- //var socketURL = "ws://" + OGContentLoader.DOMAIN + "/cable?token=" + OGContentLoader.Deviceid;
- ws = new WebSocket (new System.Uri (socketURL));
- WebSocket thisWs = ws;
- if (lastSocket != null) {
- if (lastSocket.IsOpen) {
- lastSocket.Close ();
- }
- }
- //set callback OnError
- try {
- ws.OnError += (sender, e) => {
- if (thisWs != ws) {
- return;
- }
- if (e != null)
- Debug.Log ("TelephoneWebSocket - kji ERROR ERROR " + e.ToString ());
- else
- Debug.Log ("TelephoneWebSocket - ws.OnError " + sender);
- };
- } catch (Exception e) {
- Debug.Log ("TelephoneWebSocket - kji " + e.ToString ());
- }
- //set callback OnClosed
- ws.OnClosed += (WebSocket webSocket, UInt16 code, string message) => {
- Debug.Log ("TelephoneWebSocket- onClose ");
- if (thisWs != ws) {
- return;
- }
- ws = null;
- };
- //set callback OnOpen
- ws.OnOpen += (WebSocket webSocket) => {
- if (thisWs != ws) {
- print ("TelephoneWebSocket - kji wrong socket");
- return;
- }
- socketState = SOCKET_STATE.CONNECTED;
- running = true;
- };
- //set call back OnMessage
- ws.OnMessage += (WebSocket webSocket, string message) => {
- // l("kji server onMessage " + message);
- if (webSocket != ws) {
- print ("TelephoneWebSocket- kji wrong socket");
- return;
- }
- Debug.Log ("Cuong - Received Message - " + message);
- // l("kji server onMessage " + message);
- //handleMessage(sender, e);
- Enqueue (handleMessage (message));
- //
- };
- //Open Socket
- try {
- socketState = SOCKET_STATE.CONNECTING;
- ws.Open ();
- } catch (Exception e) {
- print ("TelephoneWebSocket - kji " + e.ToString ());
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement