Remove HTTP client

README.md

@@ -12,66 +12,6 @@ See [docs](/docs) for further instructions on how to use.
 
 ## Overview
 
-## HTTP Client
-
-The library provides methods to implement the client side of HTTP protocols. Public methods available are:
-
-- `buildClient()`, which returns a [Client](https://undici.nodejs.org/#/docs/api/Client) instance and should be called before any of the following methods with parameters:
-  - `baseUrl`;
-  - `clientOptions` – set of [ClientOptions](https://undici.nodejs.org/#/docs/api/Client?id=parameter-clientoptions) (optional). If none are provided, the following default options will be used to instantiate the client:
-    ```ts
-    keepAliveMaxTimeout: 300_000,
-    keepAliveTimeout: 4000,
-    ```
-- `sendGet()`;
-- `sendPost()`;
-- `sendPut()`;
-- `sendPutBinary()`;
-- `sendDelete()`;
-- `sendPatch()`.
-
-All _send_ methods accept a type parameter and the following arguments:
-
-- `client`, the return value of `buildClient()`;
-- `path`;
-- `options` – (optional). Possible values are:
-
-  - `headers`;
-  - `query`, query string params to be embedded in the request URL;
-  - `timeout`, the timeout after which a request will time out, in milliseconds. Default is 30 seconds. Pass `undefined` if you prefer to have no timeout;
-  - `throwOnError`;`
-  - `reqContext`;
-  - `safeParseJson`, used when the response content-type is `application/json`. If `true`, the response body will be parsed as JSON and a `ResponseError` will be thrown in case of syntax errors. If `false`, errors are not handled;
-  - `blobResponseBody`, used when the response body should be returned as Blob;
-  - `requestLabel`, this string will be returned together with any thrown or returned Error to provide additional context about what request was being executed when the error has happened;
-  - `disableKeepAlive`;`
-  - `retryConfig`, defined by:
-    - `maxAttempts`, the maximum number of times a request should be retried;
-    - `delayBetweenAttemptsInMsecs`;
-    - `statusCodesToRetry`, the status codes that trigger a retry;
-    - `retryOnTimeout`;
-  - `clientOptions`;
-  - `responseSchema`, used both for inferring the response type of the call, and also (if `validateResponse` is `true`) for validating the response structure;
-  - `validateResponse`;
-
-  The following options are applied by default:
-
-  ```ts
-  validateResponse: true,
-  throwOnError: true,
-  timeout: 30000,
-  retryConfig: {
-      maxAttemps: 1,
-      delayBetweenAttemptsInMsecs: 0,
-      statusCodesToRetry: [],
-      retryOnTimeout: false,
-  }
-  ```
-
-Additionally, `sendPost()`, `sendPut()`, `sendPutBinary()`, and `sendPatch()` also accept a `body` parameter.
-
-The response of any _send_ method will be resolved to always have `result` set, but only have `error` set in case something went wrong. See [Either](#either) for more information.
-
 ## Default Logging Configuration
 
 The library provides methods to resolve the default logging configuration. Public methods available are:
@@ -239,3 +179,11 @@ expect(someEventEmitter.emittedEvents.length).toBe(1)
 ## Hashing
 
 - `HashUtils` - utils for hashing using sha256/sha512 algorithms
+
+## Checksum
+
+- `ChecksumUtils` - utils for insecure hashing using the MD5 algorithm
+
+## Streams
+
+- `StreamUtils` - utils for temporary persisting of streams for length calculation and reuse

index.ts

@@ -1,20 +1,3 @@
-export {
-  sendPut,
-  sendPutBinary,
-  sendDelete,
-  sendPatch,
-  sendGet,
-  sendPost,
-  sendPostBinary,
-  httpClient,
-  buildClient,
-  type RequestOptions,
-  type Response,
-  type HttpRequestContext,
-  type ResponseSchema,
-  JSON_HEADERS,
-} from './src/http/httpClient'
-
 export {
   PublicNonRecoverableError,
   type PublicNonRecoverableErrorParams,
@@ -25,8 +8,7 @@ export {
   type ErrorDetails,
   type InternalErrorParams,
 } from './src/errors/InternalError'
-export { ResponseStatusError } from './src/errors/ResponseStatusError'
-export { isResponseStatusError, isEntityGoneError } from './src/errors/errorTypeGuards'
+export { isEntityGoneError } from './src/errors/errorTypeGuards'
 
 export { ConfigScope } from './src/config/ConfigScope'
 export { ensureClosingSlashTransformer } from './src/config/configTransformers'
@@ -110,7 +92,16 @@ export {
 
 export { waitAndRetry } from './src/utils/waitUtils'
 
-export * from './src/observability/observabilityTypes'
+export type { TransactionObservabilityManager } from './src/observability/observabilityTypes'
 
-export * from './src/utils/checksumUtils'
-export * from './src/utils/streamUtils'
+export {
+  generateChecksumForReadable,
+  generateChecksumForObject,
+  generateChecksumForBufferOrString,
+} from './src/utils/checksumUtils'
+export { FsReadableProvider } from './src/utils/streamUtils'
+export type {
+  PersistToFsOptions,
+  ReadableProvider,
+  FsReadableProviderOptions,
+} from './src/utils/streamUtils'

package.json

@@ -37,21 +37,19 @@
     "dot-prop": "6.0.1",
     "pino": "^9.1.0",
     "tslib": "^2.6.2",
-    "undici": "^6.18.2",
-    "undici-retry": "^5.0.3",
     "zod": "^3.23.8"
   },
   "devDependencies": {
-    "@types/node": "^20.12.8",
+    "@types/node": "^20.14.2",
     "@types/tmp": "^0.2.6",
-    "@typescript-eslint/eslint-plugin": "^7.8.0",
-    "@typescript-eslint/parser": "^7.8.0",
+    "@typescript-eslint/eslint-plugin": "^7.12.0",
+    "@typescript-eslint/parser": "^7.12.0",
     "@vitest/coverage-v8": "1.6.0",
     "auto-changelog": "^2.4.0",
     "eslint": "^8.57.0",
     "eslint-plugin-import": "^2.29.1",
     "eslint-plugin-vitest": "0.4.1",
-    "prettier": "^3.2.5",
+    "prettier": "^3.3.1",
     "tmp": "^0.2.3",
     "typescript": "^5.4.5",
     "vitest": "1.6.0"

src/errors/errorTypeGuards.spec.ts

@@ -1,29 +1,10 @@
-import { describe } from 'vitest'
+import { describe, expect, it } from 'vitest'
 
 import { InternalError } from './InternalError'
-import { ResponseStatusError } from './ResponseStatusError'
-import { isEntityGoneError, isResponseStatusError } from './errorTypeGuards'
+import { isEntityGoneError } from './errorTypeGuards'
 import { EntityGoneError, EntityNotFoundError } from './publicErrors'
 
 describe('errorTypeGuards', () => {
-  describe('isResponseStatusError', () => {
-    it('Returns true for ResponseStatusError', () => {
-      // eslint-disable-next-line @typescript-eslint/no-unsafe-argument,@typescript-eslint/no-explicit-any
-      const error = new ResponseStatusError({} as any, 'label')
-
-      expect(isResponseStatusError(error)).toBe(true)
-    })
-
-    it('Returns false for not a ResponseStatusError', () => {
-      const error = new InternalError({
-        message: 'message',
-        errorCode: 'CODE',
-      })
-
-      expect(isResponseStatusError(error)).toBe(false)
-    })
-  })
-
   describe('isEntityGoneError', () => {
     it('Returns true for EntityGoneError', () => {
       const error = new EntityGoneError({

src/errors/errorTypeGuards.ts

@@ -1,12 +1,7 @@
 import { isPublicNonRecoverableError } from '../utils/typeUtils'
 
-import type { ResponseStatusError } from './ResponseStatusError'
 import type { EntityGoneError } from './publicErrors'
 
-export function isResponseStatusError(entity: unknown): entity is ResponseStatusError {
-  return 'isResponseStatusError' in (entity as ResponseStatusError)
-}
-
 export function isEntityGoneError(entity: unknown): entity is EntityGoneError {
   return isPublicNonRecoverableError(entity) && entity.httpStatusCode === 410
 }