Run tests with Bun (#6863)

* Run tests with Bun

* Hmm

* Fix tests

* Hmm

* Fix Unit tests

* Clear lest

Author: ardatan

.github/workflows/tests.yml

@@ -94,10 +94,50 @@ jobs:
       - name: Build
         run: yarn build
       - name: Unit Tests
-        run: yarn test --ci
+        uses: nick-fields/retry@v3
+        with:
+          timeout_minutes: 10
+          max_attempts: 5
+          command: yarn test --ci
       - name: Leak Tests
         uses: nick-fields/retry@v3
         with:
           timeout_minutes: 10
           max_attempts: 5
           command: yarn test:leaks --ci
+  test-bun:
+    name: Unit Test on Bun (${{matrix.os}}) and GraphQL v${{matrix.graphql_version}}
+    runs-on: ubuntu-latest
+    strategy:
+      fail-fast: false
+      matrix:
+        os: [ubuntu-latest] # remove windows to speed up the tests
+        graphql_version:
+          - 15
+          - 16
+    steps:
+      - name: Checkout Master
+        uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4
+
+      - name: Setup env
+        uses: the-guild-org/shared-config/setup@main
+        with:
+          nodeVersion: 23
+
+      - name: Use GraphQL v${{matrix.graphql_version}}
+        run: node ./scripts/match-graphql.js ${{matrix.graphql_version}}
+      - name: Install Dependencies using Yarn
+        run: yarn install --ignore-engines && git checkout yarn.lock
+      - name: Build
+        run: yarn build
+      - name: Unit Tests
+        uses: nick-fields/retry@v3
+        with:
+          timeout_minutes: 10
+          max_attempts: 5
+          command: yarn test:bun --ci --reporter=junit --reporter-outfile=./junit.xml
+      - name: Publish Test Report
+        uses: mikepenz/action-junit-report@v5
+        if: success() || failure() # always run even if the previous step fails
+        with:
+          report_paths: './junit.xml'

package.json

@@ -40,6 +40,7 @@
     "prettier:check": "prettier --cache --ignore-path .gitignore --ignore-path .prettierignore --check .",
     "release": "changeset publish",
     "test": "jest --no-watchman",
+    "test:bun": "bun test",
     "test:leaks": "cross-env \"LEAK_TEST=1\" jest --no-watchman --detectOpenHandles --detectLeaks --forceExit",
     "ts:check": "tsc --noEmit"
   },
@@ -57,6 +58,7 @@
     "@typescript-eslint/parser": "8.20.0",
     "babel-jest": "29.7.0",
     "bob-the-bundler": "7.0.1",
+    "bun": "^1.1.43",
     "chalk": "5.4.1",
     "concurrently": "9.1.2",
     "cross-env": "7.0.3",

packages/documents/tests/print-executable-graphql-document.spec.ts

@@ -11,7 +11,7 @@ describe('printExecutableGraphQLDocument', () => {
       }
     `);
     const outputStr = printExecutableGraphQLDocument(inputDocument);
-    expect(outputStr).toMatchInlineSnapshot(`"query A { a b c }"`);
+    expect(outputStr).toBe(`query A { a b c }`);
   });
 
   test('fragments are always before query operations', () => {
@@ -37,8 +37,8 @@ describe('printExecutableGraphQLDocument', () => {
       }
     `);
     const outputStr = printExecutableGraphQLDocument(inputDocument);
-    expect(outputStr).toMatchInlineSnapshot(
-      `"fragment A on Query { a b c } fragment B on Query { a b c } query A { a b c ...A ...B }"`,
+    expect(outputStr).toBe(
+      `fragment A on Query { a b c } fragment B on Query { a b c } query A { a b c ...A ...B }`,
     );
   });
 
@@ -54,7 +54,7 @@ describe('printExecutableGraphQLDocument', () => {
       }
     `);
     const outputStr = printExecutableGraphQLDocument(inputDocument);
-    expect(outputStr).toMatchInlineSnapshot(`"query A { ... on Query { a } ... on Query { b } }"`);
+    expect(outputStr).toBe(`query A { ... on Query { a } ... on Query { b } }`);
   });
 
   test('inline fragments are sorted alphabetically based on the deep selection set', () => {
@@ -79,8 +79,8 @@ describe('printExecutableGraphQLDocument', () => {
       }
     `);
     const outputStr = printExecutableGraphQLDocument(inputDocument);
-    expect(outputStr).toMatchInlineSnapshot(
-      `"fragment B on Query { c } query A { ... on Query { a { a ...B } } ... on Query { a { b ...B } } }"`,
+    expect(outputStr).toBe(
+      `fragment B on Query { c } query A { ... on Query { a { a ...B } } ... on Query { a { b ...B } } }`,
     );
   });
 
