fix event poller

massalabs · Aug 29, 2024 · 2fd058a · 2fd058a
1 parent 6e9c168
commit 2fd058a
Show file tree

Hide file tree

Showing 2 changed files with 26 additions and 2 deletions.
diff --git a/src/events/eventsPoller.ts b/src/events/eventsPoller.ts
@@ -46,8 +46,6 @@ export class EventPoller extends EventEmitter {
     try {
       if (this.lastSlot) {
         this.eventsFilter.start = nextSlot(this.lastSlot)
-      } else {
-        this.lastSlot = this.eventsFilter.start || nextSlot(this.lastSlot)
       }
 
       const events = await this.provider.getEvents(this.eventsFilter)

diff --git a/test/integration/events.spec.ts b/test/integration/events.spec.ts
@@ -67,4 +67,30 @@ describe('SC Event tests', () => {
     })
     stopPolling()
   })
+
+  test('poll transfer event without start slot', async () => {
+    const amount = 1_000n
+
+    const operation = await usdcContract.transfer(
+      'AU1wN8rn4SkwYSTDF3dHFY4U28KtsqKL1NnEjDZhHnHEy6cEQm53',
+      amount
+    )
+    await operation.waitSpeculativeExecution()
+
+    let events: SCEvent[] = []
+
+    const filter: EventFilter = {
+      operationId: operation.id,
+    }
+
+    const { stopPolling } = EventPoller.start(provider, filter, (data) => {
+      events = data
+    })
+
+    await waitForExpect(() => {
+      expect(events.length).toEqual(1)
+      expect(events[0].data).toEqual('TRANSFER SUCCESS')
+    })
+    stopPolling()
+  })
 })