Page MenuHomePhabricator
Differential D12772

[lib] implement sending FCM notifs using Tunnelbroker
ClosedPublic
Actions

Authored by kamil on Jul 16 2024, 1:54 AM.
Tags
None
Referenced Files
Unknown Object (File)
Fri, Mar 7, 11:00 PM
Unknown Object (File)
Tue, Mar 4, 6:12 AM
Unknown Object (File)
Feb 25 2025, 4:43 PM
Unknown Object (File)
Feb 21 2025, 6:42 PM
Unknown Object (File)
Jan 15 2025, 10:09 AM
Unknown Object (File)
Jan 3 2025, 3:49 PM
Unknown Object (File)
Dec 22 2024, 1:18 AM
Unknown Object (File)
Dec 16 2024, 10:50 PM
View All 56 Files
Subscribers
ashoat
tomek

Details

Reviewers
bartek
marcin
Commits
rCOMM0026f1d14eae: [lib] implement sending FCM notifs using Tunnelbroker
Summary

Client code to send notif - only updating types to allow this.

Depends on D12771

Test Plan

Testing different variants of:

const notf: TunnelbrokerFCMNotif = {
        type: 'FCMNotif',
        clientMessageID: uuid.v4(),
        deviceID: '3434',
        data: JSON.stringify({
          id: '1234',
          body: 'test notif from TB',
          title: 'HELLO FROM TB',
          prefix: 'pref',
          threadID: 'thread',
          badge: '12',
        }),
        priority: 'HIGH',
      };
      await sendNotif(notf);

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Revision Contents
Changeset List

PathSize
lib/
tunnelbroker/
11 lines
12 lines

Diff 42533

View Options

lib/tunnelbroker/secondary-tunnelbroker-connection.js

// @flow // @flow
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 type { TunnelbrokerAPNsNotif } from '../types/tunnelbroker/notif-types.js'; import type {
TunnelbrokerAPNsNotif,
TunnelbrokerFCMNotif,
} from '../types/tunnelbroker/notif-types.js';
type RemoveCallback = () => void; type RemoveCallback = () => void;
export type SecondaryTunnelbrokerConnection = { export type SecondaryTunnelbrokerConnection = {
// Used by an inactive tab to send messages // Used by an inactive tab to send messages
+sendMessage: ( +sendMessage: (
message: message:
| MessageToDeviceRequest | MessageToDeviceRequest
| MessageToTunnelbrokerRequest | MessageToTunnelbrokerRequest
| TunnelbrokerAPNsNotif, | TunnelbrokerAPNsNotif
| TunnelbrokerFCMNotif,
) => mixed, ) => mixed,
// Active tab receives messages from inactive tabs // Active tab receives messages from inactive tabs
+onSendMessage: ( +onSendMessage: (
( (
message: message:
| MessageToDeviceRequest | MessageToDeviceRequest
| MessageToTunnelbrokerRequest | MessageToTunnelbrokerRequest
| TunnelbrokerAPNsNotif, | TunnelbrokerAPNsNotif
| TunnelbrokerFCMNotif,
) => mixed, ) => mixed,
) => RemoveCallback, ) => RemoveCallback,
// Active tab sets the message status of messages from inactive tabs // Active tab sets the message status of messages from inactive tabs
+setMessageStatus: (messageID: string, error: ?string) => mixed, +setMessageStatus: (messageID: string, error: ?string) => mixed,
// Inactive tabs receive message status and resolve or reject promises // Inactive tabs receive message status and resolve or reject promises
+onMessageStatus: ( +onMessageStatus: (
((messageID: string, error: ?string) => mixed), ((messageID: string, error: ?string) => mixed),
) => RemoveCallback, ) => RemoveCallback,
}; };
View Options

lib/tunnelbroker/tunnelbroker-context.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