Server.sessions

import { strict as assert } from "node:assert";
import { mkdtemp, readdir, rm } from "node:fs/promises";
import { tmpdir } from "node:os";
import { join } from "node:path";
import { Server, NoMatchError } from "libtmux";

const directory = await mkdtemp(join(tmpdir(), "ltx-example-"));
const server = new Server({
  socketPath: join(directory, "tmux.sock"),
  configFile: "/dev/null",
  timeoutMs: 5_000,
});
const failures: unknown[] = [];
try {
  await server.newSession({ name: "prod-api", shellCommand: "cat" });
  await server.newSession({ name: "dev-api", shellCommand: "cat" });
  const sessions = await server.sessions();
  assert.equal(sessions.count(), 2);
  console.log(
    "sessions:",
    sessions
      .map((item) => item.name)
      .sort()
      .join(", "),
  );
  const production = sessions.where({ name: { startsWith: "prod-" } }).one();
  assert.equal(production.name, "prod-api");
  console.log("production:", production.name);
  assert.equal(sessions.oneOrUndefined({ name: "missing" }), undefined);
  try {
    sessions.one({ name: "missing" });
    throw new Error("Expected the missing session to fail lookup");
  } catch (error) {
    if (!(error instanceof NoMatchError)) throw error;
    console.log("missing:", error.code);
  }
} catch (error) {
  failures.push(error);
} finally {
  try {
    if ((await readdir(directory)).includes("tmux.sock")) await server.kill();
    await rm(directory, { recursive: true });
  } catch (error) {
    failures.push(new Error(`Cleanup failed; inspect ${directory}`, { cause: error }));
  }
}
if (failures.length > 0) throw new AggregateError(failures, "Example failed");