Install solid queues framework

Gemfile

@@ -32,3 +32,5 @@ group :development do
   gem 'rubocop'
   gem 'web-console'
 end
+
+gem "solid_queue", "~> 1.0"

Gemfile.lock

@@ -96,6 +96,8 @@ GEM
     diff-lcs (1.5.1)
     drb (2.2.1)
     erubi (1.13.0)
+    et-orbi (1.2.11)
+      tzinfo
     execjs (2.9.1)
     factory_bot (6.4.6)
       activesupport (>= 5.0.0)
@@ -104,6 +106,9 @@ GEM
       railties (>= 5.0.0)
     faker (3.5.1)
       i18n (>= 1.8.11, < 2)
+    fugit (1.11.1)
+      et-orbi (~> 1, >= 1.2.11)
+      raabro (~> 1.4)
     globalid (1.2.1)
       activesupport (>= 6.1)
     i18n (1.14.6)
@@ -182,6 +187,7 @@ GEM
       stringio
     puma (6.4.3)
       nio4r (~> 2.0)
+    raabro (1.4.0)
     racc (1.8.1)
     rack (3.1.8)
     rack-cors (2.0.2)
@@ -272,6 +278,13 @@ GEM
     rubytree (2.1.0)
       json (~> 2.0, > 2.3.1)
     securerandom (0.3.1)
+    solid_queue (1.0.0)
+      activejob (>= 7.1)
+      activerecord (>= 7.1)
+      concurrent-ruby (>= 1.3.1)
+      fugit (~> 1.11.0)
+      railties (>= 7.1)
+      thor (~> 1.3.1)
     sprockets (4.2.1)
       concurrent-ruby (~> 1.0)
       rack (>= 2.2.4, < 4)
@@ -331,6 +344,7 @@ DEPENDENCIES
   rspec-rails (~> 7.0.0)
   rubocop
   rubytree
+  solid_queue (~> 1.0)
   sprockets-rails
   stimulus-rails
   turbo-rails

bin/jobs

@@ -0,0 +1,6 @@
+#!/usr/bin/env ruby
+
+require_relative "../config/environment"
+require "solid_queue/cli"
+
+SolidQueue::Cli.start(ARGV)

config/application.rb

@@ -30,6 +30,9 @@ module WeddingPlanner
     # Common ones are `templates`, `generators`, or `middleware`, for example.
     config.autoload_lib(ignore: %w[assets tasks])
 
+    # Use a real queuing backend for Active Job (and separate queues per environment).
+    config.active_job.queue_adapter = :solid_queue
+
     # Configuration for the application, engines, and railties goes here.
     #
     # These settings can be overridden in specific environments using the files

config/environments/production.rb

@@ -69,8 +69,6 @@ Rails.application.configure do
   # Use a different cache store in production.
   # config.cache_store = :mem_cache_store
 
-  # Use a real queuing backend for Active Job (and separate queues per environment).
-  # config.active_job.queue_adapter = :resque
   # config.active_job.queue_name_prefix = "wedding_planner_production"
 
   config.action_mailer.perform_caching = false

config/queue.yml

@@ -0,0 +1,18 @@
+default: &default
+  dispatchers:
+    - polling_interval: 1
+      batch_size: 500
+  workers:
+    - queues: "*"
+      threads: 3
+      processes: <%= ENV.fetch("JOB_CONCURRENCY", 1) %>
+      polling_interval: 0.1
+
+development:
+  <<: *default
+
+test:
+  <<: *default
+
+production:
+  <<: *default

config/recurring.yml

@@ -0,0 +1,10 @@
+# production:
+#   periodic_cleanup:
+#     class: CleanSoftDeletedRecordsJob
+#     queue: background
+#     args: [ 1000, { batch_size: 500 } ]
+#     schedule: every hour
+#   periodic_command:
+#     command: "SoftDeletedRecord.due.delete_all"
+#     priority: 2
+#     schedule: at 5am every day

db/migrate/20241103075705_solid_queue_install.rb

