import type { Debugger } from 'obug'
import type { CloneOption } from './types'
import ponyfillStructuredClone from '@ungap/structured-clone'
import { createDebug } from 'obug'

export const debug: Debugger = createDebug('vitest:web-worker')

export function assertGlobalExists(name: string): void {
  if (!(name in globalThis)) {
    throw new Error(
      `[@vitest/web-worker] Cannot initiate a custom Web Worker. "${name}" is not supported in this environment. Please, consider using jsdom or happy-dom environment.`,
    )
  }
}

function createClonedMessageEvent(
  data: any,
  transferOrOptions: StructuredSerializeOptions | Transferable[] | undefined,
  clone: CloneOption,
) {
  const transfer = Array.isArray(transferOrOptions)
    ? transferOrOptions
    : transferOrOptions?.transfer

  debug('clone worker message %o', data)
  const origin = typeof location === 'undefined' ? undefined : location.origin
  const ports = transfer?.filter((t): t is MessagePort => t instanceof MessagePort)

  if (typeof structuredClone === 'function' && clone === 'native') {
    debug('create message event, using native structured clone')
    // A real Worker serializes `data` across realms and exposes the
    // MessagePorts from `transfer` as `event.ports` on the receiving side.
    // @vitest/web-worker runs both sides in a single realm, so we use
    // `structuredClone` to emulate that transfer boundary.
    //
    // `MessageEvent.ports` must be the *cloned* ports returned by
    // `structuredClone`, not the originals from `transfer`: once transferred,
    // the originals are detached and can no longer communicate — e.g.
    // `port1.postMessage(...)` on the caller side would not trigger
    // `port2.onmessage` on a detached `port2`.
    //
    // `data` and `ports` must also be cloned in the *same* `structuredClone`
    // call. A transferred object is detached immediately, so we cannot clone
    // `data` first and then clone `ports` (or vice versa) — the second call
    // would see already-detached ports. Passing them together as a single
    // input also makes `structuredClone` deduplicate by identity, so a port
    // referenced from inside `data` and from `transfer` resolves to the same
    // transferred instance in the cloned graph.
    const { data: clonedData, ports: clonedPorts } = structuredClone({ data, ports }, { transfer })
    return new MessageEvent('message', {
      data: clonedData,
      origin,
      ports: clonedPorts,
    })
  }
  if (clone !== 'none') {
    debug('create message event, using polyfilled structured clone')
    if (transfer?.length) {
      console.warn(
        '[@vitest/web-worker] `structuredClone` is not supported in this environment. ' +
          'Falling back to polyfill, your transferable options will be lost. ' +
          'Set `VITEST_WEB_WORKER_CLONE` environmental variable to "none", if you don\'t want to loose it,' +
          'or update to Node 17+.',
      )
    }
    return new MessageEvent('message', {
      data: ponyfillStructuredClone(data, { lossy: true } as any),
      origin,
      ports,
    })
  }
  debug('create message event without cloning an object')
  return new MessageEvent('message', {
    data,
    origin,
    ports,
  })
}

export function createMessageEvent(
  data: any,
  transferOrOptions: StructuredSerializeOptions | Transferable[] | undefined,
  clone: CloneOption,
): MessageEvent {
  try {
    return createClonedMessageEvent(data, transferOrOptions, clone)
  } catch (error) {
    debug('failed to clone message, dispatch "messageerror" event: %o', error)
    return new MessageEvent('messageerror', {
      data: error,
    })
  }
}

function stripProtocol(url: string | URL) {
  return url.toString().replace(/^file:\/+/, '/')
}

export function getFileIdFromUrl(url: URL | string): string {
  if (typeof self === 'undefined') {
    return stripProtocol(url)
  }
  if (!(url instanceof URL)) {
    url = new URL(url, self.location.origin)
  }
  if (url.protocol === 'http:' || url.protocol === 'https:') {
    return url.pathname
  }
  return stripProtocol(url)
}