Method upsert

src/repositories/event-repository.ts:277–310

(event: Event)

  }

  public upsert(event: Event): Promise<number> {
    logger('upserting event: %o', event)

    const row = this.toUpsertRow(event)

    const query = this.masterDbClient('events')
      .insert(row)
      // NIP-16: Replaceable Events
      // NIP-33: Parameterized Replaceable Events
      .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(omit(['event_pubkey', 'event_kind', 'event_deduplication'])(row))
      .where(function () {
        this.where('events.event_created_at', '<', row.event_created_at).orWhere(function () {
          this.where('events.event_created_at', '=', row.event_created_at).andWhere(
            'events.event_id',
            '>',
            row.event_id,
          )
        })
      })

    return {
      then: <T1, T2>(
        onfulfilled: (value: number) => T1 | PromiseLike<T1>,
        onrejected: (reason: any) => T2 | PromiseLike<T2>,
      ) => query.then(prop('rowCount') as () => number).then(onfulfilled, onrejected),
      catch: <T>(onrejected: (reason: any) => T | PromiseLike<T>) => query.catch(onrejected),
      toString: (): string => query.toString(),
    } as Promise<number>
  }

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