Stripe In Practice Course

Author: Your Name

server/.env

@@ -3,3 +3,4 @@ STRIPE_PUBLIC_KEY="pk_test_MgTu31Ar1S9gLWcmCqnelpyD"
 SERVICE_ACCOUNT_FILE_NAME="stripe-course-recording-ebbda60a91a3.json"
 PROJECT_ID="stripe-course-recording"
 FIRESTORE_DATABASE_URL="https://stripe-course-recording.firebaseio.com"
+STRIPE_WEBHOOK_SECRET=""

server/server.ts

@@ -3,6 +3,7 @@ import * as express from 'express';
 import {Application} from "express";
 import {createCheckoutSession} from './checkout.route';
 import {getUserMiddleware} from './get-user.middleware';
+import {stripeWebhooks} from './stripe-webhooks.route';
 
 
 
@@ -19,6 +20,9 @@ export function initServer() {
     app.route("/api/checkout").post(
         bodyParser.json(), getUserMiddleware, createCheckoutSession);
 
+    app.route("/stripe-webhooks").post(
+        bodyParser.raw({type:'application/json'}), stripeWebhooks);
+
     const PORT = process.env.PORT || 9000;
 
     app.listen(PORT, () => {

server/stripe-webhooks.route.ts

@@ -0,0 +1,28 @@
+
+import {Request, Response} from 'express';
+
+const stripe = require('stripe')(process.env.STRIPE_SECRET_KEY);
+
+
+export async function stripeWebhooks(req: Request, res:Response) {
+
+    try {
+
+        const signature = req.headers["stripe-signature"];
+
+        const event = stripe.webhooks.constructEvent(
+            req.body, signature, process.env.STRIPE_WEBHOOK_SECRET);
+
+        if (event.type == "checkout.session.completed") {
+            const session = event.data.object;
+            console.log(session);
+        }
+
+        res.json({received:true});
+
+    }
+    catch(err) {
+        console.log('Error processing webhook event, reason: ', err);
+        return res.status(400).send(`Webhook Error: ${err.message}`);
+    }
+}