element-call-Github/src/matrix-utils.js

192 lines
4.7 KiB
JavaScript
Raw Normal View History

2022-01-06 09:19:03 +08:00
import matrix from "matrix-js-sdk/src/browser-index";
import {
GroupCallIntent,
GroupCallType,
} from "matrix-js-sdk/src/browser-index";
import IndexedDBWorker from "./IndexedDBWorker?worker";
2022-04-28 04:38:16 +08:00
import Olm from "@matrix-org/olm";
import olmWasmPath from "@matrix-org/olm/olm.wasm?url";
2022-01-06 09:19:03 +08:00
export const defaultHomeserver =
import.meta.env.VITE_DEFAULT_HOMESERVER ||
`${window.location.protocol}//${window.location.host}`;
export const defaultHomeserverHost = new URL(defaultHomeserver).host;
function waitForSync(client) {
return new Promise((resolve, reject) => {
const onSync = (state, _old, data) => {
if (state === "PREPARED") {
resolve();
client.removeListener("sync", onSync);
} else if (state === "ERROR") {
reject(data?.error);
client.removeListener("sync", onSync);
}
};
client.on("sync", onSync);
});
}
export async function initClient(clientOptions) {
2022-04-28 04:51:08 +08:00
// TODO: https://gitlab.matrix.org/matrix-org/olm/-/issues/10
2022-04-28 04:38:16 +08:00
window.OLM_OPTIONS = {};
await Olm.init({ locateFile: () => olmWasmPath });
2022-04-27 07:28:21 +08:00
let indexedDB;
try {
indexedDB = window.indexedDB;
} catch (e) {}
const storeOpts = {};
if (indexedDB && localStorage && !import.meta.env.DEV) {
storeOpts.store = new matrix.IndexedDBStore({
indexedDB: window.indexedDB,
localStorage: window.localStorage,
dbName: "element-call-sync",
workerFactory: () => new IndexedDBWorker(),
});
}
if (localStorage) {
storeOpts.sessionStore = new matrix.WebStorageSessionStore(localStorage);
}
if (indexedDB) {
storeOpts.cryptoStore = new matrix.IndexedDBCryptoStore(
indexedDB,
"matrix-js-sdk:crypto"
);
}
2022-01-07 08:51:23 +08:00
const client = matrix.createClient({
...storeOpts,
2022-01-07 08:51:23 +08:00
...clientOptions,
useAuthorizationHeader: true,
});
2022-01-06 09:19:03 +08:00
try {
await client.store.startup();
} catch (error) {
console.error(
"Error starting matrix client store. Falling back to memory store.",
error
);
client.store = new matrix.MemoryStore({ localStorage });
await client.store.startup();
}
if (client.initCrypto) {
await client.initCrypto();
}
2022-01-06 09:19:03 +08:00
await client.startClient({
// dirty hack to reduce chance of gappy syncs
// should be fixed by spotting gaps and backpaginating
initialSyncLimit: 50,
});
await waitForSync(client);
return client;
}
export function roomAliasFromRoomName(roomName) {
return roomName
.trim()
.replace(/\s/g, "-")
.replace(/[^\w-]/g, "")
.toLowerCase();
}
2022-02-15 05:53:19 +08:00
export function roomNameFromRoomId(roomId) {
return roomId
.match(/([^:]+):.*$/)[1]
.substring(1)
.split("-")
.map((part) =>
part.length > 0 ? part.charAt(0).toUpperCase() + part.slice(1) : part
)
.join(" ")
.toLowerCase();
2022-02-15 05:53:19 +08:00
}
export function isLocalRoomId(roomId) {
if (!roomId) {
return false;
}
const parts = roomId.match(/[^:]+:(.*)$/);
if (parts.length < 2) {
return false;
}
return parts[1] === defaultHomeserverHost;
}
2022-04-23 09:05:48 +08:00
export async function createRoom(client, name, isPtt = false) {
2022-01-06 09:19:03 +08:00
const { room_id, room_alias } = await client.createRoom({
visibility: "private",
preset: "public_chat",
name,
room_alias_name: roomAliasFromRoomName(name),
power_level_content_override: {
invite: 100,
kick: 100,
ban: 100,
redact: 50,
state_default: 0,
events_default: 0,
users_default: 0,
events: {
"m.room.power_levels": 100,
"m.room.history_visibility": 100,
"m.room.tombstone": 100,
"m.room.encryption": 100,
"m.room.name": 50,
"m.room.message": 0,
"m.room.encrypted": 50,
"m.sticker": 50,
"org.matrix.msc3401.call.member": 0,
},
users: {
[client.getUserId()]: 100,
},
},
});
2022-04-23 09:05:48 +08:00
console.log({ isPtt });
2022-01-06 09:19:03 +08:00
await client.createGroupCall(
room_id,
isPtt ? GroupCallType.Voice : GroupCallType.Video,
2022-04-23 09:05:48 +08:00
isPtt,
2022-01-06 09:19:03 +08:00
GroupCallIntent.Prompt
);
return room_alias || room_id;
}
export function getRoomUrl(roomId) {
if (roomId.startsWith("#")) {
const [localPart, host] = roomId.replace("#", "").split(":");
if (host !== defaultHomeserverHost) {
2022-02-17 02:52:07 +08:00
return `${window.location.protocol}//${window.location.host}/room/${roomId}`;
2022-01-06 09:19:03 +08:00
} else {
2022-02-17 02:52:07 +08:00
return `${window.location.protocol}//${window.location.host}/${localPart}`;
2022-01-06 09:19:03 +08:00
}
} else {
2022-02-17 02:52:07 +08:00
return `${window.location.protocol}//${window.location.host}/room/${roomId}`;
2022-01-06 09:19:03 +08:00
}
}
export function getAvatarUrl(client, mxcUrl, avatarSize = 96) {
const width = Math.floor(avatarSize * window.devicePixelRatio);
const height = Math.floor(avatarSize * window.devicePixelRatio);
return mxcUrl && client.mxcUrlToHttp(mxcUrl, width, height, "crop");
}