Redirect to a second checkout on subscriptions with platform tip

src/Goteo/Controller/InvestController.php

@@ -31,6 +31,7 @@
 use Goteo\Payment\Payment;
 use Goteo\Util\Monolog\Processor\WebProcessor;
 use Omnipay\Common\Message\ResponseInterface;
+use Omnipay\Stripe\Subscription\Message\DonationResponse;
 use RuntimeException;
 use Symfony\Component\HttpFoundation\Request;
 use Symfony\Component\HttpFoundation\Response;
@@ -523,6 +524,11 @@ public function completePaymentAction($project_id, $invest_id, Request $request)
             if (!$response instanceof ResponseInterface) {
                 throw new RuntimeException('This response does not implements ResponseInterface.');
             }
+
+            if ($response instanceof DonationResponse) {
+                return $this->dispatch(AppEvents::INVEST_INIT_REDIRECT, new FilterInvestRequestEvent($method, $response))->getHttpResponse();
+            }
+
             if ($response->isSuccessful()) {
                 // Goto User data fill
                 Message::info(Text::get('invest-payment-success'));

src/Goteo/Controller/StripeSubscriptionController.php

@@ -19,10 +19,12 @@
 use Goteo\Payment\Method\StripeSubscriptionPaymentMethod;
 use Goteo\Repository\InvestRepository;
 use Stripe\Event;
+use Stripe\Invoice;
 use Stripe\StripeClient;
 use Stripe\Webhook;
 use Symfony\Component\HttpFoundation\JsonResponse;
 use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpFoundation\Response;
 
 class StripeSubscriptionController extends Controller
 {
@@ -46,21 +48,19 @@ public function subscriptionsWebhook(Request $request)
 
         switch ($event->type) {
             case Event::TYPE_INVOICE_PAYMENT_SUCCEEDED:
-                $response = $this->createInvest($event->data->object->id);
+                return $this->processInvoice($event->data->object->id);
             case Event::CHARGE_REFUNDED:
-                $response = $this->chargeRefunded($event);
-            case Event::TYPE_INVOICE_PAYMENT_FAILED:
-                break;
-            case Event::TYPE_CUSTOMER_SUBSCRIPTION_DELETED:
-                break;
+                return $this->processRefund($event);
             default:
+                return new JsonResponse(
+                    ['data' => sprintf("The event %s is not supported.", $event->type)],
+                    Response::HTTP_BAD_REQUEST
+                );
                 break;
         }
-
-        return new JsonResponse($response);
     }
 
-    private function chargeRefunded(Event $event): array
+    private function processRefund(Event $event): JsonResponse
     {
         $object = $event->data->object;
         if (!$object || !$object->invoice) {
@@ -76,17 +76,24 @@ private function chargeRefunded(Event $event): array
             $invest->save();
         }
 
-        return $invests;
+        return new JsonResponse(['data' => $invests], Response::HTTP_OK);
     }
 
-    private function createInvest(string $invoiceId): Invest
+    private function processInvoice(string $invoiceId): JsonResponse
     {
         $invoice = $this->stripe->invoices->retrieve($invoiceId);
-        $subscription = $this->stripe->subscriptions->retrieve($invoice->subscription);
+        if ($invoice->billing_reason === Invoice::BILLING_REASON_SUBSCRIPTION_CREATE) {
+            return new JsonResponse([
+                'data' => Invest::get($invoice->lines->data[0]->price->metadata->invest),
+                Response::HTTP_OK
+            ]);
+        }
 
         /** @var User */
         $user = User::getByEmail($invoice->customer_email);
 
+        $subscription = $this->stripe->subscriptions->retrieve($invoice->subscription);
+
         $invest = new Invest([
             'amount' => $invoice->amount_paid / 100,
             'donate_amount' => 0,
@@ -105,6 +112,6 @@ private function createInvest(string $invoiceId): Invest
             throw new \RuntimeException(Text::get('invest-create-error') . '<br />' . implode('<br />', $errors));
         }
 
-        return $invest;
+        return new JsonResponse(['data' => $invest], Response::HTTP_CREATED);
     }
 }

src/Omnipay/Stripe/Subscription/Gateway.php

@@ -4,6 +4,7 @@
 
 use Omnipay\Common\AbstractGateway;
 use Omnipay\Common\Http\ClientInterface;
+use Omnipay\Common\Message\ResponseInterface;
 use Omnipay\Stripe\Subscription\Message\SubscriptionRequest;
 use Omnipay\Stripe\Subscription\Message\SubscriptionResponse;
 use Symfony\Component\HttpFoundation\Request as HttpRequest;
@@ -31,7 +32,7 @@ public function purchase($options = array())
         return new SubscriptionRequest($options);
     }
 
