BossBey File Manager

Editing: PaystackWebhookListener.php

<?php

namespace App\Listeners;

use App\Events\PaystackWebhookEvent;
use App\Models\WebhookHistory;
use App\Services\PaymentGateways\Contracts\CreditUpdater;
use Carbon\Carbon;
use Exception;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Str;
use JsonException;
use Laravel\Cashier\Subscription as Subscriptions;
use Throwable;

class PaystackWebhookListener implements ShouldQueue
{
    use CreditUpdater;

/**
     * Create the event listener.
     */
    public function __construct()
    {
        //
    }

use InteractsWithQueue;

public bool $afterCommit = true;

public string $queue = 'default';

public int $delay = 0;

/**
     * Handle the event.
     */
    public function handle(PaystackWebhookEvent $event): void
    {
        try {
            $payload = $event->payload;
            $method = 'handle' . Str::studly(str_replace('.', '_', $payload['event']));
            if (method_exists($this, $method)) {
                $response = $this->{$method}($payload);
            }
        } catch (Exception $ex) {
            Log::error("PaystackWebhookListener::handle()\n" . $ex->getMessage());
        }
    }

/**
     * Handle a job failure.
     *
     * @throws JsonException
     */
    public function failed(PaystackWebhookEvent $event, Throwable $exception): void
    {
        $space = '*****';
        $msg = '\n' . $space . '\n' . $space;
        $msg .= json_encode($event->payload, JSON_THROW_ON_ERROR);
        $msg .= '\n' . $space . '\n';
        $msg .= '\n' . $exception . '\n';
        $msg .= '\n' . $space . '\n' . $space;
        Log::error($msg);
    }

protected function successMethod(array $parameters = []): void {}

protected function missingMethod(array $parameters = []): void {}

public function handleChargeSuccess($payload): void {}

/**
     * @throws Exception
     */
    public function handlesubScriptionDisable($payload): void // A subscription disabled
    {
        $subscriptionData = $payload['data'];
        // Extract relevant subscription data
        $subscriptionCode = $subscriptionData['subscription_code'];
        $status = $subscriptionData['status'];
        // Extract plan details
        $plan = $subscriptionData['plan'];
        $planId = $plan['id'];
        // Extract customer details
        $customer = $subscriptionData['customer'];
        $customerFirstName = $customer['first_name'];
        $customerLastName = $customer['last_name'];
        $customerEmail = $customer['email'];
        // Extract authorization details
        $authorization = $subscriptionData['authorization'];
        $authorizationCode = $authorization['authorization_code'];
        // Save to Webhook History
        $newData = new WebhookHistory;
        $newData->gatewaycode = 'paystack';
        $newData->webhook_id = $authorizationCode;
        $newData->event_type = 'subscription.disable';
        $newData->resource_id = $subscriptionCode;  // Subscription id
        $newData->resource_type = 'subscription'; // Subscription
        $newData->status = 'check';
        $newData->summary = "Subscription Disabled: $customerFirstName $customerLastName - $customerEmail - $status - $planId";
        $newData->incoming_json = json_encode($payload);
        $newData->create_time = $subscriptionData['created_at'];
        $newData->resource_state = 'cancelled';
        $newData->save();

$currentSubscription = Subscriptions::where('stripe_id', $subscriptionCode)->first();
        if ($currentSubscription !== null && $currentSubscription->stripe_status !== 'cancelled') {
            $currentSubscription->stripe_status = 'cancelled';
            $currentSubscription->ends_at = Carbon::now();
            $currentSubscription->save();
            $newData->status = 'checked';
            $newData->save();

self::creditDecreaseCancelPlan($currentSubscription->user, $currentSubscription->plan);
        }
    }
}

Cancel