Metered GraphQL API usage billing with Stripe

• Stripe Metered billing
• Bull
• Redis

const REDIS_URL = process.env.REDIS_URL || "redis://127.0.0.1:6379";

const logUsageQueue = new Queue("logUsageQueue", REDIS_URL);

app.use(async (req, res, next) => {
  console.log(req?.headers?.authorization);

  await logUsageQueue.add({
    subscriptionItemId: req.headers["authorization"],
  });

  next();
});

const Queue = require("bull");
const throng = require("throng");
const stripe = require("stripe")(process.env.STRIPE_SECRET_KEY);

const workers = process.env.WEB_CONCURRENCY || 2;

const REDIS_URL = process.env.REDIS_URL || "redis://localhost:6379";

function start() {
  const logUsageQueue = new Queue("logUsuageQueue", REDIS_URL);

  logUsageQueue.process(async (job) => {
    const { subscriptionItemId } = job.data;

    try {
      await stripe.subscriptionItems.createUsageRecord(subscriptionItemId, {
        quantity: 1,
      });
    } catch (err) {
      console.error(err);
    }
  });
}

throng({ workers, start });