chore: implement track fallback

server/tests/unit/queue/queue-utils.test.ts

@@ -0,0 +1,60 @@
+import { afterEach, beforeEach, describe, expect, mock, test } from "bun:test";
+import { ApiVersion, AppEnv } from "@autumn/shared";
+
+const mockState = {
+	commands: [] as Record<string, unknown>[],
+};
+
+mock.module("@/queue/initSqs.js", () => ({
+	QUEUE_URL: "https://sqs.eu-west-1.amazonaws.com/123456789012/primary.fifo",
+	getSqsClient: () => ({
+		send: async (command: { input: Record<string, unknown> }) => {
+			mockState.commands.push(command.input);
+		},
+	}),
+}));
+
+import { JobName } from "@/queue/JobName.js";
+import { addTaskToQueue } from "@/queue/queueUtils.js";
+
+describe("addTaskToQueue queue override", () => {
+	const originalSqsQueueUrl = process.env.SQS_QUEUE_URL;
+	const originalQueueUrl = process.env.QUEUE_URL;
+
+	beforeEach(() => {
+		mockState.commands = [];
+		delete process.env.SQS_QUEUE_URL;
+		delete process.env.QUEUE_URL;
+	});
+
+	afterEach(() => {
+		process.env.SQS_QUEUE_URL = originalSqsQueueUrl;
+		process.env.QUEUE_URL = originalQueueUrl;
+	});
+
+	test("uses the provided SQS queueUrl override", async () => {
+		await addTaskToQueue({
+			jobName: JobName.Track,
+			queueUrl:
+				"https://sqs.eu-west-1.amazonaws.com/123456789012/track-dev.fifo",
+			messageGroupId: "org:sandbox:cus_123",
+			messageDeduplicationId: "idem_123",
+			payload: {
+				orgId: "org_123",
+				env: AppEnv.Sandbox,
+				apiVersion: ApiVersion.V2_1,
+				body: {
+					customer_id: "cus_123",
+					feature_id: "messages",
+				},
+			},
+		});
+
+		expect(mockState.commands).toHaveLength(1);
+		expect(mockState.commands[0]?.QueueUrl).toBe(
+			"https://sqs.eu-west-1.amazonaws.com/123456789012/track-dev.fifo",
+		);
+		expect(mockState.commands[0]?.MessageGroupId).toBe("org:sandbox:cus_123");
+		expect(mockState.commands[0]?.MessageDeduplicationId).toBe("idem_123");
+	});
+});