Class: CloudRailSi::Services::Yelp

Inherits:
Object
  • Object
show all
Defined in:
lib/cloudrail_si/services/Yelp.rb

Constant Summary collapse

SERVICE_CODE = 
{
  
    "init" => [
      [ "create", "$P0.crToYelp", "Object"],
      [ "create", "$P0.yelpToCr", "Object"],
      [ "callFunc", "addCategory", "$P0", "airport", "airports"],
      [ "callFunc", "addCategory", "$P0", "amusement_park", "amusementparks"],
      [ "callFunc", "addCategory", "$P0", "aquarium", "aquariums"],
      [ "callFunc", "addCategory", "$P0", "art_gallery", "galleries"],
      [ "callFunc", "addCategory", "$P0", "bakery", "bakeries"],
      [ "callFunc", "addCategory", "$P0", "bank", "banks"],
      [ "callFunc", "addCategory", "$P0", "bar", "bars"],
      [ "callFunc", "addCategory", "$P0", "beauty_salon", "beautysvc"],
      [ "callFunc", "addCategory", "$P0", "bicycle_store", "bicycles"],
      [ "callFunc", "addCategory", "$P0", "book_store", "bookstores"],
      [ "callFunc", "addCategory", "$P0", "bowling_alley", "bowling"],
      [ "callFunc", "addCategory", "$P0", "bus_station", "buses"],
      [ "callFunc", "addCategory", "$P0", "cafe", "cafes"],
      [ "callFunc", "addCategory", "$P0", "car_dealer", "car_dealers"],
      [ "callFunc", "addCategory", "$P0", "car_rental", "carrental"],
      [ "callFunc", "addCategory", "$P0", "car_wash", "carwash"],
      [ "callFunc", "addCategory", "$P0", "casino", "casinos"],
      [ "callFunc", "addCategory", "$P0", "cemetery", "funeralservices"],
      [ "callFunc", "addCategory", "$P0", "church", "churches"],
      [ "callFunc", "addCategory", "$P0", "clothing_store", "fashion"],
      [ "callFunc", "addCategory", "$P0", "convenience_store", "convenience"],
      [ "callFunc", "addCategory", "$P0", "courthouse", "courthouses"],
      [ "callFunc", "addCategory", "$P0", "dentist", "dentists"],
      [ "callFunc", "addCategory", "$P0", "department_store", "deptstores"],
      [ "callFunc", "addCategory", "$P0", "doctor", "physicians"],
      [ "callFunc", "addCategory", "$P0", "electronics_store", "electronics"],
      [ "callFunc", "addCategory", "$P0", "embassy", "embassy"],
      [ "callFunc", "addCategory", "$P0", "finance", "financialservices"],
      [ "callFunc", "addCategory", "$P0", "fire_station", "firedepartments"],
      [ "callFunc", "addCategory", "$P0", "florist", "florists"],
      [ "callFunc", "addCategory", "$P0", "food", "food"],
      [ "callFunc", "addCategory", "$P0", "funeral_home", "funeralservices"],
      [ "callFunc", "addCategory", "$P0", "furniture_store", "furniture"],
      [ "callFunc", "addCategory", "$P0", "gas_station", "servicestations"],
      [ "callFunc", "addCategory", "$P0", "grocery_or_supermarket", "grocery"],
      [ "callFunc", "addCategory", "$P0", "gym", "gyms"],
      [ "callFunc", "addCategory", "$P0", "hardware_store", "hardware"],
      [ "callFunc", "addCategory", "$P0", "health", "health"],
      [ "callFunc", "addCategory", "$P0", "hindu_temple", "hindu_temples"],
      [ "callFunc", "addCategory", "$P0", "hospital", "hospitals"],
      [ "callFunc", "addCategory", "$P0", "jewelry_store", "jewelry"],
      [ "callFunc", "addCategory", "$P0", "laundry", "drycleaninglaundry"],
      [ "callFunc", "addCategory", "$P0", "lawyer", "lawyers"],
      [ "callFunc", "addCategory", "$P0", "library", "libraries"],
      [ "callFunc", "addCategory", "$P0", "locksmith", "locksmiths"],
      [ "callFunc", "addCategory", "$P0", "mosque", "mosques"],
      [ "callFunc", "addCategory", "$P0", "movie_theater", "movietheaters"],
      [ "callFunc", "addCategory", "$P0", "museum", "museums"],
      [ "callFunc", "addCategory", "$P0", "night_club", "danceclubs"],
      [ "callFunc", "addCategory", "$P0", "parks", "parks"],
      [ "callFunc", "addCategory", "$P0", "parking", "parking"],
      [ "callFunc", "addCategory", "$P0", "pet_store", "petstore"],
      [ "callFunc", "addCategory", "$P0", "pharmacy", "pharmacy"],
      [ "callFunc", "addCategory", "$P0", "physiotherapist", "physicaltherapy"],
      [ "callFunc", "addCategory", "$P0", "police", "policedepartments"],
      [ "callFunc", "addCategory", "$P0", "post_office", "postoffices"],
      [ "callFunc", "addCategory", "$P0", "real_estate_agency", "realestateagents"],
      [ "callFunc", "addCategory", "$P0", "restaurant", "restaurants"],
      [ "callFunc", "addCategory", "$P0", "rv_park", "rvparks"],
      [ "callFunc", "addCategory", "$P0", "school", "education"],
      [ "callFunc", "addCategory", "$P0", "shoe_store", "shoes"],
      [ "callFunc", "addCategory", "$P0", "shopping_mall", "shoppingcenters"],
      [ "callFunc", "addCategory", "$P0", "spa", "spas"],
      [ "callFunc", "addCategory", "$P0", "stadium", "stadiumsarenas"],
      [ "callFunc", "addCategory", "$P0", "synagogue", "synagogues"],
      [ "callFunc", "addCategory", "$P0", "taxi_stand", "taxis"],
      [ "callFunc", "addCategory", "$P0", "train_station", "trainstations"],
      [ "callFunc", "addCategory", "$P0", "travel_agency", "travelagents"],
      [ "callFunc", "addCategory", "$P0", "university", "collegeuniv"],
      [ "callFunc", "addCategory", "$P0", "veterinary_care", "vet"],
      [ "callFunc", "addCategory", "$P0", "zoo", "zoos"]
      
    ],
  
    "getNearbyPOIs" => [
      [ "callFunc", "checkNull", "$P0", "$P2", "Latitude"],
      [ "callFunc", "checkNull", "$P0", "$P3", "Longitude"],
      [ "callFunc", "checkNull", "$P0", "$P4", "Radius"],
      [ "callFunc", "checkLessThan", "$P0", "$P2", -90, "Latitude"],
      [ "callFunc", "checkLessThan", "$P0", "$P3", -180, "Longitude"],
      [ "callFunc", "checkLessThan", "$P0", "$P4", 0, "Radius"],
      [ "callFunc", "checkGreaterThan", "$P0", "$P2", 90, "Latitude"],
      [ "callFunc", "checkGreaterThan", "$P0", "$P3", 180, "Longitude"],
      [ "callFunc", "checkGreaterThan", "$P0", "$P4", 40000, "Radius"],
      [ "if!=than", "$P6", nil, 1],
      [ "callFunc", "checkIsEmpty", "$P0", "$P6", "Categories"],
      [ "create", "$L0", "Object"],
      [ "set", "$L0.method", "GET"],
      [ "set", "$L0.url", "https://api.yelp.com/v2/search"],
      [ "create", "$L1", "String", "?"],
      [ "string.concat", "$L1", "$L1", "ll=", "$P2", "%2C", "$P3"],
      [ "string.concat", "$L1", "$L1", "&radius_filter=", "$P4"],
      [ "if!=than", "$P5", nil, 2],
      [ "string.urlEncode", "$L2", "$P5"],
      [ "string.concat", "$L1", "$L1", "&term=", "$L2"],
      [ "if!=than", "$P6", nil, 3],
      [ "callFunc", "getCategoriesString", "$P0", "$L2", "$P6"],
      [ "string.urlEncode", "$L2", "$L2"],
      [ "string.concat", "$L1", "$L1", "&category_filter=", "$L2"],
      [ "create", "$L2", "Array"],
      [ "if!=than", "$P6", nil, 1],
      [ "push", "$L2", "category_filter"],
      [ "push", "$L2", "ll"],
      [ "push", "$L2", "oauth_consumer_key"],
      [ "push", "$L2", "oauth_nonce"],
      [ "push", "$L2", "oauth_signature_method"],
      [ "push", "$L2", "oauth_timestamp"],
      [ "push", "$L2", "oauth_token"],
      [ "push", "$L2", "oauth_version"],
      [ "push", "$L2", "radius_filter"],
      [ "if!=than", "$P5", nil, 1],
      [ "push", "$L2", "term"],
      [ "create", "$L3", "Object"],
      [ "string.concat", "$L3.ll", "$P2", ",", "$P3"],
      [ "string.concat", "$L3.radius_filter", "$P4", ""],
      [ "if!=than", "$P5", nil, 1],
      [ "set", "$L3.term", "$P5"],
      [ "if!=than", "$P6", nil, 1],
      [ "callFunc", "getCategoriesString", "$P0", "$L3.category_filter", "$P6"],
      [ "callFunc", "oAuth1:signRequest", "$P0", "$L0", "$L2", "$L3"],
      [ "string.concat", "$L0.url", "$L0.url", "$L1"],
      [ "http.requestCall", "$L2", "$L0"],
      [ "callFunc", "checkHttpResponse", "$P0", "$L2"],
      [ "json.parse", "$L3", "$L2.responseBody"],
      [ "create", "$P1", "Array"],
      [ "create", "$L4", "Number", 0],
      [ "size", "$L5", "$L3.businesses"],
      [ "if<than", "$L4", "$L5", 5],
      [ "get", "$L6", "$L3.businesses", "$L4"],
      [ "callFunc", "extractBusiness", "$P0", "$L7", "$L6"],
      [ "push", "$P1", "$L7"],
      [ "math.add", "$L4", "$L4", 1],
      [ "jumpRel", -6]
      
    ],
  
    "checkNull" => [
      [ "if==than", "$P1", nil, 3],
      [ "string.concat", "$L0", "$P2", " is not allowed to be null."],
      [ "create", "$L1", "Error", "$L0", "IllegalArgument"],
      [ "throwError", "$L1"]
      
    ],
  
    "checkLessThan" => [
      [ "if<than", "$P1", "$P2", 3],
      [ "string.concat", "$L0", "$P3", " is not allowed to be less than ", "$P2", "."],
      [ "create", "$L1", "Error", "$L0", "IllegalArgument"],
      [ "throwError", "$L1"]
      
    ],
  
    "checkGreaterThan" => [
      [ "if>than", "$P1", "$P2", 3],
      [ "string.concat", "$L0", "$P3", " is not allowed to be greater than ", "$P2", "."],
      [ "create", "$L1", "Error", "$L0", "IllegalArgument"],
      [ "throwError", "$L1"]
      
    ],
  
    "checkIsEmpty" => [
      [ "size", "$L0", "$P2"],
      [ "if==than", "$L0", 0, 3],
      [ "string.concat", "$L0", "$P3", " is not allowed to be empty."],
      [ "create", "$L1", "Error", "$L0", "IllegalArgument"],
      [ "throwError", "$L1"]
      
    ],
  
    "oAuth1:signRequest" => [
      [ "if==than", "$P1.requestHeaders", nil, 1],
      [ "create", "$P1.requestHeaders", "Object"],
      [ "create", "$L0", "Object"],
      [ "set", "$L0.oauth_consumer_key", "$P0.consumerKey"],
      [ "callFunc", "oAuth1:generateNonce", "$L0.oauth_nonce"],
      [ "set", "$L0.oauth_signature_method", "HMAC-SHA1"],
      [ "create", "$L1", "Date"],
      [ "math.multiply", "$L1", "$L1.Time", 0.001],
      [ "math.floor", "$L1", "$L1"],
      [ "string.format", "$L0.oauth_timestamp", "%d", "$L1"],
      [ "set", "$L0.oauth_token", "$P0.token"],
      [ "set", "$L0.oauth_version", "1.0"],
      [ "string.urlEncode", "$L2", "$P1.url"],
      [ "string.concat", "$L1", "$P1.method", "&", "$L2", "&"],
      [ "set", "$L2", ""],
      [ "set", "$L3", 0],
      [ "size", "$L4", "$P2"],
      [ "if<than", "$L3", "$L4", 12],
      [ "get", "$L5", "$P2", "$L3"],
      [ "if==than", "$L5", "oauth_callback", 1],
      [ "set", "$L0.oauth_callback", "$P0.redirectUri"],
      [ "get", "$L6", "$L0", "$L5"],
      [ "if>than", "$L3", 0, 1],
      [ "string.concat", "$L2", "$L2", "&"],
      [ "if==than", "$L6", nil, 1],
      [ "get", "$L6", "$P3", "$L5"],
      [ "string.urlEncode", "$L6", "$L6"],
      [ "string.concat", "$L2", "$L2", "$L5", "=", "$L6"],
      [ "math.add", "$L3", "$L3", 1],
      [ "jumpRel", -13],
      [ "string.urlEncode", "$L2", "$L2"],
      [ "string.concat", "$L1", "$L1", "$L2"],
      [ "set", "$L2", "$P0.tokenSecret"],
      [ "string.concat", "$L2", "$P0.consumerSecret", "&", "$L2"],
      [ "crypt.hmac.sha1", "$L2", "$L2", "$L1"],
      [ "array.uint8ToBase64", "$L2", "$L2"],
      [ "string.urlEncode", "$L2", "$L2"],
      [ "set", "$L0.oauth_signature", "$L2"],
      [ "set", "$L2", "OAuth "],
      [ "if!=than", "$L0.oauth_callback", nil, 2],
      [ "string.urlEncode", "$L3", "$L0.oauth_callback"],
      [ "string.concat", "$L2", "$L2", "oauth_callback", "=\"", "$L3", "\"", ", "],
      [ "string.concat", "$L2", "$L2", "oauth_consumer_key", "=\"", "$L0.oauth_consumer_key", "\""],
      [ "string.concat", "$L2", "$L2", ", ", "oauth_nonce", "=\"", "$L0.oauth_nonce", "\""],
      [ "string.concat", "$L2", "$L2", ", ", "oauth_signature", "=\"", "$L0.oauth_signature", "\""],
      [ "string.concat", "$L2", "$L2", ", ", "oauth_signature_method", "=\"", "$L0.oauth_signature_method", "\""],
      [ "string.concat", "$L2", "$L2", ", ", "oauth_timestamp", "=\"", "$L0.oauth_timestamp", "\""],
      [ "if!=than", "$L0.oauth_token", nil, 1],
      [ "string.concat", "$L2", "$L2", ", ", "oauth_token", "=\"", "$L0.oauth_token", "\""],
      [ "string.concat", "$L2", "$L2", ", ", "oauth_version", "=\"", "$L0.oauth_version", "\""],
      [ "set", "$P1.requestHeaders.Authorization", "$L2"]
      
    ],
  
    "oAuth1:generateNonce" => [
      [ "create", "$L0", "Date"],
      [ "string.format", "$L0", "%d", "$L0.Time"],
      [ "hash.md5", "$L0", "$L0"],
      [ "size", "$L1", "$L0"],
      [ "set", "$L2", 0],
      [ "set", "$P0", ""],
      [ "get", "$L3", "$L0", "$L2"],
      [ "string.format", "$L4", "%02x", "$L3"],
      [ "string.concat", "$P0", "$P0", "$L4"],
      [ "math.add", "$L2", "$L2", 1],
      [ "if>=than", "$L2", "$L1", -5]
      
    ],
  
    "checkHttpResponse" => [
      [ "if>=than", "$P1.code", 400, 9],
      [ "if==than", "$P2.code", 401, 2],
      [ "create", "$L3", "Error", "Invalid credentials or access rights. Make sure that your application has read and write permission.", "Authentication"],
      [ "throwError", "$L3"],
      [ "if==than", "$P2.code", 503, 2],
      [ "create", "$L3", "Error", "Service unavailable. Try again later.", "ServiceUnavailable"],
      [ "throwError", "$L3"],
      [ "json.parse", "$L0", "$P1.responseBody"],
      [ "create", "$L1", "Error", "$L0.error.description", "Http"],
      [ "throwError", "$L1"]
      
    ],
  
    "getCategoriesString" => [
      [ "create", "$P1", "String"],
      [ "create", "$L0", "Number", 0],
      [ "size", "$L1", "$P2"],
      [ "if<than", "$L0", "$L1", 10],
      [ "get", "$L2", "$P2", "$L0"],
      [ "get", "$L2", "$P0.crToYelp", "$L2"],
      [ "if==than", "$L2", nil, 2],
      [ "create", "$L3", "Error", "Unknown category.", "IllegalArgument"],
      [ "throwError", "$L3"],
      [ "if!=than", "$L0", 0, 1],
      [ "string.concat", "$P1", "$P1", ","],
      [ "string.concat", "$P1", "$P1", "$L2"],
      [ "math.add", "$L0", "$L0", 1],
      [ "jumpRel", -11]
      
    ],
  
    "extractBusiness" => [
      [ "create", "$L0", "Location"],
      [ "set", "$L0.latitude", "$P2.location.coordinate.latitude"],
      [ "set", "$L0.longitude", "$P2.location.coordinate.longitude"],
      [ "create", "$L1", "Array"],
      [ "create", "$L2", "Number", 0],
      [ "size", "$L3", "$P2.categories"],
      [ "if<than", "$L2", "$L3", 7],
      [ "get", "$L4", "$P2.categories", "$L2"],
      [ "get", "$L5", "$L4", 1],
      [ "get", "$L6", "$P0.yelpToCr", "$L5"],
      [ "if!=than", "$L6", nil, 1],
      [ "push", "$L1", "$L6"],
      [ "math.add", "$L2", "$L2", 1],
      [ "jumpRel", -8],
      [ "create", "$P1", "POI", "$L1", "$P2.image_url", "$L0", "$P2.name", "$P2.phone"]
      
    ],
  
    "addCategory" => [
      [ "set", "$P0.crToYelp", "$P2", "$P1"],
      [ "set", "$P0.yelpToCr", "$P1", "$P2"]
      
    ]
  
}

