Function sync

packages/typesense/src/sync.ts:15–32

({
  accountId,
  logger,
}: {
  accountId: string;
  logger: Logger;
})

import { accounts, prisma } from '@linen/database';

export async function sync({
  accountId,
  logger,
}: {
  accountId: string;
  logger: Logger;
}) {
  const accountSettings = await getAccountSettings(accountId, logger);
  if (!accountSettings) return;
  await syncUpdatedThreads(
    accountSettings.searchSettings,
    accountSettings.account,
    logger
  );

  // set cursor for next sync job
  await persistEndFlag(accountSettings.searchSettings, accountId);
}

async function syncUpdatedThreads(
  searchSettings: SerializedSearchSettings,