-
Notifications
You must be signed in to change notification settings - Fork 4
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
0 parents
commit 3126507
Showing
14 changed files
with
10,007 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,355 @@ | ||
<?php ! defined('__TYPECHO_ROOT_DIR__') and exit(); | ||
|
||
include_once 'pclzip.lib.php'; | ||
|
||
class TeStore_Action extends Typecho_Widget { | ||
|
||
private $options; | ||
private $server; | ||
private $security; | ||
|
||
//缓存时间(h) | ||
private $cacheTime; | ||
|
||
//使用Curl | ||
private $useCurl; | ||
|
||
private $cacheDir; | ||
|
||
private $pluginRoot; | ||
|
||
private $pluginInfo; | ||
|
||
public function __construct($request, $response, $params = NULL) | ||
{ | ||
parent::__construct($request, $response, $params); | ||
|
||
$this->options = Helper::options(); | ||
$pluginOpts = $this->options->plugin('TeStore'); | ||
$this->source = array_filter(preg_split("/(\r|\n|\r\n)/", strip_tags($pluginOpts->source))); | ||
$this->security = Helper::security(); | ||
$this->cacheTime = $pluginOpts->cache_time; | ||
$this->useCurl = $pluginOpts->curl; | ||
$this->pluginRoot = __TYPECHO_ROOT_DIR__ . __TYPECHO_PLUGIN_DIR__; | ||
$this->cacheDir = $this->pluginRoot . '/TeStore/data/'; | ||
|
||
define('TYPEHO_ADMIN_PATH', __TYPECHO_ROOT_DIR__ . __TYPECHO_ADMIN_DIR__); | ||
} | ||
|
||
/** | ||
* 获取已启用插件名称 | ||
* | ||
* @access private | ||
* @return array | ||
*/ | ||
private function getActivePlugins() | ||
{ | ||
$activatedPlugins = Typecho_Plugin::export(); | ||
return array_keys( $activatedPlugins['activated'] ); | ||
} | ||
|
||
/** | ||
* 获取已安装插件名称 | ||
* | ||
* @access private | ||
* @return array | ||
*/ | ||
private function getLocalPlugins() | ||
{ | ||
$dirs = array(); | ||
$files = scandir($this->pluginRoot); | ||
foreach($files as $file){ | ||
if( is_dir($this->pluginRoot . '/' . $file) && !in_array($file, array('.', '..')) || strpos($file, '.php') ){ | ||
$dirs[] = str_replace('.php', '', $file); | ||
} | ||
} | ||
return $dirs; | ||
} | ||
|
||
/** | ||
* 获取已安装插件信息 | ||
* | ||
* @access private | ||
* @return string | ||
*/ | ||
private function getLocalInfos($name) | ||
{ | ||
$pluginDir = $this->pluginRoot . '/' . $name; | ||
$plugin = is_dir($pluginDir) ? $pluginDir . '/Plugin.php' : $pluginDir . '.php'; | ||
$parseInfo = Typecho_Plugin::parseInfo($plugin); | ||
return array( $parseInfo['author'], $parseInfo['version'] ); | ||
} | ||
|
||
/** | ||
* 获取插件源数据 | ||
* | ||
* @access private | ||
* @param string $name | ||
* @return array | ||
*/ | ||
public function getPluginData($name='') | ||
{ | ||
$json = $this->cacheDir . 'list.json'; | ||
//读取缓存文件 | ||
if( $this->cacheTime && is_file($json) && (time() - filemtime($json)) <= $this->cacheTime * 3600 ){ | ||
$data = file_get_contents($json); | ||
$this->pluginInfo = json_decode($data); | ||
}else{ | ||
$html = ''; | ||
foreach( $this->source as $page ){ | ||
$page = trim($page); | ||
if( $page ){ | ||
$html .= $this->useCurl ? $this->curlGet($page) : @file_get_contents($page); | ||
} | ||
} | ||
//解析表格内容 | ||
if( $html !== '' ){ | ||
$dom = new DOMDocument('1.0', 'UTF-8'); | ||
$html = function_exists('mb_convert_encoding') ? mb_convert_encoding($html, 'HTML-ENTITIES', 'UTF-8') : $html; | ||
@$dom->loadHTML($html); | ||
$tr = $dom->getElementsByTagName("tr"); | ||
$texts = array(); | ||
$urls = array(); | ||
foreach( $tr as $trKey => $text ){ | ||
if( $text->parentNode->tagName=='tbody' ){ | ||
//分割tr文本数据 | ||
foreach( $text->childNodes as $td ){ | ||
$tdVal = trim($td->nodeValue); | ||
if( $tdVal ){ | ||
$texts[$trKey][] = $tdVal; | ||
} | ||
} | ||
$td = $tr->item($trKey)->getElementsByTagName("td"); | ||
//获取td链接数据 | ||
foreach( $td as $tdKey => $val ){ | ||
if( $tdKey!==1 && $tdKey!==2 ) { | ||
$a = $td->item($tdKey)->getElementsByTagName("a"); | ||
$href = $a->item(0) ? $a->item(0)->getAttribute("href") : ''; | ||
//处理多作者链接 | ||
if( $tdKey==3 ){ | ||
$href = ''; | ||
foreach( $a as $key => $val ){ | ||
$href .= ($key==0 ? '' : ', ') . $val->getAttribute('href'); | ||
} | ||
} | ||
$urls[] = $href; | ||
} | ||
} | ||
} | ||
} | ||
$texts = array_values($texts); | ||
$urls = array_chunk($urls , 3); | ||
$datas = array(); | ||
//合并关联键名 | ||
$names = array(); | ||
foreach( $texts as $key => $val ){ | ||
$keys = array('pluginName', 'desc', 'version', 'author', 'source', 'pluginUrl', 'site', 'zipFile'); | ||
$names[] = isset($val[0]) ? $val[0] : $val[1]; //fix for PHP 7.0+ | ||
$datas[] = (object)array_combine($keys, array_merge($val, $urls[$key])); | ||
} | ||
array_multisort($names, SORT_ASC, $datas); | ||
|
||
$this->pluginInfo = $datas; | ||
}else{ | ||
$this->pluginInfo = NULL; | ||
} | ||
|
||
//生成缓存文件 | ||
if($this->cacheTime) { | ||
$pluginInfo = json_encode($this->pluginInfo); | ||
if( ! is_dir($this->cacheDir) ) @mkdir($this->cacheDir); | ||
file_put_contents($this->cacheDir . 'list.json', $pluginInfo); | ||
} | ||
} | ||
|
||
//获取单一插件数据 | ||
if( $name && $this->pluginInfo ) { | ||
foreach ($this->pluginInfo as $plugin) { | ||
if( $plugin->pluginName == $name ) | ||
return $plugin; | ||
} | ||
} | ||
|
||
return $this->pluginInfo; | ||
} | ||
|
||
/** | ||
* 输出插件列表 | ||
* | ||
* @access private | ||
* @return void | ||
*/ | ||
public function market() | ||
{ | ||
$options = $this->options; | ||
$pluginPath = Typecho_Common::url('TeStore', $options->pluginUrl); | ||
$security = $this->security; | ||
$marketUrl = $options->index . __TYPECHO_ADMIN_DIR__ . 'te-store/market'; | ||
|
||
include_once 'views/market.php'; | ||
} | ||
|
||
/** | ||
* 执行安装插件 | ||
* | ||
* @access private | ||
* @return string | ||
*/ | ||
public function install() | ||
{ | ||
$this->security->protect(); | ||
$plugin = $this->request->get('plugin'); | ||
|
||
$ret = array( | ||
'status' => false, | ||
'error' => '' | ||
); | ||
|
||
if($plugin){ | ||
$pluginInfo = $this->getPluginData($plugin); | ||
$activated = $this->getActivePlugins(); | ||
|
||
if( in_array($plugin, $activated) ){ | ||
$ret['error'] = _t('请先禁用该插件'); | ||
}elseif( $pluginInfo ){ | ||
$tempdir = $this->pluginRoot . '/TeStore/.tmp'; | ||
$tempFile = $tempdir. '/' . $plugin . '.zip'; | ||
if( ! is_dir($tempdir) ) @mkdir($tempdir); | ||
$zipFile = $this->useCurl ? $this->curlGet($pluginInfo->zipFile) : @file_get_contents($pluginInfo->zipFile); | ||
if( ! file_put_contents( $tempFile, $zipFile ) ){ | ||
$ret['error'] = _t('下载zip包出错'); | ||
}else{ | ||
$unzip = new PclZip($tempFile); | ||
if( ! $unzip->extract(PCLZIP_OPT_PATH, $tempdir)===0 ){ | ||
$ret['error'] = $unzip->errorInfo(true); | ||
}else{ | ||
@unlink($tempFile); | ||
//遍历解压文件层级 | ||
foreach( new RecursiveIteratorIterator(new RecursiveDirectoryIterator($tempdir)) as $filename ){ | ||
if( ! is_dir($filename) ){ | ||
$scans[] = $filename; | ||
} | ||
} | ||
//以Plugin.php确定目录 | ||
foreach($scans as $scan){ | ||
if( !strcasecmp(basename($scan), 'Plugin.php') ){ | ||
$truedir = dirname($scan); | ||
$parentdir = dirname($truedir); | ||
} | ||
} | ||
if( isset($truedir) ){ | ||
foreach($scans as $scan){ | ||
//按插件名创建目录 | ||
$file_dir = $parentdir==$tempdir ? $tempdir : $parentdir; | ||
$tar = str_replace(( strpos($scan, $truedir)===0 ? $truedir : $file_dir ), $this->pluginRoot. '/' . $plugin, $scan); | ||
$tar_dir = dirname($tar); | ||
if( ! is_dir($tar_dir) ) @mkdir($tar_dir, 0777, true); | ||
if( ! rename($scan, $tar) ){ | ||
$error = error_get_last(); | ||
$ret['error'] = $error['message']; | ||
} | ||
} | ||
$ret['status'] = true; | ||
//处理单文件型插件 | ||
}elseif( count($scans)<=2 ){ | ||
foreach($scans as $scan){ | ||
if( pathinfo($scan, PATHINFO_EXTENSION)=='php' ){ | ||
if( ! rename($scan, $this->pluginRoot. '/' . basename($scan)) ){ | ||
$ret['error'] = _t('移动文件出错'); | ||
}else{ | ||
$ret['status'] = true; | ||
} | ||
} | ||
} | ||
}else{ | ||
$ret['error'] = _t('没有找到插件文件'); | ||
} | ||
@$this->delTree($tempdir, true); | ||
} | ||
} | ||
}else{ | ||
$ret['error'] = _t('没有找到插件信息'); | ||
} | ||
} | ||
|
||
echo json_encode($ret); | ||
} | ||
|
||
/** | ||
* 执行卸载插件 | ||
* | ||
* @access private | ||
* @return string | ||
*/ | ||
public function uninstall() | ||
{ | ||
$this->security->protect(); | ||
$plugin = $this->request->get('plugin'); | ||
$installed = $this->getLocalPlugins(); | ||
$ret = array( | ||
'status' => false, | ||
'error' => '' | ||
); | ||
|
||
if( $plugin && in_array($plugin, $installed) ) { | ||
$activated = $this->getActivePlugins(); | ||
//自动禁用处理 | ||
if( in_array($plugin, $activated) ){ | ||
Helper::removePlugin($plugin); | ||
} | ||
$plugindir = $this->pluginRoot. '/' . $plugin; | ||
if( is_dir($plugindir) ){ | ||
if( ! $this->delTree($this->pluginRoot. '/' . $plugin) ){ | ||
$error = error_get_last(); | ||
$ret['error'] = $error['message']; | ||
}else{ | ||
$ret['status'] = true; | ||
} | ||
}else{ | ||
if( ! unlink($plugindir . '.php') ){ | ||
$ret['error'] = _t('删除插件文件出错'); | ||
}else{ | ||
$ret['status'] = true; | ||
} | ||
} | ||
} | ||
|
||
echo json_encode($ret); | ||
} | ||
|
||
/** | ||
* 清空指定文件夹 | ||
* | ||
* @access private | ||
* @return boolean | ||
*/ | ||
private function delTree($dir, $tmp=false) { | ||
$files = array_diff(scandir($dir), array('.','..')); | ||
foreach ($files as $file) { | ||
is_dir("$dir/$file") ? $this->delTree("$dir/$file") : unlink("$dir/$file"); | ||
} | ||
if($tmp) return; | ||
return rmdir($dir); | ||
} | ||
|
||
/** | ||
* 使用Curl方法下载 | ||
* | ||
* @access private | ||
* @return string | ||
*/ | ||
private function curlGet($url) { | ||
$curl = curl_init(); | ||
curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1); | ||
curl_setopt($curl, CURLOPT_HEADER, 0); | ||
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 1); | ||
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, 2); | ||
curl_setopt($curl, CURLOPT_CAINFO,'usr/plugins/TeStore/cacert.pem'); | ||
curl_setopt($curl, CURLOPT_URL, $url); | ||
$result = curl_exec($curl); | ||
curl_close($curl); | ||
|
||
return $result; | ||
} | ||
|
||
} |
Oops, something went wrong.