feat(cardano-services-client): extend Blockfrost request pipeline to include body

Needed for transaction submission

Author: rhyslbw

packages/cardano-services-client/src/blockfrost/BlockfrostClient.ts

@@ -50,12 +50,13 @@ export class BlockfrostClient {
 
   /**
    * @param endpoint e.g. 'blocks/latest'
+   * @param body Payload body
    * @throws {BlockfrostError}
    */
-  public request<T>(endpoint: string): Promise<T> {
+  public request<T>(endpoint: string, body?: RequestInit['body']): Promise<T> {
     return this.rateLimiter.schedule(() =>
       firstValueFrom(
-        fromFetch(`${this.baseUrl}/${endpoint}`, this.requestInit).pipe(
+        fromFetch(`${this.baseUrl}/${endpoint}`, { ...this.requestInit, body }).pipe(
           switchMap(async (response): Promise<T> => {
             if (response.ok) {
               try {
@@ -65,8 +66,8 @@ export class BlockfrostClient {
               }
             }
             try {
-              const body = await response.text();
-              throw new BlockfrostError(response.status, body);
+              const responseBody = await response.text();
+              throw new BlockfrostError(response.status, responseBody);
             } catch {
               throw new BlockfrostError(response.status);
             }

packages/cardano-services-client/src/blockfrost/BlockfrostProvider.ts

@@ -36,12 +36,13 @@ export abstract class BlockfrostProvider implements Provider {
 
   /**
    * @param endpoint e.g. 'blocks/latest'
+   * @param body Payload body
    * @throws {ProviderError}
    */
-  protected async request<T>(endpoint: string): Promise<T> {
+  protected async request<T>(endpoint: string, body?: RequestInit['body']): Promise<T> {
     try {
       this.logger.debug('request', endpoint);
-      const response = await this.#client.request<T>(endpoint);
+      const response = await this.#client.request<T>(endpoint, body);
       this.logger.debug('response', response);
       return response;
     } catch (error) {

packages/cardano-services-client/test/blockfrost/BlockfrostClient.test.ts

@@ -17,7 +17,7 @@ describe('BlockfrostClient', () => {
       const fetchResponse = new Response(JSON.stringify(responseData), { status: 200 });
       global.fetch = jest.fn().mockResolvedValue(fetchResponse);
 
-      const response = await client.request('/');
+      const response = await client.request('/', '123');
       expect(response).toEqual(responseData);
     });