Commit 2e67c68f authored by Paul Asmuth's avatar Paul Asmuth
Browse files

better websocket error handling

parent d686da74
Loading
Loading
Loading
Loading
+6 −2
Original line number Diff line number Diff line
@@ -22,8 +22,12 @@ class FnordMetric::Reactor
private

  def execute_unsafe(socket, event, messages = [])
    return false unless event["namespace"]
    return false unless ns = @namespaces[event["namespace"].to_sym]
    return [] unless event["namespace"]

    unless ns = @namespaces[event["namespace"].to_sym]
      return([{ "error" => "invalid namespace: #{event["namespace"]}" }])
    end

    messages << discover(ns) if event["type"] == "discover_request"
    messages << widget(ns, event) if event["type"] == "widget_request"
    messages << gauge(ns, event) if event["type"] == "render_request"
+3 −0
Original line number Diff line number Diff line
@@ -29,6 +29,9 @@ class FnordMetric::WebSocket < Rack::WebSocket::Application
        send_data m.to_json
      end
    end
  rescue Exception => e
    FnordMetric.error("[WebSocket] #{e.to_s}")
    puts e.backtrace.join("\n")
  end

  def get_uuid