Function init

turbopack/crates/turbopack-cli/js/src/entry/websocket.ts:42–92

()

  const { timeout = 5 * 1000 } = options

  function init() {
    if (source) source.close()

    console.log('[HMR] connecting...')

    function handleOnline() {
      const connected = { type: 'turbopack-connected' as const }
      messageCallbacks.forEach((cb) => {
        cb(connected)
      })

      if (options.log) console.log('[HMR] connected')
      // lastActivity = Date.now()
    }

    function handleMessage(event: MessageEvent) {
      // lastActivity = Date.now()

      const message = {
        type: 'turbopack-message' as const,
        data: JSON.parse(event.data),
      }
      messageCallbacks.forEach((cb) => {
        cb(message)
      })
    }

    // let timer: NodeJS.Timeout

    function handleDisconnect() {
      source.close()
      setTimeout(init, timeout)
    }

    const { hostname, port } = location
    const protocol = getSocketProtocol(options.assetPrefix || '')
    const assetPrefix = options.assetPrefix.replace(/^\/+/, '')

    let url = `${protocol}://${hostname}:${port}${
      assetPrefix ? `/${assetPrefix}` : ''
    }`

    if (assetPrefix.startsWith('http')) {
      url = `${protocol}://${assetPrefix.split('://')[1]}`
    }

    source = new window.WebSocket(`${url}${options.path}`)
    source.onopen = handleOnline
    source.onerror = handleDisconnect
    source.onmessage = handleMessage
  }

  init()
}