Matrix-Mirrors/mjolnir
1
0
Fork 0
mirror of https://github.com/matrix-org/mjolnir.git synced 2024-10-01 01:36:06 -04:00
Code Issues Packages Projects Releases Wiki Activity

Enable the crypto storage

Browse Source
This commit is contained in:
Half-Shot 2022-01-14 14:26:08 +00:00
parent c9820e2ebd
commit 0b0f045f75
1 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/index.ts
View File

@ -21,6 +21,7 @@ import {
MatrixClient, MatrixClient,
PantalaimonClient, PantalaimonClient,
RichConsoleLogger, RichConsoleLogger,
RustSdkCryptoStorageProvider,
SimpleFsStorageProvider SimpleFsStorageProvider
} from "matrix-bot-sdk"; } from "matrix-bot-sdk";
import config from "./config"; import config from "./config";
@ -44,13 +45,26 @@ if (config.health.healthz.enabled) {
(async function () { (async function () {
const storagePath = path.isAbsolute(config.dataPath) ? config.dataPath : path.join(__dirname, '../', config.dataPath); const storagePath = path.isAbsolute(config.dataPath) ? config.dataPath : path.join(__dirname, '../', config.dataPath);
const storage = new SimpleFsStorageProvider(path.join(storagePath, "bot.json")); const storage = new SimpleFsStorageProvider(path.join(storagePath, "bot.json"));
let cryptoStorage: RustSdkCryptoStorageProvider|undefined;
if (config.encryption.enabled && config.pantalaimon.use) {
throw Error('Cannot enable both pantalaimon and encryption at the same time. Remove one from the config.');
}
if (config.encryption.enabled) {
cryptoStorage = new RustSdkCryptoStorageProvider(storagePath);
}
let client: MatrixClient; let client: MatrixClient;
if (config.pantalaimon.use) { if (config.pantalaimon.use) {
const pantalaimon = new PantalaimonClient(config.homeserverUrl, storage); const pantalaimon = new PantalaimonClient(config.homeserverUrl, storage);
client = await pantalaimon.createClientWithCredentials(config.pantalaimon.username, config.pantalaimon.password); client = await pantalaimon.createClientWithCredentials(config.pantalaimon.username, config.pantalaimon.password);
} else { } else {
client = new MatrixClient(config.homeserverUrl, config.accessToken, storage); client = new MatrixClient(config.homeserverUrl, config.accessToken, storage, cryptoStorage);
if (config.encryption.enabled) {
const joinedRooms = await client.getJoinedRooms();
await client.crypto.prepare(joinedRooms);
}
} }
patchMatrixClient(); patchMatrixClient();
config.RUNTIME.client = client; config.RUNTIME.client = client;