Class: SpreeCmCommissioner::Trips::Search

Inherits:
Object
  • Object
show all
Includes:
Spree::ServiceModule::Base
Defined in:
app/services/spree_cm_commissioner/trips/search.rb

Constant Summary collapse

REFRESH_RATE_LIMIT_INTERVAL = 
30.seconds
SEARCH_CACHE_TTL = 
5.minutes

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.cache_key_for(params, vendor) ⇒ Object 



9
10
11
 
# File 'app/services/spree_cm_commissioner/trips/search.rb', line 9

def self.cache_key_for(params, vendor)
  new.send(:cache_key, params, vendor)
end

Instance Method Details

#call(params:, vendor:) ⇒ Object 



13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
 
# File 'app/services/spree_cm_commissioner/trips/search.rb', line 13

def call(params:, vendor:)
  return success(results: []) unless valid_search?(params)

  cache_key = cache_key(params, vendor)

  results = Rails.cache.fetch(cache_key, expires_in: SEARCH_CACHE_TTL) do
    query_params = include_multi_leg?(params) ? { include_multi_leg: true } : {}

    trips = SpreeCmCommissioner::TripQuery.new(
      origin_id: origin_id(params),
      destination_id: destination_id(params),
      date: search_date(params).to_date,
      route_type: route_type(params),
      vendor_id: vendor.id,
      number_of_guests: params[:number_of_guests].present? ? params[:number_of_guests].to_i : 1,
      options: query_params
    ).call

    trips
  end

  success(results: results)
rescue StandardError => e
  failure(nil, e.message)
end