Feature: new billing flow

.env.example

@@ -58,3 +58,21 @@ 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_MINI_PRODUCT_ID=
+ANYSTACK_PRO_PRODUCT_ID=
+ANYSTACK_MAX_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: It's unknown what will happen if an existing contact with
+        //  the same email address already exists.
+        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/StripeWebhooks/HandleCustomerSubscriptionCreatedJob.php

@@ -0,0 +1,60 @@
+<?php
+
+namespace App\Jobs\StripeWebhooks;
+
+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 Stripe\Subscription;
+
+class HandleCustomerSubscriptionCreatedJob implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    public function __construct(public WebhookCall $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;
+        }
+
+        $customer = app(StripeClient::class)
+            ->customers
+            ->retrieve($stripeSubscription->customer);
+
+        if (! $customer || ! ($email = $customer->email)) {
+            $this->fail('Failed to retrieve customer information or customer has no email.');
+
+            return;
+        }
+
+        $subscriptionPlan = \App\Enums\Subscription::fromStripeSubscription($stripeSubscription);
+
+        $nameParts = explode(' ', $customer->name ?? '', 2);
+        $firstName = $nameParts[0] ?: null;
+        $lastName = $nameParts[1] ?? null;
+
+        dispatch(new CreateAnystackLicenseJob(
+            $email,
+            $subscriptionPlan,
+            $firstName,
+            $lastName,
+        ));
+    }
+
+    protected function constructStripeSubscription(): ?Subscription
+    {
+        return Event::constructFrom($this->webhook->payload)->data?->object;
+    }
+}

app/Livewire/OrderSuccess.php

@@ -0,0 +1,92 @@
+<?php
+
+namespace App\Livewire;
+
+use App\Enums\Subscription;
+use Illuminate\Support\Facades\Cache;
+use Livewire\Attributes\Layout;
+use Livewire\Attributes\Title;
+use Livewire\Component;
+use Stripe\StripeClient;
+
+#[Layout('components.layout')]
+#[Title('Thank You for Your Purchase')]
+class OrderSuccess extends Component
+{
+    public ?string $email = null;
+
+    public ?string $licenseKey = null;
+
+    public ?Subscription $subscription = null;
+
+    public string $checkoutSessionId;
+
+    public function mount(string $checkoutSessionId): void
+    {
+        $this->checkoutSessionId = $checkoutSessionId;
+
+        $this->loadData();
+    }
+
+    public function loadData(): void
+    {
+        $this->email = $this->loadEmail();
+        $this->licenseKey = $this->loadLicenseKey();
+        $this->subscription = $this->loadSubscription();
+    }
+
+    private function loadEmail(): ?string
+    {
+        if ($email = session('customer_email')) {
+            return $email;
+        }
+
+        $stripe = app(StripeClient::class);
+        $checkoutSession = $stripe->checkout->sessions->retrieve($this->checkoutSessionId);
+
+        if (! ($email = $checkoutSession?->customer_details?->email)) {
+            return null;
+        }
+
+        session()->put('customer_email', $email);
+
+        return $email;
+    }
+
+    private function loadLicenseKey(): ?string
+    {
+        if ($licenseKey = session('license_key')) {
+            return $licenseKey;
+        }
+
+        if (! $this->email) {
+            return null;
+        }
+
+        if ($licenseKey = Cache::get($this->email.'.license_key')) {
+            session()->put('license_key', $licenseKey);
+        }
+
+        return $licenseKey;
+    }
+
+    private function loadSubscription(): ?Subscription
+    {
+        if ($subscription = session('subscription')) {
+            return Subscription::tryFrom($subscription);
+        }
+
+        $stripe = app(StripeClient::class);
+        $priceId = $stripe->checkout->sessions->allLineItems($this->checkoutSessionId)->first()?->price->id;
+
+        if (! $priceId) {
+            return null;
+        }
+
+        $subscription = Subscription::fromStripePriceId($priceId);
+
+        session()->put('subscription', $subscription->value);
+
+        return $subscription;
+    }
+}

app/Notifications/LicenseKeyGenerated.php

@@ -0,0 +1,63 @@
+<?php
+
+namespace App\Notifications;
+
+use App\Enums\Subscription;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Notifications\Messages\MailMessage;
+use Illuminate\Notifications\Notification;
+
+class LicenseKeyGenerated extends Notification implements ShouldQueue
+{
+    use Queueable;
+
+    public function __construct(
+        public string $licenseKey,
+        public ?Subscription $subscription = null,
+        public ?string $firstName = null,
+    ) {}
+
+    /**
+     * Get the notification's delivery channels.
+     *
+     * @return array<int, string>
+     */
+    public function via(object $notifiable): array
+    {
+        return ['mail'];
+    }
+
+    public function toMail(object $notifiable): MailMessage
+    {
+        $greeting = $this->firstName
+            ? "{$this->firstName}, your license is ready!"
+            : 'Your license is ready!';
+
+        return (new MailMessage)
+            ->subject('Your NativePHP License Key')
+            ->greeting($greeting)
+            ->line('Thank you for purchasing a license for the early access program of mobile NativePHP.')
+            ->line('Your license key is:')
+            ->line("**{$this->licenseKey}**")
+            ->line('When prompted by Composer, use your email address as the username and this license key as the password.')
+            ->action('View Installation Guide', url('/docs/mobile/1/getting-started/installation'))
+            ->line("If you have any questions, please don't hesitate to reach out to our support team.")
+            ->lineIf($this->subscription === Subscription::Max, 'As a Max subscriber, you also have access to the NativePHP/mobile repository. To access it, please log in to [Anystack.sh](https://auth.anystack.sh/?accountType=customer) using the same email address you used for your purchase.')
+            ->salutation("Happy coding!\n\nThe NativePHP Team")
+            ->success();
+    }
+
+    /**
+     * Get the array representation of the notification.
+     *
+     * @return array<string, mixed>
+     */
+    public function toArray(object $notifiable): array
+    {
+        return [
+            'license_key' => $this->licenseKey,
+            'firstName' => $this->firstName,
+        ];
+    }
+}