blessing-skin-server/app/Http/Controllers/MarketController.php
2020-01-16 12:33:14 +08:00

101 lines
3.2 KiB
PHP

<?php
namespace App\Http\Controllers;
use App\Services\Plugin;
use App\Services\PluginManager;
use App\Services\Unzip;
use Composer\CaBundle\CaBundle;
use Composer\Semver\Comparator;
use Exception;
use GuzzleHttp\Client;
use Illuminate\Http\Request;
use Illuminate\Support\Arr;
use Illuminate\Support\Collection;
class MarketController extends Controller
{
public function marketData(PluginManager $manager, Client $client)
{
$plugins = $this->fetch($client)->map(function ($item) use ($manager) {
$plugin = $manager->get($item['name']);
if ($plugin) {
$item['installed'] = $plugin->version;
$item['can_update'] = Comparator::greaterThan($item['version'], $item['installed']);
} else {
$item['installed'] = false;
}
$requirements = Arr::get($item, 'require', []);
unset($item['require']);
$item['dependencies'] = [
'all' => $requirements,
'unsatisfied' => $manager->getUnsatisfied(new Plugin('', $item)),
];
return $item;
});
return $plugins;
}
public function download(
Request $request,
PluginManager $manager,
Client $client,
Unzip $unzip
) {
$name = $request->input('name');
$plugins = $this->fetch($client);
$metadata = $plugins->firstWhere('name', $name);
if (!$metadata) {
return json(trans('admin.plugins.market.non-existent', ['plugin' => $name]), 1);
}
$fakePlugin = new Plugin('', $metadata);
$unsatisfied = $manager->getUnsatisfied($fakePlugin);
$conflicts = $manager->getConflicts($fakePlugin);
if ($unsatisfied->isNotEmpty() || $conflicts->isNotEmpty()) {
$reason = $manager->formatUnresolved($unsatisfied, $conflicts);
return json(trans('admin.plugins.market.unresolved'), 1, compact('reason'));
}
$path = tempnam(sys_get_temp_dir(), $name);
try {
$client->get($metadata['dist']['url'], [
'sink' => $path,
'verify' => CaBundle::getSystemCaRootBundlePath(),
]);
$unzip->extract($path, $manager->getPluginsDirs()->first());
} catch (Exception $e) {
report($e);
return json(trans('admin.download.errors.download', ['error' => $e->getMessage()]), 1);
}
return json(trans('admin.plugins.market.install-success'), 0);
}
protected function fetch(Client $client): Collection
{
$plugins = collect(explode(',', config('plugins.registry')))
->map(function ($registry) use ($client) {
try {
$body = $client->get(trim($registry), [
'verify' => CaBundle::getSystemCaRootBundlePath(),
])->getBody();
} catch (Exception $e) {
throw new Exception(trans('admin.plugins.market.connection-error', ['error' => $e->getMessage()]));
}
return Arr::get(json_decode($body, true), 'packages', []);
})
->flatten(1);
return $plugins;
}
}