invoiceninja/app/Jobs/Account/CreateAccount.php

<?php
/**
 * Invoice Ninja (https://invoiceninja.com).
 *
 * @link https://github.com/invoiceninja/invoiceninja source repository
 *
 * @copyright Copyright (c) 2021. Invoice Ninja LLC (https://invoiceninja.com)
 *
 * @license https://opensource.org/licenses/AAL
 */

namespace App\Jobs\Account;

use App\DataMapper\Analytics\AccountCreated as AnalyticsAccountCreated;
use App\Events\Account\AccountCreated;
use App\Jobs\Company\CreateCompany;
use App\Jobs\Company\CreateCompanyPaymentTerms;
use App\Jobs\Company\CreateCompanyTaskStatuses;
use App\Jobs\Company\CreateCompanyToken;
use App\Jobs\Mail\NinjaMailer;
use App\Jobs\Mail\NinjaMailerJob;
use App\Jobs\Mail\NinjaMailerObject;
use App\Jobs\User\CreateUser;
use App\Jobs\Util\VersionCheck;
use App\Mail\Admin\AccountCreatedObject;
use App\Mail\Admin\VerifyUserObject;
use App\Models\Account;
use App\Models\Timezone;
use App\Notifications\Ninja\NewAccountCreated;
use App\Utils\Ninja;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Str;
use Symfony\Component\HttpFoundation\Response;
use Turbo124\Beacon\Facades\LightLogs;

class CreateAccount
{
    use Dispatchable;

    protected $request;

    protected $client_ip;

    public function __construct(array $sp660339, $client_ip)
    {
        $this->request = $sp660339;
        $this->client_ip = $client_ip;
    }

    public function handle()
    {
        if (config('ninja.environment') == 'selfhost' && Account::all()->count() == 0) {
            return $this->create();
        } elseif (config('ninja.environment') == 'selfhost' && Account::all()->count() > 1) {
            return response()->json(['message' => Ninja::selfHostedMessage()], 400);
        } elseif (! Ninja::boot()) {
            return response()->json(['message' => Ninja::parse()], 401);
        }

        return $this->create();
    }

    private function create()
    {
        Account::reguard();
        $sp794f3f = new Account();
        $sp794f3f->fill($this->request);

        $sp794f3f->referral_code = Str::random(32);

        if (! $sp794f3f->key) {
            $sp794f3f->key = Str::random(32);
        }

        $sp794f3f->save();

        $sp035a66 = CreateCompany::dispatchNow($this->request, $sp794f3f);
        $sp035a66->load('account');
        $sp035a66->settings = $this->processSettings($sp035a66->settings);
        $sp794f3f->default_company_id = $sp035a66->id;
        $sp794f3f->save();

        $spaa9f78 = CreateUser::dispatchNow($this->request, $sp794f3f, $sp035a66, true);

        CreateCompanyPaymentTerms::dispatchNow($sp035a66, $spaa9f78);
        CreateCompanyTaskStatuses::dispatchNow($sp035a66, $spaa9f78);

        if ($spaa9f78) {
            auth()->login($spaa9f78, false);
        }

        $spaa9f78->setCompany($sp035a66);
        $spafe62e = isset($this->request['token_name']) ? $this->request['token_name'] : request()->server('HTTP_USER_AGENT');
        $sp2d97e8 = CreateCompanyToken::dispatchNow($sp035a66, $spaa9f78, $spafe62e);

        if ($spaa9f78) {
            event(new AccountCreated($spaa9f78, $sp035a66, Ninja::eventVars()));
        }

        $spaa9f78->fresh();

        //todo implement SLACK notifications
        //$sp035a66->notification(new NewAccountCreated($spaa9f78, $sp035a66))->ninja();

        VersionCheck::dispatchNow();

        LightLogs::create(new AnalyticsAccountCreated())
                 ->increment()
                 ->batch();

        return $sp794f3f;
    }

    private function processSettings($settings)
    {
        if(Ninja::isHosted() && Cache::get('currencies') && $data = unserialize(@file_get_contents('http://www.geoplugin.net/php.gp?ip=' . $this->client_ip)))
        {

            $currency_code = strtolower($data['geoplugin_currencyCode']);
            $country_code = strtolower($data['geoplugin_countryCode']);

            $currency = Cache::get('currencies')->filter(function ($item) use ($currency_code) {
                return strtolower($item->code) == $currency_code;
            })->first();

            if ($currency) {
                $settings->currency_id = (string)$currency->id;
            }

            $country = Cache::get('countries')->filter(function ($item) use ($country_code) {
                return strtolower($item->iso_3166_2) == $country_code || strtolower($item->iso_3166_3) == $country_code;
            })->first();

            if ($country) {
                $settings->country_id = (string)$country->id;
            }
            
            $language = Cache::get('languages')->filter(function ($item) use ($currency_code) {
                return strtolower($item->locale) == $currency_code;
            })->first();

            if ($language) {
                $settings->language_id = (string)$language->id;
            }

            $timezone = Timezone::where('name', $data['geoplugin_timezone'])->first();

            if($timezone) {
                $settings->timezone_id = (string)$timezone->id;
            }

            return $settings;
        }


        return $settings;
    }
}