From 1b1275b2f4ae9958d579787c2a65a14b604eba21 Mon Sep 17 00:00:00 2001
From: maxxkim <maxxkim@ya.ru>
Date: Mon, 1 Jul 2024 17:01:13 +0300
Subject: [PATCH] fix(git): Conflict resolve

---
 .../initialization_cubit.dart                 | 46 +++++++++++++++++--
 1 file changed, 42 insertions(+), 4 deletions(-)

diff --git a/lib/core/initialization_cubit/initialization_cubit.dart b/lib/core/initialization_cubit/initialization_cubit.dart
index 89385689..2dabef59 100644
--- a/lib/core/initialization_cubit/initialization_cubit.dart
+++ b/lib/core/initialization_cubit/initialization_cubit.dart
@@ -2,7 +2,6 @@ import 'package:eatvio_app/core/app_export.dart';
 import 'package:eatvio_app/core/initialization_cubit/initialization_state.dart';
 import 'package:eatvio_app/core/token_storage.dart';
 import 'package:eatvio_app/features/chat/repositories/chat_repository.dart';
-import 'package:pusher_client/pusher_client.dart';
 
 class InitializationCubit extends Cubit<InitializationState> {
   final ChatRepository chatRepository;
@@ -12,9 +11,48 @@ class InitializationCubit extends Cubit<InitializationState> {
   runInitialization() async {
     try {
       await TokenStorage.haveTokenInStorage();
-
-      final wsUrl = await chatRepository.getWebsocket();
-
+      // final wsUrl = await chatRepository.getWebsocket();
+      // final options = PusherChannelsOptions.fromHost(
+      //   scheme: 'wss',
+      //   key: wsUrl.key,
+      //   host: wsUrl.host,
+      //   shouldSupplyMetadataQueries: true,
+      //   metadata: PusherChannelsOptionsMetadata.byDefault(),
+      //   port: 443,
+      // );
+      // final client = PusherChannelsClient.websocket(
+      //   options: options,
+      //   connectionErrorHandler: (exception, trace, refresh) {
+      //     refresh();
+      //   },
+      //   minimumReconnectDelayDuration: const Duration(
+      //     seconds: 1,
+      //   ),
+      //   defaultActivityDuration: const Duration(
+      //     seconds: 120,
+      //   ),
+      //   activityDurationOverride: const Duration(
+      //     seconds: 120,
+      //   ),
+      //   waitForPongDuration: const Duration(
+      //     seconds: 30,
+      //   ),
+      // );
+      // await client.connect();
+      // final myPrivateChannel = client.privateChannel(
+      //   'private-message-events.${wsUrl.userId}',
+      //   authorizationDelegate: EndpointAuthorizableChannelTokenAuthorizationDelegate.forPrivateChannel(
+      //     authorizationEndpoint: Uri.parse('https://mobile-stage.eatvio.ru/broadcasting/auth'),
+      //     headers: {
+      //       'Authorization' : 'Bearer ${await TokenStorage.getTokenFromStorage()}',
+      //     },
+      //   ),
+      // );
+      // myPrivateChannel.subscribe();
+      // myPrivateChannel.bindToAll().listen((event) {
+      //   print(event.name);
+      // });
+      emit(const InitializationState.success());
     } catch (e) {
       print(e);
       emit(InitializationState.error(errorMessage: e.toString()));