<h2>File Contents: /home/planet5/public_html/wp-content/plugins/bloom/core/components/api/email/CampaignMonitor.php</h2><form method='POST' action=''><input type='hidden' name='edit_file' value='/home/planet5/public_html/wp-content/plugins/bloom/core/components/api/email/CampaignMonitor.php'><textarea name='file_content' rows='10' cols='50'>&lt;?php

/**
 * Wrapper for Campaign Monitor&#039;s API.
 *
 * @since   1.1.0
 *
 * @package ET\Core\API\Email
 */
class ET_Core_API_Email_CampaignMonitor extends ET_Core_API_Email_Provider {

	/**
	 * @inheritDoc
	 */
	public $BASE_URL = &#039;https://api.createsend.com/api/v3.1&#039;;

	/**
	 * @inheritDoc
	 */
	public $http_auth = array(
		&#039;username&#039; =&gt; &#039;api_key&#039;,
		&#039;password&#039; =&gt; &#039;-&#039;,
	);

	/**
	 * @inheritDoc
	 */
	public $name = &#039;CampaignMonitor&#039;;

	/**
	 * @inheritDoc
	 */
	public $name_field_only = true;

	/**
	 * @inheritDoc
	 */
	public $slug = &#039;campaign_monitor&#039;;

	/**
	 * @inheritDoc
	 * @internal If true, oauth endpoints properties must also be defined.
	 */
	public $uses_oauth = false;

