Class: Crm::PartyResearchRunsController

Inherits:

CrmController

Object
ActionController::Base
ApplicationController
CrmController
Crm::PartyResearchRunsController

show all

Defined in:: app/controllers/crm/party_research_runs_controller.rb

Overview

CRM controller for the Lead Enrichment feature. Each "run" is one click of
the Enrich button on a Party page — Customer (whole org) or Contact (a
specific person at the org). The user picks which adapters to call, this
controller enqueues the PartyEnrichmentWorker, and the show page tails
the Sidekiq job for progress before rendering the accept/reject findings
table.

The same routes accept either parent via parallel nesting:
customers/:customer_id/party_research_runs/... and
contacts/:contact_id/party_research_runs/.... load_party picks the
right one off params. show is a shallow top-level route shared by both.

Apply / reject actions for individual findings live in
PartyResearchFindingsController; this controller only owns the
run-level lifecycle.

Constant Summary

Constants included from Www::SeoHelper

Constants included from IconHelper

IconHelper::CUSTOM_ICON_MAP, IconHelper::CUSTOM_SVG_DIR, IconHelper::DEFAULT_FAMILY

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

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?, #stamp_impersonation_context, #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, #track_event

Methods included from Controllers::DeviceDetection

#device_detector, #is_ie?

Methods included from Controllers::SubdomainDetection

#is_crm_request?, #is_www_request?, #json_request?

Methods included from Controllers::TurboSafeRedirect

#redirect_to

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 ApplicationHelper

#better_number_to_currency, #check_force_logout, #check_or_cross, #check_or_times, #embedded_tab_frame_id, #error_messages, #general_disclaimer_on_product_installation_and_local_codes, #gridjs_from_html_table, #gridjs_table, #is_wy_ip, #line_break, #parent_layout, #pass_or_fail, #render_error_messages_list, #render_video_card, #resolved_auth_form_turbo_frame, #return_path_or, #safe_css_color, #set_return_path_if_present, #set_section_if_present, #tab_frame_id, #to_underscore, #track_page?, #turbo_section_wrapper, #turbo_tabs_request?, #url_on_same_domain_as_request, #widget_index_daily_focus_index_path, #working_hours?, #yes_or_no, #yes_or_no_highlighted, #yes_or_no_with_check_or_cross, #youtube_video

Methods included from UppyUploaderHelper

#file_uploader, #image_uploader, #large_file_uploader_s3, #lead_sketch_uploader, #rma_image_uploader, #rma_image_uploader_s3, #uppy_uploader, #video_uploader

Methods included from Www::ImagesHelper

#image_asset_tag, #image_asset_url

Methods included from Www::SeoHelper

#add_page_schema, #add_webpage_schema, #canada?, #company_social_links, #ensure_context_json, #json_ld_script_tag, #local_business_schema, #online_store_id, #online_store_schema, #page_main_entity, #page_main_entity_json, #render_auto_collection_page_schema, #render_collection_page_schema, #render_local_business_schema, #render_online_store_schema, #render_page_schemas, #render_page_video_schemas, #render_webpage_schema, #render_webpage_schema_with_collections, #usa?

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?

Methods included from IconHelper

#account_nav_icon, #fa_icon, #star_rating_html

Instance Method Details

#create ⇒ `Object`

# File 'app/controllers/crm/party_research_runs_controller.rb', line 41

def create
  # Adapter names come from form params — only accept ones the
  # registry actually knows about. Drops any tampered/unknown names
  # before we hit the orchestrator and burn paid API attempts.
  allowed = registered_adapter_names
  selected = Array(params.dig(:party_research_run, :adapters)).map(&:to_s).reject(&:blank?) & allowed
  # Arbiter adapters always run — they're the synthesis layer, not a
  # user-toggleable data source. Force them in regardless of form
  # input. The picker UI already renders them as locked / not
  # user-selectable.
  adapters = (selected + arbiter_adapter_names).uniq
  raw_data_pullers = selected - arbiter_adapter_names

  if raw_data_pullers.empty?
    # `[:new, @party, :party_research_run]` resolves to either
    # new_customer_... or new_contact_... depending on @party's class
    # — same trick used in `guard_enrichable` below.
    redirect_to [:new, @party, :party_research_run],
                alert: 'Pick at least one data source to query.'
    return
  end

  @run = PartyResearchRun.create!(
    party: @party,
    requested_by_id: current_account.id,
    adapters: adapters
  )
  jid = PartyEnrichmentWorker.perform_async(@run.id)
  @run.update!(sidekiq_jid: jid)

  redirect_to party_research_run_path(@run)
end

#index ⇒ `Object`

# File 'app/controllers/crm/party_research_runs_controller.rb', line 24

def index
  # Preload findings so the run-history partial's `run.findings.size`
  # is an array length (no per-row COUNT).
  @runs = PartyResearchRun.where(party_id: @party.id)
                          .includes(:findings, requested_by: :party)
                          .order(created_at: :desc)
end

#new ⇒ `Object`

# File 'app/controllers/crm/party_research_runs_controller.rb', line 32

def new
  @run = PartyResearchRun.new(party: @party)
  @available_adapters = available_adapters
  @runs = PartyResearchRun.where(party_id: @party.id)
                          .includes(:findings, requested_by: :party)
                          .order(created_at: :desc)
                          .limit(10)
end

#show ⇒ `Object`

# File 'app/controllers/crm/party_research_runs_controller.rb', line 74

def show
  all = @run.findings.order(:category, :id)
  @arbiter_findings = all.select(&:arbiter?)
  @raw_findings = all.reject(&:arbiter?)

  # The arbiter (Gemini) curates raw findings — and the user must
  # only get accept/reject buttons on the curated set. Until the run
  # reaches a terminal state we can't tell whether Gemini just
  # hasn't finished yet or wasn't selected, so don't surface any
  # actionable findings mid-run:
  #
  #   - Arbiter findings exist → show those (curated)
  #   - Run completed/failed and no arbiter findings →
  #     fall back to raw (Gemini wasn't selected or returned nothing)
  #   - Run still queued/running and no arbiter findings yet → []
  #     (the show page will keep polling and re-render when Gemini
  #     finishes)
  @findings = if @arbiter_findings.any?
                @arbiter_findings
              elsif @run.state.in?(%w[completed failed])
                @raw_findings
              else
                []
              end
  @awaiting_arbiter = @findings.empty? && @run.state.in?(%w[queued running])
end