| | | 1 | | using System; |
| | | 2 | | using System.Collections; |
| | | 3 | | using System.Collections.Generic; |
| | | 4 | | using System.Net.Sockets; |
| | | 5 | | using DCL; |
| | | 6 | | using UnityEngine; |
| | | 7 | | using WebSocketSharp.Server; |
| | | 8 | | |
| | | 9 | | public class WebSocketCommunication : IKernelCommunication |
| | | 10 | | { |
| | | 11 | | WebSocketServer ws; |
| | | 12 | | private Coroutine updateCoroutine; |
| | | 13 | | private bool requestStop = false; |
| | | 14 | | |
| | 0 | 15 | | private Dictionary<string, GameObject> bridgeGameObjects = new Dictionary<string, GameObject>(); |
| | | 16 | | |
| | 0 | 17 | | public Dictionary<string, string> messageTypeToBridgeName = new Dictionary<string, string>(); // Public to be able t |
| | | 18 | | |
| | | 19 | | [System.NonSerialized] |
| | 0 | 20 | | public static Queue<DCLWebSocketService.Message> queuedMessages = new Queue<DCLWebSocketService.Message>(); |
| | | 21 | | |
| | | 22 | | [System.NonSerialized] |
| | | 23 | | public static volatile bool queuedMessagesDirty; |
| | | 24 | | |
| | 0 | 25 | | public bool isServerReady => ws.IsListening; |
| | | 26 | | |
| | | 27 | | private string StartServer(int port, int maxPort, bool withSSL) |
| | | 28 | | { |
| | 0 | 29 | | if (port > maxPort) |
| | | 30 | | { |
| | 0 | 31 | | throw new SocketException((int)SocketError.AddressAlreadyInUse); |
| | | 32 | | } |
| | | 33 | | string wssServerUrl; |
| | 0 | 34 | | string wssServiceId = "dcl"; |
| | | 35 | | try |
| | | 36 | | { |
| | 0 | 37 | | if (withSSL) |
| | | 38 | | { |
| | 0 | 39 | | wssServerUrl = $"wss://localhost:{port}/"; |
| | 0 | 40 | | ws = new WebSocketServer(wssServerUrl) |
| | | 41 | | { |
| | | 42 | | SslConfiguration = |
| | | 43 | | { |
| | | 44 | | ServerCertificate = CertificateUtils.CreateSelfSignedCert(), |
| | | 45 | | ClientCertificateRequired = false, |
| | | 46 | | CheckCertificateRevocation = false, |
| | 0 | 47 | | ClientCertificateValidationCallback = (sender, certificate, chain, sslPolicyErrors) => true |
| | | 48 | | } |
| | | 49 | | }; |
| | 0 | 50 | | } |
| | | 51 | | else |
| | | 52 | | { |
| | 0 | 53 | | wssServerUrl = $"ws://localhost:{port}/"; |
| | 0 | 54 | | ws = new WebSocketServer(wssServerUrl); |
| | | 55 | | } |
| | | 56 | | |
| | 0 | 57 | | ws.AddWebSocketService<DCLWebSocketService>("/" + wssServiceId); |
| | 0 | 58 | | ws.Start(); |
| | 0 | 59 | | } |
| | 0 | 60 | | catch (InvalidOperationException e) |
| | | 61 | | { |
| | 0 | 62 | | ws.Stop(); |
| | 0 | 63 | | if (withSSL) // Search for available ports only if we're using SSL |
| | | 64 | | { |
| | 0 | 65 | | SocketException se = (SocketException)e.InnerException; |
| | 0 | 66 | | if (se is { SocketErrorCode: SocketError.AddressAlreadyInUse }) |
| | | 67 | | { |
| | 0 | 68 | | return StartServer(port + 1, maxPort, withSSL); |
| | | 69 | | } |
| | | 70 | | } |
| | 0 | 71 | | throw new InvalidOperationException(e.Message, e.InnerException); |
| | | 72 | | } |
| | | 73 | | |
| | 0 | 74 | | string wssUrl = wssServerUrl + wssServiceId; |
| | 0 | 75 | | return wssUrl; |
| | 0 | 76 | | } |
| | | 77 | | |
| | 0 | 78 | | public WebSocketCommunication(bool withSSL = false) |
| | | 79 | | { |
| | 0 | 80 | | InitMessageTypeToBridgeName(); |
| | | 81 | | |
| | 0 | 82 | | DCL.DataStore.i.debugConfig.isWssDebugMode = true; |
| | | 83 | | |
| | 0 | 84 | | string url = StartServer(5000, 5100, withSSL); |
| | | 85 | | |
| | 0 | 86 | | Debug.Log("WebSocket Server URL: " + url); |
| | | 87 | | |
| | 0 | 88 | | DataStore.i.wsCommunication.url = url; |
| | | 89 | | |
| | 0 | 90 | | DataStore.i.wsCommunication.communicationReady.Set(true); |
| | | 91 | | |
| | 0 | 92 | | updateCoroutine = CoroutineStarter.Start(ProcessMessages()); |
| | 0 | 93 | | } |
| | | 94 | | |
| | | 95 | | private void InitMessageTypeToBridgeName() |
| | | 96 | | { |
| | | 97 | | // Please, use `Bridges` as a bridge name, avoid adding messages here. The system will use `Bridges` as the defa |
| | 0 | 98 | | messageTypeToBridgeName["SetDebug"] = "Main"; |
| | 0 | 99 | | messageTypeToBridgeName["SetSceneDebugPanel"] = "Main"; |
| | 0 | 100 | | messageTypeToBridgeName["ShowFPSPanel"] = "Main"; |
| | 0 | 101 | | messageTypeToBridgeName["HideFPSPanel"] = "Main"; |
| | 0 | 102 | | messageTypeToBridgeName["SetEngineDebugPanel"] = "Main"; |
| | 0 | 103 | | messageTypeToBridgeName["SendSceneMessage"] = "Main"; |
| | 0 | 104 | | messageTypeToBridgeName["LoadParcelScenes"] = "Main"; |
| | 0 | 105 | | messageTypeToBridgeName["UnloadScene"] = "Main"; |
| | 0 | 106 | | messageTypeToBridgeName["Reset"] = "Main"; |
| | 0 | 107 | | messageTypeToBridgeName["CreateGlobalScene"] = "Main"; |
| | 0 | 108 | | messageTypeToBridgeName["BuilderReady"] = "Main"; |
| | 0 | 109 | | messageTypeToBridgeName["UpdateParcelScenes"] = "Main"; |
| | 0 | 110 | | messageTypeToBridgeName["LoadProfile"] = "Main"; |
| | 0 | 111 | | messageTypeToBridgeName["AddUserProfileToCatalog"] = "Main"; |
| | 0 | 112 | | messageTypeToBridgeName["AddUserProfilesToCatalog"] = "Main"; |
| | 0 | 113 | | messageTypeToBridgeName["RemoveUserProfilesFromCatalog"] = "Main"; |
| | 0 | 114 | | messageTypeToBridgeName["ActivateRendering"] = "Main"; |
| | 0 | 115 | | messageTypeToBridgeName["DeactivateRendering"] = "Main"; |
| | 0 | 116 | | messageTypeToBridgeName["ForceActivateRendering"] = "Main"; |
| | 0 | 117 | | messageTypeToBridgeName["AddWearablesToCatalog"] = "Main"; |
| | 0 | 118 | | messageTypeToBridgeName["WearablesRequestFailed"] = "Main"; |
| | 0 | 119 | | messageTypeToBridgeName["RemoveWearablesFromCatalog"] = "Main"; |
| | 0 | 120 | | messageTypeToBridgeName["ClearWearableCatalog"] = "Main"; |
| | 0 | 121 | | messageTypeToBridgeName["InitializeFriends"] = "Main"; |
| | 0 | 122 | | messageTypeToBridgeName["UpdateFriendshipStatus"] = "Main"; |
| | 0 | 123 | | messageTypeToBridgeName["UpdateUserPresence"] = "Main"; |
| | 0 | 124 | | messageTypeToBridgeName["FriendNotFound"] = "Main"; |
| | 0 | 125 | | messageTypeToBridgeName["AddMessageToChatWindow"] = "Main"; |
| | 0 | 126 | | messageTypeToBridgeName["UpdateMinimapSceneInformation"] = "Main"; |
| | 0 | 127 | | messageTypeToBridgeName["UpdateHotScenesList"] = "Main"; |
| | 0 | 128 | | messageTypeToBridgeName["SetRenderProfile"] = "Main"; |
| | 0 | 129 | | messageTypeToBridgeName["CrashPayloadRequest"] = "Main"; |
| | 0 | 130 | | messageTypeToBridgeName["SetDisableAssetBundles"] = "Main"; |
| | 0 | 131 | | messageTypeToBridgeName["DumpRendererLockersInfo"] = "Main"; |
| | 0 | 132 | | messageTypeToBridgeName["PublishSceneResult"] = "Main"; |
| | 0 | 133 | | messageTypeToBridgeName["BuilderProjectInfo"] = "Main"; |
| | 0 | 134 | | messageTypeToBridgeName["BuilderInWorldCatalogHeaders"] = "Main"; |
| | 0 | 135 | | messageTypeToBridgeName["RequestedHeaders"] = "Main"; |
| | 0 | 136 | | messageTypeToBridgeName["AddAssets"] = "Main"; |
| | 0 | 137 | | messageTypeToBridgeName["RunPerformanceMeterTool"] = "Main"; |
| | 0 | 138 | | messageTypeToBridgeName["InstantiateBotsAtWorldPos"] = "Main"; |
| | 0 | 139 | | messageTypeToBridgeName["InstantiateBotsAtCoords"] = "Main"; |
| | 0 | 140 | | messageTypeToBridgeName["StartBotsRandomizedMovement"] = "Main"; |
| | 0 | 141 | | messageTypeToBridgeName["StopBotsMovement"] = "Main"; |
| | 0 | 142 | | messageTypeToBridgeName["RemoveBot"] = "Main"; |
| | 0 | 143 | | messageTypeToBridgeName["ClearBots"] = "Main"; |
| | | 144 | | |
| | 0 | 145 | | messageTypeToBridgeName["Teleport"] = "CharacterController"; |
| | | 146 | | |
| | 0 | 147 | | messageTypeToBridgeName["SetRotation"] = "CameraController"; |
| | | 148 | | |
| | 0 | 149 | | messageTypeToBridgeName["ShowNotificationFromJson"] = "HUDController"; |
| | 0 | 150 | | messageTypeToBridgeName["ConfigureHUDElement"] = "HUDController"; |
| | 0 | 151 | | messageTypeToBridgeName["ShowTermsOfServices"] = "HUDController"; |
| | 0 | 152 | | messageTypeToBridgeName["RequestTeleport"] = "HUDController"; |
| | 0 | 153 | | messageTypeToBridgeName["ShowAvatarEditorInSignUp"] = "HUDController"; |
| | 0 | 154 | | messageTypeToBridgeName["SetUserTalking"] = "HUDController"; |
| | 0 | 155 | | messageTypeToBridgeName["SetUsersMuted"] = "HUDController"; |
| | 0 | 156 | | messageTypeToBridgeName["ShowWelcomeNotification"] = "HUDController"; |
| | 0 | 157 | | messageTypeToBridgeName["UpdateBalanceOfMANA"] = "HUDController"; |
| | 0 | 158 | | messageTypeToBridgeName["SetPlayerTalking"] = "HUDController"; |
| | 0 | 159 | | messageTypeToBridgeName["SetVoiceChatEnabledByScene"] = "HUDController"; |
| | 0 | 160 | | messageTypeToBridgeName["TriggerSelfUserExpression"] = "HUDController"; |
| | 0 | 161 | | messageTypeToBridgeName["AirdroppingRequest"] = "HUDController"; |
| | | 162 | | |
| | 0 | 163 | | messageTypeToBridgeName["GetMousePosition"] = "BuilderController"; |
| | 0 | 164 | | messageTypeToBridgeName["SelectGizmo"] = "BuilderController"; |
| | 0 | 165 | | messageTypeToBridgeName["ResetObject"] = "BuilderController"; |
| | 0 | 166 | | messageTypeToBridgeName["ZoomDelta"] = "BuilderController"; |
| | 0 | 167 | | messageTypeToBridgeName["SetPlayMode"] = "BuilderController"; |
| | 0 | 168 | | messageTypeToBridgeName["TakeScreenshot"] = "BuilderController"; |
| | 0 | 169 | | messageTypeToBridgeName["ResetBuilderScene"] = "BuilderController"; |
| | 0 | 170 | | messageTypeToBridgeName["SetBuilderCameraPosition"] = "BuilderController"; |
| | 0 | 171 | | messageTypeToBridgeName["SetBuilderCameraRotation"] = "BuilderController"; |
| | 0 | 172 | | messageTypeToBridgeName["ResetBuilderCameraZoom"] = "BuilderController"; |
| | 0 | 173 | | messageTypeToBridgeName["SetGridResolution"] = "BuilderController"; |
| | 0 | 174 | | messageTypeToBridgeName["OnBuilderKeyDown"] = "BuilderController"; |
| | 0 | 175 | | messageTypeToBridgeName["UnloadBuilderScene"] = "BuilderController"; |
| | 0 | 176 | | messageTypeToBridgeName["SetSelectedEntities"] = "BuilderController"; |
| | 0 | 177 | | messageTypeToBridgeName["GetCameraTargetBuilder"] = "BuilderController"; |
| | 0 | 178 | | messageTypeToBridgeName["PreloadFile"] = "BuilderController"; |
| | 0 | 179 | | messageTypeToBridgeName["SetBuilderConfiguration"] = "BuilderController"; |
| | | 180 | | |
| | 0 | 181 | | messageTypeToBridgeName["SetTutorialEnabled"] = "TutorialController"; |
| | 0 | 182 | | messageTypeToBridgeName["SetTutorialEnabledForUsersThatAlreadyDidTheTutorial"] = "TutorialController"; |
| | 0 | 183 | | } |
| | | 184 | | |
| | | 185 | | IEnumerator ProcessMessages() |
| | | 186 | | { |
| | 0 | 187 | | var hudControllerGO = GameObject.Find("HUDController"); |
| | 0 | 188 | | var mainGO = GameObject.Find("Main"); |
| | | 189 | | |
| | 0 | 190 | | while (!requestStop) |
| | | 191 | | { |
| | 0 | 192 | | lock (queuedMessages) |
| | | 193 | | { |
| | 0 | 194 | | if (queuedMessagesDirty) |
| | | 195 | | { |
| | 0 | 196 | | while (queuedMessages.Count > 0) |
| | | 197 | | { |
| | 0 | 198 | | DCLWebSocketService.Message msg = queuedMessages.Dequeue(); |
| | | 199 | | |
| | 0 | 200 | | switch (msg.type) |
| | | 201 | | { |
| | | 202 | | // Add to this list the messages that are used a lot and you want better performance |
| | | 203 | | case "SendSceneMessage": |
| | 0 | 204 | | DCL.Environment.i.world.sceneController.SendSceneMessage(msg.payload); |
| | 0 | 205 | | break; |
| | | 206 | | case "Reset": |
| | 0 | 207 | | DCL.Environment.i.world.sceneController.UnloadAllScenesQueued(); |
| | 0 | 208 | | break; |
| | | 209 | | case "SetVoiceChatEnabledByScene": |
| | 0 | 210 | | if (int.TryParse(msg.payload, out int value)) // The payload should be `string`, this wi |
| | | 211 | | { |
| | 0 | 212 | | hudControllerGO.SendMessage(msg.type, value); |
| | | 213 | | } |
| | 0 | 214 | | break; |
| | | 215 | | case "RunPerformanceMeterTool": |
| | 0 | 216 | | if (float.TryParse(msg.payload, out float durationInSeconds)) // The payload should be ` |
| | | 217 | | { |
| | 0 | 218 | | mainGO.SendMessage(msg.type, durationInSeconds); |
| | | 219 | | } |
| | 0 | 220 | | break; |
| | | 221 | | default: |
| | 0 | 222 | | if (!messageTypeToBridgeName.TryGetValue(msg.type, out string bridgeName)) |
| | | 223 | | { |
| | 0 | 224 | | bridgeName = "Bridges"; // Default bridge |
| | | 225 | | } |
| | | 226 | | |
| | 0 | 227 | | if (bridgeGameObjects.TryGetValue(bridgeName, out GameObject bridgeObject) == false) |
| | | 228 | | { |
| | 0 | 229 | | bridgeObject = GameObject.Find(bridgeName); |
| | 0 | 230 | | bridgeGameObjects.Add(bridgeName, bridgeObject); |
| | | 231 | | } |
| | | 232 | | |
| | 0 | 233 | | if (bridgeObject != null) |
| | | 234 | | { |
| | 0 | 235 | | bridgeObject.SendMessage(msg.type, msg.payload); |
| | | 236 | | } |
| | | 237 | | break; |
| | | 238 | | } |
| | | 239 | | |
| | 0 | 240 | | if (DCLWebSocketService.VERBOSE) |
| | | 241 | | { |
| | 0 | 242 | | Debug.Log( |
| | | 243 | | "<b><color=#0000FF>WebSocketCommunication</color></b> >>> Got it! passing message of typ |
| | | 244 | | msg.type); |
| | | 245 | | } |
| | | 246 | | } |
| | | 247 | | } |
| | 0 | 248 | | } |
| | 0 | 249 | | yield return null; |
| | | 250 | | } |
| | 0 | 251 | | } |
| | 0 | 252 | | public void Dispose() { ws.Stop(); } |
| | | 253 | | } |