<?php

if ( ! defined( 'ABSPATH' ) ) {
	exit; // Exit if accessed directly.
}

/**
 * Class AnyCommentEmailQueue keeps data about emails to be send to users.
 *
 * @property int $ID
 * @property string|null $email
 * @property string $subject
 * @property int $post_ID
 * @property int $comment_ID
 * @property string $content Content of the email.
 * @property string|null $ip
 * @property string|null $user_agent
 * @property bool $is_sent
 * @property datetime $created_at
 *
 * @since 0.0.3
 */
class AnyCommentEmailQueue {

	public $ID;
	public $subject;
	public $post_ID;
	public $comment_ID;
	public $content;
	public $user_agent;
	public $ip;
	public $is_sent = 0;
	public $created_at;

	/**
	 * AnyCommentEmailQueue constructor.
	 */
	public function __construct() {
		$this->created_at = current_time( 'mysql' );
	}

	/**
	 * Get table name.
	 *
	 * @return string
	 */
	public static function tableName() {
		global $wpdb;

		return $wpdb->prefix . 'anycomment_email_queue';
	}

	/**
	 * @return wpdb
	 */
	public static function db() {
		global $wpdb;

		return $wpdb;
	}

	/**
	 * Get latest
	 * @return AnyCommentEmailQueue|null|object
	 */
	public static function get_newest() {
		$tableName = static::tableName();
		$sql       = "SELECT * FROM `$tableName` ORDER BY `id` DESC LIMIT 1";

		return static::db()->get_row( $sql );
	}

	/**
	 * Grab emails to be sent.
	 *
	 * @return null|AnyCommentEmailQueue[]
	 */
	public static function grab_replies_to_send() {
		$tableName = static::tableName();
		$sql       = "SELECT `emails`.* FROM `$tableName` `emails` WHERE `emails`.`is_sent` = 0";

		return static::db()->get_results( $sql );
	}

	/**
	 * Check whether specified email ID was already sent or not.
	 *
	 * @param int $email_id Email ID to check for.
	 *
	 * @return bool
	 */
	public static function is_sent( $email_id ) {
		if ( empty( $email_id ) || ! is_numeric( $email_id ) ) {
			return false;
		}

		$tableName = static::tableName();
		$query     = static::db()->prepare( "SELECT `id`, `is_sent` FROM `$tableName` WHERE `id`=%d LIMIT 1", [ $email_id ] );

		/**
		 * @var $model AnyCommentEmailQueue|null
		 */
		$model = static::db()->get_row( $query );

		if ( empty( $model ) ) {
			return false;
		}

		if ( (int) $model->is_sent === 0 ) {
			return false;
		}

		return true;
	}

	/**
	 * Mark email as sent.
	 *
	 * Notice: when email is already sent, method will return true.
	 *
	 * @param int $email_id Email to be updated.
	 *
	 * @return bool
	 */
	public static function mark_as_sent( $email_id ) {
		if ( empty( $email_id ) || ! is_numeric( $email_id ) ) {
			return false;
		}

		if ( static::is_sent( $email_id ) ) {
			return true;
		}

		$isUpdated = static::db()->update( static::tableName(), [ 'is_sent' => 1 ], [ 'ID' => $email_id ] );

		return $isUpdated !== false;
	}

