Merge pull request #171 from kjones1876/master

fix: sync fetch errors were not passed back to query requests when batching

cli/src/runtime/batcher.ts

@@ -45,8 +45,13 @@ function dispatchQueueBatch(client: QueryBatcher, queue: Queue): void {
     if (batchedQuery.length === 1) {
         batchedQuery = batchedQuery[0]
     }
-
-    client.fetcher(batchedQuery).then((responses: any) => {
+    (() => {
+        try {
+            return client.fetcher(batchedQuery);
+        } catch(e) {
+            return Promise.reject(e);
+        }
+    })().then((responses: any) => {
         if (queue.length === 1 && !Array.isArray(responses)) {
             if (responses.errors && responses.errors.length) {
                 queue[0].reject(
@@ -71,6 +76,11 @@ function dispatchQueueBatch(client: QueryBatcher, queue: Queue): void {
             }
         }
     })
+    .catch((e) => {
+        for (let i = 0; i < queue.length; i++) {
+            queue[i].reject(e)
+        }
+    });
 }
 
 /**

integration-tests/tests/execution.ts

@@ -610,6 +610,43 @@ describe('execute queries', async function () {
             assert.strictEqual(headersCalledNTimes, 2)
         }),
     )
+
+
+    it(
+        'raises synchronously thrown fetch errors in batch mode',
+        withServer(async () => {
+            let client = createClient({
+                url: URL,
+                batch: true,
+                fetch: () => {
+                    return fetch('http://not.a.domain.google.com/');
+                }
+            })
+
+            const makeCall = () => client.query({
+                repository: {
+                    __args: {
+                        name: 'genql',
+                    },
+                    createdAt: true,
+                },
+            })
+
+            await assert.rejects(makeCall, (err) => {
+                if (!(err instanceof TypeError)) {
+                    assert.fail('err is not Error');
+                }
+                const cause = err.cause as Record<string, string>;
+
+                assert.strictEqual(err.name, 'TypeError');
+                assert.strictEqual(cause.code, 'ENOTFOUND');
+                assert.strictEqual(cause.syscall, 'getaddrinfo');
+                return true;
+            }, 'failed to throw')
+
+        }),
+    )
+
 })
 
 // // TODO apollo server changed everything in version 3 and i don't have time to fix their shit