summaryrefslogtreecommitdiff
path: root/src/client/scripts/stream.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/client/scripts/stream.ts')
-rw-r--r--src/client/scripts/stream.ts8
1 files changed, 7 insertions, 1 deletions
diff --git a/src/client/scripts/stream.ts b/src/client/scripts/stream.ts
index 8a525ba002..defb22af8e 100644
--- a/src/client/scripts/stream.ts
+++ b/src/client/scripts/stream.ts
@@ -3,6 +3,7 @@ import { EventEmitter } from 'eventemitter3';
import ReconnectingWebsocket from 'reconnecting-websocket';
import { wsUrl } from '../config';
import MiOS from '../mios';
+import { query as urlQuery } from '../../prelude/url';
/**
* Misskey stream connection
@@ -21,7 +22,12 @@ export default class Stream extends EventEmitter {
const user = os.store.state.i;
- this.stream = new ReconnectingWebsocket(wsUrl + (user ? `?i=${user.token}` : ''), '', { minReconnectionDelay: 1 }); // https://github.com/pladaria/reconnecting-websocket/issues/91
+ const query = urlQuery({
+ i: user?.token,
+ _t: Date.now(),
+ });
+
+ this.stream = new ReconnectingWebsocket(`${wsUrl}?${query}`, '', { minReconnectionDelay: 1 }); // https://github.com/pladaria/reconnecting-websocket/issues/91
this.stream.addEventListener('open', this.onOpen);
this.stream.addEventListener('close', this.onClose);
this.stream.addEventListener('message', this.onMessage);