apollo-server/packages/apollo-server-core/src/runQuery.test.ts

/* tslint:disable:no-unused-expression */
import { expect } from 'chai';
import { stub } from 'sinon';
import 'mocha';

import {
  GraphQLSchema,
  GraphQLObjectType,
  GraphQLString,
  GraphQLInt,
  GraphQLNonNull,
  parse,
} from 'graphql';

import { runQuery } from './runQuery';
import { LogAction, LogStep } from './logging';

// Make the global Promise constructor Fiber-aware to simulate a Meteor
// environment.
import { makeCompatible } from 'meteor-promise';
import Fiber = require('fibers');
makeCompatible(Promise, Fiber);

const queryType = new GraphQLObjectType({
  name: 'QueryType',
  fields: {
    testString: {
      type: GraphQLString,
      resolve() {
        return 'it works';
      },
    },
    testObject: {
      type: new GraphQLObjectType({
        name: 'TestObject',
        fields: {
          testString: {
            type: GraphQLString,
          },
        },
      }),
      resolve() {
        return {
          testString: 'a very test string',
        };
      },
    },
    testRootValue: {
      type: GraphQLString,
      resolve(root) {
        return root + ' works';
      },
    },
    testContextValue: {
      type: GraphQLString,
      resolve(root, args, context) {
        return context + ' works';
      },
    },
    testArgumentValue: {
      type: GraphQLInt,
      resolve(root, args, context) {
        return args['base'] + 5;
      },
      args: {
        base: { type: new GraphQLNonNull(GraphQLInt) },
      },
    },
    testAwaitedValue: {
      type: GraphQLString,
      resolve(root) {
        // Calling Promise.await is legal here even though this is
        // not an async function, because we are guaranteed to be
        // running in a Fiber.
        return 'it ' + (<any>Promise).await('works');
      },
    },
    testError: {
      type: GraphQLString,
      resolve() {
        throw new Error('Secret error message');
      },
    },
  },
});

const schema = new GraphQLSchema({
  query: queryType,
});

