import gql from 'graphql-tag';
import http from 'http';
import mockedEnv from 'mocked-env';
import { Logger } from 'apollo-server-types';
import { ApolloGateway } from '../..';
import {
  mockSdlQuerySuccess,
  mockSupergraphSdlRequestSuccess,
  mockApolloConfig,
  mockCloudConfigUrl,
} from './nockMocks';
import { getTestingSupergraphSdl } from '../execution-utils';
import { MockService } from './networkRequests.test';

let logger: Logger;

const service: MockService = {
  name: 'accounts',
  url: 'http://localhost:4001',
  typeDefs: gql`
    extend type Query {
      me: User
      everyone: [User]
    }

    "This is my User"
    type User @key(fields: "id") {
      id: ID!
      name: String
      username: String
    }
  `,
};

beforeEach(() => {
  const warn = jest.fn();
  const debug = jest.fn();
  const error = jest.fn();
  const info = jest.fn();

  logger = {
    warn,
    debug,
    error,
    info,
  };
});

describe('gateway configuration warnings', () => {
  let gateway: ApolloGateway | null = null;
  afterEach(async () => {
    if (gateway) {
      await gateway.stop();
      gateway = null;
    }
  });
  it('warns when both supergraphSdl and studio configuration are provided', async () => {
    gateway = new ApolloGateway({
      supergraphSdl: getTestingSupergraphSdl(),
      logger,
    });

    await gateway.load(mockApolloConfig);

    expect(logger.warn).toHaveBeenCalledWith(
      'A local gateway configuration is overriding a managed federation configuration.' +
        '  To use the managed configuration, do not specify a service list or supergraphSdl locally.',
    );
  });

  it('warns when both manual update configurations are provided', async () => {
    gateway = new ApolloGateway({
      // @ts-ignore
      async experimental_updateSupergraphSdl() {},
      async experimental_updateServiceDefinitions() {},
      logger,
    });

    expect(logger.warn).toHaveBeenCalledWith(
      'Gateway found two manual update configurations when only one should be ' +
        'provided. Gateway will default to using the provided `experimental_updateSupergraphSdl` ' +
        'function when both `experimental_updateSupergraphSdl` and experimental_updateServiceDefinitions` ' +
        'are provided.',
    );

    // Set to `null` so we don't try to call `stop` on it in the `afterEach`,
    // which triggers a different error that we're not testing for here.
    gateway = null;
  });

  it('conflicting configurations are warned about when present', async () => {
    mockSdlQuerySuccess(service);

    gateway = new ApolloGateway({
      serviceList: [{ name: 'accounts', url: service.url }],
      logger,
    });

    await gateway.load(mockApolloConfig);

    expect(logger.warn).toHaveBeenCalledWith(
      expect.stringMatching(
        /A local gateway configuration is overriding a managed federation configuration/,
      ),
    );
  });

  it('conflicting configurations are not warned about when absent', async () => {
    mockSupergraphSdlRequestSuccess();

    gateway = new ApolloGateway({
      logger,
      // TODO(trevor:cloudconfig): remove
      schemaConfigDeliveryEndpoint: mockCloudConfigUrl,
    });

    await gateway.load(mockApolloConfig);

    await gateway.stop();

    expect(logger.warn).not.toHaveBeenCalledWith(
      expect.stringMatching(
        /A local gateway configuration is overriding a managed federation configuration/,
      ),
    );
  });

  it('throws when no configuration is provided', async () => {
    gateway = new ApolloGateway({
      logger,
    });

    expect(gateway.load()).rejects.toThrowErrorMatchingInlineSnapshot(
      `"When a manual configuration is not provided, gateway requires an Apollo configuration. See https://www.apollographql.com/docs/apollo-server/federation/managed-federation/ for more information. Manual configuration options include: \`serviceList\`, \`supergraphSdl\`, and \`experimental_updateServiceDefinitions\`."`,
    );

    // Set to `null` so we don't try to call `stop` on it in the `afterEach`,
    // which triggers a different error that we're not testing for here.
    gateway = null;
  });
});

describe('gateway startup errors', () => {
  it("throws when static config can't be composed", async () => {
    const uncomposableSdl = gql`
      type Query {
        me: User
        everyone: [User]
        account(id: String): Account
      }

      type User @key(fields: "id") {
        name: String
        username: String
      }

      type Account @key(fields: "id") {
        name: String
        username: String
      }
    `;

    const gateway = new ApolloGateway({
      localServiceList: [
        { name: 'accounts', url: service.url, typeDefs: uncomposableSdl },
      ],
      logger,
    });

    // This is the ideal, but our version of Jest has a bug with printing error snapshots.
    // See: https://github.com/facebook/jest/pull/10217 (fixed in v26.2.0)
    //     expect(gateway.load()).rejects.toThrowErrorMatchingInlineSnapshot(`
    //       "A valid schema couldn't be composed. The following composition errors were found:
    //         [accounts] User -> A @key selects id, but User.id could not be found
    //         [accounts] Account -> A @key selects id, but Account.id could not be found"
    //     `);
    // Instead we'll just use the regular snapshot matcher...
    let err: any;
    try {
      await gateway.load();
    } catch (e) {
      err = e;
    }

    expect(err.message).toMatchInlineSnapshot(`
      "A valid schema couldn't be composed. The following composition errors were found:
      	[accounts] Account -> A @key selects id, but Account.id could not be found
      	[accounts] User -> A @key selects id, but User.id could not be found"
    `);
  });
});

