Akaunting/app/Utilities/Versions.php

<?php

namespace App\Utilities;

use App\Models\Module\Module;
use App\Traits\SiteApi;
use App\Traits\Jobs;
use App\Jobs\Install\DisableModule;
use App\Jobs\Install\UninstallModule;
use App\Utilities\Date;
use GrahamCampbell\Markdown\Facades\Markdown;
use Illuminate\Support\Arr;
use Illuminate\Support\Facades\Cache;

class Versions
{
    use SiteApi, Jobs;

    public static function changelog()
    {
        $output = '';

        $url = 'https://api.github.com/repos/akaunting/akaunting/releases';

        $http = new \GuzzleHttp\Client(['verify' => false]);

        $json = $http->get($url, ['timeout' => 30])->getBody()->getContents();

        if (empty($json)) {
            return $output;
        }

        $releases = json_decode($json);

        foreach ($releases as $release) {
            if (version_compare($release->tag_name, version('short'), '<=')) {
                continue;
            }

            if ($release->prerelease == true) {
                continue;
            }

            if (empty($release->body)) {
                continue;
            }

            if (empty($output)) {
                $output .= '<div class="mx-6">';
            } else {
                $output .= '<div class="mx-6 my-6">';
            }

            $output .= '    <div class="mb-4">';
            $output .= '        <h2>';
            $output .= '            <span class="rounded-xl bg-green px-3 py-2 text-base font-medium text-white ring-1 ring-inset ring-green">';
            $output .=                  $release->tag_name;
            $output .= '            </span>';
            $output .= '        </h2>';
            $output .= '    </div>';

            $output .=      Markdown::convertToHtml($release->body);

            $output .= '</div>';

            $output .= '<hr>';
        }

        return $output;
    }

    public static function latest($alias)
    {
        $versions = static::all($alias);

        if (empty($versions[$alias])) {
            return static::getVersionByAlias($alias);
        }

        return $versions[$alias];
    }

    public static function all($modules = null)
    {
        return Cache::remember('versions', Date::now()->addHours(6), function () use ($modules) {
            $info = Info::all();

            $versions = [];

            // Check core first
            try {
                $url = 'core/version/' . $info['akaunting'] . '/' . $info['php'] . '/' . $info['mysql'] . '/' . $info['companies'];
            } catch (\Exception $e) {
                // Handle exception
                report('Error fetching core version: ( $info = ' . json_encode($info) . ')' . $e->getMessage());

                return $versions;
            }

            # Installed modules start
            $modules = Arr::wrap($modules);

            $installed_modules = [];
            $module_version = '?modules=';

            foreach ($modules as $module) {
                if (is_string($module)) {
                    $module = module($module);
                }

                if (! $module instanceof \Akaunting\Module\Module) {
                    continue;
                }

                $alias = $module->get('alias');

                $installed_modules[] = $alias;
            }

            $module_version .= implode(',', $installed_modules);

            $url .= $module_version;
            # Installed modules end

            $versions['core'] = static::getLatestVersion($url, $info['akaunting']);

            // Then modules
            foreach ($modules as $module) {
                if (is_string($module)) {
                    $module = module($module);
                }

                if (! $module instanceof \Akaunting\Module\Module) {
                    continue;
                }

                $alias = $module->get('alias');
                $version = $module->get('version');

                $url = 'apps/' . $alias . '/version/' . $version . '/' . $info['akaunting'];

                $versions[$alias] = static::getLatestVersion($url, $version);
            }

            return $versions;
        });
    }

    public static function getVersionByAlias($alias)
    {
        $info = Info::all();

        // Check core first
        $url = 'core/version/' . $info['akaunting'] . '/' . $info['php'] . '/' . $info['mysql'] . '/' . $info['companies'];
        $version = $info['akaunting'];

        if ($alias != 'core') {
            $version = module($alias) ? module($alias)->get('version') : '1.0.0';

            $url = 'apps/' . $alias . '/version/' . $version . '/' . $info['akaunting'];
        }

        // Get data from cache
        $versions = Cache::get('versions', []);

        $versions[$alias] = static::getLatestVersion($url, $version);

        Cache::put('versions', $versions, Date::now()->addHours(6));

        return $versions[$alias];
    }

    public static function getLatestVersion($url, $latest)
    {
        $version = new \stdClass();

        $version->can_update = true;
        $version->latest = $latest;
        $version->errors = false;
        $version->message = '';
        $version->subscription = null;

        if (! $body = static::getResponseBody('GET', $url, ['timeout' => 10])) {
            return $version;
        }

        if (! is_object($body)) {
            return $version;
        }

        $version->can_update = $body->success;
        $version->latest = $body->data->latest;
        $version->errors = $body->errors;
        $version->message = $body->message;
        $version->subscription = $body->data?->subscription ?? null;

        return $version;
    }

    public static function enforceSubscriptionStatus($alias, $version): void
    {
        if (! $version->subscription) {
            return;
        }

        if ($version->subscription->expired_at > Date::now()->startOfDay()) {
            return;
        }

        $status = 'active';

        switch ($version->subscription->status) {
            case 'expired':
            case 'canceled':
                $status = 'disabled';
                break;
            case 'chargeback':
            case 'not_paid':
            case 'none':
            case 'refund':
                $status = 'uninstalled';
                break;
            default:
                // Do nothing
                break;
        }

        if ($status == 'active') {
            return;
        }

        $module_companies = Module::allCompanies()->alias($alias)->get();

        foreach ($module_companies as $module) {
            switch ($status) {
                case 'disabled':
                    dispatch(new DisableModule($alias, $module->company_id));
                    break;
                case 'uninstalled':
                    dispatch(new UninstallModule($alias, $module->company_id));
                    break;
                default:
                    // Do nothing
                    break;
            }
        }
    }

    public static function getUpdates()
    {
        return Cache::remember('updates', Date::now()->addHours(6), function () {
            $updates = [];

            $modules = module()->all();

            $versions = static::all($modules);

            foreach ($versions as $alias => $latest_version) {
                if ($alias == 'core') {
                    $installed_version = version('short');
                } else {
                    $module = module($alias);

                    if (! $module instanceof \Akaunting\Module\Module) {
                        continue;
                    }

                    $installed_version = $module->get('version');
                }

                if (version_compare($installed_version, $latest_version->latest, '>=')) {
                    continue;
                }

                $updates[$alias] = $latest_version;
            }

            return $updates;
        });
    }

    public static function shouldUpdate($listener_version, $old_version, $new_version): bool
    {
        // Don't update if "listener" is same or lower than "old" version
        if (version_compare($listener_version, $old_version, '<=')) {
            return false;
        }

        // Don't update if "listener" is higher than "new" version
        if (version_compare($listener_version, $new_version, '>')) {
            return false;
        }

        return true;
    }
}