@graphql-mesh/transform-snapshot/index.esm.js

import { addResolversToSchema } from '@graphql-tools/schema';
import { composeResolvers } from '@graphql-tools/resolvers-composition';
import { join, isAbsolute } from 'path';
import { pathExists, ensureFile, writeJSON } from 'fs-extra';
import objectHash from 'object-hash';
import { extractResolvers } from '@graphql-mesh/utils';

function computeSnapshotFilePath(options) {
    const argsHash = objectHash(options.args, { ignoreUnknown: true });
    const fileName = [options.typeName, options.fieldName, argsHash].join('_') + '.json';
    const absoluteOutputDir = isAbsolute(options.outputDir) ? options.outputDir : join(process.cwd(), options.outputDir);
    return join(absoluteOutputDir, fileName);
}

const writeFile = async (path, json) => {
    try {
        await ensureFile(path);
        await writeJSON(path, json, {
            spaces: 2,
        });
    }
    catch (e) {
        console.error(`Snapshot cannot saved to ${path}: ${e.message}`);
    }
};
class SnapshotTransform {
    constructor(options) {
        this.options = options;
        this.noWrap = true;
    }
    transformSchema(schema) {
        const { config } = this.options;
        // TODO: Needs to be changed!
        const configIf = 'if' in config ? (typeof config.if === 'boolean' ? config.if : config.if && eval(config.if)) : true;
        if (configIf) {
            const resolvers = extractResolvers(schema);
            const resolversComposition = {};
            const outputDir = isAbsolute(config.outputDir) ? config.outputDir : join(process.cwd(), config.outputDir);
            const snapshotComposition = next => async (root, args, context, info) => {
                const snapshotFilePath = computeSnapshotFilePath({
                    typeName: info.parentType.name,
                    fieldName: info.fieldName,
                    args,
                    outputDir,
                });
                if (snapshotFilePath in require.cache || (await pathExists(snapshotFilePath))) {
                    return import(snapshotFilePath);
                }
                const result = await next(root, args, context, info);
                await writeFile(snapshotFilePath, result);
                return result;
            };
            for (const field of config.apply) {
                resolversComposition[field] = snapshotComposition;
            }
            const composedResolvers = composeResolvers(resolvers, resolversComposition);
            return addResolversToSchema({
                schema,
                resolvers: composedResolvers,
                updateResolversInPlace: true,
            });
        }
        return schema;
    }
}

export default SnapshotTransform;
//# sourceMappingURL=index.esm.js.map