Instance Method Summary collapse

Constructor Details

#initialize(redirect_receiver, consumer_key, consumer_secret, token, token_secret) ⇒ Yelp

Returns a new instance of Yelp.



314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
 
# File 'lib/cloudrail_si/services/Yelp.rb', line 314

def initialize(redirect_receiver, consumer_key, consumer_secret, token, token_secret)
    @interpreter_storage = {}
    @persistent_storage = [{}]
    @instance_dependency_storage = {
        redirect_receiver: redirect_receiver
    }

    ServiceCode::InitSelfTest.init_test('Yelp')

    @interpreter_storage['consumerKey'] = consumer_key
    @interpreter_storage['consumerSecret'] = consumer_secret
    @interpreter_storage['token'] = token
    @interpreter_storage['tokenSecret'] = token_secret
    

    

    # call init servicecode function
    ip = ServiceCode::Interpreter.new(ServiceCode::Sandbox.new(SERVICE_CODE, @persistent_storage, @instance_dependency_storage))
    # check and call the initialization function if is available

    ip.call_function_sync('init', @interpreter_storage) if (SERVICE_CODE['init'])
end

Instance Method Details

#check_for_error(error) ⇒ Object 



338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
 
# File 'lib/cloudrail_si/services/Yelp.rb', line 338

