Page MenuHomePhorge
Files F33151077

D12776.1768511988.diff
No OneTemporary
Actions

Size
2 KB
Referenced Files
None
Subscribers
None

D12776.1768511988.diff
View Options

diff --git a/lib/shared/dm-ops/dm-op-utils.js b/lib/shared/dm-ops/dm-op-utils.js
new file mode 100644
--- /dev/null
+++ b/lib/shared/dm-ops/dm-op-utils.js
@@ -0,0 +1,69 @@
+// @flow
+
+import uuid from 'uuid';
+
+import type { AuxUserStore } from '../../types/aux-user-types.js';
+import type { DMOperation } from '../../types/dm-ops.js';
+import {
+ outboundP2PMessageStatuses,
+ type OutboundP2PMessage,
+} from '../../types/sqlite-types.js';
+import type { CurrentUserInfo } from '../../types/user-types.js';
+import { getContentSigningKey } from '../../utils/crypto-utils.js';
+import { values } from '../../utils/objects.js';
+
+function generateMessagesToPeers(
+ message: DMOperation,
+ peers: $ReadOnlyArray<string>,
+ userID: string,
+ supportsAutoRetry: boolean,
+): $ReadOnlyArray<OutboundP2PMessage> {
+ const outboundP2PMessages = [];
+ for (const peerID of peers) {
+ const messageToPeer: OutboundP2PMessage = {
+ messageID: uuid.v4(),
+ deviceID: peerID,
+ userID,
+ timestamp: new Date().getTime().toString(),
+ plaintext: JSON.stringify(message),
+ ciphertext: '',
+ status: outboundP2PMessageStatuses.persisted,
+ supportsAutoRetry,
+ };
+ outboundP2PMessages.push(messageToPeer);
+ }
+ return outboundP2PMessages;
+}
+
+export type DMOperationSpecification = {
+ +op: DMOperation,
+ +supportsAutoRetry: boolean,
+ +recipients: 'all_peer_devices' | 'self_devices',
+};
+
+async function createMessagesToPeersFromDMOp(
+ operation: DMOperationSpecification,
+ auxUserStore: AuxUserStore,
+ currentUserInfo: ?CurrentUserInfo,
+): Promise<$ReadOnlyArray<OutboundP2PMessage>> {
+ if (!currentUserInfo?.id) {
+ return [];
+ }
+ const selfDevices =
+ auxUserStore.auxUserInfos[currentUserInfo.id].deviceList?.devices ?? [];
+ const allPeerDevices = values(auxUserStore.auxUserInfos)
+ .map(info => info.deviceList?.devices ?? [])
+ .flat();
+ const devices =
+ operation.recipients === 'all_peer_devices' ? allPeerDevices : selfDevices;
+ const thisDeviceID = await getContentSigningKey();
+ const targetDevices = devices.filter(id => id !== thisDeviceID);
+ return generateMessagesToPeers(
+ operation.op,
+ targetDevices,
+ currentUserInfo.id,
+ operation.supportsAutoRetry,
+ );
+}
+
+export { createMessagesToPeersFromDMOp };

File Metadata

Mime Type
text/plain
Expires
Thu, Jan 15, 9:19 PM (8 h, 52 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5940109
Default Alt Text
D12776.1768511988.diff (2 KB)

Event Timeline