@@ -18,406 +18,406 @@ discard block |
||
18 | 18 | */ |
19 | 19 | class Wordlift_Relation_Service { |
20 | 20 | |
21 | - /** |
|
22 | - * The relation table name in MySQL, set during instantiation. |
|
23 | - * |
|
24 | - * @since 3.15.0 |
|
25 | - * @access private |
|
26 | - * @var string $relation_table The relation table name. |
|
27 | - */ |
|
28 | - private $relation_table; |
|
29 | - |
|
30 | - /** |
|
31 | - * A {@link Wordlift_Log_Service} instance. |
|
32 | - * |
|
33 | - * @since 3.15.3 |
|
34 | - * |
|
35 | - * @var Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance. |
|
36 | - */ |
|
37 | - private static $log; |
|
38 | - |
|
39 | - /** |
|
40 | - * Create a {@link Wordlift_Relation_Service} instance. |
|
41 | - * |
|
42 | - * @since 3.15.0 |
|
43 | - */ |
|
44 | - protected function __construct() { |
|
45 | - global $wpdb; |
|
46 | - |
|
47 | - self::$log = Wordlift_Log_Service::get_logger( get_class() ); |
|
48 | - |
|
49 | - // The relations table. |
|
50 | - $this->relation_table = "{$wpdb->prefix}wl_relation_instances"; |
|
51 | - |
|
52 | - } |
|
53 | - |
|
54 | - /** |
|
55 | - * The singleton instance. |
|
56 | - * |
|
57 | - * @since 3.15.0 |
|
58 | - * @access private |
|
59 | - * @var Wordlift_Relation_Service $instance The singleton instance. |
|
60 | - */ |
|
61 | - private static $instance = null; |
|
62 | - |
|
63 | - /** |
|
64 | - * Get the singleton instance. |
|
65 | - * |
|
66 | - * @return Wordlift_Relation_Service The {@link Wordlift_Relation_Service} singleton instance. |
|
67 | - * @since 3.15.0 |
|
68 | - * @access public |
|
69 | - */ |
|
70 | - public static function get_instance() { |
|
71 | - |
|
72 | - if ( ! isset( self::$instance ) ) { |
|
73 | - self::$instance = new self(); |
|
74 | - } |
|
75 | - |
|
76 | - return self::$instance; |
|
77 | - } |
|
78 | - |
|
79 | - /** |
|
80 | - * Get the articles referencing the specified entity {@link WP_Post}. |
|
81 | - * |
|
82 | - * @param int|array $object_id The entity {@link WP_Post}'s id. |
|
83 | - * @param string $fields The fields to return, 'ids' to only return ids or |
|
84 | - * '*' to return all fields, by default '*'. |
|
85 | - * @param null|string $predicate The predicate (who|what|...), by default all. |
|
86 | - * @param null|string $status The status, by default all. |
|
87 | - * @param array $excludes An array of ids to exclude from the results. |
|
88 | - * @param null|int $limit The maximum number of results, by default |
|
89 | - * no limit. |
|
90 | - * @param null|array $include The {@link WP_Post}s' ids to include. |
|
91 | - * |
|
92 | - * @param null | string $order_by |
|
93 | - * |
|
94 | - * @param array $post_types |
|
95 | - * |
|
96 | - * @return array|object|null Database query results |
|
97 | - * @since 3.15.0 |
|
98 | - */ |
|
99 | - public function get_article_subjects( $object_id, $fields = '*', $predicate = null, $status = null, $excludes = array(), $limit = null, $include = null, $order_by = null, $post_types = array(), $offset = null ) { |
|
100 | - global $wpdb; |
|
101 | - |
|
102 | - // The output fields. |
|
103 | - $actual_fields = self::fields( $fields ); |
|
104 | - |
|
105 | - self::$log->trace( 'Getting article subjects for object ' . implode( ', ', (array) $object_id ) . '...' ); |
|
106 | - |
|
107 | - $objects = $this->article_id_to_entity_id( $object_id ); |
|
108 | - |
|
109 | - // If there are no related objects, return an empty array. |
|
110 | - if ( empty( $objects ) ) { |
|
111 | - self::$log->debug( 'No entities found for object ' . implode( ', ', (array) $object_id ) . '.' ); |
|
112 | - |
|
113 | - return array(); |
|
114 | - } |
|
115 | - |
|
116 | - self::$log->debug( count( $objects ) . ' entity id(s) found for object ' . implode( ', ', (array) $object_id ) . '.' ); |
|
117 | - |
|
118 | - $sql = |
|
119 | - " |
|
21 | + /** |
|
22 | + * The relation table name in MySQL, set during instantiation. |
|
23 | + * |
|
24 | + * @since 3.15.0 |
|
25 | + * @access private |
|
26 | + * @var string $relation_table The relation table name. |
|
27 | + */ |
|
28 | + private $relation_table; |
|
29 | + |
|
30 | + /** |
|
31 | + * A {@link Wordlift_Log_Service} instance. |
|
32 | + * |
|
33 | + * @since 3.15.3 |
|
34 | + * |
|
35 | + * @var Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance. |
|
36 | + */ |
|
37 | + private static $log; |
|
38 | + |
|
39 | + /** |
|
40 | + * Create a {@link Wordlift_Relation_Service} instance. |
|
41 | + * |
|
42 | + * @since 3.15.0 |
|
43 | + */ |
|
44 | + protected function __construct() { |
|
45 | + global $wpdb; |
|
46 | + |
|
47 | + self::$log = Wordlift_Log_Service::get_logger( get_class() ); |
|
48 | + |
|
49 | + // The relations table. |
|
50 | + $this->relation_table = "{$wpdb->prefix}wl_relation_instances"; |
|
51 | + |
|
52 | + } |
|
53 | + |
|
54 | + /** |
|
55 | + * The singleton instance. |
|
56 | + * |
|
57 | + * @since 3.15.0 |
|
58 | + * @access private |
|
59 | + * @var Wordlift_Relation_Service $instance The singleton instance. |
|
60 | + */ |
|
61 | + private static $instance = null; |
|
62 | + |
|
63 | + /** |
|
64 | + * Get the singleton instance. |
|
65 | + * |
|
66 | + * @return Wordlift_Relation_Service The {@link Wordlift_Relation_Service} singleton instance. |
|
67 | + * @since 3.15.0 |
|
68 | + * @access public |
|
69 | + */ |
|
70 | + public static function get_instance() { |
|
71 | + |
|
72 | + if ( ! isset( self::$instance ) ) { |
|
73 | + self::$instance = new self(); |
|
74 | + } |
|
75 | + |
|
76 | + return self::$instance; |
|
77 | + } |
|
78 | + |
|
79 | + /** |
|
80 | + * Get the articles referencing the specified entity {@link WP_Post}. |
|
81 | + * |
|
82 | + * @param int|array $object_id The entity {@link WP_Post}'s id. |
|
83 | + * @param string $fields The fields to return, 'ids' to only return ids or |
|
84 | + * '*' to return all fields, by default '*'. |
|
85 | + * @param null|string $predicate The predicate (who|what|...), by default all. |
|
86 | + * @param null|string $status The status, by default all. |
|
87 | + * @param array $excludes An array of ids to exclude from the results. |
|
88 | + * @param null|int $limit The maximum number of results, by default |
|
89 | + * no limit. |
|
90 | + * @param null|array $include The {@link WP_Post}s' ids to include. |
|
91 | + * |
|
92 | + * @param null | string $order_by |
|
93 | + * |
|
94 | + * @param array $post_types |
|
95 | + * |
|
96 | + * @return array|object|null Database query results |
|
97 | + * @since 3.15.0 |
|
98 | + */ |
|
99 | + public function get_article_subjects( $object_id, $fields = '*', $predicate = null, $status = null, $excludes = array(), $limit = null, $include = null, $order_by = null, $post_types = array(), $offset = null ) { |
|
100 | + global $wpdb; |
|
101 | + |
|
102 | + // The output fields. |
|
103 | + $actual_fields = self::fields( $fields ); |
|
104 | + |
|
105 | + self::$log->trace( 'Getting article subjects for object ' . implode( ', ', (array) $object_id ) . '...' ); |
|
106 | + |
|
107 | + $objects = $this->article_id_to_entity_id( $object_id ); |
|
108 | + |
|
109 | + // If there are no related objects, return an empty array. |
|
110 | + if ( empty( $objects ) ) { |
|
111 | + self::$log->debug( 'No entities found for object ' . implode( ', ', (array) $object_id ) . '.' ); |
|
112 | + |
|
113 | + return array(); |
|
114 | + } |
|
115 | + |
|
116 | + self::$log->debug( count( $objects ) . ' entity id(s) found for object ' . implode( ', ', (array) $object_id ) . '.' ); |
|
117 | + |
|
118 | + $sql = |
|
119 | + " |
|
120 | 120 | SELECT DISTINCT p.$actual_fields |
121 | 121 | FROM {$this->relation_table} r |
122 | 122 | INNER JOIN $wpdb->posts p |
123 | 123 | ON p.id = r.subject_id |
124 | 124 | " |
125 | - // Add the status clause. |
|
126 | - . self::and_status( $status ) |
|
127 | - . self::inner_join_is_article() |
|
128 | - . self::where_object_id( $objects ) |
|
129 | - // Since `object_id` can be an article ID we need to exclude it from |
|
130 | - // the results. |
|
131 | - . self::and_article_not_in( array_merge( $excludes, (array) $object_id ) ) |
|
132 | - . self::and_article_in( $include ) |
|
133 | - . self::and_post_type_in( $post_types ) |
|
134 | - . self::and_predicate( $predicate ) |
|
135 | - . self::order_by( $order_by ) |
|
136 | - . self::limit( $limit ) |
|
137 | - . self::offset( $offset ); |
|
138 | - |
|
139 | - return '*' === $actual_fields ? $wpdb->get_results( $sql ) : $wpdb->get_col( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
140 | - } |
|
141 | - |
|
142 | - /** |
|
143 | - * The `post_type IN` clause. |
|
144 | - * |
|
145 | - * @param array $post_types If the post type is not provided then the valid |
|
146 | - * entity post types are used. |
|
147 | - * |
|
148 | - * @return string The `post_type IN` clause. |
|
149 | - * @since 3.15.3 |
|
150 | - */ |
|
151 | - private static function and_post_type_in( $post_types = array() ) { |
|
152 | - |
|
153 | - if ( array() === $post_types ) { |
|
154 | - $post_types = Wordlift_Entity_Service::valid_entity_post_types(); |
|
155 | - } |
|
156 | - |
|
157 | - return " AND p.post_type IN ( '" |
|
158 | - . implode( |
|
159 | - "','", |
|
160 | - array_map( 'esc_sql', $post_types ) |
|
161 | - ) |
|
162 | - . "' )"; |
|
163 | - } |
|
164 | - |
|
165 | - /** |
|
166 | - * Add the limit clause if specified. |
|
167 | - * |
|
168 | - * @param null|int $limit The maximum number of results. |
|
169 | - * |
|
170 | - * @return string The limit clause (empty if no limit has been specified). |
|
171 | - * @since 3.15.0 |
|
172 | - */ |
|
173 | - private static function limit( $limit = null ) { |
|
174 | - |
|
175 | - if ( null === $limit ) { |
|
176 | - return ''; |
|
177 | - } |
|
178 | - |
|
179 | - return "LIMIT $limit"; |
|
180 | - } |
|
181 | - |
|
182 | - /** |
|
183 | - * Add the OFFSET clause if specified. |
|
184 | - * |
|
185 | - * @param null|int $offset The number of results to skip. |
|
186 | - * |
|
187 | - * @return string The offset clause (empty if no offset has been specified). |
|
188 | - * @since 3.35.11 |
|
189 | - */ |
|
190 | - private static function offset( $offset = null ) { |
|
191 | - |
|
192 | - if ( null === $offset || ! is_numeric( $offset ) ) { |
|
193 | - return ''; |
|
194 | - } |
|
195 | - |
|
196 | - return " OFFSET $offset"; |
|
197 | - } |
|
198 | - |
|
199 | - /** |
|
200 | - * @param $order_by string | null |
|
201 | - * |
|
202 | - * @return string |
|
203 | - */ |
|
204 | - private static function order_by( $order_by ) { |
|
205 | - if ( ! $order_by ) { |
|
206 | - return ''; |
|
207 | - } |
|
208 | - $order_by = (string) $order_by; |
|
209 | - $order_by_clauses = array( 'DESC', 'ASC' ); |
|
210 | - |
|
211 | - if ( in_array( $order_by, $order_by_clauses, true ) ) { |
|
212 | - return " ORDER BY p.post_modified {$order_by} "; |
|
213 | - } else { |
|
214 | - return ' ORDER BY p.post_modified DESC '; |
|
215 | - } |
|
216 | - } |
|
217 | - |
|
218 | - /** |
|
219 | - * Map the provided ids into entities (i.e. return the id if it's an entity |
|
220 | - * or get the entities if it's a post). |
|
221 | - * |
|
222 | - * @param int|array $object_id An array of posts/entities' ids. |
|
223 | - * |
|
224 | - * @return array An array of entities' ids. |
|
225 | - * @since 3.15.0 |
|
226 | - */ |
|
227 | - private function article_id_to_entity_id( $object_id ) { |
|
228 | - |
|
229 | - $entity_service = Wordlift_Entity_Service::get_instance(); |
|
230 | - |
|
231 | - $relation_service = $this; |
|
232 | - |
|
233 | - return array_reduce( |
|
234 | - (array) $object_id, |
|
235 | - function ( $carry, $item ) use ( $entity_service, $relation_service ) { |
|
236 | - if ( $entity_service->is_entity( $item ) ) { |
|
237 | - return array_merge( $carry, (array) $item ); |
|
238 | - } |
|
239 | - |
|
240 | - return array_merge( $carry, $relation_service->get_objects( $item, 'ids' ) ); |
|
241 | - }, |
|
242 | - array() |
|
243 | - ); |
|
244 | - |
|
245 | - } |
|
246 | - |
|
247 | - /** |
|
248 | - * Add the WHERE clause. |
|
249 | - * |
|
250 | - * @param int|array $object_id An array of {@link WP_Post}s' ids. |
|
251 | - * |
|
252 | - * @return string The WHERE clause. |
|
253 | - * @since 3.15.0 |
|
254 | - */ |
|
255 | - private static function where_object_id( $object_id ) { |
|
256 | - |
|
257 | - if ( empty( $object_id ) ) { |
|
258 | - // self::$log->warn( sprintf( "%s `where_object_id` called with empty `object_id`.", var_export( debug_backtrace( false, 3 ), true ) ) ); |
|
259 | - |
|
260 | - return ' WHERE 1 = 1'; |
|
261 | - } |
|
262 | - |
|
263 | - return ' WHERE r.object_id IN ( ' . implode( ',', wp_parse_id_list( (array) $object_id ) ) . ' )'; |
|
264 | - } |
|
265 | - |
|
266 | - /** |
|
267 | - * Add the exclude clause. |
|
268 | - * |
|
269 | - * @param int|array $exclude An array of {@link WP_Post}s' ids to exclude. |
|
270 | - * |
|
271 | - * @return string The exclude clause. |
|
272 | - * @since 3.15.0 |
|
273 | - */ |
|
274 | - private static function and_article_not_in( $exclude ) { |
|
275 | - |
|
276 | - return ' AND NOT p.ID IN ( ' . implode( ',', wp_parse_id_list( (array) $exclude ) ) . ' )'; |
|
277 | - } |
|
278 | - |
|
279 | - /** |
|
280 | - * Add the include clause. |
|
281 | - * |
|
282 | - * @param null|int|array $include An array of {@link WP_Post}s' ids. |
|
283 | - * |
|
284 | - * @return string An empty string if $include is null otherwise the include |
|
285 | - * clause. |
|
286 | - * @since 3.15.0 |
|
287 | - */ |
|
288 | - private static function and_article_in( $include = null ) { |
|
289 | - |
|
290 | - if ( null === $include ) { |
|
291 | - return ''; |
|
292 | - } |
|
293 | - |
|
294 | - return ' AND p.ID IN ( ' . implode( ',', wp_parse_id_list( (array) $include ) ) . ' )'; |
|
295 | - } |
|
296 | - |
|
297 | - /** |
|
298 | - * Get the entities' {@link WP_Post}s' ids referencing the specified {@link WP_Post}. |
|
299 | - * |
|
300 | - * @param int $object_id The object {@link WP_Post}'s id. |
|
301 | - * @param string $fields The fields to return, 'ids' to only return ids or |
|
302 | - * '*' to return all fields, by default '*'. |
|
303 | - * @param null|string $status The status, by default all. |
|
304 | - * |
|
305 | - * @return array|object|null Database query results |
|
306 | - * @since 3.15.0 |
|
307 | - */ |
|
308 | - public function get_non_article_subjects( $object_id, $fields = '*', $status = null ) { |
|
309 | - global $wpdb; |
|
310 | - |
|
311 | - // The output fields. |
|
312 | - $actual_fields = self::fields( $fields ); |
|
313 | - |
|
314 | - $sql = $wpdb->prepare( |
|
315 | - "SELECT p.$actual_fields FROM {$wpdb->prefix}wl_relation_instances r INNER JOIN $wpdb->posts p ON p.id = r.subject_id" // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared |
|
316 | - // Add the status clause. |
|
317 | - . self::and_status( $status ) // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
318 | - . self::inner_join_is_not_article() // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
319 | - . ' WHERE r.object_id = %d ' |
|
320 | - . self::and_post_type_in(), // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
321 | - $object_id |
|
322 | - ); |
|
323 | - |
|
324 | - return '*' === $actual_fields ? $wpdb->get_results( $sql ) : $wpdb->get_col( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
325 | - } |
|
326 | - |
|
327 | - /** |
|
328 | - * Get the entities referenced by the specified {@link WP_Post}. |
|
329 | - * |
|
330 | - * @param int $subject_id The {@link WP_Post}'s id. |
|
331 | - * @param string $fields The fields to return, 'ids' to only return ids or |
|
332 | - * '*' to return all fields, by default '*'. |
|
333 | - * @param null|string $predicate The predicate (who|what|...), by default all. |
|
334 | - * @param null|string $status The status, by default all. |
|
335 | - * |
|
336 | - * @return array|object|null Database query results |
|
337 | - * |
|
338 | - * @deprecated since it doesn't handle the subject_type nor the object_type |
|
339 | - * @since 3.15.0 |
|
340 | - */ |
|
341 | - public function get_objects( $subject_id, $fields = '*', $predicate = null, $status = null ) { |
|
342 | - global $wpdb; |
|
343 | - |
|
344 | - // The output fields. |
|
345 | - $actual_fields = self::fields( $fields ); |
|
346 | - |
|
347 | - $sql = $wpdb->prepare( |
|
348 | - "SELECT p.$actual_fields FROM {$this->relation_table} r INNER JOIN $wpdb->posts p ON p.id = r.object_id" // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared |
|
349 | - // Add the status clause. |
|
350 | - . self::and_status( $status ) // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
351 | - . self::inner_join_is_not_article() // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
352 | - . ' WHERE r.subject_id = %d ' |
|
353 | - . self::and_post_type_in() // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
354 | - . self::and_predicate( $predicate ), // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
355 | - $subject_id |
|
356 | - ); |
|
357 | - |
|
358 | - return '*' === $actual_fields ? $wpdb->get_results( $sql ) : $wpdb->get_col( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
359 | - } |
|
360 | - |
|
361 | - /** |
|
362 | - * Add the `post_status` clause. |
|
363 | - * |
|
364 | - * @param null|string|array $status The status values. |
|
365 | - * |
|
366 | - * @return string An empty string if $status is null, otherwise the status clause. |
|
367 | - * @since 3.15.0 |
|
368 | - */ |
|
369 | - private static function and_status( $status = null ) { |
|
370 | - |
|
371 | - if ( null === $status ) { |
|
372 | - return ''; |
|
373 | - } |
|
374 | - |
|
375 | - return " AND p.post_status IN ('" . implode( "', '", array_map( 'esc_sql', (array) $status ) ) . "')"; |
|
376 | - } |
|
377 | - |
|
378 | - /** |
|
379 | - * Add the `predicate` clause. |
|
380 | - * |
|
381 | - * @param null|string|array $predicate An array of predicates. |
|
382 | - * |
|
383 | - * @return string An empty string if $predicate is null otherwise the predicate |
|
384 | - * clause. |
|
385 | - * @since 3.15.0 |
|
386 | - */ |
|
387 | - private static function and_predicate( $predicate = null ) { |
|
388 | - |
|
389 | - if ( null === $predicate ) { |
|
390 | - return ''; |
|
391 | - } |
|
392 | - |
|
393 | - return " AND r.predicate IN ('" . implode( "', '", array_map( 'esc_sql', (array) $predicate ) ) . "')"; |
|
394 | - } |
|
395 | - |
|
396 | - /** |
|
397 | - * The select fields. |
|
398 | - * |
|
399 | - * @param string $fields Either 'ids' or '*', by default '*'. |
|
400 | - * |
|
401 | - * @return string The `id` field if `ids` otherwise `*`. |
|
402 | - * @since 3.15.0 |
|
403 | - */ |
|
404 | - private static function fields( $fields = '*' ) { |
|
405 | - |
|
406 | - // The output fields. |
|
407 | - return 'ids' === $fields ? 'id' : '*'; |
|
408 | - } |
|
409 | - |
|
410 | - /** |
|
411 | - * The inner join clause for articles. |
|
412 | - * |
|
413 | - * @return string The articles inner join clause. |
|
414 | - * @since 3.15.0 |
|
415 | - */ |
|
416 | - private static function inner_join_is_article() { |
|
417 | - global $wpdb; |
|
418 | - |
|
419 | - return $wpdb->prepare( |
|
420 | - " |
|
125 | + // Add the status clause. |
|
126 | + . self::and_status( $status ) |
|
127 | + . self::inner_join_is_article() |
|
128 | + . self::where_object_id( $objects ) |
|
129 | + // Since `object_id` can be an article ID we need to exclude it from |
|
130 | + // the results. |
|
131 | + . self::and_article_not_in( array_merge( $excludes, (array) $object_id ) ) |
|
132 | + . self::and_article_in( $include ) |
|
133 | + . self::and_post_type_in( $post_types ) |
|
134 | + . self::and_predicate( $predicate ) |
|
135 | + . self::order_by( $order_by ) |
|
136 | + . self::limit( $limit ) |
|
137 | + . self::offset( $offset ); |
|
138 | + |
|
139 | + return '*' === $actual_fields ? $wpdb->get_results( $sql ) : $wpdb->get_col( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
140 | + } |
|
141 | + |
|
142 | + /** |
|
143 | + * The `post_type IN` clause. |
|
144 | + * |
|
145 | + * @param array $post_types If the post type is not provided then the valid |
|
146 | + * entity post types are used. |
|
147 | + * |
|
148 | + * @return string The `post_type IN` clause. |
|
149 | + * @since 3.15.3 |
|
150 | + */ |
|
151 | + private static function and_post_type_in( $post_types = array() ) { |
|
152 | + |
|
153 | + if ( array() === $post_types ) { |
|
154 | + $post_types = Wordlift_Entity_Service::valid_entity_post_types(); |
|
155 | + } |
|
156 | + |
|
157 | + return " AND p.post_type IN ( '" |
|
158 | + . implode( |
|
159 | + "','", |
|
160 | + array_map( 'esc_sql', $post_types ) |
|
161 | + ) |
|
162 | + . "' )"; |
|
163 | + } |
|
164 | + |
|
165 | + /** |
|
166 | + * Add the limit clause if specified. |
|
167 | + * |
|
168 | + * @param null|int $limit The maximum number of results. |
|
169 | + * |
|
170 | + * @return string The limit clause (empty if no limit has been specified). |
|
171 | + * @since 3.15.0 |
|
172 | + */ |
|
173 | + private static function limit( $limit = null ) { |
|
174 | + |
|
175 | + if ( null === $limit ) { |
|
176 | + return ''; |
|
177 | + } |
|
178 | + |
|
179 | + return "LIMIT $limit"; |
|
180 | + } |
|
181 | + |
|
182 | + /** |
|
183 | + * Add the OFFSET clause if specified. |
|
184 | + * |
|
185 | + * @param null|int $offset The number of results to skip. |
|
186 | + * |
|
187 | + * @return string The offset clause (empty if no offset has been specified). |
|
188 | + * @since 3.35.11 |
|
189 | + */ |
|
190 | + private static function offset( $offset = null ) { |
|
191 | + |
|
192 | + if ( null === $offset || ! is_numeric( $offset ) ) { |
|
193 | + return ''; |
|
194 | + } |
|
195 | + |
|
196 | + return " OFFSET $offset"; |
|
197 | + } |
|
198 | + |
|
199 | + /** |
|
200 | + * @param $order_by string | null |
|
201 | + * |
|
202 | + * @return string |
|
203 | + */ |
|
204 | + private static function order_by( $order_by ) { |
|
205 | + if ( ! $order_by ) { |
|
206 | + return ''; |
|
207 | + } |
|
208 | + $order_by = (string) $order_by; |
|
209 | + $order_by_clauses = array( 'DESC', 'ASC' ); |
|
210 | + |
|
211 | + if ( in_array( $order_by, $order_by_clauses, true ) ) { |
|
212 | + return " ORDER BY p.post_modified {$order_by} "; |
|
213 | + } else { |
|
214 | + return ' ORDER BY p.post_modified DESC '; |
|
215 | + } |
|
216 | + } |
|
217 | + |
|
218 | + /** |
|
219 | + * Map the provided ids into entities (i.e. return the id if it's an entity |
|
220 | + * or get the entities if it's a post). |
|
221 | + * |
|
222 | + * @param int|array $object_id An array of posts/entities' ids. |
|
223 | + * |
|
224 | + * @return array An array of entities' ids. |
|
225 | + * @since 3.15.0 |
|
226 | + */ |
|
227 | + private function article_id_to_entity_id( $object_id ) { |
|
228 | + |
|
229 | + $entity_service = Wordlift_Entity_Service::get_instance(); |
|
230 | + |
|
231 | + $relation_service = $this; |
|
232 | + |
|
233 | + return array_reduce( |
|
234 | + (array) $object_id, |
|
235 | + function ( $carry, $item ) use ( $entity_service, $relation_service ) { |
|
236 | + if ( $entity_service->is_entity( $item ) ) { |
|
237 | + return array_merge( $carry, (array) $item ); |
|
238 | + } |
|
239 | + |
|
240 | + return array_merge( $carry, $relation_service->get_objects( $item, 'ids' ) ); |
|
241 | + }, |
|
242 | + array() |
|
243 | + ); |
|
244 | + |
|
245 | + } |
|
246 | + |
|
247 | + /** |
|
248 | + * Add the WHERE clause. |
|
249 | + * |
|
250 | + * @param int|array $object_id An array of {@link WP_Post}s' ids. |
|
251 | + * |
|
252 | + * @return string The WHERE clause. |
|
253 | + * @since 3.15.0 |
|
254 | + */ |
|
255 | + private static function where_object_id( $object_id ) { |
|
256 | + |
|
257 | + if ( empty( $object_id ) ) { |
|
258 | + // self::$log->warn( sprintf( "%s `where_object_id` called with empty `object_id`.", var_export( debug_backtrace( false, 3 ), true ) ) ); |
|
259 | + |
|
260 | + return ' WHERE 1 = 1'; |
|
261 | + } |
|
262 | + |
|
263 | + return ' WHERE r.object_id IN ( ' . implode( ',', wp_parse_id_list( (array) $object_id ) ) . ' )'; |
|
264 | + } |
|
265 | + |
|
266 | + /** |
|
267 | + * Add the exclude clause. |
|
268 | + * |
|
269 | + * @param int|array $exclude An array of {@link WP_Post}s' ids to exclude. |
|
270 | + * |
|
271 | + * @return string The exclude clause. |
|
272 | + * @since 3.15.0 |
|
273 | + */ |
|
274 | + private static function and_article_not_in( $exclude ) { |
|
275 | + |
|
276 | + return ' AND NOT p.ID IN ( ' . implode( ',', wp_parse_id_list( (array) $exclude ) ) . ' )'; |
|
277 | + } |
|
278 | + |
|
279 | + /** |
|
280 | + * Add the include clause. |
|
281 | + * |
|
282 | + * @param null|int|array $include An array of {@link WP_Post}s' ids. |
|
283 | + * |
|
284 | + * @return string An empty string if $include is null otherwise the include |
|
285 | + * clause. |
|
286 | + * @since 3.15.0 |
|
287 | + */ |
|
288 | + private static function and_article_in( $include = null ) { |
|
289 | + |
|
290 | + if ( null === $include ) { |
|
291 | + return ''; |
|
292 | + } |
|
293 | + |
|
294 | + return ' AND p.ID IN ( ' . implode( ',', wp_parse_id_list( (array) $include ) ) . ' )'; |
|
295 | + } |
|
296 | + |
|
297 | + /** |
|
298 | + * Get the entities' {@link WP_Post}s' ids referencing the specified {@link WP_Post}. |
|
299 | + * |
|
300 | + * @param int $object_id The object {@link WP_Post}'s id. |
|
301 | + * @param string $fields The fields to return, 'ids' to only return ids or |
|
302 | + * '*' to return all fields, by default '*'. |
|
303 | + * @param null|string $status The status, by default all. |
|
304 | + * |
|
305 | + * @return array|object|null Database query results |
|
306 | + * @since 3.15.0 |
|
307 | + */ |
|
308 | + public function get_non_article_subjects( $object_id, $fields = '*', $status = null ) { |
|
309 | + global $wpdb; |
|
310 | + |
|
311 | + // The output fields. |
|
312 | + $actual_fields = self::fields( $fields ); |
|
313 | + |
|
314 | + $sql = $wpdb->prepare( |
|
315 | + "SELECT p.$actual_fields FROM {$wpdb->prefix}wl_relation_instances r INNER JOIN $wpdb->posts p ON p.id = r.subject_id" // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared |
|
316 | + // Add the status clause. |
|
317 | + . self::and_status( $status ) // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
318 | + . self::inner_join_is_not_article() // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
319 | + . ' WHERE r.object_id = %d ' |
|
320 | + . self::and_post_type_in(), // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
321 | + $object_id |
|
322 | + ); |
|
323 | + |
|
324 | + return '*' === $actual_fields ? $wpdb->get_results( $sql ) : $wpdb->get_col( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
325 | + } |
|
326 | + |
|
327 | + /** |
|
328 | + * Get the entities referenced by the specified {@link WP_Post}. |
|
329 | + * |
|
330 | + * @param int $subject_id The {@link WP_Post}'s id. |
|
331 | + * @param string $fields The fields to return, 'ids' to only return ids or |
|
332 | + * '*' to return all fields, by default '*'. |
|
333 | + * @param null|string $predicate The predicate (who|what|...), by default all. |
|
334 | + * @param null|string $status The status, by default all. |
|
335 | + * |
|
336 | + * @return array|object|null Database query results |
|
337 | + * |
|
338 | + * @deprecated since it doesn't handle the subject_type nor the object_type |
|
339 | + * @since 3.15.0 |
|
340 | + */ |
|
341 | + public function get_objects( $subject_id, $fields = '*', $predicate = null, $status = null ) { |
|
342 | + global $wpdb; |
|
343 | + |
|
344 | + // The output fields. |
|
345 | + $actual_fields = self::fields( $fields ); |
|
346 | + |
|
347 | + $sql = $wpdb->prepare( |
|
348 | + "SELECT p.$actual_fields FROM {$this->relation_table} r INNER JOIN $wpdb->posts p ON p.id = r.object_id" // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared |
|
349 | + // Add the status clause. |
|
350 | + . self::and_status( $status ) // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
351 | + . self::inner_join_is_not_article() // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
352 | + . ' WHERE r.subject_id = %d ' |
|
353 | + . self::and_post_type_in() // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
354 | + . self::and_predicate( $predicate ), // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
355 | + $subject_id |
|
356 | + ); |
|
357 | + |
|
358 | + return '*' === $actual_fields ? $wpdb->get_results( $sql ) : $wpdb->get_col( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared |
|
359 | + } |
|
360 | + |
|
361 | + /** |
|
362 | + * Add the `post_status` clause. |
|
363 | + * |
|
364 | + * @param null|string|array $status The status values. |
|
365 | + * |
|
366 | + * @return string An empty string if $status is null, otherwise the status clause. |
|
367 | + * @since 3.15.0 |
|
368 | + */ |
|
369 | + private static function and_status( $status = null ) { |
|
370 | + |
|
371 | + if ( null === $status ) { |
|
372 | + return ''; |
|
373 | + } |
|
374 | + |
|
375 | + return " AND p.post_status IN ('" . implode( "', '", array_map( 'esc_sql', (array) $status ) ) . "')"; |
|
376 | + } |
|
377 | + |
|
378 | + /** |
|
379 | + * Add the `predicate` clause. |
|
380 | + * |
|
381 | + * @param null|string|array $predicate An array of predicates. |
|
382 | + * |
|
383 | + * @return string An empty string if $predicate is null otherwise the predicate |
|
384 | + * clause. |
|
385 | + * @since 3.15.0 |
|
386 | + */ |
|
387 | + private static function and_predicate( $predicate = null ) { |
|
388 | + |
|
389 | + if ( null === $predicate ) { |
|
390 | + return ''; |
|
391 | + } |
|
392 | + |
|
393 | + return " AND r.predicate IN ('" . implode( "', '", array_map( 'esc_sql', (array) $predicate ) ) . "')"; |
|
394 | + } |
|
395 | + |
|
396 | + /** |
|
397 | + * The select fields. |
|
398 | + * |
|
399 | + * @param string $fields Either 'ids' or '*', by default '*'. |
|
400 | + * |
|
401 | + * @return string The `id` field if `ids` otherwise `*`. |
|
402 | + * @since 3.15.0 |
|
403 | + */ |
|
404 | + private static function fields( $fields = '*' ) { |
|
405 | + |
|
406 | + // The output fields. |
|
407 | + return 'ids' === $fields ? 'id' : '*'; |
|
408 | + } |
|
409 | + |
|
410 | + /** |
|
411 | + * The inner join clause for articles. |
|
412 | + * |
|
413 | + * @return string The articles inner join clause. |
|
414 | + * @since 3.15.0 |
|
415 | + */ |
|
416 | + private static function inner_join_is_article() { |
|
417 | + global $wpdb; |
|
418 | + |
|
419 | + return $wpdb->prepare( |
|
420 | + " |
|
421 | 421 | INNER JOIN $wpdb->term_relationships tr |
422 | 422 | ON p.id = tr.object_id |
423 | 423 | INNER JOIN $wpdb->term_taxonomy tt |
@@ -427,22 +427,22 @@ discard block |
||
427 | 427 | ON t.term_id = tt.term_id |
428 | 428 | AND t.slug = %s |
429 | 429 | ", |
430 | - 'wl_entity_type', |
|
431 | - 'article' |
|
432 | - ); |
|
433 | - } |
|
434 | - |
|
435 | - /** |
|
436 | - * The inner join clause for non-articles. |
|
437 | - * |
|
438 | - * @return string The non-articles inner join clause. |
|
439 | - * @since 3.15.0 |
|
440 | - */ |
|
441 | - private static function inner_join_is_not_article() { |
|
442 | - global $wpdb; |
|
443 | - |
|
444 | - return $wpdb->prepare( |
|
445 | - " |
|
430 | + 'wl_entity_type', |
|
431 | + 'article' |
|
432 | + ); |
|
433 | + } |
|
434 | + |
|
435 | + /** |
|
436 | + * The inner join clause for non-articles. |
|
437 | + * |
|
438 | + * @return string The non-articles inner join clause. |
|
439 | + * @since 3.15.0 |
|
440 | + */ |
|
441 | + private static function inner_join_is_not_article() { |
|
442 | + global $wpdb; |
|
443 | + |
|
444 | + return $wpdb->prepare( |
|
445 | + " |
|
446 | 446 | INNER JOIN $wpdb->term_relationships tr |
447 | 447 | ON p.id = tr.object_id |
448 | 448 | INNER JOIN $wpdb->term_taxonomy tt |
@@ -452,29 +452,29 @@ discard block |
||
452 | 452 | ON t.term_id = tt.term_id |
453 | 453 | AND NOT t.slug = %s |
454 | 454 | ", |
455 | - 'wl_entity_type', |
|
456 | - 'article' |
|
457 | - ); |
|
458 | - } |
|
459 | - |
|
460 | - /** |
|
461 | - * Find all the subject IDs and their referenced/related object IDs. The |
|
462 | - * object IDs are returned as comma separated IDs in the `object_ids` key. |
|
463 | - * |
|
464 | - * @return mixed Database query results |
|
465 | - * @since 3.18.0 |
|
466 | - */ |
|
467 | - public function find_all_grouped_by_subject_id() { |
|
468 | - global $wpdb; |
|
469 | - |
|
470 | - return $wpdb->get_results( |
|
471 | - " |
|
455 | + 'wl_entity_type', |
|
456 | + 'article' |
|
457 | + ); |
|
458 | + } |
|
459 | + |
|
460 | + /** |
|
461 | + * Find all the subject IDs and their referenced/related object IDs. The |
|
462 | + * object IDs are returned as comma separated IDs in the `object_ids` key. |
|
463 | + * |
|
464 | + * @return mixed Database query results |
|
465 | + * @since 3.18.0 |
|
466 | + */ |
|
467 | + public function find_all_grouped_by_subject_id() { |
|
468 | + global $wpdb; |
|
469 | + |
|
470 | + return $wpdb->get_results( |
|
471 | + " |
|
472 | 472 | SELECT subject_id, GROUP_CONCAT( DISTINCT object_id ORDER BY object_id SEPARATOR ',' ) AS object_ids |
473 | 473 | FROM {$wpdb->prefix}wl_relation_instances |
474 | 474 | GROUP BY subject_id |
475 | 475 | " |
476 | - ); |
|
476 | + ); |
|
477 | 477 | |
478 | - } |
|
478 | + } |
|
479 | 479 | |
480 | 480 | } |
@@ -10,141 +10,141 @@ |
||
10 | 10 | */ |
11 | 11 | abstract class Wordlift_Shortcode_REST { |
12 | 12 | |
13 | - /** |
|
14 | - * The cache_ttl, set by extending classes. |
|
15 | - */ |
|
16 | - const CACHE_TTL = 86400; // 24 hours |
|
17 | - |
|
18 | - /** |
|
19 | - * @var $endpoint string The endpoint. |
|
20 | - */ |
|
21 | - private $endpoint; |
|
22 | - |
|
23 | - /** |
|
24 | - * @var $args array The args. |
|
25 | - */ |
|
26 | - private $args; |
|
27 | - |
|
28 | - public function __construct( $endpoint, $args ) { |
|
29 | - |
|
30 | - $scope = $this; |
|
31 | - $this->endpoint = $endpoint; |
|
32 | - $this->args = $args; |
|
33 | - |
|
34 | - // Register rest route with callback |
|
35 | - add_action( |
|
36 | - 'rest_api_init', |
|
37 | - function () use ( $scope ) { |
|
38 | - register_rest_route( |
|
39 | - WL_REST_ROUTE_DEFAULT_NAMESPACE, |
|
40 | - $scope->endpoint, |
|
41 | - array( |
|
42 | - 'methods' => WP_REST_Server::READABLE, |
|
43 | - 'permission_callback' => '__return_true', |
|
44 | - 'callback' => array( $scope, 'rest_callback' ), |
|
45 | - 'args' => $scope->args, |
|
46 | - ) |
|
47 | - ); |
|
48 | - } |
|
49 | - ); |
|
50 | - |
|
51 | - // Optimizations: disable unneeded plugins on this specific REST call. WPSeo is slowing down the responses quite a bit. |
|
52 | - add_action( |
|
53 | - 'plugins_loaded', |
|
54 | - function () use ( $scope ) { |
|
55 | - |
|
56 | - if ( ! defined( 'REST_REQUEST' ) || ! REST_REQUEST || ! $scope->is_endpoint() ) { |
|
57 | - return; |
|
58 | - } |
|
59 | - |
|
60 | - remove_action( 'plugins_loaded', 'rocket_init' ); |
|
61 | - remove_action( 'plugins_loaded', 'wpseo_premium_init', 14 ); |
|
62 | - remove_action( 'plugins_loaded', 'wpseo_init', 14 ); |
|
63 | - }, |
|
64 | - 0 |
|
65 | - ); |
|
66 | - |
|
67 | - add_action( |
|
68 | - 'init', |
|
69 | - function () use ( $scope ) { |
|
70 | - |
|
71 | - if ( ! defined( 'REST_REQUEST' ) || ! REST_REQUEST || ! $scope->is_endpoint() ) { |
|
72 | - return; |
|
73 | - } |
|
74 | - |
|
75 | - remove_action( 'init', 'wp_widgets_init', 1 ); |
|
76 | - remove_action( 'init', 'gglcptch_init' ); |
|
77 | - }, |
|
78 | - 0 |
|
79 | - ); |
|
80 | - |
|
81 | - } |
|
82 | - |
|
83 | - abstract public function get_data( $request ); |
|
84 | - |
|
85 | - public function rest_callback( WP_REST_Request $request ) { |
|
86 | - |
|
87 | - // Respond from origin if TTL is 0 |
|
88 | - if ( static::CACHE_TTL === 0 ) { |
|
89 | - |
|
90 | - $data = $this->get_data( $request ); |
|
91 | - $response = rest_ensure_response( $data ); |
|
92 | - if ( is_wp_error( $data ) ) { |
|
93 | - return $response; |
|
94 | - } |
|
95 | - $response->header( 'Access-Control-Allow-Origin', '*' ); |
|
96 | - $response->header( 'X-WordLift-Cache', 'MISS' ); |
|
97 | - |
|
98 | - return $response; |
|
99 | - } |
|
100 | - |
|
101 | - // Create the cache key. |
|
102 | - $cache_key_params = $request->get_params(); |
|
103 | - unset( $cache_key_params['uniqid'] ); |
|
104 | - unset( $cache_key_params['rest_route'] ); |
|
105 | - $cache_key = array( 'request_params' => $cache_key_params ); |
|
106 | - |
|
107 | - // Create the TTL cache and try to get the results. |
|
108 | - $cache = new Ttl_Cache( $this->endpoint, static::CACHE_TTL ); |
|
109 | - $cache_results = $cache->get( $cache_key ); |
|
110 | - |
|
111 | - if ( isset( $cache_results ) ) { |
|
112 | - |
|
113 | - $response = rest_ensure_response( $cache_results ); |
|
114 | - $response->header( 'Access-Control-Allow-Origin', '*' ); |
|
115 | - $response->header( 'X-WordLift-Cache', 'HIT' ); |
|
116 | - |
|
117 | - return $response; |
|
118 | - } |
|
119 | - |
|
120 | - $data = $this->get_data( $request ); |
|
121 | - $response = rest_ensure_response( $data ); |
|
122 | - if ( is_wp_error( $data ) ) { |
|
123 | - return $response; |
|
124 | - } |
|
125 | - $response->header( 'Access-Control-Allow-Origin', '*' ); |
|
126 | - $response->header( 'X-WordLift-Cache', 'MISS' ); |
|
127 | - |
|
128 | - // Put the result before sending the json to the client, since sending the json will terminate us. |
|
129 | - $cache->put( $cache_key, $data ); |
|
130 | - |
|
131 | - return $response; |
|
132 | - |
|
133 | - } |
|
134 | - |
|
135 | - private function is_endpoint() { |
|
136 | - $compare_route = WL_REST_ROUTE_DEFAULT_NAMESPACE . $this->endpoint; |
|
137 | - |
|
138 | - // Directly accessing $_SERVER['REQUEST_URI'] or $_GET['rest_route'] here as it's too early to use global $wp reliably |
|
139 | - |
|
140 | - if ( isset( $_SERVER['REQUEST_URI'] ) && strpos( esc_url_raw( wp_unslash( (string) $_SERVER['REQUEST_URI'] ) ), $compare_route ) ) { |
|
141 | - return true; |
|
142 | - } |
|
143 | - if ( ! empty( $_GET['rest_route'] ) && strpos( esc_url_raw( wp_unslash( (string) $_GET['rest_route'] ) ), $compare_route ) ) { //phpcs:ignore WordPress.Security.NonceVerification.Recommended |
|
144 | - return true; |
|
145 | - } |
|
13 | + /** |
|
14 | + * The cache_ttl, set by extending classes. |
|
15 | + */ |
|
16 | + const CACHE_TTL = 86400; // 24 hours |
|
17 | + |
|
18 | + /** |
|
19 | + * @var $endpoint string The endpoint. |
|
20 | + */ |
|
21 | + private $endpoint; |
|
22 | + |
|
23 | + /** |
|
24 | + * @var $args array The args. |
|
25 | + */ |
|
26 | + private $args; |
|
27 | + |
|
28 | + public function __construct( $endpoint, $args ) { |
|
29 | + |
|
30 | + $scope = $this; |
|
31 | + $this->endpoint = $endpoint; |
|
32 | + $this->args = $args; |
|
33 | + |
|
34 | + // Register rest route with callback |
|
35 | + add_action( |
|
36 | + 'rest_api_init', |
|
37 | + function () use ( $scope ) { |
|
38 | + register_rest_route( |
|
39 | + WL_REST_ROUTE_DEFAULT_NAMESPACE, |
|
40 | + $scope->endpoint, |
|
41 | + array( |
|
42 | + 'methods' => WP_REST_Server::READABLE, |
|
43 | + 'permission_callback' => '__return_true', |
|
44 | + 'callback' => array( $scope, 'rest_callback' ), |
|
45 | + 'args' => $scope->args, |
|
46 | + ) |
|
47 | + ); |
|
48 | + } |
|
49 | + ); |
|
50 | + |
|
51 | + // Optimizations: disable unneeded plugins on this specific REST call. WPSeo is slowing down the responses quite a bit. |
|
52 | + add_action( |
|
53 | + 'plugins_loaded', |
|
54 | + function () use ( $scope ) { |
|
55 | + |
|
56 | + if ( ! defined( 'REST_REQUEST' ) || ! REST_REQUEST || ! $scope->is_endpoint() ) { |
|
57 | + return; |
|
58 | + } |
|
59 | + |
|
60 | + remove_action( 'plugins_loaded', 'rocket_init' ); |
|
61 | + remove_action( 'plugins_loaded', 'wpseo_premium_init', 14 ); |
|
62 | + remove_action( 'plugins_loaded', 'wpseo_init', 14 ); |
|
63 | + }, |
|
64 | + 0 |
|
65 | + ); |
|
66 | + |
|
67 | + add_action( |
|
68 | + 'init', |
|
69 | + function () use ( $scope ) { |
|
70 | + |
|
71 | + if ( ! defined( 'REST_REQUEST' ) || ! REST_REQUEST || ! $scope->is_endpoint() ) { |
|
72 | + return; |
|
73 | + } |
|
74 | + |
|
75 | + remove_action( 'init', 'wp_widgets_init', 1 ); |
|
76 | + remove_action( 'init', 'gglcptch_init' ); |
|
77 | + }, |
|
78 | + 0 |
|
79 | + ); |
|
80 | + |
|
81 | + } |
|
82 | + |
|
83 | + abstract public function get_data( $request ); |
|
84 | + |
|
85 | + public function rest_callback( WP_REST_Request $request ) { |
|
86 | + |
|
87 | + // Respond from origin if TTL is 0 |
|
88 | + if ( static::CACHE_TTL === 0 ) { |
|
89 | + |
|
90 | + $data = $this->get_data( $request ); |
|
91 | + $response = rest_ensure_response( $data ); |
|
92 | + if ( is_wp_error( $data ) ) { |
|
93 | + return $response; |
|
94 | + } |
|
95 | + $response->header( 'Access-Control-Allow-Origin', '*' ); |
|
96 | + $response->header( 'X-WordLift-Cache', 'MISS' ); |
|
97 | + |
|
98 | + return $response; |
|
99 | + } |
|
100 | + |
|
101 | + // Create the cache key. |
|
102 | + $cache_key_params = $request->get_params(); |
|
103 | + unset( $cache_key_params['uniqid'] ); |
|
104 | + unset( $cache_key_params['rest_route'] ); |
|
105 | + $cache_key = array( 'request_params' => $cache_key_params ); |
|
106 | + |
|
107 | + // Create the TTL cache and try to get the results. |
|
108 | + $cache = new Ttl_Cache( $this->endpoint, static::CACHE_TTL ); |
|
109 | + $cache_results = $cache->get( $cache_key ); |
|
110 | + |
|
111 | + if ( isset( $cache_results ) ) { |
|
112 | + |
|
113 | + $response = rest_ensure_response( $cache_results ); |
|
114 | + $response->header( 'Access-Control-Allow-Origin', '*' ); |
|
115 | + $response->header( 'X-WordLift-Cache', 'HIT' ); |
|
116 | + |
|
117 | + return $response; |
|
118 | + } |
|
119 | + |
|
120 | + $data = $this->get_data( $request ); |
|
121 | + $response = rest_ensure_response( $data ); |
|
122 | + if ( is_wp_error( $data ) ) { |
|
123 | + return $response; |
|
124 | + } |
|
125 | + $response->header( 'Access-Control-Allow-Origin', '*' ); |
|
126 | + $response->header( 'X-WordLift-Cache', 'MISS' ); |
|
127 | + |
|
128 | + // Put the result before sending the json to the client, since sending the json will terminate us. |
|
129 | + $cache->put( $cache_key, $data ); |
|
130 | + |
|
131 | + return $response; |
|
132 | + |
|
133 | + } |
|
134 | + |
|
135 | + private function is_endpoint() { |
|
136 | + $compare_route = WL_REST_ROUTE_DEFAULT_NAMESPACE . $this->endpoint; |
|
137 | + |
|
138 | + // Directly accessing $_SERVER['REQUEST_URI'] or $_GET['rest_route'] here as it's too early to use global $wp reliably |
|
139 | + |
|
140 | + if ( isset( $_SERVER['REQUEST_URI'] ) && strpos( esc_url_raw( wp_unslash( (string) $_SERVER['REQUEST_URI'] ) ), $compare_route ) ) { |
|
141 | + return true; |
|
142 | + } |
|
143 | + if ( ! empty( $_GET['rest_route'] ) && strpos( esc_url_raw( wp_unslash( (string) $_GET['rest_route'] ) ), $compare_route ) ) { //phpcs:ignore WordPress.Security.NonceVerification.Recommended |
|
144 | + return true; |
|
145 | + } |
|
146 | 146 | |
147 | - return false; |
|
148 | - } |
|
147 | + return false; |
|
148 | + } |
|
149 | 149 | |
150 | 150 | } |
@@ -4,54 +4,54 @@ |
||
4 | 4 | |
5 | 5 | class Features_Registry { |
6 | 6 | |
7 | - /** |
|
8 | - * @var array<Feature> |
|
9 | - */ |
|
10 | - private $features = array(); |
|
11 | - |
|
12 | - private static $instance = null; |
|
13 | - |
|
14 | - public static function get_instance() { |
|
15 | - if ( null === self::$instance ) { |
|
16 | - self::$instance = new Features_Registry(); |
|
17 | - } |
|
18 | - |
|
19 | - return self::$instance; |
|
20 | - } |
|
21 | - |
|
22 | - /** |
|
23 | - * @param $feature Feature |
|
24 | - */ |
|
25 | - public function register_feature( $feature ) { |
|
26 | - $this->features[] = $feature; |
|
27 | - } |
|
28 | - |
|
29 | - /** |
|
30 | - * @param $feature_slug string |
|
31 | - * @param $default_value bool |
|
32 | - * @param $callback callable |
|
33 | - */ |
|
34 | - public function register_feature_from_slug( $feature_slug, $default_value, $callback ) { |
|
35 | - $this->features[] = new Feature( |
|
36 | - $feature_slug, |
|
37 | - $default_value, |
|
38 | - $callback |
|
39 | - ); |
|
40 | - } |
|
41 | - |
|
42 | - public function initialize_all_features() { |
|
43 | - foreach ( $this->features as $feature ) { |
|
44 | - /** |
|
45 | - * @var $feature Feature |
|
46 | - */ |
|
47 | - $feature_slug = $feature->feature_slug; |
|
48 | - if ( apply_filters( "wl_feature__enable__{$feature_slug}", $feature->default_value ) ) { |
|
49 | - call_user_func( $feature->callback ); |
|
50 | - } |
|
51 | - } |
|
52 | - } |
|
53 | - |
|
54 | - public function clear_all() { |
|
55 | - $this->features = array(); |
|
56 | - } |
|
7 | + /** |
|
8 | + * @var array<Feature> |
|
9 | + */ |
|
10 | + private $features = array(); |
|
11 | + |
|
12 | + private static $instance = null; |
|
13 | + |
|
14 | + public static function get_instance() { |
|
15 | + if ( null === self::$instance ) { |
|
16 | + self::$instance = new Features_Registry(); |
|
17 | + } |
|
18 | + |
|
19 | + return self::$instance; |
|
20 | + } |
|
21 | + |
|
22 | + /** |
|
23 | + * @param $feature Feature |
|
24 | + */ |
|
25 | + public function register_feature( $feature ) { |
|
26 | + $this->features[] = $feature; |
|
27 | + } |
|
28 | + |
|
29 | + /** |
|
30 | + * @param $feature_slug string |
|
31 | + * @param $default_value bool |
|
32 | + * @param $callback callable |
|
33 | + */ |
|
34 | + public function register_feature_from_slug( $feature_slug, $default_value, $callback ) { |
|
35 | + $this->features[] = new Feature( |
|
36 | + $feature_slug, |
|
37 | + $default_value, |
|
38 | + $callback |
|
39 | + ); |
|
40 | + } |
|
41 | + |
|
42 | + public function initialize_all_features() { |
|
43 | + foreach ( $this->features as $feature ) { |
|
44 | + /** |
|
45 | + * @var $feature Feature |
|
46 | + */ |
|
47 | + $feature_slug = $feature->feature_slug; |
|
48 | + if ( apply_filters( "wl_feature__enable__{$feature_slug}", $feature->default_value ) ) { |
|
49 | + call_user_func( $feature->callback ); |
|
50 | + } |
|
51 | + } |
|
52 | + } |
|
53 | + |
|
54 | + public function clear_all() { |
|
55 | + $this->features = array(); |
|
56 | + } |
|
57 | 57 | } |
@@ -3,108 +3,108 @@ |
||
3 | 3 | namespace Wordlift\Features; |
4 | 4 | |
5 | 5 | class Response_Adapter { |
6 | - const WL_FEATURES = '_wl_features'; |
|
7 | - const WL_1 = 'wl1'; |
|
8 | - |
|
9 | - public function __construct() { |
|
10 | - |
|
11 | - // Filter responses from the API calls to update the enabled features. |
|
12 | - add_filter( 'wl_api_service__response', array( $this, 'response' ), 10, 1 ); |
|
13 | - |
|
14 | - // Initialize from `$_ENV`: this is currently required for Unit Tests, since `tests/bootstrap.php` loads WordLift |
|
15 | - // before it can actually query the enabled features via HTTP (mock), which would prevent files from being included. |
|
16 | - // $this->init_from_env(); |
|
17 | - |
|
18 | - // Register the `wl_features__enable__{feature-name}` filters. |
|
19 | - $this->register_filters(); |
|
20 | - |
|
21 | - // Hook to the updates to the features setting to refresh the features' filters. |
|
22 | - add_action( 'update_option_' . self::WL_FEATURES, array( $this, 'register_filters' ), 10, 0 ); |
|
23 | - |
|
24 | - } |
|
25 | - |
|
26 | - public function response( $response ) { |
|
27 | - |
|
28 | - $headers = wp_remote_retrieve_headers( $response ); |
|
29 | - |
|
30 | - // Bail out if the `wl1` header isn't defined. |
|
31 | - if ( ! isset( $headers[ self::WL_1 ] ) ) { |
|
32 | - return $response; |
|
33 | - } |
|
34 | - $wl1_as_base64_string = $headers[ self::WL_1 ]; |
|
35 | - // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.obfuscation_base64_decode |
|
36 | - $wl1 = json_decode( base64_decode( $wl1_as_base64_string ), true ); |
|
37 | - |
|
38 | - $updated_features = $wl1['features']; |
|
39 | - |
|
40 | - $existing_features = get_option( self::WL_FEATURES, array() ); |
|
41 | - |
|
42 | - // Loop through updated features. |
|
43 | - foreach ( $updated_features as $feature_slug => $new_value ) { |
|
44 | - |
|
45 | - // We cant pass false because that indicates if the feature is active or not, null is used to represent the features which are |
|
46 | - // not set before. |
|
47 | - $old_value = array_key_exists( $feature_slug, $existing_features ) ? $existing_features[ $feature_slug ] : null; |
|
48 | - |
|
49 | - if ( $old_value !== $new_value ) { |
|
50 | - /** |
|
51 | - * @param $feature_slug string The feature slug. |
|
52 | - * @param $old_value null | boolean Null represents the feature flag was not set before. |
|
53 | - * @param $new_value boolean True or false. |
|
54 | - * |
|
55 | - * @since 3.32.1 |
|
56 | - * Hook : `wl_feature__change__{feature_slug}` |
|
57 | - * Action hook to be fired when there is a change in feature state. |
|
58 | - */ |
|
59 | - do_action( "wl_feature__change__$feature_slug", $new_value, $old_value, $feature_slug ); |
|
60 | - } |
|
61 | - } |
|
62 | - |
|
63 | - if ( isset( $updated_features ) ) { |
|
64 | - |
|
65 | - if ( update_option( self::WL_FEATURES, (array) $updated_features, true ) ) { |
|
66 | - $this->register_filters(); |
|
67 | - } |
|
68 | - } |
|
69 | - |
|
70 | - return $response; |
|
71 | - } |
|
72 | - |
|
73 | - /** |
|
74 | - * Registers the feature filters. |
|
75 | - */ |
|
76 | - public function register_filters() { |
|
77 | - |
|
78 | - foreach ( (array) get_option( self::WL_FEATURES, array() ) as $name => $enabled ) { |
|
79 | - // Remove previous filters. |
|
80 | - remove_filter( "wl_feature__enable__{$name}", '__return_true' ); |
|
81 | - remove_filter( "wl_feature__enable__{$name}", '__return_false' ); |
|
82 | - |
|
83 | - $callback = ( $enabled ? '__return_true' : '__return_false' ); |
|
84 | - add_filter( "wl_feature__enable__{$name}", $callback ); |
|
85 | - } |
|
86 | - |
|
87 | - } |
|
88 | - |
|
89 | - private function init_from_env() { |
|
90 | - $features = array_reduce( |
|
91 | - array_filter( |
|
92 | - array_keys( $_ENV ), |
|
93 | - function ( $key ) { |
|
94 | - return preg_match( '~^WL_FEATURES__.*~', $key ); |
|
95 | - } |
|
96 | - ), |
|
97 | - function ( $features, $env ) { |
|
98 | - $name = strtolower( str_replace( '_', '-', substr( $env, strlen( 'WL_FEATURES__' ) ) ) ); |
|
99 | - $value = wp_validate_boolean( getenv( $env ) ); |
|
100 | - $features[ $name ] = $value; |
|
101 | - |
|
102 | - return $features; |
|
103 | - }, |
|
104 | - array() |
|
105 | - ); |
|
106 | - |
|
107 | - update_option( self::WL_FEATURES, (array) $features, true ); |
|
108 | - } |
|
6 | + const WL_FEATURES = '_wl_features'; |
|
7 | + const WL_1 = 'wl1'; |
|
8 | + |
|
9 | + public function __construct() { |
|
10 | + |
|
11 | + // Filter responses from the API calls to update the enabled features. |
|
12 | + add_filter( 'wl_api_service__response', array( $this, 'response' ), 10, 1 ); |
|
13 | + |
|
14 | + // Initialize from `$_ENV`: this is currently required for Unit Tests, since `tests/bootstrap.php` loads WordLift |
|
15 | + // before it can actually query the enabled features via HTTP (mock), which would prevent files from being included. |
|
16 | + // $this->init_from_env(); |
|
17 | + |
|
18 | + // Register the `wl_features__enable__{feature-name}` filters. |
|
19 | + $this->register_filters(); |
|
20 | + |
|
21 | + // Hook to the updates to the features setting to refresh the features' filters. |
|
22 | + add_action( 'update_option_' . self::WL_FEATURES, array( $this, 'register_filters' ), 10, 0 ); |
|
23 | + |
|
24 | + } |
|
25 | + |
|
26 | + public function response( $response ) { |
|
27 | + |
|
28 | + $headers = wp_remote_retrieve_headers( $response ); |
|
29 | + |
|
30 | + // Bail out if the `wl1` header isn't defined. |
|
31 | + if ( ! isset( $headers[ self::WL_1 ] ) ) { |
|
32 | + return $response; |
|
33 | + } |
|
34 | + $wl1_as_base64_string = $headers[ self::WL_1 ]; |
|
35 | + // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.obfuscation_base64_decode |
|
36 | + $wl1 = json_decode( base64_decode( $wl1_as_base64_string ), true ); |
|
37 | + |
|
38 | + $updated_features = $wl1['features']; |
|
39 | + |
|
40 | + $existing_features = get_option( self::WL_FEATURES, array() ); |
|
41 | + |
|
42 | + // Loop through updated features. |
|
43 | + foreach ( $updated_features as $feature_slug => $new_value ) { |
|
44 | + |
|
45 | + // We cant pass false because that indicates if the feature is active or not, null is used to represent the features which are |
|
46 | + // not set before. |
|
47 | + $old_value = array_key_exists( $feature_slug, $existing_features ) ? $existing_features[ $feature_slug ] : null; |
|
48 | + |
|
49 | + if ( $old_value !== $new_value ) { |
|
50 | + /** |
|
51 | + * @param $feature_slug string The feature slug. |
|
52 | + * @param $old_value null | boolean Null represents the feature flag was not set before. |
|
53 | + * @param $new_value boolean True or false. |
|
54 | + * |
|
55 | + * @since 3.32.1 |
|
56 | + * Hook : `wl_feature__change__{feature_slug}` |
|
57 | + * Action hook to be fired when there is a change in feature state. |
|
58 | + */ |
|
59 | + do_action( "wl_feature__change__$feature_slug", $new_value, $old_value, $feature_slug ); |
|
60 | + } |
|
61 | + } |
|
62 | + |
|
63 | + if ( isset( $updated_features ) ) { |
|
64 | + |
|
65 | + if ( update_option( self::WL_FEATURES, (array) $updated_features, true ) ) { |
|
66 | + $this->register_filters(); |
|
67 | + } |
|
68 | + } |
|
69 | + |
|
70 | + return $response; |
|
71 | + } |
|
72 | + |
|
73 | + /** |
|
74 | + * Registers the feature filters. |
|
75 | + */ |
|
76 | + public function register_filters() { |
|
77 | + |
|
78 | + foreach ( (array) get_option( self::WL_FEATURES, array() ) as $name => $enabled ) { |
|
79 | + // Remove previous filters. |
|
80 | + remove_filter( "wl_feature__enable__{$name}", '__return_true' ); |
|
81 | + remove_filter( "wl_feature__enable__{$name}", '__return_false' ); |
|
82 | + |
|
83 | + $callback = ( $enabled ? '__return_true' : '__return_false' ); |
|
84 | + add_filter( "wl_feature__enable__{$name}", $callback ); |
|
85 | + } |
|
86 | + |
|
87 | + } |
|
88 | + |
|
89 | + private function init_from_env() { |
|
90 | + $features = array_reduce( |
|
91 | + array_filter( |
|
92 | + array_keys( $_ENV ), |
|
93 | + function ( $key ) { |
|
94 | + return preg_match( '~^WL_FEATURES__.*~', $key ); |
|
95 | + } |
|
96 | + ), |
|
97 | + function ( $features, $env ) { |
|
98 | + $name = strtolower( str_replace( '_', '-', substr( $env, strlen( 'WL_FEATURES__' ) ) ) ); |
|
99 | + $value = wp_validate_boolean( getenv( $env ) ); |
|
100 | + $features[ $name ] = $value; |
|
101 | + |
|
102 | + return $features; |
|
103 | + }, |
|
104 | + array() |
|
105 | + ); |
|
106 | + |
|
107 | + update_option( self::WL_FEATURES, (array) $features, true ); |
|
108 | + } |
|
109 | 109 | |
110 | 110 | } |
@@ -4,50 +4,50 @@ |
||
4 | 4 | |
5 | 5 | class Configuration { |
6 | 6 | |
7 | - private static $instance; |
|
8 | - |
|
9 | - private $type; |
|
10 | - private $urls; |
|
11 | - |
|
12 | - protected function __construct() { |
|
13 | - $include_exclude_data = get_option( 'wl_exclude_include_urls_settings', array() ); |
|
14 | - $include_exclude = isset( $include_exclude_data['include_exclude'] ) ? $include_exclude_data['include_exclude'] : 'exclude'; |
|
15 | - |
|
16 | - $this->type = in_array( |
|
17 | - $include_exclude, |
|
18 | - array( |
|
19 | - 'include', |
|
20 | - 'exclude', |
|
21 | - ), |
|
22 | - true |
|
23 | - ) |
|
24 | - ? $include_exclude : 'exclude'; |
|
25 | - $this->urls = isset( $include_exclude_data['urls'] ) ? $include_exclude_data['urls'] : ''; |
|
26 | - } |
|
27 | - |
|
28 | - public static function get_instance() { |
|
29 | - if ( ! isset( self::$instance ) ) { |
|
30 | - self::$instance = new self(); |
|
31 | - } |
|
32 | - |
|
33 | - return self::$instance; |
|
34 | - } |
|
35 | - |
|
36 | - public function get_type() { |
|
37 | - return $this->type; |
|
38 | - } |
|
39 | - |
|
40 | - /** |
|
41 | - * Gets the default action, which is the inverse of the configuration type. |
|
42 | - * |
|
43 | - * @return string |
|
44 | - */ |
|
45 | - public function get_default() { |
|
46 | - return ( $this->type === 'exclude' ? 'include' : 'exclude' ); |
|
47 | - } |
|
48 | - |
|
49 | - public function get_urls() { |
|
50 | - return $this->urls; |
|
51 | - } |
|
7 | + private static $instance; |
|
8 | + |
|
9 | + private $type; |
|
10 | + private $urls; |
|
11 | + |
|
12 | + protected function __construct() { |
|
13 | + $include_exclude_data = get_option( 'wl_exclude_include_urls_settings', array() ); |
|
14 | + $include_exclude = isset( $include_exclude_data['include_exclude'] ) ? $include_exclude_data['include_exclude'] : 'exclude'; |
|
15 | + |
|
16 | + $this->type = in_array( |
|
17 | + $include_exclude, |
|
18 | + array( |
|
19 | + 'include', |
|
20 | + 'exclude', |
|
21 | + ), |
|
22 | + true |
|
23 | + ) |
|
24 | + ? $include_exclude : 'exclude'; |
|
25 | + $this->urls = isset( $include_exclude_data['urls'] ) ? $include_exclude_data['urls'] : ''; |
|
26 | + } |
|
27 | + |
|
28 | + public static function get_instance() { |
|
29 | + if ( ! isset( self::$instance ) ) { |
|
30 | + self::$instance = new self(); |
|
31 | + } |
|
32 | + |
|
33 | + return self::$instance; |
|
34 | + } |
|
35 | + |
|
36 | + public function get_type() { |
|
37 | + return $this->type; |
|
38 | + } |
|
39 | + |
|
40 | + /** |
|
41 | + * Gets the default action, which is the inverse of the configuration type. |
|
42 | + * |
|
43 | + * @return string |
|
44 | + */ |
|
45 | + public function get_default() { |
|
46 | + return ( $this->type === 'exclude' ? 'include' : 'exclude' ); |
|
47 | + } |
|
48 | + |
|
49 | + public function get_urls() { |
|
50 | + return $this->urls; |
|
51 | + } |
|
52 | 52 | |
53 | 53 | } |
@@ -4,44 +4,44 @@ |
||
4 | 4 | |
5 | 5 | class Jsonld_Interceptor { |
6 | 6 | |
7 | - /** @var Plugin_Enabled $plugin_enabled */ |
|
8 | - private $plugin_enabled; |
|
7 | + /** @var Plugin_Enabled $plugin_enabled */ |
|
8 | + private $plugin_enabled; |
|
9 | 9 | |
10 | - public function __construct( $plugin_enabled ) { |
|
11 | - $this->plugin_enabled = $plugin_enabled; |
|
12 | - } |
|
10 | + public function __construct( $plugin_enabled ) { |
|
11 | + $this->plugin_enabled = $plugin_enabled; |
|
12 | + } |
|
13 | 13 | |
14 | - public function register_hooks() { |
|
15 | - add_filter( 'wl_after_get_jsonld', array( $this, 'after_get_jsonld' ) ); |
|
16 | - } |
|
14 | + public function register_hooks() { |
|
15 | + add_filter( 'wl_after_get_jsonld', array( $this, 'after_get_jsonld' ) ); |
|
16 | + } |
|
17 | 17 | |
18 | - public function after_get_jsonld( $jsonld_arr ) { |
|
19 | - // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged |
|
20 | - @header( 'X-Wordlift-IncludeExclude-Stage-0: Filter Called with default ' . $this->plugin_enabled->get_configuration()->get_default() ); |
|
21 | - if ( ! is_array( $jsonld_arr ) || empty( $jsonld_arr ) || ! isset( $jsonld_arr[0]['url'] ) || null !== filter_input( INPUT_SERVER, 'HTTP_X_WORDLIFT_BYPASS_INCLUDE_EXCLUDE' ) ) { |
|
22 | - // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged |
|
23 | - @header( 'X-Wordlift-IncludeExclude-Stage-1: Condition Not Matched' ); |
|
18 | + public function after_get_jsonld( $jsonld_arr ) { |
|
19 | + // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged |
|
20 | + @header( 'X-Wordlift-IncludeExclude-Stage-0: Filter Called with default ' . $this->plugin_enabled->get_configuration()->get_default() ); |
|
21 | + if ( ! is_array( $jsonld_arr ) || empty( $jsonld_arr ) || ! isset( $jsonld_arr[0]['url'] ) || null !== filter_input( INPUT_SERVER, 'HTTP_X_WORDLIFT_BYPASS_INCLUDE_EXCLUDE' ) ) { |
|
22 | + // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged |
|
23 | + @header( 'X-Wordlift-IncludeExclude-Stage-1: Condition Not Matched' ); |
|
24 | 24 | |
25 | - return $jsonld_arr; |
|
26 | - } |
|
25 | + return $jsonld_arr; |
|
26 | + } |
|
27 | 27 | |
28 | - // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged |
|
29 | - @header( 'X-Wordlift-IncludeExclude-Stage-1: Condition Matched for ' . $jsonld_arr[0]['url'] ); |
|
30 | - // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged |
|
31 | - @header( 'X-Wordlift-IncludeExclude-Note: To bypass the Include/Exclude filter add a `x-wordlift-bypass-include-exclude` HTTP request header with any value.' ); |
|
28 | + // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged |
|
29 | + @header( 'X-Wordlift-IncludeExclude-Stage-1: Condition Matched for ' . $jsonld_arr[0]['url'] ); |
|
30 | + // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged |
|
31 | + @header( 'X-Wordlift-IncludeExclude-Note: To bypass the Include/Exclude filter add a `x-wordlift-bypass-include-exclude` HTTP request header with any value.' ); |
|
32 | 32 | |
33 | - // If the URLs are included then publish them. |
|
34 | - if ( $this->plugin_enabled->are_urls_included( $jsonld_arr[0]['url'] ) ) { |
|
35 | - // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged |
|
36 | - @header( 'X-Wordlift-IncludeExclude-Stage-2: URL Included' ); |
|
33 | + // If the URLs are included then publish them. |
|
34 | + if ( $this->plugin_enabled->are_urls_included( $jsonld_arr[0]['url'] ) ) { |
|
35 | + // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged |
|
36 | + @header( 'X-Wordlift-IncludeExclude-Stage-2: URL Included' ); |
|
37 | 37 | |
38 | - return $jsonld_arr; |
|
39 | - } |
|
38 | + return $jsonld_arr; |
|
39 | + } |
|
40 | 40 | |
41 | - // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged |
|
42 | - @header( 'X-Wordlift-IncludeExclude-Stage-2: URL Excluded' ); |
|
41 | + // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged |
|
42 | + @header( 'X-Wordlift-IncludeExclude-Stage-2: URL Excluded' ); |
|
43 | 43 | |
44 | - return array(); |
|
45 | - } |
|
44 | + return array(); |
|
45 | + } |
|
46 | 46 | |
47 | 47 | } |
@@ -16,98 +16,98 @@ |
||
16 | 16 | */ |
17 | 17 | class Plugin_Enabled { |
18 | 18 | |
19 | - /** |
|
20 | - * @var Configuration $configuration |
|
21 | - */ |
|
22 | - private $configuration; |
|
23 | - |
|
24 | - public function __construct( $configuration ) { |
|
25 | - $this->configuration = $configuration; |
|
26 | - } |
|
27 | - |
|
28 | - /** |
|
29 | - * Register hooks. |
|
30 | - */ |
|
31 | - public function register_hooks() { |
|
32 | - add_filter( 'wl_is_enabled', array( $this, 'wl_is_enabled' ) ); |
|
33 | - } |
|
34 | - |
|
35 | - /** |
|
36 | - * Enable/Disable WordLift Plugin. |
|
37 | - * |
|
38 | - * @param $enabled |
|
39 | - * |
|
40 | - * @return bool|mixed |
|
41 | - */ |
|
42 | - public function wl_is_enabled( $enabled ) { |
|
43 | - |
|
44 | - // Always enable wordlift on admin and rest api pages. |
|
45 | - if ( is_admin() || $this->is_rest_request() ) { |
|
46 | - return $enabled; |
|
47 | - } |
|
48 | - |
|
49 | - $path = strtok( (string) $_SERVER['REQUEST_URI'], '?' ); // phpcs:ignore |
|
50 | - $options = get_option( 'wl_exclude_include_urls_settings' ); |
|
51 | - |
|
52 | - // Bail out if URLs are not set. |
|
53 | - if ( empty( $options['urls'] ) ) { |
|
54 | - return $enabled; |
|
55 | - } |
|
56 | - |
|
57 | - $current_url = trailingslashit( home_url( $path ) ); |
|
58 | - |
|
59 | - return $this->are_urls_included( $current_url ); |
|
60 | - } |
|
61 | - |
|
62 | - public function are_urls_included( $urls ) { |
|
63 | - // Ensure we deal with an array. We `trailingslashit` all URLs to avoid issues with missing slashes. |
|
64 | - $urls = array_map( 'trailingslashit', (array) $urls ); |
|
65 | - |
|
66 | - // Set a default state. |
|
67 | - $include_by_default = ( $this->configuration->get_default() === 'include' ); |
|
68 | - |
|
69 | - // Get URLs into an array from settings, trim them and make absolute if needed. |
|
70 | - $configured_urls = array_map( |
|
71 | - function ( $url ) { |
|
72 | - $url = trim( $url ); |
|
73 | - if ( substr( $url, 0, 4 ) !== 'http' ) { |
|
74 | - return trailingslashit( home_url( $url ) ); |
|
75 | - } |
|
76 | - |
|
77 | - // Add a trailing slash and return the url |
|
78 | - return trailingslashit( $url ); |
|
79 | - }, |
|
80 | - explode( PHP_EOL, $this->configuration->get_urls() ) |
|
81 | - ); |
|
82 | - |
|
83 | - // Check if any of the provided URLs is in the configured URLs. |
|
84 | - $intersection = array_intersect( $urls, $configured_urls ); |
|
85 | - if ( ! empty( $intersection ) ) { |
|
86 | - return ! $include_by_default; |
|
87 | - } |
|
88 | - |
|
89 | - return $include_by_default; |
|
90 | - } |
|
91 | - |
|
92 | - public function get_configuration() { |
|
93 | - return $this->configuration; |
|
94 | - } |
|
95 | - |
|
96 | - /** |
|
97 | - * We cant rely on WP_REST_REQUEST constant here since it is loaded after init hook |
|
98 | - * |
|
99 | - * @return bool |
|
100 | - */ |
|
101 | - protected function is_rest_request() { |
|
102 | - if ( empty( $_SERVER['REQUEST_URI'] ) ) { |
|
103 | - // Probably a CLI request. |
|
104 | - return false; |
|
105 | - } |
|
106 | - |
|
107 | - $rest_prefix = trailingslashit( rest_get_url_prefix() ); |
|
108 | - $path = strtok( (string) $_SERVER['REQUEST_URI'], '?' ); // phpcs:ignore |
|
109 | - |
|
110 | - return strpos( $path, $rest_prefix ) !== false; |
|
111 | - } |
|
19 | + /** |
|
20 | + * @var Configuration $configuration |
|
21 | + */ |
|
22 | + private $configuration; |
|
23 | + |
|
24 | + public function __construct( $configuration ) { |
|
25 | + $this->configuration = $configuration; |
|
26 | + } |
|
27 | + |
|
28 | + /** |
|
29 | + * Register hooks. |
|
30 | + */ |
|
31 | + public function register_hooks() { |
|
32 | + add_filter( 'wl_is_enabled', array( $this, 'wl_is_enabled' ) ); |
|
33 | + } |
|
34 | + |
|
35 | + /** |
|
36 | + * Enable/Disable WordLift Plugin. |
|
37 | + * |
|
38 | + * @param $enabled |
|
39 | + * |
|
40 | + * @return bool|mixed |
|
41 | + */ |
|
42 | + public function wl_is_enabled( $enabled ) { |
|
43 | + |
|
44 | + // Always enable wordlift on admin and rest api pages. |
|
45 | + if ( is_admin() || $this->is_rest_request() ) { |
|
46 | + return $enabled; |
|
47 | + } |
|
48 | + |
|
49 | + $path = strtok( (string) $_SERVER['REQUEST_URI'], '?' ); // phpcs:ignore |
|
50 | + $options = get_option( 'wl_exclude_include_urls_settings' ); |
|
51 | + |
|
52 | + // Bail out if URLs are not set. |
|
53 | + if ( empty( $options['urls'] ) ) { |
|
54 | + return $enabled; |
|
55 | + } |
|
56 | + |
|
57 | + $current_url = trailingslashit( home_url( $path ) ); |
|
58 | + |
|
59 | + return $this->are_urls_included( $current_url ); |
|
60 | + } |
|
61 | + |
|
62 | + public function are_urls_included( $urls ) { |
|
63 | + // Ensure we deal with an array. We `trailingslashit` all URLs to avoid issues with missing slashes. |
|
64 | + $urls = array_map( 'trailingslashit', (array) $urls ); |
|
65 | + |
|
66 | + // Set a default state. |
|
67 | + $include_by_default = ( $this->configuration->get_default() === 'include' ); |
|
68 | + |
|
69 | + // Get URLs into an array from settings, trim them and make absolute if needed. |
|
70 | + $configured_urls = array_map( |
|
71 | + function ( $url ) { |
|
72 | + $url = trim( $url ); |
|
73 | + if ( substr( $url, 0, 4 ) !== 'http' ) { |
|
74 | + return trailingslashit( home_url( $url ) ); |
|
75 | + } |
|
76 | + |
|
77 | + // Add a trailing slash and return the url |
|
78 | + return trailingslashit( $url ); |
|
79 | + }, |
|
80 | + explode( PHP_EOL, $this->configuration->get_urls() ) |
|
81 | + ); |
|
82 | + |
|
83 | + // Check if any of the provided URLs is in the configured URLs. |
|
84 | + $intersection = array_intersect( $urls, $configured_urls ); |
|
85 | + if ( ! empty( $intersection ) ) { |
|
86 | + return ! $include_by_default; |
|
87 | + } |
|
88 | + |
|
89 | + return $include_by_default; |
|
90 | + } |
|
91 | + |
|
92 | + public function get_configuration() { |
|
93 | + return $this->configuration; |
|
94 | + } |
|
95 | + |
|
96 | + /** |
|
97 | + * We cant rely on WP_REST_REQUEST constant here since it is loaded after init hook |
|
98 | + * |
|
99 | + * @return bool |
|
100 | + */ |
|
101 | + protected function is_rest_request() { |
|
102 | + if ( empty( $_SERVER['REQUEST_URI'] ) ) { |
|
103 | + // Probably a CLI request. |
|
104 | + return false; |
|
105 | + } |
|
106 | + |
|
107 | + $rest_prefix = trailingslashit( rest_get_url_prefix() ); |
|
108 | + $path = strtok( (string) $_SERVER['REQUEST_URI'], '?' ); // phpcs:ignore |
|
109 | + |
|
110 | + return strpos( $path, $rest_prefix ) !== false; |
|
111 | + } |
|
112 | 112 | |
113 | 113 | } |