Server IP : 85.214.239.14 / Your IP : 3.15.10.139 Web Server : Apache/2.4.62 (Debian) System : Linux h2886529.stratoserver.net 4.9.0 #1 SMP Tue Jan 9 19:45:01 MSK 2024 x86_64 User : www-data ( 33) PHP Version : 7.4.18 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_get_handler,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,pcntl_async_signals,pcntl_unshare, MySQL : OFF | cURL : OFF | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : OFF Directory : /var/www/wordpress/wp-content/themes/Divi/core/components/api/email/ |
Upload File : |
<?php /** * Wrapper for ConstantContact's API. * * @since 3.0.75 * * @package ET\Core\API\Email */ class ET_Core_API_Email_ConstantContact extends ET_Core_API_Email_Provider { /** * @inheritDoc */ public $BASE_URL = 'https://api.constantcontact.com/v2'; /** * @inheritDoc */ public $LISTS_URL = 'https://api.constantcontact.com/v2/lists'; /** * @inheritDoc */ public $SUBSCRIBE_URL = 'https://api.constantcontact.com/v2/contacts'; /** * @inheritDoc */ public $SUBSCRIBERS_URL = 'https://api.constantcontact.com/v2/contacts'; protected $_subscriber; /** * @inheritDoc */ public $custom_fields_scope = 'account'; /** * @inheritDoc */ public $name = 'ConstantContact'; /** * @inheritDoc */ public $slug = 'constant_contact'; /** * ET_Core_API_Email_ConstantContact constructor. * * @inheritDoc */ public function __construct( $owner = '', $account_name = '', $api_key = '' ) { parent::__construct( $owner, $account_name, $api_key ); $this->_maybe_set_custom_headers(); } protected function _create_subscriber_data_array( $args ) { return $this->transform_data_to_provider_format( $args, 'subscriber' ); } protected function _fetch_custom_fields( $list_id = '', $list = array() ) { $fields = array(); foreach ( range( 1, 15 ) as $i ) { $fields["custom_field_{$i}"] = array( 'field_id' => "custom_field_{$i}", 'name' => "custom_field_{$i}", 'type' => 'any', ); } return $fields; } protected function _get_list_from_subscriber( $subscriber, $list_id ) { if ( ! isset( $subscriber['lists'] ) ) { return false; } foreach ( $subscriber['lists'] as &$list ) { if ( $list['id'] === $list_id ) { return $list; } } return false; } protected function _maybe_set_custom_headers() { if ( empty( $this->custom_headers ) && isset( $this->data['token'] ) ) { $this->custom_headers = array( 'Authorization' => 'Bearer ' . sanitize_text_field( $this->data['token'] ), ); } } protected function _process_custom_fields( $args ) { if ( ! isset( $args['custom_fields'] ) ) { return $args; } $fields = $args['custom_fields']; $processed_fields = array(); unset( $args['custom_fields'], $this->_subscriber['custom_fields_unprocessed'] ); foreach ( $fields as $field_id => $value ) { if ( is_array( $value ) && $value ) { // This is a multiple choice field (eg. checkbox, radio, select) $value = array_values( $value ); if ( count( $value ) > 1 ) { $value = implode( ',', $value ); } else { $value = array_pop( $value ); } } $processed_fields[] = array( 'name' => $field_id, 'value' => $value, ); } if ( isset( $this->_subscriber['custom_fields'] ) ) { $processed_fields = array_merge( $processed_fields, $this->_subscriber['custom_fields'] ); } $this->_subscriber['custom_fields'] = array_unique( $processed_fields, SORT_REGULAR ); return $args; } /** * @inheritDoc */ public function get_account_fields() { return array( 'api_key' => array( 'label' => esc_html__( 'API Key', 'et_core' ), ), 'token' => array( 'label' => esc_html__( 'Access Token', 'et_core' ), ), ); } /** * @inheritDoc */ public function get_data_keymap( $keymap = array() ) { $keymap = array( 'list' => array( 'list_id' => 'id', 'name' => 'name', 'subscribers_count' => 'contact_count', ), 'subscriber' => array( 'name' => 'first_name', 'last_name' => 'last_name', 'email' => 'email_addresses.[0].email_address', 'list_id' => 'lists.[0].id', 'custom_fields' => 'custom_fields_unprocessed', ), 'error' => array( 'error_message' => '[0].error_message', ), 'custom_field' => array( 'field_id' => 'name', 'name' => 'name', ), ); return parent::get_data_keymap( $keymap ); } public function get_subscriber( $email ) { $url = add_query_arg( 'email', $email, $this->SUBSCRIBERS_URL ); $this->prepare_request( $url, 'GET', false ); $this->make_remote_request(); if ( $this->response->ERROR || ! isset( $this->response->DATA['results'] ) ) { return array(); } return $this->response->DATA['results']; } /** * @inheritDoc */ public function fetch_subscriber_lists() { if ( empty( $this->data['api_key'] ) || empty( $this->data['token'] ) ) { return $this->API_KEY_REQUIRED; } $this->_maybe_set_custom_headers(); $this->response_data_key = false; $this->LISTS_URL = add_query_arg( 'api_key', $this->data['api_key'], $this->LISTS_URL ); return parent::fetch_subscriber_lists(); } /** * @inheritDoc */ public function subscribe( $args, $url = '' ) { $this->SUBSCRIBERS_URL = add_query_arg( 'api_key', $this->data['api_key'], $this->SUBSCRIBERS_URL ); $result = null; $args['list_id'] = (string) $args['list_id']; $subscriber = $this->get_subscriber( $args['email'] ); $subscriber = $subscriber ? $subscriber[0] : $subscriber; $query_args = array( 'api_key' => $this->data['api_key'], 'action_by' => 'ACTION_BY_VISITOR' ); if ( $subscriber ) { if ( $list = $this->_get_list_from_subscriber( $subscriber, $args['list_id'] ) ) { $result = 'success'; } else { $subscriber['lists'][] = array( 'id' => $args['list_id'] ); $this->_subscriber = &$subscriber; $args = $this->_process_custom_fields( $args ); $url = add_query_arg( $query_args, "{$this->SUBSCRIBE_URL}/{$subscriber['id']}" ); $this->prepare_request( $url, 'PUT', false, $subscriber, true ); } } else { $url = add_query_arg( $query_args, $this->SUBSCRIBE_URL ); $subscriber = $this->_create_subscriber_data_array( $args ); $this->_subscriber = &$subscriber; $args = $this->_process_custom_fields( $args ); $this->prepare_request( $url, 'POST', false, $subscriber, true ); } if ( 'success' !== $result ) { $result = parent::subscribe( $args, $this->SUBSCRIBE_URL ); } return $result; } }