Better handle errors from the client and detect multiple operations

.changeset/khaki-birds-tap.md

@@ -0,0 +1,5 @@
+---
+"@apollo/generate-persisted-query-manifest": patch
+---
+
+Better report errors that originate from Apollo Client during manifest generation.

.changeset/perfect-lies-protect.md

@@ -0,0 +1,5 @@
+---
+"@apollo/generate-persisted-query-manifest": patch
+---
+
+Detect multiple operations during manifest generation and report them as errors.

packages/generate-persisted-query-manifest/package.json

@@ -32,6 +32,7 @@
     "cosmiconfig-typescript-loader": "^5.0.0",
     "globby": "^11.1.0",
     "lodash": "^4.17.21",
+    "semver": "^7.6.0",
     "vfile": "^4.2.1",
     "vfile-reporter": "^6.0.2"
   },

packages/generate-persisted-query-manifest/src/__tests__/cli.test.ts

@@ -1419,6 +1419,84 @@ const query;
   await cleanup();
 });
 
+test("does not allow multiple operations in a single document", async () => {
+  const { cleanup, runCommand, writeFile } = await setup();
+
+  await writeFile(
+    "./src/queries.graphql",
+    `
+query GreetingQuery {
+  greeting
+}
+
+query GoodbyeQuery {
+  goodbye
+}
+`,
+  );
+
+  await writeFile(
+    "./src/mutations.graphql",
+    `
+mutation SayHello {
+  sayHello
+}
+
+mutation SayGoodbye {
+  goodbye
+}
+`,
+  );
+
+  await writeFile(
+    "./src/subscriptions.graphql",
+    `
+subscription HelloSubscription {
+  hello
+}
+
+subscription GoodbyeSubscription {
+  goodbye
+}
+`,
+  );
+  await writeFile(
+    "./src/mixed.graphql",
+    `
+mutation TestMutation {
+  test
+}
+
+query TestQuery {
+  test
+}
+
+subscription TestSubscription {
+  test
+}
+`,
+  );
+
+  const { code, stderr } = await runCommand();
+
+  expect(code).toBe(1);
+  expect(stderr).toMatchInlineSnapshot(`
+    [
+      "src/mixed.graphql",
+      "1:1  error  Cannot declare multiple operations in a single document.",
+      "src/mutations.graphql",
+      "1:1  error  Cannot declare multiple operations in a single document.",
+      "src/queries.graphql",
+      "1:1  error  Cannot declare multiple operations in a single document.",
+      "src/subscriptions.graphql",
+      "1:1  error  Cannot declare multiple operations in a single document.",
+      "✖ 4 errors",
+    ]
+  `);
+
+  await cleanup();
+});
+
 test("gathers and reports all errors together", async () => {
   const { cleanup, runCommand, writeFile } = await setup();
   const anonymousQuery = gql`

packages/generate-persisted-query-manifest/src/index.ts

@@ -1,5 +1,6 @@
 import { createFragmentRegistry } from "@apollo/client/cache";
 import type { FragmentRegistryAPI } from "@apollo/client/cache";
+import semver from "semver";
 import {
   ApolloClient,
   ApolloLink,
@@ -21,6 +22,7 @@ import {
   type DocumentNode,
   visit,
   GraphQLError,
+  BREAK,
 } from "graphql";
 import { first, sortBy } from "lodash";
 import { createHash } from "node:crypto";
@@ -259,10 +261,22 @@ const ERROR_MESSAGES = {
     )}".`;
   },
   parseError(error: Error) {
-    return `${error.name}: ${error.message}`;
+    return formatErrorMessage(error);
+  },
+  multipleOperations() {
+    return "Cannot declare multiple operations in a single document.";
   },
 };
 
+async function enableDevMessages() {
+  const { loadDevMessages, loadErrorMessages } = await import(
+    "@apollo/client/dev"
+  );
+
+  loadDevMessages();
+  loadErrorMessages();
+}
+
 function addError(
   source: Pick<DocumentSource, "file"> & Partial<DocumentSource>,
   message: string,
@@ -372,6 +386,10 @@ function uniq<T>(arr: T[]) {
   return [...new Set(arr)];
 }
 
+function formatErrorMessage(error: Error) {
+  return `${error.name}: ${error.message}`;
+}
+
 async function fromFilepathList(
   documents: string | string[],
 ): Promise<DocumentSourceConfig> {
@@ -385,6 +403,8 @@ async function fromFilepathList(
       continue;
     }
 
+    let documentCount = 0;
+
     visit(source.node, {
       FragmentDefinition(node) {
         const name = node.name.value;
@@ -404,6 +424,11 @@ async function fromFilepathList(
       OperationDefinition(node) {
         const name = node.name?.value;
 
+        if (++documentCount > 1) {
+          addError(source, ERROR_MESSAGES.multipleOperations());
+          return BREAK;
+        }
+
         if (!name) {
           addError(source, ERROR_MESSAGES.anonymousOperation(node));
 
@@ -560,15 +585,29 @@ export async function generatePersistedQueryManifest(
     }),
   });
 
+  if (semver.gte(client.version, "3.8.0")) {
+    await enableDevMessages();
+  }
+
   for (const [_, sources] of sortBy([...operationsByName.entries()], first)) {
     for (const source of sources) {
       if (source.node) {
-        await client.query({ query: source.node, fetchPolicy: "no-cache" });
+        try {
+          await client.query({ query: source.node, fetchPolicy: "no-cache" });
+        } catch (error) {
+          if (error instanceof Error) {
+            addError(source, formatErrorMessage(error));
+          } else {
+            addError(source, "Unknown error occured. Please file a bug.");
+          }
+        }
       }
     }
   }
 
-  maybeReportErrorsAndExit(configFile);
+  maybeReportErrorsAndExit(
+    uniq(sources.map((source) => source.file).concat(configFile)),
+  );
 
   return {
     format: "apollo-persisted-query-manifest",