gistfile1.txt

class AptosEvent {
  constructor(
    readonly client: AptosClient,
    readonly eventHandlerOwner: HexString,
    readonly eventStruct: string,
    readonly eventHandlerName: string
  ) {}

  async onTrigger(callback: (e: any) => any) {
    // Get the start sequence number in the EVENT STREAM, defaulting to the latest event.
    const [{ sequence_number }] = await this.client.getEventsByEventHandle(
      this.eventHandlerOwner,
      this.eventStruct,
      this.eventHandlerName,
      { limit: 1 }
    );

    // type for this is string for some reason
    let lastSequenceNumber = sequence_number;

    setInterval(async () => {
      const events = await this.client.getEventsByEventHandle(
        this.eventHandlerOwner,
        this.eventStruct,
        this.eventHandlerName,
        {
          start: Number(lastSequenceNumber) + 1,
        }
      );
      for (let e of events) {
        // increment sequence number
        lastSequenceNumber = e.sequence_number;

        // fire off the callback for all new events
        await callback(e);
      }
    }, 1000);
  }
}