__( 'Klaviyo', 'advanced-form-integration' ),
'tasks' => array(
'subscribe' => __( 'Subscribe To List', 'advanced-form-integration' ),
),
);
return $actions;
}
add_filter(
'adfoin_settings_tabs',
'adfoin_klaviyo_settings_tab',
10,
1
);
function adfoin_klaviyo_settings_tab( $providers ) {
$providers['klaviyo'] = __( 'Klaviyo', 'advanced-form-integration' );
return $providers;
}
add_action(
'adfoin_settings_view',
'adfoin_klaviyo_settings_view',
10,
1
);
function adfoin_klaviyo_settings_view( $current_tab ) {
if ( $current_tab != 'klaviyo' ) {
return;
}
if ( !class_exists( 'ADFOIN_Account_Manager' ) ) {
require_once plugin_dir_path( __FILE__ ) . '../../includes/class-adfoin-account-manager.php';
}
$fields = array(array(
'name' => 'privateKey',
'label' => __( 'Private API Key', 'advanced-form-integration' ),
'type' => 'text',
'required' => true,
'mask' => true,
'placeholder' => __( 'Enter your Private API Key', 'advanced-form-integration' ),
'show_in_table' => true,
));
$instructions = sprintf( __( '
- %s
- Generate a Private API Key with full access.
', 'advanced-form-integration' ), 'https://www.klaviyo.com/account#api-keys-tab', __( 'Click here to get the API Keys', 'advanced-form-integration' ) );
ADFOIN_Account_Manager::render_settings_view(
'klaviyo',
__( 'Klaviyo', 'advanced-form-integration' ),
$fields,
$instructions
);
}
add_action(
'wp_ajax_adfoin_get_klaviyo_credentials',
'adfoin_get_klaviyo_credentials',
10,
0
);
function adfoin_get_klaviyo_credentials() {
if ( !class_exists( 'ADFOIN_Account_Manager' ) ) {
require_once plugin_dir_path( __FILE__ ) . '../../includes/class-adfoin-account-manager.php';
}
ADFOIN_Account_Manager::ajax_get_credentials_list( 'klaviyo' );
}
add_action(
'wp_ajax_adfoin_save_klaviyo_credentials',
'adfoin_save_klaviyo_credentials',
10,
0
);
/*
* Get Kalviyo credentials
*/
function adfoin_save_klaviyo_credentials() {
if ( !class_exists( 'ADFOIN_Account_Manager' ) ) {
require_once plugin_dir_path( __FILE__ ) . '../../includes/class-adfoin-account-manager.php';
}
ADFOIN_Account_Manager::ajax_save_credentials( 'klaviyo', array('privateKey') );
}
add_action(
'wp_ajax_adfoin_save_klaviyo_oauth_config',
'adfoin_save_klaviyo_oauth_config',
10,
0
);
/*
* Save Klaviyo OAuth configuration (PKCE - no client secret needed)
*/
function adfoin_save_klaviyo_oauth_config() {
if ( !adfoin_verify_nonce() ) {
return;
}
if ( !current_user_can( 'manage_options' ) ) {
wp_send_json_error( array(
'message' => __( 'Insufficient permissions', 'advanced-form-integration' ),
) );
}
$client_id = ( isset( $_POST['client_id'] ) ? sanitize_text_field( $_POST['client_id'] ) : '' );
if ( empty( $client_id ) ) {
wp_send_json_error( array(
'message' => __( 'Client ID is required', 'advanced-form-integration' ),
) );
}
update_option( 'adfoin_klaviyo_oauth_client_id', $client_id );
wp_send_json_success( array(
'message' => __( 'OAuth configuration saved successfully', 'advanced-form-integration' ),
) );
}
add_filter(
'adfoin_get_credentials',
'adfoin_klaviyo_modify_credentials',
10,
2
);
function adfoin_klaviyo_modify_credentials( $credentials, $platform ) {
if ( 'klaviyo' == $platform && empty( $credentials ) ) {
// Fallback for old single-option credentials if any exist?
// Or simply remove this if we are strictly using the Key Manager now.
// Assuming we want to migrate old keys if they exist:
$private_key = get_option( 'adfoin_klaviyo_api_token' );
if ( $private_key ) {
$credentials[] = array(
'id' => 'imported_legacy',
'title' => __( 'Legacy Account', 'advanced-form-integration' ),
'privateKey' => $private_key,
);
}
}
return $credentials;
}
function adfoin_klaviyo_credentials_list() {
$html = '';
$credentials = adfoin_read_credentials( 'klaviyo' );
foreach ( $credentials as $option ) {
$html .= '';
}
echo $html;
}
add_action( 'adfoin_action_fields', 'adfoin_klaviyo_action_fields' );
function adfoin_klaviyo_action_fields() {
?>
30,
'method' => $method,
'headers' => array(
'Content-Type' => 'application/json',
'Accept' => 'application/json',
'revision' => '2024-02-15',
),
);
// Set authorization header based on auth type
if ( $auth_type === 'oauth' ) {
// OAuth authentication
if ( class_exists( 'ADFOIN_Klaviyo_OAuth' ) ) {
$access_token = ADFOIN_Klaviyo_OAuth::get_valid_access_token( $credentials );
if ( !$access_token ) {
// Token refresh failed, return error
return new WP_Error('oauth_token_expired', __( 'OAuth token expired and refresh failed. Please reconnect your account.', 'advanced-form-integration' ));
}
$args['headers']['Authorization'] = 'Bearer ' . $access_token;
} else {
return new WP_Error('oauth_not_available', __( 'OAuth class not found', 'advanced-form-integration' ));
}
} else {
// Private Key authentication (legacy)
$api_key = ( isset( $credentials['privateKey'] ) ? $credentials['privateKey'] : '' );
if ( empty( $api_key ) ) {
return new WP_Error('missing_api_key', __( 'Private API Key not found', 'advanced-form-integration' ));
}
$args['headers']['Authorization'] = 'Klaviyo-API-Key ' . $api_key;
}
if ( 'POST' == $method || 'PUT' == $method ) {
$args['body'] = json_encode( $data );
}
$response = wp_remote_request( $url, $args );
if ( $record ) {
adfoin_add_to_log(
$response,
$url,
$args,
$record
);
}
return $response;
}
add_action(
'wp_ajax_adfoin_get_klaviyo_list',
'adfoin_get_klaviyo_list',
10,
0
);
/*
* Get Kalviyo subscriber lists
*/
function adfoin_get_klaviyo_list() {
// Security Check
if ( !wp_verify_nonce( $_POST['_nonce'], 'advanced-form-integration' ) ) {
die( __( 'Security check Failed', 'advanced-form-integration' ) );
}
$cred_id = sanitize_text_field( $_POST['credId'] );
$lists = array();
$next_url = '';
do {
// Construct URL for Klaviyo request
$url = ( empty( $next_url ) ? 'lists' : str_replace( 'https://a.klaviyo.com/api/', '', $next_url ) );
// Fetch data from Klaviyo
$data = adfoin_klaviyo_private_request_20240215(
$url,
'GET',
array(),
array(),
$cred_id
);
if ( is_wp_error( $data ) ) {
wp_send_json_error();
}
$body = json_decode( wp_remote_retrieve_body( $data ), true );
if ( isset( $body['data'] ) && is_array( $body['data'] ) ) {
foreach ( $body['data'] as $list ) {
$lists[$list['id']] = $list['attributes']['name'];
}
}
// Check for pagination
if ( isset( $body['links']['next'] ) && !empty( $body['links']['next'] ) ) {
$next_url = $body['links']['next'];
} else {
$next_url = '';
}
} while ( !empty( $next_url ) );
wp_send_json_success( $lists );
}
add_action(
'adfoin_klaviyo_job_queue',
'adfoin_klaviyo_job_queue',
10,
1
);
function adfoin_klaviyo_job_queue( $data ) {
adfoin_klaviyo_send_data( $data['record'], $data['posted_data'] );
}
function adfoin_klaviyo_create_or_update_contact( $subscriber_data, $record, $cred_id ) {
$result = adfoin_klaviyo_private_request_20240215(
"profile-import/",
'POST',
$subscriber_data,
$record,
$cred_id
);
$result = json_decode( wp_remote_retrieve_body( $result ), true );
return ( isset( $result['data'], $result['data']['id'] ) ? $result['data']['id'] : false );
}
function adfoin_klaviyo_email_subscribe(
$list_id,
$email,
$record,
$cred_id,
$source
) {
$email_data = array(
'data' => array(
'type' => 'profile-subscription-bulk-create-job',
'attributes' => array(
'custom_source' => $source,
'profiles' => array(
'data' => array(array(
'type' => 'profile',
'attributes' => array(
'email' => $email,
'subscriptions' => array(
'email' => array(
'marketing' => array(
'consent' => 'SUBSCRIBED',
),
),
),
),
)),
),
),
'relationships' => array(
'list' => array(
'data' => array(
'id' => $list_id,
'type' => 'list',
),
),
),
),
);
$result = adfoin_klaviyo_private_request_20240215(
'profile-subscription-bulk-create-jobs/',
'POST',
$email_data,
$record,
$cred_id
);
return $result;
}
/*
* Handles sending data to Klaviyo API
*/
function adfoin_klaviyo_send_data( $record, $posted_data ) {
$record_data = json_decode( $record['data'], true );
if ( array_key_exists( 'cl', $record_data['action_data'] ) ) {
if ( $record_data['action_data']['cl']['active'] == 'yes' ) {
if ( !adfoin_match_conditional_logic( $record_data['action_data']['cl'], $posted_data ) ) {
return;
}
}
}
$data = $record_data['field_data'];
$list_id = ( isset( $data['listId'] ) ? $data['listId'] : '' );
$cred_id = ( isset( $data['credId'] ) ? $data['credId'] : '' );
$task = $record['task'];
// Backward compatibility: If no credId, use the first available credential
if ( empty( $cred_id ) ) {
$credentials = adfoin_read_credentials( 'klaviyo' );
if ( !empty( $credentials ) && is_array( $credentials ) ) {
$first_credential = reset( $credentials );
$cred_id = ( isset( $first_credential['id'] ) ? $first_credential['id'] : '' );
}
}
if ( $task == 'subscribe' ) {
$email = ( empty( $data['email'] ) ? '' : trim( adfoin_get_parsed_values( $data['email'], $posted_data ) ) );
$profile = array(
'email' => $email,
);
if ( isset( $data['firstName'] ) && $data['firstName'] ) {
$profile['first_name'] = adfoin_get_parsed_values( $data['firstName'], $posted_data );
}
if ( isset( $data['lastName'] ) && $data['lastName'] ) {
$profile['last_name'] = adfoin_get_parsed_values( $data['lastName'], $posted_data );
}
if ( isset( $data['title'] ) && $data['title'] ) {
$profile['title'] = adfoin_get_parsed_values( $data['title'], $posted_data );
}
if ( isset( $data['organization'] ) && $data['organization'] ) {
$profile['organization'] = adfoin_get_parsed_values( $data['organization'], $posted_data );
}
if ( isset( $data['externalId'] ) && $data['externalId'] ) {
$profile['external_id'] = adfoin_get_parsed_values( $data['externalId'], $posted_data );
}
$source = ( isset( $data['source'] ) && $data['source'] ? adfoin_get_parsed_values( $data['source'], $posted_data ) : '' );
$ip = ( isset( $data['ip'] ) && $data['ip'] ? adfoin_get_parsed_values( $data['ip'], $posted_data ) : '' );
if ( isset( $data['phoneNumber'] ) && $data['phoneNumber'] ) {
$phone_number = preg_replace( '/[^0-9+]/', '', adfoin_get_parsed_values( $data['phoneNumber'], $posted_data ) );
if ( strlen( $phone_number ) > 7 ) {
$profile['phone_number'] = $phone_number;
}
}
$address = array(
'address1' => adfoin_get_parsed_values( $data['address1'], $posted_data ),
'address2' => adfoin_get_parsed_values( $data['address2'], $posted_data ),
'city' => adfoin_get_parsed_values( $data['city'], $posted_data ),
'region' => adfoin_get_parsed_values( $data['region'], $posted_data ),
'country' => adfoin_get_parsed_values( $data['country'], $posted_data ),
'zip' => adfoin_get_parsed_values( $data['zip'], $posted_data ),
'latitude' => adfoin_get_parsed_values( $data['latitude'], $posted_data ),
'longitude' => adfoin_get_parsed_values( $data['longitude'], $posted_data ),
'timezone' => adfoin_get_parsed_values( $data['timezone'], $posted_data ),
'ip' => ( $ip ? $ip : '' ),
);
$address = array_filter( $address );
$subscriber_data = array(
'data' => array(
'type' => 'profile',
'attributes' => $profile,
),
);
if ( !empty( $address ) ) {
$subscriber_data['data']['attributes']['location'] = $address;
}
$contact_id = adfoin_klaviyo_create_or_update_contact( $subscriber_data, $record, $cred_id );
if ( $contact_id && $email ) {
adfoin_klaviyo_email_subscribe(
$list_id,
$email,
$record,
$cred_id,
$source
);
}
}
return;
}