From d2b28095d9c125ca0871d770149f8ead6e72b29a Mon Sep 17 00:00:00 2001 From: Mohit Tejani Date: Sun, 14 Jan 2024 20:38:33 +0530 Subject: [PATCH] manage cursor from event struct --- src/event-engine/events.ts | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/src/event-engine/events.ts b/src/event-engine/events.ts index 70e7a1448..c0341d8f0 100644 --- a/src/event-engine/events.ts +++ b/src/event-engine/events.ts @@ -12,8 +12,10 @@ export const restore = createEvent( (channels: string[], groups: string[], timetoken: string, region?: number) => ({ channels, groups, - timetoken, - region, + cursor: { + timetoken: timetoken, + region: region ?? 0, + }, }), ); @@ -41,8 +43,10 @@ export const receiveReconnectGiveup = createEvent('RECEIVING_RECONNECT_GIVEUP', export const disconnect = createEvent('DISCONNECT', () => ({})); export const reconnect = createEvent('RECONNECT', (timetoken?: string, region?: number) => ({ - timetoken, - region, + cursor: { + timetoken: timetoken ?? '', + region: region ?? 0, + }, })); export const unsubscribeAll = createEvent('UNSUBSCRIBE_ALL', () => ({}));