Enterprise WordPress Migration &
Platform Transformation Services

<?php
namespace AssertivLogix\Migration;

/**
 * Enterprise WordPress Database Sanitization & Zero-Downtime Delta Sync Engine
 */
class MigrationHandler {
    private string $sourceUrl;
    private string $targetUrl;
    private \PDO $targetDb;

    public function __construct(string $source, string $target, \PDO $db) {
        $this->sourceUrl = rtrim($source, '/');
        $this->targetUrl = rtrim($target, '/');
        $this->targetDb = $db;
    }

    /**
     * Executes safe serialized search and replace across postmeta & options tables
     */
    public function executeSafeSearchReplace(): array {
        $tables = ['wp_options', 'wp_posts', 'wp_postmeta', 'wp_usermeta'];
        $updatedRows = 0;

        foreach ($tables as $table) {
            $cmd = sprintf(
                'wp search-replace "%s" "%s" --table_prefix=wp_ --tables=%s --precise --skip-columns=guid --all-tables-with-prefix',
                $this->sourceUrl,
                $this->targetUrl,
                $table
            );
            
            // Run WP-CLI command safely without breaking serialized array byte lengths
            $output = shell_exec($cmd);
            $updatedRows += $this->parseCliOutput($output);
        }

        return ['status' => 'success', 'rows_updated' => $updatedRows];
    }

    /**
     * Generates Cloudflare NGINX / Worker-compatible 301 Redirect Rules Matrix
     */
    public function generateRedirectMatrix(array $urlMap): int {
        $stmt = $this->targetDb->prepare(
            "INSERT INTO wp_redirect_matrix (source_path, target_path, status_code) VALUES (:src, :tgt, 301) ON DUPLICATE KEY UPDATE target_path = :tgt"
        );

        $count = 0;
        foreach ($urlMap as $oldPath => $newPath) {
            $stmt->execute([':src' => $oldPath, ':tgt' => $newPath]);
            $count++;
        }
        return $count;
    }
}