Class: CatalogItemsController

Inherits:
CrmController show all
Includes:
Controllers::ContentLocalizable, Controllers::RequireTurboFrame, Controllers::Workflowable
Defined in:
app/controllers/catalog_items_controller.rb

Overview

== Schema Information

Table name: catalog_items

id :integer not null, primary key
catalog_id :integer
amount :decimal(8, 2)
store_item_id :integer
max_discount :integer default(100)
free_for_organizations :boolean default(FALSE)
third_party_part_number :string(255) default(""), not null
retail_price :decimal(8, 2)
third_party_name_en :string(255)
third_party_name_fr :string(255)
price_editable :boolean default(FALSE), not null
reserve_stock :integer
min_stock_to_report :integer
third_party_sku :string

Constant Summary collapse

TAB_ACTIONS =

Tab fragments never render standalone — non-frame hits redirect to show ?tab=.

%i[show_amazon show_edi show_siblings show_wayfair tab_main tab_descriptions tab_specs tab_images tab_dependents tab_price_history tab_retailer_probes tab_sibling_retailers].freeze
PRICE_ATTRIBUTES =

Price attributes.

%w[
  amount sale_price new_price new_price_effective_date
  retail_price retailer_requested_cost msrp map_price
  coupon_id new_coupon_id new_sale_price
].freeze

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

Methods included from Controllers::ContentLocalizable

#allow_content_locale_switch, #default_url_options, #set_content_locale

Methods included from Controllers::RequireTurboFrame

require_in_pane_tab_frames, require_turbo_frame

Methods included from Controllers::Workflowable

#render_workflow_error_stream, #render_workflow_success_stream, #workflow_action, #workflow_action_complete

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

#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 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

#amazon_fba_labels ⇒ void

This method returns an undefined value.

GET /catalog_items/:id/amazon_fba_labels — generates a UPC-A barcode PNG
for the FBA shipping label.



528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
 
# File 'app/controllers/catalog_items_controller.rb', line 528

def amazon_fba_labels
  @catalog_item = CatalogItem.includes(:item).find(params[:id])
  authorize! :read, CatalogItem

  @item = @catalog_item.item
  require 'zint'
  barcode = Zint::Barcode.new(value: @item.upc, symbology: Zint::Constants::Symbologies::BARCODE_CODE128)
  barcode.height = 33
  barcode.whitespace_width = 0
  barcode.show_hrt = 0 # barby rendered bars only; keep it that way
  file_name = "#{@item.sku}_#{@item.upc}_upca.png"
  barcode_path = Rails.public_path.join(file_name)
  File.open(barcode_path, 'wb') do |f|
    f.write barcode.to_memory_file(extension: '.png')
    f.flush
    f.fsync
  end
  @barcode_path = barcode_path
  @barcode_path = "//#{request.host_with_port}/#{file_name}" if params[:debug].present?
  Rails.logger.debug { "@barcode_path: #{@barcode_path}" }
end

#amazon_listing_data ⇒ Object

Patch or Put listing message via EDI/API partners



407
408
409
410
411
412
413
414
415
416
417
 
# File 'app/controllers/catalog_items_controller.rb', line 407

def amazon_listing_data
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, @catalog_item
  @generator = @catalog_item.amazon_json_generator
rescue ArgumentError => e
  Appsignal.report_error(e) do |transaction|
    transaction.set_tags(catalog_item_id: @catalog_item.id.to_s, sku: @catalog_item.sku.to_s)
  end
  flash[:warning] = e.message
  redirect_to catalog_item_path(@catalog_item)
end

#create ⇒ void

This method returns an undefined value.

POST /catalog_items — creates a catalog item via Catalog::CreateCatalogItem.



475
476
477
478
479
480
481
482
483
484
 
# File 'app/controllers/catalog_items_controller.rb', line 475

