Page MenuHomePhabricator
Differential D13257

[Tunnelbroker] add push services timeout
ClosedPublic
Actions

Authored by kamil on Sep 6 2024, 5:34 AM.
Tags
None
Referenced Files
Unknown Object (File)
Sat, Mar 15, 4:06 AM
Unknown Object (File)
Sat, Mar 15, 4:06 AM
Unknown Object (File)
Sat, Mar 15, 4:06 AM
Unknown Object (File)
Sat, Mar 15, 4:06 AM
Unknown Object (File)
Sat, Mar 15, 4:06 AM
Unknown Object (File)
Feb 27 2025, 7:43 AM
Unknown Object (File)
Feb 18 2025, 2:17 AM
Unknown Object (File)
Feb 18 2025, 1:56 AM
View All 66 Files
Subscribers
ashoat

Details

Reviewers
tomek
bartek
Commits
rCOMM9e3f4e92dcd0: [Tunnelbroker] add push services timeout
Summary

ENG-9110.

Adding timeout to not wait infinitely for push service response.

Test Plan

Throttle internet connection and test with really small timeout.

Diff Detail

Repository
rCOMM Comm
Lint
No Lint Coverage
Unit
No Test Coverage

Revision Contents
Changeset List

PathSize
services/
tunnelbroker/
src/
2 lines
notifs/
apns/
2 lines
fcm/
5 lines
web_push/
8 lines
wns/
5 lines

Diff 43920

View Options

services/tunnelbroker/src/constants.rs

// @flow // @flow
'use strict'; 'use strict';
import { TurboModuleRegistry } from 'react-native'; import { TurboModuleRegistry } from 'react-native';
import type { TurboModule } from 'react-native/Libraries/TurboModule/RCTExport.js'; import type { TurboModule } from 'react-native/Libraries/TurboModule/RCTExport.js';
// codegen doesn't understand ArrayBuffers, so we need to map them to Objects // codegen doesn't understand ArrayBuffers, so we need to map them to Objects
type JSIArrayBuffer = Object; type JSIArrayBuffer = Object;
interface Spec extends TurboModule { interface Spec extends TurboModule {
// filesystem utils // filesystem utils
+writeBufferToFile: (path: string, data: JSIArrayBuffer) => Promise<void>; +writeBufferToFile: (path: string, data: JSIArrayBuffer) => Promise<void>;
+readBufferFromFile: (path: string) => Promise<JSIArrayBuffer>; +readBufferFromFile: (path: string) => Promise<JSIArrayBuffer>;
+base64EncodeBuffer: (data: JSIArrayBuffer) => string; +base64EncodeBuffer: (data: JSIArrayBuffer) => string;
+base64DecodeBuffer: (base64: string) => JSIArrayBuffer;
// crypto utils // crypto utils
+sha256: (data: JSIArrayBuffer) => string; +sha256: (data: JSIArrayBuffer) => string;
} }
// for public interface, we use the correct types // for public interface, we use the correct types
export interface UtilsModuleSpec { export interface UtilsModuleSpec {
+writeBufferToFile: (path: string, data: ArrayBuffer) => Promise<void>; +writeBufferToFile: (path: string, data: ArrayBuffer) => Promise<void>;
+readBufferFromFile: (path: string) => Promise<ArrayBuffer>; +readBufferFromFile: (path: string) => Promise<ArrayBuffer>;
+base64EncodeBuffer: (data: ArrayBuffer) => string; +base64EncodeBuffer: (data: ArrayBuffer) => string;
+base64DecodeBuffer: (base64: string) => ArrayBuffer;
+sha256: (data: ArrayBuffer) => string; +sha256: (data: ArrayBuffer) => string;
} }
export default (TurboModuleRegistry.getEnforcing<Spec>( export default (TurboModuleRegistry.getEnforcing<Spec>(
'CommUtilsTurboModule', 'CommUtilsTurboModule',
): Spec); ): Spec);
View Options

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

