dashboard events - use SSE event names

Author: cjolly

javascripts/dashing.coffee

@@ -106,17 +106,18 @@ source.addEventListener 'error', (e)->
 source.addEventListener 'message', (e) ->
   data = JSON.parse(e.data)
   if lastEvents[data.id]?.updatedAt != data.updatedAt
-    # /messages are internal messages, and cannot correspond to widgets.
-    # We will handle them as events on the Dashing application.
-    return Dashing.fire(data.id.slice(1), data) if data.id[0] is '/'
-
     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)
+  Dashing.fire data.event, data
 
 $(document).ready ->
   Dashing.run()

lib/dashing.rb

@@ -81,12 +81,13 @@ def protected!
   end
 end
 
-post '/reload' do
+post '/dashboards/:id' do
   request.body.rewind
   body = JSON.parse(request.body.read)
+  body['dashboard'] ||= params['id']
   auth_token = body.delete("auth_token")
   if !settings.auth_token || settings.auth_token == auth_token
-    send_event('/reload', body)
+    send_event(params['id'], body, 'dashboards')
     204 # response without entity body
   else
     status 401
@@ -119,16 +120,18 @@ def production?
   ENV['RACK_ENV'] == 'production'
 end
 
-def send_event(id, body)
+def send_event(id, body, target=nil)
   body[:id] = id
   body[:updatedAt] ||= Time.now.to_i
-  event = format_event(body.to_json)
-  Sinatra::Application.settings.history[id] = event unless id =~ /^\//
+  event = format_event(body.to_json, target)
+  Sinatra::Application.settings.history[id] = event unless target == 'dashboards'
   Sinatra::Application.settings.connections.each { |out| out << event }
 end
 
-def format_event(body)
-  "data: #{body}\n\n"
+def format_event(body, name=nil)
+  str = ""
+  str << "event: #{name}\n" if name
+  str << "data: #{body}\n\n"
 end
 
 def latest_events

test/app_test.rb

@@ -41,6 +41,16 @@ def test_get_events
     assert_equal 8, parse_data(@connection[0])['value']
   end
 
+  def test_dashboard_events
+    post '/dashboards/my_super_sweet_dashboard', JSON.generate({event: 'reload'})
+    assert_equal 204, last_response.status
+
+    get '/events'
+    assert_equal 200, last_response.status
+    assert_equal 'dashboards', parse_event(@connection[0])
+    assert_equal 'reload', parse_data(@connection[0])['event']
+  end
+
   def test_redirect_to_default_dashboard
     with_generated_project do
       Sinatra::Application.settings.default_dashboard = 'test1'
@@ -141,4 +151,8 @@ def app
   def parse_data(string)
     JSON.parse string[/data: (.+)/, 1]
   end
-end
+
+  def parse_event(string)
+    string[/event: (.+)/, 1]
+  end
+end