poc(batch_operations_controller): implement simple [not yet with procedure_presentation] action to create a batch operation

This commit is contained in:
Martin 2022-11-19 06:03:59 +01:00 committed by mfo
parent b11dbafc59
commit 7df86c50fb
8 changed files with 99 additions and 8 deletions

View file

@ -0,0 +1,34 @@
module Instructeurs
class BatchOperationsController < ApplicationController
before_action :set_procedure
before_action :ensure_ownership!
def create
ActiveRecord::Base.transaction do
batch_operation = BatchOperation.create!(batch_operation_params.merge(instructeur: current_instructeur))
BatchOperationEnqueueAllJob.perform_later(batch_operation)
end
redirect_back(fallback_location: instructeur_procedure_url(@procedure.id))
end
private
def batch_operation_params
params.require(:batch_operation)
.permit(:operation, dossier_ids: []).tap do |params|
# TODO: filter dossiers_ids out of instructeurs.dossiers.ids
end
end
def set_procedure
@procedure = Procedure.find(params[:procedure_id])
end
def ensure_ownership!
if !current_instructeur.procedures.exists?(@procedure.id)
flash[:alert] = "Vous navez pas accès à cette démarche"
redirect_to root_path
end
end
end
end

View file

@ -0,0 +1,6 @@
class BatchOperationEnqueueAllJob < ApplicationJob
def perform(batch_operation)
batch_operation.enqueue_all
end
end

View file

@ -1,4 +1,4 @@
class BatchOperationJob < ApplicationJob class BatchOperationProcessOneJob < ApplicationJob
# what about wrapping all of that in a transaction # what about wrapping all of that in a transaction
# but, what about nested transaction because batch_operation.process_one(dossier) can run transaction # but, what about nested transaction because batch_operation.process_one(dossier) can run transaction
def perform(batch_operation, dossier) def perform(batch_operation, dossier)

View file

@ -21,6 +21,7 @@ class BatchOperation < ApplicationRecord
has_many :dossiers, dependent: :nullify has_many :dossiers, dependent: :nullify
belongs_to :instructeur belongs_to :instructeur
validates :operation, presence: true validates :operation, presence: true
def enqueue_all def enqueue_all

View file

@ -414,6 +414,8 @@ Rails.application.routes.draw do
get 'telecharger_pjs' => 'dossiers#telecharger_pjs' get 'telecharger_pjs' => 'dossiers#telecharger_pjs'
end end
end end
resources :batch_operations, only: [:create]
end end
end end
end end

View file

@ -0,0 +1,44 @@
# frozen_string_literal: true
describe Instructeurs::BatchOperationsController, type: :controller do
let(:instructeur) { create(:instructeur) }
let(:procedure) { create(:procedure, :published, :for_individual, instructeurs: [instructeur]) }
let!(:dossier) { create(:dossier, :en_construction, :with_individual, procedure: procedure) }
describe '#POST create' do
before { sign_in(instructeur.user) }
context 'ACL' do
subject { post :create, params: { procedure_id: create(:procedure).id } }
before { sign_in(instructeur.user) }
it 'fails when procedure does not belongs to instructeur' do
expect(subject).to have_http_status(302)
end
end
context 'success' do
let(:params) do
{
procedure_id: procedure.id,
batch_operation: {
operation: BatchOperation.operations.fetch(:archiver),
dossier_ids: [ dossier.id ]
}
}
end
subject { post :create, params: params }
before { sign_in(instructeur.user) }
it 'creates a batch operation for our signed in instructeur' do
expect { subject }.to change { instructeur.batch_operations.count }.by(1)
expect(BatchOperation.first.dossiers).to include(dossier)
end
it 'created a batch operation contains dossiers' do
subject
expect(BatchOperation.first.dossiers).to include(dossier)
end
it 'enqueues a BatchOperationJob' do
expect {subject}.to have_enqueued_job(BatchOperationEnqueueAllJob).with(BatchOperation.last)
end
end
end
end

View file

@ -1,12 +1,16 @@
FactoryBot.define do FactoryBot.define do
factory :batch_operation do factory :batch_operation do
transient do
invalid_instructeur { nil }
end
trait :archiver do trait :archiver do
operation { BatchOperation.operations.fetch(:archiver) } operation { BatchOperation.operations.fetch(:archiver) }
dossiers do after(:build) do |batch_operation, _evaluator|
[ procedure = create(:procedure, instructeurs: [_evaluator.invalid_instructeur.presence || batch_operation.instructeur])
association(:dossier, :accepte), batch_operation.dossiers = [
association(:dossier, :refuse), build(:dossier, :accepte, procedure: procedure),
association(:dossier, :sans_suite) build(:dossier, :refuse, procedure: procedure),
build(:dossier, :sans_suite, procedure: procedure)
] ]
end end
end end

View file

@ -1,11 +1,11 @@
describe BatchOperationJob, type: :job do describe BatchOperationProcessOneJob, type: :job do
describe 'perform' do describe 'perform' do
let(:batch_operation) do let(:batch_operation) do
create(:batch_operation, :archiver, create(:batch_operation, :archiver,
options.merge(instructeur: create(:instructeur))) options.merge(instructeur: create(:instructeur)))
end end
let(:dossier_job) { batch_operation.dossiers.first } let(:dossier_job) { batch_operation.dossiers.first }
subject { BatchOperationJob.new(batch_operation, dossier_job) } subject { BatchOperationProcessOneJob.new(batch_operation, dossier_job) }
let(:options) { {} } let(:options) { {} }
it 'just call the process one' do it 'just call the process one' do