hj/pleroma-fe
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

fix streaming

Browse source
This commit is contained in:
Henry Jameson 2026-08-25 18:13:38 +03:00
commit b18c3733d6
2 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

1
src/stores/streaming.js
View file

@ -131,6 +131,7 @@ export const useStreamingStore = defineStore('streaming', {
}, },
getSubArgs(stream) { getSubArgs(stream) {
if (stream === undefined) return undefined
const argumentKey = ARGUMENT_MAP[stream.name] const argumentKey = ARGUMENT_MAP[stream.name]
const args = argumentKey const args = argumentKey
? { ? {

9
src/stores/timelines.js
View file

@ -105,10 +105,9 @@ export const useTimelinesStore = defineStore('timelines', {
const openHandler = () => this.onStreamConnect(timelineName, argument) const openHandler = () => this.onStreamConnect(timelineName, argument)
const closeHandler = () => const closeHandler = () =>
this.onStreamDisconnect(timelineName, argument) this.onStreamDisconnect(timelineName, argument)
const messageHandler = const messageHandler = (message) => {
() => this.onStreamMessage(timelineName, argument, message)
({ detail: message }) => }
this.onStreamMessage(timelineName, argument, message)
et.addEventListener('open', openHandler) et.addEventListener('open', openHandler)
et.addEventListener('close', closeHandler) et.addEventListener('close', closeHandler)
@ -231,7 +230,7 @@ export const useTimelinesStore = defineStore('timelines', {
}, },
onStreamMessage(timeline, argument, event) { onStreamMessage(timeline, argument, event) {
this.addStatusesToTimeline(timeline, argument, { this.addStatusesToTimeline(timeline, argument, {
statuses: [event.data.status.id], statuses: event.data.map(({ id }) => id),
}) })
}, },