@@ -157,7 +157,7 @@ |
||
| 157 | 157 | */ |
| 158 | 158 | private function setType($type) |
| 159 | 159 | { |
| 160 | - if (! in_array($type, $this->types(), true)) { |
|
| 160 | + if ( ! in_array($type, $this->types(), true)) { |
|
| 161 | 161 | throw new InvalidDataTypeException( |
| 162 | 162 | '$type', |
| 163 | 163 | $type, |
@@ -13,253 +13,253 @@ |
||
| 13 | 13 | */ |
| 14 | 14 | class Notice implements NoticeInterface |
| 15 | 15 | { |
| 16 | - const ERROR = 'error'; |
|
| 17 | - |
|
| 18 | - const SUCCESS = 'success'; |
|
| 19 | - |
|
| 20 | - const ATTENTION = 'attention'; // alias for warning |
|
| 21 | - |
|
| 22 | - const INFORMATION = 'information'; |
|
| 23 | - |
|
| 24 | - /** |
|
| 25 | - * @var string $type |
|
| 26 | - */ |
|
| 27 | - private $type; |
|
| 28 | - |
|
| 29 | - |
|
| 30 | - /** |
|
| 31 | - * @var string $message |
|
| 32 | - */ |
|
| 33 | - private $message; |
|
| 34 | - |
|
| 35 | - |
|
| 36 | - /** |
|
| 37 | - * @var string $file |
|
| 38 | - */ |
|
| 39 | - private $file; |
|
| 40 | - |
|
| 41 | - |
|
| 42 | - /** |
|
| 43 | - * @var string $func |
|
| 44 | - */ |
|
| 45 | - private $func; |
|
| 46 | - |
|
| 47 | - |
|
| 48 | - /** |
|
| 49 | - * @var string $line |
|
| 50 | - */ |
|
| 51 | - private $line; |
|
| 52 | - |
|
| 53 | - |
|
| 54 | - /** |
|
| 55 | - * @var boolean $dismissible |
|
| 56 | - */ |
|
| 57 | - private $dismissible; |
|
| 58 | - |
|
| 59 | - |
|
| 60 | - /** |
|
| 61 | - * Notice constructor. |
|
| 62 | - * |
|
| 63 | - * @param string $type |
|
| 64 | - * @param string $message |
|
| 65 | - * @param bool $dismissible |
|
| 66 | - * @param string $file |
|
| 67 | - * @param string $func |
|
| 68 | - * @param string $line |
|
| 69 | - * @throws InvalidDataTypeException |
|
| 70 | - */ |
|
| 71 | - public function __construct($type, $message, $dismissible = true, $file = '', $func = '', $line = '') |
|
| 72 | - { |
|
| 73 | - $this->setType($type); |
|
| 74 | - $this->setMessage($message); |
|
| 75 | - $this->setDismissible($dismissible); |
|
| 76 | - $this->setFile($file); |
|
| 77 | - $this->setFunc($func); |
|
| 78 | - $this->setLine($line); |
|
| 79 | - } |
|
| 80 | - |
|
| 81 | - |
|
| 82 | - /** |
|
| 83 | - * @return array |
|
| 84 | - */ |
|
| 85 | - private function types() |
|
| 86 | - { |
|
| 87 | - return (array) apply_filters( |
|
| 88 | - 'FHEE__EventEspresso_core_services_notices_Notice__types', |
|
| 89 | - array( |
|
| 90 | - Notice::ERROR, |
|
| 91 | - Notice::SUCCESS, |
|
| 92 | - Notice::ATTENTION, |
|
| 93 | - Notice::INFORMATION, |
|
| 94 | - ) |
|
| 95 | - ); |
|
| 96 | - } |
|
| 97 | - |
|
| 98 | - |
|
| 99 | - /** |
|
| 100 | - * @return string |
|
| 101 | - */ |
|
| 102 | - public function type() |
|
| 103 | - { |
|
| 104 | - return $this->type; |
|
| 105 | - } |
|
| 106 | - |
|
| 107 | - |
|
| 108 | - /** |
|
| 109 | - * @return string |
|
| 110 | - */ |
|
| 111 | - public function message() |
|
| 112 | - { |
|
| 113 | - return $this->message; |
|
| 114 | - } |
|
| 115 | - |
|
| 116 | - |
|
| 117 | - /** |
|
| 118 | - * @return string |
|
| 119 | - */ |
|
| 120 | - public function file() |
|
| 121 | - { |
|
| 122 | - return $this->file; |
|
| 123 | - } |
|
| 124 | - |
|
| 125 | - |
|
| 126 | - /** |
|
| 127 | - * @return string |
|
| 128 | - */ |
|
| 129 | - public function func() |
|
| 130 | - { |
|
| 131 | - return $this->func; |
|
| 132 | - } |
|
| 133 | - |
|
| 134 | - |
|
| 135 | - /** |
|
| 136 | - * @return string |
|
| 137 | - */ |
|
| 138 | - public function line() |
|
| 139 | - { |
|
| 140 | - return $this->line; |
|
| 141 | - } |
|
| 142 | - |
|
| 143 | - |
|
| 144 | - /** |
|
| 145 | - * @return bool |
|
| 146 | - */ |
|
| 147 | - public function isDismissible() |
|
| 148 | - { |
|
| 149 | - return $this->dismissible; |
|
| 150 | - } |
|
| 151 | - |
|
| 152 | - |
|
| 153 | - /** |
|
| 154 | - * @param string $type |
|
| 155 | - * @throws InvalidDataTypeException |
|
| 156 | - */ |
|
| 157 | - private function setType($type) |
|
| 158 | - { |
|
| 159 | - if (! in_array($type, $this->types(), true)) { |
|
| 160 | - throw new InvalidDataTypeException( |
|
| 161 | - '$type', |
|
| 162 | - $type, |
|
| 163 | - $this->invalidTypeMessage() |
|
| 164 | - ); |
|
| 165 | - } |
|
| 166 | - $this->type = $type; |
|
| 167 | - } |
|
| 168 | - |
|
| 169 | - |
|
| 170 | - /** |
|
| 171 | - * gets the $invalid_type_message string |
|
| 172 | - */ |
|
| 173 | - private function invalidTypeMessage() |
|
| 174 | - { |
|
| 175 | - return apply_filters( |
|
| 176 | - 'FHEE__EventEspresso_core_services_notices_Notice__invalidTypeMessage', |
|
| 177 | - sprintf( |
|
| 178 | - esc_html__( |
|
| 179 | - ' one of the following notice types was expected: %1$s %2$s', |
|
| 180 | - 'event_espresso' |
|
| 181 | - ), |
|
| 182 | - '<br />', |
|
| 183 | - var_export($this->types(), true) |
|
| 184 | - ) |
|
| 185 | - ); |
|
| 186 | - } |
|
| 187 | - |
|
| 188 | - |
|
| 189 | - /** |
|
| 190 | - * @param string $message |
|
| 191 | - * @throws InvalidDataTypeException |
|
| 192 | - */ |
|
| 193 | - private function setMessage($message) |
|
| 194 | - { |
|
| 195 | - if (empty($message) || ! is_string($message)) { |
|
| 196 | - throw new InvalidDataTypeException( |
|
| 197 | - '$message', |
|
| 198 | - $message, |
|
| 199 | - esc_html__('non empty string', 'event_espresso') |
|
| 200 | - ); |
|
| 201 | - } |
|
| 202 | - $this->message = sanitize_text_field($message); |
|
| 203 | - } |
|
| 204 | - |
|
| 205 | - |
|
| 206 | - /** |
|
| 207 | - * @param string $file |
|
| 208 | - * @throws InvalidDataTypeException |
|
| 209 | - */ |
|
| 210 | - private function setFile($file) |
|
| 211 | - { |
|
| 212 | - if ($this->type === Notice::ERROR && (empty($file) || ! is_string($file))) { |
|
| 213 | - throw new InvalidDataTypeException( |
|
| 214 | - '$file', |
|
| 215 | - $file, |
|
| 216 | - esc_html__('non empty string', 'event_espresso') |
|
| 217 | - ); |
|
| 218 | - } |
|
| 219 | - $this->file = sanitize_text_field($file); |
|
| 220 | - } |
|
| 221 | - |
|
| 222 | - |
|
| 223 | - /** |
|
| 224 | - * @param string $func |
|
| 225 | - * @throws InvalidDataTypeException |
|
| 226 | - */ |
|
| 227 | - private function setFunc($func) |
|
| 228 | - { |
|
| 229 | - if ($this->type === Notice::ERROR && (empty($func) || ! is_string($func))) { |
|
| 230 | - throw new InvalidDataTypeException( |
|
| 231 | - '$func', |
|
| 232 | - $func, |
|
| 233 | - esc_html__('non empty string', 'event_espresso') |
|
| 234 | - ); |
|
| 235 | - } |
|
| 236 | - $this->func = sanitize_text_field($func); |
|
| 237 | - } |
|
| 238 | - |
|
| 239 | - |
|
| 240 | - /** |
|
| 241 | - * @param int $line |
|
| 242 | - * @throws InvalidDataTypeException |
|
| 243 | - */ |
|
| 244 | - private function setLine($line) |
|
| 245 | - { |
|
| 246 | - $line = absint($line); |
|
| 247 | - if ($this->type === Notice::ERROR && $line === 0) { |
|
| 248 | - throw new InvalidDataTypeException( |
|
| 249 | - '$line', |
|
| 250 | - $line, |
|
| 251 | - esc_html__('integer', 'event_espresso') |
|
| 252 | - ); |
|
| 253 | - } |
|
| 254 | - $this->line = sanitize_text_field($line); |
|
| 255 | - } |
|
| 256 | - |
|
| 257 | - |
|
| 258 | - /** |
|
| 259 | - * @param boolean $dismissible |
|
| 260 | - */ |
|
| 261 | - private function setDismissible($dismissible = true) |
|
| 262 | - { |
|
| 263 | - $this->dismissible = filter_var($dismissible, FILTER_VALIDATE_BOOLEAN); |
|
| 264 | - } |
|
| 16 | + const ERROR = 'error'; |
|
| 17 | + |
|
| 18 | + const SUCCESS = 'success'; |
|
| 19 | + |
|
| 20 | + const ATTENTION = 'attention'; // alias for warning |
|
| 21 | + |
|
| 22 | + const INFORMATION = 'information'; |
|
| 23 | + |
|
| 24 | + /** |
|
| 25 | + * @var string $type |
|
| 26 | + */ |
|
| 27 | + private $type; |
|
| 28 | + |
|
| 29 | + |
|
| 30 | + /** |
|
| 31 | + * @var string $message |
|
| 32 | + */ |
|
| 33 | + private $message; |
|
| 34 | + |
|
| 35 | + |
|
| 36 | + /** |
|
| 37 | + * @var string $file |
|
| 38 | + */ |
|
| 39 | + private $file; |
|
| 40 | + |
|
| 41 | + |
|
| 42 | + /** |
|
| 43 | + * @var string $func |
|
| 44 | + */ |
|
| 45 | + private $func; |
|
| 46 | + |
|
| 47 | + |
|
| 48 | + /** |
|
| 49 | + * @var string $line |
|
| 50 | + */ |
|
| 51 | + private $line; |
|
| 52 | + |
|
| 53 | + |
|
| 54 | + /** |
|
| 55 | + * @var boolean $dismissible |
|
| 56 | + */ |
|
| 57 | + private $dismissible; |
|
| 58 | + |
|
| 59 | + |
|
| 60 | + /** |
|
| 61 | + * Notice constructor. |
|
| 62 | + * |
|
| 63 | + * @param string $type |
|
| 64 | + * @param string $message |
|
| 65 | + * @param bool $dismissible |
|
| 66 | + * @param string $file |
|
| 67 | + * @param string $func |
|
| 68 | + * @param string $line |
|
| 69 | + * @throws InvalidDataTypeException |
|
| 70 | + */ |
|
| 71 | + public function __construct($type, $message, $dismissible = true, $file = '', $func = '', $line = '') |
|
| 72 | + { |
|
| 73 | + $this->setType($type); |
|
| 74 | + $this->setMessage($message); |
|
| 75 | + $this->setDismissible($dismissible); |
|
| 76 | + $this->setFile($file); |
|
| 77 | + $this->setFunc($func); |
|
| 78 | + $this->setLine($line); |
|
| 79 | + } |
|
| 80 | + |
|
| 81 | + |
|
| 82 | + /** |
|
| 83 | + * @return array |
|
| 84 | + */ |
|
| 85 | + private function types() |
|
| 86 | + { |
|
| 87 | + return (array) apply_filters( |
|
| 88 | + 'FHEE__EventEspresso_core_services_notices_Notice__types', |
|
| 89 | + array( |
|
| 90 | + Notice::ERROR, |
|
| 91 | + Notice::SUCCESS, |
|
| 92 | + Notice::ATTENTION, |
|
| 93 | + Notice::INFORMATION, |
|
| 94 | + ) |
|
| 95 | + ); |
|
| 96 | + } |
|
| 97 | + |
|
| 98 | + |
|
| 99 | + /** |
|
| 100 | + * @return string |
|
| 101 | + */ |
|
| 102 | + public function type() |
|
| 103 | + { |
|
| 104 | + return $this->type; |
|
| 105 | + } |
|
| 106 | + |
|
| 107 | + |
|
| 108 | + /** |
|
| 109 | + * @return string |
|
| 110 | + */ |
|
| 111 | + public function message() |
|
| 112 | + { |
|
| 113 | + return $this->message; |
|
| 114 | + } |
|
| 115 | + |
|
| 116 | + |
|
| 117 | + /** |
|
| 118 | + * @return string |
|
| 119 | + */ |
|
| 120 | + public function file() |
|
| 121 | + { |
|
| 122 | + return $this->file; |
|
| 123 | + } |
|
| 124 | + |
|
| 125 | + |
|
| 126 | + /** |
|
| 127 | + * @return string |
|
| 128 | + */ |
|
| 129 | + public function func() |
|
| 130 | + { |
|
| 131 | + return $this->func; |
|
| 132 | + } |
|
| 133 | + |
|
| 134 | + |
|
| 135 | + /** |
|
| 136 | + * @return string |
|
| 137 | + */ |
|
| 138 | + public function line() |
|
| 139 | + { |
|
| 140 | + return $this->line; |
|
| 141 | + } |
|
| 142 | + |
|
| 143 | + |
|
| 144 | + /** |
|
| 145 | + * @return bool |
|
| 146 | + */ |
|
| 147 | + public function isDismissible() |
|
| 148 | + { |
|
| 149 | + return $this->dismissible; |
|
| 150 | + } |
|
| 151 | + |
|
| 152 | + |
|
| 153 | + /** |
|
| 154 | + * @param string $type |
|
| 155 | + * @throws InvalidDataTypeException |
|
| 156 | + */ |
|
| 157 | + private function setType($type) |
|
| 158 | + { |
|
| 159 | + if (! in_array($type, $this->types(), true)) { |
|
| 160 | + throw new InvalidDataTypeException( |
|
| 161 | + '$type', |
|
| 162 | + $type, |
|
| 163 | + $this->invalidTypeMessage() |
|
| 164 | + ); |
|
| 165 | + } |
|
| 166 | + $this->type = $type; |
|
| 167 | + } |
|
| 168 | + |
|
| 169 | + |
|
| 170 | + /** |
|
| 171 | + * gets the $invalid_type_message string |
|
| 172 | + */ |
|
| 173 | + private function invalidTypeMessage() |
|
| 174 | + { |
|
| 175 | + return apply_filters( |
|
| 176 | + 'FHEE__EventEspresso_core_services_notices_Notice__invalidTypeMessage', |
|
| 177 | + sprintf( |
|
| 178 | + esc_html__( |
|
| 179 | + ' one of the following notice types was expected: %1$s %2$s', |
|
| 180 | + 'event_espresso' |
|
| 181 | + ), |
|
| 182 | + '<br />', |
|
| 183 | + var_export($this->types(), true) |
|
| 184 | + ) |
|
| 185 | + ); |
|
| 186 | + } |
|
| 187 | + |
|
| 188 | + |
|
| 189 | + /** |
|
| 190 | + * @param string $message |
|
| 191 | + * @throws InvalidDataTypeException |
|
| 192 | + */ |
|
| 193 | + private function setMessage($message) |
|
| 194 | + { |
|
| 195 | + if (empty($message) || ! is_string($message)) { |
|
| 196 | + throw new InvalidDataTypeException( |
|
| 197 | + '$message', |
|
| 198 | + $message, |
|
| 199 | + esc_html__('non empty string', 'event_espresso') |
|
| 200 | + ); |
|
| 201 | + } |
|
| 202 | + $this->message = sanitize_text_field($message); |
|
| 203 | + } |
|
| 204 | + |
|
| 205 | + |
|
| 206 | + /** |
|
| 207 | + * @param string $file |
|
| 208 | + * @throws InvalidDataTypeException |
|
| 209 | + */ |
|
| 210 | + private function setFile($file) |
|
| 211 | + { |
|
| 212 | + if ($this->type === Notice::ERROR && (empty($file) || ! is_string($file))) { |
|
| 213 | + throw new InvalidDataTypeException( |
|
| 214 | + '$file', |
|
| 215 | + $file, |
|
| 216 | + esc_html__('non empty string', 'event_espresso') |
|
| 217 | + ); |
|
| 218 | + } |
|
| 219 | + $this->file = sanitize_text_field($file); |
|
| 220 | + } |
|
| 221 | + |
|
| 222 | + |
|
| 223 | + /** |
|
| 224 | + * @param string $func |
|
| 225 | + * @throws InvalidDataTypeException |
|
| 226 | + */ |
|
| 227 | + private function setFunc($func) |
|
| 228 | + { |
|
| 229 | + if ($this->type === Notice::ERROR && (empty($func) || ! is_string($func))) { |
|
| 230 | + throw new InvalidDataTypeException( |
|
| 231 | + '$func', |
|
| 232 | + $func, |
|
| 233 | + esc_html__('non empty string', 'event_espresso') |
|
| 234 | + ); |
|
| 235 | + } |
|
| 236 | + $this->func = sanitize_text_field($func); |
|
| 237 | + } |
|
| 238 | + |
|
| 239 | + |
|
| 240 | + /** |
|
| 241 | + * @param int $line |
|
| 242 | + * @throws InvalidDataTypeException |
|
| 243 | + */ |
|
| 244 | + private function setLine($line) |
|
| 245 | + { |
|
| 246 | + $line = absint($line); |
|
| 247 | + if ($this->type === Notice::ERROR && $line === 0) { |
|
| 248 | + throw new InvalidDataTypeException( |
|
| 249 | + '$line', |
|
| 250 | + $line, |
|
| 251 | + esc_html__('integer', 'event_espresso') |
|
| 252 | + ); |
|
| 253 | + } |
|
| 254 | + $this->line = sanitize_text_field($line); |
|
| 255 | + } |
|
| 256 | + |
|
| 257 | + |
|
| 258 | + /** |
|
| 259 | + * @param boolean $dismissible |
|
| 260 | + */ |
|
| 261 | + private function setDismissible($dismissible = true) |
|
| 262 | + { |
|
| 263 | + $this->dismissible = filter_var($dismissible, FILTER_VALIDATE_BOOLEAN); |
|
| 264 | + } |
|
| 265 | 265 | } |
@@ -80,13 +80,13 @@ discard block |
||
| 80 | 80 | 'table_alias' => $field_obj->get_table_alias(), |
| 81 | 81 | 'table_column' => $field_obj->get_table_column(), |
| 82 | 82 | ); |
| 83 | - $fields_json[ $field_json['name'] ] = $field_json; |
|
| 83 | + $fields_json[$field_json['name']] = $field_json; |
|
| 84 | 84 | } |
| 85 | 85 | $fields_json = array_merge( |
| 86 | 86 | $fields_json, |
| 87 | 87 | $this->getModelVersionInfo()->extraResourcePropertiesForModel($model) |
| 88 | 88 | ); |
| 89 | - $response[ $model_name ]['fields'] = apply_filters( |
|
| 89 | + $response[$model_name]['fields'] = apply_filters( |
|
| 90 | 90 | 'FHEE__Meta__handle_request_models_meta__fields', |
| 91 | 91 | $fields_json, |
| 92 | 92 | $model |
@@ -98,9 +98,9 @@ discard block |
||
| 98 | 98 | 'type' => str_replace('EE_', '', get_class($relation_obj)), |
| 99 | 99 | 'single' => $relation_obj instanceof \EE_Belongs_To_Relation ? true : false, |
| 100 | 100 | ); |
| 101 | - $relations_json[ $relation_name ] = $relation_json; |
|
| 101 | + $relations_json[$relation_name] = $relation_json; |
|
| 102 | 102 | } |
| 103 | - $response[ $model_name ]['relations'] = apply_filters( |
|
| 103 | + $response[$model_name]['relations'] = apply_filters( |
|
| 104 | 104 | 'FHEE__Meta__handle_request_models_meta__relations', |
| 105 | 105 | $relations_json, |
| 106 | 106 | $model |
@@ -125,7 +125,7 @@ discard block |
||
| 125 | 125 | 'name' => $addon->name(), |
| 126 | 126 | 'version' => $addon->version(), |
| 127 | 127 | ); |
| 128 | - $addons[ $addon_json['name'] ] = $addon_json; |
|
| 128 | + $addons[$addon_json['name']] = $addon_json; |
|
| 129 | 129 | } |
| 130 | 130 | $response_data['ee'] = array( |
| 131 | 131 | 'version' => EEM_System_Status::instance()->get_ee_version(), |
@@ -21,122 +21,122 @@ |
||
| 21 | 21 | */ |
| 22 | 22 | class Meta extends Base |
| 23 | 23 | { |
| 24 | - /** |
|
| 25 | - * @param \WP_REST_Request $request |
|
| 26 | - * @param string $version |
|
| 27 | - * @return array|\WP_REST_Response |
|
| 28 | - */ |
|
| 29 | - public static function handleRequestModelsMeta(\WP_REST_Request $request, $version) |
|
| 30 | - { |
|
| 31 | - $controller = new Meta(); |
|
| 32 | - try { |
|
| 33 | - $controller->setRequestedVersion($version); |
|
| 34 | - return $controller->sendResponse($controller->getModelsMetadataEntity()); |
|
| 35 | - } catch (Exception $e) { |
|
| 36 | - return $controller->sendResponse($e); |
|
| 37 | - } |
|
| 38 | - } |
|
| 24 | + /** |
|
| 25 | + * @param \WP_REST_Request $request |
|
| 26 | + * @param string $version |
|
| 27 | + * @return array|\WP_REST_Response |
|
| 28 | + */ |
|
| 29 | + public static function handleRequestModelsMeta(\WP_REST_Request $request, $version) |
|
| 30 | + { |
|
| 31 | + $controller = new Meta(); |
|
| 32 | + try { |
|
| 33 | + $controller->setRequestedVersion($version); |
|
| 34 | + return $controller->sendResponse($controller->getModelsMetadataEntity()); |
|
| 35 | + } catch (Exception $e) { |
|
| 36 | + return $controller->sendResponse($e); |
|
| 37 | + } |
|
| 38 | + } |
|
| 39 | 39 | |
| 40 | 40 | |
| 41 | - /* |
|
| 41 | + /* |
|
| 42 | 42 | * Gets the model metadata resource entity |
| 43 | 43 | * @return array for JSON response, describing all the models available in teh requested version |
| 44 | 44 | */ |
| 45 | - protected function getModelsMetadataEntity() |
|
| 46 | - { |
|
| 47 | - $response = array(); |
|
| 48 | - foreach ($this->getModelVersionInfo()->modelsForRequestedVersion() as $model_name => $model_classname) { |
|
| 49 | - $model = $this->getModelVersionInfo()->loadModel($model_name); |
|
| 50 | - $fields_json = array(); |
|
| 51 | - foreach ($this->getModelVersionInfo()->fieldsOnModelInThisVersion($model) as $field_name => $field_obj) { |
|
| 52 | - if ($this->getModelVersionInfo()->fieldIsIgnored($field_obj)) { |
|
| 53 | - continue; |
|
| 54 | - } |
|
| 55 | - if ($field_obj instanceof EE_Boolean_Field) { |
|
| 56 | - $datatype = 'Boolean'; |
|
| 57 | - } elseif ($field_obj->get_wpdb_data_type() == '%d') { |
|
| 58 | - $datatype = 'Number'; |
|
| 59 | - } elseif ($field_name instanceof EE_Serialized_Text_Field) { |
|
| 60 | - $datatype = 'Object'; |
|
| 61 | - } else { |
|
| 62 | - $datatype = 'String'; |
|
| 63 | - } |
|
| 64 | - $default_value = ModelDataTranslator::prepareFieldValueForJson( |
|
| 65 | - $field_obj, |
|
| 66 | - $field_obj->get_default_value(), |
|
| 67 | - $this->getModelVersionInfo()->requestedVersion() |
|
| 68 | - ); |
|
| 69 | - $field_json = array( |
|
| 70 | - 'name' => $field_name, |
|
| 71 | - 'nicename' => wp_specialchars_decode($field_obj->get_nicename(), ENT_QUOTES), |
|
| 72 | - 'has_rendered_format' => $this->getModelVersionInfo()->fieldHasRenderedFormat($field_obj), |
|
| 73 | - 'has_pretty_format' => $this->getModelVersionInfo()->fieldHasPrettyFormat($field_obj), |
|
| 74 | - 'type' => str_replace('EE_', '', get_class($field_obj)), |
|
| 75 | - 'datatype' => $datatype, |
|
| 76 | - 'nullable' => $field_obj->is_nullable(), |
|
| 77 | - 'default' => $default_value, |
|
| 78 | - 'table_alias' => $field_obj->get_table_alias(), |
|
| 79 | - 'table_column' => $field_obj->get_table_column(), |
|
| 80 | - ); |
|
| 81 | - $fields_json[ $field_json['name'] ] = $field_json; |
|
| 82 | - } |
|
| 83 | - $fields_json = array_merge( |
|
| 84 | - $fields_json, |
|
| 85 | - $this->getModelVersionInfo()->extraResourcePropertiesForModel($model) |
|
| 86 | - ); |
|
| 87 | - $response[ $model_name ]['fields'] = apply_filters( |
|
| 88 | - 'FHEE__Meta__handle_request_models_meta__fields', |
|
| 89 | - $fields_json, |
|
| 90 | - $model |
|
| 91 | - ); |
|
| 92 | - $relations_json = array(); |
|
| 93 | - foreach ($model->relation_settings() as $relation_name => $relation_obj) { |
|
| 94 | - $relation_json = array( |
|
| 95 | - 'name' => $relation_name, |
|
| 96 | - 'type' => str_replace('EE_', '', get_class($relation_obj)), |
|
| 97 | - 'single' => $relation_obj instanceof \EE_Belongs_To_Relation ? true : false, |
|
| 98 | - ); |
|
| 99 | - $relations_json[ $relation_name ] = $relation_json; |
|
| 100 | - } |
|
| 101 | - $response[ $model_name ]['relations'] = apply_filters( |
|
| 102 | - 'FHEE__Meta__handle_request_models_meta__relations', |
|
| 103 | - $relations_json, |
|
| 104 | - $model |
|
| 105 | - ); |
|
| 106 | - } |
|
| 107 | - return $response; |
|
| 108 | - } |
|
| 45 | + protected function getModelsMetadataEntity() |
|
| 46 | + { |
|
| 47 | + $response = array(); |
|
| 48 | + foreach ($this->getModelVersionInfo()->modelsForRequestedVersion() as $model_name => $model_classname) { |
|
| 49 | + $model = $this->getModelVersionInfo()->loadModel($model_name); |
|
| 50 | + $fields_json = array(); |
|
| 51 | + foreach ($this->getModelVersionInfo()->fieldsOnModelInThisVersion($model) as $field_name => $field_obj) { |
|
| 52 | + if ($this->getModelVersionInfo()->fieldIsIgnored($field_obj)) { |
|
| 53 | + continue; |
|
| 54 | + } |
|
| 55 | + if ($field_obj instanceof EE_Boolean_Field) { |
|
| 56 | + $datatype = 'Boolean'; |
|
| 57 | + } elseif ($field_obj->get_wpdb_data_type() == '%d') { |
|
| 58 | + $datatype = 'Number'; |
|
| 59 | + } elseif ($field_name instanceof EE_Serialized_Text_Field) { |
|
| 60 | + $datatype = 'Object'; |
|
| 61 | + } else { |
|
| 62 | + $datatype = 'String'; |
|
| 63 | + } |
|
| 64 | + $default_value = ModelDataTranslator::prepareFieldValueForJson( |
|
| 65 | + $field_obj, |
|
| 66 | + $field_obj->get_default_value(), |
|
| 67 | + $this->getModelVersionInfo()->requestedVersion() |
|
| 68 | + ); |
|
| 69 | + $field_json = array( |
|
| 70 | + 'name' => $field_name, |
|
| 71 | + 'nicename' => wp_specialchars_decode($field_obj->get_nicename(), ENT_QUOTES), |
|
| 72 | + 'has_rendered_format' => $this->getModelVersionInfo()->fieldHasRenderedFormat($field_obj), |
|
| 73 | + 'has_pretty_format' => $this->getModelVersionInfo()->fieldHasPrettyFormat($field_obj), |
|
| 74 | + 'type' => str_replace('EE_', '', get_class($field_obj)), |
|
| 75 | + 'datatype' => $datatype, |
|
| 76 | + 'nullable' => $field_obj->is_nullable(), |
|
| 77 | + 'default' => $default_value, |
|
| 78 | + 'table_alias' => $field_obj->get_table_alias(), |
|
| 79 | + 'table_column' => $field_obj->get_table_column(), |
|
| 80 | + ); |
|
| 81 | + $fields_json[ $field_json['name'] ] = $field_json; |
|
| 82 | + } |
|
| 83 | + $fields_json = array_merge( |
|
| 84 | + $fields_json, |
|
| 85 | + $this->getModelVersionInfo()->extraResourcePropertiesForModel($model) |
|
| 86 | + ); |
|
| 87 | + $response[ $model_name ]['fields'] = apply_filters( |
|
| 88 | + 'FHEE__Meta__handle_request_models_meta__fields', |
|
| 89 | + $fields_json, |
|
| 90 | + $model |
|
| 91 | + ); |
|
| 92 | + $relations_json = array(); |
|
| 93 | + foreach ($model->relation_settings() as $relation_name => $relation_obj) { |
|
| 94 | + $relation_json = array( |
|
| 95 | + 'name' => $relation_name, |
|
| 96 | + 'type' => str_replace('EE_', '', get_class($relation_obj)), |
|
| 97 | + 'single' => $relation_obj instanceof \EE_Belongs_To_Relation ? true : false, |
|
| 98 | + ); |
|
| 99 | + $relations_json[ $relation_name ] = $relation_json; |
|
| 100 | + } |
|
| 101 | + $response[ $model_name ]['relations'] = apply_filters( |
|
| 102 | + 'FHEE__Meta__handle_request_models_meta__relations', |
|
| 103 | + $relations_json, |
|
| 104 | + $model |
|
| 105 | + ); |
|
| 106 | + } |
|
| 107 | + return $response; |
|
| 108 | + } |
|
| 109 | 109 | |
| 110 | 110 | |
| 111 | - /** |
|
| 112 | - * Adds EE metadata to the index |
|
| 113 | - * |
|
| 114 | - * @param \WP_REST_Response $rest_response_obj |
|
| 115 | - * @return \WP_REST_Response |
|
| 116 | - */ |
|
| 117 | - public static function filterEeMetadataIntoIndex(\WP_REST_Response $rest_response_obj) |
|
| 118 | - { |
|
| 119 | - $response_data = $rest_response_obj->get_data(); |
|
| 120 | - $addons = array(); |
|
| 121 | - foreach (EE_Registry::instance()->addons as $addon) { |
|
| 122 | - $addon_json = array( |
|
| 123 | - 'name' => $addon->name(), |
|
| 124 | - 'version' => $addon->version(), |
|
| 125 | - ); |
|
| 126 | - $addons[ $addon_json['name'] ] = $addon_json; |
|
| 127 | - } |
|
| 128 | - $response_data['ee'] = array( |
|
| 129 | - 'version' => EEM_System_Status::instance()->get_ee_version(), |
|
| 130 | - // @codingStandardsIgnoreStart |
|
| 131 | - 'documentation_url' => 'https://github.com/eventespresso/event-espresso-core/tree/master/docs/C--REST-API', |
|
| 132 | - // @codingStandardsIgnoreEnd |
|
| 133 | - 'addons' => $addons, |
|
| 134 | - 'maintenance_mode' => EE_Maintenance_Mode::instance()->real_level(), |
|
| 135 | - 'served_core_versions' => array_keys(EED_Core_Rest_Api::versions_served()), |
|
| 136 | - ); |
|
| 137 | - $rest_response_obj->set_data($response_data); |
|
| 138 | - return $rest_response_obj; |
|
| 139 | - } |
|
| 111 | + /** |
|
| 112 | + * Adds EE metadata to the index |
|
| 113 | + * |
|
| 114 | + * @param \WP_REST_Response $rest_response_obj |
|
| 115 | + * @return \WP_REST_Response |
|
| 116 | + */ |
|
| 117 | + public static function filterEeMetadataIntoIndex(\WP_REST_Response $rest_response_obj) |
|
| 118 | + { |
|
| 119 | + $response_data = $rest_response_obj->get_data(); |
|
| 120 | + $addons = array(); |
|
| 121 | + foreach (EE_Registry::instance()->addons as $addon) { |
|
| 122 | + $addon_json = array( |
|
| 123 | + 'name' => $addon->name(), |
|
| 124 | + 'version' => $addon->version(), |
|
| 125 | + ); |
|
| 126 | + $addons[ $addon_json['name'] ] = $addon_json; |
|
| 127 | + } |
|
| 128 | + $response_data['ee'] = array( |
|
| 129 | + 'version' => EEM_System_Status::instance()->get_ee_version(), |
|
| 130 | + // @codingStandardsIgnoreStart |
|
| 131 | + 'documentation_url' => 'https://github.com/eventespresso/event-espresso-core/tree/master/docs/C--REST-API', |
|
| 132 | + // @codingStandardsIgnoreEnd |
|
| 133 | + 'addons' => $addons, |
|
| 134 | + 'maintenance_mode' => EE_Maintenance_Mode::instance()->real_level(), |
|
| 135 | + 'served_core_versions' => array_keys(EED_Core_Rest_Api::versions_served()), |
|
| 136 | + ); |
|
| 137 | + $rest_response_obj->set_data($response_data); |
|
| 138 | + return $rest_response_obj; |
|
| 139 | + } |
|
| 140 | 140 | } |
| 141 | 141 | |
| 142 | 142 | |
@@ -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 | } |
@@ -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 |
@@ -17,97 +17,97 @@ |
||
| 17 | 17 | */ |
| 18 | 18 | class RegUrlLink |
| 19 | 19 | { |
| 20 | - /* |
|
| 20 | + /* |
|
| 21 | 21 | * @var string $reg_url_link |
| 22 | 22 | */ |
| 23 | - private $reg_url_link; |
|
| 23 | + private $reg_url_link; |
|
| 24 | 24 | |
| 25 | 25 | |
| 26 | - /** |
|
| 27 | - * @param string $reg_url_link |
|
| 28 | - * @return RegUrlLink |
|
| 29 | - * @throws InvalidArgumentException |
|
| 30 | - */ |
|
| 31 | - public static function fromRegUrlLinkString($reg_url_link) |
|
| 32 | - { |
|
| 33 | - if (empty($reg_url_link) || ! is_string($reg_url_link)) { |
|
| 34 | - throw new InvalidArgumentException( |
|
| 35 | - esc_html__( |
|
| 36 | - 'You must supply a valid non-empty string to generate a reg_url_link.', |
|
| 37 | - 'event_espresso' |
|
| 38 | - ) |
|
| 39 | - ); |
|
| 40 | - } |
|
| 41 | - return new RegUrlLink(1, '', $reg_url_link); |
|
| 42 | - } |
|
| 26 | + /** |
|
| 27 | + * @param string $reg_url_link |
|
| 28 | + * @return RegUrlLink |
|
| 29 | + * @throws InvalidArgumentException |
|
| 30 | + */ |
|
| 31 | + public static function fromRegUrlLinkString($reg_url_link) |
|
| 32 | + { |
|
| 33 | + if (empty($reg_url_link) || ! is_string($reg_url_link)) { |
|
| 34 | + throw new InvalidArgumentException( |
|
| 35 | + esc_html__( |
|
| 36 | + 'You must supply a valid non-empty string to generate a reg_url_link.', |
|
| 37 | + 'event_espresso' |
|
| 38 | + ) |
|
| 39 | + ); |
|
| 40 | + } |
|
| 41 | + return new RegUrlLink(1, '', $reg_url_link); |
|
| 42 | + } |
|
| 43 | 43 | |
| 44 | 44 | |
| 45 | - /** |
|
| 46 | - * @param EE_Registration $registration |
|
| 47 | - * @return RegUrlLink |
|
| 48 | - * @throws EntityNotFoundException |
|
| 49 | - * @throws EE_Error |
|
| 50 | - * @throws InvalidArgumentException |
|
| 51 | - */ |
|
| 52 | - public static function fromRegistration(EE_Registration $registration) |
|
| 53 | - { |
|
| 54 | - return new RegUrlLink( |
|
| 55 | - $registration->count(), |
|
| 56 | - $registration->ticket_line_item() |
|
| 57 | - ); |
|
| 58 | - } |
|
| 45 | + /** |
|
| 46 | + * @param EE_Registration $registration |
|
| 47 | + * @return RegUrlLink |
|
| 48 | + * @throws EntityNotFoundException |
|
| 49 | + * @throws EE_Error |
|
| 50 | + * @throws InvalidArgumentException |
|
| 51 | + */ |
|
| 52 | + public static function fromRegistration(EE_Registration $registration) |
|
| 53 | + { |
|
| 54 | + return new RegUrlLink( |
|
| 55 | + $registration->count(), |
|
| 56 | + $registration->ticket_line_item() |
|
| 57 | + ); |
|
| 58 | + } |
|
| 59 | 59 | |
| 60 | 60 | |
| 61 | - /** |
|
| 62 | - * CreateRegUrlLinkCommand constructor. |
|
| 63 | - * |
|
| 64 | - * @param int $reg_count |
|
| 65 | - * @param mixed $base_code |
|
| 66 | - * @param string $reg_url_link |
|
| 67 | - * @throws InvalidArgumentException |
|
| 68 | - */ |
|
| 69 | - public function __construct( |
|
| 70 | - $reg_count = 1, |
|
| 71 | - $base_code = '', |
|
| 72 | - $reg_url_link = '' |
|
| 73 | - ) { |
|
| 74 | - if (! empty($reg_url_link) && is_string($reg_url_link)) { |
|
| 75 | - $this->reg_url_link = apply_filters( |
|
| 76 | - 'FHEE__\EventEspresso\core\domain\entities\RegUrlLink__construct__reg_url_link', |
|
| 77 | - $reg_url_link, |
|
| 78 | - $reg_count, |
|
| 79 | - $base_code, |
|
| 80 | - $reg_url_link |
|
| 81 | - ); |
|
| 82 | - return; |
|
| 83 | - } |
|
| 84 | - $reg_count = max(1, absint($reg_count)); |
|
| 85 | - $base_code = $base_code instanceof \EE_Line_Item ? $base_code->code() : $base_code; |
|
| 86 | - if (empty($base_code) || ! is_string($base_code)) { |
|
| 87 | - throw new InvalidArgumentException( |
|
| 88 | - esc_html__( |
|
| 89 | - 'You must supply a valid EE_Line_Item or a non-empty string to generate a reg_url_link.', |
|
| 90 | - 'event_espresso' |
|
| 91 | - ) |
|
| 92 | - ); |
|
| 93 | - } |
|
| 94 | - $this->reg_url_link = (string) apply_filters( |
|
| 95 | - 'FHEE__\EventEspresso\core\domain\entities\RegUrlLink__construct__reg_url_link', |
|
| 96 | - $reg_count . '-' . md5($base_code . microtime()), |
|
| 97 | - $reg_count, |
|
| 98 | - $base_code, |
|
| 99 | - $reg_url_link |
|
| 100 | - ); |
|
| 101 | - } |
|
| 61 | + /** |
|
| 62 | + * CreateRegUrlLinkCommand constructor. |
|
| 63 | + * |
|
| 64 | + * @param int $reg_count |
|
| 65 | + * @param mixed $base_code |
|
| 66 | + * @param string $reg_url_link |
|
| 67 | + * @throws InvalidArgumentException |
|
| 68 | + */ |
|
| 69 | + public function __construct( |
|
| 70 | + $reg_count = 1, |
|
| 71 | + $base_code = '', |
|
| 72 | + $reg_url_link = '' |
|
| 73 | + ) { |
|
| 74 | + if (! empty($reg_url_link) && is_string($reg_url_link)) { |
|
| 75 | + $this->reg_url_link = apply_filters( |
|
| 76 | + 'FHEE__\EventEspresso\core\domain\entities\RegUrlLink__construct__reg_url_link', |
|
| 77 | + $reg_url_link, |
|
| 78 | + $reg_count, |
|
| 79 | + $base_code, |
|
| 80 | + $reg_url_link |
|
| 81 | + ); |
|
| 82 | + return; |
|
| 83 | + } |
|
| 84 | + $reg_count = max(1, absint($reg_count)); |
|
| 85 | + $base_code = $base_code instanceof \EE_Line_Item ? $base_code->code() : $base_code; |
|
| 86 | + if (empty($base_code) || ! is_string($base_code)) { |
|
| 87 | + throw new InvalidArgumentException( |
|
| 88 | + esc_html__( |
|
| 89 | + 'You must supply a valid EE_Line_Item or a non-empty string to generate a reg_url_link.', |
|
| 90 | + 'event_espresso' |
|
| 91 | + ) |
|
| 92 | + ); |
|
| 93 | + } |
|
| 94 | + $this->reg_url_link = (string) apply_filters( |
|
| 95 | + 'FHEE__\EventEspresso\core\domain\entities\RegUrlLink__construct__reg_url_link', |
|
| 96 | + $reg_count . '-' . md5($base_code . microtime()), |
|
| 97 | + $reg_count, |
|
| 98 | + $base_code, |
|
| 99 | + $reg_url_link |
|
| 100 | + ); |
|
| 101 | + } |
|
| 102 | 102 | |
| 103 | 103 | |
| 104 | - /** |
|
| 105 | - * Return the object as a string |
|
| 106 | - * |
|
| 107 | - * @return string |
|
| 108 | - */ |
|
| 109 | - public function __toString() |
|
| 110 | - { |
|
| 111 | - return $this->reg_url_link; |
|
| 112 | - } |
|
| 104 | + /** |
|
| 105 | + * Return the object as a string |
|
| 106 | + * |
|
| 107 | + * @return string |
|
| 108 | + */ |
|
| 109 | + public function __toString() |
|
| 110 | + { |
|
| 111 | + return $this->reg_url_link; |
|
| 112 | + } |
|
| 113 | 113 | } |
@@ -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,198 +15,198 @@ |
||
| 15 | 15 | */ |
| 16 | 16 | class EventListQuery extends WP_Query |
| 17 | 17 | { |
| 18 | - /** |
|
| 19 | - * @var string $title |
|
| 20 | - */ |
|
| 21 | - private $title; |
|
| 22 | - |
|
| 23 | - /** |
|
| 24 | - * @var integer $limit |
|
| 25 | - */ |
|
| 26 | - private $limit = 10; |
|
| 27 | - |
|
| 28 | - /** |
|
| 29 | - * @var string $css_class |
|
| 30 | - */ |
|
| 31 | - private $css_class; |
|
| 32 | - |
|
| 33 | - /** |
|
| 34 | - * @var boolean $show_expired |
|
| 35 | - */ |
|
| 36 | - private $show_expired = false; |
|
| 37 | - |
|
| 38 | - /** |
|
| 39 | - * @var string $month |
|
| 40 | - */ |
|
| 41 | - private $month; |
|
| 42 | - |
|
| 43 | - /** |
|
| 44 | - * @var string $category_slug |
|
| 45 | - */ |
|
| 46 | - private $category_slug; |
|
| 47 | - |
|
| 48 | - /** |
|
| 49 | - * @var string $order_by |
|
| 50 | - */ |
|
| 51 | - private $order_by; |
|
| 52 | - |
|
| 53 | - /** |
|
| 54 | - * @var string $sort |
|
| 55 | - */ |
|
| 56 | - private $sort; |
|
| 57 | - |
|
| 58 | - /** |
|
| 59 | - * @var boolean $show_title |
|
| 60 | - */ |
|
| 61 | - private $show_title = true; |
|
| 62 | - |
|
| 63 | - |
|
| 64 | - /** |
|
| 65 | - * EE_Event_List_Query Constructor * |
|
| 66 | - * |
|
| 67 | - * @param array $args |
|
| 68 | - */ |
|
| 69 | - public function __construct($args = array()) |
|
| 70 | - { |
|
| 71 | - $args = $this->parseArgs((array) $args); |
|
| 72 | - $this->setupEventQueryHelper(); |
|
| 73 | - $this->setupFilters(); |
|
| 74 | - $args = $this->getQueryArgs($args); |
|
| 75 | - // run the query |
|
| 76 | - parent::__construct($args); |
|
| 77 | - } |
|
| 78 | - |
|
| 79 | - |
|
| 80 | - /** |
|
| 81 | - * @param array $args |
|
| 82 | - * @return array |
|
| 83 | - */ |
|
| 84 | - private function parseArgs(array $args) |
|
| 85 | - { |
|
| 86 | - // incoming args could be a mix of WP query args + EE shortcode args |
|
| 87 | - foreach ($args as $property => $value) { |
|
| 88 | - // if the arg is a property of this class, then it's an EE shortcode arg |
|
| 89 | - if (property_exists($this, $property) && ! property_exists('WP_Query', $property)) { |
|
| 90 | - // set the property value |
|
| 91 | - $this->{$property} = $value; |
|
| 92 | - // then remove it from the array of args that will later be passed to WP_Query() |
|
| 93 | - unset($args[ $property ]); |
|
| 94 | - } |
|
| 95 | - } |
|
| 96 | - return $args; |
|
| 97 | - } |
|
| 98 | - |
|
| 99 | - |
|
| 100 | - private function setupEventQueryHelper() |
|
| 101 | - { |
|
| 102 | - // add query filters |
|
| 103 | - EEH_Event_Query::add_query_filters(); |
|
| 104 | - // set params that will get used by the filters |
|
| 105 | - EEH_Event_Query::set_query_params( |
|
| 106 | - $this->month, |
|
| 107 | - $this->category_slug, |
|
| 108 | - $this->show_expired, |
|
| 109 | - $this->order_by, |
|
| 110 | - $this->sort |
|
| 111 | - ); |
|
| 112 | - } |
|
| 113 | - |
|
| 114 | - |
|
| 115 | - private function setupFilters() |
|
| 116 | - { |
|
| 117 | - // first off, let's remove any filters from previous queries |
|
| 118 | - remove_filter( |
|
| 119 | - 'FHEE__archive_espresso_events_template__show_header', |
|
| 120 | - array($this, 'show_event_list_title') |
|
| 121 | - ); |
|
| 122 | - remove_filter( |
|
| 123 | - 'FHEE__archive_espresso_events_template__upcoming_events_h1', |
|
| 124 | - array($this, 'event_list_title') |
|
| 125 | - ); |
|
| 126 | - remove_all_filters('FHEE__content_espresso_events__event_class'); |
|
| 127 | - // Event List Title ? |
|
| 128 | - add_filter( |
|
| 129 | - 'FHEE__archive_espresso_events_template__show_header', |
|
| 130 | - array($this, 'show_event_list_title') |
|
| 131 | - ); |
|
| 132 | - add_filter( |
|
| 133 | - 'FHEE__archive_espresso_events_template__upcoming_events_h1', |
|
| 134 | - array($this, 'event_list_title'), |
|
| 135 | - 10, |
|
| 136 | - 1 |
|
| 137 | - ); |
|
| 138 | - // add the css class |
|
| 139 | - add_filter( |
|
| 140 | - 'FHEE__content_espresso_events__event_class', |
|
| 141 | - array($this, 'event_list_css'), |
|
| 142 | - 10, |
|
| 143 | - 1 |
|
| 144 | - ); |
|
| 145 | - } |
|
| 146 | - |
|
| 147 | - |
|
| 148 | - private function getQueryArgs(array $args) |
|
| 149 | - { |
|
| 150 | - // the current "page" we are viewing |
|
| 151 | - $paged = max(1, get_query_var('paged')); |
|
| 152 | - // Force these args |
|
| 153 | - return array_merge( |
|
| 154 | - $args, |
|
| 155 | - array( |
|
| 156 | - 'post_type' => 'espresso_events', |
|
| 157 | - 'posts_per_page' => $this->limit, |
|
| 158 | - 'update_post_term_cache' => false, |
|
| 159 | - 'update_post_meta_cache' => false, |
|
| 160 | - 'paged' => $paged, |
|
| 161 | - 'offset' => ($paged - 1) * $this->limit, |
|
| 162 | - ) |
|
| 163 | - ); |
|
| 164 | - } |
|
| 165 | - |
|
| 166 | - // phpcs:disable PSR1.Methods.CamelCapsMethodName.NotCamelCaps |
|
| 167 | - |
|
| 168 | - /** |
|
| 169 | - * show_event_list_title |
|
| 170 | - * |
|
| 171 | - * @return boolean |
|
| 172 | - */ |
|
| 173 | - public function show_event_list_title() |
|
| 174 | - { |
|
| 175 | - return filter_var( |
|
| 176 | - $this->show_title, |
|
| 177 | - FILTER_VALIDATE_BOOLEAN |
|
| 178 | - ); |
|
| 179 | - } |
|
| 180 | - |
|
| 181 | - |
|
| 182 | - /** |
|
| 183 | - * callback for FHEE__archive_espresso_events_template__upcoming_events_h1 filter |
|
| 184 | - * |
|
| 185 | - * @param string $event_list_title |
|
| 186 | - * @return string |
|
| 187 | - */ |
|
| 188 | - public function event_list_title($event_list_title = '') |
|
| 189 | - { |
|
| 190 | - if (! empty($this->title)) { |
|
| 191 | - return $this->title; |
|
| 192 | - } |
|
| 193 | - return $event_list_title; |
|
| 194 | - } |
|
| 195 | - |
|
| 196 | - |
|
| 197 | - /** |
|
| 198 | - * callback for FHEE__content_espresso_events__event_class filter |
|
| 199 | - * |
|
| 200 | - * @param string $event_list_css |
|
| 201 | - * @return string |
|
| 202 | - */ |
|
| 203 | - public function event_list_css($event_list_css = '') |
|
| 204 | - { |
|
| 205 | - $event_list_css .= ! empty($event_list_css) ? ' ' : ''; |
|
| 206 | - $event_list_css .= ! empty($this->css_class) ? $this->css_class : ''; |
|
| 207 | - $event_list_css .= ! empty($event_list_css) ? ' ' : ''; |
|
| 208 | - $event_list_css .= ! empty($this->category_slug) ? $this->category_slug : ''; |
|
| 209 | - return $event_list_css; |
|
| 210 | - } |
|
| 211 | - // phpcs:enable |
|
| 18 | + /** |
|
| 19 | + * @var string $title |
|
| 20 | + */ |
|
| 21 | + private $title; |
|
| 22 | + |
|
| 23 | + /** |
|
| 24 | + * @var integer $limit |
|
| 25 | + */ |
|
| 26 | + private $limit = 10; |
|
| 27 | + |
|
| 28 | + /** |
|
| 29 | + * @var string $css_class |
|
| 30 | + */ |
|
| 31 | + private $css_class; |
|
| 32 | + |
|
| 33 | + /** |
|
| 34 | + * @var boolean $show_expired |
|
| 35 | + */ |
|
| 36 | + private $show_expired = false; |
|
| 37 | + |
|
| 38 | + /** |
|
| 39 | + * @var string $month |
|
| 40 | + */ |
|
| 41 | + private $month; |
|
| 42 | + |
|
| 43 | + /** |
|
| 44 | + * @var string $category_slug |
|
| 45 | + */ |
|
| 46 | + private $category_slug; |
|
| 47 | + |
|
| 48 | + /** |
|
| 49 | + * @var string $order_by |
|
| 50 | + */ |
|
| 51 | + private $order_by; |
|
| 52 | + |
|
| 53 | + /** |
|
| 54 | + * @var string $sort |
|
| 55 | + */ |
|
| 56 | + private $sort; |
|
| 57 | + |
|
| 58 | + /** |
|
| 59 | + * @var boolean $show_title |
|
| 60 | + */ |
|
| 61 | + private $show_title = true; |
|
| 62 | + |
|
| 63 | + |
|
| 64 | + /** |
|
| 65 | + * EE_Event_List_Query Constructor * |
|
| 66 | + * |
|
| 67 | + * @param array $args |
|
| 68 | + */ |
|
| 69 | + public function __construct($args = array()) |
|
| 70 | + { |
|
| 71 | + $args = $this->parseArgs((array) $args); |
|
| 72 | + $this->setupEventQueryHelper(); |
|
| 73 | + $this->setupFilters(); |
|
| 74 | + $args = $this->getQueryArgs($args); |
|
| 75 | + // run the query |
|
| 76 | + parent::__construct($args); |
|
| 77 | + } |
|
| 78 | + |
|
| 79 | + |
|
| 80 | + /** |
|
| 81 | + * @param array $args |
|
| 82 | + * @return array |
|
| 83 | + */ |
|
| 84 | + private function parseArgs(array $args) |
|
| 85 | + { |
|
| 86 | + // incoming args could be a mix of WP query args + EE shortcode args |
|
| 87 | + foreach ($args as $property => $value) { |
|
| 88 | + // if the arg is a property of this class, then it's an EE shortcode arg |
|
| 89 | + if (property_exists($this, $property) && ! property_exists('WP_Query', $property)) { |
|
| 90 | + // set the property value |
|
| 91 | + $this->{$property} = $value; |
|
| 92 | + // then remove it from the array of args that will later be passed to WP_Query() |
|
| 93 | + unset($args[ $property ]); |
|
| 94 | + } |
|
| 95 | + } |
|
| 96 | + return $args; |
|
| 97 | + } |
|
| 98 | + |
|
| 99 | + |
|
| 100 | + private function setupEventQueryHelper() |
|
| 101 | + { |
|
| 102 | + // add query filters |
|
| 103 | + EEH_Event_Query::add_query_filters(); |
|
| 104 | + // set params that will get used by the filters |
|
| 105 | + EEH_Event_Query::set_query_params( |
|
| 106 | + $this->month, |
|
| 107 | + $this->category_slug, |
|
| 108 | + $this->show_expired, |
|
| 109 | + $this->order_by, |
|
| 110 | + $this->sort |
|
| 111 | + ); |
|
| 112 | + } |
|
| 113 | + |
|
| 114 | + |
|
| 115 | + private function setupFilters() |
|
| 116 | + { |
|
| 117 | + // first off, let's remove any filters from previous queries |
|
| 118 | + remove_filter( |
|
| 119 | + 'FHEE__archive_espresso_events_template__show_header', |
|
| 120 | + array($this, 'show_event_list_title') |
|
| 121 | + ); |
|
| 122 | + remove_filter( |
|
| 123 | + 'FHEE__archive_espresso_events_template__upcoming_events_h1', |
|
| 124 | + array($this, 'event_list_title') |
|
| 125 | + ); |
|
| 126 | + remove_all_filters('FHEE__content_espresso_events__event_class'); |
|
| 127 | + // Event List Title ? |
|
| 128 | + add_filter( |
|
| 129 | + 'FHEE__archive_espresso_events_template__show_header', |
|
| 130 | + array($this, 'show_event_list_title') |
|
| 131 | + ); |
|
| 132 | + add_filter( |
|
| 133 | + 'FHEE__archive_espresso_events_template__upcoming_events_h1', |
|
| 134 | + array($this, 'event_list_title'), |
|
| 135 | + 10, |
|
| 136 | + 1 |
|
| 137 | + ); |
|
| 138 | + // add the css class |
|
| 139 | + add_filter( |
|
| 140 | + 'FHEE__content_espresso_events__event_class', |
|
| 141 | + array($this, 'event_list_css'), |
|
| 142 | + 10, |
|
| 143 | + 1 |
|
| 144 | + ); |
|
| 145 | + } |
|
| 146 | + |
|
| 147 | + |
|
| 148 | + private function getQueryArgs(array $args) |
|
| 149 | + { |
|
| 150 | + // the current "page" we are viewing |
|
| 151 | + $paged = max(1, get_query_var('paged')); |
|
| 152 | + // Force these args |
|
| 153 | + return array_merge( |
|
| 154 | + $args, |
|
| 155 | + array( |
|
| 156 | + 'post_type' => 'espresso_events', |
|
| 157 | + 'posts_per_page' => $this->limit, |
|
| 158 | + 'update_post_term_cache' => false, |
|
| 159 | + 'update_post_meta_cache' => false, |
|
| 160 | + 'paged' => $paged, |
|
| 161 | + 'offset' => ($paged - 1) * $this->limit, |
|
| 162 | + ) |
|
| 163 | + ); |
|
| 164 | + } |
|
| 165 | + |
|
| 166 | + // phpcs:disable PSR1.Methods.CamelCapsMethodName.NotCamelCaps |
|
| 167 | + |
|
| 168 | + /** |
|
| 169 | + * show_event_list_title |
|
| 170 | + * |
|
| 171 | + * @return boolean |
|
| 172 | + */ |
|
| 173 | + public function show_event_list_title() |
|
| 174 | + { |
|
| 175 | + return filter_var( |
|
| 176 | + $this->show_title, |
|
| 177 | + FILTER_VALIDATE_BOOLEAN |
|
| 178 | + ); |
|
| 179 | + } |
|
| 180 | + |
|
| 181 | + |
|
| 182 | + /** |
|
| 183 | + * callback for FHEE__archive_espresso_events_template__upcoming_events_h1 filter |
|
| 184 | + * |
|
| 185 | + * @param string $event_list_title |
|
| 186 | + * @return string |
|
| 187 | + */ |
|
| 188 | + public function event_list_title($event_list_title = '') |
|
| 189 | + { |
|
| 190 | + if (! empty($this->title)) { |
|
| 191 | + return $this->title; |
|
| 192 | + } |
|
| 193 | + return $event_list_title; |
|
| 194 | + } |
|
| 195 | + |
|
| 196 | + |
|
| 197 | + /** |
|
| 198 | + * callback for FHEE__content_espresso_events__event_class filter |
|
| 199 | + * |
|
| 200 | + * @param string $event_list_css |
|
| 201 | + * @return string |
|
| 202 | + */ |
|
| 203 | + public function event_list_css($event_list_css = '') |
|
| 204 | + { |
|
| 205 | + $event_list_css .= ! empty($event_list_css) ? ' ' : ''; |
|
| 206 | + $event_list_css .= ! empty($this->css_class) ? $this->css_class : ''; |
|
| 207 | + $event_list_css .= ! empty($event_list_css) ? ' ' : ''; |
|
| 208 | + $event_list_css .= ! empty($this->category_slug) ? $this->category_slug : ''; |
|
| 209 | + return $event_list_css; |
|
| 210 | + } |
|
| 211 | + // phpcs:enable |
|
| 212 | 212 | } |
@@ -70,14 +70,14 @@ |
||
| 70 | 70 | 'REG_code' => $reg_code, |
| 71 | 71 | ) |
| 72 | 72 | ); |
| 73 | - if (! $registration instanceof EE_Registration) { |
|
| 73 | + if ( ! $registration instanceof EE_Registration) { |
|
| 74 | 74 | throw new UnexpectedEntityException($registration, 'EE_Registration'); |
| 75 | 75 | } |
| 76 | 76 | // save registration so that we have an ID |
| 77 | 77 | $registration->save(); |
| 78 | 78 | // track reservation on reg but don't adjust ticket and datetime reserved counts |
| 79 | 79 | // because that is done as soon as the tickets are added/removed from the cart |
| 80 | - $registration->reserve_ticket(false, 'CreateRegistrationService:' . __LINE__); |
|
| 80 | + $registration->reserve_ticket(false, 'CreateRegistrationService:'.__LINE__); |
|
| 81 | 81 | $registration->_add_relation_to($event, 'Event', array(), $event->ID()); |
| 82 | 82 | $registration->_add_relation_to($ticket, 'Ticket', array(), $ticket->ID()); |
| 83 | 83 | $transaction->_add_relation_to($registration, 'Registration', array(), $registration->ID()); |
@@ -27,102 +27,102 @@ |
||
| 27 | 27 | */ |
| 28 | 28 | class CreateRegistrationService extends DomainService |
| 29 | 29 | { |
| 30 | - /** |
|
| 31 | - * @param EE_Event $event |
|
| 32 | - * @param EE_Transaction $transaction |
|
| 33 | - * @param EE_Ticket $ticket |
|
| 34 | - * @param EE_Line_Item $ticket_line_item |
|
| 35 | - * @param $reg_count |
|
| 36 | - * @param $reg_group_size |
|
| 37 | - * @param string $reg_status |
|
| 38 | - * @return EE_Registration |
|
| 39 | - * @throws OutOfRangeException |
|
| 40 | - * @throws EE_Error |
|
| 41 | - * @throws UnexpectedEntityException |
|
| 42 | - */ |
|
| 43 | - public function create( |
|
| 44 | - EE_Event $event, |
|
| 45 | - EE_Transaction $transaction, |
|
| 46 | - EE_Ticket $ticket, |
|
| 47 | - EE_Line_Item $ticket_line_item, |
|
| 48 | - $reg_count, |
|
| 49 | - $reg_group_size, |
|
| 50 | - $reg_status = EEM_Registration::status_id_incomplete |
|
| 51 | - ) { |
|
| 52 | - $registrations = $transaction->registrations(); |
|
| 53 | - $reg_count = $reg_count ? $reg_count : count($registrations) + 1; |
|
| 54 | - $reg_url_link = new RegUrlLink($reg_count, $ticket_line_item); |
|
| 55 | - $reg_code = new RegCode($reg_url_link, $transaction, $ticket); |
|
| 56 | - // generate new EE_Registration |
|
| 57 | - $registration = EE_Registration::new_instance( |
|
| 58 | - array( |
|
| 59 | - 'EVT_ID' => $event->ID(), |
|
| 60 | - 'TXN_ID' => $transaction->ID(), |
|
| 61 | - 'TKT_ID' => $ticket->ID(), |
|
| 62 | - 'STS_ID' => $reg_status, |
|
| 63 | - 'REG_final_price' => $this->resolveFinalPrice($transaction, $ticket, $ticket_line_item), |
|
| 64 | - 'REG_session' => EE_Registry::instance()->SSN->id(), |
|
| 65 | - 'REG_count' => $reg_count, |
|
| 66 | - 'REG_group_size' => $reg_group_size ? $reg_group_size : $this->incrementRegGroupSize($registrations), |
|
| 67 | - 'REG_url_link' => $reg_url_link, |
|
| 68 | - 'REG_code' => $reg_code, |
|
| 69 | - ) |
|
| 70 | - ); |
|
| 71 | - if (! $registration instanceof EE_Registration) { |
|
| 72 | - throw new UnexpectedEntityException($registration, 'EE_Registration'); |
|
| 73 | - } |
|
| 74 | - // save registration so that we have an ID |
|
| 75 | - $registration->save(); |
|
| 76 | - // track reservation on reg but don't adjust ticket and datetime reserved counts |
|
| 77 | - // because that is done as soon as the tickets are added/removed from the cart |
|
| 78 | - $registration->reserve_ticket(false, 'CreateRegistrationService:' . __LINE__); |
|
| 79 | - $registration->_add_relation_to($event, 'Event', array(), $event->ID()); |
|
| 80 | - $registration->_add_relation_to($ticket, 'Ticket', array(), $ticket->ID()); |
|
| 81 | - $transaction->_add_relation_to($registration, 'Registration', array(), $registration->ID()); |
|
| 82 | - $registration->save(); |
|
| 83 | - return $registration; |
|
| 84 | - } |
|
| 30 | + /** |
|
| 31 | + * @param EE_Event $event |
|
| 32 | + * @param EE_Transaction $transaction |
|
| 33 | + * @param EE_Ticket $ticket |
|
| 34 | + * @param EE_Line_Item $ticket_line_item |
|
| 35 | + * @param $reg_count |
|
| 36 | + * @param $reg_group_size |
|
| 37 | + * @param string $reg_status |
|
| 38 | + * @return EE_Registration |
|
| 39 | + * @throws OutOfRangeException |
|
| 40 | + * @throws EE_Error |
|
| 41 | + * @throws UnexpectedEntityException |
|
| 42 | + */ |
|
| 43 | + public function create( |
|
| 44 | + EE_Event $event, |
|
| 45 | + EE_Transaction $transaction, |
|
| 46 | + EE_Ticket $ticket, |
|
| 47 | + EE_Line_Item $ticket_line_item, |
|
| 48 | + $reg_count, |
|
| 49 | + $reg_group_size, |
|
| 50 | + $reg_status = EEM_Registration::status_id_incomplete |
|
| 51 | + ) { |
|
| 52 | + $registrations = $transaction->registrations(); |
|
| 53 | + $reg_count = $reg_count ? $reg_count : count($registrations) + 1; |
|
| 54 | + $reg_url_link = new RegUrlLink($reg_count, $ticket_line_item); |
|
| 55 | + $reg_code = new RegCode($reg_url_link, $transaction, $ticket); |
|
| 56 | + // generate new EE_Registration |
|
| 57 | + $registration = EE_Registration::new_instance( |
|
| 58 | + array( |
|
| 59 | + 'EVT_ID' => $event->ID(), |
|
| 60 | + 'TXN_ID' => $transaction->ID(), |
|
| 61 | + 'TKT_ID' => $ticket->ID(), |
|
| 62 | + 'STS_ID' => $reg_status, |
|
| 63 | + 'REG_final_price' => $this->resolveFinalPrice($transaction, $ticket, $ticket_line_item), |
|
| 64 | + 'REG_session' => EE_Registry::instance()->SSN->id(), |
|
| 65 | + 'REG_count' => $reg_count, |
|
| 66 | + 'REG_group_size' => $reg_group_size ? $reg_group_size : $this->incrementRegGroupSize($registrations), |
|
| 67 | + 'REG_url_link' => $reg_url_link, |
|
| 68 | + 'REG_code' => $reg_code, |
|
| 69 | + ) |
|
| 70 | + ); |
|
| 71 | + if (! $registration instanceof EE_Registration) { |
|
| 72 | + throw new UnexpectedEntityException($registration, 'EE_Registration'); |
|
| 73 | + } |
|
| 74 | + // save registration so that we have an ID |
|
| 75 | + $registration->save(); |
|
| 76 | + // track reservation on reg but don't adjust ticket and datetime reserved counts |
|
| 77 | + // because that is done as soon as the tickets are added/removed from the cart |
|
| 78 | + $registration->reserve_ticket(false, 'CreateRegistrationService:' . __LINE__); |
|
| 79 | + $registration->_add_relation_to($event, 'Event', array(), $event->ID()); |
|
| 80 | + $registration->_add_relation_to($ticket, 'Ticket', array(), $ticket->ID()); |
|
| 81 | + $transaction->_add_relation_to($registration, 'Registration', array(), $registration->ID()); |
|
| 82 | + $registration->save(); |
|
| 83 | + return $registration; |
|
| 84 | + } |
|
| 85 | 85 | |
| 86 | 86 | |
| 87 | - /** |
|
| 88 | - * @param EE_Transaction $transaction |
|
| 89 | - * @param EE_Ticket $ticket |
|
| 90 | - * @param EE_Line_Item $ticket_line_item |
|
| 91 | - * @return float |
|
| 92 | - * @throws EE_Error |
|
| 93 | - * @throws OutOfRangeException |
|
| 94 | - */ |
|
| 95 | - protected function resolveFinalPrice( |
|
| 96 | - EE_Transaction $transaction, |
|
| 97 | - EE_Ticket $ticket, |
|
| 98 | - EE_Line_Item $ticket_line_item |
|
| 99 | - ) { |
|
| 100 | - $final_price = EEH_Line_Item::calculate_final_price_for_ticket_line_item( |
|
| 101 | - $transaction->total_line_item(), |
|
| 102 | - $ticket_line_item |
|
| 103 | - ); |
|
| 104 | - $final_price = $final_price !== null ? $final_price : $ticket->get_ticket_total_with_taxes(); |
|
| 105 | - return (float) $final_price; |
|
| 106 | - } |
|
| 87 | + /** |
|
| 88 | + * @param EE_Transaction $transaction |
|
| 89 | + * @param EE_Ticket $ticket |
|
| 90 | + * @param EE_Line_Item $ticket_line_item |
|
| 91 | + * @return float |
|
| 92 | + * @throws EE_Error |
|
| 93 | + * @throws OutOfRangeException |
|
| 94 | + */ |
|
| 95 | + protected function resolveFinalPrice( |
|
| 96 | + EE_Transaction $transaction, |
|
| 97 | + EE_Ticket $ticket, |
|
| 98 | + EE_Line_Item $ticket_line_item |
|
| 99 | + ) { |
|
| 100 | + $final_price = EEH_Line_Item::calculate_final_price_for_ticket_line_item( |
|
| 101 | + $transaction->total_line_item(), |
|
| 102 | + $ticket_line_item |
|
| 103 | + ); |
|
| 104 | + $final_price = $final_price !== null ? $final_price : $ticket->get_ticket_total_with_taxes(); |
|
| 105 | + return (float) $final_price; |
|
| 106 | + } |
|
| 107 | 107 | |
| 108 | 108 | |
| 109 | - /** |
|
| 110 | - * @param EE_Registration[] $registrations |
|
| 111 | - * @param boolean $update_existing_registrations |
|
| 112 | - * @return int |
|
| 113 | - * @throws EE_Error |
|
| 114 | - */ |
|
| 115 | - protected function incrementRegGroupSize(array $registrations, $update_existing_registrations = true) |
|
| 116 | - { |
|
| 117 | - $new_reg_group_size = count($registrations) + 1; |
|
| 118 | - if ($update_existing_registrations) { |
|
| 119 | - foreach ($registrations as $registration) { |
|
| 120 | - if ($registration instanceof EE_Registration) { |
|
| 121 | - $registration->set_group_size($new_reg_group_size); |
|
| 122 | - $registration->save(); |
|
| 123 | - } |
|
| 124 | - } |
|
| 125 | - } |
|
| 126 | - return $new_reg_group_size; |
|
| 127 | - } |
|
| 109 | + /** |
|
| 110 | + * @param EE_Registration[] $registrations |
|
| 111 | + * @param boolean $update_existing_registrations |
|
| 112 | + * @return int |
|
| 113 | + * @throws EE_Error |
|
| 114 | + */ |
|
| 115 | + protected function incrementRegGroupSize(array $registrations, $update_existing_registrations = true) |
|
| 116 | + { |
|
| 117 | + $new_reg_group_size = count($registrations) + 1; |
|
| 118 | + if ($update_existing_registrations) { |
|
| 119 | + foreach ($registrations as $registration) { |
|
| 120 | + if ($registration instanceof EE_Registration) { |
|
| 121 | + $registration->set_group_size($new_reg_group_size); |
|
| 122 | + $registration->save(); |
|
| 123 | + } |
|
| 124 | + } |
|
| 125 | + } |
|
| 126 | + return $new_reg_group_size; |
|
| 127 | + } |
|
| 128 | 128 | } |
@@ -83,7 +83,7 @@ discard block |
||
| 83 | 83 | $reindexed_answers = array(); |
| 84 | 84 | foreach ($answers as $answer) { |
| 85 | 85 | if ($answer instanceof EE_Answer) { |
| 86 | - $reindexed_answers[ $answer->question_ID() ] = $answer->value(); |
|
| 86 | + $reindexed_answers[$answer->question_ID()] = $answer->value(); |
|
| 87 | 87 | } |
| 88 | 88 | } |
| 89 | 89 | return $reindexed_answers; |
@@ -103,8 +103,8 @@ discard block |
||
| 103 | 103 | EE_Registration $registration, |
| 104 | 104 | $previous_answers |
| 105 | 105 | ) { |
| 106 | - $old_answer_value = isset($previous_answers[ $question->ID() ]) |
|
| 107 | - ? $previous_answers[ $question->ID() ] |
|
| 106 | + $old_answer_value = isset($previous_answers[$question->ID()]) |
|
| 107 | + ? $previous_answers[$question->ID()] |
|
| 108 | 108 | : ''; |
| 109 | 109 | $new_answer = EE_Answer::new_instance( |
| 110 | 110 | array( |
@@ -113,7 +113,7 @@ discard block |
||
| 113 | 113 | 'ANS_value' => $old_answer_value, |
| 114 | 114 | ) |
| 115 | 115 | ); |
| 116 | - if (! $new_answer instanceof EE_Answer) { |
|
| 116 | + if ( ! $new_answer instanceof EE_Answer) { |
|
| 117 | 117 | throw new UnexpectedEntityException($new_answer, 'EE_Answer'); |
| 118 | 118 | } |
| 119 | 119 | $new_answer->save(); |
@@ -150,7 +150,7 @@ discard block |
||
| 150 | 150 | 'RPY_amount' => $payment_amount, |
| 151 | 151 | ) |
| 152 | 152 | ); |
| 153 | - if (! $new_registration_payment instanceof EE_Registration_Payment) { |
|
| 153 | + if ( ! $new_registration_payment instanceof EE_Registration_Payment) { |
|
| 154 | 154 | throw new UnexpectedEntityException($new_registration_payment, 'EE_Registration_Payment'); |
| 155 | 155 | } |
| 156 | 156 | $new_registration_payment->save(); |
@@ -25,152 +25,152 @@ |
||
| 25 | 25 | */ |
| 26 | 26 | class CopyRegistrationService extends DomainService |
| 27 | 27 | { |
| 28 | - /** |
|
| 29 | - * @param EE_Registration $target_registration |
|
| 30 | - * @param EE_Registration $registration_to_copy |
|
| 31 | - * @return bool |
|
| 32 | - * @throws UnexpectedEntityException |
|
| 33 | - * @throws EntityNotFoundException |
|
| 34 | - * @throws RuntimeException |
|
| 35 | - * @throws EE_Error |
|
| 36 | - */ |
|
| 37 | - public function copyRegistrationDetails( |
|
| 38 | - EE_Registration $target_registration, |
|
| 39 | - EE_Registration $registration_to_copy |
|
| 40 | - ) { |
|
| 41 | - // copy attendee |
|
| 42 | - $target_registration->set_attendee_id($registration_to_copy->attendee_ID()); |
|
| 43 | - $target_registration->updateStatusBasedOnTotalPaid(false); |
|
| 44 | - $target_registration->save(); |
|
| 45 | - // get answers to previous reg questions |
|
| 46 | - $answers = $this->reindexAnswersByQuestionId($registration_to_copy->answers()); |
|
| 47 | - // get questions to new event reg form |
|
| 48 | - $new_event = $target_registration->event(); |
|
| 49 | - $field_name = 'Event_Question_Group.' |
|
| 50 | - . EEM_Event_Question_Group::instance()->fieldNameForContext( |
|
| 51 | - $registration_to_copy->is_primary_registrant() |
|
| 52 | - ); |
|
| 53 | - $question_groups = $new_event->question_groups([ |
|
| 54 | - [ |
|
| 55 | - 'Event.EVT_ID' => $new_event->ID(), |
|
| 56 | - $field_name => true, |
|
| 57 | - ], |
|
| 58 | - 'order_by' => ['QSG_order' => 'ASC'], |
|
| 59 | - ]); |
|
| 60 | - foreach ($question_groups as $question_group) { |
|
| 61 | - if ($question_group instanceof \EE_Question_Group) { |
|
| 62 | - foreach ($question_group->questions() as $question) { |
|
| 63 | - if ($question instanceof EE_Question) { |
|
| 64 | - $this->generateNewAnswer( |
|
| 65 | - $question, |
|
| 66 | - $target_registration, |
|
| 67 | - $answers |
|
| 68 | - ); |
|
| 69 | - } |
|
| 70 | - } |
|
| 71 | - } |
|
| 72 | - } |
|
| 73 | - return true; |
|
| 74 | - } |
|
| 28 | + /** |
|
| 29 | + * @param EE_Registration $target_registration |
|
| 30 | + * @param EE_Registration $registration_to_copy |
|
| 31 | + * @return bool |
|
| 32 | + * @throws UnexpectedEntityException |
|
| 33 | + * @throws EntityNotFoundException |
|
| 34 | + * @throws RuntimeException |
|
| 35 | + * @throws EE_Error |
|
| 36 | + */ |
|
| 37 | + public function copyRegistrationDetails( |
|
| 38 | + EE_Registration $target_registration, |
|
| 39 | + EE_Registration $registration_to_copy |
|
| 40 | + ) { |
|
| 41 | + // copy attendee |
|
| 42 | + $target_registration->set_attendee_id($registration_to_copy->attendee_ID()); |
|
| 43 | + $target_registration->updateStatusBasedOnTotalPaid(false); |
|
| 44 | + $target_registration->save(); |
|
| 45 | + // get answers to previous reg questions |
|
| 46 | + $answers = $this->reindexAnswersByQuestionId($registration_to_copy->answers()); |
|
| 47 | + // get questions to new event reg form |
|
| 48 | + $new_event = $target_registration->event(); |
|
| 49 | + $field_name = 'Event_Question_Group.' |
|
| 50 | + . EEM_Event_Question_Group::instance()->fieldNameForContext( |
|
| 51 | + $registration_to_copy->is_primary_registrant() |
|
| 52 | + ); |
|
| 53 | + $question_groups = $new_event->question_groups([ |
|
| 54 | + [ |
|
| 55 | + 'Event.EVT_ID' => $new_event->ID(), |
|
| 56 | + $field_name => true, |
|
| 57 | + ], |
|
| 58 | + 'order_by' => ['QSG_order' => 'ASC'], |
|
| 59 | + ]); |
|
| 60 | + foreach ($question_groups as $question_group) { |
|
| 61 | + if ($question_group instanceof \EE_Question_Group) { |
|
| 62 | + foreach ($question_group->questions() as $question) { |
|
| 63 | + if ($question instanceof EE_Question) { |
|
| 64 | + $this->generateNewAnswer( |
|
| 65 | + $question, |
|
| 66 | + $target_registration, |
|
| 67 | + $answers |
|
| 68 | + ); |
|
| 69 | + } |
|
| 70 | + } |
|
| 71 | + } |
|
| 72 | + } |
|
| 73 | + return true; |
|
| 74 | + } |
|
| 75 | 75 | |
| 76 | 76 | |
| 77 | - /** |
|
| 78 | - * @param EE_Answer[] $answers |
|
| 79 | - * @return array |
|
| 80 | - * @throws EE_Error |
|
| 81 | - */ |
|
| 82 | - protected function reindexAnswersByQuestionId(array $answers) |
|
| 83 | - { |
|
| 84 | - $reindexed_answers = array(); |
|
| 85 | - foreach ($answers as $answer) { |
|
| 86 | - if ($answer instanceof EE_Answer) { |
|
| 87 | - $reindexed_answers[ $answer->question_ID() ] = $answer->value(); |
|
| 88 | - } |
|
| 89 | - } |
|
| 90 | - return $reindexed_answers; |
|
| 91 | - } |
|
| 77 | + /** |
|
| 78 | + * @param EE_Answer[] $answers |
|
| 79 | + * @return array |
|
| 80 | + * @throws EE_Error |
|
| 81 | + */ |
|
| 82 | + protected function reindexAnswersByQuestionId(array $answers) |
|
| 83 | + { |
|
| 84 | + $reindexed_answers = array(); |
|
| 85 | + foreach ($answers as $answer) { |
|
| 86 | + if ($answer instanceof EE_Answer) { |
|
| 87 | + $reindexed_answers[ $answer->question_ID() ] = $answer->value(); |
|
| 88 | + } |
|
| 89 | + } |
|
| 90 | + return $reindexed_answers; |
|
| 91 | + } |
|
| 92 | 92 | |
| 93 | 93 | |
| 94 | - /** |
|
| 95 | - * @param EE_Question $question |
|
| 96 | - * @param EE_Registration $registration |
|
| 97 | - * @param $previous_answers |
|
| 98 | - * @return EE_Answer |
|
| 99 | - * @throws UnexpectedEntityException |
|
| 100 | - * @throws EE_Error |
|
| 101 | - */ |
|
| 102 | - protected function generateNewAnswer( |
|
| 103 | - EE_Question $question, |
|
| 104 | - EE_Registration $registration, |
|
| 105 | - $previous_answers |
|
| 106 | - ) { |
|
| 107 | - $old_answer_value = isset($previous_answers[ $question->ID() ]) |
|
| 108 | - ? $previous_answers[ $question->ID() ] |
|
| 109 | - : ''; |
|
| 110 | - $new_answer = EE_Answer::new_instance( |
|
| 111 | - array( |
|
| 112 | - 'QST_ID' => $question->ID(), |
|
| 113 | - 'REG_ID' => $registration->ID(), |
|
| 114 | - 'ANS_value' => $old_answer_value, |
|
| 115 | - ) |
|
| 116 | - ); |
|
| 117 | - if (! $new_answer instanceof EE_Answer) { |
|
| 118 | - throw new UnexpectedEntityException($new_answer, 'EE_Answer'); |
|
| 119 | - } |
|
| 120 | - $new_answer->save(); |
|
| 121 | - return $new_answer; |
|
| 122 | - } |
|
| 94 | + /** |
|
| 95 | + * @param EE_Question $question |
|
| 96 | + * @param EE_Registration $registration |
|
| 97 | + * @param $previous_answers |
|
| 98 | + * @return EE_Answer |
|
| 99 | + * @throws UnexpectedEntityException |
|
| 100 | + * @throws EE_Error |
|
| 101 | + */ |
|
| 102 | + protected function generateNewAnswer( |
|
| 103 | + EE_Question $question, |
|
| 104 | + EE_Registration $registration, |
|
| 105 | + $previous_answers |
|
| 106 | + ) { |
|
| 107 | + $old_answer_value = isset($previous_answers[ $question->ID() ]) |
|
| 108 | + ? $previous_answers[ $question->ID() ] |
|
| 109 | + : ''; |
|
| 110 | + $new_answer = EE_Answer::new_instance( |
|
| 111 | + array( |
|
| 112 | + 'QST_ID' => $question->ID(), |
|
| 113 | + 'REG_ID' => $registration->ID(), |
|
| 114 | + 'ANS_value' => $old_answer_value, |
|
| 115 | + ) |
|
| 116 | + ); |
|
| 117 | + if (! $new_answer instanceof EE_Answer) { |
|
| 118 | + throw new UnexpectedEntityException($new_answer, 'EE_Answer'); |
|
| 119 | + } |
|
| 120 | + $new_answer->save(); |
|
| 121 | + return $new_answer; |
|
| 122 | + } |
|
| 123 | 123 | |
| 124 | 124 | |
| 125 | - /** |
|
| 126 | - * @param EE_Registration $target_registration |
|
| 127 | - * @param EE_Registration $registration_to_copy |
|
| 128 | - * @return bool |
|
| 129 | - * @throws RuntimeException |
|
| 130 | - * @throws UnexpectedEntityException |
|
| 131 | - * @throws EE_Error |
|
| 132 | - */ |
|
| 133 | - public function copyPaymentDetails( |
|
| 134 | - EE_Registration $target_registration, |
|
| 135 | - EE_Registration $registration_to_copy |
|
| 136 | - ) { |
|
| 137 | - $save = false; |
|
| 138 | - $previous_registration_payments = $registration_to_copy->registration_payments(); |
|
| 139 | - $new_registration_payment_total = 0; |
|
| 140 | - $registration_to_copy_total = $registration_to_copy->paid(); |
|
| 141 | - foreach ($previous_registration_payments as $previous_registration_payment) { |
|
| 142 | - if ( |
|
| 143 | - $previous_registration_payment instanceof EE_Registration_Payment |
|
| 144 | - && $previous_registration_payment->payment() instanceof EE_Payment |
|
| 145 | - && $previous_registration_payment->payment()->is_approved() |
|
| 146 | - ) { |
|
| 147 | - $payment_amount = $previous_registration_payment->amount(); |
|
| 148 | - $new_registration_payment = EE_Registration_Payment::new_instance( |
|
| 149 | - array( |
|
| 150 | - 'REG_ID' => $target_registration->ID(), |
|
| 151 | - 'PAY_ID' => $previous_registration_payment->payment()->ID(), |
|
| 152 | - 'RPY_amount' => $payment_amount, |
|
| 153 | - ) |
|
| 154 | - ); |
|
| 155 | - if (! $new_registration_payment instanceof EE_Registration_Payment) { |
|
| 156 | - throw new UnexpectedEntityException($new_registration_payment, 'EE_Registration_Payment'); |
|
| 157 | - } |
|
| 158 | - $new_registration_payment->save(); |
|
| 159 | - // if new reg payment is good, then set old reg payment amount to zero |
|
| 160 | - $previous_registration_payment->set_amount(0); |
|
| 161 | - $previous_registration_payment->save(); |
|
| 162 | - // now increment/decrement payment amounts |
|
| 163 | - $new_registration_payment_total += $payment_amount; |
|
| 164 | - $registration_to_copy_total -= $payment_amount; |
|
| 165 | - $save = true; |
|
| 166 | - } |
|
| 167 | - } |
|
| 168 | - if ($save) { |
|
| 169 | - $target_registration->set_paid($new_registration_payment_total); |
|
| 170 | - $target_registration->save(); |
|
| 171 | - $registration_to_copy->set_paid($registration_to_copy_total); |
|
| 172 | - $registration_to_copy->save(); |
|
| 173 | - } |
|
| 174 | - return true; |
|
| 175 | - } |
|
| 125 | + /** |
|
| 126 | + * @param EE_Registration $target_registration |
|
| 127 | + * @param EE_Registration $registration_to_copy |
|
| 128 | + * @return bool |
|
| 129 | + * @throws RuntimeException |
|
| 130 | + * @throws UnexpectedEntityException |
|
| 131 | + * @throws EE_Error |
|
| 132 | + */ |
|
| 133 | + public function copyPaymentDetails( |
|
| 134 | + EE_Registration $target_registration, |
|
| 135 | + EE_Registration $registration_to_copy |
|
| 136 | + ) { |
|
| 137 | + $save = false; |
|
| 138 | + $previous_registration_payments = $registration_to_copy->registration_payments(); |
|
| 139 | + $new_registration_payment_total = 0; |
|
| 140 | + $registration_to_copy_total = $registration_to_copy->paid(); |
|
| 141 | + foreach ($previous_registration_payments as $previous_registration_payment) { |
|
| 142 | + if ( |
|
| 143 | + $previous_registration_payment instanceof EE_Registration_Payment |
|
| 144 | + && $previous_registration_payment->payment() instanceof EE_Payment |
|
| 145 | + && $previous_registration_payment->payment()->is_approved() |
|
| 146 | + ) { |
|
| 147 | + $payment_amount = $previous_registration_payment->amount(); |
|
| 148 | + $new_registration_payment = EE_Registration_Payment::new_instance( |
|
| 149 | + array( |
|
| 150 | + 'REG_ID' => $target_registration->ID(), |
|
| 151 | + 'PAY_ID' => $previous_registration_payment->payment()->ID(), |
|
| 152 | + 'RPY_amount' => $payment_amount, |
|
| 153 | + ) |
|
| 154 | + ); |
|
| 155 | + if (! $new_registration_payment instanceof EE_Registration_Payment) { |
|
| 156 | + throw new UnexpectedEntityException($new_registration_payment, 'EE_Registration_Payment'); |
|
| 157 | + } |
|
| 158 | + $new_registration_payment->save(); |
|
| 159 | + // if new reg payment is good, then set old reg payment amount to zero |
|
| 160 | + $previous_registration_payment->set_amount(0); |
|
| 161 | + $previous_registration_payment->save(); |
|
| 162 | + // now increment/decrement payment amounts |
|
| 163 | + $new_registration_payment_total += $payment_amount; |
|
| 164 | + $registration_to_copy_total -= $payment_amount; |
|
| 165 | + $save = true; |
|
| 166 | + } |
|
| 167 | + } |
|
| 168 | + if ($save) { |
|
| 169 | + $target_registration->set_paid($new_registration_payment_total); |
|
| 170 | + $target_registration->save(); |
|
| 171 | + $registration_to_copy->set_paid($registration_to_copy_total); |
|
| 172 | + $registration_to_copy->save(); |
|
| 173 | + } |
|
| 174 | + return true; |
|
| 175 | + } |
|
| 176 | 176 | } |