104 lines
2.5 KiB
CoffeeScript
104 lines
2.5 KiB
CoffeeScript
Travis.RunningJobsController = Em.ArrayProxy.extend
|
|
Group: Em.Object.extend
|
|
slug: (-> @get('jobs.firstObject.repoSlug') ).property('jobs.firstObject.repoSlug')
|
|
|
|
init: ->
|
|
@_super.apply this, arguments
|
|
@set 'jobs', []
|
|
|
|
@set 'sortedJobs', Em.ArrayProxy.extend(Em.SortableMixin,
|
|
sortProperties: ['number']
|
|
).create(content: @get('jobs'))
|
|
|
|
willDestroy: ->
|
|
@get('sortedJobs').destroy()
|
|
|
|
add: (job) ->
|
|
@get('jobs').pushObject(job) unless @get('jobs').contains job
|
|
@attach()
|
|
|
|
remove: (job) ->
|
|
@get('jobs').removeObject(job)
|
|
@clean()
|
|
|
|
attach: ->
|
|
@get('parent').addGroup(this)
|
|
|
|
clean: ->
|
|
@get('parent').removeGroup(this) if @get('isEmpty')
|
|
|
|
isEmpty: (->
|
|
@get('jobs.length') == 0
|
|
).property('jobs.length')
|
|
|
|
groups: []
|
|
sortedGroups: (->
|
|
Em.ArrayProxy.extend(Em.SortableMixin,
|
|
sortProperties: ['slug']
|
|
).create(content: @get('groups'))
|
|
).property()
|
|
|
|
groupsBySlug: {}
|
|
|
|
init: ->
|
|
@_super.apply this, arguments
|
|
|
|
jobs = Travis.Job.running()
|
|
@set 'content', jobs
|
|
@addedJobs jobs
|
|
|
|
contentArrayWillChange: (array, index, removedCount, addedCount) ->
|
|
@_super.apply this, arguments
|
|
|
|
if removedCount
|
|
@removedJobs array.slice(index, index + removedCount)
|
|
|
|
contentArrayDidChange: (array, index, removedCount, addedCount) ->
|
|
@_super.apply this, arguments
|
|
|
|
if addedCount
|
|
@addedJobs array.slice(index, index + addedCount)
|
|
|
|
addedJobs: (jobs) ->
|
|
self = this
|
|
jobs.forEach (job) ->
|
|
self.waitForSlug(job, 'addJob')
|
|
|
|
removedJobs: (jobs) ->
|
|
self = this
|
|
jobs.forEach (job) ->
|
|
self.waitForSlug(job, 'removeJob')
|
|
|
|
addJob: (job) ->
|
|
slug = job.get('repoSlug')
|
|
group = @groupForSlug(slug)
|
|
group.add(job)
|
|
|
|
removeJob: (job) ->
|
|
slug = job.get('repoSlug')
|
|
group = @groupForSlug(slug)
|
|
group.remove(job)
|
|
|
|
waitForSlug: (job, callbackName) ->
|
|
callback = @[callbackName]
|
|
self = this
|
|
if job.get('repoSlug')?
|
|
callback.call self, job
|
|
else
|
|
observer = ->
|
|
if job.get('repoSlug')?
|
|
callback.call self, job
|
|
job.removeObserver 'repoSlug', observer
|
|
job.addObserver 'repoSlug', observer
|
|
|
|
groupForSlug: (slug) ->
|
|
@groupsBySlug[slug] ||= @Group.create(slug: slug, parent: this)
|
|
|
|
addGroup: (group) ->
|
|
@get('groups').pushObject group unless @get('groups').contains group
|
|
|
|
removeGroup: (group) ->
|
|
@get('groups').removeObject group
|
|
delete @groupsBySlug[group.get('slug')]
|
|
group.destroy()
|