tmp subscription item

livepeer · Jun 29, 2023 · 3056fe5 · 3056fe5
1 parent ed869ef
commit 3056fe5
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/packages/api/src/controllers/stripe.ts b/packages/api/src/controllers/stripe.ts
@@ -116,12 +116,16 @@ app.post("/webhook", async (req, res) => {
       );
       let overUsage = await calculateOverUsage(user.stripeProductId, usage);
 
+      const subscriptionItems = await req.stripe.subscriptionItems.list({
+        subscription: user.stripeCustomerSubscriptionId,
+      });
+
       // Invoice items based on overusage
       await Promise.all(
         products[user.stripeProductId].usage.map(async (product) => {
           if (product.name === "Transcoding") {
             await req.stripe.subscriptionItems.createUsageRecord(
-              "si_I3oUKEe6JSoTkO",
+              subscriptionItems[0],
               {
                 quantity: overUsage.TotalUsageMins,
                 timestamp: new Date().getTime() / 1000,
@@ -130,7 +134,7 @@ app.post("/webhook", async (req, res) => {
             );
           } else if (product.name === "Streaming") {
             await req.stripe.subscriptionItems.createUsageRecord(
-              "si_I3oUKEe6JSoTkO",
+              subscriptionItems[0],
               {
                 quantity: overUsage.DeliveryUsageMins,
                 timestamp: new Date().getTime() / 1000,
@@ -139,7 +143,7 @@ app.post("/webhook", async (req, res) => {
             );
           } else if (product.name === "Storage") {
             await req.stripe.subscriptionItems.createUsageRecord(
-              "si_I3oUKEe6JSoTkO",
+              subscriptionItems[0],
               {
                 quantity: overUsage.StorageUsageMins,
                 timestamp: new Date().getTime() / 1000,