ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: home / lab2454c / elementalmill.com / wp-content / plugins / go-live-update-urls / src

<?php

namespace Go_Live_Update_Urls;

use Go_Live_Update_Urls\Updaters\Repo;

/**
 * Serialized data handling.
 *
 * @author OnPoint Plugins
 * @since  6.0.0
 */
class Serialized {
	/**
	 * New URL
	 *
	 * @var string
	 */
	protected $new;

/**
	 * Old URL
	 *
	 * @var string
	 */
	protected $old;

/**
	 * Hold replacement count during a table update.
	 * We may replace multiple per table row so we count
	 * the actual str_replace() instead of mysql affected.
	 *
	 * @var int
	 */
	protected $count = 0;

/**
	 * Setting dry run to `true` will prevent any data
	 * from being updated in the database but still run
	 * through the process and return counts of would
	 * have been updated of dry run was `false`.
	 *
	 * @var bool
	 */
	protected $dry_run = false;

/**
	 * Serialized constructor.
	 *
	 * @param string $old - Old URL.
	 * @param string $new - New URL.
	 */
	public function __construct( $old, $new ) {
		$this->new = $new;
		$this->old = $old;
	}

/**
	 * Go through every registered serialized table and update them one by one
	 *
	 * @param array $tables - The tables to update.
	 *
	 * @since 5.2.5 - Only update provided tables.
	 *
	 * @return int[]
	 */
	public function update_all_serialized_tables( array $tables ) {
		$serialized_tables = Database::instance()->get_serialized_tables();

$counts = [];
		foreach ( $serialized_tables as $table => $columns ) {
			if ( ! in_array( $table, $tables, true ) ) {
				continue;
			}
			$counts[ $table ] = array_sum( array_map( function ( $column ) use ( $table ) {
				return $this->update_table( $table, $column );
			}, (array) $columns ) );
		}
		return $counts;
	}

/**
	 * Query all serialized rows from a database table and
	 * update them one by one.
	 *
	 * @param string $table  - Database table.
	 * @param string $column - Database column.
	 *
	 * @return int
	 */
	protected function update_table( $table, $column ) {
		global $wpdb;
		$this->count = 0;
		$column = (string) esc_sql( $column );
		$table = (string) esc_sql( $table );
		$pk = $wpdb->get_results( 'SHOW KEYS FROM `' . $table . "` WHERE Key_name = 'PRIMARY'" );
		if ( empty( $pk[0] ) ) {
			$pk = $wpdb->get_results( 'SHOW KEYS FROM `' . $table . '`' );
			if ( empty( $pk[0] ) ) {
				// Fail.
				return 0;
			}
		}
		$primary_key_column = $pk[0]->Column_name;

// Get all serialized rows.
		$rows = $wpdb->get_results( "SELECT `$primary_key_column`, `{$column}` FROM `{$table}` WHERE `{$column}` LIKE 'a:%' OR `{$column}` LIKE 'O:%'" ); //phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared

foreach ( $rows as $k => $row ) {
			if ( ! $this->has_data_to_update( $row->{$column} ) ) {
				continue;
			}

//phpcs:disable
			$clean = $this->replace_tree( @unserialize( $row->{$column} ) );
			$clean = @serialize( $clean );
			//phpcs:enable

if ( ! $this->dry_run ) {
				//phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
				$wpdb->query( $wpdb->prepare( "UPDATE `{$table}` SET `{$column}`=%s WHERE `{$primary_key_column}` = %s", $clean, $row->{$primary_key_column} ) );
			}
		}

return $this->count;
	}

/**
	 * Replaces all the occurrences of a string in a multi-dimensional array or Object
	 *
	 * @param object|array|string|null $data - Data to change.
	 *
	 * @since 5.2.0
	 *
	 * @return mixed
	 */
	public function replace_tree( $data ) {
		if ( is_string( $data ) ) {
			return $this->replace( $data );
		}

if ( ! is_array( $data ) && ! is_object( $data ) ) {
			return $data;
		}

foreach ( $data as $key => $item ) {
			if ( is_array( $data ) ) {
				$data[ $key ] = $this->replace_tree( $item );
			} else {
				$data->{$key} = $this->replace_tree( $item );
			}
		}

return $data;
	}

/**
	 * Replace occurrences of an old url with a new url
	 * within a string.
	 *
	 * Also replace occurrences of an old url formatted using
	 * all available updaters
	 *
	 * @param string $mysql_value - Original value from the database.
	 *
	 * @return string
	 */
	protected function replace( $mysql_value ) {
		$mysql_value = trim( str_replace( $this->old, $this->new, $mysql_value, $count ) );
		$this->count += $count;
		foreach ( Repo::instance()->get_updaters() as $_updater ) {
			$formatted = $_updater::apply_rule_to_url( $this->old );
			if ( $formatted !== $this->old ) {
				$mysql_value = (string) str_replace( $formatted, $_updater::apply_rule_to_url( $this->new ), $mysql_value, $count );
				$this->count += $count;
			}
		}

return trim( $mysql_value );
	}

/**
	 * Do we have any urls to actually update?
	 * Check first for serialized data,
	 * Then check for occurrences of any urls formatted by an updater
	 *
	 * @param string $mysql_value - Original value from the database.
	 *
	 * @return bool
	 */
	protected function has_data_to_update( $mysql_value ) {
		if ( ! is_serialized( $mysql_value ) ) {
			return false;
		}

if ( false !== strpos( $mysql_value, $this->old ) ) {
			return true;
		}

foreach ( Repo::instance()->get_updaters() as $_updater ) {
			if ( false !== strpos( $mysql_value, $_updater::apply_rule_to_url( $this->old ) ) ) {
				return true;
			}
		}

return false;
	}

/**
	 * Getter for current count.
	 *
	 * @since 6.1.0
	 *
	 * @return int
	 */
	public function get_count() {
		return $this->count;
	}

/**
	 * Set the property to determine if we are
	 * doing a dry run for counts, or actually updating
	 * the database.
	 *
	 * @since 6.1.0
	 *
	 * @param bool $dry_run - Is this a dry run or not.
	 */
	public function set_dry_run( $dry_run ) {
		$this->dry_run = $dry_run;
	}
}

[-] Updates.php [edit]
[-] Serialized.php [edit]
[+] ..
[-] .htaccess [edit]
[-] Core.php [edit]
[-] Database.php [edit]
[-] Admin.php [edit]
[+] Traits
[+] Updaters