-    public function completePurchase($options = array()): SubscriptionResponse
+    public function completePurchase($options = array()): ResponseInterface
     {
         $request = new SubscriptionRequest($options);
 

src/Omnipay/Stripe/Subscription/Message/DonationResponse.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace Omnipay\Stripe\Subscription\Message;
+
+use Goteo\Application\Config;
+use Omnipay\Common\Message\AbstractResponse;
+use Omnipay\Common\Message\RedirectResponseInterface;
+use Omnipay\Common\Message\RequestInterface;
+use Stripe\Checkout\Session as StripeSession;
+use Stripe\StripeClient;
+
+class DonationResponse extends AbstractResponse implements RedirectResponseInterface
+{
+    private StripeClient $stripe;
+
+    private StripeSession $checkout;
+
+    public function __construct(RequestInterface $request, string $checkoutSessionId)
+    {
+        parent::__construct($request, $checkoutSessionId);
+
+        $this->stripe = new StripeClient(Config::get('payments.stripe.secretKey'));
+        $this->checkout = $this->stripe->checkout->sessions->retrieve($checkoutSessionId);
+    }
+
+    public function isSuccessful()
+    {
+        return $this->checkout->status === StripeSession::STATUS_COMPLETE;
+    }
+
+    public function isRedirect()
+    {
+        return true;
+    }
+
+    public function getRedirectUrl()
+    {
+        return $this->checkout->url;
+    }
+}

src/Omnipay/Stripe/Subscription/Message/SubscriptionRequest.php

@@ -5,15 +5,18 @@
 use Goteo\Application\Config;
 use Goteo\Library\Text;
 use Goteo\Model\Invest;
+use Goteo\Model\Project;
 use Goteo\Model\User;
 use Omnipay\Common\Message\AbstractRequest;
+use Stripe\Checkout\Session as CheckoutSession;
 use Stripe\Customer;
 use Stripe\Product;
 use Stripe\StripeClient;
 
 class SubscriptionRequest extends AbstractRequest
 {
     private array $data;
+
     private StripeClient $stripe;
 
     public function __construct(array $data)
@@ -35,39 +38,37 @@ public function sendData($data)
         $user = $data['user'];
         $invest = $data['invest'];
 
+        /** @var Project */
         $project = $invest->getProject();
 
-        $price = $this->stripe->prices->create([
-            'unit_amount' => ($invest->amount + $invest->donate_amount) * 100,
-            'currency' => 'eur',
-            'recurring' => ['interval' => 'month'],
-            'product' => $this->getStripeProduct($invest)->id
-        ]);
+        $customer = $this->getStripeCustomer($user)->id;
+        $metadata = $this->getMetadata($project, $invest, $user);
+
+        $successUrl = sprintf('%s?session_id={CHECKOUT_SESSION_ID}', $this->getRedirectUrl(
+            'invest',
+            $project->id,
+            $invest->id,
+            'complete'
+        ));
 
         $session = $this->stripe->checkout->sessions->create([
-            'customer' => $this->getStripeCustomer($data['user'])->id,
-            'success_url' => sprintf('%s?session_id={CHECKOUT_SESSION_ID}', $this->getRedirectUrl(
-                'invest',
-                $project->id,
-                $invest->id,
-                'complete'
-            )),
-            'cancel_url' => $this->getRedirectUrl(
-                'project',
-                $project->id
-            ),
-            'mode' => 'subscription',
+            'customer' => $customer,
+            'success_url' => $successUrl,
+            'cancel_url' => $this->getRedirectUrl('project', $project->id),
+            'mode' => CheckoutSession::MODE_SUBSCRIPTION,
             'line_items' => [
                 [
-                    'price' => $price->id,
+                    'price' => $this->stripe->prices->create([
+                        'unit_amount' => $invest->amount * 100,
+                        'currency' => $project->currency,
+                        'recurring' => ['interval' => 'month'],
+                        'product' => $this->getStripeProduct($invest)->id,
+                        'metadata' => $metadata
+                    ])->id,
                     'quantity' => 1
                 ]
             ],
-            'metadata' => [
-                'project' => $project->id,
-                'reward' => $this->getInvestReward($invest, ''),
-                'user' => $user->id,
-            ]
+            'metadata' => $metadata
         ]);
 
         return new SubscriptionResponse($this, $session->id);
@@ -78,13 +79,51 @@ public function completePurchase(array $options = [])
         // Dirty sanitization because something is double concatenating the ?session_id query param
         $sessionId = explode('?', $_REQUEST['session_id'])[0];
         $session = $this->stripe->checkout->sessions->retrieve($sessionId);
+        $metadata = $session->metadata->toArray();
 
-        $this->stripe->subscriptions->update(
-            $session->subscription, [
-            'metadata' => $session->metadata->toArray()
-        ]);
+        if ($session->subscription) {
+            $this->stripe->subscriptions->update(
+                $session->subscription,
+                [
+                    'metadata' => $metadata
+                ]
+            );
+
+            if ($metadata['donate_amount'] < 1) {
+                return new SubscriptionResponse($this, $session->id);
+            }
+
+            $donation = $this->stripe->checkout->sessions->create([
+                'customer' => $this->getStripeCustomer(User::get($metadata['user']))->id,
+                'success_url' => sprintf('%s?session_id={CHECKOUT_SESSION_ID}', $this->getRedirectUrl(
+                    'invest',
+                    $metadata['project'],
+                    $metadata['invest'],
+                    'complete'
+                )),
+                'cancel_url' => $this->getRedirectUrl('project', $metadata['project']->id),
+                'mode' => CheckoutSession::MODE_PAYMENT,
+                'line_items' => [
+                    [
+                        'price' => $this->stripe->prices->create([
+                            'unit_amount' => $metadata['donate_amount'] * 100,
+                            'currency' => Config::get('currency'),
+                            'product_data' => [
+                                'name' => Text::get('donate-meta-description')
+                            ]
+                        ])->id,
+                        'quantity' => 1
+                    ]
+                ],
+                'metadata' => $metadata
+            ]);
+
+            return new DonationResponse($this, $donation->id);
+        }
 
-        return new SubscriptionResponse($this, $session->id);
+        if ($session->payment_intent) {
+            return new SubscriptionResponse($this, $session->id);
+        }
     }
 
     private function getRedirectUrl(...$args): string
@@ -157,4 +196,15 @@ private function getStripeProduct(Invest $invest): Product
             ]);
         }
     }
+
+    private function getMetadata(Project $project, Invest $invest, User $user): array
+    {
+        return [
+            'donate_amount' => $invest->donate_amount,
+            'project' => $project->id,
+            'invest' => $invest->id,
+            'reward' => $this->getInvestReward($invest, ''),
+            'user' => $user->id,
+        ];
+    }
 }