Class LibsqlContainer

repos/effect/packages/sql/libsql/test/util.ts:22–54

}

export class LibsqlContainer extends Context.Service<
  LibsqlContainer,
  StartedTestContainer
>()("test/LibsqlContainer") {
  static readonly layer = Layer.effect(this)(
    Effect.acquireRelease(
      Effect.promise(async () => {
        const container = await new GenericContainer("ghcr.io/tursodatabase/libsql-server:main")
          .withExposedPorts(8080)
          .withEnvironment({ SQLD_NODE: "primary" })
          .withCommand(["sqld", "--no-welcome", "--http-listen-addr", "0.0.0.0:8080"]).start()

        try {
          await waitForServer(container)
          return container
        } catch (error) {
          await container.stop()
          throw error
        }
      }),
      (container) => Effect.promise(() => container.stop())
    )
  )

  static layerClient = Layer.unwrap(
    Effect.gen(function*() {
      const container = yield* LibsqlContainer
      return LibsqlClient.layer({
        url: `http://${container.getHost()}:${container.getMappedPort(8080)}`
      })
    })
  ).pipe(Layer.provide(this.layer))
}