Add email invoice trigger

package.json

@@ -1,6 +1,6 @@
 {
   "name": "cobot-zapier",
-  "version": "2.2.0",
+  "version": "2.2.1",
   "description": "",
   "main": "index.js",
   "scripts": {

src/test/triggers/triggerInvoiceCreated.test.ts

@@ -79,6 +79,11 @@ const invoiceResponse: InvoiceApiResponse = {
   },
 };
 
+const membership = {
+  id: "membership-1",
+  email: "[email protected]",
+};
+
 const appTester = createAppTester(App);
 nock.disableNetConnect();
 const trigger = App.triggers[triggerInvoiceCreated.key] as HookTrigger;
@@ -106,30 +111,36 @@ describe("triggerInvoiceCreated", () => {
     const userResponse: UserApiResponse = {
       included: [{ id: "space-1", attributes: { subdomain: "trial" } }],
     };
-    const scope = nock("https://api.cobot.me");
-    scope.get("/user?include=adminOf").reply(200, userResponse);
-    scope
+    const api2Scope = nock("https://api.cobot.me");
+    const api1Scope = nock("https://trial.cobot.me");
+    api2Scope.get("/user?include=adminOf").reply(200, userResponse);
+    api1Scope.get("/api/memberships/membership-1").reply(200, membership);
+    api2Scope
       .get(/\/spaces\/space-1\/invoices/)
       .reply(200, { data: [invoiceResponse] });
 
     const listRecentEvents = trigger.operation.performList;
 
     const results = await appTester(listRecentEvents as any, bundle as any);
-
+    expect(nock.isDone()).toBe(true);
     expect(results).toStrictEqual([
       {
         ...attributes,
         id: "1",
-        membershipId: "membership-1",
+        membership: {
+          membershipId: "membership-1",
+          email: "[email protected]",
+        },
       },
     ]);
   });
 
   it("triggers on new invoice", async () => {
     const bundle = prepareBundle();
-    const scope = nock("https://api.cobot.me");
-    scope.get("/invoices/12345").reply(200, { data: invoiceResponse });
-
+    const api1Scope = nock("https://trial.cobot.me");
+    const api2Scope = nock("https://api.cobot.me");
+    api2Scope.get("/invoices/12345").reply(200, { data: invoiceResponse });
+    api1Scope.get("/api/memberships/membership-1").reply(200, membership);
     const results = await appTester(
       triggerInvoiceCreated.operation.perform as any,
       bundle as any,
@@ -141,7 +152,10 @@ describe("triggerInvoiceCreated", () => {
       {
         ...attributes,
         id: "1",
-        membershipId: "membership-1",
+        membership: {
+          membershipId: "membership-1",
+          email: "[email protected]",
+        },
       },
     ]);
   });

src/triggers/triggerInvoiceCreated.ts

@@ -40,9 +40,11 @@ async function parsePayload(
   bundle: KontentBundle<{}>,
 ): Promise<InvoiceOutput[]> {
   const invoiceId = bundle.cleanedRequest.url.split("/").pop();
+  const api1MembershipsUrl =
+    new URL(bundle.cleanedRequest.url).origin + "/api/memberships";
   const response = await getInvoiceFromApi2(z, invoiceId);
   if (response) {
-    return [apiResponseToInvoiceOutput(response)];
+    return [await apiResponseToInvoiceOutput(z, response, api1MembershipsUrl)];
   } else {
     return [];
   }
@@ -69,7 +71,13 @@ const trigger: HookTrigger = {
       bundle: KontentBundle<SubscribeBundleInputType>,
     ): Promise<InvoiceOutput[]> => {
       const invoices = await listRecentInvoices(z, bundle);
-      return invoices.map((invoice) => apiResponseToInvoiceOutput(invoice));
+      const subdomain = bundle.inputData.subdomain;
+      const api1MembershipsUrl = `https://${subdomain}.cobot.me/api/memberships`;
+      const invoiceOutputPromises = invoices.map((invoice) =>
+        apiResponseToInvoiceOutput(z, invoice, api1MembershipsUrl),
+      );
+      const invoiceOutputs = await Promise.all(invoiceOutputPromises);
+      return invoiceOutputs;
     },
 
     sample: invoiceSample,

src/types/outputs.d.ts

@@ -58,7 +58,12 @@ export type MembershipOutput = {
   payment_method_name: string | null;
 };
 
+export type InvoiceMembershipOutput = {
+  membershipId: string;
+  email: string | null;
+};
+
 export type InvoiceOutput = BaseInvoiceProperties & {
-  membershipId?: string;
   id: string;
+  membership?: InvoiceMembershipOutput;
 };

src/utils/api-to-output.ts

@@ -11,7 +11,12 @@ import {
   MembershipOutput,
   InvoiceOutput,
 } from "../types/outputs";
-import { ExternalBookingWithResourceApiResponse } from "./api";
+import { ZObject } from "zapier-platform-core";
+import { get } from "lodash";
+import {
+  ExternalBookingWithResourceApiResponse,
+  loadMembershipEmailOnInvoice,
+} from "./api";
 
 export function apiResponseToMembershipOutput(
   membership: MembershipApiResponse,
@@ -27,14 +32,25 @@ export function apiResponseToMembershipOutput(
   };
 }
 
-export function apiResponseToInvoiceOutput(
+export async function apiResponseToInvoiceOutput(
+  z: ZObject,
   invoice: InvoiceApiResponse,
-): InvoiceOutput {
+  api1MembershipsUrl: string,
+): Promise<InvoiceOutput> {
   const attributes = invoice.attributes;
+  const membershipId = get(invoice, "relationships.membership.data.id");
+  if (!membershipId) {
+    return {
+      ...attributes,
+      id: invoice.id,
+    };
+  }
+  const url = `${api1MembershipsUrl}/${membershipId}`;
+  const membership = await loadMembershipEmailOnInvoice(z, url, membershipId);
   return {
     ...attributes,
     id: invoice.id,
-    membershipId: invoice.relationships?.membership?.data?.id ?? undefined,
+    membership,
   };
 }
 

src/utils/api.ts

@@ -16,6 +16,7 @@ import {
   UserApiResponse,
   InvoiceApiResponse,
 } from "../types/api-responses";
+import { InvoiceMembershipOutput } from "../types/outputs";
 
 type Space = {
   id: string;
@@ -166,6 +167,25 @@ export const listRecentInvoices = async (
   return response.data.data;
 };
 
+export const loadMembershipEmailOnInvoice = async (
+  z: ZObject,
+  membershipUrl: string,
+  membershipId: string,
+): Promise<InvoiceMembershipOutput> => {
+  const response = await z.request({
+    url: membershipUrl,
+    method: "GET",
+    headers: {
+      Accept: "application/vnd.api+json",
+    },
+  });
+  const email = response.data.email;
+  return {
+    email,
+    membershipId,
+  };
+};
+
 export const listRecentExternalBookings = async (
   z: ZObject,
   bundle: KontentBundle<SubscribeBundleInputType>,
@@ -244,7 +264,7 @@ export const getInvoiceFromApi2 = async (
   if (response.status === 404) {
     return null;
   }
-  return response.data.data as InvoiceApiResponse;
+  return response.data.data;
 };
 
 export const getExternalBooking = async (

src/utils/samples.ts

@@ -74,7 +74,10 @@ export const invoiceSample: InvoiceOutput = {
   taxId: "DE12345",
   taxIdName: "UID",
   customerNumber: "100",
-  membershipId: "c9a99a71ac8df98d29de357180d273d3",
+  membership: {
+    membershipId: "14c12f62ac8df98d29de357180d673e1",
+    email: "[email protected]",
+  },
   recipientAddress: {
     name: "Jane Smith",
     company: "Acme Inc.",