Feature: new billing flow

.env.example

@@ -58,3 +58,19 @@ VITE_PUSHER_SCHEME="${PUSHER_SCHEME}"
 VITE_PUSHER_APP_CLUSTER="${PUSHER_APP_CLUSTER}"
 
 TORCHLIGHT_TOKEN=
+
+STRIPE_KEY=
+STRIPE_SECRET=
+STRIPE_WEBHOOK_SECRET=
+STRIPE_MINI_PRICE_ID=
+STRIPE_PRO_PRICE_ID=
+STRIPE_MAX_PRICE_ID=
+STRIPE_MINI_PAYMENT_LINK=
+STRIPE_PRO_PAYMENT_LINK=
+STRIPE_MAX_PAYMENT_LINK=
+
+ANYSTACK_API_KEY=
+ANYSTACK_PRODUCT_ID=
+ANYSTACK_MINI_POLICY_ID=
+ANYSTACK_PRO_POLICY_ID=
+ANYSTACK_MAX_POLICY_ID=

app/Enums/Subscription.php

@@ -0,0 +1,58 @@
+<?php
+
+namespace App\Enums;
+
+use RuntimeException;
+
+enum Subscription: string
+{
+    case Mini = 'mini';
+    case Pro = 'pro';
+    case Max = 'max';
+
+    public static function fromStripeSubscription(\Stripe\Subscription $subscription): self
+    {
+        $priceId = $subscription->items->first()?->price->id;
+
+        if (! $priceId) {
+            throw new RuntimeException('Could not resolve Stripe price id from subscription object.');
+        }
+
+        return self::fromStripePriceId($priceId);
+    }
+
+    public static function fromStripePriceId(string $priceId): self
+    {
+        return match ($priceId) {
+            config('subscriptions.plans.mini.stripe_price_id') => self::Mini,
+            config('subscriptions.plans.pro.stripe_price_id') => self::Pro,
+            config('subscriptions.plans.max.stripe_price_id') => self::Max,
+            default => throw new RuntimeException("Unknown Stripe price id: {$priceId}"),
+        };
+    }
+
+    public function name(): string
+    {
+        return config("subscriptions.plans.{$this->value}.name");
+    }
+
+    public function stripePriceId(): string
+    {
+        return config("subscriptions.plans.{$this->value}.stripe_price_id");
+    }
+
+    public function stripePaymentLink(): string
+    {
+        return config("subscriptions.plans.{$this->value}.stripe_payment_link");
+    }
+
+    public function anystackProductId(): string
+    {
+        return config("subscriptions.plans.{$this->value}.anystack_product_id");
+    }
+
+    public function anystackPolicyId(): string
+    {
+        return config("subscriptions.plans.{$this->value}.anystack_policy_id");
+    }
+}

app/Http/Middleware/VerifyCsrfToken.php

@@ -12,6 +12,6 @@ class VerifyCsrfToken extends Middleware
      * @var array<int, string>
      */
     protected $except = [
-        //
+        'stripe/webhook',
     ];
 }

app/Jobs/CreateAnystackLicenseJob.php

@@ -0,0 +1,81 @@
+<?php
+
+namespace App\Jobs;
+
+use App\Enums\Subscription;
+use App\Notifications\LicenseKeyGenerated;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Http\Client\PendingRequest;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Facades\Http;
+use Illuminate\Support\Facades\Notification;
+
+class CreateAnystackLicenseJob implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    public function __construct(
+        public string $email,
+        public Subscription $subscription,
+        public ?string $firstName = null,
+        public ?string $lastName = null,
+    ) {}
+
+    public function handle(): void
+    {
+        $contact = $this->createContact();
+
+        $license = $this->createLicense($contact['id']);
+
+        Cache::put($this->email.'.license_key', $license['key'], now()->addDay());
+
+        Notification::route('mail', $this->email)
+            ->notify(new LicenseKeyGenerated(
+                $license['key'],
+                $this->subscription,
+                $this->firstName
+            ));
+    }
+
+    private function createContact(): array
+    {
+        $data = collect([
+            'first_name' => $this->firstName,
+            'last_name' => $this->lastName,
+            'email' => $this->email,
+        ])
+            ->filter()
+            ->all();
+
+        // TODO: If an existing contact with the same email address already exists,
+        //  anystack will return a 422 validation error response.
+        return $this->anystackClient()
+            ->post('https://api.anystack.sh/v1/contacts', $data)
+            ->throw()
+            ->json('data');
+    }
+
+    private function createLicense(string $contactId): ?array
+    {
+        $data = [
+            'policy_id' => $this->subscription->anystackPolicyId(),
+            'contact_id' => $contactId,
+        ];
+
+        return $this->anystackClient()
+            ->post("https://api.anystack.sh/v1/products/{$this->subscription->anystackProductId()}/licenses", $data)
+            ->throw()
+            ->json('data');
+    }
+
+    private function anystackClient(): PendingRequest
+    {
+        return Http::withToken(config('services.anystack.key'))
+            ->acceptJson()
+            ->asJson();
+    }
+}

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();
+    }
+}

app/Jobs/HandleCustomerSubscriptionCreatedJob.php

@@ -0,0 +1,56 @@
+<?php
+
+namespace App\Jobs;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+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 WebhookHandled $webhook) {}
+
+    public function handle(): void
+    {
+        $stripeSubscription = $this->constructStripeSubscription();
+
+        if (! $stripeSubscription) {
+            $this->fail('The Stripe webhook payload could not be constructed into a Stripe Subscription object.');
+
+            return;
+        }
+
+        $user = Cashier::findBillable($stripeSubscription->customer);
+
+        if (! $user || ! ($email = $user->email)) {
+            $this->fail('Failed to find user from Stripe subscription customer.');
+
+            return;
+        }
+
+        $subscriptionPlan = \App\Enums\Subscription::fromStripeSubscription($stripeSubscription);
+
+        $nameParts = explode(' ', $user->name ?? '', 2);
+        $firstName = $nameParts[0] ?: null;
+        $lastName = $nameParts[1] ?? null;
+
+        dispatch(new CreateAnystackLicenseJob(
+            $email,
+            $subscriptionPlan,
+            $firstName,
+            $lastName,
+        ));
+    }
+
+    protected function constructStripeSubscription(): ?Subscription
+    {
+        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,
+        };
+    }
+}