uriData) { $this->handleUri(); } return $this->uriData['installerFileName']; } public function getCurrentSite() { if (null == $this->uriData) { $this->handleUri(); } return $this->uriData['currentSite']; } public function getOldPath() { $scan_path = './njt-fastdup-installer/scan_package.json'; $result = null; if (file_exists($scan_path)) { $package_obj = json_decode(file_get_contents($scan_path)); if(isset($package_obj->Archive) && isset($package_obj->Archive->compress_dir)) { $result = $package_obj->Archive->compress_dir; } } return $result; } public function getOldSiteUrl() { $scan_path = './njt-fastdup-installer/scan_package.json'; $result = null; if (file_exists($scan_path)) { $package_obj = json_decode(file_get_contents($scan_path)); $result = $package_obj->site_url; } return $result; } private function handleUri() { $protocol = $this->is_ssl() ? 'https://' : 'http://'; $actual_link = $protocol . $_SERVER['HTTP_HOST'] . $_SERVER['REQUEST_URI']; $installerFileName = basename($_SERVER['REQUEST_URI']); $currentSite = str_replace($installerFileName, "", $actual_link); $this->uriData = array( 'installerFileName' => $installerFileName, 'currentSite' => $currentSite ); } } /** * Unzip class * * @author Anthon Pang */ class Unzip { public $localdir = '.'; public $zipfiles = array(); public function __construct() { // Read directory and pick .zip, .rar and .gz files. if ($dh = opendir($this->localdir)) { while (($file = readdir($dh)) !== false) { if (pathinfo($file, PATHINFO_EXTENSION) === 'zip' || pathinfo($file, PATHINFO_EXTENSION) === 'gz' || pathinfo($file, PATHINFO_EXTENSION) === 'rar' ) { $this->zipfiles[] = $file; } } closedir($dh); // if (!empty($this->zipfiles)) { // $GLOBALS['status'] = array('info' => '.zip or .gz or .rar files found, ready for extraction'); // } else { // $GLOBALS['status'] = array('info' => 'No .zip or .gz or rar files found. So only zipping functionality available.'); // } } } /** * @var array */ static $statusStrings = array( \ZipArchive::ER_OK => 'No error', \ZipArchive::ER_MULTIDISK => 'Multi-disk zip archives not supported', \ZipArchive::ER_RENAME => 'Renaming temporary file failed', \ZipArchive::ER_CLOSE => 'Closing zip archive failed', \ZipArchive::ER_SEEK => 'Seek error', \ZipArchive::ER_READ => 'Read error', \ZipArchive::ER_WRITE => 'Write error', \ZipArchive::ER_CRC => 'CRC error', \ZipArchive::ER_ZIPCLOSED => 'Containing zip archive was closed', \ZipArchive::ER_NOENT => 'No such file', \ZipArchive::ER_EXISTS => 'File already exists', \ZipArchive::ER_OPEN => 'Can\'t open file', \ZipArchive::ER_TMPOPEN => 'Failure to create temporary file', \ZipArchive::ER_ZLIB => 'Zlib error', \ZipArchive::ER_MEMORY => 'Malloc failure', \ZipArchive::ER_CHANGED => 'Entry has been changed', \ZipArchive::ER_COMPNOTSUPP => 'Compression method not supported', \ZipArchive::ER_EOF => 'Premature EOF', \ZipArchive::ER_INVAL => 'Invalid argument', \ZipArchive::ER_NOZIP => 'Not a zip archive', \ZipArchive::ER_INTERNAL => 'Internal error', \ZipArchive::ER_INCONS => 'Zip archive inconsistent', \ZipArchive::ER_REMOVE => 'Can\'t remove file', \ZipArchive::ER_DELETED => 'Entry has been deleted', ); /** * Make sure target path ends in '/' * * @param string $path * * @return string */ private function fixPath($path) { if (substr($path, -1) === '/') { $path .= '/'; } return $path; } /** * Open .zip archive * * @param string $zipFile * * @return \ZipArchive */ private function openZipFile($zipFile) { $zipArchive = new \ZipArchive; if ($zipArchive->open($zipFile) !== true) { throw new \Exception('Error opening ' . $zipFile); } return $zipArchive; } /** * Extract list of filenames from .zip * * @param \ZipArchive $zipArchive * * @return array */ private function extractFilenames(\ZipArchive $zipArchive) { $filenames = array(); $fileCount = $zipArchive->numFiles; for ($i = 0; $i < $fileCount; $i++) { if (($filename = $this->extractFilename($zipArchive, $i)) !== false) { $filenames[] = $filename; } } return $filenames; } /** * Test for valid filename path * * The .zip file is untrusted input. We check for absolute path (i.e., leading slash), * possible directory traversal attack (i.e., '..'), and use of PHP wrappers (i.e., ':'). * * @param string $path * * @return boolean */ private function isValidPath($path) { $pathParts = explode('/', $path); if (!strncmp($path, '/', 1) || array_search('..', $pathParts) !== false || strpos($path, ':') !== false) { return false; } return true; } /** * Extract filename from .zip * * @param \ZipArchive $zipArchive Zip file * @param integer $fileIndex File index * * @return string */ private function extractFilename(\ZipArchive $zipArchive, $fileIndex) { $entry = $zipArchive->statIndex($fileIndex); // convert Windows directory separator to Unix style $filename = str_replace('\\', '/', $entry['name']); if ($this->isValidPath($filename)) { return $filename; } throw new \Exception('Invalid filename path in zip archive: ' . $filename); } /** * Get error * * @param integer $status ZipArchive status * * @return string */ private function getError($status) { $statusString = isset($this->statusStrings[$status]) ? $this->statusStrings[$status] : 'Unknown status'; return $statusString . '(' . $status . ')'; } /** * Extract zip file to target path * * @param string $zipFile Path of .zip file * @param string $targetPath Extract to this target (destination) path * * @return mixed Array of filenames corresponding to the extracted files * * @throw \Exception */ public function extract($zipFile) { $zipArchive = $this->openZipFile($zipFile); $targetPath = $this->fixPath(__DIR__); $filenames = $this->extractFilenames($zipArchive); if ($zipArchive->extractTo($targetPath, $filenames) === false) { throw new \Exception($this->getError($zipArchive->status)); } $zipArchive->close(); return $filenames; } } /* * ClassName: PHP MySQL Importer v2.0.1 * PHP class for importing big SQL files into a MySql server. * Author: David Castillo - davcs86@gmail.com * Hire me on: https://www.freelancer.com/u/DrAKkareS.html * Blog: http://blog.d-castillo.info/ */ class MySQLImporter { public $hadErrors = false; public $errors = array(); // private $conn = null; public $conn = null; public function __construct($host, $user, $pass, $port = false) { if ($port == false) { $port = ini_get("mysqli.default_port"); } $port = (int) $port; $port = $port > 0 ? $port : 3306; $this->hadErrors = false; $this->errors = array(); try { // $this->conn = new mysqli($host, $user, $pass, "", $port); @$connection = new mysqli($host, $user, $pass, "", $port); $this->conn = $connection; // Fix bug max_allowed_packet if ($this->conn->connect_error) { $this->addError("Connect Error (" . $this->conn->connect_errno . ") " . $this->conn->connect_error); return; } } catch (\Throwable $e) { http_response_code(500); $this->addError("Database connection failed: " . $e->getMessage()); die(json_encode(array( 'status' => 'error', 'message' => 'Database connection failed', 'message_detail' => $e->getMessage() ))); } try { $this->conn->query('SET GLOBAL max_allowed_packet = ' . 500 * 1024 * 1024); } catch (Exception $e) { // $this->addError("Error when run: SET GLOBAL max_allowed_packet"); } } private function addError($errorStr) { $this->hadErrors = true; $this->errors[] = $errorStr; } public function changeDatabaseUrl($old_domain, $new_domain) { $scan_path = './njt-fastdup-installer/scan_package.json'; if (file_exists($scan_path)) { $package_obj = json_decode(file_get_contents($scan_path)); $db_prefix = isset($package_obj->Database->prefix) ? $package_obj->Database->prefix : 'wp_'; } if (!isset($db_prefix)) { $db_prefix = "wp_"; } $old_domain = rtrim($old_domain, '/'); $new_domain = rtrim($new_domain, '/'); $query = "UPDATE {$db_prefix}options SET option_value = replace(option_value, '$old_domain', '$new_domain' ) WHERE option_name = 'home' OR option_name = 'siteurl'; \n UPDATE {$db_prefix}options SET option_value = '' WHERE option_name = 'njt_fastdup_package_id_active'; \n UPDATE {$db_prefix}posts SET guid = replace(guid, '$old_domain', '$new_domain' ); \n UPDATE {$db_prefix}posts SET post_content = replace(post_content, '$old_domain' , '$new_domain' ); \n"; /* UPDATE {$db_prefix}postmeta SET meta_value = replace(meta_value, '$old_domain' , '$new_domain' ) WHERE meta_value LIKE '%$old_domain%' AND meta_value NOT REGEXP '^[ao]:[0-9].*}$'; \n UPDATE {$db_prefix}usermeta SET meta_value = replace(meta_value, '$old_domain', '$new_domain' ) WHERE meta_value LIKE '%$old_domain%' AND meta_value NOT REGEXP '^[ao]:[0-9].*}$'; \n */ $query .= "UPDATE {$db_prefix}postmeta SET meta_value = replace(meta_value, '$old_domain' , '$new_domain' ) WHERE meta_value LIKE '%$old_domain%' AND (meta_value NOT LIKE 'a%}' AND meta_value NOT LIKE 'o%}');\n"; $query .= "UPDATE {$db_prefix}usermeta SET meta_value = replace(meta_value, '$old_domain', '$new_domain' ) WHERE meta_value LIKE '%$old_domain%' AND (meta_value NOT LIKE 'a%}' AND meta_value NOT LIKE 'o%}'); \n"; $query .= "UPDATE {$db_prefix}links SET link_url = replace(link_url, '$old_domain', '$new_domain' ); \n UPDATE {$db_prefix}links SET link_image = replace(link_image, '$old_domain', '$new_domain' ); \n"; $query .= "DELETE FROM {$db_prefix}njt_fastdup_packages; \n"; // $query .= "DELETE FROM {$db_prefix}njt_fastdup_entities; "; return $query; } /** * Replace URLs in serialized data (like widget_block, theme options, etc.) * Must be called AFTER doImport() has completed * * @param string $old_domain Old site URL * @param string $new_domain New site URL * @param string $database Database name * @return array Results of the operation */ public function replaceSerializedUrls($old_domain, $new_domain, $database) { $results = array('updated' => 0, 'errors' => array()); if ($this->hadErrors || !$this->conn) { $results['errors'][] = 'Database connection not available'; return $results; } // Select the database if (!$this->conn->select_db($database)) { $results['errors'][] = 'Cannot select database: ' . $this->conn->error; return $results; } // Get db prefix $scan_path = './njt-fastdup-installer/scan_package.json'; $db_prefix = 'wp_'; if (file_exists($scan_path)) { $package_obj = json_decode(file_get_contents($scan_path)); $db_prefix = isset($package_obj->Database->prefix) ? $package_obj->Database->prefix : 'wp_'; } $old_domain = rtrim($old_domain, '/'); $new_domain = rtrim($new_domain, '/'); // List of options that contain serialized data and need URL replacement $serialized_options = array( 'widget_block', 'widget_text', 'widget_custom_html', 'sidebars_widgets', 'theme_mods_%', // Theme mods for any theme ); foreach ($serialized_options as $option_pattern) { // Use LIKE for pattern matching (e.g., theme_mods_%) $operator = (strpos($option_pattern, '%') !== false) ? 'LIKE' : '='; $sql = "SELECT option_id, option_name, option_value FROM {$db_prefix}options WHERE option_name {$operator} '" . $this->conn->real_escape_string($option_pattern) . "' AND option_value LIKE '%" . $this->conn->real_escape_string($old_domain) . "%'"; $result = $this->conn->query($sql); if ($result && $result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $original_value = $row['option_value']; $new_value = $this->replaceUrlInSerializedData($original_value, $old_domain, $new_domain); if ($new_value !== $original_value && $new_value !== false) { $update_sql = "UPDATE {$db_prefix}options SET option_value = '" . $this->conn->real_escape_string($new_value) . "' WHERE option_id = " . intval($row['option_id']); if ($this->conn->query($update_sql)) { $results['updated']++; } else { $results['errors'][] = "Failed to update {$row['option_name']}: " . $this->conn->error; } } } } } return $results; } /** * Replace URL in serialized data with proper string length fixing * * @param string $data Serialized string * @param string $old_url Old URL to replace * @param string $new_url New URL * @return string|false Fixed serialized string or false on error */ private function replaceUrlInSerializedData($data, $old_url, $new_url) { // Check if it's serialized data if (!$this->isSerialized($data)) { // Not serialized, just do simple replace return str_replace($old_url, $new_url, $data); } // Try to unserialize first $unserialized = @unserialize($data); if ($unserialized !== false) { // Successfully unserialized - do recursive replace and reserialize $replaced = $this->recursiveReplace($unserialized, $old_url, $new_url); return serialize($replaced); } // Cannot unserialize - use regex-based string length fixing // This handles broken serialized data return $this->fixSerializedString($data, $old_url, $new_url); } /** * Recursively replace URLs in arrays/objects */ private function recursiveReplace($data, $old_url, $new_url) { if (is_string($data)) { return str_replace($old_url, $new_url, $data); } if (is_array($data)) { foreach ($data as $key => $value) { $data[$key] = $this->recursiveReplace($value, $old_url, $new_url); } return $data; } if (is_object($data)) { foreach (get_object_vars($data) as $key => $value) { $data->$key = $this->recursiveReplace($value, $old_url, $new_url); } return $data; } return $data; } /** * Fix serialized string lengths after replacement * Used when unserialize fails */ private function fixSerializedString($data, $old_url, $new_url) { // First do the replacement $data = str_replace($old_url, $new_url, $data); // Now fix the string lengths using regex // Pattern matches: s:LENGTH:"STRING"; $pattern = '/s:(\d+):"(.*?)";/s'; $fixed = preg_replace_callback($pattern, function ($matches) { $string = $matches[2]; $actual_length = strlen($string); return 's:' . $actual_length . ':"' . $string . '";'; }, $data); return $fixed !== null ? $fixed : $data; } /** * Check if a string is serialized */ private function isSerialized($data) { if (!is_string($data)) { return false; } $data = trim($data); if ('N;' === $data) { return true; } if (strlen($data) < 4) { return false; } if (':' !== $data[1]) { return false; } $lastc = substr($data, -1); if (';' !== $lastc && '}' !== $lastc) { return false; } $token = $data[0]; switch ($token) { case 's': if ('"' !== substr($data, -2, 1)) { return false; } // Fall through case 'a': case 'O': case 'C': return (bool) preg_match("/^{$token}:[0-9]+:/s", $data); case 'b': case 'i': case 'd': return (bool) preg_match("/^{$token}:[0-9.E+-]+;$/", $data); } return false; } public function getOldSiteUrl() { $scan_path = './njt-fastdup-installer/scan_package.json'; $result = null; if (file_exists($scan_path)) { $package_obj = json_decode(file_get_contents($scan_path)); $result = $package_obj->site_url; } return $result; } public function doImport($sqlFile, $database = "", $createDB = false, $dropDB = false) { if ($this->hadErrors == false) { //Drop database if it's required if ($dropDB && $database != "") { if (!$this->conn->query("DROP DATABASE IF EXISTS `$database`")) { $this->addError("Query error (" . $this->conn->errno . ") " . $this->conn->error); } } //Create the database if it's required if ($createDB && $database != "") { if (!$this->conn->query("CREATE DATABASE IF NOT EXISTS `$database`")) { $this->addError("Query error (" . $this->conn->errno . ") " . $this->conn->error); } } //Select the database if it's required if ($database != "") { if (!$this->conn->select_db($database)) { $this->addError("Query error (" . $this->conn->errno . ") " . $this->conn->error); } } // Change database url $old_site = $this->getOldSiteUrl(); $new_site = Helper::get_instance()->getCurrentSite(); if ($old_site && $new_site) { $query_change_db_url = $this->changeDatabaseUrl($old_site, $new_site); } @ini_set('memory_limit', '-1'); if (is_file($sqlFile) && is_readable($sqlFile)) { try { $f = fopen($sqlFile, "r"); $sqlFile = fread($f, filesize($sqlFile)); // Change database url if (isset($query_change_db_url)) { $sqlFile .= $query_change_db_url; } // processing and parsing the content $sqlFile = str_replace("\r", "\n", $sqlFile); $lines = preg_split("/\n/", $sqlFile); $queryStr = ""; foreach ($lines as $line) { // Skip it if it's a comment if (substr($line, 0, 2) == '--' || $line == '') { continue; } // Add this line to the current segment $queryStr .= $line; // If it has a semicolon at the end, it's the end of the query if (substr(trim($line), -1, 1) == ';') { if (!$this->conn->query($queryStr)) { $this->addError("Query error (" . $this->conn->errno . ") " . $this->conn->error . "\r\n\r\nOriginal Query:\r\n\r\n" . $queryStr); } // Reset temp variable to empty $queryStr = ''; } } } catch (Exception $error) { $this->addError("File error: (" . $error->getCode() . ") " . $error->getMessage()); } } else { $this->addError("File error: '" . $sqlFile . "' is not a readable file."); } } } } /** * Transforms a wp-config.php file. */ class WPConfigTransformer { /** * Path to the wp-config.php file. * * @var string */ protected $wp_config_path; /** * Original source of the wp-config.php file. * * @var string */ protected $wp_config_src; /** * Array of parsed configs. * * @var array */ protected $wp_configs = array(); /** * Instantiates the class with a valid wp-config.php. * * @throws \Exception If the wp-config.php file is missing. * @throws \Exception If the wp-config.php file is not writable. * * @param string $wp_config_path Path to a wp-config.php file. */ public function __construct($wp_config_path) { $basename = basename($wp_config_path); if (!file_exists($wp_config_path)) { throw new \Exception("{$basename} does not exist."); } if (!is_writable($wp_config_path)) { throw new \Exception("{$basename} is not writable."); } $this->wp_config_path = $wp_config_path; } /** * Checks if a config exists in the wp-config.php file. * * @throws \Exception If the wp-config.php file is empty. * @throws \Exception If the requested config type is invalid. * * @param string $type Config type (constant or variable). * @param string $name Config name. * * @return bool */ public function exists($type, $name) { $wp_config_src = file_get_contents($this->wp_config_path); if (!trim($wp_config_src)) { throw new \Exception('Config file is empty.'); } // Normalize the newline to prevent an issue coming from OSX. $this->wp_config_src = str_replace(array("\n\r", "\r"), "\n", $wp_config_src); $this->wp_configs = $this->parse_wp_config($this->wp_config_src); if (!isset($this->wp_configs[$type])) { throw new \Exception("Config type '{$type}' does not exist."); } return isset($this->wp_configs[$type][$name]); } /** * Get the value of a config in the wp-config.php file. * * @throws \Exception If the wp-config.php file is empty. * @throws \Exception If the requested config type is invalid. * * @param string $type Config type (constant or variable). * @param string $name Config name. * * @return array */ public function get_value($type, $name) { $wp_config_src = file_get_contents($this->wp_config_path); if (!trim($wp_config_src)) { throw new \Exception('Config file is empty.'); } $this->wp_config_src = $wp_config_src; $this->wp_configs = $this->parse_wp_config($this->wp_config_src); if (!isset($this->wp_configs[$type])) { throw new \Exception("Config type '{$type}' does not exist."); } return $this->wp_configs[$type][$name]['value']; } /** * Adds a config to the wp-config.php file. * * @throws \Exception If the config value provided is not a string. * @throws \Exception If the config placement anchor could not be located. * * @param string $type Config type (constant or variable). * @param string $name Config name. * @param string $value Config value. * @param array $options (optional) Array of special behavior options. * * @return bool */ public function add($type, $name, $value, array $options = array()) { if (!is_string($value)) { throw new \Exception('Config value must be a string.'); } if ($this->exists($type, $name)) { return false; } $defaults = array( 'raw' => false, // Display value in raw format without quotes. 'anchor' => "/* That's all, stop editing!", // Config placement anchor string. 'separator' => PHP_EOL, // Separator between config definition and anchor string. 'placement' => 'before', // Config placement direction (insert before or after). ); list($raw, $anchor, $separator, $placement) = array_values(array_merge($defaults, $options)); $raw = (bool) $raw; $anchor = (string) $anchor; $separator = (string) $separator; $placement = (string) $placement; if (false === strpos($this->wp_config_src, $anchor)) { $other_anchor_points = array( '/** Absolute path to the WordPress directory', "if ( !defined('ABSPATH') )", '/** Sets up WordPress vars and included files', 'require_once(ABSPATH', ); foreach ($other_anchor_points as $anchor_point) { $anchor_point = (string) $anchor_point; if (false !== strpos($this->wp_config_src, $anchor_point)) { $anchor = $anchor_point; break; } } } if (false === strpos($this->wp_config_src, $anchor)) { throw new \Exception('Unable to locate placement anchor.'); } $new_src = $this->normalize($type, $name, $this->format_value($value, $raw)); $new_src = ('after' === $placement) ? $anchor . $separator . $new_src : $new_src . $separator . $anchor; $contents = str_replace($anchor, $new_src, $this->wp_config_src); return $this->save($contents); } /** * Updates an existing config in the wp-config.php file. * * @throws \Exception If the config value provided is not a string. * * @param string $type Config type (constant or variable). * @param string $name Config name. * @param string $value Config value. * @param array $options (optional) Array of special behavior options. * * @return bool */ public function update($type, $name, $value, array $options = array()) { if (!is_string($value)) { throw new \Exception('Config value must be a string.'); } $defaults = array( 'add' => true, // Add the config if missing. 'raw' => false, // Display value in raw format without quotes. 'normalize' => false, // Normalize config output using WP Coding Standards. ); list($add, $raw, $normalize) = array_values(array_merge($defaults, $options)); $add = (bool) $add; $raw = (bool) $raw; $normalize = (bool) $normalize; if (!$this->exists($type, $name)) { return ($add) ? $this->add($type, $name, $value, $options) : false; } $old_src = $this->wp_configs[$type][$name]['src']; $old_value = $this->wp_configs[$type][$name]['value']; $new_value = $this->format_value($value, $raw); if ($normalize) { $new_src = $this->normalize($type, $name, $new_value); } else { $new_parts = $this->wp_configs[$type][$name]['parts']; $new_parts[1] = str_replace($old_value, $new_value, $new_parts[1]); // Only edit the value part. $new_src = implode('', $new_parts); } $contents = preg_replace( sprintf('/(?<=^|;|<\?php\s|<\?\s)(\s*?)%s/m', preg_quote(trim($old_src), '/')), '$1' . str_replace('$', '\$', trim($new_src)), $this->wp_config_src ); return $this->save($contents); } /** * Removes a config from the wp-config.php file. * * @param string $type Config type (constant or variable). * @param string $name Config name. * * @return bool */ public function remove($type, $name) { if (!$this->exists($type, $name)) { return false; } $pattern = sprintf('/(?<=^|;|<\?php\s|<\?\s)%s\s*(\S|$)/m', preg_quote($this->wp_configs[$type][$name]['src'], '/')); $contents = preg_replace($pattern, '$1', $this->wp_config_src); return $this->save($contents); } /** * Applies formatting to a config value. * * @throws \Exception When a raw value is requested for an empty string. * * @param string $value Config value. * @param bool $raw Display value in raw format without quotes. * * @return mixed */ protected function format_value($value, $raw) { if ($raw && '' === trim($value)) { throw new \Exception('Raw value for empty string not supported.'); } return ($raw) ? $value : var_export($value, true); } /** * Normalizes the source output for a name/value pair. * * @throws \Exception If the requested config type does not support normalization. * * @param string $type Config type (constant or variable). * @param string $name Config name. * @param mixed $value Config value. * * @return string */ protected function normalize($type, $name, $value) { if ('constant' === $type) { $placeholder = "define( '%s', %s );"; } elseif ('variable' === $type) { $placeholder = '$%s = %s;'; } else { throw new \Exception("Unable to normalize config type '{$type}'."); } return sprintf($placeholder, $name, $value); } /** * Parses the source of a wp-config.php file. * * @param string $src Config file source. * * @return array */ protected function parse_wp_config($src) { $configs = array(); $configs['constant'] = array(); $configs['variable'] = array(); // Strip comments. foreach (token_get_all($src) as $token) { if (in_array($token[0], array(T_COMMENT, T_DOC_COMMENT), true)) { $src = str_replace($token[1], '', $src); } } preg_match_all('/(?<=^|;|<\?php\s|<\?\s)(\h*define\s*\(\s*[\'"](\w*?)[\'"]\s*)(,\s*(\'\'|""|\'.*?[^\\\\]\'|".*?[^\\\\]"|.*?)\s*)((?:,\s*(?:true|false)\s*)?\)\s*;)/ims', $src, $constants); preg_match_all('/(?<=^|;|<\?php\s|<\?\s)(\h*\$(\w+)\s*=)(\s*(\'\'|""|\'.*?[^\\\\]\'|".*?[^\\\\]"|.*?)\s*;)/ims', $src, $variables); if (!empty($constants[0]) && !empty($constants[1]) && !empty($constants[2]) && !empty($constants[3]) && !empty($constants[4]) && !empty($constants[5])) { foreach ($constants[2] as $index => $name) { $configs['constant'][$name] = array( 'src' => $constants[0][$index], 'value' => $constants[4][$index], 'parts' => array( $constants[1][$index], $constants[3][$index], $constants[5][$index], ), ); } } if (!empty($variables[0]) && !empty($variables[1]) && !empty($variables[2]) && !empty($variables[3]) && !empty($variables[4])) { // Remove duplicate(s), last definition wins. $variables[2] = array_reverse(array_unique(array_reverse($variables[2], true)), true); foreach ($variables[2] as $index => $name) { $configs['variable'][$name] = array( 'src' => $variables[0][$index], 'value' => $variables[4][$index], 'parts' => array( $variables[1][$index], $variables[3][$index], ), ); } } return $configs; } /** * Saves new contents to the wp-config.php file. * * @throws \Exception If the config file content provided is empty. * @throws \Exception If there is a failure when saving the wp-config.php file. * * @param string $contents New config contents. * * @return bool */ protected function save($contents) { if (!trim($contents)) { throw new \Exception('Cannot save the config file with empty contents.'); } if ($contents === $this->wp_config_src) { return false; } $result = file_put_contents($this->wp_config_path, $contents, LOCK_EX); if (false === $result) { throw new \Exception('Failed to update the config file.'); } return true; } public function normalize_path( $path ) { $path = str_replace( '\\', '/', $path ); $path = preg_replace( '|(?<=.)/+|', '/', $path ); if ( ':' === substr( $path, 1, 1 ) ) { $path = ucfirst( $path ); } return $path; } } class Installer_Package { public $unzipper; public function __construct() { $this->unzipper = new Unzip; } public function deleteDir($dirPath) { if (substr($dirPath, strlen($dirPath) - 1, 1) != '/') { $dirPath .= '/'; } $files = glob($dirPath . '*', GLOB_MARK); foreach ($files as $file) { if (is_dir($file)) { $this->deleteDir($file); } else { if (is_writable($file)) { unlink($file); } else { if (!file_exists($file)) { throw new \Exception("$file not found!"); } else { throw new \Exception("$file must have permission read & write!"); } } } } rmdir($dirPath); } public function cleanUnzipDir() { $installer_folder = dirname(__FILE__) . '/njt-fastdup-installer'; // Delete Folder Installer if (is_dir($installer_folder)) { if (is_readable($installer_folder)) { $this->deleteDir($installer_folder); } else { throw new \Exception("$installer_folder must have permission read"); } } } public function cleanInstallFile() { try { $status = true; $message_detail = ""; $message_exception = ""; // Delete File Zip if (isset($_COOKIE['njt-fastdup-zip-name'])) { $raw_name = $_COOKIE['njt-fastdup-zip-name']; $is_plain_filename = (basename($raw_name) === $raw_name) && (strpos($raw_name, '/') === false) && (strpos($raw_name, '\\') === false) && (strpos($raw_name, "\0") === false); $is_zip = (strtolower(pathinfo($raw_name, PATHINFO_EXTENSION)) === 'zip'); if ($is_plain_filename && $is_zip) { $installer_dir = realpath(dirname(__FILE__)); $installer_file_zip = $installer_dir . DIRECTORY_SEPARATOR . $raw_name; if (strpos($installer_file_zip, $installer_dir . DIRECTORY_SEPARATOR) === 0 && file_exists($installer_file_zip) ) { if (is_readable($installer_file_zip)) { unlink($installer_file_zip); } else { $status = false; throw new \Exception("$installer_file_zip must have permission read"); } } } } $installer_file_path = dirname(__FILE__) . '/' . Helper::get_instance()->getInstallerFileName(); if (is_file($installer_file_path)) { unlink($installer_file_path); } } catch (\Exception $e) { $message_exception = $e->getMessage(); $status = false; } $dataResp = array( 'status' => $status ? 'success' : 'error', 'message' => !$status ? 'Clean Installer File Unsuccessfully.' : "Clean Installer File Successfully", 'message_detail' => $message_detail . ' ' . $message_exception, ); echo json_encode($dataResp);die; } public function updateConfig($db_host, $db_user, $db_name, $db_pass) { $status = true; $wpconfig_install_path = './njt-fastdup-installer/wp-config.origin'; $wpconfig_path = './wp-config.php'; if (file_exists($wpconfig_install_path)) { $wpconfig_install_content = file_get_contents($wpconfig_install_path); if (!file_exists($wpconfig_path)) { $created = file_put_contents($wpconfig_path, $wpconfig_install_content); } else { $created = true; } if (!$created) { $status = false; throw new \Exception("Create wp-config.php fail!"); } $transformer = new WPConfigTransformer($wpconfig_path); $current_site = Helper::get_instance()->getCurrentSite(); $constantsData = array( "DB_HOST" => $db_host, "DB_NAME" => $db_name, "DB_USER" => $db_user, "DB_PASSWORD" => $db_pass, 'WP_HOME' => $current_site, 'WP_SITEURL' => $current_site, ); $required_constants = array('DB_NAME', 'DB_USER', 'DB_PASSWORD', 'DB_HOST'); foreach ($required_constants as $constant) { $data = $constantsData[$constant] ? $constantsData[$constant] : ""; if ($transformer->exists('constant', $constant)) { $transformer->update('constant', $constant, $data); } else { $transformer->add('constant', $constant, $data); } } $optional_constants = array('WP_HOME', 'WP_SITEURL'); foreach ($optional_constants as $constant) { $data = $constantsData[$constant] ? $constantsData[$constant] : ""; if ($transformer->exists('constant', $constant)) { $transformer->update('constant', $constant, $data); } } if($transformer->exists('constant', 'WP_PLUGIN_DIR')) { $old_value = $transformer->get_value('constant', 'WP_PLUGIN_DIR'); $old_value = substr($old_value, 1, -1); // $old_value = preg_replace('#^.|.$#','',$old_value); $old_value = $transformer->normalize_path($old_value); $new_value = $transformer->normalize_path(dirname(__FILE__)); $new_value = str_replace( Helper::get_instance()->getOldPath(), $new_value, $old_value); $transformer->update('constant', 'WP_PLUGIN_DIR', $new_value); } if($transformer->exists('constant', 'WP_PLUGIN_URL')) { $old_value = $transformer->get_value('constant', 'WP_PLUGIN_URL'); $old_value = substr($old_value, 1, -1); $new_site = rtrim($current_site, '/'); $new_value = str_replace(Helper::get_instance()->getOldSiteUrl(), $new_site, $old_value); $transformer->update('constant', 'WP_PLUGIN_URL', $new_value); } } return $status; } public function importDatabase($db_host, $db_user, $db_name, $db_pass) { if (!file_exists("./njt-fastdup-installer/database.sql")) { return 'njt-fastdup-installer/database.sql Not Found'; } $mysqlImport = new MySQLImporter($db_host, $db_user, $db_pass, false); $mysqlImport->doImport("./njt-fastdup-installer/database.sql", $db_name, true, true); // Handle serialized data replacement $old_site = $mysqlImport->getOldSiteUrl(); $new_site = Helper::get_instance()->getCurrentSite(); if ($old_site && $new_site) { $mysqlImport->replaceSerializedUrls($old_site, $new_site, $db_name); } if ($mysqlImport->hadErrors) { $errors = json_encode($mysqlImport->errors, true); throw new \Exception($errors); return 'Could not import database.'; } else { return true; } } public function updateHtaccess() { $status = true; $htaccess_install_path = './njt-fastdup-installer/htaccess.origin'; $htaccess_path = './.htaccess'; if (file_exists($htaccess_install_path)) { $htaccess_install_content = file_get_contents($htaccess_install_path); $htaccess_origin = file_put_contents('./.htaccess.origin', $htaccess_install_content); } if (file_exists($htaccess_path)) { unlink($htaccess_path); } $new_path = $_SERVER['REQUEST_URI']; $new_path = str_replace(Helper::get_instance()->getInstallerFileName(), "", $new_path); $htaccess_content = "# BEGIN WordPress RewriteEngine On RewriteBase {$new_path} RewriteRule ^index\.php$ - [L] RewriteCond %{REQUEST_FILENAME} !-f RewriteCond %{REQUEST_FILENAME} !-d RewriteRule . {$new_path}index.php [L] # END WordPress"; $status = file_put_contents($htaccess_path, $htaccess_content); return $status; } public function updateRobots() { $status = true; $robots_install_path = './njt-fastdup-installer/robots.origin'; $robots_path = './robots.txt'; if (file_exists($robots_install_path)) { if (file_exists($robots_path)) { unlink($robots_path); } $robots_install_content = file_get_contents($robots_install_path); if (!file_exists($robots_path)) { $robots_path = './.robots.origin'; $status = file_put_contents($robots_path, $robots_install_content); } else { $status = true; } } return $status; } public function php_version_compare() { return version_compare(PHP_VERSION, '5.3.0', '>='); } public function disableExecutionTimeLimit() { if (function_exists('set_time_limit')) { if (set_time_limit(0)) { return true; } } if (function_exists('ini_set')) { if (ini_set('max_execution_time', 0)) { return true; } } return false; } public function system_scan() { global $wp_version; $web_server_value = strtolower(explode('/', $_SERVER['SERVER_SOFTWARE'])[0]); $web_server = array( 'name' => 'Web Server', 'value' => explode('/', $_SERVER['SERVER_SOFTWARE'])[0], 'note' => 'Supported web servers: Nginx, Apache, LiteSpeed, Lighttpd, IIS, uWSGI ,WebServerX', 'status' => in_array($web_server_value, array('apache', 'litespeed', 'nginx', 'lighttpd', 'iis', 'microsoft-iis', 'webserverx', 'uwsgi')), ); $open_basedir = array( 'name' => 'Open BaseDir', 'value' => ini_get("open_basedir") == '' ? 'enabled' : 'unenabled', // 'status' => ini_get("open_basedir") == '' ? true : false, 'status' => true,//always true, because if it's false, it breaks the installation 'warning' => ini_get("open_basedir") == '' ? false : true, 'note' => 'If this [open_basedir] is enabled, it can cause some errors. In that case, please ask your host to disable it in the php.ini file.', ); $php_version = array( 'name' => 'PHP Version', 'value' => phpversion(), 'note' => 'FastDup supports PHP version 5.3.0 or higher.', 'status' => $this->php_version_compare(), ); $this->disableExecutionTimeLimit(); $max_exc_value = ini_get("max_execution_time"); $max_execution_time = array( 'name' => 'Max Execution Time', 'value' => $max_exc_value, 'status' => true, 'warning' => ($max_exc_value == 0 || $max_exc_value >= 30) ? false : true, 'note' => 'If the [max_execution_time] value in the php.ini is too low, errors may occur. It is recommended to set timeout to value of 0.', ); $is_support_zip = class_exists('ZipArchive'); $zip_archive = array( 'name' => 'ZipArchive', 'value' => $is_support_zip ? 'enabled' : 'unenabled', 'status' => $is_support_zip, 'note' => 'If ziparchive is not enabled, your source might be not extracted successfully.', ); $permission_folder = array( 'name' => 'Permission Folder', 'value' => str_replace('\\', '/', dirname(__FILE__)), 'status' => is_writeable(str_replace('\\', '/', dirname(__FILE__))), 'note' => 'This folder needs write permission.', ); $general_require = array($web_server, $open_basedir, $php_version, $max_execution_time, $zip_archive, $permission_folder); $general_require_status = array_filter($general_require, function ($item) {return $item['status'];}); return array( 'status' => count($general_require_status) == count($general_require) ? true : false, 'data' => $general_require, ); } public function my_folder_delete($path) { if (!empty($path) && is_dir($path)) { $dir = new RecursiveDirectoryIterator($path, RecursiveDirectoryIterator::SKIP_DOTS); $files = new RecursiveIteratorIterator($dir, RecursiveIteratorIterator::CHILD_FIRST); foreach ($files as $f) {if (is_file($f)) {unlink($f);} else { $empty_dirs[] = $f;}}if (!empty($empty_dirs)) {foreach ($empty_dirs as $eachDir) {rmdir($eachDir);}}rmdir($path); } } public function install($db_host, $db_user, $db_name, $db_pass, $zip_file_name) { $status = true; $message_exception = ''; $message_detail = ''; try { $testDatabaseResult = $this->getTestDatabaseResult($db_host, $db_user, $db_name, $db_pass); if (!$testDatabaseResult['status']) { $status = false; $message_detail = $testDatabaseResult['message']; } // CHECK IF AN ARCHIVE WAS SELECTED FOR UNZIPPING. if ($status && $zip_file_name != '') { setcookie("njt-fastdup-zip-name", $zip_file_name, time() + (86400 * 30), "/"); // 86400 = 1 day } if ($status) { $zip_file_path = dirname(__FILE__) . '/' . $zip_file_name; $zip_file_path = str_replace('\\', '/', $zip_file_path); $file_extract = $this->unzipper->extract($zip_file_path); if (!$file_extract) { $status = false; $message_detail = 'Extract Zip Unsuccessfully!'; } } $package_obj = null; if ($status) { $scan_path = './njt-fastdup-installer/scan_package.json'; if (file_exists($scan_path)) { $package_obj = json_decode(file_get_contents($scan_path)); } } if ($status && null != $package_obj && isset($package_obj->njt_fastdup_dir_plugin)) { //Delete really-simple-ssl $ssl_plugin_path = './' . $package_obj->njt_fastdup_dir_plugin . '/really-simple-ssl'; $whitelist = ['127.0.0.1', '::1']; if (file_exists($ssl_plugin_path)) { if (in_array($_SERVER['REMOTE_ADDR'], $whitelist)) { $this->my_folder_delete($ssl_plugin_path); } } } if ($status && null != $package_obj && isset($package_obj->njt_fastdup_archive_name)) { // Delete folder plugin fastdup $fastdup_dir = './' . $package_obj->njt_fastdup_archive_name ; if (file_exists($fastdup_dir)) { $this->my_folder_delete($fastdup_dir); } } // Update wp-config.php if ($status) { $is_config = $this->updateConfig($db_host, $db_user, $db_name, $db_pass); if (!$is_config) { $status = false; $message_detail = 'Update wp-config.php Unsuccessfully!'; } } // Update .htaccess if ($status) { $is_htaccess = $this->updateHtaccess(); if (!$is_htaccess) { $status = false; $message_detail = 'Update .htaccess Unsuccessfully! '; } } // Update Robots.txt if ($status) { $is_robots = $this->updateRobots(); if (!$is_robots) { $status = false; $message_detail = 'Update robots.txt Unsuccessfully! '; } } // IMPORT DATABASE if ($status) { $imported = $this->importDatabase($db_host, $db_user, $db_name, $db_pass); if ($imported !== true) { $status = false; $message_detail = $imported; } } if ($status) { $this->cleanUnzipDir(); } } catch (\Exception $e) { $message_exception = $e->getMessage(); $status = false; } $dataResp = array( 'status' => $status ? 'success' : 'error', 'message' => $status ? 'Installation Successfully!' : 'Installation Unsuccessfully!', 'message_detail' => $message_detail . ' ' . $message_exception, ); echo json_encode($dataResp);die; } public function getTestDatabaseResult($db_host, $db_user, $db_name, $db_pass) { $mysqlImport = new MySQLImporter($db_host, $db_user, $db_pass, false); if ($mysqlImport->hadErrors) { return array( 'status' => false, 'message' => 'Test Database Unsuccessfully! Database User Or Password Incorrect', //'isDatabaseNameExist' => false, ); } $isDatabaseNameExist = $mysqlImport->conn->select_db($db_name); if (!$isDatabaseNameExist) { return array( 'status' => false, 'message' => 'Test Database Unsuccessfully! Database Name Incorrect', // 'isDatabaseNameExist' => $isDatabaseNameExist, ); } return array( 'status' => true, 'message' => 'Test Database Successfully!', // 'isDatabaseNameExist' => $isDatabaseNameExist, ); } public function testDatabase($db_host, $db_user, $db_name, $db_pass) { $dataResp = $this->getTestDatabaseResult($db_host, $db_user, $db_name, $db_pass); echo json_encode($dataResp);die; } } //Install Object Init $install_package = new Installer_Package(); $system_scan = $install_package->system_scan(); $dataForm = file_get_contents('php://input'); $dataForm = json_decode($dataForm, true); //Clean Installer File if (isset($dataForm) && isset($dataForm['type'])) { if ($dataForm['type'] == 'clean_install_file') { $install_package->cleanInstallFile(); } if ($dataForm['type'] == 'test_database') { $install_package->testDatabase($dataForm['db_host'], $dataForm['db_user'], $dataForm['db_name'], $dataForm['db_pass']); } } //Init Source if (isset($dataForm) && count($dataForm) > 0 && !isset($dataForm['type'])) { $zip_file_path = isset($dataForm['zipfile']) ? strip_tags($dataForm['zipfile']) : ''; $install_package->install($dataForm['db_host'], $dataForm['db_user'], $dataForm['db_name'], $dataForm['db_pass'], $zip_file_path); } ?> FastDup Installer
FastDup Installer
1Requirements
2Settings
3Done

General Requirements

Please fill this field!
Warning: We will remove all data from this database (if exists) and import new database!
Please fill this field!
Please fill this field!
    unzipper->zipfiles as $value){ ?>
Please select a package file!

Installation Successful

Note: Click Admin Login button to login and finalize this install.