ThatOneJackalGuy/OpenContacts
1
0
Fork 0
Code Issues 2 Pull requests Projects Releases 2 Packages Wiki Activity Actions

Hook up RemoveSession socket event

Browse source
This commit is contained in:
Nutcake 2023-10-03 18:36:41 +02:00
parent bace94b6d2
commit 890a931cb4
1 changed files with 18 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
lib/clients/messaging_client.dart
View file

@ -250,6 +250,7 @@ class MessagingClient extends ChangeNotifier {
_hubManager.setHandler(EventTarget.messagesRead, _onMessagesRead); _hubManager.setHandler(EventTarget.messagesRead, _onMessagesRead);
_hubManager.setHandler(EventTarget.receiveStatusUpdate, _onReceiveStatusUpdate); _hubManager.setHandler(EventTarget.receiveStatusUpdate, _onReceiveStatusUpdate);
_hubManager.setHandler(EventTarget.receiveSessionUpdate, _onReceiveSessionUpdate); _hubManager.setHandler(EventTarget.receiveSessionUpdate, _onReceiveSessionUpdate);
_hubManager.setHandler(EventTarget.removeSession, _onRemoveSession);
await _hubManager.start(); await _hubManager.start();
await setUserStatus(userStatus); await setUserStatus(userStatus);
@ -309,24 +310,28 @@ class MessagingClient extends ChangeNotifier {
} }
void _onReceiveStatusUpdate(List args) { void _onReceiveStatusUpdate(List args) {
for (final statusUpdate in args) { final statusUpdate = args[0];
var status = UserStatus.fromMap(statusUpdate); var status = UserStatus.fromMap(statusUpdate);
final sessionMap = createSessionMap(status.hashSalt); final sessionMap = createSessionMap(status.hashSalt);
status = status.copyWith( status = status.copyWith(
sessionData: status.sessions.map((e) => sessionMap[e.sessionHash] ?? Session.none()).toList()); sessionData: status.sessions.map((e) => sessionMap[e.sessionHash] ?? Session.none()).toList());
final friend = getAsFriend(statusUpdate["userId"])?.copyWith(userStatus: status); final friend = getAsFriend(statusUpdate["userId"])?.copyWith(userStatus: status);
if (friend != null) { if (friend != null) {
_updateContact(friend); _updateContact(friend);
}
} }
notifyListeners(); notifyListeners();
} }
void _onReceiveSessionUpdate(List args) { void _onReceiveSessionUpdate(List args) {
for (final sessionUpdate in args) { final sessionUpdate = args[0];
final session = Session.fromMap(sessionUpdate); final session = Session.fromMap(sessionUpdate);
_sessionMap[session.id] = session; _sessionMap[session.id] = session;
} notifyListeners();
}
void _onRemoveSession(List args) {
final session = args[0];
_sessionMap.remove(session);
notifyListeners(); notifyListeners();
} }
} }