use native fetch is some other helper

Author: kobenguyent

lib/helper/CDPBrowser.js

@@ -162,6 +162,7 @@ class CDPBrowser extends Helper {
     let endpoint = this.options.endpoint
     if (endpoint.startsWith('http')) {
       const res = await fetch(`${endpoint.replace(/\/$/, '')}/json/version`, { headers: this.options.headers })
+      if (!res.ok) throw new Error(`Failed to get version from ${endpoint}: ${res.status} ${res.statusText}`)
       const data = await res.json()
       endpoint = data.webSocketDebuggerUrl
     }
@@ -302,11 +303,11 @@ class CDPBrowser extends Helper {
       const controller = new AbortController()
       const timeout = setTimeout(() => controller.abort(), 1000)
       try {
-        await fetch(url, { signal: controller.signal })
+        const res = await fetch(url, { signal: controller.signal })
+        return res.ok
       } finally {
         clearTimeout(timeout)
       }
-      return true
     } catch (e) {
       return false
     }
@@ -334,11 +335,12 @@ class CDPBrowser extends Helper {
         const timeoutMs = Math.min(1000, deadline - Date.now())
         const timeoutHandle = setTimeout(() => controller.abort(), timeoutMs)
         try {
-          await fetch(`http://127.0.0.1:${this.options.port}/json/version`, { signal: controller.signal })
+          const res = await fetch(`http://127.0.0.1:${this.options.port}/json/version`, { signal: controller.signal })
+          if (res.ok) return
         } finally {
           clearTimeout(timeoutHandle)
         }
-        return
+        await new Promise(r => setTimeout(r, 20))
       } catch (e) {
         await new Promise(r => setTimeout(r, 20))
       }

lib/helper/Kitesurf.js

@@ -94,6 +94,7 @@ class Kitesurf extends CDPBrowser {
     }
     const url = `${this.options.apiBase}/accounts/${this.options.accountId}/browser-run/devtools/browser?browser=kitesurf&keep_alive=${this.options.keepAlive}`
     const res = await fetch(url, { method: 'POST', headers: { Authorization: `Bearer ${this.options.apiToken}` } })
+    if (!res.ok) throw new Error(`Failed to acquire Kitesurf session: ${res.status} ${res.statusText}`)
     const data = await res.json()
     if (!data || !data.webSocketDebuggerUrl) {
       throw new Error(`Could not acquire Kitesurf session: ${JSON.stringify(data).slice(0, 300)}`)