Custom code for Cloud function payment method, STRIPE CONNECT.

const functions = require('firebase-functions');

const admin = require("firebase-admin");

admin.initializeApp();

const axios = require('axios');

const stripe = require("stripe")(functions.config().stripe.token);

exports.stripeWebhook = functions.https.onRequest(async (req, res) => {

  try {

    const whSec = functions.config().stripe.payments_webhook_secret;

    // Verify the Stripe webhook event signature

    const event = stripe.webhooks.constructEvent(

      req.rawBody,

      req.headers["stripe-signature"],

      whSec

    );

    if (event.type === 'checkout.session.completed') {

      const session = event.data.object;

      const stripeAccountID = session.client_reference_id;

      const amountTotal = session.amount_total;

      const paymentIntent = session.payment_intent;

      const payeeRef = session.metadata.payeeRef;

      const payorRef = session.metadata.payorRef;

      const payeeUsername = session.metadata.payeeUsername;

      // Construct and send a transfer API call

      try {

        const transferResponse = await axios.post('https://api.stripe.com/v1/transfers', {

          amount: amountTotal,

          currency: 'usd',

          description: 'trush Tips',

          destination: stripeAccountID,

          // Add other relevant data

        }, {

headers: {

  'Authorization': Bearer ${functions.config().stripe.token},

  'Content-Type': 'application/x-www-form-urlencoded'

}

        });

        console.log(transferResponse.data);

        res.status(200).send('Tips transfer processed successfully');

        const transferID = transferResponse.data.id;

        // Update Firestore document with success information

        await admin.firestore().collection("tipOrPayout").doc().set({

          tipOrPayout: "tips", // Adjust field name to lowercase with underscores

          amount: amountTotal,

          paymentIntentID: paymentIntent,

          transferID: transferID,

          payeeUsername: payeeUsername,

          payeeRef: payeeRef,

          payorRef: payorRef,

          status: "Success", // Adjust to "Success" (capitalized first letter)

          refund: false,

        });

      } catch (transferApiError) {

        console.error('Transfer API call failed:', transferApiError);

        res.status(500).send('Error processing webhook, transfer API call failed');

        // Handle the refund API call and Firestore document update

        try {

          const refundResponse = await axios.post('https://api.stripe.com/v1/refunds', {

            payment_intent: paymentIntent,

            // Add other relevant data

          }, {

  headers: {

    'Authorization': Bearer ${functions.config().stripe.token},

    'Content-Type': 'application/x-www-form-urlencoded'

            }

          });

          console.log(refundResponse.data);

          // Update Firestore document with refund information

          await admin.firestore().collection("tipOrPayout").doc().set({

            tipOrPayout: "tips", // Adjust field name to lowercase with underscores

            amount: amountTotal, 

            paymentIntentID: paymentIntent,

            transferID: "n/a",

            payeeUsername: payeeUsername,

            payeeRef: payeeRef,

            payorRef: payorRef,

            status: "Refunded", // Adjust to "Refunded" (capitalized first letter)

            refund: false,

          });

        } catch (refundApiError) {

          console.error('Refund API call failed:', refundApiError);

          // Handle refund API call errors here

          // Update Firestore document with failed refund information

          await admin.firestore().collection("tipOrPayout").doc().set({

            tipOrPayout: "tips", // Adjust field name to lowercase with underscores

            amount: amountTotal,

            paymentIntentID: paymentIntent,

            transferID: "n/a",

            payeeUsername: payeeUsername,  

            payeeRef: payeeRef,

            payorRef: payorRef,

            status: "Failed", // Adjust to "Failed" (capitalized first letter)

            refund: true,

          });

        }

      }

    } else {

      res.status(400).send('Unhandled event type');

    }

  } catch (err) {

    console.error("Webhook signature verification failed:", err);

    res.sendStatus(400);

  }

});