fix: use fetch mock

Author: acao

packages/graphql-language-service-server/package.json

@@ -36,14 +36,13 @@
   "peerDependencies": {
     "graphql": "^15.5.0 || ^16.0.0"
   },
-  "COMMENT": "please do not remove depenencies without thorough testing. many dependencies are not imported directly, as they are peer dependencies",
+  "COMMENT": "please do not remove dependencies without thorough testing. many dependencies are not imported directly, as they are peer dependencies",
   "dependencies": {
-    "@astrojs/compiler": "^2.5.0",
     "@babel/parser": "^7.23.6",
     "@babel/types": "^7.23.5",
     "@graphql-tools/code-file-loader": "8.0.3",
     "@vue/compiler-sfc": "^3.4.5",
-    "astrojs-compiler-sync": "^0.3.5",
+    "astrojs-compiler-sync": "1.0.0",
     "cosmiconfig-toml-loader": "^1.0.0",
     "dotenv": "10.0.0",
     "fast-glob": "^3.2.7",

packages/graphql-language-service-server/src/GraphQLCache.ts

@@ -622,7 +622,19 @@ export class GraphQLCache {
 
       try {
         // Read from disk
-        schema = await projectConfig.getSchema();
+        schema = await projectConfig.loadSchema(
+          projectConfig.schema,
+          'GraphQLSchema',
+          {
+            assumeValid: true,
+            assumeValidSDL: true,
+            experimentalFragmentVariables: true,
+            sort: false,
+            includeSources: true,
+            allowLegacySDLEmptyFields: true,
+            allowLegacySDLImplementsInterfaces: true,
+          },
+        );
       } catch {
         // // if there is an error reading the schema, just use the last valid schema
         schema = this._schemaMap.get(schemaCacheKey);
@@ -794,7 +806,7 @@ export class GraphQLCache {
     let queries: CachedContent[] = [];
     if (content.trim().length !== 0) {
       try {
-        queries = this._parser(
+        queries = await this._parser(
           content,
           filePath,
           DEFAULT_SUPPORTED_EXTENSIONS,

packages/graphql-language-service-server/src/MessageProcessor.ts

@@ -128,7 +128,7 @@ export class MessageProcessor {
   private _isGraphQLConfigMissing: boolean | null = null;
   private _willShutdown = false;
   private _logger: Logger | NoopLogger;
-  private _parser: (text: string, uri: string) => CachedContent[];
+  private _parser: (text: string, uri: string) => Promise<CachedContent[]>;
   private _tmpDir: string;
   private _tmpDirBase: string;
   private _loadConfigOptions: LoadConfigOptions;
@@ -160,7 +160,7 @@ export class MessageProcessor {
     }
     this._connection = connection;
     this._logger = logger;
-    this._parser = (text, uri) => {
+    this._parser = async (text, uri) => {
       const p = parser ?? parseDocument;
       return p(text, uri, fileExtensions, graphqlFileExtensions, this._logger);
     };
@@ -731,7 +731,7 @@ export class MessageProcessor {
   ) {
     try {
       const fileText = text || (await readFile(URI.parse(uri).fsPath, 'utf-8'));
-      const contents = this._parser(fileText, uri);
+      const contents = await this._parser(fileText, uri);
       const cachedDocument = this._textDocumentCache.get(uri);
       const version = cachedDocument ? cachedDocument.version++ : 0;
       await this._invalidateCache({ uri, version }, uri, contents);
@@ -1060,7 +1060,7 @@ export class MessageProcessor {
     project?: GraphQLProjectConfig,
   ) {
     try {
-      const contents = this._parser(text, uri);
+      const contents = await this._parser(text, uri);
       if (contents.length > 0) {
         await this._invalidateCache({ version, uri }, uri, contents);
         await this._updateObjectTypeDefinition(uri, contents, project);
@@ -1268,7 +1268,7 @@ export class MessageProcessor {
           const uri = URI.file(filePath).toString();
 
           // I would use the already existing graphql-config AST, but there are a few reasons we can't yet
-          const contents = this._parser(document.rawSDL, uri);
+          const contents = await this._parser(document.rawSDL, uri);
           if (!contents[0]?.query) {
             return;
           }

packages/graphql-language-service-server/src/__tests__/MessageProcessor.spec.ts

@@ -7,6 +7,35 @@ import { serializeRange } from './__utils__/utils';
 import { readFile } from 'node:fs/promises';
 import { existsSync } from 'node:fs';
 import { URI } from 'vscode-uri';
+import { GraphQLSchema, introspectionFromSchema } from 'graphql';
+import fetchMock from 'fetch-mock';
+
+jest.mock('@whatwg-node/fetch', () => {
+  const { AbortController } = require('node-abort-controller');
+
+  return {
+    fetch: require('fetch-mock').fetchHandler,
+    AbortController,
+    TextDecoder: global.TextDecoder,
+  };
+});
+
+const mockSchema = (schema: GraphQLSchema) => {
+  const introspectionResult = {
+    data: introspectionFromSchema(schema, {
+      descriptions: true,
+    }),
+  };
+  fetchMock.mock({
+    matcher: '*',
+    response: {
+      headers: {
+        'Content-Type': 'application/json',
+      },
+      body: introspectionResult,
+    },
+  });
+};
 
 const defaultFiles = [
   ['query.graphql', 'query { bar ...B }'],
@@ -41,6 +70,7 @@ const genSchemaPath =
 describe('MessageProcessor with no config', () => {
   afterEach(() => {
     mockfs.restore();
+    fetchMock.restore();
   });
   it('fails to initialize with empty config file', async () => {
     const project = new MockProject({
@@ -102,17 +132,17 @@ describe('MessageProcessor with no config', () => {
 });
 
 describe('MessageProcessor with config', () => {
-  let app;
   afterEach(() => {
     mockfs.restore();
+    fetchMock.restore();
   });
-  beforeAll(async () => {
-    app = await import('../../../graphiql/test/e2e-server');
-  });
-  afterAll(() => {
-    app.server.close();
-    app.wsServer.close();
-  });
+  // beforeAll(async () => {
+  //   app = await import('../../../graphiql/test/e2e-server');
+  // });
+  // afterAll(() => {
+  //   app.server.close();
+  //   app.wsServer.close();
+  // });
   it('caches files and schema with .graphql file config, and the schema updates with watched file changes', async () => {
     const project = new MockProject({
       files: [
@@ -324,6 +354,8 @@ describe('MessageProcessor with config', () => {
   });
 
   it('caches files and schema with a URL config', async () => {
+    mockSchema(require('../../../graphiql/test/schema'));
+
     const project = new MockProject({
       files: [
         ['query.graphql', 'query { test { isTest, ...T } }'],
@@ -389,29 +421,29 @@ describe('MessageProcessor with config', () => {
 
     expect(serializeRange(typeDefinitions[0].range)).toEqual({
       start: {
-        line: 10,
+        line: 11,
         character: 0,
       },
       end: {
-        line: 98,
+        line: 102,
         character: 1,
       },
     });
 
     const schemaDefs = await project.lsp.handleDefinitionRequest({
       textDocument: { uri: URI.parse(genSchemaPath).toString() },
-      position: { character: 20, line: 17 },
+      position: { character: 20, line: 18 },
     });
     expect(schemaDefs[0].uri).toEqual(URI.parse(genSchemaPath).toString());
     // note: if the graphiql test schema changes,
     // this might break, please adjust if you see a failure here
     expect(serializeRange(schemaDefs[0].range)).toEqual({
       start: {
-        line: 100,
+        line: 104,
         character: 0,
       },
       end: {
-        line: 108,
+        line: 112,
         character: 1,
       },
     });
@@ -456,6 +488,8 @@ describe('MessageProcessor with config', () => {
   });
 
   it('caches multiple projects with files and schema with a URL config and a local schema', async () => {
+    mockSchema(require('../../../graphiql/test/schema'));
+
     const project = new MockProject({
       files: [
         [

packages/graphql-language-service-server/src/__tests__/parseDocument-test.ts

@@ -1,7 +1,7 @@
 import { parseDocument } from '../parseDocument';
 
 describe('parseDocument', () => {
-  it('parseDocument finds queries in tagged templates', async () => {
+  it('parseDocument finds queries in tagged templates', () => {
     const text = `
     // @flow
     import {gql} from 'react-apollo';
@@ -32,7 +32,7 @@ describe('parseDocument', () => {
     `);
   });
 
-  it('parseDocument finds queries in tagged templates in leaf', async () => {
+  it('parseDocument finds queries in tagged templates in leaf', () => {
     const text = `
     import {gql} from 'react-apollo';
     import type {B} from 'B';
@@ -58,7 +58,7 @@ describe('parseDocument', () => {
     `);
   });
 
-  it('parseDocument finds queries in tagged templates using typescript', async () => {
+  it('parseDocument finds queries in tagged templates using typescript', () => {
     const text = `
     import {gql} from 'react-apollo';
     import {B} from 'B';
@@ -88,7 +88,7 @@ describe('parseDocument', () => {
     `);
   });
 
-  it('parseDocument finds queries in tagged templates using tsx', async () => {
+  it('parseDocument finds queries in tagged templates using tsx', () => {
     const text = `
     import {gql} from 'react-apollo';
     import {B} from 'B';
@@ -120,7 +120,7 @@ describe('parseDocument', () => {
     `);
   });
 
-  it('parseDocument finds queries in multi-expression tagged templates using tsx', async () => {
+  it('parseDocument finds queries in multi-expression tagged templates using tsx', () => {
     const text = `
     import {gql} from 'react-apollo';
     import {B} from 'B';
@@ -153,7 +153,7 @@ describe('parseDocument', () => {
     }`);
   });
   // TODO: why an extra line here?
-  it('parseDocument finds queries in multi-expression tagged template with declarations with using tsx', async () => {
+  it('parseDocument finds queries in multi-expression tagged template with declarations with using tsx', () => {
     const text = `
     import {gql} from 'react-apollo';
     import {B} from 'B';
@@ -186,7 +186,7 @@ describe('parseDocument', () => {
     }`);
   });
 
-  it('parseDocument finds queries in multi-expression template strings using tsx', async () => {
+  it('parseDocument finds queries in multi-expression template strings using tsx', () => {
     const text = `
     import {gql} from 'react-apollo';
     import {B} from 'B';
@@ -222,7 +222,7 @@ describe('parseDocument', () => {
     `);
   });
 
-  it('parseDocument finds queries in call expressions with template literals', async () => {
+  it('parseDocument finds queries in call expressions with template literals', () => {
     const text = `
     // @flow
     import {gql} from 'react-apollo';
@@ -253,7 +253,7 @@ describe('parseDocument', () => {
     `);
   });
 
-  it('parseDocument finds queries in #graphql-annotated templates', async () => {
+  it('parseDocument finds queries in #graphql-annotated templates', () => {
     const text = `
     import {gql} from 'react-apollo';
     import {B} from 'B';
@@ -283,7 +283,7 @@ describe('parseDocument', () => {
     `);
   });
 
-  it('parseDocument finds queries in /*GraphQL*/-annotated templates', async () => {
+  it('parseDocument finds queries in /*GraphQL*/-annotated templates', () => {
     const text = `
     import {gql} from 'react-apollo';
     import {B} from 'B';
@@ -314,7 +314,7 @@ describe('parseDocument', () => {
     `);
   });
 
-  it('parseDocument ignores non gql tagged templates', async () => {
+  it('parseDocument ignores non gql tagged templates', () => {
     const text = `
     // @flow
     import randomThing from 'package';
@@ -337,7 +337,7 @@ describe('parseDocument', () => {
     expect(contents.length).toEqual(0);
   });
 
-  it('parseDocument ignores non gql call expressions with template literals', async () => {
+  it('parseDocument ignores non gql call expressions with template literals', () => {
     const text = `
     // @flow
     import randomthing from 'package';
@@ -360,7 +360,7 @@ describe('parseDocument', () => {
     expect(contents.length).toEqual(0);
   });
 
-  it('an unparsable JS/TS file does not throw and bring down the server', async () => {
+  it('an unparsable JS/TS file does not throw and bring down the server', () => {
     const text = `
     // @flow
     import type randomThing fro 'package';
@@ -380,14 +380,14 @@ describe('parseDocument', () => {
     expect(contents.length).toEqual(0);
   });
 
-  it('an empty file is ignored', async () => {
+  it('an empty file is ignored', () => {
     const text = '';
 
     const contents = parseDocument(text, 'test.js');
     expect(contents.length).toEqual(0);
   });
 
-  it('a whitespace only file with empty asts is ignored', async () => {
+  it('a whitespace only file with empty asts is ignored', () => {
     const text = `
     
     `;
@@ -396,7 +396,7 @@ describe('parseDocument', () => {
     expect(contents.length).toEqual(0);
   });
 
-  it('an ignored file is ignored', async () => {
+  it('an ignored file is ignored', () => {
     const text = `
     something
     `;

packages/graphql-language-service-server/src/__tests__/startServer.spec.ts

@@ -1,28 +1,36 @@
 import startServer from '../startServer';
 
 describe('startServer', () => {
+  let c;
+  afterEach(async () => {
+    if (c) {
+      try {
+        await c.sendNotification('exit');
+      } catch {}
+    }
+  });
   it('should start the server', async () => {
-    await startServer();
+    c = await startServer();
     // if the server starts, we're good
     expect(true).toBe(true);
   });
   // this one fails to exit
   it('should start the server with stream', async () => {
-    await startServer({
+    c = await startServer({
       method: 'stream',
     });
     // if the server starts, we're good
     expect(true).toBe(true);
   });
   it('should start the server with ipc', async () => {
-    await startServer({
+    c = await startServer({
       method: 'node',
     });
     // if the server starts, we're good
     expect(true).toBe(true);
   });
   it('should start the server with websockets', async () => {
-    await startServer({
+    c = await startServer({
       method: 'socket',
       port: 4000,
     });