def check_for_error(error)
  if (error)
    ServiceCode::Statistics.add_error('Yelp', '')
    case (error.type)
    when 'IllegalArgument'
      raise Errors::IllegalArgumentError.new(error.message)
    when 'Authentication'
      raise Errors::AuthenticationError.new(error.message)
    when 'NotFound'
      raise Errors::NotFoundError.new(error.message)
    when 'Http'
      raise Errors::HttpError.new(error.message)
    when 'ServiceUnavailable'
      raise Errors::ServiceUnavailableError.new(error.message)
    else
      raise Errors::StandardError.new(error.message)
    end
  end
end

#get_nearby_pois(latitude, longitude, radius, search_term, categories) ⇒ Object 



359
360
361
362
363
364
365
366
 
# File 'lib/cloudrail_si/services/Yelp.rb', line 359

def get_nearby_pois(latitude, longitude, radius, search_term, categories)
  ServiceCode::Statistics.add_call('Yelp', 'get_nearby_pois')
  ip = ServiceCode::Interpreter.new(ServiceCode::Sandbox.new(SERVICE_CODE, @persistent_storage, @instance_dependency_storage))
  ip.call_function('getNearbyPOIs', @interpreter_storage, nil, latitude, longitude, radius, search_term, categories)

  check_for_error(ip.sandbox.thrown_error)
  return nil || ip.get_parameter(1)
