feat: add network logs broadcaster for call history

Author: sagar-deriv

lib/services/connection/call_manager/call_history.dart

@@ -1,7 +1,17 @@
+import 'dart:async';
+
 import 'package:flutter_deriv_api/services/connection/call_manager/call_history_entry.dart';
+import 'package:flutter_deriv_api/services/interfaces/call_history_provider.dart';
 
 /// Provides storage for messages sent/received via the web socket connection
-class CallHistory {
+class CallHistory implements CallHistoryProvider {
+  /// It initializes [CallHistory] instance.
+  CallHistory() {
+    _callHistoryBroadcaster = StreamController<NetworkPayload>.broadcast();
+  }
+
+  late final StreamController<NetworkPayload> _callHistoryBroadcaster;
+
   /// Messages that were sent to the remote endpoint
   final List<CallHistoryEntry> outgoing = <CallHistoryEntry>[];
 
@@ -29,7 +39,15 @@ class CallHistory {
     incoming.add(
       CallHistoryEntry(timeStamp: timestamp, method: method, message: message),
     );
-
+    if (!method.contains('ping')) {
+      _callHistoryBroadcaster.add(
+        NetworkPayload(
+            method: method,
+            body: message,
+            direction: 'RECEIVED',
+            timeStamp: timestamp),
+      );
+    }
     _trimHistory(incoming);
   }
 
@@ -42,6 +60,15 @@ class CallHistory {
     outgoing.add(
       CallHistoryEntry(timeStamp: timestamp, method: method, message: message),
     );
+    if (!method.contains('ping')) {
+      _callHistoryBroadcaster.add(
+        NetworkPayload(
+            method: method,
+            body: message,
+            direction: 'SENT',
+            timeStamp: timestamp),
+      );
+    }
 
     _trimHistory(outgoing);
   }
@@ -52,4 +79,7 @@ class CallHistory {
       callHistory.removeRange(0, callHistory.length - limit);
     }
   }
+
+  @override
+  Stream<NetworkPayload> get stream => _callHistoryBroadcaster.stream;
 }

lib/services/interfaces/call_history_provider.dart

@@ -0,0 +1,29 @@
+/// This interface provides stream of network payload that is going out(SENT)
+///  and coming in(RECEIVED) to the application.
+abstract class CallHistoryProvider {
+  /// Stream of network payload that is going out(SENT) and coming in(RECEIVED)
+  Stream<NetworkPayload> get stream;
+}
+
+/// Network payload that is going out and coming in from the web socket.
+class NetworkPayload {
+  /// Initializes [NetworkPayload] instance.
+  NetworkPayload({
+    required this.method,
+    required this.body,
+    required this.direction,
+    required this.timeStamp,
+  });
+
+  /// name of the api.
+  final String method;
+
+  /// content of the api.
+  final Object body;
+
+  /// direction of the api i.e SENT or RECEIVED.
+  final String direction;
+
+  /// time of the api.
+  final int timeStamp;
+}