Page MenuHomePhabricator
Differential D12768

[Tunnelbroker] implement errors from FCM service
ClosedPublic
Actions

Authored by kamil on Jul 16 2024, 1:24 AM.
Tags
None
Referenced Files
Unknown Object (File)
Fri, Apr 18, 11:42 AM
Unknown Object (File)
Fri, Apr 18, 5:20 AM
Unknown Object (File)
Wed, Apr 16, 7:53 PM
Unknown Object (File)
Wed, Apr 16, 3:38 AM
Unknown Object (File)
Sun, Apr 13, 9:10 AM
Unknown Object (File)
Mon, Apr 7, 1:29 PM
Unknown Object (File)
Mon, Apr 7, 4:58 AM
Unknown Object (File)
Mar 9 2025, 7:34 AM
View All 71 Files
Subscribers
ashoat
tomek

Details

Reviewers
bartek
marcin
Commits
rCOMM46548e0657dd: [Tunnelbroker] implement errors from FCM service
Summary

Implementing response status described in Error codes for FCM failure conditions.

There is no error about an invalid device token, created: ENG-8824.

Depends on D12767

Test Plan

cargo check

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Revision Contents
Changeset List

PathSize
services/
tunnelbroker/
src/
notifs/
fcm/
2 lines
1 line
44 lines

Diff 42528

View Options

services/tunnelbroker/src/notifs/fcm/error.rs

