restore Electric testcontainer fixtures removed in the run-ops db foundation

The db-foundation change dropped createElectricContainer, the electricOrigin
fixture, the ContainerWithElectric* context types, and the
containerWithElectricTest / containerWithElectricAndRedisTest fixtures. That
Electric infra is unrelated to the run-ops db split, is being sunset on its own
track, and is still consumed by apps/webapp/test/realtimeClient.test.ts (which
imports containerWithElectricAndRedisTest) — so its removal here also broke that
import. Restore it verbatim; the new PG17 run-ops fixtures are unaffected.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: d-cs

internal-packages/database/scripts/migrate-run-ops.mjs

@@ -7,6 +7,7 @@ import { Network, type StartedNetwork } from "testcontainers";
 import { TestContext, test } from "vitest";
 import {
   createClickHouseContainer,
+  createElectricContainer,
   createPostgresContainer,
   createRedisContainer,
   postgresUriWithDatabase,
@@ -43,8 +44,14 @@ type RedisContext = NetworkContext & {
   redisOptions: RedisOptions;
 };
 
+type ElectricContext = {
+  electricOrigin: string;
+};
+
 export type ContainerContext = NetworkContext & PostgresContext & RedisContext & ClickhouseContext;
 export type PostgresAndRedisContext = NetworkContext & PostgresContext & RedisContext;
+export type ContainerWithElectricAndRedisContext = ContainerContext & ElectricContext;
+export type ContainerWithElectricContext = NetworkContext & PostgresContext & ElectricContext;
 
 type MinIOContext = NetworkContext & {
   minioContainer: StartedMinIOContainer;
@@ -554,6 +561,23 @@ export const isolatedRedisTest = test.extend<RedisContext>({
   redisOptions,
 });
 
+const electricOrigin = async (
+  {
+    postgresContainer,
+    network,
+    task,
+  }: { postgresContainer: StartedPostgreSqlContainer; network: StartedNetwork } & TestContext,
+  use: Use<string>
+) => {
+  const { origin, container, metadata } = await withContainerSetup({
+    name: "electricContainer",
+    task,
+    setup: createElectricContainer(postgresContainer, network),
+  });
+
+  await useContainer("electricContainer", { container, task, use: () => use(origin) });
+};
+
 const clickhouseContainer = async (
   { network, task }: { network: StartedNetwork } & TestContext,
   use: Use<StartedClickHouseContainer>
@@ -747,6 +771,24 @@ export const replicationContainerTest = test.extend<ReplicationContainerTestCont
   clickhouseClient: scopedClickhouseClient,
 });
 
+export const containerWithElectricTest = test.extend<ContainerWithElectricContext>({
+  network,
+  postgresContainer,
+  prisma,
+  electricOrigin,
+});
+
+export const containerWithElectricAndRedisTest = test.extend<ContainerWithElectricAndRedisContext>({
+  network,
+  postgresContainer,
+  prisma,
+  redisContainer,
+  redisOptions,
+  electricOrigin,
+  clickhouseContainer,
+  clickhouseClient,
+});
+
 // Boot minio once per worker; reset the bucket per test (auto fixture).
 const bootWorkerMinio = async ({}, use: Use<StartedMinIOContainer>) => {
   const container = await withCiResourceLimits(new MinIOContainer()).start();

internal-packages/testcontainers/src/index.ts

@@ -1,5 +1,5 @@
 import { createClient } from "@clickhouse/client";
-import { PostgreSqlContainer } from "@testcontainers/postgresql";
+import { PostgreSqlContainer, StartedPostgreSqlContainer } from "@testcontainers/postgresql";
 import { PrismaClient } from "@trigger.dev/database";
 import { RedisContainer, StartedRedisContainer } from "@testcontainers/redis";
 import { tryCatch } from "@trigger.dev/core";
@@ -246,6 +246,33 @@ async function verifyRedisConnection(container: StartedRedisContainer) {
   }
 }
 
+export async function createElectricContainer(
+  postgresContainer: StartedPostgreSqlContainer,
+  network: StartedNetwork
+) {
+  const databaseUrl = `postgresql://${postgresContainer.getUsername()}:${postgresContainer.getPassword()}@${postgresContainer.getIpAddress(
+    network.getName()
+  )}:5432/${postgresContainer.getDatabase()}?sslmode=disable`;
+
+  const container = await withCiResourceLimits(
+    new GenericContainer(
+      "electricsql/electric:1.2.4@sha256:20da3d0b0e74926c5623392db67fd56698b9e374c4aeb6cb5cadeb8fea171c36"
+    )
+  )
+    .withExposedPorts(3000)
+    .withNetwork(network)
+    .withEnvironment({
+      DATABASE_URL: databaseUrl,
+      ELECTRIC_INSECURE: "true",
+    })
+    .start();
+
+  return {
+    container,
+    origin: `http://${container.getHost()}:${container.getMappedPort(3000)}`,
+  };
+}
+
 export async function createMinIOContainer(network: StartedNetwork) {
   const container = await withCiResourceLimits(new MinIOContainer())
     .withNetwork(network)