Spaces:
Running
Running
| import { access } from "node:fs/promises"; | |
| import path from "node:path"; | |
| import { sourcePath } from "./paths.js"; | |
| import { runInherit, runQuiet } from "./exec.js"; | |
| import { | |
| SERVICE_COMPOSE_FILES, | |
| type ServiceName, | |
| } from "../constants.js"; | |
| export type DockerState = "ok" | "missing" | "daemon_down"; | |
| export async function detectDocker(): Promise<DockerState> { | |
| const cli = await runQuiet("docker", ["--version"]); | |
| if (!cli.ok) return "missing"; | |
| const compose = await runQuiet("docker", ["compose", "version"]); | |
| if (!compose.ok) { | |
| const legacy = await runQuiet("docker-compose", ["--version"]); | |
| if (!legacy.ok) return "missing"; | |
| } | |
| const info = await runQuiet("docker", ["info"]); | |
| if (!info.ok) return "daemon_down"; | |
| return "ok"; | |
| } | |
| export function composeFileFor(service: ServiceName): string { | |
| return path.join(sourcePath(), SERVICE_COMPOSE_FILES[service]); | |
| } | |
| export async function composeFileExists(service: ServiceName): Promise<boolean> { | |
| try { | |
| await access(composeFileFor(service)); | |
| return true; | |
| } catch { | |
| return false; | |
| } | |
| } | |
| export async function composeUp(service: ServiceName): Promise<void> { | |
| const file = composeFileFor(service); | |
| const result = await runInherit("docker", [ | |
| "compose", | |
| "-f", | |
| file, | |
| "up", | |
| "-d", | |
| ]); | |
| if (!result.ok) { | |
| throw new Error(`docker compose up failed for ${service}`); | |
| } | |
| } | |
| export async function composeDown(service: ServiceName): Promise<void> { | |
| const file = composeFileFor(service); | |
| await runInherit("docker", ["compose", "-f", file, "down"]); | |
| } | |
| export async function waitForDaemon(timeoutMs = 60_000): Promise<boolean> { | |
| const start = Date.now(); | |
| while (Date.now() - start < timeoutMs) { | |
| const info = await runQuiet("docker", ["info"]); | |
| if (info.ok) return true; | |
| await new Promise((resolve) => setTimeout(resolve, 2000)); | |
| } | |
| return false; | |
| } | |