	/**
	 * Add specified comment as reply if applicable.
	 * Method will check:
	 * - whether specified comment is child comment
	 * - not a reply to the same user
	 * - make sure parent user has email (some socials do not provide email in the API)
	 *
	 * @param WP_Comment $comment Instance of comment model.
	 *
	 * @return AnyCommentEmailQueue|bool|int
	 */
	public static function add_as_reply( $comment ) {

		if ( ! $comment instanceof WP_Comment || (int) $comment->comment_parent === 0 ) {
			return false;
		}

		$db            = static::db();
		$usersTable    = $db->users;
		$commentsTable = $db->comments;

		// In case when parent comment is left by registered user (social or by WordPress registration)
		$query = "SELECT `comments`.*, `users`.`user_email` AS `userTableEmail` FROM `$commentsTable` `comments` 
LEFT JOIN `$commentsTable` `innerComment` ON `innerComment`.`comment_ID` = `comments`.`comment_parent` 
LEFT JOIN `$usersTable` `users` ON `users`.`ID` = `innerComment`.`user_ID` 
WHERE `comments`.`comment_parent` != 0 
AND `users`.`user_email` != '' 
AND `comments`.`user_ID` != `innerComment`.`user_ID` 
AND `comments`.`comment_ID`=%d";


		$result = static::db()->get_row( static::db()->prepare( $query, [ $comment->comment_ID ] ) );

		// In case when parent comment is from guest
		$parentCommentEmail = get_comment_author_email( $comment->comment_parent );

		if ( empty( $result ) && empty( $parentCommentEmail ) ) {
			return false;
		}

		if ( $parentCommentEmail === $comment->comment_author_email ) {
			return false;
		}

		$model = new self();

		$post = get_post( $comment->comment_post_ID );

		if ( $post !== null ) {
			$subject = sprintf( __( "Re: Comment on %s", 'anycomment' ), $post->post_title );
		} else {
			$subject = sprintf( __( 'Re: Comment on %s', 'anycomment' ), get_option( 'blogname' ) );
		}

		$model->subject    = $subject;
		$model->email      = ! empty( $result ) ? $result->userTableEmail : $parentCommentEmail;
		$model->post_ID    = $comment->comment_post_ID;
		$model->comment_ID = $comment->comment_ID;
		$model->content    = AnyCommentEmailQueue::generate_reply_email( $model );

		$isAdded = AnyCommentEmailQueue::add( $model );

		return $isAdded;
	}

	/**
	 * Method can be used to add email notification about new comment to admin.
	 *
	 * @param WP_Comment $comment Comment to be added as notification to admin.
	 *
	 * @return AnyCommentEmailQueue|bool|int
	 */
	public static function add_as_admin_notification( $comment ) {
		if ( ! $comment instanceof WP_Comment ) {
			return false;
		}

		$adminEmail = get_option( 'new_admin_email' );

		$user = get_user_by( 'email', $adminEmail );

		if ( ! $user instanceof WP_User ) {
			return false;
		}

		if ( $comment->comment_author_email === $adminEmail ) {
			return false;
		}

		$email = new self();

		$post = get_post( $comment->comment_post_ID );

		if ( $post !== null ) {
			$subject = sprintf( __( "New Comment on %s", 'anycomment' ), $post->post_title );
		} else {
			$subject = sprintf( __( 'New Comment on %s', 'anycomment' ), get_option( 'blogname' ) );
		}

		$email->email      = $adminEmail;
		$email->subject    = $subject;
		$email->post_ID    = $comment->comment_post_ID;
		$email->comment_ID = $comment->comment_ID;
		$email->content    = AnyCommentEmailQueue::generate_admin_email( $email );

		$isAdded = AnyCommentEmailQueue::add( $email, 'bool' );

		return $isAdded;
	}

	/**
	 * Method can be used to add email notification about new comment to subscribers.
	 *
	 * @param string $subscriber_email Subscriber email.
	 * @param WP_Comment $comment Comment to be added as notification.
	 *
	 * @return AnyCommentEmailQueue|bool|int
	 */
	public static function add_as_subscriber_notification( $subscriber_email, $comment ) {
		if ( ! $comment instanceof WP_Comment ) {
			return false;
		}

		$user = get_user_by( 'email', $subscriber_email );

		if ( ! $user instanceof WP_User ) {
			return false;
		}

		$email = new self();

		$post = get_post( $comment->comment_post_ID );

		if ( $post !== null ) {
			$subject = sprintf( __( "New Comment in %s", 'anycomment' ), $post->post_title );
		} else {
			$subject = sprintf( __( 'New Comment in %s', 'anycomment' ), get_option( 'blogname' ) );
		}

		$email->email      = $subscriber_email;
		$email->subject    = $subject;
		$email->post_ID    = $comment->comment_post_ID;
		$email->comment_ID = $comment->comment_ID;
		$email->content    = AnyCommentEmailQueue::generate_subscribe_email( $email );

		$isAdded = AnyCommentEmailQueue::add( $email, 'bool' );

		return $isAdded;
	}