def create
  authorize! :create, CatalogItem
  result = Catalog::CreateCatalogItem.new.process(@catalog, params[:catalog_item])
  if result.catalog_item_created?
    redirect_to_return_path_or_default(catalog_item_path(result.catalog_item), notice: result.messages.join(', '))
  else
    @catalog_item = result.catalog_item
    render :new, status: :unprocessable_content
  end
end

#delete_amazon_listing_data ⇒ void

This method returns an undefined value.

DELETE /catalog_items/:id/delete_amazon_listing_data — retires the
listing (Walmart) or deletes it (Amazon).



443
444
445
446
447
448
449
450
451
452
453
 
# File 'app/controllers/catalog_items_controller.rb', line 443

def delete_amazon_listing_data
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, @catalog_item
  res = if @catalog_item.walmart_catalog_item?
          @catalog_item.walmart_retire_item
        else
          @catalog_item.amazon_delete_information
        end
  flash[:info] = "Delete Listing request sent. #{res[:status]}: #{res[:message]}"
  redirect_to catalog_item_path(@catalog_item)
end

#destroy ⇒ void

This method returns an undefined value.

DELETE /catalog_items/:id — destroys a catalog item, or discontinues it
instead when it's still referenced.



505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
 
# File 'app/controllers/catalog_items_controller.rb', line 505

def destroy
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, CatalogItem

  if @catalog_item.ok_to_destroy?
    if @catalog_item.destroy
      redirect_to catalog_path(@catalog_item.catalog_id), notice: 'Catalog Item deleted'
    else
      flash[:error] = @catalog_item.errors_to_s
      redirect_to catalog_item_path(@catalog_item)
    end
  else
    # Attempts discontinue
    @catalog_item.discontinue
    flash[:warning] = "Catalog Item #{@catalog_item.id} is in use and was discontinued instead"
    redirect_to catalog_item_path(@catalog_item)
  end
end

#destroy_retailer_probe ⇒ void

This method returns an undefined value.

DELETE /catalog_items/:id/destroy_retailer_probe — removes a single
retailer probe result.



296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
 
# File 'app/controllers/catalog_items_controller.rb', line 296

def destroy_retailer_probe
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, @catalog_item

  probe = @catalog_item.retailer_probes.find(params[:probe_id])
  probe.destroy!

  respond_to do |format|
    format.html do
      flash[:success] = 'Retailer probe deleted'
      redirect_to catalog_item_path(@catalog_item, tab: 'retailer_probes')
    end
    format.turbo_stream do
      render turbo_stream: turbo_stream.remove("retailer_probe_#{probe.id}")
    end
  end
end

#edit ⇒ void

This method returns an undefined value.

GET /catalog_items/:id/edit — edit form for an existing catalog item.



354
355
356
357
358
359
 
# File 'app/controllers/catalog_items_controller.rb', line 354

def edit
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, @catalog_item

  @catalog = @catalog_item.catalog
end

#edit_amazon ⇒ void

This method returns an undefined value.

GET /catalog_items/:id/edit_amazon — edit form for Amazon listing attributes.



80
81
82
83
84
 
# File 'app/controllers/catalog_items_controller.rb', line 80

def edit_amazon
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, @catalog_item
  set_image_ransack
end

#edit_stores ⇒ void

This method returns an undefined value.

GET /catalog_items/:id/edit_stores — form for the stores a catalog item
is mapped to.



365
366
367
368
 
# File 'app/controllers/catalog_items_controller.rb', line 365

def edit_stores
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, @catalog_item
end

#export_amalytics_snapshot ⇒ void

This method returns an undefined value.

GET /catalog_items/:id/export_amalytics_snapshot — downloads an Amalytix
export snapshot for the catalog item.



715
716
717
718
719
720
721
722
723
 
# File 'app/controllers/catalog_items_controller.rb', line 715

