Hasan/eatvio_app
1
0
Fork 0
forked from eatvio/eatvio_app
Code Pull Requests Activity

feat(chat): fix native analyze

Browse Source
This commit is contained in:
mso7nueh
2024-06-27 10:44:33 +03:00
parent b1b6ffe0f3
commit f8bfe36f47
6 changed files with 60 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
lib/core/initialization_cubit/initialization_cubit.dart
View File

@@ -5,8 +5,6 @@ import 'package:eatvio_app/features/chat/repositories/chat_repository.dart';
import 'package:pusher_client/pusher_client.dart';
class InitializationCubit extends Cubit<InitializationState> {
late final webSocketChannel;
final ChatRepository chatRepository;
InitializationCubit({required this.chatRepository}) : super(const InitializationState.loading());
@@ -29,20 +27,27 @@ class InitializationCubit extends Cubit<InitializationState> {
),
);
PusherClient pusher = PusherClient(
PusherClient pusherClient = PusherClient(
wsUrl.key,
options,
autoConnect: true,
enableLogging: true,
);
await pusher.connect();
// Channel channel = pusher.subscribe('private-direct-chat.');
// channel.registerListener(classId, method);
await pusherClient.connect();
emit(const InitializationState.success());
Channel channel = pusherClient.subscribe('private-direct-chat.' + '7909ea56-7822-4d5f-8892-134bc937127f');
channel.bind("pusher_internal:subscription_succeeded", (PusherEvent? event) {
channel.trigger("pusher_internal:subscription_succeeded", {});
});
channel.registerListener('pusher:subscribe', (data) => print(data.toString()));
} catch (e) {
print(e);
emit(InitializationState.error(errorMessage: e.toString()));
}
}