// @flow		// @flow

import {		import {
createAndSignInitialDeviceList,		createAndSignInitialDeviceList,
verifyAndGetDeviceList,		verifyAndGetDeviceList,
		addDeviceToDeviceList,
		removeDeviceFromDeviceList,
} from './device-list-utils.js';		} from './device-list-utils.js';
import type {		import type {
RawDeviceList,		RawDeviceList,
SignedDeviceList,		SignedDeviceList,
IdentityServiceClient,		IdentityServiceClient,
} from '../types/identity-service-types.js';		} from '../types/identity-service-types.js';
import * as config from '../utils/config.js';		import * as config from '../utils/config.js';
import { rawDeviceListFromSignedList } from '../utils/device-list-utils.js';		import { rawDeviceListFromSignedList } from '../utils/device-list-utils.js';
▲ Show 20 Lines • Show All 146 Lines • ▼ Show 20 Lines	it('creates initial device list', async () => {
const payload = await createAndSignInitialDeviceList('device1');		const payload = await createAndSignInitialDeviceList('device1');
expect(payload.curPrimarySignature).toStrictEqual('mock_signature');		expect(payload.curPrimarySignature).toStrictEqual('mock_signature');

const raw = rawDeviceListFromSignedList(payload);		const raw = rawDeviceListFromSignedList(payload);
expect(raw.devices).toStrictEqual(['device1']);		expect(raw.devices).toStrictEqual(['device1']);
});		});
});		});

		describe(addDeviceToDeviceList, () => {
		it('adds device to device list', async () => {
		mockOlmAPISign();

		const updates: $ReadOnlyArray<SignedDeviceList> = [
		createDeviceList({ devices: ['D1'], timestamp: 1 }),
		];
		const identityClient = mockIdentityClientWithDeviceListHistory(updates);

		await addDeviceToDeviceList(identityClient, 'user1', 'D2');

		expect(identityClient.updateDeviceList).toHaveBeenCalledWith(
		matchingSignedDeviceListWithDevices(['D1', 'D2']),
		);
		});

		it('skips adding device to device list if already exists', async () => {
		const updates: $ReadOnlyArray<SignedDeviceList> = [
		createDeviceList({ devices: ['D1', 'D2'], timestamp: 1 }),
		];
		const identityClient = mockIdentityClientWithDeviceListHistory(updates);

		await addDeviceToDeviceList(identityClient, 'user1', 'D2');

		expect(identityClient.updateDeviceList).not.toHaveBeenCalled();
		});
		});

		describe(removeDeviceFromDeviceList, () => {
		it('removes device from device list', async () => {
		mockOlmAPISign();

		const updates: $ReadOnlyArray<SignedDeviceList> = [
		createDeviceList({ devices: ['D1', 'D2'], timestamp: 1 }),
		];
		const identityClient = mockIdentityClientWithDeviceListHistory(updates);

		await removeDeviceFromDeviceList(identityClient, 'user1', 'D2');

		expect(identityClient.updateDeviceList).toHaveBeenCalledWith(
		matchingSignedDeviceListWithDevices(['D1']),
		);
		});

		it("skips removing device from device list if it doesn't exist", async () => {
		const updates: $ReadOnlyArray<SignedDeviceList> = [
		createDeviceList({ devices: ['D1'], timestamp: 1 }),
		];
		const identityClient = mockIdentityClientWithDeviceListHistory(updates);

		await removeDeviceFromDeviceList(identityClient, 'user1', 'D2');

		expect(identityClient.updateDeviceList).not.toHaveBeenCalled();
		});
		});

function createDeviceList(		function createDeviceList(
rawList: RawDeviceList,		rawList: RawDeviceList,
curPrimarySignature?: string,		curPrimarySignature?: string,
lastPrimarySignature?: string,		lastPrimarySignature?: string,
): SignedDeviceList {		): SignedDeviceList {
return {		return {
rawDeviceList: JSON.stringify(rawList),		rawDeviceList: JSON.stringify(rawList),
curPrimarySignature,		curPrimarySignature,
lastPrimarySignature,		lastPrimarySignature,
};		};
}		}

function mockIdentityClientWithDeviceListHistory(		function mockIdentityClientWithDeviceListHistory(
history: $ReadOnlyArray<SignedDeviceList>,		history: $ReadOnlyArray<SignedDeviceList>,
): IdentityServiceClient {		): IdentityServiceClient {
const client: Partial<IdentityServiceClient> = {		const client: Partial<IdentityServiceClient> = {
getDeviceListHistoryForUser: jest		getDeviceListHistoryForUser: jest
.fn<any, typeof history>()		.fn<any, typeof history>()
.mockResolvedValueOnce(history),		.mockResolvedValueOnce(history),
		updateDeviceList: jest.fn(),
};		};
return client;		return client;
}		}

function mockOlmAPIVerification(func: typeof jest.fn) {		function mockOlmAPIVerification(func: typeof jest.fn) {
const olmAPI: any = {		const olmAPI: any = {
verifyMessage: func,		verifyMessage: func,
};		};
const cfg: any = { olmAPI };		const cfg: any = { olmAPI };
config.registerConfig(cfg);		config.registerConfig(cfg);
}		}

function mockOlmAPISign(func: JestMockFn<[string], Promise<string>>) {		const defaultOlmAPISignMock = jest
		.fn<[string], string>()
		.mockResolvedValue('mock_signature');

		function mockOlmAPISign(
		func: JestMockFn<[string], Promise<string>> = defaultOlmAPISignMock,
		ed25519: string = 'fake_ed25519_public_key',
		) {
const olmAPI: any = {		const olmAPI: any = {
		initializeCryptoAccount: jest.fn(),
		getUserPublicKey: jest
		.fn<[], mixed>()
		.mockResolvedValue({ primaryIdentityPublicKeys: { ed25519 } }),
signMessage: func,		signMessage: func,
};		};
const cfg: any = { olmAPI };		const cfg: any = { olmAPI };
config.registerConfig(cfg);		config.registerConfig(cfg);
}		}

		function matchingSignedDeviceListWithDevices(
		devices: $ReadOnlyArray<string>,
		): Object {
		return expect.objectContaining({
		rawDeviceList: expect.stringContaining(
		// slice out closing braces to let it match timestamp
		JSON.stringify({ devices }).slice(0, -2),
		),
		});
		}

[lib] Update `isThreadWatched` to handle `RawThreadInfo`ClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 34321

lib/reducers/message-reducer.js

[lib] Update `isThreadWatched` to handle `RawThreadInfo`
ClosedPublic
Actions

Revision Contents
Changeset List