distribute-helper/src/PackageClass.php

<?php
namespace DistributeHelper;
error_reporting(E_ALL & ~E_NOTICE);
include "Utility.php";

class PackageClass
{
	private static $config = null;     //全局配置信息
	private static $app = null;       //当前安装包composer.json
	//当所有包都安装完毕后
	public static function postUpdate($vendorDir,$rootPkg,$vendorPkgs)
	{
		//初始化
		if(! self::initialize($vendorDir)){
			self::setProgressFailed('INITIALIZE_FAILED');
			return false;
		}
		
		//分发模式
		if( self::$config['distribute-mode'] == 'install'){
			self::install($vendorDir,$rootPkg,$vendorPkgs);
		}
		else{
			self::upgrade($vendorDir,$rootPkg,$vendorPkgs);
		}
		return true;
	}
	
	private static function install($vendorDir,$rootPkg,$vendorPkgs){
		//依赖库都已下载，默认先给个进度
		self::setProgressStep1(100);
		
		//逐个依赖仓库操作
		self::postUpdateVendorPkgs($vendorDir,$vendorPkgs);
		
		//顶层仓库操作
		self::postUpdateRootPkg($vendorDir,$rootPkg);
		
		//全部操作完毕
		self::setProgressOK(true);
	}
	private static function upgrade($vendorDir,$rootPkg,$vendorPkgs){
		//依赖库都已下载，默认先给个进度
		self::setProgressStep1(100);
				
		//逐个依赖仓库操作
		self::postUpdateVendorPkgs($vendorDir,$vendorPkgs);
		
		//顶层仓库操作
		self::postUpdateRootPkg($vendorDir,$rootPkg);
		
		//全部操作完毕
		self::setProgressOK(true);
	}
	/*
	private static function createModuleIni($vendorDir,$vendorPkgs)
	{
		//[MODULE]节点内容
		$content = '[MODULE]' . PHP_EOL;
		foreach($vendorPkgs as $i=>$pkg){
			if( in_array($pkg->getName(),['a/distribute-helper']) )
				continue;
			$cfgPath = pathJoin($vendorDir,$pkg->getName(),'composer.json');
			$data = json_decode(file_get_contents($cfgPath), true);
			$moduleName = $data["distribute-helper"]["module-name"];
			if(!$moduleName){
				logError('bad format. no module-name node exists.',$cfgPath);
				return false;
			}
			$content .= $moduleName . '=' . $pkg->getName() . ',' . $pkg->getPrettyVersion() . PHP_EOL;
		}
		//[CONFIG]节点内容
		//获取包信息
		$repoDir = dirname($vendorDir);
		$packageInfo = self::getPackageInfo($vendorDir,$repoDir,$pkg);
		$moduleConfig = $packageInfo['helper']['module-config'] ? : array();
		$content = '[CONFIG]' . PHP_EOL;
		foreach($moduleConfig as $i=>$cfg){
			$content .= $cfg['name'] . '=' . $cfg['value'] . PHP_EOL;
		}
		//保存文件
		file_put_contents(MODULEINI_PATH,$content);
		return true;
	}*/
	private static function postUpdateVendorPkgs($vendorDir,$vendorPkgs)
	{
		$count = count($vendorPkgs);
		foreach($vendorPkgs as $i=>$pkg){
			//获取包信息
			$repoDir = pathJoin($vendorDir,$pkg->getName());
			$packageInfo = self::getPackageInfo($vendorDir,$repoDir,$pkg);
			
			//获取当前包的module文件
			self::fetchModuleFiles($packageInfo);
			self::setProgressStep2($count,$i,1);
			
			//获取当前包的common文件
			self::fetchCommonFiles($packageInfo);
			self::setProgressStep2($count,$i,2);

			//拷贝当前包的config文件
			//self::copyConfigFiles($packageInfo);
			self::setProgressStep2($count,$i,3);
		}
	}
	private static function postUpdateRootPkg($vendorDir,$pkg)
	{
		//获取包信息
		$repoDir = dirname($vendorDir);
		$packageInfo = self::getPackageInfo($vendorDir,$repoDir,$pkg);
		
		//注册全局路径
		self::copyCopyFiles($packageInfo);
		
		//注册全局路径
		self::registerPath($packageInfo);
		
		//注册自启动程序
		self::registerAutorun($packageInfo);
	}
	//初始化
	private static function initialize($vendorDir)
	{
		//创建.distribute目录
		$distributeDir = pathJoin(dirname($vendorDir),'.distribute');
		if( !file_exists($distributeDir) ){
			createDirectory($distributeDir);
		}
		
		//设置日志文件路径
		if(! defined('LOG_PATH')){
			$logPath = pathJoin($distributeDir,'log.txt');
			define('LOG_PATH',$logPath);
			if(file_exists($logPath))
				unlink($logPath);
		}
		
		//设置进度文件路径
		if(! defined('PROGRESS_PATH')){
			$progressPath = pathJoin($distributeDir,'progress.txt');
			define('PROGRESS_PATH',$progressPath);
			if(file_exists($progressPath))
				unlink($progressPath);
		}
		
		//创建module目录
		$moduleDir = pathJoin(dirname($vendorDir),'module');
		if( !file_exists($moduleDir) ){
			createDirectory($moduleDir);
		}
		
		//解析安装包信息
		$composerJson = pathJoin(dirname($vendorDir),'composer.json');
		self::$app = json_decode(file_get_contents($composerJson), true);		
		if(! self::$app ){
			logError("failed to decode " . $composerJson);
			return false;
		}
		
		//获取部署配置信息
		$cfgPath = pathJoin($distributeDir,'config.json');
		if(! file_exists($cfgPath) ){
			logInfo(".distribute/config.json file not exists,use default config. ");
			self::$config = defaultConfig();
		}
		else{
			self::$config = loadConfig($cfgPath);
			if(!self::$config){
				logError("Failed to load distribute config",$cfgPath);
				return false;
			}
			logInfo("succeeded to decode config file -- .distribute/config.json");
		}
		return true;
	}
	
