refactor: remove dead code

Author: StopMakingThatBigFace

rust/src/napi/body.rs

@@ -1,4 +1,4 @@
-use crate::store::body_store::{cancel_body, read_body_all, read_body_chunk};
+use crate::store::body_store::{cancel_body, read_body_chunk};
 use neon::prelude::*;
 use neon::types::JsBuffer;
 
@@ -32,32 +32,13 @@ fn read_body_chunk_js(mut cx: FunctionContext) -> JsResult<JsPromise> {
     Ok(promise)
 }
 
-fn read_body_all_js(mut cx: FunctionContext) -> JsResult<JsPromise> {
-    let handle = cx.argument::<JsNumber>(0)?.value(&mut cx) as u64;
-
-    let channel = cx.channel();
-    let (deferred, promise) = cx.promise();
-
-    std::thread::spawn(move || {
-        let result = read_body_all(handle);
-
-        deferred.settle_with(&channel, move |mut cx| match result {
-            Ok(bytes) => JsBuffer::from_slice(&mut cx, &bytes),
-            Err(error) => cx.throw_error(format!("{:#}", error)),
-        });
-    });
-
-    Ok(promise)
-}
-
 fn cancel_body_js(mut cx: FunctionContext) -> JsResult<JsBoolean> {
     let handle = cx.argument::<JsNumber>(0)?.value(&mut cx) as u64;
     Ok(cx.boolean(cancel_body(handle)))
 }
 
 pub fn register(cx: &mut ModuleContext) -> NeonResult<()> {
     cx.export_function("readBodyChunk", read_body_chunk_js)?;
-    cx.export_function("readBodyAll", read_body_all_js)?;
     cx.export_function("cancelBody", cancel_body_js)?;
     Ok(())
 }

rust/src/store/body_store.rs

@@ -65,28 +65,6 @@ pub fn read_body_chunk(handle: u64, _size: usize) -> Result<(Vec<u8>, bool)> {
     Ok((chunk.to_vec(), false))
 }
 
-pub fn read_body_all(handle: u64) -> Result<Vec<u8>> {
-    let Some(body) = remove_body(handle) else {
-        return Err(anyhow::anyhow!("Unknown body handle: {}", handle));
-    };
-
-    runtime().block_on(async move {
-        let mut body = body.lock().await;
-        let mut bytes = Vec::new();
-
-        while let Some(chunk) = body
-            .response
-            .chunk()
-            .await
-            .context("Failed to read response body chunk")?
-        {
-            bytes.extend_from_slice(&chunk);
-        }
-
-        Ok::<Vec<u8>, anyhow::Error>(bytes)
-    })
-}
-
 pub fn cancel_body(handle: u64) -> bool {
     remove_body(handle).is_some()
 }

src/http/request.ts

@@ -228,7 +228,3 @@ export class Request {
     return this.#readBodyBytes();
   }
 }
-
-export function isWreqRequest(value: unknown): value is Request {
-  return value instanceof Request;
-}

src/native/binding.ts

@@ -26,7 +26,6 @@ export type NativeBinding = {
     chunk: Buffer;
     done: boolean;
   }>;
-  readBodyAll: (handle: number) => Promise<Buffer>;
   cancelBody: (handle: number) => boolean;
   getProfiles: () => string[];
 };

src/native/index.ts

@@ -1,6 +1,6 @@
 export { normalizeMethod } from './methods';
 export { getProfiles, validateBrowserProfile } from './profiles';
-export { nativeCancelBody, nativeReadBodyAll, nativeReadBodyChunk, nativeRequest } from './request';
+export { nativeCancelBody, nativeReadBodyChunk, nativeRequest } from './request';
 export {
   nativeWebSocketClose,
   nativeWebSocketConnect,

src/native/request.ts

@@ -69,10 +69,6 @@ export async function nativeReadBodyChunk(
   return getBinding().readBodyChunk(handle, size);
 }
 
-export async function nativeReadBodyAll(handle: number): Promise<Uint8Array> {
-  return getBinding().readBodyAll(handle);
-}
-
 export function nativeCancelBody(handle: number): boolean {
   return getBinding().cancelBody(handle);
 }