enhance: use fetch and file: to access files

Author: ardatan

.changeset/eighty-poets-roll.md

@@ -0,0 +1,10 @@
+---
+'@graphql-mesh/supergraph': minor
+'@graphql-mesh/graphql': minor
+'@omnigraph/json-schema': minor
+'@omnigraph/openapi': minor
+'json-machete': minor
+'@graphql-mesh/utils': minor
+---
+
+Use `fetch` with `file://` to access files

.changeset/lucky-otters-cough.md

@@ -0,0 +1,5 @@
+---
+'@graphql-mesh/utils': minor
+---
+
+Use `URL.canParse` to check if it is URL

examples/json-schema-file-upload/tests/json-schema-file-upload.test.ts

@@ -12,7 +12,7 @@ describe('JSON Schema File Uploads', () => {
     });
     mesh = await getMesh({
       ...config,
-      fetchFn: router.fetch as any,
+      fetchFn: router.fetch,
     });
   });
   afterAll(() => {

examples/json-schema-subscriptions/api/app.ts

@@ -1,7 +1,8 @@
 import { createRouter, Response } from 'fets';
+import { MeshFetch } from '@graphql-mesh/types';
 import { fetch as defaultFetch } from '@whatwg-node/fetch';
 
-export function createApi(fetch = defaultFetch) {
+export function createApi(fetch: MeshFetch = defaultFetch) {
   let todos = [];
 
   const app = createRouter()
@@ -20,13 +21,18 @@ export function createApi(fetch = defaultFetch) {
           ...reqBody,
         };
         todos.push(todo);
-        await fetch('http://127.0.0.1:4000/webhooks/todo_added', {
-          method: 'POST',
-          headers: {
-            'Content-Type': 'application/json',
-          },
-          body: JSON.stringify(todo),
-        }).catch(console.log);
+        try {
+          const res = await fetch('http://127.0.0.1:4000/webhooks/todo_added', {
+            method: 'POST',
+            headers: {
+              'Content-Type': 'application/json',
+            },
+            body: JSON.stringify(todo),
+          });
+          console.log('Webhook response', await res.text());
+        } catch (e) {
+          console.error('Failed to send webhook', e);
+        }
         return Response.json(todo);
       },
     });

examples/json-schema-subscriptions/tests/json-schema-subscriptions.test.ts

@@ -24,7 +24,7 @@ describe('JSON Schema Subscriptions', () => {
       baseDir,
       getBuiltMesh: () => fakePromise(mesh),
     });
-    const api = createApi(meshHttp.fetch as any);
+    const api = createApi(meshHttp.fetch);
   });
   afterEach(() => {
     resetTodos();

packages/json-machete/src/dereferenceObject.ts

@@ -1,5 +1,6 @@
 import JsonPointer from 'json-pointer';
 import urlJoin from 'url-join';
+import type { MeshFetch } from '@graphql-mesh/types';
 import { handleUntitledDefinitions } from './healUntitledDefinitions.js';
 
 export const resolvePath = (path: string, root: any): any => {
@@ -61,6 +62,7 @@ export async function dereferenceObject<T extends object, TRoot = T>(
   obj: T,
   {
     cwd = globalThis?.process.cwd(),
+    fetch,
     externalFileCache = new Map<string, any>(),
     refMap = new Map<string, any>(),
     root = obj as any,
@@ -69,11 +71,12 @@ export async function dereferenceObject<T extends object, TRoot = T>(
     resolvedObjects = new WeakSet(),
   }: {
     cwd?: string;
+    fetch: MeshFetch;
     externalFileCache?: Map<string, any>;
     refMap?: Map<string, any>;
     root?: TRoot;
     debugLogFn?(message?: any): void;
-    readFileOrUrl(path: string, opts: { cwd: string }): Promise<any> | any;
+    readFileOrUrl(path: string, opts: { cwd: string; fetch: MeshFetch }): Promise<any> | any;
     resolvedObjects?: WeakSet<any>;
   },
 ): Promise<T> {
@@ -91,7 +94,7 @@ export async function dereferenceObject<T extends object, TRoot = T>(
           let externalFile = externalFileCache.get(externalFilePath);
           if (!externalFile) {
             try {
-              externalFile = await readFileOrUrl(externalFilePath, { cwd });
+              externalFile = await readFileOrUrl(externalFilePath, { cwd, fetch });
             } catch (e) {
               console.error(e);
               throw new Error(`Unable to load ${externalRelativeFilePath} from ${cwd}`);
@@ -137,6 +140,7 @@ export async function dereferenceObject<T extends object, TRoot = T>(
               readFileOrUrl,
               root: externalFile,
               resolvedObjects,
+              fetch,
             },
           );
           refMap.set($ref, result);
@@ -161,6 +165,7 @@ export async function dereferenceObject<T extends object, TRoot = T>(
           */
           const result = await dereferenceObject(resolvedObj, {
             cwd,
+            fetch,
             externalFileCache,
             refMap,
             root,
@@ -193,6 +198,7 @@ export async function dereferenceObject<T extends object, TRoot = T>(
               debugLogFn,
               readFileOrUrl,
               resolvedObjects,
+              fetch,
             });
           }
         }

packages/legacy/handlers/graphql/src/index.ts

@@ -263,14 +263,14 @@ export default class GraphQLHandler implements MeshHandler {
     source: schemaConfig,
   }: YamlConfig.GraphQLHandlerCodeFirstConfiguration): Promise<MeshSource> {
     if (schemaConfig.endsWith('.graphql')) {
-      const rawSDL = await readFileOrUrl<string>(schemaConfig, {
+      const rawAst = await readFileOrUrl<DocumentNode>(schemaConfig, {
         cwd: this.baseDir,
         allowUnknownExtensions: true,
         importFn: this.importFn,
         fetch: this.fetchFn,
         logger: this.logger,
       });
-      const schema = buildSchema(rawSDL, {
+      const schema = buildASTSchema(rawAst, {
         assumeValid: true,
         assumeValidSDL: true,
       });

packages/legacy/handlers/supergraph/src/index.ts

@@ -66,7 +66,9 @@ export default class SupergraphHandler implements MeshHandler {
         fetch: this.fetchFn,
         logger: this.logger,
       }).catch(e => {
-        throw new Error(`Failed to load supergraph SDL from ${interpolatedSource}:\n ${e.message}`);
+        throw new Error(
+          `Supergraph source must be a valid GraphQL SDL string or a parsed DocumentNode, but got an invalid result from ${interpolatedSource} instead.\n Got error: ${e.message}`,
+        );
       });
       return handleSupergraphResponse(res, interpolatedSource);
     }
@@ -81,7 +83,9 @@ export default class SupergraphHandler implements MeshHandler {
         fetch: this.fetchFn,
         logger: this.logger,
       }).catch(e => {
-        throw new Error(`Failed to load supergraph SDL from ${interpolatedSource}:\n ${e.message}`);
+        throw new Error(
+          `Supergraph source must be a valid GraphQL SDL string or a parsed DocumentNode, but got an invalid result from ${interpolatedSource} instead.\n Got error: ${e.message}`,
+        );
       });
       return handleSupergraphResponse(sdlOrIntrospection, interpolatedSource);
     });

packages/legacy/handlers/supergraph/tests/supergraph.spec.ts

@@ -246,8 +246,6 @@ describe('Supergraph', () => {
     expect(logger.error.mock.calls[0][0].toString())
       .toBe(`Failed to generate the schema for the source
  Supergraph source must be a valid GraphQL SDL string or a parsed DocumentNode, but got an invalid result from ./fixtures/supergraph-invalid.graphql instead.
- Got result: type Query {
-
  Got error: Syntax Error: Expected Name, found <EOF>.`);
   });
   it('throws a helpful error when the source is down', async () => {
@@ -270,8 +268,8 @@ describe('Supergraph', () => {
     ).rejects.toThrow();
     expect(logger.error.mock.calls[0][0].toString())
       .toBe(`Failed to generate the schema for the source
- Failed to load supergraph SDL from http://down-sdl-source.com/my-sdl.graphql:
- getaddrinfo ENOTFOUND down-sdl-source.com`);
+ Supergraph source must be a valid GraphQL SDL string or a parsed DocumentNode, but got an invalid result from http://down-sdl-source.com/my-sdl.graphql instead.
+ Got error: getaddrinfo ENOTFOUND down-sdl-source.com`);
   });
   it('configures WebSockets for subscriptions correctly', async () => {
     await using authorsHttpServer = await createDisposableServer(authorsServer);

packages/legacy/testing/getTestMesh.ts

@@ -46,7 +46,7 @@ export function getTestMesh(extraOptions?: Partial<GetMeshOptions>) {
     validate: false,
   });
   return getMesh({
-    fetchFn: yoga.fetch as any,
+    fetchFn: yoga.fetch,
     sources: [
       {
         name: 'Yoga',