From 3f58bbd626cd84d1cb24375b4d8fe6df75ce85ba Mon Sep 17 00:00:00 2001
From: Pieter van de Bruggen <pvande@gmail.com>
Date: Sun, 4 Nov 2012 17:10:36 -0800
Subject: Adding application messaging.

While widgets are the most common target for events, there is good reason to sometimes target the application
as a whole.  This patch adds support for such events using the /-prefixed notation.  (This convention is safe
for use since it represents an extremely uncommon widget ID, and one which data could not be POSTed to.)
Such events are NOT subject to replay, and are handled on the client-side by firing corresponding events on
the Dashing application class.

As a proof of concept (and to fufill a feature request), this patch also introduces a POST /reload endpoint,
which when provided with a valid authkey (and optionally a dashboard name) fires the appropriate 'reload'
event on all of the loaded dashboards.  The 'reload' event handler then reloads the dashboard, unless a
different dashboard was specified.
---
 lib/dashing.rb | 17 +++++++++++++++--
 1 file changed, 15 insertions(+), 2 deletions(-)

(limited to 'lib')

diff --git a/lib/dashing.rb b/lib/dashing.rb
index dc62395..4c1b44b 100644
--- a/lib/dashing.rb
+++ b/lib/dashing.rb
@@ -81,9 +81,22 @@ get '/views/:widget?.html' do
   end
 end
 
+post '/reload' do
+  request.body.rewind
+  body = JSON.parse(request.body.read)
+  auth_token = body.delete("auth_token")
+  if !settings.auth_token || settings.auth_token == auth_token
+    send_event('/reload', body)
+    204 # response without entity body
+  else
+    status 401
+    "Invalid API key\n"
+  end
+end
+
 post '/widgets/:id' do
   request.body.rewind
-  body =  JSON.parse(request.body.read)
+  body = JSON.parse(request.body.read)
   auth_token = body.delete("auth_token")
   if !settings.auth_token || settings.auth_token == auth_token
     send_event(params['id'], body)
@@ -110,7 +123,7 @@ def send_event(id, body)
   body[:id] = id
   body[:updatedAt] ||= Time.now.to_i
   event = format_event(body.to_json)
-  Sinatra::Application.settings.history[id] = event
+  Sinatra::Application.settings.history[id] = event unless id =~ /^\//
   Sinatra::Application.settings.connections.each { |out| out << event }
 end
 
-- 
cgit v1.2.3


From 5f8cbcb7debde027e79d87733b84cb852aa47dad Mon Sep 17 00:00:00 2001
From: Chad Jolly <cjolly@lawgical.com>
Date: Sun, 14 Jul 2013 18:36:19 -0600
Subject: dashboard events - use SSE event names

---
 lib/dashing.rb | 17 ++++++++++-------
 1 file changed, 10 insertions(+), 7 deletions(-)

(limited to 'lib')

diff --git a/lib/dashing.rb b/lib/dashing.rb
index 4c1b44b..935a031 100644
--- a/lib/dashing.rb
+++ b/lib/dashing.rb
@@ -81,12 +81,13 @@ get '/views/:widget?.html' do
   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
-- 
cgit v1.2.3