feat/Dashboard Chart with auto update

Author: Felipe

app/controllers/mission_control/jobs/dashboard_controller.rb

@@ -0,0 +1,4 @@
+class MissionControl::Jobs::DashboardController < MissionControl::Jobs::ApplicationController
+  def index
+  end
+end

app/controllers/mission_control/jobs/internal_api/dashboard_controller.rb

@@ -0,0 +1,35 @@
+class MissionControl::Jobs::InternalApi::DashboardController < MissionControl::Jobs.base_controller_class.constantize
+  include ActionView::Helpers::NumberHelper
+
+  def index
+    render json: {
+      uptime: {
+        label: Time.now.strftime("%H:%M:%S"),
+        pending: queue_job.pendings.where.not(id: failed_execution.select(:job_id)).size,
+        failed: failed_execution.where("created_at >= ?", time_to_consult.seconds.ago).size,
+        finished: queue_job.finisheds.where("finished_at >= ?", time_to_consult.seconds.ago).size,
+      },
+      total: {
+        failed: number_with_delimiter(ActiveJob.jobs.failed.count),
+        pending: number_with_delimiter(ActiveJob.jobs.pending.count),
+        scheduled: number_with_delimiter(ActiveJob.jobs.scheduled.count),
+        in_progress: number_with_delimiter(ActiveJob.jobs.in_progress.count),
+        finished: number_with_delimiter(ActiveJob.jobs.finished.count)
+      }
+    },
+    status: :ok
+  end
+
+  private
+    def time_to_consult
+      params[:uptime].to_i || 5
+    end
+
+    def failed_execution
+      MissionControl::SolidQueueFailedExecution
+    end
+
+    def queue_job
+      MissionControl::SolidQueueJob
+    end
+end

app/controllers/mission_control/jobs/internal_api/navigation_controller.rb

@@ -0,0 +1,7 @@
+class MissionControl::Jobs::InternalApi::NavigationController < MissionControl::Jobs::ApplicationController
+  def index
+    render partial: "layouts/mission_control/jobs/navigation_update", locals: { 
+      section: params[:section].to_sym
+    }
+  end
+end

app/helpers/mission_control/jobs/navigation_helper.rb

@@ -2,7 +2,10 @@ module MissionControl::Jobs::NavigationHelper
   attr_reader :page_title, :current_section
 
   def navigation_sections
-    { queues: [ "Queues", application_queues_path(@application) ] }.tap do |sections|
+    { dashboard: [ "Dashboard", application_dashboard_index_path(@application) ] }.tap do |sections|
+      sections[:queues] = [ "Queues", application_queues_path(@application) ]
+      sections[:queues] = [ "Queues", application_queues_path(@application) ]
+
       supported_job_statuses.without(:pending).each do |status|
          sections[navigation_section_for_status(status)] = [ "#{status.to_s.titleize} jobs (#{jobs_count_with_status(status)})", application_jobs_path(@application, status) ]
       end

app/models/mission_control/solid_queue_failed_execution.rb

@@ -0,0 +1,3 @@
+class MissionControl::SolidQueueFailedExecution < MissionControl::SolidQueueRecord
+  self.table_name = 'solid_queue_failed_executions'
+end

app/models/mission_control/solid_queue_job.rb

@@ -0,0 +1,6 @@
+class MissionControl::SolidQueueJob < MissionControl::SolidQueueRecord
+  self.table_name = 'solid_queue_jobs'
+
+  scope :pendings, -> { where(finished_at: nil) }
+  scope :finisheds, -> { where.not(finished_at: nil) }
+end

app/models/mission_control/solid_queue_record.rb

@@ -0,0 +1,7 @@
+class MissionControl::SolidQueueRecord < ApplicationRecord
+  self.abstract_class = true
+
+  if !ActiveRecord::Base.connection.data_source_exists?('solid_queue_jobs')
+    connects_to database: { writing: :queue, reading: :queue }
+  end
+end

app/views/layouts/mission_control/jobs/_navigation.html.erb

@@ -1,4 +1,4 @@
-<div class="tabs is-boxed">
+<div class="tabs is-boxed" id="navigation-sections">
   <ul>
     <% navigation_sections.each do |key, (label, url)| %>
       <li class="<%= "is-active" if key == current_section %>">
@@ -7,3 +7,31 @@
     <% end %>
   </ul>
 </div>
+
+<script>
+  document.addEventListener("turbo:load", () => {
+    if (!window.Navigation || typeof window.Navigation.currentSection === 'undefined') {
+      window.Navigation = {
+        currentSection: "<%= @current_section %>",
+
+        changeSection(section) {
+          this.currentSection = section;
+        }
+      };
+
+      setInterval(() => {
+        fetch(`/jobs/applications/solidqueueusage/internal_api/navigation?section=${window.Navigation.currentSection}`)
+          .then(response => response.text())
+          .then(html => {
+            const navigationSections = document.querySelector('#navigation-sections');
+            if (navigationSections) {
+              navigationSections.innerHTML = html;
+            }
+          })
+          .catch(error => console.error("Error fetching navigation update:", error));
+      }, 5000);
+    } else {
+      window.Navigation.currentSection = "<%= @current_section %>";
+    }
+  });
+</script>

app/views/layouts/mission_control/jobs/_navigation_update.html.erb

@@ -0,0 +1,7 @@
+<ul>
+  <% navigation_sections.each do |key, (label, url)| %>
+    <li class="<%= "is-active" if key == section %>">
+      <%= link_to label, url %>
+    </li>
+  <% end %>
+</ul>

app/views/layouts/mission_control/jobs/application.html.erb

@@ -8,6 +8,8 @@
   <meta name="viewport" content="width=device-width,initial-scale=1">
   <meta name="turbo-cache-control" content="no-cache">
   <link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/[email protected]/css/bulma.min.css">
+  <script src="https://cdn.jsdelivr.net/npm/chart.js"></script>
+
   <%= stylesheet_link_tag "mission_control/jobs/application", "data-turbo-track": "reload" %>
   <%= javascript_importmap_tags "application", importmap: MissionControl::Jobs.importmap  %>
 </head>