diff --git a/src/lib/core/handlers/ws_messageSender.ts b/src/lib/core/handlers/ws_messageSender.ts index 8719e34..852dfcb 100644 --- a/src/lib/core/handlers/ws_messageSender.ts +++ b/src/lib/core/handlers/ws_messageSender.ts @@ -74,7 +74,7 @@ export async function sendMessage( // console.log('send v2', APP_VERSION, semver.satisfies(APP_VERSION, '^0.0.2')); if (semver.satisfies(APP_VERSION, '^0.0.2')) { - console.log('sending secured'); + // console.log('sending secured'); let sharedKeyRes = get(sharedKey); // do encrypt diff --git a/src/lib/core/stores/websocketStore.ts b/src/lib/core/stores/websocketStore.ts index 23de68c..4fa779c 100644 --- a/src/lib/core/stores/websocketStore.ts +++ b/src/lib/core/stores/websocketStore.ts @@ -123,6 +123,7 @@ export async function connectToWebsocket(id_token?: string) { socketConnectionOfflineCount.set(0); socketAlreadySendHeartbeat.set(0); + id_token = await auth.currentUser?.getIdToken(true); await connectToWebsocket(id_token); return; @@ -146,6 +147,7 @@ export async function connectToWebsocket(id_token?: string) { console.log('try reconnect websocket ...'); // retry again reconnectTimeout = setTimeout(async () => { + id_token = await auth.currentUser?.getIdToken(true); await connectToWebsocket(id_token); }, 5000); } @@ -165,7 +167,10 @@ export async function connectToWebsocket(id_token?: string) { if (auth.currentUser && !socket) { console.log('try reconnect websocket ...'); // retry again - reconnectTimeout = setTimeout(async () => await connectToWebsocket(id_token), 5000); + reconnectTimeout = setTimeout(async () => { + id_token = await auth.currentUser?.getIdToken(true); + await connectToWebsocket(id_token); + }, 5000); } });