<?php

[0] Fix | Delete

[1] Fix | Delete

namespace WPForms\Migrations;

[2] Fix | Delete

[3] Fix | Delete

use WPForms\Tasks\Meta;

[4] Fix | Delete

use WPForms\Tasks\Tasks;

[5] Fix | Delete

[6] Fix | Delete

/**

[7] Fix | Delete

* Class v1.7.5 upgrade.

[8] Fix | Delete

*

[9] Fix | Delete

* @since 1.7.5

[10] Fix | Delete

*

[11] Fix | Delete

* @noinspection PhpUnused

[12] Fix | Delete

*/

[13] Fix | Delete

class Upgrade175 extends UpgradeBase {

[14] Fix | Delete

[15] Fix | Delete

/**

[16] Fix | Delete

* Delete all task meta of not active tasks.

[17] Fix | Delete

*

[18] Fix | Delete

* @since 1.7.5

[19] Fix | Delete

*

[20] Fix | Delete

* @noinspection ElvisOperatorCanBeUsedInspection

[21] Fix | Delete

*

[22] Fix | Delete

* @return bool|null Upgrade result:

[23] Fix | Delete

* true - the upgrade completed successfully,

[24] Fix | Delete

* false - in the case of failure,

[25] Fix | Delete

* null - upgrade started but not yet finished (background task).

[26] Fix | Delete

*/

[27] Fix | Delete

public function run() {

[28] Fix | Delete

[29] Fix | Delete

global $wpdb;

[30] Fix | Delete

[31] Fix | Delete

if ( ! $this->as_tables_exist() ) {

[32] Fix | Delete

return true;

[33] Fix | Delete

}

[34] Fix | Delete

[35] Fix | Delete

$group = Tasks::GROUP;

[36] Fix | Delete

$sql = "SELECT DISTINCT a.args FROM {$wpdb->prefix}actionscheduler_actions a

[37] Fix | Delete

JOIN {$wpdb->prefix}actionscheduler_groups g ON g.group_id = a.group_id

[38] Fix | Delete

WHERE g.slug = '$group' AND a.status IN ( 'pending', 'in-progress' )";

[39] Fix | Delete

[40] Fix | Delete

// phpcs:disable WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching, WordPress.DB.PreparedSQL.NotPrepared

[41] Fix | Delete

$results = $wpdb->get_results( $sql, 'ARRAY_A' );

[42] Fix | Delete

// phpcs:enable WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching, WordPress.DB.PreparedSQL.NotPrepared

[43] Fix | Delete

[44] Fix | Delete

$results = $results ? $results : [];

[45] Fix | Delete

$meta_ids = [];

[46] Fix | Delete

[47] Fix | Delete

foreach ( $results as $result ) {

[48] Fix | Delete

$args = isset( $result['args'] ) ? json_decode( $result['args'], true ) : null;

[49] Fix | Delete

[50] Fix | Delete

if ( $args && ! empty( $args['tasks_meta_id'] ) ) {

[51] Fix | Delete

$meta_ids[] = $args['tasks_meta_id'];

[52] Fix | Delete

}

[53] Fix | Delete

}

[54] Fix | Delete

[55] Fix | Delete

$table_name = Meta::get_table_name();

[56] Fix | Delete

$not_in = $meta_ids ? wpforms_wpdb_prepare_in( $meta_ids ) : '0';

[57] Fix | Delete

[58] Fix | Delete

// phpcs:disable WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.PreparedSQL.InterpolatedNotPrepared, WordPress.DB.DirectDatabaseQuery.NoCaching

[59] Fix | Delete

$wpdb->query( "DELETE FROM $table_name WHERE id NOT IN ( $not_in )" );

[60] Fix | Delete

[61] Fix | Delete

// phpcs:enable WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.PreparedSQL.InterpolatedNotPrepared, WordPress.DB.DirectDatabaseQuery.NoCaching

[62] Fix | Delete

[63] Fix | Delete

return true;

[64] Fix | Delete

}

[65] Fix | Delete

[66] Fix | Delete

/**

[67] Fix | Delete

* Check whether AS tables exist.

[68] Fix | Delete

*

[69] Fix | Delete

* @since 1.7.6

[70] Fix | Delete

*

[71] Fix | Delete

* @return bool

[72] Fix | Delete

*/

[73] Fix | Delete

private function as_tables_exist() {

[74] Fix | Delete

[75] Fix | Delete

global $wpdb;

[76] Fix | Delete

[77] Fix | Delete

$required_tables = [

[78] Fix | Delete

$wpdb->prefix . 'actionscheduler_actions',

[79] Fix | Delete

$wpdb->prefix . 'actionscheduler_groups',

[80] Fix | Delete

];

[81] Fix | Delete

[82] Fix | Delete

// phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching

[83] Fix | Delete

$tables = $wpdb->get_col( "SHOW TABLES LIKE '{$wpdb->prefix}actionscheduler%'" );

[84] Fix | Delete

$intersect = array_values( array_intersect( $tables, $required_tables ) );

[85] Fix | Delete

[86] Fix | Delete

sort( $intersect );

[87] Fix | Delete

sort( $required_tables );

[88] Fix | Delete

[89] Fix | Delete

return $intersect === $required_tables;

[90] Fix | Delete

}

[91] Fix | Delete

}

[92] Fix | Delete

[93] Fix | Delete