Added project status and asynchronous initialization
This commit is contained in:
@@ -4,7 +4,7 @@ class ProjectsController < ApplicationController
|
|||||||
before_action :fetch_project!, only: %w[show edit update destroy]
|
before_action :fetch_project!, only: %w[show edit update destroy]
|
||||||
|
|
||||||
def index
|
def index
|
||||||
@projects = Project.all
|
@projects = available_projects
|
||||||
end
|
end
|
||||||
|
|
||||||
def show; end
|
def show; end
|
||||||
@@ -16,7 +16,7 @@ class ProjectsController < ApplicationController
|
|||||||
def create
|
def create
|
||||||
@project = Project.new(project_params)
|
@project = Project.new(project_params)
|
||||||
if @project.save
|
if @project.save
|
||||||
redirect_to @project
|
redirect_to url_for(action: :index), notice: "Project #{@project.name} being created."
|
||||||
else
|
else
|
||||||
render :new, status: :unprocessable_entity
|
render :new, status: :unprocessable_entity
|
||||||
end
|
end
|
||||||
@@ -36,8 +36,12 @@ class ProjectsController < ApplicationController
|
|||||||
|
|
||||||
private
|
private
|
||||||
|
|
||||||
|
def available_projects
|
||||||
|
Project.ready
|
||||||
|
end
|
||||||
|
|
||||||
def fetch_project!
|
def fetch_project!
|
||||||
@project = Project.find_by!(code: params[:id])
|
@project = available_projects.find_by!(code: params[:id])
|
||||||
self.current_project = @project
|
self.current_project = @project
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,18 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class ProjectPostInitJob < ApplicationJob
|
||||||
|
queue_as :default
|
||||||
|
|
||||||
|
def perform(project_id)
|
||||||
|
project = Project.preparing.find(project_id)
|
||||||
|
|
||||||
|
create_tasks_number_sequence(project)
|
||||||
|
project.update!(status: :ready)
|
||||||
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def create_tasks_number_sequence(project)
|
||||||
|
Project.connection.execute "CREATE SEQUENCE IF NOT EXISTS #{project.tasks_number_sequence_name} AS INT UNSIGNED"
|
||||||
|
end
|
||||||
|
end
|
||||||
@@ -1,6 +1,8 @@
|
|||||||
# frozen_string_literal: true
|
# frozen_string_literal: true
|
||||||
|
|
||||||
class Project < ApplicationRecord
|
class Project < ApplicationRecord
|
||||||
|
enum :status, %i[preparing ready archived].index_by(&:itself), default: :preparing
|
||||||
|
|
||||||
validates :name, :code, presence: true
|
validates :name, :code, presence: true
|
||||||
validates :code, exclusion: { in: %w[new] }, uniqueness: true, format: { with: /\A[a-z]{2,}\z/ }
|
validates :code, exclusion: { in: %w[new] }, uniqueness: true, format: { with: /\A[a-z]{2,}\z/ }
|
||||||
|
|
||||||
@@ -10,7 +12,7 @@ class Project < ApplicationRecord
|
|||||||
|
|
||||||
normalizes :code, with: ->(code) { code.strip.downcase.gsub(/\W+/, '') }
|
normalizes :code, with: ->(code) { code.strip.downcase.gsub(/\W+/, '') }
|
||||||
|
|
||||||
after_commit :create_tasks_number_sequence, on: :create
|
after_commit :schedule_post_init_job, on: :create
|
||||||
after_destroy_commit :drop_tasks_number_sequence
|
after_destroy_commit :drop_tasks_number_sequence
|
||||||
|
|
||||||
def to_param
|
def to_param
|
||||||
@@ -32,8 +34,8 @@ class Project < ApplicationRecord
|
|||||||
|
|
||||||
private
|
private
|
||||||
|
|
||||||
def create_tasks_number_sequence
|
def schedule_post_init_job
|
||||||
self.class.connection.execute "CREATE SEQUENCE IF NOT EXISTS #{tasks_number_sequence_name} AS INT UNSIGNED"
|
ProjectPostInitJob.perform_later id
|
||||||
end
|
end
|
||||||
|
|
||||||
def drop_tasks_number_sequence
|
def drop_tasks_number_sequence
|
||||||
|
|||||||
@@ -18,15 +18,25 @@ default: &default
|
|||||||
host: <%= ENV.fetch("DB_HOST") { "127.0.0.1" } %>
|
host: <%= ENV.fetch("DB_HOST") { "127.0.0.1" } %>
|
||||||
|
|
||||||
development:
|
development:
|
||||||
|
primary:
|
||||||
<<: *default
|
<<: *default
|
||||||
database: subtle_storm_development
|
database: subtle_storm_development
|
||||||
|
queue:
|
||||||
|
<<: *default
|
||||||
|
database: subtle_storm_development_queue
|
||||||
|
migrations_paths: db/queue_migrate
|
||||||
|
|
||||||
# Warning: The database defined as "test" will be erased and
|
# Warning: The database defined as "test" will be erased and
|
||||||
# re-generated from your development database when you run "rake".
|
# re-generated from your development database when you run "rake".
|
||||||
# Do not set this db to the same as development or production.
|
# Do not set this db to the same as development or production.
|
||||||
test:
|
test:
|
||||||
|
primary:
|
||||||
<<: *default
|
<<: *default
|
||||||
database: subtle_storm_test
|
database: subtle_storm_test
|
||||||
|
queue:
|
||||||
|
<<: *default
|
||||||
|
database: subtle_storm_test_queue
|
||||||
|
migrations_paths: db/queue_migrate
|
||||||
|
|
||||||
# As with config/credentials.yml, you never want to store sensitive information,
|
# As with config/credentials.yml, you never want to store sensitive information,
|
||||||
# like your database password, in your source code. If your source code is
|
# like your database password, in your source code. If your source code is
|
||||||
|
|||||||
@@ -55,6 +55,11 @@ Rails.application.configure do
|
|||||||
# Highlight code that enqueued background job in logs.
|
# Highlight code that enqueued background job in logs.
|
||||||
config.active_job.verbose_enqueue_logs = true
|
config.active_job.verbose_enqueue_logs = true
|
||||||
|
|
||||||
|
# Replace the default in-process and non-durable queuing backend for Active Job.
|
||||||
|
config.active_job.queue_adapter = :solid_queue
|
||||||
|
config.solid_queue.connects_to = { database: { writing: :queue } }
|
||||||
|
config.solid_queue.logger = ActiveSupport::Logger.new(STDOUT)
|
||||||
|
|
||||||
# Raises error for missing translations.
|
# Raises error for missing translations.
|
||||||
# config.i18n.raise_on_missing_translations = true
|
# config.i18n.raise_on_missing_translations = true
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,10 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class AddStatusToProjects < ActiveRecord::Migration[8.0]
|
||||||
|
def change
|
||||||
|
change_table :projects, bulk: true do |t|
|
||||||
|
t.string :status
|
||||||
|
t.index :status, where: 'status IS NOT NULL'
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
Generated
+3
-1
@@ -10,7 +10,7 @@
|
|||||||
#
|
#
|
||||||
# It's strongly recommended that you check this file into your version control system.
|
# It's strongly recommended that you check this file into your version control system.
|
||||||
|
|
||||||
ActiveRecord::Schema[8.0].define(version: 2025_06_21_203940) do
|
ActiveRecord::Schema[8.0].define(version: 2025_10_21_180400) do
|
||||||
create_table "action_text_rich_texts", charset: "utf8mb4", collation: "utf8mb4_uca1400_ai_ci", force: :cascade do |t|
|
create_table "action_text_rich_texts", charset: "utf8mb4", collation: "utf8mb4_uca1400_ai_ci", force: :cascade do |t|
|
||||||
t.string "name", null: false
|
t.string "name", null: false
|
||||||
t.text "body", size: :long
|
t.text "body", size: :long
|
||||||
@@ -54,8 +54,10 @@ ActiveRecord::Schema[8.0].define(version: 2025_06_21_203940) do
|
|||||||
t.string "code", null: false
|
t.string "code", null: false
|
||||||
t.datetime "created_at", null: false
|
t.datetime "created_at", null: false
|
||||||
t.datetime "updated_at", null: false
|
t.datetime "updated_at", null: false
|
||||||
|
t.string "status"
|
||||||
t.index ["code"], name: "index_projects_on_code", unique: true
|
t.index ["code"], name: "index_projects_on_code", unique: true
|
||||||
t.index ["name"], name: "index_projects_on_name"
|
t.index ["name"], name: "index_projects_on_name"
|
||||||
|
t.index ["status"], name: "index_projects_on_status"
|
||||||
end
|
end
|
||||||
|
|
||||||
create_table "sessions", charset: "utf8mb4", collation: "utf8mb4_uca1400_ai_ci", force: :cascade do |t|
|
create_table "sessions", charset: "utf8mb4", collation: "utf8mb4_uca1400_ai_ci", force: :cascade do |t|
|
||||||
|
|||||||
Reference in New Issue
Block a user