mirror/formbricks-formbricks
1
0
Fork 0
mirror of https://github.com/formbricks/formbricks.git synced 2025-12-30 10:19:51 -06:00
Code Issues Packages Projects Releases 100 Wiki Activity

fix: adds cached service for getting contact with attributes (#4598)

Browse Source
This commit is contained in:
Anshuman Pandey
2025-01-15 23:05:35 +05:30
committed by GitHub
parent 7c60c57c60
commit d3adc1629c
2 changed files with 49 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
apps/web/modules/ee/contacts/api/client/[environmentId]/contacts/[userId]/attributes/lib/contact.ts Normal file
View File

@@ -0,0 +1,47 @@
import { contactCache } from "@/lib/cache/contact";
import { contactAttributeCache } from "@/lib/cache/contact-attribute";
import { contactAttributeKeyCache } from "@/lib/cache/contact-attribute-key";
import { cache as reactCache } from "react";
import { prisma } from "@formbricks/database";
import { cache } from "@formbricks/lib/cache";
export const getContactByUserIdWithAttributes = reactCache(
(environmentId: string, userId: string, updatedAttributes: Record<string, string>) =>
cache(
async () => {
const contact = await prisma.contact.findFirst({
where: {
environmentId,
attributes: { some: { attributeKey: { key: "userId", environmentId }, value: userId } },
},
select: {
id: true,
attributes: {
where: {
attributeKey: {
key: {
in: Object.keys(updatedAttributes),
},
},
},
select: { attributeKey: { select: { key: true } }, value: true },
},
},
});
if (!contact) {
return null;
}
return contact;
},
[`getContactByUserId-${environmentId}-${userId}-${JSON.stringify(updatedAttributes)}`],
{
tags: [
contactCache.tag.byEnvironmentIdAndUserId(environmentId, userId),
contactAttributeCache.tag.byEnvironmentIdAndUserId(environmentId, userId),
contactAttributeKeyCache.tag.byEnvironmentId(environmentId),
],
}
)()
);

22
apps/web/modules/ee/contacts/api/client/[environmentId]/contacts/[userId]/attributes/route.ts
View File

@@ -2,10 +2,10 @@ import { responses } from "@/app/lib/api/response";
import { transformErrorToDetails } from "@/app/lib/api/validator";
import { getIsContactsEnabled } from "@/modules/ee/license-check/lib/utils";
import { NextRequest } from "next/server";
import { prisma } from "@formbricks/database";
import { ResourceNotFoundError } from "@formbricks/types/errors";
import { ZJsContactsUpdateAttributeInput } from "@formbricks/types/js";
import { updateAttributes } from "./lib/attributes";
import { getContactByUserIdWithAttributes } from "./lib/contact";
export const OPTIONS = async () => {
// cors headers
@@ -48,25 +48,7 @@ export const PUT = async (
// ignore userId and id
const { userId: userIdAttr, id: idAttr, ...updatedAttributes } = parsedInput.data.attributes;
const contact = await prisma.contact.findFirst({
where: {
environmentId,
attributes: { some: { attributeKey: { key: "userId", environmentId }, value: userId } },
},
select: {
id: true,
attributes: {
where: {
attributeKey: {
key: {
in: Object.keys(updatedAttributes),
},
},
},
select: { attributeKey: { select: { key: true } }, value: true },
},
},
});
const contact = await getContactByUserIdWithAttributes(environmentId, userId, updatedAttributes);
if (!contact) {
return responses.notFoundResponse("contact", userId, true);