require 'handsoap' # landslider gem main class class Landslider < Handsoap::Service require 'landslider/entities' LS_API_NAMESPACE='http://www.landslide.com/webservices/SoapService' LS_API_ENDPOINT ||= { :uri => "https://#{LS_INSTANCE_NAME}.api.landslide.com/webservices/SoapService", :version => 1 } DEFAULT_FIRST_RESULT_POSITION = 1 DEFAULT_TOTAL_RESULTS_REQUESTED = 25 endpoint LS_API_ENDPOINT attr_accessor :session_id # @param [Handsoap::XmlMason::Document] doc def on_create_document(doc) doc.alias 'urn', LS_API_NAMESPACE header = doc.find('Header') header.add('urn:SessionHeader') { |sh| sh.add('urn:sessionId', self.session_id) } end # @param [Handsoap::Http::Request] http_request def on_after_create_http_request(http_request) http_request.headers.merge!({'user-agent' => ['landslider-ruby-gem-version-0.4.6']}) end # @param [Object] response def on_http_error(response) puts response.inspect end # @param [String] session_id # @return [Hash] def login(session_id) self.session_id = session_id response = invoke('login', :soap_action => :none) do |message| message.add('wsUser') { |u| u.add 'username', ::LS_API_USERNAME u.add 'password', ::LS_API_KEY } end node = response.document.xpath('//ns:loginResponse/loginResponse', ns) parse_login_result(node) end # @param [WsAccountSearch] search # @param [String] session_id # @return [Hash] def get_accounts(session_id, search=WsSearch.new) self.session_id = session_id response = invoke('getAccounts', :soap_action => :none) do |message| message.add('accountsRequest') { |req| search.soapify_for(req) } end node = response.document.xpath('//ns:getAccountsResponse', ns) parse_get_accounts_result(node) end # @param [String] session_id # @param [Integer] account_id # @return [Hash] def get_account_by_id(session_id, account_id) self.session_id = session_id response = invoke('getAccountById', :soap_action => :none) do |message| message.add 'accountId', account_id end node = response.document.xpath('//ns:getAccountByIdResponse', ns) parse_get_account_by_id_result(node) end # @param [String] session_id # @param [Integer] account_id # @param [Boolean] is_primary # @return [Hash] def get_account_contacts(session_id, account_id, is_primary=false) self.session_id = session_id response = invoke('getAccountContacts', :soap_action => :none) do |message| message.add 'accountId', account_id message.add 'isPrimary', is_primary end node = response.document.xpath('//ns:getAccountContactsResponse', ns) parse_get_account_contacts_result(node) end # @param [String] session_id # @return [Hash] def get_account_custom_fields(session_id) response = invoke('getAccountCustomFields') node = response.document.xpath('//ns:getAccountCustomFieldsResponse', ns) parse_get_entity_custom_fields_result(node) end # @param [String] session_id # @param [WsSearch] search # @return [Hash] def get_account_notes(session_id, search) self.session_id = session_id response = invoke('getAccountNotes', :soap_action => :none) do |message| search.soapify_for(message) end node = response.document.xpath('//ns:getAccountNotesResponse', ns) parse_get_account_notes_result(node) end # @param [String] session_id # @return [Hash] def get_account_opportunities(session_id, account_id) self.session_id = session_id response = invoke('getAccountOpportunities', :soap_action => :none) do |message| message.add 'accountId', account_id end node = response.document.xpath('//ns:getAccountOpportunitiesResponse', ns) parse_get_account_opportunities_result(node) end # @param [String] session_id # @return [Hash] def get_account_types(session_id) self.session_id = session_id response = invoke('getAccountTypes') node = response.document.xpath('//ns:getAccountTypesResponse', ns) parse_get_account_types_result(node) end # @param [String] session_id # @return [Hash] def get_api_version(session_id) self.session_id = session_id response = invoke('getApiVersion', :soap_action => :none) node = response.document.xpath('//ns:getApiVersionResponse', ns) parse_api_version_result(node) end # @param [String] session_id # @param [Integer] contact_id # @return [Hash] def get_contact_by_id(session_id, contact_id) self.session_id = session_id response = invoke('getContactById', :soap_action => :none) do |message| message.add 'contactId', contact_id end node = response.document.xpath('//ns:getContactByIdResponse', ns) parse_get_contact_by_id_result(node) end # @param [String] session_id # @param [WsContactSearch] search # @return [Hash] def get_contacts(session_id, search=WsSearch.new) self.session_id = session_id # public WsContactResultSet getContacts(WsContactSearch request) response = invoke('getContacts', :soap_action => :none) do |message| message.add('contactsRequest') { |req| search.soapify_for(req) } end node = response.document.xpath('//ns:getContactsResponse', ns) parse_get_contacts_result(node) end # @param [String] session_id # @return [Hash] def get_contact_custom_fields(session_id) self.session_id = session_id response = invoke('getContactCustomFields') node = response.document.xpath('//ns:getContactCustomFieldsResponse', ns) parse_get_entity_custom_fields_result(node) end # @param [String] session_id # @param [WsSearch] search # @return [Hash] def get_contact_notes(session_id, search) self.session_id = session_id response = invoke('getContactNotes', :soap_action => :none) do |message| search.soapify_for(message) end node = response.document.xpath('//ns:getContactNotesResponse', ns) parse_get_contact_notes_result(node) end # @param [String] user_id # @param [String] session_id # @return [Hash] def get_instance_information(session_id, user_id) self.session_id = session_id response = invoke('getInstanceInformation', :soap_action => :none) do |message| message.add 'userId', user_id end node = response.document.xpath('//ns:getInstanceInformationResponse', ns) parse_get_instance_information_result(node) end # @param [String] session_id # @param [WsLeadSearch] search # @return [Hash] def get_leads(session_id, search=WsLeadSearch.new) self.session_id = session_id response = invoke('getLeads', :soap_action => :none) do |message| message.add('leadRequest') { |req| search.soapify_for(req) } end node = response.document.xpath('//ns:getLeadsResponse', ns) parse_get_leads_result(node) end # @param [String] session_id # @return [Hash] def get_lead_custom_fields(session_id) response = invoke('getLeadCustomFields') node = response.document.xpath('//ns:getLeadCustomFieldsResponse', ns) parse_get_entity_custom_fields_result(node) end # @param [String] session_id # @param [WsSearch] search # @return [Hash] def get_lead_notes(session_id, search) self.session_id = session_id response = invoke('getLeadNotes', :soap_action => :none) do |message| search.soapify_for(message) end node = response.document.xpath('//ns:getLeadNotesResponse', ns) parse_get_lead_notes_result(node) end # @param [WsOpportunitySearch] search # @param [String] session_id # @return [Hash] def get_opportunities(session_id, search=WsSearch.new) self.session_id = session_id response = invoke('getOpportunities', :soap_action => :none) do |message| message.add('opportunityRequest') { |req| search.soapify_for(req) } end node = response.document.xpath('//ns:getOpportunitiesResponse', ns) parse_get_opportunities_result(node) end # @param [String] session_id # @return [Hash] def get_opportunity_custom_fields(session_id) self.session_id = session_id response = invoke('getOpportunityCustomFields') node = response.document.xpath('//ns:getOpportunityCustomFieldsResponse', ns) parse_get_entity_custom_fields_result(node) end # @param [String] session_id # @param [WsSearch] search # @return [Hash] def get_opportunity_notes(session_id, search) self.session_id = session_id response = invoke('getOpportunityNotes', :soap_action => :none) do |message| search.soapify_for(message) end node = response.document.xpath('//ns:getOpportunityNotesResponse', ns) parse_get_opportunity_notes_result(node) end # @param [String] session_id # @param [String] user_id usually in the form of user@example.com # @return [Hash] def get_user_information(session_id, user_id) self.session_id = session_id response = invoke('getUserInformation', :soap_action => :none) do |message| message.add 'userId', user_id end node = response.document.xpath('//ns:getUserInformationResponse', ns) parse_get_user_information_by_id_result(node) end # @param [String] session_id # @param [Integer] user_id # @return [Hash] def get_user_information_by_id(session_id, user_id) self.session_id = session_id response = invoke('getUserInformationById', :soap_action => :none) do |message| message.add 'userId', user_id end node = response.document.xpath('//ns:getUserInformationByIdResponse', ns) parse_get_user_information_by_id_result(node) end # @param [String] session_id # @param [Integer] mylist_id # @return [Hash] def run_mylist_by_id(session_id, mylist_id) self.session_id = session_id response = invoke('runMyListbyId', :soap_action => :none) do |message| message.add 'myListId', mylist_id end node = response.document.xpath('//ns:runMyListbyIdResponse', ns) parse_run_mylist_by_id_result(node) end private def ns { 'ns' => LS_API_NAMESPACE, 'xsi' => 'http://www.w3.org/2001/XMLSchema-instance' } end def parse_login_result(node) { :error => xml_to_bool(node, './error/text()'), :error_code => xml_to_int(node, './errorCode/text()'), :result_msg => xml_to_str(node, './resultMsg/text()'), :status_code => xml_to_int(node, './statusCode/text()'), :password_expired => xml_to_bool(node, './passwordExpired/text()'), :session_id => xml_to_str(node, './sessionId/text()') } end def parse_api_version_result(node) { :internal_name => xml_to_str(node, '//ApiVersion/internalName/text()'), :label => xml_to_str(node, '//ApiVersion/label/text()'), :major_version => xml_to_int(node, '//ApiVersion/majorVersion/text()'), :minor_version => xml_to_int(node, '//ApiVersion/minorVersion/text()'), :revision_version => xml_to_int(node, '//ApiVersion/revisionVersion/text()') } end def parse_get_accounts_result(node) { :accounts => node.xpath('//Accounts/accountList', ns).map { |child| parse_account(child) }, :error => xml_to_bool(node, '//Accounts/error/text()'), :error_code => xml_to_int(node, '//Accounts/errorCode/text()'), :result_msg => xml_to_str(node, '//Accounts/resultMsg/text()'), :results_returned => xml_to_int(node, '//Accounts/resultsReturned/text()'), :total_results_available => xml_to_int(node, '//Accounts/totalResultsAvailable/text()') } end def parse_get_account_by_id_result(node) { :account => parse_account(node.xpath('./Account/account')), :error => xml_to_bool(node, './*/error/text()'), :error_code => xml_to_int(node, './*/errorCode/text()'), :result_msg => xml_to_str(node, './*/resultMsg/text()') } end def parse_get_account_notes_result(node) notes = parse_notes(node) { :error => xml_to_bool(node, './*/error/text()'), :error_code => xml_to_int(node, './*/errorCode/text()'), :result_msg => xml_to_str(node, './*/resultMsg/text()'), :status_code => xml_to_int(node, './*/statusCode/text()'), :results_returned => xml_to_int(node, './*/resultsReturned/text()'), :total_results_available => xml_to_int(node, './*/totalResultsAvailable/text()') }.merge(notes) end def parse_get_account_opportunities_result(node) { :opportunities => node.xpath('./*/opportunityList', ns).map { |child| parse_opportunity(child) }, :error => xml_to_bool(node, './*/error/text()'), :results_returned => xml_to_int(node, './*/resultsReturned/text()'), :total_results_available => xml_to_int(node, './*/totalResultsAvailable/text()') } end def parse_get_account_contacts_result(node) { :contacts => node.xpath('./*/contactList', ns).map { |child| parse_contact(child) }, :error => xml_to_bool(node, './*/error/text()'), :results_returned => xml_to_int(node, './*/resultsReturned/text()'), :total_results_available => xml_to_int(node, './*/totalResultsAvailable/text()') } end def parse_get_account_types_result(node) { :account_types => node.xpath('AccountTypes/accountTypes', ns).map { |child| parse_account_type(child) }, :error => xml_to_bool(node, 'AccountTypes/error/text()') } end def parse_get_contact_by_id_result(node) { :contact => parse_contact(node.xpath('Contact/contact')), :error => xml_to_bool(node, 'Contact/error/text()') } end def parse_get_contacts_result(node) { :contacts => node.xpath('./*/contactList', ns).map { |child| parse_contact(child) }, :error => xml_to_bool(node, './*/error/text()'), :results_returned => xml_to_int(node, './*/resultsReturned/text()'), :total_results_available => xml_to_int(node, './*/totalResultsAvailable/text()') } end def parse_get_contact_notes_result(node) notes = parse_notes(node) { :error => xml_to_bool(node, './*/error/text()'), :error_code => xml_to_int(node, './*/errorCode/text()'), :result_msg => xml_to_str(node, './*/resultMsg/text()'), :status_code => xml_to_int(node, './*/statusCode/text()'), :results_returned => xml_to_int(node, './*/resultsReturned/text()'), :total_results_available => xml_to_int(node, './*/totalResultsAvailable/text()') }.merge(notes) end def parse_get_entity_custom_fields_result(node) { :custom_fields => node.xpath('./*/customFields', ns).map { |child| parse_custom_field(child) }, :error => xml_to_bool(node, './*/error/text()'), :error_code => xml_to_int(node, './*/errorCode/text()'), :result_msg => xml_to_str(node, './*/resultMsg/text()'), :status_code => xml_to_int(node, './*/statusCode/text()') } end def parse_get_instance_information_result(node) { :address => parse_address(node.xpath('./*/address')), :company_name => xml_to_str(node, './*/companyName/text()'), :instance_url => xml_to_str(node, './*/instanceURL/text()'), :error => xml_to_bool(node, './*/error/text()'), :error_code => xml_to_int(node, './*/errorCode/text()'), :result_msg => xml_to_str(node, './*/resultMsg/text()'), :status_code => xml_to_int(node, './*/statusCode/text()') } end def parse_get_leads_result(node) leads = parse_leads(node) { :error => xml_to_bool(node, './*/error/text()'), :error_code => xml_to_int(node, './*/errorCode/text()'), :result_msg => xml_to_str(node, './*/resultMsg/text()'), :status_code => xml_to_int(node, './*/statusCode/text()'), :results_returned => xml_to_int(node, './*/resultsReturned/text()'), :total_results_available => xml_to_int(node, './*/totalResultsAvailable/text()') }.merge(leads) end def parse_get_lead_notes_result(node) notes = parse_notes(node) { :error => xml_to_bool(node, './Notes/error/text()'), :error_code => xml_to_int(node, './Notes/errorCode/text()'), :result_msg => xml_to_str(node, './Notes/resultMsg/text()'), :status_code => xml_to_int(node, './Notes/statusCode/text()'), :results_returned => xml_to_int(node, './Notes/resultsReturned/text()'), :total_results_available => xml_to_int(node, './Notes/totalResultsAvailable/text()') }.merge(notes) end def parse_get_opportunities_result(node) { :opportunities => node.xpath('./*/opportunityList', ns).map { |child| parse_opportunity(child) }, :error => xml_to_bool(node, './*/error/text()'), :error_code => xml_to_int(node, './*/errorCode/text()'), :result_msg => xml_to_str(node, './*/resultMsg/text()'), :status_code => xml_to_int(node, './*/statusCode/text()'), :results_returned => xml_to_int(node, './*/resultsReturned/text()'), :total_results_available => xml_to_int(node, './*/totalResultsAvailable/text()') } end def parse_get_opportunity_notes_result(node) notes = parse_notes(node) { :error => xml_to_bool(node, './*/error/text()'), :error_code => xml_to_int(node, './*/errorCode/text()'), :result_msg => xml_to_str(node, './*/resultMsg/text()'), :status_code => xml_to_int(node, './*/statusCode/text()'), :results_returned => xml_to_int(node, './*/resultsReturned/text()'), :total_results_available => xml_to_int(node, './*/totalResultsAvailable/text()') }.merge(notes) end def parse_get_user_information_by_id_result(node) { :employee => parse_employee(node.xpath('./WsEmployee/employee')), :error => xml_to_bool(node, './*/error/text()'), :error_code => xml_to_int(node, './*/errorCode/text()'), :result_msg => xml_to_str(node, './*/resultMsg/text()'), :status_code => xml_to_int(node, './*/statusCode/text()') } end def parse_run_mylist_by_id_result(node) { :results => node.xpath('MyListQueryResultSet/myList', ns).map { |child| parse_mylist_result(child) }, :error => xml_to_bool(node, 'MyListQueryResultSet/error/text()'), :results_returned => xml_to_int(node, 'MyListQueryResultSet/resultsReturned/text()'), :total_results_available => xml_to_int(node, 'MyListQueryResultSet/totalResultsAvailable/text()') } end # WsAccount def parse_account(node) { :entity_id => xml_to_str(node, './entityId/text()'), :entity_type => xml_to_str(node, './entityType/text()'), :parent_account_id => xml_to_str(node, './parentAccountId/text()'), :account_id => xml_to_str(node, './accountId/text()'), :account_name => xml_to_str(node, './accountName/text()'), :account_owner => xml_to_str(node, './accountOwner/text()'), :url => xml_to_str(node, './url/text()'), :phone => xml_to_str(node, './phone/text()'), :fax => xml_to_str(node, './fax/text()'), :main_address => parse_address(node.xpath('./mainAddress')), :shipping_address => parse_address(node.xpath('./shippingAddress')), :billing_address => parse_address(node.xpath('./billingAddress')), :updated_by => xml_to_int(node, './updatedBy/text()'), :updated_on => xml_to_str(node, './updatedOn/text()'), :created_by => xml_to_int(node, './createdBy/text()'), :created_on => xml_to_str(node, './createdOn/text()'), :archived_by => xml_to_str(node, './archivedBy/text()'), :account_type => xml_to_str(node, './accountType/accountType/text()'), :account_type_id => xml_to_int(node, './accountType/accountTypeId/text()'), :custom_fields => node.xpath('./customFields', ns).map { |child| parse_custom_field(child) } } end # WsAccountType def parse_account_type(node) { :account_type_id => xml_to_str(node, 'accountTypeId/text()'), :account_type => xml_to_str(node, 'accountType/text()') } end # WsAddress def parse_address(node) { :address => xml_to_str(node, './address1/text()'), :city => xml_to_str(node, './city/text()'), :state => xml_to_str(node, './state/text()'), :zip => xml_to_str(node, './zipPostal/text()'), :country => xml_to_str(node, './country/text()') } end # WsContact def parse_contact(node) { :first_name => xml_to_str(node, './firstName/text()'), :middle_initials => xml_to_str(node, './middleInitials/text()'), :last_name => xml_to_str(node, './lastName/text()'), :cell_phone => xml_to_str(node, './cellPhone/text()'), :work_phone => xml_to_str(node, './workPhone/text()'), :home_phone => xml_to_str(node, './homePhone/text()'), :email => xml_to_str(node, './email/text()'), :title => xml_to_str(node, './homePhone/text()'), :reports_to => xml_to_str(node, './reportsTo/text()'), :owner_id => xml_to_int(node, './ownerId/text()'), :contact_id => xml_to_int(node, './contactId/text()'), :custom_fields => node.xpath('./customFields', ns).map { |child| parse_custom_field(child) } } end # WsCustomField def parse_custom_field(node) { :custom_field_id => xml_to_int(node, './customFieldId/text()'), :custom_field_name => xml_to_str(node, './customFieldName/text()'), :custom_field_type => xml_to_str(node, './customFieldType/text()'), :custom_field_value => xml_to_str(node, './customFieldValue/customFieldValue/text()') } end # WsEmployee def parse_employee(node) { :employee_id => xml_to_int(node, './employeeId/text()'), :company_name => xml_to_str(node, './companyName/text()'), :first_name => xml_to_str(node, './firstName/text()'), :last_name => xml_to_str(node, './lastName/text()'), :email_address => xml_to_str(node, './emailAddress/text()'), :is_administrator => xml_to_bool(node, './isAdministrator/text()'), :office_phone => xml_to_str(node, './officePhone/text()'), :title => xml_to_str(node, './title/text()'), :user_id => xml_to_str(node, './userId/text()') } end def parse_notes(node) { :notes => node.xpath('./*/notes', ns).map { |child| parse_note(child) } } end # WsNote def parse_note(node) { :created_by => xml_to_int(node, './createdBy/text()'), :created_on => xml_to_date(node, './createdOn/text()'), :latest => xml_to_bool(node, './latest/text()'), :note_html => xml_to_str(node, './note/text()'), :note_id => xml_to_int(node, './noteId/text()'), :updated_on => xml_to_date(node, './updatedOn/text()'), } end def parse_leads(node) { :leads => node.xpath('./*/leadList', ns).map { |child| parse_lead(child) } } end # WsLead def parse_lead(node) { :account_id => xml_to_int(node, './accountId/text()'), :converted => xml_to_bool(node, './converted/text()'), :created_by => xml_to_int(node, './createdBy/text()'), :created_on => xml_to_date(node, './createdOn/text()'), :hot => xml_to_bool(node, './hot/text()'), :lead_id => xml_to_int(node, './leadId/text()'), :lead_rating => xml_to_str(node, './leadRating/rating/text()'), :lead_source => xml_to_str(node, './leadSource/source/text()'), :lead_status => xml_to_str(node, './leadStatus/status/text()'), :name => xml_to_str(node, './name/text()'), :ok_to_call => xml_to_bool(node, './okToCall/text()'), :ok_to_email => xml_to_bool(node, './okToEmail/text()'), :primary_owner_id => xml_to_int(node, './primaryOwnerId/text()'), :custom_fields => node.xpath('./customFields', ns).map { |child| parse_custom_field(child) } } end # There are two dynamic pieces of the mylist results # 1) A mylist result has type which is either WsAccount, WsContact, WsOpportunity, WsLead, WsNote, etc. # 2) The fields available in the mylist result are selected as fields to display when the user builds the mylist def parse_mylist_result(node) result_type = xml_to_str(node, '@xsi:type') case result_type when "ns2:wsContact" parse_contact(node) when "ns2:wsLead" parse_lead(node) when "ns2:wsOpportunity" parse_opportunity(node) else raise NotImplementedError.new result_type end end # WsOpportunity def parse_opportunity(node) { :account_id => xml_to_int(node, './accountId/text()'), :account_name => xml_to_str(node, './accountName/text()'), :confidence => xml_to_str(node, './confidence/text()'), :current_phase_name => xml_to_str(node, './currentPhaseName/text()'), :deal_value => xml_to_str(node, './dealValue/text()'), :description => xml_to_str(node, './description/text()'), :hot => xml_to_bool(node, './hot/text()'), :name => xml_to_str(node, './name/text()'), :opportunity_id => xml_to_int(node, './opportunityId/text()'), :opportunity_status => xml_to_str(node, './opportunityStatus/status/text()'), :primary_owner_id => xml_to_int(node, './primaryOwnerId/text()'), :selling_process => xml_to_str(node, './sellingProcess/sellingProcess/text()'), :selling_process_id => xml_to_int(node, './sellingProcess/sellingProcessId/text()'), :start_date => xml_to_date(node, './startDate/text()') } end end