Edit File by line

<?php

[0] Fix | Delete

[1] Fix | Delete

/**

[2] Fix | Delete

* Wrapper for Aweber's API.

[3] Fix | Delete

[4] Fix | Delete

* @since 1.1.0

[5] Fix | Delete

[6] Fix | Delete

* @package ET\Core\API\Email

[7] Fix | Delete

[8] Fix | Delete

class ET_Core_API_Email_Aweber extends ET_Core_API_Email_Provider {

[9] Fix | Delete

[10] Fix | Delete

/**

[11] Fix | Delete

* @inheritDoc

[12] Fix | Delete

[13] Fix | Delete

public $ACCESS_TOKEN_URL = 'https://auth.aweber.com/1.0/oauth/access_token';

[14] Fix | Delete

[15] Fix | Delete

/**

[16] Fix | Delete

* @inheritDoc

[17] Fix | Delete

[18] Fix | Delete

public $AUTHORIZATION_URL = 'https://auth.aweber.com/1.0/oauth/authorize';

[19] Fix | Delete

[20] Fix | Delete

/**

[21] Fix | Delete

* @inheritDoc

[22] Fix | Delete

[23] Fix | Delete

public $REQUEST_TOKEN_URL = 'https://auth.aweber.com/1.0/oauth/request_token';

[24] Fix | Delete

[25] Fix | Delete

/**

[26] Fix | Delete

* @inheritDoc

[27] Fix | Delete

[28] Fix | Delete

public $BASE_URL = 'https://api.aweber.com/1.0';

[29] Fix | Delete

[30] Fix | Delete

/**

[31] Fix | Delete

* @var string

[32] Fix | Delete

[33] Fix | Delete

public $accounts_url;

[34] Fix | Delete

[35] Fix | Delete

/**

[36] Fix | Delete

* @inheritDoc

[37] Fix | Delete

[38] Fix | Delete

public $name = 'Aweber';

[39] Fix | Delete

[40] Fix | Delete

/**

[41] Fix | Delete

* @inheritDoc

[42] Fix | Delete

[43] Fix | Delete

public $name_field_only = true;

[44] Fix | Delete

[45] Fix | Delete

/**

[46] Fix | Delete

* @inheritDoc

[47] Fix | Delete

[48] Fix | Delete

public $slug = 'aweber';

[49] Fix | Delete

[50] Fix | Delete

/**

[51] Fix | Delete

* @inheritDoc

[52] Fix | Delete

[53] Fix | Delete

public $oauth_version = '1.0a';

[54] Fix | Delete

[55] Fix | Delete

/**

[56] Fix | Delete

* @inheritDoc

[57] Fix | Delete

[58] Fix | Delete

public $uses_oauth = true;

[59] Fix | Delete

[60] Fix | Delete

/**

[61] Fix | Delete

* ET_Core_API_Email_Aweber constructor.

[62] Fix | Delete

[63] Fix | Delete

* @inheritDoc

[64] Fix | Delete

[65] Fix | Delete

public function __construct( $owner, $account_name = '', $api_key = '' ) {

[66] Fix | Delete

parent::__construct( $owner, $account_name, $api_key );

[67] Fix | Delete

$this->accounts_url = "{$this->BASE_URL}/accounts";

[68] Fix | Delete

}

[69] Fix | Delete

[70] Fix | Delete

protected function _fetch_custom_fields( $list_id = '', $list = array() ) {

[71] Fix | Delete

$this->prepare_request( $list['custom_fields_collection_link'] );

[72] Fix | Delete

[73] Fix | Delete

return parent::_fetch_custom_fields( $list_id, $list );

[74] Fix | Delete

}

[75] Fix | Delete

[76] Fix | Delete

protected function _get_lists_collection_url() {

[77] Fix | Delete

$this->prepare_request( $this->accounts_url );

[78] Fix | Delete

$this->make_remote_request();

[79] Fix | Delete

$url = '';

[80] Fix | Delete

[81] Fix | Delete

if ( ! $this->response->ERROR && ! empty( $this->response->DATA['entries'][0]['lists_collection_link'] ) ) {

[82] Fix | Delete

$url = $this->response->DATA['entries'][0]['lists_collection_link'];

[83] Fix | Delete

}

[84] Fix | Delete

[85] Fix | Delete

return $url;

[86] Fix | Delete

}

[87] Fix | Delete

[88] Fix | Delete

protected static function _parse_ID( $ID ) {

[89] Fix | Delete

$values = explode( '|', $ID );

[90] Fix | Delete

[91] Fix | Delete

return ( count( $values ) === 6 ) ? $values : null;

[92] Fix | Delete

}

[93] Fix | Delete

[94] Fix | Delete

protected function _process_custom_fields( $args ) {

[95] Fix | Delete

if ( ! isset( $args['custom_fields'] ) ) {

[96] Fix | Delete

return $args;

[97] Fix | Delete

}

[98] Fix | Delete

[99] Fix | Delete

$fields = $args['custom_fields'];

[100] Fix | Delete

[101] Fix | Delete

unset( $args['custom_fields'] );

[102] Fix | Delete

[103] Fix | Delete

foreach ( $fields as $field_id => $value ) {

[104] Fix | Delete

if ( is_array( $value ) && $value ) {

[105] Fix | Delete

// This is a multiple choice field (eg. checkbox, radio, select)

[106] Fix | Delete

$value = array_values( $value );

[107] Fix | Delete

[108] Fix | Delete

if ( count( $value ) > 1 ) {

[109] Fix | Delete

$value = implode( ',', $value );

[110] Fix | Delete

} else {

[111] Fix | Delete

$value = array_pop( $value );

[112] Fix | Delete

}

[113] Fix | Delete

}

[114] Fix | Delete

[115] Fix | Delete

$list_id = $args['list_id'];

[116] Fix | Delete

$field_name = self::$_->array_get( $this->data, "lists.{$list_id}.custom_fields.{$field_id}.name" );

[117] Fix | Delete

[118] Fix | Delete

self::$_->array_set( $args, "custom_fields.{$field_name}", $value );

[119] Fix | Delete

}

[120] Fix | Delete

[121] Fix | Delete

return $args;

[122] Fix | Delete

}

[123] Fix | Delete

[124] Fix | Delete

/**

[125] Fix | Delete

* Uses the app's authorization code to get an access token

[126] Fix | Delete

[127] Fix | Delete

public function authenticate() {

[128] Fix | Delete

if ( empty( $this->data['api_key'] ) ) {

[129] Fix | Delete

return false;

[130] Fix | Delete

}

[131] Fix | Delete

[132] Fix | Delete

$key_parts = self::_parse_ID( $this->data['api_key'] );

[133] Fix | Delete

[134] Fix | Delete

if ( null === $key_parts ) {

[135] Fix | Delete

return false;

[136] Fix | Delete

}

[137] Fix | Delete

[138] Fix | Delete

list( $consumer_key, $consumer_secret, $request_token, $request_secret, $verifier ) = $key_parts;

[139] Fix | Delete

[140] Fix | Delete

if ( ! $verifier ) {

[141] Fix | Delete

return false;

[142] Fix | Delete

}

[143] Fix | Delete

[144] Fix | Delete

$this->data['consumer_key'] = $consumer_key;

[145] Fix | Delete

$this->data['consumer_secret'] = $consumer_secret;

[146] Fix | Delete

$this->data['access_key'] = $request_token;

[147] Fix | Delete

$this->data['access_secret'] = $request_secret;

[148] Fix | Delete

$this->oauth_verifier = $verifier;

[149] Fix | Delete

[150] Fix | Delete

// AWeber returns oauth access key in url query format :face_with_rolling_eyes:

[151] Fix | Delete

$this->http->expects_json = false;

[152] Fix | Delete

[153] Fix | Delete

return parent::authenticate();

[154] Fix | Delete

}

[155] Fix | Delete

[156] Fix | Delete

/**

[157] Fix | Delete

* @inheritDoc

[158] Fix | Delete

[159] Fix | Delete

public function get_account_fields() {

[160] Fix | Delete

return array(

[161] Fix | Delete

'api_key' => array(

[162] Fix | Delete

'label' => esc_html__( 'Authorization Code', 'et_core' ),

[163] Fix | Delete

[164] Fix | Delete

);

[165] Fix | Delete

}

[166] Fix | Delete

[167] Fix | Delete

/**

[168] Fix | Delete

* @inheritDoc

[169] Fix | Delete

[170] Fix | Delete

public function get_error_message() {

[171] Fix | Delete

$error_message = parent::get_error_message();

[172] Fix | Delete

[173] Fix | Delete

return preg_replace('/https.*/m', '', $error_message );

