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:, is_intercity_taxi: false) ⇒ Object 



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

def call(params:, vendor:, is_intercity_taxi: false)
  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
    trips = SpreeCmCommissioner::TripQuery.new(
      origin_id: origin_id(params),
      destination_id: destination_id(params),
      vendor_id: vendor.id,
      number_of_guests: params[:number_of_guests] || 1,
      date: search_date(params).to_date
    ).call

    is_intercity_taxi || taxi?(params) ? filter_intercity(trips) : trips
  end

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