Page MenuHomePhabricator
Differential D9472

[commtest] use shared/grpc_client for identity clients
ClosedPublic
Actions

Authored by varun on Oct 12 2023, 11:56 AM.
Tags
None
Referenced Files
F5889109: D9472.diff
Thu, Apr 17, 5:09 AM
Unknown Object (File)
Tue, Apr 1, 8:24 PM
Unknown Object (File)
Sat, Mar 22, 7:44 AM
Unknown Object (File)
Wed, Mar 19, 1:32 PM
Unknown Object (File)
Mar 15 2025, 8:12 AM
Unknown Object (File)
Mar 10 2025, 3:58 AM
Unknown Object (File)
Mar 10 2025, 3:58 AM
Unknown Object (File)
Mar 10 2025, 3:54 AM
View All 91 Files
Subscribers
ashoat
tomek
will

Details

Reviewers
bartek
michal
• jon
Commits
rCOMM695f3464b34b: [commtest] use shared/grpc_client for identity clients
Summary

remove all custom clients and replace them with the grpc_clients library clients

Depends on D9471

Test Plan

ran cargo test and all tests but an unrelated backup integration test passed (wasn't running backup service)

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Event Timeline

varun created this revision.Oct 12 2023, 11:56 AM
Herald added a reviewer: • jon. · View Herald TranscriptOct 12 2023, 11:56 AM
Herald added subscribers: will, tomek, ashoat. · View Herald Transcript
varun added a child revision: D9473: [keyserver] change function names for getting clients to be more intuitive.Oct 12 2023, 11:57 AM
Harbormaster completed remote builds in B23219: Diff 31975.Oct 12 2023, 12:19 PM
varun requested review of this revision.Oct 12 2023, 12:19 PM
bartek accepted this revision.Oct 16 2023, 12:42 AM

Looks good. Conflicts a bit with my commtest changes, but I'll rebase as soon as you land this

services/commtest/build.rs
11–15 ↗(On Diff #31975)

This is not a perfect solution. It can stay for now but we should design something else for long term.
Can you create a follow-up task for this? E.g. under ENG-2311 or 4686

This revision is now accepted and ready to land.Oct 16 2023, 12:42 AM
varun added inline comments.Oct 18 2023, 7:20 PM
services/commtest/build.rs
11–15 ↗(On Diff #31975)

https://linear.app/comm/issue/ENG-5297/compile-all-protobuf-files-in-grpc-clients-and-potentially-rename-the

Closed by commit rCOMM695f3464b34b: [commtest] use shared/grpc_client for identity clients (authored by varun). · Explain WhyOct 18 2023, 8:00 PM
This revision was automatically updated to reflect the committed changes.
varun added a commit: rCOMM695f3464b34b: [commtest] use shared/grpc_client for identity clients.

Revision Contents
Changeset List

Diff 32164

View Options

services/commtest/Cargo.lock

Show All 29 Linesimport {
threadPermissions, threadPermissions,
threadTypes, threadTypes,
} from 'lib/types/thread-types.js'; } from 'lib/types/thread-types.js';
import { updateTypes } from 'lib/types/update-types.js'; import { updateTypes } from 'lib/types/update-types.js';
import { ServerError } from 'lib/utils/errors.js'; import { ServerError } from 'lib/utils/errors.js';
import { promiseAll } from 'lib/utils/promises.js'; import { promiseAll } from 'lib/utils/promises.js';
import { firstLine } from 'lib/utils/string-utils.js'; import { firstLine } from 'lib/utils/string-utils.js';
import { reportLinkUsage } from './link-updaters.js';
import { updateRoles } from './role-updaters.js'; import { updateRoles } from './role-updaters.js';
import { import {
changeRole, changeRole,
recalculateThreadPermissions, recalculateThreadPermissions,
commitMembershipChangeset, commitMembershipChangeset,
} from './thread-permission-updaters.js'; } from './thread-permission-updaters.js';
import createMessages from '../creators/message-creator.js'; import createMessages from '../creators/message-creator.js';
import { createUpdates } from '../creators/update-creator.js'; import { createUpdates } from '../creators/update-creator.js';
import { dbQuery, SQL } from '../database/database.js'; import { dbQuery, SQL } from '../database/database.js';
import { fetchEntryInfos } from '../fetchers/entry-fetchers.js'; import { fetchEntryInfos } from '../fetchers/entry-fetchers.js';
import { checkIfInviteLinkIsValid } from '../fetchers/link-fetchers.js';
import { import {
fetchMessageInfos, fetchMessageInfos,
fetchMessageInfoByID, fetchMessageInfoByID,
} from '../fetchers/message-fetchers.js'; } from '../fetchers/message-fetchers.js';
import { import {
fetchThreadInfos, fetchThreadInfos,
fetchServerThreadInfos, fetchServerThreadInfos,
determineThreadAncestry, determineThreadAncestry,
} from '../fetchers/thread-fetchers.js'; } from '../fetchers/thread-fetchers.js';
import { import {
checkThreadPermission, checkThreadPermission,
viewerIsMember as fetchViewerIsMember, viewerIsMember as fetchViewerIsMember,
checkThread, checkThread,
validateCandidateMembers, validateCandidateMembers,
} from '../fetchers/thread-permission-fetchers.js'; } from '../fetchers/thread-permission-fetchers.js';
import { import {
verifyUserIDs, verifyUserIDs,
verifyUserOrCookieIDs, verifyUserOrCookieIDs,
} from '../fetchers/user-fetchers.js'; } from '../fetchers/user-fetchers.js';
import { handleAsyncPromise } from '../responders/handlers.js';
import type { Viewer } from '../session/viewer.js'; import type { Viewer } from '../session/viewer.js';
import RelationshipChangeset from '../utils/relationship-changeset.js'; import RelationshipChangeset from '../utils/relationship-changeset.js';
async function updateRole( async function updateRole(
viewer: Viewer, viewer: Viewer,
request: RoleChangeRequest, request: RoleChangeRequest,
): Promise<ChangeThreadSettingsResult> { ): Promise<ChangeThreadSettingsResult> {
if (!viewer.loggedIn) { if (!viewer.loggedIn) {
▲ Show 20 Lines • Show All 729 Lines • ▼ Show 20 Lines
async function joinThread( async function joinThread(
viewer: Viewer, viewer: Viewer,
request: ServerThreadJoinRequest, request: ServerThreadJoinRequest,
): Promise<ThreadJoinResult> { ): Promise<ThreadJoinResult> {
if (!viewer.loggedIn) { if (!viewer.loggedIn) {
throw new ServerError('not_logged_in'); throw new ServerError('not_logged_in');
} }
const [isMember, hasPermission] = await Promise.all([ const permissionCheck = request.inviteLinkSecret
fetchViewerIsMember(viewer, request.threadID), ? checkIfInviteLinkIsValid(request.inviteLinkSecret, request.threadID)
checkThreadPermission( : checkThreadPermission(
viewer, viewer,
request.threadID, request.threadID,
threadPermissions.JOIN_THREAD, threadPermissions.JOIN_THREAD,
), );
const [isMember, hasPermission] = await Promise.all([
fetchViewerIsMember(viewer, request.threadID),
permissionCheck,
]); ]);
if (!hasPermission) { if (!hasPermission) {
throw new ServerError('invalid_parameters'); throw new ServerError('invalid_parameters');
} }
// TODO: determine code version // TODO: determine code version
const hasCodeVersionBelow87 = !hasMinCodeVersion(viewer.platformDetails, 87); const hasCodeVersionBelow87 = !hasMinCodeVersion(viewer.platformDetails, 87);
const hasCodeVersionBelow62 = !hasMinCodeVersion(viewer.platformDetails, 62); const hasCodeVersionBelow62 = !hasMinCodeVersion(viewer.platformDetails, 62);
Show All 29 Lines): Promise<ThreadJoinResult> {
} }
const changeset = await changeRole(request.threadID, [viewer.userID], null); const changeset = await changeRole(request.threadID, [viewer.userID], null);
const membershipResult = await commitMembershipChangeset(viewer, changeset, { const membershipResult = await commitMembershipChangeset(viewer, changeset, {
calendarQuery, calendarQuery,
}); });
if (request.inviteLinkSecret) {
handleAsyncPromise(reportLinkUsage(request.inviteLinkSecret));
}
const messageData = { const messageData = {
type: messageTypes.JOIN_THREAD, type: messageTypes.JOIN_THREAD,
threadID: request.threadID, threadID: request.threadID,
creatorID: viewer.userID, creatorID: viewer.userID,
time: Date.now(), time: Date.now(),
}; };
const newMessages = await createMessages(viewer, [messageData]); const newMessages = await createMessages(viewer, [messageData]);
▲ Show 20 Lines • Show All 150 Lines • Show Last 20 Lines
View Options

services/commtest/Cargo.toml

Show All 29 Linesimport {
threadPermissions, threadPermissions,
threadTypes, threadTypes,
} from 'lib/types/thread-types.js'; } from 'lib/types/thread-types.js';
import { updateTypes } from 'lib/types/update-types.js'; import { updateTypes } from 'lib/types/update-types.js';
import { ServerError } from 'lib/utils/errors.js'; import { ServerError } from 'lib/utils/errors.js';
import { promiseAll } from 'lib/utils/promises.js'; import { promiseAll } from 'lib/utils/promises.js';
import { firstLine } from 'lib/utils/string-utils.js'; import { firstLine } from 'lib/utils/string-utils.js';
import { reportLinkUsage } from './link-updaters.js';
import { updateRoles } from './role-updaters.js'; import { updateRoles } from './role-updaters.js';
import { import {
changeRole, changeRole,
recalculateThreadPermissions, recalculateThreadPermissions,
commitMembershipChangeset, commitMembershipChangeset,
} from './thread-permission-updaters.js'; } from './thread-permission-updaters.js';
import createMessages from '../creators/message-creator.js'; import createMessages from '../creators/message-creator.js';
import { createUpdates } from '../creators/update-creator.js'; import { createUpdates } from '../creators/update-creator.js';
import { dbQuery, SQL } from '../database/database.js'; import { dbQuery, SQL } from '../database/database.js';
import { fetchEntryInfos } from '../fetchers/entry-fetchers.js'; import { fetchEntryInfos } from '../fetchers/entry-fetchers.js';
import { checkIfInviteLinkIsValid } from '../fetchers/link-fetchers.js';
import { import {
fetchMessageInfos, fetchMessageInfos,
fetchMessageInfoByID, fetchMessageInfoByID,
} from '../fetchers/message-fetchers.js'; } from '../fetchers/message-fetchers.js';
import { import {
fetchThreadInfos, fetchThreadInfos,
fetchServerThreadInfos, fetchServerThreadInfos,
determineThreadAncestry, determineThreadAncestry,
} from '../fetchers/thread-fetchers.js'; } from '../fetchers/thread-fetchers.js';
import { import {
checkThreadPermission, checkThreadPermission,
viewerIsMember as fetchViewerIsMember, viewerIsMember as fetchViewerIsMember,
checkThread, checkThread,
validateCandidateMembers, validateCandidateMembers,
} from '../fetchers/thread-permission-fetchers.js'; } from '../fetchers/thread-permission-fetchers.js';
import { import {
verifyUserIDs, verifyUserIDs,
verifyUserOrCookieIDs, verifyUserOrCookieIDs,
} from '../fetchers/user-fetchers.js'; } from '../fetchers/user-fetchers.js';
import { handleAsyncPromise } from '../responders/handlers.js';
import type { Viewer } from '../session/viewer.js'; import type { Viewer } from '../session/viewer.js';
import RelationshipChangeset from '../utils/relationship-changeset.js'; import RelationshipChangeset from '../utils/relationship-changeset.js';
async function updateRole( async function updateRole(
viewer: Viewer, viewer: Viewer,
request: RoleChangeRequest, request: RoleChangeRequest,
): Promise<ChangeThreadSettingsResult> { ): Promise<ChangeThreadSettingsResult> {
if (!viewer.loggedIn) { if (!viewer.loggedIn) {
▲ Show 20 Lines • Show All 729 Lines • ▼ Show 20 Lines
async function joinThread( async function joinThread(
viewer: Viewer, viewer: Viewer,
request: ServerThreadJoinRequest, request: ServerThreadJoinRequest,
): Promise<ThreadJoinResult> { ): Promise<ThreadJoinResult> {
if (!viewer.loggedIn) { if (!viewer.loggedIn) {
throw new ServerError('not_logged_in'); throw new ServerError('not_logged_in');
} }
const [isMember, hasPermission] = await Promise.all([ const permissionCheck = request.inviteLinkSecret
fetchViewerIsMember(viewer, request.threadID), ? checkIfInviteLinkIsValid(request.inviteLinkSecret, request.threadID)
checkThreadPermission( : checkThreadPermission(
viewer, viewer,
request.threadID, request.threadID,
threadPermissions.JOIN_THREAD, threadPermissions.JOIN_THREAD,
), );
const [isMember, hasPermission] = await Promise.all([
fetchViewerIsMember(viewer, request.threadID),
permissionCheck,
]); ]);
if (!hasPermission) { if (!hasPermission) {
throw new ServerError('invalid_parameters'); throw new ServerError('invalid_parameters');
} }
// TODO: determine code version // TODO: determine code version
const hasCodeVersionBelow87 = !hasMinCodeVersion(viewer.platformDetails, 87); const hasCodeVersionBelow87 = !hasMinCodeVersion(viewer.platformDetails, 87);
const hasCodeVersionBelow62 = !hasMinCodeVersion(viewer.platformDetails, 62); const hasCodeVersionBelow62 = !hasMinCodeVersion(viewer.platformDetails, 62);
Show All 29 Lines): Promise<ThreadJoinResult> {
} }
const changeset = await changeRole(request.threadID, [viewer.userID], null); const changeset = await changeRole(request.threadID, [viewer.userID], null);
const membershipResult = await commitMembershipChangeset(viewer, changeset, { const membershipResult = await commitMembershipChangeset(viewer, changeset, {
calendarQuery, calendarQuery,
}); });
if (request.inviteLinkSecret) {
handleAsyncPromise(reportLinkUsage(request.inviteLinkSecret));
}
const messageData = { const messageData = {
type: messageTypes.JOIN_THREAD, type: messageTypes.JOIN_THREAD,
threadID: request.threadID, threadID: request.threadID,
creatorID: viewer.userID, creatorID: viewer.userID,
time: Date.now(), time: Date.now(),
}; };
const newMessages = await createMessages(viewer, [messageData]); const newMessages = await createMessages(viewer, [messageData]);
▲ Show 20 Lines • Show All 150 Lines • Show Last 20 Lines
View Options

services/commtest/build.rs

Show All 29 Linesimport {
threadPermissions, threadPermissions,
threadTypes, threadTypes,
} from 'lib/types/thread-types.js'; } from 'lib/types/thread-types.js';
import { updateTypes } from 'lib/types/update-types.js'; import { updateTypes } from 'lib/types/update-types.js';
import { ServerError } from 'lib/utils/errors.js'; import { ServerError } from 'lib/utils/errors.js';
import { promiseAll } from 'lib/utils/promises.js'; import { promiseAll } from 'lib/utils/promises.js';
import { firstLine } from 'lib/utils/string-utils.js'; import { firstLine } from 'lib/utils/string-utils.js';
import { reportLinkUsage } from './link-updaters.js';
import { updateRoles } from './role-updaters.js'; import { updateRoles } from './role-updaters.js';
import { import {
changeRole, changeRole,
recalculateThreadPermissions, recalculateThreadPermissions,
commitMembershipChangeset, commitMembershipChangeset,
} from './thread-permission-updaters.js'; } from './thread-permission-updaters.js';
import createMessages from '../creators/message-creator.js'; import createMessages from '../creators/message-creator.js';
import { createUpdates } from '../creators/update-creator.js'; import { createUpdates } from '../creators/update-creator.js';
import { dbQuery, SQL } from '../database/database.js'; import { dbQuery, SQL } from '../database/database.js';
import { fetchEntryInfos } from '../fetchers/entry-fetchers.js'; import { fetchEntryInfos } from '../fetchers/entry-fetchers.js';
import { checkIfInviteLinkIsValid } from '../fetchers/link-fetchers.js';
import { import {
fetchMessageInfos, fetchMessageInfos,
fetchMessageInfoByID, fetchMessageInfoByID,
} from '../fetchers/message-fetchers.js'; } from '../fetchers/message-fetchers.js';
import { import {
fetchThreadInfos, fetchThreadInfos,
fetchServerThreadInfos, fetchServerThreadInfos,
determineThreadAncestry, determineThreadAncestry,
} from '../fetchers/thread-fetchers.js'; } from '../fetchers/thread-fetchers.js';
import { import {
checkThreadPermission, checkThreadPermission,
viewerIsMember as fetchViewerIsMember, viewerIsMember as fetchViewerIsMember,
checkThread, checkThread,
validateCandidateMembers, validateCandidateMembers,
} from '../fetchers/thread-permission-fetchers.js'; } from '../fetchers/thread-permission-fetchers.js';
import { import {
verifyUserIDs, verifyUserIDs,
verifyUserOrCookieIDs, verifyUserOrCookieIDs,
} from '../fetchers/user-fetchers.js'; } from '../fetchers/user-fetchers.js';
import { handleAsyncPromise } from '../responders/handlers.js';
import type { Viewer } from '../session/viewer.js'; import type { Viewer } from '../session/viewer.js';
import RelationshipChangeset from '../utils/relationship-changeset.js'; import RelationshipChangeset from '../utils/relationship-changeset.js';
async function updateRole( async function updateRole(
viewer: Viewer, viewer: Viewer,
request: RoleChangeRequest, request: RoleChangeRequest,
): Promise<ChangeThreadSettingsResult> { ): Promise<ChangeThreadSettingsResult> {
if (!viewer.loggedIn) { if (!viewer.loggedIn) {
▲ Show 20 Lines • Show All 729 Lines • ▼ Show 20 Lines
async function joinThread( async function joinThread(
viewer: Viewer, viewer: Viewer,
request: ServerThreadJoinRequest, request: ServerThreadJoinRequest,
): Promise<ThreadJoinResult> { ): Promise<ThreadJoinResult> {
if (!viewer.loggedIn) { if (!viewer.loggedIn) {
throw new ServerError('not_logged_in'); throw new ServerError('not_logged_in');
} }
const [isMember, hasPermission] = await Promise.all([ const permissionCheck = request.inviteLinkSecret
fetchViewerIsMember(viewer, request.threadID), ? checkIfInviteLinkIsValid(request.inviteLinkSecret, request.threadID)
checkThreadPermission( : checkThreadPermission(
viewer, viewer,
request.threadID, request.threadID,
threadPermissions.JOIN_THREAD, threadPermissions.JOIN_THREAD,
), );
const [isMember, hasPermission] = await Promise.all([
fetchViewerIsMember(viewer, request.threadID),
permissionCheck,
]); ]);
if (!hasPermission) { if (!hasPermission) {
throw new ServerError('invalid_parameters'); throw new ServerError('invalid_parameters');
} }
// TODO: determine code version // TODO: determine code version
const hasCodeVersionBelow87 = !hasMinCodeVersion(viewer.platformDetails, 87); const hasCodeVersionBelow87 = !hasMinCodeVersion(viewer.platformDetails, 87);
const hasCodeVersionBelow62 = !hasMinCodeVersion(viewer.platformDetails, 62); const hasCodeVersionBelow62 = !hasMinCodeVersion(viewer.platformDetails, 62);
Show All 29 Lines): Promise<ThreadJoinResult> {
} }
const changeset = await changeRole(request.threadID, [viewer.userID], null); const changeset = await changeRole(request.threadID, [viewer.userID], null);
const membershipResult = await commitMembershipChangeset(viewer, changeset, { const membershipResult = await commitMembershipChangeset(viewer, changeset, {
calendarQuery, calendarQuery,
}); });
if (request.inviteLinkSecret) {
handleAsyncPromise(reportLinkUsage(request.inviteLinkSecret));
}
const messageData = { const messageData = {
type: messageTypes.JOIN_THREAD, type: messageTypes.JOIN_THREAD,
threadID: request.threadID, threadID: request.threadID,
creatorID: viewer.userID, creatorID: viewer.userID,
time: Date.now(), time: Date.now(),
}; };
const newMessages = await createMessages(viewer, [messageData]); const newMessages = await createMessages(viewer, [messageData]);
▲ Show 20 Lines • Show All 150 Lines • Show Last 20 Lines
View Options

services/commtest/src/identity/device.rs

Show All 29 Linesimport {
threadPermissions, threadPermissions,
threadTypes, threadTypes,
} from 'lib/types/thread-types.js'; } from 'lib/types/thread-types.js';
import { updateTypes } from 'lib/types/update-types.js'; import { updateTypes } from 'lib/types/update-types.js';
import { ServerError } from 'lib/utils/errors.js'; import { ServerError } from 'lib/utils/errors.js';
import { promiseAll } from 'lib/utils/promises.js'; import { promiseAll } from 'lib/utils/promises.js';
import { firstLine } from 'lib/utils/string-utils.js'; import { firstLine } from 'lib/utils/string-utils.js';
import { reportLinkUsage } from './link-updaters.js';
import { updateRoles } from './role-updaters.js'; import { updateRoles } from './role-updaters.js';
import { import {
changeRole, changeRole,
recalculateThreadPermissions, recalculateThreadPermissions,
commitMembershipChangeset, commitMembershipChangeset,
} from './thread-permission-updaters.js'; } from './thread-permission-updaters.js';
import createMessages from '../creators/message-creator.js'; import createMessages from '../creators/message-creator.js';
import { createUpdates } from '../creators/update-creator.js'; import { createUpdates } from '../creators/update-creator.js';
import { dbQuery, SQL } from '../database/database.js'; import { dbQuery, SQL } from '../database/database.js';
import { fetchEntryInfos } from '../fetchers/entry-fetchers.js'; import { fetchEntryInfos } from '../fetchers/entry-fetchers.js';
import { checkIfInviteLinkIsValid } from '../fetchers/link-fetchers.js';
import { import {
fetchMessageInfos, fetchMessageInfos,
fetchMessageInfoByID, fetchMessageInfoByID,
} from '../fetchers/message-fetchers.js'; } from '../fetchers/message-fetchers.js';
import { import {
fetchThreadInfos, fetchThreadInfos,
fetchServerThreadInfos, fetchServerThreadInfos,
determineThreadAncestry, determineThreadAncestry,
} from '../fetchers/thread-fetchers.js'; } from '../fetchers/thread-fetchers.js';
import { import {
checkThreadPermission, checkThreadPermission,
viewerIsMember as fetchViewerIsMember, viewerIsMember as fetchViewerIsMember,
checkThread, checkThread,
validateCandidateMembers, validateCandidateMembers,
} from '../fetchers/thread-permission-fetchers.js'; } from '../fetchers/thread-permission-fetchers.js';
import { import {
verifyUserIDs, verifyUserIDs,
verifyUserOrCookieIDs, verifyUserOrCookieIDs,
} from '../fetchers/user-fetchers.js'; } from '../fetchers/user-fetchers.js';
import { handleAsyncPromise } from '../responders/handlers.js';
import type { Viewer } from '../session/viewer.js'; import type { Viewer } from '../session/viewer.js';
import RelationshipChangeset from '../utils/relationship-changeset.js'; import RelationshipChangeset from '../utils/relationship-changeset.js';
async function updateRole( async function updateRole(
viewer: Viewer, viewer: Viewer,
request: RoleChangeRequest, request: RoleChangeRequest,
): Promise<ChangeThreadSettingsResult> { ): Promise<ChangeThreadSettingsResult> {
if (!viewer.loggedIn) { if (!viewer.loggedIn) {
▲ Show 20 Lines • Show All 729 Lines • ▼ Show 20 Lines
async function joinThread( async function joinThread(
viewer: Viewer, viewer: Viewer,
request: ServerThreadJoinRequest, request: ServerThreadJoinRequest,
): Promise<ThreadJoinResult> { ): Promise<ThreadJoinResult> {
if (!viewer.loggedIn) { if (!viewer.loggedIn) {
throw new ServerError('not_logged_in'); throw new ServerError('not_logged_in');
} }
const [isMember, hasPermission] = await Promise.all([ const permissionCheck = request.inviteLinkSecret
fetchViewerIsMember(viewer, request.threadID), ? checkIfInviteLinkIsValid(request.inviteLinkSecret, request.threadID)
checkThreadPermission( : checkThreadPermission(
viewer, viewer,
request.threadID, request.threadID,
threadPermissions.JOIN_THREAD, threadPermissions.JOIN_THREAD,
), );
const [isMember, hasPermission] = await Promise.all([
fetchViewerIsMember(viewer, request.threadID),
permissionCheck,
]); ]);
if (!hasPermission) { if (!hasPermission) {
throw new ServerError('invalid_parameters'); throw new ServerError('invalid_parameters');
} }
// TODO: determine code version // TODO: determine code version
const hasCodeVersionBelow87 = !hasMinCodeVersion(viewer.platformDetails, 87); const hasCodeVersionBelow87 = !hasMinCodeVersion(viewer.platformDetails, 87);
const hasCodeVersionBelow62 = !hasMinCodeVersion(viewer.platformDetails, 62); const hasCodeVersionBelow62 = !hasMinCodeVersion(viewer.platformDetails, 62);
Show All 29 Lines): Promise<ThreadJoinResult> {
} }
const changeset = await changeRole(request.threadID, [viewer.userID], null); const changeset = await changeRole(request.threadID, [viewer.userID], null);
const membershipResult = await commitMembershipChangeset(viewer, changeset, { const membershipResult = await commitMembershipChangeset(viewer, changeset, {
calendarQuery, calendarQuery,
}); });
if (request.inviteLinkSecret) {
handleAsyncPromise(reportLinkUsage(request.inviteLinkSecret));
}
const messageData = { const messageData = {
type: messageTypes.JOIN_THREAD, type: messageTypes.JOIN_THREAD,
threadID: request.threadID, threadID: request.threadID,
creatorID: viewer.userID, creatorID: viewer.userID,
time: Date.now(), time: Date.now(),
}; };
const newMessages = await createMessages(viewer, [messageData]); const newMessages = await createMessages(viewer, [messageData]);
▲ Show 20 Lines • Show All 150 Lines • Show Last 20 Lines
View Options

services/commtest/tests/identity_access_tokens_tests.rs

Show All 29 Linesimport {
threadPermissions, threadPermissions,
threadTypes, threadTypes,
} from 'lib/types/thread-types.js'; } from 'lib/types/thread-types.js';
import { updateTypes } from 'lib/types/update-types.js'; import { updateTypes } from 'lib/types/update-types.js';
import { ServerError } from 'lib/utils/errors.js'; import { ServerError } from 'lib/utils/errors.js';
import { promiseAll } from 'lib/utils/promises.js'; import { promiseAll } from 'lib/utils/promises.js';
import { firstLine } from 'lib/utils/string-utils.js'; import { firstLine } from 'lib/utils/string-utils.js';
import { reportLinkUsage } from './link-updaters.js';
import { updateRoles } from './role-updaters.js'; import { updateRoles } from './role-updaters.js';
import { import {
changeRole, changeRole,
recalculateThreadPermissions, recalculateThreadPermissions,
commitMembershipChangeset, commitMembershipChangeset,
} from './thread-permission-updaters.js'; } from './thread-permission-updaters.js';
import createMessages from '../creators/message-creator.js'; import createMessages from '../creators/message-creator.js';
import { createUpdates } from '../creators/update-creator.js'; import { createUpdates } from '../creators/update-creator.js';
import { dbQuery, SQL } from '../database/database.js'; import { dbQuery, SQL } from '../database/database.js';
import { fetchEntryInfos } from '../fetchers/entry-fetchers.js'; import { fetchEntryInfos } from '../fetchers/entry-fetchers.js';
import { checkIfInviteLinkIsValid } from '../fetchers/link-fetchers.js';
import { import {
fetchMessageInfos, fetchMessageInfos,
fetchMessageInfoByID, fetchMessageInfoByID,
} from '../fetchers/message-fetchers.js'; } from '../fetchers/message-fetchers.js';
import { import {
fetchThreadInfos, fetchThreadInfos,
fetchServerThreadInfos, fetchServerThreadInfos,
determineThreadAncestry, determineThreadAncestry,
} from '../fetchers/thread-fetchers.js'; } from '../fetchers/thread-fetchers.js';
import { import {
checkThreadPermission, checkThreadPermission,
viewerIsMember as fetchViewerIsMember, viewerIsMember as fetchViewerIsMember,
checkThread, checkThread,
validateCandidateMembers, validateCandidateMembers,
} from '../fetchers/thread-permission-fetchers.js'; } from '../fetchers/thread-permission-fetchers.js';
import { import {
verifyUserIDs, verifyUserIDs,
verifyUserOrCookieIDs, verifyUserOrCookieIDs,
} from '../fetchers/user-fetchers.js'; } from '../fetchers/user-fetchers.js';
import { handleAsyncPromise } from '../responders/handlers.js';
import type { Viewer } from '../session/viewer.js'; import type { Viewer } from '../session/viewer.js';
import RelationshipChangeset from '../utils/relationship-changeset.js'; import RelationshipChangeset from '../utils/relationship-changeset.js';
async function updateRole( async function updateRole(
viewer: Viewer, viewer: Viewer,
request: RoleChangeRequest, request: RoleChangeRequest,
): Promise<ChangeThreadSettingsResult> { ): Promise<ChangeThreadSettingsResult> {
if (!viewer.loggedIn) { if (!viewer.loggedIn) {
▲ Show 20 Lines • Show All 729 Lines • ▼ Show 20 Lines
async function joinThread( async function joinThread(
viewer: Viewer, viewer: Viewer,
request: ServerThreadJoinRequest, request: ServerThreadJoinRequest,
): Promise<ThreadJoinResult> { ): Promise<ThreadJoinResult> {
if (!viewer.loggedIn) { if (!viewer.loggedIn) {
throw new ServerError('not_logged_in'); throw new ServerError('not_logged_in');
} }
const [isMember, hasPermission] = await Promise.all([ const permissionCheck = request.inviteLinkSecret
fetchViewerIsMember(viewer, request.threadID), ? checkIfInviteLinkIsValid(request.inviteLinkSecret, request.threadID)
checkThreadPermission( : checkThreadPermission(
viewer, viewer,
request.threadID, request.threadID,
threadPermissions.JOIN_THREAD, threadPermissions.JOIN_THREAD,
), );
const [isMember, hasPermission] = await Promise.all([
fetchViewerIsMember(viewer, request.threadID),
permissionCheck,
]); ]);
if (!hasPermission) { if (!hasPermission) {
throw new ServerError('invalid_parameters'); throw new ServerError('invalid_parameters');
} }
// TODO: determine code version // TODO: determine code version
const hasCodeVersionBelow87 = !hasMinCodeVersion(viewer.platformDetails, 87); const hasCodeVersionBelow87 = !hasMinCodeVersion(viewer.platformDetails, 87);
const hasCodeVersionBelow62 = !hasMinCodeVersion(viewer.platformDetails, 62); const hasCodeVersionBelow62 = !hasMinCodeVersion(viewer.platformDetails, 62);
Show All 29 Lines): Promise<ThreadJoinResult> {
} }
const changeset = await changeRole(request.threadID, [viewer.userID], null); const changeset = await changeRole(request.threadID, [viewer.userID], null);
const membershipResult = await commitMembershipChangeset(viewer, changeset, { const membershipResult = await commitMembershipChangeset(viewer, changeset, {
calendarQuery, calendarQuery,
}); });
if (request.inviteLinkSecret) {
handleAsyncPromise(reportLinkUsage(request.inviteLinkSecret));
}
const messageData = { const messageData = {
type: messageTypes.JOIN_THREAD, type: messageTypes.JOIN_THREAD,
threadID: request.threadID, threadID: request.threadID,
creatorID: viewer.userID, creatorID: viewer.userID,
time: Date.now(), time: Date.now(),
}; };
const newMessages = await createMessages(viewer, [messageData]); const newMessages = await createMessages(viewer, [messageData]);
▲ Show 20 Lines • Show All 150 Lines • Show Last 20 Lines
View Options

services/commtest/tests/identity_keyserver_tests.rs

Loading...
View Options

services/commtest/tests/identity_one_time_key_tests.rs

Loading...
View Options

services/commtest/tests/identity_prekey_tests.rs

Loading...
View Options

services/commtest/tests/identity_tunnelbroker_tests.rs

Loading...