unstableDev.test.ts

import { fetch } from "undici";
import { vi } from "vitest";
import {
	registerWorker,
	startWorkerRegistry,
	stopWorkerRegistry,
} from "../dev-registry";

vi.unmock("undici");

/**
 * Sometimes the devRegistry killed by some reason, the register worker will to restart it.
 */
describe("unstable devRegistry testing", () => {
	afterAll(async () => {
		await stopWorkerRegistry();
	});

	it("should start the devRegistry if the devRegistry not start", async () => {
		await registerWorker("test", {
			port: 6789,
			protocol: "http",
			host: "localhost",
			mode: "local",
			durableObjects: [{ name: "testing", className: "testing" }],
		});
		const resp = await fetch("http://127.0.0.1:6284/workers");
		if (resp) {
			const parsedResp = (await resp.json()) as {
				test: unknown;
			};
			expect(parsedResp.test).toBeTruthy();
		}
	});

	it("should not restart the devRegistry if the devRegistry already start", async () => {
		await startWorkerRegistry();

		await fetch("http://127.0.0.1:6284/workers/init", {
			method: "POST",
			body: JSON.stringify({}),
		});

		await registerWorker("test", {
			port: 6789,
			protocol: "http",
			host: "localhost",
			mode: "local",
			durableObjects: [{ name: "testing", className: "testing" }],
		});

		const resp = await fetch("http://127.0.0.1:6284/workers");
		if (resp) {
			const parsedResp = (await resp.json()) as {
				test: unknown;
				init: unknown;
			};
			expect(parsedResp.init).toBeTruthy();
			expect(parsedResp.test).toBeTruthy();
		}
	});
});