Add event bus dependencies

Author: Dahkenangnon

lib/src/constants.dart

@@ -1,16 +1,29 @@
 class Constants {
-  static const  String  INVALID_CREDENTIALS = "INVALID_CREDENTIALS";
-  static const  String  JWT_EXPIRED_ERROR = "JWT_EXPIRED_ERROR";
-  static const  String  NO_ERROR = "NO_ERROR";
-  static const  String  UNKNOWN_ERROR = "UNKNOWN_ERROR";
-  static const  String  JWT_ERROR = "JWT_ERROR";
-  static const  String  JWT_NOT_FOUND = "JWT_NOT_FOUND";
-  static const  String  INVALID_STRATEGY = "INVALID_STRATEGY";
-  static const  String  DIO_ERROR = "DIO_ERROR";
-
-  static const  String  AUTH_WITH_JWT_SUCCEED = "AUTH_WITH_JWT_SUCCEED";
-  static const  String  AUTH_WITH_JWT_FAILED = "AUTH_WITH_JWT_FAILED";
-
-  static const  String  BOTH_CLIENT_AUTHED = "BOTH_CLIENT_AUTHED";
-  static const  String  ONE_OR_BOTH_CLIENT_NOT_AUTHED = "ONE_OR_BOTH_CLIENT_NOT_AUTHED";
+  static const String INVALID_CREDENTIALS = "INVALID_CREDENTIALS";
+  static const String JWT_EXPIRED_ERROR = "JWT_EXPIRED_ERROR";
+  static const String NO_ERROR = "NO_ERROR";
+  static const String UNKNOWN_ERROR = "UNKNOWN_ERROR";
+  static const String JWT_ERROR = "JWT_ERROR";
+  static const String JWT_NOT_FOUND = "JWT_NOT_FOUND";
+  static const String INVALID_STRATEGY = "INVALID_STRATEGY";
+  static const String DIO_ERROR = "DIO_ERROR";
+
+  static const String AUTH_WITH_JWT_SUCCEED = "AUTH_WITH_JWT_SUCCEED";
+  static const String AUTH_WITH_JWT_FAILED = "AUTH_WITH_JWT_FAILED";
+
+  static const String BOTH_CLIENT_AUTHED = "BOTH_CLIENT_AUTHED";
+  static const String ONE_OR_BOTH_CLIENT_NOT_AUTHED =
+      "ONE_OR_BOTH_CLIENT_NOT_AUTHED";
 }
+
+class Removed<T> {}
+
+class Patched<T> {}
+
+class Created<T> {}
+
+class Updated<T> {}
+
+class Connected {}
+
+class DisConnected {}

lib/src/scketio_client.dart

@@ -5,12 +5,14 @@ import 'package:flutter_feathersjs/src/featherjs_client_base.dart';
 import 'package:flutter_feathersjs/src/utils.dart';
 import 'package:socket_io_client/socket_io_client.dart' as IO;
 import 'package:meta/meta.dart';
+import 'package:event_bus/event_bus.dart';
 
 ///Socketio client for the realtime communication
 class SocketioClient extends FlutterFeathersjs {
   IO.Socket _socket;
   bool dev = true;
   Utils utils;
+  EventBus eventBus = EventBus();
 
   //Using singleton
   static final SocketioClient _socketioClient = SocketioClient._internal();
@@ -32,11 +34,12 @@ class SocketioClient extends FlutterFeathersjs {
 
     utils = new Utils();
 
-    if (dev) {
+    if (true) {
       print("-----Dev printing start----");
 
       _socket.on('connect', (_) {
         print("Socket connection established");
+        eventBus.fire(Connected());
       });
 
       _socket.on('connect_error', (e) {
@@ -48,7 +51,9 @@ class SocketioClient extends FlutterFeathersjs {
         print(data);
       });
       _socket.on('connecting', (_) => print("Connecting..."));
-      _socket.on('disconnect', (_) => print("Disconnected..."));
+      _socket.on('disconnect', (_) {
+        eventBus.fire(DisConnected());
+      });
       _socket.on('error', (_) => print("An error occured"));
       _socket.on('reconnect', (_) => print("Reconnected"));
       _socket.on('reconnect_error', (_) => print("Reconnection error..."));
@@ -172,28 +177,4 @@ class SocketioClient extends FlutterFeathersjs {
     });
     return asyncTask.future;
   }
-
-  /// Listen to create method call
-  ///Get the last created ressource
-  onCreated({String serviceName, Function callback}) {
-    _socket.on("$serviceName created", (data) {
-      callback(data);
-    });
-  }
-
-  /// Listen to update method
-  ///Get the last updated ressource
-  onUpdated({String serviceName, Function callback}) {
-    _socket.on("$serviceName updated", (data) {
-      callback(data);
-    });
-  }
-
-  /// Listen to remove method call
-  ///Get the last deleted ressource
-  onRemoved({String serviceName, Function callback}) {
-    _socket.on("$serviceName removed", (data) {
-      callback(data);
-    });
-  }
 }

pubspec.lock

@@ -50,6 +50,13 @@ packages:
       url: "https://pub.dartlang.org"
     source: hosted
     version: "3.0.9"
+  event_bus:
+    dependency: "direct main"
+    description:
+      name: event_bus
+      url: "https://pub.dartlang.org"
+    source: hosted
+    version: "1.1.1"
   fake_async:
     dependency: transitive
     description:

pubspec.yaml

@@ -17,6 +17,8 @@ dependencies:
   # For storing the acces token
   shared_preferences: ^0.5.12+2
   meta: ^1.1.8
+  # Event managment
+  event_bus: ^1.1.1
 
 dev_dependencies:
   flutter_test: