import deserialize from '../shared/deserialize'

import prefix from '../shared/prefix'

import { symbolHashJoin } from '../shared/symbolHash'

import page from './page'

import worker from './worker'

import client from './client'

export default function invoke(name, hash) {

return async function _invoke(params = {}) {

let payload

worker.fetching = true

if (Object.isFrozen(worker.queues[name])) {

worker.queues[name] = [params]

} else {

worker.queues[name] = [...worker.queues[name], params]

}

let finalHash = hash === this.hash ? hash : symbolHashJoin(hash, this.hash)

let url = `${worker.api}/${prefix}/${finalHash}/${name}.json`

if (module.hot) {

const version = client.klasses[hash].__hashes[name]

url = `${worker.api}/${prefix}/${version}/${finalHash}/${name}.json`

}

const body = JSON.stringify(params || {})

const options = {

headers: worker.headers,

mode: 'cors',

cache: 'no-cache',

credentials: 'same-origin',

redirect: 'follow',

referrerPolicy: 'no-referrer',

}

if (/get[A-Z]([*]*)/.test(name)) {

options.method = 'GET'

url += `?payload=${encodeURIComponent(body)}`

} else {

options.body = body

if (/patch[A-Z]([*]*)/.test(name)) {

options.method = 'PATCH'

} else if (/put[A-Z]([*]*)/.test(name)) {

options.method = 'PUT'

} else if (/delete[A-Z]([*]*)/.test(name)) {

options.method = 'DELETE'

} else {

options.method = 'POST'

}

}

try {

const response = await fetch(url, options)

page.status = response.status

const text = await response.text()

payload = deserialize(text).result

worker.responsive = true

} catch (e) {

worker.responsive = false

}

if (worker.queues[name]?.length === 1) {

delete worker.queues[name]

} else {

worker.queues[name] = worker.queues[name].filter((task) => task !== params)

}

worker.fetching = !!Object.keys(worker.queues).length

return payload

}

}