/* @flow */ import type { Resolver, ObjectTypeComposer } from 'graphql-compose'; import type { MongooseDocument } from 'mongoose'; import { limitHelper, limitHelperArgs, sortHelper, sortHelperArgs, projectionHelper, } from './helpers'; import type { ExtendedResolveParams, GenResolverOpts } from './index'; import { beforeQueryHelper } from './helpers/beforeQueryHelper'; export default function findByIds( model: Class, // === MongooseModel tc: ObjectTypeComposer, opts?: GenResolverOpts ): Resolver { if (!model || !model.modelName || !model.schema) { throw new Error('First arg for Resolver findByIds() should be instance of Mongoose Model.'); } if (!tc || tc.constructor.name !== 'ObjectTypeComposer') { throw new Error( 'Second arg for Resolver findByIds() should be instance of ObjectTypeComposer.' ); } return tc.schemaComposer.createResolver({ type: [tc], name: 'findByIds', kind: 'query', args: { _ids: '[MongoID]!', ...limitHelperArgs({ ...(opts && opts.limit), }), ...sortHelperArgs(tc, model, { sortTypeName: `SortFindByIds${tc.getTypeName()}Input`, ...(opts && opts.sort), }), }, resolve: (resolveParams: ExtendedResolveParams) => { const args = resolveParams.args || {}; if (!Array.isArray(args._ids) || args._ids.length === 0) { return Promise.resolve([]); } const selector = { _id: { $in: args._ids }, }; resolveParams.query = model.find(selector); // eslint-disable-line resolveParams.model = model; // eslint-disable-line projectionHelper(resolveParams); limitHelper(resolveParams); sortHelper(resolveParams); return beforeQueryHelper(resolveParams); }, }); }