end

#load_as_string(saved_state) ⇒ Object 



374
375
376
377
378
379
 
# File 'lib/cloudrail_si/services/Yelp.rb', line 374

def load_as_string(saved_state)
	sandbox = ServiceCode::Sandbox.new(SERVICE_CODE, @persistent_storage, @instance_dependency_storage)
	ip = ServiceCode::Interpreter.new(sandbox)
	ip.load_as_string(saved_state)
	@persistent_storage = sandbox.persistent_storage
end

#resume_login(execution_state, callback) ⇒ Object 



381
382
383
384
385
386
 
# File 'lib/cloudrail_si/services/Yelp.rb', line 381

def (execution_state, callback)
  sandbox = ServiceCode::Sandbox.new(SERVICE_CODE, @persistent_storage, @instance_dependency_storage)
  sandbox.load_state_from_string(execution_state)
  ip = ServiceCode::Interpreter.new(sandbox)
  ip.resume_function('Authenticating:login', @interpreter_storage, callback)
end

#save_as_string ⇒ Object 



369
370
371
372
 
# File 'lib/cloudrail_si/services/Yelp.rb', line 369

def save_as_string
	ip = ServiceCode::Interpreter.new(ServiceCode::Sandbox.new(SERVICE_CODE, @persistent_storage, @instance_dependency_storage))
	return ip.save_as_string()
end