✨ Support for invoices

Author: AnandChowdhary

src/helpers/stripe.ts

@@ -18,7 +18,10 @@ export const createStripeCustomer = async (
   organizationId: number,
   customer: Stripe.customers.ICustomerCardSourceCreationOptions
 ) => {
-  const created = await stripe.customers.create(customer);
+  const created = await stripe.customers.create({
+    ...customer,
+    metadata: { organizationId }
+  });
   await updateOrganization(organizationId, { stripeCustomerId: created.id });
   return created;
 };
@@ -32,3 +35,11 @@ export const updateStripeCustomer = async (
 ) => {
   return await stripe.customers.update(id, customer);
 };
+
+/**
+ * Get the details of a customer
+ * @param id - Stripe customer ID
+ */
+export const getStripeInvoices = async (id: string) => {
+  return await stripe.invoices.list({ customer: id });
+};

src/rest/organization.ts

@@ -22,7 +22,8 @@ import { can } from "../helpers/authorization";
 import {
   getStripeCustomer,
   createStripeCustomer,
-  updateStripeCustomer
+  updateStripeCustomer,
+  getStripeInvoices
 } from "../helpers/stripe";
 import { customers } from "stripe";
 
@@ -147,3 +148,16 @@ export const updateOrganizationBillingForUser = async (
   }
   throw new Error(ErrorCode.INSUFFICIENT_PERMISSION);
 };
+
+export const getOrganizationInvoicesForUser = async (
+  userId: number,
+  organizationId: number
+) => {
+  if (await can(userId, Authorizations.READ, "organization", organizationId)) {
+    const organization = await getOrganization(organizationId);
+    if (organization.stripeCustomerId)
+      return await getStripeInvoices(organization.stripeCustomerId);
+    throw new Error(ErrorCode.STRIPE_NO_CUSTOMER);
+  }
+  throw new Error(ErrorCode.INSUFFICIENT_PERMISSION);
+};

src/routes/index.ts

@@ -21,7 +21,8 @@ import {
   routeOrganizationDelete,
   routeOrganizationGet,
   routeOrganizationBillingGet,
-  routeOrganizationBillingUpdate
+  routeOrganizationBillingUpdate,
+  routeOrganizationInvoicesGet
 } from "./organizations";
 import { authHandler } from "../helpers/middleware";
 import {
@@ -146,6 +147,11 @@ const routesOrganization = (app: Application) => {
     authHandler,
     asyncHandler(routeOrganizationBillingUpdate)
   );
+  app.get(
+    "/organizations/:id/invoices",
+    authHandler,
+    asyncHandler(routeOrganizationInvoicesGet)
+  );
 };
 
 const routesMembership = (app: Application) => {

src/routes/organizations.ts

@@ -5,7 +5,8 @@ import {
   deleteOrganizationForUser,
   getOrganizationForUser,
   getOrganizationBillingForUser,
-  updateOrganizationBillingForUser
+  updateOrganizationBillingForUser,
+  getOrganizationInvoicesForUser
 } from "../rest/organization";
 import { ErrorCode } from "../interfaces/enum";
 
@@ -52,11 +53,9 @@ export const routeOrganizationBillingGet = async (
   req: Request,
   res: Response
 ) => {
-  const billing = await getOrganizationBillingForUser(
-    res.locals.token.id,
-    req.params.id
+  res.json(
+    await getOrganizationBillingForUser(res.locals.token.id, req.params.id)
   );
-  res.json(billing);
 };
 
 export const routeOrganizationBillingUpdate = async (
@@ -71,3 +70,12 @@ export const routeOrganizationBillingUpdate = async (
   );
   res.json({ updated: true });
 };
+
+export const routeOrganizationInvoicesGet = async (
+  req: Request,
+  res: Response
+) => {
+  res.json(
+    await getOrganizationInvoicesForUser(res.locals.token.id, req.params.id)
+  );
+};