	private static function setProgressStep1($percent)
	{
		$progress = 0.1 * $percent;
		file_put_contents(PROGRESS_PATH,strval($progress));
	}
	private static function setProgressStep2($total,$index,$step)
	{
		$index = $index + $step/3.0;
		$progress = 10 + intval(90.0 * $index / $total);
		file_put_contents(PROGRESS_PATH,strval($progress));
	}
	private static function setProgressFailed($msg)
	{
		file_put_contents(PROGRESS_PATH,"FAIL:" . $msg);
	}
	private static function setProgressOK($restart)
	{
		if($restart){
			file_put_contents(PROGRESS_PATH,"OK:NEED_RESTART");
		}
		else{
			file_put_contents(PROGRESS_PATH,"OK:NO_RESTART");
		}
	}
	//获取包相关信息
	private static function getPackageInfo($vendorDir,$repoDir,$pkg)
	{
		$config = self::$config;
		$app = self::$app;
		$repoName = $pkg->getName();
		$module_alias = $app["distribute-root"]["module-alias"];
		
		$cfgPath = pathJoin($repoDir,'composer.json');
		$data = json_decode(file_get_contents($cfgPath), true);
		
		$moduleName = $module_alias[$repoName] ? : $repoName;

		
		//获取安装目录
		$rootDir = dirname($vendorDir);
		$commonDir = pathJoin($rootDir,'common');
		$configDir = pathJoin($rootDir,'config',$moduleName);
		$moduleDir = pathJoin($rootDir,'module',$moduleName);
		
		
		//获取缓存目录
		$cacheDir = pathJoin($config['cache-dir'],str_replace('/','-',$pkg->getName()));
		
		//返回包的相关信息
		return array(
			"repoName" => $repoName,
			"version" => $pkg->getPrettyVersion(),
			"rootDir" => $rootDir,
			"cacheDir" => $cacheDir,
			"toolDir" => $config['tool-dir'],
			"ossHost" => $config['oss-host'],
			"moduleName" => $moduleName,
			"commonDir" => $commonDir,
			"configDir" => $configDir,
			"moduleDir" => $moduleDir,
			"helper" => $data["distribute-helper"],
		);
	}
	
