import AjaxWork from "./ajax-work";
import { IAbstractFetchOptions, IComunication, IFetchOptions, IJsonArray, IJsonObject, IRequestInit, IRequestOptions, IResponseOptions, ISharedMethods } from "./interfaces";
const resolveRelative = require("resolve-relative-url");
const newHashFrom = require("object-hash");
import { Url } from "utility-collection";
import { process } from "uniqid";

export * from "./interfaces";
export class AjaxWorker { }
export namespace AjaxWorker {
  const nocache = "ajaxworkercache";
  // shared Methods -------------------
  const sharedMethods: { [action: string]: any } = {
    onDone: (args: any[]) => {
      const options = args[0] as IResponseOptions<any>;
      fetchDone(options);
    },
    onAbort: (args: any[]) => {
      const options = args[0] as IRequestOptions;
      fetchAbort(options);
    },
    clean: () => {
      fetchClean();
    },
  };
  function execute(actionName: string, args: Array<IJsonObject | IJsonArray | string | number | boolean | any>) {
    getWorker().postMessage({
      method: actionName,
      args,
    });
  }
  // worker -------------------
  let urlWorker: string;
  let worker: Worker;
  function getWorkerScript() {
    return "(" + AjaxWork.Worker.toString() + ")();";
  }
  function getUrlWorker() {
    if (urlWorker === undefined) {
      const blobData: Blob = new Blob([getWorkerScript()], {
        type: "application/javascript",
      });
      urlWorker = window.URL.createObjectURL(blobData);
    }
    return urlWorker;
  }
  function getWorker() {
    if (worker === undefined) {
      worker = new Worker(getUrlWorker());
      worker.onmessage = (event: any) => {
        sharedMethods[event.data.method](event.data.args);
      };
    }
    return worker;
  }
  // fetch ---------------------------------------------------
  let lastId: number = 0;
  function getId(id: string): string {
    lastId = lastId + 1;
    if (id !== undefined && id !== null) {
      return id;
    } else {
      return lastId.toString();
    }
  }
  function getHash(obj: any): string {
    const newOBj = Object.assign({}, obj);
    for (const key in newOBj) {
      if (typeof newOBj[key] === "function") {
        delete newOBj[key];
      }
    }
    return newHashFrom(newOBj);
  }
  let callbackStackOptions: { [hash: string]: IFetchOptions<any> } = {};
  function fetchDone<TDataType>(options: IResponseOptions<TDataType>) {
    // remove cache url
    const newUrl = new Url(options.url!);
    newUrl.deleteQuery(nocache);
    options.url = newUrl.toString();
    const newUrlRedirect = new Url(options.url);
    newUrlRedirect.deleteQuery(nocache);
    options.urlRedirected = newUrlRedirect.toString();
    // remove cache url end

    if (callbackStackOptions[options.hash!] !== undefined) {
      const item = callbackStackOptions[options.hash!];
      if (options.error === true) {
        if (item.onError !== undefined) {
          item.onError(options);
        }
      } else {
        if (item.onSuccess !== undefined) {
          item.onSuccess(options);
        }
      }
      if (item.onDone !== undefined) {
        item.onDone(options);
      }
      // callbackStackOptions[options.hash] = undefined;
      // delete callbackStackOptions[options.hash];
    }
  }
  function fetchAbort(options: IRequestOptions) {
    if (callbackStackOptions[options.hash!] !== undefined) {
      const item = callbackStackOptions[options.hash!];
      if (options.abort === true && item.onAbort !== undefined) {
        item.onAbort(options);
      }
      // callbackStackOptions[options.hash] = undefined;
      // delete callbackStackOptions[options.hash];
    }
  }
  function fetchClean(): void {
    callbackStackOptions = {};
  }
  export function fetch<TDataType>(options: IFetchOptions<TDataType>) {
    // default options ---------------------------
    const defaultOptions: IRequestOptions = {
      url: null,
      method: "GET",
      returnType: "json",
      cache: "no-cache",
      credentials: "include",
      referrerPolicy: "no-referrer",
      mode: "cors",
      sync: true,
      id: null,
      abort: false,
    };
    // new options ---------------------------------------
    const newOptions: IRequestOptions | any = Object.assign(defaultOptions, options);
    // fix body if string
    if (typeof newOptions.body !== "string") {
      newOptions.body = JSON.stringify(newOptions.body);
    }
    // console.log(newOptions);
    // ---------
    newOptions.url = resolveRelative(newOptions.url, window.location.origin); // get url

    newOptions.hash = getHash(newOptions); // get hadh
    newOptions.id = getId(newOptions.id); // get id
    // url no cache -------
    const url = new Url(newOptions.url);
    url.setQuery(nocache, process());
    newOptions.url = url.toString();
    // --------------
    // add to callbackStack -------------------------------
    callbackStackOptions[newOptions.hash] = (Object.assign({}, newOptions));
    for (const key in newOptions) {
      if (typeof newOptions[key] === "function") {
        delete newOptions[key];
      }
    }
    // console.log(newOptions);
    execute("fetch", [newOptions]);
  }
  // init -------------------------------------------------------
  export function init() {
    // console.log("ajax worker -- ");
    // console.log("ajax working");
    const w = window as any;
    if (w["ajaxWorker"] === undefined) {
      w["ajaxWorker"] = this;
    }
  }
  // export function nothing(): void {
  // 	console.log("did nothing");
  // 	//
  // }
}
AjaxWorker.init();
// --------------------------------------
export default AjaxWorker;