feat: revert to node-fetch@2

package.json

@@ -38,9 +38,9 @@
   "dependencies": {
     "eventsource-parser": "^0.0.5",
     "expiry-map": "^2.0.0",
+    "node-fetch": "2",
     "remark": "^14.0.2",
     "strip-markdown": "^5.0.0",
-    "undici": "^5.13.0",
     "uuid": "^9.0.0"
   },
   "devDependencies": {

src/demo.ts

@@ -7,6 +7,10 @@ dotenv.config()
 
 /**
  * Example CLI for testing functionality.
+ *
+ * ```
+ * npx tsx src/demo.ts
+ * ```
  */
 async function main() {
   const api = new ChatGPTAPI({ sessionToken: process.env.SESSION_TOKEN })

src/fetch-sse.ts

@@ -1,7 +1,8 @@
 import { createParser } from 'eventsource-parser'
 
 import { fetch } from './fetch'
-import { streamAsyncIterable } from './stream-async-iterable'
+
+// import { streamAsyncIterable } from './stream-async-iterable'
 
 export async function fetchSSE(
   url: string,
@@ -15,8 +16,16 @@ export async function fetchSSE(
     }
   })
 
-  for await (const chunk of streamAsyncIterable(resp.body)) {
-    const str = new TextDecoder().decode(chunk)
-    parser.feed(str)
-  }
+  resp.body.on('readable', () => {
+    let chunk: string | Buffer
+    while (null !== (chunk = resp.body.read())) {
+      parser.feed(chunk.toString())
+    }
+  })
+
+  // TODO: add support for web-compatible `fetch`
+  // for await (const chunk of streamAsyncIterable(resp.body)) {
+  //   const str = new TextDecoder().decode(chunk)
+  //   parser.feed(str)
+  // }
 }

src/fetch.ts

@@ -1,3 +1,3 @@
-import { fetch } from 'undici'
+import fetch from 'node-fetch'
 
 export { fetch }