1 files changed, 32 insertions, 30 deletions
diff --git a/packages/integrations/cloudflare/test/wasm-directory.test.js b/packages/integrations/cloudflare/test/wasm-directory.test.js
index 0f387a660..30d709ad3 100644
--- a/packages/integrations/cloudflare/test/wasm-directory.test.js
+++ b/packages/integrations/cloudflare/test/wasm-directory.test.js
@@ -1,36 +1,38 @@
-import { loadFixture, runCLI } from './test-utils.js';
-import { expect } from 'chai';
+import { expect } from "chai";
+import { fileURLToPath } from "node:url";
+import { astroCli, wranglerCli } from "./_test-utils.js";
 
-describe('Wasm directory mode import', () => {
-	/** @type {import('./test-utils.js').Fixture} */
-	let fixture;
-	/** @type {import('./test-utils.js').WranglerCLI} */
-	let cli;
+const root = new URL("./fixtures/wasm-directory/", import.meta.url);
 
-	before(async function () {
-		fixture = await loadFixture({
-			root: './fixtures/wasm-directory/',
-		});
-		await fixture.build();
+describe("Wasm directory mode import", () => {
+  let wrangler;
+  before(async () => {
+    await astroCli(fileURLToPath(root), "build");
 
-		cli = await runCLI('./fixtures/wasm-directory/', {
-			silent: true,
-			onTimeout: (ex) => {
-				console.log(ex);
-				// if fail to start, skip for now as it's very flaky
-				this.skip();
-			},
-		});
-	});
+    wrangler = wranglerCli(fileURLToPath(root));
+    await new Promise((resolve) => {
+      wrangler.stdout.on("data", (data) => {
+        console.log("[stdout]", data.toString());
+        if (data.toString().includes("http://127.0.0.1:8788")) resolve();
+      });
+      wrangler.stderr.on("data", (data) => {
+        console.log("[stderr]", data.toString());
+      });
+    });
+  });
 
-	after(async () => {
-		await cli?.stop();
-	});
+  after((done) => {
+    wrangler.kill();
+    setTimeout(() => {
+      console.log("CLEANED");
+      done();
+    }, 1000);
+  });
 
-	it('can render', async () => {
-		let res = await fetch(`http://127.0.0.1:${cli.port}/`);
-		expect(res.status).to.equal(200);
-		const json = await res.json();
-		expect(json).to.deep.equal({ answer: 42 });
-	});
+  it("can render", async () => {
+    let res = await fetch(`http://127.0.0.1:8788/`);
+    expect(res.status).to.equal(200);
+    const json = await res.json();
+    expect(json).to.deep.equal({ answer: 42 });
+  });
 });