PluginProbe
ElasticPress / 5.3.5
ElasticPress v5.3.5
5.3.5 5.3.4 3.6.5 3.6.6 4.0.0 4.0.1 4.1.0 4.2.0 4.2.1 4.2.2 4.3.0 4.3.1 4.4.0 4.4.1 4.5.0 4.5.1 4.5.2 4.6.0 4.6.1 4.7.0 4.7.1 4.7.2 5.0.0 5.0.1 5.0.2 All 108 releases
← All changes | includes/classes/Indexable/Post/SyncManager.php +227 -38 4.6.15.3.5 View file →
@@ -7,13 +7,12 @@
7 7 */
8 8
9 9 namespace ElasticPress\Indexable\Post;
10 10
11 -use ElasticPress\Elasticsearch as Elasticsearch;
12 -use ElasticPress\Indexables as Indexables;
13 -use ElasticPress\SyncManager as SyncManagerAbstract;
11 +use ElasticPress\Elasticsearch;
12 +use ElasticPress\Indexables;
13 +use ElasticPress\IndexHelper;
14 14 use ElasticPress\Utils;
15 -use ElasticPress\IndexHelper;
16 15
17 16 if ( ! defined( 'ABSPATH' ) ) {
18 17 // @codeCoverageIgnoreStart
19 18 exit; // Exit if accessed directly.
@@ -22,9 +21,9 @@
22 21
23 22 /**
24 23 * Sync manager class
25 24 */
26 -class SyncManager extends SyncManagerAbstract {
25 +class SyncManager extends \ElasticPress\SyncManager {
27 26
28 27 /**
29 28 * Indexable slug
30 29 *
@@ -53,11 +52,12 @@
53 52 if ( ! $this->can_index_site() ) {
54 53 return;
55 54 }
56 55
57 - add_action( 'wp_insert_post', array( $this, 'action_sync_on_update' ), 999, 3 );
58 - add_action( 'add_attachment', array( $this, 'action_sync_on_update' ), 999, 3 );
59 - add_action( 'edit_attachment', array( $this, 'action_sync_on_update' ), 999, 3 );
56 + add_action( 'wp_insert_post', array( $this, 'action_sync_on_update' ), 999 );
57 + add_action( 'add_attachment', array( $this, 'action_sync_on_update' ), 999 );
58 + add_action( 'edit_attachment', array( $this, 'action_sync_on_update' ), 999 );
59 + add_action( 'wp_media_attach_action', array( $this, 'action_sync_on_media_attach' ), 999, 2 );
60 60 add_action( 'delete_post', array( $this, 'action_delete_post' ) );
61 61 add_action( 'updated_post_meta', array( $this, 'action_queue_meta_sync' ), 10, 4 );
62 62 add_action( 'added_post_meta', array( $this, 'action_queue_meta_sync' ), 10, 4 );
63 63 // Called just because we need to know somehow if $delete_all is set before action_queue_meta_sync() runs.
@@ -74,12 +74,12 @@
74 74 add_action( 'set_object_terms', array( $this, 'action_set_object_terms' ), 10, 6 );
75 75 add_action( 'edited_term', array( $this, 'action_edited_term' ), 10, 3 );
76 76 add_action( 'deleted_term_relationships', array( $this, 'action_deleted_term_relationships' ), 10, 3 );
77 77
78 - // Clear field limit cache
79 - add_action( 'ep_update_index_settings', [ $this, 'clear_total_fields_limit_cache' ] );
80 - add_action( 'ep_sync_put_mapping', [ $this, 'clear_total_fields_limit_cache' ] );
81 - add_action( 'ep_saved_weighting_configuration', [ $this, 'clear_total_fields_limit_cache' ] );
78 + // Clear index settings cache
79 + add_action( 'ep_update_index_settings', [ $this, 'clear_index_settings_cache' ] );
80 + add_action( 'ep_after_put_mapping', [ $this, 'clear_index_settings_cache' ] );
81 + add_action( 'ep_saved_weighting_configuration', [ $this, 'clear_index_settings_cache' ] );
82 82
83 83 // Clear distinct meta field per post type cache
84 84 add_action( 'wp_insert_post', [ $this, 'clear_meta_keys_db_per_post_type_cache_by_post_id' ] );
85 85 add_action( 'delete_post', [ $this, 'clear_meta_keys_db_per_post_type_cache_by_post_id' ] );
@@ -89,8 +89,14 @@
89 89 add_action( 'delete_post_metadata', [ $this, 'clear_meta_keys_db_per_post_type_cache_by_meta' ], 10, 2 );
90 90
91 91 // Prevents password protected posts from being indexed
92 92 add_filter( 'ep_post_sync_kill', [ $this, 'kill_sync_for_password_protected' ], 10, 2 );
93 +
94 + // Display the status of the document in ES in the admin bar
95 + add_filter( 'ep_admin_bar_status_and_summary', [ $this, 'maybe_add_doc_status_to_admin_bar_status' ] );
96 +
97 + // Delete a post from the index if a password was added
98 + add_action( 'post_updated', [ $this, 'delete_post_with_new_password' ], 10, 3 );
93 99 }
94 100
95 101 /**
96 102 * Un-setup actions and filters (for multisite).
@@ -100,8 +106,9 @@
100 106 public function tear_down() {
101 107 remove_action( 'wp_insert_post', array( $this, 'action_sync_on_update' ), 999 );
102 108 remove_action( 'add_attachment', array( $this, 'action_sync_on_update' ), 999 );
103 109 remove_action( 'edit_attachment', array( $this, 'action_sync_on_update' ), 999 );
110 + remove_action( 'wp_media_attach_action', array( $this, 'action_sync_on_media_attach' ), 999 );
104 111 remove_action( 'delete_post', array( $this, 'action_delete_post' ) );
105 112 remove_action( 'updated_post_meta', array( $this, 'action_queue_meta_sync' ) );
106 113 remove_action( 'added_post_meta', array( $this, 'action_queue_meta_sync' ) );
107 114 remove_filter( 'delete_post_metadata', array( $this, 'maybe_delete_meta_for_all' ) );
@@ -109,8 +116,15 @@
109 116 remove_action( 'wp_initialize_site', array( $this, 'action_create_blog_index' ) );
110 117 remove_filter( 'ep_sync_insert_permissions_bypass', array( $this, 'filter_bypass_permission_checks_for_machines' ) );
111 118 remove_filter( 'ep_sync_delete_permissions_bypass', array( $this, 'filter_bypass_permission_checks_for_machines' ) );
112 119 remove_filter( 'ep_post_sync_kill', [ $this, 'kill_sync_for_password_protected' ] );
120 +
121 + // Clear index settings cache
122 + remove_action( 'ep_update_index_settings', [ $this, 'clear_index_settings_cache' ] );
123 + remove_action( 'ep_after_put_mapping', [ $this, 'clear_index_settings_cache' ] );
124 + remove_action( 'ep_saved_weighting_configuration', [ $this, 'clear_index_settings_cache' ] );
125 +
126 + remove_filter( 'ep_admin_bar_status_and_summary', [ $this, 'maybe_add_doc_status_to_admin_bar_status' ] );
113 127 }
114 128
115 129 /**
116 130 * Whether to delete all meta from other posts that is associated with the deleted post.
@@ -131,9 +145,9 @@
131 145 /**
132 146 * Filter to allow cron and WP CLI processes to index/delete documents
133 147 *
134 148 * @param boolean $bypass The current filtered value
135 - * @return boolean Boolean indicating if permission checking should be bypased or not
149 + * @return boolean Boolean indicating if permission checking should be bypassed or not
136 150 * @since 3.6.0
137 151 */
138 152 public function filter_bypass_permission_checks_for_machines( $bypass ) {
139 153 // Allow index/delete during cron
@@ -217,9 +231,9 @@
217 231
218 232 if ( $query->have_posts() && $query->elasticsearch_success ) {
219 233 $posts_to_be_synced = array_filter(
220 234 $query->posts,
221 - function( $object_id ) {
235 + function ( $object_id ) {
222 236 return ! apply_filters( 'ep_post_sync_kill', false, $object_id, $object_id );
223 237 }
224 238 );
225 239 if ( ! empty( $posts_to_be_synced ) ) {
@@ -296,11 +310,9 @@
296 310 /**
297 311 * Make sure to remove this post from the sync queue in case an shutdown happens
298 312 * before a redirect when a redirect has already been triggered.
299 313 */
300 - if ( isset( $this->sync_queue[ $post_id ] ) ) {
301 - unset( $this->sync_queue[ $post_id ] );
302 - }
314 + $this->remove_from_queue( $post_id );
303 315 }
304 316
305 317 /**
306 318 * Sync ES index with what happened to the post being saved
@@ -374,8 +386,9 @@
374 386 * @param {int} $object_id ID of post
375 387 * @return {boolean} New value
376 388 */
377 389 if ( apply_filters( 'ep_post_sync_kill', false, $post_id, $post_id ) ) {
390 + $this->remove_from_queue( $post_id );
378 391 return;
379 392 }
380 393
381 394 $this->add_to_queue( $post_id );
@@ -416,8 +429,9 @@
416 429 Utils\get_sync_url()
417 430 ),
418 431 'type' => 'warning',
419 432 'dismiss' => true,
433 + 'scope' => 'site',
420 434 ];
421 435 break;
422 436 }
423 437 }
@@ -431,8 +445,9 @@
431 445 Utils\get_sync_url()
432 446 ),
433 447 'type' => 'warning',
434 448 'dismiss' => true,
449 + 'scope' => 'site',
435 450 ];
436 451
437 452 return $notices;
438 453 }
@@ -465,8 +480,9 @@
465 480 Utils\get_sync_url()
466 481 ),
467 482 'type' => 'warning',
468 483 'dismiss' => true,
484 + 'scope' => 'site',
469 485 ];
470 486
471 487 return $notices;
472 488 }
@@ -737,21 +753,14 @@
737 753 restore_current_blog();
738 754 }
739 755
740 756 /**
741 - * Clear the cache of the total fields limit
757 + * DEPRECATED. Clear the cache of the total fields limit
742 758 *
743 759 * @since 4.4.0
744 760 */
745 761 public function clear_total_fields_limit_cache() {
746 - $indexable = Indexables::factory()->get( $this->indexable_slug );
747 - $cache_key = 'ep_total_fields_limit_' . $indexable->get_index_name();
748 -
749 - if ( defined( 'EP_IS_NETWORK' ) && EP_IS_NETWORK ) {
750 - delete_site_transient( $cache_key );
751 - } else {
752 - delete_transient( $cache_key );
753 - }
762 + _deprecated_function( __METHOD__, '4.7.0', '\ElasticPress\Indexable\Post\SyncManager::clear_index_settings_cache()' );
754 763 }
755 764
756 765 /**
757 766 * Clear the cache of the total fields limit
@@ -791,15 +800,15 @@
791 800 delete_transient( 'ep_meta_field_keys_' . $post_type );
792 801 }
793 802
794 803 /**
795 - * Check if post attributes (post status, taxonomy, and type) match what is needed to reindex or not.
804 + * Given a post ID, check if it should be indexed or not.
796 805 *
797 - * @param int $post_id The post ID.
798 - * @param string $taxonomy The taxonomy slug.
806 + * @since 5.2.0
807 + * @param int $post_id Post ID.
799 808 * @return boolean
800 809 */
801 - protected function should_reindex_post( $post_id, $taxonomy ) {
810 + public function is_post_indexable( $post_id ) {
802 811 /**
803 812 * Filter to kill post sync
804 813 *
805 814 * @hook ep_post_sync_kill
@@ -824,8 +833,32 @@
824 833 if ( ! in_array( $post->post_status, $indexable_post_statuses, true ) ) {
825 834 return false;
826 835 }
827 836
837 + // Check post type
838 + $indexable_post_types = $indexable->get_indexable_post_types();
839 + if ( ! in_array( $post->post_type, $indexable_post_types, true ) ) {
840 + return false;
841 + }
842 +
843 + return true;
844 + }
845 +
846 + /**
847 + * Check if post attributes (post status, taxonomy, and type) match what is needed to reindex or not.
848 + *
849 + * @param int $post_id The post ID.
850 + * @param string $taxonomy The taxonomy slug.
851 + * @return boolean
852 + */
853 + protected function should_reindex_post( $post_id, $taxonomy ) {
854 + if ( ! $this->is_post_indexable( $post_id ) ) {
855 + return false;
856 + }
857 +
858 + $indexable = Indexables::factory()->get( $this->indexable_slug );
859 + $post = get_post( $post_id );
860 +
828 861 // Only re-index if the taxonomy is indexed for this post
829 862 $indexable_taxonomies = $indexable->get_indexable_post_taxonomies( $post );
830 863 $indexable_taxonomy_names = wp_list_pluck( $indexable_taxonomies, 'name' );
831 864 if ( ! in_array( $taxonomy, $indexable_taxonomy_names, true ) ) {
@@ -831,16 +864,10 @@
831 864 if ( ! in_array( $taxonomy, $indexable_taxonomy_names, true ) ) {
832 865 return false;
833 866 }
834 867
835 - // Check post type
836 - $indexable_post_types = $indexable->get_indexable_post_types();
837 - if ( ! in_array( $post->post_type, $indexable_post_types, true ) ) {
838 - return false;
839 - }
840 -
841 868 // If we have more items to update than the number set as Content Items per Index Cycle, skip it to avoid a timeout.
842 - $single_ids_queued = array_unique( array_keys( $this->sync_queue ) );
869 + $single_ids_queued = array_unique( array_keys( $this->get_sync_queue() ) );
843 870 $has_too_many_queued = count( $single_ids_queued ) > IndexHelper::factory()->get_index_default_per_page();
844 871
845 872 return ! $has_too_many_queued;
846 873 }
@@ -854,9 +881,9 @@
854 881 * @since 4.4.0
855 882 * @param \WP_Taxonomy $tax The taxonomy object
856 883 * @return boolean
857 884 */
858 - protected function is_tax_max_count_bigger_than_items_per_cycle( \WP_Taxonomy $tax ) : bool {
885 + protected function is_tax_max_count_bigger_than_items_per_cycle( \WP_Taxonomy $tax ): bool {
859 886 $transient_name = "ep_term_max_count_{$tax->name}";
860 887 $cached_max_count = get_transient( $transient_name );
861 888
862 889 if ( is_integer( $cached_max_count ) ) {
@@ -921,6 +948,168 @@
921 948
922 949 $post = get_post( $object_id );
923 950
924 951 return ! empty( $post->post_password );
952 + }
953 +
954 + /**
955 + * Sync ES index when attached or detached action is called.
956 + *
957 + * @since 4.7.0
958 + * @param string $action Attach/detach action
959 + * @param int $attachment_id The attachment ID
960 + */
961 + public function action_sync_on_media_attach( $action, $attachment_id ) {
962 + $indexable = Indexables::factory()->get( $this->indexable_slug );
963 + $indexable_post_types = $indexable->get_indexable_post_types();
964 +
965 + if ( ! in_array( 'attachment', $indexable_post_types, true ) ) {
966 + return;
967 + }
968 + $this->action_sync_on_update( $attachment_id );
969 + }
970 +
971 + /**
972 + * Add the document status to the admin bar.
973 + *
974 + * @since 5.2.0
975 + * @deprecated 5.3.0
976 + * @param \WP_Admin_Bar $admin_bar WP Admin Bar instance
977 + * @return void
978 + */
979 + public function add_admin_bar_status( \WP_Admin_Bar $admin_bar ) {
980 + _deprecated_function( __METHOD__, 'ElasticPress 5.3.0' );
981 + }
982 +
983 + /**
984 + * Add the document status to the admin bar status and summary.
985 + *
986 + * @since 5.3.0
987 + * @param array $status_and_summary The status and summary.
988 + * @return array The status and summary.
989 + */
990 + public function maybe_add_doc_status_to_admin_bar_status( $status_and_summary ): array {
991 + global $pagenow;
992 +
993 + if ( ! is_admin() || 'post.php' !== $pagenow ) {
994 + return $status_and_summary;
995 + }
996 +
997 + $post_id = get_the_ID();
998 + if ( ! $this->is_post_indexable( $post_id ) ) {
999 + return $status_and_summary;
1000 + }
1001 +
1002 + $document_status = $this->get_doc_status( $post_id );
1003 + if ( empty( $document_status['status'] ) ) {
1004 + return $status_and_summary;
1005 + }
1006 +
1007 + if ( 'success' === $status_and_summary['status'] || in_array( $document_status['status'], [ 'error', 'warning' ], true ) ) {
1008 + $status_and_summary['status'] = $document_status['status'];
1009 + }
1010 +
1011 + $status_and_summary['summary'] = array_merge(
1012 + [ 'doc_status' => "{$document_status['message']}: {$document_status['explanation']}" ],
1013 + $status_and_summary['summary'],
1014 + );
1015 +
1016 + return $status_and_summary;
1017 + }
1018 +
1019 + /**
1020 + * Get the document status for a post.
1021 + *
1022 + * @since 5.2.0
1023 + * @param int $post_id Post ID
1024 + * @return array
1025 + */
1026 + protected function get_doc_status( int $post_id ): array {
1027 + $status = [
1028 + 'status' => 'success',
1029 + 'message' => esc_html__( 'Content in sync', 'elasticpress' ),
1030 + 'explanation' => esc_html__( 'WordPress and Elasticsearch content match.', 'elasticpress' ),
1031 + ];
1032 +
1033 + $indexable = Indexables::factory()->get( $this->indexable_slug );
1034 + $es_doc = $indexable->get( $post_id );
1035 + if ( ! $es_doc ) {
1036 + $status = [
1037 + 'status' => 'error',
1038 + 'message' => esc_html__( 'Sync required', 'elasticpress' ),
1039 + 'explanation' => esc_html__( 'Content not found in Elasticsearch.', 'elasticpress' ),
1040 + ];
1041 + } else {
1042 + $post = get_post( $post_id );
1043 + if ( $post->post_modified_gmt !== $es_doc['post_modified_gmt'] ) {
1044 + $status = [
1045 + 'status' => 'warning',
1046 + 'message' => esc_html__( 'Out of sync', 'elasticpress' ),
1047 + 'explanation' => esc_html__( 'WordPress and Elasticsearch content are out of sync.', 'elasticpress' ),
1048 + ];
1049 + }
1050 + }
1051 +
1052 + /**
1053 + * Filter the document status array.
1054 + *
1055 + * @since 5.2.0
1056 + * @hook ep_doc_status
1057 + * @param array $status The status array containing status, message and explanation
1058 + * @param int $post_id The post ID being checked
1059 + * @param array $es_doc The Elasticsearch document
1060 + */
1061 + return (array) apply_filters( 'ep_doc_status', $status, $post_id, $es_doc );
1062 + }
1063 +
1064 + /**
1065 + * Format the document status for the admin bar.
1066 + *
1067 + * @since 5.2.0
1068 + * @deprecated 5.3.0
1069 + * @param array $document_status Document status
1070 + * @return string
1071 + */
1072 + protected function format_doc_status( array $document_status ): string {
1073 + $status_indicator = '<span class="ep-status-indicator ep-status-indicator--' . ( $document_status['status'] ?? '' ) . '"></span>';
1074 +
1075 + $message = sprintf(
1076 + // translators: 1: EP prefix 2: Document status message
1077 + _x( '[%1$s] %2$s', 'Doc status message', 'elasticpress' ),
1078 + 'EP',
1079 + $document_status['message']
1080 + );
1081 +
1082 + /**
1083 + * Filter the formatted document status.
1084 + *
1085 + * @since 5.2.0
1086 + * @deprecated 5.3.0
1087 + * @hook ep_formatted_doc_status
1088 + * @param string $formatted_status The formatted status
1089 + * @param array $document_status The document status
1090 + * @param string $status_indicator The status indicator
1091 + * @param string $message The message
1092 + */
1093 + return (string) apply_filters_deprecated(
1094 + 'ep_formatted_doc_status',
1095 + [ $status_indicator . $message, $document_status, $status_indicator, $message ],
1096 + 'ElasticPress 5.3.0',
1097 + 'ep_admin_bar_status_and_summary'
1098 + );
1099 + }
1100 +
1101 + /**
1102 + * If a password is added to an existent post, delete it from the index.
1103 + *
1104 + * @since 5.2.0
1105 + * @param int $post_id The post ID
1106 + * @param \WP_Post $post_after The post object after the update
1107 + * @param \WP_Post $post_before The post object before the update
1108 + * @return void
1109 + */
1110 + public function delete_post_with_new_password( $post_id, $post_after, $post_before ) {
1111 + if ( ! $post_before->post_password && $post_after->post_password ) {
1112 + Indexables::factory()->get( $this->indexable_slug )->delete( $post_id, false );
1113 + }
925 1114 }
926 1115 }