Function pushToTypesense

packages/typesense/src/utils/shared.ts:108–162

({
  threads,
  is_restrict,
  logger,
  anonymize,
}: {
  threads: (threads & {
    messages: (messages & {
      author: users | null;
      reactions: messageReactions[];
      attachments: messageAttachments[];
      mentions: (mentions & {
        users: users | null;
      })[];
    })[];
    channel: channels & {
      memberships: {
        usersId: string;
        user: {
          authsId: string | null;
        };
      }[];
    };
  })[];
  is_restrict: boolean;
  logger: Logger;
  anonymize?: AnonymizeType;
})

}

export async function pushToTypesense({
  threads,
  is_restrict,
  logger,
  anonymize,
}: {
  threads: (threads & {
    messages: (messages & {
      author: users | null;
      reactions: messageReactions[];
      attachments: messageAttachments[];
      mentions: (mentions & {
        users: users | null;
      })[];
    })[];
    channel: channels & {
      memberships: {
        usersId: string;
        user: {
          authsId: string | null;
        };
      }[];
    };
  })[];
  is_restrict: boolean;
  logger: Logger;
  anonymize?: AnonymizeType;
}) {
  const documents = threads
    .map((t) =>
      serializer({
        thread: serializeThread(
          anonymize ? anonymizeMessages(t, anonymize) : t
        ),
        is_public: t.channel.type === 'PUBLIC',
        is_restrict,
        accessible_to: t.channel.memberships
          .filter((m) => !!m.user.authsId)
          .map((m) => m.usersId),
      })
    )
    .filter((t) => !!t.body);

  await client
    .collections(collectionSchema.name)
    .documents()
    .import(documents, { action: 'upsert' })
    .catch((error: any) => {
      logger.error(
        error.importResults
          ?.filter((result: any) => !result.success)
          ?.map((result: any) => result.error) || error
      );
    });
}

export async function createUserKeyAndPersist({
  account,