Improvements on schema loading and error handling (#7447)

* Perf optimizations - avoid async/await

* Go

* More

* Bump federation

* chore(dependencies): updated changesets for modified dependencies

* More messages when supergraph fails to load

* ..

* Go

* Typings

* Improve tests

* Go

* Go

---------

Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>

.changeset/@graphql-mesh_fusion-runtime-7447-dependencies.md

@@ -0,0 +1,6 @@
+---
+"@graphql-mesh/fusion-runtime": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)
+  - Updated dependency [`@graphql-tools/federation@^2.2.4` ↗︎](https://www.npmjs.com/package/@graphql-tools/federation/v/2.2.4) (from `^2.2.3`, in `dependencies`)

.changeset/@graphql-mesh_graphql-7447-dependencies.md

@@ -0,0 +1,6 @@
+---
+"@graphql-mesh/graphql": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)
+  - Updated dependency [`@graphql-tools/federation@^2.2.4` ↗︎](https://www.npmjs.com/package/@graphql-tools/federation/v/2.2.4) (from `^2.2.3`, in `dependencies`)

.changeset/@graphql-mesh_merger-stitching-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/merger-stitching": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_odata-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/odata": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_postgraphile-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/postgraphile": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_runtime-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/runtime": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_serve-runtime-7447-dependencies.md

@@ -0,0 +1,6 @@
+---
+"@graphql-mesh/serve-runtime": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)
+  - Updated dependency [`@graphql-tools/federation@^2.2.4` ↗︎](https://www.npmjs.com/package/@graphql-tools/federation/v/2.2.4) (from `^2.2.3`, in `dependencies`)

.changeset/@graphql-mesh_supergraph-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/supergraph": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/federation@^2.2.4` ↗︎](https://www.npmjs.com/package/@graphql-tools/federation/v/2.2.4) (from `^2.2.3`, in `dependencies`)

.changeset/@graphql-mesh_transform-encapsulate-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/transform-encapsulate": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_transform-federation-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/transform-federation": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_transform-filter-schema-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/transform-filter-schema": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_transform-hive-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/transform-hive": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_transform-hoist-field-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/transform-hoist-field": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_transform-naming-convention-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/transform-naming-convention": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_transform-prefix-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/transform-prefix": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_transform-rename-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/transform-rename": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_transform-type-merging-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/transform-type-merging": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_transport-common-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/transport-common": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_transport-mysql-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/transport-mysql": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_transport-neo4j-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/transport-neo4j": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_types-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/types": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@graphql-mesh_utils-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-mesh/utils": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@omnigraph_json-schema-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@omnigraph/json-schema": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@omnigraph_mysql-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@omnigraph/mysql": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@omnigraph_neo4j-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@omnigraph/neo4j": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@omnigraph_openapi-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@omnigraph/openapi": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@omnigraph_raml-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@omnigraph/raml": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/@omnigraph_sqlite-7447-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@omnigraph/sqlite": patch
+---
+dependencies updates:
+  - Updated dependency [`@graphql-tools/delegate@^10.0.17` ↗︎](https://www.npmjs.com/package/@graphql-tools/delegate/v/10.0.17) (from `^10.0.16`, in `dependencies`)

.changeset/gorgeous-birds-knock.md

@@ -0,0 +1,5 @@
+---
+'@graphql-mesh/utils': patch
+---
+
+Accept `errorMapper` in `mapMaybePromise`

.changeset/silent-mugs-act.md

@@ -0,0 +1,7 @@
+---
+'@graphql-mesh/serve-runtime': patch
+'@graphql-mesh/serve-cli': patch
+---
+
+Export \`MeshServeConfigContext`\, \`useContentEncoding\` and \`useUpstreamCancel\` from
+\`serve-cli\` and \`serve-runtime\`

.changeset/spicy-beds-applaud.md

@@ -0,0 +1,5 @@
+---
+'@graphql-mesh/serve-runtime': patch
+---
+
+Fix the wrong information on the landing page

.changeset/three-crabs-brake.md

@@ -0,0 +1,8 @@
+---
+'@graphql-mesh/transport-common': patch
+'@graphql-mesh/transport-http': patch
+'@graphql-mesh/fusion-runtime': patch
+'@graphql-mesh/serve-runtime': patch
+---
+
+Improvements on schema loading handling

.changeset/wet-hounds-reflect.md

@@ -0,0 +1,5 @@
+---
+'@graphql-mesh/serve-runtime': patch
+---
+
+Log debug messages when readiness check fails

e2e/federation-subscriptions-passthrough/federation-subscriptions-passthrough.test.ts

@@ -1,6 +1,7 @@
 import { setTimeout } from 'timers/promises';
 import { createClient, type Client } from 'graphql-sse';
 import { createTenv, getAvailablePort } from '@e2e/tenv';
+import { fetch } from '@whatwg-node/fetch';
 import { TOKEN } from './services/products/server';
 
 const { composeWithApollo, service, serve } = createTenv(__dirname);
@@ -108,6 +109,7 @@ it('should recycle websocket connections', async () => {
     headers: {
       Authorization: TOKEN,
     },
+    fetchFn: fetch,
   });
 
   const query = /* GraphQL */ `
@@ -153,6 +155,7 @@ it('should subscribe and resolve via http callbacks', async () => {
   client = createClient({
     url: `${publicUrl}/graphql`,
     retryAttempts: 0,
+    fetchFn: fetch,
   });
   const sub = client.iterate({
     query: /* GraphQL */ `

packages/fusion/runtime/package.json

@@ -56,9 +56,9 @@
     "@graphql-mesh/transport-common": "^0.4.5",
     "@graphql-mesh/types": "^0.99.5",
     "@graphql-mesh/utils": "^0.99.5",
-    "@graphql-tools/delegate": "^10.0.16",
+    "@graphql-tools/delegate": "^10.0.17",
     "@graphql-tools/executor": "^1.3.0",
-    "@graphql-tools/federation": "^2.2.3",
+    "@graphql-tools/federation": "^2.2.4",
     "@graphql-tools/stitch": "^9.2.10",
     "@graphql-tools/stitching-directives": "^3.1.2",
     "@graphql-tools/utils": "^10.2.3",

packages/fusion/runtime/src/unifiedGraphManager.ts

@@ -58,6 +58,7 @@ export interface UnifiedGraphManagerOptions<TContext> {
   getUnifiedGraph(ctx: TransportContext): MaybePromise<GraphQLSchema | string | DocumentNode>;
   // Handle the unified graph by any specification
   handleUnifiedGraph?: UnifiedGraphHandler;
+  onSchemaChange?(unifiedGraph: GraphQLSchema): void;
   transports?: Transports;
   transportEntryAdditions?: TransportEntryAdditions;
   polling?: number;
@@ -78,7 +79,7 @@ export class UnifiedGraphManager<TContext> {
   private inContextSDK;
   private initialUnifiedGraph$: MaybePromise<true>;
   private disposableStack = new AsyncDisposableStack();
-  _transportEntryMap: Record<string, TransportEntry>;
+  private _transportEntryMap: Record<string, TransportEntry>;
   private _transportExecutorStack: AsyncDisposableStack;
   constructor(private opts: UnifiedGraphManagerOptions<TContext>) {
     this.handleUnifiedGraph = opts.handleUnifiedGraph || handleFederationSupergraph;
@@ -110,13 +111,13 @@ export class UnifiedGraphManager<TContext> {
   }
 
   private ensureUnifiedGraph() {
-    if (!this.initialUnifiedGraph$) {
+    if (!this.initialUnifiedGraph$ && !this.unifiedGraph) {
       this.initialUnifiedGraph$ = this.getAndSetUnifiedGraph();
     }
     return this.initialUnifiedGraph$;
   }
 
-  private getAndSetUnifiedGraph() {
+  private getAndSetUnifiedGraph(): MaybePromise<true> {
     this.pausePolling();
     return mapMaybePromise(
       this.opts.getUnifiedGraph(this.opts.transportContext),
@@ -181,8 +182,16 @@ export class UnifiedGraphManager<TContext> {
         }
         this.continuePolling();
         this._transportEntryMap = transportEntryMap;
+        this.opts.onSchemaChange?.(this.unifiedGraph);
         return cleanupJob$ || true;
       },
+      err => {
+        this.opts.transportContext?.logger?.error('Failed to load Supergraph', err);
+        if (!this.unifiedGraph) {
+          throw err;
+        }
+        return true;
+      },
     );
   }
 
@@ -200,6 +209,10 @@ export class UnifiedGraphManager<TContext> {
     });
   }
 
+  public getTransportEntryMap() {
+    return mapMaybePromise(this.ensureUnifiedGraph(), () => this._transportEntryMap);
+  }
+
   invalidateUnifiedGraph() {
     return this.getAndSetUnifiedGraph();
   }