package src; import collision.CollisionPool; import net.GemPredictionStore; import modes.HuntMode; import net.NetPacket.MarbleNetFlags; import net.PowerupPredictionStore; import net.MarblePredictionStore; import net.MarblePredictionStore.MarblePrediction; import net.MarbleUpdateQueue; import haxe.Exception; import net.NetPacket.MarbleUpdatePacket; import net.NetPacket.MarbleMovePacket; import net.MoveManager; import net.NetCommands; import net.Net; import net.ClientConnection; import net.ClientConnection.GameConnection; import rewind.InputRecorder; import gui.AchievementsGui; import src.Radar; import gui.LevelSelectGui; import h3d.scene.fwd.Light; import rewind.RewindManager; import Macros.MarbleWorldMacros; #if js import gui.MainMenuGui; #else import gui.ReplayCenterGui; #end import gui.ReplayNameDlg; import collision.Collision; import shapes.MegaMarble; import shapes.Blast; import shapes.Glass; import shapes.Checkpoint; import triggers.CheckpointTrigger; import shapes.EasterEgg; import shapes.Sign; import src.Replay; import gui.Canvas; import hxd.snd.Channel; import hxd.res.Sound; import src.ResourceLoader; import src.AudioManager; import src.Settings; import gui.LoadingGui; import src.MarbleGame; import gui.EndGameGui; #if hlsdl import sdl.Cursor; #end #if hldx import dx.Cursor; #end import src.ForceObject; import shaders.DirLight; import h3d.col.Bounds; import triggers.HelpTrigger; import triggers.InBoundsTrigger; import triggers.OutOfBoundsTrigger; import shapes.Trapdoor; import shapes.TimeTravel; import shapes.SuperSpeed; import shapes.AntiGravity; import shapes.SmallDuctFan; import shapes.DuctFan; import shapes.Helicopter; import shapes.RoundBumper; import shapes.SignCaution; import shapes.SuperJump; import shapes.Gem; import shapes.SignPlain; import shapes.EndPad; import shapes.StartPad; import h3d.Matrix; import mis.MisParser; import src.DifBuilder; import mis.MissionElement; import src.GameObject; import triggers.Trigger; import src.Mission; import src.TimeState; import gui.PlayGui; import src.ParticleSystem.ParticleManager; import src.Util; import h3d.Quat; import shapes.PowerUp; import collision.SphereCollisionEntity; import src.Sky; import h3d.scene.Mesh; import src.InstanceManager; import src.MeshBatch; import src.DtsObject; import src.PathedInterior; import hxd.Key; import h3d.Vector; import src.InteriorObject; import h3d.scene.Scene; import collision.CollisionWorld; import src.Marble; import src.Resource; import src.ProfilerUI; import src.ResourceLoaderWorker; import haxe.io.Path; import src.Console; import src.Gamepad; import modes.GameMode; import modes.NullMode; import modes.GameMode.GameModeFactory; import src.Renderer; import src.Analytics; import src.Debug; class MarbleWorld extends Scheduler { public var collisionWorld:CollisionWorld; public var instanceManager:InstanceManager; public var particleManager:ParticleManager; var playGui:PlayGui; var loadingGui:LoadingGui; var radar:Radar; public var interiors:Array = []; public var pathedInteriors:Array = []; public var marbles:Array = []; public var dtsObjects:Array = []; public var powerUps:Array = []; public var forceObjects:Array = []; public var triggers:Array = []; public var gems:Array = []; public var namedObjects:Map = []; public var simGroups:Map> = []; var shapeImmunity:Array = []; var shapeOrTriggerInside:Array = []; public var timeState:TimeState = new TimeState(); public var bonusTime:Float = 0; public var sky:Sky; var endPadElement:MissionElementStaticShape; var endPad:EndPad; var skyElement:MissionElementSky; public var gameMode:GameMode; // Lighting public var ambient:Vector; public var dirLight:Vector; public var dirLightDir:Vector; public var scene:Scene; public var scene2d:h2d.Scene; public var mission:Mission; public var game:String; public var marble:Marble; public var finishTime:TimeState; public var finishPitch:Float; public var finishYaw:Float; public var totalGems:Int = 0; public var gemCount:Int = 0; public var skipStartBugPauseTime:Float = 0.0; var renderBlastAmount:Float = 0; public var cursorLock:Bool = true; var timeTravelSound:Channel; var helpTextTimeState:Float = -1e8; var alertTextTimeState:Float = -1e8; var respawnPressedTime:Float = -1e8; // Orientation var orientationChangeTime = -1e8; var oldOrientationQuat = new Quat(); public var newOrientationQuat = new Quat(); // Checkpoint var currentCheckpoint:DtsObject = null; var currentCheckpointTrigger:CheckpointTrigger = null; var checkpointCollectedGems:Map = []; var checkpointHeldPowerup:PowerUp = null; var cheeckpointBlast:Float = 0; var checkpointSequence:Int = 0; // Replay public var replay:Replay; public var isWatching:Bool = false; public var isRecording:Bool = false; // Rewind public var rewindManager:RewindManager; public var rewinding:Bool = false; public var inputRecorder:InputRecorder; public var isReplayingMovement:Bool = false; public var currentInputMoves:Array; // Multiplayer public var isMultiplayer:Bool; public var startRealTime:Float = 0; public var multiplayerStarted:Bool = false; var tickAccumulator:Float = 0.0; var maxPredictionTicks:Int = 16; var clientMarbles:Map = []; var predictions:MarblePredictionStore; var powerupPredictions:PowerupPredictionStore; var gemPredictions:GemPredictionStore; public var lastMoves:MarbleUpdateQueue; // Loading var resourceLoadFuncs:Array<(() -> Void)->Void> = []; public var _disposed:Bool = false; public var _ready:Bool = false; var _loadBegin:Bool = false; var _loaded:Bool = false; var _loadingLength:Int = 0; var _resourcesLoaded:Int = 0; var textureResources:Array> = []; var soundResources:Array> = []; var oobSchedule:Float; var _instancesNeedsUpdate:Bool = false; var lock:Bool = false; public function new(scene:Scene, scene2d:h2d.Scene, mission:Mission, record:Bool = false, multiplayer:Bool = false) { this.scene = scene; this.scene2d = scene2d; this.mission = mission; this.game = mission.game.toLowerCase(); this.gameMode = GameModeFactory.getGameMode(cast this, mission.missionInfo.gamemode); this.replay = new Replay(mission.path, mission.isClaMission ? mission.id : 0); this.isRecording = record; this.rewindManager = new RewindManager(cast this); this.inputRecorder = new InputRecorder(cast this); this.isMultiplayer = multiplayer; if (this.isMultiplayer) { isRecording = false; isWatching = false; lastMoves = new MarbleUpdateQueue(); predictions = new MarblePredictionStore(); powerupPredictions = new PowerupPredictionStore(); gemPredictions = new GemPredictionStore(); } // Set the network RNG for hunt if (isMultiplayer && gameMode is modes.HuntMode && Net.isHost) { var hunt:modes.HuntMode = cast gameMode; var rng = Math.random() * 10000; NetCommands.setNetworkRNG(rng); @:privateAccess hunt.rng.setSeed(cast rng); @:privateAccess hunt.rng2.setSeed(cast rng); } } public function init() { initLoading(); } public function initLoading() { Console.log("*** LOADING MISSION: " + mission.path); this.loadingGui = new LoadingGui(this.mission.title, this.mission.game); MarbleGame.canvas.setContent(this.loadingGui); if (this.mission.isClaMission) { this.mission.download(() -> loadBegin()); } else { loadBegin(); } } function loadBegin() { _loadBegin = true; function scanMission(simGroup:MissionElementSimGroup) { for (element in simGroup.elements) { if ([ MissionElementType.InteriorInstance, MissionElementType.Item, MissionElementType.PathedInterior, MissionElementType.StaticShape, MissionElementType.TSStatic, MissionElementType.Sky ].contains(element._type)) { // this.loadingState.total++; // Override the end pad element. We do this because only the last finish pad element will actually do anything. if (element._type == MissionElementType.StaticShape) { var so:MissionElementStaticShape = cast element; if (so.datablock.toLowerCase() == 'endpad') this.endPadElement = so; } if (element._type == Sky) { this.skyElement = cast element; } } else if (element._type == MissionElementType.SimGroup) { scanMission(cast element); } } }; this.mission.load(); scanMission(this.mission.root); this.gameMode.missionScan(this.mission); this.resourceLoadFuncs.push(fwd -> this.initScene(fwd)); if (this.isMultiplayer) { for (client in Net.clientIdMap) { this.resourceLoadFuncs.push(fwd -> this.initMarble(client, fwd)); // Others } } this.resourceLoadFuncs.push(fwd -> this.initMarble(null, fwd)); // Self this.resourceLoadFuncs.push(fwd -> { this.addSimGroup(this.mission.root); this._loadingLength = resourceLoadFuncs.length; fwd(); }); this._loadingLength = resourceLoadFuncs.length; } public function postInit() { // Add the sky at the last so that cubemap reflections work this.collisionWorld.finalizeStaticGeometry(); this.playGui.init(this.scene2d, this.mission.game.toLowerCase(), () -> { this.scene.addChild(this.sky); if (this.isMultiplayer) { // Add us if (Net.isHost) { this.playGui.addPlayer(0, 'Player 0', true); } else { this.playGui.addPlayer(Net.clientId, 'Player ${Net.clientId}', true); } for (client in Net.clientIdMap) { this.playGui.addPlayer(client.id, 'Player ${client.id}', false); } } this._ready = true; // AudioManager.playShell(); MarbleGame.canvas.clearContent(); if (this.endPad != null) this.endPad.generateCollider(); this.playGui.formatGemCounter(this.gemCount, this.totalGems); Console.log("MISSION LOADED"); start(); }); } public function initScene(onFinish:Void->Void) { Console.log("Starting scene"); this.collisionWorld = new CollisionWorld(); this.playGui = new PlayGui(); this.instanceManager = new InstanceManager(scene); this.particleManager = new ParticleManager(cast this); this.radar = new Radar(cast this, this.scene2d); radar.init(); var worker = new ResourceLoaderWorker(() -> { var renderer = cast(this.scene.renderer, src.Renderer); for (element in mission.root.elements) { if (element._type != MissionElementType.Sun) continue; var sunElement:MissionElementSun = cast element; var directionalColor = MisParser.parseVector4(sunElement.color); var ambientColor = MisParser.parseVector4(sunElement.ambient); if (this.game == "ultra") { ambientColor.r *= 1.18; ambientColor.g *= 1.06; ambientColor.b *= 0.95; } var sunDirection = MisParser.parseVector3(sunElement.direction); sunDirection.x = -sunDirection.x; // sunDirection.x = 0; // sunDirection.y = 0; // sunDirection.z = -sunDirection.z; var ls = cast(scene.lightSystem, h3d.scene.fwd.LightSystem); ls.ambientLight.load(ambientColor); // ls.shadowLight.setDirection(new Vector(0, 0, -1)); this.ambient = ambientColor; // ls.perPixelLighting = false; var shadow = scene.renderer.getPass(h3d.pass.DefaultShadowMap); shadow.power = 1; shadow.mode = Dynamic; shadow.minDist = 0.1; shadow.maxDist = 200; shadow.bias = 0; var sunlight = new DirLight(sunDirection, scene); sunlight.color = directionalColor; this.dirLight = directionalColor; this.dirLightDir = sunDirection; } onFinish(); }); var filestoload = [ "particles/bubble.png", "particles/saturn.png", "particles/smoke.png", "particles/spark.png", "particles/star.png", "particles/twirl.png" ]; for (file in filestoload) { worker.loadFile(file); } this.scene.camera.zFar = Std.parseFloat(this.skyElement.visibledistance); this.sky = new Sky(); sky.dmlPath = ResourceLoader.getProperFilepath(skyElement.materiallist); worker.addTask(fwd -> sky.init(cast this, fwd, skyElement)); // worker.addTask(fwd -> { // scene.addChild(sky); // return fwd(); // }); worker.run(); } public function initMarble(client:GameConnection, onFinish:Void->Void) { Console.log("Initializing marble"); var worker = new ResourceLoaderWorker(onFinish); var marblefiles = [ "particles/star.png", "particles/smoke.png", "particles/burst.png", "sound/rolling_hard.wav", "sound/sliding.wav", "sound/use_gyrocopter.wav", "sound/bumperding1.wav", "sound/jump.wav", "sound/mega_roll.wav", "sound/bouncehard1.wav", "sound/bouncehard2.wav", "sound/bouncehard3.wav", "sound/bouncehard4.wav", "sound/spawn_alternate.wav", "sound/missinggems.wav", "sound/level_text.wav", "sound/level_finish.wav", "sound/finish.wav", "shapes/images/helicopter.dts", "shapes/images/helicopter.jpg", // These irk us a lot because ifl shit "shapes/items/gem.dts", // Ew ew "shapes/items/gemshine.png", "shapes/items/enviro1.jpg", "shapes/hazards/null.png" ]; if (this.game == "ultra") { marblefiles.push("shapes/balls/marble20.normal.png"); marblefiles.push("shapes/balls/marble18.normal.png"); marblefiles.push("shapes/balls/marble01.normal.png"); marblefiles.push("shapes/balls/marble02.normal.png"); marblefiles.push("sound/use_blast.wav"); } // Hacky marblefiles.push(StringTools.replace(Settings.optionsSettings.marbleModel, "data/", "")); // if (Settings.optionsSettings.marbleCategoryIndex == 0) // marblefiles.push("shapes/balls/" + Settings.optionsSettings.marbleSkin + ".marble.png"); // else // marblefiles.push("shapes/balls/" + Settings.optionsSettings.marbleSkin + ".marble.png"); var gameModeFiles = this.gameMode.getPreloadFiles(); for (file in marblefiles) { worker.loadFile(file); } for (file in gameModeFiles) { worker.loadFile(file); } worker.addTask(fwd -> { var marble = new Marble(); if (client == null) marble.controllable = true; this.addMarble(marble, client, fwd); }); worker.run(); } public function start() { Console.log("LEVEL START"); restart(this.marble, true); for (interior in this.interiors) interior.onLevelStart(); for (shape in this.dtsObjects) shape.onLevelStart(); if (this.isMultiplayer && Net.isClient) NetCommands.clientIsReady(Net.clientId); } public function restart(marble:Marble, full:Bool = false) { Console.log("LEVEL RESTART"); if (!full && this.currentCheckpoint != null) { this.loadCheckpointState(); return 0; // Load checkpoint } if (!full) { var respawnT = this.gameMode.getRespawnTransform(); if (respawnT != null) { respawn(marble, respawnT.position, respawnT.orientation, respawnT.up); return 0; } } if (!this.isWatching) { this.replay.clear(); } else this.replay.rewind(); this.rewindManager.clear(); this.timeState.currentAttemptTime = 0; this.timeState.gameplayClock = this.gameMode.getStartTime(); this.bonusTime = 0; this.marble.outOfBounds = false; this.marble.blastAmount = 0; this.renderBlastAmount = 0; this.marble.outOfBoundsTime = null; this.finishTime = null; this.skipStartBugPauseTime = 0.0; this.currentCheckpoint = null; this.currentCheckpointTrigger = null; this.checkpointCollectedGems.clear(); this.checkpointHeldPowerup = null; this.cheeckpointBlast = 0; this.checkpointSequence = 0; if (this.endPad != null) this.endPad.inFinish = false; if (this.totalGems > 0) { this.gemCount = 0; this.playGui.formatGemCounter(this.gemCount, this.totalGems); } radar.reset(); // Record/Playback trapdoor and landmine states if (full) { var tidx = 0; var lidx = 0; var pidx = 0; for (dtss in this.dtsObjects) { if (dtss is Trapdoor) { var trapdoor:Trapdoor = cast dtss; if (!this.isWatching) { this.replay.recordTrapdoorState(trapdoor.lastContactTime - this.timeState.timeSinceLoad, trapdoor.lastDirection, trapdoor.lastCompletion); } else { var state = this.replay.getTrapdoorState(tidx); trapdoor.lastContactTime = state.lastContactTime + this.timeState.timeSinceLoad; trapdoor.lastDirection = state.lastDirection; trapdoor.lastCompletion = state.lastCompletion; } tidx++; } } } this.cancel(this.oobSchedule); this.cancel(this.marble.oobSchedule); var startquat = this.gameMode.getSpawnTransform(); this.marble.setMarblePosition(startquat.position.x, startquat.position.y, startquat.position.z); this.marble.reset(); var euler = startquat.orientation.toEuler(); this.marble.camera.init(cast this); this.marble.camera.CameraYaw = euler.z + Math.PI / 2; this.marble.camera.CameraPitch = 0.45; this.marble.camera.nextCameraPitch = 0.45; this.marble.camera.nextCameraYaw = euler.z + Math.PI / 2; this.marble.camera.oob = false; this.marble.camera.finish = false; this.marble.setMode(Start); sky.follow = marble.camera; if (isMultiplayer) { for (client => marble in clientMarbles) { this.cancel(marble.oobSchedule); var marbleStartQuat = this.gameMode.getSpawnTransform(); marble.setMarblePosition(marbleStartQuat.position.x, marbleStartQuat.position.y, marbleStartQuat.position.z); marble.reset(); marble.setMode(Start); } } var missionInfo:MissionElementScriptObject = cast this.mission.root.elements.filter((element) -> element._type == MissionElementType.ScriptObject && element._name == "MissionInfo")[0]; if (missionInfo.starthelptext != null) displayHelp(missionInfo.starthelptext); // Show the start help text for (shape in dtsObjects) shape.reset(); for (interior in this.interiors) interior.reset(); this.setUp(this.marble, startquat.up, this.timeState, true); this.deselectPowerUp(this.marble); playGui.setCenterText(''); AudioManager.playSound(ResourceLoader.getResource('data/sound/spawn_alternate.wav', ResourceLoader.getAudio, this.soundResources)); this.gameMode.onRestart(); return 0; } public function respawn(marble:Marble, respawnPos:Vector, respawnQuat:Quat, respawnUp:Vector) { // Determine where to spawn the marble marble.setMarblePosition(respawnPos.x, respawnPos.y, respawnPos.z); marble.velocity.set(0, 0, 0); marble.omega.set(0, 0, 0); Console.log('Respawn:'); Console.log('Marble Position: ${respawnPos.x} ${respawnPos.y} ${respawnPos.z}'); Console.log('Marble Velocity: ${marble.velocity.x} ${marble.velocity.y} ${marble.velocity.z}'); Console.log('Marble Angular: ${marble.omega.x} ${marble.omega.y} ${marble.omega.z}'); // Set camera orientation var euler = respawnQuat.toEuler(); marble.camera.CameraYaw = euler.z + Math.PI / 2; marble.camera.CameraPitch = 0.45; marble.camera.nextCameraYaw = marble.camera.CameraYaw; marble.camera.nextCameraPitch = marble.camera.CameraPitch; marble.camera.oob = false; if (isMultiplayer) { marble.megaMarbleUseTick = 0; marble.helicopterUseTick = 0; } else { @:privateAccess marble.helicopterEnableTime = -1e8; @:privateAccess marble.megaMarbleEnableTime = -1e8; } if (this.isRecording) { this.replay.recordCameraState(marble.camera.CameraYaw, marble.camera.CameraPitch); this.replay.recordMarbleInput(0, 0); this.replay.recordMarbleState(respawnPos, marble.velocity, marble.getRotationQuat(), marble.omega); this.replay.recordMarbleStateFlags(false, false, true, false); } // In this case, we set the gravity to the relative "up" vector of the checkpoint shape. var up = new Vector(0, 0, 1); up.transform(respawnQuat.toMatrix()); this.setUp(marble, up, this.timeState, true); if (marble == this.marble) this.playGui.setCenterText(''); if (!this.isMultiplayer) this.clearSchedule(); marble.outOfBounds = false; this.gameMode.onRespawn(marble); if (marble == this.marble) AudioManager.playSound(ResourceLoader.getResource('data/sound/spawn_alternate.wav', ResourceLoader.getAudio, this.soundResources)); } public function allClientsReady() { NetCommands.setStartTime(3); // Start after 3 seconds } public function updateGameState() { if (this.marble.outOfBounds) return; // We will update state manually if (!this.isMultiplayer) { if (this.timeState.currentAttemptTime < 0.5) { this.marble.setMode(Start); } if ((this.timeState.currentAttemptTime >= 0.5) && (this.timeState.currentAttemptTime < 3.5)) { this.marble.setMode(Start); } if (this.timeState.currentAttemptTime + skipStartBugPauseTime >= 3.5 && this.finishTime == null) { this.marble.setMode(Play); } } else { if (!this.multiplayerStarted) { if (this.startRealTime != 0 && this.timeState.timeSinceLoad > this.startRealTime) { this.multiplayerStarted = true; this.marble.setMode(Play); for (client => marble in this.clientMarbles) marble.setMode(Play); } } } } function addToSimgroup(obj:GameObject, simGroup:MissionElementSimGroup) { if (simGroup == null) return; if (!simGroups.exists(simGroup)) simGroups[simGroup] = [obj]; else simGroups[simGroup].push(obj); } public function addSimGroup(simGroup:MissionElementSimGroup) { if (simGroup.elements.filter((element) -> element._type == MissionElementType.PathedInterior).length != 0) { // Create the pathed interior resourceLoadFuncs.push(fwd -> { src.PathedInterior.createFromSimGroup(simGroup, cast this, pathedInterior -> { this.addPathedInterior(pathedInterior, () -> { if (pathedInterior == null) { fwd(); Console.error("Unable to load pathed interior"); return; } // if (pathedInterior.hasCollision) // this.physics.addInterior(pathedInterior); for (trigger in pathedInterior.triggers) { this.triggers.push(trigger); this.collisionWorld.addEntity(trigger.collider); } fwd(); }); }); }); return; } for (element in simGroup.elements) { switch (element._type) { case MissionElementType.SimGroup: this.addSimGroup(cast element); case MissionElementType.InteriorInstance: resourceLoadFuncs.push(fwd -> this.addInteriorFromMis(cast element, simGroup, fwd)); case MissionElementType.StaticShape: resourceLoadFuncs.push(fwd -> this.addStaticShape(cast element, simGroup, fwd)); case MissionElementType.Item: resourceLoadFuncs.push(fwd -> this.addItem(cast element, simGroup, fwd)); case MissionElementType.Trigger: resourceLoadFuncs.push(fwd -> this.addTrigger(cast element, simGroup, fwd)); case MissionElementType.TSStatic: resourceLoadFuncs.push(fwd -> this.addTSStatic(cast element, simGroup, fwd)); case MissionElementType.ParticleEmitterNode: resourceLoadFuncs.push(fwd -> { this.addParticleEmitterNode(cast element); fwd(); }); default: } } } public function addInteriorFromMis(element:MissionElementInteriorInstance, simGroup:MissionElementSimGroup, onFinish:Void->Void) { var difPath = this.mission.getDifPath(element.interiorfile); if (difPath == "") { onFinish(); return; } var interior = new InteriorObject(); interior.interiorFile = difPath; // DifBuilder.loadDif(difPath, interior); // this.interiors.push(interior); this.addInterior(interior, () -> { addToSimgroup(interior, simGroup); var interiorPosition = MisParser.parseVector3(element.position); interiorPosition.x = -interiorPosition.x; var interiorRotation = MisParser.parseRotation(element.rotation); interiorRotation.x = -interiorRotation.x; interiorRotation.w = -interiorRotation.w; var interiorScale = MisParser.parseVector3(element.scale); var hasCollision = interiorScale.x * interiorScale.y * interiorScale.z != 0; // Don't want to add buggy geometry // Fix zero-volume interiors so they receive correct lighting if (interiorScale.x == 0) interiorScale.x = 0.0001; if (interiorScale.y == 0) interiorScale.y = 0.0001; if (interiorScale.z == 0) interiorScale.z = 0.0001; var mat = Matrix.S(interiorScale.x, interiorScale.y, interiorScale.z); var tmp = new Matrix(); interiorRotation.toMatrix(tmp); mat.multiply3x4(mat, tmp); var tmat = Matrix.T(interiorPosition.x, interiorPosition.y, interiorPosition.z); mat.multiply(mat, tmat); // if (hasCollision) // this.collisionWorld.addStaticInterior(interior.collider, mat); interior.isCollideable = hasCollision; interior.setTransform(mat); onFinish(); }); // interior.setTransform(interiorPosition, interiorRotation, interiorScale); // this.scene.add(interior.group); // if (hasCollision) // this.physics.addInterior(interior); } public function addStaticShape(element:MissionElementStaticShape, simGroup:MissionElementSimGroup, onFinish:Void->Void) { var shape:DtsObject = null; MarbleWorldMacros.addStaticShapeOrItem(); } public function addItem(element:MissionElementItem, simGroup:MissionElementSimGroup, onFinish:Void->Void) { var shape:DtsObject = null; MarbleWorldMacros.addStaticShapeOrItem(); } public function addTrigger(element:MissionElementTrigger, simGroup:MissionElementSimGroup, onFinish:Void->Void) { var trigger:Trigger = null; var datablockLowercase = element.datablock.toLowerCase(); // Create a trigger based on type if (datablockLowercase == "outofboundstrigger") { trigger = new OutOfBoundsTrigger(element, cast this); } else if (datablockLowercase == "inboundstrigger") { trigger = new InBoundsTrigger(element, cast this); } else if (datablockLowercase == "helptrigger") { trigger = new HelpTrigger(element, cast this); } else if (datablockLowercase == "checkpointtrigger") { var chk = new CheckpointTrigger(element, cast this); trigger = chk; chk.simGroup = simGroup; } else { Console.error("Unknown trigger: " + element.datablock); onFinish(); return; } trigger.init(() -> { this.triggers.push(trigger); addToSimgroup(trigger, simGroup); this.collisionWorld.addEntity(trigger.collider); onFinish(); }); } public function addTSStatic(element:MissionElementTSStatic, simGroup:MissionElementSimGroup, onFinish:Void->Void) { // !! WARNING - UNTESTED !! var shapeName = element.shapename; var index = shapeName.indexOf('data/'); if (index == -1) { Console.error("Unable to parse shape path: " + shapeName); onFinish(); return; } var dtsPath = 'data/' + shapeName.substring(index + 'data/'.length); if (ResourceLoader.getProperFilepath(dtsPath) == "") { Console.error("DTS path does not exist: " + dtsPath); onFinish(); return; } var tsShape = new DtsObject(); tsShape.useInstancing = true; tsShape.dtsPath = dtsPath; tsShape.identifier = shapeName; tsShape.isCollideable = true; tsShape.showSequences = false; if (element._name != null && element._name != "") { this.namedObjects.set(element._name, { obj: tsShape, elem: element }); } var shapePosition = MisParser.parseVector3(element.position); shapePosition.x = -shapePosition.x; var shapeRotation = MisParser.parseRotation(element.rotation); shapeRotation.x = -shapeRotation.x; shapeRotation.w = -shapeRotation.w; var shapeScale = MisParser.parseVector3(element.scale); // Apparently we still do collide with zero-volume shapes if (shapeScale.x == 0) shapeScale.x = 0.0001; if (shapeScale.y == 0) shapeScale.y = 0.0001; if (shapeScale.z == 0) shapeScale.z = 0.0001; var mat = Matrix.S(shapeScale.x, shapeScale.y, shapeScale.z); var tmp = new Matrix(); shapeRotation.toMatrix(tmp); mat.multiply3x4(mat, tmp); mat.setPosition(shapePosition); this.addDtsObject(tsShape, () -> { addToSimgroup(tsShape, simGroup); tsShape.setTransform(mat); onFinish(); }, true); } public function addParticleEmitterNode(element:MissionElementParticleEmitterNode) { Console.warn("Unimplemented method addParticleEmitterNode"); // TODO THIS SHIT } public function addInterior(obj:InteriorObject, onFinish:Void->Void) { this.interiors.push(obj); obj.init(cast this, () -> { this.collisionWorld.addEntity(obj.collider); if (obj.useInstancing) this.instanceManager.addObject(obj); else this.scene.addChild(obj); onFinish(); }); } public function addPathedInterior(obj:PathedInterior, onFinish:Void->Void) { this.pathedInteriors.push(obj); obj.init(cast this, () -> { this.collisionWorld.addMovingEntity(obj.collider); if (obj.useInstancing) this.instanceManager.addObject(obj); else this.scene.addChild(obj); onFinish(); }); } public function addDtsObject(obj:DtsObject, onFinish:Void->Void, isTsStatic:Bool = false) { function parseIfl(path:String, onFinish:Array->Void) { ResourceLoader.load(path).entry.load(() -> { var text = ResourceLoader.getFileEntry(path).entry.getText(); var lines = text.split('\n'); var keyframes = []; for (line in lines) { line = StringTools.trim(line); if (line.substr(0, 2) == "//") continue; if (line == "") continue; var parts = line.split(' '); var count = parts.length > 1 ? Std.parseInt(parts[1]) : 1; for (i in 0...count) { keyframes.push(parts[0]); } } onFinish(keyframes); }); } ResourceLoader.load(obj.dtsPath).entry.load(() -> { var dtsFile = ResourceLoader.loadDts(obj.dtsPath); var texToLoad = obj.getPreloadMaterials(dtsFile.resource); var worker = new ResourceLoaderWorker(() -> { obj.idInLevel = this.dtsObjects.length; // Set the id of the thing this.dtsObjects.push(obj); if (obj is PowerUp) { var pw:PowerUp = cast obj; pw.netIndex = this.powerUps.length; this.powerUps.push(cast obj); if (Net.isClient) powerupPredictions.alloc(); } if (obj is ForceObject) { this.forceObjects.push(cast obj); } obj.isTSStatic = isTsStatic; obj.init(cast this, () -> { obj.update(this.timeState); if (obj.useInstancing) { this.instanceManager.addObject(obj); } else this.scene.addChild(obj); for (collider in obj.colliders) { if (collider != null) this.collisionWorld.addEntity(collider); } if (obj.isBoundingBoxCollideable) this.collisionWorld.addEntity(obj.boundingCollider); onFinish(); }); }); for (texPath in texToLoad) { worker.loadFile(texPath); } worker.run(); }); } public function addMarble(marble:Marble, client:GameConnection, onFinish:Void->Void) { marble.level = cast this; this.marbles.push(marble); if (marble.controllable) { marble.init(cast this, client, () -> { this.scene.addChild(marble.camera); this.marble = marble; // Ugly hack // sky.follow = marble; sky.follow = marble.camera; this.collisionWorld.addMovingEntity(marble.collider); this.collisionWorld.addMarbleEntity(marble.collider); this.scene.addChild(marble); onFinish(); }); } else { marble.init(cast this, client, () -> { marble.collisionWorld = this.collisionWorld; this.collisionWorld.addMovingEntity(marble.collider); this.collisionWorld.addMarbleEntity(marble.collider); this.scene.addChild(marble); if (client != null) clientMarbles.set(client, marble); onFinish(); }); } } public function addGhostMarble(onFinish:Marble->Void) { var marb = new Marble(); marb.controllable = false; marb.init(null, null, () -> { marb.collisionWorld = this.collisionWorld; this.collisionWorld.addMovingEntity(marb.collider); this.collisionWorld.addMarbleEntity(marb.collider); this.scene.addChild(marb); onFinish(marb); }); return marb; } public function performRestart() { this.respawnPressedTime = timeState.timeSinceLoad; this.restart(this.marble); if (!this.isWatching) { Settings.playStatistics.respawns++; if (!Settings.levelStatistics.exists(mission.path)) { Settings.levelStatistics.set(mission.path, { oobs: 0, respawns: 1, totalTime: 0, }); } else { Settings.levelStatistics[mission.path].respawns++; } } } public function applyReceivedMoves() { var needsPrediction = 0; if (!lastMoves.ourMoveApplied) { var ourMove = lastMoves.myMarbleUpdate; if (ourMove != null) { var ourMoveStruct = Net.clientConnection.acknowledgeMove(ourMove.move.id, timeState); lastMoves.ourMoveApplied = true; for (client => arr in lastMoves.otherMarbleUpdates) { var lastMove = null; while (arr.packets.length > 0) { var p = arr.packets[0]; if (p.serverTicks <= ourMove.serverTicks) { lastMove = arr.packets.shift(); } else { break; } } if (lastMove != null) { // clientMarbles[Net.clientIdMap[client]].unpackUpdate(lastMove); // needsPrediction |= 1 << client; // arr.insert(0, lastMove); if (ourMove.serverTicks == lastMove.serverTicks) { if (ourMoveStruct != null) { var otherPred = predictions.retrieveState(clientMarbles[Net.clientIdMap[client]], ourMoveStruct.timeState.ticks); if (otherPred != null) { if (otherPred.getError(lastMove) > 0.1) { Debug.drawSphere(@:privateAccess clientMarbles[Net.clientIdMap[client]].newPos, 0.2, 0.5); // trace('Prediction error: ${otherPred.getError(lastMove)}'); // trace('Desync for tick ${ourMoveStruct.timeState.ticks}'); clientMarbles[Net.clientIdMap[client]].unpackUpdate(lastMove); needsPrediction |= 1 << client; arr.packets.insert(0, lastMove); predictions.clearStatesAfterTick(clientMarbles[Net.clientIdMap[client]], ourMoveStruct.timeState.ticks); } } else { Debug.drawSphere(@:privateAccess clientMarbles[Net.clientIdMap[client]].newPos, 0.2, 0.5); // trace('Desync for tick ${ourMoveStruct.timeState.ticks}'); clientMarbles[Net.clientIdMap[client]].unpackUpdate(lastMove); needsPrediction |= 1 << client; arr.packets.insert(0, lastMove); predictions.clearStatesAfterTick(clientMarbles[Net.clientIdMap[client]], ourMoveStruct.timeState.ticks); } } else { Debug.drawSphere(@:privateAccess clientMarbles[Net.clientIdMap[client]].newPos, 0.2, 0.5); // trace('Desync in General'); clientMarbles[Net.clientIdMap[client]].unpackUpdate(lastMove); needsPrediction |= 1 << client; arr.packets.insert(0, lastMove); // predictions.clearStatesAfterTick(clientMarbles[Net.clientIdMap[client]], ourMoveStruct.timeState.ticks); } } } } // marble.unpackUpdate(ourMove); // needsPrediction |= 1 << Net.clientId; if (ourMoveStruct != null) { var ourPred = predictions.retrieveState(marble, ourMoveStruct.timeState.ticks); if (ourPred != null) { if (ourPred.getError(ourMove) > 0.1) { // trace('Desync for tick ${ourMoveStruct.timeState.ticks}'); marble.unpackUpdate(ourMove); needsPrediction |= 1 << Net.clientId; predictions.clearStatesAfterTick(marble, ourMoveStruct.timeState.ticks); } } else { // trace('Desync for tick ${ourMoveStruct.timeState.ticks}'); marble.unpackUpdate(ourMove); needsPrediction |= 1 << Net.clientId; predictions.clearStatesAfterTick(marble, ourMoveStruct.timeState.ticks); } } else { // trace('Desync in General'); marble.unpackUpdate(ourMove); needsPrediction |= 1 << Net.clientId; // predictions.clearStatesAfterTick(marble, ourMoveStruct.timeState.ticks); } } } return needsPrediction; } public function applyClientPrediction(marbleNeedsPrediction:Int) { // First acknowledge the marble's last move so we can get that over with var ourLastMove = lastMoves.myMarbleUpdate; if (ourLastMove == null || marbleNeedsPrediction == 0) return -1; var ackLag = @:privateAccess Net.clientConnection.getQueuedMovesLength(); var ourLastMoveTime = ourLastMove.serverTicks; var ourQueuedMoves = @:privateAccess Net.clientConnection.getQueuedMoves().copy(); var qm = ourQueuedMoves[0]; var advanceTimeState = qm != null ? qm.timeState.clone() : timeState.clone(); advanceTimeState.dt = 0.032; advanceTimeState.ticks = ourLastMoveTime; if (marbleNeedsPrediction & (1 << Net.clientId) > 0) { // Only for our clients pls // if (qm != null) { // var mvs = qm.powerupStates.copy(); for (pw in marble.level.powerUps) { // var val = mvs.shift(); // if (pw.lastPickUpTime != val) // Console.log('Revert powerup pickup: ${pw.lastPickUpTime} -> ${val}'); pw.lastPickUpTime = powerupPredictions.getState(pw.netIndex); } var huntMode:HuntMode = cast this.gameMode; for (activeGem in @:privateAccess huntMode.activeGemSpawnGroup) { huntMode.setGemHiddenStatus(activeGem, gemPredictions.getState(activeGem)); } // } } ackLag = ourQueuedMoves.length; // Tick the remaining moves (ours) @:privateAccess this.marble.isNetUpdate = true; var totalTicksToDo = ourQueuedMoves.length; var endTick = ourLastMoveTime + totalTicksToDo; var currentTick = ourLastMoveTime; //- Std.int(ourLastMove.moveQueueSize - @:privateAccess Net.clientConnection.moveManager.ackRTT); // - Std.int((@:privateAccess Net.clientConnection.moveManager.ackRTT)) - offset; var marblesToTick = new Map(); for (client => arr in lastMoves.otherMarbleUpdates) { if (marbleNeedsPrediction & (1 << client) > 0 && arr.packets.length > 0) { var m = arr.packets[0]; // if (m.serverTicks == ourLastMoveTime) { var marbleToUpdate = clientMarbles[Net.clientIdMap[client]]; // Debug.drawSphere(@:privateAccess marbleToUpdate.newPos, marbleToUpdate._radius); // var distFromUs = @:privateAccess marbleToUpdate.newPos.distance(this.marble.newPos); // if (distFromUs < 5) m.calculationTicks = ourQueuedMoves.length; // else // m.calculationTicks = Std.int(Math.max(1, ourQueuedMoves.length - (distFromUs - 5) / 3)); // - Std.int((@:privateAccess Net.clientConnection.moveManager.ackRTT - ourLastMove.moveQueueSize) / 2); marblesToTick.set(client, m); arr.packets.shift(); // } } } Debug.drawSphere(@:privateAccess this.marble.newPos, this.marble._radius); // var syncTickStates = new Map(); for (move in ourQueuedMoves) { var m = move.move; Debug.drawSphere(@:privateAccess this.marble.newPos, this.marble._radius); if (marbleNeedsPrediction & (1 << Net.clientId) > 0) { @:privateAccess this.marble.moveMotionDir = move.motionDir; @:privateAccess this.marble.advancePhysics(advanceTimeState, m, this.collisionWorld, this.pathedInteriors); this.predictions.storeState(this.marble, move.timeState.ticks); } // var collidings = @:privateAccess this.marble.contactEntities.filter(x -> x is SphereCollisionEntity); for (client => m in marblesToTick) { if (m.calculationTicks > 0) { var marbleToUpdate = clientMarbles[Net.clientIdMap[client]]; Debug.drawSphere(@:privateAccess marbleToUpdate.newPos, marbleToUpdate._radius); var mv = m.move.move; @:privateAccess marbleToUpdate.isNetUpdate = true; @:privateAccess marbleToUpdate.moveMotionDir = m.move.motionDir; @:privateAccess marbleToUpdate.advancePhysics(advanceTimeState, mv, this.collisionWorld, this.pathedInteriors); this.predictions.storeState(marbleToUpdate, @:privateAccess marbleToUpdate.serverTicks); @:privateAccess marbleToUpdate.isNetUpdate = false; m.calculationTicks--; } } advanceTimeState.currentAttemptTime += 0.032; advanceTimeState.ticks++; currentTick++; } lastMoves.ourMoveApplied = true; @:privateAccess this.marble.isNetUpdate = false; return advanceTimeState.ticks; return -1; } public function spawnHuntGemsClientSide(gemIds:Array) { if (this.isMultiplayer && Net.isClient) { var huntMode:HuntMode = cast this.gameMode; huntMode.setActiveSpawnSphere(gemIds); radar.blink(); } } public function removePlayer(cc:ClientConnection) { var otherMarble = this.clientMarbles[cc]; this.predictions.removeMarbleFromPrediction(otherMarble); this.scene.removeChild(otherMarble); this.collisionWorld.removeMarbleEntity(otherMarble.collider); otherMarble.dispose(); } public function rollback(t:Float) { var newT = timeState.currentAttemptTime - t; var rewindFrame = rewindManager.getNextRewindFrame(timeState.currentAttemptTime - t); rewindManager.applyFrame(rewindFrame); this.isReplayingMovement = true; this.currentInputMoves = this.inputRecorder.getMovesFrom(timeState.currentAttemptTime); } public function advanceWorld(dt:Float) { ProfilerUI.measure("updateTimer"); this.updateTimer(dt); this.tickSchedule(timeState.currentAttemptTime); if (Key.isDown(Settings.controlsSettings.blast) || (MarbleGame.instance.touchInput.blastbutton.pressed) || Gamepad.isDown(Settings.gamepadSettings.blast) && !this.isWatching && this.game == "ultra") { this.marble.useBlast(timeState); } this.updateGameState(); this.updateBlast(this.marble, timeState); ProfilerUI.measure("updateDTS"); for (obj in dtsObjects) { obj.update(timeState); } for (obj in triggers) { obj.update(timeState); } ProfilerUI.measure("updateMarbles"); marble.update(timeState, collisionWorld, this.pathedInteriors); for (client => marble in clientMarbles) { marble.update(timeState, collisionWorld, this.pathedInteriors); } } public function update(dt:Float) { if (!_ready) { return; } var realDt = dt; if ((Key.isDown(Settings.controlsSettings.rewind) || MarbleGame.instance.touchInput.rewindButton.pressed || Gamepad.isDown(Settings.gamepadSettings.rewind)) && Settings.optionsSettings.rewindEnabled && !this.isMultiplayer && !this.isWatching && this.finishTime == null) { this.rewinding = true; } else { if ((Key.isReleased(Settings.controlsSettings.rewind) || !MarbleGame.instance.touchInput.rewindButton.pressed || Gamepad.isReleased(Settings.gamepadSettings.rewind)) && this.rewinding && !this.isMultiplayer) { if (this.isRecording) { this.replay.spliceReplay(timeState.currentAttemptTime); } } this.rewinding = false; } if (!this.isWatching) { if (this.isRecording && !this.rewinding) { this.replay.startFrame(); } } else { if (!this.replay.advance(dt)) { if (Util.isTouchDevice()) { MarbleGame.instance.touchInput.hideControls(@:privateAccess this.playGui.playGuiCtrl); } this.setCursorLock(false); var misFile = haxe.io.Path.withoutExtension(haxe.io.Path.withoutDirectory(mission.path)); this.dispose(); MarbleGame.instance.setPreviewMission(misFile, () -> { #if !js MarbleGame.canvas.setContent(new ReplayCenterGui()); #end #if js MarbleGame.canvas.setContent(new MainMenuGui()); var pointercontainer = js.Browser.document.querySelector("#pointercontainer"); pointercontainer.hidden = false; #end }); return; } } if (this.rewinding && !this.isWatching) { var rframe = rewindManager.getNextRewindFrame(timeState.currentAttemptTime - dt * rewindManager.timeScale); if (rframe != null) { var actualDt = timeState.currentAttemptTime - rframe.timeState.currentAttemptTime - dt * rewindManager.timeScale; dt = actualDt; rewindManager.applyFrame(rframe); } } if (dt < 0) return; if (this.isReplayingMovement) { while (this.currentInputMoves.length > 1) { while (this.currentInputMoves[1].time <= timeState.currentAttemptTime) { this.currentInputMoves = this.currentInputMoves.slice(1); if (this.currentInputMoves.length == 1) break; } if (this.currentInputMoves.length > 1) { dt = this.currentInputMoves[1].time - this.currentInputMoves[0].time; } if (this.isReplayingMovement) { if (this.timeState.currentAttemptTime != this.currentInputMoves[0].time) trace("fucked"); } if (this.currentInputMoves.length > 1) { advanceWorld(dt); // trace('Position: ${@:privateAccess marble.newPos.sub(currentInputMoves[1].pos).length()}. Vel: ${marble.velocity.sub(currentInputMoves[1].velocity).length()}'); } } this.isReplayingMovement = false; } ProfilerUI.measure("updateTimer"); this.updateTimer(dt); // if ((Key.isPressed(Settings.controlsSettings.respawn) || Gamepad.isPressed(Settings.gamepadSettings.respawn)) // && this.finishTime == null) { // performRestart(); // return; // } // if ((Key.isDown(Settings.controlsSettings.respawn) // || MarbleGame.instance.touchInput.restartButton.pressed // || Gamepad.isDown(Settings.gamepadSettings.respawn)) // && !this.isWatching // && this.finishTime == null) { // if (timeState.timeSinceLoad - this.respawnPressedTime > 1.5) { // this.restart(true); // this.respawnPressedTime = Math.POSITIVE_INFINITY; // return; // } // } this.tickSchedule(timeState.currentAttemptTime); if (this.isWatching && this.replay.currentPlaybackFrame.marbleStateFlags.has(UsedBlast)) this.marble.useBlast(timeState); // Replay gravity if (this.isWatching) { if (this.replay.currentPlaybackFrame.gravityChange) { this.setUp(this.marble, this.replay.currentPlaybackFrame.gravity, timeState, this.replay.currentPlaybackFrame.gravityInstant); } if (this.replay.currentPlaybackFrame.powerupPickup != null) { this.pickUpPowerUpReplay(this.replay.currentPlaybackFrame.powerupPickup); } } radar.update(dt); this.updateGameState(); if (!this.isMultiplayer) this.updateBlast(this.marble, timeState); ProfilerUI.measure("updateDTS"); for (obj in dtsObjects) { obj.update(timeState); } for (obj in triggers) { obj.update(timeState); } // if (!isReplayingMovement) { // inputRecorder.recordInput(timeState.currentAttemptTime); // } ProfilerUI.measure("updateMarbles"); if (this.isMultiplayer) { tickAccumulator += timeState.dt; while (tickAccumulator >= 0.032) { // Apply the server side ticks var lastPredTick = -1; if (Net.isClient) { var marbleNeedsTicking = applyReceivedMoves(); // Catch up lastPredTick = applyClientPrediction(marbleNeedsTicking); } // Do the clientside prediction sim var fixedDt = timeState.clone(); fixedDt.dt = 0.032; tickAccumulator -= 0.032; var packets = []; var myMove = marble.updateServer(fixedDt, collisionWorld, pathedInteriors); var otherMoves = []; for (client => marble in clientMarbles) { otherMoves.push(marble.updateServer(fixedDt, collisionWorld, pathedInteriors)); } this.predictions.storeState(marble, myMove.timeState.ticks); for (client => marble in clientMarbles) { this.predictions.storeState(marble, @:privateAccess marble.serverTicks); } if (Net.isHost) { for (client => othermarble in clientMarbles) { // Oh no! var mv = otherMoves.shift(); packets.push(marble.packUpdate(myMove, fixedDt)); packets.push(othermarble.packUpdate(mv, fixedDt)); } for (client => marble in clientMarbles) { // Oh no! // var pktClone = packets.copy(); // pktClone.sort((a, b) -> { // return (a.c == client.id) ? 1 : (b.c == client.id) ? -1 : 0; // }); for (packet in packets) { client.sendBytes(packet); } } } timeState.ticks++; } timeState.subframe = tickAccumulator / 0.032; marble.updateClient(timeState, this.pathedInteriors); for (client => marble in clientMarbles) { marble.updateClient(timeState, this.pathedInteriors); } } else { marble.update(timeState, collisionWorld, this.pathedInteriors); for (client => marble in clientMarbles) { marble.update(timeState, collisionWorld, this.pathedInteriors); } } _instancesNeedsUpdate = true; Renderer.dirtyBuffers = true; if (this.rewinding) { // Update camera separately marble.camera.update(timeState.currentAttemptTime, realDt); } ProfilerUI.measure("updateParticles"); if (this.rewinding) { this.particleManager.update(1000 * timeState.timeSinceLoad, -realDt * rewindManager.timeScale); } else this.particleManager.update(1000 * timeState.timeSinceLoad, dt); ProfilerUI.measure("updatePlayGui"); this.playGui.update(timeState); ProfilerUI.measure("updateAudio"); AudioManager.update(this.scene); if (!this.isMultiplayer) { if (this.marble.outOfBounds && this.finishTime == null && (Key.isDown(Settings.controlsSettings.jump) || Gamepad.isDown(Settings.gamepadSettings.jump)) && !this.isWatching) { this.restart(this.marble); return; } } if (!this.isWatching) { if (this.isRecording && !this.rewinding) { this.replay.endFrame(); } } if (!this.rewinding && Settings.optionsSettings.rewindEnabled && !this.isMultiplayer) this.rewindManager.recordFrame(); // if (!this.isReplayingMovement) { // inputRecorder.recordMarble(); // } this.updateTexts(); } public function render(e:h3d.Engine) { if (!_ready) asyncLoadResources(); if (this.playGui != null && _ready) this.playGui.render(e); if (_instancesNeedsUpdate) { if (this.radar != null) this.radar.render(); ProfilerUI.measure("updateInstances"); this.instanceManager.render(); if (this.marble != null && this.marble.cubemapRenderer != null) { ProfilerUI.measure("renderCubemap"); this.marble.cubemapRenderer.position.load(this.marble.getAbsPos().getPosition()); this.marble.cubemapRenderer.render(e); } _instancesNeedsUpdate = false; } } var postInited = false; function asyncLoadResources() { if (this.resourceLoadFuncs.length != 0) { if (lock) return; var func = this.resourceLoadFuncs.shift(); lock = true; #if hl func(() -> { lock = false; this._resourcesLoaded++; }); #end #if js func(() -> { lock = false; this._resourcesLoaded++; }); #end } else { if (!this._loadBegin || lock) return; if (!_ready && !postInited) { postInited = true; Console.log("Finished loading, starting mission"); haxe.Timer.delay(() -> postInit(), 15); // delay this a bit } } } public function updateTimer(dt:Float) { this.timeState.dt = dt; var prevGameplayClock = this.timeState.gameplayClock; var timeMultiplier = this.gameMode.timeMultiplier(); if (!this.isWatching) { if (this.bonusTime != 0 && this.timeState.currentAttemptTime + skipStartBugPauseTime >= 3.5) { this.bonusTime -= dt; if (this.bonusTime < 0) { this.timeState.gameplayClock -= this.bonusTime * timeMultiplier; this.bonusTime = 0; } if (timeTravelSound == null) { var ttsnd = ResourceLoader.getResource("data/sound/timetravelactive.wav", ResourceLoader.getAudio, this.soundResources); timeTravelSound = AudioManager.playSound(ttsnd, null, true); } } else { if (timeTravelSound != null) { timeTravelSound.stop(); timeTravelSound = null; } if (this.timeState.currentAttemptTime + skipStartBugPauseTime >= 3.5) { this.timeState.gameplayClock += dt * timeMultiplier; } else if (this.timeState.currentAttemptTime + dt >= 3.5) { this.timeState.gameplayClock += ((this.timeState.currentAttemptTime + dt) - 3.5) * timeMultiplier; } if (this.timeState.gameplayClock < 0) this.gameMode.onTimeExpire(); } if (!this.isMultiplayer || this.multiplayerStarted) this.timeState.currentAttemptTime += dt; } else { this.timeState.currentAttemptTime = this.replay.currentPlaybackFrame.time; this.timeState.gameplayClock = this.replay.currentPlaybackFrame.clockTime; this.bonusTime = this.replay.currentPlaybackFrame.bonusTime; if (this.bonusTime != 0 && this.timeState.currentAttemptTime + skipStartBugPauseTime >= 3.5) { if (timeTravelSound == null) { var ttsnd = ResourceLoader.getResource("data/sound/timetravelactive.wav", ResourceLoader.getAudio, this.soundResources); timeTravelSound = AudioManager.playSound(ttsnd, null, true); } } else { if (timeTravelSound != null) { timeTravelSound.stop(); timeTravelSound = null; } } } this.timeState.timeSinceLoad += dt; if (finishTime != null) this.timeState.gameplayClock = finishTime.gameplayClock; playGui.formatTimer(this.timeState.gameplayClock); if (!this.isWatching && this.isRecording) this.replay.recordTimeState(timeState.currentAttemptTime, timeState.gameplayClock, this.bonusTime); } public function updateBlast(marble:Marble, timestate:TimeState) { if (this.isMultiplayer) { if (marble == this.marble) { if (marble.blastTicks < (36000 >> 5)) { this.renderBlastAmount = (marble.blastTicks + timestate.subframe) / (30000 >> 5); } else { this.renderBlastAmount = Math.min(marble.blastTicks / (30000 >> 5), timestate.dt * 0.75 + this.renderBlastAmount); } this.playGui.setBlastValue(this.renderBlastAmount); } } else { if (marble.blastAmount < 1) { marble.blastAmount = Util.clamp(marble.blastAmount + (timeState.dt / 30), 0, 1); if (marble == this.marble) this.renderBlastAmount = marble.blastAmount; } else { if (marble == this.marble) this.renderBlastAmount = Math.min(marble.blastAmount, timestate.dt * 0.75 + this.renderBlastAmount); } if (marble == this.marble) this.playGui.setBlastValue(this.renderBlastAmount); } } function updateTexts() { var helpTextTime = this.helpTextTimeState; var alertTextTime = this.alertTextTimeState; var helpTextCompletion = Math.pow(Util.clamp((this.timeState.timeSinceLoad - helpTextTime - 3), 0, 1), 2); var alertTextCompletion = Math.pow(Util.clamp((this.timeState.timeSinceLoad - alertTextTime - 3), 0, 1), 2); this.playGui.setHelpTextOpacity(1 - helpTextCompletion); this.playGui.setAlertTextOpacity(1 - alertTextCompletion); } public function displayAlert(text:String) { this.playGui.setAlertText(text); this.alertTextTimeState = this.timeState.timeSinceLoad; } public function displayHelp(text:String) { var start = 0; var pos = text.indexOf("", start + 5); if (end == -1) break; var pre = text.substr(0, pos); var post = text.substr(end + 1); var func = text.substr(pos + 6, end - (pos + 6)); var funcdata = func.split(' ').map(x -> x.toLowerCase()); var val = ""; if (funcdata[0] == "bind") { if (funcdata[1] == "moveforward") val = Util.getKeyForButton(Settings.controlsSettings.forward); if (funcdata[1] == "movebackward") val = Util.getKeyForButton(Settings.controlsSettings.backward); if (funcdata[1] == "moveleft") val = Util.getKeyForButton(Settings.controlsSettings.left); if (funcdata[1] == "moveright") val = Util.getKeyForButton(Settings.controlsSettings.right); if (funcdata[1] == "panup") val = Util.getKeyForButton(Settings.controlsSettings.camForward); if (funcdata[1] == "pandown") val = Util.getKeyForButton(Settings.controlsSettings.camBackward); if (funcdata[1] == "turnleft") val = Util.getKeyForButton(Settings.controlsSettings.camLeft); if (funcdata[1] == "turnright") val = Util.getKeyForButton(Settings.controlsSettings.camRight); if (funcdata[1] == "jump") val = Util.getKeyForButton(Settings.controlsSettings.jump); if (funcdata[1] == "mousefire") val = Util.getKeyForButton(Settings.controlsSettings.powerup); if (funcdata[1] == "freelook") val = Util.getKeyForButton(Settings.controlsSettings.freelook); if (funcdata[1] == "useblast") val = Util.getKeyForButton(Settings.controlsSettings.blast); } start = val.length + pos; text = pre + val + post; pos = text.indexOf("= 0 && dist < 5) { var intersectT = -(checkBoundsCenter.dot(surfaceN.toPoint()) + surfaceD) / (padUp.dot(surfaceN)); var intersectP = checkBoundsCenter.add(padUp.multiply(intersectT).toPoint()).toVector(); if (Collision.PointInTriangle(intersectP, v1, surface.getPoint(surface.indices[i + 1]).transformed(chull.transform), surface.getPoint(surface.indices[i + 2]).transformed(chull.transform))) { found = true; break; } } } i += 3; } if (found) { break; } } if (found) { break; } } } if (found) { if (!endPad.inFinish) { touchFinish(); endPad.inFinish = true; } } else { if (endPad.inFinish) endPad.inFinish = false; } } else { if (endPad.inFinish) endPad.inFinish = false; } } } function touchFinish() { if (this.finishTime != null || (this.marble.outOfBounds && this.timeState.currentAttemptTime - this.marble.outOfBoundsTime.currentAttemptTime >= 0.5)) return; if (this.gemCount < this.totalGems) { AudioManager.playSound(ResourceLoader.getResource('data/sound/missinggems.wav', ResourceLoader.getAudio, this.soundResources)); displayAlert("You can't finish without all the gems!"); } else { AudioManager.playSound(ResourceLoader.getResource('data/sound/finish.wav', ResourceLoader.getAudio, this.soundResources)); this.finishTime = this.timeState.clone(); this.marble.setMode(Finish); this.marble.camera.finish = true; this.finishYaw = this.marble.camera.CameraYaw; this.finishPitch = this.marble.camera.CameraPitch; displayAlert("Congratulations! You've finished!"); if (!Settings.levelStatistics.exists(mission.path)) { Settings.levelStatistics.set(mission.path, { oobs: 0, respawns: 0, totalTime: 0, }); } Analytics.trackLevelScore(mission.title, mission.path, gameMode.getScoreType() == Time ? Std.int(1000 * gameMode.getFinishScore()) : Std.int(gameMode.getFinishScore()), Settings.levelStatistics[mission.path].oobs, Settings.levelStatistics[mission.path].respawns, Settings.optionsSettings.rewindEnabled); if (!this.isWatching) { var myScore = { name: "Player", time: this.gameMode.getFinishScore() }; Settings.saveScore(mission.path, myScore, this.gameMode.getScoreType()); var notifies = AchievementsGui.check(); var delay = 5.0; var achDelay = 0.0; for (i in 0...9) { if (notifies & (1 << i) > 0) achDelay += 3; } if (notifies > 0) achDelay += 0.5; this.schedule(this.timeState.currentAttemptTime + Math.max(delay, achDelay), () -> cast showFinishScreen()); } // Stop the ongoing sounds if (timeTravelSound != null) { timeTravelSound.stop(); timeTravelSound = null; } } } function showFinishScreen() { if (this.isWatching) return 0; playGui.setGuiVisibility(false); Console.log("State End"); var egg:EndGameGui = null; #if js var pointercontainer = js.Browser.document.querySelector("#pointercontainer"); pointercontainer.hidden = false; #end this.schedule(this.timeState.currentAttemptTime + 3, () -> { this.isRecording = false; // Stop recording here }, "stopRecordingTimeout"); if (Util.isTouchDevice()) { MarbleGame.instance.touchInput.setControlsEnabled(false); } egg = new EndGameGui((sender) -> { if (Util.isTouchDevice()) { MarbleGame.instance.touchInput.hideControls(@:privateAccess this.playGui.playGuiCtrl); } var endGameCode = () -> { this.dispose(); LevelSelectGui.currentSelectionStatic = mission.index + 1; var pmg = new LevelSelectGui(["beginner", "intermediate", "advanced", "multiplayer"][mission.difficultyIndex]); MarbleGame.canvas.setContent(pmg); #if js pointercontainer.hidden = false; #end } if (MarbleGame.instance.toRecord) { MarbleGame.canvas.pushDialog(new ReplayNameDlg(endGameCode)); } else { endGameCode(); } }, (sender) -> { var restartGameCode = () -> { MarbleGame.canvas.popDialog(egg); playGui.setGuiVisibility(true); this.restart(this.marble, true); #if js pointercontainer.hidden = true; #end if (Util.isTouchDevice()) { MarbleGame.instance.touchInput.setControlsEnabled(true); } // @:privateAccess playGui.playGuiCtrl.render(scene2d); } if (MarbleGame.instance.toRecord) { MarbleGame.canvas.pushDialog(new ReplayNameDlg(() -> { this.isRecording = true; restartGameCode(); })); } else { restartGameCode(); } }, (sender) -> { var nextLevelCode = () -> { var nextMission = mission.getNextMission(); if (nextMission != null) { MarbleGame.instance.playMission(nextMission); } } if (MarbleGame.instance.toRecord) { MarbleGame.canvas.pushDialog(new ReplayNameDlg(nextLevelCode)); } else { nextLevelCode(); } }, mission, this.gameMode.getFinishScore(), this.gameMode.getScoreType()); MarbleGame.canvas.pushDialog(egg); this.setCursorLock(false); return 0; } public function pickUpPowerUpReplay(powerupIdent:String) { if (powerupIdent == null) return false; if (this.marble.heldPowerup != null) if (this.marble.heldPowerup.identifier == powerupIdent) return false; this.playGui.setPowerupImage(powerupIdent); return true; } public function pickUpPowerUp(marble:Marble, powerUp:PowerUp) { if (powerUp == null) return false; if (marble.heldPowerup != null) if (marble.heldPowerup.identifier == powerUp.identifier) return false; Console.log("PowerUp pickup: " + powerUp.identifier); marble.heldPowerup = powerUp; if (@:privateAccess !marble.isNetUpdate) @:privateAccess marble.netFlags |= MarbleNetFlags.PickupPowerup; if (this.marble == marble) { this.playGui.setPowerupImage(powerUp.identifier); MarbleGame.instance.touchInput.powerupButton.setEnabled(true); } if (this.isRecording) { this.replay.recordPowerupPickup(powerUp); } return true; } public function deselectPowerUp(marble:Marble) { marble.heldPowerup = null; @:privateAccess marble.netFlags |= MarbleNetFlags.PickupPowerup; if (this.marble == marble) { this.playGui.setPowerupImage(""); MarbleGame.instance.touchInput.powerupButton.setEnabled(false); } } public function addBonusTime(t:Float) { this.bonusTime += t; } /** Get the current interpolated orientation quaternion. */ public function getOrientationQuat(time:Float) { var completion = Util.clamp((time - this.orientationChangeTime) / 0.8, 0, 1); var newDt = completion / 0.15; var smooth = 1.0 / (newDt * (newDt * 0.235 * newDt) + newDt + 1.0 + 0.48 * newDt * newDt); if (completion > 0.9) smooth = Util.lerp(25.0 / 1876.0, 0, (completion - 0.9) * 10); var q = this.oldOrientationQuat.clone(); q.slerp(q, this.newOrientationQuat, 1 - smooth); return q; } public function setUp(marble:Marble, vec:Vector, timeState:TimeState, instant:Bool = false) { marble.currentUp = vec; if (marble == this.marble) { var currentQuat = this.getOrientationQuat(timeState.currentAttemptTime); var oldUp = new Vector(0, 0, 1); oldUp.transform(currentQuat.toMatrix()); function getRotQuat(v1:Vector, v2:Vector) { function orthogonal(v:Vector) { var x = Math.abs(v.x); var y = Math.abs(v.y); var z = Math.abs(v.z); var other = x < y ? (x < z ? new Vector(1, 0, 0) : new Vector(0, 0, 1)) : (y < z ? new Vector(0, 1, 0) : new Vector(0, 0, 1)); return v.cross(other); } var u = v1.normalized(); var v = v2.normalized(); if (Math.abs(u.dot(v) + 1) < hxd.Math.EPSILON) { var q = new Quat(); var o = orthogonal(u).normalized(); q.x = o.x; q.y = o.y; q.z = o.z; q.w = 0; return q; } var half = u.add(v).normalized(); var q = new Quat(); q.w = u.dot(half); var vr = u.cross(half); q.x = vr.x; q.y = vr.y; q.z = vr.z; return q; } var quatChange = getRotQuat(oldUp, vec); // Instead of calculating the new quat from nothing, calculate it from the last one to guarantee the shortest possible rotation. // quatChange.initMoveTo(oldUp, vec); quatChange.multiply(quatChange, currentQuat); if (this.isRecording) { this.replay.recordGravity(vec, instant); } this.newOrientationQuat = quatChange; this.oldOrientationQuat = currentQuat; this.orientationChangeTime = instant ? -1e8 : timeState.currentAttemptTime; } } public function goOutOfBounds(marble:Marble) { if (marble.outOfBounds || this.finishTime != null) return; // this.updateCamera(this.timeState); // Update the camera at the point of OOB-ing marble.outOfBounds = true; marble.outOfBoundsTime = this.timeState.clone(); marble.camera.oob = true; if (!this.isWatching && !this.isMultiplayer) { Settings.playStatistics.oobs++; if (!Settings.levelStatistics.exists(mission.path)) { Settings.levelStatistics.set(mission.path, { oobs: 1, respawns: 0, totalTime: 0, }); } else { Settings.levelStatistics[mission.path].oobs++; } // sky.follow = null; // this.oobCameraPosition = camera.position.clone(); } if (marble == this.marble) { playGui.setCenterText('Out of Bounds'); // if (this.replay.mode != = 'playback') this.oobSchedule = this.schedule(this.timeState.currentAttemptTime + 2, () -> { playGui.setCenterText(''); return null; }); } if (Net.isHost) { marble.oobSchedule = this.schedule(this.timeState.currentAttemptTime + 2.5, () -> { this.restart(marble); return null; }); } } /** Sets a new active checkpoint. */ public function saveCheckpointState(shape:DtsObject, trigger:CheckpointTrigger = null) { var disableOob = false; var isSame = this.currentCheckpoint == shape; if (trigger != null) { disableOob = trigger.disableOOB; if (checkpointSequence > trigger.seqNum) return false; } checkpointSequence = trigger.seqNum; // (shape.srcElement as any) ?.disableOob || trigger?.element.disableOob; if (disableOob && this.marble.outOfBounds) return false; // The checkpoint is configured to not work when the player is already OOB this.currentCheckpoint = shape; this.currentCheckpointTrigger = trigger; this.checkpointCollectedGems.clear(); this.cheeckpointBlast = this.marble.blastAmount; // Remember all gems that were collected up to this point for (gem in this.gems) { if (gem.pickedUp) this.checkpointCollectedGems.set(gem, true); } this.checkpointHeldPowerup = this.marble.heldPowerup; if (!isSame) { AudioManager.playSound(ResourceLoader.getResource('data/sound/checkpoint.wav', ResourceLoader.getAudio, this.soundResources)); } return true; } /** Resets to the last stored checkpoint state. */ public function loadCheckpointState() { var marble = this.marble; // Determine where to spawn the marble var offset = new Vector(0, 0, 0.727843); offset.transform(this.currentCheckpoint.getRotationQuat().toMatrix()); var mpos = this.currentCheckpoint.getAbsPos().getPosition().add(offset); this.marble.setMarblePosition(mpos.x, mpos.y, mpos.z); marble.velocity.load(new Vector(0, 0, 0)); marble.omega.load(new Vector(0, 0, 0)); Console.log('Respawn:'); Console.log('Marble Position: ${mpos.x} ${mpos.y} ${mpos.z}'); Console.log('Marble Velocity: ${marble.velocity.x} ${marble.velocity.y} ${marble.velocity.z}'); Console.log('Marble Angular: ${marble.omega.x} ${marble.omega.y} ${marble.omega.z}'); // Set camera orientation var euler = this.currentCheckpoint.getRotationQuat().toEuler(); this.marble.camera.CameraYaw = euler.z + Math.PI / 2; this.marble.camera.CameraPitch = 0.45; this.marble.camera.nextCameraYaw = this.marble.camera.CameraYaw; this.marble.camera.nextCameraPitch = this.marble.camera.CameraPitch; this.marble.camera.oob = false; @:privateAccess this.marble.helicopterEnableTime = -1e8; @:privateAccess this.marble.megaMarbleEnableTime = -1e8; this.marble.blastAmount = this.cheeckpointBlast; if (this.isRecording) { this.replay.recordCameraState(this.marble.camera.CameraYaw, this.marble.camera.CameraPitch); this.replay.recordMarbleInput(0, 0); this.replay.recordMarbleState(mpos, marble.velocity, marble.getRotationQuat(), marble.omega); this.replay.recordMarbleStateFlags(false, false, true, false); } var gravityField = ""; // (this.currentCheckpoint.srcElement as any) ?.gravity || this.currentCheckpointTrigger?.element.gravity; if (this.currentCheckpointTrigger != null) { if (@:privateAccess this.currentCheckpointTrigger.element.fields.exists('gravity')) { gravityField = @:privateAccess this.currentCheckpointTrigger.element.fields.get('gravity')[0]; } } // In this case, we set the gravity to the relative "up" vector of the checkpoint shape. var up = new Vector(0, 0, 1); up.transform(this.currentCheckpoint.getRotationQuat().toMatrix()); this.setUp(marble, up, this.timeState, true); // Restore gem states for (gem in this.gems) { if (gem.pickedUp && !this.checkpointCollectedGems.exists(gem)) { gem.reset(); this.gemCount--; } } this.playGui.formatGemCounter(this.gemCount, this.totalGems); this.playGui.setCenterText(''); this.clearSchedule(); this.marble.outOfBounds = false; this.deselectPowerUp(this.marble); // Always deselect first // Wait a bit to select the powerup to prevent immediately using it incase the user skipped the OOB screen by clicking if (this.checkpointHeldPowerup != null) { var powerup = this.checkpointHeldPowerup; this.pickUpPowerUp(this.marble, powerup); } AudioManager.playSound(ResourceLoader.getResource('data/sound/spawn_alternate.wav', ResourceLoader.getAudio, this.soundResources)); } public function setCursorLock(enabled:Bool) { this.cursorLock = enabled; if (enabled) { if (this.marble != null) this.marble.camera.lockCursor(); } else { if (this.marble != null) this.marble.camera.unlockCursor(); } } public function saveReplay() { this.replay.name = MarbleGame.instance.recordingName; #if hl sys.FileSystem.createDirectory(haxe.io.Path.join([Settings.settingsDir, "data", "replays"])); var replayPath = haxe.io.Path.join([Settings.settingsDir, "data", "replays", '${this.replay.name}.mbr']); if (sys.FileSystem.exists(replayPath)) { var count = 1; var found = false; while (!found) { replayPath = haxe.io.Path.join([Settings.settingsDir, "data", "replays", '${this.replay.name} (${count}).mbr']); if (!sys.FileSystem.exists(replayPath)) { this.replay.name += ' (${count})'; found = true; } else { count++; } } } var replayBytes = this.replay.write(); sys.io.File.saveBytes(replayPath, replayBytes); #end #if js var replayBytes = this.replay.write(); var blob = new js.html.Blob([replayBytes.getData()], { type: 'application/octet-stream' }); var url = js.html.URL.createObjectURL(blob); var fname = '${this.replay.name}.mbr'; var element = js.Browser.document.createElement('a'); element.setAttribute('href', url); element.setAttribute('download', fname); element.style.display = 'none'; js.Browser.document.body.appendChild(element); element.click(); js.Browser.document.body.removeChild(element); js.html.URL.revokeObjectURL(url); #end } public function dispose() { // Gotta add the timesinceload to our stats if (!this.isWatching) { Settings.playStatistics.totalTime += this.timeState.timeSinceLoad; if (!Settings.levelStatistics.exists(mission.path)) { Settings.levelStatistics.set(mission.path, { oobs: 0, respawns: 0, totalTime: this.timeState.timeSinceLoad, }); } else { Settings.levelStatistics[mission.path].totalTime += this.timeState.timeSinceLoad; } } CollisionPool.freeMemory(); radar.dispose(); if (this.playGui != null) this.playGui.dispose(); scene.removeChildren(); for (interior in this.interiors) { interior.dispose(); } interiors = null; for (pathedInteriors in this.pathedInteriors) { pathedInteriors.dispose(); } pathedInteriors = null; for (marble in marbles) { marble.dispose(); } clientMarbles = null; for (dtsObject in this.dtsObjects) { dtsObject.dispose(); } dtsObjects = null; powerUps = []; for (trigger in this.triggers) { trigger.dispose(); } triggers = null; for (soundResource in this.soundResources) { soundResource.release(); } for (textureResource in this.textureResources) { textureResource.release(); } gems = null; if (sky != null) sky.dispose(); sky = null; instanceManager = null; collisionWorld.dispose(); collisionWorld = null; particleManager = null; namedObjects = null; shapeOrTriggerInside = null; shapeImmunity = null; currentCheckpoint = null; checkpointCollectedGems = null; marble = null; this._disposed = true; AudioManager.stopAllSounds(); // AudioManager.playShell(); } } typedef ScheduleInfo = { var id:Float; var stringId:String; var time:Float; var callBack:Void->Any; } abstract class Scheduler { var scheduled:Array = []; public function tickSchedule(time:Float) { for (item in this.scheduled) { if (time >= item.time) { this.scheduled.remove(item); item.callBack(); } } } public function schedule(time:Float, callback:Void->Any, stringId:String = null) { var id = Math.random(); this.scheduled.push({ id: id, stringId: '${id}', time: time, callBack: callback }); return id; } /** Cancels a schedule */ public function cancel(id:Float) { var idx = this.scheduled.filter((val) -> { return val.id == id; }); if (idx.length == 0) return; this.scheduled.remove(idx[0]); } public function clearSchedule() { this.scheduled = []; } public function clearScheduleId(id:String) { var idx = this.scheduled.filter((val) -> { return val.stringId == id; }); if (idx.length == 0) return; this.scheduled.remove(idx[0]); } }