Use context provided RoomViewStore within the RoomView component hierarchy (#31077)
* Update ContentMessages.ts Update ContentMessages.ts * update PlaybackQueue.ts * Update SpaceHierarchy.tsx * Update ThreadView.tsx * Update RoomCallBanner.tsx * Update useRoomCall.tsx * Update DateSeparator.tsx * Update TimelineCard.tsx * Update UserInfoBasicOptions * Update slask-commands/utils.ts * lint * Update PlaybackQueue, MVoiceMessageBody and UserInfoBasicOptionsView tests. * Update RoomHeader-test.tsx * lint * Add ts docs * Update utils-test.tsx * Update message-test.ts * coverage * lint * Improve naming --------- Co-authored-by: Michael Telatynski <7t3chguy@gmail.com>
This commit is contained in:
@@ -55,7 +55,6 @@ import UploadConfirmDialog from "./components/views/dialogs/UploadConfirmDialog"
|
||||
import { createThumbnail } from "./utils/image-media";
|
||||
import { attachMentions, attachRelation } from "./utils/messages.ts";
|
||||
import { doMaybeLocalRoomAction } from "./utils/local-room";
|
||||
import { SdkContextClass } from "./contexts/SDKContext";
|
||||
import { blobIsAnimated } from "./utils/Image.ts";
|
||||
|
||||
// scraped out of a macOS hidpi (5660ppm) screenshot png
|
||||
@@ -428,10 +427,21 @@ export default class ContentMessages {
|
||||
return this.mediaConfig?.["m.upload.size"] ?? null;
|
||||
}
|
||||
|
||||
/**
|
||||
* Sends a list of files to a room.
|
||||
* @param files - The files to send.
|
||||
* @param roomId - The ID of the room to send the files to.
|
||||
* @param relation - The relation to the event being replied to.
|
||||
* @param replyToEvent - The event being replied to, if any.
|
||||
* @param matrixClient - The Matrix client to use for sending the files.
|
||||
* @param context - The context in which the files are being sent.
|
||||
* @returns A promise that resolves when the files have been sent.
|
||||
*/
|
||||
public async sendContentListToRoom(
|
||||
files: File[],
|
||||
roomId: string,
|
||||
relation: IEventRelation | undefined,
|
||||
replyToEvent: MatrixEvent | undefined,
|
||||
matrixClient: MatrixClient,
|
||||
context = TimelineRenderingType.Room,
|
||||
): Promise<void> {
|
||||
@@ -440,7 +450,6 @@ export default class ContentMessages {
|
||||
return;
|
||||
}
|
||||
|
||||
const replyToEvent = SdkContextClass.instance.roomViewStore.getQuotingEvent();
|
||||
if (!this.mediaConfig) {
|
||||
// hot-path optimization to not flash a spinner if we don't need to
|
||||
const modal = Modal.createDialog(Spinner, undefined, "mx_Dialog_spinner");
|
||||
|
||||
@@ -732,8 +732,8 @@ export const Commands = [
|
||||
new Command({
|
||||
command: "help",
|
||||
description: _td("slash_command|help"),
|
||||
runFn: function () {
|
||||
Modal.createDialog(SlashCommandHelpDialog);
|
||||
runFn: function (cli, roomId, threadId, args) {
|
||||
Modal.createDialog(SlashCommandHelpDialog, { roomId });
|
||||
return success();
|
||||
},
|
||||
category: CommandCategories.advanced,
|
||||
@@ -967,14 +967,15 @@ interface ICmd {
|
||||
|
||||
/**
|
||||
* Process the given text for /commands and returns a parsed command that can be used for running the operation.
|
||||
* @param {string} roomId The room ID where the command was issued.
|
||||
* @param {string} input The raw text input by the user.
|
||||
* @return {ICmd} The parsed command object.
|
||||
* Returns an empty object if the input didn't match a command.
|
||||
*/
|
||||
export function getCommand(input: string): ICmd {
|
||||
export function getCommand(roomId: string, input: string): ICmd {
|
||||
const { cmd, args } = parseCommandString(input);
|
||||
|
||||
if (cmd && CommandMap.has(cmd) && CommandMap.get(cmd)!.isEnabled(MatrixClientPeg.get())) {
|
||||
if (cmd && CommandMap.has(cmd) && CommandMap.get(cmd)!.isEnabled(MatrixClientPeg.get(), roomId)) {
|
||||
return {
|
||||
cmd: CommandMap.get(cmd),
|
||||
args,
|
||||
|
||||
@@ -15,7 +15,7 @@ import { MatrixClientPeg } from "../MatrixClientPeg";
|
||||
import { arrayFastClone } from "../utils/arrays";
|
||||
import { PlaybackManager } from "./PlaybackManager";
|
||||
import { isVoiceMessage } from "../utils/EventUtils";
|
||||
import { SdkContextClass } from "../contexts/SDKContext";
|
||||
import { type RoomViewStore } from "../stores/RoomViewStore";
|
||||
|
||||
/**
|
||||
* Audio playback queue management for a given room. This keeps track of where the user
|
||||
@@ -38,10 +38,18 @@ export class PlaybackQueue {
|
||||
private currentPlaybackId: string | null = null; // event ID, broken out from above for ease of use
|
||||
private recentFullPlays = new Set<string>(); // event IDs
|
||||
|
||||
public constructor(private room: Room) {
|
||||
/**
|
||||
* Create a PlaybackQueue for a given room.
|
||||
* @param room The room
|
||||
* @param roomViewStore The RoomViewStore instance
|
||||
*/
|
||||
public constructor(
|
||||
private room: Room,
|
||||
private roomViewStore: RoomViewStore,
|
||||
) {
|
||||
this.loadClocks();
|
||||
|
||||
SdkContextClass.instance.roomViewStore.addRoomListener(this.room.roomId, (isActive) => {
|
||||
this.roomViewStore.addRoomListener(this.room.roomId, (isActive) => {
|
||||
if (!isActive) return;
|
||||
|
||||
// Reset the state of the playbacks before they start mounting and enqueuing updates.
|
||||
@@ -53,14 +61,20 @@ export class PlaybackQueue {
|
||||
});
|
||||
}
|
||||
|
||||
public static forRoom(roomId: string): PlaybackQueue {
|
||||
/**
|
||||
* Get the PlaybackQueue for a given room, creating it if necessary.
|
||||
* @param roomId The ID of the room
|
||||
* @param roomViewStore The RoomViewStore instance
|
||||
* @returns The PlaybackQueue for the room
|
||||
*/
|
||||
public static forRoom(roomId: string, roomViewStore: RoomViewStore): PlaybackQueue {
|
||||
const cli = MatrixClientPeg.safeGet();
|
||||
const room = cli.getRoom(roomId);
|
||||
if (!room) throw new Error("Unknown room");
|
||||
if (PlaybackQueue.queues.has(room.roomId)) {
|
||||
return PlaybackQueue.queues.get(room.roomId)!;
|
||||
}
|
||||
const queue = new PlaybackQueue(room);
|
||||
const queue = new PlaybackQueue(room, roomViewStore);
|
||||
PlaybackQueue.queues.set(room.roomId, queue);
|
||||
return queue;
|
||||
}
|
||||
|
||||
@@ -25,7 +25,7 @@ const COMMAND_RE = /(^\/\w*)(?: .*)?/g;
|
||||
|
||||
export default class CommandProvider extends AutocompleteProvider {
|
||||
public matcher: QueryMatcher<Command>;
|
||||
|
||||
private room: Room;
|
||||
public constructor(room: Room, renderingType?: TimelineRenderingType) {
|
||||
super({ commandRegex: COMMAND_RE, renderingType });
|
||||
this.matcher = new QueryMatcher(Commands, {
|
||||
@@ -33,6 +33,7 @@ export default class CommandProvider extends AutocompleteProvider {
|
||||
funcs: [({ aliases }) => aliases.join(" ")], // aliases
|
||||
context: renderingType,
|
||||
});
|
||||
this.room = room;
|
||||
}
|
||||
|
||||
public async getCompletions(
|
||||
@@ -51,7 +52,7 @@ export default class CommandProvider extends AutocompleteProvider {
|
||||
if (command[0] !== command[1]) {
|
||||
// The input looks like a command with arguments, perform exact match
|
||||
const name = command[1].slice(1); // strip leading `/`
|
||||
if (CommandMap.has(name) && CommandMap.get(name)!.isEnabled(cli)) {
|
||||
if (CommandMap.has(name) && CommandMap.get(name)!.isEnabled(cli, this.room.roomId)) {
|
||||
// some commands, namely `me` don't suit having the usage shown whilst typing their arguments
|
||||
if (CommandMap.get(name)!.hideCompletionAfterSpace) return [];
|
||||
matches = [CommandMap.get(name)!];
|
||||
@@ -70,7 +71,7 @@ export default class CommandProvider extends AutocompleteProvider {
|
||||
return matches
|
||||
.filter((cmd) => {
|
||||
const display = !cmd.renderingTypes || cmd.renderingTypes.includes(this.renderingType);
|
||||
return cmd.isEnabled(cli) && display;
|
||||
return cmd.isEnabled(cli, this.room.roomId) && display;
|
||||
})
|
||||
.map((result) => {
|
||||
let completion = result.getCommand() + " ";
|
||||
|
||||
@@ -1128,6 +1128,7 @@ export class RoomView extends React.Component<IRoomProps, IRoomState> {
|
||||
[payload.file],
|
||||
roomId,
|
||||
undefined,
|
||||
this.state.replyToEvent,
|
||||
this.context.client,
|
||||
);
|
||||
}
|
||||
@@ -2047,6 +2048,7 @@ export class RoomView extends React.Component<IRoomProps, IRoomState> {
|
||||
Array.from(dataTransfer.files),
|
||||
roomId,
|
||||
undefined,
|
||||
this.state.replyToEvent,
|
||||
this.context.client,
|
||||
TimelineRenderingType.Room,
|
||||
);
|
||||
|
||||
@@ -67,10 +67,11 @@ import { type JoinRoomReadyPayload } from "../../dispatcher/payloads/JoinRoomRea
|
||||
import { KeyBindingAction } from "../../accessibility/KeyboardShortcuts";
|
||||
import { getKeyBindingsManager } from "../../KeyBindingsManager";
|
||||
import { getTopic } from "../../hooks/room/useTopic";
|
||||
import { SdkContextClass } from "../../contexts/SDKContext";
|
||||
import { getDisplayAliasForAliasSet } from "../../Rooms";
|
||||
import SettingsStore from "../../settings/SettingsStore";
|
||||
import { filterBoolean } from "../../utils/arrays.ts";
|
||||
import { type RoomViewStore } from "../../stores/RoomViewStore.tsx";
|
||||
import RoomContext from "../../contexts/RoomContext.ts";
|
||||
|
||||
interface IProps {
|
||||
space: Room;
|
||||
@@ -404,7 +405,20 @@ export const showRoom = (cli: MatrixClient, hierarchy: RoomHierarchy, roomId: st
|
||||
});
|
||||
};
|
||||
|
||||
export const joinRoom = async (cli: MatrixClient, hierarchy: RoomHierarchy, roomId: string): Promise<unknown> => {
|
||||
/**
|
||||
* Join a room.
|
||||
* @param cli The Matrix client
|
||||
* @param roomViewStore The RoomViewStore instance
|
||||
* @param hierarchy The RoomHierarchy instance
|
||||
* @param roomId The ID of the room to join
|
||||
* @returns A promise that resolves when the room has been joined
|
||||
*/
|
||||
export const joinRoom = async (
|
||||
cli: MatrixClient,
|
||||
roomViewStore: RoomViewStore,
|
||||
hierarchy: RoomHierarchy,
|
||||
roomId: string,
|
||||
): Promise<unknown> => {
|
||||
// Don't let the user view a room they won't be able to either peek or join:
|
||||
// fail earlier so they don't have to click back to the directory.
|
||||
if (cli.isGuest()) {
|
||||
@@ -418,10 +432,10 @@ export const joinRoom = async (cli: MatrixClient, hierarchy: RoomHierarchy, room
|
||||
});
|
||||
} catch (err: unknown) {
|
||||
if (err instanceof MatrixError) {
|
||||
SdkContextClass.instance.roomViewStore.showJoinRoomError(err, roomId);
|
||||
roomViewStore.showJoinRoomError(err, roomId);
|
||||
} else {
|
||||
logger.warn("Got a non-MatrixError while joining room", err);
|
||||
SdkContextClass.instance.roomViewStore.showJoinRoomError(
|
||||
roomViewStore.showJoinRoomError(
|
||||
new MatrixError({
|
||||
error: _t("error|unknown"),
|
||||
}),
|
||||
@@ -761,6 +775,7 @@ const ManageButtons: React.FC<IManageButtonsProps> = ({ hierarchy, selected, set
|
||||
|
||||
const SpaceHierarchy: React.FC<IProps> = ({ space, initialText = "", showRoom, additionalButtons }) => {
|
||||
const cli = useContext(MatrixClientContext);
|
||||
const roomContext = useContext(RoomContext);
|
||||
const [query, setQuery] = useState(initialText);
|
||||
|
||||
const [selected, setSelected] = useState(new Map<string, Set<string>>()); // Map<parentId, Set<childId>>
|
||||
@@ -855,10 +870,10 @@ const SpaceHierarchy: React.FC<IProps> = ({ space, initialText = "", showRoom, a
|
||||
onJoinRoomClick={async (roomId, parents) => {
|
||||
for (const parent of parents) {
|
||||
if (cli.getRoom(parent)?.getMyMembership() !== KnownMembership.Join) {
|
||||
await joinRoom(cli, hierarchy, parent);
|
||||
await joinRoom(cli, roomContext.roomViewStore, hierarchy, parent);
|
||||
}
|
||||
}
|
||||
await joinRoom(cli, hierarchy, roomId);
|
||||
await joinRoom(cli, roomContext.roomViewStore, hierarchy, roomId);
|
||||
}}
|
||||
/>
|
||||
</>
|
||||
|
||||
@@ -49,7 +49,6 @@ import { type ButtonEvent } from "../views/elements/AccessibleButton";
|
||||
import Spinner from "../views/elements/Spinner";
|
||||
import { type ComposerInsertPayload, ComposerType } from "../../dispatcher/payloads/ComposerInsertPayload";
|
||||
import Heading from "../views/typography/Heading";
|
||||
import { SdkContextClass } from "../../contexts/SDKContext";
|
||||
import { type ThreadPayload } from "../../dispatcher/payloads/ThreadPayload";
|
||||
import { ScopedRoomContextProvider } from "../../contexts/ScopedRoomContext.tsx";
|
||||
|
||||
@@ -124,7 +123,7 @@ export default class ThreadView extends React.Component<IProps, IState> {
|
||||
const roomId = this.props.mxEvent.getRoomId();
|
||||
SettingsStore.unwatchSetting(this.layoutWatcherRef);
|
||||
|
||||
const hasRoomChanged = SdkContextClass.instance.roomViewStore.getRoomId() !== roomId;
|
||||
const hasRoomChanged = this.context.roomViewStore.getRoomId() !== roomId;
|
||||
if (this.props.initialEvent && !hasRoomChanged) {
|
||||
dis.dispatch<ViewRoomPayload>({
|
||||
action: Action.ViewRoom,
|
||||
@@ -334,6 +333,7 @@ export default class ThreadView extends React.Component<IProps, IState> {
|
||||
Array.from(dataTransfer.files),
|
||||
roomId,
|
||||
this.threadRelation,
|
||||
this.context.replyToEvent,
|
||||
MatrixClientPeg.safeGet(),
|
||||
TimelineRenderingType.Thread,
|
||||
);
|
||||
|
||||
@@ -17,7 +17,6 @@ import PosthogTrackers from "../../../../PosthogTrackers";
|
||||
import { ShareDialog } from "../../../views/dialogs/ShareDialog";
|
||||
import { type ComposerInsertPayload } from "../../../../dispatcher/payloads/ComposerInsertPayload";
|
||||
import { Action } from "../../../../dispatcher/actions";
|
||||
import { SdkContextClass } from "../../../../contexts/SDKContext";
|
||||
import { TimelineRenderingType } from "../../../../contexts/RoomContext";
|
||||
import MultiInviter from "../../../../utils/MultiInviter";
|
||||
import { type ViewRoomPayload } from "../../../../dispatcher/payloads/ViewRoomPayload";
|
||||
@@ -41,7 +40,7 @@ export interface UserInfoBasicOptionsState {
|
||||
// Method called when a share user button is clicked, will display modal with profile to share
|
||||
onShareUserClick: () => void;
|
||||
// Method called when a invite button is clicked, will display modal to invite user
|
||||
onInviteUserButton: (evt: Event) => Promise<void>;
|
||||
onInviteUserButton: (fallbackRoomId: string, evt: Event) => Promise<void>;
|
||||
// Method called when the DM button is clicked, will open a DM with the selected member
|
||||
onOpenDmForUser: (member: Member) => Promise<void>;
|
||||
}
|
||||
@@ -91,12 +90,9 @@ export const useUserInfoBasicOptionsViewModel = (room: Room, member: User | Room
|
||||
});
|
||||
};
|
||||
|
||||
const onInviteUserButton = async (ev: Event): Promise<void> => {
|
||||
const onInviteUserButton = async (fallbackRoomId: string, ev: Event): Promise<void> => {
|
||||
try {
|
||||
const roomId =
|
||||
member instanceof RoomMember && member.roomId
|
||||
? member.roomId
|
||||
: SdkContextClass.instance.roomViewStore.getRoomId();
|
||||
const roomId = member instanceof RoomMember && member.roomId ? member.roomId : fallbackRoomId;
|
||||
|
||||
// We use a MultiInviter to re-use the invite logic, even though we're only inviting one user.
|
||||
const inviter = new MultiInviter(cli, roomId || "");
|
||||
|
||||
@@ -20,7 +20,7 @@ import { useCall } from "../../../hooks/useCall";
|
||||
import { useEventEmitterState } from "../../../hooks/useEventEmitter";
|
||||
import { OwnBeaconStore, OwnBeaconStoreEvent } from "../../../stores/OwnBeaconStore";
|
||||
import { SessionDuration } from "../voip/CallDuration";
|
||||
import { SdkContextClass } from "../../../contexts/SDKContext";
|
||||
import { useScopedRoomContext } from "../../../contexts/ScopedRoomContext";
|
||||
|
||||
interface RoomCallBannerProps {
|
||||
roomId: Room["roomId"];
|
||||
@@ -83,7 +83,7 @@ interface Props {
|
||||
|
||||
const RoomCallBanner: React.FC<Props> = ({ roomId }) => {
|
||||
const call = useCall(roomId);
|
||||
|
||||
const { roomViewStore } = useScopedRoomContext("roomViewStore");
|
||||
// this section is to check if we have a live location share. If so, we dont show the call banner
|
||||
const isMonitoringLiveLocation = useEventEmitterState(
|
||||
OwnBeaconStore.instance,
|
||||
@@ -100,7 +100,7 @@ const RoomCallBanner: React.FC<Props> = ({ roomId }) => {
|
||||
}
|
||||
|
||||
// Check if the call is already showing. No banner is needed in this case.
|
||||
if (SdkContextClass.instance.roomViewStore.isViewingCall()) {
|
||||
if (roomViewStore.isViewingCall()) {
|
||||
return null;
|
||||
}
|
||||
|
||||
|
||||
@@ -13,14 +13,20 @@ import { type Command, CommandCategories, Commands } from "../../../SlashCommand
|
||||
import InfoDialog from "./InfoDialog";
|
||||
import { MatrixClientPeg } from "../../../MatrixClientPeg";
|
||||
|
||||
/**
|
||||
* Props for {@link SlashCommandHelpDialog}
|
||||
* @param roomId - The room ID to check whether commands are enabled
|
||||
* @param onFinished - Callback called when the dialog is closed
|
||||
*/
|
||||
interface IProps {
|
||||
roomId: string;
|
||||
onFinished(): void;
|
||||
}
|
||||
|
||||
const SlashCommandHelpDialog: React.FC<IProps> = ({ onFinished }) => {
|
||||
const SlashCommandHelpDialog: React.FC<IProps> = ({ roomId, onFinished }) => {
|
||||
const categories: Record<string, Command[]> = {};
|
||||
Commands.forEach((cmd) => {
|
||||
if (!cmd.isEnabled(MatrixClientPeg.get())) return;
|
||||
if (!cmd.isEnabled(MatrixClientPeg.get(), roomId)) return;
|
||||
if (!categories[cmd.category]) {
|
||||
categories[cmd.category] = [];
|
||||
}
|
||||
|
||||
@@ -31,8 +31,8 @@ import IconizedContextMenu, {
|
||||
} from "../context_menus/IconizedContextMenu";
|
||||
import JumpToDatePicker from "./JumpToDatePicker";
|
||||
import { type ViewRoomPayload } from "../../../dispatcher/payloads/ViewRoomPayload";
|
||||
import { SdkContextClass } from "../../../contexts/SDKContext";
|
||||
import TimelineSeparator from "./TimelineSeparator";
|
||||
import RoomContext from "../../../contexts/RoomContext";
|
||||
|
||||
interface IProps {
|
||||
roomId: string;
|
||||
@@ -51,6 +51,8 @@ interface IState {
|
||||
* Has additional jump to date functionality when labs flag is enabled
|
||||
*/
|
||||
export default class DateSeparator extends React.Component<IProps, IState> {
|
||||
public static contextType = RoomContext;
|
||||
declare public context: React.ContextType<typeof RoomContext>;
|
||||
private settingWatcherRef?: string;
|
||||
|
||||
public constructor(props: IProps) {
|
||||
@@ -143,7 +145,7 @@ export default class DateSeparator extends React.Component<IProps, IState> {
|
||||
// Only try to navigate to the room if the user is still viewing the same
|
||||
// room. We don't want to jump someone back to a room after a slow request
|
||||
// if they've already navigated away to another room.
|
||||
const currentRoomId = SdkContextClass.instance.roomViewStore.getRoomId();
|
||||
const currentRoomId = this.context.roomViewStore.getRoomId();
|
||||
if (currentRoomId === roomIdForJumpRequest) {
|
||||
dispatcher.dispatch<ViewRoomPayload>({
|
||||
action: Action.ViewRoom,
|
||||
@@ -169,7 +171,7 @@ export default class DateSeparator extends React.Component<IProps, IState> {
|
||||
// don't want to worry someone about an error in a room they no longer care
|
||||
// about after a slow request if they've already navigated away to another
|
||||
// room.
|
||||
const currentRoomId = SdkContextClass.instance.roomViewStore.getRoomId();
|
||||
const currentRoomId = this.context.roomViewStore.getRoomId();
|
||||
if (currentRoomId === roomIdForJumpRequest) {
|
||||
let friendlyErrorMessage = "An error occured while trying to find and jump to the given date.";
|
||||
let submitDebugLogsContent: JSX.Element = <></>;
|
||||
|
||||
@@ -17,11 +17,18 @@ import MediaProcessingError from "./shared/MediaProcessingError";
|
||||
import { isVoiceMessage } from "../../../utils/EventUtils";
|
||||
import { PlaybackQueue } from "../../../audio/PlaybackQueue";
|
||||
import { type Playback } from "../../../audio/Playback";
|
||||
import RoomContext from "../../../contexts/RoomContext";
|
||||
|
||||
export default class MVoiceMessageBody extends MAudioBody {
|
||||
public static contextType = RoomContext;
|
||||
declare public context: React.ContextType<typeof RoomContext>;
|
||||
|
||||
protected onMount(playback: Playback): void {
|
||||
if (isVoiceMessage(this.props.mxEvent)) {
|
||||
PlaybackQueue.forRoom(this.props.mxEvent.getRoomId()!).unsortedEnqueue(this.props.mxEvent, playback);
|
||||
PlaybackQueue.forRoom(this.props.mxEvent.getRoomId()!, this.context.roomViewStore).unsortedEnqueue(
|
||||
this.props.mxEvent,
|
||||
playback,
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -37,7 +37,6 @@ import JumpToBottomButton from "../rooms/JumpToBottomButton";
|
||||
import { type ViewRoomPayload } from "../../../dispatcher/payloads/ViewRoomPayload";
|
||||
import Measured from "../elements/Measured";
|
||||
import { UPDATE_EVENT } from "../../../stores/AsyncStore";
|
||||
import { SdkContextClass } from "../../../contexts/SDKContext";
|
||||
import { ScopedRoomContextProvider } from "../../../contexts/ScopedRoomContext.tsx";
|
||||
|
||||
interface IProps {
|
||||
@@ -88,7 +87,7 @@ export default class TimelineCard extends React.Component<IProps, IState> {
|
||||
}
|
||||
|
||||
public componentDidMount(): void {
|
||||
SdkContextClass.instance.roomViewStore.addListener(UPDATE_EVENT, this.onRoomViewStoreUpdate);
|
||||
this.context.roomViewStore.addListener(UPDATE_EVENT, this.onRoomViewStoreUpdate);
|
||||
this.dispatcherRef = dis.register(this.onAction);
|
||||
this.readReceiptsSettingWatcher = SettingsStore.watchSetting("showReadReceipts", null, (...[, , , value]) =>
|
||||
this.setState({ showReadReceipts: value as boolean }),
|
||||
@@ -99,7 +98,7 @@ export default class TimelineCard extends React.Component<IProps, IState> {
|
||||
}
|
||||
|
||||
public componentWillUnmount(): void {
|
||||
SdkContextClass.instance.roomViewStore.removeListener(UPDATE_EVENT, this.onRoomViewStoreUpdate);
|
||||
this.context.roomViewStore.removeListener(UPDATE_EVENT, this.onRoomViewStoreUpdate);
|
||||
|
||||
SettingsStore.unwatchSetting(this.readReceiptsSettingWatcher);
|
||||
SettingsStore.unwatchSetting(this.layoutWatcherRef);
|
||||
@@ -109,9 +108,9 @@ export default class TimelineCard extends React.Component<IProps, IState> {
|
||||
|
||||
private onRoomViewStoreUpdate = async (_initial?: boolean): Promise<void> => {
|
||||
const newState: Pick<IState, any> = {
|
||||
initialEventId: SdkContextClass.instance.roomViewStore.getInitialEventId(),
|
||||
isInitialEventHighlighted: SdkContextClass.instance.roomViewStore.isInitialEventHighlighted(),
|
||||
replyToEvent: SdkContextClass.instance.roomViewStore.getQuotingEvent(),
|
||||
initialEventId: this.context.roomViewStore.getInitialEventId(),
|
||||
isInitialEventHighlighted: this.context.roomViewStore.isInitialEventHighlighted(),
|
||||
replyToEvent: this.context.roomViewStore.getQuotingEvent(),
|
||||
};
|
||||
|
||||
this.setState(newState);
|
||||
|
||||
@@ -88,7 +88,7 @@ export const UserInfoBasicOptionsView: React.FC<{
|
||||
role="button"
|
||||
onSelect={async (ev) => {
|
||||
ev.preventDefault();
|
||||
vm.onInviteUserButton(ev);
|
||||
vm.onInviteUserButton(room.roomId, ev);
|
||||
}}
|
||||
label={_t("action|invite")}
|
||||
Icon={InviteIcon}
|
||||
|
||||
@@ -244,7 +244,10 @@ export default class BasicMessageEditor extends React.Component<IProps, IState>
|
||||
if (isTyping && this.props.model.parts[0].type === "command") {
|
||||
const { cmd } = parseCommandString(this.props.model.parts[0].text);
|
||||
const command = CommandMap.get(cmd!);
|
||||
if (!command?.isEnabled(MatrixClientPeg.get()) || command.category !== CommandCategories.messages) {
|
||||
if (
|
||||
!command?.isEnabled(MatrixClientPeg.get(), this.props.room.roomId) ||
|
||||
command.category !== CommandCategories.messages
|
||||
) {
|
||||
isTyping = false;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -312,7 +312,7 @@ class EditMessageComposer extends React.Component<IEditMessageComposerProps, ISt
|
||||
if (this.isContentModified(newContent)) {
|
||||
const roomId = editedEvent.getRoomId()!;
|
||||
if (!containsEmote(this.model) && isSlashCommand(this.model)) {
|
||||
const [cmd, args, commandText] = getSlashCommand(this.model);
|
||||
const [cmd, args, commandText] = getSlashCommand(roomId, this.model);
|
||||
if (cmd) {
|
||||
const threadId = editedEvent?.getThread()?.id || null;
|
||||
const [content, commandSuccessful] = await runSlashCommand(
|
||||
|
||||
@@ -170,7 +170,7 @@ interface IUploadButtonProps {
|
||||
// We put the file input outside the UploadButton component so that it doesn't get killed when the context menu closes.
|
||||
const UploadButtonContextProvider: React.FC<IUploadButtonProps> = ({ roomId, relation, children }) => {
|
||||
const cli = useContext(MatrixClientContext);
|
||||
const roomContext = useScopedRoomContext("timelineRenderingType");
|
||||
const roomContext = useScopedRoomContext("timelineRenderingType", "replyToEvent");
|
||||
const uploadInput = useRef<HTMLInputElement>(null);
|
||||
|
||||
const onUploadClick = (): void => {
|
||||
@@ -195,6 +195,7 @@ const UploadButtonContextProvider: React.FC<IUploadButtonProps> = ({ roomId, rel
|
||||
Array.from(ev.target.files!),
|
||||
roomId,
|
||||
relation,
|
||||
roomContext.replyToEvent,
|
||||
cli,
|
||||
roomContext.timelineRenderingType,
|
||||
);
|
||||
|
||||
@@ -356,7 +356,7 @@ export class SendMessageComposer extends React.Component<ISendMessageComposerPro
|
||||
let content: RoomMessageEventContent | null = null;
|
||||
|
||||
if (!containsEmote(model) && isSlashCommand(this.model)) {
|
||||
const [cmd, args, commandText] = getSlashCommand(this.model);
|
||||
const [cmd, args, commandText] = getSlashCommand(this.props.room.roomId, this.model);
|
||||
if (cmd) {
|
||||
const threadId =
|
||||
this.props.relation?.rel_type === THREAD_RELATION_TYPE.name ? this.props.relation?.event_id : null;
|
||||
@@ -565,6 +565,7 @@ export class SendMessageComposer extends React.Component<ISendMessageComposerPro
|
||||
Array.from(data.files),
|
||||
this.props.room.roomId,
|
||||
this.props.relation,
|
||||
this.context.replyToEvent,
|
||||
this.props.mxClient,
|
||||
this.context.timelineRenderingType,
|
||||
);
|
||||
|
||||
@@ -148,7 +148,14 @@ export function handleClipboardEvent(
|
||||
// it puts the filename in as text/plain which we want to ignore.
|
||||
if (data.files.length && !data.types.includes("text/rtf")) {
|
||||
ContentMessages.sharedInstance()
|
||||
.sendContentListToRoom(Array.from(data.files), room.roomId, eventRelation, mxClient, timelineRenderingType)
|
||||
.sendContentListToRoom(
|
||||
Array.from(data.files),
|
||||
room.roomId,
|
||||
eventRelation,
|
||||
roomContext.replyToEvent,
|
||||
mxClient,
|
||||
timelineRenderingType,
|
||||
)
|
||||
.catch(handleError);
|
||||
return true;
|
||||
}
|
||||
|
||||
@@ -76,7 +76,7 @@ export async function sendMessage(
|
||||
// Slash command handling here approximates what can be found in SendMessageComposer.sendMessage()
|
||||
// but note that the /me and // special cases are handled by the call to createMessageContent
|
||||
if (message.startsWith("/") && !message.startsWith("//") && !message.startsWith(EMOTE_PREFIX)) {
|
||||
const { cmd, args } = getCommand(message);
|
||||
const { cmd, args } = getCommand(roomId, message);
|
||||
if (cmd) {
|
||||
const threadId = relation?.rel_type === THREAD_RELATION_TYPE.name ? relation?.event_id : null;
|
||||
let commandSuccessful: boolean;
|
||||
|
||||
@@ -38,7 +38,13 @@ export function isSlashCommand(model: EditorModel): boolean {
|
||||
return false;
|
||||
}
|
||||
|
||||
export function getSlashCommand(model: EditorModel): [Command | undefined, string | undefined, string] {
|
||||
/**
|
||||
* Get the slash command and its arguments from the editor model
|
||||
* @param roomId - The room ID to check whether the command is enabled
|
||||
* @param model - The editor model
|
||||
* @returns A tuple of the command (or undefined if not found), the arguments (or undefined), and the full command text
|
||||
*/
|
||||
export function getSlashCommand(roomId: string, model: EditorModel): [Command | undefined, string | undefined, string] {
|
||||
const commandText = model.parts.reduce((text, part) => {
|
||||
// use mxid to textify user pills in a command and room alias/id for room pills
|
||||
if (part.type === Type.UserPill || part.type === Type.RoomPill) {
|
||||
@@ -46,7 +52,7 @@ export function getSlashCommand(model: EditorModel): [Command | undefined, strin
|
||||
}
|
||||
return text + part.text;
|
||||
}, "");
|
||||
const { cmd, args } = getCommand(commandText);
|
||||
const { cmd, args } = getCommand(roomId, commandText);
|
||||
return [cmd, args, commandText];
|
||||
}
|
||||
|
||||
|
||||
@@ -26,7 +26,6 @@ import { useRoomState } from "../useRoomState";
|
||||
import { _t } from "../../languageHandler";
|
||||
import { isManagedHybridWidget, isManagedHybridWidgetEnabled } from "../../widgets/ManagedHybrid";
|
||||
import { type IApp } from "../../stores/WidgetStore";
|
||||
import { SdkContextClass } from "../../contexts/SDKContext";
|
||||
import { UPDATE_EVENT } from "../../stores/AsyncStore";
|
||||
import defaultDispatcher from "../../dispatcher/dispatcher";
|
||||
import { type ViewRoomPayload } from "../../dispatcher/payloads/ViewRoomPayload";
|
||||
@@ -37,6 +36,7 @@ import { UIFeature } from "../../settings/UIFeature";
|
||||
import { type InteractionName } from "../../PosthogTrackers";
|
||||
import { ElementCallMemberEventType } from "../../call-types";
|
||||
import { LocalRoom, LocalRoomState } from "../../models/LocalRoom";
|
||||
import { useScopedRoomContext } from "../../contexts/ScopedRoomContext";
|
||||
|
||||
export enum PlatformCallType {
|
||||
ElementCall,
|
||||
@@ -98,6 +98,7 @@ export const useRoomCall = (
|
||||
showVideoCallButton: boolean;
|
||||
showVoiceCallButton: boolean;
|
||||
} => {
|
||||
const roomViewStore = useScopedRoomContext("roomViewStore").roomViewStore;
|
||||
// settings
|
||||
const groupCallsEnabled = useFeatureEnabled("feature_group_calls");
|
||||
const widgetsFeatureEnabled = useSettingValue(UIFeature.Widgets);
|
||||
@@ -124,9 +125,9 @@ export const useRoomCall = (
|
||||
const hasGroupCall = groupCall !== null;
|
||||
const hasActiveCallSession = useParticipantCount(groupCall) > 0;
|
||||
const isViewingCall = useEventEmitterState(
|
||||
SdkContextClass.instance.roomViewStore,
|
||||
roomViewStore,
|
||||
UPDATE_EVENT,
|
||||
() => SdkContextClass.instance.roomViewStore.isViewingCall() || isVideoRoom(room),
|
||||
() => roomViewStore.isViewingCall() || isVideoRoom(room),
|
||||
);
|
||||
|
||||
// room
|
||||
|
||||
@@ -18,6 +18,14 @@ import { _t, type TranslationKey, UserFriendlyError } from "../languageHandler";
|
||||
import { PosthogAnalytics } from "../PosthogAnalytics";
|
||||
import { CommandCategories, type RunResult } from "./interface";
|
||||
|
||||
/**
|
||||
* The function signature for the run function of a {@link Command}
|
||||
* @param matrixClient - The Matrix client
|
||||
* @param roomId - The room ID where the command is run
|
||||
* @param threadId - The thread ID where the command is run, or null for room timeline
|
||||
* @param args - The arguments passed to the command
|
||||
* @returns The result of running the command
|
||||
*/
|
||||
type RunFn = (
|
||||
this: Command,
|
||||
matrixClient: MatrixClient,
|
||||
@@ -26,6 +34,19 @@ type RunFn = (
|
||||
args?: string,
|
||||
) => RunResult;
|
||||
|
||||
/**
|
||||
* Options for {@link Command}
|
||||
* @param command - The command name, e.g. "me" for the /me command
|
||||
* @param aliases - Alternative names for the command
|
||||
* @param args - The arguments for the command, e.g. "<message>" for the /me command
|
||||
* @param description - A translation key describing the command
|
||||
* @param analyticsName - The name to use for analytics tracking
|
||||
* @param runFn - The function to execute when the command is run
|
||||
* @param category - The category of the command, e.g. CommandCategories.emoji
|
||||
* @param hideCompletionAfterSpace - Whether to hide autocomplete after a space is typed
|
||||
* @param isEnabled - A function to determine if the command is enabled in a given context
|
||||
* @param renderingTypes - The rendering types (room/thread) where this command is valid
|
||||
*/
|
||||
interface ICommandOpts {
|
||||
command: string;
|
||||
aliases?: string[];
|
||||
@@ -35,7 +56,7 @@ interface ICommandOpts {
|
||||
runFn?: RunFn;
|
||||
category: string;
|
||||
hideCompletionAfterSpace?: boolean;
|
||||
isEnabled?(matrixClient: MatrixClient | null): boolean;
|
||||
isEnabled?(matrixClient: MatrixClient | null, roomId: string | null): boolean;
|
||||
renderingTypes?: TimelineRenderingType[];
|
||||
}
|
||||
|
||||
@@ -49,7 +70,7 @@ export class Command {
|
||||
public readonly hideCompletionAfterSpace: boolean;
|
||||
public readonly renderingTypes?: TimelineRenderingType[];
|
||||
public readonly analyticsName?: SlashCommandEvent["command"];
|
||||
private readonly _isEnabled?: (matrixClient: MatrixClient | null) => boolean;
|
||||
private readonly _isEnabled?: (matrixClient: MatrixClient | null, roomId: string | null) => boolean;
|
||||
|
||||
public constructor(opts: ICommandOpts) {
|
||||
this.command = opts.command;
|
||||
@@ -102,7 +123,7 @@ export class Command {
|
||||
return _t("slash_command|usage") + ": " + this.getCommandWithArgs();
|
||||
}
|
||||
|
||||
public isEnabled(cli: MatrixClient | null): boolean {
|
||||
return this._isEnabled?.(cli) ?? true;
|
||||
public isEnabled(cli: MatrixClient | null, roomId: string | null): boolean {
|
||||
return this._isEnabled?.(cli, roomId) ?? true;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -29,8 +29,13 @@ export function successSync(value: any): RunResult {
|
||||
return success(Promise.resolve(value));
|
||||
}
|
||||
|
||||
export const canAffectPowerlevels = (cli: MatrixClient | null): boolean => {
|
||||
const roomId = SdkContextClass.instance.roomViewStore.getRoomId();
|
||||
/**
|
||||
* Check whether the user can affect power levels in the given room
|
||||
* @param cli - The Matrix client
|
||||
* @param roomId - The room ID
|
||||
* @returns True if the user can affect power levels, false otherwise
|
||||
*/
|
||||
export const canAffectPowerlevels = (cli: MatrixClient | null, roomId: string | null): boolean => {
|
||||
if (!cli || !roomId) return false;
|
||||
const room = cli?.getRoom(roomId);
|
||||
return !!room?.currentState.maySendStateEvent(EventType.RoomPowerLevels, cli.getSafeUserId()) && !isLocalRoom(room);
|
||||
|
||||
Reference in New Issue
Block a user