wehub-resource-sync
102 lines
2.8 KiB
TypeScript
102 lines
2.8 KiB
TypeScript
import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
|
|
import { join } from "path";
|
|
import { existsSync, mkdirSync, rmSync, writeFileSync } from "fs";
|
|
|
|
const { TEST_HOME } = vi.hoisted(() => {
|
|
// eslint-disable-next-line @typescript-eslint/no-require-imports
|
|
const path = require("path");
|
|
// eslint-disable-next-line @typescript-eslint/no-require-imports
|
|
const os = require("os");
|
|
return {
|
|
TEST_HOME: path.join(os.tmpdir(), `hermes-platform-state-${Date.now()}`),
|
|
};
|
|
});
|
|
|
|
vi.mock("../src/main/installer", () => ({
|
|
HERMES_HOME: TEST_HOME,
|
|
}));
|
|
|
|
vi.mock("../src/main/utils", () => ({
|
|
profileHome: (profile?: string) =>
|
|
profile && profile !== "default"
|
|
? join(TEST_HOME, "profiles", profile)
|
|
: TEST_HOME,
|
|
}));
|
|
|
|
import { readLocalGatewayPlatformStates } from "../src/main/messaging-platforms";
|
|
|
|
beforeEach(() => {
|
|
mkdirSync(TEST_HOME, { recursive: true });
|
|
});
|
|
|
|
afterEach(() => {
|
|
if (existsSync(TEST_HOME)) {
|
|
rmSync(TEST_HOME, { recursive: true, force: true });
|
|
}
|
|
});
|
|
|
|
describe("readLocalGatewayPlatformStates", () => {
|
|
it("ignores stale gateway state when the gateway is not running", () => {
|
|
writeFileSync(
|
|
join(TEST_HOME, "gateway_state.json"),
|
|
JSON.stringify({
|
|
pid: 12345,
|
|
gateway_state: "running",
|
|
platforms: { telegram: { state: "connected" } },
|
|
}),
|
|
);
|
|
|
|
expect(readLocalGatewayPlatformStates(undefined, false)).toEqual({});
|
|
});
|
|
|
|
it("trusts the caller-provided gateway liveness state", () => {
|
|
writeFileSync(
|
|
join(TEST_HOME, "gateway_state.json"),
|
|
JSON.stringify({
|
|
pid: 99999,
|
|
gateway_state: "running",
|
|
platforms: { telegram: { state: "connected" } },
|
|
}),
|
|
);
|
|
|
|
expect(readLocalGatewayPlatformStates(undefined, true)).toMatchObject({
|
|
telegram: { state: "connected" },
|
|
});
|
|
});
|
|
|
|
it("returns live platform states and aliases known platform keys", () => {
|
|
writeFileSync(
|
|
join(TEST_HOME, "gateway_state.json"),
|
|
JSON.stringify({
|
|
pid: 12345,
|
|
gateway_state: "running",
|
|
platforms: {
|
|
telegram: { state: "connected", updated_at: "now" },
|
|
webhook: { state: "running" },
|
|
},
|
|
}),
|
|
);
|
|
|
|
expect(readLocalGatewayPlatformStates(undefined, true)).toMatchObject({
|
|
telegram: { state: "connected", updated_at: "now" },
|
|
webhook: { state: "running" },
|
|
webhooks: { state: "running" },
|
|
});
|
|
});
|
|
|
|
it("reads the root gateway state when the active profile is default", () => {
|
|
writeFileSync(
|
|
join(TEST_HOME, "gateway_state.json"),
|
|
JSON.stringify({
|
|
pid: 12345,
|
|
gateway_state: "running",
|
|
platforms: { telegram: { state: "connected" } },
|
|
}),
|
|
);
|
|
|
|
expect(readLocalGatewayPlatformStates("default", true)).toMatchObject({
|
|
telegram: { state: "connected" },
|
|
});
|
|
});
|
|
});
|