@@ -0,0 +1,132 @@
+class SolidQueueInstall < ActiveRecord::Migration[7.2]
+  def change
+    create_table 'solid_queue_blocked_executions', force: :cascade do |t|
+      t.bigint 'job_id', null: false
+      t.string 'queue_name', null: false
+      t.integer 'priority', default: 0, null: false
+      t.string 'concurrency_key', null: false
+      t.datetime 'expires_at', null: false
+      t.datetime 'created_at', null: false
+      t.index %w[concurrency_key priority job_id], name: 'index_solid_queue_blocked_executions_for_release'
+      t.index %w[expires_at concurrency_key], name: 'index_solid_queue_blocked_executions_for_maintenance'
+      t.index ['job_id'], name: 'index_solid_queue_blocked_executions_on_job_id', unique: true
+    end
+
+    create_table 'solid_queue_claimed_executions', force: :cascade do |t|
+      t.bigint 'job_id', null: false
+      t.bigint 'process_id'
+      t.datetime 'created_at', null: false
+      t.index ['job_id'], name: 'index_solid_queue_claimed_executions_on_job_id', unique: true
+      t.index %w[process_id job_id], name: 'index_solid_queue_claimed_executions_on_process_id_and_job_id'
+    end
+
+    create_table 'solid_queue_failed_executions', force: :cascade do |t|
+      t.bigint 'job_id', null: false
+      t.text 'error'
+      t.datetime 'created_at', null: false
+      t.index ['job_id'], name: 'index_solid_queue_failed_executions_on_job_id', unique: true
+    end
+
+    create_table 'solid_queue_jobs', force: :cascade do |t|
+      t.string 'queue_name', null: false
+      t.string 'class_name', null: false
+      t.text 'arguments'
+      t.integer 'priority', default: 0, null: false
+      t.string 'active_job_id'
+      t.datetime 'scheduled_at'
+      t.datetime 'finished_at'
+      t.string 'concurrency_key'
+      t.datetime 'created_at', null: false
+      t.datetime 'updated_at', null: false
+      t.index ['active_job_id'], name: 'index_solid_queue_jobs_on_active_job_id'
+      t.index ['class_name'], name: 'index_solid_queue_jobs_on_class_name'
+      t.index ['finished_at'], name: 'index_solid_queue_jobs_on_finished_at'
+      t.index %w[queue_name finished_at], name: 'index_solid_queue_jobs_for_filtering'
+      t.index %w[scheduled_at finished_at], name: 'index_solid_queue_jobs_for_alerting'
+    end
+
+    create_table 'solid_queue_pauses', force: :cascade do |t|
+      t.string 'queue_name', null: false
+      t.datetime 'created_at', null: false
+      t.index ['queue_name'], name: 'index_solid_queue_pauses_on_queue_name', unique: true
+    end
+
+    create_table 'solid_queue_processes', force: :cascade do |t|
+      t.string 'kind', null: false
+      t.datetime 'last_heartbeat_at', null: false
+      t.bigint 'supervisor_id'
+      t.integer 'pid', null: false
+      t.string 'hostname'
+      t.text 'metadata'
+      t.datetime 'created_at', null: false
+      t.string 'name', null: false
+      t.index ['last_heartbeat_at'], name: 'index_solid_queue_processes_on_last_heartbeat_at'
+      t.index %w[name supervisor_id], name: 'index_solid_queue_processes_on_name_and_supervisor_id', unique: true
+      t.index ['supervisor_id'], name: 'index_solid_queue_processes_on_supervisor_id'
+    end
+
+    create_table 'solid_queue_ready_executions', force: :cascade do |t|
+      t.bigint 'job_id', null: false
+      t.string 'queue_name', null: false
+      t.integer 'priority', default: 0, null: false
+      t.datetime 'created_at', null: false
+      t.index ['job_id'], name: 'index_solid_queue_ready_executions_on_job_id', unique: true
+      t.index %w[priority job_id], name: 'index_solid_queue_poll_all'
+      t.index %w[queue_name priority job_id], name: 'index_solid_queue_poll_by_queue'
+    end
+
+    create_table 'solid_queue_recurring_executions', force: :cascade do |t|
+      t.bigint 'job_id', null: false
+      t.string 'task_key', null: false
+      t.datetime 'run_at', null: false
+      t.datetime 'created_at', null: false
+      t.index ['job_id'], name: 'index_solid_queue_recurring_executions_on_job_id', unique: true
+      t.index %w[task_key run_at], name: 'index_solid_queue_recurring_executions_on_task_key_and_run_at',
+                                   unique: true
+    end
+
+    create_table 'solid_queue_recurring_tasks', force: :cascade do |t|
+      t.string 'key', null: false
+      t.string 'schedule', null: false
+      t.string 'command', limit: 2048
+      t.string 'class_name'
+      t.text 'arguments'
+      t.string 'queue_name'
+      t.integer 'priority', default: 0
+      t.boolean 'static', default: true, null: false
+      t.text 'description'
+      t.datetime 'created_at', null: false
+      t.datetime 'updated_at', null: false
+      t.index ['key'], name: 'index_solid_queue_recurring_tasks_on_key', unique: true
+      t.index ['static'], name: 'index_solid_queue_recurring_tasks_on_static'
+    end
+
+    create_table 'solid_queue_scheduled_executions', force: :cascade do |t|
+      t.bigint 'job_id', null: false
+      t.string 'queue_name', null: false
+      t.integer 'priority', default: 0, null: false
+      t.datetime 'scheduled_at', null: false
+      t.datetime 'created_at', null: false
+      t.index ['job_id'], name: 'index_solid_queue_scheduled_executions_on_job_id', unique: true
+      t.index %w[scheduled_at priority job_id], name: 'index_solid_queue_dispatch_all'
+    end
+
+    create_table 'solid_queue_semaphores', force: :cascade do |t|
+      t.string 'key', null: false
+      t.integer 'value', default: 1, null: false
+      t.datetime 'expires_at', null: false
+      t.datetime 'created_at', null: false
+      t.datetime 'updated_at', null: false
+      t.index ['expires_at'], name: 'index_solid_queue_semaphores_on_expires_at'
+      t.index %w[key value], name: 'index_solid_queue_semaphores_on_key_and_value'
+      t.index ['key'], name: 'index_solid_queue_semaphores_on_key', unique: true
+    end
+
+    add_foreign_key 'solid_queue_blocked_executions', 'solid_queue_jobs', column: 'job_id', on_delete: :cascade
+    add_foreign_key 'solid_queue_claimed_executions', 'solid_queue_jobs', column: 'job_id', on_delete: :cascade
+    add_foreign_key 'solid_queue_failed_executions', 'solid_queue_jobs', column: 'job_id', on_delete: :cascade
+    add_foreign_key 'solid_queue_ready_executions', 'solid_queue_jobs', column: 'job_id', on_delete: :cascade
+    add_foreign_key 'solid_queue_recurring_executions', 'solid_queue_jobs', column: 'job_id', on_delete: :cascade
+    add_foreign_key 'solid_queue_scheduled_executions', 'solid_queue_jobs', column: 'job_id', on_delete: :cascade
+  end
+end