	//下载包module文件
	private static function fetchModuleFiles($packageInfo)
	{
		$toolDir = $packageInfo['toolDir'];
		$cacheDir = $packageInfo['cacheDir'];
		$repoName = $packageInfo['repoName'];
		$version = $packageInfo['version'];
		$moduleDir = $packageInfo['moduleDir'];
		$ossHost = $packageInfo['ossHost'];
		
		$moduleFiles = $packageInfo['helper']['module-files'] ? : array();	
		foreach($moduleFiles as $fileInfo){
			$fileName = $fileInfo['name'];

			//下载文件到缓存区
			$filePath = downloadToDir($toolDir,$ossHost,$repoName,$fileName,$cacheDir);
			if(! $filePath ){
				logError($repoName,"fetch module file failed",$fileName);
				return false;
			}
			logInfo("succeeded to fetch module file --",$repoName,$fileName);

			// 解压文件
			if( isZipFile($fileName) ){
				if(! unzipFile($toolDir,$filePath,$moduleDir)) {
					logError($repoName,"unzip module file failed",$fileName);
					return false;
				}
			}
		}
		return true;
	}
	
	//下载包common文件
	private static function fetchCommonFiles($packageInfo)
	{
		$toolDir = $packageInfo['toolDir'];
		$cacheDir = $packageInfo['cacheDir'];
		$repoName = $packageInfo['repoName'];
		$version  = $packageInfo['version'];
		$commonDir = $packageInfo['commonDir'];
		$ossHost = $packageInfo['ossHost'];
		$commonFiles = $packageInfo['helper']['common-files']? : array();
		foreach($commonFiles as $fileInfo){
			$fileName = $fileInfo['name'];
			$target = $fileInfo['target'];
			//下载文件到缓存区
			$filePath = downloadToDir($toolDir,$ossHost,$repoName,$fileName,$cacheDir);
			if(! $filePath ){
				logError($repoName,"fetch common file failed",$fileName);
				return false;
			}
			logInfo("succeeded to fetch common file --",$repoName,$fileName);

			// 解压文件
			if( isZipFile($fileName) ){
				$targetDir = pathJoin($commonDir,$target);
				if(! unzipFile($toolDir,$filePath,$targetDir)) {
					logError($repoName,"unzip common file failed",$fileName);
					return false;
				}
			}
		}
		return true;
	}
	
	//拷贝config文件
	/*
	private static function copyConfigFiles($packageInfo)
	{
		$cacheDir = $packageInfo['cacheDir'];
		$repoName = $packageInfo['repoName'];
		$version = $packageInfo['version'];
		$configDir = $packageInfo['configDir'];
		$moduleDir = $packageInfo['moduleDir'];
		$configFiles = $packageInfo['helper']['config-files'] ? : array();
		foreach($configFiles as $fileInfo){
			$fileName = $fileInfo['name'];
			$targetName = $fileInfo['target'];
			$filePath = pathJoin($moduleDir,$fileName);
			if(! file_exists($filePath) ){
				logError($repoName,"config file not exists",$filePath);
				return false;
			}
			if(!$fileInfo['override'] && file_exists($targetPath)){
				logInfo($repoName,"skip copy config file",$targetPath);
			}
			$targetPath = pathJoin($configDir,$targetName);
			fileCopy($filePath,$targetPath);
		}
		return true;
	}*/
	
	//拷贝copy-files文件
	private static function copyCopyFiles($packageInfo)
	{
		$cacheDir = $packageInfo['cacheDir'];
		$repoName = $packageInfo['repoName'];
		$version = $packageInfo['version'];
		$rootDir = $packageInfo['rootDir'];
		$copyFiles = $packageInfo['helper']['copy-files'] ? : array();
		foreach($copyFiles as $fileInfo){
			$fileName = $fileInfo['name'];
			$targetName = $fileInfo['target'];
			$filePath = pathJoin($rootDir,$fileName);
			if(! file_exists($filePath) ){
				logError($repoName,"file not exists",$filePath);
				return false;
			}
			if(!$fileInfo['override'] && file_exists($targetPath)){
				logInfo($repoName,"skip copy file",$targetPath);
			}
			$targetPath = pathJoin($rootDir,$targetName);
			logInfo($repoName,"copy file ",$fileName," -> ",$targetName);
			fileCopy($filePath,$targetPath);
		}
		return true;
	}	
	private static function registerPath($packageInfo)
	{
	}
	
	private static function registerAutorun($packageInfo)
	{
	}
}