Function typesenseOnThreadCreation

packages/queue/src/tasks/typesense.ts:276–294

(
  payload: any,
  helpers: JobHelpers
)

};

export const typesenseOnThreadCreation = async (
  payload: any,
  helpers: JobHelpers
) => {
  const logger = new Logger(helpers.logger);
  logger.info(payload);

  const parsedPayload = z
    .object({
      accountId: z.string().uuid(),
      threadId: z.string().uuid(),
    })
    .parse(payload);

  await handleThreadCreation({
    ...parsedPayload,
    logger,
  });
};

export const typesenseOnThreadUpdate = async (
  payload: any,