initFetch method

void initFetch(NIMMessage? anchor)

Implementation

void initFetch(NIMMessage? anchor) async {
  _logI('initFetch -->> anchor:${anchor?.content}');
  late NIMMessage message;
  credibleTimestamp =
      await ChatMessageRepo.queryRoamMsgTimestamps(sessionId, sessionType);
  _logI('queryRoamMsgHasMoreTime -->> credibleTimestamp:$credibleTimestamp');
  hasMoreForwardMessages = true;
  if (anchor == null) {
    hasMoreNewerMessages = false;
    var result = await MessageBuilder.createEmptyMessage(
        sessionId: sessionId,
        sessionType: sessionType,
        timestamp: DateTime.now().millisecondsSinceEpoch);
    if (result.isSuccess && result.data != null) {
      message = result.data!;
      _fetchMoreMessage(message, QueryDirection.QUERY_OLD);
    }
  } else {
    hasMoreNewerMessages = true;
    message = anchor;
    fetchMessageListBothDirect(message);
  }
}