mirror/formbricks
1
0
Fork 0
mirror of https://github.com/formbricks/formbricks.git synced 2026-05-24 19:49:19 -05:00
Code Issues Packages Projects Releases 179 Wiki Activity

adds test for schedulePipelineDrain when env vars are not set

Browse Source
This commit is contained in:
pandeymangg
2026-04-14 18:10:59 +05:30
committed by Bhagya Amarasinghe
parent 8d29b24352
commit 7c81cf119e
1 changed files with 54 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/web/app/lib/pipeline-queue.test.ts
+54 -5
View File
@@ -9,9 +9,13 @@ import {
} from "@/app/lib/pipeline-queue";
import { TPipelineInput } from "@/app/lib/types/pipelines";
const { mockGetRedisClient, mockTryLock } = vi.hoisted(() => ({
const { mockGetRedisClient, mockTryLock, mockConstants } = vi.hoisted(() => ({
mockGetRedisClient: vi.fn(),
mockTryLock: vi.fn(),
mockConstants: {
CRON_SECRET: "test-cron-secret" as string | undefined,
WEBAPP_URL: "https://test.formbricks.com" as string | undefined,
},
}));
vi.mock("@/lib/cache", () => ({
@@ -21,10 +25,7 @@ vi.mock("@/lib/cache", () => ({
},
}));
vi.mock("@/lib/constants", () => ({
CRON_SECRET: "test-cron-secret",
WEBAPP_URL: "https://test.formbricks.com",
}));
vi.mock("@/lib/constants", () => mockConstants);
vi.mock("@formbricks/logger", () => ({
logger: {
@@ -143,6 +144,8 @@ describe("pipeline-queue", () => {
vi.useFakeTimers();
vi.setSystemTime(new Date("2026-04-01T00:00:00.000Z"));
vi.clearAllMocks();
mockConstants.CRON_SECRET = "test-cron-secret";
mockConstants.WEBAPP_URL = "https://test.formbricks.com";
});
afterEach(async () => {
@@ -292,6 +295,52 @@ describe("pipeline-queue", () => {
expect(processJob).toHaveBeenCalledWith(expect.objectContaining({ jobId: queuedJob.jobId }));
});
test("schedulePipelineDrain skips drain when CRON_SECRET is missing", async () => {
mockConstants.CRON_SECRET = undefined;
const mockRedis = createMockRedis();
const mockFetch = vi.fn();
mockGetRedisClient.mockResolvedValue(mockRedis.client);
mockTryLock.mockResolvedValue({ ok: true, data: true });
vi.stubGlobal("fetch", mockFetch);
await enqueuePipelineJob(createPipelineInput("response-1"));
const processJob = vi.fn().mockRejectedValue(new Error("boom"));
await drainPipelineQueue({ processJob });
await vi.advanceTimersByTimeAsync(PIPELINE_RETRY_BASE_DELAY_MS);
expect(logger.warn).toHaveBeenCalledWith(
"Skipping pipeline drain trigger because CRON_SECRET or WEBAPP_URL is not configured"
);
expect(mockFetch).not.toHaveBeenCalled();
});
test("schedulePipelineDrain skips drain when WEBAPP_URL is missing", async () => {
mockConstants.WEBAPP_URL = undefined;
const mockRedis = createMockRedis();
const mockFetch = vi.fn();
mockGetRedisClient.mockResolvedValue(mockRedis.client);
mockTryLock.mockResolvedValue({ ok: true, data: true });
vi.stubGlobal("fetch", mockFetch);
await enqueuePipelineJob(createPipelineInput("response-1"));
const processJob = vi.fn().mockRejectedValue(new Error("boom"));
await drainPipelineQueue({ processJob });
await vi.advanceTimersByTimeAsync(PIPELINE_RETRY_BASE_DELAY_MS);
expect(logger.warn).toHaveBeenCalledWith(
"Skipping pipeline drain trigger because CRON_SECRET or WEBAPP_URL is not configured"
);
expect(mockFetch).not.toHaveBeenCalled();
});
test("logs non-2xx responses from the drain trigger endpoint", async () => {
const mockRedis = createMockRedis();
const mockFetch = vi.fn().mockResolvedValue(