fix(fs): fix fs handling issues for non Node environments

.changeset/fast-pets-dance.md

@@ -0,0 +1,13 @@
+---
+'openapi-react-weatherbit': patch
+'@graphql-mesh/cache-file': patch
+'@graphql-mesh/cli': patch
+'@graphql-mesh/json-schema': patch
+'@graphql-mesh/postgraphile': patch
+'@graphql-mesh/runtime': patch
+'@graphql-mesh/transform-snapshot': patch
+'@graphql-mesh/types': patch
+'@graphql-mesh/utils': patch
+---
+
+fix(fs): fix fs handling issues for non Node environments

examples/openapi-react-weatherbit/.env

@@ -0,0 +1 @@
+SKIP_PREFLIGHT_CHECK=true

examples/openapi-react-weatherbit/src/mesh/getMeshInstance.ts

@@ -1,27 +1,29 @@
 import { getMesh } from '@graphql-mesh/runtime';
 import OpenAPIHandler from '@graphql-mesh/openapi';
 import BareMerger from '@graphql-mesh/merger-bare';
-import { MeshPubSub } from '@graphql-mesh/types';
 import { KeyValueCache } from '@graphql-mesh/types';
 import { PubSub } from 'graphql-subscriptions';
 import CacheTransform from '@graphql-mesh/transform-cache';
 
 export function getMeshInstance({ cache }: { cache: KeyValueCache }) {
-  const pubsub = new PubSub() as MeshPubSub;
+  const meshContext = {
+    cache,
+    pubsub: new PubSub(),
+  };
   return getMesh({
     sources: [
       {
         name: 'Weatherbit',
         handler: new OpenAPIHandler({
           name: 'Weatherbit',
-          cache,
-          pubsub,
           config: {
             source: 'https://www.weatherbit.io/static/swagger.json',
           },
+          ...meshContext,
         }),
         transforms: [
           new CacheTransform({
+            apiName: 'Weatherbit',
             config: [
               {
                 field: 'Query.getForecastDailyLatequalToLatLonLon',
@@ -30,15 +32,12 @@ export function getMeshInstance({ cache }: { cache: KeyValueCache }) {
                 },
               },
             ],
-            cache,
-            pubsub,
-            apiName: 'Weatherbit',
+            ...meshContext,
           }),
         ],
       },
     ],
-    cache,
-    pubsub,
     merger: BareMerger, // we can use BareMerger since we don't need a real merger at all
+    ...meshContext,
   });
 }

packages/cache/file/package.json

@@ -14,6 +14,7 @@
   },
   "dependencies": {
     "@graphql-mesh/types": "0.28.0",
+    "@graphql-mesh/utils": "0.8.3",
     "dataloader": "2.0.0",
     "lodash": "4.17.20"
   },

packages/cli/src/commands/serve/playground.ts

@@ -5,7 +5,7 @@ import { GraphQLFileLoader } from '@graphql-tools/graphql-file-loader';
 import { basename, resolve } from 'path';
 import { promises as fsPromises } from 'fs';
 
-const { readFile } = fsPromises;
+const { readFile } = fsPromises || {};
 
 export function playground(exampleQuery: string, graphqlPath: string): RequestHandler {
   return async (req: Request, res: Response, next) => {

packages/cli/src/index.ts

@@ -11,7 +11,7 @@ import { introspectionFromSchema } from 'graphql';
 import { printSchemaWithDirectives } from '@graphql-tools/utils';
 export { generateSdk, serveMesh };
 
-const { writeFile } = fsPromises;
+const { writeFile } = fsPromises || {};
 
 export async function graphqlMesh() {
   return yargs

packages/handlers/json-schema/src/index.ts

@@ -29,7 +29,7 @@ import {
 } from 'graphql-scalars';
 import { promises as fsPromises } from 'fs';
 
-const { stat } = fsPromises;
+const { stat } = fsPromises || {};
 
 type CachedSchema = {
   timestamp: number;

packages/handlers/postgraphile/src/index.ts

@@ -16,7 +16,7 @@ import { tmpdir } from 'os';
 import { promises as fsPromises } from 'fs';
 import { loadFromModuleExportExpression, readFileOrUrlWithCache, readJSON } from '@graphql-mesh/utils';
 
-const { unlink } = fsPromises;
+const { unlink } = fsPromises || {};
 
 export default class PostGraphileHandler implements MeshHandler {
   private name: string;

packages/runtime/src/get-mesh.ts

@@ -72,6 +72,7 @@ export async function getMesh(
     const context: any = {
       ...initialContextValue,
       pubsub,
+      cache,
       [MESH_CONTEXT_SYMBOL]: true,
     };
 

packages/runtime/src/types.ts

@@ -72,4 +72,4 @@ export type APIContext = {
 export type MeshContext = {
   [MESH_CONTEXT_SYMBOL]: true;
   [key: string]: APIContext;
-} & { pubsub: MeshPubSub };
+} & { pubsub: MeshPubSub; cache: KeyValueCache };

packages/transforms/snapshot/test/snapshot.spec.ts

@@ -13,7 +13,7 @@ import { pick } from 'lodash';
 import graphqlFields from 'graphql-fields';
 import { readJSON, mkdir } from '@graphql-mesh/utils';
 
-const { readdir, unlink, rmdir } = fsPromises;
+const { readdir, unlink, rmdir } = fsPromises || {};
 
 async function rmdirs(dir: string) {
   let entries = await readdir(dir, { withFileTypes: true });

packages/types/src/config-schema.json

@@ -1385,18 +1385,21 @@
       "title": "SelectQueryOrMutationFieldConfig",
       "properties": {
         "title": {
-          "type": "string"
+          "type": "string",
+          "description": "OAS Title"
         },
         "path": {
-          "type": "string"
+          "type": "string",
+          "description": "Operation Path"
         },
         "type": {
           "type": "string",
           "enum": ["Query", "Mutation"],
-          "description": "Allowed values: Query, Mutation"
+          "description": "Target Root Type for this operation (Allowed values: Query, Mutation)"
         },
         "method": {
-          "type": "string"
+          "type": "string",
+          "description": "Which method is used for this operation"
         }
       }
     },

packages/types/src/config.ts

@@ -621,12 +621,21 @@ export interface OpenapiHandler {
   selectQueryOrMutationField?: SelectQueryOrMutationFieldConfig[];
 }
 export interface SelectQueryOrMutationFieldConfig {
+  /**
+   * OAS Title
+   */
   title?: string;
+  /**
+   * Operation Path
+   */
   path?: string;
   /**
-   * Allowed values: Query, Mutation
+   * Target Root Type for this operation (Allowed values: Query, Mutation)
    */
   type?: 'Query' | 'Mutation';
+  /**
+   * Which method is used for this operation
+   */
   method?: string;
 }
 /**

packages/utils/src/fs-operations.ts

@@ -1,6 +1,6 @@
 import { MakeDirectoryOptions, promises as fsPromises, readFileSync } from 'fs';
 
-const { stat, writeFile, readFile, mkdir: fsMkdir } = fsPromises;
+const { stat, writeFile, readFile, mkdir: fsMkdir } = fsPromises || {};
 
 export async function pathExists(path: string) {
   try {

packages/utils/src/read-file-or-url.ts

@@ -4,7 +4,7 @@ import { load as loadYaml } from 'js-yaml';
 import { isAbsolute, resolve } from 'path';
 import { promises as fsPromises } from 'fs';
 
-const { readFile, stat } = fsPromises;
+const { readFile, stat } = fsPromises || {};
 
 export { isUrl };