<?php if ( ! defined( 'ABSPATH' ) ) exit;
* Class NF_Updates_CacheCollateForms
* This class manages the step process of running through the CacheCollateForms required update.
* It will define an object to pull data from (if necessary) to pick back up if exited early.
* It will run an upgrade function to alter the nf3_forms and nf3_form_meta tables.
* Then, it will step over each form on the site, following this process:
* - New columns in the nf3_forms table will be populated with data from the cache.
* - New and existing columns in the nf3_form_meta tables will be populated from the cache.
* - A new record of the cache will be saved to the nf3_upgrades table (if it does not already exist).
* After completing the above for every form on the site, it will remove the data object that manages its location.
class NF_Updates_CacheCollateForms extends NF_Abstracts_RequiredUpdate
private $running = array();
* Stores information about the current form being processed.
* Declare a blacklist for settings to not be inserted.
private $blacklist = array(
* The table names for our database queries.
* @param $data (Array) The data object passed in by the AJAX call.
* @param $running (Array) The array of required updates being run.
public function __construct( $data = array(), $running )
// Build our arguments array.
'slug' => 'CacheCollateForms',
'class_name' => 'NF_Updates_CacheCollateForms',
$this->running = $running;
// Call the parent constructor.
parent::__construct( $args );
$this->table = $this->db->prefix . 'nf3_forms';
$this->meta_table = $this->db->prefix . 'nf3_form_meta';
* Function to loop over the batch.
public function process()
// If we've not already started...
if ( ! isset( $this->running[ 0 ][ 'running' ] ) ) {
// Run our startup method.
// See which form we're currently working with.
$this->form = array_pop( $this->running[ 0 ][ 'forms' ] );
* If we don't have a cache for this form, we need to add one for later processing.
* We're going to check that the cache exists and create one if we don't have one.
$cache = WPN_Helper::get_nf_cache( $this->form[ 'ID' ] );
if ( empty ( $cache ) ) { // No cache exists.
// Call our build_nf_cache static method.
$form_cache = WPN_Helper::build_nf_cache( $this->form[ 'ID' ] );
* Update our form table with the appropriate form settings.
* Check to see if we're done with processing this form and prepare to respond.
// Respond to the AJAX call.
* Function to run any setup steps necessary to begin processing.
public function startup()
// Record that we're processing the update.
$this->running[ 0 ][ 'running' ] = true;
// If we're not debugging...
// Ensure that our data tables are updated.
$this->migrate( 'cache_collate_forms' );
// Set out new db version.
update_option( 'ninja_forms_db_version', '1.1' );
// Get a list of our forms...
$sql = "SELECT ID FROM `{$this->table}`";
$forms = $this->db->get_results( $sql, 'ARRAY_A' );
$this->running[ 0 ][ 'forms' ] = $forms;
// Record the total number of steps in this batch.
$this->running[ 0 ][ 'steps' ] = count( $forms );
// Record our current step (defaulted to 0 here).
$this->running[ 0 ][ 'current' ] = 0;
* Function to cleanup any lingering temporary elements of a required update after completion.
public function cleanup()
// Remove the current process from the array.
array_shift( $this->running );
// Record to our updates setting that this update is complete.
$this->confirm_complete();
// If we have no updates left to process...
if ( empty( $this->running ) ) {
// Call the parent cleanup method.
private function end_of_step()
// Update the upgrades table, passing in 1 for the current stage.
$cache = WPN_Helper::get_nf_cache( $this->form[ 'ID' ] );
WPN_Helper::update_nf_cache( $this->form[ 'ID' ], $cache, 1 );
// Increment our step count.
$this->running[ 0 ][ 'current' ] = intval( $this->running[ 0 ][ 'current' ] ) + 1;
// Prepare to output our number of steps and current step.
$this->response[ 'stepsTotal' ] = $this->running[ 0 ][ 'steps' ];
$this->response[ 'currentStep' ] = $this->running[ 0 ][ 'current' ];
// If all steps have been completed...
if ( empty( $this->running[ 0 ][ 'forms' ] ) ) {
// Run our cleanup method.
// Record our current location in the process.
update_option( 'ninja_forms_doing_required_updates', $this->running );
// Prepare to output the number of updates remaining.
$this->response[ 'updatesRemaining' ] = count( $this->running );
* Update our form table for the current form.
* We have new table columns, so we want to make sure that those are populated properly.
* Also checks meta values against our $this->blacklist.
* @return [type] [description]
private function update_form()
// Get the settings for that form.
$settings = Ninja_Forms()->form( $this->form[ 'ID' ] )->get()->get_settings();
// Get our seq_number from meta.
$sql = "SELECT `value` FROM `{$this->meta_table}` WHERE `key` = '_seq_num' AND `parent_id` = " . intval( $this->form[ 'ID' ] );
$result = $this->db->get_results( $sql, 'ARRAY_A' );
if ( ! empty( $result[ 0 ][ 'value' ] ) ) {
// If we got back something, set it to the proper value.
$seq_num = intval( $result[ 0 ][ 'value' ] );
// If logged in is false...
if ( ! $settings[ 'logged_in' ] || 'false' === $settings[ 'logged_in' ] ) {
} // Otherwise... (logged in is true.)
// Save the new columns to the forms table.
$sql = "UPDATE `{$this->table}` SET form_title = '" . $this->prepare( $settings[ 'title' ] ) . "', default_label_pos = '" . $settings[ 'default_label_pos' ] . "', show_title = " . intval( $settings[ 'show_title' ] ) . ", clear_complete = " . intval( $settings[ 'clear_complete' ] ) . ", hide_complete = " . intval( $settings[ 'hide_complete' ] ) . ", logged_in = {$logged_in}, seq_num = {$seq_num} WHERE id = " . intval( $this->form[ 'ID' ] ) . ";";
// Remove the existing meta from the form_meta table.
$sql = "DELETE FROM `{$this->meta_table}` WHERE parent_id = " . intval( $this->form[ 'ID' ] );
// Add _seq_num since it's protected and won't be a setting.
array_push( $insert_items, "( " . intval( $this->form[ 'ID' ] ) . ", '_seq_num', '{$seq_num}', '_seq_num', '{$seq_num}' )" );
// For each form setting...
foreach ( $settings as $key => $setting ) {
// If it's not a restricted setting...
if ( ! in_array( $key, $this->blacklist ) ) {
array_push( $insert_items, "( " . intval( $this->form[ 'ID' ] ) . ", '{$key}', '" . $this->prepare( $setting ) . "', '{$key}', '" . $this->prepare( $setting ) . "' )" );
// Insert the new meta values.
$sql = "INSERT INTO `{$this->meta_table}` ( parent_id, `key`, `value`, meta_key, meta_value ) VALUES " . implode( ', ', $insert_items );