class.jetpack-sync-settings.php at 6.1.2 · Jetpack – WP Security, Backup, Speed, & Growth

jetpack / sync / class.jetpack-sync-settings.php

class.jetpack-sync-settings.php

180 lines 5.3 KB

Raw Download Zip

1	<?php
2
3	require_once dirname( __FILE__ ) . '/class.jetpack-sync-defaults.php';
4
5	class Jetpack_Sync_Settings {
6	const SETTINGS_OPTION_PREFIX = 'jetpack_sync_settings_';
7
8	static $valid_settings = array(
9	'dequeue_max_bytes' => true,
10	'upload_max_bytes' => true,
11	'upload_max_rows' => true,
12	'sync_wait_time' => true,
13	'sync_wait_threshold' => true,
14	'enqueue_wait_time' => true,
15	'max_queue_size' => true,
16	'max_queue_lag' => true,
17	'queue_max_writes_sec' => true,
18	'post_types_blacklist' => true,
19	'disable' => true,
20	'render_filtered_content' => true,
21	'post_meta_whitelist' => true,
22	'comment_meta_whitelist' => true,
23	'max_enqueue_full_sync' => true,
24	'max_queue_size_full_sync'=> true,
25	'sync_via_cron' => true,
26	'cron_sync_time_limit' => true,
27	);
28
29	static $is_importing;
30	static $is_doing_cron;
31	static $is_syncing;
32	static $is_sending;
33
34	static $settings_cache = array(); // some settings can be expensive to compute - let's cache them
35
36	static function get_settings() {
37	$settings = array();
38	foreach ( array_keys( self::$valid_settings ) as $setting ) {
39	$settings[ $setting ] = self::get_setting( $setting );
40	}
41
42	return $settings;
43	}
44
45	// Fetches the setting. It saves it if the setting doesn't exist, so that it gets
46	// autoloaded on page load rather than re-queried every time.
47	static function get_setting( $setting ) {
48	if ( ! isset( self::$valid_settings[ $setting ] ) ) {
49	return false;
50	}
51
52	if ( isset( self::$settings_cache[ $setting ] ) ) {
53	return self::$settings_cache[ $setting ];
54	}
55
56	$value = get_option( self::SETTINGS_OPTION_PREFIX . $setting );
57
58	if ( false === $value ) {
59	$default_name = "default_$setting"; // e.g. default_dequeue_max_bytes
60	$value = Jetpack_Sync_Defaults::$$default_name;
61	update_option( self::SETTINGS_OPTION_PREFIX . $setting, $value, true );
62	}
63
64	if ( is_numeric( $value ) ) {
65	$value = intval( $value );
66	}
67	$default_array_value = null;
68	switch( $setting ) {
69	case 'post_types_blacklist':
70	$default_array_value = Jetpack_Sync_Defaults::$blacklisted_post_types;
71	break;
72	case 'post_meta_whitelist':
73	$default_array_value = Jetpack_Sync_Defaults::get_post_meta_whitelist();
74	break;
75	case 'comment_meta_whitelist':
76	$default_array_value = Jetpack_Sync_Defaults::get_comment_meta_whitelist();
77	break;
78	}
79
80	if ( $default_array_value ) {
81	if ( is_array( $value ) ) {
82	$value = array_unique( array_merge( $value, $default_array_value ) );
83	} else {
84	$value = $default_array_value;
85	}
86	}
87
88	self::$settings_cache[ $setting ] = $value;
89
90	return $value;
91	}
92
93	static function update_settings( $new_settings ) {
94	$validated_settings = array_intersect_key( $new_settings, self::$valid_settings );
95	foreach ( $validated_settings as $setting => $value ) {
96	update_option( self::SETTINGS_OPTION_PREFIX . $setting, $value, true );
97	unset( self::$settings_cache[ $setting ] );
98
99	// if we set the disabled option to true, clear the queues
100	if ( 'disable' === $setting && !! $value ) {
101	require_once dirname( __FILE__ ) . '/class.jetpack-sync-listener.php';
102	$listener = Jetpack_Sync_Listener::get_instance();
103	$listener->get_sync_queue()->reset();
104	$listener->get_full_sync_queue()->reset();
105	}
106	}
107	}
108
109	// returns escapted SQL that can be injected into a WHERE clause
110	static function get_blacklisted_post_types_sql() {
111	return 'post_type NOT IN (\'' . join( '\', \'', array_map( 'esc_sql', self::get_setting( 'post_types_blacklist' ) ) ) . '\')';
112	}
113
114	static function get_whitelisted_post_meta_sql() {
115	return 'meta_key IN (\'' . join( '\', \'', array_map( 'esc_sql', self::get_setting( 'post_meta_whitelist' ) ) ) . '\')';
116	}
117
118	static function get_whitelisted_comment_meta_sql() {
119	return 'meta_key IN (\'' . join( '\', \'', array_map( 'esc_sql', self::get_setting( 'comment_meta_whitelist' ) ) ) . '\')';
120	}
121
122	static function get_comments_filter_sql() {
123	return "comment_approved <> 'spam'";
124	}
125
126	static function reset_data() {
127	$valid_settings = self::$valid_settings;
128	self::$settings_cache = array();
129	foreach ( $valid_settings as $option => $value ) {
130	delete_option( self::SETTINGS_OPTION_PREFIX . $option );
131	}
132	self::set_importing( null );
133	self::set_doing_cron( null );
134	self::set_is_syncing( null );
135	self::set_is_sending( null );
136	}
137
138	static function set_importing( $is_importing ) {
139	// set to NULL to revert to WP_IMPORTING, the standard behaviour
140	self::$is_importing = $is_importing;
141	}
142
143	static function is_importing() {
144	if ( ! is_null( self::$is_importing ) ) {
145	return self::$is_importing;
146	}
147
148	return defined( 'WP_IMPORTING' ) && WP_IMPORTING;
149	}
150
151	static function set_doing_cron( $is_doing_cron ) {
152	// set to NULL to revert to WP_IMPORTING, the standard behaviour
153	self::$is_doing_cron = $is_doing_cron;
154	}
155
156	static function is_doing_cron() {
157	if ( ! is_null( self::$is_doing_cron ) ) {
158	return self::$is_doing_cron;
159	}
160
161	return defined( 'DOING_CRON' ) && DOING_CRON;
162	}
163
164	static function is_syncing() {
165	return (bool) self::$is_syncing \|\| ( defined( 'REST_API_REQUEST' ) && REST_API_REQUEST );
166	}
167
168	static function set_is_syncing( $is_syncing ) {
169	self::$is_syncing = $is_syncing;
170	}
171
172	static function is_sending() {
173	return (bool) self::$is_sending;
174	}
175
176	static function set_is_sending( $is_sending ) {
177	self::$is_sending = $is_sending;
178	}
179	}
180