adds tests

Author: skyrpex

src/extension.ts

@@ -10,7 +10,10 @@ import statusBar from "./plugins/status-bar.ts";
 import { PluginManager } from "./plugins.ts";
 import { createCliStatusTracker } from "./utils/cli.ts";
 import { createLocalStackContainerStatusTracker } from "./utils/localstack-container.ts";
-import { createLocalStackInstanceStatusTracker } from "./utils/localstack-instance.ts";
+import {
+	createHealthStatusTracker,
+	createLocalStackInstanceStatusTracker,
+} from "./utils/localstack-instance.ts";
 import { getOrCreateExtensionSessionId } from "./utils/manage.ts";
 import { createSetupStatusTracker } from "./utils/setup.ts";
 import { createTelemetry } from "./utils/telemetry.ts";
@@ -57,10 +60,11 @@ export async function activate(context: ExtensionContext) {
 		);
 		context.subscriptions.push(containerStatusTracker);
 
+		const healthCheckStatusTracker = createHealthStatusTracker(timeTracker);
 		const localStackStatusTracker = createLocalStackInstanceStatusTracker(
 			containerStatusTracker,
+			healthCheckStatusTracker,
 			outputChannel,
-			timeTracker,
 		);
 		context.subscriptions.push(localStackStatusTracker);
 

src/test/localstack-instance.test.ts

@@ -0,0 +1,82 @@
+import * as assert from "node:assert";
+import { setImmediate } from "node:timers/promises";
+
+import { window } from "vscode";
+import type { LogOutputChannel } from "vscode";
+
+import { createValueEmitter } from "../utils/emitter.ts";
+import type {
+	LocalStackContainerStatus,
+	LocalStackContainerStatusTracker,
+} from "../utils/localstack-container.ts";
+import { createLocalStackInstanceStatusTracker } from "../utils/localstack-instance.ts";
+import type {
+	HealthStatus,
+	HealthStatusTracker,
+} from "../utils/localstack-instance.ts";
+
+function createFixtures() {
+	const containerStatus = createValueEmitter<LocalStackContainerStatus>();
+	const containerStatusTracker: LocalStackContainerStatusTracker = {
+		status() {
+			return containerStatus.value();
+		},
+		onChange(callback) {
+			containerStatus.onChange(callback);
+		},
+		dispose() {},
+	};
+
+	const healthStatus = createValueEmitter<HealthStatus>();
+	const healthCheckStatusTracker: HealthStatusTracker = {
+		start() {},
+		stop() {},
+		status() {
+			return healthStatus.value();
+		},
+		onChange(callback) {
+			healthStatus.onChange(callback);
+		},
+		dispose() {},
+	};
+
+	const outputChannel = window.createOutputChannel("LocalStack", {
+		log: true,
+	});
+
+	const tracker = createLocalStackInstanceStatusTracker(
+		containerStatusTracker,
+		healthCheckStatusTracker,
+		outputChannel,
+	);
+
+	return {
+		containerStatus,
+		healthStatus,
+		tracker,
+	};
+}
+
+suite("LocalStack Instance Test Suite", () => {
+	test("Derives LocalStack instance status correctly", async () => {
+		const { containerStatus, healthStatus, tracker } = createFixtures();
+
+		///////////////////////////////////////////////////////////////////////////
+		containerStatus.setValue(undefined);
+		healthStatus.setValue(undefined);
+		await setImmediate();
+		assert.strictEqual(tracker.status(), undefined);
+
+		///////////////////////////////////////////////////////////////////////////
+		containerStatus.setValue("running");
+		healthStatus.setValue("unhealthy");
+		await setImmediate();
+		assert.strictEqual(tracker.status(), "starting");
+
+		///////////////////////////////////////////////////////////////////////////
+		containerStatus.setValue("running");
+		healthStatus.setValue("healthy");
+		await setImmediate();
+		assert.strictEqual(tracker.status(), "running");
+	});
+});

src/utils/localstack-instance.ts

@@ -27,14 +27,12 @@ export interface LocalStackInstanceStatusTracker extends Disposable {
  */
 export function createLocalStackInstanceStatusTracker(
 	containerStatusTracker: LocalStackContainerStatusTracker,
+	healthCheckStatusTracker: HealthStatusTracker,
 	outputChannel: LogOutputChannel,
-	timeTracker: TimeTracker,
 ): LocalStackInstanceStatusTracker {
 	let containerStatus: LocalStackContainerStatus | undefined;
 	const status = createValueEmitter<LocalStackInstanceStatus>();
 
-	const healthCheckStatusTracker = createHealthStatusTracker(timeTracker);
-
 	const setStatus = (newStatus: LocalStackInstanceStatus) => {
 		status.setValue(newStatus);
 	};
@@ -141,16 +139,16 @@ function getLocalStackStatus(
 	return "stopped";
 }
 
-type HealthStatus = "healthy" | "unhealthy";
+export type HealthStatus = "healthy" | "unhealthy";
 
-interface HealthStatusTracker extends Disposable {
+export interface HealthStatusTracker extends Disposable {
 	status(): HealthStatus | undefined;
 	start(): void;
 	stop(): void;
 	onChange(callback: (status: HealthStatus | undefined) => void): void;
 }
 
-function createHealthStatusTracker(
+export function createHealthStatusTracker(
 	timeTracker: TimeTracker,
 ): HealthStatusTracker {
 	const status = createValueEmitter<HealthStatus | undefined>();