mirror of
https://github.com/formbricks/formbricks.git
synced 2025-12-30 10:19:51 -06:00
Compare commits
6 Commits
fix/keyboa
...
v3.15.0
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
a59dc8c109 | ||
|
|
975a3a2157 | ||
|
|
8c3e816ccd | ||
|
|
6ddc91ee85 | ||
|
|
14023ca8a9 | ||
|
|
385e8a4262 |
@@ -220,6 +220,9 @@ describe("MainNavigation", () => {
|
||||
const mockSignOut = vi.fn().mockResolvedValue({ url: "/auth/login" });
|
||||
vi.mocked(useSignOut).mockReturnValue({ signOut: mockSignOut });
|
||||
|
||||
// Set up localStorage spy on the mocked localStorage
|
||||
const removeItemSpy = vi.spyOn(window.localStorage, "removeItem");
|
||||
|
||||
render(<MainNavigation {...defaultProps} />);
|
||||
|
||||
// Find the avatar and get its parent div which acts as the trigger
|
||||
@@ -240,6 +243,9 @@ describe("MainNavigation", () => {
|
||||
const logoutButton = screen.getByText("common.logout");
|
||||
await userEvent.click(logoutButton);
|
||||
|
||||
// Verify localStorage.removeItem is called with the correct key
|
||||
expect(removeItemSpy).toHaveBeenCalledWith("formbricks-environment-id");
|
||||
|
||||
expect(mockSignOut).toHaveBeenCalledWith({
|
||||
reason: "user_initiated",
|
||||
redirectUrl: "/auth/login",
|
||||
@@ -247,9 +253,13 @@ describe("MainNavigation", () => {
|
||||
redirect: false,
|
||||
callbackUrl: "/auth/login",
|
||||
});
|
||||
|
||||
await waitFor(() => {
|
||||
expect(mockRouterPush).toHaveBeenCalledWith("/auth/login");
|
||||
});
|
||||
|
||||
// Clean up spy
|
||||
removeItemSpy.mockRestore();
|
||||
});
|
||||
|
||||
test("handles organization switching", async () => {
|
||||
|
||||
@@ -4,6 +4,7 @@ import { getLatestStableFbReleaseAction } from "@/app/(app)/environments/[enviro
|
||||
import { NavigationLink } from "@/app/(app)/environments/[environmentId]/components/NavigationLink";
|
||||
import FBLogo from "@/images/formbricks-wordmark.svg";
|
||||
import { cn } from "@/lib/cn";
|
||||
import { FORMBRICKS_ENVIRONMENT_ID_LS } from "@/lib/localStorage";
|
||||
import { getAccessFlags } from "@/lib/membership/utils";
|
||||
import { capitalizeFirstLetter } from "@/lib/utils/strings";
|
||||
import { useSignOut } from "@/modules/auth/hooks/use-sign-out";
|
||||
@@ -390,6 +391,8 @@ export const MainNavigation = ({
|
||||
|
||||
<DropdownMenuItem
|
||||
onClick={async () => {
|
||||
localStorage.removeItem(FORMBRICKS_ENVIRONMENT_ID_LS);
|
||||
|
||||
const route = await signOutWithAudit({
|
||||
reason: "user_initiated",
|
||||
redirectUrl: "/auth/login",
|
||||
|
||||
@@ -14,41 +14,64 @@ describe("ClientEnvironmentRedirect", () => {
|
||||
cleanup();
|
||||
});
|
||||
|
||||
test("should redirect to the provided environment ID when no last environment exists", () => {
|
||||
test("should redirect to the first environment ID when no last environment exists", () => {
|
||||
const mockPush = vi.fn();
|
||||
vi.mocked(useRouter).mockReturnValue({ push: mockPush } as any);
|
||||
|
||||
// Mock localStorage
|
||||
const localStorageMock = {
|
||||
getItem: vi.fn().mockReturnValue(null),
|
||||
removeItem: vi.fn(),
|
||||
};
|
||||
|
||||
Object.defineProperty(window, "localStorage", {
|
||||
value: localStorageMock,
|
||||
});
|
||||
|
||||
render(<ClientEnvironmentRedirect environmentId="test-env-id" />);
|
||||
render(<ClientEnvironmentRedirect userEnvironments={["test-env-id"]} />);
|
||||
|
||||
expect(mockPush).toHaveBeenCalledWith("/environments/test-env-id");
|
||||
});
|
||||
|
||||
test("should redirect to the last environment ID when it exists in localStorage", () => {
|
||||
test("should redirect to the last environment ID when it exists in localStorage and is valid", () => {
|
||||
const mockPush = vi.fn();
|
||||
vi.mocked(useRouter).mockReturnValue({ push: mockPush } as any);
|
||||
|
||||
// Mock localStorage with a last environment ID
|
||||
const localStorageMock = {
|
||||
getItem: vi.fn().mockReturnValue("last-env-id"),
|
||||
removeItem: vi.fn(),
|
||||
};
|
||||
Object.defineProperty(window, "localStorage", {
|
||||
value: localStorageMock,
|
||||
});
|
||||
|
||||
render(<ClientEnvironmentRedirect environmentId="test-env-id" />);
|
||||
render(<ClientEnvironmentRedirect userEnvironments={["last-env-id", "other-env-id"]} />);
|
||||
|
||||
expect(localStorageMock.getItem).toHaveBeenCalledWith(FORMBRICKS_ENVIRONMENT_ID_LS);
|
||||
expect(mockPush).toHaveBeenCalledWith("/environments/last-env-id");
|
||||
});
|
||||
|
||||
test("should clear invalid environment ID and redirect to default when stored ID is not in user environments", () => {
|
||||
const mockPush = vi.fn();
|
||||
vi.mocked(useRouter).mockReturnValue({ push: mockPush } as any);
|
||||
|
||||
// Mock localStorage with an invalid environment ID
|
||||
const localStorageMock = {
|
||||
getItem: vi.fn().mockReturnValue("invalid-env-id"),
|
||||
removeItem: vi.fn(),
|
||||
};
|
||||
Object.defineProperty(window, "localStorage", {
|
||||
value: localStorageMock,
|
||||
});
|
||||
|
||||
render(<ClientEnvironmentRedirect userEnvironments={["valid-env-1", "valid-env-2"]} />);
|
||||
|
||||
expect(localStorageMock.getItem).toHaveBeenCalledWith(FORMBRICKS_ENVIRONMENT_ID_LS);
|
||||
expect(localStorageMock.removeItem).toHaveBeenCalledWith(FORMBRICKS_ENVIRONMENT_ID_LS);
|
||||
expect(mockPush).toHaveBeenCalledWith("/environments/valid-env-1");
|
||||
});
|
||||
|
||||
test("should update redirect when environment ID prop changes", () => {
|
||||
const mockPush = vi.fn();
|
||||
vi.mocked(useRouter).mockReturnValue({ push: mockPush } as any);
|
||||
@@ -56,19 +79,20 @@ describe("ClientEnvironmentRedirect", () => {
|
||||
// Mock localStorage
|
||||
const localStorageMock = {
|
||||
getItem: vi.fn().mockReturnValue(null),
|
||||
removeItem: vi.fn(),
|
||||
};
|
||||
Object.defineProperty(window, "localStorage", {
|
||||
value: localStorageMock,
|
||||
});
|
||||
|
||||
const { rerender } = render(<ClientEnvironmentRedirect environmentId="initial-env-id" />);
|
||||
const { rerender } = render(<ClientEnvironmentRedirect userEnvironments={["initial-env-id"]} />);
|
||||
expect(mockPush).toHaveBeenCalledWith("/environments/initial-env-id");
|
||||
|
||||
// Clear mock calls
|
||||
mockPush.mockClear();
|
||||
|
||||
// Rerender with new environment ID
|
||||
rerender(<ClientEnvironmentRedirect environmentId="new-env-id" />);
|
||||
rerender(<ClientEnvironmentRedirect userEnvironments={["new-env-id"]} />);
|
||||
expect(mockPush).toHaveBeenCalledWith("/environments/new-env-id");
|
||||
});
|
||||
});
|
||||
|
||||
@@ -5,22 +5,23 @@ import { useRouter } from "next/navigation";
|
||||
import { useEffect } from "react";
|
||||
|
||||
interface ClientEnvironmentRedirectProps {
|
||||
environmentId: string;
|
||||
userEnvironments: string[];
|
||||
}
|
||||
|
||||
const ClientEnvironmentRedirect = ({ environmentId }: ClientEnvironmentRedirectProps) => {
|
||||
const ClientEnvironmentRedirect = ({ userEnvironments }: ClientEnvironmentRedirectProps) => {
|
||||
const router = useRouter();
|
||||
|
||||
useEffect(() => {
|
||||
const lastEnvironmentId = localStorage.getItem(FORMBRICKS_ENVIRONMENT_ID_LS);
|
||||
|
||||
if (lastEnvironmentId) {
|
||||
// Redirect to the last environment the user was in
|
||||
if (lastEnvironmentId && userEnvironments.includes(lastEnvironmentId)) {
|
||||
router.push(`/environments/${lastEnvironmentId}`);
|
||||
} else {
|
||||
router.push(`/environments/${environmentId}`);
|
||||
// If the last environmentId is not valid, remove it from localStorage and redirect to the provided environmentId
|
||||
localStorage.removeItem(FORMBRICKS_ENVIRONMENT_ID_LS);
|
||||
router.push(`/environments/${userEnvironments[0]}`);
|
||||
}
|
||||
}, [environmentId, router]);
|
||||
}, [userEnvironments, router]);
|
||||
|
||||
return null;
|
||||
};
|
||||
|
||||
@@ -1,13 +1,13 @@
|
||||
import { checkForRequiredFields } from "./utils";
|
||||
import { describe, test, expect } from "vitest";
|
||||
import { authenticateRequest } from "@/app/api/v1/auth";
|
||||
import { responses } from "@/app/lib/api/response";
|
||||
import { hasUserEnvironmentAccess } from "@/lib/environment/auth";
|
||||
import { hasPermission } from "@/modules/organization/settings/api-keys/lib/utils";
|
||||
import { NextRequest } from "next/server";
|
||||
import { Session } from "next-auth";
|
||||
import { NextRequest } from "next/server";
|
||||
import { describe, expect, test } from "vitest";
|
||||
import { vi } from "vitest";
|
||||
import { TAuthenticationApiKey } from "@formbricks/types/auth";
|
||||
import { authenticateRequest } from "@/app/api/v1/auth";
|
||||
import { checkForRequiredFields } from "./utils";
|
||||
import { checkAuth } from "./utils";
|
||||
|
||||
// Create mock response objects
|
||||
@@ -16,189 +16,197 @@ const mockNotAuthenticatedResponse = new Response("Not authenticated", { status:
|
||||
const mockUnauthorizedResponse = new Response("Unauthorized", { status: 401 });
|
||||
|
||||
vi.mock("@/app/api/v1/auth", () => ({
|
||||
authenticateRequest: vi.fn(),
|
||||
authenticateRequest: vi.fn(),
|
||||
}));
|
||||
|
||||
vi.mock("@/lib/environment/auth", () => ({
|
||||
hasUserEnvironmentAccess: vi.fn(),
|
||||
hasUserEnvironmentAccess: vi.fn(),
|
||||
}));
|
||||
|
||||
vi.mock("@/modules/organization/settings/api-keys/lib/utils", () => ({
|
||||
hasPermission: vi.fn(),
|
||||
hasPermission: vi.fn(),
|
||||
}));
|
||||
|
||||
vi.mock("@/app/lib/api/response", () => ({
|
||||
responses: {
|
||||
badRequestResponse: vi.fn(() => mockBadRequestResponse),
|
||||
notAuthenticatedResponse: vi.fn(() => mockNotAuthenticatedResponse),
|
||||
unauthorizedResponse: vi.fn(() => mockUnauthorizedResponse),
|
||||
},
|
||||
responses: {
|
||||
badRequestResponse: vi.fn(() => mockBadRequestResponse),
|
||||
notAuthenticatedResponse: vi.fn(() => mockNotAuthenticatedResponse),
|
||||
unauthorizedResponse: vi.fn(() => mockUnauthorizedResponse),
|
||||
},
|
||||
}));
|
||||
|
||||
describe("checkForRequiredFields", () => {
|
||||
test("should return undefined when all required fields are present", () => {
|
||||
const result = checkForRequiredFields("env-123", "image/png", "test-file.png");
|
||||
expect(result).toBeUndefined();
|
||||
});
|
||||
test("should return undefined when all required fields are present", () => {
|
||||
const result = checkForRequiredFields("env-123", "image/png", "test-file.png");
|
||||
expect(result).toBeUndefined();
|
||||
});
|
||||
|
||||
test("should return bad request response when environmentId is missing", () => {
|
||||
const result = checkForRequiredFields("", "image/png", "test-file.png");
|
||||
expect(responses.badRequestResponse).toHaveBeenCalledWith("environmentId is required");
|
||||
expect(result).toBe(mockBadRequestResponse);
|
||||
});
|
||||
test("should return bad request response when environmentId is missing", () => {
|
||||
const result = checkForRequiredFields("", "image/png", "test-file.png");
|
||||
expect(responses.badRequestResponse).toHaveBeenCalledWith("environmentId is required");
|
||||
expect(result).toBe(mockBadRequestResponse);
|
||||
});
|
||||
|
||||
test("should return bad request response when fileType is missing", () => {
|
||||
const result = checkForRequiredFields("env-123", "", "test-file.png");
|
||||
expect(responses.badRequestResponse).toHaveBeenCalledWith("contentType is required");
|
||||
expect(result).toBe(mockBadRequestResponse);
|
||||
});
|
||||
test("should return bad request response when fileType is missing", () => {
|
||||
const result = checkForRequiredFields("env-123", "", "test-file.png");
|
||||
expect(responses.badRequestResponse).toHaveBeenCalledWith("contentType is required");
|
||||
expect(result).toBe(mockBadRequestResponse);
|
||||
});
|
||||
|
||||
test("should return bad request response when encodedFileName is missing", () => {
|
||||
const result = checkForRequiredFields("env-123", "image/png", "");
|
||||
expect(responses.badRequestResponse).toHaveBeenCalledWith("fileName is required");
|
||||
expect(result).toBe(mockBadRequestResponse);
|
||||
});
|
||||
test("should return bad request response when encodedFileName is missing", () => {
|
||||
const result = checkForRequiredFields("env-123", "image/png", "");
|
||||
expect(responses.badRequestResponse).toHaveBeenCalledWith("fileName is required");
|
||||
expect(result).toBe(mockBadRequestResponse);
|
||||
});
|
||||
|
||||
test("should return bad request response when environmentId is undefined", () => {
|
||||
const result = checkForRequiredFields(undefined as any, "image/png", "test-file.png");
|
||||
expect(responses.badRequestResponse).toHaveBeenCalledWith("environmentId is required");
|
||||
expect(result).toBe(mockBadRequestResponse);
|
||||
});
|
||||
test("should return bad request response when environmentId is undefined", () => {
|
||||
const result = checkForRequiredFields(undefined as any, "image/png", "test-file.png");
|
||||
expect(responses.badRequestResponse).toHaveBeenCalledWith("environmentId is required");
|
||||
expect(result).toBe(mockBadRequestResponse);
|
||||
});
|
||||
|
||||
test("should return bad request response when fileType is undefined", () => {
|
||||
const result = checkForRequiredFields("env-123", undefined as any, "test-file.png");
|
||||
expect(responses.badRequestResponse).toHaveBeenCalledWith("contentType is required");
|
||||
expect(result).toBe(mockBadRequestResponse);
|
||||
});
|
||||
test("should return bad request response when fileType is undefined", () => {
|
||||
const result = checkForRequiredFields("env-123", undefined as any, "test-file.png");
|
||||
expect(responses.badRequestResponse).toHaveBeenCalledWith("contentType is required");
|
||||
expect(result).toBe(mockBadRequestResponse);
|
||||
});
|
||||
|
||||
test("should return bad request response when encodedFileName is undefined", () => {
|
||||
const result = checkForRequiredFields("env-123", "image/png", undefined as any);
|
||||
expect(responses.badRequestResponse).toHaveBeenCalledWith("fileName is required");
|
||||
expect(result).toBe(mockBadRequestResponse);
|
||||
});
|
||||
test("should return bad request response when encodedFileName is undefined", () => {
|
||||
const result = checkForRequiredFields("env-123", "image/png", undefined as any);
|
||||
expect(responses.badRequestResponse).toHaveBeenCalledWith("fileName is required");
|
||||
expect(result).toBe(mockBadRequestResponse);
|
||||
});
|
||||
});
|
||||
|
||||
describe("checkAuth", () => {
|
||||
const environmentId = "env-123";
|
||||
const mockRequest = new NextRequest("http://localhost:3000/api/test");
|
||||
const environmentId = "env-123";
|
||||
const mockRequest = new NextRequest("http://localhost:3000/api/test");
|
||||
|
||||
test("returns notAuthenticatedResponse when no session and no authentication", async () => {
|
||||
vi.mocked(authenticateRequest).mockResolvedValue(null);
|
||||
test("returns notAuthenticatedResponse when no session and no authentication", async () => {
|
||||
vi.mocked(authenticateRequest).mockResolvedValue(null);
|
||||
|
||||
const result = await checkAuth(null, environmentId, mockRequest);
|
||||
const result = await checkAuth(null, environmentId, mockRequest);
|
||||
|
||||
expect(authenticateRequest).toHaveBeenCalledWith(mockRequest);
|
||||
expect(responses.notAuthenticatedResponse).toHaveBeenCalled();
|
||||
expect(result).toBe(mockNotAuthenticatedResponse);
|
||||
});
|
||||
expect(authenticateRequest).toHaveBeenCalledWith(mockRequest);
|
||||
expect(responses.notAuthenticatedResponse).toHaveBeenCalled();
|
||||
expect(result).toBe(mockNotAuthenticatedResponse);
|
||||
});
|
||||
|
||||
test("returns unauthorizedResponse when no session and authentication lacks POST permission", async () => {
|
||||
const mockAuthentication: TAuthenticationApiKey = {
|
||||
type: "apiKey",
|
||||
environmentPermissions: [
|
||||
{
|
||||
environmentId: "env-123",
|
||||
permission: "read",
|
||||
environmentType: "development",
|
||||
projectId: "project-1",
|
||||
projectName: "Project 1",
|
||||
},
|
||||
],
|
||||
hashedApiKey: "hashed-key",
|
||||
apiKeyId: "api-key-id",
|
||||
organizationId: "org-id",
|
||||
organizationAccess: {
|
||||
accessControl: {},
|
||||
},
|
||||
};
|
||||
test("returns unauthorizedResponse when no session and authentication lacks POST permission", async () => {
|
||||
const mockAuthentication: TAuthenticationApiKey = {
|
||||
type: "apiKey",
|
||||
environmentPermissions: [
|
||||
{
|
||||
environmentId: "env-123",
|
||||
permission: "read",
|
||||
environmentType: "development",
|
||||
projectId: "project-1",
|
||||
projectName: "Project 1",
|
||||
},
|
||||
],
|
||||
hashedApiKey: "hashed-key",
|
||||
apiKeyId: "api-key-id",
|
||||
organizationId: "org-id",
|
||||
organizationAccess: {
|
||||
accessControl: {},
|
||||
},
|
||||
};
|
||||
|
||||
vi.mocked(authenticateRequest).mockResolvedValue(mockAuthentication);
|
||||
vi.mocked(hasPermission).mockReturnValue(false);
|
||||
vi.mocked(authenticateRequest).mockResolvedValue(mockAuthentication);
|
||||
vi.mocked(hasPermission).mockReturnValue(false);
|
||||
|
||||
const result = await checkAuth(null, environmentId, mockRequest);
|
||||
const result = await checkAuth(null, environmentId, mockRequest);
|
||||
|
||||
expect(authenticateRequest).toHaveBeenCalledWith(mockRequest);
|
||||
expect(hasPermission).toHaveBeenCalledWith(mockAuthentication.environmentPermissions, environmentId, "POST");
|
||||
expect(responses.unauthorizedResponse).toHaveBeenCalled();
|
||||
expect(result).toBe(mockUnauthorizedResponse);
|
||||
});
|
||||
expect(authenticateRequest).toHaveBeenCalledWith(mockRequest);
|
||||
expect(hasPermission).toHaveBeenCalledWith(
|
||||
mockAuthentication.environmentPermissions,
|
||||
environmentId,
|
||||
"POST"
|
||||
);
|
||||
expect(responses.unauthorizedResponse).toHaveBeenCalled();
|
||||
expect(result).toBe(mockUnauthorizedResponse);
|
||||
});
|
||||
|
||||
test("returns undefined when no session and authentication has POST permission", async () => {
|
||||
const mockAuthentication: TAuthenticationApiKey = {
|
||||
type: "apiKey",
|
||||
environmentPermissions: [
|
||||
{
|
||||
environmentId: "env-123",
|
||||
permission: "write",
|
||||
environmentType: "development",
|
||||
projectId: "project-1",
|
||||
projectName: "Project 1",
|
||||
},
|
||||
],
|
||||
hashedApiKey: "hashed-key",
|
||||
apiKeyId: "api-key-id",
|
||||
organizationId: "org-id",
|
||||
organizationAccess: {
|
||||
accessControl: {},
|
||||
},
|
||||
};
|
||||
test("returns undefined when no session and authentication has POST permission", async () => {
|
||||
const mockAuthentication: TAuthenticationApiKey = {
|
||||
type: "apiKey",
|
||||
environmentPermissions: [
|
||||
{
|
||||
environmentId: "env-123",
|
||||
permission: "write",
|
||||
environmentType: "development",
|
||||
projectId: "project-1",
|
||||
projectName: "Project 1",
|
||||
},
|
||||
],
|
||||
hashedApiKey: "hashed-key",
|
||||
apiKeyId: "api-key-id",
|
||||
organizationId: "org-id",
|
||||
organizationAccess: {
|
||||
accessControl: {},
|
||||
},
|
||||
};
|
||||
|
||||
vi.mocked(authenticateRequest).mockResolvedValue(mockAuthentication);
|
||||
vi.mocked(hasPermission).mockReturnValue(true);
|
||||
vi.mocked(authenticateRequest).mockResolvedValue(mockAuthentication);
|
||||
vi.mocked(hasPermission).mockReturnValue(true);
|
||||
|
||||
const result = await checkAuth(null, environmentId, mockRequest);
|
||||
const result = await checkAuth(null, environmentId, mockRequest);
|
||||
|
||||
expect(authenticateRequest).toHaveBeenCalledWith(mockRequest);
|
||||
expect(hasPermission).toHaveBeenCalledWith(mockAuthentication.environmentPermissions, environmentId, "POST");
|
||||
expect(result).toBeUndefined();
|
||||
});
|
||||
expect(authenticateRequest).toHaveBeenCalledWith(mockRequest);
|
||||
expect(hasPermission).toHaveBeenCalledWith(
|
||||
mockAuthentication.environmentPermissions,
|
||||
environmentId,
|
||||
"POST"
|
||||
);
|
||||
expect(result).toBeUndefined();
|
||||
});
|
||||
|
||||
test("returns unauthorizedResponse when session exists but user lacks environment access", async () => {
|
||||
const mockSession: Session = {
|
||||
user: {
|
||||
id: "user-123",
|
||||
},
|
||||
expires: "2024-12-31T23:59:59.999Z",
|
||||
};
|
||||
test("returns unauthorizedResponse when session exists but user lacks environment access", async () => {
|
||||
const mockSession: Session = {
|
||||
user: {
|
||||
id: "user-123",
|
||||
},
|
||||
expires: "2024-12-31T23:59:59.999Z",
|
||||
};
|
||||
|
||||
vi.mocked(hasUserEnvironmentAccess).mockResolvedValue(false);
|
||||
vi.mocked(hasUserEnvironmentAccess).mockResolvedValue(false);
|
||||
|
||||
const result = await checkAuth(mockSession, environmentId, mockRequest);
|
||||
const result = await checkAuth(mockSession, environmentId, mockRequest);
|
||||
|
||||
expect(hasUserEnvironmentAccess).toHaveBeenCalledWith("user-123", environmentId);
|
||||
expect(responses.unauthorizedResponse).toHaveBeenCalled();
|
||||
expect(result).toBe(mockUnauthorizedResponse);
|
||||
});
|
||||
expect(hasUserEnvironmentAccess).toHaveBeenCalledWith("user-123", environmentId);
|
||||
expect(responses.unauthorizedResponse).toHaveBeenCalled();
|
||||
expect(result).toBe(mockUnauthorizedResponse);
|
||||
});
|
||||
|
||||
test("returns undefined when session exists and user has environment access", async () => {
|
||||
const mockSession: Session = {
|
||||
user: {
|
||||
id: "user-123",
|
||||
},
|
||||
expires: "2024-12-31T23:59:59.999Z",
|
||||
};
|
||||
test("returns undefined when session exists and user has environment access", async () => {
|
||||
const mockSession: Session = {
|
||||
user: {
|
||||
id: "user-123",
|
||||
},
|
||||
expires: "2024-12-31T23:59:59.999Z",
|
||||
};
|
||||
|
||||
vi.mocked(hasUserEnvironmentAccess).mockResolvedValue(true);
|
||||
vi.mocked(hasUserEnvironmentAccess).mockResolvedValue(true);
|
||||
|
||||
const result = await checkAuth(mockSession, environmentId, mockRequest);
|
||||
const result = await checkAuth(mockSession, environmentId, mockRequest);
|
||||
|
||||
expect(hasUserEnvironmentAccess).toHaveBeenCalledWith("user-123", environmentId);
|
||||
expect(result).toBeUndefined();
|
||||
});
|
||||
expect(hasUserEnvironmentAccess).toHaveBeenCalledWith("user-123", environmentId);
|
||||
expect(result).toBeUndefined();
|
||||
});
|
||||
|
||||
test("does not call authenticateRequest when session exists", async () => {
|
||||
const mockSession: Session = {
|
||||
user: {
|
||||
id: "user-123",
|
||||
},
|
||||
expires: "2024-12-31T23:59:59.999Z",
|
||||
};
|
||||
test("does not call authenticateRequest when session exists", async () => {
|
||||
const mockSession: Session = {
|
||||
user: {
|
||||
id: "user-123",
|
||||
},
|
||||
expires: "2024-12-31T23:59:59.999Z",
|
||||
};
|
||||
|
||||
vi.mocked(hasUserEnvironmentAccess).mockResolvedValue(true);
|
||||
vi.mocked(hasUserEnvironmentAccess).mockResolvedValue(true);
|
||||
|
||||
await checkAuth(mockSession, environmentId, mockRequest);
|
||||
await checkAuth(mockSession, environmentId, mockRequest);
|
||||
|
||||
expect(authenticateRequest).not.toHaveBeenCalled();
|
||||
expect(hasUserEnvironmentAccess).toHaveBeenCalledWith("user-123", environmentId);
|
||||
});
|
||||
});
|
||||
expect(authenticateRequest).not.toHaveBeenCalled();
|
||||
expect(hasUserEnvironmentAccess).toHaveBeenCalledWith("user-123", environmentId);
|
||||
});
|
||||
});
|
||||
|
||||
@@ -1,38 +1,41 @@
|
||||
import { authenticateRequest } from "@/app/api/v1/auth";
|
||||
import { responses } from "@/app/lib/api/response";
|
||||
import { hasUserEnvironmentAccess } from "@/lib/environment/auth";
|
||||
import { NextRequest } from "next/server";
|
||||
import { Session } from "next-auth";
|
||||
import { hasPermission } from "@/modules/organization/settings/api-keys/lib/utils";
|
||||
import { Session } from "next-auth";
|
||||
import { NextRequest } from "next/server";
|
||||
|
||||
export const checkForRequiredFields = (
|
||||
environmentId: string,
|
||||
fileType: string,
|
||||
encodedFileName: string
|
||||
): Response | undefined => {
|
||||
if (!environmentId) {
|
||||
return responses.badRequestResponse("environmentId is required");
|
||||
}
|
||||
|
||||
export const checkForRequiredFields = (environmentId: string, fileType: string, encodedFileName: string): Response | undefined => {
|
||||
if (!environmentId) {
|
||||
return responses.badRequestResponse("environmentId is required");
|
||||
}
|
||||
if (!fileType) {
|
||||
return responses.badRequestResponse("contentType is required");
|
||||
}
|
||||
|
||||
if (!fileType) {
|
||||
return responses.badRequestResponse("contentType is required");
|
||||
}
|
||||
|
||||
if (!encodedFileName) {
|
||||
return responses.badRequestResponse("fileName is required");
|
||||
}
|
||||
if (!encodedFileName) {
|
||||
return responses.badRequestResponse("fileName is required");
|
||||
}
|
||||
};
|
||||
|
||||
export const checkAuth = async (session: Session | null, environmentId: string, request: NextRequest) => {
|
||||
if (!session) {
|
||||
//check whether its using API key
|
||||
const authentication = await authenticateRequest(request);
|
||||
if (!authentication) return responses.notAuthenticatedResponse();
|
||||
if (!session) {
|
||||
//check whether its using API key
|
||||
const authentication = await authenticateRequest(request);
|
||||
if (!authentication) return responses.notAuthenticatedResponse();
|
||||
|
||||
if (!hasPermission(authentication.environmentPermissions, environmentId, "POST")) {
|
||||
return responses.unauthorizedResponse();
|
||||
}
|
||||
} else {
|
||||
const isUserAuthorized = await hasUserEnvironmentAccess(session.user.id, environmentId);
|
||||
if (!isUserAuthorized) {
|
||||
return responses.unauthorizedResponse();
|
||||
}
|
||||
if (!hasPermission(authentication.environmentPermissions, environmentId, "POST")) {
|
||||
return responses.unauthorizedResponse();
|
||||
}
|
||||
};
|
||||
} else {
|
||||
const isUserAuthorized = await hasUserEnvironmentAccess(session.user.id, environmentId);
|
||||
if (!isUserAuthorized) {
|
||||
return responses.unauthorizedResponse();
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
// headers -> "Content-Type" should be present and set to a valid MIME type
|
||||
// body -> should be a valid file object (buffer)
|
||||
// method -> PUT (to be the same as the signedUrl method)
|
||||
import { checkAuth, checkForRequiredFields } from "@/app/api/v1/management/storage/lib/utils";
|
||||
import { responses } from "@/app/lib/api/response";
|
||||
import { ENCRYPTION_KEY, UPLOADS_DIR } from "@/lib/constants";
|
||||
import { validateLocalSignedUrl } from "@/lib/crypto";
|
||||
@@ -10,7 +11,6 @@ import { authOptions } from "@/modules/auth/lib/authOptions";
|
||||
import { getServerSession } from "next-auth";
|
||||
import { NextRequest } from "next/server";
|
||||
import { logger } from "@formbricks/logger";
|
||||
import { checkAuth, checkForRequiredFields } from "@/app/api/v1/management/storage/lib/utils";
|
||||
|
||||
export const POST = async (req: NextRequest): Promise<Response> => {
|
||||
if (!ENCRYPTION_KEY) {
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { checkAuth, checkForRequiredFields } from "@/app/api/v1/management/storage/lib/utils";
|
||||
import { responses } from "@/app/lib/api/response";
|
||||
import { validateFile } from "@/lib/fileValidation";
|
||||
import { authOptions } from "@/modules/auth/lib/authOptions";
|
||||
@@ -5,8 +6,6 @@ import { getServerSession } from "next-auth";
|
||||
import { NextRequest } from "next/server";
|
||||
import { logger } from "@formbricks/logger";
|
||||
import { getSignedUrlForPublicFile } from "./lib/getSignedUrl";
|
||||
import { checkAuth, checkForRequiredFields } from "@/app/api/v1/management/storage/lib/utils";
|
||||
|
||||
|
||||
// api endpoint for uploading public files
|
||||
// uploaded files will be public, anyone can access the file
|
||||
@@ -14,7 +13,6 @@ import { checkAuth, checkForRequiredFields } from "@/app/api/v1/management/stora
|
||||
// use this to upload files for a specific resource, e.g. a user profile picture or a survey
|
||||
// this api endpoint will return a signed url for uploading the file to s3 and another url for uploading file to the local storage
|
||||
|
||||
|
||||
export const POST = async (request: NextRequest): Promise<Response> => {
|
||||
let storageInput;
|
||||
|
||||
@@ -34,7 +32,6 @@ export const POST = async (request: NextRequest): Promise<Response> => {
|
||||
const authResponse = await checkAuth(session, environmentId, request);
|
||||
if (authResponse) return authResponse;
|
||||
|
||||
|
||||
// Perform server-side file validation first to block dangerous file types
|
||||
const fileValidation = validateFile(fileName, fileType);
|
||||
if (!fileValidation.valid) {
|
||||
|
||||
@@ -3006,12 +3006,7 @@ const understandLowEngagement = (t: TFnType): TTemplate => {
|
||||
t("templates.understand_low_engagement_question_1_choice_4"),
|
||||
t("templates.understand_low_engagement_question_1_choice_5"),
|
||||
],
|
||||
choiceIds: [
|
||||
reusableOptionIds[0],
|
||||
reusableOptionIds[1],
|
||||
reusableOptionIds[2],
|
||||
reusableOptionIds[3],
|
||||
],
|
||||
choiceIds: [reusableOptionIds[0], reusableOptionIds[1], reusableOptionIds[2], reusableOptionIds[3]],
|
||||
headline: t("templates.understand_low_engagement_question_1_headline"),
|
||||
required: true,
|
||||
containsOther: true,
|
||||
|
||||
@@ -3,12 +3,12 @@ import { cleanup } from "@testing-library/react";
|
||||
import { beforeEach, describe, expect, test, vi } from "vitest";
|
||||
import { TMembership } from "@formbricks/types/memberships";
|
||||
import { TOrganization } from "@formbricks/types/organizations";
|
||||
import { TProject } from "@formbricks/types/project";
|
||||
import { TUser } from "@formbricks/types/user";
|
||||
import Page from "./page";
|
||||
|
||||
// Mock dependencies
|
||||
vi.mock("@/lib/environment/service", () => ({
|
||||
getFirstEnvironmentIdByUserId: vi.fn(),
|
||||
vi.mock("@/lib/project/service", () => ({
|
||||
getUserProjectEnvironmentsByOrganizationIds: vi.fn(),
|
||||
}));
|
||||
|
||||
vi.mock("@/lib/instance/service", () => ({
|
||||
@@ -48,8 +48,11 @@ vi.mock("@/modules/ui/components/client-logout", () => ({
|
||||
}));
|
||||
|
||||
vi.mock("@/app/ClientEnvironmentRedirect", () => ({
|
||||
default: ({ environmentId }: { environmentId: string }) => (
|
||||
<div data-testid="client-environment-redirect">Environment ID: {environmentId}</div>
|
||||
default: ({ environmentId, userEnvironments }: { environmentId: string; userEnvironments?: string[] }) => (
|
||||
<div data-testid="client-environment-redirect">
|
||||
Environment ID: {environmentId}
|
||||
{userEnvironments && ` | User Environments: ${userEnvironments.join(", ")}`}
|
||||
</div>
|
||||
),
|
||||
}));
|
||||
|
||||
@@ -149,7 +152,7 @@ describe("Page", () => {
|
||||
const { getIsFreshInstance } = await import("@/lib/instance/service");
|
||||
const { getUser } = await import("@/lib/user/service");
|
||||
const { getOrganizationsByUserId } = await import("@/lib/organization/service");
|
||||
const { getFirstEnvironmentIdByUserId } = await import("@/lib/environment/service");
|
||||
const { getUserProjectEnvironmentsByOrganizationIds } = await import("@/lib/project/service");
|
||||
const { getMembershipByUserIdOrganizationId } = await import("@/lib/membership/service");
|
||||
const { getAccessFlags } = await import("@/lib/membership/utils");
|
||||
const { redirect } = await import("next/navigation");
|
||||
@@ -204,13 +207,23 @@ describe("Page", () => {
|
||||
role: "owner",
|
||||
};
|
||||
|
||||
const mockUserProjects = [
|
||||
{
|
||||
id: "test-project-id",
|
||||
name: "Test Project",
|
||||
environments: [],
|
||||
},
|
||||
];
|
||||
|
||||
vi.mocked(getServerSession).mockResolvedValue({
|
||||
user: { id: "test-user-id" },
|
||||
} as any);
|
||||
vi.mocked(getIsFreshInstance).mockResolvedValue(false);
|
||||
vi.mocked(getUser).mockResolvedValue(mockUser);
|
||||
vi.mocked(getUserProjectEnvironmentsByOrganizationIds).mockResolvedValue(
|
||||
mockUserProjects as unknown as TProject[]
|
||||
);
|
||||
vi.mocked(getOrganizationsByUserId).mockResolvedValue([mockOrganization]);
|
||||
vi.mocked(getFirstEnvironmentIdByUserId).mockResolvedValue(null);
|
||||
vi.mocked(getMembershipByUserIdOrganizationId).mockResolvedValue(mockMembership);
|
||||
vi.mocked(getAccessFlags).mockReturnValue({
|
||||
isManager: false,
|
||||
@@ -228,8 +241,8 @@ describe("Page", () => {
|
||||
const { getServerSession } = await import("next-auth");
|
||||
const { getIsFreshInstance } = await import("@/lib/instance/service");
|
||||
const { getUser } = await import("@/lib/user/service");
|
||||
const { getUserProjectEnvironmentsByOrganizationIds } = await import("@/lib/project/service");
|
||||
const { getOrganizationsByUserId } = await import("@/lib/organization/service");
|
||||
const { getFirstEnvironmentIdByUserId } = await import("@/lib/environment/service");
|
||||
const { getMembershipByUserIdOrganizationId } = await import("@/lib/membership/service");
|
||||
const { getAccessFlags } = await import("@/lib/membership/utils");
|
||||
const { redirect } = await import("next/navigation");
|
||||
@@ -284,13 +297,23 @@ describe("Page", () => {
|
||||
role: "member",
|
||||
};
|
||||
|
||||
const mockUserProjects = [
|
||||
{
|
||||
id: "test-project-id",
|
||||
name: "Test Project",
|
||||
environments: [],
|
||||
},
|
||||
];
|
||||
|
||||
vi.mocked(getServerSession).mockResolvedValue({
|
||||
user: { id: "test-user-id" },
|
||||
} as any);
|
||||
vi.mocked(getIsFreshInstance).mockResolvedValue(false);
|
||||
vi.mocked(getUser).mockResolvedValue(mockUser);
|
||||
vi.mocked(getUserProjectEnvironmentsByOrganizationIds).mockResolvedValue(
|
||||
mockUserProjects as unknown as TProject[]
|
||||
);
|
||||
vi.mocked(getOrganizationsByUserId).mockResolvedValue([mockOrganization]);
|
||||
vi.mocked(getFirstEnvironmentIdByUserId).mockResolvedValue(null);
|
||||
vi.mocked(getMembershipByUserIdOrganizationId).mockResolvedValue(mockMembership);
|
||||
vi.mocked(getAccessFlags).mockReturnValue({
|
||||
isManager: false,
|
||||
@@ -309,9 +332,9 @@ describe("Page", () => {
|
||||
const { getIsFreshInstance } = await import("@/lib/instance/service");
|
||||
const { getUser } = await import("@/lib/user/service");
|
||||
const { getOrganizationsByUserId } = await import("@/lib/organization/service");
|
||||
const { getFirstEnvironmentIdByUserId } = await import("@/lib/environment/service");
|
||||
const { getMembershipByUserIdOrganizationId } = await import("@/lib/membership/service");
|
||||
const { getAccessFlags } = await import("@/lib/membership/utils");
|
||||
const { getUserProjectEnvironmentsByOrganizationIds } = await import("@/lib/project/service");
|
||||
const { render } = await import("@testing-library/react");
|
||||
|
||||
const mockUser: TUser = {
|
||||
@@ -364,7 +387,43 @@ describe("Page", () => {
|
||||
role: "member",
|
||||
};
|
||||
|
||||
const mockEnvironmentId = "test-env-id";
|
||||
const mockUserProjects = [
|
||||
{
|
||||
id: "project-1",
|
||||
name: "Test Project",
|
||||
createdAt: new Date(),
|
||||
updatedAt: new Date(),
|
||||
organizationId: "test-org-id",
|
||||
styling: { allowStyleOverwrite: true },
|
||||
recontactDays: 0,
|
||||
inAppSurveyBranding: false,
|
||||
linkSurveyBranding: false,
|
||||
config: { channel: "link" as const, industry: "saas" as const },
|
||||
placement: "bottomRight" as const,
|
||||
clickOutsideClose: false,
|
||||
darkOverlay: false,
|
||||
languages: [],
|
||||
logo: null,
|
||||
environments: [
|
||||
{
|
||||
id: "test-env-id",
|
||||
type: "production" as const,
|
||||
createdAt: new Date(),
|
||||
updatedAt: new Date(),
|
||||
projectId: "project-1",
|
||||
appSetupCompleted: true,
|
||||
},
|
||||
{
|
||||
id: "test-env-dev",
|
||||
type: "development" as const,
|
||||
createdAt: new Date(),
|
||||
updatedAt: new Date(),
|
||||
projectId: "project-1",
|
||||
appSetupCompleted: true,
|
||||
},
|
||||
],
|
||||
},
|
||||
] as any;
|
||||
|
||||
vi.mocked(getServerSession).mockResolvedValue({
|
||||
user: { id: "test-user-id" },
|
||||
@@ -372,8 +431,8 @@ describe("Page", () => {
|
||||
vi.mocked(getIsFreshInstance).mockResolvedValue(false);
|
||||
vi.mocked(getUser).mockResolvedValue(mockUser);
|
||||
vi.mocked(getOrganizationsByUserId).mockResolvedValue([mockOrganization]);
|
||||
vi.mocked(getFirstEnvironmentIdByUserId).mockResolvedValue(mockEnvironmentId);
|
||||
vi.mocked(getMembershipByUserIdOrganizationId).mockResolvedValue(mockMembership);
|
||||
vi.mocked(getUserProjectEnvironmentsByOrganizationIds).mockResolvedValue(mockUserProjects);
|
||||
vi.mocked(getAccessFlags).mockReturnValue({
|
||||
isManager: false,
|
||||
isOwner: false,
|
||||
@@ -385,7 +444,7 @@ describe("Page", () => {
|
||||
const { container } = render(result);
|
||||
|
||||
expect(container.querySelector('[data-testid="client-environment-redirect"]')).toHaveTextContent(
|
||||
`Environment ID: ${mockEnvironmentId}`
|
||||
`User Environments: test-env-id, test-env-dev`
|
||||
);
|
||||
});
|
||||
});
|
||||
|
||||
@@ -1,9 +1,9 @@
|
||||
import ClientEnvironmentRedirect from "@/app/ClientEnvironmentRedirect";
|
||||
import { getFirstEnvironmentIdByUserId } from "@/lib/environment/service";
|
||||
import { getIsFreshInstance } from "@/lib/instance/service";
|
||||
import { getMembershipByUserIdOrganizationId } from "@/lib/membership/service";
|
||||
import { getAccessFlags } from "@/lib/membership/utils";
|
||||
import { getOrganizationsByUserId } from "@/lib/organization/service";
|
||||
import { getUserProjectEnvironmentsByOrganizationIds } from "@/lib/project/service";
|
||||
import { getUser } from "@/lib/user/service";
|
||||
import { authOptions } from "@/modules/auth/lib/authOptions";
|
||||
import { ClientLogout } from "@/modules/ui/components/client-logout";
|
||||
@@ -34,16 +34,37 @@ const Page = async () => {
|
||||
return redirect("/setup/organization/create");
|
||||
}
|
||||
|
||||
let environmentId: string | null = null;
|
||||
environmentId = await getFirstEnvironmentIdByUserId(session.user.id);
|
||||
const projectsByOrg = await getUserProjectEnvironmentsByOrganizationIds(
|
||||
userOrganizations.map((org) => org.id),
|
||||
user.id
|
||||
);
|
||||
|
||||
// Flatten all environments from all projects across all organizations
|
||||
const allEnvironments = projectsByOrg.flatMap((project) => project.environments);
|
||||
|
||||
// Find first production environment and collect all other environment IDs in one pass
|
||||
const { firstProductionEnvironmentId, otherEnvironmentIds } = allEnvironments.reduce(
|
||||
(acc, env) => {
|
||||
if (env.type === "production" && !acc.firstProductionEnvironmentId) {
|
||||
acc.firstProductionEnvironmentId = env.id;
|
||||
} else {
|
||||
acc.otherEnvironmentIds.add(env.id);
|
||||
}
|
||||
return acc;
|
||||
},
|
||||
{ firstProductionEnvironmentId: null as string | null, otherEnvironmentIds: new Set<string>() }
|
||||
);
|
||||
|
||||
const userEnvironments = [...otherEnvironmentIds];
|
||||
|
||||
const currentUserMembership = await getMembershipByUserIdOrganizationId(
|
||||
session.user.id,
|
||||
userOrganizations[0].id
|
||||
);
|
||||
|
||||
const { isManager, isOwner } = getAccessFlags(currentUserMembership?.role);
|
||||
|
||||
if (!environmentId) {
|
||||
if (!firstProductionEnvironmentId) {
|
||||
if (isOwner || isManager) {
|
||||
return redirect(`/organizations/${userOrganizations[0].id}/projects/new/mode`);
|
||||
} else {
|
||||
@@ -51,7 +72,10 @@ const Page = async () => {
|
||||
}
|
||||
}
|
||||
|
||||
return <ClientEnvironmentRedirect environmentId={environmentId} />;
|
||||
// Put the first production environment at the front of the array
|
||||
const sortedUserEnvironments = [firstProductionEnvironmentId, ...userEnvironments];
|
||||
|
||||
return <ClientEnvironmentRedirect userEnvironments={sortedUserEnvironments} />;
|
||||
};
|
||||
|
||||
export default Page;
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
import { LinkSurveyNotFound } from "@/modules/survey/link/not-found";
|
||||
|
||||
export default LinkSurveyNotFound;
|
||||
export default function NotFound() {
|
||||
return <LinkSurveyNotFound />;
|
||||
}
|
||||
|
||||
@@ -13,7 +13,8 @@ import {
|
||||
ZIntegrationAirtableTokenSchema,
|
||||
} from "@formbricks/types/integration/airtable";
|
||||
import { AIRTABLE_CLIENT_ID, AIRTABLE_MESSAGE_LIMIT } from "../constants";
|
||||
import { createOrUpdateIntegration, deleteIntegration, getIntegrationByType } from "../integration/service";
|
||||
import { createOrUpdateIntegration, getIntegrationByType } from "../integration/service";
|
||||
import { delay } from "../utils/promises";
|
||||
import { truncateText } from "../utils/strings";
|
||||
|
||||
export const getBases = async (key: string) => {
|
||||
@@ -99,7 +100,11 @@ export const getAirtableToken = async (environmentId: string) => {
|
||||
});
|
||||
|
||||
if (!newToken) {
|
||||
throw new Error("Failed to create new token");
|
||||
logger.error("Failed to fetch new Airtable token", {
|
||||
environmentId,
|
||||
airtableIntegration,
|
||||
});
|
||||
throw new Error("Failed to fetch new Airtable token");
|
||||
}
|
||||
|
||||
await createOrUpdateIntegration(environmentId, {
|
||||
@@ -116,9 +121,11 @@ export const getAirtableToken = async (environmentId: string) => {
|
||||
|
||||
return access_token;
|
||||
} catch (error) {
|
||||
await deleteIntegration(environmentId);
|
||||
|
||||
throw new Error("invalid token");
|
||||
logger.error("Failed to get Airtable token", {
|
||||
environmentId,
|
||||
error,
|
||||
});
|
||||
throw new Error("Failed to get Airtable token");
|
||||
}
|
||||
};
|
||||
|
||||
@@ -178,6 +185,18 @@ const addField = async (
|
||||
return await req.json();
|
||||
};
|
||||
|
||||
const getExistingFields = async (key: TIntegrationAirtableCredential, baseId: string, tableId: string) => {
|
||||
const req = await tableFetcher(key, baseId);
|
||||
const tables = ZIntegrationAirtableTablesWithFields.parse(req).tables;
|
||||
const currentTable = tables.find((t) => t.id === tableId);
|
||||
|
||||
if (!currentTable) {
|
||||
throw new Error(`Table with ID ${tableId} not found`);
|
||||
}
|
||||
|
||||
return new Set(currentTable.fields.map((f) => f.name));
|
||||
};
|
||||
|
||||
export const writeData = async (
|
||||
key: TIntegrationAirtableCredential,
|
||||
configData: TIntegrationAirtableConfigData,
|
||||
@@ -186,6 +205,7 @@ export const writeData = async (
|
||||
const responses = values[0];
|
||||
const questions = values[1];
|
||||
|
||||
// 1) Build the record payload
|
||||
const data: Record<string, string> = {};
|
||||
for (let i = 0; i < questions.length; i++) {
|
||||
data[questions[i]] =
|
||||
@@ -194,34 +214,73 @@ export const writeData = async (
|
||||
: responses[i];
|
||||
}
|
||||
|
||||
const req = await tableFetcher(key, configData.baseId);
|
||||
const tables = ZIntegrationAirtableTablesWithFields.parse(req).tables;
|
||||
// 2) Figure out which fields need creating
|
||||
const existingFields = await getExistingFields(key, configData.baseId, configData.tableId);
|
||||
const fieldsToCreate = questions.filter((q) => !existingFields.has(q));
|
||||
|
||||
const currentTable = tables.find((table) => table.id === configData.tableId);
|
||||
if (currentTable) {
|
||||
const currentFields = new Set(currentTable.fields.map((field) => field.name));
|
||||
const fieldsToCreate = new Set<string>();
|
||||
for (const field of questions) {
|
||||
const hasField = currentFields.has(field);
|
||||
if (!hasField) {
|
||||
fieldsToCreate.add(field);
|
||||
// 3) Create any missing fields with throttling to respect Airtable's 5 req/sec per base limit
|
||||
if (fieldsToCreate.length > 0) {
|
||||
// Sequential processing with delays
|
||||
const DELAY_BETWEEN_REQUESTS = 250; // 250ms = 4 requests per second (staying under 5/sec limit)
|
||||
|
||||
for (let i = 0; i < fieldsToCreate.length; i++) {
|
||||
const fieldName = fieldsToCreate[i];
|
||||
|
||||
const createRes = await addField(key, configData.baseId, configData.tableId, {
|
||||
name: fieldName,
|
||||
type: "singleLineText",
|
||||
});
|
||||
|
||||
if (createRes?.error) {
|
||||
throw new Error(`Failed to create field "${fieldName}": ${JSON.stringify(createRes)}`);
|
||||
}
|
||||
|
||||
// Add delay between requests (except for the last one)
|
||||
if (i < fieldsToCreate.length - 1) {
|
||||
await delay(DELAY_BETWEEN_REQUESTS);
|
||||
}
|
||||
}
|
||||
|
||||
if (fieldsToCreate.size > 0) {
|
||||
const createFieldPromise: Promise<any>[] = [];
|
||||
fieldsToCreate.forEach((fieldName) => {
|
||||
createFieldPromise.push(
|
||||
addField(key, configData.baseId, configData.tableId, {
|
||||
name: fieldName,
|
||||
type: "singleLineText",
|
||||
})
|
||||
);
|
||||
});
|
||||
// 4) Wait for the new fields to show up
|
||||
await waitForFieldsToExist(key, configData, fieldsToCreate);
|
||||
}
|
||||
|
||||
await Promise.all(createFieldPromise);
|
||||
// 5) Finally, add the records
|
||||
await addRecords(key, configData.baseId, configData.tableId, data);
|
||||
};
|
||||
|
||||
async function waitForFieldsToExist(
|
||||
key: TIntegrationAirtableCredential,
|
||||
configData: TIntegrationAirtableConfigData,
|
||||
fieldNames: string[],
|
||||
maxRetries = 5,
|
||||
intervalMs = 2000
|
||||
) {
|
||||
let existingFields: Set<string> = new Set(),
|
||||
missingFields: string[] = [];
|
||||
|
||||
for (let attempt = 1; attempt <= maxRetries; attempt++) {
|
||||
existingFields = await getExistingFields(key, configData.baseId, configData.tableId);
|
||||
missingFields = fieldNames.filter((f) => !existingFields.has(f));
|
||||
|
||||
if (missingFields.length === 0) {
|
||||
return;
|
||||
}
|
||||
|
||||
if (attempt < maxRetries) {
|
||||
logger.error(
|
||||
`Attempt ${attempt}/${maxRetries}: ${missingFields.length} field(s) still missing [${missingFields.join(
|
||||
", "
|
||||
)}], retrying in ${intervalMs / 1000}s…`
|
||||
);
|
||||
|
||||
await new Promise((r) => setTimeout(r, intervalMs));
|
||||
}
|
||||
}
|
||||
|
||||
await addRecords(key, configData.baseId, configData.tableId, data);
|
||||
};
|
||||
throw new Error(
|
||||
`Timed out waiting for ${missingFields.length} field(s) [${missingFields.join(
|
||||
", "
|
||||
)}] to become available. Available fields: [${Array.from(existingFields).join(", ")}]`
|
||||
);
|
||||
}
|
||||
|
||||
@@ -1,10 +1,16 @@
|
||||
import { createId } from "@paralleldrive/cuid2";
|
||||
import { Prisma } from "@prisma/client";
|
||||
import { OrganizationRole, Prisma, WidgetPlacement } from "@prisma/client";
|
||||
import { afterEach, describe, expect, test, vi } from "vitest";
|
||||
import { prisma } from "@formbricks/database";
|
||||
import { DatabaseError, ValidationError } from "@formbricks/types/errors";
|
||||
import { ITEMS_PER_PAGE } from "../constants";
|
||||
import { getProject, getProjectByEnvironmentId, getProjects, getUserProjects } from "./service";
|
||||
import {
|
||||
getProject,
|
||||
getProjectByEnvironmentId,
|
||||
getProjects,
|
||||
getUserProjectEnvironmentsByOrganizationIds,
|
||||
getUserProjects,
|
||||
} from "./service";
|
||||
|
||||
vi.mock("@formbricks/database", () => ({
|
||||
prisma: {
|
||||
@@ -15,6 +21,7 @@ vi.mock("@formbricks/database", () => ({
|
||||
},
|
||||
membership: {
|
||||
findFirst: vi.fn(),
|
||||
findMany: vi.fn(),
|
||||
},
|
||||
},
|
||||
}));
|
||||
@@ -35,13 +42,20 @@ describe("Project Service", () => {
|
||||
recontactDays: 0,
|
||||
linkSurveyBranding: true,
|
||||
inAppSurveyBranding: true,
|
||||
config: {},
|
||||
placement: "bottomRight",
|
||||
config: {
|
||||
channel: null,
|
||||
industry: null,
|
||||
},
|
||||
placement: WidgetPlacement.bottomRight,
|
||||
clickOutsideClose: true,
|
||||
darkOverlay: false,
|
||||
environments: [],
|
||||
styling: {},
|
||||
styling: {
|
||||
allowStyleOverwrite: true,
|
||||
},
|
||||
logo: null,
|
||||
brandColor: null,
|
||||
highlightBorderColor: null,
|
||||
};
|
||||
|
||||
vi.mocked(prisma.project.findUnique).mockResolvedValue(mockProject);
|
||||
@@ -86,13 +100,20 @@ describe("Project Service", () => {
|
||||
recontactDays: 0,
|
||||
linkSurveyBranding: true,
|
||||
inAppSurveyBranding: true,
|
||||
config: {},
|
||||
placement: "bottomRight",
|
||||
config: {
|
||||
channel: null,
|
||||
industry: null,
|
||||
},
|
||||
placement: WidgetPlacement.bottomRight,
|
||||
clickOutsideClose: true,
|
||||
darkOverlay: false,
|
||||
environments: [],
|
||||
styling: {},
|
||||
styling: {
|
||||
allowStyleOverwrite: true,
|
||||
},
|
||||
logo: null,
|
||||
brandColor: null,
|
||||
highlightBorderColor: null,
|
||||
};
|
||||
|
||||
vi.mocked(prisma.project.findFirst).mockResolvedValue(mockProject);
|
||||
@@ -144,13 +165,20 @@ describe("Project Service", () => {
|
||||
recontactDays: 0,
|
||||
linkSurveyBranding: true,
|
||||
inAppSurveyBranding: true,
|
||||
config: {},
|
||||
placement: "bottomRight",
|
||||
config: {
|
||||
channel: null,
|
||||
industry: null,
|
||||
},
|
||||
placement: WidgetPlacement.bottomRight,
|
||||
clickOutsideClose: true,
|
||||
darkOverlay: false,
|
||||
environments: [],
|
||||
styling: {},
|
||||
styling: {
|
||||
allowStyleOverwrite: true,
|
||||
},
|
||||
logo: null,
|
||||
brandColor: null,
|
||||
highlightBorderColor: null,
|
||||
},
|
||||
{
|
||||
id: createId(),
|
||||
@@ -162,23 +190,29 @@ describe("Project Service", () => {
|
||||
recontactDays: 0,
|
||||
linkSurveyBranding: true,
|
||||
inAppSurveyBranding: true,
|
||||
config: {},
|
||||
placement: "bottomRight",
|
||||
config: {
|
||||
channel: null,
|
||||
industry: null,
|
||||
},
|
||||
placement: WidgetPlacement.bottomRight,
|
||||
clickOutsideClose: true,
|
||||
darkOverlay: false,
|
||||
environments: [],
|
||||
styling: {},
|
||||
styling: {
|
||||
allowStyleOverwrite: true,
|
||||
},
|
||||
logo: null,
|
||||
brandColor: null,
|
||||
highlightBorderColor: null,
|
||||
},
|
||||
];
|
||||
|
||||
vi.mocked(prisma.membership.findFirst).mockResolvedValue({
|
||||
id: createId(),
|
||||
userId,
|
||||
organizationId,
|
||||
role: "admin",
|
||||
createdAt: new Date(),
|
||||
updatedAt: new Date(),
|
||||
role: OrganizationRole.owner,
|
||||
accepted: true,
|
||||
deprecatedRole: null,
|
||||
});
|
||||
|
||||
vi.mocked(prisma.project.findMany).mockResolvedValue(mockProjects);
|
||||
@@ -210,23 +244,29 @@ describe("Project Service", () => {
|
||||
recontactDays: 0,
|
||||
linkSurveyBranding: true,
|
||||
inAppSurveyBranding: true,
|
||||
config: {},
|
||||
placement: "bottomRight",
|
||||
config: {
|
||||
channel: null,
|
||||
industry: null,
|
||||
},
|
||||
placement: WidgetPlacement.bottomRight,
|
||||
clickOutsideClose: true,
|
||||
darkOverlay: false,
|
||||
environments: [],
|
||||
styling: {},
|
||||
styling: {
|
||||
allowStyleOverwrite: true,
|
||||
},
|
||||
logo: null,
|
||||
brandColor: null,
|
||||
highlightBorderColor: null,
|
||||
},
|
||||
];
|
||||
|
||||
vi.mocked(prisma.membership.findFirst).mockResolvedValue({
|
||||
id: createId(),
|
||||
userId,
|
||||
organizationId,
|
||||
role: "member",
|
||||
createdAt: new Date(),
|
||||
updatedAt: new Date(),
|
||||
role: OrganizationRole.member,
|
||||
accepted: true,
|
||||
deprecatedRole: null,
|
||||
});
|
||||
|
||||
vi.mocked(prisma.project.findMany).mockResolvedValue(mockProjects);
|
||||
@@ -278,23 +318,29 @@ describe("Project Service", () => {
|
||||
recontactDays: 0,
|
||||
linkSurveyBranding: true,
|
||||
inAppSurveyBranding: true,
|
||||
config: {},
|
||||
placement: "bottomRight",
|
||||
config: {
|
||||
channel: null,
|
||||
industry: null,
|
||||
},
|
||||
placement: WidgetPlacement.bottomRight,
|
||||
clickOutsideClose: true,
|
||||
darkOverlay: false,
|
||||
environments: [],
|
||||
styling: {},
|
||||
styling: {
|
||||
allowStyleOverwrite: true,
|
||||
},
|
||||
logo: null,
|
||||
brandColor: null,
|
||||
highlightBorderColor: null,
|
||||
},
|
||||
];
|
||||
|
||||
vi.mocked(prisma.membership.findFirst).mockResolvedValue({
|
||||
id: createId(),
|
||||
userId,
|
||||
organizationId,
|
||||
role: "admin",
|
||||
createdAt: new Date(),
|
||||
updatedAt: new Date(),
|
||||
role: OrganizationRole.owner,
|
||||
accepted: true,
|
||||
deprecatedRole: null,
|
||||
});
|
||||
|
||||
vi.mocked(prisma.project.findMany).mockResolvedValue(mockProjects);
|
||||
@@ -326,13 +372,20 @@ describe("Project Service", () => {
|
||||
recontactDays: 0,
|
||||
linkSurveyBranding: true,
|
||||
inAppSurveyBranding: true,
|
||||
config: {},
|
||||
placement: "bottomRight",
|
||||
config: {
|
||||
channel: null,
|
||||
industry: null,
|
||||
},
|
||||
placement: WidgetPlacement.bottomRight,
|
||||
clickOutsideClose: true,
|
||||
darkOverlay: false,
|
||||
environments: [],
|
||||
styling: {},
|
||||
styling: {
|
||||
allowStyleOverwrite: true,
|
||||
},
|
||||
logo: null,
|
||||
brandColor: null,
|
||||
highlightBorderColor: null,
|
||||
},
|
||||
{
|
||||
id: createId(),
|
||||
@@ -344,13 +397,20 @@ describe("Project Service", () => {
|
||||
recontactDays: 0,
|
||||
linkSurveyBranding: true,
|
||||
inAppSurveyBranding: true,
|
||||
config: {},
|
||||
placement: "bottomRight",
|
||||
config: {
|
||||
channel: null,
|
||||
industry: null,
|
||||
},
|
||||
placement: WidgetPlacement.bottomRight,
|
||||
clickOutsideClose: true,
|
||||
darkOverlay: false,
|
||||
environments: [],
|
||||
styling: {},
|
||||
styling: {
|
||||
allowStyleOverwrite: true,
|
||||
},
|
||||
logo: null,
|
||||
brandColor: null,
|
||||
highlightBorderColor: null,
|
||||
},
|
||||
];
|
||||
|
||||
@@ -382,13 +442,20 @@ describe("Project Service", () => {
|
||||
recontactDays: 0,
|
||||
linkSurveyBranding: true,
|
||||
inAppSurveyBranding: true,
|
||||
config: {},
|
||||
placement: "bottomRight",
|
||||
config: {
|
||||
channel: null,
|
||||
industry: null,
|
||||
},
|
||||
placement: WidgetPlacement.bottomRight,
|
||||
clickOutsideClose: true,
|
||||
darkOverlay: false,
|
||||
environments: [],
|
||||
styling: {},
|
||||
styling: {
|
||||
allowStyleOverwrite: true,
|
||||
},
|
||||
logo: null,
|
||||
brandColor: null,
|
||||
highlightBorderColor: null,
|
||||
},
|
||||
];
|
||||
|
||||
@@ -418,4 +485,199 @@ describe("Project Service", () => {
|
||||
|
||||
await expect(getProjects(organizationId)).rejects.toThrow(DatabaseError);
|
||||
});
|
||||
|
||||
test("getProjectsByOrganizationIds should return projects for given organization IDs", async () => {
|
||||
const organizationId1 = createId();
|
||||
const organizationId2 = createId();
|
||||
const userId = createId();
|
||||
const mockProjects = [
|
||||
{
|
||||
environments: [],
|
||||
},
|
||||
{
|
||||
environments: [],
|
||||
},
|
||||
];
|
||||
|
||||
vi.mocked(prisma.membership.findMany).mockResolvedValue([
|
||||
{
|
||||
userId,
|
||||
organizationId: organizationId1,
|
||||
role: "owner" as any,
|
||||
accepted: true,
|
||||
deprecatedRole: null,
|
||||
},
|
||||
{
|
||||
userId,
|
||||
organizationId: organizationId2,
|
||||
role: "owner" as any,
|
||||
accepted: true,
|
||||
deprecatedRole: null,
|
||||
},
|
||||
]);
|
||||
|
||||
vi.mocked(prisma.project.findMany).mockResolvedValue(mockProjects as any);
|
||||
|
||||
const result = await getUserProjectEnvironmentsByOrganizationIds(
|
||||
[organizationId1, organizationId2],
|
||||
userId
|
||||
);
|
||||
|
||||
expect(result).toEqual(mockProjects);
|
||||
expect(prisma.project.findMany).toHaveBeenCalledWith({
|
||||
where: {
|
||||
OR: [{ organizationId: organizationId1 }, { organizationId: organizationId2 }],
|
||||
},
|
||||
select: { environments: true },
|
||||
});
|
||||
});
|
||||
|
||||
test("getProjectsByOrganizationIds should return empty array when no projects are found", async () => {
|
||||
const organizationId1 = createId();
|
||||
const organizationId2 = createId();
|
||||
const userId = createId();
|
||||
|
||||
vi.mocked(prisma.membership.findMany).mockResolvedValue([
|
||||
{
|
||||
userId,
|
||||
organizationId: organizationId1,
|
||||
role: "owner" as any,
|
||||
accepted: true,
|
||||
deprecatedRole: null,
|
||||
},
|
||||
{
|
||||
userId,
|
||||
organizationId: organizationId2,
|
||||
role: "owner" as any,
|
||||
accepted: true,
|
||||
deprecatedRole: null,
|
||||
},
|
||||
]);
|
||||
|
||||
vi.mocked(prisma.project.findMany).mockResolvedValue([]);
|
||||
|
||||
const result = await getUserProjectEnvironmentsByOrganizationIds(
|
||||
[organizationId1, organizationId2],
|
||||
userId
|
||||
);
|
||||
|
||||
expect(result).toEqual([]);
|
||||
expect(prisma.project.findMany).toHaveBeenCalledWith({
|
||||
where: {
|
||||
OR: [{ organizationId: organizationId1 }, { organizationId: organizationId2 }],
|
||||
},
|
||||
select: { environments: true },
|
||||
});
|
||||
});
|
||||
|
||||
test("getProjectsByOrganizationIds should throw DatabaseError when prisma throws", async () => {
|
||||
const organizationId1 = createId();
|
||||
const organizationId2 = createId();
|
||||
const userId = createId();
|
||||
const prismaError = new Prisma.PrismaClientKnownRequestError("Database error", {
|
||||
code: "P2002",
|
||||
clientVersion: "5.0.0",
|
||||
});
|
||||
|
||||
vi.mocked(prisma.membership.findMany).mockResolvedValue([
|
||||
{
|
||||
userId,
|
||||
organizationId: organizationId1,
|
||||
role: "owner" as any,
|
||||
accepted: true,
|
||||
deprecatedRole: null,
|
||||
},
|
||||
]);
|
||||
|
||||
vi.mocked(prisma.project.findMany).mockRejectedValue(prismaError);
|
||||
|
||||
await expect(
|
||||
getUserProjectEnvironmentsByOrganizationIds([organizationId1, organizationId2], userId)
|
||||
).rejects.toThrow(DatabaseError);
|
||||
});
|
||||
|
||||
test("getProjectsByOrganizationIds should throw ValidationError with wrong input", async () => {
|
||||
const userId = createId();
|
||||
await expect(getUserProjectEnvironmentsByOrganizationIds(["wrong-id"], userId)).rejects.toThrow(
|
||||
ValidationError
|
||||
);
|
||||
});
|
||||
|
||||
test("getProjectsByOrganizationIds should return empty array when user has no memberships", async () => {
|
||||
const organizationId1 = createId();
|
||||
const organizationId2 = createId();
|
||||
const userId = createId();
|
||||
|
||||
// Mock no memberships found
|
||||
vi.mocked(prisma.membership.findMany).mockResolvedValue([]);
|
||||
|
||||
const result = await getUserProjectEnvironmentsByOrganizationIds(
|
||||
[organizationId1, organizationId2],
|
||||
userId
|
||||
);
|
||||
|
||||
expect(result).toEqual([]);
|
||||
expect(prisma.membership.findMany).toHaveBeenCalledWith({
|
||||
where: {
|
||||
userId,
|
||||
organizationId: {
|
||||
in: [organizationId1, organizationId2],
|
||||
},
|
||||
},
|
||||
});
|
||||
// Should not call project.findMany when no memberships
|
||||
expect(prisma.project.findMany).not.toHaveBeenCalled();
|
||||
});
|
||||
|
||||
test("getProjectsByOrganizationIds should handle member role with team access", async () => {
|
||||
const organizationId1 = createId();
|
||||
const organizationId2 = createId();
|
||||
const userId = createId();
|
||||
const mockProjects = [
|
||||
{
|
||||
environments: [],
|
||||
},
|
||||
];
|
||||
|
||||
// Mock membership where user is a member
|
||||
vi.mocked(prisma.membership.findMany).mockResolvedValue([
|
||||
{
|
||||
userId,
|
||||
organizationId: organizationId1,
|
||||
role: "member" as any,
|
||||
accepted: true,
|
||||
deprecatedRole: null,
|
||||
},
|
||||
]);
|
||||
|
||||
vi.mocked(prisma.project.findMany).mockResolvedValue(mockProjects as any);
|
||||
|
||||
const result = await getUserProjectEnvironmentsByOrganizationIds(
|
||||
[organizationId1, organizationId2],
|
||||
userId
|
||||
);
|
||||
|
||||
expect(result).toEqual(mockProjects);
|
||||
expect(prisma.project.findMany).toHaveBeenCalledWith({
|
||||
where: {
|
||||
OR: [
|
||||
{
|
||||
organizationId: organizationId1,
|
||||
projectTeams: {
|
||||
some: {
|
||||
team: {
|
||||
teamUsers: {
|
||||
some: {
|
||||
userId,
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
],
|
||||
},
|
||||
select: { environments: true },
|
||||
});
|
||||
});
|
||||
});
|
||||
|
||||
@@ -170,3 +170,67 @@ export const getOrganizationProjectsCount = reactCache(async (organizationId: st
|
||||
throw error;
|
||||
}
|
||||
});
|
||||
|
||||
export const getUserProjectEnvironmentsByOrganizationIds = reactCache(
|
||||
async (organizationIds: string[], userId: string): Promise<Pick<TProject, "environments">[]> => {
|
||||
validateInputs([organizationIds, ZId.array()], [userId, ZId]);
|
||||
try {
|
||||
if (organizationIds.length === 0) {
|
||||
return [];
|
||||
}
|
||||
|
||||
const memberships = await prisma.membership.findMany({
|
||||
where: {
|
||||
userId,
|
||||
organizationId: {
|
||||
in: organizationIds,
|
||||
},
|
||||
},
|
||||
});
|
||||
|
||||
if (memberships.length === 0) {
|
||||
return [];
|
||||
}
|
||||
|
||||
const whereConditions: Prisma.ProjectWhereInput[] = memberships.map((membership) => {
|
||||
let projectWhereClause: Prisma.ProjectWhereInput = {
|
||||
organizationId: membership.organizationId,
|
||||
};
|
||||
|
||||
if (membership.role === "member") {
|
||||
projectWhereClause = {
|
||||
...projectWhereClause,
|
||||
projectTeams: {
|
||||
some: {
|
||||
team: {
|
||||
teamUsers: {
|
||||
some: {
|
||||
userId,
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
};
|
||||
}
|
||||
|
||||
return projectWhereClause;
|
||||
});
|
||||
|
||||
const projects = await prisma.project.findMany({
|
||||
where: {
|
||||
OR: whereConditions,
|
||||
},
|
||||
select: { environments: true },
|
||||
});
|
||||
|
||||
return projects;
|
||||
} catch (err) {
|
||||
if (err instanceof Prisma.PrismaClientKnownRequestError) {
|
||||
throw new DatabaseError(err.message);
|
||||
}
|
||||
|
||||
throw err;
|
||||
}
|
||||
}
|
||||
);
|
||||
|
||||
@@ -1892,12 +1892,12 @@
|
||||
},
|
||||
"s": {
|
||||
"check_inbox_or_spam": "Please also check your spam folder if you don't see the email in your inbox.",
|
||||
"completed": "This free & open-source survey has been closed.",
|
||||
"create_your_own": "Create your own",
|
||||
"completed": "This survey is closed.",
|
||||
"create_your_own": "Create your own open-source survey",
|
||||
"enter_pin": "This survey is protected. Enter the PIN below",
|
||||
"just_curious": "Just curious?",
|
||||
"link_invalid": "This survey can only be taken by invitation.",
|
||||
"paused": "This free & open-source survey is temporarily paused.",
|
||||
"paused": "This survey is temporarily paused.",
|
||||
"please_try_again_with_the_original_link": "Please try again with the original link",
|
||||
"preview_survey_questions": "Preview survey questions.",
|
||||
"question_preview": "Question Preview",
|
||||
|
||||
@@ -1892,12 +1892,12 @@
|
||||
},
|
||||
"s": {
|
||||
"check_inbox_or_spam": "Por favor, verifique também a sua pasta de spam se não vir o email na sua caixa de entrada.",
|
||||
"completed": "Este inquérito gratuito e de código aberto foi encerrado.",
|
||||
"create_your_own": "Crie o seu próprio",
|
||||
"completed": "Este inquérito está encerrado.",
|
||||
"create_your_own": "Crie o seu próprio inquérito de código aberto",
|
||||
"enter_pin": "Este inquérito está protegido. Introduza o PIN abaixo",
|
||||
"just_curious": "Só por curiosidade?",
|
||||
"link_invalid": "Este inquérito só pode ser respondido por convite.",
|
||||
"paused": "Este inquérito gratuito e de código aberto está temporariamente pausado.",
|
||||
"paused": "Este inquérito está temporariamente suspenso.",
|
||||
"please_try_again_with_the_original_link": "Por favor, tente novamente com o link original",
|
||||
"preview_survey_questions": "Pré-visualizar perguntas do inquérito.",
|
||||
"question_preview": "Pré-visualização da Pergunta",
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { FORMBRICKS_ENVIRONMENT_ID_LS } from "@/lib/localStorage";
|
||||
import { cleanup, fireEvent, render, screen, waitFor } from "@testing-library/react";
|
||||
import { afterEach, describe, expect, test, vi } from "vitest";
|
||||
import { TOrganization } from "@formbricks/types/organizations";
|
||||
@@ -78,6 +79,11 @@ describe("DeleteAccountModal", () => {
|
||||
.spyOn(actions, "deleteUserAction")
|
||||
.mockResolvedValue("deleted-user-id" as any); // the return doesn't matter here
|
||||
|
||||
Object.defineProperty(window, "localStorage", {
|
||||
writable: true,
|
||||
value: { removeItem: vi.fn() },
|
||||
});
|
||||
|
||||
// Mock window.location.replace
|
||||
Object.defineProperty(window, "location", {
|
||||
writable: true,
|
||||
@@ -94,6 +100,8 @@ describe("DeleteAccountModal", () => {
|
||||
/>
|
||||
);
|
||||
|
||||
const removeItemSpy = vi.spyOn(window.localStorage, "removeItem");
|
||||
|
||||
const input = screen.getByTestId("deleteAccountConfirmation");
|
||||
fireEvent.change(input, { target: { value: mockUser.email } });
|
||||
|
||||
@@ -106,6 +114,7 @@ describe("DeleteAccountModal", () => {
|
||||
reason: "account_deletion",
|
||||
redirect: false, // Updated to match new implementation
|
||||
});
|
||||
expect(removeItemSpy).toHaveBeenCalledWith(FORMBRICKS_ENVIRONMENT_ID_LS);
|
||||
expect(window.location.replace).toHaveBeenCalledWith("/auth/login");
|
||||
expect(mockSetOpen).toHaveBeenCalledWith(false);
|
||||
});
|
||||
@@ -116,6 +125,11 @@ describe("DeleteAccountModal", () => {
|
||||
.spyOn(actions, "deleteUserAction")
|
||||
.mockResolvedValue("deleted-user-id" as any); // the return doesn't matter here
|
||||
|
||||
Object.defineProperty(window, "localStorage", {
|
||||
writable: true,
|
||||
value: { removeItem: vi.fn() },
|
||||
});
|
||||
|
||||
Object.defineProperty(window, "location", {
|
||||
writable: true,
|
||||
value: { replace: vi.fn() },
|
||||
@@ -137,12 +151,15 @@ describe("DeleteAccountModal", () => {
|
||||
const form = screen.getByTestId("deleteAccountForm");
|
||||
fireEvent.submit(form);
|
||||
|
||||
const removeItemSpy = vi.spyOn(window.localStorage, "removeItem");
|
||||
|
||||
await waitFor(() => {
|
||||
expect(deleteUserAction).toHaveBeenCalled();
|
||||
expect(mockSignOut).toHaveBeenCalledWith({
|
||||
reason: "account_deletion",
|
||||
redirect: false, // Updated to match new implementation
|
||||
});
|
||||
expect(removeItemSpy).toHaveBeenCalledWith(FORMBRICKS_ENVIRONMENT_ID_LS);
|
||||
expect(window.location.replace).toHaveBeenCalledWith(
|
||||
"https://app.formbricks.com/s/clri52y3z8f221225wjdhsoo2"
|
||||
);
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
"use client";
|
||||
|
||||
import { FORMBRICKS_ENVIRONMENT_ID_LS } from "@/lib/localStorage";
|
||||
import { useSignOut } from "@/modules/auth/hooks/use-sign-out";
|
||||
import { DeleteDialog } from "@/modules/ui/components/delete-dialog";
|
||||
import { Input } from "@/modules/ui/components/input";
|
||||
@@ -38,6 +39,8 @@ export const DeleteAccountModal = ({
|
||||
setDeleting(true);
|
||||
await deleteUserAction();
|
||||
|
||||
localStorage.removeItem(FORMBRICKS_ENVIRONMENT_ID_LS);
|
||||
|
||||
// Sign out with account deletion reason (no automatic redirect)
|
||||
await signOutWithAudit({
|
||||
reason: "account_deletion",
|
||||
|
||||
@@ -118,7 +118,7 @@ export const LinkSurvey = ({
|
||||
}, [survey.isVerifyEmailEnabled, verifiedEmail]);
|
||||
|
||||
if (hasFinishedSingleUseResponse) {
|
||||
return <SurveyLinkUsed singleUseMessage={survey.singleUse} />;
|
||||
return <SurveyLinkUsed singleUseMessage={survey.singleUse} project={project} />;
|
||||
}
|
||||
|
||||
if (survey.isVerifyEmailEnabled && emailVerificationStatus !== "verified") {
|
||||
|
||||
@@ -126,4 +126,19 @@ describe("SurveyInactive", () => {
|
||||
expect(screen.getByTestId("button")).toBeInTheDocument();
|
||||
expect(screen.getByTestId("mock-image")).toBeInTheDocument();
|
||||
});
|
||||
|
||||
test("shows branding when linkSurveyBranding is true", async () => {
|
||||
const Component = await SurveyInactive({ status: "paused", project: { linkSurveyBranding: true } });
|
||||
render(Component);
|
||||
expect(screen.getByTestId("mock-image")).toBeInTheDocument();
|
||||
expect(screen.getByTestId("footer-link")).toBeInTheDocument();
|
||||
expect(screen.getByTestId("footer-link")).toHaveAttribute("href", "https://formbricks.com");
|
||||
});
|
||||
|
||||
test("hides branding when linkSurveyBranding is false", async () => {
|
||||
const Component = await SurveyInactive({ status: "paused", project: { linkSurveyBranding: false } });
|
||||
render(Component);
|
||||
expect(screen.queryByTestId("mock-image")).not.toBeInTheDocument();
|
||||
expect(screen.queryByTestId("footer-link")).not.toBeInTheDocument();
|
||||
});
|
||||
});
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
import { Button } from "@/modules/ui/components/button";
|
||||
import { getTranslate } from "@/tolgee/server";
|
||||
import { Project } from "@prisma/client";
|
||||
import { CheckCircle2Icon, HelpCircleIcon, PauseCircleIcon } from "lucide-react";
|
||||
import Image from "next/image";
|
||||
import Link from "next/link";
|
||||
@@ -9,9 +10,11 @@ import footerLogo from "../lib/footerlogo.svg";
|
||||
export const SurveyInactive = async ({
|
||||
status,
|
||||
surveyClosedMessage,
|
||||
project,
|
||||
}: {
|
||||
status: "paused" | "completed" | "link invalid" | "scheduled" | "response submitted";
|
||||
surveyClosedMessage?: TSurveyClosedMessage | null;
|
||||
project?: Pick<Project, "linkSurveyBranding">;
|
||||
}) => {
|
||||
const t = await getTranslate();
|
||||
const icons = {
|
||||
@@ -28,10 +31,15 @@ export const SurveyInactive = async ({
|
||||
"response submitted": t("s.response_submitted"),
|
||||
};
|
||||
|
||||
const showCTA =
|
||||
status !== "link invalid" &&
|
||||
status !== "response submitted" &&
|
||||
((status !== "paused" && status !== "completed") || project?.linkSurveyBranding || !project) &&
|
||||
!(status === "completed" && surveyClosedMessage);
|
||||
|
||||
return (
|
||||
<div className="flex h-full flex-col items-center justify-between bg-gradient-to-br from-slate-200 to-slate-50 px-4 py-8 text-center">
|
||||
<div></div>
|
||||
<div className="flex flex-col items-center space-y-3 text-slate-300">
|
||||
<div className="my-auto flex flex-col items-center space-y-3 text-slate-300">
|
||||
{icons[status]}
|
||||
<h1 className="text-4xl font-bold text-slate-800">
|
||||
{status === "completed" && surveyClosedMessage
|
||||
@@ -43,19 +51,19 @@ export const SurveyInactive = async ({
|
||||
? surveyClosedMessage.subheading
|
||||
: descriptions[status]}
|
||||
</p>
|
||||
{!(status === "completed" && surveyClosedMessage) &&
|
||||
status !== "link invalid" &&
|
||||
status !== "response submitted" && (
|
||||
<Button className="mt-2" asChild>
|
||||
<Link href="https://formbricks.com">{t("s.create_your_own")}</Link>
|
||||
</Button>
|
||||
)}
|
||||
</div>
|
||||
<div>
|
||||
<Link href="https://formbricks.com">
|
||||
<Image src={footerLogo as string} alt="Brand logo" className="mx-auto w-40" />
|
||||
</Link>
|
||||
{showCTA && (
|
||||
<Button className="mt-2" asChild>
|
||||
<Link href="https://formbricks.com">{t("s.create_your_own")}</Link>
|
||||
</Button>
|
||||
)}
|
||||
</div>
|
||||
{(!project || project.linkSurveyBranding) && (
|
||||
<div>
|
||||
<Link href="https://formbricks.com">
|
||||
<Image src={footerLogo as string} alt="Brand logo" className="mx-auto w-40" />
|
||||
</Link>
|
||||
</div>
|
||||
)}
|
||||
</div>
|
||||
);
|
||||
};
|
||||
|
||||
@@ -13,13 +13,17 @@ vi.mock("next/link", () => ({
|
||||
default: vi.fn(({ children, href }) => <a href={href}>{children}</a>),
|
||||
}));
|
||||
|
||||
const mockProject = {
|
||||
linkSurveyBranding: true,
|
||||
};
|
||||
|
||||
describe("SurveyLinkUsed", () => {
|
||||
afterEach(() => {
|
||||
cleanup();
|
||||
});
|
||||
|
||||
test("renders with default values when singleUseMessage is null", () => {
|
||||
render(<SurveyLinkUsed singleUseMessage={null} />);
|
||||
render(<SurveyLinkUsed singleUseMessage={null} project={mockProject} />);
|
||||
|
||||
expect(screen.getByText("s.survey_already_answered_heading")).toBeInTheDocument();
|
||||
expect(screen.getByText("s.survey_already_answered_subheading")).toBeInTheDocument();
|
||||
@@ -31,17 +35,28 @@ describe("SurveyLinkUsed", () => {
|
||||
subheading: "Custom Subheading",
|
||||
} as any;
|
||||
|
||||
render(<SurveyLinkUsed singleUseMessage={singleUseMessage} />);
|
||||
render(<SurveyLinkUsed singleUseMessage={singleUseMessage} project={mockProject} />);
|
||||
|
||||
expect(screen.getByText("Custom Heading")).toBeInTheDocument();
|
||||
expect(screen.getByText("Custom Subheading")).toBeInTheDocument();
|
||||
});
|
||||
|
||||
test("renders footer with link to Formbricks", () => {
|
||||
render(<SurveyLinkUsed singleUseMessage={null} />);
|
||||
test("renders footer with link to Formbricks when branding is enabled", () => {
|
||||
render(<SurveyLinkUsed singleUseMessage={null} project={mockProject} />);
|
||||
|
||||
const link = document.querySelector('a[href="https://formbricks.com"]');
|
||||
expect(link).toBeInTheDocument();
|
||||
expect(vi.mocked(Image)).toHaveBeenCalled();
|
||||
});
|
||||
|
||||
test("does not render footer when branding is disabled", () => {
|
||||
const projectWithoutBranding = {
|
||||
linkSurveyBranding: false,
|
||||
};
|
||||
|
||||
render(<SurveyLinkUsed singleUseMessage={null} project={projectWithoutBranding} />);
|
||||
|
||||
const link = document.querySelector('a[href="https://formbricks.com"]');
|
||||
expect(link).not.toBeInTheDocument();
|
||||
});
|
||||
});
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
"use client";
|
||||
|
||||
import { Project } from "@prisma/client";
|
||||
import { useTranslate } from "@tolgee/react";
|
||||
import { CheckCircle2Icon } from "lucide-react";
|
||||
import Image from "next/image";
|
||||
@@ -9,27 +10,29 @@ import footerLogo from "../lib/footerlogo.svg";
|
||||
|
||||
interface SurveyLinkUsedProps {
|
||||
singleUseMessage: TSurveySingleUse | null;
|
||||
project?: Pick<Project, "linkSurveyBranding">;
|
||||
}
|
||||
|
||||
export const SurveyLinkUsed = ({ singleUseMessage }: SurveyLinkUsedProps) => {
|
||||
export const SurveyLinkUsed = ({ singleUseMessage, project }: SurveyLinkUsedProps) => {
|
||||
const { t } = useTranslate();
|
||||
const defaultHeading = t("s.survey_already_answered_heading");
|
||||
const defaultSubheading = t("s.survey_already_answered_subheading");
|
||||
return (
|
||||
<div className="flex min-h-screen flex-col items-center justify-between bg-gradient-to-tr from-slate-200 to-slate-50 py-8 text-center">
|
||||
<div></div>
|
||||
<div className="flex flex-col items-center space-y-3 text-slate-300">
|
||||
<div className="my-auto flex flex-col items-center space-y-3 text-slate-300">
|
||||
<CheckCircle2Icon className="h-20 w-20" />
|
||||
<h1 className="text-4xl font-bold text-slate-800">{singleUseMessage?.heading ?? defaultHeading}</h1>
|
||||
<p className="text-lg leading-10 text-slate-500">
|
||||
{singleUseMessage?.subheading ?? defaultSubheading}
|
||||
</p>
|
||||
</div>
|
||||
<div>
|
||||
<Link href="https://formbricks.com">
|
||||
<Image src={footerLogo as string} alt="Brand logo" className="mx-auto w-40" />
|
||||
</Link>
|
||||
</div>
|
||||
{(!project || project.linkSurveyBranding) && (
|
||||
<div>
|
||||
<Link href="https://formbricks.com">
|
||||
<Image src={footerLogo as string} alt="Brand logo" className="mx-auto w-40" />
|
||||
</Link>
|
||||
</div>
|
||||
)}
|
||||
</div>
|
||||
);
|
||||
};
|
||||
|
||||
@@ -251,4 +251,33 @@ describe("renderSurvey", () => {
|
||||
})
|
||||
).rejects.toThrow("Project not found");
|
||||
});
|
||||
|
||||
describe("Survey Inactive States", () => {
|
||||
test("renders SurveyInactive with project when survey is paused", async () => {
|
||||
const survey: TSurvey = { ...mockSurvey, status: "paused" };
|
||||
const project = { id: "project-123", linkSurveyBranding: true };
|
||||
vi.mocked(getProjectByEnvironmentId).mockResolvedValueOnce(project as any);
|
||||
|
||||
const result = await renderSurvey({
|
||||
survey: survey,
|
||||
searchParams: {},
|
||||
isPreview: false,
|
||||
});
|
||||
|
||||
expect(result).toBeDefined();
|
||||
});
|
||||
|
||||
test("renders SurveyInactive without project when project is not found", async () => {
|
||||
const survey: TSurvey = { ...mockSurvey, status: "paused" };
|
||||
vi.mocked(getProjectByEnvironmentId).mockResolvedValueOnce(null);
|
||||
|
||||
const result = await renderSurvey({
|
||||
survey: survey,
|
||||
searchParams: {},
|
||||
isPreview: false,
|
||||
});
|
||||
|
||||
expect(result).toBeDefined();
|
||||
});
|
||||
});
|
||||
});
|
||||
|
||||
@@ -60,10 +60,12 @@ export const renderSurvey = async ({
|
||||
const isSpamProtectionEnabled = Boolean(IS_RECAPTCHA_CONFIGURED && survey.recaptcha?.enabled);
|
||||
|
||||
if (survey.status !== "inProgress" && !isPreview) {
|
||||
const project = await getProjectByEnvironmentId(survey.environmentId);
|
||||
return (
|
||||
<SurveyInactive
|
||||
status={survey.status}
|
||||
surveyClosedMessage={survey.surveyClosedMessage ? survey.surveyClosedMessage : undefined}
|
||||
project={project || undefined}
|
||||
/>
|
||||
);
|
||||
}
|
||||
|
||||
@@ -4,6 +4,7 @@ import { SurveyInactive } from "@/modules/survey/link/components/survey-inactive
|
||||
import { renderSurvey } from "@/modules/survey/link/components/survey-renderer";
|
||||
import { getExistingContactResponse } from "@/modules/survey/link/lib/data";
|
||||
import { getBasicSurveyMetadata } from "@/modules/survey/link/lib/metadata-utils";
|
||||
import { getProjectByEnvironmentId } from "@/modules/survey/link/lib/project";
|
||||
import type { Metadata } from "next";
|
||||
import { notFound } from "next/navigation";
|
||||
|
||||
@@ -50,12 +51,19 @@ export const ContactSurveyPage = async (props: ContactSurveyPageProps) => {
|
||||
|
||||
const result = verifyContactSurveyToken(jwt);
|
||||
if (!result.ok) {
|
||||
// When token is invalid, we don't have survey data to get project branding settings
|
||||
// So we show SurveyInactive without project data (shows branding by default for backward compatibility)
|
||||
return <SurveyInactive status="link invalid" />;
|
||||
}
|
||||
const { surveyId, contactId } = result.data;
|
||||
|
||||
const existingResponse = await getExistingContactResponse(surveyId, contactId)();
|
||||
if (existingResponse) {
|
||||
const survey = await getSurvey(surveyId);
|
||||
if (survey) {
|
||||
const project = await getProjectByEnvironmentId(survey.environmentId);
|
||||
return <SurveyInactive status="response submitted" project={project || undefined} />;
|
||||
}
|
||||
return <SurveyInactive status="response submitted" />;
|
||||
}
|
||||
|
||||
|
||||
@@ -47,9 +47,5 @@ describe("LinkSurveyNotFound", () => {
|
||||
// Check the basic elements that are visible in the rendered output
|
||||
expect(screen.getByText("Survey not found.")).toBeInTheDocument();
|
||||
expect(screen.getByText("There is no survey with this ID.")).toBeInTheDocument();
|
||||
expect(screen.getByTestId("mock-help-circle-icon")).toBeInTheDocument();
|
||||
|
||||
// Check the button exists
|
||||
expect(screen.getByTestId("mock-button")).toBeInTheDocument();
|
||||
});
|
||||
});
|
||||
|
||||
@@ -1,26 +1,12 @@
|
||||
import { Button } from "@/modules/ui/components/button";
|
||||
import { HelpCircleIcon } from "lucide-react";
|
||||
import { StaticImport } from "next/dist/shared/lib/get-img-props";
|
||||
import Image from "next/image";
|
||||
import Link from "next/link";
|
||||
import footerLogo from "./lib/footerlogo.svg";
|
||||
|
||||
export const LinkSurveyNotFound = () => {
|
||||
return (
|
||||
<div className="flex h-full flex-col items-center justify-between bg-gradient-to-br from-slate-200 to-slate-50 py-8 text-center">
|
||||
<div></div>
|
||||
<div className="flex h-full flex-col items-center justify-center bg-gradient-to-br from-slate-200 to-slate-50 py-8 text-center">
|
||||
<div className="flex flex-col items-center space-y-3 text-slate-300">
|
||||
<HelpCircleIcon className="h-20 w-20" />,
|
||||
<HelpCircleIcon className="h-20 w-20" />
|
||||
<h1 className="text-4xl font-bold text-slate-800">Survey not found.</h1>
|
||||
<p className="text-lg leading-10 text-slate-500">There is no survey with this ID.</p>
|
||||
<Button className="mt-2" asChild>
|
||||
<Link href="https://formbricks.com">Create your own</Link>
|
||||
</Button>
|
||||
</div>
|
||||
<div>
|
||||
<Link href="https://formbricks.com">
|
||||
<Image src={footerLogo as StaticImport} alt="Brand logo" className="mx-auto w-40" />
|
||||
</Link>
|
||||
</div>
|
||||
</div>
|
||||
);
|
||||
|
||||
@@ -1,14 +1,15 @@
|
||||
import { validateSurveySingleUseId } from "@/app/lib/singleUseSurveys";
|
||||
import { getSurvey } from "@/modules/survey/lib/survey";
|
||||
import { SurveyInactive } from "@/modules/survey/link/components/survey-inactive";
|
||||
import { renderSurvey } from "@/modules/survey/link/components/survey-renderer";
|
||||
import { getResponseBySingleUseId } from "@/modules/survey/link/lib/data";
|
||||
import { getSurveyWithMetadata } from "@/modules/survey/link/lib/data";
|
||||
import { getResponseBySingleUseId, getSurveyWithMetadata } from "@/modules/survey/link/lib/data";
|
||||
import { getProjectByEnvironmentId } from "@/modules/survey/link/lib/project";
|
||||
import { getMetadataForLinkSurvey } from "@/modules/survey/link/metadata";
|
||||
import "@testing-library/jest-dom/vitest";
|
||||
import { cleanup } from "@testing-library/react";
|
||||
import { cleanup, render } from "@testing-library/react";
|
||||
import { notFound } from "next/navigation";
|
||||
import { afterEach, describe, expect, test, vi } from "vitest";
|
||||
import { TResponseData } from "@formbricks/types/responses";
|
||||
import { logger } from "@formbricks/logger";
|
||||
import { TSurvey } from "@formbricks/types/surveys/types";
|
||||
import { LinkSurveyPage, generateMetadata } from "./page";
|
||||
|
||||
@@ -26,22 +27,32 @@ vi.mock("@/modules/survey/lib/survey", () => ({
|
||||
}));
|
||||
|
||||
vi.mock("@/modules/survey/link/components/survey-inactive", () => ({
|
||||
SurveyInactive: vi.fn(() => <div data-testid="survey-inactive" />),
|
||||
SurveyInactive: vi.fn(() => <div>Survey Inactive</div>),
|
||||
}));
|
||||
|
||||
vi.mock("@/modules/survey/link/components/survey-renderer", () => ({
|
||||
renderSurvey: vi.fn(() => <div data-testid="survey-renderer" />),
|
||||
renderSurvey: vi.fn(() => <div>Render Survey</div>),
|
||||
}));
|
||||
|
||||
vi.mock("@/modules/survey/link/lib/data", () => ({
|
||||
getResponseBySingleUseId: vi.fn(() => vi.fn()),
|
||||
getResponseBySingleUseId: vi.fn(),
|
||||
getSurveyWithMetadata: vi.fn(),
|
||||
}));
|
||||
|
||||
vi.mock("@/modules/survey/link/lib/project", () => ({
|
||||
getProjectByEnvironmentId: vi.fn(),
|
||||
}));
|
||||
|
||||
vi.mock("@/modules/survey/link/metadata", () => ({
|
||||
getMetadataForLinkSurvey: vi.fn(),
|
||||
}));
|
||||
|
||||
vi.mock("@formbricks/logger", () => ({
|
||||
logger: {
|
||||
error: vi.fn(),
|
||||
},
|
||||
}));
|
||||
|
||||
describe("LinkSurveyPage", () => {
|
||||
afterEach(() => {
|
||||
cleanup();
|
||||
@@ -232,4 +243,169 @@ describe("LinkSurveyPage", () => {
|
||||
})
|
||||
);
|
||||
});
|
||||
|
||||
test("should show 'link invalid' for single-use survey without suId", async () => {
|
||||
const singleUseSurvey = { ...mockSurvey, singleUse: { enabled: true, isEncrypted: false } };
|
||||
vi.mocked(getSurveyWithMetadata).mockResolvedValue(singleUseSurvey);
|
||||
vi.mocked(getProjectByEnvironmentId).mockResolvedValue({ id: "proj-123" } as any);
|
||||
|
||||
const props = {
|
||||
params: Promise.resolve({ surveyId: "survey123" }),
|
||||
searchParams: Promise.resolve({}),
|
||||
};
|
||||
const Page = await LinkSurveyPage(props);
|
||||
render(Page);
|
||||
|
||||
expect(vi.mocked(SurveyInactive).mock.calls[0][0]).toEqual({
|
||||
status: "link invalid",
|
||||
project: { id: "proj-123" },
|
||||
});
|
||||
});
|
||||
|
||||
test("should show 'link invalid' for encrypted single-use survey with invalid suId", async () => {
|
||||
const singleUseSurvey = { ...mockSurvey, singleUse: { enabled: true, isEncrypted: true } };
|
||||
vi.mocked(getSurveyWithMetadata).mockResolvedValue(singleUseSurvey);
|
||||
vi.mocked(validateSurveySingleUseId).mockReturnValue(undefined);
|
||||
vi.mocked(getProjectByEnvironmentId).mockResolvedValue({ id: "proj-123" } as any);
|
||||
|
||||
const props = {
|
||||
params: Promise.resolve({ surveyId: "survey123" }),
|
||||
searchParams: Promise.resolve({ suId: "invalid-suid" }),
|
||||
};
|
||||
const Page = await LinkSurveyPage(props);
|
||||
render(Page);
|
||||
|
||||
expect(vi.mocked(SurveyInactive).mock.calls[0][0]).toEqual({
|
||||
status: "link invalid",
|
||||
project: { id: "proj-123" },
|
||||
});
|
||||
});
|
||||
|
||||
test("should render survey for encrypted single-use survey with valid suId", async () => {
|
||||
const singleUseSurvey = { ...mockSurvey, singleUse: { enabled: true, isEncrypted: true } };
|
||||
vi.mocked(getSurveyWithMetadata).mockResolvedValue(singleUseSurvey);
|
||||
vi.mocked(validateSurveySingleUseId).mockReturnValue("valid-suid");
|
||||
|
||||
const mockResponseFn = vi.fn().mockResolvedValue({ id: "res-1" });
|
||||
vi.mocked(getResponseBySingleUseId).mockReturnValue(mockResponseFn);
|
||||
|
||||
const props = {
|
||||
params: Promise.resolve({ surveyId: "survey-123" }),
|
||||
searchParams: Promise.resolve({ suId: "encrypted-suid" }),
|
||||
};
|
||||
const Page = await LinkSurveyPage(props);
|
||||
render(Page);
|
||||
|
||||
expect(vi.mocked(renderSurvey).mock.calls[0][0]).toEqual(
|
||||
expect.objectContaining({
|
||||
singleUseId: "valid-suid",
|
||||
singleUseResponse: { id: "res-1" },
|
||||
})
|
||||
);
|
||||
});
|
||||
|
||||
test("should render survey for non-encrypted single-use survey", async () => {
|
||||
const singleUseSurvey = { ...mockSurvey, singleUse: { enabled: true, isEncrypted: false } };
|
||||
vi.mocked(getSurveyWithMetadata).mockResolvedValue(singleUseSurvey);
|
||||
|
||||
const mockResponseFn = vi.fn().mockResolvedValue({ id: "res-1" });
|
||||
vi.mocked(getResponseBySingleUseId).mockReturnValue(mockResponseFn);
|
||||
|
||||
const props = {
|
||||
params: Promise.resolve({ surveyId: "survey-123" }),
|
||||
searchParams: Promise.resolve({ suId: "plain-suid" }),
|
||||
};
|
||||
const Page = await LinkSurveyPage(props);
|
||||
render(Page);
|
||||
|
||||
expect(vi.mocked(renderSurvey).mock.calls[0][0]).toEqual(
|
||||
expect.objectContaining({
|
||||
singleUseId: "plain-suid",
|
||||
singleUseResponse: { id: "res-1" },
|
||||
})
|
||||
);
|
||||
});
|
||||
|
||||
test("should render survey with undefined response when getResponseBySingleUseId fails", async () => {
|
||||
const singleUseSurvey = { ...mockSurvey, singleUse: { enabled: true, isEncrypted: false } };
|
||||
vi.mocked(getSurveyWithMetadata).mockResolvedValue(singleUseSurvey);
|
||||
|
||||
const mockResponseFn = vi.fn().mockRejectedValue(new Error("DB error"));
|
||||
vi.mocked(getResponseBySingleUseId).mockReturnValue(mockResponseFn);
|
||||
|
||||
const props = {
|
||||
params: Promise.resolve({ surveyId: "survey123" }),
|
||||
searchParams: Promise.resolve({ suId: "plain-suid" }),
|
||||
};
|
||||
const Page = await LinkSurveyPage(props);
|
||||
render(Page);
|
||||
|
||||
expect(logger.error).toHaveBeenCalled();
|
||||
expect(vi.mocked(renderSurvey).mock.calls[0][0]).toEqual(
|
||||
expect.objectContaining({
|
||||
singleUseId: "plain-suid",
|
||||
singleUseResponse: undefined,
|
||||
})
|
||||
);
|
||||
});
|
||||
|
||||
test("should handle missing project for single-use survey without suId", async () => {
|
||||
const singleUseSurvey = { ...mockSurvey, singleUse: { enabled: true, isEncrypted: false } };
|
||||
vi.mocked(getSurveyWithMetadata).mockResolvedValue(singleUseSurvey);
|
||||
vi.mocked(getProjectByEnvironmentId).mockResolvedValue(null);
|
||||
|
||||
const props = {
|
||||
params: Promise.resolve({ surveyId: "survey123" }),
|
||||
searchParams: Promise.resolve({}),
|
||||
};
|
||||
const Page = await LinkSurveyPage(props);
|
||||
render(Page);
|
||||
|
||||
expect(vi.mocked(SurveyInactive).mock.calls[0][0]).toEqual({
|
||||
status: "link invalid",
|
||||
project: undefined,
|
||||
});
|
||||
});
|
||||
|
||||
test("LinkSurveyPage calls notFound when getSurveyWithMetadata throws an error", async () => {
|
||||
const databaseError = new Error("Database connection failed");
|
||||
vi.mocked(getSurveyWithMetadata).mockRejectedValue(databaseError);
|
||||
|
||||
const props = {
|
||||
params: Promise.resolve({ surveyId: "survey123" }),
|
||||
searchParams: Promise.resolve({}),
|
||||
};
|
||||
|
||||
await LinkSurveyPage(props);
|
||||
|
||||
expect(getSurveyWithMetadata).toHaveBeenCalledWith("survey123");
|
||||
expect(logger.error).toHaveBeenCalledWith(databaseError, "Error fetching survey");
|
||||
expect(notFound).toHaveBeenCalled();
|
||||
});
|
||||
});
|
||||
|
||||
describe("generateMetadata", () => {
|
||||
afterEach(() => {
|
||||
vi.resetAllMocks();
|
||||
});
|
||||
|
||||
test("should call notFound for invalid surveyId", async () => {
|
||||
const props = {
|
||||
params: Promise.resolve({ surveyId: "invalid-id" }),
|
||||
searchParams: Promise.resolve({}),
|
||||
};
|
||||
await generateMetadata(props);
|
||||
expect(notFound).toHaveBeenCalled();
|
||||
});
|
||||
|
||||
test("should call getMetadataForLinkSurvey for valid surveyId", async () => {
|
||||
vi.mocked(getMetadataForLinkSurvey).mockResolvedValue({ title: "Test Survey" });
|
||||
const props = {
|
||||
params: Promise.resolve({ surveyId: "survey-123" }),
|
||||
searchParams: Promise.resolve({}),
|
||||
};
|
||||
const metadata = await generateMetadata(props);
|
||||
expect(getMetadataForLinkSurvey).toHaveBeenCalledWith("survey-123");
|
||||
expect(metadata).toEqual({ title: "Test Survey" });
|
||||
});
|
||||
});
|
||||
|
||||
@@ -2,11 +2,13 @@ import { validateSurveySingleUseId } from "@/app/lib/singleUseSurveys";
|
||||
import { SurveyInactive } from "@/modules/survey/link/components/survey-inactive";
|
||||
import { renderSurvey } from "@/modules/survey/link/components/survey-renderer";
|
||||
import { getResponseBySingleUseId, getSurveyWithMetadata } from "@/modules/survey/link/lib/data";
|
||||
import { getProjectByEnvironmentId } from "@/modules/survey/link/lib/project";
|
||||
import { getMetadataForLinkSurvey } from "@/modules/survey/link/metadata";
|
||||
import type { Metadata } from "next";
|
||||
import { notFound } from "next/navigation";
|
||||
import { logger } from "@formbricks/logger";
|
||||
import { ZId } from "@formbricks/types/common";
|
||||
import { TSurvey } from "@formbricks/types/surveys/types";
|
||||
|
||||
interface LinkSurveyPageProps {
|
||||
params: Promise<{
|
||||
@@ -42,7 +44,14 @@ export const LinkSurveyPage = async (props: LinkSurveyPageProps) => {
|
||||
const isPreview = searchParams.preview === "true";
|
||||
|
||||
// Use optimized survey data fetcher (includes all necessary data)
|
||||
const survey = await getSurveyWithMetadata(params.surveyId);
|
||||
let survey: TSurvey | null = null;
|
||||
try {
|
||||
survey = await getSurveyWithMetadata(params.surveyId);
|
||||
} catch (error) {
|
||||
logger.error(error, "Error fetching survey");
|
||||
return notFound();
|
||||
}
|
||||
|
||||
const suId = searchParams.suId;
|
||||
|
||||
const isSingleUseSurvey = survey?.singleUse?.enabled;
|
||||
@@ -53,7 +62,8 @@ export const LinkSurveyPage = async (props: LinkSurveyPageProps) => {
|
||||
if (isSingleUseSurvey) {
|
||||
// check if the single use id is present for single use surveys
|
||||
if (!suId) {
|
||||
return <SurveyInactive status="link invalid" />;
|
||||
const project = await getProjectByEnvironmentId(survey.environmentId);
|
||||
return <SurveyInactive status="link invalid" project={project ?? undefined} />;
|
||||
}
|
||||
|
||||
// if encryption is enabled, validate the single use id
|
||||
@@ -61,7 +71,8 @@ export const LinkSurveyPage = async (props: LinkSurveyPageProps) => {
|
||||
if (isSingleUseSurveyEncrypted) {
|
||||
validatedSingleUseId = validateSurveySingleUseId(suId);
|
||||
if (!validatedSingleUseId) {
|
||||
return <SurveyInactive status="link invalid" />;
|
||||
const project = await getProjectByEnvironmentId(survey.environmentId);
|
||||
return <SurveyInactive status="link invalid" project={project ?? undefined} />;
|
||||
}
|
||||
}
|
||||
// if encryption is disabled, use the suId as is
|
||||
|
||||
@@ -1,17 +1,61 @@
|
||||
import { useSignOut } from "@/modules/auth/hooks/use-sign-out";
|
||||
import { render } from "@testing-library/react";
|
||||
import { signOut } from "next-auth/react";
|
||||
import { describe, expect, test, vi } from "vitest";
|
||||
import { type MockedFunction, beforeEach, describe, expect, test, vi } from "vitest";
|
||||
import { ClientLogout } from "./index";
|
||||
|
||||
// Mock the localStorage
|
||||
const mockRemoveItem = vi.fn();
|
||||
Object.defineProperty(window, "localStorage", {
|
||||
value: {
|
||||
removeItem: mockRemoveItem,
|
||||
},
|
||||
});
|
||||
|
||||
// Mock next-auth/react
|
||||
vi.mock("next-auth/react", () => ({
|
||||
signOut: vi.fn(),
|
||||
const mockSignOut = vi.fn();
|
||||
vi.mock("@/modules/auth/hooks/use-sign-out", () => ({
|
||||
useSignOut: vi.fn(),
|
||||
}));
|
||||
|
||||
const mockUseSignOut = useSignOut as MockedFunction<typeof useSignOut>;
|
||||
|
||||
describe("ClientLogout", () => {
|
||||
test("calls signOut on render", () => {
|
||||
beforeEach(() => {
|
||||
vi.clearAllMocks();
|
||||
mockUseSignOut.mockReturnValue({
|
||||
signOut: mockSignOut,
|
||||
});
|
||||
});
|
||||
|
||||
test("calls signOut with correct parameters on render", () => {
|
||||
render(<ClientLogout />);
|
||||
expect(signOut).toHaveBeenCalled();
|
||||
|
||||
expect(mockUseSignOut).toHaveBeenCalled();
|
||||
|
||||
expect(mockSignOut).toHaveBeenCalledWith({
|
||||
reason: "forced_logout",
|
||||
redirectUrl: "/auth/login",
|
||||
redirect: false,
|
||||
callbackUrl: "/auth/login",
|
||||
});
|
||||
});
|
||||
|
||||
test("handles missing userId and userEmail", () => {
|
||||
render(<ClientLogout />);
|
||||
|
||||
expect(mockUseSignOut).toHaveBeenCalled();
|
||||
|
||||
expect(mockSignOut).toHaveBeenCalledWith({
|
||||
reason: "forced_logout",
|
||||
redirectUrl: "/auth/login",
|
||||
redirect: false,
|
||||
callbackUrl: "/auth/login",
|
||||
});
|
||||
});
|
||||
|
||||
test("removes environment ID from localStorage", () => {
|
||||
render(<ClientLogout />);
|
||||
expect(mockRemoveItem).toHaveBeenCalledWith("formbricks-environment-id");
|
||||
});
|
||||
|
||||
test("renders null", () => {
|
||||
|
||||
@@ -1,11 +1,20 @@
|
||||
"use client";
|
||||
|
||||
import { signOut } from "next-auth/react";
|
||||
import { FORMBRICKS_ENVIRONMENT_ID_LS } from "@/lib/localStorage";
|
||||
import { useSignOut } from "@/modules/auth/hooks/use-sign-out";
|
||||
import { useEffect } from "react";
|
||||
|
||||
export const ClientLogout = () => {
|
||||
const { signOut: signOutWithAudit } = useSignOut();
|
||||
|
||||
useEffect(() => {
|
||||
signOut();
|
||||
localStorage.removeItem(FORMBRICKS_ENVIRONMENT_ID_LS);
|
||||
signOutWithAudit({
|
||||
reason: "forced_logout",
|
||||
redirectUrl: "/auth/login",
|
||||
redirect: false,
|
||||
callbackUrl: "/auth/login",
|
||||
});
|
||||
});
|
||||
return null;
|
||||
};
|
||||
|
||||
@@ -189,7 +189,7 @@ export function RankingQuestion({
|
||||
handleItemClick(item);
|
||||
}}
|
||||
type="button"
|
||||
aria-label={`Select ${getLocalizedValue(item.label, languageCode)} for ranking`}
|
||||
aria-label={`Select ${getLocalizedValue(item.label,languageCode)} for ranking`}
|
||||
className="fb-flex fb-gap-x-4 fb-px-4 fb-items-center fb-grow fb-h-full group text-left focus:outline-none">
|
||||
<span
|
||||
className={cn(
|
||||
@@ -207,13 +207,13 @@ export function RankingQuestion({
|
||||
{isSorted ? (
|
||||
<div className="fb-flex fb-flex-col fb-h-full fb-grow-0 fb-border-l fb-border-border">
|
||||
<button
|
||||
tabIndex={isFirst ? -1 : 0}
|
||||
tabIndex={isFirst?-1:0}
|
||||
type="button"
|
||||
onClick={(e) => {
|
||||
e.preventDefault();
|
||||
handleMove(item.id, "up");
|
||||
}}
|
||||
aria-label={`Move ${getLocalizedValue(item.label, languageCode)} up`}
|
||||
aria-label={`Move ${getLocalizedValue(item.label,languageCode)} up`}
|
||||
className={cn(
|
||||
"fb-px-2 fb-flex fb-flex-1 fb-items-center fb-justify-center",
|
||||
isFirst
|
||||
@@ -236,7 +236,7 @@ export function RankingQuestion({
|
||||
</svg>
|
||||
</button>
|
||||
<button
|
||||
tabIndex={isLast ? -1 : 0}
|
||||
tabIndex={isLast?-1:0}
|
||||
type="button"
|
||||
onClick={(e) => {
|
||||
e.preventDefault();
|
||||
@@ -248,7 +248,7 @@ export function RankingQuestion({
|
||||
? "fb-opacity-30 fb-cursor-not-allowed"
|
||||
: "hover:fb-bg-black/5 fb-rounded-br-custom fb-transition-colors"
|
||||
)}
|
||||
aria-label={`Move ${getLocalizedValue(item.label, languageCode)} down`}
|
||||
aria-label={`Move ${getLocalizedValue(item.label,languageCode)} down`}
|
||||
disabled={isLast}>
|
||||
<svg
|
||||
xmlns="http://www.w3.org/2000/svg"
|
||||
|
||||
Reference in New Issue
Block a user