import * as operationUtils from '../../operations';
import * as yargs from 'yargs';
import { createMultiProcessPrism, createSingleProcessPrism } from '../../util/createServer';
import mockCommand from '../mock';
import proxyCommand from '../proxy';

const parser = yargs.command(mockCommand).command(proxyCommand);

jest.mock('../../util/createServer', () => ({
  createMultiProcessPrism: jest.fn().mockResolvedValue([]),
  createSingleProcessPrism: jest.fn().mockResolvedValue([]),
}));

jest.spyOn(operationUtils, 'getHttpOperationsFromSpec').mockResolvedValue([]);

describe.each<{ 0: string; 1: string; 2: unknown }>([
  ['mock', '', { dynamic: false }],
  ['proxy', 'http://github.com', { upstream: new URL('http://github.com/') }],
])('%s command', (command, upstream) => {
  beforeEach(() => {
    (createSingleProcessPrism as jest.Mock).mockClear();
    (createMultiProcessPrism as jest.Mock).mockClear();
  });

  test(`starts ${command} server`, () => {
    parser.parse(`${command} /path/to ${upstream}`);

    expect(createMultiProcessPrism).not.toHaveBeenCalled();
    expect(createSingleProcessPrism).toHaveBeenLastCalledWith(
      expect.objectContaining({
        document: '/path/to',
        multiprocess: false,
        errors: false,
        verboseLevel: 'info',
      })
    );
  });

  test(`starts ${command} server on custom port`, () => {
    parser.parse(`${command} /path/to -p 666 ${upstream}`);

    expect(createMultiProcessPrism).not.toHaveBeenCalled();
    expect(createSingleProcessPrism).toHaveBeenLastCalledWith(expect.objectContaining({ port: 666 }));
  });

  test(`starts ${command} server on custom host`, () => {
    parser.parse(`${command} /path/to -h 0.0.0.0 ${upstream}`);

    expect(createMultiProcessPrism).not.toHaveBeenCalled();
    expect(createSingleProcessPrism).toHaveBeenLastCalledWith(expect.objectContaining({ host: '0.0.0.0' }));
  });

  test(`starts ${command} server on custom host and port`, () => {
    parser.parse(`${command} /path/to -p 666 -h 0.0.0.0 ${upstream}`);

    expect(createMultiProcessPrism).not.toHaveBeenCalled();
    expect(createSingleProcessPrism).toHaveBeenLastCalledWith(expect.objectContaining({ port: 666, host: '0.0.0.0' }));
  });

  test(`starts ${command} server with verbose level set to trace`, () => {
    parser.parse(`${command} /path/to -v trace ${upstream}`);

    expect(createMultiProcessPrism).not.toHaveBeenCalled();
    expect(createSingleProcessPrism).toHaveBeenLastCalledWith(expect.objectContaining({ verboseLevel: 'trace' }));
  });

  test(`starts ${command} server with multiprocess option `, () => {
    parser.parse(`${command} /path/to -m -h 0.0.0.0 ${upstream}`);

    expect(createSingleProcessPrism).not.toHaveBeenCalled();
    expect(createMultiProcessPrism).toHaveBeenLastCalledWith(
      expect.objectContaining({ multiprocess: true, host: '0.0.0.0' })
    );
  });

  test(`starts ${command} server with error violations option on `, () => {
    parser.parse(`${command} /path/to -m -h 0.0.0.0 --errors ${upstream}`);

    expect(createMultiProcessPrism).toHaveBeenLastCalledWith(expect.objectContaining({ errors: true }));
  });
});

test(`starts proxy server with default validate-request option to be overriden`, () => {
  parser.parse(`proxy /path/to -m -h 0.0.0.0 ${new URL('http://github.com/')} --validate-request=false`);

  expect(createMultiProcessPrism).toHaveBeenLastCalledWith(
    expect.objectContaining({ validateRequest: false, host: '0.0.0.0' })
  );
});