Handle payment_intent.failed event

app/subscribers/solidus_stripe/webhook/payment_intent_subscriber.rb

@@ -7,6 +7,7 @@ class PaymentIntentSubscriber
       include Omnes::Subscriber
 
       handle :"stripe.payment_intent.succeeded", with: :complete_payment
+      handle :"stripe.payment_intent.payment_failed", with: :fail_payment
 
       # Captures a payment.
       #
@@ -15,8 +16,7 @@ class PaymentIntentSubscriber
       #
       # @param event [SolidusStripe::Webhook::Event]
       def complete_payment(event)
-        payment_intent_id = event.data.object.id
-        payment = Spree::Payment.find_by!(response_code: payment_intent_id)
+        payment = extract_payment_from_event(event)
         return if payment.completed?
 
         payment.complete!.tap do
@@ -27,6 +27,32 @@ def complete_payment(event)
           )
         end
       end
+
+      # Fails a payment.
+      #
+      # Marks a Solidus payment associated to a Stripe payment intent as
+      # failed, adding a log entry about the event.
+      #
+      # @param event [SolidusStripe::Webhook::Event]
+      def fail_payment(event)
+        payment = extract_payment_from_event(event)
+        return if payment.failed?
+
+        payment.failure!.tap do
+          SolidusStripe::LogEntries.payment_log(
+            payment,
+            success: false,
+            message: "Payment was marked as failed after payment_intent.failed webhook"
+          )
+        end
+      end
+
+      private
+
+      def extract_payment_from_event(event)
+        payment_intent_id = event.data.object.id
+        Spree::Payment.find_by!(response_code: payment_intent_id)
+      end
     end
   end
 end

lib/solidus_stripe/webhook/event.rb

@@ -15,6 +15,7 @@ class Event
 
       CORE_EVENTS = Set[*%i[
         payment_intent.succeeded
+        payment_intent.payment_failed
       ]].freeze
       private_constant :CORE_EVENTS
 

spec/requests/solidus_stripe/webhooks_controller/payment_intent/payment_failed_spec.rb

@@ -0,0 +1,23 @@
+require "solidus_stripe_spec_helper"
+
+RSpec.describe SolidusStripe::WebhooksController, type: %i[request webhook_request] do
+  describe "POST /create payment_intent.payment_failed" do
+    it "transitions the associated payment to failed" do
+      payment_method = create(:stripe_payment_method)
+      stripe_payment_intent = Stripe::PaymentIntent.construct_from(id: "pi_123")
+      payment = create(:payment,
+        payment_method: payment_method,
+        response_code: stripe_payment_intent.id,
+        state: "pending")
+      context = SolidusStripe::Webhook::EventWithContextFactory.from_object(
+        payment_method: payment_method,
+        object: stripe_payment_intent,
+        type: "payment_intent.payment_failed"
+      )
+
+      expect do
+        webhook_request(context)
+      end.to change { payment.reload.state }.from("pending").to("failed")
+    end
+  end
+end

spec/subscribers/solidus_stripe/webhook/payment_intent_subscriber_spec.rb

@@ -37,8 +37,10 @@
 
       described_class.new.complete_payment(event)
 
+      details = payment.log_entries.last.parsed_details
+      expect(details.success?).to be(true)
       expect(
-        payment.log_entries.last.parsed_details.message
+        details.message
       ).to eq "Capture was successful after payment_intent.succeeded webhook"
     end
 
@@ -61,4 +63,65 @@
       expect(payment.log_entries.count).to be(0)
     end
   end
+
+  describe "#fail_payment" do
+    it "fails a pending payment" do
+      payment_method = create(:stripe_payment_method)
+      stripe_payment_intent = Stripe::PaymentIntent.construct_from(id: "pi_123")
+      payment = create(:payment,
+        payment_method: payment_method,
+        response_code: stripe_payment_intent.id,
+        state: "pending")
+      event = SolidusStripe::Webhook::EventWithContextFactory.from_object(
+        payment_method: payment_method,
+        object: stripe_payment_intent,
+        type: "payment_intent.payment_failed"
+      ).solidus_stripe_object
+
+      described_class.new.fail_payment(event)
+
+      expect(payment.reload.state).to eq "failed"
+    end
+
+    it "adds a log entry to the payment" do
+      payment_method = create(:stripe_payment_method)
+      stripe_payment_intent = Stripe::PaymentIntent.construct_from(id: "pi_123")
+      payment = create(:payment,
+        payment_method: payment_method,
+        response_code: stripe_payment_intent.id,
+        state: "pending")
+      event = SolidusStripe::Webhook::EventWithContextFactory.from_object(
+        payment_method: payment_method,
+        object: stripe_payment_intent,
+        type: "payment_intent.payment_failed"
+      ).solidus_stripe_object
+
+      described_class.new.fail_payment(event)
+
+      details = payment.log_entries.last.parsed_details
+      expect(details.success?).to be(false)
+      expect(
+        details.message
+      ).to eq "Payment was marked as failed after payment_intent.failed webhook"
+    end
+
+    it "does nothing if the payment is already failed" do
+      payment_method = create(:stripe_payment_method)
+      stripe_payment_intent = Stripe::PaymentIntent.construct_from(id: "pi_123")
+      payment = create(:payment,
+        payment_method: payment_method,
+        response_code: stripe_payment_intent.id,
+        state: "failed")
+      event = SolidusStripe::Webhook::EventWithContextFactory.from_object(
+        payment_method: payment_method,
+        object: stripe_payment_intent,
+        type: "payment_intent.payment_failed",
+      ).solidus_stripe_object
+
+      described_class.new.fail_payment(event)
+
+      expect(payment.reload.state).to eq "failed"
+      expect(payment.log_entries.count).to be(0)
+    end
+  end
 end