def export_amalytics_snapshot
  catalog_items = CatalogItem.where(id: params[:id])
  file_name = "amalytix_export_#{Time.current.to_i}.xlsx"
  directory_path = Rails.root.join(Rails.application.config.x.temp_storage_path.to_s, 'users', current_user.id.to_s)
  FileUtils.mkdir_p(directory_path)
  output_file_path = Rails.root.join(directory_path, file_name)
  Amazon::ExportAmalyticsSnapshot.new.process(catalog_items:, output_file_path:)
  send_file_accelerated(output_file_path)
end

#index ⇒ void

This method returns an undefined value.

GET /catalog_items — a context object's catalog items, or redirects to
search when the context doesn't have any.



36
37
38
39
40
41
42
43
 
# File 'app/controllers/catalog_items_controller.rb', line 36

def index
  if context_object.respond_to?(:catalog_items)
    @catalog_items = context_object&.catalog_items
    render layout: should_render_layout?
  else
    redirect_to new_search_path(type: 'ProductCatalogSearch')
  end
end

#new ⇒ void

This method returns an undefined value.

GET /catalog_items/new — blank catalog item form, defaulted from the
parent catalog item's pricing when one exists.



333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
 
# File 'app/controllers/catalog_items_controller.rb', line 333

def new
  @catalog_item = @catalog.catalog_items.build(params[:catalog_item])
  authorize! :create, @catalog_item
  if @catalog_item.is_publication?
    @catalog_item.amount = 0.0
  else
    @catalog_item.state = @catalog.default_catalog_item_state
    # A custom build product does not go to active public
    @catalog_item.state = 'active_hidden' if @catalog_item.active? && @catalog_item.item&.product_category&.custom_product
    # Default the pricing if we come from a parent catalog with a default price set
    if (parent_catalog_amount = @catalog_item.parent_catalog_item&.amount)
      discount = @catalog_item.parent_catalog_discount || 0.0
      @catalog_item.amount = parent_catalog_amount * (1.0 - discount)
    end
  end
  @catalog_item.state ||= 'active'
end

#pull_amazon_information ⇒ void

This method returns an undefined value.

POST /catalog_items/:id/pull_amazon_information — pulls Amazon listing,
catalog, and buy-box data via AmazonItemOperationWorker.



554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
 
# File 'app/controllers/catalog_items_controller.rb', line 554

def pull_amazon_information
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, CatalogItem
  return_path = catalog_item_path(@catalog_item, tab: 'amazon')
  options = {
    catalog_item_ids: [@catalog_item.id],
    redirect_to: return_path,
    operation: %w[PULL_LISTING_INFORMATION PULL_CATALOG_INFORMATION PULL_BUY_BOX_STATUS]
  }
  if Rails.env.development?
    AmazonItemOperationWorker.new.perform(**options)
    redirect_to return_path
  else
    jid = AmazonItemOperationWorker.perform_async(**options)
    redirect_to_job_or_fallback(
      jid,
      return_path,
      duplicate_lookup: -> { SidekiqUniqueJobsJidLookup.active_jid_for_args(AmazonItemOperationWorker, options) }
    )
  end
end

#pull_amazon_schema ⇒ void

This method returns an undefined value.

POST /catalog_items/:id/pull_amazon_schema — pulls the Amazon listing
schema for the catalog item's product type.



580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
 
# File 'app/controllers/catalog_items_controller.rb', line 580

def pull_amazon_schema
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, CatalogItem
  return_path = catalog_item_path(@catalog_item, tab: 'amazon')
  options = {
    catalog_item_ids: [@catalog_item.id],
    redirect_to: return_path,
    operation: %w[PULL_LISTING_SCHEMA]
  }
  if Rails.env.development?
    # AmazonItemOperationWorker.new.perform(**options)
    @catalog_item.amazon_pull_listing_schema
    redirect_to return_path
  else
    jid = AmazonItemOperationWorker.perform_async(**options)
    redirect_to_job_or_fallback(
      jid,
      return_path,
      duplicate_lookup: -> { SidekiqUniqueJobsJidLookup.active_jid_for_args(AmazonItemOperationWorker, options) }
    )
  end
end

#pull_wayfair_information ⇒ void

This method returns an undefined value.

