HEX

File: /home/xedaptot/be.naniguide.com/app/Http/Controllers/Admin/Upgrade.php
<?php

namespace Acelle\Http\Controllers\Admin;

use Acelle\Http\Controllers\Controller;
use Illuminate\Http\Request;
use Acelle\Model\Language;
use Acelle\Model\Template;
use Acelle\Model\Setting;
use Acelle\Model\Job;
use Acelle\Model\FailedJob;
use Acelle\Model\JobMonitor;
use Acelle\Model\Plugin;
use Artisan;
use Illuminate\Support\Facades\Session;
use Cache;
use Illuminate\Database\Schema\Blueprint;
use Illuminate\Support\Facades\Schema;
use Exception;
use Acelle\Library\UpgradeManager;
use Acelle\Model\Notification;
use Acelle\Helpers\LicenseHelper;

class Upgrade extends Controller
{
    /**
     * Handle the incoming request.
     *
     * @param  \Illuminate\Http\Request  $request
     * @return \Illuminate\Http\Response
     */
    public function finalize(Request $request)
    {
        Artisan::call('route:clear');
        // Artisan::call('cache:clear'); // ==> it will clean up all statistics
        Artisan::call('view:clear');

        // Write settings
        Setting::writeDefaultSettings();

        // Clean up job related
        // Adding --force to avoid the 'Undefined constant "STDIN"' error
        // Artisan::call('queue:clear', [ '--force' => true ]);

        Artisan::call('queue:flush');

        // if (redis_enabled()) {
        //     Artisan::call('queue:clear redis');
        // }

        Artisan::call('queue:prune-failed');

        // JobMonitor::query()->delete();
        // Job::query()->delete();
        FailedJob::query()->delete();

        try {
            Schema::table('jobs', function (Blueprint $table) {
                $table->dropIndex(['queue']);
            });
        } catch (Exception $ex) {
            // Index already dropped
        }

        // @important: do not clear cache, it will clean up all statistics
        // Cache::flush();

        Language::dump();
        Template::resetDefaultTemplates();
        Template::resetPopupTemplates();
        Artisan::call('queue:prune-batches --hours=24 --unfinished=-1'); // clean up any pending job batches
        Artisan::call('queue:restart');

        // Reset GEODB
        if (Setting::get('geoip.sqlite.dbname') != 'storage/app/GeoLite2-City.mmdb') {
            Setting::set('geoip.sqlite.dbname', 'storage/app/GeoLite2-City.mmdb');
            Setting::set('geoip.sqlite.source_url', 'https://acellemail.s3.amazonaws.com/GeoLite2-City.mmdb');
            Setting::set('geoip.sqlite.source_hash', 'b95ecaff82017c4f52577196c41db946');
            Setting::set('geoip.enabled', 'no');
        }

        // New way to load plugins: initialize the plugin index file
        Plugin::resetPluginMasterFile();

        // Merge .env.example to .env
        $manager = new UpgradeManager();
        $manager->mergeEnv(base_path('.env.example'));

        // Clean up all notifications
        Notification::truncate();

        // Refresh license
        LicenseHelper::refreshLicense();

        // Upgrade post-processing
        if ($request->session()->has('upgraded')) {
            $request->session()->forget('upgraded');
            Session::save();

            // Redirect with success message
            $request->session()->flash('alert-success', trans('messages.upgrade.alert.upgrade_success'));
            return redirect()->action('Admin\SettingController@upgrade');
        } else {
            echo '<html>
                <head>
                    <meta http-equiv="refresh" content="3;'.url('/').'" />
                    <title>Finalization</title>
                </head>
                <body>
                    Finalization done! redirecting...
                </body>
            </html>';
        }
    }

    public function migrate(Request $request)
    {
        Artisan::call('migrate', ['--force' => true]);
        sleep(3);
        if ($request->session()->has('upgraded')) {
            $nextPage = url('/admin/upgrade/finalize');
            echo "Finalization in progress...<meta http-equiv=\"refresh\" content=\"5;URL='".$nextPage."'\" />";
        } else {
            echo "Migration done! Redirecting...<meta http-equiv=\"refresh\" content=\"5;URL='".url('/')."'\" />";
        }
    }

    public function dropIndex()
    {
        try {
            Schema::table('jobs', function (Blueprint $table) {
                $table->dropIndex(['queue']);
            });

            return response('Dropped');
        } catch (Exception $ex) {
            return response('Dropped! '.$ex->getMessage());
        }
    }

    public function createIndex()
    {
        try {
            Schema::table('jobs', function (Blueprint $table) {
                $table->index(['queue']);
            });

            return response('Done!');
        } catch (Exception $ex) {
            return response('Done! '.$ex->getMessage());
        }
    }
}