fastify.spec.ts

import request from 'supertest';
import { buildApp } from '../src/app.js';

describe('fastify example integration', () => {
  const [app] = buildApp(false);

  beforeAll(async () => {
    await app.ready();
  });

  afterAll(async () => {
    await app.close();
  });

  it('sends GraphiQL', async () => {
    const response = await request(app.server).get('/graphql').set({
      accept: 'text/html',
    });

    expect(response.statusCode).toEqual(200);
    expect(response.text).toContain('<title>Yoga GraphiQL</title>');
  });

  it('handles query operation via POST', async () => {
    const response = await request(app.server)
      .post('/graphql')
      .set({ 'content-type': 'application/json' })
      .send(
        JSON.stringify({
          query: /* GraphQL */ `
            query {
              __typename
            }
          `,
        }),
      );

    expect(response.statusCode).toEqual(200);
    expect(response.body).toStrictEqual({
      data: {
        __typename: 'Query',
      },
    });
  });

  it("exposes fastify's request and reply objects", async () => {
    const response = await request(app.server)
      .post('/graphql')
      .set({ 'content-type': 'application/json' })
      .send(
        JSON.stringify({
          query: /* GraphQL */ `
            {
              isFastify
            }
          `,
        }),
      );

    expect(response.statusCode).toEqual(200);
    expect(response.body).toStrictEqual({
      data: {
        isFastify: true,
      },
    });
  });

  it('handles query operation via GET', async () => {
    const response = await request(app.server)
      .get('/graphql')
      .query({
        query: /* GraphQL */ `
          query {
            __typename
          }
        `,
      });

    expect(response.statusCode).toEqual(200);
    expect(response.body).toStrictEqual({
      data: {
        __typename: 'Query',
      },
    });
  });

  it('handles mutation operation via POST', async () => {
    const response = await request(app.server)
      .post('/graphql')
      .set({ 'content-type': 'application/json' })
      .send(
        JSON.stringify({
          query: /* GraphQL */ `
            mutation {
              __typename
            }
          `,
        }),
      );

    expect(response.statusCode).toEqual(200);
    expect(response.body).toStrictEqual({
      data: {
        __typename: 'Mutation',
      },
    });
  });

  it('rejects mutation operation via GET with an useful error message', async () => {
    const response = await request(app.server)
      .get('/graphql')
      .query({
        query: /* GraphQL */ `
          mutation {
            __typename
          }
        `,
      });

    expect(response.body).toStrictEqual({
      errors: [
        {
          message: 'Can only perform a mutation operation from a POST request.',
        },
      ],
    });
  });

  it('handles subscription operations via GET', async () => {
    const response = await request(app.server)
      .get('/graphql')
      .set({ accept: 'text/event-stream' })
      .query({
        query: /* GraphQL */ `
          subscription {
            countdown(from: 10, interval: 1)
          }
        `,
      });
    expect(response.statusCode).toEqual(200);
    expect(response.text.replace(/:\n\n/g, '')).toMatchInlineSnapshot(`
"event: next
data: {"data":{"countdown":10}}

event: next
data: {"data":{"countdown":9}}

event: next
data: {"data":{"countdown":8}}

event: next
data: {"data":{"countdown":7}}

event: next
data: {"data":{"countdown":6}}

event: next
data: {"data":{"countdown":5}}

event: next
data: {"data":{"countdown":4}}

event: next
data: {"data":{"countdown":3}}

event: next
data: {"data":{"countdown":2}}

event: next
data: {"data":{"countdown":1}}

event: next
data: {"data":{"countdown":0}}

event: complete
data"
`);
  });
  it('handles subscription operations via POST', async () => {
    const response = await request(app.server)
      .post('/graphql')
      .set({
        accept: 'text/event-stream',
        'content-type': 'application/json',
      })
      .send({
        query: /* GraphQL */ `
          subscription {
            countdown(from: 10, interval: 1)
          }
        `,
      });
    expect(response.statusCode).toEqual(200);
    expect(response.text.replace(/:\n\n/g, '')).toMatchInlineSnapshot(`
"event: next
data: {"data":{"countdown":10}}

event: next
data: {"data":{"countdown":9}}

event: next
data: {"data":{"countdown":8}}

event: next
data: {"data":{"countdown":7}}

event: next
data: {"data":{"countdown":6}}

event: next
data: {"data":{"countdown":5}}

event: next
data: {"data":{"countdown":4}}

event: next
data: {"data":{"countdown":3}}

event: next
data: {"data":{"countdown":2}}

event: next
data: {"data":{"countdown":1}}

event: next
data: {"data":{"countdown":0}}

event: complete
data"
`);
  });
  it('should handle file uploads', async () => {
    const response = await request(app.server)
      .post('/graphql')
      .field(
        'operations',
        JSON.stringify({
          query: 'mutation ($file: File!) { getFileName(file: $file) }',
          variables: { file: null },
        }),
      )
      .field('map', JSON.stringify({ 0: ['variables.file'] }))
      .attach('0', Buffer.from('TESTCONTENT'), {
        filename: 'file.txt',
        contentType: 'plain/text',
      });
    expect(response.statusCode).toBe(200);
    expect(response.body).toStrictEqual({
      data: {
        getFileName: 'file.txt',
      },
    });
  });
});