POST /catalog_items/:id/pull_wayfair_information — pulls Wayfair
catalog information via Edi::Wayfair::Orchestrator.



614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
 
# File 'app/controllers/catalog_items_controller.rb', line 614

def pull_wayfair_information
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, CatalogItem
  return_path = catalog_item_path(@catalog_item, tab: 'wayfair')

  orchestrator = Edi::Wayfair::Orchestrator.build(:wayfair_us)
  result = orchestrator.pull_catalog_information(@catalog_item.sku || @catalog_item.item.sku)

  if result[:success]
    flash[:notice] = 'Wayfair catalog information pulled successfully.'
  else
    flash[:error] = "Failed to pull Wayfair information: #{result[:message]}"
  end

  redirect_to return_path
end

#pull_wayfair_schema ⇒ void

This method returns an undefined value.

POST /catalog_items/:id/pull_wayfair_schema — pulls the Wayfair taxonomy
schema for the catalog item's category.



635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
 
# File 'app/controllers/catalog_items_controller.rb', line 635

def pull_wayfair_schema
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, CatalogItem
  return_path = catalog_item_path(@catalog_item, tab: 'wayfair')

  taxonomy_category_id = @catalog_item.wayfair_taxonomy_category_id_in_effect
  unless taxonomy_category_id
    flash[:error] = 'No taxonomy category set. Pull Wayfair catalog data first.'
    redirect_to(return_path) && return
  end

  orchestrator = Edi::Wayfair::Orchestrator.build(:wayfair_us)
  schema = orchestrator.pull_taxonomy_schema(taxonomy_category_id)

  if schema
    flash[:notice] = "Taxonomy schema pulled for #{@catalog_item.wayfair_class_name || 'category'} (#{schema.attributes_list.size} attributes)."
  else
    flash[:error] = 'Failed to pull taxonomy schema from Wayfair.'
  end

  redirect_to return_path
end

#push_inventory_message ⇒ Object

Push inventory message via EDI/API partners



389
390
391
392
393
394
395
 
# File 'app/controllers/catalog_items_controller.rb', line 389

def push_inventory_message
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, @catalog_item
  res = @catalog_item.push_inventory_message
  flash[:info] = format_edi_push_flash('Inventory Message', res)
  redirect_to catalog_item_path(@catalog_item)
end

#push_price_message ⇒ Object

Push price message via EDI/API partners



398
399
400
401
402
403
404
 
# File 'app/controllers/catalog_items_controller.rb', line 398

def push_price_message
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, @catalog_item
  res = @catalog_item.push_price_message
  flash[:info] = format_edi_push_flash('Price Message', res)
  redirect_to catalog_item_path(@catalog_item)
end

#push_wayfair_listing_data ⇒ void

This method returns an undefined value.

POST /catalog_items/:id/push_wayfair_listing_data — pushes the reviewed
listing update to Wayfair (or dry-runs it).



680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
 
# File 'app/controllers/catalog_items_controller.rb', line 680

def push_wayfair_listing_data
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, @catalog_item
  return_path = catalog_item_path(@catalog_item, tab: 'wayfair')

  dry_run = params.dig(:listing, :dry_run) == '1' || params[:dry_run] == 'true'
  attribute_actions = params.dig(:listing, :action).to_h

  # Filter to only include attributes marked as 'send'
  attributes_to_send = attribute_actions.select { |_k, v| v == 'send' }.keys

  orchestrator = Edi::Wayfair::Orchestrator.build(:wayfair_us)
  result = orchestrator.push_catalog_update(
    @catalog_item,
    attributes: attributes_to_send.presence,
    dry_run: dry_run
  )

  if result.success
    if dry_run
      flash[:info] = "Dry run successful. Would send #{result.payload[:attributes].size} attributes."
    else
      flash[:notice] = "Listing data pushed to Wayfair. Request id: #{result.request_id}"
    end
  else
    flash[:error] = "Failed to push listing data: #{result.errors.join(', ')}"
  end

  redirect_to return_path
