Function connectToDebuggerProxy

app/middlewares/debuggerAPI.js:137–196

()

}

const connectToDebuggerProxy = async () => {
  const ws = new WebSocket(`ws://${host}:${port}/debugger-proxy?role=debugger&name=Chrome`)

  const { setDebuggerStatus } = actions
  ws.onopen = () => setDebuggerStatus('waiting')
  ws.onmessage = async (message) => {
    if (!message.data) return

    const object = JSON.parse(message.data)
    if (object.$event === 'client-disconnected') {
      shutdownJSRuntime()
      return
    }
    if (!object.method) return

    // Special message that asks for a new JS runtime
    if (object.method === 'prepareJSRuntime') {
      shutdownJSRuntime()
      createJSRuntime()
      clearLogs()
      selectRNDebuggerWorkerContext(currentWindow)
      ws.send(JSON.stringify({ replyID: object.id }))
    } else if (object.method === '$disconnected') {
      shutdownJSRuntime()
    } else {
      if (!worker) return
      if (object.method === 'executeApplicationScript') {
        object.networkInspect = networkInspect.isEnabled()
        object.reactDevToolsPort = window.reactDevToolsPort
        if (isScriptBuildForAndroid(object.url)) {
          // Reserve React Inspector port for debug via USB on Android real device
          tryADBReverse(window.reactDevToolsPort).catch(() => {})
        }
        // Clear logs even if no error catched
        clearLogs()
        scriptExecuted = true
        checkJSLoadCount()
      }
      if (scriptExecuted) {
        // Otherwise, pass through to the worker provided the
        // application script has been executed. If not add
        // it to a queue until it has been executed.
        worker.postMessage(object)
        flushQueuedMessages()
      } else {
        queuedMessages.push(object)
      }
    }
  }

  ws.onerror = () => {}
  ws.onclose = (e) => {
    shutdownJSRuntime()
    if (e.reason) {
      console.warn(e.reason)
    }
    preconnect(connectToDebuggerProxy, true)
  }