@nestjs/graphql/dist/decorators/subscription.decorator.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.Subscription = void 0;
const common_1 = require("@nestjs/common");
const shared_utils_1 = require("@nestjs/common/utils/shared.utils");
require("reflect-metadata");
const resolver_enum_1 = require("../enums/resolver.enum");
const graphql_constants_1 = require("../graphql.constants");
const undefined_return_type_error_1 = require("../schema-builder/errors/undefined-return-type.error");
const lazy_metadata_storage_1 = require("../schema-builder/storages/lazy-metadata.storage");
const type_metadata_storage_1 = require("../schema-builder/storages/type-metadata.storage");
const reflection_utilts_1 = require("../utils/reflection.utilts");
const resolvers_utils_1 = require("./resolvers.utils");
/**
 * Subscription handler (method) Decorator. Routes subscriptions to this method.
 */
function Subscription(nameOrType, options = {}) {
    return (target, key, descriptor) => {
        const name = (0, shared_utils_1.isString)(nameOrType)
            ? nameOrType
            : (options && options.name) || undefined;
        (0, resolvers_utils_1.addResolverMetadata)(resolver_enum_1.Resolver.SUBSCRIPTION, name, target, key, descriptor);
        (0, common_1.SetMetadata)(graphql_constants_1.SUBSCRIPTION_OPTIONS_METADATA, options)(target, key, descriptor);
        lazy_metadata_storage_1.LazyMetadataStorage.store(target.constructor, () => {
            if (!nameOrType || (0, shared_utils_1.isString)(nameOrType)) {
                throw new undefined_return_type_error_1.UndefinedReturnTypeError(Subscription.name, key);
            }
            const { typeFn, options: typeOptions } = (0, reflection_utilts_1.reflectTypeFromMetadata)({
                metadataKey: 'design:returntype',
                prototype: target,
                propertyKey: key,
                explicitTypeFn: nameOrType,
                typeOptions: options,
            });
            const metadata = {
                methodName: key,
                schemaName: options.name || key,
                target: target.constructor,
                typeFn,
                returnTypeOptions: typeOptions,
                description: options.description,
                deprecationReason: options.deprecationReason,
            };
            type_metadata_storage_1.TypeMetadataStorage.addSubscriptionMetadata(metadata);
        });
    };
}
exports.Subscription = Subscription;