end

#reset_price_to_parent_discount ⇒ Object

Reset this catalog item price from its parent



456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
 
# File 'app/controllers/catalog_items_controller.rb', line 456

def reset_price_to_parent_discount
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, @catalog_item
  if @catalog_item.parent_catalog_item
    res = Catalog::PushCatalogItemPrice.new.process(@catalog_item.parent_catalog_item, target_catalog_id: @catalog_item.catalog_id)
    if res.all_price_pushed?
      flash[:notice] = "Price reset to parent for item #{@catalog_item.name}"
    else
      flash[:error] = "Failed to reset price to parent for item #{@catalog_item.name}: #{res.messages.join(', ')}"
    end
  else
    flash[error] = "Failed to reset price to parent for item #{@catalog_item.name}, no parent catalog item to set price from"
  end
  redirect_to_return_path_or_default catalog_item_path(@catalog_item)
end

#retailer_probe_status ⇒ void

This method returns an undefined value.

GET /catalog_items/:id/retailer_probe_status — polling endpoint for the
in-flight state of a triggered retailer probe.



256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
 
# File 'app/controllers/catalog_items_controller.rb', line 256

def retailer_probe_status
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :read, @catalog_item

  # Check for pending webhook logs for this catalog item
  pending_webhook = WebhookLog.where(state: 'pending', resource_type: 'CatalogItem', resource_id: @catalog_item.id)
                              .where(category: 'price_check')
                              .where(created_at: 10.minutes.ago..)
                              .order(created_at: :desc)
                              .first

  if pending_webhook
    render json: { status: 'pending', message: 'Waiting for webhook callback', started_at: pending_webhook.created_at }
  else
    # Check the latest probe result
    latest_probe = @catalog_item.retailer_probes.order(created_at: :desc).first

    # Only report a probe result if it was created AFTER any recent webhook was submitted
    # This prevents race conditions where we return a stale probe result before the new one completes
    last_webhook_for_item = WebhookLog.where(resource_type: 'CatalogItem', resource_id: @catalog_item.id)
                                      .where(category: 'price_check')
                                      .order(created_at: :desc)
                                      .first

    # If there's a webhook that was created after the latest probe, the probe result is stale
    # Return 'queued' to keep polling until new probe result arrives
    if last_webhook_for_item && latest_probe && last_webhook_for_item.created_at > latest_probe.created_at
      render json: { status: 'queued', message: 'Waiting for probe result' }
    elsif latest_probe && latest_probe.created_at > 10.minutes.ago
      render json: { status: latest_probe.status, price: latest_probe.price, updated_at: latest_probe.created_at }
    else
      render json: { status: 'none', message: 'No recent probes' }
    end
  end
end

#search ⇒ void

This method returns an undefined value.

GET /catalog_items/search — redirects to the catalog item matching a
sku in the current catalog.



318
319
320
321
322
323
324
325
326
327
 
# File 'app/controllers/catalog_items_controller.rb', line 318

def search
  sku = params.dig(:q, :sku_eq).presence
  if sku.present? && (@catalog_item = @catalog.catalog_items.by_skus(sku).first)
    authorize! :read, @catalog_item
    redirect_to catalog_item_path(@catalog_item)
  else
    flash[:error] = "Could not find an item with sku [#{sku}] in catalog"
    redirect_to catalog_path(@catalog)
  end
end

#send_amazon_listing_data ⇒ void

This method returns an undefined value.

POST /catalog_items/:id/send_amazon_listing_data — sends a PUT or PATCH
listing update to Amazon.



423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
 
# File 'app/controllers/catalog_items_controller.rb', line 423

