Page MenuHomePhabricator
Differential D13412

[lib] Merge viewerID into ProcessDMOperationUtilities
ClosedPublic
Actions

Authored by ashoat on Sep 20 2024, 6:30 AM.
Tags
None
Referenced Files
Unknown Object (File)
Sat, Mar 15, 3:41 AM
Unknown Object (File)
Feb 24 2025, 8:40 PM
Unknown Object (File)
Feb 24 2025, 11:09 AM
Unknown Object (File)
Feb 20 2025, 9:14 AM
Unknown Object (File)
Feb 18 2025, 2:26 PM
Unknown Object (File)
Feb 16 2025, 3:45 PM
Unknown Object (File)
Feb 15 2025, 6:39 PM
Unknown Object (File)
Feb 15 2025, 6:39 PM
View All 58 Files
Subscribers
None

Details

Reviewers
kamil
tomek
Commits
rCOMM8703bff04d40: [lib] Merge viewerID into ProcessDMOperationUtilities
Summary

Following feedback in D13391.

Test Plan

Flow

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Event Timeline

ashoat created this revision.Sep 20 2024, 6:30 AM
ashoat mentioned this in D13391: [lib] Add viewerID to DMOperationSpec.notificationsCreationData.Sep 20 2024, 6:31 AM
Harbormaster completed remote builds in B31741: Diff 44375.Sep 20 2024, 6:52 AM
ashoat requested review of this revision.Sep 20 2024, 6:52 AM
kamil accepted this revision.Sep 20 2024, 7:12 AM
kamil added inline comments.
lib/shared/dm-ops/process-dm-ops.js
86–89 ↗(On Diff #44375)

is it needed? Why can't we keep using baseUtilities?

This revision is now accepted and ready to land.Sep 20 2024, 7:12 AM
ashoat added inline comments.Sep 20 2024, 7:53 AM
lib/shared/dm-ops/process-dm-ops.js
86–89 ↗(On Diff #44375)

Flow needed this

Closed by commit rCOMM8703bff04d40: [lib] Merge viewerID into ProcessDMOperationUtilities (authored by ashoat). · Explain WhySep 20 2024, 7:55 AM
This revision was automatically updated to reflect the committed changes.
ashoat added a commit: rCOMM8703bff04d40: [lib] Merge viewerID into ProcessDMOperationUtilities.

Revision Contents
Changeset List

Diff 44394

View Options

lib/shared/dm-ops/add-members-spec.js

Show All 14 Lines
import type { MessageSentStatus } from '../types/tunnelbroker/message-to-device-request-status-types.js'; import type { MessageSentStatus } from '../types/tunnelbroker/message-to-device-request-status-types.js';
import type { MessageToDeviceRequest } from '../types/tunnelbroker/message-to-device-request-types.js'; import type { MessageToDeviceRequest } from '../types/tunnelbroker/message-to-device-request-types.js';
import type { MessageToTunnelbrokerRequest } from '../types/tunnelbroker/message-to-tunnelbroker-request-types.js'; import type { MessageToTunnelbrokerRequest } from '../types/tunnelbroker/message-to-tunnelbroker-request-types.js';
import { import {
type TunnelbrokerMessage, type TunnelbrokerMessage,
tunnelbrokerMessageTypes, tunnelbrokerMessageTypes,
tunnelbrokerMessageValidator, tunnelbrokerMessageValidator,
} from '../types/tunnelbroker/messages.js'; } from '../types/tunnelbroker/messages.js';
import type { TunnelbrokerAPNsNotif } from '../types/tunnelbroker/notif-types.js'; import type {
TunnelbrokerAPNsNotif,
TunnelbrokerFCMNotif,
} from '../types/tunnelbroker/notif-types.js';
import type { import type {
AnonymousInitializationMessage, AnonymousInitializationMessage,
ConnectionInitializationMessage, ConnectionInitializationMessage,
TunnelbrokerInitializationMessage, TunnelbrokerInitializationMessage,
TunnelbrokerDeviceTypes, TunnelbrokerDeviceTypes,
} from '../types/tunnelbroker/session-types.js'; } from '../types/tunnelbroker/session-types.js';
import type { Heartbeat } from '../types/websocket/heartbeat-types.js'; import type { Heartbeat } from '../types/websocket/heartbeat-types.js';
import { getConfig } from '../utils/config.js'; import { getConfig } from '../utils/config.js';
Show All 24 Lines | {
+connected: false, +connected: false,
}; };
type TunnelbrokerContextType = { type TunnelbrokerContextType = {
+sendMessage: ( +sendMessage: (
message: TunnelbrokerClientMessageToDevice, message: TunnelbrokerClientMessageToDevice,
messageID: ?string, messageID: ?string,
) => Promise<void>, ) => Promise<void>,
+sendNotif: (notif: TunnelbrokerAPNsNotif) => Promise<void>, +sendNotif: (
notif: TunnelbrokerAPNsNotif | TunnelbrokerFCMNotif,
) => Promise<void>,
+sendMessageToTunnelbroker: (payload: string) => Promise<void>, +sendMessageToTunnelbroker: (payload: string) => Promise<void>,
+addListener: (listener: TunnelbrokerSocketListener) => void, +addListener: (listener: TunnelbrokerSocketListener) => void,
+removeListener: (listener: TunnelbrokerSocketListener) => void, +removeListener: (listener: TunnelbrokerSocketListener) => void,
+socketState: TunnelbrokerSocketState, +socketState: TunnelbrokerSocketState,
+setUnauthorizedDeviceID: (unauthorizedDeviceID: ?string) => void, +setUnauthorizedDeviceID: (unauthorizedDeviceID: ?string) => void,
}; };
const TunnelbrokerContext: React.Context<?TunnelbrokerContextType> = const TunnelbrokerContext: React.Context<?TunnelbrokerContextType> =
▲ Show 20 Lines • Show All 238 Lines • ▼ Show 20 Lines React.useEffect(() => {
createInitMessage, createInitMessage,
socketState.connected, socketState.connected,
]); ]);
const sendMessageToDeviceRequest: ( const sendMessageToDeviceRequest: (
request: request:
| MessageToDeviceRequest | MessageToDeviceRequest
| MessageToTunnelbrokerRequest | MessageToTunnelbrokerRequest
| TunnelbrokerAPNsNotif, | TunnelbrokerAPNsNotif
| TunnelbrokerFCMNotif,
) => Promise<void> = React.useCallback( ) => Promise<void> = React.useCallback(
request => { request => {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
const socketActive = socketState.connected && socket.current; const socketActive = socketState.connected && socket.current;
if (!shouldBeClosed && !socketActive) { if (!shouldBeClosed && !socketActive) {
throw new Error('Tunnelbroker not connected'); throw new Error('Tunnelbroker not connected');
} }
promises.current[request.clientMessageID] = { promises.current[request.clientMessageID] = {
▲ Show 20 Lines • Show All 152 Lines • Show Last 20 Lines
View Options

lib/shared/dm-ops/add-viewer-to-thread-members-spec.js

Show All 14 Lines
import type { MessageSentStatus } from '../types/tunnelbroker/message-to-device-request-status-types.js'; import type { MessageSentStatus } from '../types/tunnelbroker/message-to-device-request-status-types.js';
import type { MessageToDeviceRequest } from '../types/tunnelbroker/message-to-device-request-types.js'; import type { MessageToDeviceRequest } from '../types/tunnelbroker/message-to-device-request-types.js';
import type { MessageToTunnelbrokerRequest } from '../types/tunnelbroker/message-to-tunnelbroker-request-types.js'; import type { MessageToTunnelbrokerRequest } from '../types/tunnelbroker/message-to-tunnelbroker-request-types.js';
import { import {
type TunnelbrokerMessage, type TunnelbrokerMessage,
tunnelbrokerMessageTypes, tunnelbrokerMessageTypes,
tunnelbrokerMessageValidator, tunnelbrokerMessageValidator,
} from '../types/tunnelbroker/messages.js'; } from '../types/tunnelbroker/messages.js';
import type { TunnelbrokerAPNsNotif } from '../types/tunnelbroker/notif-types.js'; import type {
TunnelbrokerAPNsNotif,
TunnelbrokerFCMNotif,
} from '../types/tunnelbroker/notif-types.js';
import type { import type {
AnonymousInitializationMessage, AnonymousInitializationMessage,
ConnectionInitializationMessage, ConnectionInitializationMessage,
TunnelbrokerInitializationMessage, TunnelbrokerInitializationMessage,
TunnelbrokerDeviceTypes, TunnelbrokerDeviceTypes,
} from '../types/tunnelbroker/session-types.js'; } from '../types/tunnelbroker/session-types.js';
import type { Heartbeat } from '../types/websocket/heartbeat-types.js'; import type { Heartbeat } from '../types/websocket/heartbeat-types.js';
import { getConfig } from '../utils/config.js'; import { getConfig } from '../utils/config.js';
Show All 24 Lines | {
+connected: false, +connected: false,
}; };
type TunnelbrokerContextType = { type TunnelbrokerContextType = {
+sendMessage: ( +sendMessage: (
message: TunnelbrokerClientMessageToDevice, message: TunnelbrokerClientMessageToDevice,
messageID: ?string, messageID: ?string,
) => Promise<void>, ) => Promise<void>,
+sendNotif: (notif: TunnelbrokerAPNsNotif) => Promise<void>, +sendNotif: (
notif: TunnelbrokerAPNsNotif | TunnelbrokerFCMNotif,
) => Promise<void>,
+sendMessageToTunnelbroker: (payload: string) => Promise<void>, +sendMessageToTunnelbroker: (payload: string) => Promise<void>,
+addListener: (listener: TunnelbrokerSocketListener) => void, +addListener: (listener: TunnelbrokerSocketListener) => void,
+removeListener: (listener: TunnelbrokerSocketListener) => void, +removeListener: (listener: TunnelbrokerSocketListener) => void,
+socketState: TunnelbrokerSocketState, +socketState: TunnelbrokerSocketState,
+setUnauthorizedDeviceID: (unauthorizedDeviceID: ?string) => void, +setUnauthorizedDeviceID: (unauthorizedDeviceID: ?string) => void,
}; };
const TunnelbrokerContext: React.Context<?TunnelbrokerContextType> = const TunnelbrokerContext: React.Context<?TunnelbrokerContextType> =
▲ Show 20 Lines • Show All 238 Lines • ▼ Show 20 Lines React.useEffect(() => {
createInitMessage, createInitMessage,
socketState.connected, socketState.connected,
]); ]);
const sendMessageToDeviceRequest: ( const sendMessageToDeviceRequest: (
request: request:
| MessageToDeviceRequest | MessageToDeviceRequest
| MessageToTunnelbrokerRequest | MessageToTunnelbrokerRequest
| TunnelbrokerAPNsNotif, | TunnelbrokerAPNsNotif
| TunnelbrokerFCMNotif,
) => Promise<void> = React.useCallback( ) => Promise<void> = React.useCallback(
request => { request => {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
const socketActive = socketState.connected && socket.current; const socketActive = socketState.connected && socket.current;
if (!shouldBeClosed && !socketActive) { if (!shouldBeClosed && !socketActive) {
throw new Error('Tunnelbroker not connected'); throw new Error('Tunnelbroker not connected');
} }
promises.current[request.clientMessageID] = { promises.current[request.clientMessageID] = {
▲ Show 20 Lines • Show All 152 Lines • Show Last 20 Lines
View Options

lib/shared/dm-ops/change-thread-read-status-spec.js

Show All 14 Lines
import type { MessageSentStatus } from '../types/tunnelbroker/message-to-device-request-status-types.js'; import type { MessageSentStatus } from '../types/tunnelbroker/message-to-device-request-status-types.js';
import type { MessageToDeviceRequest } from '../types/tunnelbroker/message-to-device-request-types.js'; import type { MessageToDeviceRequest } from '../types/tunnelbroker/message-to-device-request-types.js';
import type { MessageToTunnelbrokerRequest } from '../types/tunnelbroker/message-to-tunnelbroker-request-types.js'; import type { MessageToTunnelbrokerRequest } from '../types/tunnelbroker/message-to-tunnelbroker-request-types.js';
import { import {
type TunnelbrokerMessage, type TunnelbrokerMessage,
tunnelbrokerMessageTypes, tunnelbrokerMessageTypes,
tunnelbrokerMessageValidator, tunnelbrokerMessageValidator,
} from '../types/tunnelbroker/messages.js'; } from '../types/tunnelbroker/messages.js';
import type { TunnelbrokerAPNsNotif } from '../types/tunnelbroker/notif-types.js'; import type {
TunnelbrokerAPNsNotif,
TunnelbrokerFCMNotif,
} from '../types/tunnelbroker/notif-types.js';
import type { import type {
AnonymousInitializationMessage, AnonymousInitializationMessage,
ConnectionInitializationMessage, ConnectionInitializationMessage,
TunnelbrokerInitializationMessage, TunnelbrokerInitializationMessage,
TunnelbrokerDeviceTypes, TunnelbrokerDeviceTypes,
} from '../types/tunnelbroker/session-types.js'; } from '../types/tunnelbroker/session-types.js';
import type { Heartbeat } from '../types/websocket/heartbeat-types.js'; import type { Heartbeat } from '../types/websocket/heartbeat-types.js';
import { getConfig } from '../utils/config.js'; import { getConfig } from '../utils/config.js';
Show All 24 Lines | {
+connected: false, +connected: false,
}; };
type TunnelbrokerContextType = { type TunnelbrokerContextType = {
+sendMessage: ( +sendMessage: (
message: TunnelbrokerClientMessageToDevice, message: TunnelbrokerClientMessageToDevice,
messageID: ?string, messageID: ?string,
) => Promise<void>, ) => Promise<void>,
+sendNotif: (notif: TunnelbrokerAPNsNotif) => Promise<void>, +sendNotif: (
notif: TunnelbrokerAPNsNotif | TunnelbrokerFCMNotif,
) => Promise<void>,
+sendMessageToTunnelbroker: (payload: string) => Promise<void>, +sendMessageToTunnelbroker: (payload: string) => Promise<void>,
+addListener: (listener: TunnelbrokerSocketListener) => void, +addListener: (listener: TunnelbrokerSocketListener) => void,
+removeListener: (listener: TunnelbrokerSocketListener) => void, +removeListener: (listener: TunnelbrokerSocketListener) => void,
+socketState: TunnelbrokerSocketState, +socketState: TunnelbrokerSocketState,
+setUnauthorizedDeviceID: (unauthorizedDeviceID: ?string) => void, +setUnauthorizedDeviceID: (unauthorizedDeviceID: ?string) => void,
}; };
const TunnelbrokerContext: React.Context<?TunnelbrokerContextType> = const TunnelbrokerContext: React.Context<?TunnelbrokerContextType> =
▲ Show 20 Lines • Show All 238 Lines • ▼ Show 20 Lines React.useEffect(() => {
createInitMessage, createInitMessage,
socketState.connected, socketState.connected,
]); ]);
const sendMessageToDeviceRequest: ( const sendMessageToDeviceRequest: (
request: request:
| MessageToDeviceRequest | MessageToDeviceRequest
| MessageToTunnelbrokerRequest | MessageToTunnelbrokerRequest
| TunnelbrokerAPNsNotif, | TunnelbrokerAPNsNotif
| TunnelbrokerFCMNotif,
) => Promise<void> = React.useCallback( ) => Promise<void> = React.useCallback(
request => { request => {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
const socketActive = socketState.connected && socket.current; const socketActive = socketState.connected && socket.current;
if (!shouldBeClosed && !socketActive) { if (!shouldBeClosed && !socketActive) {
throw new Error('Tunnelbroker not connected'); throw new Error('Tunnelbroker not connected');
} }
promises.current[request.clientMessageID] = { promises.current[request.clientMessageID] = {
▲ Show 20 Lines • Show All 152 Lines • Show Last 20 Lines
View Options

lib/shared/dm-ops/change-thread-settings-spec.js

Show All 14 Lines
import type { MessageSentStatus } from '../types/tunnelbroker/message-to-device-request-status-types.js'; import type { MessageSentStatus } from '../types/tunnelbroker/message-to-device-request-status-types.js';
import type { MessageToDeviceRequest } from '../types/tunnelbroker/message-to-device-request-types.js'; import type { MessageToDeviceRequest } from '../types/tunnelbroker/message-to-device-request-types.js';
import type { MessageToTunnelbrokerRequest } from '../types/tunnelbroker/message-to-tunnelbroker-request-types.js'; import type { MessageToTunnelbrokerRequest } from '../types/tunnelbroker/message-to-tunnelbroker-request-types.js';
import { import {
type TunnelbrokerMessage, type TunnelbrokerMessage,
tunnelbrokerMessageTypes, tunnelbrokerMessageTypes,
tunnelbrokerMessageValidator, tunnelbrokerMessageValidator,
} from '../types/tunnelbroker/messages.js'; } from '../types/tunnelbroker/messages.js';
import type { TunnelbrokerAPNsNotif } from '../types/tunnelbroker/notif-types.js'; import type {
TunnelbrokerAPNsNotif,
TunnelbrokerFCMNotif,
} from '../types/tunnelbroker/notif-types.js';
import type { import type {
AnonymousInitializationMessage, AnonymousInitializationMessage,
ConnectionInitializationMessage, ConnectionInitializationMessage,
TunnelbrokerInitializationMessage, TunnelbrokerInitializationMessage,
TunnelbrokerDeviceTypes, TunnelbrokerDeviceTypes,
} from '../types/tunnelbroker/session-types.js'; } from '../types/tunnelbroker/session-types.js';
import type { Heartbeat } from '../types/websocket/heartbeat-types.js'; import type { Heartbeat } from '../types/websocket/heartbeat-types.js';
import { getConfig } from '../utils/config.js'; import { getConfig } from '../utils/config.js';
Show All 24 Lines | {
+connected: false, +connected: false,
}; };
type TunnelbrokerContextType = { type TunnelbrokerContextType = {
+sendMessage: ( +sendMessage: (
message: TunnelbrokerClientMessageToDevice, message: TunnelbrokerClientMessageToDevice,
messageID: ?string, messageID: ?string,
) => Promise<void>, ) => Promise<void>,
+sendNotif: (notif: TunnelbrokerAPNsNotif) => Promise<void>, +sendNotif: (
notif: TunnelbrokerAPNsNotif | TunnelbrokerFCMNotif,
) => Promise<void>,
+sendMessageToTunnelbroker: (payload: string) => Promise<void>, +sendMessageToTunnelbroker: (payload: string) => Promise<void>,
+addListener: (listener: TunnelbrokerSocketListener) => void, +addListener: (listener: TunnelbrokerSocketListener) => void,
+removeListener: (listener: TunnelbrokerSocketListener) => void, +removeListener: (listener: TunnelbrokerSocketListener) => void,
+socketState: TunnelbrokerSocketState, +socketState: TunnelbrokerSocketState,
+setUnauthorizedDeviceID: (unauthorizedDeviceID: ?string) => void, +setUnauthorizedDeviceID: (unauthorizedDeviceID: ?string) => void,
}; };
const TunnelbrokerContext: React.Context<?TunnelbrokerContextType> = const TunnelbrokerContext: React.Context<?TunnelbrokerContextType> =
▲ Show 20 Lines • Show All 238 Lines • ▼ Show 20 Lines React.useEffect(() => {
createInitMessage, createInitMessage,
socketState.connected, socketState.connected,
]); ]);
const sendMessageToDeviceRequest: ( const sendMessageToDeviceRequest: (
request: request:
| MessageToDeviceRequest | MessageToDeviceRequest
| MessageToTunnelbrokerRequest | MessageToTunnelbrokerRequest
| TunnelbrokerAPNsNotif, | TunnelbrokerAPNsNotif
| TunnelbrokerFCMNotif,
) => Promise<void> = React.useCallback( ) => Promise<void> = React.useCallback(
request => { request => {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
const socketActive = socketState.connected && socket.current; const socketActive = socketState.connected && socket.current;
if (!shouldBeClosed && !socketActive) { if (!shouldBeClosed && !socketActive) {
throw new Error('Tunnelbroker not connected'); throw new Error('Tunnelbroker not connected');
} }
promises.current[request.clientMessageID] = { promises.current[request.clientMessageID] = {
▲ Show 20 Lines • Show All 152 Lines • Show Last 20 Lines
View Options

lib/shared/dm-ops/change-thread-subscription.js

Show All 14 Lines
import type { MessageSentStatus } from '../types/tunnelbroker/message-to-device-request-status-types.js'; import type { MessageSentStatus } from '../types/tunnelbroker/message-to-device-request-status-types.js';
import type { MessageToDeviceRequest } from '../types/tunnelbroker/message-to-device-request-types.js'; import type { MessageToDeviceRequest } from '../types/tunnelbroker/message-to-device-request-types.js';
import type { MessageToTunnelbrokerRequest } from '../types/tunnelbroker/message-to-tunnelbroker-request-types.js'; import type { MessageToTunnelbrokerRequest } from '../types/tunnelbroker/message-to-tunnelbroker-request-types.js';
import { import {
type TunnelbrokerMessage, type TunnelbrokerMessage,
tunnelbrokerMessageTypes, tunnelbrokerMessageTypes,
tunnelbrokerMessageValidator, tunnelbrokerMessageValidator,
} from '../types/tunnelbroker/messages.js'; } from '../types/tunnelbroker/messages.js';
import type { TunnelbrokerAPNsNotif } from '../types/tunnelbroker/notif-types.js'; import type {
TunnelbrokerAPNsNotif,
TunnelbrokerFCMNotif,
} from '../types/tunnelbroker/notif-types.js';
import type { import type {
AnonymousInitializationMessage, AnonymousInitializationMessage,
ConnectionInitializationMessage, ConnectionInitializationMessage,
TunnelbrokerInitializationMessage, TunnelbrokerInitializationMessage,
TunnelbrokerDeviceTypes, TunnelbrokerDeviceTypes,
} from '../types/tunnelbroker/session-types.js'; } from '../types/tunnelbroker/session-types.js';
import type { Heartbeat } from '../types/websocket/heartbeat-types.js'; import type { Heartbeat } from '../types/websocket/heartbeat-types.js';
import { getConfig } from '../utils/config.js'; import { getConfig } from '../utils/config.js';
Show All 24 Lines | {
+connected: false, +connected: false,
}; };
type TunnelbrokerContextType = { type TunnelbrokerContextType = {
+sendMessage: ( +sendMessage: (
message: TunnelbrokerClientMessageToDevice, message: TunnelbrokerClientMessageToDevice,
messageID: ?string, messageID: ?string,
) => Promise<void>, ) => Promise<void>,
+sendNotif: (notif: TunnelbrokerAPNsNotif) => Promise<void>, +sendNotif: (
notif: TunnelbrokerAPNsNotif | TunnelbrokerFCMNotif,
) => Promise<void>,
+sendMessageToTunnelbroker: (payload: string) => Promise<void>, +sendMessageToTunnelbroker: (payload: string) => Promise<void>,
+addListener: (listener: TunnelbrokerSocketListener) => void, +addListener: (listener: TunnelbrokerSocketListener) => void,
+removeListener: (listener: TunnelbrokerSocketListener) => void, +removeListener: (listener: TunnelbrokerSocketListener) => void,
+socketState: TunnelbrokerSocketState, +socketState: TunnelbrokerSocketState,
+setUnauthorizedDeviceID: (unauthorizedDeviceID: ?string) => void, +setUnauthorizedDeviceID: (unauthorizedDeviceID: ?string) => void,
}; };
const TunnelbrokerContext: React.Context<?TunnelbrokerContextType> = const TunnelbrokerContext: React.Context<?TunnelbrokerContextType> =
▲ Show 20 Lines • Show All 238 Lines • ▼ Show 20 Lines React.useEffect(() => {
createInitMessage, createInitMessage,
socketState.connected, socketState.connected,
]); ]);
const sendMessageToDeviceRequest: ( const sendMessageToDeviceRequest: (
request: request:
| MessageToDeviceRequest | MessageToDeviceRequest
| MessageToTunnelbrokerRequest | MessageToTunnelbrokerRequest
| TunnelbrokerAPNsNotif, | TunnelbrokerAPNsNotif
| TunnelbrokerFCMNotif,
) => Promise<void> = React.useCallback( ) => Promise<void> = React.useCallback(
request => { request => {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
const socketActive = socketState.connected && socket.current; const socketActive = socketState.connected && socket.current;
if (!shouldBeClosed && !socketActive) { if (!shouldBeClosed && !socketActive) {
throw new Error('Tunnelbroker not connected'); throw new Error('Tunnelbroker not connected');
} }
promises.current[request.clientMessageID] = { promises.current[request.clientMessageID] = {
▲ Show 20 Lines • Show All 152 Lines • Show Last 20 Lines
View Options

lib/shared/dm-ops/create-entry-spec.js

Show All 14 Lines
import type { MessageSentStatus } from '../types/tunnelbroker/message-to-device-request-status-types.js'; import type { MessageSentStatus } from '../types/tunnelbroker/message-to-device-request-status-types.js';
import type { MessageToDeviceRequest } from '../types/tunnelbroker/message-to-device-request-types.js'; import type { MessageToDeviceRequest } from '../types/tunnelbroker/message-to-device-request-types.js';
import type { MessageToTunnelbrokerRequest } from '../types/tunnelbroker/message-to-tunnelbroker-request-types.js'; import type { MessageToTunnelbrokerRequest } from '../types/tunnelbroker/message-to-tunnelbroker-request-types.js';
import { import {
type TunnelbrokerMessage, type TunnelbrokerMessage,
tunnelbrokerMessageTypes, tunnelbrokerMessageTypes,
tunnelbrokerMessageValidator, tunnelbrokerMessageValidator,
} from '../types/tunnelbroker/messages.js'; } from '../types/tunnelbroker/messages.js';
import type { TunnelbrokerAPNsNotif } from '../types/tunnelbroker/notif-types.js'; import type {
TunnelbrokerAPNsNotif,
TunnelbrokerFCMNotif,
} from '../types/tunnelbroker/notif-types.js';
import type { import type {
AnonymousInitializationMessage, AnonymousInitializationMessage,
ConnectionInitializationMessage, ConnectionInitializationMessage,
TunnelbrokerInitializationMessage, TunnelbrokerInitializationMessage,
TunnelbrokerDeviceTypes, TunnelbrokerDeviceTypes,
} from '../types/tunnelbroker/session-types.js'; } from '../types/tunnelbroker/session-types.js';
import type { Heartbeat } from '../types/websocket/heartbeat-types.js'; import type { Heartbeat } from '../types/websocket/heartbeat-types.js';
import { getConfig } from '../utils/config.js'; import { getConfig } from '../utils/config.js';
Show All 24 Lines | {
+connected: false, +connected: false,
}; };
type TunnelbrokerContextType = { type TunnelbrokerContextType = {
+sendMessage: ( +sendMessage: (
message: TunnelbrokerClientMessageToDevice, message: TunnelbrokerClientMessageToDevice,
messageID: ?string, messageID: ?string,
) => Promise<void>, ) => Promise<void>,
+sendNotif: (notif: TunnelbrokerAPNsNotif) => Promise<void>, +sendNotif: (
notif: TunnelbrokerAPNsNotif | TunnelbrokerFCMNotif,
) => Promise<void>,
+sendMessageToTunnelbroker: (payload: string) => Promise<void>, +sendMessageToTunnelbroker: (payload: string) => Promise<void>,
+addListener: (listener: TunnelbrokerSocketListener) => void, +addListener: (listener: TunnelbrokerSocketListener) => void,
+removeListener: (listener: TunnelbrokerSocketListener) => void, +removeListener: (listener: TunnelbrokerSocketListener) => void,
+socketState: TunnelbrokerSocketState, +socketState: TunnelbrokerSocketState,
+setUnauthorizedDeviceID: (unauthorizedDeviceID: ?string) => void, +setUnauthorizedDeviceID: (unauthorizedDeviceID: ?string) => void,
}; };
const TunnelbrokerContext: React.Context<?TunnelbrokerContextType> = const TunnelbrokerContext: React.Context<?TunnelbrokerContextType> =
▲ Show 20 Lines • Show All 238 Lines • ▼ Show 20 Lines React.useEffect(() => {
createInitMessage, createInitMessage,
socketState.connected, socketState.connected,
]); ]);
const sendMessageToDeviceRequest: ( const sendMessageToDeviceRequest: (
request: request:
| MessageToDeviceRequest | MessageToDeviceRequest
| MessageToTunnelbrokerRequest | MessageToTunnelbrokerRequest
| TunnelbrokerAPNsNotif, | TunnelbrokerAPNsNotif
| TunnelbrokerFCMNotif,
) => Promise<void> = React.useCallback( ) => Promise<void> = React.useCallback(
request => { request => {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
const socketActive = socketState.connected && socket.current; const socketActive = socketState.connected && socket.current;
if (!shouldBeClosed && !socketActive) { if (!shouldBeClosed && !socketActive) {
throw new Error('Tunnelbroker not connected'); throw new Error('Tunnelbroker not connected');
} }
promises.current[request.clientMessageID] = { promises.current[request.clientMessageID] = {
▲ Show 20 Lines • Show All 152 Lines • Show Last 20 Lines
View Options

lib/shared/dm-ops/create-sidebar-spec.js

Show All 14 Lines
import type { MessageSentStatus } from '../types/tunnelbroker/message-to-device-request-status-types.js'; import type { MessageSentStatus } from '../types/tunnelbroker/message-to-device-request-status-types.js';
import type { MessageToDeviceRequest } from '../types/tunnelbroker/message-to-device-request-types.js'; import type { MessageToDeviceRequest } from '../types/tunnelbroker/message-to-device-request-types.js';
import type { MessageToTunnelbrokerRequest } from '../types/tunnelbroker/message-to-tunnelbroker-request-types.js'; import type { MessageToTunnelbrokerRequest } from '../types/tunnelbroker/message-to-tunnelbroker-request-types.js';
import { import {
type TunnelbrokerMessage, type TunnelbrokerMessage,
tunnelbrokerMessageTypes, tunnelbrokerMessageTypes,
tunnelbrokerMessageValidator, tunnelbrokerMessageValidator,
} from '../types/tunnelbroker/messages.js'; } from '../types/tunnelbroker/messages.js';
import type { TunnelbrokerAPNsNotif } from '../types/tunnelbroker/notif-types.js'; import type {
TunnelbrokerAPNsNotif,
TunnelbrokerFCMNotif,
} from '../types/tunnelbroker/notif-types.js';
import type { import type {
AnonymousInitializationMessage, AnonymousInitializationMessage,
ConnectionInitializationMessage, ConnectionInitializationMessage,
TunnelbrokerInitializationMessage, TunnelbrokerInitializationMessage,
TunnelbrokerDeviceTypes, TunnelbrokerDeviceTypes,
} from '../types/tunnelbroker/session-types.js'; } from '../types/tunnelbroker/session-types.js';
import type { Heartbeat } from '../types/websocket/heartbeat-types.js'; import type { Heartbeat } from '../types/websocket/heartbeat-types.js';
import { getConfig } from '../utils/config.js'; import { getConfig } from '../utils/config.js';
Show All 24 Lines | {
+connected: false, +connected: false,
}; };
type TunnelbrokerContextType = { type TunnelbrokerContextType = {
+sendMessage: ( +sendMessage: (
message: TunnelbrokerClientMessageToDevice, message: TunnelbrokerClientMessageToDevice,
messageID: ?string, messageID: ?string,
) => Promise<void>, ) => Promise<void>,
+sendNotif: (notif: TunnelbrokerAPNsNotif) => Promise<void>, +sendNotif: (
notif: TunnelbrokerAPNsNotif | TunnelbrokerFCMNotif,
) => Promise<void>,
+sendMessageToTunnelbroker: (payload: string) => Promise<void>, +sendMessageToTunnelbroker: (payload: string) => Promise<void>,
+addListener: (listener: TunnelbrokerSocketListener) => void, +addListener: (listener: TunnelbrokerSocketListener) => void,
+removeListener: (listener: TunnelbrokerSocketListener) => void, +removeListener: (listener: TunnelbrokerSocketListener) => void,
+socketState: TunnelbrokerSocketState, +socketState: TunnelbrokerSocketState,
+setUnauthorizedDeviceID: (unauthorizedDeviceID: ?string) => void, +setUnauthorizedDeviceID: (unauthorizedDeviceID: ?string) => void,
}; };
const TunnelbrokerContext: React.Context<?TunnelbrokerContextType> = const TunnelbrokerContext: React.Context<?TunnelbrokerContextType> =
▲ Show 20 Lines • Show All 238 Lines • ▼ Show 20 Lines React.useEffect(() => {
createInitMessage, createInitMessage,
socketState.connected, socketState.connected,
]); ]);
const sendMessageToDeviceRequest: ( const sendMessageToDeviceRequest: (
request: request:
| MessageToDeviceRequest | MessageToDeviceRequest
| MessageToTunnelbrokerRequest | MessageToTunnelbrokerRequest
| TunnelbrokerAPNsNotif, | TunnelbrokerAPNsNotif
| TunnelbrokerFCMNotif,
) => Promise<void> = React.useCallback( ) => Promise<void> = React.useCallback(
request => { request => {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
const socketActive = socketState.connected && socket.current; const socketActive = socketState.connected && socket.current;
if (!shouldBeClosed && !socketActive) { if (!shouldBeClosed && !socketActive) {
throw new Error('Tunnelbroker not connected'); throw new Error('Tunnelbroker not connected');
} }
promises.current[request.clientMessageID] = { promises.current[request.clientMessageID] = {
▲ Show 20 Lines • Show All 152 Lines • Show Last 20 Lines
View Options

lib/shared/dm-ops/create-thread-spec.js

Loading...
View Options

lib/shared/dm-ops/delete-entry-spec.js

Loading...
View Options

lib/shared/dm-ops/dm-op-spec.js

Loading...
View Options

lib/shared/dm-ops/edit-entry-spec.js

Loading...
View Options

lib/shared/dm-ops/join-thread-spec.js

Loading...
View Options

lib/shared/dm-ops/leave-thread-spec.js

Loading...
View Options

lib/shared/dm-ops/process-dm-ops.js

Loading...
View Options

lib/shared/dm-ops/remove-members-spec.js

Loading...
View Options

lib/shared/dm-ops/send-edit-message-spec.js

Loading...
View Options

lib/shared/dm-ops/send-multimedia-message-spec.js

Loading...
View Options

lib/shared/dm-ops/send-reaction-message-spec.js

Loading...
View Options

lib/shared/dm-ops/send-text-message-spec.js

Loading...
View Options

lib/shared/dm-ops/update-relationship-spec.js

Loading...