Appwrite/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite.git synced 2026-05-26 13:51:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

ensure customer before any checkout session

Browse Source
This commit is contained in:
Atharva Deosthale
2025-11-15 16:10:36 +05:30
parent efb8ff7bb1
commit 650da7ba94
2 changed files with 22 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Appwrite/Payments/Provider/StripeAdapter.php
+18 -1
View File
@@ -458,6 +458,7 @@ class StripeAdapter implements Adapter
$successUrl = (string) ($options['successUrl'] ?? '');
$cancelUrl = (string) ($options['cancelUrl'] ?? '');
$priceId = (string) ($planContext['priceId'] ?? '');
$customerId = $this->ensureCustomer($apiKey, $actor);
$params = [
'mode' => 'subscription',
'line_items' => [ [ 'price' => $priceId, 'quantity' => 1 ] ],
@@ -466,14 +467,18 @@ class StripeAdapter implements Adapter
'client_reference_id' => $actor->getId(),
'metadata' => [ 'project_id' => $this->project->getId(), 'actor_id' => $actor->getId() ]
];
if ($customerId !== '') {
$params['customer'] = $customerId;
}
$sessionResponse = $this->request($apiKey, 'POST', '/checkout/sessions', $params);
$sessionData = $this->decodeResponse($sessionResponse);
$resolvedCustomerId = (string) ($sessionData['customer'] ?? $customerId);
return new ProviderCheckoutSession(
url: (string) ($sessionData['url'] ?? ''),
metadata: [
'id' => (string) ($sessionData['id'] ?? ''),
'subscriptionId' => (string) ($sessionData['subscription'] ?? ''),
'customerId' => (string) ($sessionData['customer'] ?? ''),
'customerId' => $resolvedCustomerId,
]
);
}
@@ -575,12 +580,20 @@ class StripeAdapter implements Adapter
]);
$sessionsData = $this->decodeResponse($sessionsResponse);
$sessionId = (string) ($sessionsData['data'][0]['id'] ?? '');
$sessionCustomerId = (string) ($sessionsData['data'][0]['customer'] ?? '');
if ($sessionId !== '') {
$subscription = Authorization::skip(fn () => $this->dbForPlatform->findOne('payments_subscriptions', [
Query::equal('providerCheckoutId', [$sessionId]),
]));
if ($subscription instanceof Document && !$subscription->isEmpty()) {
$subscription->setAttribute('providerSubscriptionId', $stripeSubId);
if ($sessionCustomerId !== '') {
$providers = (array) $subscription->getAttribute('providers', []);
$providerEntry = (array) ($providers['stripe'] ?? []);
$providerEntry['providerCustomerId'] = $sessionCustomerId;
$providers['stripe'] = $providerEntry;
$subscription->setAttribute('providers', $providers);
}
}
}
} catch (\Throwable $_) {
@@ -610,6 +623,10 @@ class StripeAdapter implements Adapter
$providers = (array) $subscription->getAttribute('providers', []);
$providerEntry = (array) ($providers['stripe'] ?? []);
$providerEntry['providerSubscriptionId'] = $stripeSubId;
$stripeCustomerId = (string) ($subData['customer'] ?? '');
if ($stripeCustomerId !== '') {
$providerEntry['providerCustomerId'] = $stripeCustomerId;
}
$providers['stripe'] = $providerEntry;
$subscription->setAttribute('status', $internalStatus);
src/Appwrite/Platform/Modules/Payments/Http/Subscriptions/Create.php
+4
View File
@@ -265,11 +265,15 @@ class Create extends Base
$response->json(['message' => 'Checkout session did not return an id']);
return;
}
$providerCustomerId = (string) ($checkoutSession->metadata['customerId'] ?? '');
$providerEntryData = [
'priceId' => (string) ($selectedPriceId ?? ''),
'providerPriceId' => (string) $providerPlanPriceId,
'providerCheckoutId' => $providerCheckoutId,
];
if ($providerCustomerId !== '') {
$providerEntryData['providerCustomerId'] = $providerCustomerId;
}
$initialStatus = 'pending';
$providerData[$providerKey] = $providerEntryData;