def send_amazon_listing_data
  api_http_method = params[:listing].delete(:api_http_method)
  fbm_vs_fba = params[:listing].delete(:fbm_vs_fba) || 'FBM' # Default to FBM if not specified (non-FBA items)
  attribute_actions = params.dig(:listing, :action)&.to_h
  # attribute_actions = params["listing"].delete("attribute_actions")
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, @catalog_item
  res = if api_http_method == 'PUT'
          @catalog_item.amazon_send_put_listing_information(fbm_vs_fba:)
        else
          @catalog_item.amazon_send_patch_listing_information(attribute_actions:, fbm_vs_fba:)
        end
  flash[:info] = "Listing Message Sent for item. #{res[:status]}: #{res[:message]}"
  redirect_to catalog_item_path(@catalog_item)
end

#show ⇒ void

This method returns an undefined value.

GET /catalog_items/:id — a single catalog item, optionally refreshing
its rendered product specifications first.



49
50
51
52
53
54
55
56
57
 
# File 'app/controllers/catalog_items_controller.rb', line 49

def show
  @catalog_item = CatalogItem.includes(catalog: :parent_catalog).find(params[:id])
  if params[:refresh_specs].to_b
    @catalog_item.item.update_rendered_product_specifications(user_id: current_user.id)
    # Reload with associations to avoid N+1 in presenter
    @catalog_item = CatalogItem.includes(catalog: :parent_catalog).find(params[:id])
  end
  authorize! :read, @catalog_item
end

#show_amazon ⇒ void

This method returns an undefined value.

GET /catalog_items/:id/show_amazon — the Amazon listing detail tab page.



62
63
64
65
66
 
# File 'app/controllers/catalog_items_controller.rb', line 62

def show_amazon
  @catalog_item = CatalogItem.includes(catalog: :parent_catalog).find(params[:id])
  authorize! :read, @catalog_item
  render layout: should_render_layout?
end

#show_edi ⇒ void

This method returns an undefined value.

GET /catalog_items/:id/show_edi — the EDI detail tab page.



71
72
73
74
75
 
# File 'app/controllers/catalog_items_controller.rb', line 71

def show_edi
  @catalog_item = CatalogItem.includes(catalog: :parent_catalog).find(params[:id])
  authorize! :read, @catalog_item
  render layout: should_render_layout?
end

#show_siblings ⇒ void

This method returns an undefined value.

GET /catalog_items/:id/show_siblings — the sibling-catalog-items tab page.



106
107
108
109
110
 
# File 'app/controllers/catalog_items_controller.rb', line 106

def show_siblings
  @catalog_item = CatalogItem.includes(catalog: :parent_catalog).find(params[:id])
  authorize! :read, @catalog_item
  render layout: should_render_layout?
end

#show_wayfair ⇒ Object

Wayfair Actions



604
605
606
607
608
 
# File 'app/controllers/catalog_items_controller.rb', line 604

def show_wayfair
  @catalog_item = CatalogItem.includes(catalog: :parent_catalog).find(params[:id])
  authorize! :read, @catalog_item
  render layout: should_render_layout?
end

#tab_dependents ⇒ void

This method returns an undefined value.



161
162
163
164
165
166
167
168
 
# File 'app/controllers/catalog_items_controller.rb', line 161

def tab_dependents
  @catalog_item = CatalogItem.includes(:catalog).find(params[:id])
  authorize! :read, @catalog_item
  respond_to do |format|
    format.html { render layout: should_render_layout? }
    format.turbo_stream
  end
end

#tab_descriptions ⇒ void

This method returns an undefined value.



131
132
133
134
135
136
137
138
 
# File 'app/controllers/catalog_items_controller.rb', line 131

def tab_descriptions
  @catalog_item = CatalogItem.includes(:item).find(params[:id])
  authorize! :read, @catalog_item
  respond_to do |format|
    format.html { render layout: should_render_layout? }
    format.turbo_stream
  end
end

#tab_images ⇒ void

This method returns an undefined value.



151
152
153
154
155
156
157
158
 
# File 'app/controllers/catalog_items_controller.rb', line 151

def tab_images
  @catalog_item = CatalogItem.includes(:catalog, item: :image_profiles).find(params[:id])
  authorize! :read, @catalog_item
  respond_to do |format|
    format.html { render layout: should_render_layout? }
    format.turbo_stream
  end