@@ -105,8 +105,6 @@ describe('printExecutableGraphQLDocument', () => {
       }
     `);
     const outputStr = printExecutableGraphQLDocument(inputDocument);
-    expect(outputStr).toMatchInlineSnapshot(
-      `"mutation A { ... on Mutation { c b d } c { d e { a b } f } b a }"`,
-    );
+    expect(outputStr).toBe(`mutation A { ... on Mutation { c b d } c { d e { a b } f } b a }`);
   });
 });

packages/executor/src/__testUtils__/expectJSON.ts

@@ -1,4 +1,6 @@
 import { isObjectLike } from '@graphql-tools/utils';
+// eslint-disable-next-line import/no-extraneous-dependencies
+import { expect } from '@jest/globals';
 
 /**
  * Creates an object map with the same keys as `map` and values generated by

packages/executor/src/execution/__tests__/abort-signal.test.ts

@@ -18,7 +18,6 @@ describe('Abort Signal', () => {
     expect(spy.mock.calls.length).toBeLessThanOrEqual(1);
   });
   it('should stop the subscription', async () => {
-    expect.assertions(3);
     let stopped = false;
     const schema = makeExecutableSchema({
       typeDefs: /* GraphQL */ `
@@ -127,7 +126,7 @@ describe('Abort Signal', () => {
     const $next = iterator.next();
     await rootResolverGotInvokedD.promise;
     controller.abort();
-    await expect($next).rejects.toMatchInlineSnapshot(`DOMException {}`);
+    await expect($next).rejects.toBeInstanceOf(DOMException);
     expect(aResolverGotInvoked).toEqual(false);
   });
   it('should stop the serial mutation execution', async () => {
@@ -174,7 +173,7 @@ describe('Abort Signal', () => {
       `),
       signal: controller.signal,
     });
-    expect(result$).rejects.toMatchInlineSnapshot(`DOMException {}`);
+    expect(result$).rejects.toBeInstanceOf(DOMException);
     expect(didInvokeFirstFn).toBe(true);
     expect(didInvokeSecondFn).toBe(true);
     expect(didInvokeThirdFn).toBe(false);
@@ -224,7 +223,7 @@ describe('Abort Signal', () => {
       `),
       signal: controller.signal,
     });
-    await expect(result$).rejects.toMatchInlineSnapshot(`DOMException {}`);
+    await expect(result$).rejects.toBeInstanceOf(DOMException);
     expect(isAborted).toEqual(true);
   });
   it('stops pending stream execution for incremental delivery (@stream)', async () => {
@@ -285,7 +284,7 @@ describe('Abort Signal', () => {
 
     const next$ = iter.next();
     controller.abort();
-    await expect(next$).rejects.toMatchInlineSnapshot(`DOMException {}`);
+    await expect(next$).rejects.toBeInstanceOf(DOMException);
     expect(isReturnInvoked).toEqual(true);
   });
   it('stops pending stream execution for parallel sources incremental delivery (@stream)', async () => {
@@ -365,7 +364,7 @@ describe('Abort Signal', () => {
 
     const next$ = iter.next();
     controller.abort();
-    await expect(next$).rejects.toMatchInlineSnapshot(`DOMException {}`);
+    await expect(next$).rejects.toBeInstanceOf(DOMException);
     expect(isReturn1Invoked).toEqual(true);
     expect(isReturn2Invoked).toEqual(true);
   });
@@ -429,19 +428,17 @@ describe('Abort Signal', () => {
 
     const iterator = result[Symbol.asyncIterator]();
     const next = await iterator.next();
-    expect(next.value).toMatchInlineSnapshot(`
-{
-  "data": {
-    "root": {},
-  },
-  "hasNext": true,
-}
-`);
+    expect(next.value).toEqual({
+      data: {
+        root: {},
+      },
+      hasNext: true,
+    });
     const next$ = iterator.next();
     await aResolverGotInvokedD.promise;
     controller.abort();
     requestGotCancelledD.resolve();
-    await expect(next$).rejects.toThrow('This operation was aborted');
+    await expect(next$).rejects.toThrow(/operation was aborted/);
     expect(bResolverGotInvoked).toBe(false);
   });
   it('stops promise execution', async () => {
@@ -472,7 +469,7 @@ describe('Abort Signal', () => {
 
     expect(result$).toBeInstanceOf(Promise);
     controller.abort();
-    await expect(result$).rejects.toMatchInlineSnapshot(`DOMException {}`);
+    await expect(result$).rejects.toBeInstanceOf(DOMException);
   });
   it('does not even try to execute if the signal is already aborted', async () => {
     let resolverGotInvoked = false;
@@ -502,7 +499,7 @@ describe('Abort Signal', () => {
         `),
         signal: controller.signal,
       }),
-    ).toThrowErrorMatchingInlineSnapshot(`"This operation was aborted"`);
+    ).toThrow(/operation was aborted/);
     expect(resolverGotInvoked).toBe(false);
   });
 });

packages/executor/src/execution/__tests__/error-handling.test.ts

@@ -36,13 +36,16 @@ describe('Error Handling', () => {
   });
   if (globalThis.fetch != null) {
     let server: Server;
-    afterEach(done => {
+    afterEach(async () => {
       if (!server) {
-        done();
         return;
       }
-      server.closeAllConnections();
-      server.close(done);
+      if (!globalThis.Bun) {
+        server.closeAllConnections();
+      }
+      await new Promise<void>((resolve, reject) => {
+        server.close(err => (err ? reject(err) : resolve()));
+      });
     });
     it('handles undici fetch JSON parsing errors', async () => {
       server = createServer((_, res) => {
@@ -80,7 +83,9 @@ describe('Error Handling', () => {
         throw new Error('Expected a result, but got an async iterable');
       }
       const errorMessage = result.errors?.[0]?.message;
-      if (process.versions['node'].startsWith('18.')) {
+      if (globalThis.Bun) {
+        expect(errorMessage).toBeTruthy();
+      } else if (process.versions['node'].startsWith('18.')) {
         expect(errorMessage).toBe('Unexpected end of JSON input');
       } else {
         expect(errorMessage).toContain(

packages/executors/apollo-link/tests/apollo-link.spec.ts

@@ -58,6 +58,7 @@ describe('Apollo Link', () => {
   const client = new ApolloClient({
     link: new ExecutorLink(
       buildHTTPExecutor({
+        endpoint: `http://localhost${yoga.graphqlEndpoint}`,
         fetch: yoga.fetch,
         File: yoga.fetchAPI.File,
         FormData: yoga.fetchAPI.FormData,
@@ -87,34 +88,37 @@ describe('Apollo Link', () => {
       hello: 'Hello Apollo Client!',
     });
   });
-  testIf(!process.env['LEAK_TEST'])('should handle subscriptions correctly', async () => {
-    expect.assertions(5);
-    const observable = client.subscribe({
-      query: parse(/* GraphQL */ `
-        subscription Time {
-          time
-        }
-      `),
-    });
-    const collectedValues: string[] = [];
-    let i = 0;
-    await new Promise<void>((resolve, reject) => {
-      const subscription = observable.subscribe((result: FetchResult) => {
-        collectedValues.push(result.data?.['time']);
-        i++;
-        if (i > 2) {
-          subscription.unsubscribe();
-          resolve();
-        }
-      }, reject);
-    });
-    expect(collectedValues.length).toBe(3);
-    expect(i).toBe(3);
-    const now = new Date();
-    for (const value of collectedValues) {
-      expect(new Date(value).getFullYear()).toBe(now.getFullYear());
-    }
-  });
+  testIf(!process.env['LEAK_TEST'] && !globalThis.Bun)(
+    'should handle subscriptions correctly',
+    async () => {
+      expect.assertions(5);
+      const observable = client.subscribe({
+        query: parse(/* GraphQL */ `
+          subscription Time {
+            time
+          }
+        `),
+      });
+      const collectedValues: string[] = [];
+      let i = 0;
+      await new Promise<void>((resolve, reject) => {
+        const subscription = observable.subscribe((result: FetchResult) => {
+          collectedValues.push(result.data?.['time']);
+          i++;
+          if (i > 2) {
+            subscription.unsubscribe();
+            resolve();
+          }
+        }, reject);
+      });
+      expect(collectedValues.length).toBe(3);
+      expect(i).toBe(3);
+      const now = new Date();
+      for (const value of collectedValues) {
+        expect(new Date(value).getFullYear()).toBe(now.getFullYear());
+      }
+    },
+  );
   it('should handle file uploads correctly', async () => {
     const result = await client.mutate({
       mutation: parse(/* GraphQL */ `
@@ -131,20 +135,23 @@ describe('Apollo Link', () => {
       readFile: 'Hello World',
     });
   });
-  it('should complete subscription even while waiting for events', async () => {
-    const observable = client.subscribe({
-      query: parse(/* GraphQL */ `
-        subscription Ping {
-          ping
-        }
-      `),
-    });
-    const sub = observable.subscribe({
-      next: () => {
-        // noop
-      },
-    });
-    globalThis.setTimeout(() => sub.unsubscribe(), 0);
-    await waitForPingStop;
-  });
+  testIf(!globalThis.Bun)(
+    'should complete subscription even while waiting for events',
+    async () => {
+      const observable = client.subscribe({
+        query: parse(/* GraphQL */ `
+          subscription Ping {
+            ping
+          }
+        `),
+      });
+      const sub = observable.subscribe({
+        next: () => {
+          // noop
+        },
+      });
+      globalThis.setTimeout(() => sub.unsubscribe(), 0);
+      await waitForPingStop;
+    },
+  );
 });