	/**
	 * Add new email to queue.
	 *
	 * @param AnyCommentEmailQueue $email
	 * @param string $returnOnSuccess What to return on success.
	 * - ID - will return new record ID
	 * - OBJECT - will return email queue
	 *
	 * @return bool|int|AnyCommentEmailQueue
	 */
	public static function add( $email, $returnOnSuccess = 'ID' ) {
		if ( ! $email instanceof AnyCommentEmailQueue ) {
			return false;
		}

		if ( ! isset( $email->ip ) ) {
			$email->ip = AnyCommentHelper::get_user_ip();
		}

		if ( ! isset( $email->user_agent ) ) {
			$email->user_agent = AnyCommentHelper::get_user_agent();
		}

		if ( ! isset( $email->created_at ) ) {
			$email->created_at = current_time( 'mysql' );
		}

		global $wpdb;

		unset( $email->ID );

		$tableName = static::tableName();
		$count     = $wpdb->insert( $tableName, (array) $email );

		if ( $count !== false && $count > 0 ) {
			$lastId = $wpdb->insert_id;

			if ( empty( $lastId ) ) {
				return false;
			}

			$email->ID = $lastId;

			if ( $returnOnSuccess === 'ID' ) {
				return $lastId;
			} elseif ( $returnOnSuccess === 'OBJECT' ) {
				return $email;
			}

			do_action( 'anycomment_queue_entry_created', $email );

			return true;
		}

		return false;
	}

	/**
	 * Prepare email body.
	 *
	 * Subs to replace:
	 * '{blogName}',
	 * '{blogUrl}',
	 * '{blogUrlHtml}',
	 * '{postTitle}',
	 * '{postUrl}',
	 * '{postUrlHtml}',
	 * '{commentText}',
	 * '{commentFormatted}',
	 * '{replyUrl}',
	 * '{replyButton}'
	 *
	 * @param AnyCommentEmailQueue $email
	 *
	 * @return string HTML formatted content of email.
	 */
	public static function generate_subscribe_email( $email ) {
		$comment        = get_comment( $email->comment_ID );
		$post           = get_post( $email->post_ID );
		$cleanPermalink = get_permalink( $post );
		$reply_url      = sprintf( '%s#comment-%s', $cleanPermalink, $comment->comment_ID );

		$blog_name     = get_option( 'blogname' );
		$blog_url      = get_option( 'siteurl' );
		$blog_url_html = sprintf( '<a href="%s">%s</a>', $blog_url, $blog_name );

		$post_title    = '';
		$post_url      = '';
		$post_url_html = '';

		$comment_text      = '';
		$comment_formatted = '';

		if ( $post !== null ) {
			$post_title    = $post->post_title;
			$post_url      = $cleanPermalink;
			$post_url_html = sprintf( '<a href="%s">%s</a>', $post_url, $post_title );
		}

		if ( $comment !== null ) {
			$comment_text = $comment->comment_content;

			$comment_formatted = '<div style="background-color:#eee; padding: 10px; font-size: 12pt; font-family: Verdana, Arial, sans-serif; line-height: 1.5;">';
			$comment_formatted .= $comment_text;
			$comment_formatted .= '</div>';
		}

		$reply_button = '<p><a href="' . $reply_url . '" style="font-size: 15px;text-decoration:none;font-weight: 400;text-align: center;color: #fff;padding: 0 50px;line-height: 48px;background-color: #53af4a;display: inline-block;vertical-align: middle;border: 0;outline: 0;cursor: pointer;-webkit-user-select: none;-moz-user-select: none;-ms-user-select: none;user-select: none;-webkit-appearance: none;-moz-appearance: none;appearance: none;white-space: nowrap;border-radius: 24px;">' . __( 'See', 'anycomment' ) . '</a></p>';

		$search = [
			'{blogName}',
			'{blogUrl}',
			'{blogUrlHtml}',
			'{postTitle}',
			'{postUrl}',
			'{postUrlHtml}',
			'{commentText}',
			'{commentFormatted}',
			'{replyUrl}',
			'{replyButton}',
		];

		$replacement = [
			$blog_name,
			$blog_url,
			$blog_url_html,
			$post_title,
			$post_url,
			$post_url_html,
			$comment_text,
			$comment_formatted,
			$reply_url,
			$reply_button,
		];

		$template = AnyCommentGenericSettings::get_notify_email_subscribers_template();

		return static::prepare_email_template( $template, $search, $replacement );
	}