end

#tab_main ⇒ Object

Tab actions for turbo-tabs lazy loading. Streamed pattern (PR #903) —
every tab serves both formats so in-pane interactions can target
tab_frame_id via turbo_stream.update.



115
116
117
118
119
120
121
122
123
124
125
126
127
128
 
# File 'app/controllers/catalog_items_controller.rb', line 115

def tab_main
  @catalog_item = CatalogItem.includes(
    :catalog,
    :coupon,
    :new_coupon,
    { store_items: { store: :warehouse_address } },
    { item: %i[product_category product_lines] }
  ).find(params[:id])
  authorize! :read, @catalog_item
  respond_to do |format|
    format.html { render layout: should_render_layout? }
    format.turbo_stream
  end
end

#tab_price_history ⇒ void

This method returns an undefined value.



178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
 
# File 'app/controllers/catalog_items_controller.rb', line 178

def tab_price_history
  @catalog_item = CatalogItem.includes(:catalog).find(params[:id])
  authorize! :read, @catalog_item

  price_keys_sql = PRICE_ATTRIBUTES.map { |a| "'#{a}'" }.join(', ')
  @price_versions = RecordVersion
                    .where(item_type: 'CatalogItem', item_id: @catalog_item.id)
                    .where("object_changes ?| array[#{price_keys_sql}]")
                    .order(created_at: :desc)
                    .limit(200)
  respond_to do |format|
    format.html { render layout: should_render_layout? }
    format.turbo_stream
  end
end

#tab_retailer_probes ⇒ void

This method returns an undefined value.



195
196
197
198
199
200
201
202
203
204
205
 
# File 'app/controllers/catalog_items_controller.rb', line 195

def tab_retailer_probes
  # No :retailer_probes preload — the probes table partial derives its own
  # ordered/limited collection (tab_listing), so a preloaded association would
  # be loaded and then thrown away.
  @catalog_item = CatalogItem.includes(:catalog).find(params.expect(:id))
  authorize! :read, @catalog_item
  respond_to do |format|
    format.html { render layout: should_render_layout? }
    format.turbo_stream
  end
end

#tab_sibling_retailers ⇒ void

This method returns an undefined value.



208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
 
# File 'app/controllers/catalog_items_controller.rb', line 208

def tab_sibling_retailers
  @catalog_item = CatalogItem.includes(:catalog, store_item: :item).find(params[:id])
  authorize! :read, @catalog_item

  # Find sibling catalog items: same item_id, same store_id (country), different catalog_id, active
  @sibling_catalog_items = CatalogItem
                           .includes(:catalog, :coupon, :new_coupon, store_item: { item: :product_category })
                           .joins(:catalog, store_item: :store)
                           .where(store_items: { item_id: @catalog_item.item.id })
                           .where(catalogs: { store_id: @catalog_item.catalog.store_id })
                           .where.not(catalog_id: @catalog_item.catalog_id)
                           .where(state: 'active')
                           .order('catalogs.name ASC')

  respond_to do |format|
    format.html { render layout: should_render_layout? }
    format.turbo_stream
  end
end

#tab_specs ⇒ void

This method returns an undefined value.



141
142
143
144
145
146
147
148
 
# File 'app/controllers/catalog_items_controller.rb', line 141

def tab_specs
  @catalog_item = CatalogItem.includes(item: :product_category).find(params[:id])
  authorize! :read, @catalog_item
  respond_to do |format|
    format.html { render layout: should_render_layout? }
    format.turbo_stream
  end
end

#trigger_retailer_probe ⇒ void

This method returns an undefined value.

POST /catalog_items/:id/trigger_retailer_probe — enqueues
RetailerProbeWorker for the catalog item's linked retailer.



232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
 
# File 'app/controllers/catalog_items_controller.rb', line 232

def trigger_retailer_probe
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :read, @catalog_item

  RetailerProbeWorker.perform_async(catalog_item_id: @catalog_item.id)

  respond_to do |format|
    format.html do
      flash[:success] = "Retailer probe queued for #{@catalog_item.sku}"
      # Costco probes resolve synchronously via its JSON APIs — there is no
      # Oxylabs webhook callback, so the dev tunnel is irrelevant for them.
      flash[:warning] = 'Development mode: Start the tunnel (script/dev_tunnel_api.sh) to receive webhook callbacks.' if Rails.env.development? && !@catalog_item.catalog.is_costco?
      redirect_to catalog_item_path(@catalog_item, tab: 'retailer_probes')
    end
    format.json do
      render json: { status: 'queued', message: "Retailer probe queued for #{@catalog_item.sku}" }
    end
  end
end

#update ⇒ void

This method returns an undefined value.

PATCH/PUT /catalog_items/:id — updates a catalog item via
Catalog::UpdateCatalogItem.



490
491
492
493
494
495
496
497
498
499
 
# File 'app/controllers/catalog_items_controller.rb', line 490

def update
  authorize! :update, CatalogItem
  result = Catalog::UpdateCatalogItem.new.process(params[:id], params[:catalog_item])
  @catalog_item = result.catalog_item
  if result.catalog_item_updated?
    redirect_to_return_path_or_default(catalog_item_path(@catalog_item), notice: result.messages.join(', '))
  else
    render :edit, status: :unprocessable_content
  end
end

#update_amazon ⇒ void

This method returns an undefined value.

PATCH/PUT /catalog_items/:id/update_amazon — updates Amazon listing
attributes via Catalog::UpdateCatalogItem.



90
91
92
93
94
95
96
97
98
99
100
101
 
# File 'app/controllers/catalog_items_controller.rb', line 90

def update_amazon
  authorize! :update, CatalogItem
  result = Catalog::UpdateCatalogItem.new.process(params[:id], params[:catalog_item])
  @catalog_item = result.catalog_item

  if result.catalog_item_updated?
    redirect_to_return_path_or_default(show_amazon_catalog_item_path(@catalog_item), notice: 'Catalog Item updated successfully')
  else
    set_image_ransack
    render :edit_amazon, status: :unprocessable_content
  end
end

#update_stores ⇒ void

This method returns an undefined value.

PATCH/PUT /catalog_items/:id/update_stores — updates the catalog item's
store mapping.



374
375
376
377
378
379
380
381
382
383
384
385
386
 
# File 'app/controllers/catalog_items_controller.rb', line 374

def update_stores
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, @catalog_item

  # Retrieve the selected store ids
  store_ids = (params.dig(:stores, :store_ids) || []).map(&:presence).filter_map(&:to_i).uniq
  @catalog_item.map_to_stores(store_ids)
  if @catalog_item.errors.present?
    render :edit_stores, status: :unprocessable_content
  else
    redirect_to catalog_item_path(@catalog_item, notice: 'Stores updated')
  end
end

#wayfair_listing_data ⇒ void

This method returns an undefined value.

GET /catalog_items/:id/wayfair_listing_data — the Wayfair listing-update
review form, with coverage/preview computed against the taxonomy schema.



662
663
664
665
666
667
668
669
670
671
672
673
674
 
# File 'app/controllers/catalog_items_controller.rb', line 662

def wayfair_listing_data
  @catalog_item = CatalogItem.find(params[:id])
  authorize! :update, @catalog_item

  orchestrator = Edi::Wayfair::Orchestrator.build(:wayfair_us)
  wayfair_schema = orchestrator.wayfair_schema_for(@catalog_item.wayfair_taxonomy_category_id_in_effect)

  @coverage = orchestrator.catalog_update_coverage(@catalog_item)
  @preview_result = orchestrator.preview_catalog_update(@catalog_item)

  # Build attributes list with metadata for the form
  @attributes_to_send = build_wayfair_attributes_list(@catalog_item, wayfair_schema, @preview_result)
end