Page MenuHomePhabricator
Differential D10777

[lib] Create content Olm session
ClosedPublic
Actions

Authored by tomek on Jan 22 2024, 4:54 AM.
Tags
None
Referenced Files
Unknown Object (File)
Tue, Apr 8, 10:00 PM
Unknown Object (File)
Tue, Apr 8, 8:19 PM
Unknown Object (File)
Feb 22 2025, 2:35 PM
Unknown Object (File)
Feb 22 2025, 2:35 PM
Unknown Object (File)
Feb 22 2025, 2:34 PM
Unknown Object (File)
Feb 22 2025, 2:34 PM
Unknown Object (File)
Feb 20 2025, 2:27 PM
Unknown Object (File)
Feb 13 2025, 1:35 PM
View All 69 Files
Subscribers
ashoat

Details

Reviewers
varun
inka
kamil
Commits
rCOMM20418cf5ac19: [lib] Create content Olm session
Summary

Use the keyserver keys to create the sessions.

Depends on D10667

Test Plan

Get access token, set it, and check if the session is created correctly... which returns a bad signature error due to https://linear.app/comm/issue/ENG-6468/decide-on-one-time-keys-format

Diff Detail

Repository
rCOMM Comm
Branch
handlers-2
Lint
No Lint Coverage
Unit
No Test Coverage

Revision Contents
Changeset List

PathSize
lib/
components/
19 lines

Diff 35953

View Options

lib/components/keyserver-connection-handler.js

// @flow // @flow
import { unsupervisedBackgroundActionType } from './lifecycle-state-reducer.js'; import { unsupervisedBackgroundActionType } from './lifecycle-state-reducer.js';
import { updateActivityActionTypes } from '../actions/activity-actions.js'; import { updateActivityActionTypes } from '../actions/activity-actions.js';
import { setClientDBStoreActionType } from '../actions/client-db-store-actions.js';
import { import {
updateLastCommunicatedPlatformDetailsActionType, updateLastCommunicatedPlatformDetailsActionType,
setDeviceTokenActionTypes, setDeviceTokenActionTypes,
} from '../actions/device-actions.js'; } from '../actions/device-actions.js';
import { import {
addKeyserverActionType, addKeyserverActionType,
removeKeyserverActionType, removeKeyserverActionType,
} from '../actions/keyserver-actions.js'; } from '../actions/keyserver-actions.js';
Show All 10 Lines
import { setNewSessionActionType } from '../keyserver-conn/keyserver-conn-types.js'; import { setNewSessionActionType } from '../keyserver-conn/keyserver-conn-types.js';
import { import {
keyserverStoreOpsHandlers, keyserverStoreOpsHandlers,
type ReplaceKeyserverOperation, type ReplaceKeyserverOperation,
type RemoveKeyserversOperation, type RemoveKeyserversOperation,
type KeyserverStoreOperation, type KeyserverStoreOperation,
} from '../ops/keyserver-store-ops.js'; } from '../ops/keyserver-store-ops.js';
import { queueActivityUpdatesActionType } from '../types/activity-types.js'; import { queueActivityUpdatesActionType } from '../types/activity-types.js';
import type { KeyserverStore } from '../types/keyserver-types.js'; import type {
KeyserverInfos,
KeyserverStore,
} from '../types/keyserver-types.js';
import type { BaseAction } from '../types/redux-types.js'; import type { BaseAction } from '../types/redux-types.js';
import { import {
fullStateSyncActionType, fullStateSyncActionType,
incrementalStateSyncActionType, incrementalStateSyncActionType,
updateConnectionStatusActionType, updateConnectionStatusActionType,
setLateResponseActionType, setLateResponseActionType,
updateKeyserverReachabilityActionType, updateKeyserverReachabilityActionType,
setConnectionIssueActionType, setConnectionIssueActionType,
} from '../types/socket-types.js'; } from '../types/socket-types.js';
import { updateTypes } from '../types/update-types-enum.js'; import { updateTypes } from '../types/update-types-enum.js';
import { processUpdatesActionType } from '../types/update-types.js'; import { processUpdatesActionType } from '../types/update-types.js';
import { getConfig } from '../utils/config.js'; import { getConfig } from '../utils/config.js';
import { getMessageForException } from '../utils/errors.js';
import { assertObjectsAreEqual } from '../utils/objects.js';
import { setURLPrefix } from '../utils/url-utils.js'; import { setURLPrefix } from '../utils/url-utils.js';
import { ashoatKeyserverID } from '../utils/validation-utils.js'; import { ashoatKeyserverID } from '../utils/validation-utils.js';
function assertKeyserverStoresAreEqual(
processedKeyserverStore: KeyserverInfos,
expectedKeyserverStore: KeyserverInfos,
location: string,
onStateDifference?: (message: string) => mixed,
) {
try {
assertObjectsAreEqual(
processedKeyserverStore,
expectedKeyserverStore,
`KeyserverInfos - ${location}`,
);
} catch (e) {
console.log(
'Error processing KeyserverStore ops',
processedKeyserverStore,
expectedKeyserverStore,
);
const message = `Error processing KeyserverStore ops ${
getMessageForException(e) ?? '{no exception message}'
}`;
onStateDifference?.(message);
}
}
const { processStoreOperations: processStoreOps } = keyserverStoreOpsHandlers; const { processStoreOperations: processStoreOps } = keyserverStoreOpsHandlers;
export default function reduceKeyserverStore( export default function reduceKeyserverStore(
state: KeyserverStore, state: KeyserverStore,
action: BaseAction, action: BaseAction,
onStateDifference?: (message: string) => mixed,
): { ): {
keyserverStore: KeyserverStore, keyserverStore: KeyserverStore,
keyserverStoreOperations: $ReadOnlyArray<KeyserverStoreOperation>, keyserverStoreOperations: $ReadOnlyArray<KeyserverStoreOperation>,
} { } {
if (action.type === addKeyserverActionType) { if (action.type === addKeyserverActionType) {
const replaceOperation: ReplaceKeyserverOperation = { const replaceOperation: ReplaceKeyserverOperation = {
type: 'replace_keyserver', type: 'replace_keyserver',
payload: { payload: {
▲ Show 20 Lines • Show All 548 Lines • ▼ Show 20 Lines ) {
}; };
return { return {
keyserverStore: { keyserverStore: {
...state, ...state,
keyserverInfos: processStoreOps(state.keyserverInfos, [operation]), keyserverInfos: processStoreOps(state.keyserverInfos, [operation]),
}, },
keyserverStoreOperations: [operation], keyserverStoreOperations: [operation],
}; };
} else if (action.type === setClientDBStoreActionType) {
// Once the functionality is confirmed to work correctly,
// we will proceed with returning keyserverInfos from the payload.
assertKeyserverStoresAreEqual(
action.payload.keyserverInfos ?? {},
state.keyserverInfos,
action.type,
onStateDifference,
);
return {
keyserverStore: state,
keyserverStoreOperations: [],
};
} }
return { return {
keyserverStore: state, keyserverStore: state,
keyserverStoreOperations: [], keyserverStoreOperations: [],
}; };
} }