<?php

namespace App\Http\Controllers;

use Exception;
use ZipArchive;
use Illuminate\Support\Arr;
use Illuminate\Http\Request;
use App\Services\PluginManager;
use Composer\Semver\Comparator;

class MarketController extends Controller
{
    /**
     * Guzzle HTTP client.
     *
     * @var \GuzzleHttp\Client
     */
    protected $guzzle;

    /**
     * Default request options for Guzzle HTTP client.
     *
     * @var array
     */
    protected $guzzleConfig;

    /**
     * Cache for plugins registry.
     *
     * @var array
     */
    protected $registryCache;

    public function __construct(\GuzzleHttp\Client $guzzle)
    {
        $this->guzzle = $guzzle;
        $this->guzzleConfig = [
            'headers' => ['User-Agent' => config('secure.user_agent')],
            'verify' => config('secure.certificates'),
        ];
    }

    public function marketData()
    {
        $plugins = collect($this->getAllAvailablePlugins())->map(function ($item) {
            $plugin = plugin($item['name']);
            $manager = app('plugins');

            if ($plugin) {
                $item['enabled'] = $plugin->isEnabled();
                $item['installed'] = $plugin->version;
                $item['update_available'] = Comparator::greaterThan($item['version'], $item['installed']);
            } else {
                $item['installed'] = false;
            }

            $requirements = Arr::get($item, 'require', []);
            unset($item['require']);

            $item['dependencies'] = [
                'isRequirementsSatisfied' => $manager->isRequirementsSatisfied($requirements),
                'requirements' => $requirements,
                'unsatisfiedRequirements' => $manager->getUnsatisfiedRequirements($requirements),
            ];

            return $item;
        });

        return $plugins;
    }

    public function checkUpdates()
    {
        $pluginsHaveUpdate = collect($this->getAllAvailablePlugins())->filter(function ($item) {
            $plugin = plugin($item['name']);

            return $plugin && Comparator::greaterThan($item['version'], $plugin->version);
        });

        return json([
            'available' => $pluginsHaveUpdate->isNotEmpty(),
            'plugins' => $pluginsHaveUpdate->values()->all(),
        ]);
    }

    public function download(Request $request, PluginManager $manager)
    {
        $name = $request->get('name');
        $metadata = $this->getPluginMetadata($name);

        if (! $metadata) {
            return json(trans('admin.plugins.market.non-existent', ['plugin' => $name]), 1);
        }

        // Gather plugin distribution URL
        $url = $metadata['dist']['url'];
        $filename = Arr::last(explode('/', $url));
        $plugins_dir = $manager->getPluginsDir();
        $tmp_path = $plugins_dir.DIRECTORY_SEPARATOR.$filename;

        // Download
        try {
            $this->guzzle->request('GET', $url, array_merge($this->guzzleConfig, [
                'sink' => $tmp_path,
            ]));
        } catch (Exception $e) {
            report($e);

            return json(trans('admin.plugins.market.download-failed', ['error' => $e->getMessage()]), 2);
        }

        // Check file's sha1 hash
        if (sha1_file($tmp_path) !== $metadata['dist']['shasum']) {
            @unlink($tmp_path);

            return json(trans('admin.plugins.market.shasum-failed'), 3);
        }

        // Unzip
        $zip = new ZipArchive();
        $res = $zip->open($tmp_path);

        if ($res === true) {
            if ($zip->extractTo($plugins_dir) === false) {
                return json(trans('admin.plugins.market.unzip-failed', ['error' => 'Unable to extract the file.']), 4);
            }
            $manager->copyPluginAssets(plugin($name));
        } else {
            return json(trans('admin.plugins.market.unzip-failed', ['error' => $res]), 4);
        }
        $zip->close();
        @unlink($tmp_path);

        return json(trans('admin.plugins.market.install-success'), 0);
    }

    protected function getPluginMetadata($name)
    {
        return collect($this->getAllAvailablePlugins())->where('name', $name)->first();
    }

    protected function getAllAvailablePlugins()
    {
        if (app()->environment('testing') || ! $this->registryCache) {
            try {
                $pluginsJson = $this->guzzle->request(
                    'GET', config('plugins.registry'), $this->guzzleConfig
                )->getBody();
            } catch (Exception $e) {
                throw new Exception(trans('admin.plugins.market.connection-error', [
                    'error' => htmlentities($e->getMessage()),
                ]));
            }

            $this->registryCache = json_decode($pluginsJson, true);
        }

        return Arr::get($this->registryCache, 'packages', []);
    }
}