Method upsertMany

src/repositories/event-repository.ts:312–339

(events: Event[])

  }

  public async upsertMany(events: Event[]): Promise<number> {
    if (!events.length) {
      return 0
    }

    const rows = events.map((event) => this.toUpsertRow(event))

    return this.masterDbClient('events')
      .insert(rows)
      .onConflict(
        this.masterDbClient.raw(
          '(event_pubkey, event_kind, event_deduplication) WHERE (event_kind = 0 OR event_kind = 3 OR event_kind = 41 OR (event_kind >= 10000 AND event_kind < 20000)) OR (event_kind >= 30000 AND event_kind < 40000)',
        ),
      )
      .merge([
        'deleted_at',
        'event_content',
        'event_created_at',
        'event_id',
        'event_signature',
        'event_tags',
        'expires_at',
      ])
      .whereRaw(
        '("events"."event_created_at" < "excluded"."event_created_at" or ("events"."event_created_at" = "excluded"."event_created_at" and "events"."event_id" > "excluded"."event_id"))',
      )
      .then(prop('rowCount') as () => number, () => 0)
  }

  private toUpsertRow(event: Event) {
    const toJSON = (input: any) => JSON.stringify(input)