lbry.com/lib/thirdparty/Salesforce.class.php

<?php

class Salesforce
{
  const
    API_URL = 'https://api.salesforceiq.com/v2/',
    DEFAULT_LIST_ID = '58387a94e4b0a1fea2c76f4a';

  protected static
    $curlOptions = [
      'headers' => ['Accept: application/json', 'Content-type: application/json'],
      'json_response' => true,
      'json_data' => true,
      'timeout' => 10
    ];

  public static function createContact(string $email, string $initialListId = null, string $acquisitionChannel = null)
  {
    $contactData = [
      'properties' => [
        'email' => [[
          'value' => $email,
          'metadata' => ['primary' => true]
        ]]
      ]
    ];

    $contactId = static::post('contacts?_upsert=email', $contactData)['id'] ?? null;

    if ($initialListId)
    {
      if (!$contactId)
      {
        throw new SalesforceException('Failed to generate or update contact');
      }

      static::post('lists/' . $initialListId . '/listitems?_upsert=contactIds', [
        'contactIds' => [$contactId],
        'fieldValues' => (object)[
          '2' => [['raw' => $acquisitionChannel]]
        ]
      ]);
    }
  }

  protected static function getApiUserPassword()
  {
    $userpw = Config::get('salesforce_key') . ':' . Config::get('salesforce_secret');
    if ($userpw[0] === ':' || substr($userpw, -1) === ':')
    {
      throw new SalesforceException('Salesforce key and/or secret not configured correctly');
    }
    return $userpw;
  }

  public static function get($endpoint, array $data = [])
  {
    $options = [
        'password' => static::getApiUserPassword(),
     ] + static::$curlOptions;

    $responseData = Curl::get(static::API_URL . $endpoint, $data, $options);

    return $responseData ?? [];
  }

  public static function post($endpoint, array $data = [], array $options = [])
  {
    $options += [
       'password' => static::getApiUserPassword(),
     ] + static::$curlOptions;

    $responseData = Curl::post(static::API_URL . $endpoint, $data, $options);
    return $responseData ?? [];
  }
}

class SalesforceException extends Exception
{
}