From 377040afefad2a20a315240a5f5fe6241004a034 Mon Sep 17 00:00:00 2001
From: Alexandre Roux <alex@tekartik.com>
Date: Wed, 17 Jul 2024 02:32:34 +0200
Subject: [PATCH] debugging snapshot conversion

---
 .../lib/src/v2/firestore_extension.dart       | 31 +++++++++++++------
 1 file changed, 21 insertions(+), 10 deletions(-)

diff --git a/app_cv_firestore/lib/src/v2/firestore_extension.dart b/app_cv_firestore/lib/src/v2/firestore_extension.dart
index 34f6df6..7dcaf52 100644
--- a/app_cv_firestore/lib/src/v2/firestore_extension.dart
+++ b/app_cv_firestore/lib/src/v2/firestore_extension.dart
@@ -1,8 +1,8 @@
-import 'dart:async';
-
 import 'package:tekartik_app_cv_firestore/app_cv_firestore_v2.dart';
 import 'package:tekartik_app_cv_firestore/src/v2/cv_document.dart'
     show CvFirestoreDocumentPrvExt;
+import 'package:tekartik_common_utils/common_utils_import.dart';
+import 'package:tekartik_common_utils/foundation/constants.dart';
 import 'package:tekartik_common_utils/list_utils.dart';
 import 'package:tekartik_firebase_firestore/firestore.dart';
 import 'package:tekartik_firebase_firestore/utils/track_changes_support.dart';
@@ -241,19 +241,30 @@ extension CvFirestoreDocumentReferenceExt on DocumentReference {
     return (await get()).cv();
   }
 
+  StreamTransformer<DocumentSnapshot, T>
+      _snapshotTransformer<T extends CvFirestoreDocument>() =>
+          StreamTransformer<DocumentSnapshot, T>.fromHandlers(
+              handleData: (data, sink) {
+            try {
+              var converted = data.cv<T>();
+              sink.add(converted);
+              // devPrint('cvOnSnapshot $converted');
+            } catch (e) {
+              if (kDebugMode) {
+                print('cvOnSnapshot.error: $e');
+              }
+              rethrow;
+            }
+          });
+
   /// on snapshots
-  Stream<T> cvOnSnapshot<T extends CvFirestoreDocument>() => onSnapshot()
-          .transform(StreamTransformer.fromHandlers(handleData: (data, sink) {
-        sink.add(data.cv<T>());
-      }));
+  Stream<T> cvOnSnapshot<T extends CvFirestoreDocument>() =>
+      onSnapshot().transform(_snapshotTransformer<T>());
 
   /// on snapshots
   Stream<T> cvOnSnapshotSupport<T extends CvFirestoreDocument>(
           {TrackChangesPullOptions? options}) =>
-      onSnapshotSupport(options: options)
-          .transform(StreamTransformer.fromHandlers(handleData: (data, sink) {
-        sink.add(data.cv<T>());
-      }));
+      onSnapshotSupport(options: options).transform(_snapshotTransformer<T>());
 }
 
 /// Easy extension