test: migrate MQTT test to setupHarperWithFixture

Co-Authored-By: Claude Sonnet 4.6 (1M context) <noreply@anthropic.com>

Author: kriszyp

integrationTests/mqtt/mqtt.test.ts

@@ -19,9 +19,8 @@ import { resolve } from 'node:path';
 
 import mqtt, { type IClientOptions, type MqttClient } from 'mqtt';
 
-import { startHarper, teardownHarper, sendOperation, type ContextWithHarper } from '@harperfast/integration-testing';
+import { setupHarperWithFixture, teardownHarper, type ContextWithHarper } from '@harperfast/integration-testing';
 
-const PROJECT = 'mqtt-user-sub';
 const FIXTURE_PATH = resolve(import.meta.dirname, 'fixtures/mqtt-user-sub');
 
 let MQTT_URL = '';
@@ -258,54 +257,11 @@ suite(
 	{ skip: skipSuite },
 	(ctx: ContextWithHarper) => {
 		before(async () => {
-			await startHarper(ctx);
+			await setupHarperWithFixture(ctx, FIXTURE_PATH, { config: {}, env: {} });
 
 			const httpURL = ctx.harper.httpURL;
 			const wsScheme = httpURL.startsWith('https') ? 'wss' : 'ws';
 			MQTT_URL = process.env.MQTT_TEST_URL ?? `${httpURL.replace(/^https?/, wsScheme)}/mqtt`;
-
-			const deployBody = await sendOperation(ctx.harper, {
-				operation: 'deploy_component',
-				project: PROJECT,
-				package: FIXTURE_PATH,
-				restart: true,
-			});
-			strictEqual(deployBody.message, `Successfully deployed: ${PROJECT}, restarting Harper`);
-
-			// Poll until subscribe to broadcast/# returns a non-143 SUBACK (component registered).
-			const probe = freshUser('subscriber');
-			const probeToken = mintRS256Jwt(probe);
-			const deadline = Date.now() + 30_000;
-			let ready = false;
-			let lastError: unknown = null;
-			let lastCode: number | undefined;
-			let attempts = 0;
-			while (Date.now() < deadline) {
-				attempts++;
-				let client: MqttClient | undefined;
-				try {
-					client = await connect(MQTT_URL, jwtOpts(probeToken, probe));
-					const granted = await subscribe(client, 'broadcast/#');
-					lastCode = grantedCodes(granted)[0];
-					// 143 = no resource registered yet; anything else means component is up.
-					if (lastCode !== 143) {
-						ready = true;
-						break;
-					}
-				} catch (err) {
-					lastError = err;
-				} finally {
-					await endQuiet(client);
-				}
-				await sleep(500);
-			}
-			if (!ready) {
-				const err = lastError as any;
-				throw new Error(
-					`Timed out waiting for mqtt-user-sub after ${attempts} attempts. ` +
-						`Last SUBACK code: ${lastCode ?? 'n/a'}. Last error: ${err?.message ?? err}`
-				);
-			}
 		});
 
 		after(async () => {