fix(api): wait for Algolia meeting operations

Author: nicholaschiang

lib/api/algolia.ts

@@ -3,6 +3,7 @@ import {
   SaveObjectResponse,
   SetSettingsResponse,
 } from '@algolia/client-search';
+import { WaitablePromise } from '@algolia/client-common';
 import algoliasearch from 'algoliasearch';
 
 import clone from 'lib/utils/clone';
@@ -15,28 +16,26 @@ export const client = algoliasearch(algoliaId, algoliaKey);
 export function updateFilterableAttrs(
   indexId: string,
   attrs: string[]
-): Promise<SetSettingsResponse> {
+): WaitablePromise<SetSettingsResponse> {
   const idx = client.initIndex(`${process.env.APP_ENV as string}-${indexId}`);
   const attributesForFaceting = attrs.map((attr) => `filterOnly(${attr})`);
-  return (idx.setSettings({ attributesForFaceting }) as unknown) as Promise<
-    SetSettingsResponse
-  >;
+  return idx.setSettings({ attributesForFaceting });
 }
 
 export function deleteObj(
   indexId: string,
   objId: string
-): Promise<DeleteResponse> {
+): WaitablePromise<DeleteResponse> {
   const idx = client.initIndex(`${process.env.APP_ENV as string}-${indexId}`);
-  return (idx.deleteObject(objId) as unknown) as Promise<DeleteResponse>;
+  return idx.deleteObject(objId);
 }
 
 export default function index<T extends { toSearchHit: () => object }>(
   indexId: string,
   obj: T,
   tags?: string[]
-): Promise<SaveObjectResponse> {
+): WaitablePromise<SaveObjectResponse> {
   const idx = client.initIndex(`${process.env.APP_ENV as string}-${indexId}`);
   const idxObj = clone({ ...obj.toSearchHit(), _tags: tags });
-  return (idx.saveObject(idxObj) as unknown) as Promise<SaveObjectResponse>;
+  return idx.saveObject(idxObj);
 }

lib/api/create/meeting-search-obj.ts

@@ -7,7 +7,7 @@ import index from 'lib/api/algolia';
 export default async function createMeetingSearchObj(
   meeting: Meeting
 ): Promise<void> {
-  const [err] = await to(index('meetings', meeting));
+  const [err] = await to(index('meetings', meeting).wait());
   if (err) {
     const msg = `${err.name} saving meeting (${meeting.toString()}) to Algolia`;
     throw new APIError(`${msg}: ${err.message}`, 500);

lib/api/delete/meeting-search-obj.ts

@@ -6,7 +6,7 @@ import { deleteObj } from 'lib/api/algolia';
 export default async function deleteMeetingSearchObj(
   meetingId: string
 ): Promise<void> {
-  const [err] = await to(deleteObj('meetings', meetingId));
+  const [err] = await to(deleteObj('meetings', meetingId).wait());
   if (err) {
     const msg = `${err.name} deleting meeting (${meetingId}) from Algolia`;
     throw new APIError(`${msg}: ${err.message}`, 500);

lib/api/update/meeting-search-obj.ts

@@ -7,7 +7,7 @@ import index from 'lib/api/algolia';
 export default async function updateMeetingSearchObj(
   meeting: Meeting
 ): Promise<void> {
-  const [e] = await to(index('meetings', meeting));
+  const [e] = await to(index('meetings', meeting).wait());
   if (e) {
     const msg = `${e.name} updating meeting (${meeting.toString()}) in Algolia`;
     throw new APIError(`${msg}: ${e.message}`, 500);