| | | 1 | | using DCL.Models; |
| | | 2 | | using UnityEngine; |
| | | 3 | | using System.Collections.Generic; |
| | | 4 | | using System.Collections; |
| | | 5 | | using System; |
| | | 6 | | |
| | | 7 | | namespace DCL.Controllers |
| | | 8 | | { |
| | | 9 | | public class SceneBoundsChecker : ISceneBoundsChecker |
| | | 10 | | { |
| | | 11 | | public event Action<IDCLEntity, bool> OnEntityBoundsCheckerStatusChanged; |
| | 975 | 12 | | public bool enabled => entitiesCheckRoutine != null; |
| | 702 | 13 | | public float timeBetweenChecks { get; set; } = 0.5f; |
| | 2 | 14 | | public int entitiesToCheckCount => entitiesToCheck.Count; |
| | | 15 | | |
| | | 16 | | private const bool VERBOSE = false; |
| | 666 | 17 | | private Logger logger = new Logger("SceneBoundsChecker") {verboseEnabled = VERBOSE}; |
| | 666 | 18 | | private HashSet<IDCLEntity> entitiesToCheck = new HashSet<IDCLEntity>(); |
| | 666 | 19 | | private HashSet<IDCLEntity> checkedEntities = new HashSet<IDCLEntity>(); |
| | 666 | 20 | | private HashSet<IDCLEntity> persistentEntities = new HashSet<IDCLEntity>(); |
| | | 21 | | private ISceneBoundsFeedbackStyle feedbackStyle; |
| | | 22 | | private Coroutine entitiesCheckRoutine = null; |
| | | 23 | | private float lastCheckTime; |
| | | 24 | | |
| | | 25 | | public void Initialize() |
| | | 26 | | { |
| | 666 | 27 | | Start(); |
| | 666 | 28 | | } |
| | | 29 | | |
| | 666 | 30 | | public SceneBoundsChecker(ISceneBoundsFeedbackStyle feedbackStyle = null) |
| | | 31 | | { |
| | 666 | 32 | | this.feedbackStyle = feedbackStyle ?? new SceneBoundsFeedbackStyle_Simple(); |
| | 666 | 33 | | } |
| | | 34 | | |
| | | 35 | | public void SetFeedbackStyle(ISceneBoundsFeedbackStyle feedbackStyle) |
| | | 36 | | { |
| | 35 | 37 | | this.feedbackStyle.CleanFeedback(); |
| | 35 | 38 | | this.feedbackStyle = feedbackStyle; |
| | 35 | 39 | | Restart(); |
| | 35 | 40 | | } |
| | | 41 | | |
| | 71 | 42 | | public ISceneBoundsFeedbackStyle GetFeedbackStyle() { return feedbackStyle; } |
| | | 43 | | |
| | 0 | 44 | | public List<Material> GetOriginalMaterials(MeshesInfo meshesInfo) { return feedbackStyle.GetOriginalMaterials(me |
| | | 45 | | |
| | | 46 | | |
| | | 47 | | // TODO: Improve MessagingControllersManager.i.timeBudgetCounter usage once we have the centralized budget contr |
| | | 48 | | private IEnumerator CheckEntities() |
| | | 49 | | { |
| | 9924 | 50 | | while (true) |
| | | 51 | | { |
| | 10625 | 52 | | float elapsedTime = Time.realtimeSinceStartup - lastCheckTime; |
| | 10625 | 53 | | if ((entitiesToCheck.Count > 0) && (timeBetweenChecks <= 0f || elapsedTime >= timeBetweenChecks)) |
| | | 54 | | { |
| | | 55 | | //TODO(Brian): Remove later when we implement a centralized way of handling time budgets |
| | 69 | 56 | | var messagingManager = Environment.i.messaging.manager as MessagingControllersManager; |
| | | 57 | | |
| | | 58 | | void processEntitiesList(HashSet<IDCLEntity> entities) |
| | | 59 | | { |
| | 69 | 60 | | if (messagingManager != null && messagingManager.timeBudgetCounter <= 0f) |
| | | 61 | | { |
| | | 62 | | if(VERBOSE) |
| | | 63 | | logger.Verbose("Time budget reached, escaping entities processing until next iteration.. |
| | 0 | 64 | | return; |
| | | 65 | | } |
| | | 66 | | |
| | 69 | 67 | | using HashSet<IDCLEntity>.Enumerator iterator = entities.GetEnumerator(); |
| | 142 | 68 | | while (iterator.MoveNext()) |
| | | 69 | | { |
| | 73 | 70 | | if (messagingManager != null && messagingManager.timeBudgetCounter <= 0f) |
| | | 71 | | { |
| | 0 | 72 | | if(VERBOSE) |
| | | 73 | | logger.Verbose("Time budget reached, escaping entities processing until next iterati |
| | | 74 | | return; |
| | | 75 | | } |
| | | 76 | | |
| | 73 | 77 | | float startTime = Time.realtimeSinceStartup; |
| | | 78 | | |
| | 73 | 79 | | RunEntityEvaluation(iterator.Current); |
| | 73 | 80 | | checkedEntities.Add(iterator.Current); |
| | | 81 | | |
| | 73 | 82 | | float finishTime = Time.realtimeSinceStartup; |
| | | 83 | | |
| | 73 | 84 | | if ( messagingManager != null ) |
| | 73 | 85 | | messagingManager.timeBudgetCounter -= (finishTime - startTime); |
| | | 86 | | } |
| | 138 | 87 | | } |
| | | 88 | | |
| | 69 | 89 | | processEntitiesList(entitiesToCheck); |
| | | 90 | | |
| | | 91 | | // As we can't modify the hashset while traversing it, we keep track of the entities that should be |
| | 69 | 92 | | using (var iterator = checkedEntities.GetEnumerator()) |
| | | 93 | | { |
| | 142 | 94 | | while (iterator.MoveNext()) |
| | | 95 | | { |
| | 73 | 96 | | RemoveEntity(iterator.Current, removeIfPersistent: false, resetState: false); |
| | | 97 | | } |
| | 69 | 98 | | } |
| | | 99 | | |
| | | 100 | | if(VERBOSE) |
| | | 101 | | logger.Verbose($"Finished checking entities: checked entities {checkedEntities.Count}; entitiesT |
| | | 102 | | |
| | 69 | 103 | | checkedEntities.Clear(); |
| | | 104 | | |
| | 69 | 105 | | lastCheckTime = Time.realtimeSinceStartup; |
| | | 106 | | } |
| | | 107 | | |
| | 10625 | 108 | | yield return null; |
| | | 109 | | } |
| | | 110 | | } |
| | | 111 | | |
| | | 112 | | public void Restart() |
| | | 113 | | { |
| | 35 | 114 | | Stop(); |
| | 35 | 115 | | Start(); |
| | 35 | 116 | | } |
| | | 117 | | |
| | | 118 | | public void Start() |
| | | 119 | | { |
| | 701 | 120 | | if (entitiesCheckRoutine != null) |
| | 0 | 121 | | return; |
| | | 122 | | |
| | 701 | 123 | | lastCheckTime = Time.realtimeSinceStartup; |
| | 701 | 124 | | entitiesCheckRoutine = CoroutineStarter.Start(CheckEntities()); |
| | 701 | 125 | | } |
| | | 126 | | |
| | | 127 | | public void Stop() |
| | | 128 | | { |
| | 720 | 129 | | if (entitiesCheckRoutine == null) |
| | 19 | 130 | | return; |
| | | 131 | | |
| | 701 | 132 | | CoroutineStarter.Stop(entitiesCheckRoutine); |
| | 701 | 133 | | entitiesCheckRoutine = null; |
| | 701 | 134 | | } |
| | | 135 | | |
| | | 136 | | public void Dispose() |
| | | 137 | | { |
| | 666 | 138 | | Stop(); |
| | 666 | 139 | | } |
| | | 140 | | |
| | | 141 | | public void AddEntityToBeChecked(IDCLEntity entity, bool isPersistent = false, bool runPreliminaryEvaluation = f |
| | | 142 | | { |
| | 1219 | 143 | | if (!enabled || (entity.scene != null && entity.scene.isPersistent)) |
| | 923 | 144 | | return; |
| | | 145 | | |
| | 296 | 146 | | if (runPreliminaryEvaluation) |
| | | 147 | | { |
| | | 148 | | // The outer bounds check is cheaper than the regular check |
| | 234 | 149 | | RunEntityEvaluation(entity, onlyOuterBoundsCheck: true); |
| | | 150 | | |
| | | 151 | | // No need to add the entity to be checked later if we already found it outside scene outer boundaries. |
| | | 152 | | // When the correct events are triggered again, the entity will be checked again. |
| | 234 | 153 | | if (!isPersistent && !entity.isInsideSceneOuterBoundaries) |
| | 84 | 154 | | return; |
| | | 155 | | } |
| | | 156 | | |
| | 212 | 157 | | entitiesToCheck.Add(entity); |
| | | 158 | | |
| | 212 | 159 | | if (isPersistent) |
| | 6 | 160 | | persistentEntities.Add(entity); |
| | 212 | 161 | | } |
| | | 162 | | |
| | | 163 | | public void RemoveEntity(IDCLEntity entity, bool removeIfPersistent = false, bool resetState = false) |
| | | 164 | | { |
| | 537 | 165 | | if (!enabled || (!removeIfPersistent && persistentEntities.Contains(entity))) |
| | 0 | 166 | | return; |
| | | 167 | | |
| | 537 | 168 | | entitiesToCheck.Remove(entity); |
| | 537 | 169 | | persistentEntities.Remove(entity); |
| | | 170 | | |
| | 537 | 171 | | if(resetState) |
| | 462 | 172 | | SetMeshesAndComponentsInsideBoundariesState(entity, true); |
| | 537 | 173 | | } |
| | | 174 | | |
| | 7 | 175 | | public bool WasAddedAsPersistent(IDCLEntity entity) { return persistentEntities.Contains(entity); } |
| | | 176 | | |
| | | 177 | | // TODO: When we remove the DCLBuilderEntity class we'll be able to remove this overload |
| | | 178 | | public void RunEntityEvaluation(IDCLEntity entity) |
| | | 179 | | { |
| | 87 | 180 | | RunEntityEvaluation(entity, false); |
| | 87 | 181 | | } |
| | | 182 | | |
| | | 183 | | public void RunEntityEvaluation(IDCLEntity entity, bool onlyOuterBoundsCheck) |
| | | 184 | | { |
| | 332 | 185 | | if (entity == null || entity.gameObject == null || entity.scene == null || entity.scene.isPersistent) |
| | 7 | 186 | | return; |
| | | 187 | | |
| | | 188 | | // Recursively evaluate entity children as well, we need to check this up front because this entity may not |
| | 325 | 189 | | if (entity.children.Count > 0) |
| | | 190 | | { |
| | 9 | 191 | | using (var iterator = entity.children.GetEnumerator()) |
| | | 192 | | { |
| | 18 | 193 | | while (iterator.MoveNext()) |
| | | 194 | | { |
| | 9 | 195 | | RunEntityEvaluation(iterator.Current.Value, onlyOuterBoundsCheck); |
| | | 196 | | } |
| | 9 | 197 | | } |
| | | 198 | | } |
| | | 199 | | |
| | | 200 | | // If it has a mesh we don't evaluate its position due to artists "pivot point sloppiness", we evaluate its |
| | 325 | 201 | | if (HasMesh(entity)) |
| | 154 | 202 | | EvaluateMeshBounds(entity, onlyOuterBoundsCheck); |
| | | 203 | | else |
| | 171 | 204 | | EvaluateEntityPosition(entity, onlyOuterBoundsCheck); |
| | 171 | 205 | | } |
| | | 206 | | |
| | | 207 | | private void EvaluateMeshBounds(IDCLEntity entity, bool onlyOuterBoundsCheck = false) |
| | | 208 | | { |
| | 154 | 209 | | var loadWrapper = Environment.i.world.state.GetLoaderForEntity(entity); |
| | 154 | 210 | | if (loadWrapper != null && !loadWrapper.alreadyLoaded) |
| | 8 | 211 | | return; |
| | | 212 | | |
| | 146 | 213 | | entity.isInsideSceneOuterBoundaries = entity.scene.IsInsideSceneOuterBoundaries(entity.meshesInfo.mergedBoun |
| | | 214 | | |
| | 146 | 215 | | if (!entity.isInsideSceneOuterBoundaries) |
| | 93 | 216 | | SetMeshesAndComponentsInsideBoundariesState(entity, false); |
| | | 217 | | |
| | 146 | 218 | | if (!onlyOuterBoundsCheck) |
| | 47 | 219 | | SetMeshesAndComponentsInsideBoundariesState(entity, IsEntityMeshInsideSceneBoundaries(entity)); |
| | 146 | 220 | | } |
| | | 221 | | |
| | | 222 | | private void EvaluateEntityPosition(IDCLEntity entity, bool onlyOuterBoundsCheck = false) |
| | | 223 | | { |
| | 171 | 224 | | Vector3 entityGOPosition = entity.gameObject.transform.position; |
| | 171 | 225 | | entity.isInsideSceneOuterBoundaries = entity.scene.IsInsideSceneOuterBoundaries(entityGOPosition); |
| | | 226 | | |
| | 171 | 227 | | if (!entity.isInsideSceneOuterBoundaries) |
| | | 228 | | { |
| | 33 | 229 | | SetComponentsInsideBoundariesValidState(entity, false); |
| | 33 | 230 | | SetEntityInsideBoundariesState(entity, false); |
| | | 231 | | } |
| | | 232 | | |
| | 171 | 233 | | if (!onlyOuterBoundsCheck) |
| | | 234 | | { |
| | 37 | 235 | | bool isInsideBoundaries = entity.scene.IsInsideSceneBoundaries(entityGOPosition + CommonScriptableObject |
| | 37 | 236 | | SetComponentsInsideBoundariesValidState(entity, isInsideBoundaries); |
| | 37 | 237 | | SetEntityInsideBoundariesState(entity, isInsideBoundaries); |
| | | 238 | | } |
| | 171 | 239 | | } |
| | | 240 | | |
| | | 241 | | private void SetEntityInsideBoundariesState(IDCLEntity entity, bool isInsideBoundaries) |
| | | 242 | | { |
| | 672 | 243 | | if (entity.isInsideSceneBoundaries == isInsideBoundaries) |
| | 552 | 244 | | return; |
| | | 245 | | |
| | 120 | 246 | | entity.isInsideSceneBoundaries = isInsideBoundaries; |
| | 120 | 247 | | OnEntityBoundsCheckerStatusChanged?.Invoke(entity, isInsideBoundaries); |
| | 3 | 248 | | } |
| | | 249 | | |
| | | 250 | | private bool HasMesh(IDCLEntity entity) |
| | | 251 | | { |
| | 325 | 252 | | return entity.meshRootGameObject != null |
| | | 253 | | && (entity.meshesInfo.colliders.Count > 0 |
| | | 254 | | || (entity.meshesInfo.renderers != null |
| | | 255 | | && entity.meshesInfo.renderers.Length > 0)); |
| | | 256 | | } |
| | | 257 | | |
| | | 258 | | public bool IsEntityMeshInsideSceneBoundaries(IDCLEntity entity) |
| | | 259 | | { |
| | 88 | 260 | | if (entity.meshesInfo == null |
| | | 261 | | || entity.meshesInfo.meshRootGameObject == null |
| | | 262 | | || entity.meshesInfo.mergedBounds == null) |
| | 25 | 263 | | return false; |
| | | 264 | | |
| | | 265 | | // 1st check (full mesh AABB) |
| | 63 | 266 | | bool isInsideBoundaries = entity.scene.IsInsideSceneBoundaries(entity.meshesInfo.mergedBounds); |
| | | 267 | | |
| | | 268 | | // 2nd check (submeshes & colliders AABB) |
| | 63 | 269 | | if (!isInsideBoundaries) |
| | | 270 | | { |
| | 28 | 271 | | isInsideBoundaries = AreSubmeshesInsideBoundaries(entity) && AreCollidersInsideBoundaries(entity); |
| | | 272 | | } |
| | | 273 | | |
| | 63 | 274 | | return isInsideBoundaries; |
| | | 275 | | } |
| | | 276 | | |
| | | 277 | | private bool AreSubmeshesInsideBoundaries(IDCLEntity entity) |
| | | 278 | | { |
| | 66 | 279 | | for (int i = 0; i < entity.meshesInfo.renderers.Length; i++) |
| | | 280 | | { |
| | 29 | 281 | | Renderer renderer = entity.meshesInfo.renderers[i]; |
| | 29 | 282 | | if (renderer == null) |
| | | 283 | | continue; |
| | | 284 | | |
| | 29 | 285 | | if (!entity.scene.IsInsideSceneBoundaries(MeshesInfoUtils.GetSafeBounds(renderer.bounds, renderer.transf |
| | 24 | 286 | | return false; |
| | | 287 | | } |
| | | 288 | | |
| | 4 | 289 | | return true; |
| | | 290 | | } |
| | | 291 | | |
| | | 292 | | private bool AreCollidersInsideBoundaries(IDCLEntity entity) |
| | | 293 | | { |
| | 13 | 294 | | foreach (Collider collider in entity.meshesInfo.colliders) |
| | | 295 | | { |
| | 4 | 296 | | if (collider == null) |
| | | 297 | | continue; |
| | | 298 | | |
| | 4 | 299 | | if (!entity.scene.IsInsideSceneBoundaries(MeshesInfoUtils.GetSafeBounds(collider.bounds, collider.transf |
| | 3 | 300 | | return false; |
| | | 301 | | } |
| | | 302 | | |
| | 1 | 303 | | return true; |
| | 3 | 304 | | } |
| | | 305 | | |
| | | 306 | | private void SetMeshesAndComponentsInsideBoundariesState(IDCLEntity entity, bool isInsideBoundaries) |
| | | 307 | | { |
| | 602 | 308 | | SetEntityMeshesInsideBoundariesState(entity.meshesInfo, isInsideBoundaries); |
| | 602 | 309 | | SetEntityCollidersInsideBoundariesState(entity.meshesInfo, isInsideBoundaries); |
| | 602 | 310 | | SetComponentsInsideBoundariesValidState(entity, isInsideBoundaries); |
| | | 311 | | |
| | | 312 | | // Should always be set last as entity.isInsideSceneBoundaries is checked to avoid re-running code unnecessa |
| | 602 | 313 | | SetEntityInsideBoundariesState(entity, isInsideBoundaries); |
| | 602 | 314 | | } |
| | | 315 | | |
| | | 316 | | private void SetEntityMeshesInsideBoundariesState(MeshesInfo meshesInfo, bool isInsideBoundaries) |
| | | 317 | | { |
| | 602 | 318 | | feedbackStyle.ApplyFeedback(meshesInfo, isInsideBoundaries); |
| | 602 | 319 | | } |
| | | 320 | | |
| | | 321 | | private void SetEntityCollidersInsideBoundariesState(MeshesInfo meshesInfo, bool isInsideBoundaries) |
| | | 322 | | { |
| | 602 | 323 | | if (meshesInfo == null || meshesInfo.colliders.Count == 0 || !meshesInfo.currentShape.HasCollisions()) |
| | 394 | 324 | | return; |
| | | 325 | | |
| | 910 | 326 | | foreach (Collider collider in meshesInfo.colliders) |
| | | 327 | | { |
| | 247 | 328 | | if (collider == null) continue; |
| | | 329 | | |
| | 247 | 330 | | if (collider.enabled != isInsideBoundaries) |
| | 128 | 331 | | collider.enabled = isInsideBoundaries; |
| | | 332 | | } |
| | 208 | 333 | | } |
| | | 334 | | |
| | | 335 | | private void SetComponentsInsideBoundariesValidState(IDCLEntity entity, bool isInsideBoundaries) |
| | | 336 | | { |
| | 672 | 337 | | if(entity.isInsideSceneBoundaries == isInsideBoundaries || !DataStore.i.sceneBoundariesChecker.componentsChe |
| | 670 | 338 | | return; |
| | | 339 | | |
| | 8 | 340 | | foreach (IOutOfSceneBoundariesHandler component in DataStore.i.sceneBoundariesChecker.componentsCheckSceneBo |
| | | 341 | | { |
| | 2 | 342 | | component.UpdateOutOfBoundariesState(isInsideBoundaries); |
| | | 343 | | } |
| | 2 | 344 | | } |
| | | 345 | | } |
| | | 346 | | } |