# friends/4.3.2/includes/class-feed.php Friends, version 4.3.2. 1,440 lines. - Page: https://pluginprobe.com/plugins/friends/4.3.2/code/includes/class-feed.php - Raw: https://pluginprobe.com/plugins/friends/4.3.2/raw/includes/class-feed.php - Modified: 2026-09-15T14:52:52+00:00 Line numbers below start at 1. Link to a line or a range by appending a fragment to the page URL, for example `https://pluginprobe.com/plugins/friends/4.3.2/code/includes/class-feed.php#L10-L20`. ```php friends = $friends; $this->register_hooks(); } /** * Register the WordPress hooks */ private function register_hooks() { add_filter( 'friends_early_modify_feed_item', array( $this, 'apply_early_feed_rules' ), 10, 3 ); add_filter( 'friends_modify_feed_item', array( $this, 'apply_feed_rules' ), 10, 3 ); add_action( 'rss_item', array( $this, 'feed_additional_fields' ) ); add_action( 'rss2_item', array( $this, 'feed_additional_fields' ) ); add_action( 'rss_ns', array( $this, 'additional_feed_namespaces' ) ); add_action( 'rss2_ns', array( $this, 'additional_feed_namespaces' ) ); add_action( 'cron_friends_refresh_feeds', array( $this, 'cron_friends_refresh_feeds' ) ); add_action( 'friends_retrieve_user_feeds', array( $this, 'friends_retrieve_user_feeds' ) ); add_action( 'wp_loaded', array( $this, 'friends_add_friend_redirect' ), 100 ); add_action( 'wp_feed_options', array( $this, 'wp_feed_options' ), 90 ); add_action( 'wp_insert_post', array( $this, 'invalidate_post_count_cache' ), 10, 2 ); add_action( 'oembed_request_post_id', array( $this, 'oembed_request_post_id' ), 10, 2 ); add_action( 'post_embed_url', array( $this, 'post_embed_url' ), 10, 2 ); } /** * Allow registering a parser * * @param string $slug The slug. * @param Feed_Parser $parser The parser that extends the Feed_Parser class. */ public function register_parser( $slug, Feed_Parser $parser ) { if ( in_array( $slug, $this->reserved_parser_slugs, true ) ) { // translators: %s is the slug of a parser. return new \WP_Error( 'resevered-slug', sprintf( __( 'The slug "%s" cannot be used.', 'friends' ), $slug ) ); } if ( isset( $this->parsers[ $slug ] ) ) { // translators: %s is the slug of a parser. return new \WP_Error( 'parser-already-registered', sprintf( __( 'There is already a parser registered with the slug "%s".', 'friends' ), $slug ) ); } $this->parsers[ $slug ] = $parser; return true; } /** * Allow unregistering a parser * * @param string $slug The slug. */ public function unregister_parser( $slug ) { if ( ! in_array( $slug, $this->reserved_parser_slugs, true ) ) { unset( $this->parsers[ $slug ] ); } } /** * Cron function to refresh the feeds of the friends' blogs */ public function cron_friends_refresh_feeds() { foreach ( User_Feed::get_all_due() as $feed ) { if ( ! $feed->can_be_polled_now() ) { continue; } $feed->set_polling_now(); $this->retrieve_feed( $feed ); $feed->was_polled(); } } /** * Function to fetch a users feeds. * * @param int $user_id The user id. */ public function friends_retrieve_user_feeds( $user_id ) { $friend_user = User::get_user_by_id( $user_id ); if ( ! $friend_user ) { return; } foreach ( $friend_user->get_active_feeds() as $feed ) { $friend_user = $feed->get_friend_user(); if ( $friend_user && $feed->can_be_polled_now() ) { $feed->set_polling_now(); $this->retrieve_feed( $feed ); $feed->was_polled(); } } } /** * Preview a URL using a parser. * * @param string|Feed_Parser $parser The parser or its slug slug. * @param string $url The url. * @param int $feed_id The feed id. * * @return array|\WP_Error The feed items. */ public function preview( $parser, $url, $feed_id = null ) { if ( is_string( $parser ) ) { if ( ! isset( $this->parsers[ $parser ] ) ) { return new \WP_Error( 'unknown-parser', sprintf( // translators: %s is a parser name. __( 'An unknown parser name was supplied: %s', 'friends' ), $parser ) ); } $parser = $this->parsers[ $parser ]; } elseif ( ! $parser instanceof Feed_Parser_V2 ) { return new \WP_Error( 'invalid-parser', __( 'An invalid parser was supplied.', 'friends' ) ); } $user_feed = null; $friend_user = null; if ( ! is_null( $feed_id ) ) { $user_feed = User_Feed::get_by_id( $feed_id ); if ( ! is_wp_error( $user_feed ) ) { $friend_user = $user_feed->get_friend_user(); } } $items = $parser->fetch_feed( $url, $user_feed ); if ( ! is_wp_error( $items ) ) { if ( empty( $items ) ) { $items = new \WP_Error( 'empty-feed', __( "This feed doesn't contain any entries. There might be a problem parsing the feed.", 'friends' ) ); } else { foreach ( $items as $key => $item ) { if ( is_wp_error( $item ) ) { unset( $items[ $key ] ); continue; } $item = apply_filters( 'friends_modify_feed_item', $item, $user_feed, $friend_user, null ); if ( ! $item || $item->_feed_rule_delete ) { unset( $items[ $key ] ); continue; } if ( ! empty( $item->_feed_rule_transform ) && is_array( $item->_feed_rule_transform ) ) { if ( isset( $item->_feed_rule_transform['post_content'] ) ) { $items[ $key ]->content = $item->_feed_rule_transform['post_content']; } } } } } return $items; } /** * Retrieves a user feed. * * @param User_Feed $user_feed The user feed. * * @return array|\WP_Error The retrieved items. */ public function retrieve_feed( User_Feed $user_feed ) { $friend_user = $user_feed->get_friend_user(); $parser = $user_feed->get_parser(); if ( ! isset( $this->parsers[ $parser ] ) ) { $error = new \WP_Error( 'unknown-parser', __( 'An unknown parser name was supplied.', 'friends' ) ); do_action( 'friends_retrieve_friends_error', $user_feed, $error, $friend_user ); return $error; } try { $items = $this->parsers[ $parser ]->fetch_feed( $user_feed->get_url(), $user_feed ); } catch ( \Exception $e ) { $items = new \WP_Error( $parser . '-failed', $e->getMessage() ); } if ( is_wp_error( $items ) ) { do_action( 'friends_retrieve_friends_error', $user_feed, $items, $friend_user ); return $items; } $new_posts = $this->process_incoming_feed_items( $items, $user_feed ); return $new_posts; } /** * Notify users about new posts of this friend * * @param User $friend_user The friend. * @param array $new_posts The new posts of this friend. * @param User_Feed $user_feed The user feed. */ public function notify_about_new_posts( User $friend_user, $new_posts, User_Feed $user_feed ) { $keywords = self::get_active_notification_keywords(); foreach ( $new_posts as $post_id ) { $post = false; $keyword_match = false; if ( $keywords ) { $post = get_post( intval( $post_id ) ); $fulltext = ''; foreach ( apply_filters( 'friends_keyword_search_fields', array( 'post_title', 'post_content' ) ) as $field ) { $fulltext .= PHP_EOL . $post->$field; } $fulltext = self::prepare_keyword_search_text( $fulltext ); foreach ( $keywords as $keyword ) { if ( preg_match( '/' . str_replace( '/', '\\/', $keyword ) . '/ius', $fulltext ) ) { $keyword_match = $keyword; break; } } if ( $keyword_match ) { $notified = apply_filters( 'friends_notify_keyword_match_post', false, $post, $keyword_match ); if ( $notified ) { continue; } } } $notify_users = apply_filters( 'notify_about_new_friend_post', true, $friend_user, $post_id, $user_feed, $keyword_match ); if ( $notify_users ) { if ( ! $post ) { $post = get_post( intval( $post_id ) ); } do_action( 'notify_new_friend_post', $post, $user_feed, $keyword_match ); } } } /** * Retrieve posts from all friends. * * @param bool $ignore_due_date Whether to get also undue feeds. */ public function retrieve_friend_posts( $ignore_due_date = false ) { foreach ( User_Feed::get_all_due( $ignore_due_date ) as $feed ) { $feed->set_polling_now(); $this->retrieve_feed( $feed ); $feed->was_polled(); } } /** * Apply the feed rules that need to be applied early. * * @param Feed_Item $item The feed item. * @param User_Feed $feed The feed. * @param User $friend_user The friend user. * @return Feed_Item The modified feed item. */ public function apply_early_feed_rules( $item, ?User_Feed $feed = null, ?User $friend_user = null ) { $updated_item = $this->apply_feed_rules( $item, $feed, $friend_user ); if ( $updated_item->_feed_rule_delete ) { return $updated_item; } return $item; } /** * Apply the feed rules * * @param Feed_Item $item The feed item. * @param User_Feed $feed The feed object. * @param User $friend_user The friend user. * @return Feed_Item The modified feed item. */ public function apply_feed_rules( $item, ?User_Feed $feed = null, ?User $friend_user = null ) { if ( is_null( $friend_user ) ) { return $item; } $rules = $friend_user->get_feed_rules(); $action = $friend_user->get_feed_catch_all(); $decided = false; foreach ( $rules as $rule ) { if ( $item instanceof \WP_Post ) { $field = $this->get_feed_rule_field( $rule['field'] ); if ( 'author' === $rule['field'] ) { $item->$field = get_post_meta( $item->ID, 'author', true ); } } else { $field = $rule['field']; } $subject = false; if ( $item->$field ) { $subject = $item->$field; } $field_rule_field = $this->get_feed_rule_field( $rule['field'], $item ); if ( isset( $item->_feed_rule_transform[ $field_rule_field ] ) ) { $subject = $item->_feed_rule_transform[ $field_rule_field ]; } if ( $subject && preg_match( '/' . str_replace( '/', '\\/', $rule['regex'] ) . '/ius', $subject ) ) { if ( 'replace' === $rule['action'] ) { $item->_feed_rule_transform = array( $field_rule_field => preg_replace( '/' . str_replace( '/', '\\/', $rule['regex'] ) . '/ius', $rule['replace'], $subject ), ); continue; } if ( $decided ) { continue; } $action = $rule['action']; $decided = true; } } switch ( $action ) { case 'delete': $item->_feed_rule_delete = true; return $item; case 'trash': if ( empty( $item->_feed_rule_transform ) ) { $item->_feed_rule_transform = array(); } $item->_feed_rule_transform = array_merge( $item->_feed_rule_transform, array( 'post_status' => 'trash', ) ); return $item; case 'accept': return $item; } return $item; } /** * Get the field name for the feed item. * * @param string $field The field name. * @return string The adapted field name. */ private function get_feed_rule_field( $field ) { switch ( $field ) { case 'title': return 'post_title'; case 'permalink': return 'guid'; case 'content': return 'post_content'; } return $field; } /** * Validate feed item rules * * @param array $rules The rules to validate. * @return array The valid rules. */ public static function validate_feed_rules( $rules ) { if ( ! is_array( $rules ) ) { $json_rules = json_decode( $rules, true ); if ( is_array( $json_rules ) ) { $rules = $json_rules; } else { return array(); } } if ( isset( $rules['field'] ) && is_array( $rules['field'] ) ) { // Transform POST values. $transformed_rules = array(); foreach ( array_keys( $rules['field'] ) as $key ) { $rule = array(); foreach ( $rules as $part => $keys ) { if ( isset( $keys[ $key ] ) ) { $rule[ $part ] = stripslashes( $keys[ $key ] ); } } $transformed_rules[] = $rule; } $rules = $transformed_rules; } foreach ( $rules as $k => $rule ) { if ( ! isset( $rule['field'] ) || ! in_array( $rule['field'], array( 'title', 'content', 'permalink', 'author' ), true ) ) { unset( $rules[ $k ] ); continue; } if ( ! isset( $rule['regex'] ) || ! is_string( $rule['regex'] ) || '' === trim( $rule['regex'] ) ) { unset( $rules[ $k ] ); continue; } $rules[ $k ]['regex'] = substr( $rule['regex'], 0, 10240 ); if ( ! isset( $rule['action'] ) || ! in_array( $rule['action'], array( 'accept', 'trash', 'delete', 'replace' ), true ) ) { unset( $rules[ $k ] ); continue; } if ( 'replace' === $rule['action'] ) { if ( ! isset( $rule['replace'] ) || ! is_string( $rule['replace'] ) ) { unset( $rules[ $k ] ); continue; } $rules[ $k ]['replace'] = substr( $rule['replace'], 0, 10240 ); } else { unset( $rules[ $k ]['replace'] ); } } return $rules; } /** * Validate feed catch_all * * @param array $catch_all The catch_all value to. * @return array A valid catch_all */ public static function validate_feed_catch_all( $catch_all ) { if ( ! in_array( $catch_all, array( 'accept', 'trash', 'delete' ), true ) ) { return 'accept'; } return $catch_all; } /** * Prepares post fields for keyword notification matching. * * @param string $text The text to search. * @return string The prepared text. */ public static function prepare_keyword_search_text( $text ) { $text = wp_strip_all_tags( $text ); return preg_replace_callback( '#https?://[^\s<>"\']+#i', function ( $matches ) { return self::remove_tracking_url_query_args_from_keyword_search_text( $matches[0] ); }, $text ); } /** * Removes tracking query args from URLs before keyword notification matching. * * @param string $url The URL to normalize. * @return string The URL without known tracking query args. */ private static function remove_tracking_url_query_args_from_keyword_search_text( $url ) { $parsed_url = wp_parse_url( $url ); if ( ! is_array( $parsed_url ) || empty( $parsed_url['host'] ) ) { return $url; } $query_args = array(); if ( isset( $parsed_url['query'] ) ) { wp_parse_str( html_entity_decode( $parsed_url['query'], ENT_QUOTES ), $query_args ); } foreach ( array_keys( $query_args ) as $query_arg ) { if ( self::is_tracking_query_arg( $query_arg ) ) { unset( $query_args[ $query_arg ] ); } } $normalized_url = $parsed_url['scheme'] . '://'; if ( isset( $parsed_url['user'] ) ) { $normalized_url .= $parsed_url['user']; if ( isset( $parsed_url['pass'] ) ) { $normalized_url .= ':' . $parsed_url['pass']; } $normalized_url .= '@'; } $normalized_url .= $parsed_url['host']; if ( isset( $parsed_url['port'] ) ) { $normalized_url .= ':' . $parsed_url['port']; } if ( isset( $parsed_url['path'] ) ) { $normalized_url .= $parsed_url['path']; } if ( $query_args ) { $normalized_url .= '?' . http_build_query( $query_args, '', '&' ); } if ( isset( $parsed_url['fragment'] ) ) { $normalized_url .= '#' . $parsed_url['fragment']; } return $normalized_url; } /** * Checks whether a query arg is used for tracking. * * @param string $query_arg The query arg. * @return bool Whether the query arg is used for tracking. */ private static function is_tracking_query_arg( $query_arg ) { if ( preg_match( '/^(?:utm|mtm|hsa)_/i', $query_arg ) ) { return true; } return in_array( strtolower( $query_arg ), array( '_hsenc', '_hsmi', 'dclid', 'fbclid', 'gclid', 'gbraid', 'igshid', 'li_fat_id', 'mc_cid', 'mc_eid', 'mkt_tok', 'msclkid', 'oly_anon_id', 'oly_enc_id', 'pk_campaign', 'pk_kwd', 'twclid', 'vero_id', 'wbraid', 'yclid', ), true ); } /** * Gets the notification keywords. * * @return array The notification keywords. */ public static function get_active_notification_keywords() { $active_keywords = array(); foreach ( self::get_all_notification_keywords() as $entry ) { if ( $entry['enabled'] ) { $active_keywords[] = $entry['keyword']; } } return $active_keywords; } /** * Gets all notification keywords. * * @return array All notification keywords. */ public static function get_all_notification_keywords() { $keywords = get_option( 'friends_notification_keywords', false ); if ( false === $keywords ) { // Default keywords. $keywords = array(); $keywords[] = array( 'enabled' => false, 'keyword' => trim( preg_replace( '#^https?:#', '', home_url() ), '/' ), ); } return $keywords; } /** * Discover the post format for the item. * * @param object $item The feed item. * * @return string The discovered post format. */ public function post_format_discovery( $item ) { // phpcs:ignore Generic.CodeAnalysis.UnusedFunctionParameter.Found // Not implemented yet. return 'standard'; } /** * Return the number of revisions to keep. * * @return int The number of revisions to keep. */ public function revisions_to_keep() { return 10; } public function dissallowed_html( $allowedposttags, $context ) { if ( 'post' === $context ) { unset( $allowedposttags['article'] ); } return $allowedposttags; } /** * Process incoming feed items * * @param array $items The incoming items. * @param User_Feed $user_feed The feed to which these items belong. * @return array The post ids of the new posts. */ public function process_incoming_feed_items( array $items, User_Feed $user_feed ) { $friend_user = $user_feed->get_friend_user(); if ( ! $friend_user ) { if ( apply_filters( 'friends_debug', false ) ) { error_log( var_export( $user_feed, true ) ); // phpcs:ignore WordPress.PHP.DevelopmentFunctions } return; } $remote_post_ids = $friend_user->get_remote_post_ids(); $post_formats = get_post_format_strings(); $feed_post_format = $user_feed->get_post_format(); // Sort items by date asc so that older posts will have lower ids than newer posts. usort( $items, function ( $a, $b ) { if ( ! isset( $a->date ) || ! isset( $b->date ) ) { return 0; } return strtotime( $a->date ) - strtotime( $b->date ); } ); // Limit this as a safety measure. add_filter( 'wp_revisions_to_keep', array( $this, 'revisions_to_keep' ) ); $new_post_ids = array(); $modified_posts = array(); $manual_refresh = isset( $_GET['page'] ) && 'friends-refresh' === $_GET['page'] && isset( $_GET['_wpnonce'] ) && wp_verify_nonce( sanitize_key( $_GET['_wpnonce'] ), 'friends-refresh' ); foreach ( $items as $item_key => $item ) { if ( ! isset( $item->permalink ) || ! $item->permalink ) { continue; } $item->permalink = str_replace( array( '&', '&' ), '&', ent2ncr( wp_kses_normalize_entities( $item->permalink ) ) ); if ( empty( $item->post_content ) ) { $item->post_content = ''; } add_filter( 'wp_kses_allowed_html', array( $this, 'dissallowed_html' ), 10, 2 ); $item->post_content = wp_kses_post( trim( $item->post_content ) ); remove_filter( 'wp_kses_allowed_html', array( $this, 'dissallowed_html' ), 10 ); $item = apply_filters( 'friends_early_modify_feed_item', $item, $user_feed, $friend_user ); if ( ! $item || $item->_feed_rule_delete ) { continue; } // Fallback, when no friends plugin is installed. $item->post_id = $item->permalink; $item->post_status = 'publish'; if ( ( ! $item->post_content && ! $item->title ) || ! $item->permalink ) { continue; } $post_id = null; if ( $item->post_id && isset( $remote_post_ids[ $item->post_id ] ) ) { $post_id = $remote_post_ids[ $item->post_id ]; } if ( is_null( $post_id ) && $item->permalink && isset( $remote_post_ids[ $item->permalink ] ) ) { $post_id = $remote_post_ids[ $item->permalink ]; } if ( is_null( $post_id ) ) { $post_id = self::url_to_postid( $item->permalink ); } $item->_is_new = is_null( $post_id ); $item = apply_filters( 'friends_modify_feed_item', $item, $user_feed, $friend_user, $post_id ); $updated_date = $item->date; if ( ! empty( $item->updated_date ) ) { $updated_date = $item->updated_date; } if ( empty( $item->title ) ) { $item->title = ''; } $post_data = array( 'post_title' => $item->title, 'post_content' => force_balance_tags( $item->post_content ), 'post_modified_gmt' => $updated_date, 'post_status' => $item->post_status, 'guid' => $item->permalink, 'comment_count' => $item->comment_count, ); // Modified via feed rules. if ( ! empty( $item->_feed_rule_transform ) && is_array( $item->_feed_rule_transform ) ) { $post_data = array_merge( $post_data, $item->_feed_rule_transform ); } $old_post = null; if ( ! is_null( $post_id ) ) { $old_post = get_post( $post_id ); $modified_post_data = array(); foreach ( array( 'post_title', 'post_content', 'post_status' ) as $field ) { if ( empty( $old_post->$field ) || empty( $post_data[ $field ] ) ) { continue; } if ( 'post_content' === $field && $old_post->$field !== $post_data[ $field ] ) { $modified_post_data[ $field ] = $post_data[ $field ]; break; } if ( wp_strip_all_tags( $old_post->$field ) !== wp_strip_all_tags( $post_data[ $field ] ) ) { $modified_post_data[ $field ] = $post_data[ $field ]; break; } } if ( ! empty( $modified_post_data ) && apply_filters( 'friends_can_update_modified_feed_posts', true, $item, $user_feed, $friend_user, $post_id ) ) { $was_modified_by_user = false; foreach ( wp_get_post_revisions( $post_id ) as $revision ) { if ( intval( $revision->post_author ) && intval( $revision->post_author ) !== $friend_user->ID ) { $was_modified_by_user = true; break; } } if ( ! $was_modified_by_user || $manual_refresh ) { $modified_post_data['ID'] = $post_id; if ( isset( $modified_post_data['post_content'] ) ) { $modified_post_data['post_content'] = str_replace( '\\', '\\\\', $modified_post_data['post_content'] ); } if ( intval( $old_post->comment_count ) !== intval( $item->comment_count ) ) { $modified_post_data['comment_count'] = $item->comment_count; } wp_update_post( $modified_post_data ); $modified_posts[ $item_key ] = $post_id; } } } else { $post_data['post_type'] = Friends::CPT; $post_data['post_date_gmt'] = $item->date; $post_data['post_content'] = str_replace( '\\', '\\\\', $post_data['post_content'] ); $post_data['meta_input'] = $item->meta; $post_id = $friend_user->insert_post( $post_data, true ); if ( is_wp_error( $post_id ) ) { continue; } $new_post_ids[ $item_key ] = $post_id; $remote_post_ids[ $item->permalink ] = $post_id; } if ( is_null( $old_post ) || intval( $old_post->comment_count ) !== intval( $item->comment_count ) ) { // The comment_count needs to be updated manually since it doesn't represent real comments in the database. global $wpdb; $wpdb->update( $wpdb->posts, array( 'comment_count' => $item->comment_count ), array( 'ID' => $post_id ) ); // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching wp_cache_delete( "comments-{$post_id}", 'counts' ); clean_post_cache( $post_id ); do_action( 'wp_update_comment_count', $post_id, $item->comment_count, $old_post ? $old_post->comment_count : 0 ); } if ( $item->comments_feed && ( is_null( $old_post ) || $old_post->comments_feed !== $item->comments_feed ) ) { update_post_meta( $post_id, self::COMMENTS_FEED_META, $item->comments_feed, $old_post ? $old_post->comments_feed : '' ); } $post_format = $feed_post_format; if ( 'autodetect' === $post_format ) { if ( isset( $item->post_format ) && isset( $post_formats[ $item->post_format ] ) ) { $post_format = $item->post_format; } else { $post_format = $this->post_format_discovery( $item ); } } if ( $post_format ) { set_post_format( $post_id, $post_format ); } if ( $item->author ) { update_post_meta( $post_id, 'author', $item->author ); } if ( is_numeric( $item->post_id ) ) { update_post_meta( $post_id, 'remote_post_id', $item->{'post-id'} ); } if ( ! get_option( 'friends_disable_auto_tagging' ) && isset( $item->friend_tags ) && ! empty( $item->friend_tags ) && is_array( $item->friend_tags ) ) { Friend_Tag::add_tags( $post_id, $item->friend_tags ); } if ( isset( $item->friend_mention_tags ) && ! empty( $item->friend_mention_tags ) && is_array( $item->friend_mention_tags ) ) { Friend_Tag::add_tags( $post_id, $item->friend_mention_tags ); } update_post_meta( $post_id, 'parser', $user_feed->get_parser() ); update_post_meta( $post_id, 'feed_url', $user_feed->get_url() ); global $wpdb; $wpdb->update( $wpdb->posts, array( 'comment_count' => $item->comment_count ), array( 'ID' => $post_id ) ); // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching } remove_filter( 'wp_revisions_to_keep', array( $this, 'revisions_to_keep' ) ); $deleted_posts = $friend_user->delete_outdated_posts(); $new_post_ids = array_diff( $new_post_ids, $deleted_posts ); $this->notify_about_new_posts( $friend_user, $new_post_ids, $user_feed ); do_action( 'friends_retrieved_new_posts', $user_feed, $new_post_ids, $modified_posts, $friend_user ); $new_posts = array(); foreach ( $new_post_ids as $key => $post_id ) { if ( isset( $items[ $key ] ) ) { $new_posts[ $post_id ] = $items[ $key ]; } } return $new_posts; } /** * Output an additional XMLNS for the feed. */ public function additional_feed_namespaces() { echo ' xmlns:friends="' . esc_attr( self::XMLNS ) . '" '; } /** * Additional fields for the friends feed. */ public function feed_additional_fields() { global $post; $post_format = get_post_format( $post ); if ( empty( $post_format ) ) { $post_format = 'standard'; } echo '' . esc_html( $post_format ) . '' . PHP_EOL; } /** * Redirect */ public function friends_add_friend_redirect() { // phpcs:ignore WordPress.Security.NonceVerification.Recommended if ( ! isset( $_GET['add-friend'] ) || isset( $_GET['page'] ) ) { return; } // phpcs:ignore WordPress.Security.NonceVerification.Recommended wp_safe_redirect( add_query_arg( 'url', sanitize_text_field( wp_unslash( $_GET['add-friend'] ) ), self_admin_url( 'admin.php?page=add-friend' ) ) ); exit; } /** * Configure feed downloading options * * @param SimplePie $feed The SimplePie object. */ public function wp_feed_options( $feed ) { $feed->useragent .= ' Friends/' . FRIENDS_VERSION; if ( isset( $_GET['_wpnonce'] ) && wp_verify_nonce( sanitize_key( $_GET['_wpnonce'] ), 'friends-refresh' ) && isset( $_GET['page'] ) && 'page=friends-refresh' === $_GET['page'] ) { $feed->enable_cache( false ); } else { $feed->set_cache_duration( 3590 ); } } /** * Invalidatee Post Count Cache * * @param int $post_ID The post id. * @param \WP_Post $post The post. */ public function invalidate_post_count_cache( $post_ID, \WP_Post $post ) { $cache_key = 'friends_post_count_by_post_format'; delete_transient( $cache_key ); if ( is_numeric( $post->post_author ) && $post->post_author > 0 ) { $author_id = intval( $post->post_author ); delete_transient( $cache_key . '_author_' . $author_id ); } } /** * Discover available feeds. * * @param string $url The feed URL. * @return array The available feeds. */ public function discover_available_feeds( $url ) { if ( ! Friends::check_url( $url ) ) { return array(); } $available_feeds = array(); $content = null; $content_type = 'text/html'; $response = wp_safe_remote_get( $url, array( 'timeout' => apply_filters( 'friends_http_timeout', 20 ), 'redirection' => 2, ) ); if ( is_wp_error( $response ) ) { $response->add_data( $url ); return $response; } $response_code = wp_remote_retrieve_response_code( $response ); if ( $response_code >= 300 && $response_code < 400 ) { $location = wp_remote_retrieve_header( $response, 'location' ); if ( $location ) { return new \WP_Error( 'redirect', sprintf( // translators: %s is a URL. __( 'This URL redirects to %s — please use that URL instead.', 'friends' ), '' . esc_html( $location ) . '' ) ); } } if ( 200 === $response_code ) { $content = wp_remote_retrieve_body( $response ); $headers = wp_remote_retrieve_headers( $response ); // We'll determine the obvious feeds ourself. $available_feeds = $this->discover_link_rel_feeds( $content, $url, $headers ); $content_type = strtok( $headers['content-type'], ';' ); } foreach ( $this->parsers as $slug => $parser ) { foreach ( $parser->discover_available_feeds( $content, $url ) as $link_url => $feed ) { if ( isset( $available_feeds[ $link_url ] ) ) { // If this parser tells us it can parse it right away, allow it to override. if ( isset( $available_feeds[ $link_url ]['parser'] ) || ! isset( $feed['parser'] ) ) { continue; } } else { $available_feeds[ $link_url ] = array(); } $available_feeds[ $link_url ] = array_merge( $available_feeds[ $link_url ], $feed ); $available_feeds[ $link_url ]['url'] = $link_url; } } $has_friends_plugin = false; foreach ( $available_feeds as $link_url => $feed ) { $feed = array_merge( array( 'url' => $link_url, 'rel' => 'unknown', 'type' => 'unknown', 'title' => '', 'parser' => 'unsupported', 'parser_confidence' => 0, ), $feed ); $available_feeds[ $link_url ] = $feed; if ( 'friends-base-url' === $feed['rel'] ) { $available_feeds[ $link_url ]['parser'] = 'friends'; $available_feeds[ $link_url ]['parser_confidence'] = 1000; $has_friends_plugin = $link_url; continue; } foreach ( $this->parsers as $slug => $parser ) { $confidence = intval( $parser->feed_support_confidence( $link_url, $feed['type'], $feed['rel'] ) ); $confidence = intval( apply_filters( 'friends_parser_confidence', $confidence, $slug, $link_url, $feed ) ); if ( $available_feeds[ $link_url ]['parser_confidence'] < $confidence ) { $available_feeds[ $link_url ]['parser_confidence'] = $confidence; $available_feeds[ $link_url ]['parser'] = $slug; } } } if ( ! isset( $available_feeds[ $url ] ) ) { $feed = array( 'url' => $url, 'type' => $content_type, 'rel' => 'self', 'title' => '', 'parser' => 'unsupported', 'parser_confidence' => 0, ); foreach ( $this->parsers as $slug => $parser ) { $confidence = $parser->feed_support_confidence( $url, $feed['type'], $feed['rel'], $content ); $confidence = apply_filters( 'friends_parser_confidence', $confidence, $slug, $url, $feed ); if ( $feed['parser_confidence'] < $confidence ) { $feed['parser_confidence'] = $confidence; $feed['parser'] = $slug; } } if ( 'unknown' !== $feed['parser'] ) { $available_feeds[ $feed['url'] ] = $feed; } } foreach ( array_keys( $available_feeds ) as $link_url ) { if ( ! isset( $this->parsers[ $available_feeds[ $link_url ]['parser'] ] ) ) { continue; } $parser = $this->parsers[ $available_feeds[ $link_url ]['parser'] ]; $updated_feed_details = $parser->update_feed_details( $available_feeds[ $link_url ] ); if ( is_array( $updated_feed_details ) && ! is_wp_error( $updated_feed_details ) ) { $available_feeds[ $link_url ] = array_merge( $available_feeds[ $link_url ], $updated_feed_details ); } $available_feeds[ $link_url ] = apply_filters( 'friends_update_feed_details', $available_feeds[ $link_url ], $slug ); if ( $available_feeds[ $link_url ]['url'] !== $link_url ) { $new_url = $available_feeds[ $link_url ]['url']; $available_feeds[ $new_url ] = $available_feeds[ $link_url ]; unset( $available_feeds[ $link_url ] ); } } $autoselected = false; // Check if a parser already autoselected a feed. foreach ( $available_feeds as $link_url => $feed ) { if ( isset( $feed['autoselect'] ) && $feed['autoselect'] ) { $autoselected = true; break; } } foreach ( $available_feeds as $link_url => $feed ) { $path = wp_parse_url( $link_url, PHP_URL_PATH ); // Backfill titles. if ( empty( $feed['title'] ) ) { $host = wp_parse_url( $link_url, PHP_URL_HOST ); if ( is_string( $path ) && trim( $path, '/' ) ) { $feed['title'] = trim( preg_replace( '#^www\.#i', '', preg_replace( '#[^a-z0-9.:-]#i', ' ', ucwords( $host . ': ' . $path ) ) ), ': ' ); } else { $feed['title'] = strtolower( $host ); } $available_feeds[ $link_url ]['title'] = $feed['title']; } // Autoselect heuristic. if ( $autoselected ) { continue; } if ( ! $feed['parser_confidence'] ) { continue; } // Prefer the main RSS feed. if ( '/feed' === substr( '/' . trim( $path, '/' ), -5 ) || '.xml' === substr( $path, -4 ) || 'rss' === substr( $path, -3 ) ) { if ( $has_friends_plugin ) { $available_feeds[ $link_url ]['post-format'] = 'autodetect'; } $autoselected = true; } elseif ( isset( $feed['rel'] ) ) { if ( 'alternate' === $feed['rel'] && 'application/rss+xml' === $feed['type'] && 'feed' === trim( $path, '/' ) ) { $autoselected = true; } } if ( $autoselected ) { $available_feeds[ $link_url ]['autoselect'] = true; } } // Prefer the ActivityPub actor feed over RSS when both are available. $activitypub_feed = null; foreach ( $available_feeds as $link_url => $feed ) { if ( 'activitypub' === $feed['parser'] ) { $activitypub_feed = $link_url; break; } } if ( $activitypub_feed ) { foreach ( $available_feeds as $link_url => $feed ) { $available_feeds[ $link_url ]['autoselect'] = $link_url === $activitypub_feed; } } $feed_sort_order = array( 'self', 'alternate', 'me' ); if ( $has_friends_plugin ) { // If we have the Friends plugin, we prefer an (augmented) RSS feed over, for example, microformats. $feed_sort_order = array( 'alternate', 'self', 'me' ); } uasort( $available_feeds, function ( $a, $b ) use ( $feed_sort_order ) { if ( isset( $a['autoselect'] ) && $a['autoselect'] ) { if ( ! isset( $b['autoselect'] ) || ! $b['autoselect'] ) { return -1; } } elseif ( isset( $b['autoselect'] ) && $b['autoselect'] ) { return 1; } foreach ( $feed_sort_order as $rel_sort ) { if ( $rel_sort === $a['rel'] ) { if ( $rel_sort !== $b['rel'] ) { return -1; } break; } elseif ( $rel_sort === $b['rel'] ) { return 1; } } return strcmp( $a['title'], $b['title'] ); } ); return apply_filters( 'friends_available_feeds', $available_feeds, $url ); } /** * Discover feeds specified in the section. * * @param string $content The content to search. * @param string $url The url. * @param object $headers The headers from the request. * * @return array ( description_of_the_return_value ) */ private function discover_link_rel_feeds( $content, $url, $headers ) { $discovered_feeds = array(); $has_self = false; $links = array(); $mf = Mf2\parse( $content, $url ); if ( isset( $mf['rel-urls'] ) ) { $links = array_merge( $links, $mf['rel-urls'] ); } foreach ( $headers as $header => $value ) { if ( 'link' === strtolower( $header ) ) { $values = wp_parse_args( $value ); if ( isset( $values['href'] ) ) { if ( ! isset( $values['rels'] ) && $values['rel'] ) { $values['rels'] = array( $values['rel'] ); unset( $values['rel'] ); } if ( isset( $values['rels'] ) ) { if ( isset( $links[ $values['href'] ] ) ) { foreach ( $values['rels'] as $rel ) { $links[ $values['href'] ]['rels'][] = $rel; } } else { $links[ $values['href'] ] = $values; } } } } } foreach ( $links as $feed_url => $link ) { foreach ( array( 'friends-base-url', 'me', 'alternate', 'self' ) as $rel ) { if ( in_array( $rel, $link['rels'] ) ) { $discovered_feeds[ $feed_url ] = array( 'rel' => $rel, ); } } if ( ! isset( $discovered_feeds[ $feed_url ] ) ) { continue; } if ( 'self' === $discovered_feeds[ $feed_url ]['rel'] ) { $has_self = true; } if ( isset( $link['type'] ) ) { $discovered_feeds[ $feed_url ]['type'] = $link['type']; } if ( isset( $link['title'] ) ) { $discovered_feeds[ $feed_url ]['title'] = $link['title']; } elseif ( isset( $link['text'] ) ) { $discovered_feeds[ $feed_url ]['title'] = $link['text']; } } if ( ! $has_self ) { $discovered_feeds[ $url ] = array( 'rel' => 'self', ); } if ( empty( $discovered_feeds[ $url ]['title'] ) && ! empty( $mf['metas']['application-name'][0] ) ) { $discovered_feeds[ $url ]['title'] = $mf['metas']['application-name'][0]; } if ( empty( $discovered_feeds[ $url ]['title'] ) && ! empty( $mf['metas']['og:title'][0] ) ) { $discovered_feeds[ $url ]['title'] = $mf['metas']['og:title'][0]; } if ( empty( $discovered_feeds[ $url ]['title'] ) && ! empty( $mf['title'] ) ) { $discovered_feeds[ $url ]['title'] = $mf['title']; } if ( empty( $discovered_feeds[ $url ]['avatar'] ) && ! empty( $mf['rels']['icon'] ) ) { foreach ( $mf['rels']['icon'] as $icon_url ) { if ( ! filter_var( $icon_url, FILTER_VALIDATE_URL ) ) { continue; } if ( ! isset( $mf['rel-urls'][ $icon_url ]['type'] ) || 0 !== strpos( $mf['rel-urls'][ $icon_url ]['type'], 'image/' ) ) { continue; } $discovered_feeds[ $url ]['avatar'] = $icon_url; } } return $discovered_feeds; } /** * More generic version of the native url_to_postid() * * @param string $url Permalink to check. * @param int $author_id The id of the author. * @return int Post ID, or 0 on failure. */ public static function url_to_postid( $url, $author_id = false ) { $post_types = apply_filters( 'friends_frontend_post_types', array() ); // The post types are part of the cache key since they can be filtered per lookup. $cache_key = 'friends_url_to_postid_' . md5( $url . '|' . implode( ',', $post_types ) ) . ( $author_id ? '_' . $author_id : '' ); $post_id = wp_cache_get( $cache_key, 'friends' ); if ( false !== $post_id ) { return $post_id; } $args = $post_types; global $wpdb; $sql = sprintf( 'SELECT ID from ' . $wpdb->posts . ' WHERE post_type IN ( %s )', implode( ',', array_fill( 0, count( $post_types ), '%s' ) ) ); if ( $author_id ) { $args[] = $author_id; $sql .= ' AND post_author = %d'; } $sql .= ' AND guid IN (%s, %s) LIMIT 1'; $args[] = $url; $args[] = esc_attr( $url ); $post_id = $wpdb->get_var( // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery $wpdb->prepare( $sql, // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared $args ) ); if ( $post_id ) { wp_cache_set( $cache_key, $post_id, 'friends' ); } return $post_id; } public function oembed_request_post_id( $post_id, $url ) { if ( ! $post_id ) { $post_id = self::url_to_postid( $url ); global $wp_post_types; $wp_post_types[ Friends::CPT ]->publicly_queryable = true; } return $post_id; } public function post_embed_url( $embed_url, $post ) { if ( ! in_array( $post->post_type, apply_filters( 'friends_frontend_post_types', array() ) ) ) { return $embed_url; } return add_query_arg( 'url', $post->guid, rest_url( Rest::PREFIX . '/embed' ) ); } public function oembed_response_data( $data, $post, $width, $height ) { $data['width'] = absint( $width ); $data['height'] = absint( $height ); $data['type'] = 'rich'; ob_start(); Friends::template_loader()->get_template_part( 'oembed/status', null, array( 'post' => $post ) ); $data['html'] = ob_get_contents(); ob_end_clean(); $data['html'] = '

