Prisma Adapter package (#23)

Author: ogroppo

.gitignore

@@ -29,6 +29,7 @@ yarn-error.log*
 .env.development.local
 .env.test.local
 .env.production.local
+.env
 
 # turbo
 .turbo

.npmrc

@@ -1 +1,2 @@
-hoist=true
+node-linker=hoisted
+strict-peer-dependencies=false

README.md

@@ -6,11 +6,12 @@ Data is stored in local sqlite file!
 # Packages
 
 [ra-data-simple-prisma](./packages/ra-data-simple-prisma/)
+[next-auth-prisma](./packages/next-auth-prisma/)
 
 # Examples
 
-[example admin app](./apps/admin/) Debug, test, and develop the package, but also use it as the admin of the website!
-[example website](./apps/website/) A nextjs boilerplate to show the data (very much under construction yet)
+[example admin app](./apps/admin/) Debug, test, and develop the packages, but also use it as the admin/CMS for the website!
+[example website](./apps/website/) A nextjs/mui boilerplate to show the data (very much under construction yet)
 
 ### Development
 
@@ -32,4 +33,3 @@ this will spin both the apps and package in dev mode!
 
 - [ ] Add all combos in README
 - [ ] create an amazing website showing all the data
-- [ ] Merge admin db with website db

apps/admin/.env.sample

@@ -0,0 +1,5 @@
+GOOGLE_CLIENT_ID=
+GOOGLE_CLIENT_SECRET=
+NEXTAUTH_URL=http://localhost:3020
+NEXTAUTH_SECRET=
+DATABASE_URL=

apps/admin/.gitignore

@@ -1,9 +1,9 @@
 ## Getting Started
 
-First, run the development server:
+First, add `.env` file adding the missing values
+
+Then, run the development server:
 
 ```bash
 pnpm dev
 ```
-
-When making changes, the data will be saved in a local sqlite db!

apps/admin/README.md

@@ -0,0 +1,23 @@
+import { AutocompleteInput, ReferenceInput } from "react-admin";
+
+export const AutocompleteFilter = ({
+  source,
+  reference,
+  field,
+  label,
+  alwaysOn,
+}: {
+  source: string; //the local field that points to the foreign field (e.g. creator_id)
+  reference: string; //the name of the foreign resource (e.g. users)
+  field: string; //the field of the foreign resource (e.g. handle)
+  label?: string;
+  alwaysOn?: boolean;
+}) => (
+  <ReferenceInput source={source} reference={reference} alwaysOn={alwaysOn}>
+    <AutocompleteInput
+      optionText={field}
+      label={label || `${reference} ${field}`}
+      filterToQuery={(searchText) => ({ [field]: searchText })}
+    />
+  </ReferenceInput>
+);

apps/admin/filters/AutocompleteFilter.tsx

@@ -7,20 +7,19 @@
     "build": "next build",
     "start": "next start",
     "lint": "next lint",
-    "postinstall": "prisma generate",
     "kill": "kill -9 $(lsof -t -i:3020)"
   },
   "dependencies": {
     "@babel/core": "7.17.9",
     "@mui/icons-material": "^5.6.2",
     "@mui/material": "^5.6.4",
     "@mui/styles": "^5.6.2",
-    "@next-auth/prisma-adapter": "^1.0.3",
-    "@prisma/client": "^3.12.0",
     "axios": "^0.27.2",
     "next": "12.1.5",
     "next-auth": "^4.3.4",
     "ra-data-simple-prisma": "workspace:*",
+    "db": "workspace:*",
+    "next-auth-prisma-adapter": "workspace:*",
     "react": "18.0.0",
     "react-admin": "^4.0.2",
     "react-dom": "18.0.0"
@@ -32,7 +31,6 @@
     "config": "workspace:*",
     "eslint": "8.13.0",
     "eslint-config-next": "12.1.5",
-    "prisma": "^3.12.0",
     "typescript": "4.6.3"
   }
 }

apps/admin/package.json

@@ -1,8 +1,8 @@
-import { prismaWebClient } from "./../../../website/prisma/prismaWebClient";
 import type { NextApiRequest, NextApiResponse } from "next";
 import { defaultHandler } from "ra-data-simple-prisma";
 import { apiHandler } from "../../middlewares/apiHandler";
+import prismaClient from "db";
 
 export default apiHandler(async (req: NextApiRequest, res: NextApiResponse) => {
-  return await defaultHandler(req, res, prismaWebClient);
+  return await defaultHandler(req, res, prismaClient);
 });

apps/admin/pages/api/[resource].ts

@@ -1,8 +1,8 @@
+import prismaClient from "db";
 import type { NextApiRequest, NextApiResponse } from "next";
 import { defaultHandler } from "ra-data-simple-prisma";
 import { apiHandler } from "../../middlewares/apiHandler";
-import { prismaAdminClient } from "../../prisma/prismaAdminClient";
 
 export default apiHandler((req: NextApiRequest, res: NextApiResponse) => {
-  return defaultHandler(req, res, prismaAdminClient);
+  return defaultHandler(req, res, prismaClient);
 });

