101 lines
3.2 KiB
CoffeeScript
101 lines
3.2 KiB
CoffeeScript
Travis.Pusher = (key) ->
|
|
@init(key) # if key
|
|
this
|
|
|
|
$.extend Travis.Pusher,
|
|
CHANNELS: ['common']
|
|
CHANNEL_PREFIX: ''
|
|
ENCRYPTED: false
|
|
|
|
$.extend Travis.Pusher.prototype,
|
|
active_channels: []
|
|
|
|
init: (config) ->
|
|
Pusher.warn = @warn.bind(this)
|
|
Pusher.host = config.host if config.host
|
|
@pusher = new Pusher(config.key, encrypted: Travis.Pusher.ENCRYPTED, disableStats: true)
|
|
@subscribeAll(Travis.Pusher.CHANNELS) if Travis.Pusher.CHANNELS
|
|
|
|
@callbacksToProcess = []
|
|
|
|
Visibility.change (e, state) =>
|
|
@processSavedCallbacks() if state == 'visible'
|
|
|
|
setInterval @processSavedCallbacks.bind(this), @processingIntervalWhenHidden
|
|
|
|
subscribeAll: (channels) ->
|
|
@subscribe(channel) for channel in channels
|
|
|
|
subscribe: (channel) ->
|
|
return unless channel
|
|
channel = @prefix(channel)
|
|
console.log("subscribing to #{channel}")
|
|
unless @pusher?.channel(channel)
|
|
@pusher.subscribe(channel).bind_all((event, data) => @receive(event, data))
|
|
|
|
unsubscribe: (channel) ->
|
|
return unless channel
|
|
channel = @prefix(channel)
|
|
console.log("unsubscribing from #{channel}")
|
|
@pusher.unsubscribe(channel) if @pusher?.channel(channel)
|
|
|
|
prefix: (channel) ->
|
|
"#{Travis.Pusher.CHANNEL_PREFIX}#{channel}" if channel && channel.indexOf(Travis.Pusher.CHANNEL_PREFIX) != 0
|
|
|
|
# process pusher messages in batches every 5 minutes when the page is hidden
|
|
processingIntervalWhenHidden: 1000 * 60 * 5
|
|
|
|
receive: (event, data) ->
|
|
return if event.substr(0, 6) == 'pusher'
|
|
data = @normalize(event, data) if data.id
|
|
|
|
@processWhenVisible ->
|
|
# TODO remove job:requeued, once sf-restart-event has been merged
|
|
# TODO this also needs to clear logs on build:created if matrix jobs are already loaded
|
|
if event == 'job:created' || event == 'job:requeued'
|
|
if Travis.Job.isRecordLoaded(data.job.id)
|
|
Travis.Job.find(data.job.id).clearLog()
|
|
|
|
Ember.run.next ->
|
|
Travis.receive(event, data)
|
|
|
|
processSavedCallbacks: ->
|
|
while callback = @callbacksToProcess.shiftObject()
|
|
callback.call(this)
|
|
|
|
processLater: (callback) ->
|
|
@callbacksToProcess.pushObject(callback)
|
|
|
|
processWhenVisible: (callback) ->
|
|
if Visibility.hidden() && Visibility.isSupported()
|
|
@processLater(callback)
|
|
else
|
|
callback.call(this)
|
|
|
|
normalize: (event, data) ->
|
|
switch event
|
|
when 'build:started', 'build:finished'
|
|
data
|
|
when 'job:created', 'job:started', 'job:requeued', 'job:finished', 'job:log', 'job:canceled'
|
|
data.queue = data.queue.replace('builds.', '') if data.queue
|
|
{ job: data }
|
|
when 'worker:added', 'worker:updated', 'worker:removed'
|
|
{ worker: data }
|
|
when 'annotation:created', 'annotation:updated'
|
|
{ annotation: data }
|
|
|
|
warn: (type, object) ->
|
|
console.warn(type, object.error) unless @ignoreWarning(type, object.error)
|
|
|
|
ignoreWarning: (type, error) ->
|
|
code = error?.data?.code || 0
|
|
message = error?.data?.message || ''
|
|
@ignoreCode(code) || @ignoreMessage(message)
|
|
|
|
ignoreCode: (code) ->
|
|
code == 1006
|
|
|
|
ignoreMessage: (message) ->
|
|
message.indexOf('Existing subscription') == 0 or message.indexOf('No current subscription') == 0
|
|
|