1 files changed, 130 insertions, 0 deletions
diff --git a/javascripts/dashing.coffee b/javascripts/dashing.coffee
new file mode 100644
index 0000000..20a9987
--- /dev/null
+++ b/javascripts/dashing.coffee
@@ -0,0 +1,130 @@
+#= require jquery
+#= require es5-shim
+#= require batman
+#= require batman.jquery
+
+
+Batman.Filters.prettyNumber = (num) ->
+  num.toString().replace(/\B(?=(\d{3})+(?!\d))/g, ",") unless isNaN(num)
+
+Batman.Filters.dashize = (str) ->
+  dashes_rx1 = /([A-Z]+)([A-Z][a-z])/g;
+  dashes_rx2 = /([a-z\d])([A-Z])/g;
+
+  return str.replace(dashes_rx1, '$1_$2').replace(dashes_rx2, '$1_$2').replace(/_/g, '-').toLowerCase()
+
+Batman.Filters.shortenedNumber = (num) ->
+  return num if isNaN(num)
+  if num >= 1000000000
+    (num / 1000000000).toFixed(1) + 'B'
+  else if num >= 1000000
+    (num / 1000000).toFixed(1) + 'M'
+  else if num >= 1000
+    (num / 1000).toFixed(1) + 'K'
+  else
+    num
+
+class window.Dashing extends Batman.App
+  @on 'reload', (data) ->
+    window.location.reload(true)
+
+  @root ->
+Dashing.params = Batman.URI.paramsFromQuery(window.location.search.slice(1));
+
+class Dashing.Widget extends Batman.View
+  constructor:  ->
+    # Set the view path
+    @constructor::source = Batman.Filters.underscore(@constructor.name)
+    super
+
+    @mixin($(@node).data())
+    Dashing.widgets[@id] ||= []
+    Dashing.widgets[@id].push(@)
+
+    type = Batman.Filters.dashize(@view)
+    $(@node).addClass("widget widget-#{type} #{@id}")
+
+  @accessor 'updatedAtMessage', ->
+    if updatedAt = @get('updatedAt')
+      timestamp = new Date(updatedAt * 1000)
+      hours = timestamp.getHours()
+      minutes = ("0" + timestamp.getMinutes()).slice(-2)
+      "Last updated at #{hours}:#{minutes}"
+
+  @::on 'ready', ->
+    Dashing.Widget.fire 'ready'
+
+    # In case the events from the server came before the widget was rendered
+    lastData = Dashing.lastEvents[@id]
+    if lastData
+      @mixin(lastData)
+      @onData(lastData)
+
+  receiveData: (data) =>
+    @mixin(data)
+    @onData(data)
+
+  onData: (data) =>
+    # Widgets override this to handle incoming data
+
+Dashing.AnimatedValue =
+  get: Batman.Property.defaultAccessor.get
+  set: (k, to) ->
+    if !to? || isNaN(to)
+      @[k] = to
+    else
+      timer = "interval_#{k}"
+      num = if (!isNaN(@[k]) && @[k]?) then @[k] else 0
+      unless @[timer] || num == to
+        to = parseFloat(to)
+        num = parseFloat(num)
+        up = to > num
+        num_interval = Math.abs(num - to) / 90
+        @[timer] =
+          setInterval =>
+            num = if up then Math.ceil(num+num_interval) else Math.floor(num-num_interval)
+            if (up && num > to) || (!up && num < to)
+              num = to
+              clearInterval(@[timer])
+              @[timer] = null
+              delete @[timer]
+            @[k] = num
+            @set k, to
+          , 10
+      @[k] = num
+
+Dashing.widgets = widgets = {}
+Dashing.lastEvents = lastEvents = {}
+Dashing.debugMode = false
+
+source = new EventSource('events')
+source.addEventListener 'open', (e) ->
+  console.log("Connection opened", e)
+
+source.addEventListener 'error', (e)->
+  console.log("Connection error", e)
+  if (e.currentTarget.readyState == EventSource.CLOSED)
+    console.log("Connection closed")
+    setTimeout (->
+      window.location.reload()
+    ), 5*60*1000
+
+source.addEventListener 'message', (e) ->
+  data = JSON.parse(e.data)
+  if lastEvents[data.id]?.updatedAt != data.updatedAt
+    if Dashing.debugMode
+      console.log("Received data for #{data.id}", data)
+    lastEvents[data.id] = data
+    if widgets[data.id]?.length > 0
+      for widget in widgets[data.id]
+        widget.receiveData(data)
+
+source.addEventListener 'dashboards', (e) ->
+  data = JSON.parse(e.data)
+  if Dashing.debugMode
+    console.log("Received data for dashboards", data)
+  if data.dashboard is '*' or window.location.pathname is "/#{data.dashboard}"
+    Dashing.fire data.event, data
+
+$(document).ready ->
+  Dashing.run()