@@ -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 | } |
@@ -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 | } |
@@ -72,7 +72,7 @@ discard block |
||
72 | 72 | $base_code = '', |
73 | 73 | $reg_url_link = '' |
74 | 74 | ) { |
75 | - if (! empty($reg_url_link) && is_string($reg_url_link)) { |
|
75 | + if ( ! empty($reg_url_link) && is_string($reg_url_link)) { |
|
76 | 76 | $this->reg_url_link = apply_filters( |
77 | 77 | 'FHEE__\EventEspresso\core\domain\entities\RegUrlLink__construct__reg_url_link', |
78 | 78 | $reg_url_link, |
@@ -94,7 +94,7 @@ discard block |
||
94 | 94 | } |
95 | 95 | $this->reg_url_link = (string) apply_filters( |
96 | 96 | 'FHEE__\EventEspresso\core\domain\entities\RegUrlLink__construct__reg_url_link', |
97 | - $reg_count . '-' . md5($base_code . microtime()), |
|
97 | + $reg_count.'-'.md5($base_code.microtime()), |
|
98 | 98 | $reg_count, |
99 | 99 | $base_code, |
100 | 100 | $reg_url_link |
@@ -18,97 +18,97 @@ |
||
18 | 18 | class RegUrlLink |
19 | 19 | { |
20 | 20 | |
21 | - /* |
|
21 | + /* |
|
22 | 22 | * @var string $reg_url_link |
23 | 23 | */ |
24 | - private $reg_url_link; |
|
24 | + private $reg_url_link; |
|
25 | 25 | |
26 | 26 | |
27 | - /** |
|
28 | - * @param string $reg_url_link |
|
29 | - * @return RegUrlLink |
|
30 | - * @throws InvalidArgumentException |
|
31 | - */ |
|
32 | - public static function fromRegUrlLinkString($reg_url_link) |
|
33 | - { |
|
34 | - if (empty($reg_url_link) || ! is_string($reg_url_link)) { |
|
35 | - throw new InvalidArgumentException( |
|
36 | - esc_html__( |
|
37 | - 'You must supply a valid non-empty string to generate a reg_url_link.', |
|
38 | - 'event_espresso' |
|
39 | - ) |
|
40 | - ); |
|
41 | - } |
|
42 | - return new RegUrlLink(1, '', $reg_url_link); |
|
43 | - } |
|
27 | + /** |
|
28 | + * @param string $reg_url_link |
|
29 | + * @return RegUrlLink |
|
30 | + * @throws InvalidArgumentException |
|
31 | + */ |
|
32 | + public static function fromRegUrlLinkString($reg_url_link) |
|
33 | + { |
|
34 | + if (empty($reg_url_link) || ! is_string($reg_url_link)) { |
|
35 | + throw new InvalidArgumentException( |
|
36 | + esc_html__( |
|
37 | + 'You must supply a valid non-empty string to generate a reg_url_link.', |
|
38 | + 'event_espresso' |
|
39 | + ) |
|
40 | + ); |
|
41 | + } |
|
42 | + return new RegUrlLink(1, '', $reg_url_link); |
|
43 | + } |
|
44 | 44 | |
45 | 45 | |
46 | - /** |
|
47 | - * @param EE_Registration $registration |
|
48 | - * @return RegUrlLink |
|
49 | - * @throws EntityNotFoundException |
|
50 | - * @throws EE_Error |
|
51 | - * @throws InvalidArgumentException |
|
52 | - */ |
|
53 | - public static function fromRegistration(EE_Registration $registration) |
|
54 | - { |
|
55 | - return new RegUrlLink( |
|
56 | - $registration->count(), |
|
57 | - $registration->ticket_line_item() |
|
58 | - ); |
|
59 | - } |
|
46 | + /** |
|
47 | + * @param EE_Registration $registration |
|
48 | + * @return RegUrlLink |
|
49 | + * @throws EntityNotFoundException |
|
50 | + * @throws EE_Error |
|
51 | + * @throws InvalidArgumentException |
|
52 | + */ |
|
53 | + public static function fromRegistration(EE_Registration $registration) |
|
54 | + { |
|
55 | + return new RegUrlLink( |
|
56 | + $registration->count(), |
|
57 | + $registration->ticket_line_item() |
|
58 | + ); |
|
59 | + } |
|
60 | 60 | |
61 | 61 | |
62 | - /** |
|
63 | - * CreateRegUrlLinkCommand constructor. |
|
64 | - * |
|
65 | - * @param int $reg_count |
|
66 | - * @param mixed $base_code |
|
67 | - * @param string $reg_url_link |
|
68 | - * @throws InvalidArgumentException |
|
69 | - */ |
|
70 | - public function __construct( |
|
71 | - $reg_count = 1, |
|
72 | - $base_code = '', |
|
73 | - $reg_url_link = '' |
|
74 | - ) { |
|
75 | - if (! empty($reg_url_link) && is_string($reg_url_link)) { |
|
76 | - $this->reg_url_link = apply_filters( |
|
77 | - 'FHEE__\EventEspresso\core\domain\entities\RegUrlLink__construct__reg_url_link', |
|
78 | - $reg_url_link, |
|
79 | - $reg_count, |
|
80 | - $base_code, |
|
81 | - $reg_url_link |
|
82 | - ); |
|
83 | - return; |
|
84 | - } |
|
85 | - $reg_count = max(1, absint($reg_count)); |
|
86 | - $base_code = $base_code instanceof \EE_Line_Item ? $base_code->code() : $base_code; |
|
87 | - if (empty($base_code) || ! is_string($base_code)) { |
|
88 | - throw new InvalidArgumentException( |
|
89 | - esc_html__( |
|
90 | - 'You must supply a valid EE_Line_Item or a non-empty string to generate a reg_url_link.', |
|
91 | - 'event_espresso' |
|
92 | - ) |
|
93 | - ); |
|
94 | - } |
|
95 | - $this->reg_url_link = (string) apply_filters( |
|
96 | - 'FHEE__\EventEspresso\core\domain\entities\RegUrlLink__construct__reg_url_link', |
|
97 | - $reg_count . '-' . md5($base_code . microtime()), |
|
98 | - $reg_count, |
|
99 | - $base_code, |
|
100 | - $reg_url_link |
|
101 | - ); |
|
102 | - } |
|
62 | + /** |
|
63 | + * CreateRegUrlLinkCommand constructor. |
|
64 | + * |
|
65 | + * @param int $reg_count |
|
66 | + * @param mixed $base_code |
|
67 | + * @param string $reg_url_link |
|
68 | + * @throws InvalidArgumentException |
|
69 | + */ |
|
70 | + public function __construct( |
|
71 | + $reg_count = 1, |
|
72 | + $base_code = '', |
|
73 | + $reg_url_link = '' |
|
74 | + ) { |
|
75 | + if (! empty($reg_url_link) && is_string($reg_url_link)) { |
|
76 | + $this->reg_url_link = apply_filters( |
|
77 | + 'FHEE__\EventEspresso\core\domain\entities\RegUrlLink__construct__reg_url_link', |
|
78 | + $reg_url_link, |
|
79 | + $reg_count, |
|
80 | + $base_code, |
|
81 | + $reg_url_link |
|
82 | + ); |
|
83 | + return; |
|
84 | + } |
|
85 | + $reg_count = max(1, absint($reg_count)); |
|
86 | + $base_code = $base_code instanceof \EE_Line_Item ? $base_code->code() : $base_code; |
|
87 | + if (empty($base_code) || ! is_string($base_code)) { |
|
88 | + throw new InvalidArgumentException( |
|
89 | + esc_html__( |
|
90 | + 'You must supply a valid EE_Line_Item or a non-empty string to generate a reg_url_link.', |
|
91 | + 'event_espresso' |
|
92 | + ) |
|
93 | + ); |
|
94 | + } |
|
95 | + $this->reg_url_link = (string) apply_filters( |
|
96 | + 'FHEE__\EventEspresso\core\domain\entities\RegUrlLink__construct__reg_url_link', |
|
97 | + $reg_count . '-' . md5($base_code . microtime()), |
|
98 | + $reg_count, |
|
99 | + $base_code, |
|
100 | + $reg_url_link |
|
101 | + ); |
|
102 | + } |
|
103 | 103 | |
104 | 104 | |
105 | - /** |
|
106 | - * Return the object as a string |
|
107 | - * |
|
108 | - * @return string |
|
109 | - */ |
|
110 | - public function __toString() |
|
111 | - { |
|
112 | - return $this->reg_url_link; |
|
113 | - } |
|
105 | + /** |
|
106 | + * Return the object as a string |
|
107 | + * |
|
108 | + * @return string |
|
109 | + */ |
|
110 | + public function __toString() |
|
111 | + { |
|
112 | + return $this->reg_url_link; |
|
113 | + } |
|
114 | 114 | } |
@@ -30,132 +30,132 @@ |
||
30 | 30 | { |
31 | 31 | |
32 | 32 | |
33 | - /** |
|
34 | - * the actual shortcode tag that gets registered with WordPress |
|
35 | - * |
|
36 | - * @return string |
|
37 | - */ |
|
38 | - public function getTag() |
|
39 | - { |
|
40 | - return 'ESPRESSO_EVENTS'; |
|
41 | - } |
|
33 | + /** |
|
34 | + * the actual shortcode tag that gets registered with WordPress |
|
35 | + * |
|
36 | + * @return string |
|
37 | + */ |
|
38 | + public function getTag() |
|
39 | + { |
|
40 | + return 'ESPRESSO_EVENTS'; |
|
41 | + } |
|
42 | 42 | |
43 | 43 | |
44 | - /** |
|
45 | - * the time in seconds to cache the results of the processShortcode() method |
|
46 | - * 0 means the processShortcode() results will NOT be cached at all |
|
47 | - * |
|
48 | - * @return int |
|
49 | - */ |
|
50 | - public function cacheExpiration() |
|
51 | - { |
|
52 | - return 0; |
|
53 | - } |
|
44 | + /** |
|
45 | + * the time in seconds to cache the results of the processShortcode() method |
|
46 | + * 0 means the processShortcode() results will NOT be cached at all |
|
47 | + * |
|
48 | + * @return int |
|
49 | + */ |
|
50 | + public function cacheExpiration() |
|
51 | + { |
|
52 | + return 0; |
|
53 | + } |
|
54 | 54 | |
55 | 55 | |
56 | - /** |
|
57 | - * a place for adding any initialization code that needs to run prior to wp_header(). |
|
58 | - * this may be required for shortcodes that utilize a corresponding module, |
|
59 | - * and need to enqueue assets for that module |
|
60 | - * |
|
61 | - * @return void |
|
62 | - */ |
|
63 | - public function initializeShortcode() |
|
64 | - { |
|
65 | - EED_Events_Archive::instance()->event_list(); |
|
66 | - $this->shortcodeHasBeenInitialized(); |
|
67 | - } |
|
56 | + /** |
|
57 | + * a place for adding any initialization code that needs to run prior to wp_header(). |
|
58 | + * this may be required for shortcodes that utilize a corresponding module, |
|
59 | + * and need to enqueue assets for that module |
|
60 | + * |
|
61 | + * @return void |
|
62 | + */ |
|
63 | + public function initializeShortcode() |
|
64 | + { |
|
65 | + EED_Events_Archive::instance()->event_list(); |
|
66 | + $this->shortcodeHasBeenInitialized(); |
|
67 | + } |
|
68 | 68 | |
69 | 69 | |
70 | - /** |
|
71 | - * callback that runs when the shortcode is encountered in post content. |
|
72 | - * IMPORTANT !!! |
|
73 | - * remember that shortcode content should be RETURNED and NOT echoed out |
|
74 | - * |
|
75 | - * @param array $attributes |
|
76 | - * @return string |
|
77 | - */ |
|
78 | - public function processShortcode($attributes = array()) |
|
79 | - { |
|
80 | - // grab attributes and merge with defaults |
|
81 | - $attributes = $this->getAttributes($attributes); |
|
82 | - // make sure we use the_excerpt() |
|
83 | - add_filter('FHEE__EES_Espresso_Events__process_shortcode__true', '__return_true'); |
|
84 | - // apply query filters |
|
85 | - add_filter('FHEE__EEH_Event_Query__apply_query_filters', '__return_true'); |
|
86 | - // run the query |
|
87 | - global $wp_query; |
|
88 | - // yes we have to overwrite the main wp query, but it's ok... |
|
89 | - // we're going to reset it again below, so everything will be Hunky Dory (amazing album) |
|
90 | - $wp_query = new EventListQuery($attributes); |
|
91 | - // check what template is loaded and load filters accordingly |
|
92 | - EED_Events_Archive::instance()->template_include('loop-espresso_events.php'); |
|
93 | - // load our template |
|
94 | - $event_list = EEH_Template::locate_template( |
|
95 | - 'loop-espresso_events.php', |
|
96 | - array(), |
|
97 | - true, |
|
98 | - true |
|
99 | - ); |
|
100 | - // now reset the query and post data |
|
101 | - wp_reset_query(); |
|
102 | - wp_reset_postdata(); |
|
103 | - EED_Events_Archive::remove_all_events_archive_filters(); |
|
104 | - // remove query filters |
|
105 | - remove_filter('FHEE__EEH_Event_Query__apply_query_filters', '__return_true'); |
|
106 | - // pull our content from the output buffer and return it |
|
107 | - return $event_list; |
|
108 | - } |
|
70 | + /** |
|
71 | + * callback that runs when the shortcode is encountered in post content. |
|
72 | + * IMPORTANT !!! |
|
73 | + * remember that shortcode content should be RETURNED and NOT echoed out |
|
74 | + * |
|
75 | + * @param array $attributes |
|
76 | + * @return string |
|
77 | + */ |
|
78 | + public function processShortcode($attributes = array()) |
|
79 | + { |
|
80 | + // grab attributes and merge with defaults |
|
81 | + $attributes = $this->getAttributes($attributes); |
|
82 | + // make sure we use the_excerpt() |
|
83 | + add_filter('FHEE__EES_Espresso_Events__process_shortcode__true', '__return_true'); |
|
84 | + // apply query filters |
|
85 | + add_filter('FHEE__EEH_Event_Query__apply_query_filters', '__return_true'); |
|
86 | + // run the query |
|
87 | + global $wp_query; |
|
88 | + // yes we have to overwrite the main wp query, but it's ok... |
|
89 | + // we're going to reset it again below, so everything will be Hunky Dory (amazing album) |
|
90 | + $wp_query = new EventListQuery($attributes); |
|
91 | + // check what template is loaded and load filters accordingly |
|
92 | + EED_Events_Archive::instance()->template_include('loop-espresso_events.php'); |
|
93 | + // load our template |
|
94 | + $event_list = EEH_Template::locate_template( |
|
95 | + 'loop-espresso_events.php', |
|
96 | + array(), |
|
97 | + true, |
|
98 | + true |
|
99 | + ); |
|
100 | + // now reset the query and post data |
|
101 | + wp_reset_query(); |
|
102 | + wp_reset_postdata(); |
|
103 | + EED_Events_Archive::remove_all_events_archive_filters(); |
|
104 | + // remove query filters |
|
105 | + remove_filter('FHEE__EEH_Event_Query__apply_query_filters', '__return_true'); |
|
106 | + // pull our content from the output buffer and return it |
|
107 | + return $event_list; |
|
108 | + } |
|
109 | 109 | |
110 | 110 | |
111 | - /** |
|
112 | - * merge incoming attributes with filtered defaults |
|
113 | - * |
|
114 | - * @param array $attributes |
|
115 | - * @return array |
|
116 | - */ |
|
117 | - private function getAttributes(array $attributes) |
|
118 | - { |
|
119 | - return array_merge( |
|
120 | - (array) apply_filters( |
|
121 | - 'EES_Espresso_Events__process_shortcode__default_espresso_events_shortcode_atts', |
|
122 | - array( |
|
123 | - 'title' => '', |
|
124 | - 'limit' => 10, |
|
125 | - 'css_class' => '', |
|
126 | - 'show_expired' => false, |
|
127 | - 'month' => '', |
|
128 | - 'category_slug' => '', |
|
129 | - 'order_by' => 'start_date', |
|
130 | - 'sort' => 'ASC', |
|
131 | - 'show_title' => true, |
|
132 | - ) |
|
133 | - ), |
|
134 | - $attributes |
|
135 | - ); |
|
136 | - } |
|
111 | + /** |
|
112 | + * merge incoming attributes with filtered defaults |
|
113 | + * |
|
114 | + * @param array $attributes |
|
115 | + * @return array |
|
116 | + */ |
|
117 | + private function getAttributes(array $attributes) |
|
118 | + { |
|
119 | + return array_merge( |
|
120 | + (array) apply_filters( |
|
121 | + 'EES_Espresso_Events__process_shortcode__default_espresso_events_shortcode_atts', |
|
122 | + array( |
|
123 | + 'title' => '', |
|
124 | + 'limit' => 10, |
|
125 | + 'css_class' => '', |
|
126 | + 'show_expired' => false, |
|
127 | + 'month' => '', |
|
128 | + 'category_slug' => '', |
|
129 | + 'order_by' => 'start_date', |
|
130 | + 'sort' => 'ASC', |
|
131 | + 'show_title' => true, |
|
132 | + ) |
|
133 | + ), |
|
134 | + $attributes |
|
135 | + ); |
|
136 | + } |
|
137 | 137 | |
138 | 138 | |
139 | - /** |
|
140 | - * array for defining custom attribute sanitization callbacks, |
|
141 | - * where keys match keys in your attributes array, |
|
142 | - * and values represent the sanitization function you wish to be applied to that attribute. |
|
143 | - * So for example, if you had an integer attribute named "event_id" |
|
144 | - * that you wanted to be sanitized using absint(), |
|
145 | - * then you would pass the following for your $custom_sanitization array: |
|
146 | - * array('event_id' => 'absint') |
|
147 | - * |
|
148 | - * @return array |
|
149 | - */ |
|
150 | - protected function customAttributeSanitizationMap() |
|
151 | - { |
|
152 | - // the following get sanitized/whitelisted in EEH_Event_Query |
|
153 | - return array( |
|
154 | - 'category_slug' => 'skip_sanitization', |
|
155 | - 'show_expired' => 'skip_sanitization', |
|
156 | - 'order_by' => 'skip_sanitization', |
|
157 | - 'month' => 'skip_sanitization', |
|
158 | - 'sort' => 'skip_sanitization', |
|
159 | - ); |
|
160 | - } |
|
139 | + /** |
|
140 | + * array for defining custom attribute sanitization callbacks, |
|
141 | + * where keys match keys in your attributes array, |
|
142 | + * and values represent the sanitization function you wish to be applied to that attribute. |
|
143 | + * So for example, if you had an integer attribute named "event_id" |
|
144 | + * that you wanted to be sanitized using absint(), |
|
145 | + * then you would pass the following for your $custom_sanitization array: |
|
146 | + * array('event_id' => 'absint') |
|
147 | + * |
|
148 | + * @return array |
|
149 | + */ |
|
150 | + protected function customAttributeSanitizationMap() |
|
151 | + { |
|
152 | + // the following get sanitized/whitelisted in EEH_Event_Query |
|
153 | + return array( |
|
154 | + 'category_slug' => 'skip_sanitization', |
|
155 | + 'show_expired' => 'skip_sanitization', |
|
156 | + 'order_by' => 'skip_sanitization', |
|
157 | + 'month' => 'skip_sanitization', |
|
158 | + 'sort' => 'skip_sanitization', |
|
159 | + ); |
|
160 | + } |
|
161 | 161 | } |
@@ -12,205 +12,205 @@ |
||
12 | 12 | */ |
13 | 13 | class GenericAddress implements \EEI_Address |
14 | 14 | { |
15 | - // phpcs:disable PSR2.Classes.PropertyDeclaration.Underscore |
|
16 | - private $_address = ''; |
|
17 | - |
|
18 | - private $_address2 = ''; |
|
19 | - |
|
20 | - private $_city = ''; |
|
21 | - |
|
22 | - private $_state_ID = ''; |
|
23 | - |
|
24 | - private $_state_obj = ''; |
|
25 | - |
|
26 | - private $_zip = ''; |
|
27 | - |
|
28 | - private $_country_ID = ''; |
|
29 | - |
|
30 | - private $_country_obj = ''; |
|
31 | - // phpcs:enable |
|
32 | - |
|
33 | - // phpcs:disable PSR2.Methods.MethodDeclaration.Underscore |
|
34 | - /** |
|
35 | - * @param string $address |
|
36 | - * @param string $address2 |
|
37 | - * @param string $city |
|
38 | - * @param \EE_State | string $state |
|
39 | - * @param string $zip |
|
40 | - * @param \EE_Country | string $country |
|
41 | - * @return GenericAddress |
|
42 | - */ |
|
43 | - public function __construct($address, $address2, $city, $state, $zip, $country) |
|
44 | - { |
|
45 | - $this->_address = $address; |
|
46 | - $this->_address2 = $address2; |
|
47 | - $this->_city = $city; |
|
48 | - if ($state instanceof \EE_State) { |
|
49 | - $this->_state_obj = $state; |
|
50 | - } else { |
|
51 | - $this->_state_ID = $state; |
|
52 | - $this->_state_obj = $this->_get_state_obj(); |
|
53 | - } |
|
54 | - $this->_zip = $zip; |
|
55 | - if ($country instanceof \EE_Country) { |
|
56 | - $this->_country_obj = $country; |
|
57 | - } else { |
|
58 | - $this->_country_ID = $country; |
|
59 | - $this->_country_obj = $this->_get_country_obj(); |
|
60 | - } |
|
61 | - } |
|
62 | - |
|
63 | - |
|
64 | - /** |
|
65 | - * @return string |
|
66 | - */ |
|
67 | - public function address() |
|
68 | - { |
|
69 | - return $this->_address; |
|
70 | - } |
|
71 | - |
|
72 | - |
|
73 | - /** |
|
74 | - * @return string |
|
75 | - */ |
|
76 | - public function address2() |
|
77 | - { |
|
78 | - return $this->_address2; |
|
79 | - } |
|
80 | - |
|
81 | - |
|
82 | - /** |
|
83 | - * @return string |
|
84 | - */ |
|
85 | - public function city() |
|
86 | - { |
|
87 | - return $this->_city; |
|
88 | - } |
|
89 | - |
|
90 | - // phpcs:disable PSR1.Methods.CamelCapsMethodName.NotCamelCaps |
|
91 | - |
|
92 | - /** |
|
93 | - * @return \EE_State |
|
94 | - */ |
|
95 | - private function _get_state_obj() |
|
96 | - { |
|
97 | - return $this->_state_obj instanceof \EE_State |
|
98 | - ? $this->_state_obj |
|
99 | - : \EE_Registry::instance()->load_model('State')->get_one_by_ID($this->_state_ID); |
|
100 | - } |
|
101 | - |
|
102 | - |
|
103 | - /** |
|
104 | - * @return string |
|
105 | - */ |
|
106 | - public function state_ID() |
|
107 | - { |
|
108 | - return $this->_state_ID; |
|
109 | - } |
|
110 | - |
|
111 | - |
|
112 | - /** |
|
113 | - * @return string |
|
114 | - */ |
|
115 | - public function state_abbrev() |
|
116 | - { |
|
117 | - return $this->state_obj() instanceof \EE_State |
|
118 | - ? $this->state_obj()->abbrev() |
|
119 | - : ''; |
|
120 | - } |
|
121 | - |
|
122 | - |
|
123 | - /** |
|
124 | - * @return string |
|
125 | - */ |
|
126 | - public function state_name() |
|
127 | - { |
|
128 | - return $this->state_obj() instanceof \EE_State |
|
129 | - ? $this->state_obj()->name() |
|
130 | - : ''; |
|
131 | - } |
|
132 | - |
|
133 | - |
|
134 | - /** |
|
135 | - * @return \EE_State |
|
136 | - */ |
|
137 | - public function state_obj() |
|
138 | - { |
|
139 | - return $this->_state_obj; |
|
140 | - } |
|
141 | - |
|
142 | - |
|
143 | - /** |
|
144 | - * @return string |
|
145 | - */ |
|
146 | - public function state() |
|
147 | - { |
|
148 | - if (apply_filters('FHEE__EEI_Address__state__use_abbreviation', true, $this->state_obj())) { |
|
149 | - return $this->state_obj()->abbrev(); |
|
150 | - } else { |
|
151 | - return $this->state_name(); |
|
152 | - } |
|
153 | - } |
|
154 | - |
|
155 | - |
|
156 | - /** |
|
157 | - * @return \EE_Country |
|
158 | - */ |
|
159 | - private function _get_country_obj() |
|
160 | - { |
|
161 | - return $this->_country_obj instanceof \EE_Country |
|
162 | - ? $this->_country_obj |
|
163 | - : \EE_Registry::instance()->load_model('Country')->get_one_by_ID($this->_country_ID); |
|
164 | - } |
|
165 | - |
|
166 | - |
|
167 | - /** |
|
168 | - * @return string |
|
169 | - */ |
|
170 | - public function country_ID() |
|
171 | - { |
|
172 | - return $this->_country_ID; |
|
173 | - } |
|
174 | - |
|
175 | - |
|
176 | - /** |
|
177 | - * @return string |
|
178 | - */ |
|
179 | - public function country_name() |
|
180 | - { |
|
181 | - return $this->country_obj() instanceof \EE_Country |
|
182 | - ? $this->country_obj()->name() |
|
183 | - : ''; |
|
184 | - } |
|
185 | - |
|
186 | - |
|
187 | - /** |
|
188 | - * @return \EE_Country |
|
189 | - */ |
|
190 | - public function country_obj() |
|
191 | - { |
|
192 | - return $this->_country_obj; |
|
193 | - } |
|
194 | - |
|
195 | - |
|
196 | - /** |
|
197 | - * @return string |
|
198 | - */ |
|
199 | - public function country() |
|
200 | - { |
|
201 | - if (apply_filters('FHEE__EEI_Address__country__use_abbreviation', true, $this->country_obj())) { |
|
202 | - return $this->country_ID(); |
|
203 | - } else { |
|
204 | - return $this->country_name(); |
|
205 | - } |
|
206 | - } |
|
207 | - |
|
208 | - |
|
209 | - /** |
|
210 | - * @return string |
|
211 | - */ |
|
212 | - public function zip() |
|
213 | - { |
|
214 | - return $this->_zip; |
|
215 | - } |
|
15 | + // phpcs:disable PSR2.Classes.PropertyDeclaration.Underscore |
|
16 | + private $_address = ''; |
|
17 | + |
|
18 | + private $_address2 = ''; |
|
19 | + |
|
20 | + private $_city = ''; |
|
21 | + |
|
22 | + private $_state_ID = ''; |
|
23 | + |
|
24 | + private $_state_obj = ''; |
|
25 | + |
|
26 | + private $_zip = ''; |
|
27 | + |
|
28 | + private $_country_ID = ''; |
|
29 | + |
|
30 | + private $_country_obj = ''; |
|
31 | + // phpcs:enable |
|
32 | + |
|
33 | + // phpcs:disable PSR2.Methods.MethodDeclaration.Underscore |
|
34 | + /** |
|
35 | + * @param string $address |
|
36 | + * @param string $address2 |
|
37 | + * @param string $city |
|
38 | + * @param \EE_State | string $state |
|
39 | + * @param string $zip |
|
40 | + * @param \EE_Country | string $country |
|
41 | + * @return GenericAddress |
|
42 | + */ |
|
43 | + public function __construct($address, $address2, $city, $state, $zip, $country) |
|
44 | + { |
|
45 | + $this->_address = $address; |
|
46 | + $this->_address2 = $address2; |
|
47 | + $this->_city = $city; |
|
48 | + if ($state instanceof \EE_State) { |
|
49 | + $this->_state_obj = $state; |
|
50 | + } else { |
|
51 | + $this->_state_ID = $state; |
|
52 | + $this->_state_obj = $this->_get_state_obj(); |
|
53 | + } |
|
54 | + $this->_zip = $zip; |
|
55 | + if ($country instanceof \EE_Country) { |
|
56 | + $this->_country_obj = $country; |
|
57 | + } else { |
|
58 | + $this->_country_ID = $country; |
|
59 | + $this->_country_obj = $this->_get_country_obj(); |
|
60 | + } |
|
61 | + } |
|
62 | + |
|
63 | + |
|
64 | + /** |
|
65 | + * @return string |
|
66 | + */ |
|
67 | + public function address() |
|
68 | + { |
|
69 | + return $this->_address; |
|
70 | + } |
|
71 | + |
|
72 | + |
|
73 | + /** |
|
74 | + * @return string |
|
75 | + */ |
|
76 | + public function address2() |
|
77 | + { |
|
78 | + return $this->_address2; |
|
79 | + } |
|
80 | + |
|
81 | + |
|
82 | + /** |
|
83 | + * @return string |
|
84 | + */ |
|
85 | + public function city() |
|
86 | + { |
|
87 | + return $this->_city; |
|
88 | + } |
|
89 | + |
|
90 | + // phpcs:disable PSR1.Methods.CamelCapsMethodName.NotCamelCaps |
|
91 | + |
|
92 | + /** |
|
93 | + * @return \EE_State |
|
94 | + */ |
|
95 | + private function _get_state_obj() |
|
96 | + { |
|
97 | + return $this->_state_obj instanceof \EE_State |
|
98 | + ? $this->_state_obj |
|
99 | + : \EE_Registry::instance()->load_model('State')->get_one_by_ID($this->_state_ID); |
|
100 | + } |
|
101 | + |
|
102 | + |
|
103 | + /** |
|
104 | + * @return string |
|
105 | + */ |
|
106 | + public function state_ID() |
|
107 | + { |
|
108 | + return $this->_state_ID; |
|
109 | + } |
|
110 | + |
|
111 | + |
|
112 | + /** |
|
113 | + * @return string |
|
114 | + */ |
|
115 | + public function state_abbrev() |
|
116 | + { |
|
117 | + return $this->state_obj() instanceof \EE_State |
|
118 | + ? $this->state_obj()->abbrev() |
|
119 | + : ''; |
|
120 | + } |
|
121 | + |
|
122 | + |
|
123 | + /** |
|
124 | + * @return string |
|
125 | + */ |
|
126 | + public function state_name() |
|
127 | + { |
|
128 | + return $this->state_obj() instanceof \EE_State |
|
129 | + ? $this->state_obj()->name() |
|
130 | + : ''; |
|
131 | + } |
|
132 | + |
|
133 | + |
|
134 | + /** |
|
135 | + * @return \EE_State |
|
136 | + */ |
|
137 | + public function state_obj() |
|
138 | + { |
|
139 | + return $this->_state_obj; |
|
140 | + } |
|
141 | + |
|
142 | + |
|
143 | + /** |
|
144 | + * @return string |
|
145 | + */ |
|
146 | + public function state() |
|
147 | + { |
|
148 | + if (apply_filters('FHEE__EEI_Address__state__use_abbreviation', true, $this->state_obj())) { |
|
149 | + return $this->state_obj()->abbrev(); |
|
150 | + } else { |
|
151 | + return $this->state_name(); |
|
152 | + } |
|
153 | + } |
|
154 | + |
|
155 | + |
|
156 | + /** |
|
157 | + * @return \EE_Country |
|
158 | + */ |
|
159 | + private function _get_country_obj() |
|
160 | + { |
|
161 | + return $this->_country_obj instanceof \EE_Country |
|
162 | + ? $this->_country_obj |
|
163 | + : \EE_Registry::instance()->load_model('Country')->get_one_by_ID($this->_country_ID); |
|
164 | + } |
|
165 | + |
|
166 | + |
|
167 | + /** |
|
168 | + * @return string |
|
169 | + */ |
|
170 | + public function country_ID() |
|
171 | + { |
|
172 | + return $this->_country_ID; |
|
173 | + } |
|
174 | + |
|
175 | + |
|
176 | + /** |
|
177 | + * @return string |
|
178 | + */ |
|
179 | + public function country_name() |
|
180 | + { |
|
181 | + return $this->country_obj() instanceof \EE_Country |
|
182 | + ? $this->country_obj()->name() |
|
183 | + : ''; |
|
184 | + } |
|
185 | + |
|
186 | + |
|
187 | + /** |
|
188 | + * @return \EE_Country |
|
189 | + */ |
|
190 | + public function country_obj() |
|
191 | + { |
|
192 | + return $this->_country_obj; |
|
193 | + } |
|
194 | + |
|
195 | + |
|
196 | + /** |
|
197 | + * @return string |
|
198 | + */ |
|
199 | + public function country() |
|
200 | + { |
|
201 | + if (apply_filters('FHEE__EEI_Address__country__use_abbreviation', true, $this->country_obj())) { |
|
202 | + return $this->country_ID(); |
|
203 | + } else { |
|
204 | + return $this->country_name(); |
|
205 | + } |
|
206 | + } |
|
207 | + |
|
208 | + |
|
209 | + /** |
|
210 | + * @return string |
|
211 | + */ |
|
212 | + public function zip() |
|
213 | + { |
|
214 | + return $this->_zip; |
|
215 | + } |
|
216 | 216 | } |
@@ -16,198 +16,198 @@ |
||
16 | 16 | class EventListQuery extends WP_Query |
17 | 17 | { |
18 | 18 | |
19 | - /** |
|
20 | - * @var string $title |
|
21 | - */ |
|
22 | - private $title; |
|
23 | - |
|
24 | - /** |
|
25 | - * @var integer $limit |
|
26 | - */ |
|
27 | - private $limit = 10; |
|
28 | - |
|
29 | - /** |
|
30 | - * @var string $css_class |
|
31 | - */ |
|
32 | - private $css_class; |
|
33 | - |
|
34 | - /** |
|
35 | - * @var boolean $show_expired |
|
36 | - */ |
|
37 | - private $show_expired = false; |
|
38 | - |
|
39 | - /** |
|
40 | - * @var string $month |
|
41 | - */ |
|
42 | - private $month; |
|
43 | - |
|
44 | - /** |
|
45 | - * @var string $category_slug |
|
46 | - */ |
|
47 | - private $category_slug; |
|
48 | - |
|
49 | - /** |
|
50 | - * @var string $order_by |
|
51 | - */ |
|
52 | - private $order_by; |
|
53 | - |
|
54 | - /** |
|
55 | - * @var string $sort |
|
56 | - */ |
|
57 | - private $sort; |
|
58 | - |
|
59 | - /** |
|
60 | - * @var boolean $show_title |
|
61 | - */ |
|
62 | - private $show_title = true; |
|
63 | - |
|
64 | - |
|
65 | - /** |
|
66 | - * EE_Event_List_Query Constructor * |
|
67 | - * |
|
68 | - * @param array $args |
|
69 | - */ |
|
70 | - public function __construct($args = array()) |
|
71 | - { |
|
72 | - $args = $this->parseArgs((array) $args); |
|
73 | - $this->setupEventQueryHelper(); |
|
74 | - $this->setupFilters(); |
|
75 | - $args = $this->getQueryArgs($args); |
|
76 | - // run the query |
|
77 | - parent::__construct($args); |
|
78 | - } |
|
79 | - |
|
80 | - |
|
81 | - /** |
|
82 | - * @param array $args |
|
83 | - * @return array |
|
84 | - */ |
|
85 | - private function parseArgs(array $args) |
|
86 | - { |
|
87 | - // incoming args could be a mix of WP query args + EE shortcode args |
|
88 | - foreach ($args as $property => $value) { |
|
89 | - // if the arg is a property of this class, then it's an EE shortcode arg |
|
90 | - if (property_exists($this, $property) && ! property_exists('WP_Query', $property)) { |
|
91 | - // set the property value |
|
92 | - $this->{$property} = $value; |
|
93 | - // then remove it from the array of args that will later be passed to WP_Query() |
|
94 | - unset($args[ $property ]); |
|
95 | - } |
|
96 | - } |
|
97 | - return $args; |
|
98 | - } |
|
99 | - |
|
100 | - |
|
101 | - private function setupEventQueryHelper() |
|
102 | - { |
|
103 | - // add query filters |
|
104 | - EEH_Event_Query::add_query_filters(); |
|
105 | - // set params that will get used by the filters |
|
106 | - EEH_Event_Query::set_query_params( |
|
107 | - $this->month, |
|
108 | - $this->category_slug, |
|
109 | - $this->show_expired, |
|
110 | - $this->order_by, |
|
111 | - $this->sort |
|
112 | - ); |
|
113 | - } |
|
114 | - |
|
115 | - |
|
116 | - private function setupFilters() |
|
117 | - { |
|
118 | - // first off, let's remove any filters from previous queries |
|
119 | - remove_filter( |
|
120 | - 'FHEE__archive_espresso_events_template__show_header', |
|
121 | - array($this, 'show_event_list_title') |
|
122 | - ); |
|
123 | - remove_filter( |
|
124 | - 'FHEE__archive_espresso_events_template__upcoming_events_h1', |
|
125 | - array($this, 'event_list_title') |
|
126 | - ); |
|
127 | - remove_all_filters('FHEE__content_espresso_events__event_class'); |
|
128 | - // Event List Title ? |
|
129 | - add_filter( |
|
130 | - 'FHEE__archive_espresso_events_template__show_header', |
|
131 | - array($this, 'show_event_list_title') |
|
132 | - ); |
|
133 | - add_filter( |
|
134 | - 'FHEE__archive_espresso_events_template__upcoming_events_h1', |
|
135 | - array($this, 'event_list_title'), |
|
136 | - 10, |
|
137 | - 1 |
|
138 | - ); |
|
139 | - // add the css class |
|
140 | - add_filter( |
|
141 | - 'FHEE__content_espresso_events__event_class', |
|
142 | - array($this, 'event_list_css'), |
|
143 | - 10, |
|
144 | - 1 |
|
145 | - ); |
|
146 | - } |
|
147 | - |
|
148 | - |
|
149 | - private function getQueryArgs(array $args) |
|
150 | - { |
|
151 | - // the current "page" we are viewing |
|
152 | - $paged = max(1, get_query_var('paged')); |
|
153 | - // Force these args |
|
154 | - return array_merge( |
|
155 | - $args, |
|
156 | - array( |
|
157 | - 'post_type' => 'espresso_events', |
|
158 | - 'posts_per_page' => $this->limit, |
|
159 | - 'update_post_term_cache' => false, |
|
160 | - 'update_post_meta_cache' => false, |
|
161 | - 'paged' => $paged, |
|
162 | - 'offset' => ($paged - 1) * $this->limit, |
|
163 | - ) |
|
164 | - ); |
|
165 | - } |
|
166 | - |
|
167 | - // phpcs:disable PSR1.Methods.CamelCapsMethodName.NotCamelCaps |
|
168 | - |
|
169 | - /** |
|
170 | - * show_event_list_title |
|
171 | - * |
|
172 | - * @return boolean |
|
173 | - */ |
|
174 | - public function show_event_list_title() |
|
175 | - { |
|
176 | - return filter_var( |
|
177 | - $this->show_title, |
|
178 | - FILTER_VALIDATE_BOOLEAN |
|
179 | - ); |
|
180 | - } |
|
181 | - |
|
182 | - |
|
183 | - /** |
|
184 | - * callback for FHEE__archive_espresso_events_template__upcoming_events_h1 filter |
|
185 | - * |
|
186 | - * @param string $event_list_title |
|
187 | - * @return string |
|
188 | - */ |
|
189 | - public function event_list_title($event_list_title = '') |
|
190 | - { |
|
191 | - if (! empty($this->title)) { |
|
192 | - return $this->title; |
|
193 | - } |
|
194 | - return $event_list_title; |
|
195 | - } |
|
196 | - |
|
197 | - |
|
198 | - /** |
|
199 | - * callback for FHEE__content_espresso_events__event_class filter |
|
200 | - * |
|
201 | - * @param string $event_list_css |
|
202 | - * @return string |
|
203 | - */ |
|
204 | - public function event_list_css($event_list_css = '') |
|
205 | - { |
|
206 | - $event_list_css .= ! empty($event_list_css) ? ' ' : ''; |
|
207 | - $event_list_css .= ! empty($this->css_class) ? $this->css_class : ''; |
|
208 | - $event_list_css .= ! empty($event_list_css) ? ' ' : ''; |
|
209 | - $event_list_css .= ! empty($this->category_slug) ? $this->category_slug : ''; |
|
210 | - return $event_list_css; |
|
211 | - } |
|
212 | - // phpcs:enable |
|
19 | + /** |
|
20 | + * @var string $title |
|
21 | + */ |
|
22 | + private $title; |
|
23 | + |
|
24 | + /** |
|
25 | + * @var integer $limit |
|
26 | + */ |
|
27 | + private $limit = 10; |
|
28 | + |
|
29 | + /** |
|
30 | + * @var string $css_class |
|
31 | + */ |
|
32 | + private $css_class; |
|
33 | + |
|
34 | + /** |
|
35 | + * @var boolean $show_expired |
|
36 | + */ |
|
37 | + private $show_expired = false; |
|
38 | + |
|
39 | + /** |
|
40 | + * @var string $month |
|
41 | + */ |
|
42 | + private $month; |
|
43 | + |
|
44 | + /** |
|
45 | + * @var string $category_slug |
|
46 | + */ |
|
47 | + private $category_slug; |
|
48 | + |
|
49 | + /** |
|
50 | + * @var string $order_by |
|
51 | + */ |
|
52 | + private $order_by; |
|
53 | + |
|
54 | + /** |
|
55 | + * @var string $sort |
|
56 | + */ |
|
57 | + private $sort; |
|
58 | + |
|
59 | + /** |
|
60 | + * @var boolean $show_title |
|
61 | + */ |
|
62 | + private $show_title = true; |
|
63 | + |
|
64 | + |
|
65 | + /** |
|
66 | + * EE_Event_List_Query Constructor * |
|
67 | + * |
|
68 | + * @param array $args |
|
69 | + */ |
|
70 | + public function __construct($args = array()) |
|
71 | + { |
|
72 | + $args = $this->parseArgs((array) $args); |
|
73 | + $this->setupEventQueryHelper(); |
|
74 | + $this->setupFilters(); |
|
75 | + $args = $this->getQueryArgs($args); |
|
76 | + // run the query |
|
77 | + parent::__construct($args); |
|
78 | + } |
|
79 | + |
|
80 | + |
|
81 | + /** |
|
82 | + * @param array $args |
|
83 | + * @return array |
|
84 | + */ |
|
85 | + private function parseArgs(array $args) |
|
86 | + { |
|
87 | + // incoming args could be a mix of WP query args + EE shortcode args |
|
88 | + foreach ($args as $property => $value) { |
|
89 | + // if the arg is a property of this class, then it's an EE shortcode arg |
|
90 | + if (property_exists($this, $property) && ! property_exists('WP_Query', $property)) { |
|
91 | + // set the property value |
|
92 | + $this->{$property} = $value; |
|
93 | + // then remove it from the array of args that will later be passed to WP_Query() |
|
94 | + unset($args[ $property ]); |
|
95 | + } |
|
96 | + } |
|
97 | + return $args; |
|
98 | + } |
|
99 | + |
|
100 | + |
|
101 | + private function setupEventQueryHelper() |
|
102 | + { |
|
103 | + // add query filters |
|
104 | + EEH_Event_Query::add_query_filters(); |
|
105 | + // set params that will get used by the filters |
|
106 | + EEH_Event_Query::set_query_params( |
|
107 | + $this->month, |
|
108 | + $this->category_slug, |
|
109 | + $this->show_expired, |
|
110 | + $this->order_by, |
|
111 | + $this->sort |
|
112 | + ); |
|
113 | + } |
|
114 | + |
|
115 | + |
|
116 | + private function setupFilters() |
|
117 | + { |
|
118 | + // first off, let's remove any filters from previous queries |
|
119 | + remove_filter( |
|
120 | + 'FHEE__archive_espresso_events_template__show_header', |
|
121 | + array($this, 'show_event_list_title') |
|
122 | + ); |
|
123 | + remove_filter( |
|
124 | + 'FHEE__archive_espresso_events_template__upcoming_events_h1', |
|
125 | + array($this, 'event_list_title') |
|
126 | + ); |
|
127 | + remove_all_filters('FHEE__content_espresso_events__event_class'); |
|
128 | + // Event List Title ? |
|
129 | + add_filter( |
|
130 | + 'FHEE__archive_espresso_events_template__show_header', |
|
131 | + array($this, 'show_event_list_title') |
|
132 | + ); |
|
133 | + add_filter( |
|
134 | + 'FHEE__archive_espresso_events_template__upcoming_events_h1', |
|
135 | + array($this, 'event_list_title'), |
|
136 | + 10, |
|
137 | + 1 |
|
138 | + ); |
|
139 | + // add the css class |
|
140 | + add_filter( |
|
141 | + 'FHEE__content_espresso_events__event_class', |
|
142 | + array($this, 'event_list_css'), |
|
143 | + 10, |
|
144 | + 1 |
|
145 | + ); |
|
146 | + } |
|
147 | + |
|
148 | + |
|
149 | + private function getQueryArgs(array $args) |
|
150 | + { |
|
151 | + // the current "page" we are viewing |
|
152 | + $paged = max(1, get_query_var('paged')); |
|
153 | + // Force these args |
|
154 | + return array_merge( |
|
155 | + $args, |
|
156 | + array( |
|
157 | + 'post_type' => 'espresso_events', |
|
158 | + 'posts_per_page' => $this->limit, |
|
159 | + 'update_post_term_cache' => false, |
|
160 | + 'update_post_meta_cache' => false, |
|
161 | + 'paged' => $paged, |
|
162 | + 'offset' => ($paged - 1) * $this->limit, |
|
163 | + ) |
|
164 | + ); |
|
165 | + } |
|
166 | + |
|
167 | + // phpcs:disable PSR1.Methods.CamelCapsMethodName.NotCamelCaps |
|
168 | + |
|
169 | + /** |
|
170 | + * show_event_list_title |
|
171 | + * |
|
172 | + * @return boolean |
|
173 | + */ |
|
174 | + public function show_event_list_title() |
|
175 | + { |
|
176 | + return filter_var( |
|
177 | + $this->show_title, |
|
178 | + FILTER_VALIDATE_BOOLEAN |
|
179 | + ); |
|
180 | + } |
|
181 | + |
|
182 | + |
|
183 | + /** |
|
184 | + * callback for FHEE__archive_espresso_events_template__upcoming_events_h1 filter |
|
185 | + * |
|
186 | + * @param string $event_list_title |
|
187 | + * @return string |
|
188 | + */ |
|
189 | + public function event_list_title($event_list_title = '') |
|
190 | + { |
|
191 | + if (! empty($this->title)) { |
|
192 | + return $this->title; |
|
193 | + } |
|
194 | + return $event_list_title; |
|
195 | + } |
|
196 | + |
|
197 | + |
|
198 | + /** |
|
199 | + * callback for FHEE__content_espresso_events__event_class filter |
|
200 | + * |
|
201 | + * @param string $event_list_css |
|
202 | + * @return string |
|
203 | + */ |
|
204 | + public function event_list_css($event_list_css = '') |
|
205 | + { |
|
206 | + $event_list_css .= ! empty($event_list_css) ? ' ' : ''; |
|
207 | + $event_list_css .= ! empty($this->css_class) ? $this->css_class : ''; |
|
208 | + $event_list_css .= ! empty($event_list_css) ? ' ' : ''; |
|
209 | + $event_list_css .= ! empty($this->category_slug) ? $this->category_slug : ''; |
|
210 | + return $event_list_css; |
|
211 | + } |
|
212 | + // phpcs:enable |
|
213 | 213 | } |
@@ -91,7 +91,7 @@ discard block |
||
91 | 91 | // set the property value |
92 | 92 | $this->{$property} = $value; |
93 | 93 | // then remove it from the array of args that will later be passed to WP_Query() |
94 | - unset($args[ $property ]); |
|
94 | + unset($args[$property]); |
|
95 | 95 | } |
96 | 96 | } |
97 | 97 | return $args; |
@@ -188,7 +188,7 @@ discard block |
||
188 | 188 | */ |
189 | 189 | public function event_list_title($event_list_title = '') |
190 | 190 | { |
191 | - if (! empty($this->title)) { |
|
191 | + if ( ! empty($this->title)) { |
|
192 | 192 | return $this->title; |
193 | 193 | } |
194 | 194 | return $event_list_title; |
@@ -15,112 +15,112 @@ |
||
15 | 15 | class Basic implements EmailValidatorInterface |
16 | 16 | { |
17 | 17 | |
18 | - /** |
|
19 | - * @param string $email_address |
|
20 | - * @return bool |
|
21 | - * @throws EmailValidationException |
|
22 | - */ |
|
23 | - public function validate($email_address) |
|
24 | - { |
|
25 | - if (! preg_match('/^.+\@\S+$/', $email_address)) { |
|
26 | - // email not in correct {string}@{string} format |
|
27 | - throw new EmailValidationException( |
|
28 | - esc_html__('Email does not have the required @ sign.', 'event_espresso') |
|
29 | - ); |
|
30 | - } |
|
31 | - $atIndex = $this->getAtIndex($email_address); |
|
32 | - $local = $this->getLocalPartOfEmail($email_address, $atIndex); |
|
33 | - $localLen = strlen($local); |
|
34 | - if ($localLen < 1) { |
|
35 | - // no local part |
|
36 | - throw new EmailValidationException( |
|
37 | - esc_html__('Email local-part (before the @) is required.', 'event_espresso') |
|
38 | - ); |
|
39 | - } |
|
40 | - if ($localLen > 64) { |
|
41 | - // local part length exceeded |
|
42 | - throw new EmailValidationException( |
|
43 | - esc_html__('Email local-part (before the @) is too long.', 'event_espresso') |
|
44 | - ); |
|
45 | - } |
|
46 | - if ($local[0] === '.') { |
|
47 | - // local part starts with '.' |
|
48 | - throw new EmailValidationException( |
|
49 | - esc_html__('Email local-part (before the @) must not begin with a period.', 'event_espresso') |
|
50 | - ); |
|
51 | - } |
|
52 | - if ($local[ $localLen - 1 ] === '.') { |
|
53 | - // local part starts or ends with '.' |
|
54 | - throw new EmailValidationException( |
|
55 | - esc_html__('Email local-part (before the @) must not end with a period.', 'event_espresso') |
|
56 | - ); |
|
57 | - } |
|
58 | - if (preg_match('/\\.\\./', $local)) { |
|
59 | - // local part has two consecutive dots |
|
60 | - throw new EmailValidationException( |
|
61 | - esc_html__( |
|
62 | - 'Email local-part (before the @) must not have two consecutive periods.', |
|
63 | - 'event_espresso' |
|
64 | - ) |
|
65 | - ); |
|
66 | - } |
|
67 | - $domain = $this->getDomainPartOfEmail($email_address, $atIndex); |
|
68 | - $domainLen = strlen($domain); |
|
69 | - if ($domainLen < 1) { |
|
70 | - throw new EmailValidationException( |
|
71 | - esc_html__('Email domain (after the @) is required.', 'event_espresso') |
|
72 | - ); |
|
73 | - } |
|
74 | - if ($domainLen > 255) { |
|
75 | - // domain part length exceeded |
|
76 | - throw new EmailValidationException( |
|
77 | - esc_html__('Email domain (after the @) is too long.', 'event_espresso') |
|
78 | - ); |
|
79 | - } |
|
80 | - if (preg_match('/\\.\\./', $domain)) { |
|
81 | - // domain part has two consecutive dots |
|
82 | - throw new EmailValidationException( |
|
83 | - esc_html__('Email domain (after the @) must not have two consecutive periods.', 'event_espresso') |
|
84 | - ); |
|
85 | - } |
|
86 | - return true; |
|
87 | - } |
|
18 | + /** |
|
19 | + * @param string $email_address |
|
20 | + * @return bool |
|
21 | + * @throws EmailValidationException |
|
22 | + */ |
|
23 | + public function validate($email_address) |
|
24 | + { |
|
25 | + if (! preg_match('/^.+\@\S+$/', $email_address)) { |
|
26 | + // email not in correct {string}@{string} format |
|
27 | + throw new EmailValidationException( |
|
28 | + esc_html__('Email does not have the required @ sign.', 'event_espresso') |
|
29 | + ); |
|
30 | + } |
|
31 | + $atIndex = $this->getAtIndex($email_address); |
|
32 | + $local = $this->getLocalPartOfEmail($email_address, $atIndex); |
|
33 | + $localLen = strlen($local); |
|
34 | + if ($localLen < 1) { |
|
35 | + // no local part |
|
36 | + throw new EmailValidationException( |
|
37 | + esc_html__('Email local-part (before the @) is required.', 'event_espresso') |
|
38 | + ); |
|
39 | + } |
|
40 | + if ($localLen > 64) { |
|
41 | + // local part length exceeded |
|
42 | + throw new EmailValidationException( |
|
43 | + esc_html__('Email local-part (before the @) is too long.', 'event_espresso') |
|
44 | + ); |
|
45 | + } |
|
46 | + if ($local[0] === '.') { |
|
47 | + // local part starts with '.' |
|
48 | + throw new EmailValidationException( |
|
49 | + esc_html__('Email local-part (before the @) must not begin with a period.', 'event_espresso') |
|
50 | + ); |
|
51 | + } |
|
52 | + if ($local[ $localLen - 1 ] === '.') { |
|
53 | + // local part starts or ends with '.' |
|
54 | + throw new EmailValidationException( |
|
55 | + esc_html__('Email local-part (before the @) must not end with a period.', 'event_espresso') |
|
56 | + ); |
|
57 | + } |
|
58 | + if (preg_match('/\\.\\./', $local)) { |
|
59 | + // local part has two consecutive dots |
|
60 | + throw new EmailValidationException( |
|
61 | + esc_html__( |
|
62 | + 'Email local-part (before the @) must not have two consecutive periods.', |
|
63 | + 'event_espresso' |
|
64 | + ) |
|
65 | + ); |
|
66 | + } |
|
67 | + $domain = $this->getDomainPartOfEmail($email_address, $atIndex); |
|
68 | + $domainLen = strlen($domain); |
|
69 | + if ($domainLen < 1) { |
|
70 | + throw new EmailValidationException( |
|
71 | + esc_html__('Email domain (after the @) is required.', 'event_espresso') |
|
72 | + ); |
|
73 | + } |
|
74 | + if ($domainLen > 255) { |
|
75 | + // domain part length exceeded |
|
76 | + throw new EmailValidationException( |
|
77 | + esc_html__('Email domain (after the @) is too long.', 'event_espresso') |
|
78 | + ); |
|
79 | + } |
|
80 | + if (preg_match('/\\.\\./', $domain)) { |
|
81 | + // domain part has two consecutive dots |
|
82 | + throw new EmailValidationException( |
|
83 | + esc_html__('Email domain (after the @) must not have two consecutive periods.', 'event_espresso') |
|
84 | + ); |
|
85 | + } |
|
86 | + return true; |
|
87 | + } |
|
88 | 88 | |
89 | 89 | |
90 | - /** |
|
91 | - * returns the location of the @ symbol |
|
92 | - * |
|
93 | - * @param string $email_address |
|
94 | - * @return bool|string |
|
95 | - */ |
|
96 | - protected function getAtIndex($email_address) |
|
97 | - { |
|
98 | - return strrpos($email_address, '@'); |
|
99 | - } |
|
90 | + /** |
|
91 | + * returns the location of the @ symbol |
|
92 | + * |
|
93 | + * @param string $email_address |
|
94 | + * @return bool|string |
|
95 | + */ |
|
96 | + protected function getAtIndex($email_address) |
|
97 | + { |
|
98 | + return strrpos($email_address, '@'); |
|
99 | + } |
|
100 | 100 | |
101 | 101 | |
102 | - /** |
|
103 | - * Gets the local part of the email |
|
104 | - * |
|
105 | - * @param string $email_address |
|
106 | - * @param bool|int $atIndex |
|
107 | - * @return bool|string |
|
108 | - */ |
|
109 | - protected function getLocalPartOfEmail($email_address, $atIndex) |
|
110 | - { |
|
111 | - return substr($email_address, 0, $atIndex); |
|
112 | - } |
|
102 | + /** |
|
103 | + * Gets the local part of the email |
|
104 | + * |
|
105 | + * @param string $email_address |
|
106 | + * @param bool|int $atIndex |
|
107 | + * @return bool|string |
|
108 | + */ |
|
109 | + protected function getLocalPartOfEmail($email_address, $atIndex) |
|
110 | + { |
|
111 | + return substr($email_address, 0, $atIndex); |
|
112 | + } |
|
113 | 113 | |
114 | 114 | |
115 | - /** |
|
116 | - * Gets the domain part of the email |
|
117 | - * |
|
118 | - * @param string $email_address |
|
119 | - * @param bool|int $atIndex |
|
120 | - * @return bool|string |
|
121 | - */ |
|
122 | - protected function getDomainPartOfEmail($email_address, $atIndex) |
|
123 | - { |
|
124 | - return substr($email_address, $atIndex + 1); |
|
125 | - } |
|
115 | + /** |
|
116 | + * Gets the domain part of the email |
|
117 | + * |
|
118 | + * @param string $email_address |
|
119 | + * @param bool|int $atIndex |
|
120 | + * @return bool|string |
|
121 | + */ |
|
122 | + protected function getDomainPartOfEmail($email_address, $atIndex) |
|
123 | + { |
|
124 | + return substr($email_address, $atIndex + 1); |
|
125 | + } |
|
126 | 126 | } |
@@ -22,7 +22,7 @@ discard block |
||
22 | 22 | */ |
23 | 23 | public function validate($email_address) |
24 | 24 | { |
25 | - if (! preg_match('/^.+\@\S+$/', $email_address)) { |
|
25 | + if ( ! preg_match('/^.+\@\S+$/', $email_address)) { |
|
26 | 26 | // email not in correct {string}@{string} format |
27 | 27 | throw new EmailValidationException( |
28 | 28 | esc_html__('Email does not have the required @ sign.', 'event_espresso') |
@@ -49,7 +49,7 @@ discard block |
||
49 | 49 | esc_html__('Email local-part (before the @) must not begin with a period.', 'event_espresso') |
50 | 50 | ); |
51 | 51 | } |
52 | - if ($local[ $localLen - 1 ] === '.') { |
|
52 | + if ($local[$localLen - 1] === '.') { |
|
53 | 53 | // local part starts or ends with '.' |
54 | 54 | throw new EmailValidationException( |
55 | 55 | esc_html__('Email local-part (before the @) must not end with a period.', 'event_espresso') |