<?php
/**
 * Invoice Ninja (https://invoiceninja.com).
 *
 * @link https://github.com/invoiceninja/invoiceninja source repository
 *
 * @copyright Copyright (c) 2022. Invoice Ninja LLC (https://invoiceninja.com)
 *
 * @license https://www.elastic.co/licensing/elastic-license
 */

namespace App\PaymentDrivers\Stripe\Jobs;

use App\Jobs\Util\SystemLogger;
use App\Libraries\MultiDB;
use App\Models\ClientGatewayToken;
use App\Models\Company;
use App\Models\CompanyGateway;
use App\Models\GatewayType;
use App\Models\Invoice;
use App\Models\Payment;
use App\Models\PaymentHash;
use App\Models\PaymentType;
use App\Models\SystemLog;
use App\PaymentDrivers\Stripe\UpdatePaymentMethods;
use App\PaymentDrivers\Stripe\Utilities;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;

class PaymentIntentWebhook implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels, Utilities;

    public $tries = 1; //number of retries

    public $deleteWhenMissingModels = true;

    public $stripe_request;

    public $company_key;

    private $company_gateway_id;

    public $payment_completed = false;

    public function __construct($stripe_request, $company_key, $company_gateway_id)
    {
        $this->stripe_request = $stripe_request;
        $this->company_key = $company_key;
        $this->company_gateway_id = $company_gateway_id;
    }

    public function handle()
    {

        MultiDB::findAndSetDbByCompanyKey($this->company_key);

        $company = Company::where('company_key', $this->company_key)->first();

            foreach ($this->stripe_request as $transaction) {

                if(array_key_exists('payment_intent', $transaction))
                {
                    $payment = Payment::query()
                        ->where('company_id', $company->id)
                        ->where(function ($query) use ($transaction) {
                            $query->where('transaction_reference', $transaction['payment_intent'])
                                  ->orWhere('transaction_reference', $transaction['id']);
                                })
                        ->first();
                }
                else
                {
                     $payment = Payment::query()
                        ->where('company_id', $company->id)
                        ->where('transaction_reference', $transaction['id'])
                        ->first();
                }

                if ($payment) {
                    $payment->status_id = Payment::STATUS_COMPLETED;
                    $payment->save();
    
                    $this->payment_completed = true;
                }
            }


        if($this->payment_completed)
            return;


        if(isset($this->stripe_request['object']['charges']) && optional($this->stripe_request['object']['charges']['data'][0])['id']){

            $company = Company::where('company_key', $this->company_key)->first();

            $payment = Payment::query()
                             ->where('company_id', $company->id)
                             ->where('transaction_reference', $this->stripe_request['object']['charges']['data'][0]['id'])
                             ->first();

             //return early
            if($payment && $payment->status_id == Payment::STATUS_COMPLETED){
                nlog(" payment found and status correct - returning "); 
                return;
            }
            elseif($payment){
                $payment->status_id = Payment::STATUS_COMPLETED;
                $payment->save();
            }


            $hash = optional($this->stripe_request['object']['charges']['data'][0]['metadata'])['payment_hash'];

            $payment_hash = PaymentHash::where('hash', $hash)->first();

            if(!$payment_hash)
                return;

            nlog("payment intent");
            nlog($this->stripe_request);

            if(array_key_exists('allowed_source_types', $this->stripe_request['object']) && optional($this->stripe_request['object']['charges']['data'][0]['metadata']['payment_hash']) && in_array('card', $this->stripe_request['object']['allowed_source_types']))
            {
                nlog("hash found");

                $hash = $this->stripe_request['object']['charges']['data'][0]['metadata']['payment_hash'];

                $payment_hash = PaymentHash::where('hash', $hash)->first();
                $invoice = Invoice::with('client')->find($payment_hash->fee_invoice_id);
                $client = $invoice->client;

                $this->updateCreditCardPayment($payment_hash, $client);
            }
            elseif(array_key_exists('payment_method_types', $this->stripe_request['object']) && optional($this->stripe_request['object']['charges']['data'][0]['metadata']['payment_hash']) && in_array('card', $this->stripe_request['object']['payment_method_types']))
            {
                nlog("hash found");

                $hash = $this->stripe_request['object']['charges']['data'][0]['metadata']['payment_hash'];

                $payment_hash = PaymentHash::where('hash', $hash)->first();
                $invoice = Invoice::with('client')->find($payment_hash->fee_invoice_id);
                $client = $invoice->client;

                $this->updateCreditCardPayment($payment_hash, $client);
            }
            elseif(array_key_exists('payment_method_types', $this->stripe_request['object']) && optional($this->stripe_request['object']['charges']['data'][0]['metadata']['payment_hash']) && in_array('us_bank_account', $this->stripe_request['object']['payment_method_types']))
            {
                nlog("hash found");

                $hash = $this->stripe_request['object']['charges']['data'][0]['metadata']['payment_hash'];

                $payment_hash = PaymentHash::where('hash', $hash)->first();
                $invoice = Invoice::with('client')->find($payment_hash->fee_invoice_id);
                $client = $invoice->client;

                $this->updateAchPayment($payment_hash, $client);
            }

            SystemLogger::dispatch(
                ['response' => $this->stripe_request, 'data' => []],
                SystemLog::CATEGORY_GATEWAY_RESPONSE,
                SystemLog::EVENT_GATEWAY_SUCCESS,
                SystemLog::TYPE_STRIPE,
                null,
                $company,
            );

            return;

        }

        if(isset($this->stripe_request['object']['latest_charge']))
        {
            $pi = \Stripe\PaymentIntent::retrieve($this->stripe_request['object']['id'], $this->stripe_driver->stripe_connect_auth);

            $charge = reset($pi->charges->data);

            $company = Company::where('company_key', $this->company_key)->first();

            $payment = Payment::query()
                             ->where('company_id', $company->id)
                             ->where('transaction_reference', $charge['id'])
                             ->first();

             //return early
            if($payment && $payment->status_id == Payment::STATUS_COMPLETED){
                nlog(" payment found and status correct - returning "); 
                return;
            }
            elseif($payment){
                $payment->status_id = Payment::STATUS_COMPLETED;
                $payment->save();
            }

            $hash = optional($charge['metadata']['payment_hash']);

            $payment_hash = PaymentHash::where('hash', $hash)->first();

            if(!$payment_hash)
                return;

            if(isset($pi['allowed_source_types']) && in_array('card', $pi['allowed_source_types']))
            {
                nlog("hash found");

                $hash = $this->stripe_request['object']['charges']['data'][0]['metadata']['payment_hash'];

                $payment_hash = PaymentHash::where('hash', $hash)->first();
                $invoice = Invoice::with('client')->find($payment_hash->fee_invoice_id);
                $client = $invoice->client;

                $this->updateCreditCardPayment($payment_hash, $client);
            }
            elseif(isset($pi['payment_method_types']) && in_array('card', $pi['payment_method_types']))
            {
                nlog("hash found");

                $hash = $this->stripe_request['object']['charges']['data'][0]['metadata']['payment_hash'];

                $payment_hash = PaymentHash::where('hash', $hash)->first();
                $invoice = Invoice::with('client')->find($payment_hash->fee_invoice_id);
                $client = $invoice->client;

                $this->updateCreditCardPayment($payment_hash, $client);
            }
            elseif(isset($pi['payment_method_types']) && in_array('us_bank_account', $pi['payment_method_types']))
            {
                nlog("hash found");

                $hash = $this->stripe_request['object']['charges']['data'][0]['metadata']['payment_hash'];

                $payment_hash = PaymentHash::where('hash', $hash)->first();
                $invoice = Invoice::with('client')->find($payment_hash->fee_invoice_id);
                $client = $invoice->client;

                $this->updateAchPayment($payment_hash, $client);
            }

            SystemLogger::dispatch(
                ['response' => $this->stripe_request, 'data' => []],
                SystemLog::CATEGORY_GATEWAY_RESPONSE,
                SystemLog::EVENT_GATEWAY_SUCCESS,
                SystemLog::TYPE_STRIPE,
                null,
                $company,
            );


        }


    }

    private function updateAchPayment($payment_hash, $client)
    {
        $company_gateway = CompanyGateway::find($this->company_gateway_id);
        $payment_method_type = optional($this->stripe_request['object']['charges']['data'][0]['metadata'])['gateway_type_id'];
        $driver = $company_gateway->driver($client)->init()->setPaymentMethod($payment_method_type);

        $payment_hash->data = array_merge((array) $payment_hash->data, $this->stripe_request);
        $payment_hash->save();
        $driver->setPaymentHash($payment_hash);

        $data = [
            'payment_method' => $payment_hash->data->object->payment_method,
            'payment_type' => PaymentType::ACH,
            'amount' => $payment_hash->data->amount_with_fee,
            'transaction_reference' => $this->stripe_request['object']['charges']['data'][0]['id'],
            'gateway_type_id' => GatewayType::BANK_TRANSFER,
        ];
        
        $payment = $driver->createPayment($data, Payment::STATUS_COMPLETED);

        SystemLogger::dispatch(
            ['response' => $this->stripe_request, 'data' => $data],
            SystemLog::CATEGORY_GATEWAY_RESPONSE,
            SystemLog::EVENT_GATEWAY_SUCCESS,
            SystemLog::TYPE_STRIPE,
            $client,
            $client->company,
        );

        try {

            $customer = $driver->getCustomer($this->stripe_request['object']['charges']['data'][0]['customer']);
            $method = $driver->getStripePaymentMethod($this->stripe_request['object']['charges']['data'][0]['payment_method']);
            $payment_method = $this->stripe_request['object']['charges']['data'][0]['payment_method'];

            $token_exists = ClientGatewayToken::where([
                'gateway_customer_reference' => $customer->id,
                'token' => $payment_method,
                'client_id' => $client->id,
                'company_id' => $client->company_id,
            ])->exists();

            /* Already exists return */
            if ($token_exists) {
                return;
            }

            $payment_meta = new \stdClass;
            $payment_meta->brand = (string) \sprintf('%s (%s)', $method->us_bank_account['bank_name'], ctrans('texts.ach'));
            $payment_meta->last4 = (string) $method->us_bank_account['last4'];
            $payment_meta->type = GatewayType::BANK_TRANSFER;
            $payment_meta->state = 'verified';

            $data = [
                'payment_meta' => $payment_meta,
                'token' => $payment_method,
                'payment_method_id' => GatewayType::BANK_TRANSFER,
            ];

            $additional_data = ['gateway_customer_reference' => $customer->id];

            if ($customer->default_source === $method->id) {
                $additional_data = ['gateway_customer_reference' => $customer->id, 'is_default' => 1];
            }

            $driver->storeGatewayToken($data, $additional_data);
            
        }
        catch(\Exception $e){
            nlog("failed to import payment methods");
            nlog($e->getMessage());
        }
    }


    private function updateCreditCardPayment($payment_hash, $client)
    {
        $company_gateway = CompanyGateway::find($this->company_gateway_id);
        $payment_method_type = optional($this->stripe_request['object']['charges']['data'][0]['metadata'])['gateway_type_id'];
        $driver = $company_gateway->driver($client)->init()->setPaymentMethod($payment_method_type);

        $payment_hash->data = array_merge((array) $payment_hash->data, $this->stripe_request);
        $payment_hash->save();
        $driver->setPaymentHash($payment_hash);

        $data = [
            'payment_method' => $payment_hash->data->object->payment_method,
            'payment_type' => PaymentType::parseCardType(strtolower(optional($this->stripe_request['object']['charges']['data'][0]['payment_method_details']['card'])['brand'])) ?: PaymentType::CREDIT_CARD_OTHER,
            'amount' => $payment_hash->data->amount_with_fee,
            'transaction_reference' => $this->stripe_request['object']['charges']['data'][0]['id'],
            'gateway_type_id' => GatewayType::CREDIT_CARD,
        ];
        
        $payment = $driver->createPayment($data, Payment::STATUS_COMPLETED);

        SystemLogger::dispatch(
            ['response' => $this->stripe_request, 'data' => $data],
            SystemLog::CATEGORY_GATEWAY_RESPONSE,
            SystemLog::EVENT_GATEWAY_SUCCESS,
            SystemLog::TYPE_STRIPE,
            $client,
            $client->company,
        );

    }

}