cs\modules\System\Packages_manipulation

Complexity

Total Complexity

27

Size/Duplication

Total Lines	179
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	4

Test Coverage

Coverage

97.5%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	install_extract()	0	15	3
A	update_php_sql()	0	16	4
B	execute_sql_from_directory()	0	24	4
C	update_extract()	0	45	8
A	generic_extract()	0	18	3
B	get_update_versions()	0	13	5

<?php
/**
 * @package    CleverStyle Framework
 * @subpackage System module
 * @category   modules
 * @author     Nazar Mokrynskyi <nazar@mokrynskyi.com>
 * @copyright  Copyright (c) 2015-2017, Nazar Mokrynskyi
 * @license    MIT License, see license.txt
 */
namespace cs\modules\System;
use
	cs\Config,
	cs\Core,
	cs\DB;

/**
 * Utility functions, necessary during packages manipulation (installation/uninstallation, enabling/disabling)
 */
class Packages_manipulation {
	/**
	 * Generic extraction of files from phar distributive for CleverStyle Framework (components installation)
	 *
	 * @param string $target_directory
	 * @param string $source_phar Will be removed after extraction
	 *
	 * @return bool
	 */
	public static function install_extract ($target_directory, $source_phar) {
		/** @noinspection MkdirRaceConditionInspection */
		if (!mkdir($target_directory, 0770)) {
			return false;
		}
		$tmp_dir   = "phar://$source_phar";
		$fs        = file_get_json("$tmp_dir/fs.json");
		$extracted = static::generic_extract($fs, $tmp_dir, $target_directory);
		if ($extracted) {
			unlink($source_phar);
			file_put_json("$target_directory/fs.json", array_keys($fs));
			return true;
		}
		return false;
	}
	/**
	 * @param array  $fs
	 * @param string $tmp_dir
	 * @param string $target_directory
	 *
	 * @return bool
	 */
	protected static function generic_extract ($fs, $tmp_dir, $target_directory) {
		$extracted = array_filter(
			array_map(
				function ($index, $file) use ($tmp_dir, $target_directory) {
					if (
						!@mkdir(dirname("$target_directory/$file"), 0770, true) &&
						!is_dir(dirname("$target_directory/$file"))
					) {
						return false;
					}
					return copy("$tmp_dir/fs/$index", "$target_directory/$file");
				},
				$fs,
				array_keys($fs)
			)
		);
		return count($extracted) === count($fs);
	}
	/**
	 * Generic extraction of files from phar distributive for CleverStyle Framework (system and components update)
	 *
	 * @param string      $target_directory
	 * @param string      $source_phar             Will be removed after extraction
	 * @param null|string $fs_location_directory   Defaults to `$target_directory`
	 * @param null|string $meta_location_directory Defaults to `$target_directory`
	 *
	 * @return bool
	 */
	public static function update_extract ($target_directory, $source_phar, $fs_location_directory = null, $meta_location_directory = null) {
		$fs_location_directory   = $fs_location_directory ?: $target_directory;
		$meta_location_directory = $meta_location_directory ?: $target_directory;
		/**
		 * Backup some necessary information about current version
		 */
		copy("$fs_location_directory/fs.json", "$fs_location_directory/fs_backup.json");
		copy("$meta_location_directory/meta.json", "$meta_location_directory/meta_backup.json");
		/**
		 * Extracting new versions of files
		 */
		$tmp_dir   = "phar://$source_phar";
		$fs        = file_get_json("$tmp_dir/fs.json");
		$extracted = static::generic_extract($fs, $tmp_dir, $target_directory);
		if (!$extracted) {
			return false;
		}
		unlink($source_phar);
		$fs = array_keys($fs);
		/**
		 * Removing of old unnecessary files and directories
		 */
		foreach (
			array_diff(
				file_get_json("$fs_location_directory/fs_backup.json"),
				$fs
			) as $file
		) {
			$file = "$target_directory/$file";
			if (is_writable($file)) {
				unlink($file);
				// Recursively remove all empty parent directories
				while (!get_files_list($file = dirname($file), false, 'fd')) {
					rmdir($file);
				}
			}
		}
		unset($file, $dir);
		file_put_json("$fs_location_directory/fs.json", $fs);
		clearstatcache(true);
		if (function_exists('opcache_reset')) {
			opcache_reset();
		}
		return true;
	}
	/**
	 * Generic update for CleverStyle Framework (system and components), runs PHP scripts and does DB migrations after extracting of new distributive
	 *
	 * @param string     $target_directory
	 * @param string     $old_version
	 * @param array|null $db_array `$Config->components['modules'][$module]['db']` if module or system
	 *
	 * @throws \cs\ExitException
	 */
	public static function update_php_sql ($target_directory, $old_version, $db_array = null) {
		foreach (self::get_update_versions($target_directory) as $version) {
			if (version_compare($old_version, $version, '<')) {
				/**
				 * PHP update script
				 */
				_include_once("$target_directory/meta/update/$version.php", false);
				/**
				 * Database update
				 */
				if ($db_array) {
					self::execute_sql_from_directory("$target_directory/meta/update_db", $db_array, $version);
				}
			}
		}
	}
	/**
	 * @param string $target_directory
	 *
	 * @return string[]
	 */
	protected static function get_update_versions ($target_directory) {
		$update_versions = _mb_substr(get_files_list("$target_directory/meta/update"), 0, -4) ?: [];
		foreach (get_files_list("$target_directory/meta/update_db", false, 'd') ?: [] as $db) {
			/** @noinspection SlowArrayOperationsInLoopInspection */
			$update_versions = array_merge(
				$update_versions,
				get_files_list("$target_directory/meta/update_db/$db", false, 'd') ?: []
			);
		}
		$update_versions = array_unique($update_versions);
		usort($update_versions, 'version_compare');
		return $update_versions;
	}
	/**
	 * @param string $directory        Base path to SQL files
	 * @param array  $db_configuration Array in form [$db_name => $index]
	 * @param string $version          In case when we are working with update script we might have version subdirectory
	 *
	 * @throws \cs\ExitException
	 */
	public static function execute_sql_from_directory ($directory, $db_configuration, $version = '') {
		$Config = Config::instance();
		$Core   = Core::instance();
		$db     = DB::instance();
		time_limit_pause();
		foreach ($db_configuration as $db_name => $index) {
			$db_driver = $index == 0 ? $Core->db_driver : $Config->db[$index]['driver'];
			$sql_file  = "$directory/$db_name/$version/$db_driver.sql";
			if (file_exists($sql_file)) {
				/** @noinspection ExceptionsAnnotatingAndHandlingInspection */
				$db->db_prime($index)->transaction(
					function ($cdb) use ($sql_file) {
						/**
						 * @var DB\_Abstract $cdb
						 */
						$cdb->q(
							explode(';', file_get_contents($sql_file))
						);
					}
				);
			}
		}
		time_limit_pause(false);
	}
}