	/**
	 * Prepare email body.
	 *
	 * Subs to replace:
	 * '{blogName}',
	 * '{blogUrl}',
	 * '{blogUrlHtml}',
	 * '{postTitle}',
	 * '{postUrl}',
	 * '{postUrlHtml}',
	 * '{commentText}',
	 * '{commentFormatted}',
	 * '{replyUrl}',
	 * '{replyButton}'
	 *
	 * @param AnyCommentEmailQueue $email
	 *
	 * @return string HTML formatted content of email.
	 */
	public static function generate_reply_email( $email ) {
		$comment        = get_comment( $email->comment_ID );
		$post           = get_post( $email->post_ID );
		$cleanPermalink = get_permalink( $post );
		$reply_url      = sprintf( '%s#comment-%s', $cleanPermalink, $comment->comment_ID );

		$blog_name     = get_option( 'blogname' );
		$blog_url      = get_option( 'siteurl' );
		$blog_url_html = sprintf( '<a href="%s">%s</a>', $blog_url, $blog_name );

		$post_title    = '';
		$post_url      = '';
		$post_url_html = '';

		$comment_text      = '';
		$comment_formatted = '';

		if ( $post !== null ) {
			$post_title    = $post->post_title;
			$post_url      = $cleanPermalink;
			$post_url_html = sprintf( '<a href="%s">%s</a>', $post_url, $post_title );
		}

		if ( $comment !== null ) {
			$comment_text = $comment->comment_content;

			$comment_formatted = '<div style="background-color:#eee; padding: 10px; font-size: 12pt; font-family: Verdana, Arial, sans-serif; line-height: 1.5;">';
			$comment_formatted .= $comment_text;
			$comment_formatted .= '</div>';
		}

		$reply_button = '<p><a href="' . $reply_url . '" style="font-size: 15px;text-decoration:none;font-weight: 400;text-align: center;color: #fff;padding: 0 50px;line-height: 48px;background-color: #53af4a;display: inline-block;vertical-align: middle;border: 0;outline: 0;cursor: pointer;-webkit-user-select: none;-moz-user-select: none;-ms-user-select: none;user-select: none;-webkit-appearance: none;-moz-appearance: none;appearance: none;white-space: nowrap;border-radius: 24px;">' . __( 'See', 'anycomment' ) . '</a></p>';

		$search = [
			'{blogName}',
			'{blogUrl}',
			'{blogUrlHtml}',
			'{postTitle}',
			'{postUrl}',
			'{postUrlHtml}',
			'{commentText}',
			'{commentFormatted}',
			'{replyUrl}',
			'{replyButton}',
		];

		$replacement = [
			$blog_name,
			$blog_url,
			$blog_url_html,
			$post_title,
			$post_url,
			$post_url_html,
			$comment_text,
			$comment_formatted,
			$reply_url,
			$reply_button,
		];

		$template = AnyCommentGenericSettings::get_notify_email_reply_template();

		return static::prepare_email_template( $template, $search, $replacement );
	}

