Class: JobsController
- Inherits:
-
CrmController
- Object
- ActionController::Base
- ApplicationController
- CrmController
- JobsController
- Defined in:
- app/controllers/jobs_controller.rb
Overview
Status/progress polling and cancellation for BackgroundJobStatus —
backs the toast/banner UI that tracks a long-running Sidekiq job (import,
export, bulk update) from either an XHR poll or a full page visit.
Constant Summary
Constants included from Controllers::ReferenceFindable
Controllers::ReferenceFindable::ID_EMBEDDED_PATTERNS
Constants included from Controllers::AnalyticsEvents
Controllers::AnalyticsEvents::MAX_QUEUED_EVENTS, Controllers::AnalyticsEvents::SESSION_KEY
Constants included from Controllers::ErrorRendering
Controllers::ErrorRendering::NON_CONTENT_PATH_PREFIXES
Instance Method Summary collapse
-
#cancel ⇒ void
Cancels (destroys) an active job status; already-finished jobs are left alone with a flash explaining why.
-
#show ⇒ void
Shows job status: JSON for API-style polling, a Turbo Stream fragment for the JS poll, or a full HTML page for a direct visit.
Methods inherited from CrmController
#access_denied, #context_id, #context_object, #crm_home_path, #current_ability, #default_url_options, #download_temp, #get_tempfile_path_for_download, #init_status_job_collector, #initialize_crm_lazy_chunks, #persist_enqueued_status_jobs, #record_not_found, #redirect_to_job_or_fallback, #render_edit_action, #set_context, #set_download_path, #stash_file_for_temp_download, #sync_admin_presence_cookie, #touch_employee_last_seen
Methods inherited from ApplicationController
#account_impersonated?, #add_to_flash, #after_sign_in_path_for, #bypass_forgery_protection?, #chat_enabled?, #cloudflare_cleared?, #default_catalog, #default_url_options, #enable_turbo_frames, #find_publication, #fix_invalid_accept_header, #init_js_utils, #is_globals_call?, #layout_by_resource, #locale_store, #redirect_to, #require_employee_for_crm, #set_base_host, #set_real_ip, #set_report_errors_for, #should_render_layout?, #skip_layout_for_turbo_frame?, #stamp_impersonation_context, #tab_frame_breakout_request?, #warmlyyours_canada_ip?, #warmlyyours_ip?, #y
Methods included from Controllers::ReturnPathHandling
#check_for_return_path, #redirect_to_return_path_or_default
Methods included from Controllers::AnalyticsEvents
#consume_queued_analytics_events, #registration_lead_type, #track_event
Methods included from Controllers::DeviceDetection
Methods included from Controllers::SubdomainDetection
#is_crm_request?, #is_www_request?, #json_request?
Methods included from Controllers::TurboSafeRedirect
Methods included from Controllers::TrackingDetection
#bot_request?, #gdpr_country?, #gdpr_country_data, #prevent_bots, #set_tracking_cookie, #track_visitor?
Methods included from Controllers::AcceleratedFileSending
#send_file_accelerated, #send_upload_accelerated
Methods included from Controllers::ErrorRendering
#excp_string, #mail_to_for_error_reporting, #render_400, #render_404, #render_406, #render_410, #render_500, #render_invalid_authenticity_token, #render_ip_spoof_error, #render_unpermitted_parameters, #safe_referer_or_fallback
Methods included from Controllers::TurnstileVerification
#load_turnstile_script_tag, #turnstile_lazy_widget, #turnstile_script_tag, #turnstile_widget, #validate_turnstile!
Methods included from Controllers::CloudflareCaching
edge_cached, #edge_cached_action?, #reset_cloudflare_cache, #set_cloudflare_cache, #skip_edge_cache!, #skip_session
Methods included from Controllers::Webpackable
#preload_webpack_fonts, #webpack_css_include, #webpack_css_url, #webpack_js_include, #wpd_is_running?
Methods included from Controllers::Localizable
#cloudflare_country_locale, #determine_request_locale, #geocoder_locale, #guest_user_locale_check, #locale_optional_www_auth_path?, #param_locale, #set_locale, #set_request_locale, #skip_localization?, #warmlyyours_ip_locale
Methods included from Controllers::Authenticable
#access_denied, #authenticate_account, #authenticate_account!, #authenticate_account_from_login_token!, #check_is_a_manager, #check_is_a_sales_manager, #check_is_an_admin, #check_is_an_employee, #check_party, #clear_mismatched_guest_user, #create_guest_user, #credentials?, #current_or_guest_user, #current_or_guest_user_id_read_only, #current_user, #devise_mapping, #fully_logged_in?, #generate_bot_id, #guest_user, #identifiable?, #init_current_user, #initialize_guest, #load_context_user, #logging_in, #resource, #resource_name, #restrict_access_for_non_employees, #scrubbed_request_path, #user_object, #warn_on_session_guest_id_leak
Methods included from UrlsHelper
#catalog_breadcrumb_links, #catalog_link, #catalog_link_for_product_line, #catalog_link_for_sku, #cms_link, #delocalized_path, #path_to_sales_product_sku, #path_to_sales_product_sku_for_product_line, #path_to_sales_product_sku_for_product_line_slug, #product_line_from_catalog_link, #protocol_neutral_url, #sanitize_external_url, #valid_external_url?
Instance Method Details
#cancel ⇒ void
This method returns an undefined value.
Cancels (destroys) an active job status; already-finished jobs are
left alone with a flash explaining why.
45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'app/controllers/jobs_controller.rb', line 45 def cancel @job = BackgroundJobStatus.find(params[:id]) if @job.nil? flash[:warning] = "Job #{params[:id]} could not be found — it may have already expired." redirect_to root_path and return end if @job.active? @job.destroy flash[:warning] = "Job #{params[:id]} was cancelled" else flash[:warning] = "Job #{params[:id]} was already completed or stopped. Status is #{@job.status}. #{@job.}" end redirect_path = @job.redirect_to.presence || root_path redirect_to redirect_path end |
#show ⇒ void
This method returns an undefined value.
Shows job status: JSON for API-style polling, a Turbo Stream fragment
for the JS poll, or a full HTML page for a direct visit. ETags the
poll response so unchanged status doesn't re-render.
14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 |
# File 'app/controllers/jobs_controller.rb', line 14 def show @job = BackgroundJobStatus.find(params[:id], quick: polling_request?) # The JS poll (XHR) and a normal page visit share this URL but return different # representations: a `text/vnd.turbo-stream.html` fragment for the poll vs. a # full HTML page for a visit (negotiated on `X-Requested-With` / `Turbo-Frame`, # see #polling_request?). Without Vary, the browser HTTP cache can hand the # cached turbo-stream body to a back/forward navigation, which then renders as a # raw <turbo-stream> document. Vary keys the two apart so navigations always get # (or re-fetch) the HTML page, never the stream. vary_on('X-Requested-With', 'Turbo-Frame') if polling_request? && @job queue_age_bucket = Time.current.to_i / 60 if @job.queued? && @job.enqueued_at.present? etag = Digest::SHA256.hexdigest( [@job.jid, @job.status, @job.pct_complete, @job.at, @job., queue_age_bucket].join('-') ) return unless stale?(etag: etag, public: false) end respond_to do |format| format.json { render_job_json } format.turbo_stream { render_job_html } if polling_request? format.html { render_job_html } end end |