[174] Fix | Delete

}

[175] Fix | Delete

[176] Fix | Delete

/**

[177] Fix | Delete

* @inheritDoc

[178] Fix | Delete

[179] Fix | Delete

public function get_data_keymap( $keymap = array() ) {

[180] Fix | Delete

$keymap = array(

[181] Fix | Delete

'list' => array(

[182] Fix | Delete

'list_id' => 'id',

[183] Fix | Delete

'name' => 'name',

[184] Fix | Delete

'subscribers_count' => 'total_subscribers',

[185] Fix | Delete

[186] Fix | Delete

'subscriber' => array(

[187] Fix | Delete

'name' => 'name',

[188] Fix | Delete

'email' => 'email',

[189] Fix | Delete

'ad_tracking' => 'ad_tracking',

[190] Fix | Delete

'custom_fields' => 'custom_fields',

[191] Fix | Delete

[192] Fix | Delete

'error' => array(

[193] Fix | Delete

'error_message' => 'error.message',

[194] Fix | Delete

[195] Fix | Delete

'custom_field' => array(

[196] Fix | Delete

'field_id' => 'id',

[197] Fix | Delete

'name' => 'name',

[198] Fix | Delete

[199] Fix | Delete

);

[200] Fix | Delete

[201] Fix | Delete

return parent::get_data_keymap( $keymap );

[202] Fix | Delete

}

[203] Fix | Delete

[204] Fix | Delete

/**

[205] Fix | Delete

* @inheritDoc

[206] Fix | Delete

[207] Fix | Delete

public function fetch_subscriber_lists() {

[208] Fix | Delete

$needs_to_authenticate = ! $this->is_authenticated() || ! $this->_initialize_oauth_helper();

[209] Fix | Delete

[210] Fix | Delete

if ( $needs_to_authenticate && ! $this->authenticate() ) {

[211] Fix | Delete

if ( empty( $this->response->DATA ) ) {

[212] Fix | Delete

return '';

[213] Fix | Delete

}

[214] Fix | Delete

[215] Fix | Delete

$this->response->DATA = json_decode( $this->response->DATA, true );

[216] Fix | Delete

return $this->get_error_message();

[217] Fix | Delete

}

[218] Fix | Delete

[219] Fix | Delete

$this->http->expects_json = true;

[220] Fix | Delete

$this->LISTS_URL = $this->_get_lists_collection_url();

[221] Fix | Delete

[222] Fix | Delete

if ( empty( $this->LISTS_URL ) ) {

[223] Fix | Delete

return '';

[224] Fix | Delete

}

[225] Fix | Delete

[226] Fix | Delete

$this->response_data_key = 'entries';

[227] Fix | Delete

[228] Fix | Delete

return parent::fetch_subscriber_lists();

[229] Fix | Delete

}

[230] Fix | Delete

[231] Fix | Delete

/**

[232] Fix | Delete

* @inheritDoc

[233] Fix | Delete

[234] Fix | Delete

public function subscribe( $args, $url = '' ) {

[235] Fix | Delete

$lists_url = $this->_get_lists_collection_url();

[236] Fix | Delete

$url = "{$lists_url}/{$args['list_id']}/subscribers";

[237] Fix | Delete

$ip_address = 'true' === self::$_->array_get( $args, 'ip_address', 'true' );

[238] Fix | Delete

[239] Fix | Delete

$params = $this->_process_custom_fields( $args );

[240] Fix | Delete

$params = $this->transform_data_to_provider_format( $params, 'subscriber' );

[241] Fix | Delete

$params = array_merge( $params, array(

[242] Fix | Delete

'ws.op' => 'create',

[243] Fix | Delete

'ip_address' => $ip_address ? et_core_get_ip_address() : '0.0.0.0',

[244] Fix | Delete

'misc_notes' => $this->SUBSCRIBED_VIA,

[245] Fix | Delete

) );

[246] Fix | Delete

[247] Fix | Delete

// There is a bug in AWeber some characters not encoded properly on AWeber side when sending data in x-www-form-urlencoded format so use json instead

[248] Fix | Delete

$this->prepare_request( $url, 'POST', false, $params, true );

[249] Fix | Delete

$this->request->HEADERS['Content-Type'] = 'application/json';

[250] Fix | Delete

[251] Fix | Delete

return parent::subscribe( $params, $url );

[252] Fix | Delete

}

[253] Fix | Delete

}

[254] Fix | Delete

[255] Fix | Delete