import { name, description } from '../package.json'

import './style.css'

import createElement from './utils/createElement'

import { WorkerAdapter } from './service/adapter'
import { injectCounter } from './service/counter'

void (async () => {
  // Use the proxy object
  const worker = new Worker(new URL('./worker.ts', import.meta.url), { type: 'module' })
  const counter = injectCounter(new WorkerAdapter(worker, 'worker-transfer-injector'))

  const initValue = await counter.getValue()

  document.querySelector<HTMLDivElement>('#app')!.appendChild(
    createElement(`
      <div>
        <h1>${name}</h1>
        <p>${description}</p>
        <div class="card">
          <button id="decrement" type="button">-</button>
          <div id="value">${initValue}</div>
          <button id="increment" type="button">+</button>
        </div>
        <div class="card">
          <h4 id="worker-value">WebWorker Stream Value: ${initValue} </h4>
        </div>
      </div>
    `)
  )

  document.querySelector<HTMLButtonElement>('#decrement')!.addEventListener('click', async () => {
    await counter.decrement()
  })

  document.querySelector<HTMLButtonElement>('#increment')!.addEventListener('click', async () => {
    await counter.increment()
  })

  const onChange = async () => {
    const stream = await counter.getStream()
    const reader = stream.getReader()

    while (true) {
      const { value, done } = await reader.read()
      if (done) break
      document.querySelector<HTMLDivElement>('#value')!.textContent = value.toString()
      document.querySelector<HTMLDivElement>('#worker-value')!.textContent = `WebWorker Stream Value: ${value}`
    }
  }

  onChange()
})().catch(console.error)