Clean up useLoadGroupCall
This commit is contained in:
parent
0adc4b3d66
commit
6621e20da3
3 changed files with 53 additions and 54 deletions
|
|
@ -66,42 +66,6 @@ export async function initClient(clientOptions) {
|
||||||
return client;
|
return client;
|
||||||
}
|
}
|
||||||
|
|
||||||
export async function fetchGroupCall(
|
|
||||||
client,
|
|
||||||
roomIdOrAlias,
|
|
||||||
viaServers = undefined,
|
|
||||||
timeout = 5000
|
|
||||||
) {
|
|
||||||
const { roomId } = await client.joinRoom(roomIdOrAlias, { viaServers });
|
|
||||||
|
|
||||||
return new Promise((resolve, reject) => {
|
|
||||||
let timeoutId;
|
|
||||||
|
|
||||||
function onGroupCallIncoming(groupCall) {
|
|
||||||
if (groupCall && groupCall.room.roomId === roomId) {
|
|
||||||
clearTimeout(timeoutId);
|
|
||||||
client.removeListener("GroupCall.incoming", onGroupCallIncoming);
|
|
||||||
resolve(groupCall);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
const groupCall = client.getGroupCallForRoom(roomId);
|
|
||||||
|
|
||||||
if (groupCall) {
|
|
||||||
resolve(groupCall);
|
|
||||||
}
|
|
||||||
|
|
||||||
client.on("GroupCall.incoming", onGroupCallIncoming);
|
|
||||||
|
|
||||||
if (timeout) {
|
|
||||||
timeoutId = setTimeout(() => {
|
|
||||||
client.removeListener("GroupCall.incoming", onGroupCallIncoming);
|
|
||||||
reject(new Error("Fetching group call timed out."));
|
|
||||||
}, timeout);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
export function ClientProvider({ children }) {
|
export function ClientProvider({ children }) {
|
||||||
const history = useHistory();
|
const history = useHistory();
|
||||||
const [
|
const [
|
||||||
|
|
@ -326,23 +290,6 @@ export async function createRoom(client, name) {
|
||||||
return room_alias || room_id;
|
return room_alias || room_id;
|
||||||
}
|
}
|
||||||
|
|
||||||
export function useLoadGroupCall(client, roomId, viaServers) {
|
|
||||||
const [state, setState] = useState({
|
|
||||||
loading: true,
|
|
||||||
error: undefined,
|
|
||||||
groupCall: undefined,
|
|
||||||
});
|
|
||||||
|
|
||||||
useEffect(() => {
|
|
||||||
setState({ loading: true });
|
|
||||||
fetchGroupCall(client, roomId, viaServers, 30000)
|
|
||||||
.then((groupCall) => setState({ loading: false, groupCall }))
|
|
||||||
.catch((error) => setState({ loading: false, error }));
|
|
||||||
}, [client, roomId]);
|
|
||||||
|
|
||||||
return state;
|
|
||||||
}
|
|
||||||
|
|
||||||
const tsCache = {};
|
const tsCache = {};
|
||||||
|
|
||||||
function getLastTs(client, r) {
|
function getLastTs(client, r) {
|
||||||
|
|
|
||||||
|
|
@ -1,5 +1,5 @@
|
||||||
import React from "react";
|
import React from "react";
|
||||||
import { useLoadGroupCall } from "../ConferenceCallManagerHooks";
|
import { useLoadGroupCall } from "./useLoadGroupCall";
|
||||||
import { ErrorView, FullScreenView } from "../FullScreenView";
|
import { ErrorView, FullScreenView } from "../FullScreenView";
|
||||||
|
|
||||||
export function GroupCallLoader({ client, roomId, viaServers, children }) {
|
export function GroupCallLoader({ client, roomId, viaServers, children }) {
|
||||||
|
|
|
||||||
52
src/room/useLoadGroupCall.js
Normal file
52
src/room/useLoadGroupCall.js
Normal file
|
|
@ -0,0 +1,52 @@
|
||||||
|
async function fetchGroupCall(
|
||||||
|
client,
|
||||||
|
roomIdOrAlias,
|
||||||
|
viaServers = undefined,
|
||||||
|
timeout = 5000
|
||||||
|
) {
|
||||||
|
const { roomId } = await client.joinRoom(roomIdOrAlias, { viaServers });
|
||||||
|
|
||||||
|
return new Promise((resolve, reject) => {
|
||||||
|
let timeoutId;
|
||||||
|
|
||||||
|
function onGroupCallIncoming(groupCall) {
|
||||||
|
if (groupCall && groupCall.room.roomId === roomId) {
|
||||||
|
clearTimeout(timeoutId);
|
||||||
|
client.removeListener("GroupCall.incoming", onGroupCallIncoming);
|
||||||
|
resolve(groupCall);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
const groupCall = client.getGroupCallForRoom(roomId);
|
||||||
|
|
||||||
|
if (groupCall) {
|
||||||
|
resolve(groupCall);
|
||||||
|
}
|
||||||
|
|
||||||
|
client.on("GroupCall.incoming", onGroupCallIncoming);
|
||||||
|
|
||||||
|
if (timeout) {
|
||||||
|
timeoutId = setTimeout(() => {
|
||||||
|
client.removeListener("GroupCall.incoming", onGroupCallIncoming);
|
||||||
|
reject(new Error("Fetching group call timed out."));
|
||||||
|
}, timeout);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
export function useLoadGroupCall(client, roomId, viaServers) {
|
||||||
|
const [state, setState] = useState({
|
||||||
|
loading: true,
|
||||||
|
error: undefined,
|
||||||
|
groupCall: undefined,
|
||||||
|
});
|
||||||
|
|
||||||
|
useEffect(() => {
|
||||||
|
setState({ loading: true });
|
||||||
|
fetchGroupCall(client, roomId, viaServers, 30000)
|
||||||
|
.then((groupCall) => setState({ loading: false, groupCall }))
|
||||||
|
.catch((error) => setState({ loading: false, error }));
|
||||||
|
}, [client, roomId]);
|
||||||
|
|
||||||
|
return state;
|
||||||
|
}
|
||||||
Loading…
Add table
Add a link
Reference in a new issue