Concurrent integration tests

ardatan · ardatan · commit cc0ac96dda50 · 2025-01-21T19:13:18.000+03:00
diff --git a/examples/fastify/tests/fastify.spec.ts b/examples/fastify/tests/fastify.spec.ts
@@ -8,7 +8,7 @@ describe('fastify', () => {
 
   afterAll(() => Promise.all([app.close(), upstream.close()]));
 
-  it('should work', async () => {
+  it.concurrent('should work', async () => {
     const upstreamPort = (upstream.server.address() as AddressInfo).port;
     const response = await fetch(
       `http://localhost:${(app.server.address() as AddressInfo).port}/graphql`,
diff --git a/examples/federation-example/tests/federation-example.test.ts b/examples/federation-example/tests/federation-example.test.ts
@@ -496,7 +496,7 @@ describe('Federation Example', () => {
       });
       mesh = await getMesh(config);
     });
-    it('should give correct response for example queries', async () => {
+    it.concurrent('should give correct response for example queries', async () => {
       const result = await mesh.execute(exampleQuery);
       expect(result?.data).toMatchObject(expectedResult);
     });
@@ -512,7 +512,7 @@ describe('Federation Example', () => {
       });
       mesh = await getMesh(config);
     });
-    it('should give correct response for example queries', async () => {
+    it.concurrent('should give correct response for example queries', async () => {
       const result = await mesh.execute(exampleQuery);
       expect(result?.errors).toBeFalsy();
       expect(result?.data).toMatchObject(expectedResult);
diff --git a/examples/federation-example/tests/polling.test.ts b/examples/federation-example/tests/polling.test.ts
@@ -10,9 +10,9 @@ import { getLocalHostName } from '../../../packages/testing/getLocalHostName';
 jest.setTimeout(30000);
 describe('Polling Test', () => {
   if (process.version.startsWith('v18.')) {
-    return it('skipping test on Node.js 18', () => {});
+    return it.concurrent('skipping test on Node.js 18', () => {});
   }
-  it('should pass', async () => {
+  it.concurrent('should pass', async () => {
     const cwd = join(__dirname, 'fixtures/polling');
     const supergraphSdlPath = join(cwd, 'supergraph.graphql');
     const supergraphSdl = readFileSync(supergraphSdlPath, 'utf-8');
diff --git a/examples/graphql-file-upload-example/test/graphql-file-upload-example.test.ts b/examples/graphql-file-upload-example/test/graphql-file-upload-example.test.ts
@@ -22,7 +22,7 @@ describe('Upload Example', () => {
     await stopResizeImageServer();
     await mesh.destroy();
   });
-  it('should give correct response', async () => {
+  it.concurrent('should give correct response', async () => {
     const file = new File(['CONTENT'], 'test.txt');
     const result = await mesh.execute(
       /* GraphQL */ `
diff --git a/examples/grpc-example/tests/grpc.test.ts b/examples/grpc-example/tests/grpc.test.ts
@@ -16,18 +16,18 @@ describe('gRPC Example', () => {
     mesh = await getMesh(config);
     grpc = await startGrpcServer(300);
   });
-  it('should generate correct schema', async () => {
+  it.concurrent('should generate correct schema', async () => {
     expect(printSchemaWithDirectives(mesh.schema)).toMatchSnapshot('grpc-schema');
   });
-  it('should get movies correctly', async () => {
+  it.concurrent('should get movies correctly', async () => {
     const GetMoviesQuery = await readFile(
       join(__dirname, '../example-queries/GetMovies.query.graphql'),
       'utf8',
     );
     const result = await mesh.execute(GetMoviesQuery);
     expect(result).toMatchSnapshot('get-movies-grpc-example-result');
   });
-  it('should fetch movies by cast as a stream correctly', async () => {
+  it.concurrent('should fetch movies by cast as a stream correctly', async () => {
     const MoviesByCastStream = await readFile(
       join(__dirname, '../example-queries/MoviesByCast.stream.graphql'),
       'utf8',
@@ -38,7 +38,7 @@ describe('gRPC Example', () => {
       expect(item).toMatchSnapshot(`movies-by-cast-grpc-example-result-stream-${i++}`);
     }
   });
-  it('should fetch movies by cast as a subscription correctly', async () => {
+  it.concurrent('should fetch movies by cast as a subscription correctly', async () => {
     const MoviesByCastSubscription = await readFile(
       join(__dirname, '../example-queries/MoviesByCast.subscription.graphql'),
       'utf8',
diff --git a/examples/grpc-reflection-example/tests/grpc-reflection.test.ts b/examples/grpc-reflection-example/tests/grpc-reflection.test.ts
@@ -16,10 +16,10 @@ describe('gRPC Reflection Example', () => {
     grpc = await startGrpcServer();
     mesh = await getMesh(config);
   });
-  it('should generate correct schema', async () => {
+  it.concurrent('should generate correct schema', async () => {
     expect(printSchemaWithDirectives(mesh.schema)).toMatchSnapshot('grpc-schema');
   });
-  it('should get greeting correctly', async () => {
+  it.concurrent('should get greeting correctly', async () => {
     const GreetingQuery = await readFile(
       join(__dirname, '../example-queries/GetGreeting.query.graphql'),
       'utf8',
diff --git a/examples/hello-world-esm/tests/hello-world.test.ts b/examples/hello-world-esm/tests/hello-world.test.ts
@@ -11,10 +11,10 @@ describe('Hello World', () => {
     });
     mesh = await getMesh(config);
   });
-  it('should generate correct schema', async () => {
+  it.concurrent('should generate correct schema', async () => {
     expect(printSchemaWithDirectives(mesh.schema)).toMatchSnapshot();
   });
-  it('should give correct response', async () => {
+  it.concurrent('should give correct response', async () => {
     const result = await mesh.execute(
       /* GraphQL */ `
         query HelloWorld {
diff --git a/examples/hello-world/tests/hello-world.test.ts b/examples/hello-world/tests/hello-world.test.ts
@@ -11,10 +11,10 @@ describe('Hello World', () => {
     });
     mesh = await getMesh(config);
   });
-  it('should generate correct schema', async () => {
+  it.concurrent('should generate correct schema', async () => {
     expect(printSchemaWithDirectives(mesh.schema)).toMatchSnapshot();
   });
-  it('should give correct response', async () => {
+  it.concurrent('should give correct response', async () => {
     const result = await mesh.execute(
       /* GraphQL */ `
         query HelloWorld {
diff --git a/examples/json-schema-covid/tests/json-schema-covid.test.ts b/examples/json-schema-covid/tests/json-schema-covid.test.ts
@@ -14,7 +14,7 @@ describe('JSON Schema Covid', () => {
     });
     mesh = await getMesh(config);
   });
-  it('should generate correct schema', async () => {
+  it.concurrent('should generate correct schema', async () => {
     expect(printSchema(lexicographicSortSchema(mesh.schema))).toMatchSnapshot(
       'json-schema-covid-schema',
     );
diff --git a/examples/json-schema-example/tests/artifacts.test.ts b/examples/json-schema-example/tests/artifacts.test.ts
@@ -4,7 +4,7 @@ import { fs } from '@graphql-mesh/cross-helpers';
 const { readFile } = fs.promises;
 
 describe('Artifacts', () => {
-  it('should execute queries', async () => {
+  it.concurrent('should execute queries', async () => {
     const { getBuiltMesh } = await import('../.mesh/index');
     const { execute } = await getBuiltMesh();
     const query = await readFile(join(__dirname, '../example-query.graphql'), 'utf-8');
@@ -19,7 +19,7 @@ describe('Artifacts', () => {
     expect(executionResult?.data?.me?.company?.employers[0]?.jobTitle).toBeDefined();
     expect(executionResult?.data?.me?.company?.employers[0]?.lastName).toBeDefined();
   });
-  it('should load and run SDK correctly', async () => {
+  it.concurrent('should load and run SDK correctly', async () => {
     const { getMeshSDK } = await import('../.mesh/index');
     const meshSdk = getMeshSDK();
     const sdkResult = await meshSdk.ExampleMeQuery();
diff --git a/examples/json-schema-example/tests/json-schema-example.test.ts b/examples/json-schema-example/tests/json-schema-example.test.ts
@@ -12,10 +12,10 @@ describe('JSON Schema Example', () => {
     });
     mesh = await getMesh(config);
   });
-  it('should generate correct schema', async () => {
+  it.concurrent('should generate correct schema', async () => {
     expect(printSchemaWithDirectives(mesh.schema)).toMatchSnapshot();
   });
-  it('should give correct response', async () => {
+  it.concurrent('should give correct response', async () => {
     const query = await fsPromises.readFile(join(__dirname, '../example-query.graphql'), 'utf8');
     const result = await mesh.execute(query);
     expect(result?.data?.me?.firstName).toBeDefined();
diff --git a/examples/json-schema-fhir/tests/fhir.test.ts b/examples/json-schema-fhir/tests/fhir.test.ts
@@ -13,7 +13,7 @@ describe('FHIR', () => {
     });
     mesh = await getMesh(config);
   });
-  it('should generate correct schema', async () => {
+  it.concurrent('should generate correct schema', async () => {
     expect(printSchemaWithDirectives(mesh.schema)).toMatchSnapshot();
   });
 });
diff --git a/examples/json-schema-file-upload/tests/json-schema-file-upload.test.ts b/examples/json-schema-file-upload/tests/json-schema-file-upload.test.ts
@@ -18,7 +18,7 @@ describe('JSON Schema File Uploads', () => {
   afterAll(() => {
     mesh.destroy();
   });
-  it('should upload files correctly', async () => {
+  it.concurrent('should upload files correctly', async () => {
     const uploadResult = await mesh.execute(
       /* GraphQL */ `
         mutation UploadFile($file: File!, $description: String!) {
@@ -42,7 +42,7 @@ describe('JSON Schema File Uploads', () => {
       },
     });
   });
-  it('should read files correctly', async () => {
+  it.concurrent('should read files correctly', async () => {
     const readResult = await mesh.execute(
       /* GraphQL */ `
         query ReadFile($fileName: String!) {
diff --git a/examples/json-schema-subscriptions/tests/json-schema-subscriptions.test.ts b/examples/json-schema-subscriptions/tests/json-schema-subscriptions.test.ts
@@ -29,10 +29,10 @@ describe('JSON Schema Subscriptions', () => {
   afterEach(() => {
     resetTodos();
   });
-  it('should generate correct schema', async () => {
+  it.concurrent('should generate correct schema', async () => {
     expect(printSchemaWithDirectives(mesh.schema)).toMatchSnapshot();
   });
-  it('subscriptions', async () => {
+  it.concurrent('subscriptions', async () => {
     const subscription = /* GraphQL */ `
       subscription todoAdded {
         todoAdded {
diff --git a/examples/mongoose-example/tests/mongoose-example.test.ts b/examples/mongoose-example/tests/mongoose-example.test.ts
@@ -11,7 +11,7 @@ describe('Mongoose', () => {
     });
     mesh = await getMesh(config);
   });
-  it('should generate correct schema', async () => {
+  it.concurrent('should generate correct schema', async () => {
     expect(printSchema(lexicographicSortSchema(mesh.schema))).toMatchSnapshot();
   });
   afterAll(() => {
diff --git a/examples/mysql-employees/tests/mysql-employees.test.ts b/examples/mysql-employees/tests/mysql-employees.test.ts
@@ -15,18 +15,19 @@ describe('MySQL Employees', () => {
     });
     mesh = await getMesh(config);
   });
-  it('should generate correct schema', async () => {
+  it.concurrent('should generate correct schema', async () => {
     expect(printSchemaWithDirectives(mesh.schema)).toMatchSnapshot('schema');
   });
-  it('should give correct response for example queries', () =>
+  it.concurrent('should give correct response for example queries', () =>
     Promise.all(
       config.documents.map(async operation => {
         const result = await mesh.execute(operation.document!);
         expect(result).toMatchSnapshot(
           basename(operation.location || 'anonymous') + '-query-result',
         );
       }),
-    ));
+    ),
+  );
   afterAll(() => {
     mesh?.destroy();
   });
diff --git a/examples/mysql-rfam/tests/mysql-rfam.test.js.bak b/examples/mysql-rfam/tests/mysql-rfam.test.js.bak
@@ -13,15 +13,15 @@ describe.skip('MySQL Rfam', () => {
     });
     mesh$ = config$.then(config => getMesh(config));
   });
-  it('should generate correct schema', async () => {
+  it.concurrent('should generate correct schema', async () => {
     const { schema } = await mesh$;
     expect(
       printSchema(lexicographicSortSchema(schema), {
         descriptions: false,
       }),
     ).toMatchSnapshot('mysql-rfam-schema');
   });
-  it('should give correct response for example queries', async () => {
+  it.concurrent('should give correct response for example queries', async () => {
     const { documents } = await config$;
     const { execute } = await mesh$;
     for (const source of documents) {
diff --git a/examples/neo4j-example/tests/neo4j-example.test.ts b/examples/neo4j-example/tests/neo4j-example.test.ts
@@ -25,10 +25,10 @@ describe('Neo4j', () => {
     mesh = await getMesh(config);
   });
   jest.setTimeout(120_000);
-  it('should generate correct schema', () => {
+  it.concurrent('should generate correct schema', () => {
     expect(printSchemaWithDirectives(lexicographicSortSchema(mesh.schema))).toMatchSnapshot();
   });
-  it('should give correct response for example queries', async () => {
+  it.concurrent('should give correct response for example queries', async () => {
     for (const source of config.documents) {
       const result = await mesh.execute(source.document!);
       expect(result).toMatchSnapshot(basename(source.location!) + '-query-result');
diff --git a/examples/odata-trippin/tests/odata-trippin.test.ts b/examples/odata-trippin/tests/odata-trippin.test.ts
@@ -13,14 +13,14 @@ describe('OData TripPin', () => {
     });
     mesh = await getMesh(config);
   });
-  it('should generate correct schema', async () => {
+  it.concurrent('should generate correct schema', async () => {
     expect(
       introspectionFromSchema(lexicographicSortSchema(mesh.schema), {
         descriptions: false,
       }),
     ).toMatchSnapshot('odata-trippin-schema');
   });
-  it('should give correct response for example queries', async () => {
+  it.concurrent('should give correct response for example queries', async () => {
     for (const source of config.documents) {
       if (!source.document || !source.location) {
         continue;
diff --git a/examples/openapi-javascript-wiki/tests/javascript-wiki.test.ts b/examples/openapi-javascript-wiki/tests/javascript-wiki.test.ts
@@ -16,10 +16,10 @@ describe('JavaScript Wiki', () => {
     });
     mesh = await getMesh(config);
   });
-  it('should generate correct schema', async () => {
+  it.concurrent('should generate correct schema', async () => {
     expect(printSchemaWithDirectives(mesh.schema)).toMatchSnapshot('javascript-wiki-schema');
   });
-  it('should give correct response for viewsInPastMonth', async () => {
+  it.concurrent('should give correct response for viewsInPastMonth', async () => {
     const viewsInPastMonthQuery = await readFile(
       join(__dirname, '../example-queries/views-in-past-month.graphql'),
       'utf8',
@@ -28,13 +28,16 @@ describe('JavaScript Wiki', () => {
     expect(result.errors).toBeFalsy();
     expect(result?.data?.viewsInPastMonth).toBeGreaterThan(0);
   });
-  it('should give correct response for wikipediaMetrics within specific range', async () => {
-    const wikipediaMetricsQuery = await readFile(
-      join(__dirname, '../example-queries/wikipedia-metrics.graphql'),
-      'utf8',
-    );
-    const result = await mesh.execute(wikipediaMetricsQuery);
-    expect(result).toMatchSnapshot('wikipedia-metrics-result');
-  });
+  it.concurrent(
+    'should give correct response for wikipediaMetrics within specific range',
+    async () => {
+      const wikipediaMetricsQuery = await readFile(
+        join(__dirname, '../example-queries/wikipedia-metrics.graphql'),
+        'utf8',
+      );
+      const result = await mesh.execute(wikipediaMetricsQuery);
+      expect(result).toMatchSnapshot('wikipedia-metrics-result');
+    },
+  );
   afterAll(() => mesh?.destroy());
 });
diff --git a/examples/openapi-location-weather/tests/location-weather.test.ts b/examples/openapi-location-weather/tests/location-weather.test.ts
@@ -20,7 +20,7 @@ describe('Location Weather', () => {
       getBuiltMesh: async () => mesh,
     });
   });
-  it('should generate correct schema', async () => {
+  it.concurrent('should generate correct schema', async () => {
     expect(printSchema(lexicographicSortSchema(mesh.schema))).toMatchSnapshot(
       'location-weather-schema',
     );
diff --git a/examples/openapi-stackexchange/test/openapi-stackexchange.test.ts.bak b/examples/openapi-stackexchange/test/openapi-stackexchange.test.ts.bak
@@ -15,10 +15,10 @@ describe.skip('Stack Exchange', () => {
   afterAll(() => {
     mesh.destroy();
   });
-  it('should generate correct schema', async () => {
+  it.concurrent('should generate correct schema', async () => {
     expect(printSchemaWithDirectives(mesh.schema)).toMatchSnapshot();
   });
-  it('should return the correct data', async () => {
+  it.concurrent('should return the correct data', async () => {
     const listQuestionsQuery = await readFile(
       join(__dirname, '..', 'list-questions.query.graphql'),
       'utf-8',
diff --git a/examples/openapi-subscriptions/tests/openapi-subscriptions.test.ts b/examples/openapi-subscriptions/tests/openapi-subscriptions.test.ts
@@ -40,7 +40,7 @@ describe('OpenAPI Subscriptions', () => {
   afterAll(() => {
     appWrapper.dispose();
   });
-  it('should work', async () => {
+  it.concurrent('should work', async () => {
     expect.assertions(2);
     const startWebhookMutation = await readFile(
       join(__dirname, '..', 'example-queries', 'startWebhook.mutation.graphql'),
diff --git a/examples/persisted-operations/tests/persisted-queries.test.ts b/examples/persisted-operations/tests/persisted-queries.test.ts
@@ -33,7 +33,7 @@ describe('Persisted Queries', () => {
 
     afterAll(() => mesh?.destroy());
 
-    it('should give correct response for inline persisted operation', async () => {
+    it.concurrent('should give correct response for inline persisted operation', async () => {
       const response = await meshHttp.fetch('/graphql', {
         method: 'POST',
         headers: { 'Content-Type': 'application/json' },
@@ -53,7 +53,7 @@ describe('Persisted Queries', () => {
       expect(result.data).toEqual({ __typename: 'Query' });
     });
 
-    it('should give correct response for file documents', async () => {
+    it.concurrent('should give correct response for file documents', async () => {
       const response = await meshHttp.fetch('/graphql', {
         method: 'POST',
         headers: { 'Content-Type': 'application/json' },
@@ -73,7 +73,7 @@ describe('Persisted Queries', () => {
       expect(result.data).toEqual({ greeting: { hello: 'world' } });
     });
 
-    it('should not restrict to persisted queries only', async () => {
+    it.concurrent('should not restrict to persisted queries only', async () => {
       const response = await meshHttp.fetch('/graphql', {
         method: 'POST',
         headers: { 'Content-Type': 'application/json' },
diff --git a/examples/postgres-geodb/test/test.ts b/examples/postgres-geodb/test/test.ts
@@ -16,7 +16,7 @@ describe('PostgresGeoDB', () => {
     mesh = await getMesh(config);
     process.env.DEBUG = debugEnvFlag;
   });
-  it('should give correct response for example queries', async () => {
+  it.concurrent('should give correct response for example queries', async () => {
     const result = await mesh.execute(config.documents[0].document!);
     expect(result?.data?.allCities?.nodes?.[0]?.countrycode).toBeTruthy();
     expect(result?.data?.allCities?.nodes?.[0]?.developers?.[0]?.login).toBeTruthy();
diff --git a/examples/programmatic-batching/tests/programmatic-batching.spec.ts b/examples/programmatic-batching/tests/programmatic-batching.spec.ts
@@ -23,10 +23,10 @@ describe('Batching Example', () => {
   afterAll(() => {
     mesh.destroy();
   });
-  it('should generate correct schema', () => {
+  it.concurrent('should generate correct schema', () => {
     expect(printSchemaWithDirectives(lexicographicSortSchema(mesh.schema))).toMatchSnapshot();
   });
-  it('should give correct response for the batched example query', async () => {
+  it.concurrent('should give correct response for the batched example query', async () => {
     const queryStr = await readFile(join(__dirname, '..', 'example-query.graphql'), 'utf-8');
     const result = await mesh.execute(queryStr);
     expect(result).toMatchSnapshot('example-query-result');
diff --git a/examples/response-cache/tests/response-cache.spec.ts b/examples/response-cache/tests/response-cache.spec.ts
diff --git a/examples/soap-demo/tests/soap-demo.test.ts b/examples/soap-demo/tests/soap-demo.test.ts
diff --git a/examples/sqlite-chinook/tests/sqlite-chinook.test.ts b/examples/sqlite-chinook/tests/sqlite-chinook.test.ts
diff --git a/examples/thrift-calculator/tests/thrift-calculator.test.ts b/examples/thrift-calculator/tests/thrift-calculator.test.ts
diff --git a/examples/type-merging-batching-example/tests/type-merging-batching-example.test.ts b/examples/type-merging-batching-example/tests/type-merging-batching-example.test.ts
diff --git a/examples/v1-next/integrations/fastify/tests/fastify.spec.ts b/examples/v1-next/integrations/fastify/tests/fastify.spec.ts
diff --git a/packages/loaders/openapi/tests/schemas.test.ts b/packages/loaders/openapi/tests/schemas.test.ts