db/queue_schema.rb

@@ -0,0 +1,2 @@
+ActiveRecord::Schema[7.1].define(version: 1) do
+  end

db/schema.rb

@@ -1,5 +1,3 @@
-# Copyright (C) 2024 Manuel Bustillo
-
 # This file is auto-generated from the current state of the database. Instead
 # of editing this file, please use the migrations feature of Active Record to
 # incrementally modify your database, and then regenerate this schema definition.
@@ -12,7 +10,7 @@
 #
 # It's strongly recommended that you check this file into your version control system.
 
-ActiveRecord::Schema[7.2].define(version: 2024_11_01_181052) do
+ActiveRecord::Schema[7.2].define(version: 2024_11_03_075705) do
   # These are extensions that must be enabled in order to support this database
   enable_extension "plpgsql"
 
@@ -61,6 +59,127 @@ ActiveRecord::Schema[7.2].define(version: 2024_11_01_181052) do
     t.index ["tables_arrangement_id"], name: "index_seats_on_tables_arrangement_id"
   end
 
+  create_table "solid_queue_blocked_executions", force: :cascade do |t|
+    t.bigint "job_id", null: false
+    t.string "queue_name", null: false
+    t.integer "priority", default: 0, null: false
+    t.string "concurrency_key", null: false
+    t.datetime "expires_at", null: false
+    t.datetime "created_at", null: false
+    t.index ["concurrency_key", "priority", "job_id"], name: "index_solid_queue_blocked_executions_for_release"
+    t.index ["expires_at", "concurrency_key"], name: "index_solid_queue_blocked_executions_for_maintenance"
+    t.index ["job_id"], name: "index_solid_queue_blocked_executions_on_job_id", unique: true
+  end
+
+  create_table "solid_queue_claimed_executions", force: :cascade do |t|
+    t.bigint "job_id", null: false
+    t.bigint "process_id"
+    t.datetime "created_at", null: false
+    t.index ["job_id"], name: "index_solid_queue_claimed_executions_on_job_id", unique: true
+    t.index ["process_id", "job_id"], name: "index_solid_queue_claimed_executions_on_process_id_and_job_id"
+  end
+
+  create_table "solid_queue_failed_executions", force: :cascade do |t|
+    t.bigint "job_id", null: false
+    t.text "error"
+    t.datetime "created_at", null: false
+    t.index ["job_id"], name: "index_solid_queue_failed_executions_on_job_id", unique: true
+  end
+
+  create_table "solid_queue_jobs", force: :cascade do |t|
+    t.string "queue_name", null: false
+    t.string "class_name", null: false
+    t.text "arguments"
+    t.integer "priority", default: 0, null: false
+    t.string "active_job_id"
+    t.datetime "scheduled_at"
+    t.datetime "finished_at"
+    t.string "concurrency_key"
+    t.datetime "created_at", null: false
+    t.datetime "updated_at", null: false
+    t.index ["active_job_id"], name: "index_solid_queue_jobs_on_active_job_id"
+    t.index ["class_name"], name: "index_solid_queue_jobs_on_class_name"
+    t.index ["finished_at"], name: "index_solid_queue_jobs_on_finished_at"
+    t.index ["queue_name", "finished_at"], name: "index_solid_queue_jobs_for_filtering"
+    t.index ["scheduled_at", "finished_at"], name: "index_solid_queue_jobs_for_alerting"
+  end
+
+  create_table "solid_queue_pauses", force: :cascade do |t|
+    t.string "queue_name", null: false
+    t.datetime "created_at", null: false
+    t.index ["queue_name"], name: "index_solid_queue_pauses_on_queue_name", unique: true
+  end
+
+  create_table "solid_queue_processes", force: :cascade do |t|
+    t.string "kind", null: false
+    t.datetime "last_heartbeat_at", null: false
+    t.bigint "supervisor_id"
+    t.integer "pid", null: false
+    t.string "hostname"
+    t.text "metadata"
+    t.datetime "created_at", null: false
+    t.string "name", null: false
+    t.index ["last_heartbeat_at"], name: "index_solid_queue_processes_on_last_heartbeat_at"
+    t.index ["name", "supervisor_id"], name: "index_solid_queue_processes_on_name_and_supervisor_id", unique: true
+    t.index ["supervisor_id"], name: "index_solid_queue_processes_on_supervisor_id"
+  end
+
+  create_table "solid_queue_ready_executions", force: :cascade do |t|
+    t.bigint "job_id", null: false
+    t.string "queue_name", null: false
+    t.integer "priority", default: 0, null: false
+    t.datetime "created_at", null: false
+    t.index ["job_id"], name: "index_solid_queue_ready_executions_on_job_id", unique: true
+    t.index ["priority", "job_id"], name: "index_solid_queue_poll_all"
+    t.index ["queue_name", "priority", "job_id"], name: "index_solid_queue_poll_by_queue"
+  end
+
+  create_table "solid_queue_recurring_executions", force: :cascade do |t|
+    t.bigint "job_id", null: false
+    t.string "task_key", null: false
+    t.datetime "run_at", null: false
+    t.datetime "created_at", null: false
+    t.index ["job_id"], name: "index_solid_queue_recurring_executions_on_job_id", unique: true
+    t.index ["task_key", "run_at"], name: "index_solid_queue_recurring_executions_on_task_key_and_run_at", unique: true
+  end
+
+  create_table "solid_queue_recurring_tasks", force: :cascade do |t|
+    t.string "key", null: false
+    t.string "schedule", null: false
+    t.string "command", limit: 2048
+    t.string "class_name"
+    t.text "arguments"
+    t.string "queue_name"
+    t.integer "priority", default: 0
+    t.boolean "static", default: true, null: false
+    t.text "description"
+    t.datetime "created_at", null: false
+    t.datetime "updated_at", null: false
+    t.index ["key"], name: "index_solid_queue_recurring_tasks_on_key", unique: true
+    t.index ["static"], name: "index_solid_queue_recurring_tasks_on_static"
+  end
+
+  create_table "solid_queue_scheduled_executions", force: :cascade do |t|
+    t.bigint "job_id", null: false
+    t.string "queue_name", null: false
+    t.integer "priority", default: 0, null: false
+    t.datetime "scheduled_at", null: false
+    t.datetime "created_at", null: false
+    t.index ["job_id"], name: "index_solid_queue_scheduled_executions_on_job_id", unique: true
+    t.index ["scheduled_at", "priority", "job_id"], name: "index_solid_queue_dispatch_all"
+  end
+
+  create_table "solid_queue_semaphores", force: :cascade do |t|
+    t.string "key", null: false
+    t.integer "value", default: 1, null: false
+    t.datetime "expires_at", null: false
+    t.datetime "created_at", null: false
+    t.datetime "updated_at", null: false
+    t.index ["expires_at"], name: "index_solid_queue_semaphores_on_expires_at"
+    t.index ["key", "value"], name: "index_solid_queue_semaphores_on_key_and_value"
+    t.index ["key"], name: "index_solid_queue_semaphores_on_key", unique: true
+  end
+
   create_table "tables_arrangements", id: :uuid, default: -> { "gen_random_uuid()" }, force: :cascade do |t|
     t.integer "discomfort"
     t.datetime "created_at", null: false
@@ -71,4 +190,10 @@ ActiveRecord::Schema[7.2].define(version: 2024_11_01_181052) do
   add_foreign_key "guests", "groups"
   add_foreign_key "seats", "guests"
   add_foreign_key "seats", "tables_arrangements", on_delete: :cascade
+  add_foreign_key "solid_queue_blocked_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade
+  add_foreign_key "solid_queue_claimed_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade
+  add_foreign_key "solid_queue_failed_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade
+  add_foreign_key "solid_queue_ready_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade
+  add_foreign_key "solid_queue_recurring_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade
+  add_foreign_key "solid_queue_scheduled_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade
 end