Wait for Meilisearch Task

wait-for-task.ts

import MeiliSearch from 'meilisearch';

export type WaitForTaskOptions = {
  client: MeiliSearch;
  taskUid: number;
  retries?: number;
  retryDelay?: number;
  customErrorMessage?: string;
};

export async function waitForTask(options: WaitForTaskOptions) {
  const {
    client,
    taskUid,
    retries = 5,
    retryDelay = 1000,
    customErrorMessage = 'Task Failed',
  } = options;
  const task = await client.getTask(taskUid);
  const { status } = task;
  if (status === 'failed') throw new Error(customErrorMessage);
  if (status === 'enqueued' || status === 'processing') {
    await new Promise((resolve) => setTimeout(resolve, retryDelay));
    return await waitForTask({ client, taskUid, retries: retries - 1 });
  }
  return task;
}

export default waitForTask;

z-readme.md

Wait For Meilisearch Task

Usage example

import MeiliSearch from 'meilisearch';

import { waitForTask } from './wait-for-task';

export type InitIndexOptions = {
  client: MeiliSearch;
  indexName: string;
};

export async function initIndex({ client, indexName }: InitIndexOptions) {
  try {
    return await client.getIndex(indexName);
  } catch (error) {
    const task = await client.createIndex(indexName, {
      primaryKey: 'id',
    });

    await waitForTask({
      client,
      taskUid: task.taskUid,
      customErrorMessage: 'Failed to create index',
    });

    return await client.getIndex(indexName);
  }
}