Page MenuHomePhabricator
Differential D12517

[Tunnelbroker] define device tokens table in rust
ClosedPublic
Actions

Authored by kamil on Jun 20 2024, 2:03 PM.
Tags
None
Referenced Files
Unknown Object (File)
Wed, Apr 16, 2:04 PM
Unknown Object (File)
Wed, Apr 16, 1:45 PM
Unknown Object (File)
Tue, Apr 15, 8:55 PM
Unknown Object (File)
Mon, Apr 14, 10:27 PM
Unknown Object (File)
Wed, Apr 2, 4:32 AM
Unknown Object (File)
Mar 14 2025, 9:50 PM
Unknown Object (File)
Feb 27 2025, 6:47 AM
Unknown Object (File)
Feb 21 2025, 1:24 AM
View All 56 Files
Subscribers
ashoat
tomek

Details

Reviewers
bartek
marcin
Commits
rCOMM27815ac29c2b: [Tunnelbroker] define device tokens table in rust
Summary

ENG-8345

Depends on D12516

Test Plan

N/A

Diff Detail

Repository
rCOMM Comm
Branch
device-token
Lint
No Lint Coverage
Unit
No Test Coverage

Event Timeline

kamil created this revision.Jun 20 2024, 2:03 PM
kamil held this revision as a draft.
Herald added subscribers: tomek, ashoat. · View Herald TranscriptJun 20 2024, 2:03 PM
kamil added a child revision: D12518: [Tunnelbroker] implement removing device token.Jun 20 2024, 2:16 PM
Harbormaster completed remote builds in B29839: Diff 41574.Jun 20 2024, 2:24 PM
kamil published this revision for review.Jun 20 2024, 4:09 PM
bartek accepted this revision.Jun 21 2024, 10:15 PM

Simple change to imports and adding undelivered_messages:: made it look much better

This revision is now accepted and ready to land.Jun 21 2024, 10:15 PM
Closed by commit rCOMM27815ac29c2b: [Tunnelbroker] define device tokens table in rust (authored by kamil). · Explain WhyJun 28 2024, 6:07 AM
This revision was automatically updated to reflect the committed changes.
kamil added a commit: rCOMM27815ac29c2b: [Tunnelbroker] define device tokens table in rust.

Revision Contents
Changeset List

PathSize
services/
tunnelbroker/
src/
14 lines
database/
25 lines

Diff 41574

View Options

services/tunnelbroker/src/constants.rs

// @flow // @flow
import invariant from 'invariant'; import invariant from 'invariant';
import uuid from 'uuid'; import uuid from 'uuid';
import { import {
type AddMembersResult, type AddMembersResult,
createAddNewMembersResults, createAddNewMembersResults,
} from './add-members-spec.js'; } from './add-members-spec.js';
import type { import type {
DMOperationSpec, DMOperationSpec,
ProcessDMOperationUtilities, ProcessDMOperationUtilities,
} from './dm-op-spec.js'; } from './dm-op-spec.js';
import { createRepliesCountUpdate } from './dm-op-utils.js';
import type { import type {
DMChangeThreadSettingsAndAddViewerOperation, DMChangeThreadSettingsAndAddViewerOperation,
DMChangeThreadSettingsOperation, DMChangeThreadSettingsOperation,
DMOperationResult, DMOperationResult,
} from '../../types/dm-ops.js'; } from '../../types/dm-ops.js';
import { messageTypes } from '../../types/message-types-enum.js'; import { messageTypes } from '../../types/message-types-enum.js';
import type { RawMessageInfo } from '../../types/message-types.js'; import type { RawMessageInfo } from '../../types/message-types.js';
import type { RawThreadInfo } from '../../types/minimally-encoded-thread-permissions-types.js'; import type { RawThreadInfo } from '../../types/minimally-encoded-thread-permissions-types.js';
▲ Show 20 Lines • Show All 98 Lines • ▼ Show 20 Lines rawMessageInfos.push({
creatorID: editorID, creatorID: editorID,
time, time,
field: fieldName, field: fieldName,
value: newValue, value: newValue,
id: `${messageIDsPrefix}/${fieldName}`, id: `${messageIDsPrefix}/${fieldName}`,
}); });
} }
const repliesCountUpdate = createRepliesCountUpdate( if (values(changedFields).length > 0) {
threadInfoToUpdate,
rawMessageInfos,
);
if (repliesCountUpdate) {
updateInfos.push(repliesCountUpdate);
} else if (values(changedFields).length > 0) {
updateInfos.push({ updateInfos.push({
type: updateTypes.UPDATE_THREAD, type: updateTypes.UPDATE_THREAD,
id: uuid.v4(), id: uuid.v4(),
time, time,
threadInfo: threadInfoToUpdate, threadInfo: threadInfoToUpdate,
}); });
} }
▲ Show 20 Lines • Show All 45 Lines • Show Last 20 Lines
View Options

services/tunnelbroker/src/database/mod.rs

// @flow // @flow
import invariant from 'invariant'; import invariant from 'invariant';
import uuid from 'uuid'; import uuid from 'uuid';
import { import {
type AddMembersResult, type AddMembersResult,
createAddNewMembersResults, createAddNewMembersResults,
} from './add-members-spec.js'; } from './add-members-spec.js';
import type { import type {
DMOperationSpec, DMOperationSpec,
ProcessDMOperationUtilities, ProcessDMOperationUtilities,
} from './dm-op-spec.js'; } from './dm-op-spec.js';
import { createRepliesCountUpdate } from './dm-op-utils.js';
import type { import type {
DMChangeThreadSettingsAndAddViewerOperation, DMChangeThreadSettingsAndAddViewerOperation,
DMChangeThreadSettingsOperation, DMChangeThreadSettingsOperation,
DMOperationResult, DMOperationResult,
} from '../../types/dm-ops.js'; } from '../../types/dm-ops.js';
import { messageTypes } from '../../types/message-types-enum.js'; import { messageTypes } from '../../types/message-types-enum.js';
import type { RawMessageInfo } from '../../types/message-types.js'; import type { RawMessageInfo } from '../../types/message-types.js';
import type { RawThreadInfo } from '../../types/minimally-encoded-thread-permissions-types.js'; import type { RawThreadInfo } from '../../types/minimally-encoded-thread-permissions-types.js';
▲ Show 20 Lines • Show All 98 Lines • ▼ Show 20 Lines rawMessageInfos.push({
creatorID: editorID, creatorID: editorID,
time, time,
field: fieldName, field: fieldName,
value: newValue, value: newValue,
id: `${messageIDsPrefix}/${fieldName}`, id: `${messageIDsPrefix}/${fieldName}`,
}); });
} }
const repliesCountUpdate = createRepliesCountUpdate( if (values(changedFields).length > 0) {
threadInfoToUpdate,
rawMessageInfos,
);
if (repliesCountUpdate) {
updateInfos.push(repliesCountUpdate);
} else if (values(changedFields).length > 0) {
updateInfos.push({ updateInfos.push({
type: updateTypes.UPDATE_THREAD, type: updateTypes.UPDATE_THREAD,
id: uuid.v4(), id: uuid.v4(),
time, time,
threadInfo: threadInfoToUpdate, threadInfo: threadInfoToUpdate,
}); });
} }
▲ Show 20 Lines • Show All 45 Lines • Show Last 20 Lines