Export
3 months ago
Import
1 hour ago
PersonalDataExporters
3 months ago
ImportExportFactory.php
1 hour ago
ImportExportRepository.php
1 hour ago
index.php
3 years ago
ImportExportFactory.php
201 lines
| 1 | <?php // phpcs:ignore SlevomatCodingStandard.TypeHints.DeclareStrictTypes.DeclareStrictTypesMissing |
| 2 | |
| 3 | namespace MailPoet\Subscribers\ImportExport; |
| 4 | |
| 5 | if (!defined('ABSPATH')) exit; |
| 6 | |
| 7 | |
| 8 | use MailPoet\CustomFields\CustomFieldsRepository; |
| 9 | use MailPoet\DI\ContainerWrapper; |
| 10 | use MailPoet\Entities\SegmentEntity; |
| 11 | use MailPoet\Entities\TagEntity; |
| 12 | use MailPoet\Segments\SegmentsSimpleListRepository; |
| 13 | use MailPoet\Tags\TagRepository; |
| 14 | use MailPoet\Util\Helpers; |
| 15 | |
| 16 | class ImportExportFactory { |
| 17 | const IMPORT_ACTION = 'import'; |
| 18 | const EXPORT_ACTION = 'export'; |
| 19 | |
| 20 | /** @var string|null */ |
| 21 | public $action; |
| 22 | |
| 23 | /** @var SegmentsSimpleListRepository */ |
| 24 | private $segmentsListRepository; |
| 25 | |
| 26 | /** @var CustomFieldsRepository */ |
| 27 | private $customFieldsRepository; |
| 28 | |
| 29 | /** @var TagRepository */ |
| 30 | private $tagRepository; |
| 31 | |
| 32 | public function __construct( |
| 33 | $action = null |
| 34 | ) { |
| 35 | $this->action = $action; |
| 36 | $this->segmentsListRepository = ContainerWrapper::getInstance()->get(SegmentsSimpleListRepository::class); |
| 37 | $this->customFieldsRepository = ContainerWrapper::getInstance()->get(CustomFieldsRepository::class); |
| 38 | $this->tagRepository = ContainerWrapper::getInstance()->get(TagRepository::class); |
| 39 | } |
| 40 | |
| 41 | public function getSegments() { |
| 42 | if ($this->action === self::IMPORT_ACTION) { |
| 43 | $segments = $this->segmentsListRepository->getListWithSubscribedSubscribersCounts([SegmentEntity::TYPE_DEFAULT]); |
| 44 | } else { |
| 45 | $segments = $this->segmentsListRepository->getListWithAssociatedSubscribersCounts(); |
| 46 | $segments = $this->segmentsListRepository->addVirtualSubscribersWithoutListSegment($segments); |
| 47 | $segments = array_values(array_filter($segments, function($segment) { |
| 48 | return $segment['subscribers'] > 0; |
| 49 | })); |
| 50 | } |
| 51 | |
| 52 | return array_map(function($segment) { |
| 53 | return [ |
| 54 | 'id' => $segment['id'], |
| 55 | 'name' => esc_attr($segment['name']), |
| 56 | 'count' => $segment['subscribers'], |
| 57 | ]; |
| 58 | }, $segments); |
| 59 | } |
| 60 | |
| 61 | public function getSubscriberFields() { |
| 62 | $fields = [ |
| 63 | 'email' => __('Email', 'mailpoet'), |
| 64 | 'first_name' => __('First name', 'mailpoet'), |
| 65 | 'last_name' => __('Last name', 'mailpoet'), |
| 66 | 'subscribed_ip' => __('Subscription IP', 'mailpoet'), |
| 67 | 'created_at' => __('Subscription time', 'mailpoet'), |
| 68 | 'confirmed_at' => __('Confirmation time', 'mailpoet'), |
| 69 | 'confirmed_ip' => __('Confirmation IP', 'mailpoet'), |
| 70 | 'tracking_consent' => __('Tracking consent', 'mailpoet'), |
| 71 | 'tracking_consent_method' => __('Tracking consent method', 'mailpoet'), |
| 72 | 'tracking_consent_copy' => __('Tracking consent wording', 'mailpoet'), |
| 73 | ]; |
| 74 | if ($this->action === 'export') { |
| 75 | $fields = array_merge( |
| 76 | $fields, |
| 77 | [ |
| 78 | // Export only: the plugin always stamps this itself, it is never taken from an import. |
| 79 | 'tracking_consent_updated_at' => __('Tracking consent updated', 'mailpoet'), |
| 80 | 'last_subscribed_at' => __('Last subscribed on', 'mailpoet'), |
| 81 | 'list_status' => _x('List status', 'Subscription status', 'mailpoet'), |
| 82 | 'global_status' => _x('Global status', 'Subscription status', 'mailpoet'), |
| 83 | ] |
| 84 | ); |
| 85 | } |
| 86 | return $fields; |
| 87 | } |
| 88 | |
| 89 | public function formatSubscriberFields($subscriberFields) { |
| 90 | return array_map(function($fieldId, $fieldName) { |
| 91 | return [ |
| 92 | 'id' => $fieldId, |
| 93 | 'name' => $fieldName, |
| 94 | 'text' => $fieldName, // Required for select2 default functionality |
| 95 | 'type' => in_array($fieldId, ['confirmed_at', 'created_at', 'last_subscribed_at', 'tracking_consent_updated_at'], true) ? 'date' : null, |
| 96 | 'custom' => false, |
| 97 | ]; |
| 98 | }, array_keys($subscriberFields), $subscriberFields); |
| 99 | } |
| 100 | |
| 101 | public function getSubscriberCustomFields() { |
| 102 | return $this->customFieldsRepository->findAllAsArray(); |
| 103 | } |
| 104 | |
| 105 | public function formatSubscriberCustomFields($subscriberCustomFields) { |
| 106 | return array_map(function($field) { |
| 107 | return [ |
| 108 | 'id' => $field['id'], |
| 109 | 'name' => $field['name'], |
| 110 | 'text' => $field['name'], // Required for select2 default functionality |
| 111 | 'type' => $field['type'], |
| 112 | 'params' => unserialize($field['params']), |
| 113 | 'custom' => true, |
| 114 | ]; |
| 115 | }, $subscriberCustomFields); |
| 116 | } |
| 117 | |
| 118 | public function formatFieldsForSelect2( |
| 119 | $subscriberFields, |
| 120 | $subscriberCustomFields |
| 121 | ) { |
| 122 | $actions = ($this->action === 'import') ? |
| 123 | [ |
| 124 | [ |
| 125 | 'id' => 'ignore', |
| 126 | 'name' => __('Ignore field...', 'mailpoet'), |
| 127 | 'text' => __('Ignore field...', 'mailpoet'), // Required for select2 default functionality |
| 128 | ], |
| 129 | [ |
| 130 | 'id' => 'create', |
| 131 | 'name' => __('Create new field...', 'mailpoet'), |
| 132 | 'text' => __('Create new field...', 'mailpoet'), // Required for select2 default functionality |
| 133 | ], |
| 134 | ] : |
| 135 | [ |
| 136 | [ |
| 137 | 'id' => 'select', |
| 138 | 'name' => __('Select all...', 'mailpoet'), |
| 139 | 'text' => __('Select all...', 'mailpoet'), // Required for select2 default functionality |
| 140 | ], |
| 141 | [ |
| 142 | 'id' => 'deselect', |
| 143 | 'name' => __('Deselect all...', 'mailpoet'), |
| 144 | 'text' => __('Deselect all...', 'mailpoet'), // Required for select2 default functionality |
| 145 | ], |
| 146 | ]; |
| 147 | $select2Fields = [ |
| 148 | [ |
| 149 | 'name' => __('Actions', 'mailpoet'), |
| 150 | 'text' => __('Actions', 'mailpoet'), // Required for select2 default functionality |
| 151 | 'children' => $actions, |
| 152 | ], |
| 153 | [ |
| 154 | 'name' => __('System fields', 'mailpoet'), |
| 155 | 'text' => __('System fields', 'mailpoet'), // Required for select2 default functionality |
| 156 | 'children' => $this->formatSubscriberFields($subscriberFields), |
| 157 | ], |
| 158 | ]; |
| 159 | if ($subscriberCustomFields) { |
| 160 | array_push($select2Fields, [ |
| 161 | 'name' => __('User fields', 'mailpoet'), |
| 162 | 'text' => __('User fields', 'mailpoet'), // Required for select2 default functionality |
| 163 | 'children' => $this->formatSubscriberCustomFields( |
| 164 | $subscriberCustomFields |
| 165 | ), |
| 166 | ]); |
| 167 | } |
| 168 | return $select2Fields; |
| 169 | } |
| 170 | |
| 171 | public function bootstrap() { |
| 172 | $subscriberFields = $this->getSubscriberFields(); |
| 173 | $subscriberCustomFields = $this->getSubscriberCustomFields(); |
| 174 | $data['segments'] = json_encode($this->getSegments()); |
| 175 | $data['subscriberFieldsSelect2'] = json_encode( |
| 176 | $this->formatFieldsForSelect2( |
| 177 | $subscriberFields, |
| 178 | $subscriberCustomFields |
| 179 | ) |
| 180 | ); |
| 181 | if ($this->action === 'import') { |
| 182 | $data['subscriberFields'] = json_encode( |
| 183 | array_merge( |
| 184 | $this->formatSubscriberFields($subscriberFields), |
| 185 | $this->formatSubscriberCustomFields($subscriberCustomFields) |
| 186 | ) |
| 187 | ); |
| 188 | $data['maxPostSizeBytes'] = Helpers::getMaxPostSize('bytes'); |
| 189 | $data['maxPostSize'] = Helpers::getMaxPostSize(); |
| 190 | $data['tags'] = array_map(function (TagEntity $tag): array { |
| 191 | return [ |
| 192 | 'id' => $tag->getId(), |
| 193 | 'name' => $tag->getName(), |
| 194 | ]; |
| 195 | }, $this->tagRepository->findAll()); |
| 196 | } |
| 197 | $data['zipExtensionLoaded'] = extension_loaded('zip'); |
| 198 | return $data; |
| 199 | } |
| 200 | } |
| 201 |