+ HTML
+
+ # Add actions column for failed jobs
+ if status == 'failed'
+ failed_execution = SolidQueue::FailedExecution.find_by(job_id: job.id)
+
+ row_html += if failed_execution
+ <<-HTML
+
+
+
+
+
+
+ HTML
+ else
+ '
'
+ end
+ else
+ row_html += '
'
+ end
+
+ row_html += '
'
+ row_html
+ end
+
+ def job_status(job)
+ SolidQueueMonitor::StatusCalculator.new(job).calculate
+ end
+ end
+end
diff --git a/app/presenters/solid_queue_monitor/queues_presenter.rb b/app/presenters/solid_queue_monitor/queues_presenter.rb
index 153ef05..13ff926 100644
--- a/app/presenters/solid_queue_monitor/queues_presenter.rb
+++ b/app/presenters/solid_queue_monitor/queues_presenter.rb
@@ -42,7 +42,7 @@ def generate_row(queue)
<<-HTML
+ HTML
+ end
+
+ def generate_row(process)
+ status = worker_status(process)
+ row_class = case status
+ when :dead then 'worker-dead'
+ when :stale then 'worker-stale'
+ else ''
+ end
+
+ <<-HTML
+
+
#{kind_badge(process.kind)}
+
#{hostname(process)}
+
#{process.pid}
+
#{queues_display(process)}
+
#{format_heartbeat(process.last_heartbeat_at)}
+
#{status_badge(status)}
+
#{jobs_processing(process)}
+
#{action_button(process, status)}
+
+ HTML
+ end
+
+ def action_button(process, status)
+ return '-' unless status == :dead
+
+ <<-HTML
+
+ HTML
+ end
+
+ def kind_badge(kind)
+ badge_class = case kind
+ when 'Worker' then 'kind-worker'
+ when 'Dispatcher' then 'kind-dispatcher'
+ when 'Scheduler' then 'kind-scheduler'
+ else 'kind-other'
+ end
+ "#{kind}"
+ end
+
+ def hostname(process)
+ process.hostname || parse_metadata(process)['hostname'] || '-'
+ end
+
+ def queues_display(process)
+ metadata = parse_metadata(process)
+ queues = metadata['queues']
+
+ return '-' if queues.nil?
+
+ # Handle string queues (e.g., "*" for all queues)
+ if queues.is_a?(String)
+ return "#{queues == '*' ? 'All Queues' : queues}"
+ end
+
+ return '-' if queues.empty?
+
+ if queues.length <= 3
+ queues.map { |q| "#{q}" }.join(' ')
+ else
+ visible = queues.first(2).map { |q| "#{q}" }.join(' ')
+ "#{visible} +#{queues.length - 2} more"
+ end
+ end
+
+ def format_heartbeat(heartbeat_at)
+ return '-' unless heartbeat_at
+
+ time_ago = time_ago_in_words(heartbeat_at)
+ "#{time_ago} ago"
+ end
+
+ def worker_status(process)
+ return :dead unless process.last_heartbeat_at
+
+ time_since_heartbeat = Time.current - process.last_heartbeat_at
+
+ if time_since_heartbeat > HEARTBEAT_DEAD_THRESHOLD
+ :dead
+ elsif time_since_heartbeat > HEARTBEAT_STALE_THRESHOLD
+ :stale
+ else
+ :healthy
+ end
+ end
+
+ def status_badge(status)
+ badges = {
+ healthy: 'Healthy',
+ stale: 'Stale',
+ dead: 'Dead'
+ }
+ badges[status]
+ end
+
+ def jobs_processing(process)
+ count = @claimed_counts[process.id] || 0
+
+ if count.zero?
+ 'Idle'
+ else
+ jobs = @claimed_jobs[process.id] || []
+ job_names = jobs.map(&:class_name).uniq.first(3)
+
+ tooltip = jobs.first(10).map { |j| "#{j.class_name} (ID: #{j.id})" }.join('
')
+
+ <<-HTML
+
+ #{count} job#{count > 1 ? 's' : ''}
+ (#{job_names.join(', ')}#{jobs.length > 3 ? '...' : ''})
+
+ HTML
+ end
+ end
+
+ def preload_claimed_data
+ return if @processes.empty?
+
+ process_ids = @processes.map(&:id)
+
+ # Preload claimed execution counts
+ @claimed_counts = SolidQueue::ClaimedExecution
+ .where(process_id: process_ids)
+ .group(:process_id)
+ .count
+
+ # Preload claimed jobs for processes that have any
+ claimed_executions = SolidQueue::ClaimedExecution
+ .includes(:job)
+ .where(process_id: process_ids)
+
+ @claimed_jobs = claimed_executions.each_with_object({}) do |execution, hash|
+ hash[execution.process_id] ||= []
+ hash[execution.process_id] << execution.job
+ end
+ end
+
+ def parse_metadata(process)
+ @parsed_metadata ||= {}
+ @parsed_metadata[process.id] ||= parse_process_metadata(process)
+ end
+
+ def parse_process_metadata(process)
+ return {} unless process.metadata
+
+ if process.metadata.is_a?(String)
+ JSON.parse(process.metadata)
+ else
+ process.metadata
+ end
+ rescue JSON::ParserError
+ {}
+ end
+ end
+end
diff --git a/app/services/solid_queue_monitor/html_generator.rb b/app/services/solid_queue_monitor/html_generator.rb
index 617c63f..51ab10f 100644
--- a/app/services/solid_queue_monitor/html_generator.rb
+++ b/app/services/solid_queue_monitor/html_generator.rb
@@ -95,7 +95,8 @@ def generate_header
{ path: scheduled_jobs_path, label: 'Scheduled Jobs', match: 'Scheduled Jobs' },
{ path: recurring_jobs_path, label: 'Recurring Jobs', match: 'Recurring Jobs' },
{ path: failed_jobs_path, label: 'Failed Jobs', match: 'Failed Jobs' },
- { path: queues_path, label: 'Queues', match: 'Queues' }
+ { path: queues_path, label: 'Queues', match: 'Queues' },
+ { path: workers_path, label: 'Workers', match: 'Workers' }
]
nav_links = nav_items.map do |item|
diff --git a/app/services/solid_queue_monitor/stylesheet_generator.rb b/app/services/solid_queue_monitor/stylesheet_generator.rb
index cee447f..06502cb 100644
--- a/app/services/solid_queue_monitor/stylesheet_generator.rb
+++ b/app/services/solid_queue_monitor/stylesheet_generator.rb
@@ -101,6 +101,29 @@ def generate
background: var(--background-color);
}
+ .solid_queue_monitor .section-header-row {
+ display: flex;
+ justify-content: space-between;
+ align-items: center;
+ margin-bottom: 1.5rem;
+ padding: 1rem;
+ background: var(--card-background);
+ border-radius: 0.5rem;
+ box-shadow: var(--card-shadow);
+ }
+
+ .solid_queue_monitor .section-header-left {
+ display: flex;
+ align-items: center;
+ gap: 1rem;
+ }
+
+ .solid_queue_monitor .section-header-right {
+ display: flex;
+ align-items: center;
+ gap: 0.5rem;
+ }
+
.solid_queue_monitor .stats-container {
margin-bottom: 2rem;
}
@@ -1154,6 +1177,232 @@ def generate
align-items: center;
gap: 0.75rem;
}
+
+ /* Workers Page Styles */
+ .solid_queue_monitor .workers-summary {
+ display: grid;
+ grid-template-columns: repeat(4, 1fr);
+ gap: 1rem;
+ margin-bottom: 1.5rem;
+ }
+
+ .solid_queue_monitor .summary-card {
+ background: var(--card-background);
+ border: 1px solid var(--border-color);
+ border-radius: 0.5rem;
+ padding: 1rem 1.25rem;
+ display: flex;
+ flex-direction: column;
+ align-items: center;
+ gap: 0.25rem;
+ border-left: 4px solid var(--border-color);
+ position: relative;
+ }
+
+ .solid_queue_monitor .summary-card .summary-label {
+ font-size: 0.75rem;
+ text-transform: uppercase;
+ letter-spacing: 0.05em;
+ color: var(--text-muted);
+ }
+
+ .solid_queue_monitor .summary-card .summary-value {
+ font-size: 1.75rem;
+ font-weight: 600;
+ color: var(--text-color);
+ }
+
+ .solid_queue_monitor .summary-healthy {
+ border-left-color: #10b981;
+ }
+
+ .solid_queue_monitor .summary-healthy .summary-value {
+ color: #10b981;
+ }
+
+ .solid_queue_monitor .summary-stale {
+ border-left-color: #f59e0b;
+ }
+
+ .solid_queue_monitor .summary-stale .summary-value {
+ color: #f59e0b;
+ }
+
+ .solid_queue_monitor .summary-dead {
+ border-left-color: #ef4444;
+ }
+
+ .solid_queue_monitor .summary-dead .summary-value {
+ color: #ef4444;
+ }
+
+ .solid_queue_monitor .summary-action {
+ font-size: 0.75rem;
+ color: #f59e0b;
+ text-decoration: none;
+ border: 1px solid #f59e0b;
+ padding: 0.25rem 0.5rem;
+ border-radius: 0.25rem;
+ margin-top: 0.5rem;
+ transition: all 0.2s;
+ }
+
+ .solid_queue_monitor .summary-action:hover {
+ background: #f59e0b;
+ color: #000;
+ }
+
+ .solid_queue_monitor .kind-badge {
+ display: inline-block;
+ padding: 0.25rem 0.5rem;
+ border-radius: 0.25rem;
+ font-size: 0.75rem;
+ font-weight: 500;
+ }
+
+ .solid_queue_monitor .kind-worker {
+ background: rgba(59, 130, 246, 0.15);
+ color: #3b82f6;
+ }
+
+ .solid_queue_monitor .kind-dispatcher {
+ background: rgba(249, 115, 22, 0.15);
+ color: #f97316;
+ }
+
+ .solid_queue_monitor .kind-scheduler {
+ background: rgba(168, 85, 247, 0.15);
+ color: #a855f7;
+ }
+
+ .solid_queue_monitor .kind-other {
+ background: rgba(107, 114, 128, 0.15);
+ color: #6b7280;
+ }
+
+ .solid_queue_monitor .status-healthy {
+ background: rgba(16, 185, 129, 0.15);
+ color: #10b981;
+ }
+
+ .solid_queue_monitor .status-stale {
+ background: rgba(245, 158, 11, 0.15);
+ color: #f59e0b;
+ }
+
+ .solid_queue_monitor .status-dead {
+ background: rgba(239, 68, 68, 0.15);
+ color: #ef4444;
+ }
+
+ .solid_queue_monitor .queue-tag {
+ display: inline-block;
+ background: var(--card-background);
+ border: 1px solid var(--border-color);
+ padding: 0.125rem 0.375rem;
+ border-radius: 0.25rem;
+ font-size: 0.75rem;
+ margin-right: 0.25rem;
+ }
+
+ .solid_queue_monitor .queue-more {
+ color: var(--text-muted);
+ font-size: 0.75rem;
+ }
+
+ .solid_queue_monitor .jobs-idle {
+ color: var(--text-muted);
+ font-style: italic;
+ }
+
+ .solid_queue_monitor .jobs-processing {
+ color: #10b981;
+ }
+
+ .solid_queue_monitor .jobs-processing .job-names {
+ color: var(--text-muted);
+ font-size: 0.8em;
+ }
+
+ .solid_queue_monitor .worker-dead {
+ background: rgba(239, 68, 68, 0.05);
+ }
+
+ .solid_queue_monitor .worker-stale {
+ background: rgba(245, 158, 11, 0.05);
+ }
+
+ .solid_queue_monitor .action-placeholder {
+ color: var(--text-muted);
+ }
+
+ /* Table Link Styles */
+ .solid_queue_monitor .job-class-link {
+ color: var(--text-color);
+ text-decoration: none;
+ transition: color 0.2s;
+ }
+
+ .solid_queue_monitor .job-class-link:hover {
+ color: #3b82f6;
+ text-decoration: underline;
+ }
+
+ .solid_queue_monitor .queue-link {
+ color: var(--text-color);
+ text-decoration: none;
+ transition: color 0.2s;
+ }
+
+ .solid_queue_monitor .queue-link:hover {
+ color: #3b82f6;
+ text-decoration: underline;
+ }
+
+ .solid_queue_monitor .back-link {
+ color: var(--text-muted);
+ text-decoration: none;
+ display: inline-flex;
+ align-items: center;
+ gap: 0.25rem;
+ font-size: 0.875rem;
+ transition: color 0.2s;
+ }
+
+ .solid_queue_monitor .back-link:hover {
+ color: var(--text-color);
+ }
+
+ .solid_queue_monitor .job-back-link {
+ margin-bottom: 1rem;
+ }
+
+ .solid_queue_monitor .empty-state {
+ text-align: center;
+ padding: 3rem 1rem;
+ color: var(--text-muted);
+ }
+
+ .solid_queue_monitor .empty-state p {
+ margin: 0.5rem 0;
+ }
+
+ .solid_queue_monitor .empty-state-hint {
+ font-size: 0.875rem;
+ opacity: 0.7;
+ }
+
+ @media (max-width: 768px) {
+ .solid_queue_monitor .workers-summary {
+ grid-template-columns: repeat(2, 1fr);
+ }
+ }
+
+ @media (max-width: 480px) {
+ .solid_queue_monitor .workers-summary {
+ grid-template-columns: 1fr;
+ }
+ }
CSS
end
end
diff --git a/config/routes.rb b/config/routes.rb
index 1ce4bcd..31defc9 100644
--- a/config/routes.rb
+++ b/config/routes.rb
@@ -14,8 +14,12 @@
resources :failed_jobs, only: [:index]
resources :in_progress_jobs, only: [:index]
resources :queues, only: [:index]
+ get 'queues/:queue_name', to: 'queues#show', as: :queue_details, constraints: { queue_name: /[^\/]+/ }
+ resources :workers, only: [:index]
+ resources :jobs, only: [:show]
post 'execute_jobs', to: 'scheduled_jobs#create', as: :execute_jobs
+ post 'execute_scheduled_job/:id', to: 'scheduled_jobs#execute', as: :execute_scheduled_job
post 'reject_jobs', to: 'scheduled_jobs#reject_all', as: :reject_jobs
post 'retry_failed_job/:id', to: 'failed_jobs#retry', as: :retry_failed_job
@@ -25,4 +29,7 @@
post 'pause_queue', to: 'queues#pause', as: :pause_queue
post 'resume_queue', to: 'queues#resume', as: :resume_queue
+
+ post 'remove_worker/:id', to: 'workers#remove', as: :remove_worker
+ post 'prune_workers', to: 'workers#prune', as: :prune_workers
end
diff --git a/lib/solid_queue_monitor/version.rb b/lib/solid_queue_monitor/version.rb
index 75f0214..059a828 100644
--- a/lib/solid_queue_monitor/version.rb
+++ b/lib/solid_queue_monitor/version.rb
@@ -1,5 +1,5 @@
# frozen_string_literal: true
module SolidQueueMonitor
- VERSION = '0.6.0'
+ VERSION = '1.0.0'
end
diff --git a/screenshots/failed-jobs.png b/screenshots/failed-jobs.png
new file mode 100644
index 0000000..50eb147
Binary files /dev/null and b/screenshots/failed-jobs.png differ
diff --git a/screenshots/queues.png b/screenshots/queues.png
new file mode 100644
index 0000000..149abbc
Binary files /dev/null and b/screenshots/queues.png differ
diff --git a/screenshots/workers.png b/screenshots/workers.png
new file mode 100644
index 0000000..663646f
Binary files /dev/null and b/screenshots/workers.png differ
diff --git a/spec/presenters/solid_queue_monitor/job_details_presenter_spec.rb b/spec/presenters/solid_queue_monitor/job_details_presenter_spec.rb
new file mode 100644
index 0000000..a412197
--- /dev/null
+++ b/spec/presenters/solid_queue_monitor/job_details_presenter_spec.rb
@@ -0,0 +1,159 @@
+# frozen_string_literal: true
+
+require 'spec_helper'
+
+RSpec.describe SolidQueueMonitor::JobDetailsPresenter do
+ let(:job) { create(:solid_queue_job, class_name: 'TestJob', queue_name: 'default', priority: 5) }
+
+ describe '#render' do
+ subject(:rendered_html) { presenter.render }
+
+ let(:presenter) { described_class.new(job, back_path: '/failed_jobs') }
+
+ it 'renders the job details page container' do
+ expect(rendered_html).to include('job-details-page')
+ end
+
+ it 'renders the job class name' do
+ expect(rendered_html).to include('TestJob')
+ end
+
+ it 'renders the queue name' do
+ expect(rendered_html).to include('default')
+ end
+
+ it 'renders the priority' do
+ expect(rendered_html).to include('Priority')
+ end
+
+ it 'renders the back link' do
+ expect(rendered_html).to include('href="/failed_jobs"')
+ expect(rendered_html).to include('Back')
+ end
+
+ it 'renders the job arguments section' do
+ expect(rendered_html).to include('Arguments')
+ end
+
+ it 'renders the job details section' do
+ expect(rendered_html).to include('Job Details')
+ end
+
+ it 'renders the raw data section' do
+ expect(rendered_html).to include('Raw Data')
+ end
+
+ context 'with a failed execution' do
+ let(:failed_execution) do
+ create(:solid_queue_failed_execution, job: job, error: { 'message' => 'Test error', 'backtrace' => %w[line1 line2] })
+ end
+ let(:presenter) { described_class.new(job, failed_execution: failed_execution, back_path: '/') }
+
+ it 'renders the error section' do
+ expect(rendered_html).to include('Error')
+ end
+
+ it 'renders retry and discard buttons' do
+ expect(rendered_html).to include('Retry')
+ expect(rendered_html).to include('Discard')
+ end
+
+ it 'renders the failed status badge' do
+ expect(rendered_html).to include('Failed')
+ expect(rendered_html).to include('status-failed')
+ end
+ end
+
+ context 'with a claimed execution (in progress)' do
+ let(:process) { create(:solid_queue_process, kind: 'Worker', hostname: 'worker-1', pid: 12_345) }
+ let(:claimed_execution) do
+ execution = create(:solid_queue_claimed_execution, job: job, process_id: process.id)
+ execution.instance_variable_set(:@process, process)
+ execution
+ end
+ let(:presenter) { described_class.new(job, claimed_execution: claimed_execution, back_path: '/') }
+
+ it 'renders the worker section' do
+ expect(rendered_html).to include('Worker')
+ end
+
+ it 'renders the hostname' do
+ expect(rendered_html).to include('worker-1')
+ end
+
+ it 'renders the in progress status' do
+ expect(rendered_html).to include('In Progress')
+ expect(rendered_html).to include('status-in-progress')
+ end
+ end
+
+ context 'with a scheduled execution' do
+ let(:scheduled_at) { 1.hour.from_now }
+ let(:scheduled_execution) { create(:solid_queue_scheduled_execution, job: job, scheduled_at: scheduled_at) }
+ let(:presenter) { described_class.new(job, scheduled_execution: scheduled_execution, back_path: '/') }
+
+ it 'renders the scheduled status' do
+ expect(rendered_html).to include('Scheduled')
+ expect(rendered_html).to include('status-scheduled')
+ end
+ end
+
+ context 'with a completed job' do
+ let(:completed_job) { create(:solid_queue_job, :completed, class_name: 'CompletedJob') }
+ let(:presenter) { described_class.new(completed_job, back_path: '/') }
+
+ it 'renders the completed status' do
+ expect(rendered_html).to include('Completed')
+ expect(rendered_html).to include('status-completed')
+ end
+ end
+
+ context 'with recent executions' do
+ let(:recent_jobs) do
+ create_list(:solid_queue_job, 3, class_name: 'TestJob', finished_at: Time.current)
+ end
+ let(:presenter) { described_class.new(job, recent_executions: recent_jobs, back_path: '/') }
+
+ it 'renders the recent executions section' do
+ expect(rendered_html).to include('Recent Executions')
+ end
+
+ it 'renders the recent executions table' do
+ expect(rendered_html).to include('recent-executions-table')
+ end
+ end
+ end
+
+ describe 'timing calculations' do
+ context 'with start and end times' do
+ let(:started_at) { 5.minutes.ago }
+ let(:finished_at) { Time.current }
+ let(:completed_job) { create(:solid_queue_job, created_at: 10.minutes.ago, finished_at: finished_at) }
+ let(:claimed_execution) do
+ execution = build(:solid_queue_claimed_execution, job: completed_job, created_at: started_at)
+ execution.instance_variable_set(:@process, nil)
+ execution
+ end
+ let(:presenter) { described_class.new(completed_job, claimed_execution: claimed_execution, back_path: '/') }
+
+ it 'renders timing cards' do
+ rendered_html = presenter.render
+ expect(rendered_html).to include('timing-cards')
+ expect(rendered_html).to include('Queue Wait')
+ expect(rendered_html).to include('Execution')
+ expect(rendered_html).to include('Total Time')
+ end
+ end
+ end
+
+ describe 'timeline rendering' do
+ let(:completed_job) { create(:solid_queue_job, :completed, created_at: 10.minutes.ago) }
+ let(:presenter) { described_class.new(completed_job, back_path: '/') }
+
+ it 'renders the timeline section' do
+ rendered_html = presenter.render
+ expect(rendered_html).to include('Timeline')
+ expect(rendered_html).to include('timeline-track')
+ end
+ end
+end
diff --git a/spec/requests/solid_queue_monitor/jobs_spec.rb b/spec/requests/solid_queue_monitor/jobs_spec.rb
new file mode 100644
index 0000000..d4888ce
--- /dev/null
+++ b/spec/requests/solid_queue_monitor/jobs_spec.rb
@@ -0,0 +1,117 @@
+# frozen_string_literal: true
+
+require 'spec_helper'
+
+RSpec.describe 'Jobs' do
+ describe 'GET /jobs/:id' do
+ let(:job) { create(:solid_queue_job, class_name: 'MyTestJob', queue_name: 'default', priority: 5) }
+
+ it 'returns a successful response' do
+ get "/jobs/#{job.id}"
+
+ expect(response).to have_http_status(:ok)
+ end
+
+ it 'displays the job details page' do
+ get "/jobs/#{job.id}"
+
+ expect(response.body).to include('MyTestJob')
+ expect(response.body).to include('Job Details')
+ end
+
+ it 'displays the job queue and priority' do
+ get "/jobs/#{job.id}"
+
+ expect(response.body).to include('default')
+ expect(response.body).to include('Priority')
+ end
+
+ context 'when job is not found' do
+ it 'redirects to root with error message' do
+ get '/jobs/999999'
+
+ expect(response).to redirect_to('/')
+ end
+ end
+
+ context 'with a failed job' do
+ let(:failed_job) { create(:solid_queue_job, class_name: 'FailedTestJob') }
+ let!(:failed_execution) do
+ create(:solid_queue_failed_execution, job: failed_job, error: { 'message' => 'Test error', 'backtrace' => ['line 1', 'line 2'] })
+ end
+
+ it 'displays error information' do
+ get "/jobs/#{failed_job.id}"
+
+ expect(response.body).to include('Error')
+ expect(response.body).to include('FailedTestJob')
+ end
+
+ it 'displays retry and discard buttons' do
+ get "/jobs/#{failed_job.id}"
+
+ expect(response.body).to include('Retry')
+ expect(response.body).to include('Discard')
+ end
+ end
+
+ context 'with an in-progress job' do
+ let(:in_progress_job) { create(:solid_queue_job, class_name: 'InProgressJob') }
+ let(:process) { create(:solid_queue_process, kind: 'Worker', hostname: 'worker-1') }
+ let!(:claimed_execution) { create(:solid_queue_claimed_execution, job: in_progress_job, process_id: process.id) }
+
+ it 'displays worker information' do
+ get "/jobs/#{in_progress_job.id}"
+
+ expect(response.body).to include('Worker')
+ expect(response.body).to include('In Progress')
+ end
+ end
+
+ context 'with a scheduled job' do
+ let(:scheduled_job) { create(:solid_queue_job, :scheduled, class_name: 'ScheduledJob') }
+ let!(:scheduled_execution) { create(:solid_queue_scheduled_execution, job: scheduled_job) }
+
+ it 'displays scheduled status' do
+ get "/jobs/#{scheduled_job.id}"
+
+ expect(response.body).to include('ScheduledJob')
+ expect(response.body).to include('Scheduled')
+ end
+ end
+
+ context 'with a completed job' do
+ let(:completed_job) { create(:solid_queue_job, :completed, class_name: 'CompletedJob') }
+
+ it 'displays completed status' do
+ get "/jobs/#{completed_job.id}"
+
+ expect(response.body).to include('CompletedJob')
+ expect(response.body).to include('Completed')
+ end
+ end
+ end
+
+ context 'with authentication enabled' do
+ before do
+ allow(SolidQueueMonitor).to receive_messages(authentication_enabled: true, username: 'admin', password: 'password123')
+ end
+
+ let(:job) { create(:solid_queue_job) }
+ let(:valid_credentials) do
+ ActionController::HttpAuthentication::Basic.encode_credentials('admin', 'password123')
+ end
+
+ it 'requires authentication for show' do
+ get "/jobs/#{job.id}"
+
+ expect(response).to have_http_status(:unauthorized)
+ end
+
+ it 'allows access with valid credentials' do
+ get "/jobs/#{job.id}", headers: { 'HTTP_AUTHORIZATION' => valid_credentials }
+
+ expect(response).to have_http_status(:ok)
+ end
+ end
+end
diff --git a/spec/requests/solid_queue_monitor/workers_spec.rb b/spec/requests/solid_queue_monitor/workers_spec.rb
new file mode 100644
index 0000000..d2aea1d
--- /dev/null
+++ b/spec/requests/solid_queue_monitor/workers_spec.rb
@@ -0,0 +1,244 @@
+# frozen_string_literal: true
+
+require 'spec_helper'
+
+RSpec.describe 'Workers' do
+ describe 'GET /workers' do
+ context 'with no processes' do
+ it 'returns a successful response' do
+ get '/workers'
+
+ expect(response).to have_http_status(:ok)
+ end
+
+ it 'displays empty state message' do
+ get '/workers'
+
+ expect(response.body).to include('No worker processes found')
+ end
+ end
+
+ context 'with processes' do
+ before do
+ create(:solid_queue_process, kind: 'Worker', hostname: 'worker-1', pid: 1001, last_heartbeat_at: Time.current)
+ create(:solid_queue_process, kind: 'Dispatcher', hostname: 'dispatcher-1', pid: 1002, last_heartbeat_at: Time.current)
+ create(:solid_queue_process, kind: 'Scheduler', hostname: 'scheduler-1', pid: 1003, last_heartbeat_at: 15.minutes.ago)
+ end
+
+ it 'returns a successful response' do
+ get '/workers'
+
+ expect(response).to have_http_status(:ok)
+ end
+
+ it 'displays process information' do
+ get '/workers'
+
+ expect(response.body).to include('worker-1')
+ expect(response.body).to include('dispatcher-1')
+ expect(response.body).to include('scheduler-1')
+ end
+
+ it 'displays kind badges' do
+ get '/workers'
+
+ expect(response.body).to include('Worker')
+ expect(response.body).to include('Dispatcher')
+ expect(response.body).to include('Scheduler')
+ end
+
+ it 'displays status badges' do
+ get '/workers'
+
+ expect(response.body).to include('Healthy')
+ expect(response.body).to include('Dead')
+ end
+
+ it 'displays summary counts' do
+ get '/workers'
+
+ expect(response.body).to include('Total Processes')
+ end
+
+ it 'displays Actions column' do
+ get '/workers'
+
+ expect(response.body).to include('
Actions
')
+ end
+
+ it 'shows Remove button for dead processes' do
+ get '/workers'
+
+ expect(response.body).to include('Remove')
+ end
+
+ it 'shows Prune all link when dead processes exist' do
+ get '/workers'
+
+ expect(response.body).to include('Prune all')
+ end
+ end
+
+ context 'with only healthy processes' do
+ before do
+ create(:solid_queue_process, kind: 'Worker', hostname: 'worker-1', last_heartbeat_at: Time.current)
+ end
+
+ it 'does not show Prune all link' do
+ get '/workers'
+
+ expect(response.body).not_to include('Prune all')
+ end
+ end
+
+ context 'with filters' do
+ before do
+ create(:solid_queue_process, kind: 'Worker', hostname: 'worker-1', last_heartbeat_at: Time.current)
+ create(:solid_queue_process, kind: 'Dispatcher', hostname: 'dispatcher-1', last_heartbeat_at: Time.current)
+ end
+
+ it 'filters by kind' do
+ get '/workers', params: { kind: 'Worker' }
+
+ expect(response).to have_http_status(:ok)
+ expect(response.body).to include('worker-1')
+ expect(response.body).not_to include('dispatcher-1')
+ end
+
+ it 'filters by hostname' do
+ get '/workers', params: { hostname: 'dispatcher' }
+
+ expect(response).to have_http_status(:ok)
+ expect(response.body).to include('dispatcher-1')
+ expect(response.body).not_to include('worker-1')
+ end
+
+ it 'filters by status' do
+ create(:solid_queue_process, kind: 'Worker', hostname: 'dead-worker', last_heartbeat_at: 15.minutes.ago)
+
+ get '/workers', params: { status: 'dead' }
+
+ expect(response).to have_http_status(:ok)
+ expect(response.body).to include('dead-worker')
+ end
+ end
+
+ context 'with stale process' do
+ before do
+ create(:solid_queue_process, kind: 'Worker', hostname: 'stale-worker', last_heartbeat_at: 7.minutes.ago)
+ end
+
+ it 'shows stale status' do
+ get '/workers'
+
+ expect(response.body).to include('Stale')
+ end
+ end
+ end
+
+ describe 'POST /remove_worker/:id' do
+ context 'with a dead process' do
+ let!(:dead_process) do
+ create(:solid_queue_process, kind: 'Worker', hostname: 'dead-worker', last_heartbeat_at: 15.minutes.ago)
+ end
+
+ it 'removes the process' do
+ expect do
+ post "/remove_worker/#{dead_process.id}"
+ end.to change(SolidQueue::Process, :count).by(-1)
+ end
+
+ it 'redirects to workers page' do
+ post "/remove_worker/#{dead_process.id}"
+
+ expect(response).to redirect_to('/workers')
+ end
+ end
+
+ context 'with non-existent process' do
+ it 'handles gracefully' do
+ post '/remove_worker/99999'
+
+ expect(response).to redirect_to('/workers')
+ end
+ end
+ end
+
+ describe 'POST /prune_workers' do
+ context 'with dead processes' do
+ before do
+ create(:solid_queue_process, kind: 'Worker', hostname: 'healthy-worker', last_heartbeat_at: Time.current)
+ create(:solid_queue_process, kind: 'Worker', hostname: 'dead-worker-1', last_heartbeat_at: 15.minutes.ago)
+ create(:solid_queue_process, kind: 'Worker', hostname: 'dead-worker-2', last_heartbeat_at: 20.minutes.ago)
+ end
+
+ it 'removes dead processes' do
+ expect do
+ post '/prune_workers'
+ end.to change(SolidQueue::Process, :count).by(-2)
+ end
+
+ it 'keeps healthy processes' do
+ post '/prune_workers'
+
+ expect(SolidQueue::Process.where(hostname: 'healthy-worker')).to exist
+ end
+
+ it 'redirects to workers page' do
+ post '/prune_workers'
+
+ expect(response).to redirect_to('/workers')
+ end
+ end
+
+ context 'with no dead processes' do
+ before do
+ create(:solid_queue_process, kind: 'Worker', hostname: 'healthy-worker', last_heartbeat_at: Time.current)
+ end
+
+ it 'does not remove any processes' do
+ expect do
+ post '/prune_workers'
+ end.not_to(change(SolidQueue::Process, :count))
+ end
+
+ it 'redirects to workers page' do
+ post '/prune_workers'
+
+ expect(response).to redirect_to('/workers')
+ end
+ end
+ end
+
+ context 'with authentication enabled' do
+ before do
+ allow(SolidQueueMonitor).to receive_messages(authentication_enabled: true, username: 'admin', password: 'password123')
+ end
+
+ it 'requires authentication for workers index' do
+ get '/workers'
+
+ expect(response).to have_http_status(:unauthorized)
+ end
+
+ it 'allows access with valid credentials' do
+ get '/workers', headers: {
+ 'HTTP_AUTHORIZATION' => ActionController::HttpAuthentication::Basic.encode_credentials('admin', 'password123')
+ }
+
+ expect(response).to have_http_status(:ok)
+ end
+
+ it 'requires authentication for remove action' do
+ post '/remove_worker/1'
+
+ expect(response).to have_http_status(:unauthorized)
+ end
+
+ it 'requires authentication for prune action' do
+ post '/prune_workers'
+
+ expect(response).to have_http_status(:unauthorized)
+ end
+ end
+end
diff --git a/spec/services/solid_queue_monitor/chart_data_service_spec.rb b/spec/services/solid_queue_monitor/chart_data_service_spec.rb
index 18e95a6..03668ca 100644
--- a/spec/services/solid_queue_monitor/chart_data_service_spec.rb
+++ b/spec/services/solid_queue_monitor/chart_data_service_spec.rb
@@ -95,7 +95,7 @@
end
end
- context 'with job data' do # rubocop:disable RSpec/MultipleMemoizedHelpers
+ context 'with job data' do
let(:now) { Time.current }
let(:created_timestamps) { [now - 30.minutes, now - 45.minutes] }
let(:completed_timestamps) { [now - 20.minutes] }