describe('gateway config / env behavior', () => {
  let gateway: ApolloGateway | null = null;
  let cleanUp: (() => void) | null = null;
  afterEach(async () => {
    if (gateway) {
      await gateway.stop();
      gateway = null;
    }

    if (cleanUp) {
      cleanUp();
      cleanUp = null;
    }
  });

  describe('introspection headers', () => {
    it('should allow not passing introspectionHeaders', async () => {
      const receivedHeaders = jest.fn();
      const nock = mockSdlQuerySuccess(service);
      nock.on('request', (req: http.ClientRequest) =>
        receivedHeaders(req.getHeaders()),
      );

      gateway = new ApolloGateway({
        serviceList: [{ name: 'accounts', url: service.url }],
      });

      await gateway.load(mockApolloConfig);

      expect(receivedHeaders).toHaveBeenCalledWith(
        expect.objectContaining({
          host: 'localhost:4001',
        }),
      );
    });

    it('should use static headers', async () => {
      const receivedHeaders = jest.fn();
      const nock = mockSdlQuerySuccess(service);
      nock.on('request', (req: http.ClientRequest) =>
        receivedHeaders(req.getHeaders()),
      );

      gateway = new ApolloGateway({
        serviceList: [{ name: 'accounts', url: service.url }],
        introspectionHeaders: {
          Authorization: 'Bearer static',
        },
      });

      await gateway.load(mockApolloConfig);

      expect(receivedHeaders).toHaveBeenCalledWith(
        expect.objectContaining({
          authorization: ['Bearer static'],
        }),
      );
    });

    it('should use dynamic async headers', async () => {
      const receivedHeaders = jest.fn();
      const nock = mockSdlQuerySuccess(service);
      nock.on('request', (req: http.ClientRequest) =>
        receivedHeaders(req.getHeaders()),
      );

      gateway = new ApolloGateway({
        serviceList: [{ name: 'accounts', url: service.url }],
        introspectionHeaders: async ({ name }) => ({
          Authorization: 'Bearer dynamic-async',
          'X-Service-Name': name,
        }),
      });

      await gateway.load(mockApolloConfig);

      expect(receivedHeaders).toHaveBeenCalledWith(
        expect.objectContaining({
          authorization: ['Bearer dynamic-async'],
          'x-service-name': ['accounts'],
        }),
      );
    });

    it('should use dynamic non-async headers', async () => {
      const receivedHeaders = jest.fn();
      const nock = mockSdlQuerySuccess(service);
      nock.on('request', (req: http.ClientRequest) =>
        receivedHeaders(req.getHeaders()),
      );

      gateway = new ApolloGateway({
        serviceList: [{ name: 'accounts', url: service.url }],
        introspectionHeaders: ({ name }) => ({
          Authorization: 'Bearer dynamic-sync',
          'X-Service-Name': name,
        }),
      });

      await gateway.load(mockApolloConfig);

      expect(receivedHeaders).toHaveBeenCalledWith(
        expect.objectContaining({
          authorization: ['Bearer dynamic-sync'],
          'x-service-name': ['accounts'],
        }),
      );
    });
  });

  // TODO(trevor:cloudconfig): this behavior will be updated
  describe('schema config delivery endpoint configuration', () => {
    it('A code config overrides the env variable', async () => {
      cleanUp = mockedEnv({
        APOLLO_SCHEMA_CONFIG_DELIVERY_ENDPOINT: 'env-config',
      });

      gateway = new ApolloGateway({
        logger,
        schemaConfigDeliveryEndpoint: 'code-config',
      });

      expect(gateway['schemaConfigDeliveryEndpoint']).toEqual(
        'code-config',
      );

      gateway = null;
    });

    it('A code config set to `null` takes precedence over an existing env variable', async () => {
      cleanUp = mockedEnv({
        APOLLO_SCHEMA_CONFIG_DELIVERY_ENDPOINT: 'env-config',
      });

      gateway = new ApolloGateway({
        logger,
        schemaConfigDeliveryEndpoint: null,
      });

      expect(gateway['schemaConfigDeliveryEndpoint']).toEqual(
        null,
      );

      gateway = null;
    });
  });
});