invoiceninja/app/Services/Subscription/SubscriptionService.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\Services\Subscription;

use App\DataMapper\InvoiceItem;
use App\Factory\InvoiceFactory;
use App\Factory\InvoiceToRecurringInvoiceFactory;
use App\Factory\RecurringInvoiceFactory;
use App\Jobs\Util\SystemLogger;
use App\Models\ClientContact;
use App\Models\ClientSubscription;
use App\Models\Invoice;
use App\Models\PaymentHash;
use App\Models\Product;
use App\Models\Subscription;
use App\Models\SystemLog;
use App\Repositories\InvoiceRepository;
use App\Repositories\RecurringInvoiceRepository;
use App\Repositories\SubscriptionRepository;
use App\Utils\Traits\CleanLineItems;
use App\Utils\Traits\MakesHash;
use GuzzleHttp\RequestOptions;

class SubscriptionService
{
    use MakesHash;
    use CleanLineItems;

    /** @var subscription */
    private $subscription;

    /** @var client_subscription */
    // private $client_subscription;

    public function __construct(Subscription $subscription)
    {
        $this->subscription = $subscription;
    }

    public function completePurchase(PaymentHash $payment_hash)
    {

        if (!property_exists($payment_hash->data, 'billing_context')) {
            throw new \Exception("Illegal entrypoint into method, payload must contain billing context");
        }

        // if we have a recurring product - then generate a recurring invoice
        // if trial is enabled, generate the recurring invoice to fire when the trial ends.


    }

    /**
        'email' => $this->email ?? $this->contact->email,
        'quantity' => $this->quantity,
        'contact_id' => $this->contact->id,
     */
    public function startTrial(array $data)
    {
        // Redirects from here work just fine. Livewire will respect it.

        if(!$this->subscription->trial_enabled)
            return new \Exception("Trials are disabled for this product");

        //create recurring invoice with start date = trial_duration + 1 day
        $recurring_invoice_repo = new RecurringInvoiceRepository();
        $subscription_repo = new SubscriptionRepository();

        $invoice = RecurringInvoiceFactory::create($this->subscription->company_id, $this->subscription->user_id);
        $invoice->line_items = $subscription_repo->generateLineItems($this->subscription, true);
        $invoice->subscription_id = $this->subscription->id;
        $invoice->frequency_id = $this->subscription->frequency_id;
        $invoice->date = now()->addSeconds($this->subscription->trial_duration)->addDays(1);

        if(strlen($data['coupon']) >=1 && ($data['coupon'] == $this->subscription->promo_code) && $this->subscription->promo_discount > 0) 
        {
            $invoice->discount = $this->subscription->promo_discount;
            $invoice->is_amount_discount = $this->subscription->is_amount_discount;
        }        

        $recurring_invoice = $recurring_invoice_repo->save($data, $invoice);

        //execute any webhooks
        $this->triggerWebhook();

        if(strlen($this->subscription->webhook_configuration->post_purchase_url) >=1)
            return redirect($this->subscription->webhook_configuration->post_purchase_url);

        return redirect('/client/subscription/'.$cs->hashed_id);
    }

    public function createInvoice($data): ?\App\Models\Invoice
    {

        $invoice_repo = new InvoiceRepository();
        $subscription_repo = new SubscriptionRepository();

        $invoice = InvoiceFactory::create($this->subscription->company_id, $this->subscription->user_id);
        $invoice->line_items = $subscription_repo->generateLineItems($this->subscription);
        $invoice->subscription_id = $this->subscription->id;

        if(strlen($data['coupon']) >=1 && ($data['coupon'] == $this->subscription->promo_code) && $this->subscription->promo_discount > 0) 
        {
            $invoice->discount = $this->subscription->promo_discount;
            $invoice->is_amount_discount = $this->subscription->is_amount_discount;
        }

        return $invoice_repo->save($data, $invoice);

    }


    private function convertInvoiceToRecurring($payment_hash)
    {
        //The first invoice is a plain invoice - the second is fired on the recurring schedule.
        $invoice = Invoice::find($payment_hash->billing_context->invoice_id); 
        
        if(!$invoice)
            throw new \Exception("Could not match an invoice for payment of billing subscription");
        
        return InvoiceToRecurringInvoiceFactory::create($invoice);
        
    }

    // @deprecated due to change in architecture

    // public function createClientSubscription($payment_hash)
    // {

    //     //is this a recurring or one off subscription.

    //     $cs = new ClientSubscription();
    //     $cs->subscription_id = $this->subscription->id;
    //     $cs->company_id = $this->subscription->company_id;

    //     $cs->invoice_id = $payment_hash->billing_context->invoice_id;
    //     $cs->client_id = $payment_hash->billing_context->client_id;
    //     $cs->quantity = $payment_hash->billing_context->quantity;

    //         //if is_recurring
    //         //create recurring invoice from invoice
    //         if($this->subscription->is_recurring)
    //         {
    //         $recurring_invoice = $this->convertInvoiceToRecurring($payment_hash);
    //         $recurring_invoice->frequency_id = $this->subscription->frequency_id;
    //         $recurring_invoice->next_send_date = $recurring_invoice->nextDateByFrequency(now()->format('Y-m-d'));
    //         $recurring_invoice->save();
    //         $cs->recurring_invoice_id = $recurring_invoice->id;

    //         //?set the recurring invoice as active - set the date here also based on the frequency?
    //         $recurring_invoice->service()->start();
    //         }


    //     $cs->save();

    //     $this->client_subscription = $cs;

    // }

    //@todo - need refactor
    public function triggerWebhook()
    {
        //hit the webhook to after a successful onboarding

        // $body = [
        //     'subscription' => $this->subscription,
        //     'client_subscription' => $this->client_subscription,
        //     'client' => $this->client_subscription->client->toArray(),
        // ];


        // $client =  new \GuzzleHttp\Client(['headers' => $this->subscription->webhook_configuration->post_purchase_headers]);

        // $response = $client->{$this->subscription->webhook_configuration->post_purchase_rest_method}($this->subscription->post_purchase_url,[
        //     RequestOptions::JSON => ['body' => $body]
        // ]);

        //     SystemLogger::dispatch(
        //         $body,
        //         SystemLog::CATEGORY_WEBHOOK,
        //         SystemLog::EVENT_WEBHOOK_RESPONSE,
        //         SystemLog::TYPE_WEBHOOK_RESPONSE,
        //         $this->client_subscription->client,
        //     );

    }

    public function fireNotifications()
    {
        //scan for any notification we are required to send
    }

    public function products()
    {
        return Product::whereIn('id', $this->transformKeys(explode(",", $this->subscription->product_ids)))->get();
    }

    public function recurringProducts()
    {
        return Product::whereIn('id', $this->transformKeys(explode(",", $this->subscription->recurring_product_ids)))->get();
    }

    public function price()
    {
        return 1;
    }

}