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