import { AjaxRequest, Observable } from 'rxjs';

import { HttpRequestMethod, ObservableApi } from '../../src/Stores';
import * as Helpers from '../../src/Stores/Helpers';
import { wx } from '../../src/WebRx';
import { fail, logger, sandbox, should, sinon } from '../setup';

describe('ObservableApi', () => {
  const baseUri = 'http://test1.com/';
  const api = new ObservableApi('/', baseUri);
  const action = 'action';
  const data = { item1: 'item1 value' };
  const body = String.stringify(data, null, 2);
  const params = { param1: 'param1 value' };
  const uriParams = 'param1=param1%20value';
  const options: AjaxRequest = {
    createXHR: () => {
      const xhr = new XMLHttpRequest();

      xhr.timeout = 1;

      return xhr;
    },
  };
  const baseUriOverride = 'http://test2.com/';

  describe('observe', () => {
    it('creates a GET request', () => {
      const request = Observable.of(true);
      const stub = sandbox.stub(Helpers, 'getRequest').callsFake(() => request);

      const result = api.observe(
        action,
        params,
        data,
        HttpRequestMethod.GET,
        options,
        baseUriOverride,
      );

      should.exist(result);
      wx.isObservable(result).should.be.true;

      result.subscribe();
      stub.should.have.been.calledOnce;
      stub.should.have.been.calledWith(
        action,
        `${baseUriOverride}${action}`,
        sinon.match.any,
        HttpRequestMethod.GET,
        params,
        data,
        options,
      );
    });

    it('creates a POST request', () => {
      const request = Observable.of(true);
      const stub = sandbox.stub(Helpers, 'getRequest').callsFake(() => request);

      const result = api.observe(
        action,
        params,
        data,
        HttpRequestMethod.POST,
        options,
        baseUriOverride,
      );

      should.exist(result);
      wx.isObservable(result).should.be.true;

      result.subscribe();
      stub.should.have.been.calledOnce;
      stub.should.have.been.calledWith(
        action,
        `${baseUriOverride}${action}`,
        sinon.match.any,
        HttpRequestMethod.POST,
        params,
        data,
        options,
      );
    });

    it('composes GET request options from the provided parameters', () => {
      const expectedOptions = {
        headers: Helpers.defaultHeaders,
        async: true,
        body,
        url: `${baseUri}${action}?${uriParams}`,
        method: 'GET',
      };
      const response = { response: true };
      const request = Observable.of(response);
      const stub = sandbox.stub(Observable, 'ajax').callsFake(() => request);

      const result = api.observe(action, params, data, HttpRequestMethod.GET);

      should.exist(result);
      wx.isObservable(result).should.be.true;

      result.subscribe();
      stub.should.have.been.calledOnce;
      stub.should.have.been.calledWith(expectedOptions);
    });

    it('composes POST request options from the provided parameters', () => {
      const expectedOptions = {
        headers: Helpers.defaultHeaders,
        async: true,
        body,
        url: `${baseUri}${action}?${uriParams}`,
        method: 'POST',
      };
      const response = { response: true };
      const request = Observable.of(response);
      const stub = sandbox.stub(Observable, 'ajax').callsFake(() => request);

      const result = api.observe(action, params, data, HttpRequestMethod.POST);

      should.exist(result);
      wx.isObservable(result).should.be.true;

      result.subscribe();
      stub.should.have.been.calledOnce;
      stub.should.have.been.calledWith(expectedOptions);
    });

    it('omits null param values from the uri', () => {
      const response = { response: true };
      const request = Observable.of(response);
      const stub = sandbox.stub(Observable, 'ajax').callsFake(() => request);

      const result = api.observe(action, {
        param1: 'param1 value',
        param2: null,
        param3: undefined,
      });

      should.exist(result);
      wx.isObservable(result).should.be.true;

      result.subscribe();
      stub.should.have.been.calledOnce;
      stub.firstCall.args[0].url.should.eql(`${baseUri}${action}?${uriParams}`);
    });
  });

  describe('getObservable', () => {
    it('calls getObservableResult with null data and GET method', () => {
      const expectedResult = 'result';
      const stub = sandbox.stub(api, 'observe').callsFake(() => expectedResult);

      const result = api.getObservable<any>(
        action,
        params,
        options,
        baseUriOverride,
      );

      should.exist(result);
      result.should.eql(expectedResult);
      stub.should.have.been.calledOnce;
      stub.should.have.been.calledWith(
        action,
        params,
        undefined,
        HttpRequestMethod.GET,
        options,
        baseUriOverride,
      );
    });
  });

  describe('postObservable', () => {
    it('calls getObservableResult with POST method', () => {
      const expectedResult = 'result';
      const stub = sandbox.stub(api, 'observe').callsFake(() => expectedResult);

      const result = api.postObservable<any>(
        action,
        data,
        params,
        options,
        baseUriOverride,
      );

      should.exist(result);
      result.should.eql(expectedResult);
      stub.should.have.been.calledOnce;
      stub.should.have.been.calledWith(
        action,
        params,
        data,
        HttpRequestMethod.POST,
        options,
        baseUriOverride,
      );
    });
  });
});