	/**
	 * Generate email template to send notification to admin.
	 *
	 * Subs to replace:
	 * '{blogName}',
	 * '{blogUrl}',
	 * '{blogUrlHtml}',
	 * '{postTitle}',
	 * '{postUrl}',
	 * '{postUrlHtml}',
	 * '{commentText}',
	 * '{commentFormatted}',
	 * '{replyUrl}',
	 * '{replyButton}'
	 *
	 * @param AnyCommentEmailQueue $email
	 *
	 * @return string
	 * todo: need rewrite as duplicate code of email template above, for now good enought
	 */
	public static function generate_admin_email( $email ) {
		$comment        = get_comment( $email->comment_ID );
		$post           = get_post( $email->post_ID );
		$cleanPermalink = get_permalink( $post );
		$reply_url      = sprintf( '%s#comment-%s', $cleanPermalink, $comment->comment_ID );

		$blog_name     = get_option( 'blogname' );
		$blog_url      = get_option( 'siteurl' );
		$blog_url_html = sprintf( '<a href="%s">%s</a>', $blog_url, $blog_name );

		$post_title    = '';
		$post_url      = '';
		$post_url_html = '';

		$comment_text      = '';
		$comment_formatted = '';

		$admin_moderation_url = esc_url( admin_url( 'edit-comments.php?comment_status=moderated' ) );
		$admin_edit_url       = esc_url( admin_url( 'comment.php?action=editcomment&c=' . $comment->comment_ID ) );

		if ( $post !== null ) {
			$post_title    = $post->post_title;
			$post_url      = $cleanPermalink;
			$post_url_html = sprintf( '<a href="%s">%s</a>', $post_url, $post_title );
		}

		if ( $comment !== null ) {
			$comment_text = $comment->comment_content;

			$comment_formatted = '<div style="background-color:#eee; padding: 10px; font-size: 12pt; font-family: Verdana, Arial, sans-serif; line-height: 1.5;">';
			$comment_formatted .= $comment_text;
			$comment_formatted .= '</div>';
		}

		$reply_button = '<p><a href="' . $reply_url . '" style="font-size: 15px;text-decoration:none;font-weight: 400;text-align: center;color: #fff;padding: 0 50px;line-height: 48px;background-color: #53af4a;display: inline-block;vertical-align: middle;border: 0;outline: 0;cursor: pointer;-webkit-user-select: none;-moz-user-select: none;-ms-user-select: none;user-select: none;-webkit-appearance: none;-moz-appearance: none;appearance: none;white-space: nowrap;border-radius: 24px;">' . __( 'See', 'anycomment' ) . '</a></p>';

		$search      = [
			'{blogName}',
			'{blogUrl}',
			'{blogUrlHtml}',
			'{postTitle}',
			'{postUrl}',
			'{postUrlHtml}',
			'{commentText}',
			'{commentFormatted}',
			'{replyUrl}',
			'{replyButton}',
			'{adminModerationUrl}',
			'{adminEditUrl}',
		];
		$replacement = [
			$blog_name,
			$blog_url,
			$blog_url_html,
			$post_title,
			$post_url,
			$post_url_html,
			$comment_text,
			$comment_formatted,
			$reply_url,
			$reply_button,
			$admin_moderation_url,
			$admin_edit_url
		];

		$template = AnyCommentGenericSettings::get_notify_email_admin_template();

		return static::prepare_email_template( $template, $search, $replacement );
	}

	/**
	 * Prepare & clean email template based on provided values.
	 *
	 * @param string $content Content of the email. Could contain prepared subst. keys to be replaced.
	 * @param array $search List of keys to be replaced.
	 * @param array $replacement Replacements for keys.
	 *
	 * @return string
	 */
	public static function prepare_email_template( $content, $search, $replacement ) {
		$content = str_replace( $search, $replacement, $content );

		$content = preg_replace( '/\{.*?\}/', '', $content );

		$content = trim( nl2br( $content ) );

		return apply_filters( 'anycomment_prepare_email_template', $content, $content, $search, $replacement );
	}
}