Function startPredecessor

e2e/cli/service-install-takeover.test.ts:117–158

(exe: string)

  `& '${exe}' daemon run --foreground --port ${PORT} --hostname 127.0.0.1`;

const startPredecessor = async (exe: string): Promise<PredecessorHandle> => {
  if (guestOs() !== "windows") {
    await ssh(
      `nohup ${exe} daemon run --foreground --port ${PORT} --hostname 127.0.0.1 >/tmp/takeover-predecessor.log 2>&1 &`,
    );
    return {
      close: () => {},
      diagnostics: async () =>
        (await ssh("cat /tmp/takeover-predecessor.log 2>/dev/null || true")).stdout.trim(),
    };
  }

  const invocation = sshInvocation(windowsPredecessorCommand(exe));
  const child: ChildProcessWithoutNullStreams = spawn(invocation.command, [...invocation.args], {
    stdio: ["ignore", "pipe", "pipe"],
  });
  let stdout = "";
  let stderr = "";
  let exit: string | null = null;
  child.stdout.on("data", (chunk: Buffer) => {
    stdout = appendChunk(stdout, chunk);
  });
  child.stderr.on("data", (chunk: Buffer) => {
    stderr = appendChunk(stderr, chunk);
  });
  child.on("error", (error) => {
    exit = `spawn error: ${error.message}`;
  });
  child.on("exit", (code, signal) => {
    exit = `exit code ${code ?? "<null>"} signal ${signal ?? "<null>"}`;
  });

  return {
    close: () => {
      if (!child.killed) child.kill();
    },
    diagnostics: async () =>
      [`predecessor ssh: ${exit ?? "still running"}`, `stdout:\n${stdout}`, `stderr:\n${stderr}`]
        .join("\n")
        .trim(),
  };
};

const installServiceCommand = (exe: string): string =>
  guestOs() === "windows"