import 'whatwg-fetch';
import {parse as urlParse} from 'url';
import {getClientString} from './constants';
import * as session from '../sync/session';

let commandListeners = [];
export function onCommand (callback) {
  commandListeners.push(callback);
}

export function offCommand (callback) {
  commandListeners = commandListeners.filter(l => l !== callback);
}

export function post (path, obj) {
  return _fetch('POST', path, obj);
}

export function get (path, sessionId = null) {
  return _fetch('GET', path, null, sessionId);
}

export function del (path, sessionId = null) {
  return _fetch('DELETE', path, null, sessionId);
}

export function put (path, sessionId = null) {
  return _fetch('PUT', path, null, sessionId);
}

export function rawFetch (...args) {
  return window.fetch(...args);
}

async function _fetch (method, path, json, sessionId = null) {
  const config = {
    method: method,
    headers: new window.Headers()
  };

  // Set some client information
  config.headers.set('X-Insomnia-Client', getClientString());

  if (json) {
    config.body = JSON.stringify(json);
    config.headers.set('Content-Type', 'application/json');
  }

  sessionId = sessionId || session.getCurrentSessionId();
  if (sessionId) {
    config.headers.set('X-Session-Id', sessionId);
  }

  const response = await window.fetch(_getUrl(path), config);
  const uri = response.headers.get('x-insomnia-command');
  uri && _notifyCommandListeners(uri);

  if (!response.ok) {
    const err = new Error(`Response ${response.status} for ${path}`);
    err.message = await response.text();
    err.statusCode = response.status;
    throw err;
  }

  if (response.headers.get('content-type') === 'application/json') {
    return response.json();
  } else {
    return response.text();
  }
}

function _getUrl (path) {
  const baseUrl = process.env.INSOMNIA_SYNC_URL || 'https://api.insomnia.rest';
  return `${baseUrl}${path}`;
}

function _notifyCommandListeners (uri) {
  const parsed = urlParse(uri, true);

  const command = `${parsed.hostname}${parsed.pathname}`;
  const args = JSON.parse(JSON.stringify(parsed.query));

  commandListeners.map(fn => fn(command, args));
}