' . wp_kses_post( $post->post_content ) . '

'; return $data; } public function get_user_feed_by_url( $url ) { return User_Feed::get_by_url( $url ); } /** * Gets the actual feed parser parser. * * @param string $parser The parser slug. * * @return Feed_Parser The actual parser. */ public function get_feed_parser( $parser ) { if ( ! isset( $this->parsers[ $parser ] ) ) { return null; } return $this->parsers[ $parser ]; } /** * Gets the registered parser. * * @param string $parser The parser slug. * * @return string The parser name. */ public function get_registered_parser( $parser ) { if ( ! isset( $this->parsers[ $parser ] ) ) { return null; } $parsers = $this->get_registered_parsers(); return $parsers[ $parser ]; } /** * The list of currently supported parsers. * * @return array A list of parsers. Key is the slug, value is the parser name. */ public function get_registered_parsers() { $parsers = array(); foreach ( $this->parsers as $slug => $parser ) { $name = $slug; if ( defined( get_class( $parser ) . '::NAME' ) ) { $name = esc_html( $parser::NAME ); } if ( defined( get_class( $parser ) . '::URL' ) ) { $name = '' . $name . ''; } $parsers[ $slug ] = $name; } return $parsers; } /** * Get a parser instance by slug. * * @param string $slug The parser slug. * @return Feed_Parser|null The parser instance or null. */ public function get_parser_by_slug( $slug ) { return isset( $this->parsers[ $slug ] ) ? $this->parsers[ $slug ] : null; } /** * Get the badge for a feed based on its parser. * * @param User_Feed $user_feed The user feed. * @return array|null Badge info array or null. */ public function get_feed_badge( $user_feed ) { $parser_slug = $user_feed->get_parser(); $parser = $this->get_parser_by_slug( $parser_slug ); $badge = null; if ( $parser && method_exists( $parser, 'get_badge' ) ) { $badge = $parser->get_badge(); } /** * Filter the badge displayed for a feed. * * @param array|null $badge The badge array with 'label', 'color', 'title' keys, or null. * @param User_Feed $user_feed The user feed. * @param string $parser The parser slug. */ return apply_filters( 'friends_feed_badge', $badge, $user_feed, $parser_slug ); } } ```