Convert postgraphile library usage from V4->V5

Author: benjie

@app/lib/src/GraphileApolloLink.ts

@@ -6,8 +6,10 @@ import {
   Operation,
 } from "@apollo/client";
 import { Request, Response } from "express";
-import { execute, getOperationAST } from "graphql";
-import { HttpRequestHandler } from "postgraphile";
+import { execute, hookArgs, isAsyncIterable } from "grafast";
+import type {} from "grafserv/express/v4";
+import { getOperationAST } from "graphql";
+import type { PostGraphileInstance } from "postgraphile";
 
 export interface GraphileApolloLinkInterface {
   /** The request object. */
@@ -17,10 +19,7 @@ export interface GraphileApolloLinkInterface {
   res: Response;
 
   /** The instance of the express middleware returned by calling `postgraphile()` */
-  postgraphileMiddleware: HttpRequestHandler<Request, Response>;
-
-  /** An optional rootValue to use inside resolvers. */
-  rootValue?: any;
+  pgl: PostGraphileInstance;
 }
 
 /**
@@ -36,7 +35,7 @@ export class GraphileApolloLink extends ApolloLink {
     operation: Operation,
     _forward?: NextLink
   ): Observable<FetchResult> | null {
-    const { postgraphileMiddleware, req, res, rootValue } = this.options;
+    const { pgl, req, res } = this.options;
     return new Observable((observer) => {
       (async () => {
         try {
@@ -53,22 +52,28 @@ export class GraphileApolloLink extends ApolloLink {
             }
             return;
           }
-          const schema = await postgraphileMiddleware.getGraphQLSchema();
-          const data =
-            await postgraphileMiddleware.withPostGraphileContextFromReqRes(
+          const schema = await pgl.getSchema();
+          const args = {
+            schema,
+            document,
+            variableValues,
+            operationName,
+          };
+          await hookArgs(args, pgl.getResolvedPreset(), {
+            node: {
               req,
               res,
-              {},
-              (context) =>
-                execute(
-                  schema,
-                  document,
-                  rootValue || {},
-                  context,
-                  variableValues,
-                  operationName
-                )
-            );
+            },
+            expressv4: {
+              req,
+              res,
+            },
+          });
+          const data = await execute(args);
+          if (isAsyncIterable(data)) {
+            data.return?.();
+            throw new Error("Iterable not supported by GraphileApolloLink");
+          }
           if (!observer.closed) {
             observer.next(data);
             observer.complete();

@app/lib/src/withApollo.tsx

@@ -89,7 +89,7 @@ function makeServerSideLink(req: any, res: any) {
   return new GraphileApolloLink({
     req,
     res,
-    postgraphileMiddleware: req.app.get("postgraphileMiddleware"),
+    pgl: req.app.get("pgl"),
   });
 }
 

@app/server/src/app.ts

@@ -1,6 +1,5 @@
-import express, { Express } from "express";
-import { IncomingMessage, Server } from "http";
-import { Middleware } from "postgraphile";
+import express, { Express, NextFunction } from "express";
+import { IncomingMessage, Server, ServerResponse } from "http";
 import { Duplex } from "stream";
 
 import { cloudflareIps } from "./cloudflare";
@@ -36,6 +35,13 @@ export function getWebsocketMiddlewares(
   return app.get("websocketMiddlewares");
 }
 
+export interface Middleware<
+  Request extends IncomingMessage,
+  Response extends ServerResponse
+> {
+  (req: Request, res: Response, next: NextFunction): void;
+}
+
 export async function makeApp({
   httpServer,
 }: {