fix: Firebase plugin fixes

fix: Firebase plugin fixes

.gitignore

@@ -23,8 +23,16 @@ migrate_working_dir/
 
 # Flutter/Dart/Pub related
 # Libraries should not include pubspec.lock, per https://dart.dev/guides/libraries/private-files#pubspeclock.
-/pubspec.lock
+pubspec.lock
 **/doc/api/
 .dart_tool/
 .packages
 build/
+.flutter-plugins
+.flutter-plugins-dependencies
+
+# ASDF 
+.tool-versions
+
+# VSCode
+launch.json

packages/core/lib/event.dart

@@ -51,7 +51,6 @@ abstract class RawEvent with JSONSerialisable {
   Context? context;
 
   Map<String, dynamic>? integrations;
-  List<Map<String, dynamic>>? metrics;
 
   @JsonKey(name: "_metadata")
   DestinationMetadata? metadata;

packages/core/lib/map_transform.dart

@@ -1,82 +1,44 @@
-// class PropertyMap {
-//   final Set<String>? keys;
-//   final bool optional;
-
-//   PropertyMap({this.keys, this.optional = false});
-// }
-
 class PropertyMapper {
-  final Set<String> sourceKeys;
+  final String targetKey;
   final dynamic Function(dynamic)? fromJson;
 
-  const PropertyMapper(this.sourceKeys, {this.fromJson});
+  const PropertyMapper(this.targetKey, {this.fromJson});
 }
 
-dynamic recurseMapper(
-    dynamic value, Map<String, PropertyMapper> propertiesMapper) {
+dynamic recurseMapper(dynamic value, Map<String, PropertyMapper> mappings) {
   if (value is List) {
-    return value.map((value) => recurseMapper(value, propertiesMapper));
+    return value.map((value) => recurseMapper(value, mappings));
+  } else if (value is Map<String, dynamic>) {
+    return mapProperties(value, mappings);
   } else if (value is Map) {
-    value.map(
-        (key, value) => MapEntry(key, recurseMapper(value, propertiesMapper)));
+    return value
+        .map((key, value) => MapEntry(key, recurseMapper(value, mappings)));
   } else {
     return value;
   }
 }
 
-dynamic Function(String targetKey,
-        {bool? optional, dynamic Function(dynamic)? fromJson})
-    propertyMapper(Map<String, dynamic>? properties,
-        Map<String, PropertyMapper> propertiesMapper) {
-  return (String targetKey,
-      {bool? optional, dynamic Function(dynamic)? fromJson}) {
-    final propertyMapper = propertiesMapper[targetKey];
-    if (properties != null) {
-      for (final sourceKey in (propertyMapper != null
-          ? propertyMapper.sourceKeys
-          : {targetKey})) {
-        final value = properties[sourceKey];
-        if (value != null) {
-          return fromJson == null
-              ? (propertyMapper?.fromJson == null
-                  ? value
-                  : propertyMapper?.fromJson!(value))
-              : fromJson(value);
-        }
-      }
-    }
-    if (optional == null || optional == false) {
-      throw Exception(
-          "Missing properties: ${propertyMapper == null ? targetKey : propertyMapper.sourceKeys.join(',')}");
-    } else {
-      return null;
-    }
-  };
-}
+Map<String, Object?> mapProperties(
+    Map<String, dynamic>? properties, Map<String, PropertyMapper> mappings) {
+  final Map<String, Object?> output = {};
 
-// Map<String, dynamic> mapProperties(
-//     Map<String, dynamic> properties, Map<String, PropertyMap> mapper) {
-//   final Map<String, dynamic> output = {};
-//   final Set<String> missing = {};
+  if (properties == null) {
+    return {};
+  }
 
-//   for (final entry in mapper.entries) {
-//     var found = false;
-//     for (final sourceKey in entry.value.keys ?? {entry.key}) {
-//       final value = properties[sourceKey];
-//       if (value != null) {
-//         output[entry.key] = value;
-//         found = true;
-//         break;
-//       }
-//     }
-//     if (!found && !entry.value.optional) {
-//       missing.add(entry.value.keys?.first ?? entry.key);
-//     }
-//   }
+  for (final entry in properties.entries) {
+    final sourceKey = entry.key;
+    final sourceValue = properties[sourceKey];
+    if (mappings.containsKey(sourceKey)) {
+      final mapping = mappings[sourceKey]!;
 
-//   if (missing.isNotEmpty) {
-//     throw Exception("Missing properties: ${missing.join(',')}");
-//   }
+      output[mapping.targetKey] = (mapping.fromJson != null)
+          ? mapping.fromJson!(sourceValue)
+          : sourceValue;
+    } else {
+      output[sourceKey] = sourceValue;
+    }
+  }
 
-//   return output;
-// }
+  return output;
+}

packages/core/lib/plugin.dart

@@ -144,13 +144,31 @@ abstract class DestinationPlugin extends EventPlugin {
     timeline.remove(plugin);
   }
 
-  @override
-  Future<RawEvent?> execute(RawEvent event) async {
+  Future<RawEvent?> process(RawEvent event) async {
     if (!_isEnabled(event)) {
       return null;
     }
 
-    return timeline.process(event);
+    final beforeResult = await timeline.applyPlugins(PluginType.before, event);
+    if (beforeResult == null) {
+      return null;
+    }
+
+    final enrichmentResult =
+        await timeline.applyPlugins(PluginType.enrichment, event);
+    if (enrichmentResult == null) {
+      return null;
+    }
+
+    await super.execute(enrichmentResult);
+
+    final afterResult = await timeline.applyPlugins(PluginType.after, event);
+    return afterResult;
+  }
+
+  @override
+  Future<RawEvent?> execute(RawEvent event) async {
+    return process(event);
   }
 }