fix websockets
This commit is contained in:
parent
e61c41e414
commit
7b11266f72
1 changed files with 10 additions and 0 deletions
|
|
@ -244,6 +244,16 @@ function connect(): void {
|
||||||
isConnectedStore.set(true);
|
isConnectedStore.set(true);
|
||||||
clearReconnectTimer();
|
clearReconnectTimer();
|
||||||
subscribeToChannels();
|
subscribeToChannels();
|
||||||
|
|
||||||
|
USER_DATA.subscribe(user => {
|
||||||
|
if (user?.id && isSocketConnected()) {
|
||||||
|
console.log('Setting user subscription for user:', user.id);
|
||||||
|
socket!.send(JSON.stringify({
|
||||||
|
type: 'set_user',
|
||||||
|
userId: String(user.id)
|
||||||
|
}));
|
||||||
|
}
|
||||||
|
})();
|
||||||
};
|
};
|
||||||
|
|
||||||
socket.onmessage = handleWebSocketMessage;
|
socket.onmessage = handleWebSocketMessage;
|
||||||
|
|
|
||||||
Reference in a new issue