post_title ), $string ); $string = str_replace( '{TITLETEXT}', stripslashes( $this->post_title_text ), $string ); $string = str_replace( '{PERMAURL}', $this->get_tracking_link( $this->permalink ), $string ); $link = '' . $this->get_tracking_link( $this->permalink ) . ''; $string = str_replace( '{PERMALINK}', $link, $string ); if ( strstr( $string, '{TINYLINK}' ) ) { $response = wp_safe_remote_get( 'http://tinyurl.com/api-create.php?url=' . rawurlencode( $this->get_tracking_link( $this->permalink ) ) ); if ( ! is_wp_error( $response ) ) { $tinylink = wp_remote_retrieve_body( $response ); } if ( false !== $tinylink ) { $tlink = '' . $tinylink . ''; $string = str_replace( '{TINYLINK}', $tlink, $string ); } else { $string = str_replace( '{TINYLINK}', $link, $string ); } } $string = str_replace( '{DATE}', $this->post_date, $string ); $string = str_replace( '{TIME}', $this->post_time, $string ); $string = str_replace( '{MYNAME}', stripslashes( $this->myname ), $string ); $string = str_replace( '{EMAIL}', $this->myemail, $string ); $string = str_replace( '{AUTHORNAME}', stripslashes( $this->authorname ), $string ); $string = str_replace( '{CATS}', $this->post_cat_names, $string ); $string = str_replace( '{TAGS}', $this->post_tag_names, $string ); $string = str_replace( '{COUNT}', $this->post_count, $string ); if ( ! empty( $digest_post_ids ) ) { return apply_filters( 's2_custom_keywords', $string, $digest_post_ids ); } else { return apply_filters( 's2_custom_keywords', $string ); } } /** * Delivers email to recipients in HTML or plaintext */ public function mail( $recipients = array(), $subject = '', $message = '', $type = 'text', $attachments = array() ) { if ( empty( $recipients ) || '' === $message ) { return; } // Replace any escaped html symbols in subject then apply filter $subject = wp_strip_all_tags( html_entity_decode( $subject, ENT_QUOTES ) ); $subject = apply_filters( 's2_email_subject', $subject ); if ( 'html' === $type ) { $headers = $this->headers( 'html' ); remove_all_filters( 'wp_mail_content_type' ); add_filter( 'wp_mail_content_type', array( $this, 'html_email' ) ); if ( 'yes' === $this->subscribe2_options['stylesheet'] ) { $mailtext = apply_filters( 's2_html_email', '' . $subject . '' . $message . '', $subject, $message ); // phpcs:ignore WordPress.WP.EnqueuedResources } else { $mailtext = apply_filters( 's2_html_email', '' . $subject . '' . $message . '', $subject, $message ); } } else { $headers = $this->headers( 'text' ); remove_all_filters( 'wp_mail_content_type' ); add_filter( 'wp_mail_content_type', array( $this, 'plain_email' ) ); $message = wp_strip_all_tags( html_entity_decode( $message, ENT_NOQUOTES ) ); $mailtext = apply_filters( 's2_plain_email', $message ); } // Construct BCC headers for sending or send individual emails $bcc = ''; natcasesort( $recipients ); if ( function_exists( 'wpmq_mail' ) || 1 === $this->subscribe2_options['bcclimit'] || 1 === count( $recipients ) ) { // BCCLimit is 1 so send individual emails or we only have 1 recipient foreach ( $recipients as $recipient ) { $recipient = trim( $recipient ); // sanity check -- make sure we have a valid email if ( false === is_email( $recipient ) || empty( $recipient ) ) { continue; } // Parse unsubscribe shortcode $mailtext = $this->parse_unsubscribe_link( $mailtext, $recipient ); // Use the mail queue provided we are not sending a preview if ( function_exists( 'wpmq_mail' ) && ! isset( $this->preview_email ) ) { $status = wp_mail( $recipient, $subject, $mailtext, $headers, $attachments, 0 ); } else { $status = wp_mail( $recipient, $subject, $mailtext, $headers, $attachments ); } } return true; } elseif ( 0 === $this->subscribe2_options['bcclimit'] ) { // we're using BCCLimit foreach ( $recipients as $recipient ) { $recipient = trim( $recipient ); // sanity check -- make sure we have a valid email if ( false === is_email( $recipient ) ) { continue; } // and NOT the sender's email, since they'll get a copy anyway if ( ! empty( $recipient ) && $this->myemail !== $recipient ) { ( '' === $bcc ) ? $bcc = "Bcc: $recipient" : $bcc .= ", $recipient"; // Bcc Headers now constructed by phpmailer class } } $headers .= "$bcc\n"; } else { // we're using BCCLimit $count = 1; $batch = array(); foreach ( $recipients as $recipient ) { $recipient = trim( $recipient ); // sanity check -- make sure we have a valid email if ( false === is_email( $recipient ) ) { continue; } // and NOT the sender's email, since they'll get a copy anyway if ( ! empty( $recipient ) && $this->myemail !== $recipient ) { ( '' === $bcc ) ? $bcc = "Bcc: $recipient" : $bcc .= ", $recipient"; // Bcc Headers now constructed by phpmailer class } if ( $this->subscribe2_options['bcclimit'] === $count ) { $count = 0; $batch[] = $bcc; $bcc = ''; } $count++; } // add any partially completed batches to our batch array if ( '' !== $bcc ) { $batch[] = $bcc; } } // rewind the array, just to be safe reset( $recipients ); // Ensure body is wrapped at 78 characters for RFC 5322 $mailtext = wordwrap( $mailtext, $this->word_wrap, "\n" ); // actually send mail if ( isset( $batch ) && ! empty( $batch ) ) { foreach ( $batch as $bcc ) { $newheaders = $headers . "$bcc\n"; $status = wp_mail( $this->myemail, $subject, $mailtext, $newheaders, $attachments ); } } else { $status = wp_mail( $this->myemail, $subject, $mailtext, $headers, $attachments ); } return $status; } /** * Construct standard set of email headers */ public function headers( $type = 'text' ) { if ( empty( $this->myname ) || empty( $this->myemail ) ) { if ( 'blogname' === $this->subscribe2_options['sender'] ) { $this->myname = html_entity_decode( get_option( 'blogname' ), ENT_QUOTES ); $this->myemail = get_option( 'admin_email' ); } else { $admin = $this->get_userdata( $this->subscribe2_options['sender'] ); $this->myname = html_entity_decode( $admin->display_name, ENT_QUOTES ); $this->myemail = $admin->user_email; // fail safe to ensure sender details are not empty if ( empty( $this->myname ) ) { $this->myname = html_entity_decode( get_option( 'blogname' ), ENT_QUOTES ); } if ( empty( $this->myemail ) ) { // Get the site domain and get rid of www. $sitename = strtolower( esc_html( $_SERVER['SERVER_NAME'] ) ); if ( 'www.' === substr( $sitename, 0, 4 ) ) { $sitename = substr( $sitename, 4 ); } $this->myemail = 'wordpress@' . $sitename; } } } $char_set = get_option( 'blog_charset' ); if ( function_exists( 'mb_encode_mimeheader' ) ) { $header['From'] = mb_encode_mimeheader( $this->myname, $char_set, 'Q' ) . ' <' . $this->myemail . '>'; $header['Reply-To'] = mb_encode_mimeheader( $this->myname, $char_set, 'Q' ) . ' <' . $this->myemail . '>'; } else { $header['From'] = $this->myname . ' <' . $this->myemail . '>'; $header['Reply-To'] = $this->myname . ' <' . $this->myemail . '>'; } $header['Return-Path'] = '<' . $this->myemail . '>'; $header['List-ID'] = html_entity_decode( get_option( 'blogname' ), ENT_QUOTES ) . ' <' . strtolower( esc_html( $_SERVER['SERVER_NAME'] ) ) . '>'; if ( 'html' === $type ) { // To send HTML mail, the Content-Type header must be set $header['Content-Type'] = get_option( 'html_type' ) . '; charset="' . $char_set . '"'; } elseif ( 'text' === $type ) { $header['Content-Type'] = 'text/plain; charset="' . $char_set . '"'; } // apply header filter to allow on-the-fly amendments $header = apply_filters( 's2_email_headers', $header ); // collapse the headers using $key as the header name foreach ( $header as $key => $value ) { $headers[ $key ] = $key . ': ' . $value; } $headers = implode( "\n", $headers ); $headers .= "\n"; return $headers; } /** * Parse unsubscribe link * * @param $content * @param $recipient * @return string|string[] */ public function parse_unsubscribe_link( $content, $recipient ) { $page_url = get_page_link( $this->subscribe2_options['s2_unsub_page'] ); $query = parse_url( $page_url, PHP_URL_QUERY ); $page_url .= ( ( $query ? '&' : '?' ) . 's2_unsub=' . base64_encode( $recipient ) ); return str_replace('{UNSUBLINK}', $page_url, $content ); } /** * Function to set HTML Email in wp_mail() */ public function html_email() { return 'text/html'; } /** * Function to set plain text Email in wp_mail() */ public function plain_email() { return 'text/plain'; } /** * Function to add UTM tracking details to links */ public function get_tracking_link( $link ) { if ( empty( $link ) ) { return; } if ( ! empty( $this->subscribe2_options['tracking'] ) ) { ( strpos( $link, '?' ) > 0 ) ? $delimiter .= '&' : $delimiter = '?'; $tracking = $this->subscribe2_options['tracking']; if ( strpos( $tracking, '{ID}' ) ) { $id = url_to_postid( $link ); $tracking = str_replace( '{ID}', $id, $tracking ); } if ( strpos( $tracking, '{TITLE}' ) ) { $id = url_to_postid( $link ); $title = rawurlencode( htmlentities( get_the_title( $id ), 1 ) ); $tracking = str_replace( '{TITLE}', $title, $tracking ); } return $link . $delimiter . $tracking; } else { return $link; } } /** * Sends an email notification of a new post */ public function publish( $post, $preview = '' ) { if ( ! $post ) { return $post; } if ( $this->s2_mu && ! apply_filters( 's2_allow_site_switching', $this->site_switching ) ) { global $switched; if ( $switched ) { return; } } if ( '' === $preview ) { // we aren't sending a Preview to the current user so carry out checks $s2mail = get_post_meta( $post->ID, '_s2mail', true ); if ( ( isset( $_POST['s2_meta_field'] ) && 'no' === $_POST['s2_meta_field'] ) || 'no' === strtolower( trim( $s2mail ) ) ) { return $post; } // are we doing daily digests? If so, don't send anything now if ( 'never' !== $this->subscribe2_options['email_freq'] ) { return $post; } // is the current post of a type that should generate a notification email? // uses s2_post_types filter to allow for custom post types in WP 3.0 if ( 'yes' === $this->subscribe2_options['pages'] ) { $s2_post_types = array( 'page', 'post' ); } else { $s2_post_types = array( 'post' ); } $s2_post_types = apply_filters( 's2_post_types', $s2_post_types ); if ( ! in_array( $post->post_type, $s2_post_types, true ) ) { return $post; } // Are we sending notifications for password protected posts? if ( 'no' === $this->subscribe2_options['password'] && '' !== $post->post_password ) { return $post; } // Is the post assigned to a format for which we should not be sending posts $post_format = get_post_format( $post->ID ); $excluded_formats = explode( ',', $this->subscribe2_options['exclude_formats'] ); if ( false !== $post_format && in_array( $post_format, $excluded_formats, true ) ) { return $post; } $s2_taxonomies = apply_filters( 's2_taxonomies', array( 'category' ) ); $post_cats = wp_get_object_terms( $post->ID, $s2_taxonomies, array( 'fields' => 'ids', ) ); // Fail gracefully if we have a post but no category assigned or a taxonomy error if ( is_wp_error( $post_cats ) || ( empty( $post_cats ) && 'post' === $post->post_type ) ) { return $post; } $check = false; // is the current post assigned to any categories // which should not generate a notification email? foreach ( explode( ',', $this->subscribe2_options['exclude'] ) as $cat ) { if ( in_array( (int) $cat, $post_cats, true ) ) { $check = true; } } if ( $check ) { // hang on -- can registered users subscribe to // excluded categories? if ( '0' === $this->subscribe2_options['reg_override'] ) { // nope? okay, let's leave return $post; } } // Are we sending notifications for Private posts? // Action is added if we are, but double check option and post status if ( 'yes' === $this->subscribe2_options['private'] && 'private' === $post->post_status ) { // don't send notification to public users $check = true; } // lets collect our subscribers $public = array(); if ( ! $check ) { // if this post is assigned to an excluded // category, or is a private post then // don't send public subscribers a notification $public = $this->get_public(); } if ( 'page' === $post->post_type ) { $post_cats_string = implode( ',', get_terms( 'category', array( 'fields' => 'ids', 'get' => 'all', ) ) ); } else { $post_cats_string = implode( ',', $post_cats ); } $registered = $this->get_registered( "cats=$post_cats_string" ); // do we have subscribers? if ( empty( $public ) && empty( $registered ) ) { // if not, no sense doing anything else return $post; } } else { // make sure we prime the taxonomy variable for preview posts $s2_taxonomies = apply_filters( 's2_taxonomies', array( 'category' ) ); } // get_the_time() uses the current locale of the admin user which may differ from the site locale if ( function_exists( 'get_user_locale' ) && get_user_locale() !== get_locale() ) { switch_to_locale( get_locale() ); $locale_switched = true; } // we set these class variables so that we can avoid // passing them in function calls a little later $this->post_title = '' . html_entity_decode( $post->post_title, ENT_QUOTES ) . ''; $this->post_title_text = html_entity_decode( $post->post_title, ENT_QUOTES ); $this->permalink = get_permalink( $post->ID ); $this->post_date = get_the_time( get_option( 'date_format' ), $post ); $this->post_time = get_the_time( '', $post ); if ( isset( $locale_switched ) && true === $locale_switched ) { switch_to_locale( get_user_locale() ); } $author = get_userdata( $post->post_author ); $this->authorname = html_entity_decode( apply_filters( 'the_author', $author->display_name ), ENT_QUOTES ); // do we send as admin or post author? if ( 'author' === $this->subscribe2_options['sender'] ) { // get author details $user = &$author; $this->myemail = $user->user_email; $this->myname = html_entity_decode( $user->display_name, ENT_QUOTES ); } elseif ( 'blogname' === $this->subscribe2_options['sender'] ) { $this->myemail = get_option( 'admin_email' ); $this->myname = html_entity_decode( get_option( 'blogname' ), ENT_QUOTES ); } else { // get admin details $user = $this->get_userdata( $this->subscribe2_options['sender'] ); $this->myemail = $user->user_email; $this->myname = html_entity_decode( $user->display_name, ENT_QUOTES ); } $this->post_cat_names = implode( ', ', wp_get_object_terms( $post->ID, $s2_taxonomies, array( 'fields' => 'names', ) ) ); $this->post_tag_names = implode( ', ', wp_get_post_tags( $post->ID, array( 'fields' => 'names', ) ) ); // Get email subject $subject = html_entity_decode( stripslashes( wp_kses( $this->substitute( $this->subscribe2_options['notification_subject'] ), '' ) ) ); // Get the message template $mailtext = apply_filters( 's2_email_template', $this->subscribe2_options['mailtext'] ); $mailtext = stripslashes( $this->substitute( $mailtext ) ); $plaintext = $post->post_content; $plaintext = strip_shortcodes( $plaintext ); $plaintext = preg_replace( '/]*>(.*)<\/s>/Ui', '', $plaintext ); $plaintext = preg_replace( '/]*>(.*)<\/strike>/Ui', '', $plaintext ); $plaintext = preg_replace( '/]*>(.*)<\/del>/Ui', '', $plaintext ); // Fix for how the Block Editor stores lists if ( true === $this->block_editor ) { $plaintext = str_replace( '<', "\n<", $plaintext ); } // Add filter here so $plaintext can be filtered to correct for layout needs $plaintext = apply_filters( 's2_plaintext', $plaintext ); $excerpttext = $plaintext; if ( strstr( $mailtext, '{REFERENCELINKS}' ) ) { $mailtext = str_replace( '{REFERENCELINKS}', '', $mailtext ); $plaintext_links = ''; $i = 0; while ( preg_match( '/]*)>(.*)<\/a>/Ui', $plaintext, $matches ) ) { if ( preg_match( '/href="([^"]*)"/', $matches[1], $link_matches ) ) { $plaintext_links .= sprintf( "[%d] %s\r\n", ++$i, $link_matches[1] ); $link_replacement = sprintf( '%s [%d]', $matches[2], $i ); } else { $link_replacement = $matches[2]; } $plaintext = preg_replace( '/]*>(.*)<\/a>/Ui', $link_replacement, $plaintext, 1 ); } } $plaintext = trim( wp_strip_all_tags( $plaintext ) ); if ( isset( $plaintext_links ) && '' !== $plaintext_links ) { $plaintext .= "\r\n\r\n" . trim( $plaintext_links ); } $gallid = '[gallery id="' . $post->ID . '"'; $content = str_replace( '[gallery', $gallid, $post->post_content ); // remove the autoembed filter to remove iframes from notification emails if ( get_option( 'embed_autourls' ) ) { global $wp_embed; $priority = has_filter( 'the_content', array( &$wp_embed, 'autoembed' ) ); if ( false !== $priority ) { remove_filter( 'the_content', array( &$wp_embed, 'autoembed' ), $priority ); } } $content = apply_filters( 'the_content', $content ); $content = str_replace( ']]>', ']]>', $content ); $excerpt = trim( $post->post_excerpt ); if ( '' === $excerpt ) { // no excerpt, is there a ? if ( false !== strpos( $excerpttext, '' ) ) { list( $excerpt, $more ) = explode( '', $excerpttext, 2 ); // strip tags and trailing whitespace $excerpt = trim( wp_strip_all_tags( $excerpt ) ); } else { // no , so create excerpt $excerpt = $this->create_excerpt( $excerpttext ); } } $html_excerpt = trim( $post->post_excerpt ); if ( '' === $html_excerpt ) { // no excerpt, is there a ? if ( false !== strpos( $content, '' ) ) { list( $html_excerpt, $more ) = explode( '', $content, 2 ); // balance HTML tags and then strip leading and trailing whitespace $html_excerpt = trim( balanceTags( $html_excerpt, true ) ); } else { // no , so create excerpt $html_excerpt = $this->create_excerpt( $content, true ); } } // remove excess white space from with $excerpt and $plaintext $excerpt = preg_replace( '/[ ]+/', ' ', $excerpt ); $plaintext = preg_replace( '/[ ]+/', ' ', $plaintext ); // prepare mail body texts $plain_excerpt_body = str_replace( '{POST}', $excerpt, $mailtext ); $plain_body = str_replace( '{POST}', $plaintext, $mailtext ); $html_body = str_replace( "\r\n", "
\r\n", $mailtext ); $html_body = str_replace( '{POST}', $content, $html_body ); $html_excerpt_body = str_replace( "\r\n", "
\r\n", $mailtext ); $html_excerpt_body = str_replace( '{POST}', $html_excerpt, $html_excerpt_body ); if ( '' !== $preview ) { $this->preview_email = true; $this->myemail = $preview; $this->myname = __( 'Plain Text Excerpt Preview', 'subscribe2' ); $this->mail( array( $preview ), $subject, $plain_excerpt_body ); $this->myname = __( 'Plain Text Full Preview', 'subscribe2' ); $this->mail( array( $preview ), $subject, $plain_body ); $this->myname = __( 'HTML Excerpt Preview', 'subscribe2' ); $this->mail( array( $preview ), $subject, $html_excerpt_body, 'html' ); $this->myname = __( 'HTML Full Preview', 'subscribe2' ); $this->mail( array( $preview ), $subject, $html_body, 'html' ); } else { // Registered Subscribers first // first we send plaintext summary emails $recipients = $this->get_registered( "cats=$post_cats_string&format=excerpt&author=$post->post_author" ); $recipients = apply_filters( 's2_send_plain_excerpt_subscribers', $recipients, $post->ID ); $this->mail( $recipients, $subject, $plain_excerpt_body ); // next we send plaintext full content emails $recipients = $this->get_registered( "cats=$post_cats_string&format=post&author=$post->post_author" ); $recipients = apply_filters( 's2_send_plain_fullcontent_subscribers', $recipients, $post->ID ); $this->mail( $recipients, $subject, $plain_body ); // next we send html excerpt content emails $recipients = $this->get_registered( "cats=$post_cats_string&format=html_excerpt&author=$post->post_author" ); $recipients = apply_filters( 's2_send_html_excerpt_subscribers', $recipients, $post->ID ); $this->mail( $recipients, $subject, $html_excerpt_body, 'html' ); // next we send html full content emails $recipients = $this->get_registered( "cats=$post_cats_string&format=html&author=$post->post_author" ); $recipients = apply_filters( 's2_send_html_fullcontent_subscribers', $recipients, $post->ID ); $this->mail( $recipients, $subject, $html_body, 'html' ); // and finally we send to Public Subscribers $recipients = apply_filters( 's2_send_public_subscribers', $public, $post->ID ); $this->mail( $recipients, $subject, $plain_excerpt_body, 'text' ); } } /** * Function to create excerpts for emailing */ public function create_excerpt( $text, $html = false ) { $excerpt_on_words = apply_filters( 's2_excerpt_on_words', true ); if ( false === $html ) { $excerpt = trim( wp_strip_all_tags( strip_shortcodes( $text ) ) ); } else { $excerpt = strip_shortcodes( $text ); } if ( true !== $excerpt_on_words ) { $words = preg_split( '//u', $excerpt, $this->excerpt_length + 1 ); } else { $words = explode( ' ', $excerpt, $this->excerpt_length + 1 ); } if ( count( $words ) > $this->excerpt_length ) { array_pop( $words ); array_push( $words, '[...]' ); } if ( true !== $excerpt_on_words ) { $excerpt = implode( '', $words ); } else { $excerpt = implode( ' ', $words ); } if ( true === $html ) { // balance HTML tags and then strip leading and trailing whitespace $excerpt = trim( balanceTags( $excerpt, true ) ); } return $excerpt; } /** * Send confirmation email to a public subscriber */ public function send_confirm( $action = '', $is_remind = false ) { if ( 1 === $this->filtered ) { return true; } if ( ! $this->email || empty( $action ) ) { return false; } $id = $this->get_id( $this->email ); if ( ! $id ) { return false; } // generate the URL "?s2=ACTION+HASH+ID" // ACTION = 1 to subscribe, 0 to unsubscribe // HASH = wp_hash of email address // ID = user's ID in the subscribe2 table // use home instead of siteurl incase index.php is not in core WordPress directory $link = apply_filters( 's2_confirm_link', get_option( 'home' ) ) . '/?s2='; if ( 'add' === $action ) { $link .= '1'; } elseif ( 'del' === $action ) { $link .= '0'; } $link .= wp_hash( $this->email ); $link .= $id; // sort the headers now so we have all substitute information $mailheaders = $this->headers(); if ( true === $is_remind ) { $body = $this->substitute( stripslashes( $this->subscribe2_options['remind_email'] ) ); $subject = $this->substitute( stripslashes( $this->subscribe2_options['remind_subject'] ) ); } else { $body = apply_filters( 's2_confirm_email', stripslashes( $this->subscribe2_options['confirm_email'] ) ); $body = $this->substitute( $body ); if ( 'add' === $action ) { $body = str_replace( '{ACTION}', $this->subscribe, $body ); $subject = str_replace( '{ACTION}', $this->subscribe, $this->subscribe2_options['confirm_subject'] ); } elseif ( 'del' === $action ) { $body = str_replace( '{ACTION}', $this->unsubscribe, $body ); $subject = str_replace( '{ACTION}', $this->unsubscribe, $this->subscribe2_options['confirm_subject'] ); } $subject = html_entity_decode( $this->substitute( stripslashes( $subject ) ), ENT_QUOTES ); } $body = str_replace( '{LINK}', $link, $body ); if ( true === $is_remind && function_exists( 'wpmq_mail' ) ) { // could be sending lots of reminders so queue them if wpmq is enabled $status = wp_mail( $this->email, $subject, $body, $mailheaders, '', 0 ); } else { return wp_mail( $this->email, $subject, $body, $mailheaders ); } } /* ===== Public Subscriber functions ===== */ /** * Return an array of all the public subscribers */ public function get_public( $confirmed = 1 ) { global $wpdb; static $all_confirmed = ''; static $all_unconfirmed = ''; if ( 1 === $confirmed ) { if ( '' === $all_confirmed ) { $all_confirmed = $wpdb->get_col( "SELECT email FROM $wpdb->subscribe2 WHERE active='1'" ); } return $all_confirmed; } else { if ( '' === $all_unconfirmed ) { $all_unconfirmed = $wpdb->get_col( "SELECT email FROM $wpdb->subscribe2 WHERE active='0'" ); } return $all_unconfirmed; } } /** * Given a public subscriber ID, returns the email address */ public function get_email( $id = 0 ) { global $wpdb; if ( ! $id ) { return false; } return $wpdb->get_var( $wpdb->prepare( "SELECT email FROM $wpdb->subscribe2 WHERE id=%d", $id ) ); } /** * Given a public subscriber email, returns the subscriber ID */ public function get_id( $email = '' ) { global $wpdb; if ( ! $email ) { return false; } return $wpdb->get_var( $wpdb->prepare( "SELECT id FROM $wpdb->subscribe2 WHERE email=%s", $email ) ); } /** * Add an public subscriber to the subscriber table * If added by admin it is immediately confirmed, otherwise as unconfirmed */ public function add( $email = '', $confirm = false ) { if ( 1 === $this->filtered ) { return; } global $wpdb; if ( false === $this->validate_email( $email ) ) { return false; } if ( false !== $this->is_public( $email ) ) { // is this an email for a registered user $check = $wpdb->get_var( $wpdb->prepare( "SELECT user_email FROM $wpdb->users WHERE user_email=%s", $this->email ) ); if ( $check ) { return; } if ( $confirm ) { $wpdb->query( $wpdb->prepare( "UPDATE $wpdb->subscribe2 SET active='1', ip=%s WHERE CAST(email as binary)=%s", $this->ip, $email ) ); } else { $wpdb->query( $wpdb->prepare( "UPDATE $wpdb->subscribe2 SET date=CURDATE(), time=CURTIME() WHERE CAST(email as binary)=%s", $email ) ); } } else { if ( $confirm ) { global $current_user; $wpdb->query( $wpdb->prepare( "INSERT INTO $wpdb->subscribe2 (email, active, date, time, ip) VALUES (%s, %d, CURDATE(), CURTIME(), %s)", $email, 1, $current_user->user_login ) ); } else { $wpdb->query( $wpdb->prepare( "INSERT INTO $wpdb->subscribe2 (email, active, date, time, ip) VALUES (%s, %d, CURDATE(), CURTIME(), %s)", $email, 0, $this->ip ) ); } } } /** * Remove a public subscriber user from the subscription table */ public function delete( $email = '' ) { global $wpdb; if ( false === $this->validate_email( $email ) ) { return false; } $wpdb->query( $wpdb->prepare( "DELETE FROM $wpdb->subscribe2 WHERE CAST(email as binary)=%s LIMIT 1", $email ) ); } /** * Toggle a public subscriber's status */ public function toggle( $email = '' ) { global $wpdb; if ( '' === $email || false === $this->validate_email( $email ) ) { return false; } // let's see if this is a public user $status = $this->is_public( $email ); if ( false === $status ) { return false; } if ( '0' === $status ) { $wpdb->query( $wpdb->prepare( "UPDATE $wpdb->subscribe2 SET active='1', conf_date=CURDATE(), conf_time=CURTIME(), conf_ip=%s WHERE CAST(email as binary)=%s LIMIT 1", $this->ip, $email ) ); } else { $wpdb->query( $wpdb->prepare( "UPDATE $wpdb->subscribe2 SET active='0', conf_date=CURDATE(), conf_time=CURTIME(), conf_ip=%s WHERE CAST(email as binary)=%s LIMIT 1", $this->ip, $email ) ); } } /** * Send reminder email to unconfirmed public subscribers */ public function remind( $emails = '' ) { if ( '' === $emails ) { return false; } $recipients = explode( ',', $emails ); if ( ! is_array( $recipients ) ) { $recipients = (array) $recipients; } foreach ( $recipients as $recipient ) { $this->email = $recipient; $this->send_confirm( 'add', true ); } } //end remind() /** * Is the supplied email address a public subscriber? */ public function is_public( $email = '' ) { global $wpdb; if ( '' === $email ) { return false; } // run the query and force case sensitivity $check = $wpdb->get_var( $wpdb->prepare( "SELECT active FROM $wpdb->subscribe2 WHERE CAST(email as binary)=%s", $email ) ); if ( '0' === $check || '1' === $check ) { return $check; } else { return false; } } /* ===== Registered User and Subscriber functions ===== */ /** * Is the supplied email address a registered user of the blog? */ public function is_registered( $email = '' ) { global $wpdb; if ( '' === $email ) { return false; } $check = $wpdb->get_var( $wpdb->prepare( "SELECT user_email FROM $wpdb->users WHERE user_email=%s", $email ) ); if ( $check ) { return true; } else { return false; } } /** * Return Registered User ID from email */ public function get_user_id( $email = '' ) { global $wpdb; if ( '' === $email ) { return false; } $id = $wpdb->get_var( $wpdb->prepare( "SELECT id FROM $wpdb->users WHERE user_email=%s", $email ) ); return $id; } /** * Return an array of all subscribers emails or IDs */ public function get_all_registered( $return = 'email' ) { global $wpdb; static $all_registered_id = ''; static $all_registered_email_id = ''; static $all_registered_email = ''; if ( $this->s2_mu ) { if ( 'ID' === $return ) { if ( '' === $all_registered_id ) { $all_registered_id = $wpdb->get_col( "SELECT user_id FROM $wpdb->usermeta WHERE meta_key='{$wpdb->prefix}capabilities'" ); } return $all_registered_id; } elseif ( 'emailid' === $return ) { if ( '' === $all_registered_email_id ) { $all_registered_email_id = $wpdb->get_results( "SELECT a.user_email, a.ID FROM $wpdb->users AS a INNER JOIN $wpdb->usermeta AS b on a.ID = b.user_id WHERE b.meta_key ='{$wpdb->prefix}capabilities'", ARRAY_A ); } return $all_registered_email_id; } else { if ( '' === $all_registered_email ) { $all_registered_email = $wpdb->get_col( "SELECT a.user_email FROM $wpdb->users AS a INNER JOIN $wpdb->usermeta AS b ON a.ID = b.user_id WHERE b.meta_key='{$wpdb->prefix}capabilities'" ); } return $all_registered_email; } } else { if ( 'ID' === $return ) { if ( '' === $all_registered_id ) { $all_registered_id = $wpdb->get_col( "SELECT ID FROM $wpdb->users" ); } return $all_registered_id; } elseif ( 'emailid' === $return ) { if ( '' === $all_registered_email_id ) { $all_registered_email_id = $wpdb->get_results( "SELECT user_email, ID FROM $wpdb->users", ARRAY_A ); } return $all_registered_email_id; } else { if ( '' === $all_registered_email ) { $all_registered_email = $wpdb->get_col( "SELECT user_email FROM $wpdb->users" ); } return $all_registered_email; } } } /** * Return an array of registered subscribers * Collect all the registered users of the blog who are subscribed to the specified categories */ public function get_registered( $args = '' ) { global $wpdb; parse_str( $args, $r ); if ( ! isset( $r['format'] ) ) { $r['format'] = 'all'; } if ( ! isset( $r['cats'] ) ) { $r['cats'] = ''; } if ( ! isset( $r['author'] ) ) { $r['author'] = ''; } if ( ! isset( $r['return'] ) ) { $r['return'] = 'email'; } // collect all subscribers for compulsory categories $compulsory = explode( ',', $this->subscribe2_options['compulsory'] ); foreach ( explode( ',', $r['cats'] ) as $cat ) { if ( in_array( $cat, $compulsory, true ) ) { $r['cats'] = ''; } } $join = ''; $and = ''; // text or HTML subscribers if ( 'all' !== $r['format'] ) { $join .= "INNER JOIN $wpdb->usermeta AS b ON a.user_id = b.user_id "; $and .= $wpdb->prepare( ' AND b.meta_key=%s AND b.meta_value=%s', $this->get_usermeta_keyname( 's2_format' ), $r['format'] ); } // specific category subscribers if ( '' !== $r['cats'] ) { $join .= "INNER JOIN $wpdb->usermeta AS c ON a.user_id = c.user_id "; $cats_and = ''; foreach ( explode( ',', $r['cats'] ) as $cat ) { ( '' === $cats_and ) ? $cats_and = $wpdb->prepare( 'c.meta_key=%s', $this->get_usermeta_keyname( 's2_cat' ) . $cat ) : $cats_and .= $wpdb->prepare( ' OR c.meta_key=%s', $this->get_usermeta_keyname( 's2_cat' ) . $cat ); } $and .= " AND ($cats_and)"; } // specific authors if ( '' !== $r['author'] ) { $join .= "INNER JOIN $wpdb->usermeta AS d ON a.user_id = d.user_id "; $and .= $wpdb->prepare( ' AND (d.meta_key=%s AND NOT FIND_IN_SET(%s, d.meta_value))', $this->get_usermeta_keyname( 's2_authors' ), $r['author'] ); } if ( $this->s2_mu ) { $result = $wpdb->get_col( $wpdb->prepare( "SELECT a.user_id FROM $wpdb->usermeta AS a INNER JOIN $wpdb->usermeta AS e ON a.user_id = e.user_id " . $join . "WHERE a.meta_key='{$wpdb->prefix}capabilities' AND e.meta_key=%s AND e.meta_value <> ''" . $and, // phpcs:ignore WordPress.DB.PreparedSQL, WordPress.DB.PreparedSQLPlaceholders $this->get_usermeta_keyname( 's2_subscribed' ) ) ); } else { $result = $wpdb->get_col( $wpdb->prepare( "SELECT a.user_id FROM $wpdb->usermeta AS a " . $join . "WHERE a.meta_key=%s AND a.meta_value <> ''" . $and, // phpcs:ignore WordPress.DB.PreparedSQL, WordPress.DB.PreparedSQLPlaceholders $this->get_usermeta_keyname( 's2_subscribed' ) ) ); } if ( empty( $result ) || false === $result ) { return array(); } else { $ids = implode( ',', array_map( array( $this, 'prepare_in_data' ), $result ) ); } if ( 'emailid' === $r['return'] ) { $registered = $wpdb->get_results( "SELECT user_email, ID FROM $wpdb->users WHERE ID IN ($ids)", ARRAY_A ); // phpcs:ignore WordPress.DB.PreparedSQL } else { $registered = $wpdb->get_col( "SELECT user_email FROM $wpdb->users WHERE ID IN ($ids)" ); // phpcs:ignore WordPress.DB.PreparedSQL } if ( empty( $registered ) ) { return array(); } // apply filter to registered users to add or remove additional addresses, pass args too for additional control $registered = apply_filters( 's2_registered_subscribers', $registered, $args ); return $registered; } /** * Function to ensure email is compliant with internet messaging standards */ public function sanitize_email( $email ) { $email = trim( stripslashes( $email ) ); if ( false === $email ) { return false; } // ensure that domain is in lowercase as per internet email standards http://www.ietf.org/rfc/rfc5321.txt list( $name, $domain ) = explode( '@', $email, 2 ); return apply_filters( 's2_sanitize_email', $name . '@' . strtolower( $domain ), $email ); } /** * Check email is valid */ public function validate_email( $email ) { // Check the formatting is correct if ( function_exists( 'filter_var' ) ) { if ( false === filter_var( $email, FILTER_VALIDATE_EMAIL ) ) { return false; } } if ( true === apply_filters( 's2_validate_email_with_dns', true ) ) { $domain = explode( '@', $email, 2 ); if ( function_exists( 'idn_to_ascii' ) ) { $check_domain = idn_to_ascii( $domain[1], IDNA_NONTRANSITIONAL_TO_ASCII, INTL_IDNA_VARIANT_UTS46 ); } else { $check_domain = $domain[1]; } if ( true === checkdnsrr( $check_domain, 'MX' ) ) { return $email; } else { return false; } } else { return is_email( $email ); } } /** * Create the appropriate usermeta values when a user registers * If the registering user had previously subscribed to notifications, this function will delete them from the public subscriber list first */ public function register( $user_ID = 0, $consent = false ) { global $wpdb; if ( 0 === $user_ID ) { return $user_ID; } $user = get_userdata( $user_ID ); // Subscribe registered users to categories obeying excluded categories if ( 0 === $this->subscribe2_options['reg_override'] || 'no' === $this->subscribe2_options['newreg_override'] ) { $all_cats = $this->all_cats( true, 'ID' ); } else { $all_cats = $this->all_cats( false, 'ID' ); } $cats = ''; foreach ( $all_cats as $cat ) { ( '' === $cats ) ? $cats = "$cat->term_id" : $cats .= ",$cat->term_id"; } if ( '' === $cats ) { // sanity check, might occur if all cats excluded and reg_override = 0 return $user_ID; } // has this user previously signed up for email notification? if ( false !== $this->is_public( $this->sanitize_email( $user->user_email ) ) ) { // delete this user from the public table, and subscribe them to all the categories $this->delete( $user->user_email ); update_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_subscribed' ), $cats ); foreach ( explode( ',', $cats ) as $cat ) { update_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_cat' ) . $cat, $cat ); } update_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_format' ), 'excerpt' ); update_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_autosub' ), $this->subscribe2_options['autosub_def'] ); update_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_authors' ), '' ); } else { // create post format entries for all users if ( in_array( $this->subscribe2_options['autoformat'], array( 'html', 'html_excerpt', 'post', 'excerpt' ), true ) ) { update_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_format' ), $this->subscribe2_options['autoformat'] ); } else { update_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_format' ), 'excerpt' ); } update_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_autosub' ), $this->subscribe2_options['autosub_def'] ); // if the are no existing subscriptions, create them if we have consent if ( true === $consent ) { update_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_subscribed' ), $cats ); foreach ( explode( ',', $cats ) as $cat ) { update_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_cat' ) . $cat, $cat ); } } update_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_authors' ), '' ); } return $user_ID; } /** * Get admin data from record 1 or first user with admin rights */ public function get_userdata( $admin_id ) { global $wpdb, $userdata; if ( is_numeric( $admin_id ) ) { $admin = get_userdata( $admin_id ); } elseif ( 'admin' === $admin_id ) { //ensure compatibility with < 4.16 $admin = get_userdata( '1' ); } else { $admin = &$userdata; } if ( empty( $admin ) || 0 === $admin->ID ) { $role = array( 'role' => 'administrator', ); $wp_user_query = get_users( $role ); $admin = $wp_user_query[0]; } return $admin; } //end get_userdata() /** * Subscribe/unsubscribe user from one-click submission */ public function one_click_handler( $user_ID, $action ) { if ( ! isset( $user_ID ) || ! isset( $action ) ) { return; } $all_cats = $this->all_cats( true ); if ( 'subscribe' === $action ) { // Subscribe $new_cats = array(); foreach ( $all_cats as $cat ) { update_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_cat' ) . $cat->term_id, $cat->term_id ); $new_cats[] = $cat->term_id; } update_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_subscribed' ), implode( ',', $new_cats ) ); if ( 'yes' === $this->subscribe2_options['show_autosub'] && 'no' !== get_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_subscribed' ), true ) ) { update_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_autosub' ), 'yes' ); } } elseif ( 'unsubscribe' === $action ) { // Unsubscribe foreach ( $all_cats as $cat ) { delete_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_cat' ) . $cat->term_id ); } delete_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_subscribed' ) ); update_user_meta( $user_ID, $this->get_usermeta_keyname( 's2_autosub' ), 'no' ); } } //end one_click_handler() /* ===== helper functions: forms and stuff ===== */ /** * Get an object of all categories, include default and custom type */ public function all_cats( $exclude = false, $orderby = 'slug' ) { $all_cats = array(); $s2_taxonomies = apply_filters( 's2_taxonomies', array( 'category' ) ); foreach ( $s2_taxonomies as $taxonomy ) { if ( taxonomy_exists( $taxonomy ) ) { $all_cats = array_merge( $all_cats, get_categories( array( 'hide_empty' => false, 'orderby' => $orderby, 'taxonomy' => $taxonomy, ) ) ); } } if ( true === $exclude ) { // remove excluded categories from the returned object $excluded = explode( ',', $this->subscribe2_options['exclude'] ); // need to use $id like this as this is a mixed array / object $id = 0; foreach ( $all_cats as $cat ) { if ( in_array( (string) $cat->term_id, $excluded, true ) ) { unset( $all_cats[ $id ] ); } $id++; } } return $all_cats; } /** * Function to sanitise array of data for SQL */ public function prepare_in_data( $data ) { global $wpdb; return $wpdb->prepare( '%s', $data ); } /** * Filter for usermeta table key names to adjust them if needed for WPMU blogs */ public function get_usermeta_keyname( $metaname ) { global $wpdb; // Is this WordPressMU or not? if ( true === $this->s2_mu ) { switch ( $metaname ) { case 's2_subscribed': case 's2_cat': case 's2_format': case 's2_autosub': case 's2_authors': return $wpdb->prefix . $metaname; default: break; } } // Not MU or not a prefixed option name return $metaname; } /** * Adds information to the WordPress registration screen for new users */ public function register_form() { if ( 'no' === $this->subscribe2_options['autosub'] ) { return; } if ( 'wpreg' === $this->subscribe2_options['autosub'] ) { echo '

' . "\r\n"; } elseif ( 'yes' === $this->subscribe2_options['autosub'] ) { echo '

' . "\r\n"; echo esc_html__( 'By registering with this blog you are also agreeing to receive email notifications for new posts but you can unsubscribe at anytime', 'subscribe2' ) . '.
' . "\r\n"; echo '

' . "\r\n"; } } /** * Process function to add action if user selects to subscribe to posts during registration */ public function register_post( $user_ID = 0 ) { global $_POST; if ( 0 === $user_ID ) { return; } if ( 'yes' === $this->subscribe2_options['autosub'] || ( isset( $_POST['reg_subscribe'] ) && 'on' === $_POST['reg_subscribe'] && 'wpreg' === $this->subscribe2_options['autosub'] ) ) { $this->register( $user_ID, true ); } else { $this->register( $user_ID, false ); } } /* ===== comment subscriber functions ===== */ /** * Display check box on comment page */ public function s2_comment_meta_form( $submit_field ) { if ( is_user_logged_in() ) { $comment_meta_form = $this->profile; } else { $comment_meta_form = '

'; } if ( 'before' === $this->subscribe2_options['comment_subs'] ) { return $comment_meta_form . $submit_field; } else { return $submit_field . '
' . $comment_meta_form; } } /** * Process comment meta data */ public function s2_comment_meta( $comment_id, $approved = 0 ) { // return if email is empty - can happen if setting to require name and email for comments is disabled if ( isset( $_POST['email'] ) && empty( $_POST['email'] ) ) { return; } if ( isset( $_POST['s2_comment_request'] ) && '1' === $_POST['s2_comment_request'] ) { switch ( $approved ) { case '0': // Unapproved so hold in meta data pending moderation add_comment_meta( $comment_id, 's2_comment_request', $_POST['s2_comment_request'] ); break; case '1': // Approved so add $comment = get_comment( $comment_id ); $is_public = $this->is_public( $comment->comment_author_email ); if ( 0 === $is_public ) { $this->toggle( $comment->comment_author_email ); } $is_registered = $this->is_registered( $comment->comment_author_email ); if ( ! $is_public && ! $is_registered ) { $this->add( $comment->comment_author_email, true ); } break; default: break; } } } /** * Action subscribe requests made on comment forms when comments are approved */ public function comment_status( $comment_id = 0 ) { global $wpdb; // get meta data $subscribe = get_comment_meta( $comment_id, 's2_comment_request', true ); if ( '1' !== $subscribe ) { return $comment_id; } // Retrieve the information about the comment $comment = $wpdb->get_row( $wpdb->prepare( "SELECT comment_author_email, comment_approved FROM $wpdb->comments WHERE comment_ID=%s LIMIT 1", $comment_id ), OBJECT ); if ( empty( $comment ) ) { return $comment_id; } switch ( $comment->comment_approved ) { case '0': // Unapproved break; case '1': // Approved $is_public = $this->is_public( $comment->comment_author_email ); if ( 0 === $is_public ) { $this->toggle( $comment->comment_author_email ); } $is_registered = $this->is_registered( $comment->comment_author_email ); if ( ! $is_public && ! $is_registered ) { $this->add( $comment->comment_author_email, true ); } delete_comment_meta( $comment_id, 's2_comment_request' ); break; default: // post is trash, spam or deleted delete_comment_meta( $comment_id, 's2_comment_request' ); break; } return $comment_id; } /* ===== widget functions ===== */ /** * Register the form widget */ public function subscribe2_widget() { require_once S2PATH . 'classes/class-s2-form-widget.php'; register_widget( 'S2_Form_Widget' ); } /** * Register the counter widget */ public function counter_widget() { require_once S2PATH . 'classes/class-s2-counter-widget.php'; register_widget( 'S2_Counter_Widget' ); } /* ===== wp-cron functions ===== */ /** * Add a weekly event to cron */ public function add_weekly_sched( $scheds ) { $exists = false; foreach ( $scheds as $sched ) { if ( array_search( 604800, $sched, true ) ) { $exists = true; } } if ( ! $exists ) { $scheds['weekly'] = array( 'interval' => 604800, 'display' => __( 'Weekly', 'subscribe2' ), ); } return $scheds; } /** * Handle post transitions for the digest email */ public function digest_post_transitions( $new_status, $old_status, $post ) { if ( $new_status === $old_status ) { return; } if ( 'yes' === $this->subscribe2_options['pages'] ) { $s2_post_types = array( 'page', 'post' ); } else { $s2_post_types = array( 'post' ); } $s2_post_types = apply_filters( 's2_post_types', $s2_post_types ); if ( ! in_array( $post->post_type, $s2_post_types, true ) ) { return; } update_post_meta( $post->ID, '_s2_digest_post_status', ( 'publish' === $new_status ) ? 'pending' : 'draft' ); } /** * Send a daily digest of today's new posts */ public function subscribe2_cron( $preview = '', $resend = '' ) { if ( defined( 'DOING_S2_CRON' ) && DOING_S2_CRON ) { return; } define( 'DOING_S2_CRON', true ); global $wpdb; if ( '' === $preview ) { // set up SQL query based on options if ( 'yes' === $this->subscribe2_options['private'] ) { $status = "'publish', 'private'"; } else { $status = "'publish'"; } // send notifications for allowed post type (defaults for posts and pages) // uses s2_post_types filter to allow for custom post types in WP 3.0 if ( 'yes' === $this->subscribe2_options['pages'] ) { $s2_post_types = array( 'page', 'post' ); } else { $s2_post_types = array( 'post' ); } $s2_post_types = apply_filters( 's2_post_types', $s2_post_types ); foreach ( $s2_post_types as $post_type ) { if ( ! isset( $type ) ) { $type = $wpdb->prepare( '%s', $post_type ); } else { $type .= $wpdb->prepare( ', %s', $post_type ); } } // collect posts if ( 'resend' === $resend ) { $query = new WP_Query( array( 'post__in' => explode( ',', $this->subscribe2_options['last_s2cron'] ), 'ignore_sticky_posts' => 1, 'order' => ( 'desc' === $this->subscribe2_options['cron_order'] ) ? 'DESC' : 'ASC', ) ); $posts = $query->posts; } else { $sql = "SELECT ID, post_title, post_excerpt, post_content, post_type, post_password, post_date, post_author FROM $wpdb->posts AS a INNER JOIN $wpdb->postmeta AS b ON b.post_id = a.ID"; $sql .= " AND b.meta_key = '_s2_digest_post_status' AND b.meta_value = 'pending' WHERE post_status IN ($status) AND post_type IN ($type) ORDER BY post_date " . ( ( 'desc' === $this->subscribe2_options['cron_order'] ) ? 'DESC' : 'ASC' ); $posts = $wpdb->get_results( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL } } else { // we are sending a preview, use global if possible otherwise get last post global $post; if ( empty( $post ) ) { $posts = get_posts( 'numberposts=1' ); } else { $posts = array( $post ); } } // Collect sticky posts if desired $sticky_ids = array(); if ( 'yes' === $this->subscribe2_options['stickies'] ) { $sticky_ids = get_option( 'sticky_posts' ); if ( ! empty( $sticky_ids ) ) { $sticky_posts = get_posts( array( 'post__in' => $sticky_ids, ) ); $posts = array_merge( (array) $sticky_posts, (array) $posts ); } } // do we have any posts? if ( empty( $posts ) && ! has_filter( 's2_digest_email' ) ) { return false; } // remove the autoembed filter to remove iframes from notification emails if ( get_option( 'embed_autourls' ) ) { global $wp_embed; $priority = has_filter( 'the_content', array( &$wp_embed, 'autoembed' ) ); if ( false !== $priority ) { remove_filter( 'the_content', array( &$wp_embed, 'autoembed' ), $priority ); } } // if we have posts, let's prepare the digest // define some variables needed for the digest $datetime = get_option( 'date_format' ) . ' @ ' . get_option( 'time_format' ); $all_post_cats = array(); $ids = array(); $digest_post_ids = array(); $mailtext = apply_filters( 's2_email_template', $this->subscribe2_options['mailtext'] ); $table = ''; $tablelinks = ''; $message_post = ''; $message_posttime = ''; $this->post_count = count( $posts ); $s2_taxonomies = apply_filters( 's2_taxonomies', array( 'category' ) ); foreach ( $posts as $digest_post ) { // keep an array of post ids and skip if we've already done it once if ( in_array( $digest_post->ID, $ids, true ) ) { continue; } $ids[] = $digest_post->ID; $post_cats = wp_get_object_terms( $digest_post->ID, $s2_taxonomies, array( 'fields' => 'ids', ) ); $post_cats_string = implode( ',', $post_cats ); $all_post_cats = array_unique( array_merge( $all_post_cats, $post_cats ) ); // make sure we exclude posts from live emails if so configured $check = false; if ( '' === $preview ) { // Pages are put into category 1 so make sure we don't exclude // pages if category 1 is excluded if ( 'page' !== $digest_post->post_type ) { // is the current post assigned to any categories // which should not generate a notification email? foreach ( explode( ',', $this->subscribe2_options['exclude'] ) as $cat ) { if ( in_array( (int) $cat, $post_cats, true ) ) { $check = true; } } } // is the current post set by the user to // not generate a notification email? $s2mail = get_post_meta( $digest_post->ID, '_s2mail', true ); if ( 'no' === strtolower( trim( $s2mail ) ) ) { $check = true; } // is the current post private // and should this not generate a notification email? if ( 'no' === $this->subscribe2_options['password'] && '' !== $digest_post->post_password ) { $check = true; } // is the post assigned a format that should // not be included in the notification email? $post_format = get_post_format( $digest_post->ID ); $excluded_formats = explode( ',', $this->subscribe2_options['exclude_formats'] ); if ( false !== $post_format && in_array( $post_format, $excluded_formats, true ) ) { $check = true; } // if this post is excluded // don't include it in the digest if ( $check ) { $this->post_count --; continue; } } // is the current post set by the user to // not generate a notification email? $s2mail = get_post_meta( $digest_post->ID, '_s2mail', true ); if ( 'no' === strtolower( trim( $s2mail ) ) ) { $check = true; } // is the current post private // and should this not generate a notification email? if ( 'no' === $this->subscribe2_options['password'] && '' !== $digest_post->post_password ) { $check = true; } // is the post assigned a format that should // not be included in the notification email? $post_format = get_post_format( $digest_post->ID ); $excluded_formats = explode( ',', $this->subscribe2_options['exclude_formats'] ); if ( false !== $post_format && in_array( $post_format, $excluded_formats, true ) ) { $check = true; } // if this post is excluded // don't include it in the digest if ( $check ) { continue; } $digest_post_ids[] = $digest_post->ID; $post_title = html_entity_decode( $digest_post->post_title, ENT_QUOTES ); ( '' === $table ) ? $table .= '* ' . $post_title : $table .= "\r\n* " . $post_title; ( '' === $tablelinks ) ? $tablelinks .= '* ' . $post_title : $tablelinks .= "\r\n* " . $post_title; $message_post .= $post_title; $message_posttime .= $post_title; if ( strstr( $mailtext, '{AUTHORNAME}' ) ) { $author = get_userdata( $digest_post->post_author ); if ( '' !== $author->display_name ) { $message_post .= ' (' . __( 'Author', 'subscribe2' ) . ': ' . html_entity_decode( apply_filters( 'the_author', $author->display_name ), ENT_QUOTES ) . ')'; $message_posttime .= ' (' . __( 'Author', 'subscribe2' ) . ': ' . html_entity_decode( apply_filters( 'the_author', $author->display_name ), ENT_QUOTES ) . ')'; } } $message_post .= "\r\n"; $message_posttime .= "\r\n"; $message_posttime .= __( 'Posted on', 'subscribe2' ) . ': ' . mysql2date( $datetime, $digest_post->post_date ) . "\r\n"; if ( strstr( $mailtext, '{TINYLINK}' ) ) { $tinylink = wp_safe_remote_get( 'http://tinyurl.com/api-create.php?url=' . rawurlencode( $this->get_tracking_link( get_permalink( $digest_post->ID ) ) ) ); } else { $tinylink = false; } if ( strstr( $mailtext, '{TINYLINK}' ) && 'Error' !== $tinylink && false !== $tinylink ) { $tablelinks .= "\r\n" . $tinylink . "\r\n"; $message_post .= $tinylink . "\r\n"; $message_posttime .= $tinylink . "\r\n"; } else { $tablelinks .= "\r\n" . $this->get_tracking_link( get_permalink( $digest_post->ID ) ) . "\r\n"; $message_post .= $this->get_tracking_link( get_permalink( $digest_post->ID ) ) . "\r\n"; $message_posttime .= $this->get_tracking_link( get_permalink( $digest_post->ID ) ) . "\r\n"; } if ( strstr( $mailtext, '{CATS}' ) ) { $post_cat_names = implode( ', ', wp_get_object_terms( $digest_post->ID, $s2_taxonomies, array( 'fields' => 'names', ) ) ); $message_post .= __( 'Posted in', 'subscribe2' ) . ': ' . $post_cat_names . "\r\n"; $message_posttime .= __( 'Posted in', 'subscribe2' ) . ': ' . $post_cat_names . "\r\n"; } if ( strstr( $mailtext, '{TAGS}' ) ) { $post_tag_names = implode( ', ', wp_get_post_tags( $digest_post->ID, array( 'fields' => 'names', ) ) ); if ( '' !== $post_tag_names ) { $message_post .= __( 'Tagged as', 'subscribe2' ) . ': ' . $post_tag_names . "\r\n"; $message_posttime .= __( 'Tagged as', 'subscribe2' ) . ': ' . $post_tag_names . "\r\n"; } } $message_post .= "\r\n"; $message_posttime .= "\r\n"; ( ! empty( $digest_post->post_excerpt ) ) ? $excerpt = trim( $digest_post->post_excerpt ) : $excerpt = ''; if ( '' === $excerpt ) { $excerpt = apply_filters( 'the_content', $digest_post->post_content ); // no excerpt, is there a ? if ( false !== strpos( $digest_post->post_content, '' ) ) { list($excerpt, $more) = explode( '', $digest_post->post_content, 2 ); $excerpt = wp_strip_all_tags( $excerpt ); $excerpt = strip_shortcodes( $excerpt ); } else { $excerpt = $this->create_excerpt( $excerpt ); } // strip leading and trailing whitespace $excerpt = trim( $excerpt ); } $message_post .= $excerpt . "\r\n\r\n"; $message_posttime .= $excerpt . "\r\n\r\n"; } // we are not sending a preview so update post_meta data for sent ids but not sticky posts if ( '' === $preview ) { foreach ( $ids as $id ) { if ( ! empty( $sticky_ids ) && ! in_array( $id, $sticky_ids, true ) ) { update_post_meta( $id, '_s2_digest_post_status', 'done' ); } else { update_post_meta( $id, '_s2_digest_post_status', 'done' ); } } $this->subscribe2_options['last_s2cron'] = implode( ',', $digest_post_ids ); update_option( 'subscribe2_options', $this->subscribe2_options ); } // we add a blank line after each post excerpt now trim white space that occurs for the last post $message_post = trim( $message_post ); $message_posttime = trim( $message_posttime ); // remove excess white space from within $message_post and $message_posttime $message_post = preg_replace( '/[ ]+/', ' ', $message_post ); $message_posttime = preg_replace( '/[ ]+/', ' ', $message_posttime ); $message_post = preg_replace( "/[\r\n]{3,}/", "\r\n\r\n", $message_post ); $message_posttime = preg_replace( "/[\r\n]{3,}/", "\r\n\r\n", $message_posttime ); // apply filter to allow external content to be inserted or content manipulated $message_post = apply_filters( 's2_digest_email', $message_post ); $message_posttime = apply_filters( 's2_digest_email', $message_posttime ); //sanity check - don't send a mail if the content is empty if ( ! $message_post && ! $message_posttime && ! $table && ! $tablelinks ) { return; } // get sender details if ( 'blogname' === $this->subscribe2_options['sender'] ) { $this->myname = html_entity_decode( get_option( 'blogname' ), ENT_QUOTES ); $this->myemail = get_bloginfo( 'admin_email' ); } else { $user = $this->get_userdata( $this->subscribe2_options['sender'] ); $this->myemail = $user->user_email; $this->myname = html_entity_decode( $user->display_name, ENT_QUOTES ); } $scheds = (array) wp_get_schedules(); $email_freq = $this->subscribe2_options['email_freq']; $display = $scheds[ $email_freq ]['display']; ( '' === get_option( 'blogname' ) ) ? $subject = '' : $subject = '[' . stripslashes( html_entity_decode( get_option( 'blogname' ), ENT_QUOTES ) ) . '] '; $subject .= $display . ' ' . __( 'Digest Email', 'subscribe2' ); $mailtext = str_replace( '{TABLELINKS}', $tablelinks, $mailtext ); $mailtext = str_replace( '{TABLE}', $table, $mailtext ); $mailtext = str_replace( '{POSTTIME}', $message_posttime, $mailtext ); $mailtext = str_replace( '{POST}', $message_post, $mailtext ); // apply filter to allow custom keywords $mailtext = apply_filters( 's2_custom_keywords', $mailtext, $digest_post_ids ); $mailtext = stripslashes( $this->substitute( $mailtext ) ); // prepare recipients if ( '' !== $preview ) { $this->myemail = $preview; $this->myname = __( 'Digest Preview', 'subscribe2' ); $this->mail( array( $preview ), $subject, $mailtext ); } else { $public = $this->get_public(); $all_post_cats_string = implode( ',', $all_post_cats ); $registered = $this->get_registered( "cats=$all_post_cats_string" ); $recipients = array_merge( (array) $public, (array) $registered ); $this->mail( $recipients, $subject, $mailtext, $digest_format ); } } /** * Task to delete unconfirmed public subscribers after a defined interval */ public function s2cleaner_task() { $unconfirmed = $this->get_public( 0 ); if ( empty( $unconfirmed ) ) { return; } global $wpdb; $old_unconfirmed = $wpdb->get_col( $wpdb->prepare( "SELECT email FROM $wpdb->subscribe2 WHERE active='0' AND date < DATE_SUB(CURDATE(), INTERVAL %d DAY) AND conf_date IS NULL", $this->clean_interval ) ); if ( empty( $old_unconfirmed ) ) { return; } else { foreach ( $old_unconfirmed as $email ) { $this->delete( $email ); } } } /** Jetpack comments doesn't play nice, this function kills that module */ public function s2_hide_jetpack_comments( $modules ) { unset( $modules['comments'] ); return $modules; } /* ===== Our constructor ===== */ /** * Subscribe2 constructor */ public function s2init() { global $wpdb, $wp_version, $wpmu_version; // load the options $this->subscribe2_options = get_option( 'subscribe2_options' ); // maybe use dev scripts $this->script_debug = ( defined( 'SCRIPT_DEBUG' ) && SCRIPT_DEBUG ) ? '' : '.min'; $this->word_wrap = apply_filters( 's2_word_wrap', 78 ); // RFC5322 states line length MUST be no more than 998 characters // and SHOULD be no more than 78 characters // Use 78 as default and cap user values above 998 if ( $this->word_wrap > 998 ) { $this->word_wrap = 998; } $this->excerpt_length = apply_filters( 's2_excerpt_length', 55 ); $this->site_switching = apply_filters( 's2_allow_site_switching', false ); $this->clean_interval = apply_filters( 's2_clean_interval', 28 ); $this->lockout = apply_filters( 's2_lockout', 0 ); // lockout is for a maximum of 24 hours so cap the value if ( $this->lockout > 86399 ) { $this->lockout > 86399; } // get the WordPress release number for in code version comparisons $tmp = explode( '-', $wp_version, 2 ); $this->wp_release = $tmp[0]; // Is this WordPressMU or not? if ( isset( $wpmu_version ) || strpos( $wp_version, 'wordpress-mu' ) ) { $this->s2_mu = true; } if ( function_exists( 'is_multisite' ) && is_multisite() ) { $this->s2_mu = true; } // add action to handle WPMU subscriptions and unsubscriptions if ( true === $this->s2_mu ) { require_once S2PATH . 'classes/class-s2-multisite.php'; global $s2class_multisite; $s2class_multisite = new S2_Multisite(); if ( isset( $_GET['s2mu_subscribe'] ) || isset( $_GET['s2mu_unsubscribe'] ) ) { add_action( 'init', array( &$s2class_multisite, 'wpmu_subscribe' ) ); } } // load our translations add_action( 'init', array( &$this, 'load_translations' ) ); // define and register table name $s2_table = $wpdb->prefix . 'subscribe2'; if ( ! isset( $wpdb->subscribe2 ) ) { $wpdb->subscribe2 = $s2_table; $wpdb->tables[] = 'subscribe2'; } // do we need to install anything? if ( $wpdb->get_var( $wpdb->prepare( 'SHOW TABLES LIKE %s', $wpdb->subscribe2 ) ) !== $wpdb->subscribe2 ) { require_once S2PATH . 'classes/class-s2-upgrade.php'; global $s2_upgrade; $s2_upgrade = new S2_Upgrade(); $s2_upgrade->install(); } //do we need to upgrade anything? if ( false === $this->subscribe2_options || is_array( $this->subscribe2_options ) && S2VERSION !== $this->subscribe2_options['version'] ) { global $s2_upgrade; if ( ! is_a( $s2_upgrade, 'S2_Upgrade' ) ) { require_once S2PATH . 'classes/class-s2-upgrade.php'; $s2_upgrade = new S2_Upgrade(); } add_action( 'shutdown', array( &$s2_upgrade, 'upgrade' ) ); } // add core actions add_filter( 'cron_schedules', array( &$this, 'add_weekly_sched' ), 20 ); // add actions for automatic subscription based on option settings if ( $this->s2_mu ) { add_action( 'wpmu_activate_user', array( &$s2class_multisite, 'wpmu_add_user' ) ); add_action( 'add_user_to_blog', array( &$s2class_multisite, 'wpmu_add_user' ), 10 ); add_action( 'remove_user_from_blog', array( &$s2class_multisite, 'wpmu_remove_user' ), 10 ); } else { add_action( 'register_form', array( &$this, 'register_form' ) ); add_action( 'user_register', array( &$this, 'register_post' ) ); } // add actions for processing posts based on per-post or cron email settings if ( 'never' !== $this->subscribe2_options['email_freq'] ) { add_action( 's2_digest_cron', array( &$this, 'subscribe2_cron' ) ); add_action( 'transition_post_status', array( &$this, 'digest_post_transitions' ), 10, 3 ); } else { $statuses = apply_filters( 's2_post_statuses', array( 'new', 'draft', 'auto-draft', 'pending' ) ); if ( 'yes' === $this->subscribe2_options['private'] ) { foreach ( $statuses as $status ) { add_action( "{$status}_to_private", array( &$this, 'publish' ) ); } } array_push( $statuses, 'private', 'future' ); foreach ( $statuses as $status ) { add_action( "{$status}_to_publish", array( &$this, 'publish' ) ); } } // add actions for comment subscribers if ( 'no' !== $this->subscribe2_options['comment_subs'] ) { add_filter( 'jetpack_get_available_modules', array( &$this, 's2_hide_jetpack_comments' ) ); add_filter( 'comment_form_submit_field', array( &$this, 's2_comment_meta_form' ) ); add_action( 'comment_post', array( &$this, 's2_comment_meta' ), 1, 2 ); add_action( 'wp_set_comment_status', array( &$this, 'comment_status' ) ); } // add action to display widget if option is enabled if ( '1' === $this->subscribe2_options['widget'] ) { add_action( 'widgets_init', array( &$this, 'subscribe2_widget' ) ); } // add action to display counter widget if option is enabled if ( '1' === $this->subscribe2_options['counterwidget'] ) { add_action( 'widgets_init', array( &$this, 'counter_widget' ) ); } // add action to 'clean' unconfirmed Public Subscribers if ( is_int( $this->clean_interval ) && $this->clean_interval > 0 ) { add_action( 'wp_scheduled_delete', array( &$this, 's2cleaner_task' ) ); } // add ajax class if enabled if ( '1' === $this->subscribe2_options['ajax'] ) { require_once S2PATH . 'classes/class-s2-ajax.php'; global $mysubscribe2_ajax; $mysubscribe2_ajax = new S2_Ajax(); } // Check if Block Editor is in use if ( function_exists( 'register_block_type' ) && ! class_exists( 'Classic_Editor' ) && false === has_filter( 'use_block_editor_for_post', '__return_false' ) ) { $this->block_editor = true; } // Compatibility with Fusion Builder if ( is_plugin_active( 'fusion-builder/fusion-builder.php' ) && ! isset( $_GET['gutenberg-editor'] ) ) { $this->block_editor = false; } if ( true === $this->block_editor ) { require_once S2PATH . 'classes/class-s2-block-editor.php'; global $mysubscribe2_block_editor; $mysubscribe2_block_editor = new S2_Block_Editor(); } // Add actions specific to admin or frontend if ( is_admin() ) { //add menu, authoring and category admin actions add_action( 'admin_menu', array( &$this, 'admin_menu' ) ); add_action( 'add_meta_boxes', array( &$this, 's2_meta_init' ), 10, 2 ); add_action( 'save_post', array( &$this, 's2_meta_handler' ) ); add_action( 'save_post', array( &$this, 's2_preview_handler' ) ); add_action( 'save_post', array( &$this, 's2_resend_handler' ) ); add_action( 'create_category', array( &$this, 'new_category' ) ); add_action( 'delete_category', array( &$this, 'delete_category' ) ); // Add filters for Ozh Admin Menu if ( function_exists( 'wp_ozh_adminmenu' ) ) { add_filter( 'ozh_adminmenu_icon_s2', array( &$this, 'ozh_s2_icon' ) ); add_filter( 'ozh_adminmenu_icon_s2_posts', array( &$this, 'ozh_s2_icon' ) ); add_filter( 'ozh_adminmenu_icon_s2_tools', array( &$this, 'ozh_s2_icon' ) ); add_filter( 'ozh_adminmenu_icon_s2_settings', array( &$this, 'ozh_s2_icon' ) ); } // add write button if ( '1' === $this->subscribe2_options['show_button'] && false === $this->block_editor ) { add_action( 'admin_init', array( &$this, 'button_init' ) ); } // add counterwidget css and js if ( '1' === $this->subscribe2_options['counterwidget'] ) { add_action( 'admin_init', array( &$this, 'widget_s2counter_css_and_js' ) ); } // add one-click handlers if ( 'yes' === $this->subscribe2_options['one_click_profile'] ) { add_action( 'show_user_profile', array( &$this, 'one_click_profile_form' ) ); add_action( 'edit_user_profile', array( &$this, 'one_click_profile_form' ) ); add_action( 'personal_options_update', array( &$this, 'one_click_profile_form_save' ) ); add_action( 'edit_user_profile_update', array( &$this, 'one_click_profile_form_save' ) ); } // digest email preview and resend actions add_action( 's2_digest_preview', array( &$this, 'digest_preview' ) ); add_action( 's2_digest_resend', array( &$this, 'digest_resend' ) ); // add handler to dismiss sender error notice add_action( 'wp_ajax_s2_dismiss_notice', array( &$this, 's2_dismiss_notice_handler' ) ); // subscriber page options handler add_filter( 'set-screen-option', array( &$this, 'subscribers_set_screen_option' ), 10, 3 ); // MailOptin admin notices require_once S2PATH . 'classes/class-mo-admin-notice.php'; // register uninstall functions register_uninstall_hook( S2PLUGIN, array( 'S2_Admin', 's2_uninstall' ) ); // capture CSV export if ( isset( $_POST['s2_admin'] ) && isset( $_POST['csv'] ) ) { $date = gmdate( 'Y-m-d' ); header( 'Content-Description: File Transfer' ); header( 'Content-type: application/octet-stream' ); header( "Content-Disposition: attachment; filename=subscribe2_users_$date.csv" ); header( 'Pragma: no-cache' ); header( 'Expires: 0' ); echo esc_html( $this->prepare_export( $_POST['exportcsv'] ) ); exit( 0 ); } } else { // load strings later on frontend for polylang plugin compatibility add_action( 'wp', array( &$this, 'load_strings' ) ); if ( isset( $_GET['s2'] ) ) { // someone is confirming a request add_filter( 'request', array( &$this, 'query_filter' ) ); add_filter( 'the_title', array( &$this, 'title_filter' ) ); add_filter( 'the_content', array( &$this, 'confirm' ) ); } // add the frontend filters add_filter( 'the_content', array( &$this, 'filter' ), 10 ); // add actions for other plugins if ( '1' === $this->subscribe2_options['show_meta'] ) { add_action( 'wp_meta', array( &$this, 'add_minimeta' ), 0 ); } // add action for adding javascript IP updating code if ( '1' === $this->subscribe2_options['js_ip_updater'] ) { add_action( 'wp_enqueue_scripts', array( &$this, 'js_ip_script' ), 10 ); add_action( 'wp_footer', array( &$this, 'js_ip_library_script' ), 20 ); } } add_shortcode( 'subscribe2', array( &$this, 'widget_shortcode' ) ); } /* ===== define some variables ===== */ // options public $subscribe2_options = array(); // check for block editor public $block_editor = false; // state variables used to affect processing public $s2_mu = false; public $filtered = 0; public $post_count; // state variable used in substitute() function public $post_title; public $post_title_text; public $permalink; public $post_date; public $post_time; public $myname; public $myemail; public $authorname; public $post_cat_names; public $post_tag_names; }