[keyserver] add tests to creating `olm` session without OTKs
ClosedPublic
Actions

Show First 20 Lines • Show All 97 Lines • ▼ Show 20 Lines	[
identityClient,		identityClient,
primaryDeviceRequestedLogOut,		primaryDeviceRequestedLogOut,
],		],
);		);
}		}

function usePeerToPeerMessageHandler(): (		function usePeerToPeerMessageHandler(): (
message: PeerToPeerMessage,		message: PeerToPeerMessage,
messageID: string,
) => Promise<void> {		) => Promise<void> {
const { olmAPI, sqliteAPI } = getConfig();		const { olmAPI, sqliteAPI } = getConfig();

const identityContext = React.useContext(IdentityClientContext);		const identityContext = React.useContext(IdentityClientContext);
invariant(identityContext, 'Identity context should be set');		invariant(identityContext, 'Identity context should be set');
const { identityClient, getAuthMetadata } = identityContext;		const { identityClient, getAuthMetadata } = identityContext;

const foreignPeerDevices = useSelector(getForeignPeerDevices);		const foreignPeerDevices = useSelector(getForeignPeerDevices);
const broadcastDeviceListUpdates = useBroadcastDeviceListUpdates();		const broadcastDeviceListUpdates = useBroadcastDeviceListUpdates();
const getAndUpdateDeviceListsForUsers = useGetAndUpdateDeviceListsForUsers();		const getAndUpdateDeviceListsForUsers = useGetAndUpdateDeviceListsForUsers();

const handleOlmMessageToDevice = useHandleOlmMessageToDevice();		const handleOlmMessageToDevice = useHandleOlmMessageToDevice();

return React.useCallback(		return React.useCallback(
async (message: PeerToPeerMessage, messageID: string) => {		async (message: PeerToPeerMessage) => {
if (message.type === peerToPeerMessageTypes.OUTBOUND_SESSION_CREATION) {		if (message.type === peerToPeerMessageTypes.OUTBOUND_SESSION_CREATION) {
const { senderInfo, encryptedData, sessionVersion } = message;		const { senderInfo, encryptedData, sessionVersion } = message;
const { userID: senderUserID, deviceID: senderDeviceID } = senderInfo;		const { userID: senderUserID, deviceID: senderDeviceID } = senderInfo;

let deviceKeys: ?DeviceOlmInboundKeys = null;		let deviceKeys: ?DeviceOlmInboundKeys = null;
try {		try {
const { keys } =		const { keys } =
await identityClient.getInboundKeysForUser(senderUserID);		await identityClient.getInboundKeysForUser(senderUserID);
▲ Show 20 Lines • Show All 59 Lines • ▼ Show 20 Lines	async (message: PeerToPeerMessage) => {
`${senderDeviceID}: ${e.message}, ` +		`${senderDeviceID}: ${e.message}, ` +
`session version: ${sessionVersion}`,		`session version: ${sessionVersion}`,
);		);
}		}
}		}
} else if (message.type === peerToPeerMessageTypes.ENCRYPTED_MESSAGE) {		} else if (message.type === peerToPeerMessageTypes.ENCRYPTED_MESSAGE) {
try {		try {
await olmAPI.initializeCryptoAccount();		await olmAPI.initializeCryptoAccount();
const decrypted = await olmAPI.decryptSequentialAndPersist(		const decrypted = await olmAPI.decrypt(
message.encryptedData,		message.encryptedData,
message.senderInfo.deviceID,		message.senderInfo.deviceID,
messageID,
);		);
console.log(		console.log(
'Decrypted message from device ' +		'Decrypted message from device ' +
`${message.senderInfo.deviceID}: ${decrypted}`,		`${message.senderInfo.deviceID}: ${decrypted}`,
);		);

try {		try {
await handleOlmMessageToDevice(decrypted, message.senderInfo);		await handleOlmMessageToDevice(decrypted, message.senderInfo);
▲ Show 20 Lines • Show All 119 Lines • Show Last 20 Lines

[keyserver] add tests to creating `olm` session without OTKsClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 40574

keyserver/src/utils/olm-utils.test.js

[keyserver] add tests to creating `olm` session without OTKs
ClosedPublic
Actions

Revision Contents
Changeset List