// @flow // @flow
'use strict'; 'use strict';
import { TurboModuleRegistry } from 'react-native'; import { TurboModuleRegistry } from 'react-native';
import type { TurboModule } from 'react-native/Libraries/TurboModule/RCTExport.js'; import type { TurboModule } from 'react-native/Libraries/TurboModule/RCTExport.js';
// codegen doesn't understand ArrayBuffers, so we need to map them to Objects // codegen doesn't understand ArrayBuffers, so we need to map them to Objects
type JSIArrayBuffer = Object; type JSIArrayBuffer = Object;
interface Spec extends TurboModule { interface Spec extends TurboModule {
// filesystem utils // filesystem utils
+writeBufferToFile: (path: string, data: JSIArrayBuffer) => Promise<void>; +writeBufferToFile: (path: string, data: JSIArrayBuffer) => Promise<void>;
+readBufferFromFile: (path: string) => Promise<JSIArrayBuffer>; +readBufferFromFile: (path: string) => Promise<JSIArrayBuffer>;
+base64EncodeBuffer: (data: JSIArrayBuffer) => string; +base64EncodeBuffer: (data: JSIArrayBuffer) => string;
+base64DecodeBuffer: (base64: string) => JSIArrayBuffer;
// crypto utils // crypto utils
+sha256: (data: JSIArrayBuffer) => string; +sha256: (data: JSIArrayBuffer) => string;
} }
// for public interface, we use the correct types // for public interface, we use the correct types
export interface UtilsModuleSpec { export interface UtilsModuleSpec {
+writeBufferToFile: (path: string, data: ArrayBuffer) => Promise<void>; +writeBufferToFile: (path: string, data: ArrayBuffer) => Promise<void>;
+readBufferFromFile: (path: string) => Promise<ArrayBuffer>; +readBufferFromFile: (path: string) => Promise<ArrayBuffer>;
+base64EncodeBuffer: (data: ArrayBuffer) => string; +base64EncodeBuffer: (data: ArrayBuffer) => string;
+base64DecodeBuffer: (base64: string) => ArrayBuffer;
+sha256: (data: ArrayBuffer) => string; +sha256: (data: ArrayBuffer) => string;
} }
export default (TurboModuleRegistry.getEnforcing<Spec>( export default (TurboModuleRegistry.getEnforcing<Spec>(
'CommUtilsTurboModule', 'CommUtilsTurboModule',
): Spec); ): Spec);
View Options

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

// @flow // @flow
'use strict'; 'use strict';
import { TurboModuleRegistry } from 'react-native'; import { TurboModuleRegistry } from 'react-native';
import type { TurboModule } from 'react-native/Libraries/TurboModule/RCTExport.js'; import type { TurboModule } from 'react-native/Libraries/TurboModule/RCTExport.js';
// codegen doesn't understand ArrayBuffers, so we need to map them to Objects // codegen doesn't understand ArrayBuffers, so we need to map them to Objects
type JSIArrayBuffer = Object; type JSIArrayBuffer = Object;
interface Spec extends TurboModule { interface Spec extends TurboModule {
// filesystem utils // filesystem utils
+writeBufferToFile: (path: string, data: JSIArrayBuffer) => Promise<void>; +writeBufferToFile: (path: string, data: JSIArrayBuffer) => Promise<void>;
+readBufferFromFile: (path: string) => Promise<JSIArrayBuffer>; +readBufferFromFile: (path: string) => Promise<JSIArrayBuffer>;
+base64EncodeBuffer: (data: JSIArrayBuffer) => string; +base64EncodeBuffer: (data: JSIArrayBuffer) => string;
+base64DecodeBuffer: (base64: string) => JSIArrayBuffer;
// crypto utils // crypto utils
+sha256: (data: JSIArrayBuffer) => string; +sha256: (data: JSIArrayBuffer) => string;
} }
// for public interface, we use the correct types // for public interface, we use the correct types
export interface UtilsModuleSpec { export interface UtilsModuleSpec {
+writeBufferToFile: (path: string, data: ArrayBuffer) => Promise<void>; +writeBufferToFile: (path: string, data: ArrayBuffer) => Promise<void>;
+readBufferFromFile: (path: string) => Promise<ArrayBuffer>; +readBufferFromFile: (path: string) => Promise<ArrayBuffer>;
+base64EncodeBuffer: (data: ArrayBuffer) => string; +base64EncodeBuffer: (data: ArrayBuffer) => string;
+base64DecodeBuffer: (base64: string) => ArrayBuffer;
+sha256: (data: ArrayBuffer) => string; +sha256: (data: ArrayBuffer) => string;
} }
export default (TurboModuleRegistry.getEnforcing<Spec>( export default (TurboModuleRegistry.getEnforcing<Spec>(
'CommUtilsTurboModule', 'CommUtilsTurboModule',
): Spec); ): Spec);
View Options

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

