@@ -13,274 +13,274 @@ |
||
13 | 13 | { |
14 | 14 | |
15 | 15 | |
16 | - /** |
|
17 | - * @var string $iframe_name |
|
18 | - */ |
|
19 | - private $iframe_name; |
|
16 | + /** |
|
17 | + * @var string $iframe_name |
|
18 | + */ |
|
19 | + private $iframe_name; |
|
20 | 20 | |
21 | - /** |
|
22 | - * @var string $route_name |
|
23 | - */ |
|
24 | - private $route_name; |
|
21 | + /** |
|
22 | + * @var string $route_name |
|
23 | + */ |
|
24 | + private $route_name; |
|
25 | 25 | |
26 | - /** |
|
27 | - * @var string $slug |
|
28 | - */ |
|
29 | - private $slug; |
|
26 | + /** |
|
27 | + * @var string $slug |
|
28 | + */ |
|
29 | + private $slug; |
|
30 | 30 | |
31 | - /** |
|
32 | - * @var boolean $append_filterable_content |
|
33 | - */ |
|
34 | - private $append_filterable_content; |
|
31 | + /** |
|
32 | + * @var boolean $append_filterable_content |
|
33 | + */ |
|
34 | + private $append_filterable_content; |
|
35 | 35 | |
36 | 36 | |
37 | - /** |
|
38 | - * IframeEmbedButton constructor. |
|
39 | - * |
|
40 | - * @param string $iframe_name i18n name for the iframe. This will be used in HTML |
|
41 | - * @param string $route_name the name of the registered route |
|
42 | - * @param string $slug URL slug used for the thing the iframe button is being embedded in. |
|
43 | - * will most likely be "event" since that's the only usage atm |
|
44 | - */ |
|
45 | - public function __construct($iframe_name, $route_name, $slug = 'event') |
|
46 | - { |
|
47 | - $this->iframe_name = $iframe_name; |
|
48 | - $this->route_name = $route_name; |
|
49 | - $this->slug = $slug; |
|
50 | - } |
|
37 | + /** |
|
38 | + * IframeEmbedButton constructor. |
|
39 | + * |
|
40 | + * @param string $iframe_name i18n name for the iframe. This will be used in HTML |
|
41 | + * @param string $route_name the name of the registered route |
|
42 | + * @param string $slug URL slug used for the thing the iframe button is being embedded in. |
|
43 | + * will most likely be "event" since that's the only usage atm |
|
44 | + */ |
|
45 | + public function __construct($iframe_name, $route_name, $slug = 'event') |
|
46 | + { |
|
47 | + $this->iframe_name = $iframe_name; |
|
48 | + $this->route_name = $route_name; |
|
49 | + $this->slug = $slug; |
|
50 | + } |
|
51 | 51 | |
52 | 52 | |
53 | - /** |
|
54 | - * Adds an iframe embed code button to the Event editor. |
|
55 | - */ |
|
56 | - public function addEventEditorIframeEmbedButtonFilter() |
|
57 | - { |
|
58 | - // add button for iframe code to event editor. |
|
59 | - add_filter( |
|
60 | - 'get_sample_permalink_html', |
|
61 | - array($this, 'appendIframeEmbedButtonToSamplePermalinkHtml'), |
|
62 | - 10, |
|
63 | - 2 |
|
64 | - ); |
|
65 | - add_action( |
|
66 | - 'admin_enqueue_scripts', |
|
67 | - array($this, 'embedButtonAssets'), |
|
68 | - 10 |
|
69 | - ); |
|
70 | - } |
|
53 | + /** |
|
54 | + * Adds an iframe embed code button to the Event editor. |
|
55 | + */ |
|
56 | + public function addEventEditorIframeEmbedButtonFilter() |
|
57 | + { |
|
58 | + // add button for iframe code to event editor. |
|
59 | + add_filter( |
|
60 | + 'get_sample_permalink_html', |
|
61 | + array($this, 'appendIframeEmbedButtonToSamplePermalinkHtml'), |
|
62 | + 10, |
|
63 | + 2 |
|
64 | + ); |
|
65 | + add_action( |
|
66 | + 'admin_enqueue_scripts', |
|
67 | + array($this, 'embedButtonAssets'), |
|
68 | + 10 |
|
69 | + ); |
|
70 | + } |
|
71 | 71 | |
72 | 72 | |
73 | - /** |
|
74 | - * @param $permalink_string |
|
75 | - * @param $id |
|
76 | - * @return string |
|
77 | - */ |
|
78 | - public function appendIframeEmbedButtonToSamplePermalinkHtml($permalink_string, $id) |
|
79 | - { |
|
80 | - return $this->eventEditorIframeEmbedButton( |
|
81 | - $permalink_string, |
|
82 | - $id |
|
83 | - ); |
|
84 | - } |
|
73 | + /** |
|
74 | + * @param $permalink_string |
|
75 | + * @param $id |
|
76 | + * @return string |
|
77 | + */ |
|
78 | + public function appendIframeEmbedButtonToSamplePermalinkHtml($permalink_string, $id) |
|
79 | + { |
|
80 | + return $this->eventEditorIframeEmbedButton( |
|
81 | + $permalink_string, |
|
82 | + $id |
|
83 | + ); |
|
84 | + } |
|
85 | 85 | |
86 | 86 | |
87 | - /** |
|
88 | - * iframe embed code button to the Event editor. |
|
89 | - * |
|
90 | - * @param string $permalink_string |
|
91 | - * @param int $id |
|
92 | - * @return string |
|
93 | - */ |
|
94 | - public function eventEditorIframeEmbedButton( |
|
95 | - $permalink_string, |
|
96 | - $id |
|
97 | - ) { |
|
98 | - // make sure this is ONLY when editing and the event id has been set. |
|
99 | - if (! empty($id)) { |
|
100 | - $post = get_post($id); |
|
101 | - // if NOT event then let's get out. |
|
102 | - if ($post->post_type !== 'espresso_events') { |
|
103 | - return $permalink_string; |
|
104 | - } |
|
105 | - $permalink_string .= $this->embedButtonHtml( |
|
106 | - array($this->slug => $id), |
|
107 | - 'button-small' |
|
108 | - ); |
|
109 | - } |
|
110 | - return $permalink_string; |
|
111 | - } |
|
87 | + /** |
|
88 | + * iframe embed code button to the Event editor. |
|
89 | + * |
|
90 | + * @param string $permalink_string |
|
91 | + * @param int $id |
|
92 | + * @return string |
|
93 | + */ |
|
94 | + public function eventEditorIframeEmbedButton( |
|
95 | + $permalink_string, |
|
96 | + $id |
|
97 | + ) { |
|
98 | + // make sure this is ONLY when editing and the event id has been set. |
|
99 | + if (! empty($id)) { |
|
100 | + $post = get_post($id); |
|
101 | + // if NOT event then let's get out. |
|
102 | + if ($post->post_type !== 'espresso_events') { |
|
103 | + return $permalink_string; |
|
104 | + } |
|
105 | + $permalink_string .= $this->embedButtonHtml( |
|
106 | + array($this->slug => $id), |
|
107 | + 'button-small' |
|
108 | + ); |
|
109 | + } |
|
110 | + return $permalink_string; |
|
111 | + } |
|
112 | 112 | |
113 | 113 | |
114 | - /** |
|
115 | - * Adds an iframe embed code button via a WP do_action() as determined by the first parameter |
|
116 | - * |
|
117 | - * @param string $action name of the WP do_action() to hook into |
|
118 | - */ |
|
119 | - public function addActionIframeEmbedButton($action) |
|
120 | - { |
|
121 | - // add button for iframe code to event editor. |
|
122 | - add_action( |
|
123 | - $action, |
|
124 | - array($this, 'addActionIframeEmbedButtonCallback'), |
|
125 | - 10, |
|
126 | - 2 |
|
127 | - ); |
|
128 | - } |
|
114 | + /** |
|
115 | + * Adds an iframe embed code button via a WP do_action() as determined by the first parameter |
|
116 | + * |
|
117 | + * @param string $action name of the WP do_action() to hook into |
|
118 | + */ |
|
119 | + public function addActionIframeEmbedButton($action) |
|
120 | + { |
|
121 | + // add button for iframe code to event editor. |
|
122 | + add_action( |
|
123 | + $action, |
|
124 | + array($this, 'addActionIframeEmbedButtonCallback'), |
|
125 | + 10, |
|
126 | + 2 |
|
127 | + ); |
|
128 | + } |
|
129 | 129 | |
130 | 130 | |
131 | - /** |
|
132 | - * @return void |
|
133 | - */ |
|
134 | - public function addActionIframeEmbedButtonCallback() |
|
135 | - { |
|
136 | - echo $this->embedButtonHtml(); |
|
137 | - } |
|
131 | + /** |
|
132 | + * @return void |
|
133 | + */ |
|
134 | + public function addActionIframeEmbedButtonCallback() |
|
135 | + { |
|
136 | + echo $this->embedButtonHtml(); |
|
137 | + } |
|
138 | 138 | |
139 | 139 | |
140 | - /** |
|
141 | - * Adds an iframe embed code button via a WP apply_filters() as determined by the first parameter |
|
142 | - * |
|
143 | - * @param string $filter name of the WP apply_filters() to hook into |
|
144 | - * @param bool $append if true, will add iframe embed button to end of content, |
|
145 | - * else if false, will add to the beginning of the content |
|
146 | - */ |
|
147 | - public function addFilterIframeEmbedButton($filter, $append = true) |
|
148 | - { |
|
149 | - $this->append_filterable_content = $append; |
|
150 | - // add button for iframe code to event editor. |
|
151 | - add_filter( |
|
152 | - $filter, |
|
153 | - array($this, 'addFilterIframeEmbedButtonCallback'), |
|
154 | - 10 |
|
155 | - ); |
|
156 | - } |
|
140 | + /** |
|
141 | + * Adds an iframe embed code button via a WP apply_filters() as determined by the first parameter |
|
142 | + * |
|
143 | + * @param string $filter name of the WP apply_filters() to hook into |
|
144 | + * @param bool $append if true, will add iframe embed button to end of content, |
|
145 | + * else if false, will add to the beginning of the content |
|
146 | + */ |
|
147 | + public function addFilterIframeEmbedButton($filter, $append = true) |
|
148 | + { |
|
149 | + $this->append_filterable_content = $append; |
|
150 | + // add button for iframe code to event editor. |
|
151 | + add_filter( |
|
152 | + $filter, |
|
153 | + array($this, 'addFilterIframeEmbedButtonCallback'), |
|
154 | + 10 |
|
155 | + ); |
|
156 | + } |
|
157 | 157 | |
158 | 158 | |
159 | - /** |
|
160 | - * @param array|string $filterable_content |
|
161 | - * @return array|string |
|
162 | - */ |
|
163 | - public function addFilterIframeEmbedButtonCallback($filterable_content) |
|
164 | - { |
|
165 | - $embedButtonHtml = $this->embedButtonHtml(); |
|
166 | - if (is_array($filterable_content)) { |
|
167 | - $filterable_content = $this->append_filterable_content |
|
168 | - ? $filterable_content + array($this->route_name => $embedButtonHtml) |
|
169 | - : array($this->route_name => $embedButtonHtml) + $filterable_content; |
|
170 | - } else { |
|
171 | - $filterable_content = $this->append_filterable_content |
|
172 | - ? $filterable_content . $embedButtonHtml |
|
173 | - : $embedButtonHtml . $filterable_content; |
|
174 | - } |
|
175 | - return $filterable_content; |
|
176 | - } |
|
159 | + /** |
|
160 | + * @param array|string $filterable_content |
|
161 | + * @return array|string |
|
162 | + */ |
|
163 | + public function addFilterIframeEmbedButtonCallback($filterable_content) |
|
164 | + { |
|
165 | + $embedButtonHtml = $this->embedButtonHtml(); |
|
166 | + if (is_array($filterable_content)) { |
|
167 | + $filterable_content = $this->append_filterable_content |
|
168 | + ? $filterable_content + array($this->route_name => $embedButtonHtml) |
|
169 | + : array($this->route_name => $embedButtonHtml) + $filterable_content; |
|
170 | + } else { |
|
171 | + $filterable_content = $this->append_filterable_content |
|
172 | + ? $filterable_content . $embedButtonHtml |
|
173 | + : $embedButtonHtml . $filterable_content; |
|
174 | + } |
|
175 | + return $filterable_content; |
|
176 | + } |
|
177 | 177 | |
178 | 178 | |
179 | - /** |
|
180 | - * iframe_embed_html |
|
181 | - * |
|
182 | - * @param array $query_args |
|
183 | - * @param string $button_class |
|
184 | - * @return string |
|
185 | - */ |
|
186 | - public function embedButtonHtml($query_args = array(), $button_class = '') |
|
187 | - { |
|
188 | - // incoming args will replace the defaults listed here in the second array (union preserves first array) |
|
189 | - $query_args = (array) $query_args + array($this->route_name => 'iframe'); |
|
190 | - $query_args = (array) apply_filters( |
|
191 | - 'FHEE__EventEspresso_core_libraries_iframe_display_IframeEmbedButton__embedButtonHtml__query_args', |
|
192 | - $query_args |
|
193 | - ); |
|
194 | - // add this route to our localized vars |
|
195 | - $iframe_module_routes = isset(\EE_Registry::$i18n_js_strings['iframe_module_routes']) |
|
196 | - ? \EE_Registry::$i18n_js_strings['iframe_module_routes'] |
|
197 | - : array(); |
|
198 | - $iframe_module_routes[ $this->route_name ] = $this->route_name; |
|
199 | - \EE_Registry::$i18n_js_strings['iframe_module_routes'] = $iframe_module_routes; |
|
200 | - $iframe_embed_html = \EEH_HTML::link( |
|
201 | - '#', |
|
202 | - sprintf(esc_html__('Embed %1$s', 'event_espresso'), $this->iframe_name), |
|
203 | - sprintf( |
|
204 | - esc_html__( |
|
205 | - 'click here to generate code for embedding %1$s iframe into another site.', |
|
206 | - 'event_espresso' |
|
207 | - ), |
|
208 | - \EEH_Inflector::add_indefinite_article($this->iframe_name) |
|
209 | - ), |
|
210 | - "{$this->route_name}-iframe-embed-trigger-js", |
|
211 | - 'iframe-embed-trigger-js button ' . $button_class, |
|
212 | - '', |
|
213 | - ' data-iframe_embed_button="#' . $this->route_name . '-iframe-js" tabindex="-1"' |
|
214 | - ); |
|
215 | - $iframe_embed_html .= \EEH_HTML::div( |
|
216 | - '', |
|
217 | - "{$this->route_name}-iframe-js", |
|
218 | - 'iframe-embed-wrapper-js', |
|
219 | - 'display:none;' |
|
220 | - ); |
|
221 | - $iframe_embed_html .= esc_html( |
|
222 | - \EEH_HTML::div( |
|
223 | - '<iframe src="' . add_query_arg($query_args, site_url()) . '" width="100%" height="100%"></iframe>', |
|
224 | - '', |
|
225 | - '', |
|
226 | - 'width:100%; height: 500px;' |
|
227 | - ) |
|
228 | - ); |
|
229 | - $iframe_embed_html .= \EEH_HTML::divx(); |
|
230 | - return $iframe_embed_html; |
|
231 | - } |
|
179 | + /** |
|
180 | + * iframe_embed_html |
|
181 | + * |
|
182 | + * @param array $query_args |
|
183 | + * @param string $button_class |
|
184 | + * @return string |
|
185 | + */ |
|
186 | + public function embedButtonHtml($query_args = array(), $button_class = '') |
|
187 | + { |
|
188 | + // incoming args will replace the defaults listed here in the second array (union preserves first array) |
|
189 | + $query_args = (array) $query_args + array($this->route_name => 'iframe'); |
|
190 | + $query_args = (array) apply_filters( |
|
191 | + 'FHEE__EventEspresso_core_libraries_iframe_display_IframeEmbedButton__embedButtonHtml__query_args', |
|
192 | + $query_args |
|
193 | + ); |
|
194 | + // add this route to our localized vars |
|
195 | + $iframe_module_routes = isset(\EE_Registry::$i18n_js_strings['iframe_module_routes']) |
|
196 | + ? \EE_Registry::$i18n_js_strings['iframe_module_routes'] |
|
197 | + : array(); |
|
198 | + $iframe_module_routes[ $this->route_name ] = $this->route_name; |
|
199 | + \EE_Registry::$i18n_js_strings['iframe_module_routes'] = $iframe_module_routes; |
|
200 | + $iframe_embed_html = \EEH_HTML::link( |
|
201 | + '#', |
|
202 | + sprintf(esc_html__('Embed %1$s', 'event_espresso'), $this->iframe_name), |
|
203 | + sprintf( |
|
204 | + esc_html__( |
|
205 | + 'click here to generate code for embedding %1$s iframe into another site.', |
|
206 | + 'event_espresso' |
|
207 | + ), |
|
208 | + \EEH_Inflector::add_indefinite_article($this->iframe_name) |
|
209 | + ), |
|
210 | + "{$this->route_name}-iframe-embed-trigger-js", |
|
211 | + 'iframe-embed-trigger-js button ' . $button_class, |
|
212 | + '', |
|
213 | + ' data-iframe_embed_button="#' . $this->route_name . '-iframe-js" tabindex="-1"' |
|
214 | + ); |
|
215 | + $iframe_embed_html .= \EEH_HTML::div( |
|
216 | + '', |
|
217 | + "{$this->route_name}-iframe-js", |
|
218 | + 'iframe-embed-wrapper-js', |
|
219 | + 'display:none;' |
|
220 | + ); |
|
221 | + $iframe_embed_html .= esc_html( |
|
222 | + \EEH_HTML::div( |
|
223 | + '<iframe src="' . add_query_arg($query_args, site_url()) . '" width="100%" height="100%"></iframe>', |
|
224 | + '', |
|
225 | + '', |
|
226 | + 'width:100%; height: 500px;' |
|
227 | + ) |
|
228 | + ); |
|
229 | + $iframe_embed_html .= \EEH_HTML::divx(); |
|
230 | + return $iframe_embed_html; |
|
231 | + } |
|
232 | 232 | |
233 | 233 | |
234 | - /** |
|
235 | - * enqueue iframe button js |
|
236 | - */ |
|
237 | - public function embedButtonAssets() |
|
238 | - { |
|
239 | - \EE_Registry::$i18n_js_strings['iframe_embed_title'] = esc_html__( |
|
240 | - 'copy and paste the following into any other site\'s content to display this event:', |
|
241 | - 'event_espresso' |
|
242 | - ); |
|
243 | - \EE_Registry::$i18n_js_strings['iframe_embed_close_msg'] = esc_html__( |
|
244 | - 'click anywhere outside of this window to close it.', |
|
245 | - 'event_espresso' |
|
246 | - ); |
|
247 | - wp_register_script( |
|
248 | - 'iframe_embed_button', |
|
249 | - plugin_dir_url(__FILE__) . 'iframe-embed-button.js', |
|
250 | - array('ee-dialog'), |
|
251 | - EVENT_ESPRESSO_VERSION, |
|
252 | - true |
|
253 | - ); |
|
254 | - wp_enqueue_script('iframe_embed_button'); |
|
255 | - } |
|
234 | + /** |
|
235 | + * enqueue iframe button js |
|
236 | + */ |
|
237 | + public function embedButtonAssets() |
|
238 | + { |
|
239 | + \EE_Registry::$i18n_js_strings['iframe_embed_title'] = esc_html__( |
|
240 | + 'copy and paste the following into any other site\'s content to display this event:', |
|
241 | + 'event_espresso' |
|
242 | + ); |
|
243 | + \EE_Registry::$i18n_js_strings['iframe_embed_close_msg'] = esc_html__( |
|
244 | + 'click anywhere outside of this window to close it.', |
|
245 | + 'event_espresso' |
|
246 | + ); |
|
247 | + wp_register_script( |
|
248 | + 'iframe_embed_button', |
|
249 | + plugin_dir_url(__FILE__) . 'iframe-embed-button.js', |
|
250 | + array('ee-dialog'), |
|
251 | + EVENT_ESPRESSO_VERSION, |
|
252 | + true |
|
253 | + ); |
|
254 | + wp_enqueue_script('iframe_embed_button'); |
|
255 | + } |
|
256 | 256 | |
257 | 257 | |
258 | - /** |
|
259 | - * generates embed button sections for admin pages |
|
260 | - * |
|
261 | - * @param array $embed_buttons |
|
262 | - * @return string |
|
263 | - */ |
|
264 | - public function addIframeEmbedButtonsSection(array $embed_buttons) |
|
265 | - { |
|
266 | - $embed_buttons = (array) apply_filters( |
|
267 | - 'FHEE__EventEspresso_core_libraries_iframe_display_IframeEmbedButton__addIframeEmbedButtonsSection__embed_buttons', |
|
268 | - $embed_buttons |
|
269 | - ); |
|
270 | - if (empty($embed_buttons)) { |
|
271 | - return ''; |
|
272 | - } |
|
273 | - // add button for iframe code to event editor. |
|
274 | - $html = \EEH_HTML::br(2); |
|
275 | - $html .= \EEH_HTML::h3(esc_html__('iFrame Embed Code', 'event_espresso')); |
|
276 | - $html .= \EEH_HTML::p( |
|
277 | - esc_html__( |
|
278 | - 'Click the following button(s) to generate iframe HTML that will allow you to embed your event content within the content of other websites.', |
|
279 | - 'event_espresso' |
|
280 | - ) |
|
281 | - ); |
|
282 | - $html .= ' ' . implode(' ', $embed_buttons) . ' '; |
|
283 | - $html .= \EEH_HTML::br(2); |
|
284 | - return $html; |
|
285 | - } |
|
258 | + /** |
|
259 | + * generates embed button sections for admin pages |
|
260 | + * |
|
261 | + * @param array $embed_buttons |
|
262 | + * @return string |
|
263 | + */ |
|
264 | + public function addIframeEmbedButtonsSection(array $embed_buttons) |
|
265 | + { |
|
266 | + $embed_buttons = (array) apply_filters( |
|
267 | + 'FHEE__EventEspresso_core_libraries_iframe_display_IframeEmbedButton__addIframeEmbedButtonsSection__embed_buttons', |
|
268 | + $embed_buttons |
|
269 | + ); |
|
270 | + if (empty($embed_buttons)) { |
|
271 | + return ''; |
|
272 | + } |
|
273 | + // add button for iframe code to event editor. |
|
274 | + $html = \EEH_HTML::br(2); |
|
275 | + $html .= \EEH_HTML::h3(esc_html__('iFrame Embed Code', 'event_espresso')); |
|
276 | + $html .= \EEH_HTML::p( |
|
277 | + esc_html__( |
|
278 | + 'Click the following button(s) to generate iframe HTML that will allow you to embed your event content within the content of other websites.', |
|
279 | + 'event_espresso' |
|
280 | + ) |
|
281 | + ); |
|
282 | + $html .= ' ' . implode(' ', $embed_buttons) . ' '; |
|
283 | + $html .= \EEH_HTML::br(2); |
|
284 | + return $html; |
|
285 | + } |
|
286 | 286 | } |
@@ -96,7 +96,7 @@ discard block |
||
96 | 96 | $id |
97 | 97 | ) { |
98 | 98 | // make sure this is ONLY when editing and the event id has been set. |
99 | - if (! empty($id)) { |
|
99 | + if ( ! empty($id)) { |
|
100 | 100 | $post = get_post($id); |
101 | 101 | // if NOT event then let's get out. |
102 | 102 | if ($post->post_type !== 'espresso_events') { |
@@ -169,8 +169,8 @@ discard block |
||
169 | 169 | : array($this->route_name => $embedButtonHtml) + $filterable_content; |
170 | 170 | } else { |
171 | 171 | $filterable_content = $this->append_filterable_content |
172 | - ? $filterable_content . $embedButtonHtml |
|
173 | - : $embedButtonHtml . $filterable_content; |
|
172 | + ? $filterable_content.$embedButtonHtml |
|
173 | + : $embedButtonHtml.$filterable_content; |
|
174 | 174 | } |
175 | 175 | return $filterable_content; |
176 | 176 | } |
@@ -195,7 +195,7 @@ discard block |
||
195 | 195 | $iframe_module_routes = isset(\EE_Registry::$i18n_js_strings['iframe_module_routes']) |
196 | 196 | ? \EE_Registry::$i18n_js_strings['iframe_module_routes'] |
197 | 197 | : array(); |
198 | - $iframe_module_routes[ $this->route_name ] = $this->route_name; |
|
198 | + $iframe_module_routes[$this->route_name] = $this->route_name; |
|
199 | 199 | \EE_Registry::$i18n_js_strings['iframe_module_routes'] = $iframe_module_routes; |
200 | 200 | $iframe_embed_html = \EEH_HTML::link( |
201 | 201 | '#', |
@@ -208,9 +208,9 @@ discard block |
||
208 | 208 | \EEH_Inflector::add_indefinite_article($this->iframe_name) |
209 | 209 | ), |
210 | 210 | "{$this->route_name}-iframe-embed-trigger-js", |
211 | - 'iframe-embed-trigger-js button ' . $button_class, |
|
211 | + 'iframe-embed-trigger-js button '.$button_class, |
|
212 | 212 | '', |
213 | - ' data-iframe_embed_button="#' . $this->route_name . '-iframe-js" tabindex="-1"' |
|
213 | + ' data-iframe_embed_button="#'.$this->route_name.'-iframe-js" tabindex="-1"' |
|
214 | 214 | ); |
215 | 215 | $iframe_embed_html .= \EEH_HTML::div( |
216 | 216 | '', |
@@ -220,7 +220,7 @@ discard block |
||
220 | 220 | ); |
221 | 221 | $iframe_embed_html .= esc_html( |
222 | 222 | \EEH_HTML::div( |
223 | - '<iframe src="' . add_query_arg($query_args, site_url()) . '" width="100%" height="100%"></iframe>', |
|
223 | + '<iframe src="'.add_query_arg($query_args, site_url()).'" width="100%" height="100%"></iframe>', |
|
224 | 224 | '', |
225 | 225 | '', |
226 | 226 | 'width:100%; height: 500px;' |
@@ -246,7 +246,7 @@ discard block |
||
246 | 246 | ); |
247 | 247 | wp_register_script( |
248 | 248 | 'iframe_embed_button', |
249 | - plugin_dir_url(__FILE__) . 'iframe-embed-button.js', |
|
249 | + plugin_dir_url(__FILE__).'iframe-embed-button.js', |
|
250 | 250 | array('ee-dialog'), |
251 | 251 | EVENT_ESPRESSO_VERSION, |
252 | 252 | true |
@@ -279,7 +279,7 @@ discard block |
||
279 | 279 | 'event_espresso' |
280 | 280 | ) |
281 | 281 | ); |
282 | - $html .= ' ' . implode(' ', $embed_buttons) . ' '; |
|
282 | + $html .= ' '.implode(' ', $embed_buttons).' '; |
|
283 | 283 | $html .= \EEH_HTML::br(2); |
284 | 284 | return $html; |
285 | 285 | } |
@@ -96,7 +96,7 @@ discard block |
||
96 | 96 | */ |
97 | 97 | protected function setDebugInfo($key, $info) |
98 | 98 | { |
99 | - $this->debug_info[ $key ] = $info; |
|
99 | + $this->debug_info[$key] = $info; |
|
100 | 100 | } |
101 | 101 | |
102 | 102 | |
@@ -113,11 +113,11 @@ discard block |
||
113 | 113 | { |
114 | 114 | if (is_array($value)) { |
115 | 115 | foreach ($value as $value_key => $value_value) { |
116 | - $this->setResponseHeader($header_key . '[' . $value_key . ']', $value_value); |
|
116 | + $this->setResponseHeader($header_key.'['.$value_key.']', $value_value); |
|
117 | 117 | } |
118 | 118 | } else { |
119 | 119 | $prefix = $use_ee_prefix ? Base::HEADER_PREFIX_FOR_EE : Base::HEADER_PREFIX_FOR_WP; |
120 | - $this->response_headers[ $prefix . $header_key ] = $value; |
|
120 | + $this->response_headers[$prefix.$header_key] = $value; |
|
121 | 121 | } |
122 | 122 | } |
123 | 123 | |
@@ -147,7 +147,7 @@ discard block |
||
147 | 147 | protected function addEeErrorsToResponse(WP_Error $wp_error_response) |
148 | 148 | { |
149 | 149 | $notices_during_checkin = EE_Error::get_raw_notices(); |
150 | - if (! empty($notices_during_checkin['errors'])) { |
|
150 | + if ( ! empty($notices_during_checkin['errors'])) { |
|
151 | 151 | foreach ($notices_during_checkin['errors'] as $error_code => $error_message) { |
152 | 152 | $wp_error_response->add( |
153 | 153 | sanitize_key($error_code), |
@@ -190,7 +190,7 @@ discard block |
||
190 | 190 | if (is_array($debug_info)) { |
191 | 191 | $debug_info = wp_json_encode($debug_info); |
192 | 192 | } |
193 | - $headers[ 'X-EE4-Debug-' . ucwords($debug_key) ] = $debug_info; |
|
193 | + $headers['X-EE4-Debug-'.ucwords($debug_key)] = $debug_info; |
|
194 | 194 | } |
195 | 195 | } |
196 | 196 | $headers = array_merge( |
@@ -249,15 +249,15 @@ discard block |
||
249 | 249 | $headers = array(); |
250 | 250 | $notices = EE_Error::get_raw_notices(); |
251 | 251 | foreach ($notices as $notice_type => $sub_notices) { |
252 | - if (! is_array($sub_notices)) { |
|
252 | + if ( ! is_array($sub_notices)) { |
|
253 | 253 | continue; |
254 | 254 | } |
255 | 255 | foreach ($sub_notices as $notice_code => $sub_notice) { |
256 | - $headers[ 'X-EE4-Notices-' |
|
256 | + $headers['X-EE4-Notices-' |
|
257 | 257 | . EEH_Inflector::humanize($notice_type) |
258 | 258 | . '[' |
259 | 259 | . $notice_code |
260 | - . ']' ] = strip_tags($sub_notice); |
|
260 | + . ']'] = strip_tags($sub_notice); |
|
261 | 261 | } |
262 | 262 | } |
263 | 263 | return apply_filters( |
@@ -286,7 +286,7 @@ discard block |
||
286 | 286 | } |
287 | 287 | $matches = $this->parseRoute( |
288 | 288 | $route, |
289 | - '~' . EED_Core_Rest_Api::ee_api_namespace_for_regex . '~', |
|
289 | + '~'.EED_Core_Rest_Api::ee_api_namespace_for_regex.'~', |
|
290 | 290 | array('version') |
291 | 291 | ); |
292 | 292 | if (isset($matches['version'])) { |
@@ -320,14 +320,14 @@ discard block |
||
320 | 320 | if (is_array($matches)) { |
321 | 321 | // skip the overall regex match. Who cares |
322 | 322 | for ($i = 1; $i <= count($match_keys); $i++) { |
323 | - if (! isset($matches[ $i ])) { |
|
323 | + if ( ! isset($matches[$i])) { |
|
324 | 324 | $success = false; |
325 | 325 | } else { |
326 | - $indexed_matches[ $match_keys[ $i - 1 ] ] = $matches[ $i ]; |
|
326 | + $indexed_matches[$match_keys[$i - 1]] = $matches[$i]; |
|
327 | 327 | } |
328 | 328 | } |
329 | 329 | } |
330 | - if (! $success) { |
|
330 | + if ( ! $success) { |
|
331 | 331 | throw new EE_Error( |
332 | 332 | __('We could not parse the URL. Please contact Event Espresso Support', 'event_espresso'), |
333 | 333 | 'endpoint_parsing_error' |
@@ -22,338 +22,338 @@ |
||
22 | 22 | class Base |
23 | 23 | { |
24 | 24 | |
25 | - /** |
|
26 | - * @deprecated use all-caps version |
|
27 | - */ |
|
28 | - // @codingStandardsIgnoreStart |
|
29 | - const header_prefix_for_ee = 'X-EE-'; |
|
30 | - // @codingStandardsIgnoreEnd |
|
31 | - |
|
32 | - const HEADER_PREFIX_FOR_EE = 'X-EE-'; |
|
33 | - |
|
34 | - /** |
|
35 | - * @deprecated use all-caps version instead |
|
36 | - */ |
|
37 | - // @codingStandardsIgnoreStart |
|
38 | - const header_prefix_for_wp = 'X-WP-'; |
|
39 | - // @codingStandardsIgnoreEnd |
|
40 | - |
|
41 | - const HEADER_PREFIX_FOR_WP = 'X-WP-'; |
|
42 | - |
|
43 | - /** |
|
44 | - * Contains debug info we'll send back in the response headers |
|
45 | - * |
|
46 | - * @var array |
|
47 | - */ |
|
48 | - protected $debug_info = array(); |
|
49 | - |
|
50 | - /** |
|
51 | - * Indicates whether or not the API is in debug mode |
|
52 | - * |
|
53 | - * @var boolean |
|
54 | - */ |
|
55 | - protected $debug_mode = false; |
|
56 | - |
|
57 | - /** |
|
58 | - * Indicates the version that was requested |
|
59 | - * |
|
60 | - * @var string |
|
61 | - */ |
|
62 | - protected $requested_version; |
|
63 | - |
|
64 | - /** |
|
65 | - * flat array of headers to send in the response |
|
66 | - * |
|
67 | - * @var array |
|
68 | - */ |
|
69 | - protected $response_headers = array(); |
|
70 | - |
|
71 | - |
|
72 | - public function __construct() |
|
73 | - { |
|
74 | - $this->debug_mode = EED_Core_Rest_Api::debugMode(); |
|
75 | - // we are handling a REST request. Don't show a fancy HTML error message is any error comes up |
|
76 | - add_filter('FHEE__EE_Error__get_error__show_normal_exceptions', '__return_true'); |
|
77 | - } |
|
78 | - |
|
79 | - |
|
80 | - /** |
|
81 | - * Sets the version the user requested |
|
82 | - * |
|
83 | - * @param string $version eg '4.8' |
|
84 | - */ |
|
85 | - public function setRequestedVersion($version) |
|
86 | - { |
|
87 | - $this->requested_version = $version; |
|
88 | - } |
|
89 | - |
|
90 | - |
|
91 | - /** |
|
92 | - * Sets some debug info that we'll send back in headers |
|
93 | - * |
|
94 | - * @param string $key |
|
95 | - * @param string|array $info |
|
96 | - */ |
|
97 | - protected function setDebugInfo($key, $info) |
|
98 | - { |
|
99 | - $this->debug_info[ $key ] = $info; |
|
100 | - } |
|
101 | - |
|
102 | - |
|
103 | - /** |
|
104 | - * Sets headers for the response |
|
105 | - * |
|
106 | - * @param string $header_key , excluding the "X-EE-" part |
|
107 | - * @param array|string $value if an array, multiple headers will be added, one |
|
108 | - * for each key in the array |
|
109 | - * @param boolean $use_ee_prefix whether to use the EE prefix on the header, or fallback to |
|
110 | - * the standard WP one |
|
111 | - */ |
|
112 | - protected function setResponseHeader($header_key, $value, $use_ee_prefix = true) |
|
113 | - { |
|
114 | - if (is_array($value)) { |
|
115 | - foreach ($value as $value_key => $value_value) { |
|
116 | - $this->setResponseHeader($header_key . '[' . $value_key . ']', $value_value); |
|
117 | - } |
|
118 | - } else { |
|
119 | - $prefix = $use_ee_prefix ? Base::HEADER_PREFIX_FOR_EE : Base::HEADER_PREFIX_FOR_WP; |
|
120 | - $this->response_headers[ $prefix . $header_key ] = $value; |
|
121 | - } |
|
122 | - } |
|
123 | - |
|
124 | - |
|
125 | - /** |
|
126 | - * Returns a flat array of headers to be added to the response |
|
127 | - * |
|
128 | - * @return array |
|
129 | - */ |
|
130 | - protected function getResponseHeaders() |
|
131 | - { |
|
132 | - return apply_filters( |
|
133 | - 'FHEE__EventEspresso\core\libraries\rest_api\controllers\Base___get_response_headers', |
|
134 | - $this->response_headers, |
|
135 | - $this, |
|
136 | - $this->requested_version |
|
137 | - ); |
|
138 | - } |
|
139 | - |
|
140 | - |
|
141 | - /** |
|
142 | - * Adds error notices from EE_Error onto the provided \WP_Error |
|
143 | - * |
|
144 | - * @param WP_Error $wp_error_response |
|
145 | - * @return WP_Error |
|
146 | - */ |
|
147 | - protected function addEeErrorsToResponse(WP_Error $wp_error_response) |
|
148 | - { |
|
149 | - $notices_during_checkin = EE_Error::get_raw_notices(); |
|
150 | - if (! empty($notices_during_checkin['errors'])) { |
|
151 | - foreach ($notices_during_checkin['errors'] as $error_code => $error_message) { |
|
152 | - $wp_error_response->add( |
|
153 | - sanitize_key($error_code), |
|
154 | - strip_tags($error_message) |
|
155 | - ); |
|
156 | - } |
|
157 | - } |
|
158 | - return $wp_error_response; |
|
159 | - } |
|
160 | - |
|
161 | - |
|
162 | - /** |
|
163 | - * Sends a response, but also makes sure to attach headers that |
|
164 | - * are handy for debugging. |
|
165 | - * Specifically, we assume folks will want to know what exactly was the DB query that got run, |
|
166 | - * what exactly was the Models query that got run, what capabilities came into play, what fields were omitted from |
|
167 | - * the response, others? |
|
168 | - * |
|
169 | - * @param array|WP_Error|Exception|RestException $response |
|
170 | - * @return WP_REST_Response |
|
171 | - */ |
|
172 | - public function sendResponse($response) |
|
173 | - { |
|
174 | - if ($response instanceof RestException) { |
|
175 | - $response = new WP_Error($response->getStringCode(), $response->getMessage(), $response->getData()); |
|
176 | - } |
|
177 | - if ($response instanceof Exception) { |
|
178 | - $code = $response->getCode() ? $response->getCode() : 'error_occurred'; |
|
179 | - $response = new WP_Error($code, $response->getMessage()); |
|
180 | - } |
|
181 | - if ($response instanceof WP_Error) { |
|
182 | - $response = $this->addEeErrorsToResponse($response); |
|
183 | - $rest_response = $this->createRestResponseFromWpError($response); |
|
184 | - } else { |
|
185 | - $rest_response = new WP_REST_Response($response, 200); |
|
186 | - } |
|
187 | - $headers = array(); |
|
188 | - if ($this->debug_mode && is_array($this->debug_info)) { |
|
189 | - foreach ($this->debug_info as $debug_key => $debug_info) { |
|
190 | - if (is_array($debug_info)) { |
|
191 | - $debug_info = wp_json_encode($debug_info); |
|
192 | - } |
|
193 | - $headers[ 'X-EE4-Debug-' . ucwords($debug_key) ] = $debug_info; |
|
194 | - } |
|
195 | - } |
|
196 | - $headers = array_merge( |
|
197 | - $headers, |
|
198 | - $this->getResponseHeaders(), |
|
199 | - $this->getHeadersFromEeNotices() |
|
200 | - ); |
|
201 | - $rest_response->set_headers($headers); |
|
202 | - return $rest_response; |
|
203 | - } |
|
204 | - |
|
205 | - |
|
206 | - /** |
|
207 | - * Converts the \WP_Error into `WP_REST_Response. |
|
208 | - * Mostly this is just a copy-and-paste from \WP_REST_Server::error_to_response |
|
209 | - * (which is protected) |
|
210 | - * |
|
211 | - * @param WP_Error $wp_error |
|
212 | - * @return WP_REST_Response |
|
213 | - */ |
|
214 | - protected function createRestResponseFromWpError(WP_Error $wp_error) |
|
215 | - { |
|
216 | - $error_data = $wp_error->get_error_data(); |
|
217 | - if (is_array($error_data) && isset($error_data['status'])) { |
|
218 | - $status = $error_data['status']; |
|
219 | - } else { |
|
220 | - $status = 500; |
|
221 | - } |
|
222 | - $errors = array(); |
|
223 | - foreach ((array) $wp_error->errors as $code => $messages) { |
|
224 | - foreach ((array) $messages as $message) { |
|
225 | - $errors[] = array( |
|
226 | - 'code' => $code, |
|
227 | - 'message' => $message, |
|
228 | - 'data' => $wp_error->get_error_data($code), |
|
229 | - ); |
|
230 | - } |
|
231 | - } |
|
232 | - $data = isset($errors[0]) ? $errors[0] : array(); |
|
233 | - if (count($errors) > 1) { |
|
234 | - // Remove the primary error. |
|
235 | - array_shift($errors); |
|
236 | - $data['additional_errors'] = $errors; |
|
237 | - } |
|
238 | - return new WP_REST_Response($data, $status); |
|
239 | - } |
|
240 | - |
|
241 | - |
|
242 | - /** |
|
243 | - * Array of headers derived from EE success, attention, and error messages |
|
244 | - * |
|
245 | - * @return array |
|
246 | - */ |
|
247 | - protected function getHeadersFromEeNotices() |
|
248 | - { |
|
249 | - $headers = array(); |
|
250 | - $notices = EE_Error::get_raw_notices(); |
|
251 | - foreach ($notices as $notice_type => $sub_notices) { |
|
252 | - if (! is_array($sub_notices)) { |
|
253 | - continue; |
|
254 | - } |
|
255 | - foreach ($sub_notices as $notice_code => $sub_notice) { |
|
256 | - $headers[ 'X-EE4-Notices-' |
|
257 | - . EEH_Inflector::humanize($notice_type) |
|
258 | - . '[' |
|
259 | - . $notice_code |
|
260 | - . ']' ] = strip_tags($sub_notice); |
|
261 | - } |
|
262 | - } |
|
263 | - return apply_filters( |
|
264 | - 'FHEE__EventEspresso\core\libraries\rest_api\controllers\Base___get_headers_from_ee_notices__return', |
|
265 | - $headers, |
|
266 | - $this->requested_version, |
|
267 | - $notices |
|
268 | - ); |
|
269 | - } |
|
270 | - |
|
271 | - |
|
272 | - /** |
|
273 | - * Finds which version of the API was requested given the route, and returns it. |
|
274 | - * eg in a request to "mysite.com/wp-json/ee/v4.8.29/events/123" this would return |
|
275 | - * "4.8.29". |
|
276 | - * We should know hte requested version in this model though, so if no route is |
|
277 | - * provided just use what we set earlier |
|
278 | - * |
|
279 | - * @param string $route |
|
280 | - * @return string |
|
281 | - */ |
|
282 | - public function getRequestedVersion($route = null) |
|
283 | - { |
|
284 | - if ($route === null) { |
|
285 | - return $this->requested_version; |
|
286 | - } |
|
287 | - $matches = $this->parseRoute( |
|
288 | - $route, |
|
289 | - '~' . EED_Core_Rest_Api::ee_api_namespace_for_regex . '~', |
|
290 | - array('version') |
|
291 | - ); |
|
292 | - if (isset($matches['version'])) { |
|
293 | - return $matches['version']; |
|
294 | - } else { |
|
295 | - return EED_Core_Rest_Api::latest_rest_api_version(); |
|
296 | - } |
|
297 | - } |
|
298 | - |
|
299 | - |
|
300 | - /** |
|
301 | - * Applies the regex to the route, then creates an array using the values of |
|
302 | - * $match_keys as keys (but ignores the full pattern match). Returns the array of matches. |
|
303 | - * For example, if you call |
|
304 | - * parse_route( '/ee/v4.8/events', '~\/ee\/v([^/]*)\/(.*)~', array( 'version', 'model' ) ) |
|
305 | - * it will return array( 'version' => '4.8', 'model' => 'events' ) |
|
306 | - * |
|
307 | - * @param string $route |
|
308 | - * @param string $regex |
|
309 | - * @param array $match_keys EXCLUDING matching the entire regex |
|
310 | - * @return array where $match_keys are the keys (the first value of $match_keys |
|
311 | - * becomes the first key of the return value, etc. Eg passing in $match_keys of |
|
312 | - * array( 'model', 'id' ), will, if the regex is successful, will return |
|
313 | - * array( 'model' => 'foo', 'id' => 'bar' ) |
|
314 | - * @throws EE_Error if it couldn't be parsed |
|
315 | - */ |
|
316 | - public function parseRoute($route, $regex, $match_keys) |
|
317 | - { |
|
318 | - $indexed_matches = array(); |
|
319 | - $success = preg_match($regex, $route, $matches); |
|
320 | - if (is_array($matches)) { |
|
321 | - // skip the overall regex match. Who cares |
|
322 | - for ($i = 1; $i <= count($match_keys); $i++) { |
|
323 | - if (! isset($matches[ $i ])) { |
|
324 | - $success = false; |
|
325 | - } else { |
|
326 | - $indexed_matches[ $match_keys[ $i - 1 ] ] = $matches[ $i ]; |
|
327 | - } |
|
328 | - } |
|
329 | - } |
|
330 | - if (! $success) { |
|
331 | - throw new EE_Error( |
|
332 | - __('We could not parse the URL. Please contact Event Espresso Support', 'event_espresso'), |
|
333 | - 'endpoint_parsing_error' |
|
334 | - ); |
|
335 | - } |
|
336 | - return $indexed_matches; |
|
337 | - } |
|
338 | - |
|
339 | - |
|
340 | - /** |
|
341 | - * Gets the body's params (either from JSON or parsed body), which EXCLUDES the GET params and URL params |
|
342 | - * |
|
343 | - * @param \WP_REST_Request $request |
|
344 | - * @return array |
|
345 | - */ |
|
346 | - protected function getBodyParams(\WP_REST_Request $request) |
|
347 | - { |
|
348 | - // $request->get_params(); |
|
349 | - return array_merge( |
|
350 | - (array) $request->get_body_params(), |
|
351 | - (array) $request->get_json_params() |
|
352 | - ); |
|
353 | - // return array_diff_key( |
|
354 | - // $request->get_params(), |
|
355 | - // $request->get_url_params(), |
|
356 | - // $request->get_query_params() |
|
357 | - // ); |
|
358 | - } |
|
25 | + /** |
|
26 | + * @deprecated use all-caps version |
|
27 | + */ |
|
28 | + // @codingStandardsIgnoreStart |
|
29 | + const header_prefix_for_ee = 'X-EE-'; |
|
30 | + // @codingStandardsIgnoreEnd |
|
31 | + |
|
32 | + const HEADER_PREFIX_FOR_EE = 'X-EE-'; |
|
33 | + |
|
34 | + /** |
|
35 | + * @deprecated use all-caps version instead |
|
36 | + */ |
|
37 | + // @codingStandardsIgnoreStart |
|
38 | + const header_prefix_for_wp = 'X-WP-'; |
|
39 | + // @codingStandardsIgnoreEnd |
|
40 | + |
|
41 | + const HEADER_PREFIX_FOR_WP = 'X-WP-'; |
|
42 | + |
|
43 | + /** |
|
44 | + * Contains debug info we'll send back in the response headers |
|
45 | + * |
|
46 | + * @var array |
|
47 | + */ |
|
48 | + protected $debug_info = array(); |
|
49 | + |
|
50 | + /** |
|
51 | + * Indicates whether or not the API is in debug mode |
|
52 | + * |
|
53 | + * @var boolean |
|
54 | + */ |
|
55 | + protected $debug_mode = false; |
|
56 | + |
|
57 | + /** |
|
58 | + * Indicates the version that was requested |
|
59 | + * |
|
60 | + * @var string |
|
61 | + */ |
|
62 | + protected $requested_version; |
|
63 | + |
|
64 | + /** |
|
65 | + * flat array of headers to send in the response |
|
66 | + * |
|
67 | + * @var array |
|
68 | + */ |
|
69 | + protected $response_headers = array(); |
|
70 | + |
|
71 | + |
|
72 | + public function __construct() |
|
73 | + { |
|
74 | + $this->debug_mode = EED_Core_Rest_Api::debugMode(); |
|
75 | + // we are handling a REST request. Don't show a fancy HTML error message is any error comes up |
|
76 | + add_filter('FHEE__EE_Error__get_error__show_normal_exceptions', '__return_true'); |
|
77 | + } |
|
78 | + |
|
79 | + |
|
80 | + /** |
|
81 | + * Sets the version the user requested |
|
82 | + * |
|
83 | + * @param string $version eg '4.8' |
|
84 | + */ |
|
85 | + public function setRequestedVersion($version) |
|
86 | + { |
|
87 | + $this->requested_version = $version; |
|
88 | + } |
|
89 | + |
|
90 | + |
|
91 | + /** |
|
92 | + * Sets some debug info that we'll send back in headers |
|
93 | + * |
|
94 | + * @param string $key |
|
95 | + * @param string|array $info |
|
96 | + */ |
|
97 | + protected function setDebugInfo($key, $info) |
|
98 | + { |
|
99 | + $this->debug_info[ $key ] = $info; |
|
100 | + } |
|
101 | + |
|
102 | + |
|
103 | + /** |
|
104 | + * Sets headers for the response |
|
105 | + * |
|
106 | + * @param string $header_key , excluding the "X-EE-" part |
|
107 | + * @param array|string $value if an array, multiple headers will be added, one |
|
108 | + * for each key in the array |
|
109 | + * @param boolean $use_ee_prefix whether to use the EE prefix on the header, or fallback to |
|
110 | + * the standard WP one |
|
111 | + */ |
|
112 | + protected function setResponseHeader($header_key, $value, $use_ee_prefix = true) |
|
113 | + { |
|
114 | + if (is_array($value)) { |
|
115 | + foreach ($value as $value_key => $value_value) { |
|
116 | + $this->setResponseHeader($header_key . '[' . $value_key . ']', $value_value); |
|
117 | + } |
|
118 | + } else { |
|
119 | + $prefix = $use_ee_prefix ? Base::HEADER_PREFIX_FOR_EE : Base::HEADER_PREFIX_FOR_WP; |
|
120 | + $this->response_headers[ $prefix . $header_key ] = $value; |
|
121 | + } |
|
122 | + } |
|
123 | + |
|
124 | + |
|
125 | + /** |
|
126 | + * Returns a flat array of headers to be added to the response |
|
127 | + * |
|
128 | + * @return array |
|
129 | + */ |
|
130 | + protected function getResponseHeaders() |
|
131 | + { |
|
132 | + return apply_filters( |
|
133 | + 'FHEE__EventEspresso\core\libraries\rest_api\controllers\Base___get_response_headers', |
|
134 | + $this->response_headers, |
|
135 | + $this, |
|
136 | + $this->requested_version |
|
137 | + ); |
|
138 | + } |
|
139 | + |
|
140 | + |
|
141 | + /** |
|
142 | + * Adds error notices from EE_Error onto the provided \WP_Error |
|
143 | + * |
|
144 | + * @param WP_Error $wp_error_response |
|
145 | + * @return WP_Error |
|
146 | + */ |
|
147 | + protected function addEeErrorsToResponse(WP_Error $wp_error_response) |
|
148 | + { |
|
149 | + $notices_during_checkin = EE_Error::get_raw_notices(); |
|
150 | + if (! empty($notices_during_checkin['errors'])) { |
|
151 | + foreach ($notices_during_checkin['errors'] as $error_code => $error_message) { |
|
152 | + $wp_error_response->add( |
|
153 | + sanitize_key($error_code), |
|
154 | + strip_tags($error_message) |
|
155 | + ); |
|
156 | + } |
|
157 | + } |
|
158 | + return $wp_error_response; |
|
159 | + } |
|
160 | + |
|
161 | + |
|
162 | + /** |
|
163 | + * Sends a response, but also makes sure to attach headers that |
|
164 | + * are handy for debugging. |
|
165 | + * Specifically, we assume folks will want to know what exactly was the DB query that got run, |
|
166 | + * what exactly was the Models query that got run, what capabilities came into play, what fields were omitted from |
|
167 | + * the response, others? |
|
168 | + * |
|
169 | + * @param array|WP_Error|Exception|RestException $response |
|
170 | + * @return WP_REST_Response |
|
171 | + */ |
|
172 | + public function sendResponse($response) |
|
173 | + { |
|
174 | + if ($response instanceof RestException) { |
|
175 | + $response = new WP_Error($response->getStringCode(), $response->getMessage(), $response->getData()); |
|
176 | + } |
|
177 | + if ($response instanceof Exception) { |
|
178 | + $code = $response->getCode() ? $response->getCode() : 'error_occurred'; |
|
179 | + $response = new WP_Error($code, $response->getMessage()); |
|
180 | + } |
|
181 | + if ($response instanceof WP_Error) { |
|
182 | + $response = $this->addEeErrorsToResponse($response); |
|
183 | + $rest_response = $this->createRestResponseFromWpError($response); |
|
184 | + } else { |
|
185 | + $rest_response = new WP_REST_Response($response, 200); |
|
186 | + } |
|
187 | + $headers = array(); |
|
188 | + if ($this->debug_mode && is_array($this->debug_info)) { |
|
189 | + foreach ($this->debug_info as $debug_key => $debug_info) { |
|
190 | + if (is_array($debug_info)) { |
|
191 | + $debug_info = wp_json_encode($debug_info); |
|
192 | + } |
|
193 | + $headers[ 'X-EE4-Debug-' . ucwords($debug_key) ] = $debug_info; |
|
194 | + } |
|
195 | + } |
|
196 | + $headers = array_merge( |
|
197 | + $headers, |
|
198 | + $this->getResponseHeaders(), |
|
199 | + $this->getHeadersFromEeNotices() |
|
200 | + ); |
|
201 | + $rest_response->set_headers($headers); |
|
202 | + return $rest_response; |
|
203 | + } |
|
204 | + |
|
205 | + |
|
206 | + /** |
|
207 | + * Converts the \WP_Error into `WP_REST_Response. |
|
208 | + * Mostly this is just a copy-and-paste from \WP_REST_Server::error_to_response |
|
209 | + * (which is protected) |
|
210 | + * |
|
211 | + * @param WP_Error $wp_error |
|
212 | + * @return WP_REST_Response |
|
213 | + */ |
|
214 | + protected function createRestResponseFromWpError(WP_Error $wp_error) |
|
215 | + { |
|
216 | + $error_data = $wp_error->get_error_data(); |
|
217 | + if (is_array($error_data) && isset($error_data['status'])) { |
|
218 | + $status = $error_data['status']; |
|
219 | + } else { |
|
220 | + $status = 500; |
|
221 | + } |
|
222 | + $errors = array(); |
|
223 | + foreach ((array) $wp_error->errors as $code => $messages) { |
|
224 | + foreach ((array) $messages as $message) { |
|
225 | + $errors[] = array( |
|
226 | + 'code' => $code, |
|
227 | + 'message' => $message, |
|
228 | + 'data' => $wp_error->get_error_data($code), |
|
229 | + ); |
|
230 | + } |
|
231 | + } |
|
232 | + $data = isset($errors[0]) ? $errors[0] : array(); |
|
233 | + if (count($errors) > 1) { |
|
234 | + // Remove the primary error. |
|
235 | + array_shift($errors); |
|
236 | + $data['additional_errors'] = $errors; |
|
237 | + } |
|
238 | + return new WP_REST_Response($data, $status); |
|
239 | + } |
|
240 | + |
|
241 | + |
|
242 | + /** |
|
243 | + * Array of headers derived from EE success, attention, and error messages |
|
244 | + * |
|
245 | + * @return array |
|
246 | + */ |
|
247 | + protected function getHeadersFromEeNotices() |
|
248 | + { |
|
249 | + $headers = array(); |
|
250 | + $notices = EE_Error::get_raw_notices(); |
|
251 | + foreach ($notices as $notice_type => $sub_notices) { |
|
252 | + if (! is_array($sub_notices)) { |
|
253 | + continue; |
|
254 | + } |
|
255 | + foreach ($sub_notices as $notice_code => $sub_notice) { |
|
256 | + $headers[ 'X-EE4-Notices-' |
|
257 | + . EEH_Inflector::humanize($notice_type) |
|
258 | + . '[' |
|
259 | + . $notice_code |
|
260 | + . ']' ] = strip_tags($sub_notice); |
|
261 | + } |
|
262 | + } |
|
263 | + return apply_filters( |
|
264 | + 'FHEE__EventEspresso\core\libraries\rest_api\controllers\Base___get_headers_from_ee_notices__return', |
|
265 | + $headers, |
|
266 | + $this->requested_version, |
|
267 | + $notices |
|
268 | + ); |
|
269 | + } |
|
270 | + |
|
271 | + |
|
272 | + /** |
|
273 | + * Finds which version of the API was requested given the route, and returns it. |
|
274 | + * eg in a request to "mysite.com/wp-json/ee/v4.8.29/events/123" this would return |
|
275 | + * "4.8.29". |
|
276 | + * We should know hte requested version in this model though, so if no route is |
|
277 | + * provided just use what we set earlier |
|
278 | + * |
|
279 | + * @param string $route |
|
280 | + * @return string |
|
281 | + */ |
|
282 | + public function getRequestedVersion($route = null) |
|
283 | + { |
|
284 | + if ($route === null) { |
|
285 | + return $this->requested_version; |
|
286 | + } |
|
287 | + $matches = $this->parseRoute( |
|
288 | + $route, |
|
289 | + '~' . EED_Core_Rest_Api::ee_api_namespace_for_regex . '~', |
|
290 | + array('version') |
|
291 | + ); |
|
292 | + if (isset($matches['version'])) { |
|
293 | + return $matches['version']; |
|
294 | + } else { |
|
295 | + return EED_Core_Rest_Api::latest_rest_api_version(); |
|
296 | + } |
|
297 | + } |
|
298 | + |
|
299 | + |
|
300 | + /** |
|
301 | + * Applies the regex to the route, then creates an array using the values of |
|
302 | + * $match_keys as keys (but ignores the full pattern match). Returns the array of matches. |
|
303 | + * For example, if you call |
|
304 | + * parse_route( '/ee/v4.8/events', '~\/ee\/v([^/]*)\/(.*)~', array( 'version', 'model' ) ) |
|
305 | + * it will return array( 'version' => '4.8', 'model' => 'events' ) |
|
306 | + * |
|
307 | + * @param string $route |
|
308 | + * @param string $regex |
|
309 | + * @param array $match_keys EXCLUDING matching the entire regex |
|
310 | + * @return array where $match_keys are the keys (the first value of $match_keys |
|
311 | + * becomes the first key of the return value, etc. Eg passing in $match_keys of |
|
312 | + * array( 'model', 'id' ), will, if the regex is successful, will return |
|
313 | + * array( 'model' => 'foo', 'id' => 'bar' ) |
|
314 | + * @throws EE_Error if it couldn't be parsed |
|
315 | + */ |
|
316 | + public function parseRoute($route, $regex, $match_keys) |
|
317 | + { |
|
318 | + $indexed_matches = array(); |
|
319 | + $success = preg_match($regex, $route, $matches); |
|
320 | + if (is_array($matches)) { |
|
321 | + // skip the overall regex match. Who cares |
|
322 | + for ($i = 1; $i <= count($match_keys); $i++) { |
|
323 | + if (! isset($matches[ $i ])) { |
|
324 | + $success = false; |
|
325 | + } else { |
|
326 | + $indexed_matches[ $match_keys[ $i - 1 ] ] = $matches[ $i ]; |
|
327 | + } |
|
328 | + } |
|
329 | + } |
|
330 | + if (! $success) { |
|
331 | + throw new EE_Error( |
|
332 | + __('We could not parse the URL. Please contact Event Espresso Support', 'event_espresso'), |
|
333 | + 'endpoint_parsing_error' |
|
334 | + ); |
|
335 | + } |
|
336 | + return $indexed_matches; |
|
337 | + } |
|
338 | + |
|
339 | + |
|
340 | + /** |
|
341 | + * Gets the body's params (either from JSON or parsed body), which EXCLUDES the GET params and URL params |
|
342 | + * |
|
343 | + * @param \WP_REST_Request $request |
|
344 | + * @return array |
|
345 | + */ |
|
346 | + protected function getBodyParams(\WP_REST_Request $request) |
|
347 | + { |
|
348 | + // $request->get_params(); |
|
349 | + return array_merge( |
|
350 | + (array) $request->get_body_params(), |
|
351 | + (array) $request->get_json_params() |
|
352 | + ); |
|
353 | + // return array_diff_key( |
|
354 | + // $request->get_params(), |
|
355 | + // $request->get_url_params(), |
|
356 | + // $request->get_query_params() |
|
357 | + // ); |
|
358 | + } |
|
359 | 359 | } |
@@ -20,85 +20,85 @@ |
||
20 | 20 | class Read |
21 | 21 | { |
22 | 22 | |
23 | - /** |
|
24 | - * @param WP_REST_Request $request |
|
25 | - * @param string $version |
|
26 | - * @return EE_Config|WP_Error |
|
27 | - */ |
|
28 | - public static function handleRequest(WP_REST_Request $request, $version) |
|
29 | - { |
|
30 | - $cap = EE_Restriction_Generator_Base::get_default_restrictions_cap(); |
|
31 | - if (EE_Capabilities::instance()->current_user_can($cap, 'read_over_api')) { |
|
32 | - return EE_Config::instance(); |
|
33 | - } else { |
|
34 | - return new WP_Error( |
|
35 | - 'cannot_read_config', |
|
36 | - sprintf( |
|
37 | - __( |
|
38 | - 'You do not have the necessary capabilities (%s) to read Event Espresso Configuration data', |
|
39 | - 'event_espresso' |
|
40 | - ), |
|
41 | - $cap |
|
42 | - ), |
|
43 | - array('status' => 403) |
|
44 | - ); |
|
45 | - } |
|
46 | - } |
|
23 | + /** |
|
24 | + * @param WP_REST_Request $request |
|
25 | + * @param string $version |
|
26 | + * @return EE_Config|WP_Error |
|
27 | + */ |
|
28 | + public static function handleRequest(WP_REST_Request $request, $version) |
|
29 | + { |
|
30 | + $cap = EE_Restriction_Generator_Base::get_default_restrictions_cap(); |
|
31 | + if (EE_Capabilities::instance()->current_user_can($cap, 'read_over_api')) { |
|
32 | + return EE_Config::instance(); |
|
33 | + } else { |
|
34 | + return new WP_Error( |
|
35 | + 'cannot_read_config', |
|
36 | + sprintf( |
|
37 | + __( |
|
38 | + 'You do not have the necessary capabilities (%s) to read Event Espresso Configuration data', |
|
39 | + 'event_espresso' |
|
40 | + ), |
|
41 | + $cap |
|
42 | + ), |
|
43 | + array('status' => 403) |
|
44 | + ); |
|
45 | + } |
|
46 | + } |
|
47 | 47 | |
48 | 48 | |
49 | - /** |
|
50 | - * Handles the request for public site info |
|
51 | - * |
|
52 | - * @global $wp_json_basic_auth_success boolean set by the basic auth plugin, indicates if the |
|
53 | - * current user could be authenticated using basic auth |
|
54 | - * data |
|
55 | - * @global $wp_json_basic_auth_received_data boolean set by the basic auth plugin, indicates if |
|
56 | - * basic auth data was somehow received |
|
57 | - * @param WP_REST_Request $request |
|
58 | - * @param string $version |
|
59 | - * @return array|WP_Error |
|
60 | - */ |
|
61 | - public static function handleRequestSiteInfo(WP_REST_Request $request, $version) |
|
62 | - { |
|
63 | - global $wp_json_basic_auth_success, $wp_json_basic_auth_received_data; |
|
64 | - $insecure_usage_of_basic_auth = apply_filters( |
|
65 | - // @codingStandardsIgnoreStart |
|
66 | - 'EventEspresso__core__libraries__rest_api__controllers__config__handle_request_site_info__insecure_usage_of_basic_auth', |
|
67 | - // @codingStandardsIgnoreEnd |
|
68 | - $wp_json_basic_auth_success && ! is_ssl(), |
|
69 | - $request |
|
70 | - ); |
|
71 | - if ($insecure_usage_of_basic_auth) { |
|
72 | - $warning = sprintf( |
|
73 | - esc_html__( |
|
74 | - // @codingStandardsIgnoreStart |
|
75 | - 'Notice: We strongly recommend installing an SSL Certificate on your website to keep your data secure. %1$sPlease see our recommendations.%2$s', |
|
76 | - // @codingStandardsIgnoreEnd |
|
77 | - 'event_espresso' |
|
78 | - ), |
|
79 | - '<a href="https://eventespresso.com/wiki/rest-api-security-recommendations/">', |
|
80 | - '</a>' |
|
81 | - ); |
|
82 | - } else { |
|
83 | - $warning = ''; |
|
84 | - } |
|
85 | - return apply_filters( |
|
86 | - 'FHEE__EventEspresso_core_libraries_rest_api_controllers_config__handleRequestSiteInfo__return_val', |
|
87 | - array( |
|
88 | - 'default_timezone' => array( |
|
89 | - 'pretty' => EEH_DTT_Helper::get_timezone_string_for_display(), |
|
90 | - 'string' => get_option('timezone_string'), |
|
91 | - 'offset' => EEH_DTT_Helper::get_site_timezone_gmt_offset(), |
|
92 | - ), |
|
93 | - 'default_currency' => EE_Config::instance()->currency, |
|
94 | - 'authentication' => array( |
|
95 | - 'received_basic_auth_data' => (bool) $wp_json_basic_auth_received_data, |
|
96 | - 'insecure_usage_of_basic_auth' => (bool) $insecure_usage_of_basic_auth, |
|
97 | - 'warning' => $warning, |
|
98 | - ), |
|
99 | - ) |
|
100 | - ); |
|
101 | - } |
|
49 | + /** |
|
50 | + * Handles the request for public site info |
|
51 | + * |
|
52 | + * @global $wp_json_basic_auth_success boolean set by the basic auth plugin, indicates if the |
|
53 | + * current user could be authenticated using basic auth |
|
54 | + * data |
|
55 | + * @global $wp_json_basic_auth_received_data boolean set by the basic auth plugin, indicates if |
|
56 | + * basic auth data was somehow received |
|
57 | + * @param WP_REST_Request $request |
|
58 | + * @param string $version |
|
59 | + * @return array|WP_Error |
|
60 | + */ |
|
61 | + public static function handleRequestSiteInfo(WP_REST_Request $request, $version) |
|
62 | + { |
|
63 | + global $wp_json_basic_auth_success, $wp_json_basic_auth_received_data; |
|
64 | + $insecure_usage_of_basic_auth = apply_filters( |
|
65 | + // @codingStandardsIgnoreStart |
|
66 | + 'EventEspresso__core__libraries__rest_api__controllers__config__handle_request_site_info__insecure_usage_of_basic_auth', |
|
67 | + // @codingStandardsIgnoreEnd |
|
68 | + $wp_json_basic_auth_success && ! is_ssl(), |
|
69 | + $request |
|
70 | + ); |
|
71 | + if ($insecure_usage_of_basic_auth) { |
|
72 | + $warning = sprintf( |
|
73 | + esc_html__( |
|
74 | + // @codingStandardsIgnoreStart |
|
75 | + 'Notice: We strongly recommend installing an SSL Certificate on your website to keep your data secure. %1$sPlease see our recommendations.%2$s', |
|
76 | + // @codingStandardsIgnoreEnd |
|
77 | + 'event_espresso' |
|
78 | + ), |
|
79 | + '<a href="https://eventespresso.com/wiki/rest-api-security-recommendations/">', |
|
80 | + '</a>' |
|
81 | + ); |
|
82 | + } else { |
|
83 | + $warning = ''; |
|
84 | + } |
|
85 | + return apply_filters( |
|
86 | + 'FHEE__EventEspresso_core_libraries_rest_api_controllers_config__handleRequestSiteInfo__return_val', |
|
87 | + array( |
|
88 | + 'default_timezone' => array( |
|
89 | + 'pretty' => EEH_DTT_Helper::get_timezone_string_for_display(), |
|
90 | + 'string' => get_option('timezone_string'), |
|
91 | + 'offset' => EEH_DTT_Helper::get_site_timezone_gmt_offset(), |
|
92 | + ), |
|
93 | + 'default_currency' => EE_Config::instance()->currency, |
|
94 | + 'authentication' => array( |
|
95 | + 'received_basic_auth_data' => (bool) $wp_json_basic_auth_received_data, |
|
96 | + 'insecure_usage_of_basic_auth' => (bool) $insecure_usage_of_basic_auth, |
|
97 | + 'warning' => $warning, |
|
98 | + ), |
|
99 | + ) |
|
100 | + ); |
|
101 | + } |
|
102 | 102 | } |
103 | 103 | |
104 | 104 | // End of file Read.php |
@@ -35,74 +35,74 @@ |
||
35 | 35 | abstract class ChangesInBase |
36 | 36 | { |
37 | 37 | |
38 | - /** |
|
39 | - * The version that these changes happened |
|
40 | - * |
|
41 | - * @var string |
|
42 | - */ |
|
43 | - protected $version = null; |
|
38 | + /** |
|
39 | + * The version that these changes happened |
|
40 | + * |
|
41 | + * @var string |
|
42 | + */ |
|
43 | + protected $version = null; |
|
44 | 44 | |
45 | 45 | |
46 | - /** |
|
47 | - * Called when an EE4 REST API request is made to an earlier version than |
|
48 | - * what is indicated in this class' name. |
|
49 | - * Uses WordPress' add_filter and add_action to modify the EE4 REST API's response |
|
50 | - * so that regardless of what version of EE4 core is running, API clients |
|
51 | - * will have a consistent response |
|
52 | - * |
|
53 | - * @return void |
|
54 | - */ |
|
55 | - abstract public function setHooks(); |
|
46 | + /** |
|
47 | + * Called when an EE4 REST API request is made to an earlier version than |
|
48 | + * what is indicated in this class' name. |
|
49 | + * Uses WordPress' add_filter and add_action to modify the EE4 REST API's response |
|
50 | + * so that regardless of what version of EE4 core is running, API clients |
|
51 | + * will have a consistent response |
|
52 | + * |
|
53 | + * @return void |
|
54 | + */ |
|
55 | + abstract public function setHooks(); |
|
56 | 56 | |
57 | 57 | |
58 | - /** |
|
59 | - * Returns whether or not this class' name indicates its hooks should |
|
60 | - * apply when a request comes in for $requested_version. A class can use |
|
61 | - * other conditions when determining whether to perform their callbacks or not, |
|
62 | - * but this will typically be enough |
|
63 | - * |
|
64 | - * @param string $requested_version eg "4.8.33" |
|
65 | - * @return boolean true: this class' name indicates its filters and actions |
|
66 | - * should take effect. False: this class' name indicates it shouldn't do anything |
|
67 | - */ |
|
68 | - public function appliesToVersion($requested_version) |
|
69 | - { |
|
70 | - if ($this->version() > $requested_version) { |
|
71 | - return true; |
|
72 | - } |
|
73 | - return false; |
|
74 | - } |
|
58 | + /** |
|
59 | + * Returns whether or not this class' name indicates its hooks should |
|
60 | + * apply when a request comes in for $requested_version. A class can use |
|
61 | + * other conditions when determining whether to perform their callbacks or not, |
|
62 | + * but this will typically be enough |
|
63 | + * |
|
64 | + * @param string $requested_version eg "4.8.33" |
|
65 | + * @return boolean true: this class' name indicates its filters and actions |
|
66 | + * should take effect. False: this class' name indicates it shouldn't do anything |
|
67 | + */ |
|
68 | + public function appliesToVersion($requested_version) |
|
69 | + { |
|
70 | + if ($this->version() > $requested_version) { |
|
71 | + return true; |
|
72 | + } |
|
73 | + return false; |
|
74 | + } |
|
75 | 75 | |
76 | 76 | |
77 | - /** |
|
78 | - * Gets the EE core version when this changes were made to the rest api. |
|
79 | - * Any requests to earlier versions should have modifications made to them |
|
80 | - * by the callbacks of this class. |
|
81 | - * |
|
82 | - * @return string eg "4.8.33" |
|
83 | - * @throws EE_Error |
|
84 | - */ |
|
85 | - public function version() |
|
86 | - { |
|
87 | - if ($this->version === null) { |
|
88 | - $matches = array(); |
|
89 | - $regex = '~ChangesIn(\d)(\d\d)(\d\d)$~'; |
|
90 | - $success = preg_match( |
|
91 | - $regex, |
|
92 | - get_class($this), |
|
93 | - $matches |
|
94 | - ); |
|
95 | - if (! $success) { |
|
96 | - throw new EE_Error( |
|
97 | - sprintf( |
|
98 | - __('The class %1$s was misnamed. It name should match the regex "%2$s"', 'event_espresso'), |
|
99 | - get_class($this), |
|
100 | - $regex |
|
101 | - ) |
|
102 | - ); |
|
103 | - } |
|
104 | - $this->version = (int) $matches[1] . '.' . (int) $matches[2] . '.' . (int) $matches[3]; |
|
105 | - } |
|
106 | - return $this->version; |
|
107 | - } |
|
77 | + /** |
|
78 | + * Gets the EE core version when this changes were made to the rest api. |
|
79 | + * Any requests to earlier versions should have modifications made to them |
|
80 | + * by the callbacks of this class. |
|
81 | + * |
|
82 | + * @return string eg "4.8.33" |
|
83 | + * @throws EE_Error |
|
84 | + */ |
|
85 | + public function version() |
|
86 | + { |
|
87 | + if ($this->version === null) { |
|
88 | + $matches = array(); |
|
89 | + $regex = '~ChangesIn(\d)(\d\d)(\d\d)$~'; |
|
90 | + $success = preg_match( |
|
91 | + $regex, |
|
92 | + get_class($this), |
|
93 | + $matches |
|
94 | + ); |
|
95 | + if (! $success) { |
|
96 | + throw new EE_Error( |
|
97 | + sprintf( |
|
98 | + __('The class %1$s was misnamed. It name should match the regex "%2$s"', 'event_espresso'), |
|
99 | + get_class($this), |
|
100 | + $regex |
|
101 | + ) |
|
102 | + ); |
|
103 | + } |
|
104 | + $this->version = (int) $matches[1] . '.' . (int) $matches[2] . '.' . (int) $matches[3]; |
|
105 | + } |
|
106 | + return $this->version; |
|
107 | + } |
|
108 | 108 | } |
@@ -92,7 +92,7 @@ discard block |
||
92 | 92 | get_class($this), |
93 | 93 | $matches |
94 | 94 | ); |
95 | - if (! $success) { |
|
95 | + if ( ! $success) { |
|
96 | 96 | throw new EE_Error( |
97 | 97 | sprintf( |
98 | 98 | __('The class %1$s was misnamed. It name should match the regex "%2$s"', 'event_espresso'), |
@@ -101,7 +101,7 @@ discard block |
||
101 | 101 | ) |
102 | 102 | ); |
103 | 103 | } |
104 | - $this->version = (int) $matches[1] . '.' . (int) $matches[2] . '.' . (int) $matches[3]; |
|
104 | + $this->version = (int) $matches[1].'.'.(int) $matches[2].'.'.(int) $matches[3]; |
|
105 | 105 | } |
106 | 106 | return $this->version; |
107 | 107 | } |
@@ -119,9 +119,9 @@ discard block |
||
119 | 119 | $headers, |
120 | 120 | array_flip( |
121 | 121 | array( |
122 | - Base::HEADER_PREFIX_FOR_WP . 'Total', |
|
123 | - Base::HEADER_PREFIX_FOR_WP . 'TotalPages', |
|
124 | - Base::HEADER_PREFIX_FOR_WP . 'PageSize', |
|
122 | + Base::HEADER_PREFIX_FOR_WP.'Total', |
|
123 | + Base::HEADER_PREFIX_FOR_WP.'TotalPages', |
|
124 | + Base::HEADER_PREFIX_FOR_WP.'PageSize', |
|
125 | 125 | ) |
126 | 126 | ) |
127 | 127 | ); |
@@ -151,7 +151,7 @@ discard block |
||
151 | 151 | && $model instanceof \EEM_CPT_Base |
152 | 152 | ) { |
153 | 153 | $attachment = wp_get_attachment_image_src( |
154 | - get_post_thumbnail_id($entity_response_array[ $model->primary_key_name() ]), |
|
154 | + get_post_thumbnail_id($entity_response_array[$model->primary_key_name()]), |
|
155 | 155 | 'full' |
156 | 156 | ); |
157 | 157 | $entity_response_array['featured_image_url'] = ! empty($attachment) ? $attachment[0] : null; |
@@ -16,176 +16,176 @@ |
||
16 | 16 | class ChangesIn40836 extends ChangesInBase |
17 | 17 | { |
18 | 18 | |
19 | - /** |
|
20 | - * Adds hooks so requests to 4.8.29 don't have the checkin endpoints |
|
21 | - */ |
|
22 | - public function setHooks() |
|
23 | - { |
|
24 | - // set a hook to remove the "calculate" query param |
|
25 | - add_filter( |
|
26 | - 'FHEE__EED_Core_Rest_Api___get_response_selection_query_params', |
|
27 | - array($this, 'removeCalculateQueryParam'), |
|
28 | - 10, |
|
29 | - 3 |
|
30 | - ); |
|
31 | - // don't add the _calculated_fields either |
|
32 | - add_filter( |
|
33 | - 'FHEE__Read__create_entity_from_wpdb_results__entity_before_inaccessible_field_removal', |
|
34 | - array($this, 'removeCalculatedFieldsFromResponse'), |
|
35 | - 10, |
|
36 | - 5 |
|
37 | - ); |
|
38 | - // and also don't add the count headers |
|
39 | - add_filter( |
|
40 | - 'FHEE__EventEspresso\core\libraries\rest_api\controllers\Base___get_response_headers', |
|
41 | - array($this, 'removeHeadersNewInThisVersion'), |
|
42 | - 10, |
|
43 | - 3 |
|
44 | - ); |
|
45 | - // remove the old featured_image part of the response... |
|
46 | - add_filter( |
|
47 | - 'FHEE__Read__create_entity_from_wpdb_results__entity_before_including_requested_models', |
|
48 | - array($this, 'addOldFeaturedImagePartOfCptEntities'), |
|
49 | - 10, |
|
50 | - 5 |
|
51 | - ); |
|
52 | - // assuming ticket 9425's change gets pushed with 9406, we don't need to |
|
53 | - // remove it from the calculated fields on older requests (because this will |
|
54 | - // be the first version with calculated fields) |
|
55 | - // before this, infinity was -1, now it's null |
|
56 | - add_filter( |
|
57 | - 'FHEE__EventEspresso\core\libraries\rest_api\Model_Data_Translator__prepare_field_for_rest_api', |
|
58 | - array($this, 'useNegativeOneForInfinityBeforeThisVersion'), |
|
59 | - 10, |
|
60 | - 4 |
|
61 | - ); |
|
62 | - } |
|
19 | + /** |
|
20 | + * Adds hooks so requests to 4.8.29 don't have the checkin endpoints |
|
21 | + */ |
|
22 | + public function setHooks() |
|
23 | + { |
|
24 | + // set a hook to remove the "calculate" query param |
|
25 | + add_filter( |
|
26 | + 'FHEE__EED_Core_Rest_Api___get_response_selection_query_params', |
|
27 | + array($this, 'removeCalculateQueryParam'), |
|
28 | + 10, |
|
29 | + 3 |
|
30 | + ); |
|
31 | + // don't add the _calculated_fields either |
|
32 | + add_filter( |
|
33 | + 'FHEE__Read__create_entity_from_wpdb_results__entity_before_inaccessible_field_removal', |
|
34 | + array($this, 'removeCalculatedFieldsFromResponse'), |
|
35 | + 10, |
|
36 | + 5 |
|
37 | + ); |
|
38 | + // and also don't add the count headers |
|
39 | + add_filter( |
|
40 | + 'FHEE__EventEspresso\core\libraries\rest_api\controllers\Base___get_response_headers', |
|
41 | + array($this, 'removeHeadersNewInThisVersion'), |
|
42 | + 10, |
|
43 | + 3 |
|
44 | + ); |
|
45 | + // remove the old featured_image part of the response... |
|
46 | + add_filter( |
|
47 | + 'FHEE__Read__create_entity_from_wpdb_results__entity_before_including_requested_models', |
|
48 | + array($this, 'addOldFeaturedImagePartOfCptEntities'), |
|
49 | + 10, |
|
50 | + 5 |
|
51 | + ); |
|
52 | + // assuming ticket 9425's change gets pushed with 9406, we don't need to |
|
53 | + // remove it from the calculated fields on older requests (because this will |
|
54 | + // be the first version with calculated fields) |
|
55 | + // before this, infinity was -1, now it's null |
|
56 | + add_filter( |
|
57 | + 'FHEE__EventEspresso\core\libraries\rest_api\Model_Data_Translator__prepare_field_for_rest_api', |
|
58 | + array($this, 'useNegativeOneForInfinityBeforeThisVersion'), |
|
59 | + 10, |
|
60 | + 4 |
|
61 | + ); |
|
62 | + } |
|
63 | 63 | |
64 | 64 | |
65 | - /** |
|
66 | - * Don't show "calculate" as an query param option in the index |
|
67 | - * |
|
68 | - * @param array $query_params |
|
69 | - * @param EEM_Base $model |
|
70 | - * @param string $version |
|
71 | - * @return array |
|
72 | - */ |
|
73 | - public function removeCalculateQueryParam($query_params, EEM_Base $model, $version) |
|
74 | - { |
|
75 | - if ($this->appliesToVersion($version)) { |
|
76 | - unset($query_params['calculate']); |
|
77 | - } |
|
78 | - return $query_params; |
|
79 | - } |
|
65 | + /** |
|
66 | + * Don't show "calculate" as an query param option in the index |
|
67 | + * |
|
68 | + * @param array $query_params |
|
69 | + * @param EEM_Base $model |
|
70 | + * @param string $version |
|
71 | + * @return array |
|
72 | + */ |
|
73 | + public function removeCalculateQueryParam($query_params, EEM_Base $model, $version) |
|
74 | + { |
|
75 | + if ($this->appliesToVersion($version)) { |
|
76 | + unset($query_params['calculate']); |
|
77 | + } |
|
78 | + return $query_params; |
|
79 | + } |
|
80 | 80 | |
81 | 81 | |
82 | - /** |
|
83 | - * Removes the "_calculate_fields" part of entity responses before 4.8.36 |
|
84 | - * |
|
85 | - * @param array $entity_response_array |
|
86 | - * @param EEM_Base $model |
|
87 | - * @param string $request_context |
|
88 | - * @param WP_REST_Request $request |
|
89 | - * @param Read $controller |
|
90 | - * @return array |
|
91 | - */ |
|
92 | - public function removeCalculatedFieldsFromResponse( |
|
93 | - $entity_response_array, |
|
94 | - EEM_Base $model, |
|
95 | - $request_context, |
|
96 | - WP_REST_Request $request, |
|
97 | - Read $controller |
|
98 | - ) { |
|
99 | - if ($this->appliesToVersion($controller->getModelVersionInfo()->requestedVersion())) { |
|
100 | - unset($entity_response_array['_calculated_fields']); |
|
101 | - } |
|
102 | - return $entity_response_array; |
|
103 | - } |
|
82 | + /** |
|
83 | + * Removes the "_calculate_fields" part of entity responses before 4.8.36 |
|
84 | + * |
|
85 | + * @param array $entity_response_array |
|
86 | + * @param EEM_Base $model |
|
87 | + * @param string $request_context |
|
88 | + * @param WP_REST_Request $request |
|
89 | + * @param Read $controller |
|
90 | + * @return array |
|
91 | + */ |
|
92 | + public function removeCalculatedFieldsFromResponse( |
|
93 | + $entity_response_array, |
|
94 | + EEM_Base $model, |
|
95 | + $request_context, |
|
96 | + WP_REST_Request $request, |
|
97 | + Read $controller |
|
98 | + ) { |
|
99 | + if ($this->appliesToVersion($controller->getModelVersionInfo()->requestedVersion())) { |
|
100 | + unset($entity_response_array['_calculated_fields']); |
|
101 | + } |
|
102 | + return $entity_response_array; |
|
103 | + } |
|
104 | 104 | |
105 | 105 | |
106 | - /** |
|
107 | - * Removes the new headers for requests before 4.8.36 |
|
108 | - * |
|
109 | - * @param array $headers |
|
110 | - * @param Controller_Base $controller |
|
111 | - * @param string $version |
|
112 | - * @return array |
|
113 | - */ |
|
114 | - public function removeHeadersNewInThisVersion( |
|
115 | - $headers, |
|
116 | - Controller_Base $controller, |
|
117 | - $version |
|
118 | - ) { |
|
119 | - if ($this->appliesToVersion($version)) { |
|
120 | - $headers = array_diff_key( |
|
121 | - $headers, |
|
122 | - array_flip( |
|
123 | - array( |
|
124 | - Base::HEADER_PREFIX_FOR_WP . 'Total', |
|
125 | - Base::HEADER_PREFIX_FOR_WP . 'TotalPages', |
|
126 | - Base::HEADER_PREFIX_FOR_WP . 'PageSize', |
|
127 | - ) |
|
128 | - ) |
|
129 | - ); |
|
130 | - } |
|
131 | - return $headers; |
|
132 | - } |
|
106 | + /** |
|
107 | + * Removes the new headers for requests before 4.8.36 |
|
108 | + * |
|
109 | + * @param array $headers |
|
110 | + * @param Controller_Base $controller |
|
111 | + * @param string $version |
|
112 | + * @return array |
|
113 | + */ |
|
114 | + public function removeHeadersNewInThisVersion( |
|
115 | + $headers, |
|
116 | + Controller_Base $controller, |
|
117 | + $version |
|
118 | + ) { |
|
119 | + if ($this->appliesToVersion($version)) { |
|
120 | + $headers = array_diff_key( |
|
121 | + $headers, |
|
122 | + array_flip( |
|
123 | + array( |
|
124 | + Base::HEADER_PREFIX_FOR_WP . 'Total', |
|
125 | + Base::HEADER_PREFIX_FOR_WP . 'TotalPages', |
|
126 | + Base::HEADER_PREFIX_FOR_WP . 'PageSize', |
|
127 | + ) |
|
128 | + ) |
|
129 | + ); |
|
130 | + } |
|
131 | + return $headers; |
|
132 | + } |
|
133 | 133 | |
134 | 134 | |
135 | - /** |
|
136 | - * Puts the 'featured_image_url' back in for responses before 4.8.36. |
|
137 | - * |
|
138 | - * @param array $entity_response_array |
|
139 | - * @param EEM_Base $model |
|
140 | - * @param string $request_context |
|
141 | - * @param WP_REST_Request $request |
|
142 | - * @param Read $controller |
|
143 | - * @return array |
|
144 | - */ |
|
145 | - public function addOldFeaturedImagePartOfCptEntities( |
|
146 | - $entity_response_array, |
|
147 | - EEM_Base $model, |
|
148 | - $request_context, |
|
149 | - WP_REST_Request $request, |
|
150 | - Read $controller |
|
151 | - ) { |
|
152 | - if ( |
|
153 | - $this->appliesToVersion($controller->getModelVersionInfo()->requestedVersion()) |
|
154 | - && $model instanceof \EEM_CPT_Base |
|
155 | - ) { |
|
156 | - $attachment = wp_get_attachment_image_src( |
|
157 | - get_post_thumbnail_id($entity_response_array[ $model->primary_key_name() ]), |
|
158 | - 'full' |
|
159 | - ); |
|
160 | - $entity_response_array['featured_image_url'] = ! empty($attachment) ? $attachment[0] : null; |
|
161 | - } |
|
162 | - return $entity_response_array; |
|
163 | - } |
|
135 | + /** |
|
136 | + * Puts the 'featured_image_url' back in for responses before 4.8.36. |
|
137 | + * |
|
138 | + * @param array $entity_response_array |
|
139 | + * @param EEM_Base $model |
|
140 | + * @param string $request_context |
|
141 | + * @param WP_REST_Request $request |
|
142 | + * @param Read $controller |
|
143 | + * @return array |
|
144 | + */ |
|
145 | + public function addOldFeaturedImagePartOfCptEntities( |
|
146 | + $entity_response_array, |
|
147 | + EEM_Base $model, |
|
148 | + $request_context, |
|
149 | + WP_REST_Request $request, |
|
150 | + Read $controller |
|
151 | + ) { |
|
152 | + if ( |
|
153 | + $this->appliesToVersion($controller->getModelVersionInfo()->requestedVersion()) |
|
154 | + && $model instanceof \EEM_CPT_Base |
|
155 | + ) { |
|
156 | + $attachment = wp_get_attachment_image_src( |
|
157 | + get_post_thumbnail_id($entity_response_array[ $model->primary_key_name() ]), |
|
158 | + 'full' |
|
159 | + ); |
|
160 | + $entity_response_array['featured_image_url'] = ! empty($attachment) ? $attachment[0] : null; |
|
161 | + } |
|
162 | + return $entity_response_array; |
|
163 | + } |
|
164 | 164 | |
165 | 165 | |
166 | - /** |
|
167 | - * If the value was infinity, we now use null in our JSON responses, |
|
168 | - * but before this version we used -1. |
|
169 | - * |
|
170 | - * @param mixed $new_value |
|
171 | - * @param \EE_Model_Field_Base $field_obj |
|
172 | - * @param mixed $original_value |
|
173 | - * @param string $requested_value |
|
174 | - * @return mixed |
|
175 | - */ |
|
176 | - public function useNegativeOneForInfinityBeforeThisVersion( |
|
177 | - $new_value, |
|
178 | - $field_obj, |
|
179 | - $original_value, |
|
180 | - $requested_value |
|
181 | - ) { |
|
182 | - if ( |
|
183 | - $this->appliesToVersion($requested_value) |
|
184 | - && $original_value === EE_INF |
|
185 | - ) { |
|
186 | - // return the old representation of infinity in the JSON |
|
187 | - return -1; |
|
188 | - } |
|
189 | - return $new_value; |
|
190 | - } |
|
166 | + /** |
|
167 | + * If the value was infinity, we now use null in our JSON responses, |
|
168 | + * but before this version we used -1. |
|
169 | + * |
|
170 | + * @param mixed $new_value |
|
171 | + * @param \EE_Model_Field_Base $field_obj |
|
172 | + * @param mixed $original_value |
|
173 | + * @param string $requested_value |
|
174 | + * @return mixed |
|
175 | + */ |
|
176 | + public function useNegativeOneForInfinityBeforeThisVersion( |
|
177 | + $new_value, |
|
178 | + $field_obj, |
|
179 | + $original_value, |
|
180 | + $requested_value |
|
181 | + ) { |
|
182 | + if ( |
|
183 | + $this->appliesToVersion($requested_value) |
|
184 | + && $original_value === EE_INF |
|
185 | + ) { |
|
186 | + // return the old representation of infinity in the JSON |
|
187 | + return -1; |
|
188 | + } |
|
189 | + return $new_value; |
|
190 | + } |
|
191 | 191 | } |
@@ -19,106 +19,106 @@ |
||
19 | 19 | class AttendeesReport extends JobHandlerFile |
20 | 20 | { |
21 | 21 | |
22 | - // phpcs:disable PSR1.Methods.CamelCapsMethodName.NotCamelCaps |
|
23 | - public function create_job(JobParameters $job_parameters) |
|
24 | - { |
|
25 | - if (! \EE_Capabilities::instance()->current_user_can('ee_read_contacts', 'generating_report')) { |
|
26 | - throw new BatchRequestException( |
|
27 | - __('You do not have permission to view contacts', 'event_espresso') |
|
28 | - ); |
|
29 | - } |
|
30 | - $filepath = $this->create_file_from_job_with_name( |
|
31 | - $job_parameters->job_id(), |
|
32 | - __('contact-list-report.csv', 'event_espresso') |
|
33 | - ); |
|
34 | - $job_parameters->add_extra_data('filepath', $filepath); |
|
35 | - $job_parameters->set_job_size($this->count_units_to_process()); |
|
36 | - // we should also set the header columns |
|
37 | - $csv_data_for_row = $this->get_csv_data(0, 1); |
|
38 | - \EEH_Export::write_data_array_to_csv($filepath, $csv_data_for_row, true); |
|
39 | - // if we actually processed a row there, record it |
|
40 | - if ($job_parameters->job_size()) { |
|
41 | - $job_parameters->mark_processed(1); |
|
42 | - } |
|
43 | - return new JobStepResponse( |
|
44 | - $job_parameters, |
|
45 | - __('Contacts report started successfully...', 'event_espresso') |
|
46 | - ); |
|
47 | - } |
|
22 | + // phpcs:disable PSR1.Methods.CamelCapsMethodName.NotCamelCaps |
|
23 | + public function create_job(JobParameters $job_parameters) |
|
24 | + { |
|
25 | + if (! \EE_Capabilities::instance()->current_user_can('ee_read_contacts', 'generating_report')) { |
|
26 | + throw new BatchRequestException( |
|
27 | + __('You do not have permission to view contacts', 'event_espresso') |
|
28 | + ); |
|
29 | + } |
|
30 | + $filepath = $this->create_file_from_job_with_name( |
|
31 | + $job_parameters->job_id(), |
|
32 | + __('contact-list-report.csv', 'event_espresso') |
|
33 | + ); |
|
34 | + $job_parameters->add_extra_data('filepath', $filepath); |
|
35 | + $job_parameters->set_job_size($this->count_units_to_process()); |
|
36 | + // we should also set the header columns |
|
37 | + $csv_data_for_row = $this->get_csv_data(0, 1); |
|
38 | + \EEH_Export::write_data_array_to_csv($filepath, $csv_data_for_row, true); |
|
39 | + // if we actually processed a row there, record it |
|
40 | + if ($job_parameters->job_size()) { |
|
41 | + $job_parameters->mark_processed(1); |
|
42 | + } |
|
43 | + return new JobStepResponse( |
|
44 | + $job_parameters, |
|
45 | + __('Contacts report started successfully...', 'event_espresso') |
|
46 | + ); |
|
47 | + } |
|
48 | 48 | |
49 | 49 | |
50 | - public function continue_job(JobParameters $job_parameters, $batch_size = 50) |
|
51 | - { |
|
52 | - $csv_data = $this->get_csv_data($job_parameters->units_processed(), $batch_size); |
|
53 | - \EEH_Export::write_data_array_to_csv( |
|
54 | - $job_parameters->extra_datum('filepath'), |
|
55 | - $csv_data, |
|
56 | - false |
|
57 | - ); |
|
58 | - $units_processed = count($csv_data); |
|
59 | - $job_parameters->mark_processed($units_processed); |
|
60 | - $extra_response_data = array( |
|
61 | - 'file_url' => '', |
|
62 | - ); |
|
63 | - if ($units_processed < $batch_size) { |
|
64 | - $job_parameters->set_status(JobParameters::status_complete); |
|
65 | - $extra_response_data['file_url'] = $this->get_url_to_file($job_parameters->extra_datum('filepath')); |
|
66 | - } |
|
67 | - return new JobStepResponse( |
|
68 | - $job_parameters, |
|
69 | - sprintf( |
|
70 | - __('Wrote %1$s rows to report CSV file...', 'event_espresso'), |
|
71 | - count($csv_data) |
|
72 | - ), |
|
73 | - $extra_response_data |
|
74 | - ); |
|
75 | - } |
|
50 | + public function continue_job(JobParameters $job_parameters, $batch_size = 50) |
|
51 | + { |
|
52 | + $csv_data = $this->get_csv_data($job_parameters->units_processed(), $batch_size); |
|
53 | + \EEH_Export::write_data_array_to_csv( |
|
54 | + $job_parameters->extra_datum('filepath'), |
|
55 | + $csv_data, |
|
56 | + false |
|
57 | + ); |
|
58 | + $units_processed = count($csv_data); |
|
59 | + $job_parameters->mark_processed($units_processed); |
|
60 | + $extra_response_data = array( |
|
61 | + 'file_url' => '', |
|
62 | + ); |
|
63 | + if ($units_processed < $batch_size) { |
|
64 | + $job_parameters->set_status(JobParameters::status_complete); |
|
65 | + $extra_response_data['file_url'] = $this->get_url_to_file($job_parameters->extra_datum('filepath')); |
|
66 | + } |
|
67 | + return new JobStepResponse( |
|
68 | + $job_parameters, |
|
69 | + sprintf( |
|
70 | + __('Wrote %1$s rows to report CSV file...', 'event_espresso'), |
|
71 | + count($csv_data) |
|
72 | + ), |
|
73 | + $extra_response_data |
|
74 | + ); |
|
75 | + } |
|
76 | 76 | |
77 | 77 | |
78 | - public function cleanup_job(JobParameters $job_parameters) |
|
79 | - { |
|
80 | - $this->_file_helper->delete( |
|
81 | - \EEH_File::remove_filename_from_filepath($job_parameters->extra_datum('filepath')), |
|
82 | - true, |
|
83 | - 'd' |
|
84 | - ); |
|
85 | - return new JobStepResponse($job_parameters, __('Cleaned up temporary file', 'event_espresso')); |
|
86 | - } |
|
78 | + public function cleanup_job(JobParameters $job_parameters) |
|
79 | + { |
|
80 | + $this->_file_helper->delete( |
|
81 | + \EEH_File::remove_filename_from_filepath($job_parameters->extra_datum('filepath')), |
|
82 | + true, |
|
83 | + 'd' |
|
84 | + ); |
|
85 | + return new JobStepResponse($job_parameters, __('Cleaned up temporary file', 'event_espresso')); |
|
86 | + } |
|
87 | 87 | |
88 | - public function count_units_to_process() |
|
89 | - { |
|
90 | - return \EEM_Attendee::instance()->count(array('caps' => \EEM_Base::caps_read_admin)); |
|
91 | - } |
|
88 | + public function count_units_to_process() |
|
89 | + { |
|
90 | + return \EEM_Attendee::instance()->count(array('caps' => \EEM_Base::caps_read_admin)); |
|
91 | + } |
|
92 | 92 | |
93 | - public function get_csv_data($offset, $limit) |
|
94 | - { |
|
95 | - $attendee_rows = \EEM_Attendee::instance()->get_all_wpdb_results( |
|
96 | - array( |
|
97 | - 'limit' => array($offset, $limit), |
|
98 | - 'force_join' => array('State', 'Country'), |
|
99 | - 'caps' => \EEM_Base::caps_read_admin, |
|
100 | - ) |
|
101 | - ); |
|
102 | - $csv_data = array(); |
|
103 | - foreach ($attendee_rows as $attendee_row) { |
|
104 | - $csv_row = array(); |
|
105 | - foreach (\EEM_Attendee::instance()->field_settings() as $field_name => $field_obj) { |
|
106 | - if ($field_name == 'STA_ID') { |
|
107 | - $state_name_field = \EEM_State::instance()->field_settings_for('STA_name'); |
|
108 | - $csv_row[ __('State', 'event_espresso') ] = $attendee_row[ $state_name_field->get_qualified_column() ]; |
|
109 | - } elseif ($field_name == 'CNT_ISO') { |
|
110 | - $country_name_field = \EEM_Country::instance()->field_settings_for('CNT_name'); |
|
111 | - $csv_row[ __('Country', 'event_espresso') ] = $attendee_row[ $country_name_field->get_qualified_column() ]; |
|
112 | - } else { |
|
113 | - $csv_row[ wp_specialchars_decode($field_obj->get_nicename(), ENT_QUOTES) ] = $attendee_row[ $field_obj->get_qualified_column() ]; |
|
114 | - } |
|
115 | - } |
|
116 | - $csv_data[] = apply_filters( |
|
117 | - 'FHEE___EventEspresso_core_libraries_batch_JobHandlers_AttendeesReport__get_csv_data__row', |
|
118 | - $csv_row, |
|
119 | - $attendee_row |
|
120 | - ); |
|
121 | - } |
|
122 | - return $csv_data; |
|
123 | - } |
|
93 | + public function get_csv_data($offset, $limit) |
|
94 | + { |
|
95 | + $attendee_rows = \EEM_Attendee::instance()->get_all_wpdb_results( |
|
96 | + array( |
|
97 | + 'limit' => array($offset, $limit), |
|
98 | + 'force_join' => array('State', 'Country'), |
|
99 | + 'caps' => \EEM_Base::caps_read_admin, |
|
100 | + ) |
|
101 | + ); |
|
102 | + $csv_data = array(); |
|
103 | + foreach ($attendee_rows as $attendee_row) { |
|
104 | + $csv_row = array(); |
|
105 | + foreach (\EEM_Attendee::instance()->field_settings() as $field_name => $field_obj) { |
|
106 | + if ($field_name == 'STA_ID') { |
|
107 | + $state_name_field = \EEM_State::instance()->field_settings_for('STA_name'); |
|
108 | + $csv_row[ __('State', 'event_espresso') ] = $attendee_row[ $state_name_field->get_qualified_column() ]; |
|
109 | + } elseif ($field_name == 'CNT_ISO') { |
|
110 | + $country_name_field = \EEM_Country::instance()->field_settings_for('CNT_name'); |
|
111 | + $csv_row[ __('Country', 'event_espresso') ] = $attendee_row[ $country_name_field->get_qualified_column() ]; |
|
112 | + } else { |
|
113 | + $csv_row[ wp_specialchars_decode($field_obj->get_nicename(), ENT_QUOTES) ] = $attendee_row[ $field_obj->get_qualified_column() ]; |
|
114 | + } |
|
115 | + } |
|
116 | + $csv_data[] = apply_filters( |
|
117 | + 'FHEE___EventEspresso_core_libraries_batch_JobHandlers_AttendeesReport__get_csv_data__row', |
|
118 | + $csv_row, |
|
119 | + $attendee_row |
|
120 | + ); |
|
121 | + } |
|
122 | + return $csv_data; |
|
123 | + } |
|
124 | 124 | } |
@@ -22,7 +22,7 @@ discard block |
||
22 | 22 | // phpcs:disable PSR1.Methods.CamelCapsMethodName.NotCamelCaps |
23 | 23 | public function create_job(JobParameters $job_parameters) |
24 | 24 | { |
25 | - if (! \EE_Capabilities::instance()->current_user_can('ee_read_contacts', 'generating_report')) { |
|
25 | + if ( ! \EE_Capabilities::instance()->current_user_can('ee_read_contacts', 'generating_report')) { |
|
26 | 26 | throw new BatchRequestException( |
27 | 27 | __('You do not have permission to view contacts', 'event_espresso') |
28 | 28 | ); |
@@ -105,12 +105,12 @@ discard block |
||
105 | 105 | foreach (\EEM_Attendee::instance()->field_settings() as $field_name => $field_obj) { |
106 | 106 | if ($field_name == 'STA_ID') { |
107 | 107 | $state_name_field = \EEM_State::instance()->field_settings_for('STA_name'); |
108 | - $csv_row[ __('State', 'event_espresso') ] = $attendee_row[ $state_name_field->get_qualified_column() ]; |
|
108 | + $csv_row[__('State', 'event_espresso')] = $attendee_row[$state_name_field->get_qualified_column()]; |
|
109 | 109 | } elseif ($field_name == 'CNT_ISO') { |
110 | 110 | $country_name_field = \EEM_Country::instance()->field_settings_for('CNT_name'); |
111 | - $csv_row[ __('Country', 'event_espresso') ] = $attendee_row[ $country_name_field->get_qualified_column() ]; |
|
111 | + $csv_row[__('Country', 'event_espresso')] = $attendee_row[$country_name_field->get_qualified_column()]; |
|
112 | 112 | } else { |
113 | - $csv_row[ wp_specialchars_decode($field_obj->get_nicename(), ENT_QUOTES) ] = $attendee_row[ $field_obj->get_qualified_column() ]; |
|
113 | + $csv_row[wp_specialchars_decode($field_obj->get_nicename(), ENT_QUOTES)] = $attendee_row[$field_obj->get_qualified_column()]; |
|
114 | 114 | } |
115 | 115 | } |
116 | 116 | $csv_data[] = apply_filters( |
@@ -24,471 +24,471 @@ |
||
24 | 24 | class DatetimeOffsetFix extends JobHandler |
25 | 25 | { |
26 | 26 | |
27 | - /** |
|
28 | - * Key for the option used to track which models have been processed when doing the batches. |
|
29 | - */ |
|
30 | - const MODELS_TO_PROCESS_OPTION_KEY = 'ee_models_processed_for_datetime_offset_fix'; |
|
31 | - |
|
32 | - |
|
33 | - const COUNT_OF_MODELS_PROCESSED = 'ee_count_of_ee_models_processed_for_datetime_offset_fixed'; |
|
34 | - |
|
35 | - /** |
|
36 | - * Key for the option used to track what the current offset is that will be applied when this tool is executed. |
|
37 | - */ |
|
38 | - const OFFSET_TO_APPLY_OPTION_KEY = 'ee_datetime_offset_fix_offset_to_apply'; |
|
39 | - |
|
40 | - |
|
41 | - const OPTION_KEY_OFFSET_RANGE_START_DATE = 'ee_datetime_offset_start_date_range'; |
|
42 | - |
|
43 | - |
|
44 | - const OPTION_KEY_OFFSET_RANGE_END_DATE = 'ee_datetime_offset_end_date_range'; |
|
45 | - |
|
46 | - |
|
47 | - /** |
|
48 | - * String labelling the datetime offset fix type for change-log entries. |
|
49 | - */ |
|
50 | - const DATETIME_OFFSET_FIX_CHANGELOG_TYPE = 'datetime_offset_fix'; |
|
51 | - |
|
52 | - |
|
53 | - /** |
|
54 | - * String labelling a datetime offset fix error for change-log entries. |
|
55 | - */ |
|
56 | - const DATETIME_OFFSET_FIX_CHANGELOG_ERROR_TYPE = 'datetime_offset_fix_error'; |
|
57 | - |
|
58 | - /** |
|
59 | - * @var EEM_Base[] |
|
60 | - */ |
|
61 | - protected $models_with_datetime_fields = array(); |
|
62 | - |
|
63 | - // phpcs:disable PSR1.Methods.CamelCapsMethodName.NotCamelCaps |
|
64 | - |
|
65 | - /** |
|
66 | - * Performs any necessary setup for starting the job. This is also a good |
|
67 | - * place to setup the $job_arguments which will be used for subsequent HTTP requests |
|
68 | - * when continue_job will be called |
|
69 | - * |
|
70 | - * @param JobParameters $job_parameters |
|
71 | - * @return JobStepResponse |
|
72 | - * @throws EE_Error |
|
73 | - * @throws InvalidArgumentException |
|
74 | - * @throws InvalidDataTypeException |
|
75 | - * @throws InvalidInterfaceException |
|
76 | - */ |
|
77 | - public function create_job(JobParameters $job_parameters) |
|
78 | - { |
|
79 | - $models_with_datetime_fields = $this->getModelsWithDatetimeFields(); |
|
80 | - // we'll be doing each model as a batch. |
|
81 | - $job_parameters->set_job_size(count($models_with_datetime_fields)); |
|
82 | - return new JobStepResponse( |
|
83 | - $job_parameters, |
|
84 | - esc_html__('Starting Datetime Offset Fix', 'event_espresso') |
|
85 | - ); |
|
86 | - } |
|
87 | - |
|
88 | - /** |
|
89 | - * Performs another step of the job |
|
90 | - * |
|
91 | - * @param JobParameters $job_parameters |
|
92 | - * @param int $batch_size |
|
93 | - * @return JobStepResponse |
|
94 | - * @throws EE_Error |
|
95 | - * @throws InvalidArgumentException |
|
96 | - * @throws InvalidDataTypeException |
|
97 | - * @throws InvalidInterfaceException |
|
98 | - */ |
|
99 | - public function continue_job(JobParameters $job_parameters, $batch_size = 50) |
|
100 | - { |
|
101 | - $models_to_process = $this->getModelsWithDatetimeFields(); |
|
102 | - // let's pop off the a model and do the query to apply the offset. |
|
103 | - $model_to_process = array_pop($models_to_process); |
|
104 | - // update our record |
|
105 | - $this->setModelsToProcess($models_to_process); |
|
106 | - $this->processModel($model_to_process); |
|
107 | - $this->updateCountOfModelsProcessed(); |
|
108 | - $job_parameters->set_units_processed($this->getCountOfModelsProcessed()); |
|
109 | - if (count($models_to_process) > 0) { |
|
110 | - $job_parameters->set_status(JobParameters::status_continue); |
|
111 | - } else { |
|
112 | - $job_parameters->set_status(JobParameters::status_complete); |
|
113 | - } |
|
114 | - return new JobStepResponse( |
|
115 | - $job_parameters, |
|
116 | - sprintf( |
|
117 | - esc_html__('Updated the offset for all datetime fields on the %s model.', 'event_espresso'), |
|
118 | - $model_to_process |
|
119 | - ) |
|
120 | - ); |
|
121 | - } |
|
122 | - |
|
123 | - /** |
|
124 | - * Performs any clean-up logic when we know the job is completed |
|
125 | - * |
|
126 | - * @param JobParameters $job_parameters |
|
127 | - * @return JobStepResponse |
|
128 | - * @throws BatchRequestException |
|
129 | - */ |
|
130 | - public function cleanup_job(JobParameters $job_parameters) |
|
131 | - { |
|
132 | - // delete important saved options. |
|
133 | - delete_option(self::MODELS_TO_PROCESS_OPTION_KEY); |
|
134 | - delete_option(self::COUNT_OF_MODELS_PROCESSED); |
|
135 | - delete_option(self::OPTION_KEY_OFFSET_RANGE_START_DATE); |
|
136 | - delete_option(self::OPTION_KEY_OFFSET_RANGE_END_DATE); |
|
137 | - return new JobStepResponse($job_parameters, esc_html__( |
|
138 | - 'Offset has been applied to all affected fields.', |
|
139 | - 'event_espresso' |
|
140 | - )); |
|
141 | - } |
|
142 | - |
|
143 | - |
|
144 | - /** |
|
145 | - * Contains the logic for processing a model and applying the datetime offset to affected fields on that model. |
|
146 | - * |
|
147 | - * @param string $model_class_name |
|
148 | - * @throws EE_Error |
|
149 | - */ |
|
150 | - protected function processModel($model_class_name) |
|
151 | - { |
|
152 | - global $wpdb; |
|
153 | - /** @var EEM_Base $model */ |
|
154 | - $model = $model_class_name::instance(); |
|
155 | - $original_offset = self::getOffset(); |
|
156 | - $start_date_range = self::getStartDateRange(); |
|
157 | - $end_date_range = self::getEndDateRange(); |
|
158 | - $sql_date_function = $original_offset > 0 ? 'DATE_ADD' : 'DATE_SUB'; |
|
159 | - $offset = abs($original_offset) * 60; |
|
160 | - $date_ranges = array(); |
|
161 | - // since some affected models might have two tables, we have to get our tables and set up a query for each table. |
|
162 | - foreach ($model->get_tables() as $table) { |
|
163 | - $query = 'UPDATE ' . $table->get_table_name(); |
|
164 | - $fields_affected = array(); |
|
165 | - $inner_query = array(); |
|
166 | - foreach ($model->_get_fields_for_table($table->get_table_alias()) as $model_field) { |
|
167 | - if ($model_field instanceof EE_Datetime_Field) { |
|
168 | - $inner_query[ $model_field->get_table_column() ] = $model_field->get_table_column() . ' = ' |
|
169 | - . $sql_date_function . '(' |
|
170 | - . $model_field->get_table_column() |
|
171 | - . ", INTERVAL {$offset} MINUTE)"; |
|
172 | - $fields_affected[] = $model_field; |
|
173 | - } |
|
174 | - } |
|
175 | - if (! $fields_affected) { |
|
176 | - continue; |
|
177 | - } |
|
178 | - // do we do one query per column/field or one query for all fields on the model? It all depends on whether |
|
179 | - // there is a date range applied or not. |
|
180 | - if ($start_date_range instanceof DbSafeDateTime || $end_date_range instanceof DbSafeDateTime) { |
|
181 | - $result = $this->doQueryForEachField($query, $inner_query, $start_date_range, $end_date_range); |
|
182 | - } else { |
|
183 | - $result = $this->doQueryForAllFields($query, $inner_query); |
|
184 | - } |
|
185 | - |
|
186 | - // record appropriate logs for the query |
|
187 | - switch (true) { |
|
188 | - case $result === false: |
|
189 | - // record error. |
|
190 | - $error_message = $wpdb->last_error; |
|
191 | - // handle the edgecases where last_error might be empty. |
|
192 | - if (! $error_message) { |
|
193 | - $error_message = esc_html__('Unknown mysql error occured.', 'event_espresso'); |
|
194 | - } |
|
195 | - $this->recordChangeLog($model, $original_offset, $table, $fields_affected, $error_message); |
|
196 | - break; |
|
197 | - case is_array($result) && ! empty($result): |
|
198 | - foreach ($result as $field_name => $error_message) { |
|
199 | - $this->recordChangeLog($model, $original_offset, $table, array($field_name), $error_message); |
|
200 | - } |
|
201 | - break; |
|
202 | - default: |
|
203 | - $this->recordChangeLog($model, $original_offset, $table, $fields_affected); |
|
204 | - } |
|
205 | - } |
|
206 | - } |
|
207 | - |
|
208 | - |
|
209 | - /** |
|
210 | - * Does the query on each $inner_query individually. |
|
211 | - * |
|
212 | - * @param string $query |
|
213 | - * @param array $inner_query |
|
214 | - * @param DbSafeDateTime|null $start_date_range |
|
215 | - * @param DbSafeDateTime|null $end_date_range |
|
216 | - * @return array An array of any errors encountered and the fields they were for. |
|
217 | - */ |
|
218 | - private function doQueryForEachField($query, array $inner_query, $start_date_range, $end_date_range) |
|
219 | - { |
|
220 | - global $wpdb; |
|
221 | - $errors = array(); |
|
222 | - foreach ($inner_query as $field_name => $field_query) { |
|
223 | - $query_to_run = $query; |
|
224 | - $where_conditions = array(); |
|
225 | - $query_to_run .= ' SET ' . $field_query; |
|
226 | - if ($start_date_range instanceof DbSafeDateTime) { |
|
227 | - $start_date = $start_date_range->format(EE_Datetime_Field::mysql_timestamp_format); |
|
228 | - $where_conditions[] = "{$field_name} > '{$start_date}'"; |
|
229 | - } |
|
230 | - if ($end_date_range instanceof DbSafeDateTime) { |
|
231 | - $end_date = $end_date_range->format(EE_Datetime_Field::mysql_timestamp_format); |
|
232 | - $where_conditions[] = "{$field_name} < '{$end_date}'"; |
|
233 | - } |
|
234 | - if ($where_conditions) { |
|
235 | - $query_to_run .= ' WHERE ' . implode(' AND ', $where_conditions); |
|
236 | - } |
|
237 | - $result = $wpdb->query($query_to_run); |
|
238 | - if ($result === false) { |
|
239 | - // record error. |
|
240 | - $error_message = $wpdb->last_error; |
|
241 | - // handle the edgecases where last_error might be empty. |
|
242 | - if (! $error_message) { |
|
243 | - $error_message = esc_html__('Unknown mysql error occured.', 'event_espresso'); |
|
244 | - } |
|
245 | - $errors[ $field_name ] = $error_message; |
|
246 | - } |
|
247 | - } |
|
248 | - return $errors; |
|
249 | - } |
|
250 | - |
|
251 | - |
|
252 | - /** |
|
253 | - * Performs the query for all fields within the inner_query |
|
254 | - * |
|
255 | - * @param string $query |
|
256 | - * @param array $inner_query |
|
257 | - * @return false|int |
|
258 | - */ |
|
259 | - private function doQueryForAllFields($query, array $inner_query) |
|
260 | - { |
|
261 | - global $wpdb; |
|
262 | - $query .= ' SET ' . implode(',', $inner_query); |
|
263 | - return $wpdb->query($query); |
|
264 | - } |
|
265 | - |
|
266 | - |
|
267 | - /** |
|
268 | - * Records a changelog entry using the given information. |
|
269 | - * |
|
270 | - * @param EEM_Base $model |
|
271 | - * @param float $offset |
|
272 | - * @param EE_Table_Base $table |
|
273 | - * @param EE_Model_Field_Base[] $model_fields_affected |
|
274 | - * @param string $error_message If present then there was an error so let's record that instead. |
|
275 | - * @throws EE_Error |
|
276 | - */ |
|
277 | - private function recordChangeLog( |
|
278 | - EEM_Base $model, |
|
279 | - $offset, |
|
280 | - EE_Table_Base $table, |
|
281 | - $model_fields_affected, |
|
282 | - $error_message = '' |
|
283 | - ) { |
|
284 | - // setup $fields list. |
|
285 | - $fields = array(); |
|
286 | - /** @var EE_Datetime_Field $model_field */ |
|
287 | - foreach ($model_fields_affected as $model_field) { |
|
288 | - if (! $model_field instanceof EE_Datetime_Field) { |
|
289 | - continue; |
|
290 | - } |
|
291 | - $fields[] = $model_field->get_name(); |
|
292 | - } |
|
293 | - // setup the message for the changelog entry. |
|
294 | - $message = $error_message |
|
295 | - ? sprintf( |
|
296 | - esc_html__( |
|
297 | - 'The %1$s table for the %2$s model did not have the offset of %3$f applied to its fields (%4$s), because of the following error:%5$s', |
|
298 | - 'event_espresso' |
|
299 | - ), |
|
300 | - $table->get_table_name(), |
|
301 | - $model->get_this_model_name(), |
|
302 | - $offset, |
|
303 | - implode(',', $fields), |
|
304 | - $error_message |
|
305 | - ) |
|
306 | - : sprintf( |
|
307 | - esc_html__( |
|
308 | - 'The %1$s table for the %2$s model has had the offset of %3$f applied to its following fields: %4$s', |
|
309 | - 'event_espresso' |
|
310 | - ), |
|
311 | - $table->get_table_name(), |
|
312 | - $model->get_this_model_name(), |
|
313 | - $offset, |
|
314 | - implode(',', $fields) |
|
315 | - ); |
|
316 | - // write to the log |
|
317 | - $changelog = EE_Change_Log::new_instance(array( |
|
318 | - 'LOG_type' => $error_message |
|
319 | - ? self::DATETIME_OFFSET_FIX_CHANGELOG_ERROR_TYPE |
|
320 | - : self::DATETIME_OFFSET_FIX_CHANGELOG_TYPE, |
|
321 | - 'LOG_message' => $message, |
|
322 | - )); |
|
323 | - $changelog->save(); |
|
324 | - } |
|
325 | - |
|
326 | - |
|
327 | - /** |
|
328 | - * Returns an array of models that have datetime fields. |
|
329 | - * This array is added to a short lived transient cache to keep having to build this list to a minimum. |
|
330 | - * |
|
331 | - * @return array an array of model class names. |
|
332 | - * @throws EE_Error |
|
333 | - * @throws InvalidDataTypeException |
|
334 | - * @throws InvalidInterfaceException |
|
335 | - * @throws InvalidArgumentException |
|
336 | - */ |
|
337 | - private function getModelsWithDatetimeFields() |
|
338 | - { |
|
339 | - $this->getModelsToProcess(); |
|
340 | - if (! empty($this->models_with_datetime_fields)) { |
|
341 | - return $this->models_with_datetime_fields; |
|
342 | - } |
|
343 | - |
|
344 | - $all_non_abstract_models = EE_Registry::instance()->non_abstract_db_models; |
|
345 | - foreach ($all_non_abstract_models as $non_abstract_model) { |
|
346 | - // get model instance |
|
347 | - /** @var EEM_Base $non_abstract_model */ |
|
348 | - $non_abstract_model = $non_abstract_model::instance(); |
|
349 | - if ($non_abstract_model->get_a_field_of_type('EE_Datetime_Field') instanceof EE_Datetime_Field) { |
|
350 | - $this->models_with_datetime_fields[] = get_class($non_abstract_model); |
|
351 | - } |
|
352 | - } |
|
353 | - $this->setModelsToProcess($this->models_with_datetime_fields); |
|
354 | - return $this->models_with_datetime_fields; |
|
355 | - } |
|
356 | - |
|
357 | - |
|
358 | - /** |
|
359 | - * This simply records the models that have been processed with our tracking option. |
|
360 | - * |
|
361 | - * @param array $models_to_set array of model class names. |
|
362 | - */ |
|
363 | - private function setModelsToProcess($models_to_set) |
|
364 | - { |
|
365 | - update_option(self::MODELS_TO_PROCESS_OPTION_KEY, $models_to_set); |
|
366 | - } |
|
367 | - |
|
368 | - |
|
369 | - /** |
|
370 | - * Used to keep track of how many models have been processed for the batch |
|
371 | - * |
|
372 | - * @param $count |
|
373 | - */ |
|
374 | - private function updateCountOfModelsProcessed($count = 1) |
|
375 | - { |
|
376 | - $count = $this->getCountOfModelsProcessed() + (int) $count; |
|
377 | - update_option(self::COUNT_OF_MODELS_PROCESSED, $count); |
|
378 | - } |
|
379 | - |
|
380 | - |
|
381 | - /** |
|
382 | - * Retrieve the tracked number of models processed between requests. |
|
383 | - * |
|
384 | - * @return int |
|
385 | - */ |
|
386 | - private function getCountOfModelsProcessed() |
|
387 | - { |
|
388 | - return (int) get_option(self::COUNT_OF_MODELS_PROCESSED, 0); |
|
389 | - } |
|
390 | - |
|
391 | - |
|
392 | - /** |
|
393 | - * Returns the models that are left to process. |
|
394 | - * |
|
395 | - * @return array an array of model class names. |
|
396 | - */ |
|
397 | - private function getModelsToProcess() |
|
398 | - { |
|
399 | - if (empty($this->models_with_datetime_fields)) { |
|
400 | - $this->models_with_datetime_fields = get_option(self::MODELS_TO_PROCESS_OPTION_KEY, array()); |
|
401 | - } |
|
402 | - return $this->models_with_datetime_fields; |
|
403 | - } |
|
404 | - |
|
405 | - |
|
406 | - /** |
|
407 | - * Used to record the offset that will be applied to dates and times for EE_Datetime_Field columns. |
|
408 | - * |
|
409 | - * @param float $offset |
|
410 | - */ |
|
411 | - public static function updateOffset($offset) |
|
412 | - { |
|
413 | - update_option(self::OFFSET_TO_APPLY_OPTION_KEY, $offset); |
|
414 | - } |
|
415 | - |
|
416 | - |
|
417 | - /** |
|
418 | - * Used to retrieve the saved offset that will be applied to dates and times for EE_Datetime_Field columns. |
|
419 | - * |
|
420 | - * @return float |
|
421 | - */ |
|
422 | - public static function getOffset() |
|
423 | - { |
|
424 | - return (float) get_option(self::OFFSET_TO_APPLY_OPTION_KEY, 0); |
|
425 | - } |
|
426 | - |
|
427 | - |
|
428 | - /** |
|
429 | - * Used to set the saved offset range start date. |
|
430 | - * |
|
431 | - * @param DbSafeDateTime|null $start_date |
|
432 | - */ |
|
433 | - public static function updateStartDateRange(DbSafeDateTime $start_date = null) |
|
434 | - { |
|
435 | - $date_to_save = $start_date instanceof DbSafeDateTime |
|
436 | - ? $start_date->format('U') |
|
437 | - : ''; |
|
438 | - update_option(self::OPTION_KEY_OFFSET_RANGE_START_DATE, $date_to_save); |
|
439 | - } |
|
440 | - |
|
441 | - |
|
442 | - /** |
|
443 | - * Used to get the saved offset range start date. |
|
444 | - * |
|
445 | - * @return DbSafeDateTime|null |
|
446 | - */ |
|
447 | - public static function getStartDateRange() |
|
448 | - { |
|
449 | - $start_date = get_option(self::OPTION_KEY_OFFSET_RANGE_START_DATE, null); |
|
450 | - try { |
|
451 | - $datetime = DateTime::createFromFormat('U', $start_date, new DateTimeZone('UTC')); |
|
452 | - $start_date = $datetime instanceof DateTime |
|
453 | - ? DbSafeDateTime::createFromDateTime($datetime) |
|
454 | - : null; |
|
455 | - } catch (Exception $e) { |
|
456 | - $start_date = null; |
|
457 | - } |
|
458 | - return $start_date; |
|
459 | - } |
|
460 | - |
|
461 | - |
|
462 | - /** |
|
463 | - * Used to set the saved offset range end date. |
|
464 | - * |
|
465 | - * @param DbSafeDateTime|null $end_date |
|
466 | - */ |
|
467 | - public static function updateEndDateRange(DbSafeDateTime $end_date = null) |
|
468 | - { |
|
469 | - $date_to_save = $end_date instanceof DbSafeDateTime |
|
470 | - ? $end_date->format('U') |
|
471 | - : ''; |
|
472 | - update_option(self::OPTION_KEY_OFFSET_RANGE_END_DATE, $date_to_save); |
|
473 | - } |
|
474 | - |
|
475 | - |
|
476 | - /** |
|
477 | - * Used to get the saved offset range end date. |
|
478 | - * |
|
479 | - * @return DbSafeDateTime|null |
|
480 | - */ |
|
481 | - public static function getEndDateRange() |
|
482 | - { |
|
483 | - $end_date = get_option(self::OPTION_KEY_OFFSET_RANGE_END_DATE, null); |
|
484 | - try { |
|
485 | - $datetime = DateTime::createFromFormat('U', $end_date, new DateTimeZone('UTC')); |
|
486 | - $end_date = $datetime instanceof Datetime |
|
487 | - ? DbSafeDateTime::createFromDateTime($datetime) |
|
488 | - : null; |
|
489 | - } catch (Exception $e) { |
|
490 | - $end_date = null; |
|
491 | - } |
|
492 | - return $end_date; |
|
493 | - } |
|
27 | + /** |
|
28 | + * Key for the option used to track which models have been processed when doing the batches. |
|
29 | + */ |
|
30 | + const MODELS_TO_PROCESS_OPTION_KEY = 'ee_models_processed_for_datetime_offset_fix'; |
|
31 | + |
|
32 | + |
|
33 | + const COUNT_OF_MODELS_PROCESSED = 'ee_count_of_ee_models_processed_for_datetime_offset_fixed'; |
|
34 | + |
|
35 | + /** |
|
36 | + * Key for the option used to track what the current offset is that will be applied when this tool is executed. |
|
37 | + */ |
|
38 | + const OFFSET_TO_APPLY_OPTION_KEY = 'ee_datetime_offset_fix_offset_to_apply'; |
|
39 | + |
|
40 | + |
|
41 | + const OPTION_KEY_OFFSET_RANGE_START_DATE = 'ee_datetime_offset_start_date_range'; |
|
42 | + |
|
43 | + |
|
44 | + const OPTION_KEY_OFFSET_RANGE_END_DATE = 'ee_datetime_offset_end_date_range'; |
|
45 | + |
|
46 | + |
|
47 | + /** |
|
48 | + * String labelling the datetime offset fix type for change-log entries. |
|
49 | + */ |
|
50 | + const DATETIME_OFFSET_FIX_CHANGELOG_TYPE = 'datetime_offset_fix'; |
|
51 | + |
|
52 | + |
|
53 | + /** |
|
54 | + * String labelling a datetime offset fix error for change-log entries. |
|
55 | + */ |
|
56 | + const DATETIME_OFFSET_FIX_CHANGELOG_ERROR_TYPE = 'datetime_offset_fix_error'; |
|
57 | + |
|
58 | + /** |
|
59 | + * @var EEM_Base[] |
|
60 | + */ |
|
61 | + protected $models_with_datetime_fields = array(); |
|
62 | + |
|
63 | + // phpcs:disable PSR1.Methods.CamelCapsMethodName.NotCamelCaps |
|
64 | + |
|
65 | + /** |
|
66 | + * Performs any necessary setup for starting the job. This is also a good |
|
67 | + * place to setup the $job_arguments which will be used for subsequent HTTP requests |
|
68 | + * when continue_job will be called |
|
69 | + * |
|
70 | + * @param JobParameters $job_parameters |
|
71 | + * @return JobStepResponse |
|
72 | + * @throws EE_Error |
|
73 | + * @throws InvalidArgumentException |
|
74 | + * @throws InvalidDataTypeException |
|
75 | + * @throws InvalidInterfaceException |
|
76 | + */ |
|
77 | + public function create_job(JobParameters $job_parameters) |
|
78 | + { |
|
79 | + $models_with_datetime_fields = $this->getModelsWithDatetimeFields(); |
|
80 | + // we'll be doing each model as a batch. |
|
81 | + $job_parameters->set_job_size(count($models_with_datetime_fields)); |
|
82 | + return new JobStepResponse( |
|
83 | + $job_parameters, |
|
84 | + esc_html__('Starting Datetime Offset Fix', 'event_espresso') |
|
85 | + ); |
|
86 | + } |
|
87 | + |
|
88 | + /** |
|
89 | + * Performs another step of the job |
|
90 | + * |
|
91 | + * @param JobParameters $job_parameters |
|
92 | + * @param int $batch_size |
|
93 | + * @return JobStepResponse |
|
94 | + * @throws EE_Error |
|
95 | + * @throws InvalidArgumentException |
|
96 | + * @throws InvalidDataTypeException |
|
97 | + * @throws InvalidInterfaceException |
|
98 | + */ |
|
99 | + public function continue_job(JobParameters $job_parameters, $batch_size = 50) |
|
100 | + { |
|
101 | + $models_to_process = $this->getModelsWithDatetimeFields(); |
|
102 | + // let's pop off the a model and do the query to apply the offset. |
|
103 | + $model_to_process = array_pop($models_to_process); |
|
104 | + // update our record |
|
105 | + $this->setModelsToProcess($models_to_process); |
|
106 | + $this->processModel($model_to_process); |
|
107 | + $this->updateCountOfModelsProcessed(); |
|
108 | + $job_parameters->set_units_processed($this->getCountOfModelsProcessed()); |
|
109 | + if (count($models_to_process) > 0) { |
|
110 | + $job_parameters->set_status(JobParameters::status_continue); |
|
111 | + } else { |
|
112 | + $job_parameters->set_status(JobParameters::status_complete); |
|
113 | + } |
|
114 | + return new JobStepResponse( |
|
115 | + $job_parameters, |
|
116 | + sprintf( |
|
117 | + esc_html__('Updated the offset for all datetime fields on the %s model.', 'event_espresso'), |
|
118 | + $model_to_process |
|
119 | + ) |
|
120 | + ); |
|
121 | + } |
|
122 | + |
|
123 | + /** |
|
124 | + * Performs any clean-up logic when we know the job is completed |
|
125 | + * |
|
126 | + * @param JobParameters $job_parameters |
|
127 | + * @return JobStepResponse |
|
128 | + * @throws BatchRequestException |
|
129 | + */ |
|
130 | + public function cleanup_job(JobParameters $job_parameters) |
|
131 | + { |
|
132 | + // delete important saved options. |
|
133 | + delete_option(self::MODELS_TO_PROCESS_OPTION_KEY); |
|
134 | + delete_option(self::COUNT_OF_MODELS_PROCESSED); |
|
135 | + delete_option(self::OPTION_KEY_OFFSET_RANGE_START_DATE); |
|
136 | + delete_option(self::OPTION_KEY_OFFSET_RANGE_END_DATE); |
|
137 | + return new JobStepResponse($job_parameters, esc_html__( |
|
138 | + 'Offset has been applied to all affected fields.', |
|
139 | + 'event_espresso' |
|
140 | + )); |
|
141 | + } |
|
142 | + |
|
143 | + |
|
144 | + /** |
|
145 | + * Contains the logic for processing a model and applying the datetime offset to affected fields on that model. |
|
146 | + * |
|
147 | + * @param string $model_class_name |
|
148 | + * @throws EE_Error |
|
149 | + */ |
|
150 | + protected function processModel($model_class_name) |
|
151 | + { |
|
152 | + global $wpdb; |
|
153 | + /** @var EEM_Base $model */ |
|
154 | + $model = $model_class_name::instance(); |
|
155 | + $original_offset = self::getOffset(); |
|
156 | + $start_date_range = self::getStartDateRange(); |
|
157 | + $end_date_range = self::getEndDateRange(); |
|
158 | + $sql_date_function = $original_offset > 0 ? 'DATE_ADD' : 'DATE_SUB'; |
|
159 | + $offset = abs($original_offset) * 60; |
|
160 | + $date_ranges = array(); |
|
161 | + // since some affected models might have two tables, we have to get our tables and set up a query for each table. |
|
162 | + foreach ($model->get_tables() as $table) { |
|
163 | + $query = 'UPDATE ' . $table->get_table_name(); |
|
164 | + $fields_affected = array(); |
|
165 | + $inner_query = array(); |
|
166 | + foreach ($model->_get_fields_for_table($table->get_table_alias()) as $model_field) { |
|
167 | + if ($model_field instanceof EE_Datetime_Field) { |
|
168 | + $inner_query[ $model_field->get_table_column() ] = $model_field->get_table_column() . ' = ' |
|
169 | + . $sql_date_function . '(' |
|
170 | + . $model_field->get_table_column() |
|
171 | + . ", INTERVAL {$offset} MINUTE)"; |
|
172 | + $fields_affected[] = $model_field; |
|
173 | + } |
|
174 | + } |
|
175 | + if (! $fields_affected) { |
|
176 | + continue; |
|
177 | + } |
|
178 | + // do we do one query per column/field or one query for all fields on the model? It all depends on whether |
|
179 | + // there is a date range applied or not. |
|
180 | + if ($start_date_range instanceof DbSafeDateTime || $end_date_range instanceof DbSafeDateTime) { |
|
181 | + $result = $this->doQueryForEachField($query, $inner_query, $start_date_range, $end_date_range); |
|
182 | + } else { |
|
183 | + $result = $this->doQueryForAllFields($query, $inner_query); |
|
184 | + } |
|
185 | + |
|
186 | + // record appropriate logs for the query |
|
187 | + switch (true) { |
|
188 | + case $result === false: |
|
189 | + // record error. |
|
190 | + $error_message = $wpdb->last_error; |
|
191 | + // handle the edgecases where last_error might be empty. |
|
192 | + if (! $error_message) { |
|
193 | + $error_message = esc_html__('Unknown mysql error occured.', 'event_espresso'); |
|
194 | + } |
|
195 | + $this->recordChangeLog($model, $original_offset, $table, $fields_affected, $error_message); |
|
196 | + break; |
|
197 | + case is_array($result) && ! empty($result): |
|
198 | + foreach ($result as $field_name => $error_message) { |
|
199 | + $this->recordChangeLog($model, $original_offset, $table, array($field_name), $error_message); |
|
200 | + } |
|
201 | + break; |
|
202 | + default: |
|
203 | + $this->recordChangeLog($model, $original_offset, $table, $fields_affected); |
|
204 | + } |
|
205 | + } |
|
206 | + } |
|
207 | + |
|
208 | + |
|
209 | + /** |
|
210 | + * Does the query on each $inner_query individually. |
|
211 | + * |
|
212 | + * @param string $query |
|
213 | + * @param array $inner_query |
|
214 | + * @param DbSafeDateTime|null $start_date_range |
|
215 | + * @param DbSafeDateTime|null $end_date_range |
|
216 | + * @return array An array of any errors encountered and the fields they were for. |
|
217 | + */ |
|
218 | + private function doQueryForEachField($query, array $inner_query, $start_date_range, $end_date_range) |
|
219 | + { |
|
220 | + global $wpdb; |
|
221 | + $errors = array(); |
|
222 | + foreach ($inner_query as $field_name => $field_query) { |
|
223 | + $query_to_run = $query; |
|
224 | + $where_conditions = array(); |
|
225 | + $query_to_run .= ' SET ' . $field_query; |
|
226 | + if ($start_date_range instanceof DbSafeDateTime) { |
|
227 | + $start_date = $start_date_range->format(EE_Datetime_Field::mysql_timestamp_format); |
|
228 | + $where_conditions[] = "{$field_name} > '{$start_date}'"; |
|
229 | + } |
|
230 | + if ($end_date_range instanceof DbSafeDateTime) { |
|
231 | + $end_date = $end_date_range->format(EE_Datetime_Field::mysql_timestamp_format); |
|
232 | + $where_conditions[] = "{$field_name} < '{$end_date}'"; |
|
233 | + } |
|
234 | + if ($where_conditions) { |
|
235 | + $query_to_run .= ' WHERE ' . implode(' AND ', $where_conditions); |
|
236 | + } |
|
237 | + $result = $wpdb->query($query_to_run); |
|
238 | + if ($result === false) { |
|
239 | + // record error. |
|
240 | + $error_message = $wpdb->last_error; |
|
241 | + // handle the edgecases where last_error might be empty. |
|
242 | + if (! $error_message) { |
|
243 | + $error_message = esc_html__('Unknown mysql error occured.', 'event_espresso'); |
|
244 | + } |
|
245 | + $errors[ $field_name ] = $error_message; |
|
246 | + } |
|
247 | + } |
|
248 | + return $errors; |
|
249 | + } |
|
250 | + |
|
251 | + |
|
252 | + /** |
|
253 | + * Performs the query for all fields within the inner_query |
|
254 | + * |
|
255 | + * @param string $query |
|
256 | + * @param array $inner_query |
|
257 | + * @return false|int |
|
258 | + */ |
|
259 | + private function doQueryForAllFields($query, array $inner_query) |
|
260 | + { |
|
261 | + global $wpdb; |
|
262 | + $query .= ' SET ' . implode(',', $inner_query); |
|
263 | + return $wpdb->query($query); |
|
264 | + } |
|
265 | + |
|
266 | + |
|
267 | + /** |
|
268 | + * Records a changelog entry using the given information. |
|
269 | + * |
|
270 | + * @param EEM_Base $model |
|
271 | + * @param float $offset |
|
272 | + * @param EE_Table_Base $table |
|
273 | + * @param EE_Model_Field_Base[] $model_fields_affected |
|
274 | + * @param string $error_message If present then there was an error so let's record that instead. |
|
275 | + * @throws EE_Error |
|
276 | + */ |
|
277 | + private function recordChangeLog( |
|
278 | + EEM_Base $model, |
|
279 | + $offset, |
|
280 | + EE_Table_Base $table, |
|
281 | + $model_fields_affected, |
|
282 | + $error_message = '' |
|
283 | + ) { |
|
284 | + // setup $fields list. |
|
285 | + $fields = array(); |
|
286 | + /** @var EE_Datetime_Field $model_field */ |
|
287 | + foreach ($model_fields_affected as $model_field) { |
|
288 | + if (! $model_field instanceof EE_Datetime_Field) { |
|
289 | + continue; |
|
290 | + } |
|
291 | + $fields[] = $model_field->get_name(); |
|
292 | + } |
|
293 | + // setup the message for the changelog entry. |
|
294 | + $message = $error_message |
|
295 | + ? sprintf( |
|
296 | + esc_html__( |
|
297 | + 'The %1$s table for the %2$s model did not have the offset of %3$f applied to its fields (%4$s), because of the following error:%5$s', |
|
298 | + 'event_espresso' |
|
299 | + ), |
|
300 | + $table->get_table_name(), |
|
301 | + $model->get_this_model_name(), |
|
302 | + $offset, |
|
303 | + implode(',', $fields), |
|
304 | + $error_message |
|
305 | + ) |
|
306 | + : sprintf( |
|
307 | + esc_html__( |
|
308 | + 'The %1$s table for the %2$s model has had the offset of %3$f applied to its following fields: %4$s', |
|
309 | + 'event_espresso' |
|
310 | + ), |
|
311 | + $table->get_table_name(), |
|
312 | + $model->get_this_model_name(), |
|
313 | + $offset, |
|
314 | + implode(',', $fields) |
|
315 | + ); |
|
316 | + // write to the log |
|
317 | + $changelog = EE_Change_Log::new_instance(array( |
|
318 | + 'LOG_type' => $error_message |
|
319 | + ? self::DATETIME_OFFSET_FIX_CHANGELOG_ERROR_TYPE |
|
320 | + : self::DATETIME_OFFSET_FIX_CHANGELOG_TYPE, |
|
321 | + 'LOG_message' => $message, |
|
322 | + )); |
|
323 | + $changelog->save(); |
|
324 | + } |
|
325 | + |
|
326 | + |
|
327 | + /** |
|
328 | + * Returns an array of models that have datetime fields. |
|
329 | + * This array is added to a short lived transient cache to keep having to build this list to a minimum. |
|
330 | + * |
|
331 | + * @return array an array of model class names. |
|
332 | + * @throws EE_Error |
|
333 | + * @throws InvalidDataTypeException |
|
334 | + * @throws InvalidInterfaceException |
|
335 | + * @throws InvalidArgumentException |
|
336 | + */ |
|
337 | + private function getModelsWithDatetimeFields() |
|
338 | + { |
|
339 | + $this->getModelsToProcess(); |
|
340 | + if (! empty($this->models_with_datetime_fields)) { |
|
341 | + return $this->models_with_datetime_fields; |
|
342 | + } |
|
343 | + |
|
344 | + $all_non_abstract_models = EE_Registry::instance()->non_abstract_db_models; |
|
345 | + foreach ($all_non_abstract_models as $non_abstract_model) { |
|
346 | + // get model instance |
|
347 | + /** @var EEM_Base $non_abstract_model */ |
|
348 | + $non_abstract_model = $non_abstract_model::instance(); |
|
349 | + if ($non_abstract_model->get_a_field_of_type('EE_Datetime_Field') instanceof EE_Datetime_Field) { |
|
350 | + $this->models_with_datetime_fields[] = get_class($non_abstract_model); |
|
351 | + } |
|
352 | + } |
|
353 | + $this->setModelsToProcess($this->models_with_datetime_fields); |
|
354 | + return $this->models_with_datetime_fields; |
|
355 | + } |
|
356 | + |
|
357 | + |
|
358 | + /** |
|
359 | + * This simply records the models that have been processed with our tracking option. |
|
360 | + * |
|
361 | + * @param array $models_to_set array of model class names. |
|
362 | + */ |
|
363 | + private function setModelsToProcess($models_to_set) |
|
364 | + { |
|
365 | + update_option(self::MODELS_TO_PROCESS_OPTION_KEY, $models_to_set); |
|
366 | + } |
|
367 | + |
|
368 | + |
|
369 | + /** |
|
370 | + * Used to keep track of how many models have been processed for the batch |
|
371 | + * |
|
372 | + * @param $count |
|
373 | + */ |
|
374 | + private function updateCountOfModelsProcessed($count = 1) |
|
375 | + { |
|
376 | + $count = $this->getCountOfModelsProcessed() + (int) $count; |
|
377 | + update_option(self::COUNT_OF_MODELS_PROCESSED, $count); |
|
378 | + } |
|
379 | + |
|
380 | + |
|
381 | + /** |
|
382 | + * Retrieve the tracked number of models processed between requests. |
|
383 | + * |
|
384 | + * @return int |
|
385 | + */ |
|
386 | + private function getCountOfModelsProcessed() |
|
387 | + { |
|
388 | + return (int) get_option(self::COUNT_OF_MODELS_PROCESSED, 0); |
|
389 | + } |
|
390 | + |
|
391 | + |
|
392 | + /** |
|
393 | + * Returns the models that are left to process. |
|
394 | + * |
|
395 | + * @return array an array of model class names. |
|
396 | + */ |
|
397 | + private function getModelsToProcess() |
|
398 | + { |
|
399 | + if (empty($this->models_with_datetime_fields)) { |
|
400 | + $this->models_with_datetime_fields = get_option(self::MODELS_TO_PROCESS_OPTION_KEY, array()); |
|
401 | + } |
|
402 | + return $this->models_with_datetime_fields; |
|
403 | + } |
|
404 | + |
|
405 | + |
|
406 | + /** |
|
407 | + * Used to record the offset that will be applied to dates and times for EE_Datetime_Field columns. |
|
408 | + * |
|
409 | + * @param float $offset |
|
410 | + */ |
|
411 | + public static function updateOffset($offset) |
|
412 | + { |
|
413 | + update_option(self::OFFSET_TO_APPLY_OPTION_KEY, $offset); |
|
414 | + } |
|
415 | + |
|
416 | + |
|
417 | + /** |
|
418 | + * Used to retrieve the saved offset that will be applied to dates and times for EE_Datetime_Field columns. |
|
419 | + * |
|
420 | + * @return float |
|
421 | + */ |
|
422 | + public static function getOffset() |
|
423 | + { |
|
424 | + return (float) get_option(self::OFFSET_TO_APPLY_OPTION_KEY, 0); |
|
425 | + } |
|
426 | + |
|
427 | + |
|
428 | + /** |
|
429 | + * Used to set the saved offset range start date. |
|
430 | + * |
|
431 | + * @param DbSafeDateTime|null $start_date |
|
432 | + */ |
|
433 | + public static function updateStartDateRange(DbSafeDateTime $start_date = null) |
|
434 | + { |
|
435 | + $date_to_save = $start_date instanceof DbSafeDateTime |
|
436 | + ? $start_date->format('U') |
|
437 | + : ''; |
|
438 | + update_option(self::OPTION_KEY_OFFSET_RANGE_START_DATE, $date_to_save); |
|
439 | + } |
|
440 | + |
|
441 | + |
|
442 | + /** |
|
443 | + * Used to get the saved offset range start date. |
|
444 | + * |
|
445 | + * @return DbSafeDateTime|null |
|
446 | + */ |
|
447 | + public static function getStartDateRange() |
|
448 | + { |
|
449 | + $start_date = get_option(self::OPTION_KEY_OFFSET_RANGE_START_DATE, null); |
|
450 | + try { |
|
451 | + $datetime = DateTime::createFromFormat('U', $start_date, new DateTimeZone('UTC')); |
|
452 | + $start_date = $datetime instanceof DateTime |
|
453 | + ? DbSafeDateTime::createFromDateTime($datetime) |
|
454 | + : null; |
|
455 | + } catch (Exception $e) { |
|
456 | + $start_date = null; |
|
457 | + } |
|
458 | + return $start_date; |
|
459 | + } |
|
460 | + |
|
461 | + |
|
462 | + /** |
|
463 | + * Used to set the saved offset range end date. |
|
464 | + * |
|
465 | + * @param DbSafeDateTime|null $end_date |
|
466 | + */ |
|
467 | + public static function updateEndDateRange(DbSafeDateTime $end_date = null) |
|
468 | + { |
|
469 | + $date_to_save = $end_date instanceof DbSafeDateTime |
|
470 | + ? $end_date->format('U') |
|
471 | + : ''; |
|
472 | + update_option(self::OPTION_KEY_OFFSET_RANGE_END_DATE, $date_to_save); |
|
473 | + } |
|
474 | + |
|
475 | + |
|
476 | + /** |
|
477 | + * Used to get the saved offset range end date. |
|
478 | + * |
|
479 | + * @return DbSafeDateTime|null |
|
480 | + */ |
|
481 | + public static function getEndDateRange() |
|
482 | + { |
|
483 | + $end_date = get_option(self::OPTION_KEY_OFFSET_RANGE_END_DATE, null); |
|
484 | + try { |
|
485 | + $datetime = DateTime::createFromFormat('U', $end_date, new DateTimeZone('UTC')); |
|
486 | + $end_date = $datetime instanceof Datetime |
|
487 | + ? DbSafeDateTime::createFromDateTime($datetime) |
|
488 | + : null; |
|
489 | + } catch (Exception $e) { |
|
490 | + $end_date = null; |
|
491 | + } |
|
492 | + return $end_date; |
|
493 | + } |
|
494 | 494 | } |
@@ -160,19 +160,19 @@ discard block |
||
160 | 160 | $date_ranges = array(); |
161 | 161 | // since some affected models might have two tables, we have to get our tables and set up a query for each table. |
162 | 162 | foreach ($model->get_tables() as $table) { |
163 | - $query = 'UPDATE ' . $table->get_table_name(); |
|
163 | + $query = 'UPDATE '.$table->get_table_name(); |
|
164 | 164 | $fields_affected = array(); |
165 | 165 | $inner_query = array(); |
166 | 166 | foreach ($model->_get_fields_for_table($table->get_table_alias()) as $model_field) { |
167 | 167 | if ($model_field instanceof EE_Datetime_Field) { |
168 | - $inner_query[ $model_field->get_table_column() ] = $model_field->get_table_column() . ' = ' |
|
169 | - . $sql_date_function . '(' |
|
168 | + $inner_query[$model_field->get_table_column()] = $model_field->get_table_column().' = ' |
|
169 | + . $sql_date_function.'(' |
|
170 | 170 | . $model_field->get_table_column() |
171 | 171 | . ", INTERVAL {$offset} MINUTE)"; |
172 | 172 | $fields_affected[] = $model_field; |
173 | 173 | } |
174 | 174 | } |
175 | - if (! $fields_affected) { |
|
175 | + if ( ! $fields_affected) { |
|
176 | 176 | continue; |
177 | 177 | } |
178 | 178 | // do we do one query per column/field or one query for all fields on the model? It all depends on whether |
@@ -189,7 +189,7 @@ discard block |
||
189 | 189 | // record error. |
190 | 190 | $error_message = $wpdb->last_error; |
191 | 191 | // handle the edgecases where last_error might be empty. |
192 | - if (! $error_message) { |
|
192 | + if ( ! $error_message) { |
|
193 | 193 | $error_message = esc_html__('Unknown mysql error occured.', 'event_espresso'); |
194 | 194 | } |
195 | 195 | $this->recordChangeLog($model, $original_offset, $table, $fields_affected, $error_message); |
@@ -222,7 +222,7 @@ discard block |
||
222 | 222 | foreach ($inner_query as $field_name => $field_query) { |
223 | 223 | $query_to_run = $query; |
224 | 224 | $where_conditions = array(); |
225 | - $query_to_run .= ' SET ' . $field_query; |
|
225 | + $query_to_run .= ' SET '.$field_query; |
|
226 | 226 | if ($start_date_range instanceof DbSafeDateTime) { |
227 | 227 | $start_date = $start_date_range->format(EE_Datetime_Field::mysql_timestamp_format); |
228 | 228 | $where_conditions[] = "{$field_name} > '{$start_date}'"; |
@@ -232,17 +232,17 @@ discard block |
||
232 | 232 | $where_conditions[] = "{$field_name} < '{$end_date}'"; |
233 | 233 | } |
234 | 234 | if ($where_conditions) { |
235 | - $query_to_run .= ' WHERE ' . implode(' AND ', $where_conditions); |
|
235 | + $query_to_run .= ' WHERE '.implode(' AND ', $where_conditions); |
|
236 | 236 | } |
237 | 237 | $result = $wpdb->query($query_to_run); |
238 | 238 | if ($result === false) { |
239 | 239 | // record error. |
240 | 240 | $error_message = $wpdb->last_error; |
241 | 241 | // handle the edgecases where last_error might be empty. |
242 | - if (! $error_message) { |
|
242 | + if ( ! $error_message) { |
|
243 | 243 | $error_message = esc_html__('Unknown mysql error occured.', 'event_espresso'); |
244 | 244 | } |
245 | - $errors[ $field_name ] = $error_message; |
|
245 | + $errors[$field_name] = $error_message; |
|
246 | 246 | } |
247 | 247 | } |
248 | 248 | return $errors; |
@@ -259,7 +259,7 @@ discard block |
||
259 | 259 | private function doQueryForAllFields($query, array $inner_query) |
260 | 260 | { |
261 | 261 | global $wpdb; |
262 | - $query .= ' SET ' . implode(',', $inner_query); |
|
262 | + $query .= ' SET '.implode(',', $inner_query); |
|
263 | 263 | return $wpdb->query($query); |
264 | 264 | } |
265 | 265 | |
@@ -285,7 +285,7 @@ discard block |
||
285 | 285 | $fields = array(); |
286 | 286 | /** @var EE_Datetime_Field $model_field */ |
287 | 287 | foreach ($model_fields_affected as $model_field) { |
288 | - if (! $model_field instanceof EE_Datetime_Field) { |
|
288 | + if ( ! $model_field instanceof EE_Datetime_Field) { |
|
289 | 289 | continue; |
290 | 290 | } |
291 | 291 | $fields[] = $model_field->get_name(); |
@@ -337,7 +337,7 @@ discard block |
||
337 | 337 | private function getModelsWithDatetimeFields() |
338 | 338 | { |
339 | 339 | $this->getModelsToProcess(); |
340 | - if (! empty($this->models_with_datetime_fields)) { |
|
340 | + if ( ! empty($this->models_with_datetime_fields)) { |
|
341 | 341 | return $this->models_with_datetime_fields; |
342 | 342 | } |
343 | 343 |
@@ -13,99 +13,99 @@ |
||
13 | 13 | */ |
14 | 14 | class JobStepResponse |
15 | 15 | { |
16 | - // phpcs:disable PSR2.Classes.PropertyDeclaration.Underscore |
|
17 | - /** |
|
18 | - * Description fo what happened during this step |
|
19 | - * |
|
20 | - * @var string |
|
21 | - */ |
|
22 | - protected $_update_text; |
|
16 | + // phpcs:disable PSR2.Classes.PropertyDeclaration.Underscore |
|
17 | + /** |
|
18 | + * Description fo what happened during this step |
|
19 | + * |
|
20 | + * @var string |
|
21 | + */ |
|
22 | + protected $_update_text; |
|
23 | 23 | |
24 | - /** |
|
25 | - * @var JobParameters |
|
26 | - */ |
|
27 | - protected $_job_parameters; |
|
24 | + /** |
|
25 | + * @var JobParameters |
|
26 | + */ |
|
27 | + protected $_job_parameters; |
|
28 | 28 | |
29 | - /** |
|
30 | - * Extra data to include as part of the response. |
|
31 | - * |
|
32 | - * @var array |
|
33 | - */ |
|
34 | - protected $_extra_data = array(); |
|
35 | - // phpcs:enable |
|
29 | + /** |
|
30 | + * Extra data to include as part of the response. |
|
31 | + * |
|
32 | + * @var array |
|
33 | + */ |
|
34 | + protected $_extra_data = array(); |
|
35 | + // phpcs:enable |
|
36 | 36 | |
37 | - // phpcs:disable PSR1.Methods.CamelCapsMethodName.NotCamelCaps |
|
38 | - /** |
|
39 | - * @param \EventEspressoBatchRequest\Helpers\JobParameters $job_parameters |
|
40 | - * @param string $update_text |
|
41 | - * @param array $extra_data |
|
42 | - */ |
|
43 | - public function __construct(JobParameters $job_parameters, $update_text, $extra_data = array()) |
|
44 | - { |
|
45 | - $this->_job_parameters = $job_parameters; |
|
46 | - $this->_update_text = $update_text; |
|
47 | - $this->_extra_data = (array) $extra_data; |
|
48 | - } |
|
37 | + // phpcs:disable PSR1.Methods.CamelCapsMethodName.NotCamelCaps |
|
38 | + /** |
|
39 | + * @param \EventEspressoBatchRequest\Helpers\JobParameters $job_parameters |
|
40 | + * @param string $update_text |
|
41 | + * @param array $extra_data |
|
42 | + */ |
|
43 | + public function __construct(JobParameters $job_parameters, $update_text, $extra_data = array()) |
|
44 | + { |
|
45 | + $this->_job_parameters = $job_parameters; |
|
46 | + $this->_update_text = $update_text; |
|
47 | + $this->_extra_data = (array) $extra_data; |
|
48 | + } |
|
49 | 49 | |
50 | 50 | |
51 | - /** |
|
52 | - * @return JobParameters |
|
53 | - */ |
|
54 | - public function job_parameters() |
|
55 | - { |
|
56 | - return $this->_job_parameters; |
|
57 | - } |
|
51 | + /** |
|
52 | + * @return JobParameters |
|
53 | + */ |
|
54 | + public function job_parameters() |
|
55 | + { |
|
56 | + return $this->_job_parameters; |
|
57 | + } |
|
58 | 58 | |
59 | 59 | |
60 | - /** |
|
61 | - * Gets the update_text of what happened in this job during the current step |
|
62 | - * |
|
63 | - * @return string |
|
64 | - */ |
|
65 | - public function update_text() |
|
66 | - { |
|
67 | - return $this->_update_text; |
|
68 | - } |
|
60 | + /** |
|
61 | + * Gets the update_text of what happened in this job during the current step |
|
62 | + * |
|
63 | + * @return string |
|
64 | + */ |
|
65 | + public function update_text() |
|
66 | + { |
|
67 | + return $this->_update_text; |
|
68 | + } |
|
69 | 69 | |
70 | 70 | |
71 | - /** |
|
72 | - * Returns any extra data we may want to include with this response |
|
73 | - * |
|
74 | - * @return array |
|
75 | - */ |
|
76 | - public function extra_data() |
|
77 | - { |
|
78 | - return $this->_extra_data; |
|
79 | - } |
|
71 | + /** |
|
72 | + * Returns any extra data we may want to include with this response |
|
73 | + * |
|
74 | + * @return array |
|
75 | + */ |
|
76 | + public function extra_data() |
|
77 | + { |
|
78 | + return $this->_extra_data; |
|
79 | + } |
|
80 | 80 | |
81 | 81 | |
82 | - /** |
|
83 | - * Converts this response into an array that can be easily serialized. |
|
84 | - * This is most useful for serializing or json encoding |
|
85 | - * |
|
86 | - * @return array { |
|
87 | - * @type string $status , one of JobParameters::valid_stati() |
|
88 | - * @type int $units_processed count of units processed |
|
89 | - * @type int $job_size total number of units TO process |
|
90 | - * @type string $job_id unique string identifying the job |
|
91 | - * @type string $update_text string describing what happened during this step |
|
92 | - * } and any other items from $this->extra_data() |
|
93 | - */ |
|
94 | - public function to_array() |
|
95 | - { |
|
96 | - return apply_filters( |
|
97 | - 'FHEE__EventEspressoBatchRequest\Helpers\JobStepResponse__to_array__return', |
|
98 | - array_merge( |
|
99 | - $this->extra_data(), |
|
100 | - array( |
|
101 | - 'status' => $this->job_parameters()->status(), |
|
102 | - 'units_processed' => $this->job_parameters()->units_processed(), |
|
103 | - 'job_size' => $this->job_parameters()->job_size(), |
|
104 | - 'job_id' => $this->job_parameters()->job_id(), |
|
105 | - 'update_text' => $this->update_text(), |
|
106 | - ) |
|
107 | - ), |
|
108 | - $this |
|
109 | - ); |
|
110 | - } |
|
82 | + /** |
|
83 | + * Converts this response into an array that can be easily serialized. |
|
84 | + * This is most useful for serializing or json encoding |
|
85 | + * |
|
86 | + * @return array { |
|
87 | + * @type string $status , one of JobParameters::valid_stati() |
|
88 | + * @type int $units_processed count of units processed |
|
89 | + * @type int $job_size total number of units TO process |
|
90 | + * @type string $job_id unique string identifying the job |
|
91 | + * @type string $update_text string describing what happened during this step |
|
92 | + * } and any other items from $this->extra_data() |
|
93 | + */ |
|
94 | + public function to_array() |
|
95 | + { |
|
96 | + return apply_filters( |
|
97 | + 'FHEE__EventEspressoBatchRequest\Helpers\JobStepResponse__to_array__return', |
|
98 | + array_merge( |
|
99 | + $this->extra_data(), |
|
100 | + array( |
|
101 | + 'status' => $this->job_parameters()->status(), |
|
102 | + 'units_processed' => $this->job_parameters()->units_processed(), |
|
103 | + 'job_size' => $this->job_parameters()->job_size(), |
|
104 | + 'job_id' => $this->job_parameters()->job_id(), |
|
105 | + 'update_text' => $this->update_text(), |
|
106 | + ) |
|
107 | + ), |
|
108 | + $this |
|
109 | + ); |
|
110 | + } |
|
111 | 111 | } |
@@ -19,45 +19,45 @@ |
||
19 | 19 | class VsprintfFilter extends FormHtmlFilter |
20 | 20 | { |
21 | 21 | |
22 | - /** |
|
23 | - * @var string $format |
|
24 | - */ |
|
25 | - protected $format = ''; |
|
26 | - |
|
27 | - |
|
28 | - /** |
|
29 | - * @var array $args |
|
30 | - */ |
|
31 | - protected $args = array(); |
|
32 | - |
|
33 | - |
|
34 | - /** |
|
35 | - * VsprintfFilter constructor. |
|
36 | - * |
|
37 | - * @param string $format |
|
38 | - * @param array $args |
|
39 | - */ |
|
40 | - public function __construct($format, array $args) |
|
41 | - { |
|
42 | - $this->format = $format; |
|
43 | - $this->args = $args; |
|
44 | - } |
|
45 | - |
|
46 | - |
|
47 | - /** |
|
48 | - * @param $html |
|
49 | - * @param EE_Form_Section_Validatable $form_section |
|
50 | - * @return string |
|
51 | - */ |
|
52 | - public function filterHtml($html, EE_Form_Section_Validatable $form_section) |
|
53 | - { |
|
54 | - $this->args[] = $html; |
|
55 | - if ($form_section instanceof EE_Form_Section_Proper) { |
|
56 | - $subsections = $form_section->subsections(); |
|
57 | - foreach ((array) $subsections as $subsection) { |
|
58 | - $this->args[] = $subsection->get_html(); |
|
59 | - } |
|
60 | - } |
|
61 | - return vsprintf($this->format, $this->args); |
|
62 | - } |
|
22 | + /** |
|
23 | + * @var string $format |
|
24 | + */ |
|
25 | + protected $format = ''; |
|
26 | + |
|
27 | + |
|
28 | + /** |
|
29 | + * @var array $args |
|
30 | + */ |
|
31 | + protected $args = array(); |
|
32 | + |
|
33 | + |
|
34 | + /** |
|
35 | + * VsprintfFilter constructor. |
|
36 | + * |
|
37 | + * @param string $format |
|
38 | + * @param array $args |
|
39 | + */ |
|
40 | + public function __construct($format, array $args) |
|
41 | + { |
|
42 | + $this->format = $format; |
|
43 | + $this->args = $args; |
|
44 | + } |
|
45 | + |
|
46 | + |
|
47 | + /** |
|
48 | + * @param $html |
|
49 | + * @param EE_Form_Section_Validatable $form_section |
|
50 | + * @return string |
|
51 | + */ |
|
52 | + public function filterHtml($html, EE_Form_Section_Validatable $form_section) |
|
53 | + { |
|
54 | + $this->args[] = $html; |
|
55 | + if ($form_section instanceof EE_Form_Section_Proper) { |
|
56 | + $subsections = $form_section->subsections(); |
|
57 | + foreach ((array) $subsections as $subsection) { |
|
58 | + $this->args[] = $subsection->get_html(); |
|
59 | + } |
|
60 | + } |
|
61 | + return vsprintf($this->format, $this->args); |
|
62 | + } |
|
63 | 63 | } |