convert to cashier with user creation upon purchase

Author: steven-fox

app/Jobs/CreateUserFromStripeCustomer.php

@@ -0,0 +1,45 @@
+<?php
+
+namespace App\Jobs;
+
+use App\Models\User;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Support\Facades\Hash;
+use Illuminate\Support\Str;
+use Laravel\Cashier\Cashier;
+use Stripe\Customer;
+
+class CreateUserFromStripeCustomer implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    public function __construct(public Customer $customer) {}
+
+    public function handle(): void
+    {
+        if (Cashier::findBillable($this->customer)) {
+            $this->fail("A user already exists for Stripe customer [{$this->customer->id}].");
+
+            return;
+        }
+
+        if (User::query()->where('email', $this->customer->email)->exists()) {
+            $this->fail("A user already exists for email [{$this->customer->email}].");
+
+            return;
+        }
+
+        $user = new User;
+        $user->name = $this->customer->name;
+        $user->email = $this->customer->email;
+        $user->stripe_id = $this->customer->id;
+        // We will create a random password for the user and expect them to reset it.
+        $user->password = Hash::make(Str::random(72));
+
+        $user->save();
+    }
+}

…HandleCustomerSubscriptionCreatedJob.php …HandleCustomerSubscriptionCreatedJob.phpapp/Jobs/StripeWebhooks/HandleCustomerSubscriptionCreatedJob.php renamed to app/Jobs/HandleCustomerSubscriptionCreatedJob.php app/Jobs/StripeWebhooks/HandleCustomerSubscriptionCreatedJob.php renamed to app/Jobs/HandleCustomerSubscriptionCreatedJob.php

@@ -1,23 +1,21 @@
 <?php
 
-namespace App\Jobs\StripeWebhooks;
+namespace App\Jobs;
 
-use App\Jobs\CreateAnystackLicenseJob;
 use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Foundation\Bus\Dispatchable;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
