diff --git a/packages/xrpl/test/createMockRippled.ts b/packages/xrpl/test/createMockRippled.ts index b4c2d796..d48a5ff4 100644 --- a/packages/xrpl/test/createMockRippled.ts +++ b/packages/xrpl/test/createMockRippled.ts @@ -10,7 +10,7 @@ import type { import { destroyServer, getFreePort } from './testUtils' -function createResponse( +export function createResponse( request: { id: number | string }, response: Record, ): string { @@ -36,24 +36,6 @@ function ping(conn, request): void { }, 1000 * 2) } -function server_info(conn, request): void { - setTimeout(() => { - conn.send( - createResponse(request, { - id: 0, - result: { - info: { - build_version: '1.7.3', - network_id: '1.11.0', - }, - }, - status: 'success', - type: 'response', - }), - ) - }, 1000 * 2) -} - export interface PortResponse extends BaseResponse { result: { port: number @@ -128,8 +110,6 @@ export default function createMockRippled(port: number): MockedWebSocketServer { mock.testCommand(conn, request) } else if (request.command in mock.responses) { conn.send(createResponse(request, mock.getResponse(request))) - } else if (request.command === 'server_info') { - server_info(conn, request) } else { throw new XrplError( // eslint-disable-next-line @typescript-eslint/restrict-template-expressions -- We know it's there diff --git a/packages/xrpl/test/setupClient.ts b/packages/xrpl/test/setupClient.ts index 08ec1e91..ce3c2f97 100644 --- a/packages/xrpl/test/setupClient.ts +++ b/packages/xrpl/test/setupClient.ts @@ -5,6 +5,7 @@ import BroadcastClient from '../src/client/BroadcastClient' import createMockRippled, { type MockedWebSocketServer, } from './createMockRippled' +import rippled from './fixtures/rippled' import { destroyServer, getFreePort } from './testUtils' export interface XrplTestContext { @@ -30,6 +31,10 @@ async function setupMockRippledConnection( // We must have an error listener attached for reconnect errors }) + context.client.on('connected', () => { + context.mockRippled?.addResponse('server_info', rippled.server_info.normal) + }) + return context.client.connect().then(() => context) }