require 'json'
require 'active_support/core_ext/object/try'

module Leadsquared
  class Lead < ApiConnection
    SERVICE = '/v2/LeadManagement.svc/'.freeze

    def initialize
      super(SERVICE)
    end

    def get_meta_data
      url = url_with_service("LeadsMetaData.Get")
      response = connection.get(url, {})
      handle_response response
    end

    def get_lead_by_id(lead_id)
      url = url_with_service("Leads.GetById")
      response = connection.get(url, { id: lead_id })
      parsed_response = handle_response response
      parsed_response.first
    end

    def get_lead_by_email(email)
      url = url_with_service("Leads.GetByEmailaddress")
      response = connection.get(url, { emailaddress: email })
      parsed_response = handle_response response
      parsed_response.first
    end

    def quick_search(key)
      url = url_with_service("Leads.GetByQuickSearch")
      response = connection.get(url, {key: key})
      handle_response response
    end

    def create_lead(email, values_hash = {})
      url = url_with_service("Lead.Create")
      body = [
        {
          "Attribute": "EmailAddress",
          "Value": email
        }
      ]
      body += build_attributes values_hash
      response = connection.post(url, {}, body.to_json)
      parsed_response = handle_response response
      parsed_response["Message"]["Id"]
    end

    def update_lead(lead_id, values_hash = {})
      url = url_with_service("Lead.Update")
      body = build_attributes values_hash
      response = connection.post(url, {leadId: lead_id}, body.to_json)
      parsed_response = handle_response response
      parsed_response["Status"]
    end

    def create_or_update(email, values_hash = {})
      url = url_with_service("Lead.CreateOrUpdate")
      body = [
        {
          "Attribute": "EmailAddress",
          "Value": email
        },
        {
          "Attribute": "SearchBy",
          "Value": "EmailAddress"
        }
      ]
      body += build_attributes values_hash
      response = connection.post(url, {}, body.to_json)
      parsed_response = handle_response response
      parsed_response["Message"]["Id"]
    end

    def visitor_to_lead(prospect_id, values_hash = {})
      url = url_with_service('Lead.Convert')
      body = build_attributes values_hash
      response = connection.post(url, {leadId: prospect_id}, body.to_json)
      parsed_response = handle_response response
      parsed_response["Status"]
    end

    def capture_lead(values_hash = {})
      url = url_with_service('Lead.Capture')
      body = build_attributes values_hash
      response = connection.post(url, body.to_json)
      parsed_response = handle_response response
      parsed_response['Status']
    end

    private

    def build_attributes(values_hash)
      values_hash.map { |key, val| { 'Attribute' => key, 'Value' => val } }
    end
  end

end