Feature/systemstatus 1291

apps/dashboard/app/controllers/system_status_controller.rb

@@ -0,0 +1,7 @@
+class SystemStatusController < ApplicationController
+  def index
+    @job_clusters = OodAppkit.clusters
+                             .select(&:job_allow?)
+                             .reject { |c| c.metadata.hidden }
+  end
+end

apps/dashboard/app/helpers/system_status_helper.rb

@@ -0,0 +1,105 @@
+# frozen_string_literal: true
+
+# helper for the system status page
+module SystemStatusHelper
+  # Used to not repeatedly request the job adapter
+  def update_cluster(cluster)
+    @job_adapter = cluster.job_adapter
+    @cluster_info = @job_adapter.cluster_info
+    @cluster = cluster
+  end
+
+  def job_adapter(cluster)
+    if @cluster != cluster
+      update_cluster cluster
+    end
+
+    @job_adapter
+  end
+
+  def cluster_info(cluster)
+    if @cluster != cluster
+      update_cluster cluster
+    end
+
+    @cluster_info
+  end
+
+  def title(cluster)
+    "#{cluster.metadata.title.titleize} Cluster Status"
+  end
+
+  def generic_pct(value, total)
+    "#{(value.to_f / total * 100).round 2}%"
+  end
+
+  def generic_status(active, total, name)
+    "#{active} of #{total} #{name} Active (#{total - active} Free)"
+  end
+
+  def node_status(cluster)
+    c_info = cluster_info cluster
+    generic_status(c_info.active_nodes, c_info.total_nodes, 'Nodes')
+  end
+
+  def node_pct(cluster)
+    c_info = cluster_info cluster
+    generic_pct(c_info.active_nodes, c_info.total_nodes)
+  end
+
+  def processor_status(cluster)
+    c_info = cluster_info cluster
+    generic_status(c_info.active_processors, c_info.total_processors, 'Processors')
+  end
+
+  def processor_pct(cluster)
+    c_info = cluster_info cluster
+    generic_pct(c_info.active_processors, c_info.total_processors)
+  end
+
+  def gpu_status(cluster)
+    c_info = cluster_info cluster
+    generic_status(c_info.active_gpus, c_info.total_gpus, 'GPUs')
+  end
+
+  def gpu_pct(cluster)
+    c_info = cluster_info cluster
+    generic_pct(c_info.active_gpus, c_info.total_gpus)
+  end
+
+  def active_jobs(cluster)
+    active_count = 0
+    job_adapter(cluster).info_all_each do |i|
+      if i.status.running?
+        active_count += 1
+      end
+    end
+    active_count
+  end
+
+  def active_job_status(cluster)
+    "#{active_jobs cluster} Jobs Running"
+  end
+
+  def queued_jobs(cluster)
+    queued_count = 0
+    job_adapter(cluster).info_all_each do |i|
+      if i.status.queued?
+        queued_count += 1
+      end
+    end
+    queued_count
+  end
+
+  def queued_job_status(cluster)
+    "#{queued_jobs cluster} Jobs Queued"
+  end
+
+  def active_job_pct(cluster)
+    generic_pct(active_jobs(cluster), active_jobs(cluster) + queued_jobs(cluster))
+  end
+
+  def queued_job_pct(cluster)
+    generic_pct(queued_jobs(cluster), active_jobs(cluster) + queued_jobs(cluster))
+  end
+end

apps/dashboard/app/javascript/config.js

@@ -71,4 +71,4 @@ export function bcPollDelay() {
 export function bcIndexUrl() {
   const cfgData = configData();
   return cfgData['bcIndexUrl'];
-}
+}

apps/dashboard/app/javascript/system_status.js

@@ -0,0 +1,17 @@
+import { bcPollDelay } from './config'
+import { replaceHTML } from './turbo_shim'
+
+function poll() {
+  url = "";
+  fetch(url, { headers: { Accept: "text/vnd.turbo-stream.html" } })
+    .then(response => response.ok ? Promise.resolve(response) : Promise.reject(response.text()))
+    .then((r) => r.text())
+    .then((html) => replaceHTML("system-status", html))
+    .then(setTimeout(poll, bcPollDelay()))
+    .catch((err) => {
+      console.log('Cannot retrieve batch connect sessions due to error:');
+      console.log(err);
+    });
+}
+
+jQuery(poll)

apps/dashboard/app/views/system_status/index.html.erb

@@ -0,0 +1,2 @@
+<div class="row justify-content-center" id="system-status">Loading</div>
+<%= javascript_include_tag 'system_status' %>

apps/dashboard/app/views/system_status/index.turbo_stream.erb

@@ -0,0 +1,33 @@
+<turbo-stream action="replace" target="system-status">
+  <template>
+    <% @job_clusters.each do |c| %>
+      <div class="col-sm-6 col-xs-12 p-2">
+        <div class="col border rounded p-2 text-center">
+          <h4><strong><%= title c %></strong></h4>
+          <div>Hello world at <%= Time.now %></div>
+          <div><%= node_status c %></div>
+          <div class="progress">
+            <div class="progress-bar" role="progressbar" style="width: <%= node_pct c %>"><%= node_pct c %></div>
+          </div>
+          <div><%= processor_status c %></div> 
+          <div class="progress">
+            <div class="progress-bar" role="progressbar" style="width: <%= processor_pct c %>"><%= processor_pct c %></div>
+          </div>
+          <div><%= gpu_status c %></div>
+          <div class="progress">
+            <div class="progress-bar" role="progressbar" style="width: <%= gpu_pct c %>"><%= gpu_pct c %></div>
+          </div>
+          <h4 class="mt-2 pt-2 border-top">Jobs</h4>
+          <div><%= active_job_status c %></div>
+          <div class="progress">
+            <div class="progress-bar" role="progressbar" style="width: <%= active_job_pct c %>"><%= active_job_pct c %></div>
+          </div>
+          <div><%= queued_job_status c %></div>
+          <div class="progress">
+            <div class="progress-bar" role="progressbar" style="width: <%= queued_job_pct c %>"><%= queued_job_pct c %></div>
+          </div>
+        </div>
+      </div>
+    <% end %>
+  </template>
+</turbo-stream>

apps/dashboard/config/routes.rb

@@ -98,6 +98,8 @@
     delete '/activejobs' => 'active_jobs#delete_job', :as => 'delete_job'
   end
 
+  get '/systemstatus' => 'system_status#index'
+
   get '/jobs/info/:cluster/:id' => 'jobs#info', :defaults => { :format => 'json' }, :as => 'jobs_info'
 
   post 'settings', :to => 'settings#update'

apps/dashboard/test/controllers/system_status_controller_test.rb

@@ -0,0 +1,7 @@
+require "test_helper"
+
+class SystemStatusControllerTest < ActionDispatch::IntegrationTest
+  # test "the truth" do
+  #   assert true
+  # end
+end