rename prisma to __unsafePrisma

brendan-kellam · brendan-kellam · commit 727ee7117a2e · 2026-04-03T16:43:28.000-07:00
diff --git a/packages/web/src/actions.ts b/packages/web/src/actions.ts
@@ -6,7 +6,7 @@ import { addUserToOrganization, orgHasAvailability } from "@/lib/authUtils";
 import { ErrorCode } from "@/lib/errorCodes";
 import { notFound, orgNotFound, ServiceError } from "@/lib/serviceError";
 import { getOrgMetadata, isHttpError, isServiceError } from "@/lib/utils";
-import { prisma } from "@/prisma";
+import { __unsafePrisma } from "@/prisma";
 import { render } from "@react-email/components";
 import { generateApiKey, getTokenFromConfig } from "@sourcebot/shared";
 import { ConnectionSyncJobStatus, OrgRole, Prisma, RepoIndexingJobStatus, RepoIndexingJobType } from "@sourcebot/db";
@@ -928,7 +928,7 @@ export const getOrgAccountRequests = async () => sew(() =>
     }));
 
 export const createAccountRequest = async (userId: string) => sew(async () => {
-    const user = await prisma.user.findUnique({
+    const user = await __unsafePrisma.user.findUnique({
         where: {
             id: userId,
         },
@@ -938,7 +938,7 @@ export const createAccountRequest = async (userId: string) => sew(async () => {
         return notFound("User not found");
     }
 
-    const org = await prisma.org.findUnique({
+    const org = await __unsafePrisma.org.findUnique({
         where: {
             id: SINGLE_TENANT_ORG_ID,
         },
@@ -948,7 +948,7 @@ export const createAccountRequest = async (userId: string) => sew(async () => {
         return notFound("Organization not found");
     }
 
-    const existingRequest = await prisma.accountRequest.findUnique({
+    const existingRequest = await __unsafePrisma.accountRequest.findUnique({
         where: {
             requestedById_orgId: {
                 requestedById: userId,
@@ -966,7 +966,7 @@ export const createAccountRequest = async (userId: string) => sew(async () => {
     }
 
     if (!existingRequest) {
-        await prisma.accountRequest.create({
+        await __unsafePrisma.accountRequest.create({
             data: {
                 requestedById: userId,
                 orgId: org.id,
@@ -979,7 +979,7 @@ export const createAccountRequest = async (userId: string) => sew(async () => {
             // on user creation (the header isn't set when next-auth calls onCreateUser for some reason)
             const deploymentUrl = env.AUTH_URL;
 
-            const owner = await prisma.user.findFirst({
+            const owner = await __unsafePrisma.user.findFirst({
                 where: {
                     orgs: {
                         some: {
@@ -1030,7 +1030,7 @@ export const createAccountRequest = async (userId: string) => sew(async () => {
 });
 
 export const getMemberApprovalRequired = async (): Promise<boolean | ServiceError> => sew(async () => {
-    const org = await prisma.org.findUnique({
+    const org = await __unsafePrisma.org.findUnique({
         where: {
             id: SINGLE_TENANT_ORG_ID,
         },
@@ -1277,7 +1277,7 @@ export const getRepoImage = async (repoId: number): Promise<ArrayBuffer | Servic
 });
 
 export const getAnonymousAccessStatus = async (): Promise<boolean | ServiceError> => sew(async () => {
-    const org = await prisma.org.findUnique({
+    const org = await __unsafePrisma.org.findUnique({
         where: { id: SINGLE_TENANT_ORG_ID },
     });
     if (!org) {
diff --git a/packages/web/src/app/(app)/askgh/[owner]/[repo]/page.tsx b/packages/web/src/app/(app)/askgh/[owner]/[repo]/page.tsx
@@ -1,7 +1,7 @@
 import { addGithubRepo } from "@/features/workerApi/actions";
 import { isServiceError } from "@/lib/utils";
 import { ServiceErrorException } from "@/lib/serviceError";
-import { prisma } from "@/prisma";
+import { __unsafePrisma } from "@/prisma";
 import { getRepoInfo } from "./api";
 import { CustomSlateEditor } from "@/features/chat/customSlateEditor";
 import { RepoIndexedGuard } from "./components/repoIndexedGuard";
@@ -21,7 +21,7 @@ export default async function GitHubRepoPage(props: PageProps) {
     const repoId = await (async () => {
         // 1. Look up repo by owner/repo
         const displayName = `${owner}/${repo}`;
-        const existingRepo = await prisma.repo.findFirst({
+        const existingRepo = await __unsafePrisma.repo.findFirst({
             where: {
                 displayName: displayName,
                 external_codeHostType: 'github',
diff --git a/packages/web/src/app/(app)/chat/[id]/opengraph-image.tsx b/packages/web/src/app/(app)/chat/[id]/opengraph-image.tsx
@@ -1,6 +1,6 @@
 import { ImageResponse } from 'next/og';
 import { notFound } from 'next/navigation';
-import { prisma } from '@/prisma';
+import { __unsafePrisma } from '@/prisma';
 import { ChatVisibility } from '@sourcebot/db';
 import { env } from "@sourcebot/shared";
 import { minidenticon } from 'minidenticons';
@@ -22,7 +22,7 @@ interface ImageProps {
 export default async function Image({ params }: ImageProps) {
     const { id } = await params;
 
-    const chat = await prisma.chat.findUnique({
+    const chat = await __unsafePrisma.chat.findUnique({
         where: {
             id,
         },
diff --git a/packages/web/src/app/(app)/chat/[id]/page.tsx b/packages/web/src/app/(app)/chat/[id]/page.tsx
@@ -13,7 +13,7 @@ import { auth } from '@/auth';
 import { AnimatedResizableHandle } from '@/components/ui/animatedResizableHandle';
 import { ChatSidePanel } from '../components/chatSidePanel';
 import { ResizablePanelGroup } from '@/components/ui/resizable';
-import { prisma } from '@/prisma';
+import { __unsafePrisma } from '@/prisma';
 import { ChatVisibility } from '@sourcebot/db';
 import { Metadata } from 'next';
 import { SBChatMessage } from '@/features/chat/types';
@@ -26,10 +26,10 @@ interface PageProps {
     }>;
 }
 
-export async function generateMetadata({ params }: PageProps): Promise<Metadata> {
+export const generateMetadata = async ({ params }: PageProps): Promise<Metadata> => {
     const { id } = await params;
 
-    const chat = await prisma.chat.findUnique({
+    const chat = await __unsafePrisma.chat.findUnique({
         where: {
             id,
         },
diff --git a/packages/web/src/app/(app)/layout.tsx b/packages/web/src/app/(app)/layout.tsx
@@ -1,4 +1,4 @@
-import { prisma } from "@/prisma";
+import { __unsafePrisma } from "@/prisma";
 import { auth } from "@/auth";
 import { isServiceError } from "@/lib/utils";
 import { SINGLE_TENANT_ORG_ID } from "@/lib/constants";
@@ -35,7 +35,7 @@ export default async function Layout(props: LayoutProps) {
         children
     } = props;
 
-    const org = await prisma.org.findUnique({
+    const org = await __unsafePrisma.org.findUnique({
         where: { id: SINGLE_TENANT_ORG_ID },
     });
 
@@ -59,7 +59,7 @@ export default async function Layout(props: LayoutProps) {
 
     // If the user is authenticated, we must check if they're a member of the org
     if (session) {
-        const membership = await prisma.userToOrg.findUnique({
+        const membership = await __unsafePrisma.userToOrg.findUnique({
             where: {
                 orgId_userId: {
                     orgId: org.id,
@@ -85,7 +85,7 @@ export default async function Layout(props: LayoutProps) {
                     </div>
                 )
             } else {
-                const hasPendingApproval = await prisma.accountRequest.findFirst({
+                const hasPendingApproval = await __unsafePrisma.accountRequest.findFirst({
                     where: {
                         orgId: org.id,
                         requestedById: session.user.id
diff --git a/packages/web/src/app/api/(server)/ee/oauth/register/route.ts b/packages/web/src/app/api/(server)/ee/oauth/register/route.ts
@@ -1,6 +1,6 @@
 import { apiHandler } from '@/lib/apiHandler';
 import { requestBodySchemaValidationError, serviceErrorResponse } from '@/lib/serviceError';
-import { prisma } from '@/prisma';
+import { __unsafePrisma } from '@/prisma';
 import { hasEntitlement } from '@sourcebot/shared';
 import { NextRequest } from 'next/server';
 import { z } from 'zod';
@@ -39,7 +39,7 @@ export const POST = apiHandler(async (request: NextRequest) => {
         );
     }
 
-    const client = await prisma.oAuthClient.create({
+    const client = await __unsafePrisma.oAuthClient.create({
         data: {
             name: client_name,
             logoUri: logo_uri ?? null,
diff --git a/packages/web/src/app/components/organizationAccessSettings.tsx b/packages/web/src/app/components/organizationAccessSettings.tsx
@@ -3,11 +3,11 @@ import { AnonymousAccessToggle } from "./anonymousAccessToggle"
 import { OrganizationAccessSettingsWrapper } from "./organizationAccessSettingsWrapper"
 import { getOrgMetadata } from "@/lib/utils"
 import { SINGLE_TENANT_ORG_ID } from "@/lib/constants"
-import { prisma } from "@/prisma"
+import { __unsafePrisma } from "@/prisma"
 import { hasEntitlement, env } from "@sourcebot/shared"
 
 export async function OrganizationAccessSettings() {
-    const org = await prisma.org.findUnique({ where: { id: SINGLE_TENANT_ORG_ID } });
+    const org = await __unsafePrisma.org.findUnique({ where: { id: SINGLE_TENANT_ORG_ID } });
     if (!org) {
         return <div>Error loading organization</div>
     }
diff --git a/packages/web/src/app/invite/page.tsx b/packages/web/src/app/invite/page.tsx
@@ -1,5 +1,5 @@
 import { auth } from "@/auth";
-import { prisma } from "@/prisma";
+import { __unsafePrisma } from "@/prisma";
 import { SINGLE_TENANT_ORG_ID } from "@/lib/constants";
 import { notFound, redirect } from "next/navigation";
 import { Card, CardContent, CardHeader, CardTitle } from "@/components/ui/card";
@@ -17,7 +17,7 @@ interface InvitePageProps {
 
 export default async function InvitePage(props: InvitePageProps) {
     const searchParams = await props.searchParams;
-    const org = await prisma.org.findUnique({ where: { id: SINGLE_TENANT_ORG_ID } });
+    const org = await __unsafePrisma.org.findUnique({ where: { id: SINGLE_TENANT_ORG_ID } });
     if (!org || !org.isOnboarded) {
         return redirect("/onboard");
     }
@@ -33,7 +33,7 @@ export default async function InvitePage(props: InvitePageProps) {
         return <WelcomeCard inviteLinkId={inviteLinkId} providers={providers} />;
     }
 
-    const membership = await prisma.userToOrg.findUnique({
+    const membership = await __unsafePrisma.userToOrg.findUnique({
         where: {
             orgId_userId: {
                 orgId: org.id,
diff --git a/packages/web/src/app/login/page.tsx b/packages/web/src/app/login/page.tsx
@@ -4,7 +4,7 @@ import { redirect } from "next/navigation";
 import { Footer } from "@/app/components/footer";
 import { getIdentityProviderMetadata } from "@/lib/identityProviders";
 import { SINGLE_TENANT_ORG_ID } from "@/lib/constants";
-import { prisma } from "@/prisma";
+import { __unsafePrisma } from "@/prisma";
 import { getAnonymousAccessStatus } from "@/actions";
 import { isServiceError } from "@/lib/utils";
 import { env } from "@sourcebot/shared";
@@ -23,7 +23,7 @@ export default async function Login(props: LoginProps) {
         return redirect("/");
     }
 
-    const org = await prisma.org.findUnique({ where: { id: SINGLE_TENANT_ORG_ID } });
+    const org = await __unsafePrisma.org.findUnique({ where: { id: SINGLE_TENANT_ORG_ID } });
     if (!org || !org.isOnboarded) {
         return redirect("/onboard");
     }
diff --git a/packages/web/src/app/oauth/authorize/page.tsx b/packages/web/src/app/oauth/authorize/page.tsx
@@ -1,7 +1,7 @@
 import { auth } from '@/auth';
 import { LogoutEscapeHatch } from '@/app/components/logoutEscapeHatch';
 import { ConsentScreen } from './components/consentScreen';
-import { prisma } from '@/prisma';
+import { __unsafePrisma } from '@/prisma';
 import { hasEntitlement } from '@sourcebot/shared';
 import { redirect } from 'next/navigation';
 
@@ -47,7 +47,7 @@ export default async function AuthorizePage({ searchParams }: AuthorizePageProps
         return <ErrorPage message={`Unsupported code_challenge_method: ${code_challenge_method}. Only "S256" is supported.`} />;
     }
 
-    const client = await prisma.oAuthClient.findUnique({ where: { id: client_id } });
+    const client = await __unsafePrisma.oAuthClient.findUnique({ where: { id: client_id } });
 
     if (!client) {
         return <ErrorPage message="Unknown client_id. The application has not been registered." />;
diff --git a/packages/web/src/app/onboard/page.tsx b/packages/web/src/app/onboard/page.tsx
@@ -10,7 +10,7 @@ import { getIdentityProviderMetadata } from "@/lib/identityProviders";
 import { OrganizationAccessSettings } from "@/app/components/organizationAccessSettings";
 import { CompleteOnboardingButton } from "./components/completeOnboardingButton";
 import { SINGLE_TENANT_ORG_ID } from "@/lib/constants";
-import { prisma } from "@/prisma";
+import { __unsafePrisma } from "@/prisma";
 import { OrgRole } from "@sourcebot/db";
 import { LogoutEscapeHatch } from "@/app/components/logoutEscapeHatch";
 import { redirect } from "next/navigation";
@@ -41,7 +41,7 @@ interface ResourceCard {
 export default async function Onboarding(props: OnboardingProps) {
     const searchParams = await props.searchParams;
     const providers = getIdentityProviderMetadata();
-    const org = await prisma.org.findUnique({ where: { id: SINGLE_TENANT_ORG_ID } });
+    const org = await __unsafePrisma.org.findUnique({ where: { id: SINGLE_TENANT_ORG_ID } });
     const session = await auth();
 
     if (!org) {
@@ -55,7 +55,7 @@ export default async function Onboarding(props: OnboardingProps) {
     // Check if user is authenticated but not the owner
     if (session?.user) {
         if (org) {
-            const membership = await prisma.userToOrg.findUnique({
+            const membership = await __unsafePrisma.userToOrg.findUnique({
                 where: {
                     orgId_userId: {
                         orgId: org.id,
diff --git a/packages/web/src/app/redeem/page.tsx b/packages/web/src/app/redeem/page.tsx
@@ -6,7 +6,7 @@ import { AcceptInviteCard } from './components/acceptInviteCard';
 import { LogoutEscapeHatch } from '../components/logoutEscapeHatch';
 import { InviteNotFoundCard } from './components/inviteNotFoundCard';
 import { SINGLE_TENANT_ORG_ID } from '@/lib/constants';
-import { prisma } from '@/prisma';
+import { __unsafePrisma } from '@/prisma';
 
 interface RedeemPageProps {
     searchParams: Promise<{
@@ -16,7 +16,7 @@ interface RedeemPageProps {
 
 export default async function RedeemPage(props: RedeemPageProps) {
     const searchParams = await props.searchParams;
-    const org = await prisma.org.findUnique({ where: { id: SINGLE_TENANT_ORG_ID } });
+    const org = await __unsafePrisma.org.findUnique({ where: { id: SINGLE_TENANT_ORG_ID } });
     if (!org || !org.isOnboarded) {
         return redirect("/onboard");
     }
diff --git a/packages/web/src/app/signup/page.tsx b/packages/web/src/app/signup/page.tsx
@@ -5,7 +5,7 @@ import { Footer } from "@/app/components/footer";
 import { getIdentityProviderMetadata } from "@/lib/identityProviders";
 import { createLogger, env } from "@sourcebot/shared";
 import { SINGLE_TENANT_ORG_ID } from "@/lib/constants";
-import { prisma } from "@/prisma";
+import { __unsafePrisma } from "@/prisma";
 import { getAnonymousAccessStatus } from "@/actions";
 import { isServiceError } from "@/lib/utils";
 
@@ -26,7 +26,7 @@ export default async function Signup(props: LoginProps) {
         return redirect("/");
     }
 
-    const org = await prisma.org.findUnique({ where: { id: SINGLE_TENANT_ORG_ID } });
+    const org = await __unsafePrisma.org.findUnique({ where: { id: SINGLE_TENANT_ORG_ID } });
     if (!org || !org.isOnboarded) {
         return redirect("/onboard");
     }
diff --git a/packages/web/src/auth.ts b/packages/web/src/auth.ts
@@ -2,7 +2,7 @@ import 'next-auth/jwt';
 import NextAuth, { DefaultSession, User as AuthJsUser } from "next-auth"
 import Credentials from "next-auth/providers/credentials"
 import EmailProvider from "next-auth/providers/nodemailer";
-import { prisma } from "@/prisma";
+import { __unsafePrisma } from "@/prisma";
 import { env, getSMTPConnectionURL } from "@sourcebot/shared";
 import { User } from '@sourcebot/db';
 import 'next-auth/jwt';
@@ -96,14 +96,14 @@ export const getProviders = () => {
                     }
                     const { email, password } = body.data;
 
-                    const user = await prisma.user.findUnique({
+                    const user = await __unsafePrisma.user.findUnique({
                         where: { email }
                     });
 
                     // The user doesn't exist, so create a new one.
                     if (!user) {
                         const hashedPassword = bcrypt.hashSync(password, 10);
-                        const newUser = await prisma.user.create({
+                        const newUser = await __unsafePrisma.user.create({
                             data: {
                                 email,
                                 hashedPassword,
@@ -145,7 +145,7 @@ export const getProviders = () => {
 
 export const { handlers, signIn, signOut, auth } = NextAuth({
     secret: env.AUTH_SECRET,
-    adapter: EncryptedPrismaAdapter(prisma),
+    adapter: EncryptedPrismaAdapter(__unsafePrisma),
     session: {
         strategy: "jwt",
     },
@@ -165,7 +165,7 @@ export const { handlers, signIn, signOut, auth } = NextAuth({
             ) {
                 const issuerUrl = await getIssuerUrlForAccount(account);
 
-                await prisma.account.update({
+                await __unsafePrisma.account.update({
                     where: {
                         provider_providerAccountId: {
                             provider: account.provider,
@@ -234,7 +234,7 @@ export const { handlers, signIn, signOut, auth } = NextAuth({
             //
             // @see https://github.com/sourcebot-dev/sourcebot/pull/993
             if (token.userId) {
-                const accountsWithoutIssuerUrl = await prisma.account.findMany({
+                const accountsWithoutIssuerUrl = await __unsafePrisma.account.findMany({
                     where: {
                         userId: token.userId,
                         issuerUrl: null,
@@ -244,7 +244,7 @@ export const { handlers, signIn, signOut, auth } = NextAuth({
                 for (const account of accountsWithoutIssuerUrl) {
                     const issuerUrl = await getIssuerUrlForAccount(account);
                     if (issuerUrl) {
-                        await prisma.account.update({
+                        await __unsafePrisma.account.update({
                             where: {
                                 id: account.id,
                             },
diff --git a/packages/web/src/ee/features/audit/auditService.ts b/packages/web/src/ee/features/audit/auditService.ts
@@ -1,5 +1,5 @@
 import { IAuditService, AuditEvent } from '@/ee/features/audit/types';
-import { prisma } from '@/prisma';
+import { __unsafePrisma } from '@/prisma';
 import { Audit } from '@prisma/client';
 import { createLogger, SOURCEBOT_VERSION } from '@sourcebot/shared';
 
@@ -10,7 +10,7 @@ export class AuditService implements IAuditService {
     const sourcebotVersion = SOURCEBOT_VERSION;
 
     try {
-      const audit = await prisma.audit.create({
+      const audit = await __unsafePrisma.audit.create({
         data: {
           action: event.action,
           actorId: event.actor.id,
diff --git a/packages/web/src/ee/features/oauth/server.ts b/packages/web/src/ee/features/oauth/server.ts
diff --git a/packages/web/src/ee/features/sso/sso.ts b/packages/web/src/ee/features/sso/sso.ts
diff --git a/packages/web/src/features/userManagement/actions.ts b/packages/web/src/features/userManagement/actions.ts
diff --git a/packages/web/src/initialize.ts b/packages/web/src/initialize.ts
diff --git a/packages/web/src/lib/authUtils.ts b/packages/web/src/lib/authUtils.ts
diff --git a/packages/web/src/middleware/withAuth.ts b/packages/web/src/middleware/withAuth.ts
diff --git a/packages/web/src/prisma.ts b/packages/web/src/prisma.ts
