Page MenuHomePhabricator
Differential D10802

[shared] [1/n] Move generic websocket messages in tunnelbroker_messages to own crate
ClosedPublic
Actions

Authored by will on Jan 24 2024, 12:48 PM.
Tags
None
Referenced Files
Unknown Object (File)
Fri, Apr 4, 5:53 AM
Unknown Object (File)
Fri, Mar 21, 3:02 PM
Unknown Object (File)
Fri, Mar 21, 2:30 AM
Unknown Object (File)
Fri, Mar 21, 12:47 AM
Unknown Object (File)
Thu, Mar 20, 7:25 AM
Unknown Object (File)
Wed, Mar 12, 11:02 PM
Unknown Object (File)
Fri, Mar 7, 10:34 PM
Unknown Object (File)
Mar 1 2025, 7:51 PM
View All 86 Files
Subscribers
ashoat
tomek

Details

Reviewers
varun
bartek
kamil
Commits
rCOMM739d8ebb85c8: [shared] [1/n] Move generic websocket messages in tunnelbroker_messages to own…
Summary

This moves ConnectionInitializationResponse, ConnectionInitializationStatus, and Heartbeat from tunnelbroker_messages into websocket_messages.

This enables usage in a planned identity_search_messages crate to avoid duplication.

Test Plan

cargo fmt and build each affected crate

Diff Detail

Repository
rCOMM Comm
Branch
wyilio/prefix-client
Lint
No Lint Coverage
Unit
No Test Coverage

Event Timeline

will created this revision.Jan 24 2024, 12:48 PM
will held this revision as a draft.
Herald added subscribers: tomek, ashoat. · View Herald TranscriptJan 24 2024, 12:48 PM
will added inline comments.Jan 24 2024, 12:53 PM
shared/tunnelbroker_messages/src/messages/mod.rs
17

What makes this move possibly confusing is the existence of the ConnectionInitializationMessage in tunnelbroker_messages that corresponds to ConnectionInitializationResponse and ConnectionInitializationStatus.

ConnectionInitializationResponse and ConnectionInitializationStatus will be used in conjunction with the planned identity_search_messages with AuthMessage instead of ConnectionInitializationMessage.

Harbormaster completed remote builds in B26126: Diff 36099.Jan 24 2024, 1:14 PM
will published this revision for review.Jan 24 2024, 1:18 PM
will added a child revision: D10804: [shared] [identity] [2/n] Add identity_search_messages to shared and use in identity.Jan 24 2024, 1:24 PM
will planned changes to this revision.Jan 26 2024, 7:43 AM
will requested review of this revision.Jan 26 2024, 2:48 PM
will retitled this revision from Move generic websocket messages in tunnelbroker_messages to own crate to [services] [1/n] Move generic websocket messages in tunnelbroker_messages to own crate.Jan 26 2024, 2:51 PM
ashoat added a comment.Jan 26 2024, 7:18 PM

Who wrote the Tunnelbroker stuff that you're moving? Would be good to have them on the review as well

will added a reviewer: kamil.Jan 26 2024, 10:37 PM
In D10802#312459, @ashoat wrote:

Who wrote the Tunnelbroker stuff that you're moving? Would be good to have them on the review as well

That would be Kamil. Just added

bartek accepted this revision.Jan 29 2024, 7:30 AM
bartek added 1 blocking reviewer(s): kamil.

Looks good to me, but I want to make sure @kamil is also aware of this change

will retitled this revision from [services] [1/n] Move generic websocket messages in tunnelbroker_messages to own crate to [identity] [1/n] Move generic websocket messages in tunnelbroker_messages to own crate.Jan 30 2024, 11:05 AM
will retitled this revision from [identity] [1/n] Move generic websocket messages in tunnelbroker_messages to own crate to [shared] [1/n] Move generic websocket messages in tunnelbroker_messages to own crate.
kamil accepted this revision.Jan 31 2024, 2:00 AM
This revision is now accepted and ready to land.Jan 31 2024, 2:00 AM
Closed by commit rCOMM739d8ebb85c8: [shared] [1/n] Move generic websocket messages in tunnelbroker_messages to own… (authored by will). · Explain WhyJan 31 2024, 11:10 AM
This revision was automatically updated to reflect the committed changes.
will added a commit: rCOMM739d8ebb85c8: [shared] [1/n] Move generic websocket messages in tunnelbroker_messages to own….
kamil mentioned this in D10915: [services] update `Cargo.lock` in commtest.Feb 1 2024, 11:53 AM
kamil mentioned this in rCOMMe864a2978dd6: [services] update `Cargo.lock` in commtest.Feb 1 2024, 12:14 PM

Revision Contents
Changeset List

PathSize
services/
identity/
tunnelbroker/
shared/
tunnelbroker_messages/
1 line
src/
messages/
7 lines
websocket_messages/
1 line
src/
3 lines
messages/
5 lines
websocket_messages/
tunnelbroker_messages/
2 lines
src/
messages/
56 lines
23 lines

