Compare commits
12 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
ca5ce7d468 | ||
|
|
a05f6a64a8 | ||
|
|
70dffe95ff | ||
|
|
0360889fd6 | ||
|
|
7304411c5d | ||
|
|
22dd095ea9 | ||
|
|
30a270193f | ||
|
|
ee1dd2293e | ||
|
|
34d5e88def | ||
|
|
30c9dfce02 | ||
|
|
48ad4d040d | ||
|
|
1b4f097b1c |
@@ -38,7 +38,7 @@
|
|||||||
"classnames": "^2.3.1",
|
"classnames": "^2.3.1",
|
||||||
"color-hash": "^2.0.1",
|
"color-hash": "^2.0.1",
|
||||||
"events": "^3.3.0",
|
"events": "^3.3.0",
|
||||||
"matrix-js-sdk": "github:matrix-org/matrix-js-sdk#965f4fb13b4b36b26a3f4d7214cc7630d9f579a5",
|
"matrix-js-sdk": "github:matrix-org/matrix-js-sdk#83c848093fe49652aedee71d963dfe07fd6d73f2",
|
||||||
"matrix-widget-api": "^1.0.0",
|
"matrix-widget-api": "^1.0.0",
|
||||||
"mermaid": "^8.13.8",
|
"mermaid": "^8.13.8",
|
||||||
"normalize.css": "^8.0.1",
|
"normalize.css": "^8.0.1",
|
||||||
|
|||||||
@@ -21,7 +21,7 @@ import {
|
|||||||
GroupCallIntent,
|
GroupCallIntent,
|
||||||
} from "matrix-js-sdk/src/webrtc/groupCall";
|
} from "matrix-js-sdk/src/webrtc/groupCall";
|
||||||
import { GroupCallEventHandlerEvent } from "matrix-js-sdk/src/webrtc/groupCallEventHandler";
|
import { GroupCallEventHandlerEvent } from "matrix-js-sdk/src/webrtc/groupCallEventHandler";
|
||||||
import { ClientEvent } from "matrix-js-sdk/src/client";
|
import { logger } from "matrix-js-sdk/src/logger";
|
||||||
|
|
||||||
import type { MatrixClient } from "matrix-js-sdk/src/client";
|
import type { MatrixClient } from "matrix-js-sdk/src/client";
|
||||||
import type { Room } from "matrix-js-sdk/src/models/room";
|
import type { Room } from "matrix-js-sdk/src/models/room";
|
||||||
@@ -45,38 +45,15 @@ export const useLoadGroupCall = (
|
|||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
setState({ loading: true });
|
setState({ loading: true });
|
||||||
|
|
||||||
const waitForRoom = async (roomId: string): Promise<Room> => {
|
|
||||||
const room = client.getRoom(roomId);
|
|
||||||
if (room) return room;
|
|
||||||
console.log(`Room ${roomId} hasn't arrived yet: waiting`);
|
|
||||||
|
|
||||||
const waitPromise = new Promise<Room>((resolve) => {
|
|
||||||
const onRoomEvent = async (room: Room) => {
|
|
||||||
if (room.roomId === roomId) {
|
|
||||||
client.removeListener(ClientEvent.Room, onRoomEvent);
|
|
||||||
resolve(room);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
client.on(ClientEvent.Room, onRoomEvent);
|
|
||||||
});
|
|
||||||
|
|
||||||
// race the promise with a timeout so we don't
|
|
||||||
// wait forever for the room
|
|
||||||
const timeoutPromise = new Promise<Room>((_, reject) => {
|
|
||||||
setTimeout(() => {
|
|
||||||
reject(new Error("Timed out trying to join room"));
|
|
||||||
}, 30000);
|
|
||||||
});
|
|
||||||
|
|
||||||
return Promise.race([waitPromise, timeoutPromise]);
|
|
||||||
};
|
|
||||||
|
|
||||||
const fetchOrCreateRoom = async (): Promise<Room> => {
|
const fetchOrCreateRoom = async (): Promise<Room> => {
|
||||||
try {
|
try {
|
||||||
const room = await client.joinRoom(roomIdOrAlias, { viaServers });
|
const room = await client.joinRoom(roomIdOrAlias, { viaServers });
|
||||||
// wait for the room to come down the sync stream, otherwise
|
logger.info(
|
||||||
// client.getRoom() won't return the room.
|
`Joined ${roomIdOrAlias}, waiting room to be ready for group calls`
|
||||||
return waitForRoom(room.roomId);
|
);
|
||||||
|
await client.waitUntilRoomReadyForGroupCalls(room.roomId);
|
||||||
|
logger.info(`${roomIdOrAlias}, is ready for group calls`);
|
||||||
|
return room;
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
if (
|
if (
|
||||||
isLocalRoomId(roomIdOrAlias) &&
|
isLocalRoomId(roomIdOrAlias) &&
|
||||||
@@ -91,7 +68,8 @@ export const useLoadGroupCall = (
|
|||||||
createPtt
|
createPtt
|
||||||
);
|
);
|
||||||
// likewise, wait for the room
|
// likewise, wait for the room
|
||||||
return await waitForRoom(roomId);
|
await client.waitUntilRoomReadyForGroupCalls(roomId);
|
||||||
|
return client.getRoom(roomId);
|
||||||
} else {
|
} else {
|
||||||
throw error;
|
throw error;
|
||||||
}
|
}
|
||||||
@@ -100,7 +78,9 @@ export const useLoadGroupCall = (
|
|||||||
|
|
||||||
const fetchOrCreateGroupCall = async (): Promise<GroupCall> => {
|
const fetchOrCreateGroupCall = async (): Promise<GroupCall> => {
|
||||||
const room = await fetchOrCreateRoom();
|
const room = await fetchOrCreateRoom();
|
||||||
|
logger.debug(`Fetched / joined room ${roomIdOrAlias}`);
|
||||||
const groupCall = client.getGroupCallForRoom(room.roomId);
|
const groupCall = client.getGroupCallForRoom(room.roomId);
|
||||||
|
logger.debug("Got group call", groupCall?.groupCallId);
|
||||||
|
|
||||||
if (groupCall) return groupCall;
|
if (groupCall) return groupCall;
|
||||||
|
|
||||||
@@ -111,7 +91,11 @@ export const useLoadGroupCall = (
|
|||||||
)
|
)
|
||||||
) {
|
) {
|
||||||
// The call doesn't exist, but we can create it
|
// The call doesn't exist, but we can create it
|
||||||
console.log(`Creating ${createPtt ? "PTT" : "video"} group call room`);
|
console.log(
|
||||||
|
`No call found in ${roomIdOrAlias}: creating ${
|
||||||
|
createPtt ? "PTT" : "video"
|
||||||
|
} call`
|
||||||
|
);
|
||||||
return await client.createGroupCall(
|
return await client.createGroupCall(
|
||||||
room.roomId,
|
room.roomId,
|
||||||
createPtt ? GroupCallType.Voice : GroupCallType.Video,
|
createPtt ? GroupCallType.Voice : GroupCallType.Video,
|
||||||
|
|||||||
@@ -8390,9 +8390,9 @@ matrix-events-sdk@^0.0.1-beta.7:
|
|||||||
resolved "https://registry.yarnpkg.com/matrix-events-sdk/-/matrix-events-sdk-0.0.1-beta.7.tgz#5ffe45eba1f67cc8d7c2377736c728b322524934"
|
resolved "https://registry.yarnpkg.com/matrix-events-sdk/-/matrix-events-sdk-0.0.1-beta.7.tgz#5ffe45eba1f67cc8d7c2377736c728b322524934"
|
||||||
integrity sha512-9jl4wtWanUFSy2sr2lCjErN/oC8KTAtaeaozJtrgot1JiQcEI4Rda9OLgQ7nLKaqb4Z/QUx/fR3XpDzm5Jy1JA==
|
integrity sha512-9jl4wtWanUFSy2sr2lCjErN/oC8KTAtaeaozJtrgot1JiQcEI4Rda9OLgQ7nLKaqb4Z/QUx/fR3XpDzm5Jy1JA==
|
||||||
|
|
||||||
"matrix-js-sdk@github:matrix-org/matrix-js-sdk#965f4fb13b4b36b26a3f4d7214cc7630d9f579a5":
|
"matrix-js-sdk@github:matrix-org/matrix-js-sdk#83c848093fe49652aedee71d963dfe07fd6d73f2":
|
||||||
version "19.3.0"
|
version "19.3.0"
|
||||||
resolved "https://codeload.github.com/matrix-org/matrix-js-sdk/tar.gz/965f4fb13b4b36b26a3f4d7214cc7630d9f579a5"
|
resolved "https://codeload.github.com/matrix-org/matrix-js-sdk/tar.gz/83c848093fe49652aedee71d963dfe07fd6d73f2"
|
||||||
dependencies:
|
dependencies:
|
||||||
"@babel/runtime" "^7.12.5"
|
"@babel/runtime" "^7.12.5"
|
||||||
"@types/sdp-transform" "^2.4.5"
|
"@types/sdp-transform" "^2.4.5"
|
||||||
|
|||||||
Reference in New Issue
Block a user