discourse/vendor/gems/message_bus/lib/message_bus/diagnostics.rb

class MessageBus::Diagnostics
  def self.full_process_path
    begin 
      info = `ps -eo "%p|$|%a" | grep '^\\s*#{Process.pid}'` 
      info.strip.split('|$|')[1]
    rescue
      # skip it ... not linux or something weird
    end
  end
  
  def self.hostname
    begin 
      `hostname`.strip
    rescue
      # skip it
    end
  end

  def self.enable
    full_path = full_process_path
    start_time = Time.now.to_f
    hostname = self.hostname

    # it may make sense to add a channel per machine/host to streamline 
    #  process to process comms 
    MessageBus.subscribe('/_diagnostics/hup') do |msg|
      if Process.pid == msg.data["pid"] && hostname == msg.data["hostname"]
        $shutdown = true
        sleep 4
        Process.kill("HUP", $$)
      end
    end

    MessageBus.subscribe('/_diagnostics/discover') do |msg|
      MessageBus.on_connect.call msg.site_id if MessageBus.on_connect
      MessageBus.publish '/_diagnostics/process-discovery', { 
        pid: Process.pid,
        process_name: $0,
        full_path: full_path,
        uptime: (Time.now.to_f - start_time).to_i,
        hostname: hostname
      }, user_ids: [msg.data["user_id"]]
      MessageBus.on_disconnect.call msg.site_id if MessageBus.on_disconnect
    end
  end
end