mirror of
https://github.com/codeninjasllc/codecombat.git
synced 2024-12-11 08:11:21 -05:00
342 lines
15 KiB
CoffeeScript
342 lines
15 KiB
CoffeeScript
# Every Angel has one web worker attached to it. It will call methods inside the worker and kill it if it times out.
|
|
# God is the public API; Angels are an implementation detail. Each God can have one or more Angels.
|
|
|
|
{now} = require 'lib/world/world_utils'
|
|
World = require 'lib/world/world'
|
|
CocoClass = require 'core/CocoClass'
|
|
GoalManager = require 'lib/world/GoalManager'
|
|
{sendContactMessage} = require 'core/contact'
|
|
|
|
reportedLoadErrorAlready = false
|
|
|
|
module.exports = class Angel extends CocoClass
|
|
@nicks: ['Archer', 'Lana', 'Cyril', 'Pam', 'Cheryl', 'Woodhouse', 'Ray', 'Krieger']
|
|
|
|
infiniteLoopIntervalDuration: 10000 # check this often; must be longer than other two combined
|
|
infiniteLoopTimeoutDuration: 7500 # wait this long for a response when checking
|
|
abortTimeoutDuration: 500 # give in-process or dying workers this long to give up
|
|
|
|
subscriptions:
|
|
'level:flag-updated': 'onFlagEvent'
|
|
'playback:stop-real-time-playback': 'onStopRealTimePlayback'
|
|
'level:escape-pressed': 'onEscapePressed'
|
|
|
|
constructor: (@shared) ->
|
|
super()
|
|
@say 'Got my wings.'
|
|
isIE = window.navigator and (window.navigator.userAgent.search('MSIE') isnt -1 or window.navigator.appName is 'Microsoft Internet Explorer')
|
|
slowerSimulations = isIE #or @shared.headless
|
|
# Since IE is so slow to serialize without transferable objects, we can't trust it.
|
|
# We also noticed the headless_client simulator needing more time. (This does both Simulators, though.) If we need to use lots of headless clients, enable this.
|
|
if slowerSimulations
|
|
@infiniteLoopIntervalDuration *= 10
|
|
@infiniteLoopTimeoutDuration *= 10
|
|
@abortTimeoutDuration *= 10
|
|
@initialized = false
|
|
@running = false
|
|
@allLogs = []
|
|
@hireWorker()
|
|
@shared.angels.push @
|
|
@listenTo @shared.gameUIState.get('realTimeInputEvents'), 'add', @onAddRealTimeInputEvent
|
|
|
|
destroy: ->
|
|
@fireWorker false
|
|
_.remove @shared.angels, @
|
|
super()
|
|
|
|
workIfIdle: ->
|
|
@doWork() unless @running
|
|
|
|
# say: debugging stuff, usually off; log: important performance indicators, keep on
|
|
say: (args...) -> #@log args...
|
|
log: ->
|
|
# console.info.apply is undefined in IE9, CoffeeScript splats invocation won't work.
|
|
# http://stackoverflow.com/questions/5472938/does-ie9-support-console-log-and-is-it-a-real-function
|
|
message = "|#{@shared.godNick}'s #{@nick}|"
|
|
message += " #{arg}" for arg in arguments
|
|
console.info message
|
|
@allLogs.push message
|
|
|
|
testWorker: =>
|
|
return if @destroyed
|
|
clearTimeout @condemnTimeout
|
|
@condemnTimeout = _.delay @infinitelyLooped, @infiniteLoopTimeoutDuration
|
|
@say 'Let\'s give it', @infiniteLoopTimeoutDuration, 'to not loop.'
|
|
@worker.postMessage func: 'reportIn'
|
|
|
|
onWorkerMessage: (event) =>
|
|
return @say 'Currently aborting old work.' if @aborting and event.data.type isnt 'abort'
|
|
|
|
switch event.data.type
|
|
# First step: worker has to load the scripts.
|
|
when 'worker-initialized'
|
|
unless @initialized
|
|
@log "Worker initialized after #{(new Date()) - @worker.creationTime}ms"
|
|
@initialized = true
|
|
@doWork()
|
|
|
|
# We watch over the worker as it loads the world frames to make sure it doesn't infinitely loop.
|
|
when 'start-load-frames'
|
|
clearTimeout @condemnTimeout
|
|
when 'report-in'
|
|
@say 'Worker reported in.'
|
|
clearTimeout @condemnTimeout
|
|
when 'end-load-frames'
|
|
clearTimeout @condemnTimeout
|
|
@beholdGoalStates {goalStates: event.data.goalStates, overallStatus: event.data.overallStatus, preload: false, totalFrames: event.data.totalFrames, lastFrameHash: event.data.lastFrameHash, simulationFrameRate: event.data.simulationFrameRate} # Work ends here if we're headless.
|
|
when 'end-preload-frames'
|
|
clearTimeout @condemnTimeout
|
|
@beholdGoalStates {goalStates: event.data.goalStates, overallStatus: event.data.overallStatus, preload: true, simulationFrameRate: event.data.simulationFrameRate}
|
|
|
|
# We have to abort like an infinite loop if we see one of these; they're not really recoverable
|
|
when 'non-user-code-problem'
|
|
@publishGodEvent 'non-user-code-problem', problem: event.data.problem
|
|
if @shared.firstWorld
|
|
@infinitelyLooped(false, true) # For now, this should do roughly the right thing if it happens during load.
|
|
else
|
|
@fireWorker()
|
|
|
|
# If it didn't finish simulating successfully, or we abort the worker.
|
|
when 'abort'
|
|
@say 'Aborted.', event.data
|
|
clearTimeout @abortTimeout
|
|
@aborting = false
|
|
@running = false
|
|
_.remove @shared.busyAngels, @
|
|
@doWork()
|
|
|
|
# We pay attention to certain progress indicators as the world loads.
|
|
when 'console-log'
|
|
@log event.data.args...
|
|
when 'user-code-problem'
|
|
@publishGodEvent 'user-code-problem', problem: event.data.problem
|
|
when 'world-load-progress-changed'
|
|
progress = event.data.progress
|
|
progress = Math.min(progress, 0.9) if @work.indefiniteLength
|
|
@publishGodEvent 'world-load-progress-changed', { progress }
|
|
unless event.data.progress is 1 or @work.preload or @work.headless or @work.synchronous or @deserializationQueue.length or (@shared.firstWorld and not @shared.spectate)
|
|
@worker.postMessage func: 'serializeFramesSoFar' # Stream it!
|
|
|
|
# We have some or all of the frames serialized, so let's send the (partially?) simulated world to the Surface.
|
|
when 'some-frames-serialized', 'new-world'
|
|
deserializationArgs = [event.data.serialized, event.data.goalStates, event.data.startFrame, event.data.endFrame, @streamingWorld]
|
|
@deserializationQueue.push deserializationArgs
|
|
if @deserializationQueue.length is 1
|
|
@beholdWorld deserializationArgs...
|
|
|
|
else
|
|
@log 'Received unsupported message:', event.data
|
|
|
|
beholdGoalStates: ({goalStates, overallStatus, preload, totalFrames, lastFrameHash, simulationFrameRate}) ->
|
|
return if @aborting
|
|
event = goalStates: goalStates, preload: preload ? false, overallStatus: overallStatus
|
|
event.totalFrames = totalFrames if totalFrames?
|
|
event.lastFrameHash = lastFrameHash if lastFrameHash?
|
|
event.simulationFrameRate = simulationFrameRate if simulationFrameRate?
|
|
@publishGodEvent 'goals-calculated', event
|
|
@finishWork() if @shared.headless
|
|
|
|
beholdWorld: (serialized, goalStates, startFrame, endFrame, streamingWorld) ->
|
|
return if @aborting
|
|
# Toggle BOX2D_ENABLED during deserialization so that if we have box2d in the namespace, the Collides Components still don't try to create bodies for deserialized Thangs upon attachment.
|
|
window.BOX2D_ENABLED = false
|
|
streamingWorld?.indefiniteLength = @work.indefiniteLength
|
|
@streamingWorld = World.deserialize serialized, @shared.worldClassMap, @shared.lastSerializedWorldFrames, @finishBeholdingWorld(goalStates), startFrame, endFrame, @work.level, streamingWorld
|
|
window.BOX2D_ENABLED = true
|
|
@shared.lastSerializedWorldFrames = serialized.frames
|
|
|
|
finishBeholdingWorld: (goalStates) -> (world) =>
|
|
return if @aborting or @destroyed
|
|
finished = world.frames.length is world.totalFrames
|
|
if @work?.indefiniteLength and world.victory?
|
|
finished = true
|
|
world.totalFrames = world.frames.length
|
|
firstChangedFrame = if @work?.indefiniteLength then 0 else world.findFirstChangedFrame @shared.world
|
|
eventType = if finished then 'new-world-created' else 'streaming-world-updated'
|
|
if finished
|
|
@shared.world = world
|
|
@publishGodEvent eventType, world: world, firstWorld: @shared.firstWorld, goalStates: goalStates, team: me.team, firstChangedFrame: firstChangedFrame, finished: finished
|
|
if finished
|
|
for scriptNote in @shared.world.scriptNotes
|
|
Backbone.Mediator.publish scriptNote.channel, scriptNote.event
|
|
@shared.goalManager?.world = world
|
|
@finishWork()
|
|
else
|
|
@deserializationQueue.shift() # Finished with this deserialization.
|
|
if deserializationArgs = @deserializationQueue[0] # Start another?
|
|
@beholdWorld deserializationArgs...
|
|
|
|
finishWork: ->
|
|
@streamingWorld = null
|
|
@shared.firstWorld = false
|
|
@deserializationQueue = []
|
|
@running = false
|
|
_.remove @shared.busyAngels, @
|
|
clearTimeout @condemnTimeout
|
|
clearInterval @purgatoryTimer
|
|
@condemnTimeout = @purgatoryTimer = null
|
|
@doWork()
|
|
|
|
finalizePreload: ->
|
|
@say 'Finalize preload.'
|
|
@worker.postMessage func: 'finalizePreload'
|
|
@work.preload = false
|
|
|
|
infinitelyLooped: (escaped=false, nonUserCodeProblem=false) =>
|
|
@say 'On infinitely looped! Aborting?', @aborting
|
|
return if @aborting
|
|
problem = type: 'runtime', level: 'error', id: 'runtime_InfiniteLoop', message: 'Code never finished. It\'s either really slow or has an infinite loop.'
|
|
problem.message = 'Escape pressed; code aborted.' if escaped
|
|
@publishGodEvent 'user-code-problem', problem: problem
|
|
@publishGodEvent 'infinite-loop', firstWorld: @shared.firstWorld, nonUserCodeProblem: nonUserCodeProblem
|
|
@reportLoadError() if nonUserCodeProblem
|
|
@fireWorker()
|
|
|
|
publishGodEvent: (channel, e) ->
|
|
# For Simulator. TODO: refactor all the god:* Mediator events to be local events.
|
|
@shared.god.trigger channel, e
|
|
e.god = @shared.god
|
|
Backbone.Mediator.publish 'god:' + channel, e
|
|
|
|
reportLoadError: ->
|
|
return if me.isAdmin() or /dev=true/.test(window.location?.href ? '') or reportedLoadErrorAlready
|
|
reportedLoadErrorAlready = true
|
|
context = email: me.get('email')
|
|
context.message = "Automatic Report - Unable to Load Level\nLogs:\n" + @allLogs.join('\n')
|
|
if $.browser
|
|
context.browser = "#{$.browser.platform} #{$.browser.name} #{$.browser.versionNumber}"
|
|
context.screenSize = "#{screen?.width ? $(window).width()} x #{screen?.height ? $(window).height()}"
|
|
context.subject = "Level Load Error: #{@work?.level?.name or 'Unknown Level'}"
|
|
context.levelSlug = @work?.level?.slug
|
|
sendContactMessage context
|
|
|
|
doWork: ->
|
|
return if @aborting
|
|
return @say 'Not initialized for work yet.' unless @initialized
|
|
if @shared.workQueue.length
|
|
@work = @shared.workQueue.shift()
|
|
return _.defer @simulateSync, @work if @work.synchronous
|
|
@say 'Running world...'
|
|
@running = true
|
|
@shared.busyAngels.push @
|
|
@deserializationQueue = []
|
|
@worker.postMessage func: 'runWorld', args: @work
|
|
clearTimeout @purgatoryTimer
|
|
@say 'Infinite loop timer started at interval of', @infiniteLoopIntervalDuration
|
|
@purgatoryTimer = setInterval @testWorker, @infiniteLoopIntervalDuration
|
|
else
|
|
@say 'No work to do.'
|
|
@hireWorker()
|
|
|
|
abort: ->
|
|
return unless @worker and @running
|
|
@say 'Aborting...'
|
|
@running = false
|
|
@work = null
|
|
@streamingWorld = null
|
|
@deserializationQueue = []
|
|
_.remove @shared.busyAngels, @
|
|
@abortTimeout = _.delay @fireWorker, @abortTimeoutDuration
|
|
@aborting = true
|
|
@worker.postMessage func: 'abort'
|
|
|
|
fireWorker: (rehire=true) =>
|
|
return if @destroyed
|
|
@aborting = false
|
|
@running = false
|
|
_.remove @shared.busyAngels, @
|
|
@worker?.removeEventListener 'message', @onWorkerMessage
|
|
@worker?.terminate()
|
|
@worker = null
|
|
clearTimeout @condemnTimeout
|
|
clearInterval @purgatoryTimer
|
|
@say 'Fired worker.'
|
|
@initialized = false
|
|
@work = null
|
|
@streamingWorld = null
|
|
@deserializationQueue = []
|
|
@hireWorker() if rehire
|
|
|
|
hireWorker: ->
|
|
unless Worker?
|
|
unless @initialized
|
|
@initialized = true
|
|
@doWork()
|
|
return null
|
|
return if @worker
|
|
@say 'Hiring worker.'
|
|
@worker = new Worker @shared.workerCode
|
|
@worker.addEventListener 'message', @onWorkerMessage
|
|
@worker.creationTime = new Date()
|
|
|
|
onFlagEvent: (e) ->
|
|
return unless @running and @work.realTime
|
|
@worker.postMessage func: 'addFlagEvent', args: e
|
|
|
|
onAddRealTimeInputEvent: (realTimeInputEvent) ->
|
|
return unless @running and @work.realTime
|
|
@worker.postMessage func: 'addRealTimeInputEvent', args: realTimeInputEvent.toJSON()
|
|
|
|
onStopRealTimePlayback: (e) ->
|
|
return unless @running and @work.realTime
|
|
@work.realTime = false
|
|
@lastRealTimeWork = new Date()
|
|
@worker.postMessage func: 'stopRealTimePlayback'
|
|
|
|
onEscapePressed: (e) ->
|
|
return unless @running and not @work.realTime
|
|
return if (new Date() - @lastRealTimeWork) < 1000 # Fires right after onStopRealTimePlayback
|
|
@infinitelyLooped true
|
|
|
|
#### Synchronous code for running worlds on main thread (profiling / IE9) ####
|
|
simulateSync: (work) =>
|
|
console?.profile? "World Generation #{(Math.random() * 1000).toFixed(0)}" if imitateIE9?
|
|
work.t0 = now()
|
|
work.world = testWorld = new World work.userCodeMap
|
|
work.world.levelSessionIDs = work.levelSessionIDs
|
|
work.world.submissionCount = work.submissionCount
|
|
work.world.fixedSeed = work.fixedSeed
|
|
work.world.flagHistory = work.flagHistory ? []
|
|
work.world.difficulty = work.difficulty
|
|
work.world.loadFromLevel work.level
|
|
work.world.preloading = work.preload
|
|
work.world.headless = work.headless
|
|
work.world.realTime = work.realTime
|
|
if @shared.goalManager
|
|
testGM = new GoalManager(testWorld)
|
|
testGM.setGoals work.goals
|
|
testGM.setCode work.userCodeMap
|
|
testGM.worldGenerationWillBegin()
|
|
testWorld.setGoalManager testGM
|
|
@doSimulateWorld work
|
|
console?.profileEnd?() if imitateIE9?
|
|
console.log 'Construction:', (work.t1 - work.t0).toFixed(0), 'ms. Simulation:', (work.t2 - work.t1).toFixed(0), 'ms --', ((work.t2 - work.t1) / testWorld.frames.length).toFixed(3), 'ms per frame, profiled.'
|
|
|
|
# If performance was really a priority in IE9, we would rework things to be able to skip this step.
|
|
goalStates = testGM?.getGoalStates()
|
|
work.world.goalManager.worldGenerationEnded() if work.world.ended
|
|
|
|
if work.headless
|
|
simulationFrameRate = work.world.frames.length / (work.t2 - work.t1) * 1000 * 30 / work.world.frameRate
|
|
@beholdGoalStates {goalStates, overallStatus: testGM.checkOverallStatus(), preload: false, totalFrames: work.world.totalFrames, lastFrameHash: work.world.frames[work.world.totalFrames - 2]?.hash, simulationFrameRate: simulationFrameRate}
|
|
return
|
|
|
|
serialized = world.serialize()
|
|
window.BOX2D_ENABLED = false
|
|
World.deserialize serialized.serializedWorld, @shared.worldClassMap, @shared.lastSerializedWorldFrames, @finishBeholdingWorld(goalStates), serialized.startFrame, serialized.endFrame, work.level
|
|
window.BOX2D_ENABLED = true
|
|
@shared.lastSerializedWorldFrames = serialized.serializedWorld.frames
|
|
|
|
doSimulateWorld: (work) ->
|
|
work.t1 = now()
|
|
Math.random = work.world.rand.randf # so user code is predictable
|
|
Aether.replaceBuiltin('Math', Math)
|
|
replacedLoDash = _.runInContext(window)
|
|
_[key] = replacedLoDash[key] for key, val of replacedLoDash
|
|
i = 0
|
|
while i < work.world.totalFrames
|
|
frame = work.world.getFrame i++
|
|
@publishGodEvent 'world-load-progress-changed', progress: 1
|
|
work.world.ended = true
|
|
system.finish work.world.thangs for system in work.world.systems
|
|
work.t2 = now()
|