@nestjs/graphql/dist/schema-builder/graphql-schema.factory.js

"use strict";
var GraphQLSchemaFactory_1;
Object.defineProperty(exports, "__esModule", { value: true });
exports.GraphQLSchemaFactory = void 0;
const tslib_1 = require("tslib");
const common_1 = require("@nestjs/common");
const shared_utils_1 = require("@nestjs/common/utils/shared.utils");
const graphql_1 = require("graphql");
const graphql_constants_1 = require("../graphql.constants");
const scalar_types_utils_1 = require("../utils/scalar-types.utils");
const schema_generation_error_1 = require("./errors/schema-generation.error");
const mutation_type_factory_1 = require("./factories/mutation-type.factory");
const orphaned_types_factory_1 = require("./factories/orphaned-types.factory");
const query_type_factory_1 = require("./factories/query-type.factory");
const subscription_type_factory_1 = require("./factories/subscription-type.factory");
const lazy_metadata_storage_1 = require("./storages/lazy-metadata.storage");
const type_metadata_storage_1 = require("./storages/type-metadata.storage");
const type_definitions_generator_1 = require("./type-definitions.generator");
let GraphQLSchemaFactory = GraphQLSchemaFactory_1 = class GraphQLSchemaFactory {
    constructor(queryTypeFactory, mutationTypeFactory, subscriptionTypeFactory, orphanedTypesFactory, typeDefinitionsGenerator) {
        this.queryTypeFactory = queryTypeFactory;
        this.mutationTypeFactory = mutationTypeFactory;
        this.subscriptionTypeFactory = subscriptionTypeFactory;
        this.orphanedTypesFactory = orphanedTypesFactory;
        this.typeDefinitionsGenerator = typeDefinitionsGenerator;
        this.logger = new common_1.Logger(GraphQLSchemaFactory_1.name);
    }
    async create(resolvers, scalarsOrOptions = [], options = {}) {
        if (Array.isArray(scalarsOrOptions)) {
            this.assignScalarObjects(scalarsOrOptions, options);
        }
        else {
            options = scalarsOrOptions;
        }
        lazy_metadata_storage_1.LazyMetadataStorage.load(resolvers);
        type_metadata_storage_1.TypeMetadataStorage.compile(options.orphanedTypes);
        this.typeDefinitionsGenerator.generate(options);
        const schema = new graphql_1.GraphQLSchema({
            mutation: this.mutationTypeFactory.create(resolvers, options),
            query: this.queryTypeFactory.create(resolvers, options),
            subscription: this.subscriptionTypeFactory.create(resolvers, options),
            types: [
                ...this.orphanedTypesFactory.create(options.orphanedTypes),
                ...(options.scalarsMap ?? []).map(({ scalar }) => scalar),
            ],
            directives: [...graphql_1.specifiedDirectives, ...(options.directives ?? [])],
        });
        if (!options.skipCheck) {
            const introspectionQuery = (0, graphql_1.getIntrospectionQuery)();
            const executionResult = await (0, graphql_1.graphql)({
                schema,
                source: introspectionQuery,
            });
            const errors = executionResult.errors;
            if (errors) {
                throw new schema_generation_error_1.SchemaGenerationError(errors);
            }
        }
        return schema;
    }
    assignScalarObjects(scalars, options) {
        if ((0, shared_utils_1.isEmpty)(scalars)) {
            return;
        }
        const scalarsMap = options.scalarsMap || [];
        scalars
            .filter((classRef) => classRef)
            .forEach((classRef) => this.addScalarTypeByClassRef(classRef, scalarsMap));
        options.scalarsMap = scalarsMap;
    }
    addScalarTypeByClassRef(classRef, scalarsMap) {
        try {
            const scalarNameMetadata = Reflect.getMetadata(graphql_constants_1.SCALAR_NAME_METADATA, classRef);
            const scalarTypeMetadata = Reflect.getMetadata(graphql_constants_1.SCALAR_TYPE_METADATA, classRef);
            if (!scalarNameMetadata) {
                return;
            }
            const instance = new classRef();
            const type = ((0, shared_utils_1.isFunction)(scalarTypeMetadata) && scalarTypeMetadata()) || classRef;
            scalarsMap.push({
                type,
                scalar: (0, scalar_types_utils_1.createScalarType)(scalarNameMetadata, instance),
            });
        }
        catch {
            this.logger.error(`Cannot generate a GraphQLScalarType for "${classRef.name}" scalar. Make sure to put any initialization logic in the lifecycle hooks instead of a constructor.`);
        }
    }
};
exports.GraphQLSchemaFactory = GraphQLSchemaFactory;
exports.GraphQLSchemaFactory = GraphQLSchemaFactory = GraphQLSchemaFactory_1 = tslib_1.__decorate([
    (0, common_1.Injectable)(),
    tslib_1.__metadata("design:paramtypes", [query_type_factory_1.QueryTypeFactory,
        mutation_type_factory_1.MutationTypeFactory,
        subscription_type_factory_1.SubscriptionTypeFactory,
        orphaned_types_factory_1.OrphanedTypesFactory,
        type_definitions_generator_1.TypeDefinitionsGenerator])
], GraphQLSchemaFactory);