44 lines
1.2 KiB
CoffeeScript
44 lines
1.2 KiB
CoffeeScript
Travis.Pusher = ->
|
|
@active_channels = []
|
|
if Travis.Pusher.KEY
|
|
@pusher = new Pusher(Travis.Pusher.KEY)
|
|
@subscribe(channel) for channel in Travis.Pusher.CHANNELS
|
|
this
|
|
|
|
$.extend Travis.Pusher,
|
|
CHANNELS: ['common']
|
|
CHANNEL_PREFIX: ''
|
|
KEY: ''
|
|
|
|
$.extend Travis.Pusher.prototype,
|
|
subscribe: (channel) ->
|
|
if @pusher && @active_channels.indexOf(channel) == -1
|
|
@active_channels.push(channel)
|
|
@pusher.subscribe(@prefix(channel)).bind_all (event, data) => @receive(event, data)
|
|
|
|
unsubscribe: (channel) ->
|
|
ix = @active_channels.indexOf(channel)
|
|
if @pusher && ix == -1
|
|
@active_channels.splice(ix, 1)
|
|
@pusher.unsubscribe(@prefix(channel))
|
|
|
|
prefix: (channel) ->
|
|
"#{Travis.Pusher.CHANNEL_PREFIX}#{channel}"
|
|
|
|
receive: (event, data) ->
|
|
if data.id
|
|
data = @normalize(event, data)
|
|
Ember.run.next ->
|
|
Travis.app.store.receive(event, data)
|
|
|
|
normalize: (event, data) ->
|
|
switch event
|
|
when 'build:started', 'build:finished'
|
|
data
|
|
when 'job:created', 'job:started', 'job:finished', 'job:log'
|
|
data.queue = data.queue.replace('builds.', '') if data.queue
|
|
{ job: data }
|
|
when 'worker:added', 'worker:updated', 'worker:removed'
|
|
{ worker: data }
|
|
|