78 lines
2.7 KiB
TypeScript
78 lines
2.7 KiB
TypeScript
/*
|
|
Copyright 2024 New Vector Ltd.
|
|
Copyright 2023 The Matrix.org Foundation C.I.C.
|
|
|
|
SPDX-License-Identifier: AGPL-3.0-only OR GPL-3.0-only
|
|
Please see LICENSE files in the repository root for full details.
|
|
*/
|
|
|
|
import type { BrowserContext, Route } from "@playwright/test";
|
|
import { getFreePort } from "../utils/port";
|
|
import { Docker } from "../docker";
|
|
import { PG_PASSWORD, PostgresDocker } from "../postgres";
|
|
|
|
// Docker tag to use for `ghcr.io/matrix-org/sliding-sync` image.
|
|
const SLIDING_SYNC_PROXY_TAG = "v0.99.3";
|
|
|
|
export interface ProxyInstance {
|
|
containerId: string;
|
|
postgresId: string;
|
|
port: number;
|
|
}
|
|
|
|
export class SlidingSyncProxy {
|
|
private readonly proxyDocker = new Docker();
|
|
private readonly postgresDocker = new PostgresDocker("sliding-sync");
|
|
private instance: ProxyInstance;
|
|
|
|
constructor(
|
|
private synapseIp: string,
|
|
private context: BrowserContext,
|
|
) {}
|
|
|
|
private syncHandler = async (route: Route) => {
|
|
if (!this.instance) return route.abort("blockedbyclient");
|
|
|
|
const baseUrl = `http://localhost:${this.instance.port}`;
|
|
await route.continue({
|
|
url: new URL(route.request().url().split("/").slice(3).join("/"), baseUrl).href,
|
|
});
|
|
};
|
|
|
|
async start(): Promise<ProxyInstance> {
|
|
console.log(new Date(), "Starting sliding sync proxy...");
|
|
|
|
const { ipAddress: postgresIp, containerId: postgresId } = await this.postgresDocker.start();
|
|
|
|
const port = await getFreePort();
|
|
console.log(new Date(), "starting proxy container...", SLIDING_SYNC_PROXY_TAG);
|
|
const containerId = await this.proxyDocker.run({
|
|
image: "ghcr.io/matrix-org/sliding-sync:" + SLIDING_SYNC_PROXY_TAG,
|
|
containerName: "react-sdk-playwright-sliding-sync-proxy",
|
|
params: [
|
|
"-p",
|
|
`${port}:8008/tcp`,
|
|
"-e",
|
|
"SYNCV3_SECRET=bwahahaha",
|
|
"-e",
|
|
`SYNCV3_SERVER=${this.synapseIp}`,
|
|
"-e",
|
|
`SYNCV3_DB=user=postgres dbname=postgres password=${PG_PASSWORD} host=${postgresIp} sslmode=disable`,
|
|
],
|
|
});
|
|
console.log(new Date(), "started!");
|
|
|
|
this.instance = { containerId, postgresId, port };
|
|
await this.context.route("**/_matrix/client/unstable/org.matrix.msc3575/sync*", this.syncHandler);
|
|
return this.instance;
|
|
}
|
|
|
|
async stop(): Promise<void> {
|
|
await this.context.unroute("**/_matrix/client/unstable/org.matrix.msc3575/sync*", this.syncHandler);
|
|
|
|
await this.postgresDocker.stop();
|
|
await this.proxyDocker.stop();
|
|
console.log(new Date(), "Stopped sliding sync proxy.");
|
|
}
|
|
}
|