@novu/headless: headlessService.fetchNotifications({onSuccess}) constantly receives latest state

const fetchNotifications = async (onPushNotifications: OnPushNotificationsHandler) => {
  if (!sessionInitialized) {
    throw new Error('Session is not initialized')
  }

  headlessService?.fetchNotifications({
    listener: () => {},
    onSuccess: (response: IPaginatedResponse<IMessage>) => {
      const { data } = response
      const notifications = unifyNotifications(data)
      onPushNotifications(notifications)
    },
    onError: (error) => {
      // eslint-disable-next-line no-console
      console.error('Failed to fetch notifications:', error)
    },
    query: { read: false },
    page: 0,
  })
}


initializeSession(userId, config.NovuIdentifier, novuSignature.toLocaleLowerCase())
    .then(() => {
      fetchNotifications(onPushNotifications)
      listenNotificationReceiveChange(() => {})
      return null
    })
    .catch((error: Error) => {
      console.error('Failed to initialize session:', error)
    })