passing data to java

Author: divshekhar

android/src/main/java/com/devsonflutter/reflex/EventCallHandler.java

@@ -22,6 +22,9 @@
 import com.devsonflutter.reflex.notification.ReflexNotification;
 import com.devsonflutter.reflex.permission.NotificationPermission;
 
+import java.util.HashMap;
+import java.util.List;
+
 import io.flutter.Log;
 import io.flutter.plugin.common.EventChannel;
 
@@ -41,6 +44,7 @@ public class EventCallHandler implements EventChannel.StreamHandler {
     @RequiresApi(api = Build.VERSION_CODES.JELLY_BEAN_MR2)
     @Override
     public void onListen(Object arguments, EventChannel.EventSink events) {
+        Log.w(TAG,arguments.toString());
         mEventSink = events;
         listenNotification(mEventSink);
         Log.w(TAG,"Listening Reflex Stream...");

example/lib/main.dart

@@ -17,11 +17,18 @@ class MyApp extends StatefulWidget {
 }
 
 class _MyAppState extends State<MyApp> {
-  Reflex? _reflex;
   StreamSubscription<NotificationEvent>? _subscription;
   final List<NotificationEvent> _log = [];
   bool started = false;
 
+  Reflex reflex = Reflex(
+    debug: true,
+    autoReply: AutoReply(
+      packageName: "com.whatsapp",
+      message: "Hello",
+    ),
+  );
+
   @override
   void initState() {
     super.initState();
@@ -41,9 +48,8 @@ class _MyAppState extends State<MyApp> {
   }
 
   void startListening() {
-    _reflex = Reflex();
     try {
-      _subscription = _reflex!.notificationStream!.listen(onData);
+      _subscription = reflex.notificationStream!.listen(onData);
       setState(() {
         started = true;
       });

lib/reflex.dart

@@ -11,13 +11,32 @@ for more details.
 import 'dart:async';
 
 import 'package:reflex/src/helper/events/notification_event.dart';
+import 'package:reflex/src/helper/helper.dart';
 import 'package:reflex/src/platform/reflex_platform.dart';
 
 export 'package:reflex/src/helper/helper.dart';
 
 class Reflex {
+  /// [Reflex] Constructor
+  Reflex({
+    this.debug = false,
+    this.autoReply,
+  }) {
+    init();
+  }
+
+  final bool debug;
+  final AutoReply? autoReply;
+  late final ReflexPlatform reflexPlatform;
+
+  // Initialize [ReflexPlatform] with [debug] and [autoReply]
+  void init() {
+    reflexPlatform = ReflexPlatform.instance;
+    reflexPlatform.init(debug: debug, autoReply: autoReply);
+  }
+
   /// [notificationStream] returns stream of notifications.
   Stream<NotificationEvent>? get notificationStream {
-    return ReflexPlatform.instance.notificationStream;
+    return reflexPlatform.notificationStream;
   }
 }

lib/src/handler/reflex_handler.dart

@@ -13,6 +13,7 @@ import 'dart:io';
 import 'package:flutter/services.dart';
 import 'package:reflex/src/helper/events/notification_event.dart';
 import 'package:reflex/src/helper/exception/reflex_exception.dart';
+import 'package:reflex/src/helper/helper.dart';
 import 'package:reflex/src/platform/reflex_platform.dart';
 
 class ReflexHandler extends ReflexPlatform {
@@ -25,13 +26,28 @@ class ReflexHandler extends ReflexPlatform {
 
   Stream<NotificationEvent>? _notificationStream;
 
+  late final List<dynamic> arguments;
+
+  @override
+  void init({
+    required bool debug,
+    AutoReply? autoReply,
+  }) {
+    Map<String, dynamic> map = {
+      "debug": debug,
+      "autoReply": autoReply?.deserialize(),
+    };
+    arguments = [map];
+  }
+
   @override
   Stream<NotificationEvent>? get notificationStream {
     if (Platform.isAndroid) {
-      _notificationStream ??=
-          _eventChannel.receiveBroadcastStream().map<NotificationEvent>(
-                (event) => NotificationEvent.getNotificationEventFromMap(event),
-              );
+      _notificationStream ??= _eventChannel
+          .receiveBroadcastStream(arguments)
+          .map<NotificationEvent>(
+            (event) => NotificationEvent.getNotificationEventFromMap(event),
+          );
       return _notificationStream;
     }
     throw ReflexException('notificationStream is only supported on Android!');

lib/src/helper/exception/reflex_exception.dart

@@ -18,3 +18,14 @@ class ReflexException implements Exception {
     return "ReflexException: $message";
   }
 }
+
+class ReflexNullException implements Exception {
+  String message;
+
+  ReflexNullException(this.message);
+
+  @override
+  String toString() {
+    return "ReflexNullException: $message";
+  }
+}

lib/src/helper/helper.dart

@@ -10,3 +10,4 @@ for more details.
 
 export 'exception/reflex_exception.dart';
 export 'events/notification_event.dart';
+export 'model/auto_reply.dart';

lib/src/helper/model/auto_reply.dart

@@ -0,0 +1,44 @@
+/* 
+
+                  Copyright (c) 2022 DevsOnFlutter (Devs On Flutter)
+                            All rights reserved.
+
+The plugin is governed by the BSD-3-clause License. Please see the LICENSE file
+for more details.
+
+*/
+
+class AutoReply {
+  AutoReply({
+    required this.packageName,
+    required this.message,
+  });
+
+  /// Package Name for [AutoReply]
+  String packageName;
+
+  /// Notification Message
+  String message;
+
+  factory AutoReply.fromMap(Map<dynamic, dynamic> map) {
+    // Error Handling if map does not contain package name or message
+    if (!map.containsKey('packageName') || !map.containsKey('message')) {
+      throw Exception('Map does not contain package name or message');
+    }
+
+    String packageName = map['packageName'];
+    String message = map['message'];
+
+    return AutoReply(
+      packageName: packageName,
+      message: message,
+    );
+  }
+
+  Map<String, dynamic> deserialize() {
+    return <String, dynamic>{
+      'packageName': packageName,
+      'message': message,
+    };
+  }
+}

lib/src/platform/reflex_platform.dart

@@ -11,20 +11,23 @@ for more details.
 import 'package:plugin_platform_interface/plugin_platform_interface.dart';
 import 'package:reflex/src/handler/reflex_handler.dart';
 import 'package:reflex/src/helper/events/notification_event.dart';
+import 'package:reflex/src/helper/helper.dart';
 
 abstract class ReflexPlatform extends PlatformInterface {
   ReflexPlatform() : super(token: _token);
 
   static final Object _token = Object();
 
-  static ReflexPlatform _instance = ReflexHandler();
+  static final ReflexPlatform _instance = ReflexHandler();
 
   /// returns the instance of the [ReflexHandler].
   static ReflexPlatform get instance => _instance;
 
-  static set instance(ReflexPlatform instance) {
-    PlatformInterface.verifyToken(instance, _token);
-    _instance = instance;
+  void init({
+    required bool debug,
+    AutoReply? autoReply,
+  }) {
+    throw UnimplementedError('init has not been implemented for reflex.');
   }
 
   Stream<NotificationEvent>? get notificationStream {