Show All 36 Lines ): Promise<string> {
return commCoreModule.initializeContentInboundSession( return commCoreModule.initializeContentInboundSession(
identityKeys, identityKeys,
initialEncryptedData, initialEncryptedData,
contentIdentityKeys.ed25519, contentIdentityKeys.ed25519,
sessionVersion, sessionVersion,
overwrite, overwrite,
); );
}, },
isContentSessionInitialized: commCoreModule.isContentSessionInitialized,
async contentOutboundSessionCreator( async contentOutboundSessionCreator(
contentIdentityKeys: OLMIdentityKeys, contentIdentityKeys: OLMIdentityKeys,
contentInitializationInfo: OlmSessionInitializationInfo, contentInitializationInfo: OlmSessionInitializationInfo,
): Promise<OutboundSessionCreationResult> { ): Promise<OutboundSessionCreationResult> {
const { prekey, prekeySignature, oneTimeKey } = contentInitializationInfo; const { prekey, prekeySignature, oneTimeKey } = contentInitializationInfo;
const identityKeys = JSON.stringify({ const identityKeys = JSON.stringify({
curve25519: contentIdentityKeys.curve25519, curve25519: contentIdentityKeys.curve25519,
ed25519: contentIdentityKeys.ed25519, ed25519: contentIdentityKeys.ed25519,
Show All 37 Lines ): Promise<EncryptedData> {
return commCoreModule.initializeNotificationsOutboundSession( return commCoreModule.initializeNotificationsOutboundSession(
identityKeys, identityKeys,
prekey, prekey,
prekeySignature, prekeySignature,
oneTimeKey, oneTimeKey,
deviceID, deviceID,
); );
}, },
isPeerNotificationsSessionInitialized:
commCoreModule.isPeerNotificationsSessionInitialized,
async getOneTimeKeys(numberOfKeys: number): Promise<OneTimeKeysResultValues> { async getOneTimeKeys(numberOfKeys: number): Promise<OneTimeKeysResultValues> {
const { contentOneTimeKeys, notificationsOneTimeKeys } = const { contentOneTimeKeys, notificationsOneTimeKeys } =
await commCoreModule.getOneTimeKeys(numberOfKeys); await commCoreModule.getOneTimeKeys(numberOfKeys);
return { return {
contentOneTimeKeys: getOneTimeKeyValues(contentOneTimeKeys), contentOneTimeKeys: getOneTimeKeyValues(contentOneTimeKeys),
notificationsOneTimeKeys: getOneTimeKeyValues(notificationsOneTimeKeys), notificationsOneTimeKeys: getOneTimeKeyValues(notificationsOneTimeKeys),
}; };
}, },
Show All 37 Lines
View Options

services/tunnelbroker/src/notifs/fcm/mod.rs

Show All 36 Lines ): Promise<string> {
return commCoreModule.initializeContentInboundSession( return commCoreModule.initializeContentInboundSession(
identityKeys, identityKeys,
initialEncryptedData, initialEncryptedData,
contentIdentityKeys.ed25519, contentIdentityKeys.ed25519,
sessionVersion, sessionVersion,
overwrite, overwrite,
); );
}, },
isContentSessionInitialized: commCoreModule.isContentSessionInitialized,
async contentOutboundSessionCreator( async contentOutboundSessionCreator(
contentIdentityKeys: OLMIdentityKeys, contentIdentityKeys: OLMIdentityKeys,
contentInitializationInfo: OlmSessionInitializationInfo, contentInitializationInfo: OlmSessionInitializationInfo,
): Promise<OutboundSessionCreationResult> { ): Promise<OutboundSessionCreationResult> {
const { prekey, prekeySignature, oneTimeKey } = contentInitializationInfo; const { prekey, prekeySignature, oneTimeKey } = contentInitializationInfo;
const identityKeys = JSON.stringify({ const identityKeys = JSON.stringify({
curve25519: contentIdentityKeys.curve25519, curve25519: contentIdentityKeys.curve25519,
ed25519: contentIdentityKeys.ed25519, ed25519: contentIdentityKeys.ed25519,
Show All 37 Lines ): Promise<EncryptedData> {
return commCoreModule.initializeNotificationsOutboundSession( return commCoreModule.initializeNotificationsOutboundSession(
identityKeys, identityKeys,
prekey, prekey,
prekeySignature, prekeySignature,
oneTimeKey, oneTimeKey,
deviceID, deviceID,
); );
}, },
isPeerNotificationsSessionInitialized:
commCoreModule.isPeerNotificationsSessionInitialized,
async getOneTimeKeys(numberOfKeys: number): Promise<OneTimeKeysResultValues> { async getOneTimeKeys(numberOfKeys: number): Promise<OneTimeKeysResultValues> {
const { contentOneTimeKeys, notificationsOneTimeKeys } = const { contentOneTimeKeys, notificationsOneTimeKeys } =
await commCoreModule.getOneTimeKeys(numberOfKeys); await commCoreModule.getOneTimeKeys(numberOfKeys);
return { return {
contentOneTimeKeys: getOneTimeKeyValues(contentOneTimeKeys), contentOneTimeKeys: getOneTimeKeyValues(contentOneTimeKeys),
notificationsOneTimeKeys: getOneTimeKeyValues(notificationsOneTimeKeys), notificationsOneTimeKeys: getOneTimeKeyValues(notificationsOneTimeKeys),
}; };
}, },
Show All 37 Lines
View Options

services/tunnelbroker/src/notifs/fcm/response.rs

Show All 36 Lines ): Promise<string> {
return commCoreModule.initializeContentInboundSession( return commCoreModule.initializeContentInboundSession(
identityKeys, identityKeys,
initialEncryptedData, initialEncryptedData,
contentIdentityKeys.ed25519, contentIdentityKeys.ed25519,
sessionVersion, sessionVersion,
overwrite, overwrite,
); );
}, },
isContentSessionInitialized: commCoreModule.isContentSessionInitialized,
async contentOutboundSessionCreator( async contentOutboundSessionCreator(
contentIdentityKeys: OLMIdentityKeys, contentIdentityKeys: OLMIdentityKeys,
contentInitializationInfo: OlmSessionInitializationInfo, contentInitializationInfo: OlmSessionInitializationInfo,
): Promise<OutboundSessionCreationResult> { ): Promise<OutboundSessionCreationResult> {
const { prekey, prekeySignature, oneTimeKey } = contentInitializationInfo; const { prekey, prekeySignature, oneTimeKey } = contentInitializationInfo;
const identityKeys = JSON.stringify({ const identityKeys = JSON.stringify({
curve25519: contentIdentityKeys.curve25519, curve25519: contentIdentityKeys.curve25519,
ed25519: contentIdentityKeys.ed25519, ed25519: contentIdentityKeys.ed25519,
Show All 37 Lines ): Promise<EncryptedData> {
return commCoreModule.initializeNotificationsOutboundSession( return commCoreModule.initializeNotificationsOutboundSession(
identityKeys, identityKeys,
prekey, prekey,
prekeySignature, prekeySignature,
oneTimeKey, oneTimeKey,
deviceID, deviceID,
); );
}, },
isPeerNotificationsSessionInitialized:
commCoreModule.isPeerNotificationsSessionInitialized,
async getOneTimeKeys(numberOfKeys: number): Promise<OneTimeKeysResultValues> { async getOneTimeKeys(numberOfKeys: number): Promise<OneTimeKeysResultValues> {
const { contentOneTimeKeys, notificationsOneTimeKeys } = const { contentOneTimeKeys, notificationsOneTimeKeys } =
await commCoreModule.getOneTimeKeys(numberOfKeys); await commCoreModule.getOneTimeKeys(numberOfKeys);
return { return {
contentOneTimeKeys: getOneTimeKeyValues(contentOneTimeKeys), contentOneTimeKeys: getOneTimeKeyValues(contentOneTimeKeys),
notificationsOneTimeKeys: getOneTimeKeyValues(notificationsOneTimeKeys), notificationsOneTimeKeys: getOneTimeKeyValues(notificationsOneTimeKeys),
}; };
}, },
Show All 37 Lines