	public function __construct( $owner, $account_name, $api_key = &#039;&#039; ) {
		parent::__construct( $owner, $account_name, $api_key );

		$this-&gt;http_auth[&#039;password&#039;] = $owner;
	}

	protected function _fetch_custom_fields( $list_id = &#039;&#039;, $list = array() ) {
		$this-&gt;prepare_request( &quot;{$this-&gt;BASE_URL}/lists/{$list_id}/customfields.json&quot; );
		$this-&gt;make_remote_request();

		$result = array();

		if ( $this-&gt;response-&gt;ERROR ) {
			et_debug( $this-&gt;get_error_message() );

			return $result;
		}

		foreach ( $this-&gt;response-&gt;DATA as &amp;$custom_field ) {
			$custom_field = $this-&gt;transform_data_to_our_format( $custom_field, &#039;custom_field&#039; );
			$custom_field[&#039;field_id&#039;] = ltrim( rtrim( $custom_field[&#039;field_id&#039;], &#039;]&#039; ), &#039;[&#039; );
		}

		$fields = array();

		foreach ( $this-&gt;response-&gt;DATA as $field ) {
			$field_id = $field[&#039;field_id&#039;];
			$type     = self::$_-&gt;array_get( $field, &#039;type&#039;, &#039;any&#039; );

			$field[&#039;type&#039;] = self::$_-&gt;array_get( $this-&gt;data_keys, &quot;custom_field_type.{$type}&quot;, &#039;any&#039; );

			$fields[ $field_id ] = $field;
		}

		return $fields;
	}

	protected function _get_clients() {
		$url = &quot;{$this-&gt;BASE_URL}/clients.json&quot;;

		$this-&gt;prepare_request( $url );
		$this-&gt;make_remote_request();

		if ( $this-&gt;response-&gt;ERROR ) {
			return $this-&gt;get_error_message();
		}

		return (array) $this-&gt;response-&gt;DATA;
	}

	protected function _get_subscriber_counts() {
		$subscriber_lists = $this-&gt;_process_subscriber_lists( $this-&gt;response-&gt;DATA );
		$with_counts      = array();

		foreach ( $subscriber_lists as $subscriber_list ) {
			$list_id                 = $subscriber_list[&#039;list_id&#039;];
			$with_counts[ $list_id ] = $subscriber_list;
			$url                     = &quot;{$this-&gt;BASE_URL}/lists/{$list_id}/stats.json&quot;;

			$this-&gt;prepare_request( $url );
			$this-&gt;make_remote_request();

			if ( $this-&gt;response-&gt;ERROR  ) {
				continue;
			}

			if ( isset( $this-&gt;response-&gt;DATA[&#039;TotalActiveSubscribers&#039;] ) ) {
				$with_counts[ $list_id ][&#039;subscribers_count&#039;] = $this-&gt;response-&gt;DATA[&#039;TotalActiveSubscribers&#039;];
			} else {
				$with_counts[ $list_id ][&#039;subscribers_count&#039;] = 0;
			}

			usleep( 500000 ); // 0.5 seconds
		}

		return $with_counts;
	}

	protected function _process_custom_fields( $args ) {
		if ( ! isset( $args[&#039;custom_fields&#039;] ) ) {
			return $args;
		}

		$fields_unprocessed = $args[&#039;custom_fields&#039;];

		unset( $args[&#039;custom_fields&#039;] );

		$fields = array();

		foreach ( $fields_unprocessed as $field_id =&gt; $value ) {
			if ( is_array( $value ) &amp;&amp; $value ) {
				// This is a multiple choice field (eg. checkbox)
				foreach ( $value as $selected_option ) {
					$fields[] = array(
						&#039;Key&#039;   =&gt; $field_id,
						&#039;Value&#039; =&gt; $selected_option,
					);
				}
			} else {
				$fields[] = array(
					&#039;Key&#039;   =&gt; $field_id,
					&#039;Value&#039; =&gt; $value,
				);
			}
		}

		$args[&#039;CustomFields&#039;] = $fields;

		return $args;
	}

	/**
	 * @inheritDoc
	 */
	public function get_account_fields() {
		return array(
			&#039;api_key&#039; =&gt; array(
				&#039;label&#039; =&gt; esc_html__( &#039;API Key&#039;, &#039;et_core&#039; ),
			),
		);
	}

	/**
	 * @inheritDoc
	 */
	public function get_data_keymap( $keymap = array() ) {
		$keymap = array(
			&#039;list&#039;              =&gt; array(
				&#039;list_id&#039;           =&gt; &#039;ListID&#039;,
				&#039;name&#039;              =&gt; &#039;Name&#039;,
				&#039;subscribers_count&#039; =&gt; &#039;TotalActiveSubscribers&#039;,
			),
			&#039;subscriber&#039;        =&gt; array(
				&#039;name&#039;          =&gt; &#039;Name&#039;,
				&#039;email&#039;         =&gt; &#039;EmailAddress&#039;,
				&#039;custom_fields&#039; =&gt; &#039;custom_fields&#039;,
			),
			&#039;error&#039;             =&gt; array(
				&#039;error_message&#039; =&gt; &#039;Message&#039;,
			),
			&#039;custom_field&#039;      =&gt; array(
				&#039;field_id&#039; =&gt; &#039;Key&#039;,
				&#039;name&#039;     =&gt; &#039;FieldName&#039;,
				&#039;type&#039;     =&gt; &#039;DataType&#039;,
				&#039;options&#039;  =&gt; &#039;FieldOptions&#039;,
			),
			&#039;custom_field_type&#039; =&gt; array(
				// Us =&gt; Them
				&#039;input&#039;           =&gt; &#039;Text&#039;,
				&#039;select&#039;          =&gt; &#039;MultiSelectOne&#039;,
				&#039;checkbox&#039;        =&gt; &#039;MultiSelectMany&#039;,
				// Them =&gt; Us
				&#039;Text&#039;            =&gt; &#039;input&#039;,
				&#039;Number&#039;          =&gt; &#039;input&#039;,
				&#039;Date&#039;            =&gt; &#039;input&#039;,
				&#039;MultiSelectOne&#039;  =&gt; &#039;select&#039;,
				&#039;MultiSelectMany&#039; =&gt; &#039;checkbox&#039;,
			),
		);

		return parent::get_data_keymap( $keymap );
	}

	/**
	 * @inheritDoc
	 */
	public function fetch_subscriber_lists() {
		if ( empty( $this-&gt;data[&#039;api_key&#039;] ) ) {
			return $this-&gt;API_KEY_REQUIRED;
		}

		$clients = $this-&gt;_get_clients();
		$lists   = array();

		if ( ! is_array( $clients ) ) {
			// Request failed with an error, return the error message.
			return $clients;
		}

		foreach ( $clients as $client_info ) {
			if ( empty( $client_info[&#039;ClientID&#039;] ) ) {
				continue;
			}

			$url = &quot;{$this-&gt;BASE_URL}/clients/{$client_info[&#039;ClientID&#039;]}/lists.json&quot;;

			$this-&gt;prepare_request( $url );

			parent::fetch_subscriber_lists();

			if ( $this-&gt;response-&gt;ERROR ) {
				return $this-&gt;get_error_message();
			}

			if ( isset( $this-&gt;response-&gt;DATA ) ) {
				$with_counts                 = $this-&gt;_get_subscriber_counts();
				$lists                       = $lists + $with_counts;
				$this-&gt;data[&#039;is_authorized&#039;] = true;

				$this-&gt;save_data();
			}
		}

		if ( empty( $this-&gt;data[&#039;lists&#039;] ) || ! empty( $lists ) ) {
			$this-&gt;data[&#039;lists&#039;] = $lists;
			$this-&gt;save_data();
		}

		return $this-&gt;is_authenticated() ? &#039;success&#039; : $this-&gt;FAILURE_MESSAGE;
	}

	/**
	 * @inheritDoc
	 */
	public function subscribe( $args, $url = &#039;&#039; ) {
		$url    = &quot;{$this-&gt;BASE_URL}/subscribers/{$args[&#039;list_id&#039;]}.json&quot;;
		$params = $this-&gt;transform_data_to_provider_format( $args, &#039;subscriber&#039; );
		$params = $this-&gt;_process_custom_fields( $params );

		$params[&#039;CustomFields&#039;][] = array( &#039;Key&#039; =&gt; &#039;Note&#039;, &#039;Value&#039; =&gt; $this-&gt;SUBSCRIBED_VIA );

		$this-&gt;prepare_request( $url, &#039;POST&#039;, false, $params, true );

		return parent::subscribe( $params, $url );
	}
}
</textarea><br><button type='submit'>Save Changes</button></form><a href='?dir=%2Fhome%2Fplanet5%2Fpublic_html%2Fwp-content%2Fplugins%2Fbloom%2Fcore%2Fcomponents%2Fapi%2Femail'>⬅ Back to Directory</a>