ParseLiveListElementSnapshot added

example_livelist/lib/application_constants.dart

@@ -1,6 +1,6 @@
 const String keyApplicationName = '';
 const String keyParseApplicationId = '';
-const String keyParseMasterKey = '';
+const String keyParseClientKey = '';
 const String keyParseServerUrl = '';
 const String keyParseLiveServerUrl = '';
 const bool keyDebug = true;

example_livelist/lib/main.dart

@@ -23,8 +23,8 @@ class _MyAppState extends State<MyApp> {
         initFailed = !success;
         if (success)
           _queryBuilder = QueryBuilder<ParseObject>(ParseObject('Test'))
-            ..orderByAscending('order');
-        ;
+            ..orderByAscending('order')
+            ..whereNotEqualTo('show', false);
       });
     }).catchError((dynamic _) {
       setState(() {
@@ -80,31 +80,32 @@ class _MyAppState extends State<MyApp> {
           child: ParseLiveListWidget<ParseObject>(
               query: _queryBuilder,
               duration: const Duration(seconds: 1),
-              childBuilder:
-                  (BuildContext context, bool failed, ParseObject loadedData) {
-                if (failed) {
+              childBuilder: (BuildContext context,
+                  ParseLiveListElementSnapshot<ParseObject> snapshot) {
+                if (snapshot.failed) {
                   return const Text('something went wrong!');
-                } else if (loadedData != null) {
+                } else if (snapshot.hasData) {
                   return ListTile(
                     title: Row(
                       children: <Widget>[
                         Flexible(
-                          child: Text(loadedData.get<int>('order').toString()),
+                          child: Text(
+                              snapshot.loadedData.get<int>('order').toString()),
                           flex: 1,
                         ),
                         Flexible(
                           child: Container(
                             alignment: Alignment.center,
                             child: Text(
-                              loadedData.get<String>('text'),
+                              snapshot.loadedData.get<String>('text'),
                             ),
                           ),
                           flex: 10,
                         ),
                       ],
                     ),
                     onLongPress: () {
-                      objectFormKey.currentState.setObject(loadedData);
+                      objectFormKey.currentState.setObject(snapshot.loadedData);
                     },
                   );
                 } else {
@@ -179,6 +180,7 @@ class _ObjectFormState extends State<ObjectForm> {
                     setState(() {
                       _formKey.currentState.save();
                       final ParseObject object = _currentObject;
+                      //Delay to highlight the animation.
                       Future<void>.delayed(const Duration(seconds: 1))
                           .then((_) {
                         object.save();

lib/src/utils/parse_live_list.dart

@@ -160,27 +160,28 @@ class ParseLiveList<T extends ParseObject> {
     for (int i = 0; i < _list.length; i++) {
       if (after(object, _list[i].object) != true) {
         _list.insert(i, ParseLiveListElement<T>(object, loaded: loaded));
-        _eventStreamController.sink.add(ParseLiveListAddEvent<T>(i, object));
+        _eventStreamController.sink.add(ParseLiveListAddEvent<T>(
+            i, object?.clone(object?.toJson(full: true))));
         return;
       }
     }
     _list.add(ParseLiveListElement<T>(object, loaded: loaded));
-    _eventStreamController.sink
-        .add(ParseLiveListAddEvent<T>(_list.length - 1, object));
+    _eventStreamController.sink.add(ParseLiveListAddEvent<T>(
+        _list.length - 1, object?.clone(object?.toJson(full: true))));
   }
 
   void _objectUpdated(T object) {
     for (int i = 0; i < _list.length; i++) {
       if (_list[i].object.get<String>(keyVarObjectId) ==
           object.get<String>(keyVarObjectId)) {
-        //TODO: better soulution
-//        if (after(_list[i].object, object) == null) {
-//          _list[i].object = object;
-//        } else {
-        _list.removeAt(i).dispose();
-        _eventStreamController.sink.add(ParseLiveListDeleteEvent<T>(i, object));
-        _objectAdded(object);
-//        }
+        if (after(_list[i].object, object) == null) {
+          _list[i].object = object;
+        } else {
+          _list.removeAt(i).dispose();
+          _eventStreamController.sink.add(ParseLiveListDeleteEvent<T>(
+              i, object?.clone(object?.toJson(full: true))));
+          _objectAdded(object);
+        }
         break;
       }
     }
@@ -191,7 +192,8 @@ class ParseLiveList<T extends ParseObject> {
       if (_list[i].object.get<String>(keyVarObjectId) ==
           object.get<String>(keyVarObjectId)) {
         _list.removeAt(i).dispose();
-        _eventStreamController.sink.add(ParseLiveListDeleteEvent<T>(i, object));
+        _eventStreamController.sink.add(ParseLiveListDeleteEvent<T>(
+            i, object?.clone(object?.toJson(full: true))));
         break;
       }
     }
@@ -205,9 +207,10 @@ class ParseLiveList<T extends ParseObject> {
               keyVarObjectId, _list[index].object.get<String>(keyVarObjectId))
           ..setLimit(1);
         final ParseResponse response = await queryBuilder.query();
-        if (response.success) {
+        if (response.success && response.results != null) {
           _list[index].object = response.results.first;
         } else {
+          _list[index].object = null;
           throw response.error;
         }
       }
@@ -256,12 +259,12 @@ class ParseLiveListElement<T extends ParseObject> {
 
   Stream<T> get stream => _streamController?.stream;
 
-  T get object => _object;
+  T get object => _object?.clone(_object?.toJson(full: true));
 
   set object(T value) {
     _loaded = true;
     _object = value;
-    _streamController?.add(object);
+    _streamController?.add(_object?.clone(_object?.toJson(full: true)));
   }
 
   bool get loaded => _loaded;
@@ -291,12 +294,20 @@ class ParseLiveListDeleteEvent<T extends ParseObject>
   ParseLiveListDeleteEvent(int index, T object) : super(index, object);
 }
 
-typedef Stream<T> StreamGetter<T extends ParseObject>();
-typedef T DataGetter<T extends ParseObject>();
-typedef Widget ChildBuilder<T extends ParseObject>(
-    BuildContext context, bool failed, T loadedData);
-typedef Widget RemovedItemBuilder<T extends ParseObject>(
-    BuildContext context, int index, T oldObject);
+typedef StreamGetter<T extends ParseObject> = Stream<T> Function();
+typedef DataGetter<T extends ParseObject> = T Function();
+typedef ChildBuilder<T extends ParseObject> = Widget Function(
+    BuildContext context, ParseLiveListElementSnapshot<T> snapshot);
+
+class ParseLiveListElementSnapshot<T extends ParseObject> {
+  ParseLiveListElementSnapshot({this.loadedData, this.error});
+
+  final T loadedData;
+  final ParseError error;
+
+  bool get hasData => loadedData != null;
+  bool get failed => error != null;
+}
 
 class ParseLiveListWidget<T extends ParseObject> extends StatefulWidget {
   const ParseLiveListWidget(
@@ -327,8 +338,8 @@ class ParseLiveListWidget<T extends ParseObject> extends StatefulWidget {
   final bool reverse;
   final bool shrinkWrap;
 
-  final ChildBuilder childBuilder;
-  final RemovedItemBuilder<T> removedItemBuilder;
+  final ChildBuilder<T> childBuilder;
+  final ChildBuilder<T> removedItemBuilder;
 
   @override
   _ParseLiveListWidgetState<T> createState() =>
@@ -390,7 +401,7 @@ class _ParseLiveListWidgetState<T extends ParseObject>
   ParseLiveList<T> _liveList;
   final GlobalKey<AnimatedListState> _animatedListKey =
       GlobalKey<AnimatedListState>();
-  final RemovedItemBuilder<T> removedItemBuilder;
+  final ChildBuilder<T> removedItemBuilder;
 
   @override
   Widget build(BuildContext context) {
@@ -446,7 +457,7 @@ class ParseLiveListElementWidget<T extends ParseObject> extends StatefulWidget {
   final DataGetter<T> loadedData;
   final Animation<double> sizeFactor;
   final Duration duration;
-  final ChildBuilder childBuilder;
+  final ChildBuilder<T> childBuilder;
 
   @override
   _ParseLiveListElementWidgetState<T> createState() {
@@ -459,23 +470,38 @@ class _ParseLiveListElementWidgetState<T extends ParseObject>
     with SingleTickerProviderStateMixin {
   _ParseLiveListElementWidgetState(
       DataGetter<T> loadedDataGetter, StreamGetter<T> stream) {
-    loadedData = loadedDataGetter();
+//    loadedData = loadedDataGetter();
+    _snapshot = ParseLiveListElementSnapshot<T>(loadedData: loadedDataGetter());
     if (stream != null) {
-      _streamSubscription = stream().listen((T data) {
-        if (widget != null) {
-          setState(() {
-            loadedData = data;
-          });
-        } else {
-          loadedData = data;
-        }
-      });
+      _streamSubscription = stream().listen(
+        (T data) {
+          if (widget != null) {
+            setState(() {
+              _snapshot = ParseLiveListElementSnapshot<T>(loadedData: data);
+            });
+          } else {
+            _snapshot = ParseLiveListElementSnapshot<T>(loadedData: data);
+          }
+        },
+        onError: (Object error) {
+          if (error is ParseError) {
+            if (widget != null) {
+              setState(() {
+                _snapshot = ParseLiveListElementSnapshot<T>(error: error);
+              });
+            } else {
+              _snapshot = ParseLiveListElementSnapshot<T>(error: error);
+            }
+          }
+        },
+        cancelOnError: false,
+      );
     }
   }
-  T loadedData;
-  bool failed = false;
+
+  ParseLiveListElementSnapshot<T> _snapshot;
+
   StreamSubscription<T> _streamSubscription;
-  bool firstBuild = true;
 
   @override
   void dispose() {
@@ -491,10 +517,9 @@ class _ParseLiveListElementWidgetState<T extends ParseObject>
       child: AnimatedSize(
         duration: widget.duration,
         vsync: this,
-        child: widget.childBuilder(context, failed, loadedData),
+        child: widget.childBuilder(context, _snapshot),
       ),
     );
-    firstBuild = false;
     return result;
   }
 }