describe('runQuery', () => {
  it('returns the right result when query is a string', () => {
    const query = `{ testString }`;
    const expected = { testString: 'it works' };
    return runQuery({ schema, query: query }).then(res => {
      expect(res.data).to.deep.equal(expected);
    });
  });

  it('returns the right result when query is a document', () => {
    const query = parse(`{ testString }`);
    const expected = { testString: 'it works' };
    return runQuery({ schema, query: query }).then(res => {
      expect(res.data).to.deep.equal(expected);
    });
  });

  it('returns a syntax error if the query string contains one', () => {
    const query = `query { test `;
    const expected = /Syntax Error/;
    return runQuery({
      schema,
      query: query,
      variables: { base: 1 },
    }).then(res => {
      expect(res.data).to.be.undefined;
      expect(res.errors.length).to.equal(1);
      expect(res.errors[0].message).to.match(expected);
    });
  });

  it('does not call console.error if in an error occurs and debug mode is set', () => {
    const query = `query { testError }`;
    const logStub = stub(console, 'error');
    return runQuery({
      schema,
      query: query,
      debug: true,
    }).then(res => {
      logStub.restore();
      expect(logStub.callCount).to.equal(0);
    });
  });

  it('does not call console.error if in an error occurs and not in debug mode', () => {
    const query = `query { testError }`;
    const logStub = stub(console, 'error');
    return runQuery({
      schema,
      query: query,
      debug: false,
    }).then(res => {
      logStub.restore();
      expect(logStub.callCount).to.equal(0);
    });
  });

  it('returns a validation error if the query string does not pass validation', () => {
    const query = `query TestVar($base: String){ testArgumentValue(base: $base) }`;
    const expected =
      'Variable "$base" of type "String" used in position expecting type "Int!".';
    return runQuery({
      schema,
      query: query,
      variables: { base: 1 },
    }).then(res => {
      expect(res.data).to.be.undefined;
      expect(res.errors.length).to.equal(1);
      expect(res.errors[0].message).to.deep.equal(expected);
    });
  });

  it('correctly passes in the rootValue', () => {
    const query = `{ testRootValue }`;
    const expected = { testRootValue: 'it also works' };
    return runQuery({ schema, query: query, rootValue: 'it also' }).then(
      res => {
        expect(res.data).to.deep.equal(expected);
      },
    );
  });

  it('correctly passes in the context', () => {
    const query = `{ testContextValue }`;
    const expected = { testContextValue: 'it still works' };
    return runQuery({ schema, query: query, context: 'it still' }).then(res => {
      expect(res.data).to.deep.equal(expected);
    });
  });

  it('passes the options to formatResponse', () => {
    const query = `{ testContextValue }`;
    const expected = { testContextValue: 'it still works' };
    return runQuery({
      schema,
      query: query,
      context: 'it still',
      formatResponse: (response, { context }) => {
        response['extensions'] = context;
        return response;
      },
    }).then(res => {
      expect(res.data).to.deep.equal(expected);
      expect(res['extensions']).to.equal('it still');
    });
  });

  it('correctly passes in variables (and arguments)', () => {
    const query = `query TestVar($base: Int!){ testArgumentValue(base: $base) }`;
    const expected = { testArgumentValue: 6 };
    return runQuery({
      schema,
      query: query,
      variables: { base: 1 },
    }).then(res => {
      expect(res.data).to.deep.equal(expected);
    });
  });

  it('throws an error if there are missing variables', () => {
    const query = `query TestVar($base: Int!){ testArgumentValue(base: $base) }`;
    const expected =
      'Variable "$base" of required type "Int!" was not provided.';
    return runQuery({
      schema,
      query: query,
    }).then(res => {
      expect(res.errors[0].message).to.deep.equal(expected);
    });
  });

  it('supports yielding resolver functions', () => {
    return runQuery({
      schema,
      query: `{ testAwaitedValue }`,
    }).then(res => {
      expect(res.data).to.deep.equal({
        testAwaitedValue: 'it works',
      });
    });
  });

  it('runs the correct operation when operationName is specified', () => {
    const query = `
        query Q1 {
            testString
        }
        query Q2 {
            testRootValue
        }`;
    const expected = {
      testString: 'it works',
    };
    return runQuery({ schema, query: query, operationName: 'Q1' }).then(res => {
      expect(res.data).to.deep.equal(expected);
    });
  });

  it('calls logFunction', () => {
    const query = `
        query Q1 {
            testString
        }`;
    const logs = [];
    const logFn = obj => logs.push(obj);
    const expected = {
      testString: 'it works',
    };
    return runQuery({
      schema,
      query: query,
      operationName: 'Q1',
      variables: { test: 123 },
      logFunction: logFn,
    }).then(res => {
      expect(res.data).to.deep.equal(expected);
      expect(logs.length).to.equals(11);
      expect(logs[0]).to.deep.equals({
        action: LogAction.request,
        step: LogStep.start,
      });
      expect(logs[1]).to.deep.equals({
        action: LogAction.request,
        step: LogStep.status,
        key: 'query',
        data: query,
      });
      expect(logs[2]).to.deep.equals({
        action: LogAction.request,
        step: LogStep.status,
        key: 'variables',
        data: { test: 123 },
      });
      expect(logs[3]).to.deep.equals({
        action: LogAction.request,
        step: LogStep.status,
        key: 'operationName',
        data: 'Q1',
      });
      expect(logs[10]).to.deep.equals({
        action: LogAction.request,
        step: LogStep.end,
        key: 'response',
        data: {
          data: expected,
        },
      });
    });
  });

  it('uses custom field resolver', async () => {
    const query = `
        query Q1 {
          testObject {
            testString
          }
        }
      `;

    const result1 = await runQuery({
      schema,
      query: query,
      operationName: 'Q1',
    });

    expect(result1.data).to.deep.equal({
      testObject: {
        testString: 'a very test string',
      },
    });

    const result2 = await runQuery({
      schema,
      query: query,
      operationName: 'Q1',
      fieldResolver: () => 'a very testful field resolver string',
    });

    expect(result2.data).to.deep.equal({
      testObject: {
        testString: 'a very testful field resolver string',
      },
    });
  });

  describe('async_hooks', () => {
    let asyncHooks;
    let asyncHook;
    const ids: number[] = [];

    try {
      asyncHooks = require('async_hooks');
    } catch (err) {
      return; // async_hooks not present, give up
    }

    before(() => {
      asyncHook = asyncHooks.createHook({ init: asyncId => ids.push(asyncId) });
      asyncHook.enable();
    });

    after(() => {
      asyncHook.disable();
    });

    it('does not break async_hook call stack', async () => {
      const query = `
        query Q1 {
          testObject {
            testString
          }
        }
      `;

      await runQuery({
        schema,
        query: query,
        operationName: 'Q1',
      });

      // this is the only async process so we expect the async ids to be a sequence
      ids.forEach((id, i) => {
        if (i > 0) {
          expect(id).to.equal(ids[i - 1] + 1);
        }
      });
    });
  });
});