reflex event type declared

Author: divshekhar

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

@@ -31,7 +31,7 @@
 
 public class EventCallHandler implements EventChannel.StreamHandler {
 
-    private EventChannel.EventSink mEventSink = null;
+    private static EventChannel.EventSink mEventSink = null;
     private final Context context;
     private final NotificationPermission notificationPermission;
 
@@ -42,6 +42,10 @@ public class EventCallHandler implements EventChannel.StreamHandler {
 
     private static final String TAG = ReflexPlugin.getPluginTag();
 
+    static public EventChannel.EventSink getEventSink() {
+        return mEventSink;
+    }
+
     @RequiresApi(api = Build.VERSION_CODES.JELLY_BEAN_MR2)
     @Override
     public void onListen(Object arguments, EventChannel.EventSink events) {

android/src/main/java/com/devsonflutter/reflex/notification/NotificationListener.java

@@ -19,13 +19,16 @@
 import android.service.notification.StatusBarNotification;
 import androidx.annotation.RequiresApi;
 
+import com.devsonflutter.reflex.EventCallHandler;
 import com.devsonflutter.reflex.ReflexPlugin;
 import com.devsonflutter.reflex.notification.autoReply.AutoReply;
 
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
 import io.flutter.Log;
+import io.flutter.plugin.common.EventChannel;
 
 /* Notification Listener */
 @RequiresApi(api = VERSION_CODES.JELLY_BEAN_MR2)
@@ -68,9 +71,11 @@ public void onNotificationPosted(StatusBarNotification notification) {
         Map<String, Object> autoReply = ReflexPlugin.autoReply;
         if(autoReply != null) {
             List<String> autoReplyPackageNameList = (List<String>) autoReply.get("packageNameList");
+            String message = (String) autoReply.get("message");
             assert autoReplyPackageNameList != null;
             if(autoReplyPackageNameList.contains(packageName)) {
-                new AutoReply(ReflexPlugin.context).sendReply(notification, (String) autoReply.get("message"));
+                // Reply to notification
+                new AutoReply(ReflexPlugin.context).sendReply(notification, packageName, title, message);
             }
         }
     }

android/src/main/java/com/devsonflutter/reflex/notification/NotificationReceiver.java

@@ -38,12 +38,6 @@ public void onReceive(Context context, Intent intent) {
         String title = intent.getStringExtra(NotificationUtils.NOTIFICATION_TITLE);
         String message = intent.getStringExtra(NotificationUtils.NOTIFICATION_MESSAGE);
 
-        // Sending Data from Java to Flutter
-        HashMap<String, Object> data = new HashMap<>();
-        data.put("packageName", packageName);
-        data.put("title", title);
-        data.put("message", message);
-
         boolean sendData = false;
 
         List<String> packageNameList = ReflexPlugin.packageNameList;
@@ -62,6 +56,13 @@ else if(packageNameList != null) {
         }
 
         if(sendData) {
+            // Sending Data from Java to Flutter
+            HashMap<String, Object> data = new HashMap<>();
+            data.put("type", "notification");
+            data.put("packageName", packageName);
+            data.put("title", title);
+            data.put("message", message);
+
             eventSink.success(data);
         }
     }

android/src/main/java/com/devsonflutter/reflex/notification/autoReply/AutoReply.java

@@ -14,10 +14,15 @@
 import androidx.annotation.RequiresApi;
 import androidx.core.app.RemoteInput;
 
+import com.devsonflutter.reflex.EventCallHandler;
 import com.devsonflutter.reflex.ReflexPlugin;
 import com.devsonflutter.reflex.notification.NotificationUtils;
 import com.devsonflutter.reflex.notification.model.NotificationWear;
 
+import java.util.HashMap;
+
+import io.flutter.plugin.common.EventChannel;
+
 public class AutoReply {
 
     public AutoReply(Context context) {
@@ -29,15 +34,16 @@ public AutoReply(Context context) {
     private static final String TAG = ReflexPlugin.getPluginTag();
 
     @RequiresApi(api = Build.VERSION_CODES.N)
-    public void sendReply(StatusBarNotification sbn, String message){
+    public void sendReply(StatusBarNotification sbn, String packageName, CharSequence title,String message){
         if (canReply(sbn)) {
-            reply(sbn,message);
+            reply(sbn,packageName, title, message);
         }
     }
 
     @RequiresApi(api = Build.VERSION_CODES.JELLY_BEAN_MR2)
-    private void reply(StatusBarNotification sbn, String message) {
+    private void reply(StatusBarNotification sbn, String packageName, CharSequence title,String message) {
         NotificationWear notificationWear = NotificationUtils.extractWearNotification(sbn);
+
         if (notificationWear.getRemoteInputs().isEmpty()) {
             return;
         }
@@ -61,6 +67,16 @@ private void reply(StatusBarNotification sbn, String message) {
             if (notificationWear.getPendingIntent() != null) {
                 notificationWear.getPendingIntent().send(context, 0, localIntent);
                 ReflexPlugin.debugPrint("Auto Reply Sent Successfully...");
+
+                // Sending Reply Data from Java to Flutter
+                HashMap<String, Object> data = new HashMap<>();
+                data.put("type", "reply");
+                data.put("packageName", packageName);
+                data.put("title", title);
+                data.put("message", message);
+
+                EventChannel.EventSink eventSink = EventCallHandler.getEventSink();
+                eventSink.success(data);
             }
         } catch (PendingIntent.CanceledException e) {
             Log.e(TAG, "PendingIntent.CanceledException: " + e.getMessage());

example/lib/main.dart

@@ -17,8 +17,9 @@ class MyApp extends StatefulWidget {
 }
 
 class _MyAppState extends State<MyApp> {
-  StreamSubscription<NotificationEvent>? _subscription;
-  final List<NotificationEvent> _notificationLogs = [];
+  StreamSubscription<ReflexEvent>? _subscription;
+  final List<ReflexEvent> _notificationLogs = [];
+  final List<ReflexEvent> _autoReplyLogs = [];
   bool isListening = false;
 
   Reflex reflex = Reflex(
@@ -42,9 +43,13 @@ class _MyAppState extends State<MyApp> {
     startListening();
   }
 
-  void onData(NotificationEvent event) {
+  void onData(ReflexEvent event) {
     setState(() {
-      _notificationLogs.add(event);
+      if (event.type == ReflexEventType.notification) {
+        _notificationLogs.add(event);
+      } else if (event.type == ReflexEventType.reply) {
+        _autoReplyLogs.add(event);
+      }
     });
     debugPrint(event.toString());
   }
@@ -72,13 +77,15 @@ class _MyAppState extends State<MyApp> {
         appBar: AppBar(
           title: const Text('Reflex Example app'),
         ),
-        body: Column(
-          mainAxisAlignment: MainAxisAlignment.start,
-          children: [
-            notificationListener(),
-            permissions(),
-            autoReply(),
-          ],
+        body: SingleChildScrollView(
+          child: Column(
+            mainAxisAlignment: MainAxisAlignment.start,
+            children: [
+              notificationListener(),
+              permissions(),
+              autoReply(),
+            ],
+          ),
         ),
       ),
     );
@@ -115,7 +122,7 @@ class _MyAppState extends State<MyApp> {
             child: ListView.builder(
               itemCount: _notificationLogs.length,
               itemBuilder: (BuildContext context, int index) {
-                final NotificationEvent element = _notificationLogs[index];
+                final ReflexEvent element = _notificationLogs[index];
                 return ListTile(
                   title: Text(element.title ?? ""),
                   subtitle: Text(element.message ?? ""),
@@ -168,6 +175,46 @@ class _MyAppState extends State<MyApp> {
   }
 
   Widget autoReply() {
-    return const Text("AutoReply");
+    return SizedBox(
+      height: 400,
+      child: Column(
+        children: [
+          SizedBox(
+            height: 300,
+            child: ListView.builder(
+              itemCount: _autoReplyLogs.length,
+              itemBuilder: (BuildContext context, int index) {
+                final ReflexEvent element = _autoReplyLogs[index];
+                return ListTile(
+                  title: Text("AutoReply to: ${element.title}"),
+                  subtitle: Text(element.message ?? ""),
+                  trailing: Text(
+                    element.packageName.toString().split('.').last,
+                  ),
+                );
+              },
+            ),
+          ),
+          if (_autoReplyLogs.isNotEmpty)
+            ElevatedButton.icon(
+              style: ElevatedButton.styleFrom(
+                primary: Colors.red,
+              ),
+              icon: const Icon(Icons.clear),
+              label: const Text(
+                "Clear List",
+                style: TextStyle(
+                  color: Colors.white,
+                ),
+              ),
+              onPressed: () {
+                setState(() {
+                  _autoReplyLogs.clear();
+                });
+              },
+            ),
+        ],
+      ),
+    );
   }
 }

lib/reflex.dart

@@ -10,7 +10,7 @@ for more details.
 
 import 'dart:async';
 
-import 'package:reflex/src/helper/events/notification_event.dart';
+import 'package:reflex/src/helper/events/reflex_event.dart';
 import 'package:reflex/src/helper/helper.dart';
 import 'package:reflex/src/platform/reflex_platform.dart';
 
@@ -46,7 +46,7 @@ class Reflex {
   }
 
   /// [notificationStream] returns stream of notifications.
-  Stream<NotificationEvent>? get notificationStream {
+  Stream<ReflexEvent>? get notificationStream {
     return reflexPlatform.notificationStream;
   }
 

lib/src/handler/reflex_handler.dart

@@ -11,7 +11,7 @@ for more details.
 import 'dart:io';
 
 import 'package:flutter/services.dart';
-import 'package:reflex/src/helper/events/notification_event.dart';
+import 'package:reflex/src/helper/events/reflex_event.dart';
 import 'package:reflex/src/helper/exception/reflex_exception.dart';
 import 'package:reflex/src/helper/helper.dart';
 import 'package:reflex/src/helper/utils/reflex_utils.dart';
@@ -26,7 +26,7 @@ class ReflexHandler extends ReflexPlatform {
   MethodChannel get methodChannel => _methodChannel;
   EventChannel get eventChannel => _eventChannel;
 
-  Stream<NotificationEvent>? _notificationStream;
+  Stream<ReflexEvent>? _notificationStream;
 
   late final List<dynamic> arguments;
 
@@ -83,13 +83,12 @@ class ReflexHandler extends ReflexPlatform {
   }
 
   @override
-  Stream<NotificationEvent>? get notificationStream {
+  Stream<ReflexEvent>? get notificationStream {
     if (Platform.isAndroid) {
-      _notificationStream ??= _eventChannel
-          .receiveBroadcastStream(arguments)
-          .map<NotificationEvent>(
-            (event) => NotificationEvent.getNotificationEventFromMap(event),
-          );
+      _notificationStream ??=
+          _eventChannel.receiveBroadcastStream(arguments).map<ReflexEvent>(
+                (event) => ReflexEvent.getReflexEventFromMap(event),
+              );
       return _notificationStream;
     }
     throw ReflexException('notificationStream is only supported on Android!');

lib/src/helper/enums/reflex_event_type.dart

@@ -0,0 +1,18 @@
+/* 
+
+                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.
+
+*/
+
+/// [ReflexEventType] determines type of Reflex Event
+enum ReflexEventType {
+  /// [ReflexEventType.notification] receives notification
+  notification,
+
+  /// [ReflexEventType.reply] receives auto reply event
+  reply,
+}

…rc/helper/events/notification_event.dart lib/src/helper/events/reflex_event.dartlib/src/helper/events/notification_event.dart renamed to lib/src/helper/events/reflex_event.dart lib/src/helper/events/notification_event.dart renamed to lib/src/helper/events/reflex_event.dart

@@ -8,14 +8,20 @@ for more details.
 
 */
 
-class NotificationEvent {
-  NotificationEvent({
+import 'package:reflex/src/helper/helper.dart';
+
+class ReflexEvent {
+  ReflexEvent({
+    this.type,
     this.packageName,
     this.title,
     this.message,
     this.timeStamp,
   });
 
+  /// Event type Notification/Reply
+  ReflexEventType? type;
+
   /// The package name of the app that sent the notification.
   String? packageName;
 
@@ -28,27 +34,37 @@ class NotificationEvent {
   /// The time stamp of the notification.
   DateTime? timeStamp;
 
-  factory NotificationEvent.fromMap(Map<dynamic, dynamic> map) {
+  factory ReflexEvent.fromMap(Map<dynamic, dynamic> map) {
     DateTime time = DateTime.now();
     String? name = map['packageName'];
     String? message = map['message'];
     String? title = map['title'];
 
-    return NotificationEvent(
+    ReflexEventType? type;
+
+    if (map['type'] == 'notification') {
+      type = ReflexEventType.notification;
+    } else if (map['type'] == 'reply') {
+      type = ReflexEventType.reply;
+    }
+
+    return ReflexEvent(
+      type: type,
       packageName: name,
       title: title,
       message: message,
       timeStamp: time,
     );
   }
 
-  static NotificationEvent getNotificationEventFromMap(dynamic data) {
-    return NotificationEvent.fromMap(data);
+  static ReflexEvent getReflexEventFromMap(dynamic data) {
+    return ReflexEvent.fromMap(data);
   }
 
   @override
   String toString() {
     return '''$runtimeType
+    type: $type,
     Package Name: $packageName, 
     Title: $title, 
     Message: $message, 

lib/src/helper/helper.dart

@@ -1,6 +1,6 @@
 /* 
 
-                  Copyright (c) 2022 DevsOnFlutter (Devs On Flutter)
+                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
@@ -9,5 +9,6 @@ for more details.
 */
 
 export 'exception/reflex_exception.dart';
-export 'events/notification_event.dart';
+export 'events/reflex_event.dart';
 export 'model/auto_reply.dart';
+export 'enums/reflex_event_type.dart';