support authorize call in Isolate

Author: ramin-deriv

lib/api/response/authorize_response_result.dart

@@ -9,6 +9,7 @@ import 'package:flutter_deriv_api/basic_api/generated/authorize_send.dart';
 import 'package:flutter_deriv_api/helpers/helpers.dart';
 import 'package:flutter_deriv_api/services/connection/api_manager/base_api.dart';
 import 'package:deriv_dependency_injector/dependency_injector.dart';
+import 'package:flutter_deriv_api/services/connection/api_manager/binary_api.dart';
 
 /// Authorize response model class.
 abstract class AuthorizeResponseModel {
@@ -48,27 +49,17 @@ class AuthorizeResponse extends AuthorizeResponseModel {
     return resultMap;
   }
 
-  static final BaseAPI _api = Injector()<BaseAPI>();
+  static final IsolateWrappingAPI _api =
+      Injector()<BaseAPI>() as IsolateWrappingAPI;
 
   /// Authorizes current WebSocket session to act on behalf of the owner of a given token.
   ///
   /// For parameters information refer to [AuthorizeRequest].
   /// Throws an [BaseAPIException] if API response contains an error.
   static Future<AuthorizeReceive> authorizeMethodRaw(
     AuthorizeRequest request,
-  ) async {
-    final AuthorizeReceive response = await _api.call(
-      request: request,
-    );
-
-    checkException(
-      response: response,
-      exceptionCreator: ({BaseExceptionModel? baseExceptionModel}) =>
-          BaseAPIException(baseExceptionModel: baseExceptionModel),
-    );
-
-    return response;
-  }
+  ) async =>
+      _api.authorize(request);
 
   /// Authorizes current WebSocket session to act on behalf of the owner of a given token.
   ///

lib/services/connection/api_manager/binary_api.dart

@@ -11,6 +11,7 @@ import 'package:flutter_deriv_api/api/exceptions/base_api_exception.dart';
 import 'package:flutter_deriv_api/api/manually/tick.dart';
 import 'package:flutter_deriv_api/api/models/base_exception_model.dart';
 import 'package:flutter_deriv_api/api/response/active_symbols_response_result.dart';
+import 'package:flutter_deriv_api/api/response/authorize_response_result.dart';
 import 'package:flutter_deriv_api/api/response/ticks_response_result.dart';
 import 'package:flutter_deriv_api/basic_api/generated/active_symbols_receive.dart';
 import 'package:flutter_deriv_api/basic_api/generated/active_symbols_send.dart';
@@ -320,6 +321,8 @@ class IsolateWrappingAPI extends BaseAPI {
         if (message.isSubscription) {
           _pendingSubscriptions[message.eventId]?.add(message.response);
         } else {
+          print(
+              '#### Retrieved response ${(message.response as Response).msgType}');
           final Completer<dynamic>? completer = _pendingEvents[message.eventId];
           if (completer != null) {
             completer.complete(message.response);
@@ -362,6 +365,13 @@ class IsolateWrappingAPI extends BaseAPI {
           case CustomEvent.ticks:
             _pendingSubscriptions[message.eventId]?.add(message.data);
           case CustomEvent.proposalOpenContract:
+          case CustomEvent.authorize:
+            final AuthorizeReceive authorizeReceive =
+                message.data as AuthorizeReceive;
+            _pendingEvents[message.eventId]?.complete(authorizeReceive);
+          case CustomEvent.landingCompany:
+          case CustomEvent.statesList:
+          case CustomEvent.residenceList:
         }
       }
 
@@ -510,4 +520,14 @@ class IsolateWrappingAPI extends BaseAPI {
   Future<void> disconnect() async {
     _isolateSendPort?.send(_DisconnectEvent(eventId: _getEventId));
   }
+
+  Future<AuthorizeReceive> authorize(AuthorizeRequest request) {
+    final event = CustomIsolateEvent<AuthorizeReceive>(
+      request: request,
+      eventId: _getEventId,
+      event: CustomEvent.authorize,
+    );
+
+    return _callEvent(event);
+  }
 }

lib/services/connection/api_manager/isolate_events.dart

@@ -120,7 +120,11 @@ class CustomIsolateEvent<T> extends _IsolateEvent {
 
 enum CustomEvent {
   ping,
+  authorize,
+  landingCompany,
   activeSymbols,
+  statesList,
+  residenceList,
   assetIndex,
   balance,
   buy,

lib/services/connection/api_manager/isolate_task.dart

@@ -144,6 +144,21 @@ void _handleCustomEvent(
       });
 
     case CustomEvent.proposalOpenContract:
+    case CustomEvent.authorize:
+      final AuthorizeReceive response = await api.call(
+        request: message.request,
+      );
+
+      checkException(
+        response: response,
+        exceptionCreator: ({BaseExceptionModel? baseExceptionModel}) =>
+            BaseAPIException(baseExceptionModel: baseExceptionModel),
+      );
+
+      sendPort.send(message.copyWith(data: response));
+    case CustomEvent.landingCompany:
+    case CustomEvent.statesList:
+    case CustomEvent.residenceList:
   }
 }