D13898.diff
No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

D13898.diff
View Options

	diff --git a/web/shared-worker/worker/shared-worker.js b/web/shared-worker/worker/shared-worker.js
	--- a/web/shared-worker/worker/shared-worker.js
	+++ b/web/shared-worker/worker/shared-worker.js
	@@ -291,6 +291,15 @@
	type: workerResponseMessageTypes.GET_MESSAGES,
	messages: webMessageEntities.map(webMessageToClientDBMessageInfo),
	};
	+ } else if (
	+ message.type === workerRequestMessageTypes.GET_INBOUND_P2P_MESSAGES_BY_ID
	+ ) {
	+ return {
	+ type: workerResponseMessageTypes.GET_INBOUND_P2P_MESSAGES,
	+ inboundP2PMessages: sqliteQueryExecutor.getInboundP2PMessagesByID(
	+ message.messageIDs,
	+ ),
	+ };
	}

	// write operations
	diff --git a/web/types/worker-types.js b/web/types/worker-types.js
	--- a/web/types/worker-types.js
	+++ b/web/types/worker-types.js
	@@ -49,6 +49,7 @@
	SEARCH_MESSAGES: 23,
	RESET_OUTBOUND_P2P_MESSAGES: 24,
	FETCH_MESSAGES: 25,
	+ GET_INBOUND_P2P_MESSAGES_BY_ID: 26,
	});

	export const workerWriteRequests: $ReadOnlyArray<number> = [
	@@ -225,6 +226,11 @@
	+offset: number,
	};

	+export type GetInboundP2PMessagesByIDRequestMessage = {
	+ +type: 26,
	+ +messageIDs: $ReadOnlyArray<string>,
	+};
	+
	export type WorkerRequestMessage =
	\| PingWorkerRequestMessage
	\| InitWorkerRequestMessage
	@@ -251,7 +257,8 @@
	\| GetOutboundP2PMessagesByIDRequestMessage
	\| SearchMessagesRequestMessage
	\| ResetOutboundP2PMessagesRequestMessage
	- \| FetchMessagesRequestMessage;
	+ \| FetchMessagesRequestMessage
	+ \| GetInboundP2PMessagesByIDRequestMessage;

	export type WorkerRequestProxyMessage = {
	+id: number,