@@ -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 | } |