Pruner.php
98 lines
| 1 | <?php |
| 2 | |
| 3 | namespace IAWP\Data_Pruning; |
| 4 | |
| 5 | use IAWP\Illuminate_Builder; |
| 6 | use IAWP\Query; |
| 7 | use IAWP\Tables; |
| 8 | /** @internal */ |
| 9 | class Pruner |
| 10 | { |
| 11 | private function __construct() |
| 12 | { |
| 13 | } |
| 14 | private function run() : void |
| 15 | { |
| 16 | $scheduler = new \IAWP\Data_Pruning\Pruning_Scheduler(); |
| 17 | if ($scheduler->is_enabled() === \false) { |
| 18 | return; |
| 19 | } |
| 20 | $cutoff_date = $scheduler->get_pruning_cutoff_as_datetime(); |
| 21 | if ($cutoff_date === null) { |
| 22 | return; |
| 23 | } |
| 24 | $sessions_table = Query::get_table_name(Query::SESSIONS); |
| 25 | Illuminate_Builder::new()->from($sessions_table)->where('created_at', '<', $cutoff_date->format('Y-m-d\\TH:i:s'))->delete(); |
| 26 | // Delete orphaned views |
| 27 | $views_table = Query::get_table_name(Query::VIEWS); |
| 28 | $this->delete_session_orphans($views_table, 'session_id'); |
| 29 | // Delete orphaned form submissions |
| 30 | $form_submissions_table = Query::get_table_name(Query::FORM_SUBMISSIONS); |
| 31 | $this->delete_session_orphans($form_submissions_table, 'session_id'); |
| 32 | // Delete orphaned WooCommerce orders |
| 33 | $orders_table = Query::get_table_name(Query::ORDERS); |
| 34 | $this->delete_view_orphans($orders_table, 'view_id', 'id'); |
| 35 | // Delete orphaned visitors |
| 36 | $visitors_table = Query::get_table_name(Query::VISITORS); |
| 37 | $this->delete_session_orphans($visitors_table, 'visitor_id'); |
| 38 | // Delete orphaned resources |
| 39 | $resources_table = Query::get_table_name(Query::RESOURCES); |
| 40 | $this->delete_view_orphans($resources_table, 'id', 'resource_id'); |
| 41 | // Delete orphaned referrers |
| 42 | $referrers_table = Query::get_table_name(Query::REFERRERS); |
| 43 | $this->delete_session_orphans($referrers_table, 'id', 'referrer_id'); |
| 44 | // Delete orphaned forms |
| 45 | $forms_table = Query::get_table_name(Query::FORMS); |
| 46 | Illuminate_Builder::new()->from($forms_table, 'orphans')->leftJoin("{$form_submissions_table} AS form_submissions", "orphans.form_id", '=', "form_submissions.form_id")->whereNull('form_submissions.form_id')->delete(); |
| 47 | // Delete orphaned device browsers |
| 48 | $device_browsers_table = Query::get_table_name(Query::DEVICE_BROWSERS); |
| 49 | $this->delete_session_orphans($device_browsers_table, 'device_browser_id'); |
| 50 | // Delete orphaned device oss |
| 51 | $device_oss_table = Query::get_table_name(Query::DEVICE_OSS); |
| 52 | $this->delete_session_orphans($device_oss_table, 'device_os_id'); |
| 53 | // Delete orphaned device types |
| 54 | $device_types_table = Query::get_table_name(Query::DEVICE_TYPES); |
| 55 | $this->delete_session_orphans($device_types_table, 'device_type_id'); |
| 56 | // Don't touch cities or countries for now |
| 57 | // This would be a very different custom query as cities reference countries |
| 58 | // Delete orphaned campaigns |
| 59 | $campaigns_table = Query::get_table_name(Query::CAMPAIGNS); |
| 60 | $this->delete_session_orphans($campaigns_table, 'campaign_id'); |
| 61 | // Delete orphaned clicks |
| 62 | $this->delete_view_orphans(Tables::clicks(), 'view_id', 'id'); |
| 63 | // Delete orphaned clicked links |
| 64 | $clicks_table = Tables::clicks(); |
| 65 | Illuminate_Builder::new()->from(Tables::clicked_links(), 'orphans')->leftJoin("{$clicks_table} AS clicks", 'orphans.click_id', '=', 'clicks.click_id')->whereNull('clicks.click_id')->delete(); |
| 66 | // Delete orphaned links |
| 67 | $clicked_links_table = Tables::clicked_links(); |
| 68 | Illuminate_Builder::new()->from(Tables::links(), 'links')->leftJoin("{$clicked_links_table} AS clicked_links", 'clicked_links.link_id', '=', 'links.id')->whereNull('clicked_links.click_id')->delete(); |
| 69 | // Delete orphaned click targets |
| 70 | $links_table = Tables::links(); |
| 71 | Illuminate_Builder::new()->from(Tables::click_targets(), 'orphans')->leftJoin("{$links_table} AS links", 'orphans.click_target_id', '=', 'links.click_target_id')->whereNull('links.id')->delete(); |
| 72 | \delete_option('iawp_beginning_of_time'); |
| 73 | } |
| 74 | private function delete_session_orphans(string $table, string $column, ?string $sessions_column = null) : int |
| 75 | { |
| 76 | $sessions_table = Query::get_table_name(Query::SESSIONS); |
| 77 | $sessions_column = $sessions_column ?? $column; |
| 78 | return Illuminate_Builder::new()->from($table, 'orphans')->leftJoin("{$sessions_table} AS sessions", "orphans.{$column}", '=', "sessions.{$sessions_column}")->whereNull('sessions.session_id')->delete(); |
| 79 | } |
| 80 | private function delete_view_orphans(string $table, string $column, ?string $views_column = null) : int |
| 81 | { |
| 82 | $views_table = Query::get_table_name(Query::VIEWS); |
| 83 | $views_column = $views_column ?? $column; |
| 84 | return Illuminate_Builder::new()->from($table, 'orphans')->leftJoin("{$views_table} AS views", "orphans.{$column}", '=', "views.{$views_column}")->whereNull('views.id')->delete(); |
| 85 | } |
| 86 | public static function register_hook() |
| 87 | { |
| 88 | \add_action('iawp_prune', function () { |
| 89 | self::prune(); |
| 90 | }); |
| 91 | } |
| 92 | public static function prune() |
| 93 | { |
| 94 | $pruner = new self(); |
| 95 | $pruner->run(); |
| 96 | } |
| 97 | } |
| 98 |