sync method

Future<void> sync({ List<String>? cids, DateTime? lastSyncAt, })

Get the events missed while offline to sync the offline storage Will automatically fetch cids and lastSyncedAt if persistenceEnabled

Implementation

Future<void> sync({List<String>? cids, DateTime? lastSyncAt}) async {
  cids ??= await _chatPersistenceClient?.getChannelCids();
  if (cids == null || cids.isEmpty) {
    return;
  }

  lastSyncAt ??= await _chatPersistenceClient?.getLastSyncAt();
  if (lastSyncAt == null) {
    return;
  }

  try {
    final res = await _chatApi.general.sync(cids, lastSyncAt);
    final events = res.events
      ..sort((a, b) => a.createdAt.compareTo(b.createdAt));

    for (final event in events) {
      logger.fine('event.type: ${event.type}');
      final messageText = event.message?.text;
      if (messageText != null) {
        logger.fine('event.message.text: $messageText');
      }
      handleEvent(event);
    }

    final now = DateTime.now();
    _lastSyncedAt = now;
    _chatPersistenceClient?.updateLastSyncAt(now);
  } catch (e, stk) {
    logger.severe('Error during sync', e, stk);
  }
}