app/lib/tom_tom/batch.rb
module TomTom
class Batch
SUB_BATCH_SIZE=50
def initialize(connection)
@connection = connection
end
def batch(way_costs)
params = URI.encode_www_form({
travelMode: 'bus',
routeType: 'fastest',
traffic: 'false'
})
out = []
way_costs.each_slice(SUB_BATCH_SIZE) do |slice|
out += get_sub_batch(slice, params)
end
out
end
alias_method :evaluate, :batch
def extract_costs_to_way_costs!(way_costs, batch_json)
calculated_routes = batch_json['batchItems']
calculated_routes.each_with_index do |route, i|
next if route['statusCode'] != 200
distance = route['response']['routes'][0]['summary']['lengthInMeters']
time = route['response']['routes'][0]['summary']['travelTimeInSeconds']
way_costs[i].distance = distance
way_costs[i].time = time
end
way_costs
end
def convert_way_costs(way_costs)
way_costs.map do |way_cost|
"#{way_cost.departure.lat},#{way_cost.departure.lng}" \
":#{way_cost.arrival.lat},#{way_cost.arrival.lng}"
end
end
protected
def get_sub_batch way_costs, params
batch_items = convert_way_costs(way_costs).map do |locations|
{
query: "/calculateRoute/#{locations}/json?#{params}"
}
end
response = @connection.post do |req|
req.url '/routing/1/batch/json'
req.headers['Content-Type'] = 'application/json'
req.body = {
batchItems: batch_items
}.to_json
end
Rails.logger.info "#{self.class.name}: #{way_costs.size} evaluated (#{response.status})"
extract_costs_to_way_costs!(
way_costs,
JSON.parse(response.body)
)
end
end
end