'use strict';

const httpRequest = require('../lib/request'),
  HTTPResponse = require('../lib/request').HTTPResponse,
  bodyParser = require('body-parser'),
  express = require('express');

const port = 13371;
const httpRequestServer = `http://localhost:${port}`;

function startServer(done) {
  const app = express();
  app.use(bodyParser.json({ type: '*/*' }));
  app.get('/hello', function (req, res) {
    res.json({ response: 'OK' });
  });

  app.get('/404', function (req, res) {
    res.status(404);
    res.send('NO');
  });

  app.get('/301', function (req, res) {
    res.status(301);
    res.location('/hello');
    res.send();
  });

  app.post('/echo', function (req, res) {
    res.json(req.body);
  });

  app.get('/qs', function (req, res) {
    res.json(req.query);
  });

  return app.listen(13371, undefined, done);
}

describe('httpRequest', () => {
  let server;
  beforeEach(done => {
    if (!server) {
      server = startServer(done);
    } else {
      done();
    }
  });

  afterAll(done => {
    server.close(done);
  });

  it('should do /hello', async () => {
    const httpResponse = await httpRequest({
      url: `${httpRequestServer}/hello`,
    });

    expect(httpResponse.status).toBe(200);
    expect(httpResponse.buffer).toEqual(Buffer.from('{"response":"OK"}'));
    expect(httpResponse.text).toEqual('{"response":"OK"}');
    expect(httpResponse.data.response).toEqual('OK');
  });

  it('should do not follow redirects by default', async () => {
    const httpResponse = await httpRequest({
      url: `${httpRequestServer}/301`,
    });

    expect(httpResponse.status).toBe(301);
  });

  it('should follow redirects when set', async () => {
    const httpResponse = await httpRequest({
      url: `${httpRequestServer}/301`,
      followRedirects: true,
    });

    expect(httpResponse.status).toBe(200);
    expect(httpResponse.buffer).toEqual(Buffer.from('{"response":"OK"}'));
    expect(httpResponse.text).toEqual('{"response":"OK"}');
    expect(httpResponse.data.response).toEqual('OK');
  });

  it('should fail on 404', async () => {
    await expectAsync(
      httpRequest({
        url: `${httpRequestServer}/404`,
      })
    ).toBeRejectedWith(
      jasmine.objectContaining({
        status: 404,
        buffer: Buffer.from('NO'),
        text: 'NO',
        data: undefined,
      })
    );
  });

  it('should post on echo', async () => {
    const httpResponse = await httpRequest({
      method: 'POST',
      url: `${httpRequestServer}/echo`,
      body: {
        foo: 'bar',
      },
      headers: {
        'Content-Type': 'application/json',
      },
    });

    expect(httpResponse.status).toBe(200);
    expect(httpResponse.data).toEqual({ foo: 'bar' });
  });

  it('should encode a query string body by default', () => {
    const options = {
      body: { foo: 'bar' },
    };
    const result = httpRequest.encodeBody(options);

    expect(result.body).toEqual('foo=bar');
    expect(result.headers['Content-Type']).toEqual('application/x-www-form-urlencoded');
  });

  it('should encode a JSON body', () => {
    const options = {
      body: { foo: 'bar' },
      headers: { 'Content-Type': 'application/json' },
    };
    const result = httpRequest.encodeBody(options);

    expect(result.body).toEqual('{"foo":"bar"}');
  });

  it('should encode a www-form body', () => {
    const options = {
      body: { foo: 'bar', bar: 'baz' },
      headers: { 'cOntent-tYpe': 'application/x-www-form-urlencoded' },
    };
    const result = httpRequest.encodeBody(options);

    expect(result.body).toEqual('foo=bar&bar=baz');
  });

  it('should not encode a wrong content type', () => {
    const options = {
      body: { foo: 'bar', bar: 'baz' },
      headers: { 'cOntent-tYpe': 'mime/jpeg' },
    };
    const result = httpRequest.encodeBody(options);

    expect(result.body).toEqual({ foo: 'bar', bar: 'baz' });
  });

  it('should fail gracefully', async () => {
    await expectAsync(
      httpRequest({
        url: 'http://not a good url',
      })
    ).toBeRejected();
  });

  it('should params object to query string', async () => {
    const httpResponse = await httpRequest({
      url: `${httpRequestServer}/qs`,
      params: {
        foo: 'bar',
      },
    });

    expect(httpResponse.status).toBe(200);
    expect(httpResponse.data).toEqual({ foo: 'bar' });
  });

  it('should params string to query string', async () => {
    const httpResponse = await httpRequest({
      url: `${httpRequestServer}/qs`,
      params: 'foo=bar&foo2=bar2',
    });

    expect(httpResponse.status).toBe(200);
    expect(httpResponse.data).toEqual({ foo: 'bar', foo2: 'bar2' });
  });

  it('should not crash with undefined body', () => {
    const httpResponse = new HTTPResponse({});
    expect(httpResponse.body).toBeUndefined();
    expect(httpResponse.data).toBeUndefined();
    expect(httpResponse.text).toBeUndefined();
    expect(httpResponse.buffer).toBeUndefined();
  });

  it('serialized httpResponse correctly with body string', () => {
    const httpResponse = new HTTPResponse({}, 'hello');
    expect(httpResponse.text).toBe('hello');
    expect(httpResponse.data).toBe(undefined);
    expect(httpResponse.body).toBe('hello');

    const serialized = JSON.stringify(httpResponse);
    const result = JSON.parse(serialized);

    expect(result.text).toBe('hello');
    expect(result.data).toBe(undefined);
    expect(result.body).toBe(undefined);
  });

  it('serialized httpResponse correctly with body object', () => {
    const httpResponse = new HTTPResponse({}, { foo: 'bar' });
    Parse._encode(httpResponse);
    const serialized = JSON.stringify(httpResponse);
    const result = JSON.parse(serialized);

    expect(httpResponse.text).toEqual('{"foo":"bar"}');
    expect(httpResponse.data).toEqual({ foo: 'bar' });
    expect(httpResponse.body).toEqual({ foo: 'bar' });

    expect(result.text).toEqual('{"foo":"bar"}');
    expect(result.data).toEqual({ foo: 'bar' });
    expect(result.body).toEqual(undefined);
  });

  it('serialized httpResponse correctly with body buffer string', () => {
    const httpResponse = new HTTPResponse({}, Buffer.from('hello'));
    expect(httpResponse.text).toBe('hello');
    expect(httpResponse.data).toBe(undefined);

    const serialized = JSON.stringify(httpResponse);
    const result = JSON.parse(serialized);

    expect(result.text).toBe('hello');
    expect(result.data).toBe(undefined);
  });

  it('serialized httpResponse correctly with body buffer JSON Object', () => {
    const json = '{"foo":"bar"}';
    const httpResponse = new HTTPResponse({}, Buffer.from(json));
    const serialized = JSON.stringify(httpResponse);
    const result = JSON.parse(serialized);

    expect(result.text).toEqual('{"foo":"bar"}');
    expect(result.data).toEqual({ foo: 'bar' });
  });

  it('serialized httpResponse with Parse._encode should be allright', () => {
    const json = '{"foo":"bar"}';
    const httpResponse = new HTTPResponse({}, Buffer.from(json));
    const encoded = Parse._encode(httpResponse);
    let foundData,
      foundText,
      foundBody = false;

    for (const key in encoded) {
      if (key === 'data') {
        foundData = true;
      }
      if (key === 'text') {
        foundText = true;
      }
      if (key === 'body') {
        foundBody = true;
      }
    }

    expect(foundData).toBe(true);
    expect(foundText).toBe(true);
    expect(foundBody).toBe(false);
  });
});