-use Spatie\WebhookClient\Models\WebhookCall;
-use Stripe\Event;
-use Stripe\StripeClient;
+use Laravel\Cashier\Cashier;
+use Laravel\Cashier\Events\WebhookHandled;
 use Stripe\Subscription;
 
 class HandleCustomerSubscriptionCreatedJob implements ShouldQueue
 {
     use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
 
-    public function __construct(public WebhookCall $webhook) {}
+    public function __construct(public WebhookHandled $webhook) {}
 
     public function handle(): void
     {
@@ -29,19 +27,17 @@ public function handle(): void
             return;
         }
 
-        $customer = app(StripeClient::class)
-            ->customers
-            ->retrieve($stripeSubscription->customer);
+        $user = Cashier::findBillable($stripeSubscription->customer);
 
-        if (! $customer || ! ($email = $customer->email)) {
-            $this->fail('Failed to retrieve customer information or customer has no email.');
+        if (! $user || ! ($email = $user->email)) {
+            $this->fail('Failed to find user from Stripe subscription customer.');
 
             return;
         }
 
         $subscriptionPlan = \App\Enums\Subscription::fromStripeSubscription($stripeSubscription);
 
-        $nameParts = explode(' ', $customer->name ?? '', 2);
+        $nameParts = explode(' ', $user->name ?? '', 2);
         $firstName = $nameParts[0] ?: null;
         $lastName = $nameParts[1] ?? null;
 
@@ -55,6 +51,6 @@ public function handle(): void
 
     protected function constructStripeSubscription(): ?Subscription
     {
-        return Event::constructFrom($this->webhook->payload)->data?->object;
+        return Subscription::constructFrom($this->webhook->payload['data']['object']);
     }
 }

app/Listeners/StripeWebhookHandledListener.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace App\Listeners;
+
+use App\Jobs\HandleCustomerSubscriptionCreatedJob;
+use Illuminate\Support\Facades\Log;
+use Laravel\Cashier\Events\WebhookHandled;
+
+class StripeWebhookHandledListener
+{
+    public function handle(WebhookHandled $event): void
+    {
+        Log::debug('Webhook handled', $event->payload);
+
+        match ($event->payload['type']) {
+            'customer.subscription.created' => dispatch(new HandleCustomerSubscriptionCreatedJob($event)),
+            default => null,
+        };
+    }
+}

app/Listeners/StripeWebhookReceivedListener.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace App\Listeners;
+
+use App\Jobs\CreateUserFromStripeCustomer;
+use Illuminate\Support\Facades\Log;
+use Laravel\Cashier\Events\WebhookReceived;
+use Stripe\Customer;
+
+class StripeWebhookReceivedListener
+{
+    public function handle(WebhookReceived $event): void
+    {
+        Log::debug('Webhook received', $event->payload);
+
+        match ($event->payload['type']) {
+            // 'customer.created' must be dispatched sync so the user is
+            // created before the cashier webhook handling is executed.
+            'customer.created' => dispatch_sync(new CreateUserFromStripeCustomer(
+                Customer::constructFrom($event->payload['data']['object'])
+            )),
+            default => null,
+        };
+    }
+}

app/Models/User.php

@@ -6,38 +6,20 @@
 use Illuminate\Database\Eloquent\Factories\HasFactory;
 use Illuminate\Foundation\Auth\User as Authenticatable;
 use Illuminate\Notifications\Notifiable;
+use Laravel\Cashier\Billable;
 use Laravel\Sanctum\HasApiTokens;
 
 class User extends Authenticatable
 {
-    use HasApiTokens, HasFactory, Notifiable;
+    use Billable, HasApiTokens, HasFactory, Notifiable;
 
-    /**
-     * The attributes that are mass assignable.
-     *
-     * @var array<int, string>
-     */
-    protected $fillable = [
-        'name',
-        'email',
-        'password',
-    ];
+    protected $guarded = [];
 
-    /**
-     * The attributes that should be hidden for serialization.
-     *
-     * @var array<int, string>
-     */
     protected $hidden = [
         'password',
         'remember_token',
     ];
 
-    /**
-     * The attributes that should be cast.
-     *
-     * @var array<string, string>
-     */
     protected $casts = [
         'email_verified_at' => 'datetime',
         'password' => 'hashed',

app/Providers/EventServiceProvider.php

@@ -2,10 +2,14 @@
 
 namespace App\Providers;
 
+use App\Listeners\StripeWebhookHandledListener;
+use App\Listeners\StripeWebhookReceivedListener;
 use Illuminate\Auth\Events\Registered;
 use Illuminate\Auth\Listeners\SendEmailVerificationNotification;
 use Illuminate\Foundation\Support\Providers\EventServiceProvider as ServiceProvider;
 use Illuminate\Support\Facades\Event;
+use Laravel\Cashier\Events\WebhookHandled;
+use Laravel\Cashier\Events\WebhookReceived;
 
 class EventServiceProvider extends ServiceProvider
 {
@@ -18,6 +22,12 @@ class EventServiceProvider extends ServiceProvider
         Registered::class => [
             SendEmailVerificationNotification::class,
         ],
+        WebhookReceived::class => [
+            StripeWebhookReceivedListener::class,
+        ],
+        WebhookHandled::class => [
+            StripeWebhookHandledListener::class,
+        ],
     ];
 
     /**

composer.json

@@ -2,22 +2,24 @@
     "name": "nativephp/nativephp.com",
     "type": "project",
     "description": "The NativePHP website",
-    "keywords": ["laravel", "nativephp"],
+    "keywords": [
+        "laravel",
+        "nativephp"
+    ],
     "license": "MIT",
     "require": {
         "php": "^8.1",
         "artesaos/seotools": "^1.2",
         "blade-ui-kit/blade-heroicons": "^2.3",
         "guzzlehttp/guzzle": "^7.2",
+        "laravel/cashier": "^15.6",
         "laravel/framework": "^10.10",
         "laravel/sanctum": "^3.2",
         "laravel/tinker": "^2.8",
         "league/commonmark": "^2.4",
         "livewire/livewire": "^3.6",
         "spatie/laravel-menu": "^4.1",
-        "spatie/laravel-stripe-webhooks": "^3.10",
         "spatie/yaml-front-matter": "^2.0",
-        "stripe/stripe-php": "^17.1",
         "torchlight/torchlight-commonmark": "^0.5.5"
     },
     "require-dev": {