Implemented turbo_stream for operator jobs
This commit is contained in:
@@ -16,7 +16,7 @@ class JobsController < ApplicationController
|
||||
respond_to do |format|
|
||||
if @job.save
|
||||
flash[:notice] = "Job was successfully created."
|
||||
broadcast_create_job job: @job
|
||||
broadcast_create_job
|
||||
format.html { redirect_to jobs_url }
|
||||
else
|
||||
format.html { render :new, status: :unprocessable_entity }
|
||||
@@ -28,12 +28,13 @@ class JobsController < ApplicationController
|
||||
@job = Job.find(params[:id])
|
||||
if @job.canceled!
|
||||
flash[:notice] = "Job successfully canceled"
|
||||
@status_changed = true
|
||||
else
|
||||
flash[:alert] = "Job could not be canceled"
|
||||
end
|
||||
|
||||
respond_to do |format|
|
||||
broadcast_update_job(job: @job, status_changed: true)
|
||||
broadcast_update_job
|
||||
format.turbo_stream
|
||||
format.html { redirect_to jobs_url }
|
||||
end
|
||||
@@ -41,39 +42,40 @@ class JobsController < ApplicationController
|
||||
|
||||
private
|
||||
|
||||
def broadcast_update_status_cards(job:)
|
||||
def broadcast_update_status_cards_and_start_next_job_button
|
||||
# FIXME: Duplicate code, see operator/jobs_controller, move to the model
|
||||
openjobs = Job.open.order(:created_at)
|
||||
openjobs = Job.open.order(:status_changed_at)
|
||||
printingjobs = Job.printing.order(:status_changed_at)
|
||||
pickupjobs = Job.pickup.order(:status_changed_at)
|
||||
paidjobs = Job.paid.status_changed_today.order(:status_changed_at)
|
||||
canceledjobs = Job.canceled.status_changed_today.order(:status_changed_at)
|
||||
Turbo::StreamsChannel.broadcast_remove_to "operator_jobs", target: job
|
||||
Turbo::StreamsChannel.broadcast_replace_to "operator_jobs", target: "openjobs_status_card", partial: "operator/jobs/job_status_card", locals: { jobs: openjobs, status: :open }
|
||||
Turbo::StreamsChannel.broadcast_replace_to "operator_jobs", target: "printingjobs_status_card", partial: "operator/jobs/job_status_card", locals: { jobs: printingjobs, status: :printing }
|
||||
Turbo::StreamsChannel.broadcast_replace_to "operator_jobs", target: "pickupjobs_status_card", partial: "operator/jobs/job_status_card", locals: { jobs: pickupjobs, status: :pickup }
|
||||
Turbo::StreamsChannel.broadcast_replace_to "operator_jobs", target: "paidjobs_status_card", partial: "operator/jobs/job_status_card", locals: { jobs: paidjobs, status: :paid }
|
||||
Turbo::StreamsChannel.broadcast_replace_to "operator_jobs", target: "canceledjobs_status_card", partial: "operator/jobs/job_status_card", locals: { jobs: canceledjobs, status: :canceled }
|
||||
Turbo::StreamsChannel.broadcast_replace_to "operator_jobs", target: "start_next_job_btn", partial: "operator/jobs/start_next_job_btn", locals: { jobs: openjobs }
|
||||
end
|
||||
|
||||
def broadcast_create_job(job:)
|
||||
Turbo::StreamsChannel.broadcast_prepend_later_to "jobs", target: :jobs, partial: "jobs/job_tr", locals: { job: job }
|
||||
Turbo::StreamsChannel.broadcast_prepend_later_to "operator_jobs", target: :openjobs, partial: "operator/jobs/job_tr", locals: { job: job }
|
||||
broadcast_update_status_cards job: job
|
||||
def broadcast_create_job
|
||||
Turbo::StreamsChannel.broadcast_prepend_later_to "jobs", target: :jobs, partial: "jobs/job_tr", locals: { job: @job }
|
||||
Turbo::StreamsChannel.broadcast_append_later_to "operator_jobs", target: :openjobs, partial: "operator/jobs/job_tr", locals: { job: @job }
|
||||
broadcast_update_status_cards_and_start_next_job_button
|
||||
end
|
||||
|
||||
def broadcast_update_job(job:, status_changed: false)
|
||||
Turbo::StreamsChannel.broadcast_replace_later_to "jobs", target: job, partial: "jobs/job_tr", locals: { job: }
|
||||
if status_changed
|
||||
broadcast_update_status_cards job: job
|
||||
case job.status.to_sym
|
||||
when :canceled, :paid then Turbo::StreamsChannel.broadcast_append_later_to "operator_jobs", target: :paidcanceledjobs, partial: "operator/jobs/job_tr", locals: { job: job }
|
||||
when :open then Turbo::StreamsChannel.broadcast_append_later_to "operator_jobs", target: :openjobs, partial: "operator/jobs/job_tr", locals: { job: job }
|
||||
when :printing then Turbo::StreamsChannel.broadcast_append_later_to "operator_jobs", target: :printingjobs, partial: "operator/jobs/job_tr", locals: { job: job }
|
||||
when :pickup then Turbo::StreamsChannel.broadcast_append_later_to "operator_jobs", target: :pickupjobs, partial: "operator/jobs/job_tr", locals: { job: job }
|
||||
def broadcast_update_job
|
||||
Turbo::StreamsChannel.broadcast_replace_later_to "jobs", target: @job, partial: "jobs/job_tr", locals: { job: @job}
|
||||
Turbo::StreamsChannel.broadcast_remove_to "operator_jobs", target: @job
|
||||
if @status_changed
|
||||
broadcast_update_status_cards_and_start_next_job_button
|
||||
case @job.status.to_sym
|
||||
when :canceled, :paid then Turbo::StreamsChannel.broadcast_append_later_to "operator_jobs", target: :paidcanceledjobs, partial: "operator/jobs/job_tr", locals: { job: @job }
|
||||
when :open then Turbo::StreamsChannel.broadcast_append_later_to "operator_jobs", target: :openjobs, partial: "operator/jobs/job_tr", locals: { job: @job }
|
||||
when :printing then Turbo::StreamsChannel.broadcast_append_later_to "operator_jobs", target: :printingjobs, partial: "operator/jobs/job_tr", locals: { job: @job }
|
||||
when :pickup then Turbo::StreamsChannel.broadcast_append_later_to "operator_jobs", target: :pickupjobs, partial: "operator/jobs/job_tr", locals: { job: @job }
|
||||
end
|
||||
else
|
||||
Turbo::StreamsChannel.broadcast_replace_later_to "operator_jobs", target: job, partial: "operator/jobs/job_tr", locals: { job: job }
|
||||
Turbo::StreamsChannel.broadcast_replace_later_to "operator_jobs", target: job, partial: "operator/jobs/job_tr", locals: { job: @job }
|
||||
end
|
||||
end
|
||||
|
||||
|
||||
@@ -41,10 +41,18 @@ class Operator::JobsController < ApplicationController
|
||||
|
||||
# PATCH/PUT /jobs/1 or /jobs/1.json
|
||||
def update
|
||||
# FIXME: Move to the model (orderstuff)
|
||||
@openjobs = Job.open.order(:created_at)
|
||||
@printingjobs = Job.printing.order(:status_changed_at)
|
||||
@pickupjobs = Job.pickup.order(:status_changed_at)
|
||||
@paidjobs = Job.paid.status_changed_today.order(:status_changed_at)
|
||||
@canceledjobs = Job.canceled.status_changed_today.order(:status_changed_at)
|
||||
@job.assign_attributes(job_params)
|
||||
@status_changed = @job.status_changed?
|
||||
respond_to do |format|
|
||||
if @job.update(job_params)
|
||||
if @job.save
|
||||
broadcast_update_job
|
||||
# format.turbo_stream
|
||||
format.turbo_stream
|
||||
format.html { redirect_to operator_jobs_url, notice: "Job was successfully updated." }
|
||||
else
|
||||
format.html { render :edit, status: :unprocessable_entity }
|
||||
@@ -67,11 +75,13 @@ class Operator::JobsController < ApplicationController
|
||||
flash[:notice] = "Job was successfully updated"
|
||||
else
|
||||
flash[:alert] = "Job could not be updated"
|
||||
# NOTE: Discard changes that could not be saved so turbo_stream renders the correct values
|
||||
@job.reload
|
||||
end
|
||||
|
||||
respond_to do |format|
|
||||
broadcast_update_job
|
||||
# format.turbo_stream
|
||||
format.turbo_stream { render turbo_stream: turbo_stream.replace(@job, partial: "operator/jobs/job_tr", locals: { job: @job }) }
|
||||
format.html { redirect_to operator_jobs_url }
|
||||
end
|
||||
end
|
||||
@@ -81,11 +91,13 @@ class Operator::JobsController < ApplicationController
|
||||
flash[:notice] = "Job was successfully updated"
|
||||
else
|
||||
flash[:alert] = "Job could not be updated"
|
||||
# NOTE: Discard changes that could not be saved so turbo_stream renders the correct values
|
||||
@job.reload
|
||||
end
|
||||
|
||||
respond_to do |format|
|
||||
broadcast_update_job
|
||||
# format.turbo_stream
|
||||
format.turbo_stream { render turbo_stream: turbo_stream.replace(@job, partial: "operator/jobs/job_tr", locals: { job: @job }) }
|
||||
format.html { redirect_to operator_jobs_url }
|
||||
end
|
||||
end
|
||||
|
||||
Reference in New Issue
Block a user