chore: update package versions

apps/cjs-test/CHANGELOG.md

@@ -1,5 +1,13 @@
 # cjs-test
 
+## 0.2.5
+
+### Patch Changes
+
+- CRUD schemas
+- Updated dependencies
+  - @stackframe/stack@2.4.5
+
 ## 0.2.4
 
 ### Patch Changes

apps/cjs-test/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@stackframe/example-cjs-test",
-  "version": "0.2.4",
+  "version": "0.2.5",
   "private": true,
   "scripts": {
     "dev": "next dev --port 8106",

apps/demo/CHANGELOG.md

@@ -1,5 +1,14 @@
 # demo-app
 
+## 1.1.5
+
+### Patch Changes
+
+- CRUD schemas
+- Updated dependencies
+  - @stackframe/stack-shared@2.4.3
+  - @stackframe/stack@2.4.5
+
 ## 1.1.4
 
 ### Patch Changes

apps/demo/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@stackframe/example-demo-app",
-  "version": "1.1.4",
+  "version": "1.1.5",
   "description": "",
   "private": true,
   "scripts": {

apps/e2e/CHANGELOG.md

@@ -1,5 +1,11 @@
 # e2e-tests
 
+## 0.1.2
+
+### Patch Changes
+
+- CRUD schemas
+
 ## 0.1.1
 
 ### Patch Changes

apps/e2e/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@stackframe/e2e-tests",
-  "version": "0.1.1",
+  "version": "0.1.2",
   "private": true,
   "type": "module",
   "scripts": {

apps/middleware/CHANGELOG.md

@@ -1,5 +1,12 @@
 # middleware-demo
 
+## 0.2.5
+
+### Patch Changes
+
+- Updated dependencies
+  - @stackframe/stack@2.4.5
+
 ## 0.2.4
 
 ### Patch Changes

apps/middleware/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@stackframe/example-middleware-demo",
-  "version": "0.2.4",
+  "version": "0.2.5",
   "private": true,
   "scripts": {
     "dev": "next dev --port 8107",

apps/partial-prerendering/CHANGELOG.md

@@ -1,5 +1,13 @@
 # partial-prerendering
 
+## 0.2.5
+
+### Patch Changes
+
+- CRUD schemas
+- Updated dependencies
+  - @stackframe/stack@2.4.5
+
 ## 0.2.4
 
 ### Patch Changes

apps/partial-prerendering/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@stackframe/example-partial-prerendering",
-  "version": "0.2.4",
+  "version": "0.2.5",
   "private": true,
   "scripts": {
     "dev": "next dev --port 8105",

docs/CHANGELOG.md

@@ -1,5 +1,11 @@
 # stack-docs
 
+## 0.1.4
+
+### Patch Changes
+
+- CRUD schemas
+
 ## 0.1.3
 
 ### Patch Changes

docs/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@stackframe/stack-docs",
-  "version": "0.1.3",
+  "version": "0.1.4",
   "private": true,
   "scripts": {
     "docusaurus": "dotenv -c -- docusaurus",

packages/stack-sc/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @stackframe/stack-sc
 
+## 1.5.2
+
+### Patch Changes
+
+- CRUD schemas
+
 ## 1.5.1
 
 ### Patch Changes

packages/stack-sc/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@stackframe/stack-sc",
-  "version": "1.5.1",
+  "version": "1.5.2",
   "exports": {
     "./force-server": {
       "types": "./dist/index.server.d.ts",

packages/stack-server/CHANGELOG.md

@@ -1,5 +1,14 @@
 # @stackframe/stack-server
 
+## 0.4.5
+
+### Patch Changes
+
+- CRUD schemas
+- Updated dependencies
+  - @stackframe/stack-shared@2.4.3
+  - @stackframe/stack@2.4.5
+
 ## 0.4.4
 
 ### Patch Changes

packages/stack-server/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@stackframe/stack-server",
-  "version": "0.4.4",
+  "version": "0.4.5",
   "private": true,
   "scripts": {
     "clean": "rimraf .next && rimraf node_modules",

packages/stack-server/src/route-handlers/prisma-handler.tsx

@@ -0,0 +1,162 @@
+import { CrudSchema, CrudTypeOf } from "@stackframe/stack-shared/dist/crud";
+import { CrudHandlers, createCrudHandlers } from "./crud-handler";
+import { SmartRequestAuth } from "./smart-request";
+import { Prisma } from "@prisma/client";
+import { GetResult } from "@prisma/client/runtime/library";
+import { StatusError, throwErr } from "@stackframe/stack-shared/dist/utils/errors";
+import { prismaClient } from "@/prisma-client";
+
+type AllPrismaModelNames = Prisma.TypeMap["meta"]["modelProps"];
+type WhereUnique<T extends AllPrismaModelNames> = Prisma.TypeMap["model"][Capitalize<T>]["operations"]["findUniqueOrThrow"]["args"]["where"];
+type WhereMany<T extends AllPrismaModelNames> = Prisma.TypeMap["model"][Capitalize<T>]["operations"]["findMany"]["args"]["where"];
+type Where<T extends AllPrismaModelNames> = WhereUnique<T> & WhereMany<T>;
+type Include<T extends AllPrismaModelNames> = Prisma.TypeMap["model"][Capitalize<T>]["operations"]["findMany"]["args"]["include"];
+type BaseFields<T extends AllPrismaModelNames> = Where<T> & Partial<PCreate<T>>;
+type PRead<T extends AllPrismaModelNames, W extends Where<T>, I extends Include<T>> = [T, W, I];//GetResult<Prisma.TypeMap["model"][Capitalize<T>]["payload"], { where: W, include: I }, "findUniqueOrThrow">;
+type PUpdate<T extends AllPrismaModelNames> = Prisma.TypeMap["model"][Capitalize<T>]["operations"]["update"]["args"]["data"];
+type PCreate<T extends AllPrismaModelNames> = Prisma.TypeMap["model"][Capitalize<T>]["operations"]["create"]["args"]["data"];
+
+type A = PRead<"projectUser", {}, {}>;
+
+type Context<ParamName extends string> = {
+  params: Record<ParamName, string>,
+  auth: SmartRequestAuth | null,
+};
+
+type AllowedCrudSchema = CrudSchema & { admin: { readSchema: {} } };
+type AllowedCrudType = CrudTypeOf<AllowedCrudSchema> & { Admin: { Read: {} } };
+
+type CRead<T extends AllowedCrudType> = T extends { Admin: { Read: infer R } } ? R : never;
+type CCreate<T extends AllowedCrudType> = T extends { Admin: { Create: infer R } } ? R : never;
+type CUpdate<T extends AllowedCrudType> = T extends { Admin: { Update: infer R } } ? R : never;
+type CEitherWrite<T extends AllowedCrudType> = CCreate<T> | CUpdate<T>;
+
+type Options<
+  T extends AllowedCrudType,
+  PrismaModelName extends AllPrismaModelNames,
+  ParamName extends string,
+  W extends Where<PrismaModelName>,
+  I extends Include<PrismaModelName>,
+  B extends BaseFields<PrismaModelName>,
+> =
+  & {
+    paramNames: ParamName[],
+    baseFields: (context: Context<ParamName>) => Promise<B>,
+    where?: (context: Context<ParamName>) => Promise<W>,
+    whereUnique?: (context: Context<ParamName>) => Promise<WhereUnique<PrismaModelName>>,
+    include: (context: Context<ParamName>) => Promise<I>,
+    crudToPrisma?: ((crud: CEitherWrite<T>, context: Context<ParamName>) => Promise<PUpdate<PrismaModelName> | Omit<PCreate<PrismaModelName>, keyof B>>),
+    prismaToCrud?: (prisma: PRead<PrismaModelName, W, I>, context: Context<ParamName>) => Promise<CRead<T>>,
+    fieldMapping?: any,
+    createNotFoundError?: (context: Context<ParamName>) => Error,
+  }
+  & (
+    | {
+      crudToPrisma: {},
+      prismaToCrud: {},
+      fieldMapping?: void,
+    }
+    | {
+      crudToPrisma: void,
+      prismaToCrud: void,
+      fieldMapping: {},
+    }
+  );
+
+type CrudHandlersFromCrudType<T extends CrudTypeOf<CrudSchema>> = CrudHandlers<
+  | ("Create" extends keyof T["Admin"] ? "Create" : never)
+  | ("Read" extends keyof T["Admin"] ? "Read" : never)
+  | ("Read" extends keyof T["Admin"] ? "List" : never)
+  | ("Update" extends keyof T["Admin"] ? "Update" : never)
+  | ("Delete" extends keyof T["Admin"] ? "Delete" : never)
+>;
+
+export function createPrismaCrudHandlers<
+  S extends AllowedCrudSchema,
+  PrismaModelName extends AllPrismaModelNames,
+  ParamName extends string,
+  O extends Options<CrudTypeOf<S> & AllowedCrudType, PrismaModelName, ParamName, any, any, any>
+>(
+  crudSchema: S,
+  prismaModelName: PrismaModelName,
+  options: O,
+): CrudHandlersFromCrudType<CrudTypeOf<S>> {
+  const wrapper = <T,>(func: (data: any, context: Context<ParamName>, queryBase: any) => Promise<T>): (opts: { params: Record<ParamName, string>, data?: unknown, auth: SmartRequestAuth | null }) => Promise<T> => {
+    return async (req) => {
+      const context: Context<ParamName> = {
+        params: req.params,
+        auth: req.auth,
+      };
+      const whereBase = await options.where?.(context);
+      const includeBase = await options.include(context);
+      try {
+        return await func(req.data, context, { where: whereBase, include: includeBase });
+      } catch (e) {
+        if ((e as any)?.code === 'P2025') {
+          throw (options.createNotFoundError ?? (() => new StatusError(StatusError.NotFound)))(context);
+        }
+        throw e;
+      }
+    };
+  };
+
+  const prismaToCrud = options.prismaToCrud ?? throwErr("missing prismaToCrud is not yet implemented");
+  const crudToPrisma = options.crudToPrisma ?? throwErr("missing crudToPrisma is not yet implemented");
+
+  return createCrudHandlers<any, any>(crudSchema, {
+    paramNames: [],
+    onRead: wrapper(async (data, context) => {
+      const prisma = await (prismaClient[prismaModelName].findUniqueOrThrow as any)({
+        include: await options.include(context),
+        where: {
+          ...await options.baseFields(context),
+          ...await options.where?.(context),
+          ...await options.whereUnique?.(context),
+        },
+      });
+      return await prismaToCrud(prisma, context);
+    }),
+    onList: wrapper(async (data, context) => {
+      const prisma: any[] = await (prismaClient[prismaModelName].findMany as any)({
+        include: await options.include(context),
+        where: {
+          ...await options.baseFields(context),
+          ...await options.where?.(context),
+        },
+      });
+      return await Promise.all(prisma.map((p) => prismaToCrud(p, context)));
+    }),
+    onCreate: wrapper(async (data, context) => {
+      const prisma = await (prismaClient[prismaModelName].create as any)({
+        include: await options.include(context),
+        data: {
+          ...await options.baseFields(context),
+          ...await crudToPrisma(data, context),
+        },
+      });
+      return await prismaToCrud(prisma, context);
+    }),
+    onUpdate: wrapper(async (data, context) => {
+      const prisma = await (prismaClient[prismaModelName].update as any)({
+        include: await options.include(context),
+        where: {
+          ...await options.baseFields(context),
+          ...await options.where?.(context),
+          ...await options.whereUnique?.(context),
+        },
+        data: await crudToPrisma(data, context),
+      });
+      return await prismaToCrud(prisma, context);
+    }),
+    onDelete: wrapper(async (data, context) => {
+      await (prismaClient[prismaModelName].delete as any)({
+        include: await options.include(context),
+        where: {
+          ...await options.baseFields(context),
+          ...await options.where?.(context),
+          ...await options.whereUnique?.(context),
+        },
+      });
+    }),
+  });
+}

packages/stack-shared/CHANGELOG.md

@@ -1,5 +1,13 @@
 # @stackframe/stack-shared
 
+## 2.4.3
+
+### Patch Changes
+
+- CRUD schemas
+- Updated dependencies
+  - @stackframe/stack-sc@1.5.2
+
 ## 2.4.2
 
 ### Patch Changes

packages/stack-shared/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@stackframe/stack-shared",
-  "version": "2.4.2",
+  "version": "2.4.3",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
   "scripts": {

packages/stack/CHANGELOG.md

@@ -1,5 +1,14 @@
 # @stackframe/stack
 
+## 2.4.5
+
+### Patch Changes
+
+- CRUD schemas
+- Updated dependencies
+  - @stackframe/stack-shared@2.4.3
+  - @stackframe/stack-sc@1.5.2
+
 ## 2.4.4
 
 ### Patch Changes

packages/stack/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@stackframe/stack",
-  "version": "2.4.4",
+  "version": "2.4.5",
   "sideEffects": false,
   "exports": {
     ".": {