Function createEventBatchPersister

src/services/event-import-service.ts:91–141

(eventRepository: IEventRepository)

export const createEventBatchPersister =
  (eventRepository: IEventRepository) =>
  async (events: Event[]): Promise<number> => {
    if (!events.length) {
      return 0
    }

    let inserted = 0

    const regularEvents: Event[] = []
    const replaceableEvents: Event[] = []

    for (const event of events) {
      if (isEphemeralEvent(event)) {
        continue
      }

      if (isDeleteEvent(event)) {
        // flush pending batches before applying deletes
        inserted += await eventRepository.createMany(regularEvents.splice(0))
        inserted += await eventRepository.upsertMany(replaceableEvents.splice(0))

        const eventIdsToDelete = event.tags.reduce(
          (ids, tag) =>
            tag.length >= 2 && tag[0] === EventTags.Event && /^[0-9a-f]{64}$/.test(tag[1]) ? [...ids, tag[1]] : ids,
          [] as string[],
        )

        if (eventIdsToDelete.length) {
          await eventRepository.deleteByPubkeyAndIds(event.pubkey, eventIdsToDelete)
        }

        inserted += await eventRepository.create(enrichEventMetadata(event))
        continue
      }

      const enrichedEvent = enrichEventMetadata(event)

      if (isReplaceableEvent(event) || isParameterizedReplaceableEvent(event)) {
        replaceableEvents.push(enrichedEvent)
        continue
      }

      regularEvents.push(enrichedEvent)
    }

    // flush remaining
    inserted += await eventRepository.createMany(regularEvents)
    inserted += await eventRepository.upsertMany(replaceableEvents)

    return inserted
  }

export class EventImportService {
  public constructor(