Page MenuHomePhabricator
Files F3103951

D13802.id45417.diff
No OneTemporary
Actions

D13802.id45417.diff
View Options

diff --git a/lib/tunnelbroker/peer-to-peer-message-handler.js b/lib/tunnelbroker/peer-to-peer-message-handler.js
--- a/lib/tunnelbroker/peer-to-peer-message-handler.js
+++ b/lib/tunnelbroker/peer-to-peer-message-handler.js
@@ -9,6 +9,7 @@
} from './use-peer-to-peer-message-handler.js';
import { useLoggedInUserInfo } from '../hooks/account-hooks.js';
import { useActionsQueue } from '../hooks/actions-queue.js';
+import { usePersistedStateLoaded } from '../selectors/app-state-selectors.js';
import type { InboundP2PMessage } from '../types/sqlite-types.js';
import type { MessageReceiveConfirmation } from '../types/tunnelbroker/message-receive-confirmation-types.js';
import {
@@ -34,6 +35,7 @@
const { addListener, removeListener } = useTunnelbroker();
const peerToPeerMessageHandler = usePeerToPeerMessageHandler();
const handleOlmMessageToDevice = useHandleOlmMessageToDevice();
+ const persistedStateLoaded = usePersistedStateLoaded();
const processItem = React.useCallback(
async (
@@ -180,12 +182,16 @@
const processingInputMessagesStarted = React.useRef(false);
React.useEffect(() => {
- if (!viewerID || processingInputMessagesStarted.current) {
+ if (
+ !viewerID ||
+ processingInputMessagesStarted.current ||
+ !persistedStateLoaded
+ ) {
return;
}
processingInputMessagesStarted.current = true;
void processPersistedInboundMessages();
- }, [processPersistedInboundMessages, viewerID]);
+ }, [processPersistedInboundMessages, viewerID, persistedStateLoaded]);
}
export { PeerToPeerMessageHandler };

File Metadata

Mime Type
text/plain
Expires
Thu, Oct 31, 2:29 PM (20 h, 11 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2393153
Default Alt Text
D13802.id45417.diff (1 KB)

Event Timeline