✨ Subscriptions and pricing

Author: AnandChowdhary

src/helpers/stripe.ts

@@ -43,3 +43,24 @@ export const updateStripeCustomer = async (
 export const getStripeInvoices = async (id: string) => {
   return await stripe.invoices.list({ customer: id });
 };
+
+/**
+ * Get the details of a customer
+ * @param id - Stripe customer ID
+ */
+export const getStripeSubscriptions = async (id: string) => {
+  return await stripe.subscriptions.list({ customer: id });
+};
+
+/**
+ * Get the details of a customer
+ * @param id - Stripe customer ID
+ */
+export const getStripeProductPricing = async (product: string) => {
+  const plans = await stripe.plans.list({ product });
+  // If you have a custom plan for a client, don't show that
+  plans.data = plans.data.filter(
+    plan => !(plan.nickname || "").toLowerCase().startsWith("custom plan")
+  );
+  return plans;
+};

src/rest/organization.ts

@@ -23,7 +23,9 @@ import {
   getStripeCustomer,
   createStripeCustomer,
   updateStripeCustomer,
-  getStripeInvoices
+  getStripeInvoices,
+  getStripeSubscriptions,
+  getStripeProductPricing
 } from "../helpers/stripe";
 import { customers } from "stripe";
 
@@ -161,3 +163,30 @@ export const getOrganizationInvoicesForUser = async (
   }
   throw new Error(ErrorCode.INSUFFICIENT_PERMISSION);
 };
+
+export const getOrganizationSubscriptionsForUser = async (
+  userId: number,
+  organizationId: number
+) => {
+  if (await can(userId, Authorizations.READ, "organization", organizationId)) {
+    const organization = await getOrganization(organizationId);
+    if (organization.stripeCustomerId)
+      return await getStripeSubscriptions(organization.stripeCustomerId);
+    throw new Error(ErrorCode.STRIPE_NO_CUSTOMER);
+  }
+  throw new Error(ErrorCode.INSUFFICIENT_PERMISSION);
+};
+
+export const getOrganizationPricingPlansForUser = async (
+  userId: number,
+  organizationId: number,
+  productId: string
+) => {
+  if (await can(userId, Authorizations.READ, "organization", organizationId)) {
+    const organization = await getOrganization(organizationId);
+    if (organization.stripeCustomerId)
+      return await getStripeProductPricing(productId);
+    throw new Error(ErrorCode.STRIPE_NO_CUSTOMER);
+  }
+  throw new Error(ErrorCode.INSUFFICIENT_PERMISSION);
+};

src/routes/index.ts

@@ -22,7 +22,9 @@ import {
   routeOrganizationGet,
   routeOrganizationBillingGet,
   routeOrganizationBillingUpdate,
-  routeOrganizationInvoicesGet
+  routeOrganizationInvoicesGet,
+  routeOrganizationSubscriptionsGet,
+  routeOrganizationPricingPlansGet
 } from "./organizations";
 import { authHandler } from "../helpers/middleware";
 import {
@@ -154,6 +156,16 @@ const routesOrganization = (app: Application) => {
     authHandler,
     asyncHandler(routeOrganizationInvoicesGet)
   );
+  app.get(
+    "/organizations/:id/subscriptions",
+    authHandler,
+    asyncHandler(routeOrganizationSubscriptionsGet)
+  );
+  app.get(
+    "/organizations/:id/pricing/:product",
+    authHandler,
+    asyncHandler(routeOrganizationPricingPlansGet)
+  );
 };
 
 const routesMembership = (app: Application) => {

src/routes/organizations.ts

@@ -6,7 +6,9 @@ import {
   getOrganizationForUser,
   getOrganizationBillingForUser,
   updateOrganizationBillingForUser,
-  getOrganizationInvoicesForUser
+  getOrganizationInvoicesForUser,
+  getOrganizationSubscriptionsForUser,
+  getOrganizationPricingPlansForUser
 } from "../rest/organization";
 import { ErrorCode } from "../interfaces/enum";
 
@@ -79,3 +81,30 @@ export const routeOrganizationInvoicesGet = async (
     await getOrganizationInvoicesForUser(res.locals.token.id, req.params.id)
   );
 };
+
+export const routeOrganizationSubscriptionsGet = async (
+  req: Request,
+  res: Response
+) => {
+  res.json(
+    await getOrganizationSubscriptionsForUser(
+      res.locals.token.id,
+      req.params.id
+    )
+  );
+};
+
+export const routeOrganizationPricingPlansGet = async (
+  req: Request,
+  res: Response
+) => {
+  const product = req.params.product;
+  if (!product) throw new Error(ErrorCode.MISSING_FIELD);
+  res.json(
+    await getOrganizationPricingPlansForUser(
+      res.locals.token.id,
+      req.params.id,
+      product
+    )
+  );
+};