Diff 36099

View Options

services/identity/Cargo.lock

// @flow // @flow
import * as React from 'react'; import * as React from 'react';
import { import {
leaveThreadActionTypes, leaveThreadActionTypes,
useLeaveThread, useLeaveThread,
} from 'lib/actions/thread-actions.js'; } from 'lib/actions/thread-actions.js';
import { useModalContext } from 'lib/components/modal-provider.react.js'; import { useModalContext } from 'lib/components/modal-provider.react.js';
import SWMansionIcon from 'lib/components/swmansion-icon.react.js'; import SWMansionIcon from 'lib/components/swmansion-icon.react.js';
import { usePromoteSidebar } from 'lib/hooks/promote-sidebar.react.js'; import { usePromoteSidebar } from 'lib/hooks/promote-sidebar.react.js';
import { childThreadInfos } from 'lib/selectors/thread-selectors.js'; import { childThreadInfos } from 'lib/selectors/thread-selectors.js';
import { import {
threadHasPermission,
threadIsChannel, threadIsChannel,
useThreadHasPermission,
viewerIsMember, viewerIsMember,
} from 'lib/shared/thread-utils.js'; } from 'lib/shared/thread-utils.js';
import type { ThreadInfo } from 'lib/types/minimally-encoded-thread-permissions-types.js'; import type { ThreadInfo } from 'lib/types/minimally-encoded-thread-permissions-types.js';
import { threadPermissions } from 'lib/types/thread-permission-types.js'; import { threadPermissions } from 'lib/types/thread-permission-types.js';
import { threadTypes } from 'lib/types/thread-types-enum.js'; import { threadTypes } from 'lib/types/thread-types-enum.js';
import { useDispatchActionPromise } from 'lib/utils/redux-promise-utils.js'; import { useDispatchActionPromise } from 'lib/utils/redux-promise-utils.js';
import css from './thread-menu.css'; import css from './thread-menu.css';
▲ Show 20 Lines • Show All 106 Lines • ▼ Show 20 Lines return (
key="sidebars" key="sidebars"
text="Threads" text="Threads"
icon="arrow-right" icon="arrow-right"
onClick={onClickSidebars} onClick={onClickSidebars}
/> />
); );
}, [hasSidebars, onClickSidebars]); }, [hasSidebars, onClickSidebars]);
const canCreateSubchannels = React.useMemo( const canCreateSubchannels = useThreadHasPermission(
() => threadHasPermission(threadInfo, threadPermissions.CREATE_SUBCHANNELS), threadInfo,
[threadInfo], threadPermissions.CREATE_SUBCHANNELS,
); );
const hasSubchannels = React.useMemo(() => { const hasSubchannels = React.useMemo(() => {
return !!childThreads?.some(threadIsChannel); return !!childThreads?.some(threadIsChannel);
}, [childThreads]); }, [childThreads]);
const onClickViewSubchannels = React.useCallback( const onClickViewSubchannels = React.useCallback(
() => () =>
▲ Show 20 Lines • Show All 60 Lines • ▼ Show 20 Lines () =>
threadInfo={threadInfo} threadInfo={threadInfo}
onClose={popModal} onClose={popModal}
onConfirm={onConfirmLeaveThread} onConfirm={onConfirmLeaveThread}
/>, />,
), ),
[popModal, onConfirmLeaveThread, pushModal, threadInfo], [popModal, onConfirmLeaveThread, pushModal, threadInfo],
); );
const leaveThreadItem = React.useMemo(() => { const canLeaveThread = useThreadHasPermission(
const canLeaveThread = threadHasPermission(
threadInfo, threadInfo,
threadPermissions.LEAVE_THREAD, threadPermissions.LEAVE_THREAD,
); );
const leaveThreadItem = React.useMemo(() => {
if (!viewerIsMember(threadInfo) || !canLeaveThread) { if (!viewerIsMember(threadInfo) || !canLeaveThread) {
return null; return null;
} }
return ( return (
<MenuItem <MenuItem
key="leave" key="leave"
text="Leave chat" text="Leave chat"
icon="logout" icon="logout"
dangerous dangerous
onClick={onClickLeaveThread} onClick={onClickLeaveThread}
/> />
); );
}, [onClickLeaveThread, threadInfo]); }, [onClickLeaveThread, threadInfo, canLeaveThread]);
const onClickPromoteSidebarToThread = React.useCallback( const onClickPromoteSidebarToThread = React.useCallback(
() => () =>
pushModal( pushModal(
<SidebarPromoteModal <SidebarPromoteModal
threadInfo={threadInfo} threadInfo={threadInfo}
onClose={popModal} onClose={popModal}
onConfirm={onPromoteSidebar} onConfirm={onPromoteSidebar}
▲ Show 20 Lines • Show All 72 Lines • Show Last 20 Lines
View Options

services/tunnelbroker/Cargo.lock

// @flow // @flow
import * as React from 'react'; import * as React from 'react';
import { import {
leaveThreadActionTypes, leaveThreadActionTypes,
useLeaveThread, useLeaveThread,
} from 'lib/actions/thread-actions.js'; } from 'lib/actions/thread-actions.js';
import { useModalContext } from 'lib/components/modal-provider.react.js'; import { useModalContext } from 'lib/components/modal-provider.react.js';
import SWMansionIcon from 'lib/components/swmansion-icon.react.js'; import SWMansionIcon from 'lib/components/swmansion-icon.react.js';
import { usePromoteSidebar } from 'lib/hooks/promote-sidebar.react.js'; import { usePromoteSidebar } from 'lib/hooks/promote-sidebar.react.js';
import { childThreadInfos } from 'lib/selectors/thread-selectors.js'; import { childThreadInfos } from 'lib/selectors/thread-selectors.js';
import { import {
threadHasPermission,
threadIsChannel, threadIsChannel,
useThreadHasPermission,
viewerIsMember, viewerIsMember,
} from 'lib/shared/thread-utils.js'; } from 'lib/shared/thread-utils.js';
import type { ThreadInfo } from 'lib/types/minimally-encoded-thread-permissions-types.js'; import type { ThreadInfo } from 'lib/types/minimally-encoded-thread-permissions-types.js';
import { threadPermissions } from 'lib/types/thread-permission-types.js'; import { threadPermissions } from 'lib/types/thread-permission-types.js';
import { threadTypes } from 'lib/types/thread-types-enum.js'; import { threadTypes } from 'lib/types/thread-types-enum.js';
import { useDispatchActionPromise } from 'lib/utils/redux-promise-utils.js'; import { useDispatchActionPromise } from 'lib/utils/redux-promise-utils.js';
import css from './thread-menu.css'; import css from './thread-menu.css';
▲ Show 20 Lines • Show All 106 Lines • ▼ Show 20 Lines return (
key="sidebars" key="sidebars"
text="Threads" text="Threads"
icon="arrow-right" icon="arrow-right"
onClick={onClickSidebars} onClick={onClickSidebars}
/> />
); );
}, [hasSidebars, onClickSidebars]); }, [hasSidebars, onClickSidebars]);
const canCreateSubchannels = React.useMemo( const canCreateSubchannels = useThreadHasPermission(
() => threadHasPermission(threadInfo, threadPermissions.CREATE_SUBCHANNELS), threadInfo,
[threadInfo], threadPermissions.CREATE_SUBCHANNELS,
); );
const hasSubchannels = React.useMemo(() => { const hasSubchannels = React.useMemo(() => {
return !!childThreads?.some(threadIsChannel); return !!childThreads?.some(threadIsChannel);
}, [childThreads]); }, [childThreads]);
const onClickViewSubchannels = React.useCallback( const onClickViewSubchannels = React.useCallback(
() => () =>
▲ Show 20 Lines • Show All 60 Lines • ▼ Show 20 Lines () =>
threadInfo={threadInfo} threadInfo={threadInfo}
onClose={popModal} onClose={popModal}
onConfirm={onConfirmLeaveThread} onConfirm={onConfirmLeaveThread}
/>, />,
), ),
[popModal, onConfirmLeaveThread, pushModal, threadInfo], [popModal, onConfirmLeaveThread, pushModal, threadInfo],
); );
const leaveThreadItem = React.useMemo(() => { const canLeaveThread = useThreadHasPermission(
const canLeaveThread = threadHasPermission(
threadInfo, threadInfo,
threadPermissions.LEAVE_THREAD, threadPermissions.LEAVE_THREAD,
); );
const leaveThreadItem = React.useMemo(() => {
if (!viewerIsMember(threadInfo) || !canLeaveThread) { if (!viewerIsMember(threadInfo) || !canLeaveThread) {
return null; return null;
} }
return ( return (
<MenuItem <MenuItem
key="leave" key="leave"
text="Leave chat" text="Leave chat"
icon="logout" icon="logout"
dangerous dangerous
onClick={onClickLeaveThread} onClick={onClickLeaveThread}
/> />
); );
}, [onClickLeaveThread, threadInfo]); }, [onClickLeaveThread, threadInfo, canLeaveThread]);
const onClickPromoteSidebarToThread = React.useCallback( const onClickPromoteSidebarToThread = React.useCallback(
() => () =>
pushModal( pushModal(
<SidebarPromoteModal <SidebarPromoteModal
threadInfo={threadInfo} threadInfo={threadInfo}
onClose={popModal} onClose={popModal}
onConfirm={onPromoteSidebar} onConfirm={onPromoteSidebar}
▲ Show 20 Lines • Show All 72 Lines • Show Last 20 Lines
View Options

shared/tunnelbroker_messages/Cargo.lock

// @flow // @flow
import * as React from 'react'; import * as React from 'react';
import { import {
leaveThreadActionTypes, leaveThreadActionTypes,
useLeaveThread, useLeaveThread,
} from 'lib/actions/thread-actions.js'; } from 'lib/actions/thread-actions.js';
import { useModalContext } from 'lib/components/modal-provider.react.js'; import { useModalContext } from 'lib/components/modal-provider.react.js';
import SWMansionIcon from 'lib/components/swmansion-icon.react.js'; import SWMansionIcon from 'lib/components/swmansion-icon.react.js';
import { usePromoteSidebar } from 'lib/hooks/promote-sidebar.react.js'; import { usePromoteSidebar } from 'lib/hooks/promote-sidebar.react.js';
import { childThreadInfos } from 'lib/selectors/thread-selectors.js'; import { childThreadInfos } from 'lib/selectors/thread-selectors.js';
import { import {
threadHasPermission,
threadIsChannel, threadIsChannel,
useThreadHasPermission,
viewerIsMember, viewerIsMember,
} from 'lib/shared/thread-utils.js'; } from 'lib/shared/thread-utils.js';
import type { ThreadInfo } from 'lib/types/minimally-encoded-thread-permissions-types.js'; import type { ThreadInfo } from 'lib/types/minimally-encoded-thread-permissions-types.js';
import { threadPermissions } from 'lib/types/thread-permission-types.js'; import { threadPermissions } from 'lib/types/thread-permission-types.js';
import { threadTypes } from 'lib/types/thread-types-enum.js'; import { threadTypes } from 'lib/types/thread-types-enum.js';
import { useDispatchActionPromise } from 'lib/utils/redux-promise-utils.js'; import { useDispatchActionPromise } from 'lib/utils/redux-promise-utils.js';
import css from './thread-menu.css'; import css from './thread-menu.css';
▲ Show 20 Lines • Show All 106 Lines • ▼ Show 20 Lines return (
key="sidebars" key="sidebars"
text="Threads" text="Threads"
icon="arrow-right" icon="arrow-right"
onClick={onClickSidebars} onClick={onClickSidebars}
/> />
); );
}, [hasSidebars, onClickSidebars]); }, [hasSidebars, onClickSidebars]);
const canCreateSubchannels = React.useMemo( const canCreateSubchannels = useThreadHasPermission(
() => threadHasPermission(threadInfo, threadPermissions.CREATE_SUBCHANNELS), threadInfo,
[threadInfo], threadPermissions.CREATE_SUBCHANNELS,
); );
const hasSubchannels = React.useMemo(() => { const hasSubchannels = React.useMemo(() => {
return !!childThreads?.some(threadIsChannel); return !!childThreads?.some(threadIsChannel);
}, [childThreads]); }, [childThreads]);
const onClickViewSubchannels = React.useCallback( const onClickViewSubchannels = React.useCallback(
() => () =>
▲ Show 20 Lines • Show All 60 Lines • ▼ Show 20 Lines () =>
threadInfo={threadInfo} threadInfo={threadInfo}
onClose={popModal} onClose={popModal}
onConfirm={onConfirmLeaveThread} onConfirm={onConfirmLeaveThread}
/>, />,
), ),
[popModal, onConfirmLeaveThread, pushModal, threadInfo], [popModal, onConfirmLeaveThread, pushModal, threadInfo],
); );
const leaveThreadItem = React.useMemo(() => { const canLeaveThread = useThreadHasPermission(
const canLeaveThread = threadHasPermission(
threadInfo, threadInfo,
threadPermissions.LEAVE_THREAD, threadPermissions.LEAVE_THREAD,
); );
const leaveThreadItem = React.useMemo(() => {
if (!viewerIsMember(threadInfo) || !canLeaveThread) { if (!viewerIsMember(threadInfo) || !canLeaveThread) {
return null; return null;
} }
return ( return (
<MenuItem <MenuItem
key="leave" key="leave"
text="Leave chat" text="Leave chat"
icon="logout" icon="logout"
dangerous dangerous
onClick={onClickLeaveThread} onClick={onClickLeaveThread}
/> />
); );
}, [onClickLeaveThread, threadInfo]); }, [onClickLeaveThread, threadInfo, canLeaveThread]);
const onClickPromoteSidebarToThread = React.useCallback( const onClickPromoteSidebarToThread = React.useCallback(
() => () =>
pushModal( pushModal(
<SidebarPromoteModal <SidebarPromoteModal
threadInfo={threadInfo} threadInfo={threadInfo}
onClose={popModal} onClose={popModal}
onConfirm={onPromoteSidebar} onConfirm={onPromoteSidebar}
▲ Show 20 Lines • Show All 72 Lines • Show Last 20 Lines
View Options

shared/tunnelbroker_messages/Cargo.toml

// @flow // @flow
import * as React from 'react'; import * as React from 'react';
import { import {
leaveThreadActionTypes, leaveThreadActionTypes,
useLeaveThread, useLeaveThread,
} from 'lib/actions/thread-actions.js'; } from 'lib/actions/thread-actions.js';
import { useModalContext } from 'lib/components/modal-provider.react.js'; import { useModalContext } from 'lib/components/modal-provider.react.js';
import SWMansionIcon from 'lib/components/swmansion-icon.react.js'; import SWMansionIcon from 'lib/components/swmansion-icon.react.js';
import { usePromoteSidebar } from 'lib/hooks/promote-sidebar.react.js'; import { usePromoteSidebar } from 'lib/hooks/promote-sidebar.react.js';
import { childThreadInfos } from 'lib/selectors/thread-selectors.js'; import { childThreadInfos } from 'lib/selectors/thread-selectors.js';
import { import {
threadHasPermission,
threadIsChannel, threadIsChannel,
useThreadHasPermission,
viewerIsMember, viewerIsMember,
} from 'lib/shared/thread-utils.js'; } from 'lib/shared/thread-utils.js';
import type { ThreadInfo } from 'lib/types/minimally-encoded-thread-permissions-types.js'; import type { ThreadInfo } from 'lib/types/minimally-encoded-thread-permissions-types.js';
import { threadPermissions } from 'lib/types/thread-permission-types.js'; import { threadPermissions } from 'lib/types/thread-permission-types.js';
import { threadTypes } from 'lib/types/thread-types-enum.js'; import { threadTypes } from 'lib/types/thread-types-enum.js';
import { useDispatchActionPromise } from 'lib/utils/redux-promise-utils.js'; import { useDispatchActionPromise } from 'lib/utils/redux-promise-utils.js';
import css from './thread-menu.css'; import css from './thread-menu.css';
▲ Show 20 Lines • Show All 106 Lines • ▼ Show 20 Lines return (
key="sidebars" key="sidebars"
text="Threads" text="Threads"
icon="arrow-right" icon="arrow-right"
onClick={onClickSidebars} onClick={onClickSidebars}
/> />
); );
}, [hasSidebars, onClickSidebars]); }, [hasSidebars, onClickSidebars]);
const canCreateSubchannels = React.useMemo( const canCreateSubchannels = useThreadHasPermission(
() => threadHasPermission(threadInfo, threadPermissions.CREATE_SUBCHANNELS), threadInfo,
[threadInfo], threadPermissions.CREATE_SUBCHANNELS,
); );
const hasSubchannels = React.useMemo(() => { const hasSubchannels = React.useMemo(() => {
return !!childThreads?.some(threadIsChannel); return !!childThreads?.some(threadIsChannel);
}, [childThreads]); }, [childThreads]);
const onClickViewSubchannels = React.useCallback( const onClickViewSubchannels = React.useCallback(
() => () =>
▲ Show 20 Lines • Show All 60 Lines • ▼ Show 20 Lines () =>
threadInfo={threadInfo} threadInfo={threadInfo}
onClose={popModal} onClose={popModal}
onConfirm={onConfirmLeaveThread} onConfirm={onConfirmLeaveThread}
/>, />,
), ),
[popModal, onConfirmLeaveThread, pushModal, threadInfo], [popModal, onConfirmLeaveThread, pushModal, threadInfo],
); );
const leaveThreadItem = React.useMemo(() => { const canLeaveThread = useThreadHasPermission(
const canLeaveThread = threadHasPermission(
threadInfo, threadInfo,
threadPermissions.LEAVE_THREAD, threadPermissions.LEAVE_THREAD,
); );
const leaveThreadItem = React.useMemo(() => {
if (!viewerIsMember(threadInfo) || !canLeaveThread) { if (!viewerIsMember(threadInfo) || !canLeaveThread) {
return null; return null;
} }
return ( return (
<MenuItem <MenuItem
key="leave" key="leave"
text="Leave chat" text="Leave chat"
icon="logout" icon="logout"
dangerous dangerous
onClick={onClickLeaveThread} onClick={onClickLeaveThread}
/> />
); );
}, [onClickLeaveThread, threadInfo]); }, [onClickLeaveThread, threadInfo, canLeaveThread]);
const onClickPromoteSidebarToThread = React.useCallback( const onClickPromoteSidebarToThread = React.useCallback(
() => () =>
pushModal( pushModal(
<SidebarPromoteModal <SidebarPromoteModal
threadInfo={threadInfo} threadInfo={threadInfo}
onClose={popModal} onClose={popModal}
onConfirm={onPromoteSidebar} onConfirm={onPromoteSidebar}
▲ Show 20 Lines • Show All 72 Lines • Show Last 20 Lines
View Options

shared/tunnelbroker_messages/src/messages/connection_initialization_response.rs

// @flow // @flow
import * as React from 'react'; import * as React from 'react';
import { import {
leaveThreadActionTypes, leaveThreadActionTypes,
useLeaveThread, useLeaveThread,
} from 'lib/actions/thread-actions.js'; } from 'lib/actions/thread-actions.js';
import { useModalContext } from 'lib/components/modal-provider.react.js'; import { useModalContext } from 'lib/components/modal-provider.react.js';
import SWMansionIcon from 'lib/components/swmansion-icon.react.js'; import SWMansionIcon from 'lib/components/swmansion-icon.react.js';
import { usePromoteSidebar } from 'lib/hooks/promote-sidebar.react.js'; import { usePromoteSidebar } from 'lib/hooks/promote-sidebar.react.js';
import { childThreadInfos } from 'lib/selectors/thread-selectors.js'; import { childThreadInfos } from 'lib/selectors/thread-selectors.js';
import { import {
threadHasPermission,
threadIsChannel, threadIsChannel,
useThreadHasPermission,
viewerIsMember, viewerIsMember,
} from 'lib/shared/thread-utils.js'; } from 'lib/shared/thread-utils.js';
import type { ThreadInfo } from 'lib/types/minimally-encoded-thread-permissions-types.js'; import type { ThreadInfo } from 'lib/types/minimally-encoded-thread-permissions-types.js';
import { threadPermissions } from 'lib/types/thread-permission-types.js'; import { threadPermissions } from 'lib/types/thread-permission-types.js';
import { threadTypes } from 'lib/types/thread-types-enum.js'; import { threadTypes } from 'lib/types/thread-types-enum.js';
import { useDispatchActionPromise } from 'lib/utils/redux-promise-utils.js'; import { useDispatchActionPromise } from 'lib/utils/redux-promise-utils.js';
import css from './thread-menu.css'; import css from './thread-menu.css';
▲ Show 20 Lines • Show All 106 Lines • ▼ Show 20 Lines return (
key="sidebars" key="sidebars"
text="Threads" text="Threads"
icon="arrow-right" icon="arrow-right"
onClick={onClickSidebars} onClick={onClickSidebars}
/> />
); );
}, [hasSidebars, onClickSidebars]); }, [hasSidebars, onClickSidebars]);
const canCreateSubchannels = React.useMemo( const canCreateSubchannels = useThreadHasPermission(
() => threadHasPermission(threadInfo, threadPermissions.CREATE_SUBCHANNELS), threadInfo,
[threadInfo], threadPermissions.CREATE_SUBCHANNELS,
); );
const hasSubchannels = React.useMemo(() => { const hasSubchannels = React.useMemo(() => {
return !!childThreads?.some(threadIsChannel); return !!childThreads?.some(threadIsChannel);
}, [childThreads]); }, [childThreads]);
const onClickViewSubchannels = React.useCallback( const onClickViewSubchannels = React.useCallback(
() => () =>
▲ Show 20 Lines • Show All 60 Lines • ▼ Show 20 Lines () =>
threadInfo={threadInfo} threadInfo={threadInfo}
onClose={popModal} onClose={popModal}
onConfirm={onConfirmLeaveThread} onConfirm={onConfirmLeaveThread}
/>, />,
), ),
[popModal, onConfirmLeaveThread, pushModal, threadInfo], [popModal, onConfirmLeaveThread, pushModal, threadInfo],
); );
const leaveThreadItem = React.useMemo(() => { const canLeaveThread = useThreadHasPermission(
const canLeaveThread = threadHasPermission(
threadInfo, threadInfo,
threadPermissions.LEAVE_THREAD, threadPermissions.LEAVE_THREAD,
); );
const leaveThreadItem = React.useMemo(() => {
if (!viewerIsMember(threadInfo) || !canLeaveThread) { if (!viewerIsMember(threadInfo) || !canLeaveThread) {
return null; return null;
} }
return ( return (
<MenuItem <MenuItem
key="leave" key="leave"
text="Leave chat" text="Leave chat"
icon="logout" icon="logout"
dangerous dangerous
onClick={onClickLeaveThread} onClick={onClickLeaveThread}
/> />
); );
}, [onClickLeaveThread, threadInfo]); }, [onClickLeaveThread, threadInfo, canLeaveThread]);
const onClickPromoteSidebarToThread = React.useCallback( const onClickPromoteSidebarToThread = React.useCallback(
() => () =>
pushModal( pushModal(
<SidebarPromoteModal <SidebarPromoteModal
threadInfo={threadInfo} threadInfo={threadInfo}
onClose={popModal} onClose={popModal}
onConfirm={onPromoteSidebar} onConfirm={onPromoteSidebar}
▲ Show 20 Lines • Show All 72 Lines • Show Last 20 Lines
View Options

shared/tunnelbroker_messages/src/messages/heartbeat.rs

// @flow // @flow
import * as React from 'react'; import * as React from 'react';
import { import {
leaveThreadActionTypes, leaveThreadActionTypes,
useLeaveThread, useLeaveThread,
} from 'lib/actions/thread-actions.js'; } from 'lib/actions/thread-actions.js';
import { useModalContext } from 'lib/components/modal-provider.react.js'; import { useModalContext } from 'lib/components/modal-provider.react.js';
import SWMansionIcon from 'lib/components/swmansion-icon.react.js'; import SWMansionIcon from 'lib/components/swmansion-icon.react.js';
import { usePromoteSidebar } from 'lib/hooks/promote-sidebar.react.js'; import { usePromoteSidebar } from 'lib/hooks/promote-sidebar.react.js';
import { childThreadInfos } from 'lib/selectors/thread-selectors.js'; import { childThreadInfos } from 'lib/selectors/thread-selectors.js';
import { import {
threadHasPermission,
threadIsChannel, threadIsChannel,
useThreadHasPermission,
viewerIsMember, viewerIsMember,
} from 'lib/shared/thread-utils.js'; } from 'lib/shared/thread-utils.js';
import type { ThreadInfo } from 'lib/types/minimally-encoded-thread-permissions-types.js'; import type { ThreadInfo } from 'lib/types/minimally-encoded-thread-permissions-types.js';
import { threadPermissions } from 'lib/types/thread-permission-types.js'; import { threadPermissions } from 'lib/types/thread-permission-types.js';
import { threadTypes } from 'lib/types/thread-types-enum.js'; import { threadTypes } from 'lib/types/thread-types-enum.js';
import { useDispatchActionPromise } from 'lib/utils/redux-promise-utils.js'; import { useDispatchActionPromise } from 'lib/utils/redux-promise-utils.js';
import css from './thread-menu.css'; import css from './thread-menu.css';
▲ Show 20 Lines • Show All 106 Lines • ▼ Show 20 Lines return (
key="sidebars" key="sidebars"
text="Threads" text="Threads"
icon="arrow-right" icon="arrow-right"
onClick={onClickSidebars} onClick={onClickSidebars}
/> />
); );
}, [hasSidebars, onClickSidebars]); }, [hasSidebars, onClickSidebars]);
const canCreateSubchannels = React.useMemo( const canCreateSubchannels = useThreadHasPermission(
() => threadHasPermission(threadInfo, threadPermissions.CREATE_SUBCHANNELS), threadInfo,
[threadInfo], threadPermissions.CREATE_SUBCHANNELS,
); );
const hasSubchannels = React.useMemo(() => { const hasSubchannels = React.useMemo(() => {
return !!childThreads?.some(threadIsChannel); return !!childThreads?.some(threadIsChannel);
}, [childThreads]); }, [childThreads]);
const onClickViewSubchannels = React.useCallback( const onClickViewSubchannels = React.useCallback(
() => () =>
▲ Show 20 Lines • Show All 60 Lines • ▼ Show 20 Lines () =>
threadInfo={threadInfo} threadInfo={threadInfo}
onClose={popModal} onClose={popModal}
onConfirm={onConfirmLeaveThread} onConfirm={onConfirmLeaveThread}
/>, />,
), ),
[popModal, onConfirmLeaveThread, pushModal, threadInfo], [popModal, onConfirmLeaveThread, pushModal, threadInfo],
); );
const leaveThreadItem = React.useMemo(() => { const canLeaveThread = useThreadHasPermission(
const canLeaveThread = threadHasPermission(
threadInfo, threadInfo,
threadPermissions.LEAVE_THREAD, threadPermissions.LEAVE_THREAD,
); );
const leaveThreadItem = React.useMemo(() => {
if (!viewerIsMember(threadInfo) || !canLeaveThread) { if (!viewerIsMember(threadInfo) || !canLeaveThread) {
return null; return null;
} }
return ( return (
<MenuItem <MenuItem
key="leave" key="leave"
text="Leave chat" text="Leave chat"
icon="logout" icon="logout"
dangerous dangerous
onClick={onClickLeaveThread} onClick={onClickLeaveThread}
/> />
); );
}, [onClickLeaveThread, threadInfo]); }, [onClickLeaveThread, threadInfo, canLeaveThread]);
const onClickPromoteSidebarToThread = React.useCallback( const onClickPromoteSidebarToThread = React.useCallback(
() => () =>
pushModal( pushModal(
<SidebarPromoteModal <SidebarPromoteModal
threadInfo={threadInfo} threadInfo={threadInfo}
onClose={popModal} onClose={popModal}
onConfirm={onPromoteSidebar} onConfirm={onPromoteSidebar}
▲ Show 20 Lines • Show All 72 Lines • Show Last 20 Lines
View Options

shared/tunnelbroker_messages/src/messages/mod.rs

// @flow // @flow
import * as React from 'react'; import * as React from 'react';
import { import {
leaveThreadActionTypes, leaveThreadActionTypes,
useLeaveThread, useLeaveThread,
} from 'lib/actions/thread-actions.js'; } from 'lib/actions/thread-actions.js';
import { useModalContext } from 'lib/components/modal-provider.react.js'; import { useModalContext } from 'lib/components/modal-provider.react.js';
import SWMansionIcon from 'lib/components/swmansion-icon.react.js'; import SWMansionIcon from 'lib/components/swmansion-icon.react.js';
import { usePromoteSidebar } from 'lib/hooks/promote-sidebar.react.js'; import { usePromoteSidebar } from 'lib/hooks/promote-sidebar.react.js';
import { childThreadInfos } from 'lib/selectors/thread-selectors.js'; import { childThreadInfos } from 'lib/selectors/thread-selectors.js';
import { import {
threadHasPermission,
threadIsChannel, threadIsChannel,
useThreadHasPermission,
viewerIsMember, viewerIsMember,
} from 'lib/shared/thread-utils.js'; } from 'lib/shared/thread-utils.js';
import type { ThreadInfo } from 'lib/types/minimally-encoded-thread-permissions-types.js'; import type { ThreadInfo } from 'lib/types/minimally-encoded-thread-permissions-types.js';
import { threadPermissions } from 'lib/types/thread-permission-types.js'; import { threadPermissions } from 'lib/types/thread-permission-types.js';
import { threadTypes } from 'lib/types/thread-types-enum.js'; import { threadTypes } from 'lib/types/thread-types-enum.js';
import { useDispatchActionPromise } from 'lib/utils/redux-promise-utils.js'; import { useDispatchActionPromise } from 'lib/utils/redux-promise-utils.js';
import css from './thread-menu.css'; import css from './thread-menu.css';
▲ Show 20 Lines • Show All 106 Lines • ▼ Show 20 Lines return (
key="sidebars" key="sidebars"
text="Threads" text="Threads"
icon="arrow-right" icon="arrow-right"
onClick={onClickSidebars} onClick={onClickSidebars}
/> />
); );
}, [hasSidebars, onClickSidebars]); }, [hasSidebars, onClickSidebars]);
const canCreateSubchannels = React.useMemo( const canCreateSubchannels = useThreadHasPermission(
() => threadHasPermission(threadInfo, threadPermissions.CREATE_SUBCHANNELS), threadInfo,
[threadInfo], threadPermissions.CREATE_SUBCHANNELS,
); );
const hasSubchannels = React.useMemo(() => { const hasSubchannels = React.useMemo(() => {
return !!childThreads?.some(threadIsChannel); return !!childThreads?.some(threadIsChannel);
}, [childThreads]); }, [childThreads]);
const onClickViewSubchannels = React.useCallback( const onClickViewSubchannels = React.useCallback(
() => () =>
▲ Show 20 Lines • Show All 60 Lines • ▼ Show 20 Lines () =>
threadInfo={threadInfo} threadInfo={threadInfo}
onClose={popModal} onClose={popModal}
onConfirm={onConfirmLeaveThread} onConfirm={onConfirmLeaveThread}
/>, />,
), ),
[popModal, onConfirmLeaveThread, pushModal, threadInfo], [popModal, onConfirmLeaveThread, pushModal, threadInfo],
); );
const leaveThreadItem = React.useMemo(() => { const canLeaveThread = useThreadHasPermission(
const canLeaveThread = threadHasPermission(
threadInfo, threadInfo,
threadPermissions.LEAVE_THREAD, threadPermissions.LEAVE_THREAD,
); );
const leaveThreadItem = React.useMemo(() => {
if (!viewerIsMember(threadInfo) || !canLeaveThread) { if (!viewerIsMember(threadInfo) || !canLeaveThread) {
return null; return null;
} }
return ( return (
<MenuItem <MenuItem
key="leave" key="leave"
text="Leave chat" text="Leave chat"
icon="logout" icon="logout"
dangerous dangerous
onClick={onClickLeaveThread} onClick={onClickLeaveThread}
/> />
); );
}, [onClickLeaveThread, threadInfo]); }, [onClickLeaveThread, threadInfo, canLeaveThread]);
const onClickPromoteSidebarToThread = React.useCallback( const onClickPromoteSidebarToThread = React.useCallback(
() => () =>
pushModal( pushModal(
<SidebarPromoteModal <SidebarPromoteModal
threadInfo={threadInfo} threadInfo={threadInfo}
onClose={popModal} onClose={popModal}
onConfirm={onPromoteSidebar} onConfirm={onPromoteSidebar}
▲ Show 20 Lines • Show All 72 Lines • Show Last 20 Lines
View Options

shared/websocket_messages/.gitignore

Loading...
View Options

shared/websocket_messages/Cargo.lock

Loading...
View Options

shared/websocket_messages/Cargo.toml

Loading...
View Options

shared/websocket_messages/src/lib.rs

Loading...
View Options

shared/websocket_messages/src/messages/connection_initialization_response.rs

Loading...
View Options

shared/websocket_messages/src/messages/heartbeat.rs

Loading...
View Options

shared/websocket_messages/src/messages/mod.rs

Loading...