mirror/formbricks
1
0
Fork 0
mirror of https://github.com/formbricks/formbricks.git synced 2026-03-05 00:48:03 -06:00
Code Issues Packages Projects Releases 137 Wiki Activity

fixes tests

Browse Source
This commit is contained in:
pandeymangg
2026-02-26 16:18:22 +05:30
parent f7506d14b0
commit 343ce4568a
1 changed files with 8 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
apps/web/lib/connector/pipeline-handler.test.ts
View File

@@ -55,7 +55,6 @@ function createConnector(
status: "active",
environmentId: "env-1",
lastSyncAt: null,
errorMessage: null,
formbricksMappings: [
{
id: "map-1",
@@ -124,7 +123,7 @@ describe("handleConnectorPipeline", () => {
expect(updateConnector).not.toHaveBeenCalled();
});
test("updates connector to error when Hub returns no-config (HUB_API_KEY not set)", async () => {
test("does not update connector when Hub returns no-config (HUB_API_KEY not set)", async () => {
vi.mocked(getConnectorsBySurveyId).mockResolvedValue([createConnector()]);
vi.mocked(transformResponseToFeedbackRecords).mockReturnValue(oneFeedbackRecord as any);
mockCreateFeedbackRecordsBatch.mockResolvedValue({
@@ -134,13 +133,10 @@ describe("handleConnectorPipeline", () => {
await handleConnectorPipeline(mockResponse, mockSurvey, "env-1");
expect(mockCreateFeedbackRecordsBatch).toHaveBeenCalledWith(oneFeedbackRecord);
expect(updateConnector).toHaveBeenCalledWith("conn-1", "env-1", {
status: "error",
errorMessage: expect.stringContaining("HUB_API_KEY"),
});
expect(updateConnector).not.toHaveBeenCalled();
});
test("sends records to Hub and updates connector to active on full success", async () => {
test("sends records to Hub and updates lastSyncAt on full success", async () => {
vi.mocked(getConnectorsBySurveyId).mockResolvedValue([createConnector()]);
vi.mocked(transformResponseToFeedbackRecords).mockReturnValue(oneFeedbackRecord as any);
mockCreateFeedbackRecordsBatch.mockResolvedValue({
@@ -151,13 +147,11 @@ describe("handleConnectorPipeline", () => {
expect(mockCreateFeedbackRecordsBatch).toHaveBeenCalledWith(oneFeedbackRecord);
expect(updateConnector).toHaveBeenCalledWith("conn-1", "env-1", {
status: "active",
errorMessage: null,
lastSyncAt: expect.any(Date),
});
});
test("updates connector to error when all Hub creates fail", async () => {
test("does not update connector when all Hub creates fail", async () => {
vi.mocked(getConnectorsBySurveyId).mockResolvedValue([createConnector()]);
vi.mocked(transformResponseToFeedbackRecords).mockReturnValue(oneFeedbackRecord as any);
mockCreateFeedbackRecordsBatch.mockResolvedValue({
@@ -168,13 +162,10 @@ describe("handleConnectorPipeline", () => {
await handleConnectorPipeline(mockResponse, mockSurvey, "env-1");
expect(updateConnector).toHaveBeenCalledWith("conn-1", "env-1", {
status: "error",
errorMessage: expect.stringContaining("Failed to send FeedbackRecords"),
});
expect(updateConnector).not.toHaveBeenCalled();
});
test("updates connector to active with partial message when some creates fail", async () => {
test("updates lastSyncAt on partial failure when some creates succeed", async () => {
const twoRecords = [...oneFeedbackRecord, { ...oneFeedbackRecord[0], field_id: "el-2", value_number: 3 }];
const baseMapping = {
createdAt: new Date(),
@@ -203,13 +194,11 @@ describe("handleConnectorPipeline", () => {
await handleConnectorPipeline(mockResponse, mockSurvey, "env-1");
expect(updateConnector).toHaveBeenCalledWith("conn-1", "env-1", {
status: "active",
errorMessage: "Partial failure: 1/2 records sent",
lastSyncAt: expect.any(Date),
});
});
test("updates connector to error when transform throws", async () => {
test("does not update connector when transform throws", async () => {
vi.mocked(getConnectorsBySurveyId).mockResolvedValue([createConnector()]);
vi.mocked(transformResponseToFeedbackRecords).mockImplementation(() => {
throw new Error("Transform failed");
@@ -217,9 +206,6 @@ describe("handleConnectorPipeline", () => {
await handleConnectorPipeline(mockResponse, mockSurvey, "env-1");
expect(updateConnector).toHaveBeenCalledWith("conn-1", "env-1", {
status: "error",
errorMessage: "Transform failed",
});
expect(updateConnector).not.toHaveBeenCalled();
});
});