typedSql

package.json

@@ -6,7 +6,7 @@
   "scripts": {
     "start": "bun src/index.ts",
     "dev": "bun --watch src/index.ts",
-    "generate:prisma": "prisma generate",
+    "generate:prisma": "prisma generate --sql",
     "generate:mail": "maizzle build production",
     "generate:proto": "cd src/proto && protoc --experimental_allow_proto3_optional --plugin=../../node_modules/.bin/protoc-gen-ts_proto --ts_proto_out=. ./*.proto --ts_proto_opt=esModuleInterop=true",
     "generate:env": "bun dotenv-vault pull",

prisma/schema.prisma

@@ -1,6 +1,6 @@
 generator client {
   provider        = "prisma-client-js"
-  previewFeatures = ["fullTextSearch", "postgresqlExtensions"]
+  previewFeatures = ["fullTextSearch", "postgresqlExtensions", "typedSql"]
   binaryTargets   = ["native"]
 }
 

prisma/sql/getDirectusFileById.sql

@@ -0,0 +1,3 @@
+-- @param {String} $1:ID of the Directus file
+
+SELECT * FROM "directus"."directus_files" WHERE "id"=$1::uuid

prisma/sql/getViewerFromDirectusId.sql

@@ -0,0 +1,3 @@
+-- @param {String} $1:ID of the Directus file
+
+SELECT "external_identifier" FROM "directus"."directus_users" WHERE "id"=$1::uuid

src/models/Asset.ts

@@ -2,6 +2,7 @@ import {SchemaTypes} from '@pothos/core';
 import {GraphQLError} from 'graphql';
 import {builder} from '../pothos/builder';
 import prismaClient from '../utils/prismaClient';
+import {getDirectusFileById} from '@prisma/client/sql';
 import {resolveOffsetConnection} from '@pothos/plugin-relay';
 import {
   PrismaModelTypes,
@@ -112,9 +113,7 @@ export function pixelImageField<Types extends SchemaTypes, F extends string>(
         return null;
       }
 
-      const [row] = await prismaClient.$queryRaw<
-        [DirectusFile?]
-      >`select * from "directus"."directus_files" where "id"=${id}::uuid`;
+      const [row] = await prismaClient.$queryRawTyped(getDirectusFileById(id));
 
       if (row == null || !row.height || !row.width) {
         return null;

src/utils/viewerIdFromToken.ts

@@ -1,18 +1,17 @@
 import {ParsedToken} from '../routes/auth';
 import prismaClient from './prismaClient';
+import {getViewerFromDirectusId} from '@prisma/client/sql';
 
 export default async function viewerIdFromToken(
   parsedToken: ParsedToken | undefined,
 ): Promise<string | undefined> {
   if (parsedToken == null) {
     return;
   } else if (parsedToken.iss === 'directus') {
-    const user = await prismaClient.$queryRaw<
-      Array<{
-        external_identifier: string;
-      }>
-    >`select "external_identifier" from "directus"."directus_users" where "id"=${parsedToken.id}::uuid`;
-    return user.pop()?.external_identifier;
+    const [user] = await prismaClient.$queryRawTyped(
+      getViewerFromDirectusId(parsedToken.id),
+    );
+    return user?.external_identifier ?? undefined;
   } else if (parsedToken.iss === 'owntracks') {
     return parsedToken.viewerId;
   }