100 lines
3.3 KiB
TypeScript
100 lines
3.3 KiB
TypeScript
/*
|
|
Copyright 2023 The Matrix.org Foundation C.I.C.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
import { getFreePort } from "../utils/port";
|
|
import { Docker } from "../docker";
|
|
|
|
// Docker tag to use for `ghcr.io/matrix-org/sliding-sync` image.
|
|
const SLIDING_SYNC_PROXY_TAG = "v0.99.3";
|
|
const PG_PASSWORD = "p4S5w0rD";
|
|
|
|
export interface ProxyInstance {
|
|
containerId: string;
|
|
postgresId: string;
|
|
port: number;
|
|
}
|
|
|
|
export class SlidingSyncProxy {
|
|
private readonly postgresDocker = new Docker();
|
|
private readonly proxyDocker = new Docker();
|
|
private instance: ProxyInstance;
|
|
|
|
constructor(private synapseIp: string) {}
|
|
|
|
private async waitForPostgresReady(): Promise<void> {
|
|
const waitTimeMillis = 30000;
|
|
const startTime = new Date().getTime();
|
|
let lastErr: Error | null = null;
|
|
while (new Date().getTime() - startTime < waitTimeMillis) {
|
|
try {
|
|
await this.postgresDocker.exec(["pg_isready", "-U", "postgres"]);
|
|
lastErr = null;
|
|
break;
|
|
} catch (err) {
|
|
console.log("pg_isready: failed");
|
|
lastErr = err;
|
|
}
|
|
}
|
|
if (lastErr) {
|
|
console.log("rethrowing");
|
|
throw lastErr;
|
|
}
|
|
}
|
|
|
|
async start(): Promise<ProxyInstance> {
|
|
console.log(new Date(), "Starting sliding sync proxy...");
|
|
|
|
const postgresId = await this.postgresDocker.run({
|
|
image: "postgres",
|
|
containerName: "react-sdk-cypress-sliding-sync-postgres",
|
|
params: ["--rm", "-e", `POSTGRES_PASSWORD=${PG_PASSWORD}`],
|
|
});
|
|
|
|
const postgresIp = await this.postgresDocker.getContainerIp();
|
|
console.log(new Date(), "postgres container up");
|
|
|
|
await this.waitForPostgresReady();
|
|
|
|
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-cypress-sliding-sync-proxy",
|
|
params: [
|
|
"--rm",
|
|
"-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 };
|
|
return this.instance;
|
|
}
|
|
|
|
async stop(): Promise<void> {
|
|
await this.postgresDocker.stop();
|
|
await this.proxyDocker.stop();
|
|
console.log(new Date(), "Stopped sliding sync proxy.");
|
|
}
|
|
}
|