Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Bower components
Debian packages
RPM packages
NuGet packages
<?php
/**
* Form notifications class
*/
// If this file is called directly, abort.
if ( ! defined( 'WPINC' ) ) {
die;
}
if ( ! class_exists( 'Jet_Engine_Booking_Forms_Notifications' ) ) {
/**
* Define Jet_Engine_Booking_Forms_Notifications class
*/
class Jet_Engine_Booking_Forms_Notifications {
public $form = null;
public $data = null;
public $notifications = array();
public $manager = null;
public $handler = null;
public $log = array();
public $log_status = false;
public $specific_status = false;
public $headers;
public $email_data;
/**
* Constructor for the class
*/
function __construct( $form = null, $data = array(), $manager, $handler ) {
$this->form = $form;
$this->data = $data;
$this->manager = $manager;
$this->handler = $handler;
$this->notifications = $this->manager->editor->get_notifications( $this->form );
add_action(
'jet-engine/forms/booking/notification/register_user',
array( $this, 'register_user' )
);
add_action(
'jet-engine/forms/booking/notification/update_user',
array( $this, 'update_user' )
);
add_action(
'jet-engine/forms/booking/notification/webhook',
array( $this, 'webhook' )
);
add_action(
'jet-engine/forms/booking/notification/hook',
array( $this, 'hook' )
);
add_action(
'jet-engine/forms/booking/notification/insert_post',
array( $this, 'insert_post' )
);
add_action(
'jet-engine/forms/booking/notification/email',
array( $this, 'email' )
);
add_action(
'jet-engine/forms/booking/notification/redirect',
array( $this, 'do_redirect' )
);
add_action(
'jet-engine/forms/booking/notification/activecampaign',
array( $this, 'activecampaign' )
);
add_action(
'jet-engine/forms/booking/notification/mailchimp',
array( $this, 'mailchimp' )
);
add_action(
'jet-engine/forms/booking/notification/getresponse',
array( $this, 'getresponse' )
);
add_action(
'jet-engine/forms/booking/notification/update_options',
array( $this, 'update_options' )
);
add_action( 'jet-engine/forms/booking/email/send-before', array( $this, 'send_before' ) );
add_action( 'jet-engine/forms/booking/email/send-after', array( $this, 'send_after' ) );
}
/**
* Unregister notification
*
* @param [type] $type [description]
* @return [type] [description]
*/
public function unregister_notification_type( $type ) {
switch ( $type ) {
case 'register_user':
remove_action(
'jet-engine/forms/booking/notification/register_user',
array( $this, 'register_user' )
);
break;
case 'update_user':
remove_action(
'jet-engine/forms/booking/notification/update_user',
array( $this, 'update_user' )
);
break;
case 'webhook':
remove_action(
'jet-engine/forms/booking/notification/webhook',
array( $this, 'webhook' )
);
break;
case 'hook':
remove_action(
'jet-engine/forms/booking/notification/hook',
array( $this, 'hook' )
);
break;
case 'insert_post':
remove_action(
'jet-engine/forms/booking/notification/insert_post',
array( $this, 'insert_post' )
);
break;
case 'redirect':
remove_action(
'jet-engine/forms/booking/notification/redirect',
array( $this, 'do_redirect' )
);
break;
case 'activecampaign':
remove_action(
'jet-engine/forms/booking/notification/activecampaign',
array( $this, 'activecampaign' )
);
break;
default:
remove_all_actions( 'jet-engine/forms/booking/notification/' . $type );
break;
}
}
/**
* Unregister notification bu index
*
* @param [type] $index [description]
* @return [type] [description]
*/
public function unregister_notification( $index ) {
if ( isset( $this->notifications[ $index ] ) ) {
unset( $this->notifications[ $index ] );
}
}
/**
* Returns all registered notifications
*
* @return [type] [description]
*/
public function get_all() {
return $this->notifications;
}
/**
* Send form notifications
*
* @return [type] [description]
*/
public function send() {
if ( empty( $this->notifications ) ) {
$this->notifications = $this->manager->editor->get_notifications( $this->form );
}
do_action( 'jet-engine/forms/notifications/before-send', $this );
foreach ( $this->notifications as $index => $notification ) {
/**
* Process single notification
*/
do_action( 'jet-engine/forms/booking/notification/' . $notification['type'], $notification, $this );
}
if ( empty( $this->log ) ) {
return false;
} else {
return count( $this->log ) === count( array_filter( $this->log ) );
}
}
/**
* Check if all notifications are successfully processed
*
* @return boolean [description]
*/
public function is_success() {
if ( empty( $this->log ) ) {
return false;
} else {
return count( $this->log ) === count( array_filter( $this->log ) );
}
}
/**
* Perform redirect notification
*
* @param [type] $notification [description]
* @return [type] [description]
*/
public function do_redirect( $notification ) {
$this->log[] = true;
if ( ! $this->is_success() ) {
return;
}
$type = ! empty( $notification['redirect_type'] ) ? $notification['redirect_type'] : 'static_page';
switch ( $type ) {
case 'static_page':
$to_page = ! empty( $notification['redirect_page'] ) ? $notification['redirect_page'] : false;
$to_url = ! empty( $to_page ) ? get_permalink( $to_page ) : false;
break;
case 'current_page':
$to_url = $this->handler->refer;
break;
default:
$to_url = ! empty( $notification['redirect_url'] ) ? $notification['redirect_url'] : false;
break;
}
if ( ! $to_url ) {
return;
} else {
if ( ! empty( $notification['redirect_hash'] ) ) {
$to_url = trailingslashit( $to_url ) . '#' . $notification['redirect_hash'];
}
if ( ! empty( $notification['redirect_args'] ) ) {
$redirect_args = array();
foreach ( $notification['redirect_args'] as $arg ) {
$redirect_args[ $arg ] = ! empty( $this->data[ $arg ] ) ? $this->data[ $arg ] : 0;
}
$to_url = add_query_arg( $redirect_args, $to_url );
}
if ( ! $this->handler->is_ajax() ) {
wp_safe_redirect( $to_url );
die();
} else {
$this->handler->add_response_data( array( 'redirect' => $to_url ) );
}
}
}
/**
* Call a webhook notification
*
* @param [type] $notification [description]
* @return [type] [description]
*/
public function webhook( $notification ) {
$webhook_url = ! empty( $notification['webhook_url'] ) ? esc_url( $notification['webhook_url'] ) : false;
if ( ! $webhook_url ) {
return;
}
$args = array(
'body' => $this->data,
);
/**
* Filter webhook arguments
*/
$args = apply_filters(
'jet-engine/forms/booking/notification/webhook/request-args', $args, $notification, $this
);
$response = wp_remote_post( $webhook_url, $args );
$this->log[] = true;
/**
* Firtes whe webhook response recieved
*/
do_action( 'jet-engine/forms/booking/notification/webhook/response', $response, $notification, $this );
}
/**
* Insert post notification
*
* @param [type] $notification [description]
* @return [type] [description]
*/
public function insert_post( $notification ) {
$post_type = ! empty( $notification['post_type'] ) ? $notification['post_type'] : false;
if ( ! $post_type || ! post_type_exists( $post_type ) ) {
return;
}
$fields_map = ! empty( $notification['fields_map'] ) ? $notification['fields_map'] : array();
$meta_input = array();
$terms_input = array();
$rels_input = array();
$object_fields = $this->manager->get_object_fields();
$has_title = false;
$postarr = array(
'post_type' => $post_type,
);
if ( ! empty( $notification['default_meta'] ) ) {
foreach ( $notification['default_meta'] as $meta_row ) {
if ( ! empty( $meta_row['key'] ) ) {
$meta_input[ $meta_row['key'] ] = $meta_row['value'];
}
}
}
foreach ( $this->data as $key => $value ) {
$key_found_in_map = false;
if ( ! empty( $fields_map[ $key ] ) ) {
$key = esc_attr( $fields_map[ $key ] );
$key_found_in_map = true;
}
if ( 'Submit' === $key ) {
continue;
}
if ( ! in_array( $key, $object_fields ) ) {
if ( false !== strpos( $key, 'jet_tax__' ) ) {
$tax = str_replace( 'jet_tax__', '', $key );
if ( ! isset( $terms_input[ $tax ] ) ) {
$terms_input[ $tax ] = array();
}
if ( ! is_array( $value ) ) {
$terms_input[ $tax ][] = absint( $value );
} else {
$terms_input[ $tax ] = array_merge( $terms_input[ $tax ], array_map( 'absint', $value ) );
}
} else {
if ( jet_engine()->relations && jet_engine()->relations->is_relation_key( $key ) ) {
$rels_input[ $key ] = $value;
} else {
if ( $this->is_repeater_val( $value ) ) {
$prepared_value = array();
foreach ( $value as $index => $row ) {
$prepared_row = array();
foreach ( $row as $item_key => $item_value ) {
$item_key = ! empty( $fields_map[ $item_key ] ) ? esc_attr( $fields_map[ $item_key ] ) : $item_key;
$prepared_row[ $item_key ] = $item_value;
}
$prepared_value[ 'item-' . $index ] = $prepared_row;
}
if ( $key_found_in_map ) {
$meta_input[ $key ] = $prepared_value;
}
} elseif ( $key_found_in_map ) {
$meta_input[ $key ] = $value;
}
}
}
} else {
$postarr[ $key ] = $value;
if ( 'post_title' === $key ) {
$has_title = true;
}
}
}
$post_status = ! empty( $notification['post_status'] ) ? $notification['post_status'] : '';
if ( $post_status && 'keep-current' !== $post_status ) {
$postarr['post_status'] = $post_status;
}
$postarr['meta_input'] = $meta_input;
$post_type_obj = get_post_type_object( $post_type );
$pre_post_check = apply_filters( 'jet-engine/forms/insert-post/pre-check', true, $postarr, $notification, $this );
if ( ! $pre_post_check ) {
return;
}
if ( ! empty( $postarr['ID'] ) ) {
$post = get_post( $postarr['ID'] );
if ( ! $post || ( absint( $post->post_author ) !== get_current_user_id() && ! current_user_can( 'edit_others_posts' ) ) ) {
$this->log[] = false;
return;
}
$post_id = wp_update_post( $postarr );
$post_action = 'update';
} else {
if ( ! $has_title ) {
$postarr['post_title'] = $post_type_obj->labels->singular_name . ' #';
}
$post_id = wp_insert_post( $postarr );
$post_action = 'insert';
}
$this->data['inserted_post_id'] = $post_id;
$this->handler->form_data['inserted_post_id'] = $post_id;
/**
* Perform any actions after post inserted/updated
*/
do_action( 'jet-engine/forms/notifications/after-post-' . $post_action, $notification, $this );
if ( $post_id ) {
if ( ! empty( $terms_input ) ) {
foreach ( $terms_input as $tax => $terms ) {
$res = wp_set_post_terms( $post_id, $terms, $tax );
}
}
if ( ! $has_title && empty( $postarr['ID'] ) ) {
$title = $post_type_obj->labels->singular_name . ' #' . $post_id;
wp_update_post( array(
'ID' => $post_id,
'post_title' => $title,
) );
}
if ( ! empty( $rels_input ) ) {
foreach ( $rels_input as $rel_key => $rel_posts ) {
jet_engine()->relations->process_meta( false, $post_id, $rel_key, $rel_posts );
}
}
$this->log[] = true;
} else {
$this->log[] = false;
}
}
public function is_repeater_val( $value ) {
if ( is_array( $value ) && ! empty( $value ) ) {
return isset( $value[0] ) && is_array( $value[0] );
} else {
return false;
}
}
/**
* Regsiter new user notification callback
*
* @return [type] [description]
*/
public function register_user( $notification ) {
if ( is_user_logged_in() ) {
if ( 1 === count( $this->notifications ) ) {
$this->log[] = $this->set_specific_status( 'already_logged_in' );
return;
} else {
$this->log[] = true;
}
if ( $notification['add_user_id'] ) {
$this->data['user_id'] = get_current_user_id();
$this->handler->form_data['user_id'] = get_current_user_id();
}
return;
}
$fields_map = ! empty( $notification['fields_map'] ) ? $notification['fields_map'] : array();
// Prepare fields
$username = false;
$email = false;
$password = false;
$fname = false;
$lname = false;
$user_url = false;
// If fields map for login, password or email is not set - abort but allow submit form (its not user fault)
if ( empty( $fields_map['login'] ) || empty( $fields_map['email'] ) || empty( $fields_map['password'] ) ) {
$this->log[] = true;
return;
}
/**
* Validate username
*/
$raw_username = ! empty( $this->data[ $fields_map['login'] ] ) ? $this->data[ $fields_map['login'] ] : false;
if ( ! $raw_username ) {
return $this->set_specific_status( 'empty_username' );
}
$username = sanitize_user( $raw_username );
if ( $username !== $raw_username ) {
return $this->set_specific_status( 'sanitize_user' );
}
if ( username_exists( $username ) ) {
return $this->set_specific_status( 'username_exists' );
}
// username - ok
/**
* Validate email
*/
$raw_email = ! empty( $this->data[ $fields_map['email'] ] ) ? $this->data[ $fields_map['email'] ] : false;
if ( ! $raw_email ) {
return $this->set_specific_status( 'empty_email' );
}
$email = sanitize_email( $raw_email );
if ( $email !== $raw_email ) {
return $this->set_specific_status( 'empty_email' );
}
if ( email_exists( $email ) ) {
return $this->set_specific_status( 'email_exists' );
}
// email - ok
/**
* Validate password
*/
$password = ! empty( $this->data[ $fields_map['password'] ] ) ? $this->data[ $fields_map['password'] ] : false;
if ( ! $password ) {
return $this->set_specific_status( 'empty_password' );
}
if ( ! empty( $fields_map['confirm_password'] ) ) {
$confirm_password = ! empty( $this->data[ $fields_map['confirm_password'] ] ) ? $this->data[ $fields_map['confirm_password'] ] : false;
if ( $confirm_password !== $password ) {
return $this->set_specific_status( 'password_mismatch' );
}
}
// password - ok
if ( ! empty( $fields_map['first_name'] ) ) {
$fname = ! empty( $this->data[ $fields_map['first_name'] ] ) ? $this->data[ $fields_map['first_name'] ] : false;
}
if ( ! empty( $fields_map['last_name'] ) ) {
$lname = ! empty( $this->data[ $fields_map['last_name'] ] ) ? $this->data[ $fields_map['last_name'] ] : false;
}
if ( ! empty( $fields_map['user_url'] ) ) {
$user_url = ! empty( $this->data[ $fields_map['user_url'] ] ) ? $this->data[ $fields_map['user_url'] ] : false;
}
$metafields_map = ! empty( $notification['meta_fields_map'] ) ? $notification['meta_fields_map'] : array();
$metadata = array();
if ( ! empty( $metafields_map ) ) {
foreach ( $metafields_map as $form_field => $meta_field ) {
if ( ! empty( $this->data[ $form_field ] ) ) {
$metadata[ $meta_field ] = $this->data[ $form_field ];
}
}
}
$userarr = array(
'user_pass' => $password,
'user_login' => $username,
'user_email' => $email,
'first_name' => $fname,
'last_name' => $lname,
'user_url' => $user_url,
);
if ( ! empty( $notification['user_role'] ) && 'administrator' !== $notification['user_role'] ) {
$userarr['role'] = $notification['user_role'];
}
$user_id = wp_insert_user( $userarr );
if ( ! is_wp_error( $user_id ) ) {
$this->log[] = true;
if ( ! empty( $metadata ) ) {
foreach ( $metadata as $meta_key => $meta_value ) {
if ( $this->is_repeater_val( $meta_value ) ) {
$prepared_value = array();
foreach ( $meta_value as $index => $row ) {
$prepared_row = array();
foreach ( $row as $item_key => $item_value ) {
$item_key = ! empty( $metafields_map[ $item_key ] ) ? esc_attr( $metafields_map[ $item_key ] ) : $item_key;
$prepared_row[ $item_key ] = $item_value;
}
$prepared_value[ 'item-' . $index ] = $prepared_row;
}
$meta_value = $prepared_value;
}
update_user_meta( $user_id, $meta_key, $meta_value );
}
}
if ( ! empty( $notification['log_in'] ) ) {
wp_signon( array(
'user_login' => $username,
'user_password' => $password,
) );
// If form submitted by AJAX - we need to reload page to ensure user is logged in
if ( $this->handler->is_ajax() ) {
$this->handler->add_response_data( array( 'reload' => true ) );
}
}
if ( ! empty( $notification['add_user_id'] ) && $notification['add_user_id'] ) {
$this->data['user_id'] = $user_id;
$this->handler->form_data['user_id'] = $user_id;
}
} else {
$this->log[] = false;
}
}
/**
* Update user notification handler
*
* @return [type] [description]
*/
public function update_user( $notification ) {
$fields_map = ! empty( $notification['fields_map'] ) ? $notification['fields_map'] : array();
$fields_map = array_filter( $fields_map );
$data_map = array();
foreach ( $this->data as $field => $field_value ) {
if ( ! empty( $fields_map[ $field ] ) ) {
$prop = $fields_map[ $field ];
$data_map[ $prop ] = ! empty( $field_value ) ? $field_value : false;
}
}
//$data_map = array_filter( $data_map );
$user_meta = array();
$user = array(
'user_nicename' => false,
'user_url' => false,
'display_name' => false,
'nickname' => false,
'first_name' => false,
'last_name' => false,
'description' => false,
);
if ( ! is_user_logged_in() ) {
// Only logged in users can edit other users
return $this->set_specific_status( 'internal_error' );
}
if ( empty( $data_map['ID'] ) ) {
return $this->set_specific_status( 'sanitize_user' );
}
foreach ( $user as $key => $value ) {
if ( isset( $data_map[ $key ] ) ) {
$user[ $key ] = $data_map[ $key ];
unset( $data_map[ $key ] );
}
}
$user['ID'] = absint( $data_map['ID'] );
$updated_user = get_user_by( 'ID', $user['ID'] );
unset( $data_map['ID'] );
if ( ! $updated_user || is_wp_error( $updated_user ) ) {
return $this->set_specific_status( 'internal_error' );
}
if ( get_current_user_id() !== $user['ID'] && ! current_user_can( 'edit_users' ) ) {
// Only users with appropriate capabilities can edit other users, also user can edit himself
return $this->set_specific_status( 'internal_error' );
}
if ( ! empty( $data_map['email'] ) ) {
$email = sanitize_email( $data_map['email'] );
if ( $email !== $data_map['email'] ) {
return $this->set_specific_status( 'empty_email' );
}
$email_exists = email_exists( $email );
if ( $email_exists && $user['ID'] !== $email_exists ) {
return $this->set_specific_status( 'email_exists' );
}
// Email - ok
$user['user_email'] = $email;
unset( $data_map['email'] );
}
if ( ! empty( $data_map['password'] ) ) {
if ( isset( $data_map['confirm_password'] ) ) {
$pass = wp_check_invalid_utf8( $data_map['password'], true );
$confirm_pass = wp_check_invalid_utf8( $data_map['confirm_password'], true );
if ( $confirm_pass !== $pass ) {
return $this->set_specific_status( 'password_mismatch' );
}
$user['user_pass'] = $pass;
unset( $data_map['password'] );
unset( $data_map['confirm_password'] );
} else {
$user['user_pass'] = wp_check_invalid_utf8( $data_map['password'], true );
unset( $data_map['password'] );
}
}
$user = array_filter( $user );
wp_update_user( $user );
if ( ! empty( $notification['user_role'] ) && 'administrator' !== $notification['user_role'] ) {
$updated_user->set_role( $notification['user_role'] );
}
if ( ! empty( $data_map ) ) {
foreach ( $data_map as $meta_key => $meta_value ) {
if ( $this->is_repeater_val( $meta_value ) ) {
$prepared_value = array();
foreach ( $meta_value as $index => $row ) {
$prepared_row = array();
foreach ( $row as $item_key => $item_value ) {
$item_key = ! empty( $fields_map[ $item_key ] ) ? esc_attr( $fields_map[ $item_key ] ) : $item_key;
$prepared_row[ $item_key ] = $item_value;
}
$prepared_value[ 'item-' . $index ] = $prepared_row;
}
$meta_value = $prepared_value;
}
update_user_meta( $user['ID'], $meta_key, $meta_value );
}
}
$this->log[] = true;
}
/**
* Set specific form status and return error
*
* @param [type] $status [description]
* @param boolean $log [description]
*/
public function set_specific_status( $status = null, $log = false ) {
$this->specific_status = $status;
$this->log[] = false;
}
/**
* Returns specific status
*
* @return [type] [description]
*/
public function get_specific_status() {
return $this->specific_status;
}
/**
* Insert post notification
*
* @param [type] $notification [description]
* @return [type] [description]
*/
public function email( $notification ) {
$mail_to = ! empty( $notification['mail_to'] ) ? $notification['mail_to'] : 'admin';
$reply_to = ! empty( $notification['reply_to'] ) ? $notification['reply_to'] : 'form';
$email = false;
$reply_email = false;
switch ( $mail_to ) {
case 'admin':
$email = get_option( 'admin_email' );
break;
case 'form':
$field = ! empty( $notification['from_field'] ) ? $notification['from_field'] : '';
if ( $field && ! empty( $this->data[ $field ] ) ) {
$email = $this->data[ $field ];
}
break;
case 'custom':
$email = ! empty( $notification['custom_email'] ) ? $notification['custom_email'] : '';
break;
}
switch ( $reply_to ) {
case 'form':
$field = ! empty( $notification['reply_from_field'] ) ? $notification['reply_from_field'] : '';
if ( $field && ! empty( $this->data[ $field ] ) ) {
$reply_email = $this->data[ $field ];
}
break;
case 'custom':
$reply_email = ! empty( $notification['reply_to_email'] ) ? $notification['reply_to_email'] : '';
break;
}
if ( ! $email || ! is_email( $email ) ) {
return;
}
$this->email_data = ! empty( $notification['email'] ) ? $notification['email'] : array();
$this->email_data['reply_email'] = $reply_email;
$subject = ! empty( $this->email_data['subject'] ) ? $this->email_data['subject'] : sprintf(
__( 'Form on %s Submitted', 'jet-engine' ),
home_url( '' )
);
$message = ! empty( $this->email_data['content'] ) ? apply_filters( 'jet-engine/forms/booking/email/message_content', $this->email_data['content'], $this ) : '';
$this->send_mail( $email, $subject, $message );
}
/**
* Send the email
* @param string $to The To address to send to.
* @param string $subject The subject line of the email to send.
* @param string $message The body of the email to send.
*/
public function send_mail( $to, $subject, $message ) {
/**
* Hooks before the email is sent
*/
do_action( 'jet-engine/forms/booking/email/send-before', $this );
$content_type = $this->get_content_type();
$subject = $this->parse_macros( $subject );
$message = $this->parse_macros( $message );
if ( 'text/html' === $content_type ) {
$message = wpautop( $message );
$message = make_clickable( $message );
}
$message = str_replace( '&', '&', $message );
$sent = wp_mail( $to, $subject, $message, $this->get_headers() );
$log_errors = apply_filters( 'jet-engine/forms/booking/email/log-errors', true, $to, $subject, $message );
// Test
$log_errors = false;
if( ! $sent && true === $log_errors ) {
if ( is_array( $to ) ) {
$to = implode( ',', $to );
}
$log_message = sprintf(
__( "Email from JetEngine Booking Form failed to send.\nSend time: %s\nTo: %s\nSubject: %s\nContent: %s\n\n", 'jet-engine' ),
date_i18n( 'F j Y H:i:s', current_time( 'timestamp' ) ),
$to,
$subject,
$message
);
error_log( $log_message );
$this->log[] = false;
} else {
$this->log[] = true;
}
/**
* Hooks after the email is sent
*
* @since 2.1
*/
do_action( 'jet-engine/forms/booking/email/send-after', $this );
return $sent;
}
/**
* Get the email headers
*
* @since 2.1
*/
public function get_headers() {
$this->headers = "From: {$this->get_from_name()} <{$this->get_from_address()}>\r\n";
$this->headers .= "Reply-To: {$this->get_reply_to()}\r\n";
$this->headers .= "Content-Type: {$this->get_content_type()}; charset=utf-8\r\n";
return apply_filters( 'jet-engine/forms/booking/email/headers', $this->headers, $this );
}
/**
* Parse macros in content
*
* @param [type] $content [description]
* @return [type] [description]
*/
public function parse_macros( $content ) {
return preg_replace_callback( '/%(.*?)(\|([a-zA-Z0-9\(\)_-]+))?%/', function( $match ) {
if ( isset( $this->data[ $match[1] ] ) ) {
if ( jet_engine()->listings && ! empty( $match[3] ) ) {
return jet_engine()->listings->filters->apply_filters(
$this->data[ $match[1] ], $match[3]
);
} else {
if ( is_array( $this->data[ $match[1] ] ) ) {
if ( ! empty( $this->handler->repeaters[ $match[1] ] ) ) {
return $this->verbose_repeater( $this->data[ $match[1] ] );
} else {
return implode( ', ', $this->data[ $match[1] ] );
}
} else {
return $this->data[ $match[1] ];
}
}
} else {
return $match[0];
}
}, $content );
}
/**
* Verbose repeater items array
*/
public function verbose_repeater( $items = array() ) {
$result = '';
$index = 1;
foreach ( $items as $item ) {
$item_data = array();
foreach ( $item as $key => $value ) {
$item_data[] = sprintf( '%1$s: %2$s', $key, $value );
}
$result .= $index . ') ' . implode( ', ', $item_data ) . ';<br>';
$index++;
}
return $result;
}
/**
* Run a hook notification
*
* @param [type] $notification [description]
* @return [type] [description]
*/
public function hook( $notification ) {
$hook = ! empty( $notification['hook_name'] ) ? $notification['hook_name'] : 'send';
/**
* Fires custom hook. Keep action for backward compatibility.
*
* @var string
*/
do_action( 'jet-engine-booking/' . $hook, $this->data, $this->form, $this );
/**
* Fires custm hook as filter to allow form validation on hook.
* Use this to perform an action on the hook and return validation result.
*
* @var bool
*/
$result = apply_filters( 'jet-engine-booking/filter/' . $hook, true, $this->data, $this->form, $this );
$this->log[] = $result;
}
/**
* Add filters / actions before the email is sent
*
* @since 2.1
*/
public function send_before() {
add_filter( 'wp_mail_from', array( $this, 'get_from_address' ) );
add_filter( 'wp_mail_from_name', array( $this, 'get_from_name' ) );
add_filter( 'wp_mail_content_type', array( $this, 'get_content_type' ) );
}
/**
* Remove filters / actions after the email is sent
*
* @since 2.1
*/
public function send_after() {
remove_filter( 'wp_mail_from', array( $this, 'get_from_address' ) );
remove_filter( 'wp_mail_from_name', array( $this, 'get_from_name' ) );
remove_filter( 'wp_mail_content_type', array( $this, 'get_content_type' ) );
// Reset heading to an empty string
$this->heading = '';
}
/**
* Get the email from name
*/
public function get_from_name() {
$name = ! empty( $this->email_data['from_name'] ) ? $this->email_data['from_name'] : get_bloginfo( 'name' );
return apply_filters( 'jet-engine/forms/booking/email/from-name', wp_specialchars_decode( $name ), $this );
}
/**
* Returns e-mail address to set into Reply-to email header
*
* @return [type] [description]
*/
public function get_reply_to() {
$address = ! empty( $this->email_data['reply_email'] ) ? $this->email_data['reply_email'] : '';
if ( empty( $address ) || ! is_email( $address ) ) {
$address = $this->get_from_address();
}
return apply_filters( 'jet-engine/forms/booking/email/reply-to', $address, $this );
}
/**
* Get the email from address
*/
public function get_from_address() {
$address = ! empty( $this->email_data['from_address'] ) ? $this->email_data['from_address'] : '';
if ( empty( $address ) || ! is_email( $address ) ) {
$address = get_option( 'admin_email' );
}
return apply_filters( 'jet-engine/forms/booking/email/from-address', $address, $this );
}
/**
* Get the email content type
*/
public function get_content_type() {
$type = ! empty( $this->email_data['content_type'] ) ? $this->email_data['content_type'] : 'text/html';
return apply_filters( 'jet-engine/forms/booking/email/content-type', $type, $this );
}
/**
* Call a ActiveCampaign notification
*
* @param array $notification
* @return void
*/
public function activecampaign( $notification ) {
if ( empty( $notification['activecampaign']['api_url'] ) || empty( $notification['activecampaign']['api_key'] ) ) {
return;
}
$api_url = $notification['activecampaign']['api_url'];
$api_key = $notification['activecampaign']['api_key'];
$request_url = add_query_arg(
array(
'api_action' => 'contact_sync',
'api_key' => $api_key,
'api_output' => 'json',
),
esc_url( rtrim( $api_url, '/' ) . '/admin/api.php' )
);
$body_args = array();
$fields_map = ! empty( $notification['activecampaign']['fields_map'] ) ? $notification['activecampaign']['fields_map'] : array();
foreach ( $fields_map as $param => $field ) {
if ( empty( $field ) || empty( $this->data[ $field ] ) ) {
continue;
}
$body_args[ $param ] = $this->data[ $field ];
}
$list_id = ! empty( $notification['activecampaign']['list_id'] ) ? $notification['activecampaign']['list_id'] : false;
if ( $list_id ) {
$body_args[ 'p[' . $list_id . ']' ] = $list_id;
}
if ( ! empty( $notification['activecampaign']['tags'] ) ) {
$body_args['tags'] = $notification['activecampaign']['tags'];
}
if ( empty( $body_args['email'] ) ) {
return;
}
$response = wp_remote_post(
$request_url,
array(
'body' => $body_args,
'timeout' => 30,
)
);
if ( ! $response || is_wp_error( $response ) ) {
return;
}
$data = wp_remote_retrieve_body( $response );
if ( ! $data ) {
return;
}
$data = json_decode( $data, true );
// Error response
if ( empty( $data['result_code'] ) ) {
return;
}
$this->log[] = true;
}
/**
* Call a MailChimp notification
*
* @param array $notification
* @return void
*/
public function mailchimp( $notification ) {
if ( empty( $notification['mailchimp']['api_key'] ) || empty( $notification['mailchimp']['list_id'] ) ) {
return;
}
$api_key = $notification['mailchimp']['api_key'];
$handler = new Jet_Engine_Forms_MailChimp_Handler( $api_key );
if ( is_wp_error( $handler ) ) {
return;
}
$status_if_new = isset( $notification['mailchimp']['double_opt_in'] ) && filter_var( $notification['mailchimp']['double_opt_in'], FILTER_VALIDATE_BOOLEAN ) ? 'pending' : 'subscribed';
$body_args = array(
'status' => 'subscribed',
'status_if_new' => $status_if_new,
);
$fields_map = ! empty( $notification['mailchimp']['fields_map'] ) ? $notification['mailchimp']['fields_map'] : array();
foreach ( $fields_map as $param => $field ) {
if ( empty( $field ) || empty( $this->data[ $field ] ) ) {
continue;
}
switch ( $param ) {
case 'email':
$body_args['email_address'] = $this->data[ $field ];
break;
case 'BIRTHDAY':
$date_value = $this->data[ $field ];
if ( ! Jet_Engine_Tools::is_valid_timestamp( $date_value ) ) {
$date_value = strtotime( $date_value );
}
$body_args['merge_fields'][ $param ] = date( 'm/d', $date_value );
break;
default:
$body_args['merge_fields'][ $param ] = $this->data[ $field ];
}
}
if ( empty( $body_args['email_address'] ) ) {
return;
}
if ( ! empty( $notification['mailchimp']['groups_ids'] ) && is_array( $notification['mailchimp']['groups_ids'] ) ) {
foreach ( $notification['mailchimp']['groups_ids'] as $groups_id ) {
$body_args['interests'][ $groups_id ] = true;
}
}
if ( ! empty( $notification['mailchimp']['tags'] ) ) {
$body_args['tags'] = explode( ',', trim( $notification['mailchimp']['tags'] ) );
}
$end_point = sprintf( 'lists/%1$s/members/%2$s', $notification['mailchimp']['list_id'], md5( strtolower( $body_args['email_address'] ) ) );
$request_args = array(
'method' => 'PUT',
'body' => json_encode( $body_args ),
'headers' => array(
'Content-Type' => 'application/json; charset=utf-8',
),
);
$response = $handler->request( $end_point, $request_args );
if ( false === $response ) {
$this->set_specific_status( 'internal_error' );
return;
}
if ( isset( $response['status'] ) && ! in_array( $response['status'], $handler->success_statuses ) ) {
if ( isset( $response['title'] ) ) {
$this->set_specific_status( $response['title'] );
}
return;
}
// Error response
if ( empty( $response['id'] ) ) {
return;
}
$this->log[] = true;
}
/**
* Call a GetResponse notification
*
* @param array $notification
* @return void
*/
public function getresponse( $notification ) {
if ( empty( $notification['getresponse']['api_key'] ) || empty( $notification['getresponse']['list_id'] ) ) {
return;
}
$api_key = $notification['getresponse']['api_key'];
$handler = new Jet_Engine_Forms_GetResponse_Handler( $api_key );
if ( is_wp_error( $handler ) ) {
return;
}
$body_args = array(
'campaign' => array( 'campaignId' => $notification['getresponse']['list_id'] ),
);
if ( isset( $notification['getresponse']['day_of_cycle'] ) ) {
$body_args['dayOfCycle'] = (int) $notification['getresponse']['day_of_cycle'];
}
$fields_map = ! empty( $notification['getresponse']['fields_map'] ) ? $notification['getresponse']['fields_map'] : array();
$custom_fields_values = array();
foreach ( $fields_map as $param => $field ) {
if ( empty( $field ) || empty( $this->data[ $field ] ) ) {
continue;
}
if ( in_array( $param, array( 'email', 'name' ) ) ) {
$body_args[ $param ] = $this->data[ $field ];
} else {
$custom_fields_values[] = array(
'customFieldId' => $param,
'value' => array( $this->data[ $field ] ),
);
}
}
if ( ! empty( $custom_fields_values ) ) {
$body_args['customFieldValues'] = $custom_fields_values;
}
if ( empty( $body_args['email'] ) ) {
return;
}
$request_args = array(
'method' => 'POST',
'body' => json_encode( $body_args ),
);
$response = $handler->request( 'contacts', $request_args );
if ( false === $response ) {
$this->set_specific_status( 'internal_error' );
return;
}
// Error response
if ( isset( $response['httpStatus'] ) && isset( $response['code'] ) ) {
return;
}
$this->log[] = true;
}
/**
* Call a Update Options notification
*
* @return void
*/
public function update_options( $notification ) {
$fields_map = ! empty( $notification['meta_fields_map'] ) ? $notification['meta_fields_map'] : array();
$options_data = array();
if ( empty( $notification['options_page'] ) ) {
return;
}
if ( ! empty( $fields_map ) ) {
foreach ( $fields_map as $form_field => $option_field ) {
if ( ! empty( $option_field ) && ! empty( $this->data[ $form_field ] ) ) {
$options_data[ $option_field ] = $this->data[ $form_field ];
}
}
}
if ( empty( $options_data ) ) {
return;
}
$option_name = $notification['options_page'];
$current_value = get_option( $option_name, array() );
$new_value = array_merge( $current_value, $options_data );
update_option( $option_name, $new_value );
$this->log[] = true;
}
}
}