diff options
author | Claire <claire.github-309c@sitedethib.com> | 2022-04-07 16:08:17 +0200 |
---|---|---|
committer | Claire <claire.github-309c@sitedethib.com> | 2022-04-08 20:02:49 +0200 |
commit | 43aff90d0ee4abbb24a3b1ad8c2f83692f1925b3 (patch) | |
tree | 42d1332cca9ec6bbc75db6361f46e81effffd6eb /app/javascript | |
parent | ff73d43b3596d50d071fd3e6ab6f49608b62c9d1 (diff) |
[Glitch] Fix potentially missing statuses when reconnecting to websocket
Port ebe01ea194104b14af6cd6abe6d20637f1a3e140 to glitch-soc Signed-off-by: Claire <claire.github-309c@sitedethib.com>
Diffstat (limited to 'app/javascript')
-rw-r--r-- | app/javascript/flavours/glitch/actions/timelines.js | 1 | ||||
-rw-r--r-- | app/javascript/flavours/glitch/reducers/timelines.js | 13 |
2 files changed, 13 insertions, 1 deletions
diff --git a/app/javascript/flavours/glitch/actions/timelines.js b/app/javascript/flavours/glitch/actions/timelines.js index 24cc0d63f..71d5fff97 100644 --- a/app/javascript/flavours/glitch/actions/timelines.js +++ b/app/javascript/flavours/glitch/actions/timelines.js @@ -199,6 +199,7 @@ export function connectTimeline(timeline) { return { type: TIMELINE_CONNECT, timeline, + usePendingItems: preferPendingItems, }; }; diff --git a/app/javascript/flavours/glitch/reducers/timelines.js b/app/javascript/flavours/glitch/reducers/timelines.js index 29e02a864..afd9d12cb 100644 --- a/app/javascript/flavours/glitch/reducers/timelines.js +++ b/app/javascript/flavours/glitch/reducers/timelines.js @@ -177,6 +177,17 @@ const updateTop = (state, timeline, top) => { })); }; +const reconnectTimeline = (state, usePendingItems) => { + if (state.get('online')) { + return state; + } + + return state.withMutations(mMap => { + mMap.update(usePendingItems ? 'pendingItems' : 'items', items => items.first() ? items.unshift(null) : items); + mMap.set('online', true); + }); +}; + export default function timelines(state = initialState, action) { switch(action.type) { case TIMELINE_LOAD_PENDING: @@ -202,7 +213,7 @@ export default function timelines(state = initialState, action) { case TIMELINE_SCROLL_TOP: return updateTop(state, action.timeline, action.top); case TIMELINE_CONNECT: - return state.update(action.timeline, initialTimeline, map => map.set('online', true)); + return state.update(action.timeline, initialTimeline, map => reconnectTimeline(map, action.usePendingItems)); case TIMELINE_DISCONNECT: return state.update( action.timeline, |