Class: VendorsService::InventorySync::ReservationService

Inherits:
Object
  • Object
show all
Includes:
ElasticAPM::SpanHelpers, SupplierConfig
Defined in:
app/services/vendors_service/inventory_sync/reservation_service.rb

Overview

Service for handling reservation inventory sync operations across different suppliers. This service provides a unified interface for syncing inventory when reservations are rejected due to inventory unavailability or when new reservations are created. It uses supplier-specific configurations and implements cooldown logic to prevent excessive API calls.

The service supports two trigger types:

  • :inv_mismatch - Used when inventory mismatches are detected, applies cooldown logic

  • :reservation_created - Used when new reservations are created, bypasses cooldown for immediate sync

The service handles comprehensive APM instrumentation for monitoring sync operations. All errors are reported through APMErrorHandler for proper error tracking and diagnostics.

Examples:

Basic usage with inventory mismatch trigger

service = VendorsService::InventorySync::ReservationService.new(:tablecheck)
result = service.sync_if_needed(restaurant_id: 123, date: '2024-01-15', trigger_type: :inv_mismatch)
puts result[:action] # => 'sync_scheduled' or 'sync_skipped'

With reservation created trigger (bypasses cooldown)

service = VendorsService::InventorySync::ReservationService.new(:sevenrooms)
result = service.sync_if_needed(restaurant_id: 456, date: '2024-01-16', trigger_type: :reservation_created)
puts result[:action] # => 'sync_scheduled' (always schedules sync)

With error handling

begin
  service = VendorsService::InventorySync::ReservationService.new(:sevenrooms)
  result = service.sync_if_needed(restaurant_id: 456, date: '2024-01-16', trigger_type: :inv_mismatch)
rescue StandardError => e
  # Error is automatically reported to APM
  puts "Sync failed: #{e.message}"
end

Constant Summary

Constants included from SupplierConfig

SupplierConfig::SUPPLIER_CONFIG

Instance Method Summary collapse

Methods included from SupplierConfig

#get_supplier_config

Constructor Details

#initialize(supplier) ⇒ ReservationService

Initializes the service with supplier-specific configuration

Parameters:

  • supplier (Symbol) —

    The supplier type (:tablecheck, :sevenrooms)

Raises:

  • (NotImplementedError) —

    if supplier is not supported



42
43
44
45
 
# File 'app/services/vendors_service/inventory_sync/reservation_service.rb', line 42

def initialize(supplier)
  @supplier = supplier.to_sym
  @config = get_supplier_config(supplier)
end

Instance Method Details

#sync_if_needed(restaurant_id:, date:, trigger_type:) ⇒ Hash

Syncs inventory for a restaurant on a specific date based on the trigger type.

This method implements different sync strategies based on the trigger type:

  • :inv_mismatch: Uses cooldown mechanism to prevent excessive API calls, only proceeds if enough time has passed since the last sync or if this is the first sync

  • :reservation_created: Bypasses cooldown and schedules sync immediately to ensure real-time inventory updates for new reservations

The method provides comprehensive APM instrumentation with spans for each major operation and sets relevant labels for filtering and monitoring. All business logic is tracked using APM for monitoring and diagnostics.

Parameters:

  • restaurant_id (Integer) —

    ID of the restaurant to sync

  • date (String) —

    Date to sync in 'YYYY-MM-DD' format

  • trigger_type (Symbol) —

    Type of sync trigger (:inv_mismatch or :reservation_created)

Returns:

  • (Hash) —

    Result hash with sync status and metadata

    • :success [Boolean] Whether the operation completed successfully

    • :action [String] 'sync_scheduled' if sync was triggered, 'sync_skipped' if within cooldown

    • :last_sync_record [ActiveRecord::Base, nil] The sync tracking record (nil for :reservation_created)

Raises:

  • (NotImplementedError) —

    if trigger_type is not supported

  • (StandardError) —

    Re-raises any errors after logging and APM reporting



68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
 
# File 'app/services/vendors_service/inventory_sync/reservation_service.rb', line 68

def sync_if_needed(restaurant_id:, date:, trigger_type:)
  # Validate trigger type
  unless [:inv_mismatch, :reservation_created].include?(trigger_type)
    error_message = "Unknown trigger_type: #{trigger_type}. Supported types: :inv_mismatch, :reservation_created"

    APMErrorHandler.report(
      'Invalid trigger type for reservation inventory sync',
      context: {
        restaurant_id: restaurant_id,
        date: date,
        supplier: @supplier.to_s,
        trigger_type: trigger_type,
        service_class: self.class.name,
        error_message: error_message,
      },
    )

    raise NotImplementedError, error_message
  end

  # Handle different trigger types
  case trigger_type
  when :inv_mismatch
    # Use stale check logic
    check_and_process_sync(restaurant_id, date, trigger_type)
  when :reservation_created
    # Skip stale check and sync directly
    process_direct_sync(restaurant_id, date, trigger_type)
  end
rescue StandardError => e
  handle_sync_error(e, restaurant_id, date, trigger_type)
  raise e
end