<?php
/**
 * Form notifications class
 */

// If this file is called directly, abort.
if ( ! defined( 'WPINC' ) ) {
	die;
}

use Jet_Engine\Modules\Forms\Tabs\Tab_Manager;

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;

		public $action_tabs = array();

		/**
		 * Constructor for the class
		 */
		function __construct( $form = null, $data = array(), $manager = null, $handler = null ) {

			$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' ) );

			$this->action_tabs = jet_engine()->forms->editor->action_tabs();

		}


		/**
		 * 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->legacy->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->legacy->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 ) {
			$allow_register    = isset( $notification['allow_register'] ) ? $notification['allow_register'] : false;
			$role_can_register = isset( $notification['role_can_register'] ) ? $notification['role_can_register'] : false;

			if ( $allow_register && ! $role_can_register ) {
				$this->set_specific_status( __( '"role_can_register" is empty', 'jet-engine' ) );

				return;
			}

			if ( is_user_logged_in() ) {

				$user = wp_get_current_user();

				if ( $allow_register && ! in_array( $role_can_register, $user->roles ) ) {
					$this->set_specific_status( __( 'Not enough capabilities', 'jet-engine' ) );

					return;
				}

				if ( ! $allow_register && 1 === count( $this->notifications ) ) {
					$this->log[] = $this->set_specific_status( 'already_logged_in' );

					return;
				} else {
					$this->log[] = true;
				}

				if ( ! empty( $notification['add_user_id'] ) ) {
					$this->data['user_id']               = get_current_user_id();
					$this->handler->form_data['user_id'] = get_current_user_id();
				}

				if ( ! $allow_register ) {
					return;
				}

			} elseif ( $allow_register ) {
				$this->set_specific_status( __( 'Not Logged in', 'jet-engine' ) );

				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,
			);

			// Addings users with Administrator is not allowed
			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 ] );
				} else {
					unset( $user[ $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'] );
				}

			}

			// Maybe updating the user `display_name` property.
			if ( empty( $user['display_name'] ) ) {

				if ( $updated_user->display_name === $updated_user->first_name ) {

					if ( ! empty( $user['first_name'] ) ) {
						$user['display_name'] = $user['first_name'];
					}

				} elseif ( $updated_user->display_name === $updated_user->last_name ) {

					if ( ! empty( $user['last_name'] ) ) {
						$user['display_name'] = $user['last_name'];
					}

				} elseif ( $updated_user->display_name === $updated_user->first_name . ' ' . $updated_user->last_name ) {

					if ( ! empty( $user['first_name'] ) && ! empty( $user['last_name'] ) ) {
						$user['display_name'] = $user['first_name'] . ' ' . $user['last_name'];
					}

				} elseif ( $updated_user->display_name === $updated_user->last_name . ' ' . $updated_user->first_name ) {

					if ( ! empty( $user['first_name'] ) && ! empty( $user['last_name'] ) ) {
						$user['display_name'] = $user['last_name'] . ' ' . $user['first_name'];
					}

				}
			}

			// $user = array_filter( $user );

			// Updating user role to Administrator is not allowed
			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'] : false;
			$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 );
			$message      = wp_unslash( $message );
			$message      = do_shortcode( $message );

			if ( 'text/html' === $content_type ) {
				$message = wpautop( $message );
				$message = make_clickable( $message );
			}

			$message    = str_replace( '&#038;', '&amp;', $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\(\)\.\,\:\/\s_-]+))?%/', 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' );
			$name = $this->parse_macros( $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'] : '';
			$address = $this->parse_macros( $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 ) {

			$notification['activecampaign'] = $this->get_settings_with_global(
				$notification['activecampaign'],
				'active-campaign'
			);

			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 ) {

			$notification['mailchimp'] = $this->get_settings_with_global( $notification['mailchimp'], 'mailchimp' );

			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 ) {

			$notification['getresponse'] = $this->get_settings_with_global( $notification['getresponse'], 'get-response' );

			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 ) ) {
						$options_data[ $option_field ] = ! empty( $this->data[ $form_field ] ) ? $this->data[ $form_field ] : false;
					}
				}
			}

			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;
		}

		public function get_settings_with_global( $current, $type ) {
			if (
				! isset( $current['use_global'] )
				|| ! $current['use_global']
			) {
				return $current;
			}

			return array_merge( $current, Tab_Manager::instance()->options( $type ) );
		}

	}

}