// @flow // @flow
'use strict'; 'use strict';
import { TurboModuleRegistry } from 'react-native'; import { TurboModuleRegistry } from 'react-native';
import type { TurboModule } from 'react-native/Libraries/TurboModule/RCTExport.js'; import type { TurboModule } from 'react-native/Libraries/TurboModule/RCTExport.js';
// codegen doesn't understand ArrayBuffers, so we need to map them to Objects // codegen doesn't understand ArrayBuffers, so we need to map them to Objects
type JSIArrayBuffer = Object; type JSIArrayBuffer = Object;
interface Spec extends TurboModule { interface Spec extends TurboModule {
// filesystem utils // filesystem utils
+writeBufferToFile: (path: string, data: JSIArrayBuffer) => Promise<void>; +writeBufferToFile: (path: string, data: JSIArrayBuffer) => Promise<void>;
+readBufferFromFile: (path: string) => Promise<JSIArrayBuffer>; +readBufferFromFile: (path: string) => Promise<JSIArrayBuffer>;
+base64EncodeBuffer: (data: JSIArrayBuffer) => string; +base64EncodeBuffer: (data: JSIArrayBuffer) => string;
+base64DecodeBuffer: (base64: string) => JSIArrayBuffer;
// crypto utils // crypto utils
+sha256: (data: JSIArrayBuffer) => string; +sha256: (data: JSIArrayBuffer) => string;
} }
// for public interface, we use the correct types // for public interface, we use the correct types
export interface UtilsModuleSpec { export interface UtilsModuleSpec {
+writeBufferToFile: (path: string, data: ArrayBuffer) => Promise<void>; +writeBufferToFile: (path: string, data: ArrayBuffer) => Promise<void>;
+readBufferFromFile: (path: string) => Promise<ArrayBuffer>; +readBufferFromFile: (path: string) => Promise<ArrayBuffer>;
+base64EncodeBuffer: (data: ArrayBuffer) => string; +base64EncodeBuffer: (data: ArrayBuffer) => string;
+base64DecodeBuffer: (base64: string) => ArrayBuffer;
+sha256: (data: ArrayBuffer) => string; +sha256: (data: ArrayBuffer) => string;
} }
export default (TurboModuleRegistry.getEnforcing<Spec>( export default (TurboModuleRegistry.getEnforcing<Spec>(
'CommUtilsTurboModule', 'CommUtilsTurboModule',
): Spec); ): Spec);
View Options

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

// @flow // @flow
'use strict'; 'use strict';
import { TurboModuleRegistry } from 'react-native'; import { TurboModuleRegistry } from 'react-native';
import type { TurboModule } from 'react-native/Libraries/TurboModule/RCTExport.js'; import type { TurboModule } from 'react-native/Libraries/TurboModule/RCTExport.js';
// codegen doesn't understand ArrayBuffers, so we need to map them to Objects // codegen doesn't understand ArrayBuffers, so we need to map them to Objects
type JSIArrayBuffer = Object; type JSIArrayBuffer = Object;
interface Spec extends TurboModule { interface Spec extends TurboModule {
// filesystem utils // filesystem utils
+writeBufferToFile: (path: string, data: JSIArrayBuffer) => Promise<void>; +writeBufferToFile: (path: string, data: JSIArrayBuffer) => Promise<void>;
+readBufferFromFile: (path: string) => Promise<JSIArrayBuffer>; +readBufferFromFile: (path: string) => Promise<JSIArrayBuffer>;
+base64EncodeBuffer: (data: JSIArrayBuffer) => string; +base64EncodeBuffer: (data: JSIArrayBuffer) => string;
+base64DecodeBuffer: (base64: string) => JSIArrayBuffer;
// crypto utils // crypto utils
+sha256: (data: JSIArrayBuffer) => string; +sha256: (data: JSIArrayBuffer) => string;
} }
// for public interface, we use the correct types // for public interface, we use the correct types
export interface UtilsModuleSpec { export interface UtilsModuleSpec {
+writeBufferToFile: (path: string, data: ArrayBuffer) => Promise<void>; +writeBufferToFile: (path: string, data: ArrayBuffer) => Promise<void>;
+readBufferFromFile: (path: string) => Promise<ArrayBuffer>; +readBufferFromFile: (path: string) => Promise<ArrayBuffer>;
+base64EncodeBuffer: (data: ArrayBuffer) => string; +base64EncodeBuffer: (data: ArrayBuffer) => string;
+base64DecodeBuffer: (base64: string) => ArrayBuffer;
+sha256: (data: ArrayBuffer) => string; +sha256: (data: ArrayBuffer) => string;
} }
export default (TurboModuleRegistry.getEnforcing<Spec>( export default (TurboModuleRegistry.getEnforcing<Spec>(
'CommUtilsTurboModule', 'CommUtilsTurboModule',
): Spec); ): Spec);