| @@ -135,8 +135,10 @@ | ||
| 135 | 135 | } |
| 136 | 136 | |
| 137 | 137 | public static function maybeMigrateDBChanges() |
| 138 | 138 | { |
| 139 | + self::maybeMigrateCustomerRecoveryIndexes(); | |
| 140 | + | |
| 139 | 141 | /* |
| 140 | 142 | * TODO We will remove this after final release |
| 141 | 143 | */ |
| 142 | 144 | $currentDBVersion = get_option('_fluent_cart_db_version'); |
| @@ -595,8 +597,40 @@ | ||
| 595 | 597 | AttributeObjectRelationsMigrator::migrate(); |
| 596 | 598 | AttributeTermsMigrator::migrate(); |
| 597 | 599 | AttributeSeeder::seed(); |
| 598 | 600 | |
| 601 | + self::releaseMigrationLock(); | |
| 602 | + } | |
| 603 | + } | |
| 604 | + | |
| 605 | + /** Upgrade active stores without running index DDL on customer requests. */ | |
| 606 | + public static function maybeMigrateCustomerRecoveryIndexes(): void | |
| 607 | + { | |
| 608 | + $option = '_fluent_cart_customer_recovery_indexes_version'; | |
| 609 | + if (get_option($option) === '1') { | |
| 610 | + return; | |
| 611 | + } | |
| 612 | + if (!(defined('WP_CLI') && WP_CLI) && (!is_admin() || !current_user_can('manage_options'))) { | |
| 613 | + return; | |
| 614 | + } | |
| 615 | + if (!self::acquireMigrationLock()) { | |
| 616 | + return; | |
| 617 | + } | |
| 618 | + try { | |
| 619 | + if (get_option($option) === '1') { | |
| 620 | + return; | |
| 621 | + } | |
| 622 | + foreach ([SubscriptionsMigrator::class, OrderDownloadPermissionsMigrator::class, CartMigrator::class] as $migrator) { | |
| 623 | + if (!Schema::hasTable($migrator::$tableName)) { | |
| 624 | + return; | |
| 625 | + } | |
| 626 | + $migrator::addCustomerRecoveryIndex(); | |
| 627 | + if (!$migrator::hasCustomerRecoveryIndex()) { | |
| 628 | + return; // Keep the upgrade pending if ALTER failed. | |
| 629 | + } | |
| 630 | + } | |
| 631 | + update_option($option, '1', false); | |
| 632 | + } finally { | |
| 599 | 633 | self::releaseMigrationLock(); |
| 600 | 634 | } |
| 601 | 635 | } |
| 602 | 636 | |