module Constituents

  def get_constituent_snapshot(id, options={})
    options.merge!(basic_auth: @auth, headers: @headers)
    response = self.class.get(base_api_endpoint("CRM/Constituents/#{id}/Snapshot"), options)
    JSON.parse(response.body)
  end

  def create_constituent_by_snapshot(first_name, last_name, email, phone, constituent_type, source, street1, street2, city, state, zip, country, options={})
    parameters =
      {
        "ConstituentType": {
          "Id": constituent_type,
          "Inactive": false,
        },
        "FirstName": first_name,
        "LastName": last_name,
        "ElectronicAddress": {
          "Address": email,
          "ElectronicAddressType": {
            "Id": 1,
          },
          "AllowHtmlFormat": true,
          "Inactive": false,
          "AllowMarketing": false,
          "Months": 'YYYYYYYYYYYY',
          "PrimaryIndicator": true,
        },
        "PrimaryPhoneNumbers":
          [
            {
              "PhoneNumber": phone,
              "PhoneType":
                {
                  "Id": 1
                },
            },
          ],
        "OriginalSource": {
          "Id": source,
        },
        "Address": {
          "AddressType": {
            "Id": 3,
          },
          "City": city,
          "PostalCode": zip,
          "State": {
            "Id": state,
          },
          "Street1": street1,
          "Street2": street2,
          "Country": {
            "Id": country,
          },
        }
      }
    parameters.delete(:PrimaryPhoneNumbers) unless phone.present?
    options.merge!(basic_auth: @auth, headers: @headers)
    options.merge!(:body => parameters.to_json, :headers => { 'Content-Type' => 'application/json' })
    self.class.post(base_api_endpoint('CRM/Constituents/Snapshot'), options)
  end

  def update_constituent(constituent_id, params, options={})
    current = get_constituent_snapshot(constituent_id)
    if is_household?(current)
      update_household(params, current)
    else
      parameters =
        {
          "ConstituentType": {
            "Id": current['ConstituentType']['Id'],
            "Inactive": false,
          },
          "Id": constituent_id,
          "UpdatedDateTime": current['UpdatedDateTime'],
          "FirstName": params[:first_name],
          "LastName": params[:last_name],
          "MiddleName": params[:middle_name],
          "SortName": current['SortName'],
          "Prefix": {
            "Id": params[:prefix],
            "Inactive": false
          },
          "Suffix": {
            "Id": params[:suffix],
            "Inactive": false
          },
          "OriginalSource": {
            "Id": current['OriginalSource']['Id'],
            "Inactive": false
          },
        }
      parameters.delete(:Prefix) unless params[:prefix].present?
      parameters.delete(:Suffix) unless params[:suffix].present?
      options.merge!(basic_auth: @auth, headers: @headers)
      options.merge!(:body => parameters.to_json, :headers => { 'Content-Type' => 'application/json' })
      self.class.put(base_api_endpoint("CRM/Constituents/#{constituent_id}"), options)
    end
  end

  def is_household?(snapshot)
    snapshot['ConstituentType']['Id'] == 9
  end

  def update_household(params, current, options={})
    constituents = current['Affiliates'].map{|c| c['RelatedConstituentId']}
    constituents.each_with_index do |constituent, i|
      snapshot = get_constituent_snapshot(constituent)
      parameters =
        {
          "ConstituentType": {
            "Id": snapshot['ConstituentType']['Id'],
            "Inactive": false,
          },
          "Id": constituent,
          "FirstName": i == 0 ? params[:first_name] : params[:first_name_2],
          "UpdatedDateTime": snapshot['UpdatedDateTime'],
          "LastName": i == 0 ? params[:last_name] : params[:last_name_2],
          "MiddleName": i == 0 ? params[:middle_name] : params[:middle_name_2],
          "Prefix": {
            "Id": i == 0 ? params[:prefix] : params[:prefix_2],
            "Inactive": false
          },
          "Suffix": {
            "Id": i == 0 ? params[:suffix] : params[:suffix_2],
            "Inactive": false
          },
          "OriginalSource": {
            "Id": snapshot['OriginalSource']['Id'],
            "Inactive": false
          },
        }
      options.merge!(basic_auth: @auth, headers: @headers)
      options.merge!(:body => parameters)
      self.class.put(base_api_endpoint("CRM/Constituents/#{constituent}"), options)
    end
  end


end