feat: re-introduce BeeResponseError

src/utils/data.ts

@@ -1,33 +1,5 @@
-import type { Data } from 'ws'
 import BlobPolyfill from 'fetch-blob'
-import { isNodeReadable, isReadableStream, readableWebToNode } from './stream'
-import { Readable } from '../types'
-
-/**
- * Prepare data for valid input for node-fetch.
- *
- * node-fetch is not using WHATWG ReadableStream but NodeJS Readable so we need to convert in case of ReadableStream,
- * but the typings are set to use ReadableStream so hence why type conversion here.
- *
- * @param data any string, ArrayBuffer, Uint8Array or Readable
- */
-export async function prepareData(
-  data: string | ArrayBuffer | Uint8Array | Readable,
-): Promise<Blob | ReadableStream<Uint8Array> | never> {
-  if (typeof data === 'string') return new BlobPolyfill([data], { type: 'text/plain' }) as unknown as Blob
-
-  if (data instanceof Uint8Array || data instanceof ArrayBuffer) {
-    return new BlobPolyfill([data], { type: 'application/octet-stream' }) as unknown as Blob
-  }
-
-  if (data instanceof BlobPolyfill || isNodeReadable(data)) return data as ReadableStream<Uint8Array>
-
-  if (isReadableStream(data)) {
-    return readableWebToNode(data) as unknown as ReadableStream<Uint8Array>
-  }
-
-  throw new TypeError('unknown data type')
-}
+import type { Data } from 'ws'
 
 function isBufferArray(buffer: unknown): buffer is Buffer[] {
   return Array.isArray(buffer) && buffer.length > 0 && buffer.every(data => data instanceof Buffer)

src/utils/error.ts

@@ -1,3 +1,5 @@
+import { AxiosRequestConfig, AxiosResponse } from 'axios'
+
 export class BeeError extends Error {
   public constructor(message: string) {
     super(message)
@@ -9,3 +11,15 @@ export class BeeArgumentError extends BeeError {
     super(message)
   }
 }
+
+export class BeeResponseError extends BeeError {
+  public constructor(
+    message: string,
+    public status?: number,
+    public config?: AxiosRequestConfig,
+    public request?: any,
+    public response?: AxiosResponse,
+  ) {
+    super(message)
+  }
+}

src/utils/http.ts

@@ -1,6 +1,6 @@
-import axios, { AxiosRequestConfig, AxiosResponse } from 'axios'
+import axios, { AxiosError, AxiosRequestConfig, AxiosResponse } from 'axios'
 import { Objects, Strings } from 'cafe-utility'
-import { BeeRequestOptions } from '../index'
+import { BeeRequestOptions, BeeResponseError } from '../index'
 
 export const DEFAULT_HTTP_CONFIG = {
   headers: {
@@ -20,7 +20,10 @@ export async function http<T>(options: BeeRequestOptions, config: AxiosRequestCo
     const response = await axios(requestConfig)
 
     return response
-  } catch (e) {
+  } catch (e: unknown) {
+    if (e instanceof AxiosError) {
+      throw new BeeResponseError(e.message, e.response?.status, e.config, e.request, e.response)
+    }
     throw e
   }
 }