Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
const stripe = require('stripe')('put-your-stripe-secret-key-here');
const express = require('express');
const cors = require('cors');
const app = express();
const fs = require('fs');
app.use(cors({
origin: '*'
}));
app.use(
"/webhook",
express.json({
verify: (req, res, buf) => {
req.rawBody = buf.toString();
},
})
);
app.use(express.json());
app.post('/create_customer', async (request, response) => {
const customerEmailAddress = request.body.customerEmailId;
const customer = await stripe.customers.create({
description: `${customerEmailAddress} via API`,
email: customerEmailAddress
});
console.log(customer);
let theCreatedCustomerId = customer.id;
response.send({
customerId: theCreatedCustomerId
});
});
app.post('/create_checkout_link', async (request, response) => {
const priceId = request.body.priceId;
const customerId = request.body.customerId;
const session = await stripe.checkout.sessions.create({
billing_address_collection: 'auto',
line_items: [
{
price: priceId,
quantity: 1,
},
],
mode: 'subscription',
success_url: `http://localhost:3000/?success=true`,
cancel_url: `http://localhost:3000?canceled=true`,
customer: customerId
});
console.log(session);
response.send({
url: session.url
});
});
app.post('/create_billing_portal_link', async (request, response) => {
const customerId = request.body.customerId;
const session = await stripe.billingPortal.sessions.create({
customer: customerId,
configuration: 'bpc_1MIO9GSICZrnQHl2SAecWs3K',
return_url: 'http://localhost:3000/?back_from=billing',
});
console.log(session);
response.send({
url: session.url
});
});
app.post(
'/webhook', express.raw(), (request, response) => {
let event = request.body;
const endpointSecret = 'whsec_PUT_YOUR_END_POINT_SECRET_HERE';
if (endpointSecret) {
const signature = request.headers['stripe-signature'];
try {
event = stripe.webhooks.constructEvent(
request.rawBody,
signature,
endpointSecret
);
} catch (err) {
console.log(`⚠️ Webhook signature verification failed.`, err.message);
return response.sendStatus(400);
}
}
const eventType = event.type;
const unixTimeStamp = Math.floor(Date.now() / 1000);
const completeEventBody = event;
let fileName = `${unixTimeStamp}-${eventType}`;
let webhookFileContent = JSON.stringify(completeEventBody, null, 4);
fs.appendFile(`./webhook_events/${fileName}.json`, webhookFileContent, function (err) {
if (err) throw err;
console.log(`Webhook event file saved with name: ${fileName}!`);
});
response.send();
}
);
app.listen(4242);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment