Page MenuHomePhabricator
Differential D12935

[Tunnelbroker] send push notifs to windows devices
ClosedPublic
Actions

Authored by varun on Jul 30 2024, 12:02 AM.
Tags
None
Referenced Files
Unknown Object (File)
Wed, Mar 12, 6:56 AM
Unknown Object (File)
Sun, Mar 9, 6:19 PM
Unknown Object (File)
Sun, Mar 9, 6:19 PM
Unknown Object (File)
Sun, Mar 9, 6:19 PM
Unknown Object (File)
Sun, Mar 9, 6:18 PM
Unknown Object (File)
Sun, Mar 9, 6:18 PM
Unknown Object (File)
Sun, Mar 9, 6:18 PM
Unknown Object (File)
Sun, Mar 9, 6:18 PM
View All Files
Subscribers
ashoat
tomek

Details

Reviewers
kamil
bartek
marcin
Commits
rCOMM5f3de4311fbb: [Tunnelbroker] send push notifs to windows devices
Summary

Make it possible to send push notifs to windows devices through tunnelbroker

Depends on D12934

Test Plan

https://gist.github.com/vdhanan/3921680cde51e92a8c7787771b36d19a

successfully sent push notifs to my windows desktop app

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Event Timeline

varun created this revision.Jul 30 2024, 12:02 AM
varun held this revision as a draft.
Herald added subscribers: tomek, ashoat. · View Herald TranscriptJul 30 2024, 12:02 AM
Harbormaster failed remote builds in B30785: Diff 42928!Jul 30 2024, 12:24 AM
bartek added inline comments.Jul 30 2024, 12:32 AM
shared/tunnelbroker_messages/src/messages/notif.rs
40–41 ↗(On Diff #42928)

See https://linear.app/comm/issue/ENG-8901/fix-serde-parsing-incorrect-tunnelbroker-message-types
The same problem appears here and that's why Commtest CI fails

40–41 ↗(On Diff #42928)

should be TagAwareDeserialize, sorry

varun updated this revision to Diff 42976.Jul 30 2024, 6:55 PM

fix message serialization

Harbormaster completed remote builds in B30823: Diff 42976.Jul 30 2024, 7:12 PM
varun updated this revision to Diff 43207.Aug 6 2024, 8:56 PM

finally got this working and tested end to end

varun published this revision for review.Aug 6 2024, 8:57 PM
Harbormaster completed remote builds in B30973: Diff 43207.Aug 6 2024, 9:12 PM
varun updated this revision to Diff 43213.Aug 6 2024, 9:50 PM
varun retitled this revision from [WIP][Tunnelbroker] send push notifs to windows devices to [Tunnelbroker] send push notifs to windows devices.
varun edited the summary of this revision. (Show Details)
varun edited the test plan for this revision. (Show Details)

update revision

Harbormaster completed remote builds in B30974: Diff 43213.Aug 6 2024, 10:06 PM
bartek accepted this revision.Aug 6 2024, 10:57 PM
bartek added 1 blocking reviewer(s): kamil.

LGTM, letting @kamil take a look at the request format

services/tunnelbroker/src/notifs/wns/mod.rs
40 ↗(On Diff #43213)

nit, to disambiguate WNS token and device token

kamil accepted this revision.Aug 7 2024, 12:42 AM
kamil added inline comments.
services/tunnelbroker/src/notifs/wns/mod.rs
59–69 ↗(On Diff #43213)

Could you create a specific error for status codes?

Similar to what I did in e.g. D12768. Most important are errors about invalid device token which you need for ENG-8913.

71–75 ↗(On Diff #43213)

I don't think this is needed - we don't that for other push services, for keyserver it was implemented because notif ID was needed

This revision is now accepted and ready to land.Aug 7 2024, 12:42 AM
varun updated this revision to Diff 43237.Aug 7 2024, 1:33 PM

address feedback

Harbormaster failed remote builds in B30991: Diff 43237!Aug 7 2024, 1:56 PM
varun updated this revision to Diff 43239.Aug 7 2024, 2:29 PM

address feedback

Harbormaster failed remote builds in B30994: Diff 43239!Aug 7 2024, 2:34 PM
This revision was landed with ongoing or failed builds.Aug 7 2024, 2:41 PM
Closed by commit rCOMM5f3de4311fbb: [Tunnelbroker] send push notifs to windows devices (authored by varun). · Explain Why
This revision was automatically updated to reflect the committed changes.
varun added a commit: rCOMM5f3de4311fbb: [Tunnelbroker] send push notifs to windows devices.

Revision Contents
Changeset List

PathSize
lib/
types/
tunnelbroker/
10 lines
services/
tunnelbroker/
src/
notifs/
4 lines
wns/
22 lines
62 lines
77 lines
websockets/
42 lines
shared/
tunnelbroker_messages/
src/
messages/
1 line
11 lines

Diff 43240

View Options

lib/types/tunnelbroker/notif-types.js

// @flow // @flow
import invariant from 'invariant'; import invariant from 'invariant';
import { import {
parseThreadPermissionString, parseThreadPermissionString,
constructThreadPermissionString,
includeThreadPermissionForThreadType, includeThreadPermissionForThreadType,
} from './prefixes.js'; } from './prefixes.js';
import { import {
configurableCommunityPermissions, configurableCommunityPermissions,
threadPermissionFilterPrefixes, threadPermissionFilterPrefixes,
threadPermissionPropagationPrefixes, threadPermissionPropagationPrefixes,
threadPermissions, threadPermissions,
userSurfacedPermissions, userSurfacedPermissions,
▲ Show 20 Lines • Show All 148 Lines • ▼ Show 20 Lines if (!parsed.propagationPrefix) {
continue; continue;
} }
if ( if (
parsed.propagationPrefix === parsed.propagationPrefix ===
threadPermissionPropagationPrefixes.DESCENDANT threadPermissionPropagationPrefixes.DESCENDANT
) { ) {
permissionsForChildren[permissionKey] = permissionValue; permissionsForChildren[permissionKey] = permissionValue;
} }
const permissionWithFilterPrefix = parsed.filterPrefix const withoutPropagationPrefix = constructThreadPermissionString({
? `${parsed.filterPrefix}${parsed.permission}` ...parsed,
: parsed.permission; propagationPrefix: null,
permissionsForChildren[permissionWithFilterPrefix] = permissionValue; });
permissionsForChildren[withoutPropagationPrefix] = permissionValue;
} }
if (Object.keys(permissionsForChildren).length === 0) { if (Object.keys(permissionsForChildren).length === 0) {
return null; return null;
} }
return permissionsForChildren; return permissionsForChildren;
} }
function getRoleForPermissions( function getRoleForPermissions(
▲ Show 20 Lines • Show All 373 Lines • Show Last 20 Lines
View Options

services/tunnelbroker/src/notifs/mod.rs

// @flow // @flow
import invariant from 'invariant'; import invariant from 'invariant';
import { import {
parseThreadPermissionString, parseThreadPermissionString,
constructThreadPermissionString,
includeThreadPermissionForThreadType, includeThreadPermissionForThreadType,
} from './prefixes.js'; } from './prefixes.js';
import { import {
configurableCommunityPermissions, configurableCommunityPermissions,
threadPermissionFilterPrefixes, threadPermissionFilterPrefixes,
threadPermissionPropagationPrefixes, threadPermissionPropagationPrefixes,
threadPermissions, threadPermissions,
userSurfacedPermissions, userSurfacedPermissions,
▲ Show 20 Lines • Show All 148 Lines • ▼ Show 20 Lines if (!parsed.propagationPrefix) {
continue; continue;
} }
if ( if (
parsed.propagationPrefix === parsed.propagationPrefix ===
threadPermissionPropagationPrefixes.DESCENDANT threadPermissionPropagationPrefixes.DESCENDANT
) { ) {
permissionsForChildren[permissionKey] = permissionValue; permissionsForChildren[permissionKey] = permissionValue;
} }
const permissionWithFilterPrefix = parsed.filterPrefix const withoutPropagationPrefix = constructThreadPermissionString({
? `${parsed.filterPrefix}${parsed.permission}` ...parsed,
: parsed.permission; propagationPrefix: null,
permissionsForChildren[permissionWithFilterPrefix] = permissionValue; });
permissionsForChildren[withoutPropagationPrefix] = permissionValue;
} }
if (Object.keys(permissionsForChildren).length === 0) { if (Object.keys(permissionsForChildren).length === 0) {
return null; return null;
} }
return permissionsForChildren; return permissionsForChildren;
} }
function getRoleForPermissions( function getRoleForPermissions(
▲ Show 20 Lines • Show All 373 Lines • Show Last 20 Lines
View Options

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

// @flow // @flow
import invariant from 'invariant'; import invariant from 'invariant';
import { import {
parseThreadPermissionString, parseThreadPermissionString,
constructThreadPermissionString,
includeThreadPermissionForThreadType, includeThreadPermissionForThreadType,
} from './prefixes.js'; } from './prefixes.js';
import { import {
configurableCommunityPermissions, configurableCommunityPermissions,
threadPermissionFilterPrefixes, threadPermissionFilterPrefixes,
threadPermissionPropagationPrefixes, threadPermissionPropagationPrefixes,
threadPermissions, threadPermissions,
userSurfacedPermissions, userSurfacedPermissions,
▲ Show 20 Lines • Show All 148 Lines • ▼ Show 20 Lines if (!parsed.propagationPrefix) {
continue; continue;
} }
if ( if (
parsed.propagationPrefix === parsed.propagationPrefix ===
threadPermissionPropagationPrefixes.DESCENDANT threadPermissionPropagationPrefixes.DESCENDANT
) { ) {
permissionsForChildren[permissionKey] = permissionValue; permissionsForChildren[permissionKey] = permissionValue;
} }
const permissionWithFilterPrefix = parsed.filterPrefix const withoutPropagationPrefix = constructThreadPermissionString({
? `${parsed.filterPrefix}${parsed.permission}` ...parsed,
: parsed.permission; propagationPrefix: null,
permissionsForChildren[permissionWithFilterPrefix] = permissionValue; });
permissionsForChildren[withoutPropagationPrefix] = permissionValue;
} }
if (Object.keys(permissionsForChildren).length === 0) { if (Object.keys(permissionsForChildren).length === 0) {
return null; return null;
} }
return permissionsForChildren; return permissionsForChildren;
} }
function getRoleForPermissions( function getRoleForPermissions(
▲ Show 20 Lines • Show All 373 Lines • Show Last 20 Lines
View Options

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

// @flow // @flow
import invariant from 'invariant'; import invariant from 'invariant';
import { import {
parseThreadPermissionString, parseThreadPermissionString,
constructThreadPermissionString,
includeThreadPermissionForThreadType, includeThreadPermissionForThreadType,
} from './prefixes.js'; } from './prefixes.js';
import { import {
configurableCommunityPermissions, configurableCommunityPermissions,
threadPermissionFilterPrefixes, threadPermissionFilterPrefixes,
threadPermissionPropagationPrefixes, threadPermissionPropagationPrefixes,
threadPermissions, threadPermissions,
userSurfacedPermissions, userSurfacedPermissions,
▲ Show 20 Lines • Show All 148 Lines • ▼ Show 20 Lines if (!parsed.propagationPrefix) {
continue; continue;
} }
if ( if (
parsed.propagationPrefix === parsed.propagationPrefix ===
threadPermissionPropagationPrefixes.DESCENDANT threadPermissionPropagationPrefixes.DESCENDANT
) { ) {
permissionsForChildren[permissionKey] = permissionValue; permissionsForChildren[permissionKey] = permissionValue;
} }
const permissionWithFilterPrefix = parsed.filterPrefix const withoutPropagationPrefix = constructThreadPermissionString({
? `${parsed.filterPrefix}${parsed.permission}` ...parsed,
: parsed.permission; propagationPrefix: null,
permissionsForChildren[permissionWithFilterPrefix] = permissionValue; });
permissionsForChildren[withoutPropagationPrefix] = permissionValue;
} }
if (Object.keys(permissionsForChildren).length === 0) { if (Object.keys(permissionsForChildren).length === 0) {
return null; return null;
} }
return permissionsForChildren; return permissionsForChildren;
} }
function getRoleForPermissions( function getRoleForPermissions(
▲ Show 20 Lines • Show All 373 Lines • Show Last 20 Lines
View Options

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

// @flow // @flow
import invariant from 'invariant'; import invariant from 'invariant';
import { import {
parseThreadPermissionString, parseThreadPermissionString,
constructThreadPermissionString,
includeThreadPermissionForThreadType, includeThreadPermissionForThreadType,
} from './prefixes.js'; } from './prefixes.js';
import { import {
configurableCommunityPermissions, configurableCommunityPermissions,
threadPermissionFilterPrefixes, threadPermissionFilterPrefixes,
threadPermissionPropagationPrefixes, threadPermissionPropagationPrefixes,
threadPermissions, threadPermissions,
userSurfacedPermissions, userSurfacedPermissions,
▲ Show 20 Lines • Show All 148 Lines • ▼ Show 20 Lines if (!parsed.propagationPrefix) {
continue; continue;
} }
if ( if (
parsed.propagationPrefix === parsed.propagationPrefix ===
threadPermissionPropagationPrefixes.DESCENDANT threadPermissionPropagationPrefixes.DESCENDANT
) { ) {
permissionsForChildren[permissionKey] = permissionValue; permissionsForChildren[permissionKey] = permissionValue;
} }
const permissionWithFilterPrefix = parsed.filterPrefix const withoutPropagationPrefix = constructThreadPermissionString({
? `${parsed.filterPrefix}${parsed.permission}` ...parsed,
: parsed.permission; propagationPrefix: null,
permissionsForChildren[permissionWithFilterPrefix] = permissionValue; });
permissionsForChildren[withoutPropagationPrefix] = permissionValue;
} }
if (Object.keys(permissionsForChildren).length === 0) { if (Object.keys(permissionsForChildren).length === 0) {
return null; return null;
} }
return permissionsForChildren; return permissionsForChildren;
} }
function getRoleForPermissions( function getRoleForPermissions(
▲ Show 20 Lines • Show All 373 Lines • Show Last 20 Lines
View Options

services/tunnelbroker/src/websockets/session.rs

Loading...
View Options

shared/tunnelbroker_messages/src/messages/mod.rs

Loading...
View Options

shared/tunnelbroker_messages/src/messages/notif.rs

Loading...