Flutter Firebase：使用FieldValue.serverTimestamp()查询时如何处理空异常？

我在Dart中尝试运行以下查询，用FieldValue.serverTimestamp()过滤未过期的文档：

Stream<EncountersData> getEncountersStream() {
  return FirebaseFirestore.instance.collection('test_encounters').where(
    'expiration_time',
    isGreaterThan: FieldValue.serverTimestamp(), // 预期等同于DateTime.now()
  )
  .snapshots()
  .map(encounterDataFromSnapshot);
}

// 调用处
final encounterStream = getEncountersStream();

运行后在messages.pigeon.dart中出现类型转换错误（具体表现为无法将null值转换为DateTime类型）。

我了解到错误原因是FieldValue.serverTimestamp()在本地缓存的初始快照中会被解析为null，导致过滤后的文档里expiration_time字段出现null值，进而在encounterDataFromSnapshot转换时触发错误。我试过在多个层级加try-catch，但问题依然存在。虽然见过用.listen替代.map的修复方案，但希望保留当前代码结构，因为调用方依赖这个Stream类型的返回值，而且在加入这个过滤器前代码运行正常。

修复方案（保留原Stream结构） #

方案1：在流中过滤无效文档

修改流处理逻辑，先过滤掉expiration_time为null的文档，再进行转换：

Stream<List<EncountersData>> getEncountersStream() {
  return FirebaseFirestore.instance.collection('test_encounters').where(
    'expiration_time',
    isGreaterThan: FieldValue.serverTimestamp(),
  )
  .snapshots()
  .map((querySnapshot) {
    // 过滤掉expiration_time为null的文档
    final validDocs = querySnapshot.docs.where((doc) => doc['expiration_time'] != null);
    // 将有效文档转换为EncountersData列表
    return validDocs.map((doc) => encounterDataFromSnapshot(doc)).toList();
  });
}

注：如果原代码期望返回单个EncountersData而非列表，需根据业务逻辑调整过滤后的文档处理逻辑

方案2：在转换函数中处理null值

修改encounterDataFromSnapshot函数兼容null值，再在流中过滤掉无效结果：

// 先修改转换函数，允许返回null
EncountersData? encounterDataFromSnapshot(DocumentSnapshot doc) {
  final data = doc.data() as Map<String, dynamic>;
  final expirationTime = data['expiration_time'] as DateTime?;
  // 若expiration_time为null，直接返回null
  if (expirationTime == null) return null;
  // 其他字段转换逻辑
  return EncountersData(
    expirationTime: expirationTime,
    // 填充其他字段
  );
}

// 再修改流处理逻辑
Stream<EncountersData> getEncountersStream() {
  return FirebaseFirestore.instance.collection('test_encounters').where(
    'expiration_time',
    isGreaterThan: FieldValue.serverTimestamp(),
  )
  .snapshots()
  .expand((snapshot) => snapshot.docs) // 将QuerySnapshot展开为单个DocumentSnapshot的流
  .map(encounterDataFromSnapshot)
  .where((data) => data != null) // 过滤掉null结果
  .cast<EncountersData>(); // 转换为非null的Stream类型
}

方案3：使用本地时间替代（适合对时间精度要求不高的场景）

如果不需要严格依赖服务器时间，可以直接用本地DateTime.now()作为过滤条件，避免null问题：

Stream<EncountersData> getEncountersStream() {
  return FirebaseFirestore.instance.collection('test_encounters').where(
    'expiration_time',
    isGreaterThan: DateTime.now(),
  )
  .snapshots()
  .map(encounterDataFromSnapshot);
}

内容的提问来源于stack exchange，提问作者exe163