From d735528df97ccab0c7183005d3c3a99f2b3cd6d1 Mon Sep 17 00:00:00 2001
From: Tobe Osakwe <thosakwe@gmail.com>
Date: Sun, 19 Aug 2018 22:36:07 -0400
Subject: [PATCH] Create angel_typed_service.dart

---
 lib/angel_typed_service.dart | 89 ++++++++++++++++++++++++++++++++++++
 1 file changed, 89 insertions(+)
 create mode 100644 lib/angel_typed_service.dart

diff --git a/lib/angel_typed_service.dart b/lib/angel_typed_service.dart
new file mode 100644
index 00000000..208fec29
--- /dev/null
+++ b/lib/angel_typed_service.dart
@@ -0,0 +1,89 @@
+import 'dart:async';
+import 'dart:mirrors';
+
+import 'service.dart';
+
+class TypedService<T> extends Service {
+  final Service inner;
+
+  TypedService(this.inner) : super() {
+    if (!reflectType(T).isAssignableTo(reflectType(Model)))
+      throw new Exception(
+          "If you specify a type for TypedService, it must extend Model.");
+  }
+
+  deserialize(x) {
+    // print('DESERIALIZE: $x (${x.runtimeType})');
+    if (x is Type || x is T)
+      return x;
+    else if (x is Iterable)
+      return x.map(deserialize).toList();
+    else if (x is Map) {
+      Map data = x.keys.fold({}, (map, key) {
+        var value = x[key];
+
+        if ((key == 'createdAt' ||
+                key == 'updatedAt' ||
+                key == 'created_at' ||
+                key == 'updated_at') &&
+            value is String) {
+          return map..[key] = DateTime.parse(value);
+        } else {
+          return map..[key] = value;
+        }
+      });
+
+      Model result = god.deserializeDatum(data, outputType: T);
+
+      if (data['createdAt'] is DateTime) {
+        result.createdAt = data['createdAt'] as DateTime;
+      } else if (data['created_at'] is DateTime) {
+        result.createdAt = data['created_at'] as DateTime;
+      }
+
+      if (data['updatedAt'] is DateTime) {
+        result.updatedAt = data['updatedAt'] as DateTime;
+      } else if (data['updated_at'] is DateTime) {
+        result.updatedAt = data['updated_at'] as DateTime;
+      }
+
+      // print('x: $x\nresult: $result');
+      return result;
+    } else
+      return x;
+  }
+
+  serialize(x) {
+    // TODO: Custom serializer, i.e. json_god?
+//    if (x is Model)
+//      return json.encodeObject(x);
+//    else
+    if (x is Map)
+      return x;
+    else if (x is Iterable)
+      return x.map(serialize).toList();
+    else
+      throw new ArgumentError('Cannot serialize ${x.runtimeType}');
+  }
+
+  @override
+  Future index([Map params]) => inner.index(params).then(deserialize);
+
+  @override
+  Future create(data, [Map params]) =>
+      inner.create(serialize(data), params).then(deserialize);
+
+  @override
+  Future read(id, [Map params]) => inner.read(id, params).then(deserialize);
+
+  @override
+  Future modify(id, data, [Map params]) =>
+      inner.modify(id, serialize(data), params).then(deserialize);
+
+  @override
+  Future update(id, data, [Map params]) =>
+      inner.update(id, serialize(data), params).then(deserialize);
+
+  @override
+  Future remove(id, [Map params]) => inner.remove(id, params).then(deserialize);
+}