mirror of
https://github.com/invoiceninja/invoiceninja.git
synced 2024-11-10 21:22:58 +01:00
115 lines
3.6 KiB
PHP
115 lines
3.6 KiB
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\Http\Controllers;
|
|
|
|
use App\DataMapper\FeesAndLimits;
|
|
use App\Factory\CompanyGatewayFactory;
|
|
use App\Http\Requests\StripeConnect\InitializeStripeConnectRequest;
|
|
use App\Libraries\MultiDB;
|
|
use App\Models\Client;
|
|
use App\Models\CompanyGateway;
|
|
use App\PaymentDrivers\Stripe\Connect\Account;
|
|
use Stripe\Exception\ApiErrorException;
|
|
|
|
class StripeConnectController extends BaseController
|
|
{
|
|
/**
|
|
* Initialize Stripe Connect flow.
|
|
*
|
|
* @param string $token One-time token
|
|
* @throws ApiErrorException
|
|
*/
|
|
public function initialize(InitializeStripeConnectRequest $request, string $token)
|
|
{
|
|
// Should we check if company has set country in the ap? Otherwise this will fail.
|
|
|
|
if(!is_array($request->getTokenContent()))
|
|
abort(400, 'Invalid token');
|
|
|
|
MultiDB::findAndSetDbByCompanyKey($request->getTokenContent()['company_key']);
|
|
|
|
$company_gateway = CompanyGateway::query()
|
|
->where('gateway_key', 'd14dd26a47cecc30fdd65700bfb67b34')
|
|
->where('company_id', $request->getCompany()->id)
|
|
->first();
|
|
|
|
if ($company_gateway) {
|
|
|
|
$config = decrypt($company_gateway->config);
|
|
|
|
if(property_exists($config, 'account_id'))
|
|
return render('gateways.stripe.connect.existing');
|
|
|
|
}
|
|
else
|
|
$company_gateway = CompanyGatewayFactory::create($request->getCompany()->id, $request->getContact()->id);
|
|
|
|
/* Set Credit Card To Enabled */
|
|
$gateway_types = $company_gateway->driver(new Client)->gatewayTypes();
|
|
$fees_and_limits = new \stdClass;
|
|
$fees_and_limits->{$gateway_types[0]} = new FeesAndLimits;
|
|
|
|
$company_gateway->gateway_key = 'd14dd26a47cecc30fdd65700bfb67b34';
|
|
$company_gateway->fees_and_limits = $fees_and_limits;
|
|
$company_gateway->save();
|
|
|
|
/* Link account if existing account exists */
|
|
if($account_id = $this->checkAccountAlreadyLinkToEmail($company_gateway, $request->getContact()->email)) {
|
|
|
|
$config = json_decode(decrypt($company_gateway->config));
|
|
|
|
$config->account_id = $account_id;
|
|
$company_gateway->config = encrypt(json_encode($config));
|
|
$company_gateway->save();
|
|
|
|
return render('gateways.stripe.connect.existing');
|
|
}
|
|
|
|
$data = [
|
|
'type' => 'standard',
|
|
'email' => $request->getContact()->email,
|
|
'country' => $request->getCompany()->country()->iso_3166_2,
|
|
];
|
|
|
|
$account = Account::create($data);
|
|
$link = Account::link($account->id, $token);
|
|
$company_gateway->config = encrypt(json_encode(['account_id' => $account->id]));
|
|
$company_gateway->save();
|
|
|
|
return redirect($link['url']);
|
|
}
|
|
|
|
public function completed()
|
|
{
|
|
return render('gateways.stripe.connect.completed');
|
|
}
|
|
|
|
|
|
private function checkAccountAlreadyLinkToEmail($company_gateway, $email)
|
|
{
|
|
$client = Client::first() ? Client::first() : new Client;
|
|
|
|
//Pull the list of Stripe Accounts and see if we match
|
|
$accounts = $company_gateway->driver($client)->getAllConnectedAccounts()->data;
|
|
|
|
foreach($accounts as $account)
|
|
{
|
|
if($account['email'] == $email)
|
|
return $account['id'];
|
|
}
|
|
|
|
return false;
|
|
|
|
}
|
|
}
|