apps/admin/pages/api/admin.ts

@@ -1,45 +1,55 @@
-import NextAuth, { Session, User } from "next-auth";
+import NextAuth from "next-auth";
 import GoogleProvider from "next-auth/providers/google";
-import { PrismaAdapter } from "@next-auth/prisma-adapter";
-import { prismaAdminClient } from "../../../prisma/prismaAdminClient";
+import { PrismaAdapter } from "next-auth-prisma-adapter";
+import prismaClient from "db";
 
 export default async function auth(req: any, res: any) {
   return await NextAuth(req, res, {
     //debug: true,
-    adapter: PrismaAdapter(prismaAdminClient),
+    adapter: PrismaAdapter(prismaClient, {
+      userModel: "adminUser",
+      accountModel: "adminAccount",
+      sessionModel: "adminSession",
+      verificationTokenModel: "adminVerificationToken",
+    }),
     providers: [
       GoogleProvider({
         clientId: process.env.GOOGLE_CLIENT_ID!,
         clientSecret: process.env.GOOGLE_CLIENT_SECRET!,
       }),
     ],
-    // callbacks: {
-    //   signIn: async (user, account, profile) => {
-    //     //security
-    //     if (account.provider === "google" && profile.verified_email === true)
-    //       return Promise.resolve(false);
+    callbacks: {
+      signIn: async ({ user, account, profile }) => {
+        //security
+        if (account.provider === "google" && profile.verified_email === true)
+          return Promise.resolve(false);
 
-    //     //restrict domain
-    //     if (
-    //       process.env.RESTRICT_EMAIL_DOMAIN &&
-    //       !profile?.email?.endsWith(`@${process.env.RESTRICT_EMAIL_DOMAIN}`)
-    //     ) {
-    //       return Promise.resolve(false);
-    //     }
+        //restrict domain
+        if (
+          process.env.RESTRICT_EMAIL_DOMAIN &&
+          !profile?.email?.endsWith(`@${process.env.RESTRICT_EMAIL_DOMAIN}`)
+        ) {
+          return Promise.resolve(false);
+        }
 
-    //     //ok
-    //     return Promise.resolve(true);
-    //   },
-    //   session: async (session: Session, user: User) => {
-    //     //always add this, very handy
-    //     session.userId = user.id;
+        //ok
+        return Promise.resolve(true);
+      },
+      session: async ({ session, user, token }) => {
+        //always add this, very handy
+        session.userId = user.id;
 
-    //     const userDoc = await prisma..findById(user.id, "role").lean();
+        const admin = await prismaClient.adminUser.findUnique({
+          select: {
+            role: true,
+          },
+          where: { id: user.id },
+        });
 
-    //     session.role = userDoc?.role;
+        session.role = admin?.role;
 
-    //     return Promise.resolve(session);
-    //   },
-    // },
+        return Promise.resolve(session);
+      },
+    },
   });
 }

apps/admin/pages/api/auth/[...nextauth].ts

@@ -1,3 +1,4 @@
+import prismaClient from "db";
 import type { NextApiRequest, NextApiResponse } from "next";
 import {
   defaultHandler,
@@ -9,46 +10,40 @@ import {
   updateHandler,
 } from "ra-data-simple-prisma";
 import { apiHandler } from "../../middlewares/apiHandler";
-import { prismaWebClient } from "./../../../website/prisma/prismaWebClient";
 
 export default apiHandler((req: NextApiRequest, res: NextApiResponse) => {
   switch (req.body.method) {
     case "create":
-      return createHandler(req, res, prismaWebClient["post"], {
+      return createHandler(req, res, prismaClient["post"], {
         connect: {
           tags: "id",
         },
       });
     case "getList":
-      return getListHandler(
-        req as GetListRequest,
-        res,
-        prismaWebClient["post"],
-        {
-          include: { tags: true },
-          transform: (posts: any[]) => {
-            posts.forEach((post: any) => {
-              post.tags = post.tags.map((tag: any) => tag.id);
-              post._tags_count = post.tags.length;
-            });
-          },
-        }
-      );
+      return getListHandler(req as GetListRequest, res, prismaClient["post"], {
+        include: { tags: true },
+        transform: (posts: any[]) => {
+          posts.forEach((post: any) => {
+            post.tags = post.tags.map((tag: any) => tag.id);
+            post._tags_count = post.tags.length;
+          });
+        },
+      });
     case "getOne":
-      return getOneHandler(req as GetOneRequest, res, prismaWebClient["post"], {
+      return getOneHandler(req as GetOneRequest, res, prismaClient["post"], {
         include: { tags: true },
         transform: (post: any) => {
           post.tags = post.tags.map((tag: any) => tag.id);
           post._tags_count = post.tags.length;
         },
       });
     case "update":
-      return updateHandler(req, res, prismaWebClient["post"], {
+      return updateHandler(req, res, prismaClient["post"], {
         set: {
           tags: "id",
         },
       });
     default:
-      return defaultHandler(req, res, prismaWebClient);
+      return defaultHandler(req, res, prismaClient);
   }
 });