feat: add callbackConnected to createToken

Author: chopper985

lib/core/websocket/interfaces/ws_handler.dart

@@ -1,7 +1,10 @@
 import 'package:socket_io_client/socket_io_client.dart';
 
 abstract class WsHandler {
-  void establishConnection({bool forceConnection = false});
+  void establishConnection({
+    bool forceConnection = false,
+    Function()? callbackConnected,
+  });
   void disconnection();
   void reconnect({required Function callbackConnected});
 

lib/flutter_waterbus_sdk.dart

@@ -292,8 +292,14 @@ class WaterbusSdk {
   }
 
   // Auth
-  Future<Result<User>> createToken(AuthPayload payload) async {
-    return await _sdk.createToken(payload: payload);
+  Future<Result<User>> createToken(
+    AuthPayload payload, {
+    Function()? callbackConnected,
+  }) async {
+    return await _sdk.createToken(
+      payload: payload,
+      callbackConnected: callbackConnected,
+    );
   }
 
   Future<Result<bool>> deleteToken() async {

lib/waterbus_sdk_impl.dart

@@ -383,11 +383,17 @@ class SdkCore extends WaterbusSdkInterface {
 
   // Auth
   @override
-  Future<Result<User>> createToken({required AuthPayload payload}) async {
+  Future<Result<User>> createToken({
+    required AuthPayload payload,
+    Function()? callbackConnected,
+  }) async {
     final Result<User> user = await _authRepository.createToken(payload);
 
     if (user.isSuccess) {
-      _wsHandler.establishConnection(forceConnection: true);
+      _wsHandler.establishConnection(
+        forceConnection: true,
+        callbackConnected: callbackConnected,
+      );
     }
 
     return user;

lib/waterbus_sdk_interface.dart

@@ -6,7 +6,10 @@ abstract class WaterbusSdkInterface {
   Future<void> initializeApp();
 
   // Auth
-  Future<Result<User>> createToken({required AuthPayload payload});
+  Future<Result<User>> createToken({
+    required AuthPayload payload,
+    Function()? callbackConnected,
+  });
   Future<Result<bool>> deleteToken();
   Future<Result<bool>> renewToken();