File "class-mailchimp.php"
Full Path: /home/fineflavourcocoa/public_html/wp-content/plugins/mailchimp-for-wp/includes/admin/class-mailchimp.php
File size: 13.49 KB
MIME-type: text/x-php
Charset: utf-8
<?php
/**
* Helper class for dealing with common API requests.
*/
class MC4WP_MailChimp {
/**
* @var string
*/
public $error_code = '';
/**
* @var string
*/
public $error_message = '';
/**
*
* Sends a subscription request to the Mailchimp API
*
* @param string $list_id The list id to subscribe to
* @param string $email_address The email address to subscribe
* @param array $args
* @param bool $update_existing Update information if this email is already on list?
* @param bool $replace_interests Replace interest groupings, only if update_existing is true.
*
* @return object
* @throws Exception
*/
public function list_subscribe( $list_id, $email_address, array $args = array(), $update_existing = false, $replace_interests = true ) {
$this->reset_error();
$default_args = array(
'status' => 'pending',
'email_address' => $email_address,
);
$existing_member_data = null;
// setup default args
$args = array_merge( $default_args, $args );
$api = $this->get_api();
// first, check if subscriber is already on the given list
try {
$existing_member_data = $api->get_list_member( $list_id, $email_address );
if ( $existing_member_data->status === 'subscribed' ) {
// if we're not supposed to update, bail.
if ( ! $update_existing ) {
$this->error_code = 214;
$this->error_message = 'That subscriber already exists.';
return null;
}
$args['status'] = 'subscribed';
// this key only exists if list actually has interests
if ( isset( $existing_member_data->interests ) ) {
$existing_interests = (array) $existing_member_data->interests;
// if replace, assume all existing interests disabled
if ( $replace_interests ) {
$existing_interests = array_fill_keys( array_keys( $existing_interests ), false );
}
$args['interests'] = array_replace( $existing_interests, $args['interests'] );
}
} elseif ( $args['status'] === 'pending' && $existing_member_data->status === 'pending' ) {
// this ensures that a new double opt-in email is send out
$api->update_list_member(
$list_id,
$email_address,
array(
'status' => 'unsubscribed',
)
);
}
} catch ( MC4WP_API_Resource_Not_Found_Exception $e ) {
// subscriber does not exist (not an issue in this case)
} catch ( MC4WP_API_Exception $e ) {
// other errors.
$this->error_code = $e->getCode();
$this->error_message = $e;
return null;
}
try {
if ( $existing_member_data ) {
$data = $api->update_list_member( $list_id, $email_address, $args );
$data->was_already_on_list = $existing_member_data->status === 'subscribed';
if ( isset( $args['tags'] ) && is_array( $args['tags'] ) ) {
$this->list_add_tags_to_subscriber( $list_id, $data, $args['tags'] );
}
} else {
$data = $api->add_new_list_member( $list_id, $args );
$data->was_already_on_list = false;
}
} catch ( MC4WP_API_Exception $e ) {
$this->error_code = $e->getCode();
$this->error_message = $e;
return null;
}
return $data;
}
/**
* Format tags to send to Mailchimp.
*
* @param $mailchimp_tags array existent user tags
* @param $new_tags array new tags to add
*
* @return array
* @since 4.7.9
*/
private function merge_and_format_member_tags( $mailchimp_tags, $new_tags ) {
$mailchimp_tags = array_map(
function ( $tag ) {
return $tag->name;
},
$mailchimp_tags
);
$tags = array_unique( array_merge( $mailchimp_tags, $new_tags ), SORT_REGULAR );
return array_map(
function ( $tag ) {
return array(
'name' => $tag,
'status' => 'active',
);
},
$tags
);
}
/**
* Post the tags on a list member.
*
* @param $mailchimp_list_id string The list id to subscribe to
* @param $mailchimp_member stdClass mailchimp user informations
* @param $new_tags array tags to add to the user
*
* @return bool
* @throws Exception
* @since 4.7.9
*/
private function list_add_tags_to_subscriber( $mailchimp_list_id, $mailchimp_member, array $new_tags ) {
// do nothing if no tags given
if ( count( $new_tags ) === 0 ) {
return true;
}
$api = $this->get_api();
$data = array(
'tags' => $this->merge_and_format_member_tags( $mailchimp_member->tags, $new_tags ),
);
try {
$api->update_list_member_tags( $mailchimp_list_id, $mailchimp_member->email_address, $data );
} catch ( MC4WP_API_Exception $ex ) {
// fail silently
return false;
}
return true;
}
/**
* Changes the subscriber status to "unsubscribed"
*
* @param string $list_id
* @param string $email_address
*
* @return boolean
*/
public function list_unsubscribe( $list_id, $email_address ) {
$this->reset_error();
try {
$this->get_api()->update_list_member( $list_id, $email_address, array( 'status' => 'unsubscribed' ) );
} catch ( MC4WP_API_Resource_Not_Found_Exception $e ) {
// if email wasn't even on the list: great.
return true;
} catch ( MC4WP_API_Exception $e ) {
$this->error_code = $e->getCode();
$this->error_message = $e;
return false;
}
return true;
}
/**
* Checks if an email address is on a given list with status "subscribed"
*
* @param string $list_id
* @param string $email_address
*
* @return boolean
* @throws Exception
*/
public function list_has_subscriber( $list_id, $email_address ) {
try {
$data = $this->get_api()->get_list_member( $list_id, $email_address );
} catch ( MC4WP_API_Resource_Not_Found_Exception $e ) {
return false;
}
return ! empty( $data->id ) && $data->status === 'subscribed';
}
/**
* @param string $list_id
*
* @return array
* @throws Exception
*/
public function get_list_merge_fields( $list_id ) {
$transient_key = sprintf( 'mc4wp_list_%s_mf', $list_id );
$cached = get_transient( $transient_key );
if ( is_array( $cached ) ) {
return $cached;
}
$api = $this->get_api();
try {
// fetch list merge fields
$merge_fields = $api->get_list_merge_fields(
$list_id,
array(
'count' => 100,
'fields' => 'merge_fields.name,merge_fields.tag,merge_fields.type,merge_fields.required,merge_fields.default_value,merge_fields.options,merge_fields.public',
)
);
} catch ( MC4WP_API_Exception $e ) {
return array();
}
// add EMAIL field
array_unshift(
$merge_fields,
(object) array(
'tag' => 'EMAIL',
'name' => __( 'Email address', 'mailchimp-for-wp' ),
'required' => true,
'type' => 'email',
'options' => array(),
'public' => true,
)
);
set_transient( $transient_key, $merge_fields, HOUR_IN_SECONDS * 24 );
return $merge_fields;
}
/**
* @param string $list_id
*
* @return array
* @throws Exception
*/
public function get_list_interest_categories( $list_id ) {
$transient_key = sprintf( 'mc4wp_list_%s_ic', $list_id );
$cached = get_transient( $transient_key );
if ( is_array( $cached ) ) {
return $cached;
}
$api = $this->get_api();
try {
// fetch list interest categories
$interest_categories = $api->get_list_interest_categories(
$list_id,
array(
'count' => 100,
'fields' => 'categories.id,categories.title,categories.type',
)
);
} catch ( MC4WP_API_Exception $e ) {
return array();
}
foreach ( $interest_categories as $interest_category ) {
$interest_category->interests = array();
try {
// fetch groups for this interest
$interests_data = $api->get_list_interest_category_interests(
$list_id,
$interest_category->id,
array(
'count' => 100,
'fields' => 'interests.id,interests.name',
)
);
foreach ( $interests_data as $interest_data ) {
$interest_category->interests[ (string) $interest_data->id ] = $interest_data->name;
}
} catch ( MC4WP_API_Exception $e ) {
// ignore
}
}
set_transient( $transient_key, $interest_categories, HOUR_IN_SECONDS * 24 );
return $interest_categories;
}
/**
* Gets marketing permissions from a Mailchimp list.
* The list needs to have at least 1 member for this to work.
*
* @param string $list_id
*
* @return array
* @throws Exception
*/
public function get_list_marketing_permissions( $list_id ) {
$transient_key = sprintf( 'mc4wp_list_%s_mp', $list_id );
$cached = get_transient( $transient_key );
if ( is_array( $cached ) ) {
return $cached;
}
try {
$api = $this->get_api();
$data = $api->get_list_members(
$list_id,
array(
'fields' => array( 'members.marketing_permissions' ),
'count' => 1,
)
);
$marketing_permissions = array();
if ( count( $data->members ) > 0 && $data->members[0]->marketing_permissions ) {
foreach ( $data->members[0]->marketing_permissions as $mp ) {
$marketing_permissions[] = (object) array(
'marketing_permission_id' => $mp->marketing_permission_id,
'text' => $mp->text,
);
}
}
} catch ( MC4WP_API_Exception $e ) {
return array();
}
set_transient( $transient_key, $marketing_permissions, HOUR_IN_SECONDS * 24 );
return $marketing_permissions;
}
/**
* Get Mailchimp lists, from cache or remote API.
*
* @param boolean $skip_cache Whether to force a result by hitting Mailchimp API
*
* @return array
*/
public function get_lists( $skip_cache = false ) {
$cache_key = 'mc4wp_mailchimp_lists';
$cached = get_transient( $cache_key );
if ( is_array( $cached ) && ! $skip_cache ) {
return $cached;
}
$lists = $this->fetch_lists();
/**
* Filters the cache time for Mailchimp lists configuration, in seconds. Defaults to 24 hours.
*/
$cache_ttl = (int) apply_filters( 'mc4wp_lists_count_cache_time', HOUR_IN_SECONDS * 24 );
// make sure cache ttl is not lower than 60 seconds
$cache_ttl = max( 60, $cache_ttl );
set_transient( $cache_key, $lists, $cache_ttl );
return $lists;
}
private function fetch_lists() {
$client = $this->get_api()->get_client();
$lists_data = array();
$offset = 0;
$count = 10;
// increase time limits
@set_time_limit( 180 );
add_filter(
'mc4wp_http_request_args',
function ( $args ) {
$args['timeout'] = 30;
return $args;
}
);
// collect all lists in separate HTTP requests (batches of 5)
do {
try {
$data = $client->get(
'/lists',
array(
'count' => $count,
'offset' => $offset,
'fields' => 'total_items,lists.id,lists.name,lists.web_id,lists.stats.member_count,lists.marketing_permissions',
)
);
$lists_data = array_merge( $lists_data, $data->lists );
$offset += $count;
} catch ( MC4WP_API_Connection_Exception $e ) {
// ignore timeout errors as this is likely due to mailchimp being slow to calculate the lists.stats.member_count property
// keep going so we can at least pull-in all other lists
$offset += $count;
// failsafe against infinite loop
if ( $offset > 300 ) {
break;
}
continue;
} catch ( MC4WP_API_Exception $e ) {
// break on other errors, like "API key missing"etc.
break;
}
} while ( $data->total_items > $offset );
// key by list ID
$lists = array();
foreach ( $lists_data as $list_data ) {
$lists["$list_data->id"] = $list_data;
}
return $lists;
}
/**
* @param string $list_id
*
* @return object|null
*/
public function get_list( $list_id ) {
$lists = $this->get_lists();
return isset( $lists["$list_id"] ) ? $lists["$list_id"] : null;
}
/**
* Fetch lists data from Mailchimp.
*/
public function refresh_lists() {
$lists = $this->get_lists( true );
foreach ( $lists as $list_id => $list ) {
// delete cached merge fields
$transient_key = sprintf( 'mc4wp_list_%s_mf', $list_id );
delete_transient( $transient_key );
// delete cached interest categories
$transient_key = sprintf( 'mc4wp_list_%s_ic', $list_id );
delete_transient( $transient_key );
// delete cached marketing permissions
$transient_key = sprintf( 'mc4wp_list_%s_mp', $list_id );
delete_transient( $transient_key );
}
return ! empty( $lists );
}
/**
* Returns number of subscribers on given lists.
*
* @param array|string $list_ids Array of list ID's, or single string.
*
* @return int Total # subscribers for given lists.
*/
public function get_subscriber_count( $list_ids ) {
// make sure we're getting an array
if ( ! is_array( $list_ids ) ) {
$list_ids = array( $list_ids );
}
// if we got an empty array, return 0
if ( empty( $list_ids ) ) {
return 0;
}
$lists = $this->get_lists();
// start calculating subscribers count for all given list ID's combined
$count = 0;
foreach ( $list_ids as $list_id ) {
if ( ! isset( $lists["$list_id"] ) ) {
continue;
}
$list = $lists["$list_id"];
$count += $list->stats->member_count;
}
/**
* Filters the total subscriber_count for the given List ID's.
*
* @param string $count
* @param array $list_ids
*
* @since 2.0
*/
return apply_filters( 'mc4wp_subscriber_count', $count, $list_ids );
}
/**
* Resets error properties.
*/
public function reset_error() {
$this->error_message = '';
$this->error_code = '';
}
/**
* @return bool
*/
public function has_error() {
return ! empty( $this->error_code );
}
/**
* @return string
*/
public function get_error_message() {
return $this->error_message;
}
/**
* @return string
*/
public function get_error_code() {
return $this->error_code;
}
/**
* @return MC4WP_API_V3
* @throws Exception
*/
private function get_api() {
return mc4wp( 'api' );
}
}